diff --git a/logs/error_task.log b/logs/error_task.log index ce96b88..12c6184 100644 --- a/logs/error_task.log +++ b/logs/error_task.log @@ -2554,3 +2554,27 @@ 2026-01-04 10:29:26,171 - log_config.py - error_task_logger - ERROR - 任务 高德匹配手机号 超过执行窗口5分钟以上,标记为过期。 2026-01-04 10:29:26,171 - log_config.py - error_task_logger - ERROR - 任务 省市区人员关系表转BI 超过执行窗口5分钟以上,标记为过期。 2026-01-04 10:29:26,172 - log_config.py - error_task_logger - ERROR - 任务 续约回访待办 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,807 - log_config.py - error_task_logger - ERROR - 任务 NGV新增数据 (09:00) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,808 - log_config.py - error_task_logger - ERROR - 任务 NGV更新数据 (12:30) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,809 - log_config.py - error_task_logger - ERROR - 任务 新签客户回访 (09:05) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,810 - log_config.py - error_task_logger - ERROR - 任务 续约客户回访 (09:08) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,811 - log_config.py - error_task_logger - ERROR - 任务 接车宝日常派发 (09:10) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,811 - log_config.py - error_task_logger - ERROR - 任务 私域小程序数据支撑 (04:40) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,812 - log_config.py - error_task_logger - ERROR - 任务 小六提成数据支撑 (04:40) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,813 - log_config.py - error_task_logger - ERROR - 任务 异业合作数据支撑 (04:20) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,814 - log_config.py - error_task_logger - ERROR - 任务 短信数据支撑 (04:10) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,815 - log_config.py - error_task_logger - ERROR - 任务 海外邮件推送 (08:28) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,815 - log_config.py - error_task_logger - ERROR - 任务 异常服务待办派发 (10:00) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,816 - log_config.py - error_task_logger - ERROR - 任务 简道云海外项目CRM客户档案迁移BI (08:37) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,817 - log_config.py - error_task_logger - ERROR - 任务 分母报备调整 (09:05) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,817 - log_config.py - error_task_logger - ERROR - 任务 分子报备调整 (09:03) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,818 - log_config.py - error_task_logger - ERROR - 任务 履约表数据支撑 (09:10) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,819 - log_config.py - error_task_logger - ERROR - 任务 字段监控 (06:25) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,820 - log_config.py - error_task_logger - ERROR - 任务 经销商新签服务单转BI (08:05) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,820 - log_config.py - error_task_logger - ERROR - 任务 非标业绩提报转BI (08:01) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,821 - log_config.py - error_task_logger - ERROR - 任务 合伙人结算登记同步到BI (08:02) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,821 - log_config.py - error_task_logger - ERROR - 任务 高德匹配手机号 (05:00) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,822 - log_config.py - error_task_logger - ERROR - 任务 非标业绩提报转BI (12:01) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,823 - log_config.py - error_task_logger - ERROR - 任务 合伙人结算登记同步到BI (12:02) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,824 - log_config.py - error_task_logger - ERROR - 任务 省市区人员关系表转BI (08:00) 超过执行窗口5分钟以上,标记为过期。 +2026-01-04 13:45:42,824 - log_config.py - error_task_logger - ERROR - 任务 续约回访待办 (09:35) 超过执行窗口5分钟以上,标记为过期。 diff --git a/logs/task.log b/logs/task.log index ea54cbf..315a124 100644 --- a/logs/task.log +++ b/logs/task.log @@ -235,3 +235,59 @@ 2026-01-04 10:29:26,173 - utils.py - task_logger - INFO - 任务 续约回访待办 状态已更新为 过期。 2026-01-04 10:29:26,173 - utils.py - task_logger - INFO - 启动任务加载完成。 2026-01-04 10:29:26,173 - main.py - task_logger - INFO - 程序已启动... +2026-01-04 13:45:41,072 - utils.py - task_logger - INFO - 任务队列已从磁盘加载。 +2026-01-04 13:45:42,803 - api.py - task_logger - INFO - 获取了35条数据 +2026-01-04 13:45:42,806 - sample_cloud_modules.py - task_logger - INFO - 任务已从云端获取并保存到 tasks.csv 文件。 +2026-01-04 13:45:42,806 - main.py - task_logger - INFO - 任务列表已保存到 csv 文件中。 +2026-01-04 13:45:42,807 - utils.py - task_logger - INFO - 启动时加载并执行任务... +2026-01-04 13:45:42,807 - utils.py - task_logger - INFO - 任务已从磁盘加载到全局任务字典。 +2026-01-04 13:45:42,808 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,808 - utils.py - task_logger - INFO - 任务 NGV新增数据 (09:00) 状态已更新为 过期。 +2026-01-04 13:45:42,809 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,809 - utils.py - task_logger - INFO - 任务 NGV更新数据 (12:30) 状态已更新为 过期。 +2026-01-04 13:45:42,810 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,810 - utils.py - task_logger - INFO - 任务 新签客户回访 (09:05) 状态已更新为 过期。 +2026-01-04 13:45:42,810 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,811 - utils.py - task_logger - INFO - 任务 续约客户回访 (09:08) 状态已更新为 过期。 +2026-01-04 13:45:42,811 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,811 - utils.py - task_logger - INFO - 任务 接车宝日常派发 (09:10) 状态已更新为 过期。 +2026-01-04 13:45:42,812 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,812 - utils.py - task_logger - INFO - 任务 私域小程序数据支撑 (04:40) 状态已更新为 过期。 +2026-01-04 13:45:42,813 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,813 - utils.py - task_logger - INFO - 任务 小六提成数据支撑 (04:40) 状态已更新为 过期。 +2026-01-04 13:45:42,814 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,814 - utils.py - task_logger - INFO - 任务 异业合作数据支撑 (04:20) 状态已更新为 过期。 +2026-01-04 13:45:42,814 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,814 - utils.py - task_logger - INFO - 任务 短信数据支撑 (04:10) 状态已更新为 过期。 +2026-01-04 13:45:42,815 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,815 - utils.py - task_logger - INFO - 任务 海外邮件推送 (08:28) 状态已更新为 过期。 +2026-01-04 13:45:42,816 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,816 - utils.py - task_logger - INFO - 任务 异常服务待办派发 (10:00) 状态已更新为 过期。 +2026-01-04 13:45:42,817 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,817 - utils.py - task_logger - INFO - 任务 简道云海外项目CRM客户档案迁移BI (08:37) 状态已更新为 过期。 +2026-01-04 13:45:42,817 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,817 - utils.py - task_logger - INFO - 任务 分母报备调整 (09:05) 状态已更新为 过期。 +2026-01-04 13:45:42,818 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,818 - utils.py - task_logger - INFO - 任务 分子报备调整 (09:03) 状态已更新为 过期。 +2026-01-04 13:45:42,819 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,819 - utils.py - task_logger - INFO - 任务 履约表数据支撑 (09:10) 状态已更新为 过期。 +2026-01-04 13:45:42,819 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,819 - utils.py - task_logger - INFO - 任务 字段监控 (06:25) 状态已更新为 过期。 +2026-01-04 13:45:42,820 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,820 - utils.py - task_logger - INFO - 任务 经销商新签服务单转BI (08:05) 状态已更新为 过期。 +2026-01-04 13:45:42,821 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,821 - utils.py - task_logger - INFO - 任务 非标业绩提报转BI (08:01) 状态已更新为 过期。 +2026-01-04 13:45:42,821 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,821 - utils.py - task_logger - INFO - 任务 合伙人结算登记同步到BI (08:02) 状态已更新为 过期。 +2026-01-04 13:45:42,822 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,822 - utils.py - task_logger - INFO - 任务 高德匹配手机号 (05:00) 状态已更新为 过期。 +2026-01-04 13:45:42,823 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,823 - utils.py - task_logger - INFO - 任务 非标业绩提报转BI (12:01) 状态已更新为 过期。 +2026-01-04 13:45:42,823 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,823 - utils.py - task_logger - INFO - 任务 合伙人结算登记同步到BI (12:02) 状态已更新为 过期。 +2026-01-04 13:45:42,824 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,824 - utils.py - task_logger - INFO - 任务 省市区人员关系表转BI (08:00) 状态已更新为 过期。 +2026-01-04 13:45:42,825 - utils.py - task_logger - INFO - 所有任务状态已保存到磁盘。 +2026-01-04 13:45:42,825 - utils.py - task_logger - INFO - 任务 续约回访待办 (09:35) 状态已更新为 过期。 +2026-01-04 13:45:42,825 - utils.py - task_logger - INFO - 启动任务加载完成。 +2026-01-04 13:45:42,825 - main.py - task_logger - INFO - 程序已启动... diff --git a/tasks.csv b/tasks.csv index 6653766..412004a 100644 --- a/tasks.csv +++ b/tasks.csv @@ -1,6 +1,6 @@ unique_id,exec_time,is_switch_on,status NGV新增数据,09:00,True,过期 -NGV更新数据,12:30,True,待执行 +NGV更新数据,12:30,True,过期 新签客户回访,09:05,True,过期 续约客户回访,09:08,True,过期 大客户回访,08:55,False,已禁用 @@ -18,15 +18,19 @@ NGV更新数据,12:30,True,待执行 宜搭流程耗时写入BI,07:22,False,已禁用 简道云员工ID表更新,07:23,False,已禁用 简道云海外项目CRM客户档案迁移BI,08:37,True,过期 -安装服务历史派发,09:00,True,过期 +安装服务历史派发,09:00,False,已禁用 新签客户回访测试,09:00,False,已禁用 分母报备调整,09:05,True,过期 分子报备调整,09:03,True,过期 履约表数据支撑,09:10,True,过期 字段监控,06:25,True,过期 经销商新签服务单转BI,08:05,True,过期 -非标业绩提报转BI,17:01,True,待执行 -合伙人结算登记同步到BI,17:02,True,待执行 +非标业绩提报转BI,08:01,True,过期 +合伙人结算登记同步到BI,08:02,True,过期 高德匹配手机号,05:00,True,过期 +非标业绩提报转BI,12:01,True,过期 +非标业绩提报转BI,17:01,True,待执行 +合伙人结算登记同步到BI,12:02,True,过期 +合伙人结算登记同步到BI,17:02,True,待执行 省市区人员关系表转BI,08:00,True,过期 续约回访待办,09:35,True,过期 diff --git a/test/续约待办宜搭传给简道云.py b/test/续约待办宜搭传给简道云.py index cfbe10b..7742927 100644 --- a/test/续约待办宜搭传给简道云.py +++ b/test/续约待办宜搭传给简道云.py @@ -583,22 +583,19 @@ class YDToJDYRenewalToDo(object): print(f"读取历史文件失败: {e}") df_last = pd.DataFrame() else: - df_last = pd.DataFrame() + df_last = None # 明确标记：无历史文件 - # 假设唯一标识字段为 'instanceId'，请根据实际字段名调整 id_col = 'processInstanceId' - if not df_last.empty and not df_current.empty and id_col in df_current.columns and id_col in df_last.columns: - # 转为字符串确保可比 + + if df_last is not None and not df_last.empty and not df_current.empty and id_col in df_current.columns and id_col in df_last.columns: + # 有历史文件，计算新增 last_ids = set(df_last[id_col].astype(str)) current_ids = set(df_current[id_col].astype(str)) new_ids = current_ids - last_ids diff_records = df_current[df_current[id_col].astype(str).isin(new_ids)].to_dict('records') else: - # 没有历史文件 或 无唯一ID → 返回空 list（按你要求） - diff_records = [] - - # 保存当前全量数据（覆盖） - df_current.to_csv(current_file, index=False) + # 没有历史文件 或 无法比对 → 返回全部当前数据 + diff_records = df_current.to_dict('records') # ← 关键修改点 return diff_records