Selaa lähdekoodia

add
优化定时任务

lifang 1 kuukausi sitten
vanhempi
commit
73e1bc2623

+ 7 - 4
nb-service/web-service/src/main/java/com/nb/web/service/bus/hospital/HospitalHisDataPullJob.java

@@ -1,16 +1,19 @@
 package com.nb.web.service.bus.hospital;
 
 import cn.hutool.core.collection.CollUtil;
-import cn.hutool.extra.spring.SpringUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.nb.core.exception.CustomException;
 import com.nb.web.api.entity.BusInfusionHistoryEntity;
+import com.nb.web.service.bus.hospital.script.ScriptManager;
 import com.nb.web.service.bus.service.LocalBusHospitalService;
 import com.nb.web.service.bus.service.LocalBusInfusionHistoryService;
+import com.nb.web.service.quartz.util.SpringUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.quartz.Job;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.List;
 import java.util.Set;
@@ -33,13 +36,13 @@ public class HospitalHisDataPullJob implements Job {
     @Override
     public void execute(JobExecutionContext context) throws JobExecutionException {
         if(hospitalService==null){
-            hospitalService = SpringUtil.getBean(LocalBusHospitalService.class);
+            hospitalService = SpringUtils.getBean(LocalBusHospitalService.class);
         }
         if(infusionHistoryService==null){
-            infusionHistoryService = SpringUtil.getBean(LocalBusInfusionHistoryService.class);
+            infusionHistoryService = SpringUtils.getBean(LocalBusInfusionHistoryService.class);
         }
         if(hospitalManagerRegister==null){
-            hospitalManagerRegister = SpringUtil.getBean(HospitalManagerRegister.class);
+            hospitalManagerRegister = SpringUtils.getBean(HospitalManagerRegister.class);
         }
 
         String hospitalId = context.getJobDetail().getJobDataMap().getString("hospitalId");