From 7dcbfad4a275f7237ed97d78f815fdd177195d1c Mon Sep 17 00:00:00 2001 From: bwadmin <7469504@qq.com> Date: Fri, 31 Oct 2025 16:45:16 +0800 Subject: [PATCH] corp1031 --- ewcc2.py | 9 ++- log/app.log.2025-10-27_15 | 46 +++++++++++ log/app.log.2025-10-29_09 | 159 ++++++++++++++++++++++++++++++++++++++ query_processor.py | 22 ++++-- 4 files changed, 229 insertions(+), 7 deletions(-) create mode 100644 log/app.log.2025-10-27_15 create mode 100644 log/app.log.2025-10-29_09 diff --git a/ewcc2.py b/ewcc2.py index 7e04d09..00986c9 100644 --- a/ewcc2.py +++ b/ewcc2.py @@ -15,7 +15,7 @@ class Sinopec_ewcc(object): self.url_info= 'ewcc.sinopec' self.browser_path= r'C:\Program Files (x86)\Microsoft\Edge\Application\msedge.exe' self.co = ChromiumOptions().set_browser_path(self.browser_path) - self.co.headless(True) + # self.co.headless(True) self.co.ignore_certificate_errors(True) self.browser=Chromium(self.co) self.tab=self.browser.latest_tab @@ -26,6 +26,13 @@ class Sinopec_ewcc(object): self.is_query_oil_current_month_lj=False self.is_query_client_emp_tj=False + def reset(self): + # 关闭当前浏览器 + self.browser.quit() + + self.browser=Chromium(self.co) + self.tab=self.browser.latest_tab + def quit(self): self.browser.quit() logger.info(f"浏览器已退出") diff --git a/log/app.log.2025-10-27_15 b/log/app.log.2025-10-27_15 new file mode 100644 index 0000000..3aac5c0 --- /dev/null +++ b/log/app.log.2025-10-27_15 @@ -0,0 +1,46 @@ +2025-10-27 15:56:09,471 - INFO - ѯ +2025-10-27 15:56:11,497 - INFO - ɹȡ: +2025-10-27 15:56:11,501 - INFO - жǷ¼ +2025-10-27 15:56:22,375 - INFO - ûҵ¼ɹı־ +2025-10-27 15:56:22,376 - INFO - ʹcookiesԵ¼ +2025-10-27 15:56:22,376 - INFO - ʹôcookies¼ +2025-10-27 15:56:22,376 - INFO - ɹַcookiesΪJSON󣬹 5 +2025-10-27 15:56:22,377 - INFO - ʹôcookies¼ +2025-10-27 15:56:22,384 - INFO - ɹб͵cookies +2025-10-27 15:56:35,849 - INFO - жǷ¼ +2025-10-27 15:56:35,878 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-27 15:56:35,879 - INFO - жǷ¼ +2025-10-27 15:56:35,885 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-27 15:56:36,323 - INFO - cookies +2025-10-27 15:56:36,387 - INFO - ɹparam4ֵ +2025-10-27 15:56:36,388 - INFO - ʼѯԱȨԱϸ +2025-10-27 15:56:36,788 - INFO - +2025-10-27 15:56:36,826 - INFO - ۺϹ +2025-10-27 15:56:37,087 - INFO - ͻȨԱϸ +2025-10-27 15:56:56,662 - INFO - ɹ ԱȨԱϸ +2025-10-27 15:56:57,663 - INFO - ͻԱͳƲѯ +2025-10-27 15:56:57,663 - INFO - ʼѯվӦͳ +2025-10-27 15:56:57,926 - INFO - +2025-10-27 15:56:57,958 - INFO - ۺϹ +2025-10-27 15:56:58,217 - INFO - վӦͳ +2025-10-27 15:57:00,532 - INFO - ѡ վ +2025-10-27 15:57:18,561 - INFO - ɹ վӦͳ +2025-10-27 15:57:19,557 - INFO - ʼѯ վܱۼ +2025-10-27 15:57:19,838 - INFO - +2025-10-27 15:57:19,906 - INFO - ͳһͻ +2025-10-27 15:57:20,163 - INFO - վܱۼ +2025-10-27 15:57:23,197 - INFO - iframeԪϢ +2025-10-27 15:57:25,229 - INFO - ѯ +2025-10-27 15:57:32,172 - INFO - Ϣ +2025-10-27 15:57:32,173 - INFO - ɹ վܱۼ +2025-10-27 15:57:33,156 - INFO - ʼѯͻԱͳ +2025-10-27 15:57:33,425 - INFO - +2025-10-27 15:57:33,462 - INFO - ͳһͻ +2025-10-27 15:57:33,790 - INFO - ͻԱͳ +2025-10-27 15:57:38,105 - INFO - ѡ վ +2025-10-27 15:57:50,843 - INFO - myframeԪϢ : +2025-10-27 15:57:56,222 - INFO - ɹ ͻԱͳ +2025-10-27 15:57:57,225 - INFO - ɹȡѯ 0 +2025-10-27 15:57:57,226 - INFO - δɣȴ 60 ٴμ +2025-10-27 15:58:42,640 - INFO - ѯûж +2025-10-27 15:58:42,640 - INFO - ѯֹͣ diff --git a/log/app.log.2025-10-29_09 b/log/app.log.2025-10-29_09 new file mode 100644 index 0000000..431bda8 --- /dev/null +++ b/log/app.log.2025-10-29_09 @@ -0,0 +1,159 @@ +2025-10-29 09:24:34,377 - INFO - ѯ +2025-10-29 09:24:35,820 - INFO - ɹȡ: +2025-10-29 09:24:35,848 - INFO - жǷ¼ +2025-10-29 09:24:45,851 - INFO - ûҵ¼ɹı־ +2025-10-29 09:24:45,852 - INFO - ʹcookiesԵ¼ +2025-10-29 09:24:45,852 - INFO - ʹôcookies¼ +2025-10-29 09:24:45,853 - INFO - ɹַcookiesΪJSON󣬹 11 +2025-10-29 09:24:45,854 - INFO - ʹôcookies¼ +2025-10-29 09:24:45,865 - INFO - ɹб͵cookies +2025-10-29 09:24:55,325 - INFO - Ͱťڲѵ +2025-10-29 09:24:55,326 - INFO - жǷ¼ +2025-10-29 09:24:56,284 - INFO - ҵ¼ɹı־: +2025-10-29 09:24:56,285 - INFO - жǷ¼ +2025-10-29 09:24:56,293 - INFO - ҵ¼ɹı־: +2025-10-29 09:24:56,536 - INFO - cookies +2025-10-29 09:24:56,622 - INFO - ɹparam4ֵ +2025-10-29 09:24:56,622 - INFO - ʼѯԱȨԱϸ +2025-10-29 09:24:57,039 - INFO - +2025-10-29 09:24:57,082 - INFO - ۺϹ +2025-10-29 09:24:57,343 - INFO - ͻȨԱϸ +2025-10-29 09:25:16,991 - INFO - ɹ ԱȨԱϸ +2025-10-29 09:25:18,002 - INFO - ͻԱͳƲѯ +2025-10-29 09:25:18,003 - INFO - ʼѯվӦͳ +2025-10-29 09:25:18,256 - INFO - +2025-10-29 09:25:18,302 - INFO - ۺϹ +2025-10-29 09:25:18,559 - INFO - վӦͳ +2025-10-29 09:25:20,861 - INFO - ѡ վ +2025-10-29 09:25:39,179 - INFO - ɹ վӦͳ +2025-10-29 09:25:40,160 - INFO - ʼѯ վܱۼ +2025-10-29 09:25:40,411 - INFO - +2025-10-29 09:25:40,462 - INFO - ͳһͻ +2025-10-29 09:25:40,720 - INFO - վܱۼ +2025-10-29 09:25:43,753 - INFO - iframeԪϢ +2025-10-29 09:25:45,785 - INFO - ѯ +2025-10-29 09:25:51,755 - INFO - Ϣ +2025-10-29 09:25:51,756 - INFO - ɹ վܱۼ +2025-10-29 09:25:52,766 - INFO - ʼѯͻԱͳ +2025-10-29 09:25:53,024 - INFO - +2025-10-29 09:25:53,074 - INFO - ͳһͻ +2025-10-29 09:25:53,337 - INFO - ͻԱͳ +2025-10-29 09:25:57,655 - INFO - ѡ վ +2025-10-29 09:26:10,354 - INFO - myframeԪϢ : +2025-10-29 09:26:15,550 - INFO - ɹ ͻԱͳ +2025-10-29 09:26:16,700 - INFO - ɹȡѯ 2 +2025-10-29 09:26:16,701 - INFO - ѯƺ: A91H23 绰None +2025-10-29 09:26:24,806 - INFO - ѯ 1 ¼ +2025-10-29 09:26:25,513 - INFO - ѯ: 1 +2025-10-29 09:26:25,514 - INFO - Ϣ: [{'csrid': '850c1ff72a8540ed8c6ccce4dd87061c', 'tenantId': None, 'mchcode': '1567604249', 'orgcode': '43', 'syssource': 'WECHAT_001', 'sysusercode': '1b4feed48241481c96f763bc7eaa94b2', 'name': '*', 'certtype': '1', 'certno': '430124********7311', 'email': None, 'mobilephone': '17872347198', 'deviceid': '13fc0669093cf3743afa8e1c7759c2615', 'deviceinfo': '10.13.0.49,realme,RMX2200,10,android', 'csreffectdate': '2021-09-06 15:25:53', 'csrfaildate': None, 'flag': 1, 'reserve01': None, 'reserve02': None, 'reserve03': None, 'reserve04': None, 'reserve05': None, 'reserve06': None, 'reserve07': None, 'reserve08': None, 'reserve09': None, 'reserve10': None, 'remark': None, 'isDelete': False, 'sortNo': 0, 'creatorId': None, 'creator': 'admin', 'createTime': '2021-09-06T07:25:53.000+0000', 'editorId': None, 'editor': 'admin', 'editTime': '2023-06-14T23:51:45.000+0000', 'csrsmy': 'ksttk5x3kvm3kwtm707k71k0333hm9xt55v75k51xt357zkwkzts531t9zkz959k', 'unionid': '98dc703a2ba6706c71fd0bd032a4e978'}] +2025-10-29 09:26:25,731 - INFO - ɹ²ѯ: ID=3472, =1 +2025-10-29 09:26:25,731 - INFO - ѯƺ: A51FM1 绰None +2025-10-29 09:26:34,567 - INFO - ѯ 1 ¼ +2025-10-29 09:26:35,331 - INFO - ѯ: 1 +2025-10-29 09:26:35,332 - INFO - Ϣ: [{'csrid': 'e2a96265ff4f42f3a8b639f583e39f78', 'tenantId': None, 'mchcode': '1567604249', 'orgcode': '43', 'syssource': 'ANDSDK_SRP_PAHCZ', 'sysusercode': '8902c4a913a34cec9bce7773e6b1b73d', 'name': '*Ԫ', 'certtype': '1', 'certno': '430124********956X', 'email': None, 'mobilephone': '15116494562', 'deviceid': '206774c3dcc563d85b091de56ff8033f5', 'deviceinfo': '΢С', 'csreffectdate': '2024-09-03 16:00:44', 'csrfaildate': None, 'flag': 1, 'reserve01': None, 'reserve02': None, 'reserve03': None, 'reserve04': None, 'reserve05': None, 'reserve06': None, 'reserve07': None, 'reserve08': None, 'reserve09': None, 'reserve10': None, 'remark': None, 'isDelete': False, 'sortNo': 0, 'creatorId': None, 'creator': 'admin', 'createTime': '2024-09-03T08:00:44.000+0000', 'editorId': None, 'editor': 'admin', 'editTime': '2025-01-13T08:25:14.000+0000', 'csrsmy': '9t0339zxt909k5mz97ks31kmzh5w5515z3ktmvvxztx15wxxm950mzhh53hmwsxx', 'unionid': '5aea4dc7c3d1a7a51c9e14ff9ec342fa'}] +2025-10-29 09:26:35,412 - INFO - ɹ²ѯ: ID=3471, =1 +2025-10-29 09:26:35,412 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:27:35,433 - INFO - ɹȡ: +2025-10-29 09:27:35,433 - INFO - жǷ¼ +2025-10-29 09:27:35,454 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:27:35,454 - INFO - жǷ¼ +2025-10-29 09:27:35,472 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:27:35,472 - INFO - жǷ¼ +2025-10-29 09:27:35,565 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:27:35,805 - INFO - cookies +2025-10-29 09:27:35,880 - INFO - ɹparam4ֵ +2025-10-29 09:27:35,931 - INFO - ɹȡѯ 0 +2025-10-29 09:27:35,932 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:28:35,952 - INFO - ɹȡ: +2025-10-29 09:28:35,953 - INFO - жǷ¼ +2025-10-29 09:28:35,967 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:28:35,968 - INFO - жǷ¼ +2025-10-29 09:28:35,977 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:28:35,977 - INFO - жǷ¼ +2025-10-29 09:28:35,985 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:28:36,424 - INFO - cookies +2025-10-29 09:28:36,456 - INFO - ɹparam4ֵ +2025-10-29 09:28:36,471 - INFO - ɹȡѯ 0 +2025-10-29 09:28:36,472 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:29:52,512 - ERROR - ȡʱ: HTTPConnectionPool(host='10.190.20.156', port=99): Max retries exceeded with url: /api/parameters (Caused by ConnectTimeoutError(, 'Connection to 10.190.20.156 timed out. (connect timeout=None)')) +2025-10-29 09:29:52,512 - WARNING - ޷ȡòֹͣ5 +2025-10-29 09:29:57,547 - INFO - ɹȡ: +2025-10-29 09:29:57,547 - INFO - жǷ¼ +2025-10-29 09:29:57,561 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:29:57,562 - INFO - жǷ¼ +2025-10-29 09:29:57,569 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:29:57,570 - INFO - жǷ¼ +2025-10-29 09:29:57,580 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:29:58,048 - INFO - cookies +2025-10-29 09:29:58,281 - INFO - ɹparam4ֵ +2025-10-29 09:29:58,311 - INFO - ɹȡѯ 0 +2025-10-29 09:29:58,312 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:30:58,340 - INFO - ɹȡ: +2025-10-29 09:30:58,341 - INFO - жǷ¼ +2025-10-29 09:30:58,354 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:30:58,354 - INFO - жǷ¼ +2025-10-29 09:30:58,363 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:30:58,364 - INFO - жǷ¼ +2025-10-29 09:30:58,377 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:30:58,607 - INFO - cookies +2025-10-29 09:30:58,679 - INFO - ɹparam4ֵ +2025-10-29 09:30:58,696 - INFO - ɹȡѯ 0 +2025-10-29 09:30:58,697 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:31:58,721 - INFO - ɹȡ: +2025-10-29 09:31:58,722 - INFO - жǷ¼ +2025-10-29 09:31:58,736 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:31:58,736 - INFO - жǷ¼ +2025-10-29 09:31:58,744 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:31:58,744 - INFO - жǷ¼ +2025-10-29 09:31:58,752 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:31:58,978 - INFO - cookies +2025-10-29 09:31:59,483 - INFO - ɹparam4ֵ +2025-10-29 09:31:59,556 - INFO - ɹȡѯ 0 +2025-10-29 09:31:59,557 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:32:59,575 - INFO - ɹȡ: +2025-10-29 09:32:59,575 - INFO - жǷ¼ +2025-10-29 09:32:59,589 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:32:59,589 - INFO - жǷ¼ +2025-10-29 09:32:59,597 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:32:59,598 - INFO - жǷ¼ +2025-10-29 09:32:59,605 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:32:59,987 - INFO - cookies +2025-10-29 09:33:00,232 - INFO - ɹparam4ֵ +2025-10-29 09:33:00,326 - INFO - ɹȡѯ 0 +2025-10-29 09:33:00,327 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:34:00,352 - INFO - ɹȡ: +2025-10-29 09:34:00,353 - INFO - жǷ¼ +2025-10-29 09:34:00,367 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:34:00,367 - INFO - жǷ¼ +2025-10-29 09:34:00,375 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:34:00,376 - INFO - жǷ¼ +2025-10-29 09:34:00,383 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:34:00,643 - INFO - cookies +2025-10-29 09:34:00,683 - INFO - ɹparam4ֵ +2025-10-29 09:34:00,698 - INFO - ɹȡѯ 0 +2025-10-29 09:34:00,700 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:35:00,726 - INFO - ɹȡ: +2025-10-29 09:35:00,727 - INFO - жǷ¼ +2025-10-29 09:35:00,741 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:35:00,742 - INFO - жǷ¼ +2025-10-29 09:35:00,750 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:35:00,750 - INFO - жǷ¼ +2025-10-29 09:35:00,757 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:35:01,004 - INFO - cookies +2025-10-29 09:35:01,057 - INFO - ɹparam4ֵ +2025-10-29 09:35:01,086 - INFO - ɹȡѯ 0 +2025-10-29 09:35:01,086 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:36:01,111 - INFO - ɹȡ: +2025-10-29 09:36:01,112 - INFO - жǷ¼ +2025-10-29 09:36:01,126 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:36:01,126 - INFO - жǷ¼ +2025-10-29 09:36:01,135 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:36:01,135 - INFO - жǷ¼ +2025-10-29 09:36:01,143 - INFO - ҵ¼ɹı־: [2055260_pengf332] +2025-10-29 09:36:01,421 - INFO - cookies +2025-10-29 09:36:01,624 - INFO - ɹparam4ֵ +2025-10-29 09:36:01,656 - INFO - ɹȡѯ 0 +2025-10-29 09:36:01,656 - INFO - δɣȴ 60 ٴμ +2025-10-29 09:36:10,588 - INFO - ѯûж +2025-10-29 09:36:10,589 - INFO - ѯֹͣ +2025-10-29 09:36:11,623 - INFO - ˳ diff --git a/query_processor.py b/query_processor.py index 4c1228d..e9ada77 100644 --- a/query_processor.py +++ b/query_processor.py @@ -2,7 +2,7 @@ import requests import time from applog import logger import requests -import datetime +from datetime import datetime, timedelta from ewcc2 import Sinopec_ewcc @@ -165,6 +165,8 @@ def save_param4(param4_value): def main(): logger.info("查询处理代码启动") ewcc = Sinopec_ewcc() + # 记录上一次执行代码B的时间 + last_b_execution = datetime.now() i =0 # 主循环 while True: @@ -181,7 +183,15 @@ def main(): ewcc.quit( ) ewcc=Sinopec_ewcc() continue - + + # 循环执行A和B函数，每小时切换一次 + if datetime.now() - last_b_execution >= timedelta(hours=1): + # 执行A函数 + logger.info("每一小时重启下 浏览器") + ewcc.reset() + # 重置计时器 + last_b_execution = datetime.now() + # 自动登录 if not ewcc.Autologin(parameters['param1'],parameters['param2'],parameters['param3'],parameters['param4']): time.sleep(30) @@ -194,22 +204,22 @@ def main(): ewcc.today_is_export_date() # 查询员工拉新权益会员明细 - if not ewcc.is_query_member and datetime.datetime.now().hour >= 3: + if not ewcc.is_query_member and datetime.now().hour >= 6: logger.info("开始查询员工拉新权益会员明细") ewcc.is_query_member=ewcc.query_memeber() # 查询员工拉新权益会员明细 - if not ewcc.is_query_oil_fw_tj and datetime.datetime.now().hour >= 3: + if not ewcc.is_query_oil_fw_tj and datetime.now().hour >= 6: logger.info("开始查询油站服务号应用统计") ewcc.is_query_oil_fw_tj=ewcc.query_oil_fw_tj() # 查询油站汇总本月累计 - if not ewcc.is_query_oil_current_month_lj and datetime.datetime.now().hour >= 3: + if not ewcc.is_query_oil_current_month_lj and datetime.now().hour >= 6: logger.info("开始查询 按油站汇总本月累计") ewcc.is_query_oil_current_month_lj=ewcc.query_oil_current_month_lj() # 查询客户评价与员工关联统计 - if not ewcc.is_query_client_emp_tj and datetime.datetime.now().hour >= 3: + if not ewcc.is_query_client_emp_tj and datetime.now().hour >= 6: logger.info("开始查询客户评价与员工关联统计") ewcc.is_query_client_emp_tj=ewcc.query_client_emp_tj()