diff --git a/back_ground_module/Exception_Task.py b/back_ground_module/Exception_Task.py index 3fa2d1f..cb8126b 100644 --- a/back_ground_module/Exception_Task.py +++ b/back_ground_module/Exception_Task.py @@ -286,6 +286,7 @@ class NewExceptionTask: NGV_data_id = None reason = None create_exception =None + create_date = None # 获取关联数据 for NGV_Data in self.NGV_data_list: # NGV_Data = NGV_Data.get("data") @@ -299,6 +300,8 @@ class NewExceptionTask: logger.info(f"获取关联数据成功:{NGV_data_id}, {province_name}, {city_name}, {area_name}") # 是否生成异常待办 create_exception = NGV_Data.get("_widget_1758769279995") + # 获取上线日期(文本) + create_date = NGV_Data.get("_widget_1734062123176") # 判断门店原因 # if reason in ["门店倒闭", "门店转让", "加盟其他连锁","切换竞品","虚拟门店","重新开户","已退款","二套系统"]: @@ -307,6 +310,43 @@ class NewExceptionTask: # 判断是否继续生成异常待办 if create_exception == "否": continue + # 新增:检查 create_date_str 是否存在且有效 + if not create_date: + logger.warning("上线日期为空,跳过该记录") + continue + + # 定义可能的日期格式(灵活应对不同格式) + date_formats = [ + "%Y-%m-%d %H:%M:%S", # 含时间 + "%Y-%m-%d", # 仅日期 + "%Y/%m/%d", + "%Y/%m/%d %H:%M:%S" + ] + + parsed_date = None + for fmt in date_formats: + try: + parsed_date = datetime.datetime.strptime(create_date.strip(), fmt).date() + logger.debug(f"使用格式 {fmt} 成功解析日期: {parsed_date}") + break + except ValueError: + continue + + if parsed_date is None: + logger.error(f"无法解析上线日期: '{create_date}',支持的格式: %Y-%m-%d, %Y-%m-%d %H:%M:%S 等") + continue # 解析失败,跳过 + + # 使用解析后的日期进行判断 + now_date = datetime.date.today() + delta = now_date - parsed_date + days_diff = delta.days + + if days_diff > 30: + logger.info(f"上线日期 {parsed_date} 超过30天({days_diff}天),生成待办") + # ✅ 继续后续待办创建逻辑 + else: + logger.info(f"上线日期 {parsed_date} 在30天内,跳过处理") + continue if not NGV_data_id: diff --git a/doc/api调用.md b/doc/api调用.md new file mode 100644 index 0000000..70ff7e9 --- /dev/null +++ b/doc/api调用.md @@ -0,0 +1,40 @@ +## 获取多条数据 +```python +from api import API +api_instance =API() +payload = {"api_key": "6694d3c4fcb69ca9a111a6c4", + "entry_id": "6769204a1902c9341340a1bc", + } +staff_id = api_instance.entry_data_list(payload) +``` + +## 创建多条数据 +```python +from api import API +api_instance =API() +payload_dict = {} +payload_dict.update({ + "_widget_1734590278279": {"value": row["group_name"]}, # 公司名称 + "_widget_1735112931760": {"value": row["id_own_group"]}, # 公司id + "_widget_1735112931761": {"value": row["id_own_org"]}, # 门店id + "_widget_1734590278281": {"value": row['org_name']}, # 门店名称 +) + +routine_follow_up_payload = { + "api_key": "675b900991ad2491c69389ca", + "entry_id": "675b9c63925cd404038a6b86", + "is_start_workflow": "true", # 是否启动流程 + "data": payload_dict, + } +res = api_instance.data_batch_create(routine_follow_up_payload) +``` + +## 删除单条 +```python +from api import API +api_instance =API() +delete_data = {"api_key": Config.EFFICIENT_CAR_PICKUP_APP_ID, + "entry_id": Config.EFFICIENT_CAR_PICKUP_CUSTOMER_HISTORY_ID, + "data_id": row["数据id"]} +api_instance.entry_data_delete(delete_data) +```