异常回访提交

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:

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)
+```