From 349479e5d638d46a90014e9a26f05e948f55f106 Mon Sep 17 00:00:00 2001
From: lige <bestlige@outlook.com>
Date: 星期三, 13 十二月 2023 19:56:38 +0800
Subject: [PATCH] json
---
ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java | 195 +++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 166 insertions(+), 29 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 fe9db4e..4173982 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
@@ -1,22 +1,35 @@
package com.ltkj.web.controller.sqlserver;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.datasource.DynamicDataSourceContextHolder;
-import com.ltkj.hosp.service.LtkjMiddleDetailService;
-import com.ltkj.hosp.service.LtkjMiddleHeadService;
-import com.ltkj.hosp.service.TjvLtkjvtjpatService;
-import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
-import com.ltkj.hosp.sqlDomain.LtkjMiddleHead;
-import com.ltkj.hosp.sqlDomain.LtkjTjPat;
+import com.ltkj.hosp.domain.TjOrder;
+import com.ltkj.hosp.domain.TjOrderRemark;
+import com.ltkj.hosp.service.*;
+import com.ltkj.hosp.sqlDomain.*;
import com.ltkj.hosp.mapper.TestMapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.ConvertingCursor;
+import org.springframework.data.redis.core.Cursor;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
+import java.util.Map;
+
+import static com.ltkj.framework.datasource.DynamicDataSourceContextHolder.log;
+import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.save;
@RestController
@@ -34,20 +47,79 @@
@Resource
private LtkjMiddleHeadService headService;
+ @Resource
+ private LtkjExamJcbgdService ltkjExamJcbgdService;
+ @Resource
+ private LtkjExamJcsqdService ltkjExamJcsqdService;
+ @Resource
+ private LtkjHybgdService ltkjHybgdService;
+ @Resource
+ private LtkjHysqdService ltkjHysqdService;
+ @Autowired
+ public RedisTemplate<Object,Object> redisTemplate;
+ @Resource
+ private RedisCache redisCache;
+ @Resource
+ private TjAsyncService asyncService;
+ @Resource
+ private ITjOrderRemarkService remarkService;
+ @Resource
+ private ITjOrderService orderService;
+ @GetMapping("/getRedisValue")
+ @ApiOperation(value = "娴嬭瘯redis妯＄硦鏌ヨ")
+ public AjaxResult getRedisValue() {
+// long start = System.currentTimeMillis();
+// //闇�瑕佸尮閰嶇殑key
+// ScanOptions options = ScanOptions.scanOptions()
+// //杩欓噷鎸囧畾姣忔鎵弿key鐨勬暟閲�(寰堝鍗氬鐬庤瑕佹寚瀹欼nteger.MAX_VALUE锛岃繖鏍风殑璇濊窡 keys鏈変粈涔堝尯鍒紵)
+// .count(10000)
+// .match(aa+"*").build();
+// RedisSerializer<String> redisSerializer = (RedisSerializer<String>) redisTemplate.getKeySerializer();
+// Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+// List<Object> result = new ArrayList<>();
+// while(cursor.hasNext()){
+// String s = cursor.next().toString();
+// redisCache.deleteObject(s);
+// }
+// //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+// cursor.close();
+//// System.out.println(result);
+// log.info("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start,result.size());
+// Map<String,Object>map=new HashMap<>();
+// map.put("result",result);
+// map.put("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start+result.size());
+ List<TjOrderRemark> list = remarkService.list(new LambdaQueryWrapper<TjOrderRemark>().ne(TjOrderRemark::getType,2).groupBy(TjOrderRemark::getTjNumber));
+ for (TjOrderRemark remark : list) {
+ TjOrder orderByTjNum = orderService.getOrderByTjNum(remark.getTjNumber());
+ if(null !=orderByTjNum){
+ asyncService.dockerSetWjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());
+ asyncService.dockerSetYjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());
+ }
+ }
+ return AjaxResult.success();
+ }
@GetMapping("/getMiddleDetail")
- @ApiOperation(value = "鏌ョ湅鍒楄〃")
public AjaxResult getMiddleDetail() {
List<LtkjMiddleDetail> list = testMapper.getMiddleDetail();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjMiddleDetail ltkjMiddleDetail : list) {
+ final boolean save = middleDetailService.save(ltkjMiddleDetail);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
return AjaxResult.success(list);
}
@GetMapping("/getMiddleHead")
- @ApiOperation(value = "鏌ョ湅鍒楄〃")
public AjaxResult getMiddleHead() {
List<LtkjMiddleHead> list = testMapper.getMiddleHead();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjMiddleHead ltkjMiddleHead : list) {
+ final boolean save = headService.save(ltkjMiddleHead);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
return AjaxResult.success(list);
}
@@ -60,43 +132,108 @@
@GetMapping("/getTjPat")
- @ApiOperation(value = "鏌ョ湅鍒楄〃")
public AjaxResult getTjPat() {
List<LtkjTjPat> list = testMapper.getTjPat();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjTjPat ltkjTjPat : list) {
+ final boolean save = tjvLtkjvtjpatService.save(ltkjTjPat);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ return AjaxResult.success(list);
+ }
+
+ @GetMapping("/getExamJcbgd")
+ public AjaxResult getExamJcbgd() {
+ List<LtkjExamJcbgd> list = testMapper.getExamJcbgd();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjExamJcbgd ltkjExamJcbgd : list) {
+ final boolean save = ltkjExamJcbgdService.save(ltkjExamJcbgd);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ return AjaxResult.success(list);
+ }
+
+ @GetMapping("/getExamJcsqd")
+ public AjaxResult getExamJcsqd() {
+ List<LtkjExamJcsqd> list = testMapper.getExamJcsqd();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjExamJcsqd ltkjExamJcsqd : list) {
+ final boolean save = ltkjExamJcsqdService.save(ltkjExamJcsqd);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ return AjaxResult.success(list);
+ }
+
+ @GetMapping("/getHybgd")
+ public AjaxResult getHybgd() {
+ List<LtkjHybgd> list = testMapper.getHybgd();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjHybgd ltkjHybgd : list) {
+ final boolean save = ltkjHybgdService.save(ltkjHybgd);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ return AjaxResult.success(list);
+ }
+
+ @GetMapping("/getHysqd")
+ public AjaxResult getHysqd() {
+ List<LtkjHysqd> list = testMapper.getHysqd();
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ for (LtkjHysqd ltkjHysqd : list) {
+ final boolean save = ltkjHysqdService.save(ltkjHysqd);
+ }
+ DynamicDataSourceContextHolder.clearDataSourceType();
return AjaxResult.success(list);
}
- @GetMapping("/getLtkjTjPatById")
- @ApiOperation(value = "鏍规嵁id鏌�,瀛樿繘mysql")
- public AjaxResult getLtkjTjPatById(String id) {
- LtkjTjPat one = testMapper.getTjPatById(id);
+
+ @GetMapping("/getTjPatByCusId")
+ public AjaxResult getTjPatByCusId(String cusId) {
+ testMapper.getTjPatByCusId(cusId);
+ return AjaxResult.success();
+ }
+
+
+ @GetMapping("/saveMiddleHeadByPatId")
+ public AjaxResult saveMiddleHeadByPatId(String id) {
+ List<LtkjMiddleHead> one = testMapper.saveMiddleHeadByPatId(id);
DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
- final boolean save = tjvLtkjvtjpatService.save(one);
+ for (LtkjMiddleHead ltkjMiddleHead : one) {
+ final boolean save = headService.save(ltkjMiddleHead);
+ }
DynamicDataSourceContextHolder.clearDataSourceType();
return AjaxResult.success(save);
}
- @GetMapping("/getMiddleDetailById")
- @ApiOperation(value = "鏍规嵁id鏌�,瀛樿繘mysql")
- public AjaxResult getMiddleDetailById(String id) {
- LtkjMiddleDetail one = testMapper.getMiddleDetailById(id);
+ @GetMapping("/getMiddleDetailByHeadId")
+ public AjaxResult getMiddleDetailByHeadId(String id) {
+ List<LtkjMiddleDetail> one = testMapper.getMiddleDetailByHeadId(id);
+ for (LtkjMiddleDetail ltkjMiddleDetail : one) {
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ final boolean save = middleDetailService.save(ltkjMiddleDetail);
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ }
+ return AjaxResult.success(one);
+ }
+
+ @GetMapping("/test")
+ public AjaxResult getHysqdByTmh(String id) {
+ List<LtkjHysqd> one = testMapper.getHysqdByTmh(id);
DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
- final boolean save = middleDetailService.save(one);
+ ltkjHysqdService.saveBatch(one);
DynamicDataSourceContextHolder.clearDataSourceType();
- return AjaxResult.success(save);
+ for (LtkjHysqd ltkjHysqd : one) {
+ List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh());
+ DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
+ ltkjHybgdService.saveBatch(one1);
+ DynamicDataSourceContextHolder.clearDataSourceType();
+ }
+
+ return AjaxResult.success();
}
- @GetMapping("/getMiddleHeadById")
- @ApiOperation(value = "鏍规嵁id鏌�,瀛樿繘mysql")
- public AjaxResult getMiddleHeadById(String id) {
- LtkjMiddleHead one = testMapper.getMiddleHeadById(id);
- DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
- final boolean save = headService.save(one);
- DynamicDataSourceContextHolder.clearDataSourceType();
- return AjaxResult.success(save);
- }
}
--
Gitblit v1.8.0