| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- import os
- import django
- import sys
- 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
- import time
- import requests
- import datetime
- from apps.ReportManage.all_dict import trap_list
- from apps.AppInfoManage.models import Equip, Equip_type, Trapstatus, Trapdata, Trapphoto
- print("--------trap_transpond start!-----------")
- url = 'http://telemo.org/pest/data/grid/picturedataview.do'
- # dat= {'username': 'jkTest','password': '123456','sign':'cf6345abb2ed948a534467d278a79190'} #将携带的参数传给params
- # r = requests.get(url, params=dat)
- # rec = r.text
- # data = json.loads(rec)
- # print(data['resultData'][-1])
- while True:
- time.sleep(3600)
- nowtime = datetime.datetime.now().strftime('%Y%m%d')
- origin = sys.stdout
- f = open('../logs/'+nowtime+'trapphoto.txt','a+')
- sys.stdout = f
- for i in trap_list:
- print("=========================================")
- r = requests.get(url, params=i)
- rec = r.text
- data = json.loads(rec)
- # print("data:",data)
- try:
- trapstatus = data['resultData'][0]
- except:
- print("-------------continue-------------")
- continue
- # print("设备位置为:",trapstatus)
- imei = trapstatus['dataviewId']
- detester = datetime.datetime.strptime(trapstatus['pictureTime'],"%Y-%m-%d %H:%M:%S")
- trap_exist = Equip.objects.filter(equip_id=imei)
- addr = "http://telemo.org/" + trapstatus['picturePath']
- print("time",detester)
- print("imei",imei)
- print("addr",addr)
- # 设备存在:
- if trap_exist.exists():
- imei = Equip.objects.get(equip_id=imei)
- if Trapphoto.objects.filter(addr=addr).exists():
- print("------------image exists----------------")
- else:
- Trapphoto.objects.create(equip_id=imei,addr=addr,upl_time=detester)
- print("----------------image upload success-------------------")
- else:
- print("---------equip not exists------------")
-
- sys.stdout = origin
- f.close()
|