瀏覽代碼

线程守护

peng 1 年之前
父節點
當前提交
ca3eb0754f
共有 1 個文件被更改,包括 4 次插入4 次删除
  1. 4 4
      Controller/Cron/CronTaskController.py

+ 4 - 4
Controller/Cron/CronTaskController.py

@@ -1295,7 +1295,7 @@ class CronComparedDataView(View):
             )
             order_list = PayPalService(PAYPAL_CRD['client_id'], PAYPAL_CRD['client_secret']).get_transactions(data)
             thread = threading.Thread(target=CronComparedDataView.thread_compared_paypal_order,
-                                      args=(order_list['transaction_details'], end_date))
+                                      args=(order_list['transaction_details'], end_date), daemon=True)
             thread.start()
             return response.json(0)
         except Exception as e:
@@ -1378,7 +1378,7 @@ class CronComparedDataView(View):
         try:
             order_list = WechatPayObject().download_bill(start_date)
             thread = threading.Thread(target=CronComparedDataView.thread_compared_wechat_order,
-                                      args=(order_list,))
+                                      args=(order_list,), daemon=True)
             thread.start()
             return response.json(0)
         except Exception as e:
@@ -1437,7 +1437,7 @@ class CronComparedDataView(View):
             for item in orders:
                 order_list.append(dict(zip(key_list, item)))
             thread = threading.Thread(target=CronComparedDataView.thread_compared_alipay_order,
-                                      args=(order_list,))
+                                      args=(order_list,), daemon=True)
             thread.start()
             return response.json(0)
         except Exception as e:
@@ -1480,7 +1480,7 @@ class CronComparedDataView(View):
             if CONFIG_INFO == CONFIG_EUR:
                 return response.json(0, list(order_qs))
             thread = threading.Thread(target=CronComparedDataView.thread_compared_ansjer_order,
-                                      args=(list(order_qs), start_date))
+                                      args=(list(order_qs), start_date), daemon=True)
             thread.start()
             return response.json(0)
         except Exception as e: