异常待办派发逻辑更改

.idea/csv-editor.xml

@@ -3,13 +3,6 @@
   <component name="CsvFileAttributes">
     <option name="attributeMap">
       <map>
-        <entry key="\back_ground_module\DF.csv">
-          <value>
-            <Attribute>
-              <option name="separator" value="," />
-            </Attribute>
-          </value>
-        </entry>
         <entry key="\db\task_queue.csv">
           <value>
             <Attribute>

api.py

@@ -95,7 +95,8 @@ class API:
                 "app_id": data['api_key'],  # 应用ID
                 "entry_id": data['entry_id'],  # 表单ID
                 "limit": 100,
-                "data_id": last_data_id
+                "data_id": last_data_id,
+                "filter":data.get('filter', None)
             })
             retries = 0
             while retries <= max_retries:

back_ground_module/Exception_Task.py

@@ -174,10 +174,10 @@ class NewExceptionTask:
         self.NGV_data_list = api_instance.entry_data_list(payload).get("data", [])
         # print("NGV获取后的类型：", type(self.NGV_data_list))
 
-        # 获取异常服务待办
+        # 获取异常服务待办(添加过滤进行中的订单)
-        payload = {"api_key": "675b900991ad2491c69389ca", "entry_id": "68340de79f116c0b66b6b0cc"}
+        payload = {"api_key": "675b900991ad2491c69389ca", "entry_id": "68340de79f116c0b66b6b0cc","filter":{"rel":"and","cond":[{ "field": "flowState", "type":"flowstate", "method":"eq","value":[0] }]}}
         self.exception_service_todo = api_instance.entry_data_list(payload).get("data", [])
-        print(self.exception_service_todo)
+        # print(self.exception_service_todo)
 
     @staticmethod
     def build_index(json_list):
@@ -258,9 +258,11 @@ class NewExceptionTask:
 
                     is_pass = False
                     for exception_service in self.exception_service_todo :
-                        if exception_service['_widget_1748241895842'] == row['org_code'] and exception_service['_widget_1748512176655'] in ['未处理', '处理中']:
+                        # 通过查询筛选进行中的逻辑
+                        if exception_service['_widget_1748241895842'] == row['org_code']:
                             is_pass = True
                             break
+
                     if is_pass:
                         logger.info(f"已存在待办，跳过该条记录: {row}")
                         continue

back_ground_module/GD_match_phone_number.py

@@ -17,6 +17,7 @@ api_instance = API()
 
 
 class GDMatchPhoneNumber:
