yfwlwCut/script_file/jk_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, JKphoto, JKdata
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 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("----服务运行----")

    

jk_photo_list = get_all_files("/data/yfwlw/pyftp/ftp_file/jk_photo/")
# jk_photo_list = get_all_files("/home/web/yfwlw/pyftp/ftp_file/jk_photo/")
if len(jk_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 jk_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("jk_photo","jk_photo1"))
            JKphoto.objects.create(equip_id=Equip.objects.get(equip_id=imei),addr=i.replace("jk_photo","jk_photo1")[12:],upl_time=phototime1)
        except Exception as ee:
            print("当前时间:",datetime.datetime.now())
            print("错误信息为：",ee)
    print('=================================================')
    sys.stdout = origin
    f.close()

            # file_dir = "pyftp/ftp_file/jk_photo1/%s"%imei
            # print("file_dir",file_dir)
            # for root, dirs, files in os.walk(file_dir):
            #     for i in files:
            #         file = root + "/" + i
            #         # st = root.split("/")[-1] + i.split(".")[0]
            #         st = i.split(".")[3].split("_")[2][0:14]
            #         print("st",st)
            #         print("file====>>",file)
            #         try:
            #             pic_time = datetime.datetime.strptime(st,"%Y%m%d%H%M%S")
            #         except Exception as eeex:
            #             print("错误信息为",eeex)
            #             continue
            #         if JKphoto.objects.filter(addr=file).exists():
            #             photoobj = JKphoto.objects.get(addr=file)
            #             photoobj.upl_time = pic_time
            #             photoobj.save()
            #             print("照片存在")
            #         else:
            #             print("照片不存在")
            #             try:
            #                 imei_obj = Equip.objects.get(equip_id=imei)
            #                 JKphoto.objects.create(equip_id=imei_obj,addr=file,upl_time=pic_time)
            #             except Exception as e:
            #                 print("错误信息为",e)