From da583ad2beefb9887dca12a7574ea2d0b853fc9a Mon Sep 17 00:00:00 2001 From: zjh <zjh@888> Date: 星期一, 17 六月 2024 12:39:50 +0800 Subject: [PATCH] zjh 本地 2024/06/17 --1 --- ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java | 198 ++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 184 insertions(+), 14 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java index 4031f4c..f563a38 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java @@ -3,20 +3,21 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; +import com.ltkj.common.annotation.RepeatSubmit; import com.ltkj.common.core.controller.BaseController; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.common.core.redis.RedisCache; import com.ltkj.common.enums.DataSourceType; +import com.ltkj.framework.config.UserHoder; import com.ltkj.framework.datasource.DynamicDataSourceContextHolder; -import com.ltkj.hosp.domain.TjCustomer; -import com.ltkj.hosp.domain.TjOrder; -import com.ltkj.hosp.domain.TjOrderRemark; +import com.ltkj.hosp.domain.*; import com.ltkj.hosp.service.*; import com.ltkj.hosp.sqlDomain.*; import com.ltkj.hosp.mapper.TestMapper; import com.ltkj.system.service.ISysDeptService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.ConvertingCursor; @@ -27,12 +28,12 @@ import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpSession; import java.sql.ResultSet; import java.sql.SQLException; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; +import java.util.stream.Collectors; import static com.ltkj.framework.datasource.DynamicDataSourceContextHolder.log; import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.save; @@ -40,7 +41,7 @@ @RestController @RequestMapping("/sqlserver/getdata") -@Api(tags = "鑾峰彇浠庡簱鏁版嵁") +@Api(tags = "AAAAAAAAAAA鑾峰彇浠庡簱鏁版嵁") public class TjSqlController extends BaseController { @Resource private TestMapper testMapper; @@ -75,6 +76,46 @@ private ITjOrderService orderService; @Resource private ISysDeptService deptService; + @Resource + private LtkjHisUserService hisUserService; + @Resource + private ITjProjectService tjProjectService; + @Autowired + private ITjOrderDetailService tjOrderDetailService; + @Resource + private ITjOrderRemarkService tjOrderRemarkService; + + + @GetMapping("/getTjHyBgList") + @ApiOperation(value = "鏌ヨlis鏁版嵁搴撻」鐩俊鎭帴鍙�") + public AjaxResult getTjHyBgList(@RequestParam(required = false)String pacCode, + @RequestParam(required = false)String pacName, + @RequestParam(required = false)String pacRemark) { + List<Map<String, Object>> maps = testMapper.getTjHyBgList(pacCode,pacName,pacRemark); + DynamicDataSourceContextHolder.clearDataSourceType(); + return AjaxResult.success(maps); + } + + + @GetMapping("/newGetTjPat") + @ApiOperation(value = "A------鏂扮殑鏌ヨ浣撴淇℃伅鎺ュ彛") + public AjaxResult newGetTjPat(@RequestParam(required = false)String pacCode, + @RequestParam(required = false)String pacName, + @RequestParam(required = false)String pacRemark) { + List<Map<String, Object>> maps = testMapper.newGetTjPat(pacCode,pacName,pacRemark); + DynamicDataSourceContextHolder.clearDataSourceType(); + List<String> strings = orderService.selectTjOrderByCardId1(); + if(null !=strings && strings.size()>0){ + List<Map<String, Object>> collect = maps.stream() + .filter(item -> !strings.contains(item.get("pacCode").toString())).collect(Collectors.toList()); + return AjaxResult.success(collect); + } + return AjaxResult.success(maps); + } + + + + @GetMapping("/getRedisValue") @ApiOperation(value = "娴嬭瘯redis妯$硦鏌ヨ") public AjaxResult getRedisValue(@RequestParam int aa, @@ -129,6 +170,7 @@ @GetMapping("/getMiddleDetail") + @ApiOperation(value = "鏌ヨ鏀惰垂椤圭洰璇︽儏") public AjaxResult getMiddleDetail() { List<LtkjMiddleDetail> list = testMapper.getMiddleDetail(); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); @@ -141,6 +183,7 @@ @GetMapping("/getMiddleHead") + @ApiOperation(value = "鏌ヨ鏀惰垂淇℃伅") public AjaxResult getMiddleHead() { List<LtkjMiddleHead> list = testMapper.getMiddleHead(); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); @@ -151,12 +194,28 @@ return AjaxResult.success(list); } -// @GetMapping("/getVbjitem") -// @ApiOperation(value = "鏌ョ湅鍒楄〃") -// public AjaxResult getVbjitem() { -// List<LtkjVbjitem> list = testMapper.getVbjitem(); -// return AjaxResult.success(list); -// } + @GetMapping("/getMiddleHeadByPartId") + @ApiOperation(value = "鏍规嵁韬唤璇佸彿鏌ヨ鏀惰垂淇℃伅") + public AjaxResult getMiddleHeadByPartId(@RequestParam String partId) { + TjCustomer customer = tjCustomerService.getTjCustomerByCusIdCard(partId); + LtkjMiddleHead pat = testMapper.getMiddleHeadByPartId(customer.getCardId()); + if (null != pat) { + List<LtkjMiddleDetail> list = testMapper.getMiddleDetailByFeadId(pat.getFeadId()); + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + LtkjMiddleHead o = headService.getMiddleHeadByPartId(customer.getCardId()); + if(o==null){ + headService.save(pat); + for (LtkjMiddleDetail ltkjMiddleDetail : list) { + middleDetailService.save(ltkjMiddleDetail); + } + testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard()); + } + testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard()); + } + DynamicDataSourceContextHolder.clearDataSourceType(); + return AjaxResult.success(); + } + @GetMapping("/getTjPat") @@ -289,5 +348,116 @@ } + @GetMapping("/getLtkjHisUser") + @ApiOperation(value = "鍚屾his鐢ㄦ埛") + public AjaxResult getLtkjHisUser() { + List<LtkjHisUser> list = testMapper.getLtkjHisUser(); + if(null !=list && list.size()>0){ + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + for (LtkjHisUser user : list) { + LtkjHisUser hisUser= hisUserService.getHisUserByHisGh(user.getHisgh()); + if(null == hisUser){ + hisUserService.save(user); + } + } + DynamicDataSourceContextHolder.clearDataSourceType(); + } + return AjaxResult.success(); + } + + + + + @GetMapping("/dataSynchronization") + @ApiOperation(value = "鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛") + @RepeatSubmit + public AjaxResult dataSynchronization(@RequestParam String tjNumber) { + //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12 +// final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); +// if ("Y".equals(getInfoFromSqlData)) { + TjOrder order = orderService.getOrderByTjNum(tjNumber); + if (null != order) { + List<LtkjHysqd> one = testMapper.getHysqdByTmh(order.getCardId()); + if (one != null && one.size() > 0) { + for (LtkjHysqd ltkjHysqd : one) { +// DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + LtkjHysqd hysqd = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(ltkjHysqd.getTjh(), ltkjHysqd.getTmh()); + if(hysqd==null){ + ltkjHysqdService.save(ltkjHysqd); + DynamicDataSourceContextHolder.clearDataSourceType(); + List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh()); + if (one1 != null && one1.size() > 0) { + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + ltkjHybgdService.saveBatch(one1); + DynamicDataSourceContextHolder.clearDataSourceType(); + } + } + } + } + +// List<LtkjExamJcsqd> one2 = testMapper.getExamJcsqdTmh(tjNumber); +// if (one2 != null && one2.size() > 0) { +// DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); +// ltkjExamJcsqdService.saveBatch(one2); +// DynamicDataSourceContextHolder.clearDataSourceType(); +// for (LtkjExamJcsqd ltkjExamJcsqd : one2) { +// List<LtkjExamJcbgd> one3 = testMapper.getExamJcbgdByTjh(ltkjExamJcsqd.getTmh()); +// if (one3 != null && one3.size() > 0) { +// DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); +// ltkjExamJcbgdService.saveBatch(one3); +// DynamicDataSourceContextHolder.clearDataSourceType(); +// } +// } +// } + //鍚屾鍖栭獙椤圭洰 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(), "1"); + //鍚屾妫�鏌ラ」鐩� + testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(),"1"); + } +// } + return AjaxResult.success("鍚屾鎴愬姛"); + } + + + + @GetMapping("/getTjYxjcList") + @ApiOperation(value = "鏌ヨ褰卞搷妫�鏌ラ」鐩�") + public AjaxResult getTjYxjcList() { + List<Map<String, Object>> tjYxjcList = testMapper.getTjYxjcList("鏉ㄤ簯浜�",null,null); + return AjaxResult.success(tjYxjcList); + } + + + + @GetMapping("/getPacTjProjectList") + @ApiOperation(value = "缁存姢濂楅椤甸潰鏂板椤圭洰鏃惰皟鐢�") + public AjaxResult getPacTjProjectList() { +// LambdaQueryWrapper<TjProject> wq = new LambdaQueryWrapper<>(); +// wq.eq(TjProject::getProParentId, 0); +// wq.eq(TjProject::getProStatus, 0); + List<TjProject> tjProjects = tjProjectService.getPacTjProjectList(); +// if (tjProjects != null) { +// for (TjProject project : tjProjects) { +// List<TjProject> projectList = tjProjectService.getTjProjectListBySoneId(String.valueOf(project.getProId())); +// project.setTjProjectList(projectList); +// } +// return AjaxResult.success(tjProjects); +// } + return AjaxResult.success(tjProjects); + } + + + @GetMapping("/getHuaYanProByTjNum") + @ApiOperation(value = "鏍规嵁浣撴鍙锋煡璇㈠寲楠岄」鐩帴鍙�") + public AjaxResult getHuaYanProByTjNum(@RequestParam @ApiParam(value = "浣撴鍙�") String tjNumber) { + Map<String,Object> map=new HashMap<>(); + + List<TjOrderDetail> tjOrderDetails = tjOrderDetailService.addHuaYanTable(tjNumber); + List<TjOrderRemark> tjOrderRemarks = tjOrderRemarkService.addHuaYanTable(tjNumber); + map.put("tjOrderDetails",tjOrderDetails); + map.put("tjOrderRemarks",tjOrderRemarks); + return AjaxResult.success(map); + } + } -- Gitblit v1.8.0