+    """高德匹配手机号"""
     def __init__(self):
         self.loader_company_data = None
         self.fild_mapping = {
@@ -199,7 +200,7 @@ class GDMatchPhoneNumber:
             self.upload_df(result_df)
             logger.info(f"数据上传完成。")
         except Exception as e:
-            # common_module.send_task_error(task_start_time, "高德匹配手机号", str(e))
+            common_module.send_task_error(task_start_time, "高德匹配手机号", str(e))
             error_task_logger.error(f"任务高德匹配手机号执行失败。")
             raise
 

logs/error_task.log

@@ -2476,3 +2476,22 @@
 2025-07-09 11:35:47,205 - error_task_logger - ERROR - 任务 分子报备调整 超过执行窗口5分钟以上,标记为过期。
 2025-07-09 11:35:47,206 - error_task_logger - ERROR - 任务 履约表数据支撑 超过执行窗口5分钟以上,标记为过期。
 2025-07-09 11:35:47,206 - error_task_logger - ERROR - 任务 字段监控 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,099 - utils.py - error_task_logger - ERROR - 任务 NGV新增数据 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,101 - utils.py - error_task_logger - ERROR - 任务 新签客户回访 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,102 - utils.py - error_task_logger - ERROR - 任务 续约客户回访 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,103 - utils.py - error_task_logger - ERROR - 任务 接车宝日常派发 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,104 - utils.py - error_task_logger - ERROR - 任务 私域小程序数据支撑 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,105 - utils.py - error_task_logger - ERROR - 任务 小六提成数据支撑 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,106 - utils.py - error_task_logger - ERROR - 任务 异业合作数据支撑 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,107 - utils.py - error_task_logger - ERROR - 任务 短信数据支撑 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,107 - utils.py - error_task_logger - ERROR - 任务 海外邮件推送 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,108 - utils.py - error_task_logger - ERROR - 任务 异常服务待办派发 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,109 - utils.py - error_task_logger - ERROR - 任务 简道云海外项目CRM客户档案迁移BI 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,110 - utils.py - error_task_logger - ERROR - 任务 安装服务历史派发 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,111 - utils.py - error_task_logger - ERROR - 任务 分母报备调整 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,112 - utils.py - error_task_logger - ERROR - 任务 分子报备调整 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,114 - utils.py - error_task_logger - ERROR - 任务 履约表数据支撑 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,115 - utils.py - error_task_logger - ERROR - 任务 字段监控 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,115 - utils.py - error_task_logger - ERROR - 任务 经销商新签服务单转BI 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,117 - utils.py - error_task_logger - ERROR - 任务 非标业绩提报转BI 超过执行窗口5分钟以上,标记为过期。
+2025-11-21 10:16:19,118 - utils.py - error_task_logger - ERROR - 任务 合伙人结算登记同步到BI 超过执行窗口5分钟以上,标记为过期。

logs/task.log

@@ -47,3 +47,49 @@
 2025-07-09 11:35:47,207 - task_logger - INFO - 所有任务状态已保存到磁盘。
 2025-07-09 11:35:47,207 - task_logger - INFO - 任务 字段监控 状态已更新为 过期。
 2025-07-09 11:35:47,207 - task_logger - INFO - 启动任务加载完成。
+2025-11-21 10:16:18,869 - utils.py - task_logger - INFO - 任务队列已从磁盘加载。
+2025-11-21 10:16:19,082 - api.py - task_logger - INFO - 获取了29条数据
+2025-11-21 10:16:19,086 - sample_cloud_modules.py - task_logger - INFO - 任务已从云端获取并保存到 tasks.csv 文件。
+2025-11-21 10:16:19,086 - main.py - task_logger - INFO - 任务列表已保存到 csv 文件中。
+2025-11-21 10:16:19,086 - utils.py - task_logger - INFO - 启动时加载并执行任务...
+2025-11-21 10:16:19,099 - utils.py - task_logger - INFO - 任务已从磁盘加载到全局任务字典。
+2025-11-21 10:16:19,100 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,101 - utils.py - task_logger - INFO - 任务 NGV新增数据 状态已更新为 过期。
+2025-11-21 10:16:19,102 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,102 - utils.py - task_logger - INFO - 任务 新签客户回访 状态已更新为 过期。
+2025-11-21 10:16:19,103 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,103 - utils.py - task_logger - INFO - 任务 续约客户回访 状态已更新为 过期。
+2025-11-21 10:16:19,104 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,104 - utils.py - task_logger - INFO - 任务 接车宝日常派发 状态已更新为 过期。
+2025-11-21 10:16:19,105 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,105 - utils.py - task_logger - INFO - 任务 私域小程序数据支撑 状态已更新为 过期。
+2025-11-21 10:16:19,106 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,106 - utils.py - task_logger - INFO - 任务 小六提成数据支撑 状态已更新为 过期。
+2025-11-21 10:16:19,106 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,107 - utils.py - task_logger - INFO - 任务 异业合作数据支撑 状态已更新为 过期。
+2025-11-21 10:16:19,107 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,107 - utils.py - task_logger - INFO - 任务 短信数据支撑 状态已更新为 过期。
+2025-11-21 10:16:19,108 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,108 - utils.py - task_logger - INFO - 任务 海外邮件推送 状态已更新为 过期。
+2025-11-21 10:16:19,109 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,109 - utils.py - task_logger - INFO - 任务 异常服务待办派发 状态已更新为 过期。
+2025-11-21 10:16:19,110 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,110 - utils.py - task_logger - INFO - 任务 简道云海外项目CRM客户档案迁移BI 状态已更新为 过期。
+2025-11-21 10:16:19,111 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,111 - utils.py - task_logger - INFO - 任务 安装服务历史派发 状态已更新为 过期。
+2025-11-21 10:16:19,112 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,112 - utils.py - task_logger - INFO - 任务 分母报备调整 状态已更新为 过期。
+2025-11-21 10:16:19,113 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,113 - utils.py - task_logger - INFO - 任务 分子报备调整 状态已更新为 过期。
+2025-11-21 10:16:19,114 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,114 - utils.py - task_logger - INFO - 任务 履约表数据支撑 状态已更新为 过期。
+2025-11-21 10:16:19,115 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,115 - utils.py - task_logger - INFO - 任务 字段监控 状态已更新为 过期。
+2025-11-21 10:16:19,116 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,117 - utils.py - task_logger - INFO - 任务 经销商新签服务单转BI 状态已更新为 过期。
+2025-11-21 10:16:19,118 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,118 - utils.py - task_logger - INFO - 任务 非标业绩提报转BI 状态已更新为 过期。
+2025-11-21 10:16:19,119 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。
+2025-11-21 10:16:19,119 - utils.py - task_logger - INFO - 任务 合伙人结算登记同步到BI 状态已更新为 过期。
+2025-11-21 10:16:19,119 - utils.py - task_logger - INFO - 启动任务加载完成。
+2025-11-21 10:16:19,120 - main.py - task_logger - INFO - 程序已启动...

tasks.csv

@@ -1,26 +1,30 @@
 unique_id,exec_time,is_switch_on,status
-NGV新增数据,06:31,True,过期
+NGV新增数据,09:00,True,过期
-NGV更新数据,04:50,True,过期
+NGV更新数据,12:30,True,待执行
-新签客户回访,08:45,True,过期
+新签客户回访,09:05,True,过期
-续约客户回访,08:30,True,过期
+续约客户回访,09:08,True,过期
 大客户回访,08:55,False,已禁用
 简道云拉取数据,08:00,False,已禁用
 接车宝日常派发,09:00,True,过期
-接车宝异常派发,09:05,False,已禁用
+接车宝异常派发,09:00,False,已禁用
 私域小程序数据支撑,04:40,True,过期
 小六提成数据支撑,04:40,True,过期
 异业合作数据支撑,04:20,True,过期
 短信数据支撑,04:10,True,过期
 海外邮件推送,08:28,True,过期
-异常服务待办派发,08:35,True,过期
+异常服务待办派发,10:00,True,过期
-手动添加日常回访,06:50,True,过期
+手动添加日常回访,19:00,False,已禁用
-宜搭FPO实例同步简道云,09:28,True,过期
+宜搭FPO实例同步简道云,09:28,False,已禁用
-宜搭流程耗时写入BI,09:22,True,过期
+宜搭流程耗时写入BI,07:22,False,已禁用
-简道云员工ID表更新,07:23,True,过期
+简道云员工ID表更新,07:23,False,已禁用
 简道云海外项目CRM客户档案迁移BI,08:37,True,过期
 安装服务历史派发,09:00,True,过期
-新签客户回访测试,09:00,True,过期
+新签客户回访测试,09:00,False,已禁用
-分母报备调整,07:15,True,过期
+分母报备调整,09:05,True,过期
-分子报备调整,07:17,True,过期
+分子报备调整,09:03,True,过期
-履约表数据支撑,06:00,True,过期
+履约表数据支撑,09:10,True,过期
 字段监控,06:25,True,过期
+经销商新签服务单转BI,08:05,True,过期
+非标业绩提报转BI,08:25,True,过期
+合伙人结算登记同步到BI,08:24,True,过期
+高德匹配手机号,05:00,False,已禁用