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