优化siminfo更新脚本

crond_script/sim_info.py

@@ -285,19 +285,6 @@ class BD_SIMUpdate(object):
                 if photo_iccid and photo_iccid != zhuban_iccid:
                     SIMUpdate(deviceId=device_id,iccid=photo_iccid,device_type="测报灯",platform=2).photo_sim()
 
-
-        cbd_cursor = self.cursor.fetchall()
-        for i in cbd_cursor:
-            device_id = i["equip_id_id"]
-            cbd_status = i["cbd_status"]
-            photo_iccid = i["simid"]
-            equip_status = ast.literal_eval(cbd_status)
-            zhuban_iccid = equip_status.get("iccid","")
-            device_info = DeviceInfoUtils().get_equip_list(d_id=device_id, isfullId=1)
-            if device_info and device_info[0]["plat"]=="四情平台":
-                SIMUpdate(deviceId=device_id,iccid=zhuban_iccid,device_type="测报灯",platform=1).zhuban_sim()
-                SIMUpdate(deviceId=device_id,iccid=photo_iccid,device_type="测报灯",platform=1).photo_sim()
-
     def xycb_sim(self):
         self.mongo_ping()
         xycb_list = self.device_list(type_id=4)
@@ -370,8 +357,8 @@ class BD_SIMUpdate(object):
                     SIMUpdate(deviceId=device_id,iccid=photo_iccid,device_type="孢子仪",platform=2).photo_sim()
 
     def run(self):
-        # self.scd_sim()
-        # print("大数据杀虫灯更新完毕--%s"%(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
+        self.scd_sim()
+        print("大数据杀虫灯更新完毕--%s"%(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
         self.cbd_sim()
         print("大数据测报灯更新完毕--%s"%(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
         self.xycb_sim()
@@ -383,13 +370,12 @@ class BD_SIMUpdate(object):
 
 if __name__ == "__main__":
     print("SIM卡信息开始更新----------%s"%(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
-    # Execution_POOL= ThreadPoolExecutor(max_workers=2)
-    # all_tasks = [
-    #     Execution_POOL.submit(SQ_SIMUpdate().run),
-    #     Execution_POOL.submit(BD_SIMUpdate().run)
-    # ]
-    # wait(all_tasks, return_when=ALL_COMPLETED)
-    BD_SIMUpdate().run()
+    Execution_POOL= ThreadPoolExecutor(max_workers=2)
+    all_tasks = [
+        Execution_POOL.submit(SQ_SIMUpdate().run),
+        Execution_POOL.submit(BD_SIMUpdate().run)
+    ]
+    wait(all_tasks, return_when=ALL_COMPLETED)
     print("SIM卡信息更新完毕----------%s"%(datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
     print("")
     print("")