corp1016

2025-10-16 18:53:59 +08:00
parent 2d89545816
commit 3830f3a9df
3 changed files with 865 additions and 37 deletions
@@ -199,16 +199,23 @@ def main():
            if not ewcc.is_query_oil_fw_tj and datetime.datetime.now().hour >= 3:
                logger.info("开始查询油站服务号应用统计")
                ewcc.query_oil_fw_tj()
-                #ewcc.is_query_oil_fw_tj=ewcc.query_oil_fw_tj()  
-                #continue
+                ewcc.is_query_oil_fw_tj=ewcc.query_oil_fw_tj()  
+                continue

            # 查询油站汇总本月累计
            if not ewcc.is_query_oil_current_month_lj and datetime.datetime.now().hour >= 3:
                logger.info("开始查询  按油站汇总本月累计")
                ewcc.query_oil_current_month_lj()
-                #ewcc.is_query_oil_current_month_lj=ewcc.query_oil_current_month_lj()  
+                ewcc.is_query_oil_current_month_lj=ewcc.query_oil_current_month_lj()  
                continue
-
+            
+            # 查询客户评价与员工关联统计
+            if not ewcc.is_query_client_emp_tj and datetime.datetime.now().hour >= 3:
+                logger.info("开始查询客户评价与员工关联统计")
+                ewcc.query_client_emp_tj()
+                ewcc.is_query_client_emp_tj=ewcc.query_client_emp_tj()  
+                continue
+            
            # 获取待处理查询
            pending_queries = get_pending_queries()