fix equip reuse query 2025-6-10 11:35

unify_api/modules/zhiwei_u/dao/equipment_operations_dao.py

@@ -42,9 +42,12 @@ async def load_equip_reuse(sid):
                   f"LEFT JOIN {db}.point p on m.mtid=p.mtid " \
                   f"WHERE m.sid=%s AND m.meter_no=%s AND m.cid=%s " \
                   f"AND m.demolished=0"
+            try:
                 r = await conn.fetchone(sql, args=(sid, meter_no, cid,))
                 if r:
                     rlt.append(r)
+            except Exception:
+                continue
         return rlt
 
 

unify_api/modules/zhiwei_u/service/sid_iccid_map.py

@@ -198,7 +198,7 @@ async def update_all():
     logger.info(f"start do task, sid total：{len(sid_total)}")
     for i, sid in enumerate(sid_total, start=1):
         tmp.append(sid)
-        if i % 100 and i < len(sid_total):
+        if i % 20 and i < len(sid_total):
             continue
 
         task_lst = [load_iccid(sid) for sid in tmp]
@@ -210,7 +210,7 @@ async def update_all():
 
         tmp = []
 
-        time.sleep(180)
+        time.sleep(300)
 
     if sid_iccids:
         await batch_insert(sid_iccids)
@@ -221,7 +221,7 @@ async def update_all():
         sid_iccids, fail_two, tmp = [], set(), []
         for i, sid in enumerate(list(fail_sid), start=1):
             tmp.append(sid)
-            if i % 100 and i < len(fail_sid):
+            if i % 20 and i < len(fail_sid):
                 continue
 
             task_lst = [load_iccid(sid) for sid in tmp]
@@ -231,7 +231,7 @@ async def update_all():
                 else:
                     fail_two.add(_sid)
 
-            time.sleep(180)
+            time.sleep(300)
 
         if sid_iccids:
             await batch_insert(sid_iccids)
@@ -240,6 +240,21 @@ async def update_all():
                     f"fail：{len(fail_two)}")
 
 
+async def press_test():
+    success, fail = 0, 0
+    sid = "R2104100140"
+    for i in range(500):
+        _, iccid, sim_opt = await load_iccid(sid)
+        logger.info(f"iccid:{iccid}, sim_opt:{sim_opt}")
+        if iccid:
+            success += 1
+        else:
+            fail += 1
+        time.sleep(7)
+
+    logger.info(f"finish success:{success}, fail:{fail}")
+
+
 async def main2():
     while True:
         try:
@@ -247,7 +262,7 @@ async def main2():
         except Exception as e:
             logger.exception(f"main2 error:{e}")
 
-        time.sleep(1800)
+        time.sleep(300)
 
 
 if __name__ == '__main__':