新增定时更新设备卡账期流量接口

Controller/UnicomCombo/UnicomComboTaskController.py

@@ -61,6 +61,8 @@ class UnicomComboTaskView(View):
             return self.query_flow_cache(response)
         elif operation == 'getDeviceUsageHistory':
             return self.get_device_usage_history(response)
+        elif operation == 'updateCardCycleFlow':
+            return self.update_device_cycle_flow(response)
         else:
             return response.json(414)
 
@@ -477,3 +479,33 @@ class UnicomComboTaskView(View):
         except Exception as e:
             logger.info('查询账期流量异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
             return None
+
+    @staticmethod
+    def update_device_cycle_flow(response):
+        """
+        更新设备账期流量接口
+        """
+        card_qs = UnicomDeviceInfo.objects.filter(card_type=0).values('iccid')
+        if not card_qs.exists():
+            return response.json(0)
+        asy = threading.Thread(target=UnicomComboTaskView.async_update_device_cycle_flow, args=(card_qs,))
+        asy.start()
+        return response.json(0)
+
+    @staticmethod
+    def async_update_device_cycle_flow(qs):
+        """
+        异步更新设备账期流量
+        """
+        try:
+            logger.info('进入异步更新设备卡账期流量~~~~')
+            unicom_api = UnicomObjeect()
+            for item in qs:
+                try:
+                    unicom_api.get_flow_usage_total(item['iccid'])
+                except Exception as e:
+                    print(repr(e))
+                    continue
+        except Exception as e:
+            logger.info('更新账期流量异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
+            return None