代理订单取消任务调度方法

AdminController/CloudServiceManage/AgentOrderController.py

@@ -17,8 +17,7 @@ from django.views import View
 from AgentModel.models import AgentDevice, AgentCloudServicePackage, AgentCustomerPackage, AgentDeviceOrder, \
     AgentDeviceOrderInstallment, AgentAccount
 from Ansjer.config import LOGGER
-from Model.models import Order_Model, Store_Meal, UnicomCombo, TimeZoneInfo
-from Object.CeleryBeatObject import CeleryBeatObj
+from Model.models import Order_Model, Store_Meal, UnicomCombo
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Service.CommonService import CommonService
@@ -62,40 +61,6 @@ class AgentOrderView(View):
 
             self.check_agent_service_package(order_id, uid, int(package_id))
             return response.json(0)
-        elif operation == 'addSettlementJob':
-            self.add_settlement_job()
-            return response.json(0)
-
-        elif operation == 'delSettlementJob':
-            self.del_settlement_job()
-            return response.json(0)
-        elif operation == 'updateSettlementJob':
-            self.update_settlement_job()
-            return response.json(0)
-
-    @classmethod
-    def update_settlement_job(cls):
-        celery_beat_obj = CeleryBeatObj()
-        job_name = 'Agent-updateSettlement'
-        time_zone_info_qs = TimeZoneInfo.objects.filter(tz=8).values('zone_info')
-        if time_zone_info_qs.exists():
-            time_zone = time_zone_info_qs[0]['zone_info']
-            cron_tuple = ('*/3', '*', '*', '*', '*', time_zone)
-            celery_beat_obj.update_task(name=job_name, crontab=cron_tuple)
-
-    @classmethod
-    def add_settlement_job(cls):
-        celery_beat_obj = CeleryBeatObj()
-        job_name = 'Agent-updateSettlement'
-        SMART_SCENE_TASK = 'Controller.CeleryTasks.tasks.update_installment_settlement_order'
-        celery_beat_obj.creat_crontab_task(
-            timezone_offset=8, name=job_name, task=SMART_SCENE_TASK, minute='*/2')
-
-    @classmethod
-    def del_settlement_job(cls):
-        celery_beat_obj = CeleryBeatObj()
-        job_name = 'Agent-updateSettlement'
-        celery_beat_obj.del_task(job_name)
 
     @classmethod
     def check_agent_service_package(cls, order_id, uid, package_id):