# -*- 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 import oss2 auth = oss2.Auth('LTAI4G7tFh5Nk4KXZoSPk1D8', 'RV4S2SfbLPoFNjlI4uIOoA0J1LQPQc') # Endpoint以杭州为例，其它Region请按实际情况填写。 # bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '') # bucket = oss2.Bucket(auth, 'https://cbdphoto.oss-cn-hangzhou.aliyuncs.com', 'cbdphoto') bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', 'bzypic') def TimeStampToTime(timestamp): timeStruct = time.localtime(timestamp) str_p = time.strftime('%Y-%m-%d %H:%M:%S',timeStruct) dateTime_p = datetime.datetime.strptime(str_p,'%Y-%m-%d %H:%M:%S') return dateTime_p def get_FileCreateTime(filePath): # filePath = unicode(filePath,'utf8') t = os.path.getctime(filePath) return TimeStampToTime(t) # imei = request.POST.get("imei") for x in Equip.objects.filter(equip_type=7): imei = x.equip_id equip_obj = x file_dir = "../pyftp/ftp_file/bzy_photo/%s"%imei for root, dirs, file in os.walk(file_dir): if file != [] and "jpg" in file[0]: # print("当前路径下所有非目录子文件>>",file) for i in file: pic_addr_1 = root + "/" + i pic_addr = pic_addr_1.replace("../","") picname_1 = get_FileCreateTime(pic_addr_1) print("文件时间为",picname_1) # now = datetime.datetime.now() addr = pic_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: _time = picname_1 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: _time = picname_1 strnow = datetime.datetime.strftime(_time,'%Y%m') picname = datetime.datetime.strftime(_time,'%Y%m%d%H%M%S') # bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1) print("图片数据库路径为pic_addr",pic_addr) new_addr = "https://bzypic.oss-cn-hangzhou.aliyuncs.com/" + strnow + '/' + imei + '/'+ picname + '.jpg' exist = bucket.object_exists(strnow + '/' + imei + '/'+ picname + '.jpg') if exist: print('object exist') if BZYphoto.objects.filter(addr=new_addr).exists(): pass else: BZYphoto.objects.create(equip_id=equip_obj,addr=new_addr,upl_time=_time) os.remove(pic_addr_1) print("图片删除成功") print("数据库创建链接成功") else: print('object not exist') bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1) if BZYphoto.objects.filter(addr=new_addr).exists(): pass else: BZYphoto.objects.create(equip_id=equip_obj,addr=new_addr,upl_time=_time) os.remove(pic_addr_1) print("图片删除成功") # BZYphoto.objects.create(equip_id=imei,addr=new_addr,upl_time=picname) print("oss传输成功") # if BZYphoto.objects.filter(addr=pic_addr).exists(): # print("照片存在") # print("新的照片路径为",new_addr) # # 返回值为true表示文件存在，false表示文件不存在。 # if exist: # if BZYphoto.objects.filter(addr=new_addr).exists(): # BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=_time) # print('object exist') # BZYphoto.objects.filter(addr=pic_addr).update(equip_id=equip_obj,addr=new_addr,upl_time=_time) # else: # BZYphoto.objects.filter(addr=pic_addr).update(equip_id=equip_obj,addr=new_addr,upl_time=_time) # bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1) # print("oss传输成功") # print('object not exist') # else: # print("照片不存在") # # print("图片时间为",get_FileCreateTime(picname)) # if exist: # print('object exist') # if BZYphoto.objects.filter(addr=new_addr).exists(): # BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=_time) # else: # BZYphoto.objects.create(equip_id=equip_obj,addr=new_addr,upl_time=_time) # else: # print('object not exist') # if BZYphoto.objects.filter(addr=new_addr).exists(): # BZYphoto.objects.filter(addr=new_addr).update(equip_id=equip_obj,upl_time=_time) # else: # BZYphoto.objects.create(equip_id=equip_obj,addr=new_addr,upl_time=_time) # # BZYphoto.objects.create(equip_id=imei,addr=new_addr,upl_time=picname) # bucket_pic = bucket.put_object_from_file(strnow + '/' + imei + '/'+ picname + '.jpg', pic_addr_1) # print("oss传输成功") if equip_obj.ftp_addr: # bzy_imgs = "http://www.yfzhwlw.com/bzy/" + photo_addr data = { "Image":new_addr, "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('=================================================') # 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)