yfwlwCut/script_file/bzy_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
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


# while True:
sta1 = BZYstatus.objects.all()
sta3 = []
photo_list = []
for i in sta1:
    sta3.append(i.equip_id.equip_id)
for imei in sta3:
    equip_obj = Equip.objects.get(equip_id=imei)
    file_dir = "../pyftp/ftp_file/bzy_photo/%s"%imei
    for root, dirs, files in os.walk(file_dir):
        print(root)
        if root.endswith(imei):
            pass
        else:
            # print("当前目录------->>",root)
            for roots, dirss, file in os.walk(root):
                # print(roots) #当前目录路径
                # print(dirs) #当前路径下所有子目录
                # print(file) #当前路径下所有非目录子文件
                if file != []:
                    for i in file:
                        photo_addr = roots + "/" + i
                        photo_addr = photo_addr.replace("../","")
                        # print(photo_addr)
                        if BZYphoto.objects.filter(addr=photo_addr).exists():
                            # print("照片存在")
                            pass
                        else:
                            # addr = photo_addr
                            addr = photo_addr.split("/")[-1]
                            if "192.168" in addr:
                                print("长addr",addr)
                                _time = addr.split("_")[2][0:14]
                                print("------->>",len(_time))
                                try:
                                    _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S')
                                except:
                                    continue
                                print(_time)
                                # if i.upl_time.hour != _time.hour:
                                #     i.upl_time = _time
                                #     i.save()
                            elif len(addr) == 18:
                                print("短addr",addr)
                                _time = addr.split(".")[0][0:14]
                                print("------->>",len(_time))
                                _time = _time.split("\r")[0]
                                try:
                                    _time = datetime.datetime.strptime(_time,'%Y%m%d%H%M%S')
                                except:
                                    continue
                                print(_time)
                                # if i.upl_time.hour != _time.hour:
                                #     i.upl_time = _time
                                #     i.save()
                            print("图片时间为",_time)
                            print("图片链接为",photo_addr)
                            BZYphoto.objects.create(equip_id=equip_obj,addr=photo_addr,upl_time=_time)
                            if equip_obj.ftp_addr:
                                bzy_imgs = "http://www.yfzhwlw.com/bzy/" + photo_addr
                                data = {
                                "Image":bzy_imgs,
                                "imei":imei,
                                }
                                data = json.dumps(data)
                                headers = {"Content-Type": "application/json; charset=UTF-8", 'Connection': 'close'}
                                bzy_photo = requests.post(equip_obj.ftp_addr,data=data,headers=headers,timeout=3)
                                print("转发成功")

                            print('=================================================')
                            # sys.stdout = origin
                            # f.close()
    # print("过滤完成")
    # time.sleep(3600)