udpate

scripts/test/xy_device_data.py

@@ -1,9 +1,8 @@
 import os
 import sys
-import time
+import datetime
 import django
 local_path = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
-print(local_path)
 if local_path not in sys.path:
     sys.path.append(local_path)
 os.environ.setdefault("DJANGO_SETTINGS_MODULE", "kedong.settings")
@@ -14,6 +13,7 @@ import json
 import requests
 import pymongo
 from urllib import parse
+from tqdm import tqdm
 
 
 my_client = pymongo.MongoClient(host="8.136.98.49", port=27017, username="root", password="yfkj@6020")
@@ -37,68 +37,22 @@ def dsj_qxz_conf_info():
     collection = db.sa_device
     collection1 = db.sa_device_xycb_data
 
-    for i in scd_device:
-        device_info = collection.find_one({'device_id':i})
+    for d_id in scd_device:
+        device_info = collection.find_one({'device_id':d_id})
         device_id = device_info['id']
-        id = device_info["id"]
-        device, is_created = MongoDevice.objects.get_or_create(
-            device_id = device_info["device_id"],
-            defaults={
-                "dver_num": device_info["dver_num"],
-                "device_model": device_info["device_model"],
-                "device_type_id": device_info["device_type_id"],
-                "device_name": device_info["device_name"],
-                "owner_uid": device_info["owner_uid"],
-                "user_dealer": device_info["user_dealer"],
-                "province": device_info["province"],
-                "city": device_info["city"],
-                "district": device_info["district"],
-                "device_code": device_info["device_code"],
-                "device_status": device_info["device_status"],
-                "off_time": device_info["off_time"],
-                "ftp_push_addr": device_info["ftp_push_addr"],
-                "serverconf": device_info["serverconf"],
-                "lng": device_info["lng"],
-                "lat": device_info["lat"],
-                "gps": device_info["gps"],
-                "addtime": device_info["addtime"],
-                "uptime": device_info["uptime"],
-                "glass_slide_time": device_info["glass_slide_time"],
-                "cultivate_time": device_info["cultivate_time"],
-                "add_position": device_info["add_position"],
-                "simid": device_info["simid"],
-                "disable": device_info["disable"],
-                "decoy": device_info["decoy"],
-                "sim_dealer": device_info["sim_dealer"],
-                "xy_uptime": device_info["xy_uptime"],
-                "networking": device_info["networking"],
-                "equipment": device_info["equipment"],
-                "sale_uid": device_info["sale_uid"],
-                "salesman_task_number": device_info["salesman_task_number"],
-                "whether_equipment_status": device_info["whether_equipment_status"],
-                "device_expire_time": device_info["device_expire_time"],
-                "device_activation": device_info["device_activation"],
-                "device_expire": device_info["device_expire"],
-                "device_expire_days": device_info["device_expire_days"],
-                "water_pump_switch": device_info["water_pump_switch"],
-                "device_notes": device_info["device_notes"],
-                "water_pump_times": device_info["water_pump_times"],
-                "water_pump_switch_times": device_info["water_pump_switch_times"],
-                "xy_expire_time": device_info["xy_expire_time"],
-                "device_tag": device_info["device_tag"]
-            }
-        )
-        print(device.id, is_created)
-        data = {'device_id': device_id,'addtime':{'$gt':1681808604,'$lt':1682413404}}
+        start = "2023-10-22 13:27:25"
+        end = "2023-12-08 15:10:01"
+        start = int(datetime.datetime.strptime(start, "%Y-%m-%d %H:%M:%S").timestamp())
+        end = int(datetime.datetime.strptime(end, "%Y-%m-%d %H:%M:%S").timestamp())
+        data = {'device_id': device_id, 'addtime':{'$gt':start, "$lt": end}}
         cursor = collection1.find(data,{'_id':0,'id':0,'device_id':0})
-
-        for i in cursor:
-            scd_data = MongoXYCBData.objects.create(
-                device_id=device.id,
+        device_ids = MongoDevice.objects.get(device_id=d_id).id
+        for i in tqdm(list(cursor)):
+            MongoXYCBData.objects.create(
+                device_id=device_ids,
                 device_data=i["device_data"],
                 addtime=i['addtime']
             )
-            print(scd_data)
         print(f"设备: {i} {device_id} 数据量  {cursor.count()}")
     return True