Ver Fonte

线程守护

peng há 1 ano atrás
pai
commit
89ea2be8bf
1 ficheiros alterados com 4 adições e 4 exclusões
  1. 4 4
      Controller/Cron/CronTaskController.py

+ 4 - 4
Controller/Cron/CronTaskController.py

@@ -1491,7 +1491,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:
@@ -1574,7 +1574,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:
@@ -1633,7 +1633,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:
@@ -1676,7 +1676,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: