ソースを参照

Merge remote-tracking branch 'remotes/origin/locky' into test

Ansjer 11 ヶ月 前
コミット
a20ea23395
1 ファイル変更26 行追加0 行削除
  1. 26 0
      Controller/Cron/CronTaskController.py

+ 26 - 0
Controller/Cron/CronTaskController.py

@@ -32,6 +32,7 @@ from Model.models import Device_User, Device_Info, UidSetModel, UID_Bucket, Unus
     Store_Meal, Lang, VodBucketModel, UnicomComboOrderInfo, UnicomDeviceInfo, AbnormalOrder, DailyReconciliation, \
     CustomizedPush, UIDCompanySerialModel, UIDModel, LogModel, OperatingCosts, UidBucketStatistics, AppScannedSerial
 from Object.AWS.AmazonS3Util import AmazonS3Util
+from Object.AWS.S3Email import S3Email
 from Object.RedisObject import RedisObject
 from Object.ResponseObject import ResponseObject
 from Object.utils import LocalDateTimeUtil
@@ -836,6 +837,8 @@ class CronCollectDataView(View):
             return self.collect_operating_costs(response)
         elif operation == 'collectObjSize':  # 定时设备s3存储量
             return self.collect_obj_size(response)
+        elif operation == 'checkRequest':  # 定时检查各个服的https请求
+            return self.check_request(response)
         else:
             return response.json(404)
 
@@ -1349,6 +1352,29 @@ class CronCollectDataView(View):
             print('error')
             LOGGER.info('统计s3信息异常:errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
 
+    @staticmethod
+    def check_request(response):
+        domain_name_list = [
+            'test.zositechc.cn', 'test.push.zositechc.cn',
+            'www.zositechc.cn', 'api.zositech2.cn', 'api.loocam2.cn', 'common.neutral2.cn', 'api.aiotserver.cn',
+            'push.zositechc.cn',
+            'www.dvema.com', 'api.zositech2.com', 'api.loocam2.com', 'common.neutral2.com', '149.neutral2.com',
+            '365.neutral2.com', 'push.dvema.com',
+            'www.zositeche.com', 'api.zositeche.com', 'api.loocam3.com', 'common.neutral3.com',
+            'push.zositeche.com',
+            'www.zositech.xyz', 'smart.loocam2.com'
+        ]
+        for domain_name in domain_name_list:
+            url = 'https://{}/init/health-check'
+            try:
+                requests.post(url=url, timeout=30)
+            except Exception as e:
+                email_content = 'https请求域名{}出现异常!'.format(domain_name)
+                S3Email().faEmail(email_content, 'servers@ansjer.com')
+        return response.json(0)
+
+
+
     @staticmethod
     def collect_icloud_order(response):
         try: