yfwlwCut/script_file/ybq_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, YBQphoto
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("----服务运行----")
ybq_photo_list = get_all_files("/data/yfwlw/pyftp/ftp_file/sex_photo/")
# ybq_photo_list = get_all_files("/home/web/yfwlw/pyftp/ftp_file/sex_photo/")
if len(ybq_photo_list) > 0:
    nowtime = datetime.datetime.now().strftime('%Y%m%d')
    print('=================================================')
    print("当前时间为%s"%datetime.datetime.now())
    for i in ybq_photo_list:
        jkpath,jkname=os.path.split(i)
        print(jkpath.split("/")[6])
        if jkpath.split("/")[6].isdigit():
            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("-")[1] + jkname.split("-")[2].split(".")[0]
                print("图片时间为:",phototime)
                phototime1 = datetime.datetime.strptime(phototime,"%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("sex_photo","sex_photo1"))
                YBQphoto.objects.create(equip_id=Equip.objects.get(equip_id=imei),addr=i.replace("sex_photo","sex_photo1")[12:],upl_time=phototime1,real_time=datetime.datetime.now())
            except Exception as ee:
                print("当前时间:",datetime.datetime.now())
                print("错误信息为：",ee)
    print('=================================================')