|
|
@@ -248,17 +248,17 @@ public class HospitalManager {
|
|
|
* @return void
|
|
|
*/
|
|
|
public void refreshUpdateConfig(HisUpdateEntity updateConfig){
|
|
|
- if(Objects.equals(updateConfig,this.updateConfig)
|
|
|
- ||updateConfig==null
|
|
|
- ||!Boolean.TRUE.equals(updateConfig.getEnable())
|
|
|
- ||null==updateConfig.getInterval()
|
|
|
- ||updateConfig.getInterval()<0){
|
|
|
- if(hisSchedule !=null&&!hisSchedule.isCancelled()){
|
|
|
- //如果有定时任务正在运行,则关闭
|
|
|
- hisSchedule.cancel(true);
|
|
|
- }
|
|
|
- return;
|
|
|
- }
|
|
|
+// if(Objects.equals(updateConfig,this.updateConfig)
|
|
|
+// ||updateConfig==null
|
|
|
+// ||!Boolean.TRUE.equals(updateConfig.getEnable())
|
|
|
+// ||null==updateConfig.getInterval()
|
|
|
+// ||updateConfig.getInterval()<0){
|
|
|
+// if(hisSchedule !=null&&!hisSchedule.isCancelled()){
|
|
|
+// //如果有定时任务正在运行,则关闭
|
|
|
+// hisSchedule.cancel(true);
|
|
|
+// }
|
|
|
+// return;
|
|
|
+// }
|
|
|
hisSchedule = singleHisExecutor.schedule(() -> {
|
|
|
scheduleHis();
|
|
|
singleHisExecutor.schedule(this::scheduleHis, updateConfig.getInterval(), TimeUnit.MINUTES);
|
|
|
@@ -274,6 +274,13 @@ public class HospitalManager {
|
|
|
* @return void
|
|
|
*/
|
|
|
private void scheduleHis(){
|
|
|
+ if(Objects.equals(updateConfig,this.updateConfig)
|
|
|
+ ||updateConfig==null
|
|
|
+ ||!Boolean.TRUE.equals(updateConfig.getEnable())
|
|
|
+ ||null==updateConfig.getInterval()
|
|
|
+ ||updateConfig.getInterval()<0){
|
|
|
+ return;
|
|
|
+ }
|
|
|
//拉取最新的50条输注信息,更新病人数据
|
|
|
Page<BusInfusionHistoryEntity> infusionHistoryPage = new Page<>(0,50,false);
|
|
|
infusionHistoryPage= infusionHistoryService.page(infusionHistoryPage, new QueryWrapper<BusInfusionHistoryEntity>().lambda().eq(BusInfusionHistoryEntity::getTenantId, hospitalId)
|