yfwlwCut/script_file/tccb_photo_collect.py

# -*- coding: utf-8 -*-
# File Name:mqtt_chat_client.py
# Python Version:3.5.1

import os
import django
import sys
from qcloudsms_py import SmsSingleSender
from qcloudsms_py.httpclient import HTTPError
from qcloudsms_py import SmsMultiSender

BASE_DIR = os.path.dirname(os.path.abspath(__file__))  # 定位到你的django根目录
sys.path.append(os.path.abspath(os.path.join(BASE_DIR, os.pardir)))

os.environ.setdefault("DJANGO_SETTINGS_MODULE",
                      "yfwlw_pro.settings")  # project_name 项目名称
django.setup()

import json
from apps.AppInfoManage.models import Equip, Equip_type, MyUser, CBDphoto, CBDstatus, QXZdata, SCDstatus, CBDstatus, Equip_SimInfo, CBDdata, BZYphoto, RecentCBDdata,RecentSCDdata,\
Msg_Conf, Msg_Send, BZYstatus, TCCBphoto, TCCBstatus
import re
import datetime
import time
import random
from apps.SimInfo.views import get_siminfo
from apps.ReportManage.all_dict import insect_dict_new, transpont_equip_scd
import requests
import shutil



def get_all_files(dir_):
    files_ = []
    list_ = os.listdir(dir_)
    # print(list_)
    for i in range(0, len(list_)):
        path = os.path.join(dir_, list_[i])
        if os.path.isdir(path):
            files_.extend(get_all_files(path))
        if os.path.isfile(path):
            files_.append(path)
    return files_


# 复制
def mycopyfile(srcfile,dstfile):
    if not os.path.isfile(srcfile):
        print("%s not exist!"%(srcfile))
    else:
        fpath,fname=os.path.split(dstfile)    #分离文件名和路径
        if not os.path.exists(fpath):
            os.makedirs(fpath)                #创建路径
        shutil.copyfile(srcfile,dstfile)      #复制文件
        print("copy %s -> %s"%(srcfile,dstfile))

# 剪切
def mymovefile(srcfile,dstfile):
    if not os.path.isfile(srcfile):
        print("%s not exist!"%(srcfile))
    else:
        fpath,fname=os.path.split(dstfile)    #分离文件名和路径
        if not os.path.exists(fpath):
            os.makedirs(fpath)                #创建路径
        shutil.move(srcfile,dstfile)          #移动文件
        print("move %s -> %s"%(srcfile,dstfile))


print("----服务运行----")

    

tccb_photo_list = get_all_files("/data/yfwlw/pyftp/ftp_file/tccb_photo/")
# jk_photo_list = get_all_files("/home/web/yfwlw/pyftp/ftp_file/jk_photo/")
if len(tccb_photo_list) > 0:
    # nowtime = datetime.datetime.now().strftime('%Y%m%d')
    # origin = sys.stdout
    # f = open('/data/yfwlw/logs/'+"jkphoto_collect" + nowtime +'.txt','a')
    # sys.stdout = f
    print('=================================================')
    print("当前时间为%s"%datetime.datetime.now())
    for i in tccb_photo_list:
        try:
            jkpath,jkname=os.path.split(i)
            imei = jkpath.split("/")[6]

            print("i值为:",i)
            print("设备号为:",imei)

            # imei = jkpath.split("/")[3]
            print("imei:",imei)
            print("type:",type(i))
            phototime = jkname.split("_")[2]
            print("图片时间为:",phototime)
            phototime1 = datetime.datetime.strptime(phototime[0:13],"%Y%m%d%H%M%S")
            print("phototime1类型:",type(phototime1))
            print("phototime1:",phototime1)
            print("当前时间为====>>%s"%datetime.datetime.now())
            
            # equip_obj = Equip.objects.get(equip_id=imei)
            
            print("操作成功")
        except Exception as e:
            print("错误信息为：",e)
        try:
            mymovefile(i,i.replace("tccb_photo","tccb_photo1"))
            TCCBphoto.objects.create(equip_id=Equip.objects.get(equip_id=imei),addr=i.replace("tccb_photo","tccb_photo1")[12:],upl_time=phototime1)
        except Exception as ee:
            print("当前时间:",datetime.datetime.now())
            print("错误信息为：",ee)
    print('=================================================')
    # sys.stdout = origin
    # f.close()