diff --git a/app/api/controller/CronController.php b/app/api/controller/CronController.php index e8cc62762..0eec49bfa 100644 --- a/app/api/controller/CronController.php +++ b/app/api/controller/CronController.php @@ -185,7 +185,20 @@ class CronController extends BaseApiController ->select() ->toArray(); foreach($taskSchedulingPlanList as $taskSchedulingPlan){ - queue(TownTaskSettlementJob::class, $taskSchedulingPlan); + // 三个角色分开结算,避免某个角色的结算逻辑出现异常,导致整个镇农科公司的任务结算都终止 + $taskTemplateInfo = $taskSchedulingPlan['template_info']; + // 负责人任务结算 + if ($taskTemplateInfo['extend']['task_role'] == 1) { + queue(TownTaskSettlementJob::class, $taskSchedulingPlan); + } + // 市场部长任务结算 + if ($taskTemplateInfo['extend']['task_role'] == 2) { + queue(TownTaskSettlementJob::class, $taskSchedulingPlan); + } + // 服务部长任务结算 + if ($taskTemplateInfo['extend']['task_role'] == 3) { + queue(TownTaskSettlementJob::class, $taskSchedulingPlan); + } } Log::info('镇农科公司定时任务结算执行-结束'.date('Y-m-d H:i:s')); return $this->success('镇农科公司定时任务结算执行成功');