From c5286d60680e88a22fbe391385ad35cadb9ac874 Mon Sep 17 00:00:00 2001 From: zhaowenxuan <chacca165@163.com> Date: 星期五, 18 四月 2025 19:38:37 +0800 Subject: [PATCH] 修改套餐id --- ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java | 47 ++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 38 insertions(+), 9 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java index 8f666a2..93246b8 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/config/timer/DefaultScheduled.java @@ -1,12 +1,15 @@ package com.ltkj.web.config.timer; import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.ltkj.framework.datasource.DynamicDataSourceContextHolder; import com.ltkj.hosp.domain.TjJcycxm; +import com.ltkj.hosp.domain.TjXdtgmdjg; import com.ltkj.hosp.mapper.TestMapper; import com.ltkj.hosp.service.*; import com.ltkj.hosp.sqlDomain.*; import com.ltkj.system.service.ISysConfigService; +import com.ltkj.web.controller.system.TjXdPictureController; import jodd.util.StringUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -59,6 +62,10 @@ private TjJcycxmService jcycxmService; @Autowired private AwsService awsService; + @Resource + private TjXdtgmdjgService xdtgmdjgService; + @Resource + private TjXdPictureController pictureController; private final ReentrantLock reentrantLock = new ReentrantLock(); @@ -89,6 +96,7 @@ String dsqkssj = configService.selectConfigByKey("dsqkssj"); String dsqjssj = configService.selectConfigByKey("dsqjssj"); String yqbm = configService.selectConfigByKey("common_api_service_hospbm"); + String dqyyyqbm = configService.selectConfigByKey("dqyyyqbm"); boolean panduandangqianshijian = panduandangqianshijian(dsqkssj, dsqjssj); log.info("瀹氭椂鍣ㄨ嚜鍔ㄥ悓姝ユ楠屾鏌ョ粨鏋�"); log.info("褰撳墠鏃堕棿鏄惁鍦� " + dsqkssj + " 鐐瑰埌 " + dsqjssj + " 鐐逛箣闂�: " + panduandangqianshijian); @@ -109,7 +117,7 @@ if (null != jy && !jy.isEmpty()) { log.info("鍚屾妫�楠屼汉鍛� 鎵ц鏁伴噺->{}", jy.size()); for (String s : jy) { - extractedjianyan(s); + extractedjianyan(s,dqyyyqbm); } } @@ -117,7 +125,15 @@ if (null != jc && !jc.isEmpty()) { log.info("鍚屾妫�鏌ヤ汉鍛� 鎵ц鏁伴噺->{}", jc.size()); for (String s : jc) { - extractedjiancha(s); + extractedjiancha(s,dqyyyqbm); +// LambdaQueryWrapper<TjXdtgmdjg> wq=new LambdaQueryWrapper<>(); +// wq.eq(TjXdtgmdjg::getTjh,s); +// List<TjXdtgmdjg> list = xdtgmdjgService.list(wq); +// if(null !=list && !list.isEmpty()){ +// for (TjXdtgmdjg xdtgmdjg : list) { +// pictureController.saveTjXdtgmdjgByJcbgd(xdtgmdjg); +// } +// } } } Map<String, Object> map = new HashMap<>(); @@ -188,7 +204,7 @@ return time.isAfter(LocalTime.of(Integer.parseInt(kssj), 0)) && time.isBefore(LocalTime.of(Integer.parseInt(jssj), 0)); } - private void extractedjianyan(String s) { + private void extractedjianyan(String s,String dqyyyqbm) { try { List<Aws> awsList = testMapper.getWsxmLtkjHysqdByLisViBySLAVEWS(s); if(null !=awsList && !awsList.isEmpty()){ @@ -198,9 +214,22 @@ awsService.saveBatch(awsList); log.info("淇濆瓨澶栭�侀」鐩垚鍔�"); } - List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s); List<LtkjHysqd> wssq = testMapper.getWsxmLtkjHysqdByLisVi(s); - if(null !=wssq && !wssq.isEmpty())hysqdList.addAll(wssq); + if(null !=wssq && !wssq.isEmpty()){ + for (LtkjHysqd hysqd : wssq) { + 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.getWsxmLtkjHybgdByLisVi(s); + ltkjHybgdService.saveBatch(wsbg); + } + } + } + + List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(s,dqyyyqbm); if (null != hysqdList && !hysqdList.isEmpty()) { for (LtkjHysqd hysqd : hysqdList) { LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(), hysqd.getTmh()); @@ -210,8 +239,8 @@ } if (ltkjHysqdService.save(hysqd)) { List<LtkjHybgd> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh()); - List<LtkjHybgd> wsbg = testMapper.getWsxmLtkjHybgdByLisVi(s); - if(null !=wsbg && !wsbg.isEmpty())hybgdList.addAll(wsbg); +// List<LtkjHybgd> wsbg = testMapper.getWsxmLtkjHybgdByLisVi(s); +// if(null !=wsbg && !wsbg.isEmpty())hybgdList.addAll(wsbg); ltkjHybgdService.saveBatch(hybgdList); } } @@ -226,10 +255,10 @@ } - private void extractedjiancha(String s) { + private void extractedjiancha(String s,String dqyyyqbm) { try { - List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s); + List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(s,dqyyyqbm); if (null != jcsqdList && !jcsqdList.isEmpty()) { DynamicDataSourceContextHolder.clearDataSourceType(); jcsqdService.deletedLtkjJcsqdByTjhAndTmh(s); -- Gitblit v1.8.0