From a34be58cdf00e92607edefb3130bdfd979390c16 Mon Sep 17 00:00:00 2001 From: zhaowenxuan <chacca165@163.com> Date: 星期五, 21 三月 2025 17:29:38 +0800 Subject: [PATCH] 增加外送视图 --- ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java | 23 +++++++++++++++++++---- 1 files changed, 19 insertions(+), 4 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java index 2f5959d..532cb41 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java @@ -1,6 +1,6 @@ package com.ltkj.web.config.timer; -import cn.hutool.core.util.RandomUtil; +import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.ltkj.common.enums.DataSourceType; import com.ltkj.db.DataSourceConfig; @@ -14,8 +14,6 @@ import com.ltkj.system.service.ISysConfigService; import jodd.util.StringUtil; import lombok.extern.slf4j.Slf4j; -import org.redisson.api.RLock; -import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Profile; import org.springframework.scheduling.TaskScheduler; @@ -30,7 +28,6 @@ import java.time.temporal.ChronoUnit; import java.util.*; import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.ReentrantLock; @Slf4j @@ -248,6 +245,24 @@ } } + String isWsByView = configService.selectConfigByKey("is_ws_by_view"); + if (StrUtil.isNotBlank(isWsByView) && isWsByView.equals("Y")){ + List<LtkjHysqd> sqd = testMapper.getWsHySqdByView(s); + if (sqd != null && !sqd.isEmpty()){ + for (LtkjHysqd hysqd : sqd) { + LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh()); + if (null != jybgid) { + ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh()); + ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(hysqd.getTmh()); + } + if (ltkjHysqdService.save(hysqd)) { + List<LtkjHybgd> wsbg = testMapper.getWsHyBgdByView(hysqd.getTmh()); + ltkjHybgdService.saveBatch(wsbg); + } + } + } + } + List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s,hospId); if (null != hysqdList && !hysqdList.isEmpty()) { for (LtkjHysqd hysqd : hysqdList) { -- Gitblit v1.8.0