From 148a7f11b0ead8539cae824f02dda19a703f4d0b Mon Sep 17 00:00:00 2001 From: zjh <1084500556@qq.com> Date: 星期六, 07 十二月 2024 16:54:02 +0800 Subject: [PATCH] zjh20241207 --- ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java | 1077 ++++++++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 910 insertions(+), 167 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java index bb4c122..a8615bd 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java @@ -1,11 +1,14 @@ package com.ltkj.web.controller.system; +import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ltkj.common.annotation.RepeatSubmit; @@ -28,21 +31,29 @@ import com.ltkj.system.service.ISysConfigService; import com.ltkj.system.service.ISysDeptService; import com.ltkj.system.service.ISysUserService; +import com.ltkj.web.controller.his.HisApiGetMethodService; import com.ltkj.web.controller.his.HisApiMethodService; +import com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; +import lombok.extern.slf4j.Slf4j; import lombok.var; import org.aspectj.weaver.AjAttribute; +import org.redisson.api.RLock; +import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; +import java.math.BigDecimal; import java.util.*; +import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; +import static com.ltkj.framework.datasource.DynamicDataSourceContextHolder.log; import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.save; import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.setClipRect; @@ -51,8 +62,9 @@ * @Date: 2022/12/6 14:29 */ @RestController -@RequestMapping("/check") -@Api(tags = "鎬绘鍖诲笀鐩稿叧鎺ュ彛") +@RequestMapping ("/check") +@Api (tags = "AAAAAAAAAAAA鎬绘鍖诲笀鐩稿叧鎺ュ彛") +@Slf4j public class TjCheckController { @Resource private ITjOrderService orderService; @@ -93,21 +105,32 @@ @Resource private LtkjMiddleHeadService headService; @Resource - private LtkjExamJcbgdService ltkjExamJcbgdService; + private LtkjExamJcbgdService jcbgdService; @Resource - private LtkjExamJcsqdService ltkjExamJcsqdService; + private LtkjExamJcsqdService jcsqdService; @Resource private LtkjHybgdService ltkjHybgdService; @Resource private LtkjHysqdService ltkjHysqdService; @Autowired private HisApiMethodService controller; + @Autowired + private HisApiGetMethodService service; + @Autowired + private HisApiConfigService hisApiConfigService; + @Autowired + private RedissonClient redissonClient; +// public void csdsrw() throws InterruptedException { +// log.info("瀹氭椂浠诲姟寮�濮嬫墽琛�"+new Date()); +// Thread.sleep(1000*5); +// log.info("瀹氭椂浠诲姟缁撴潫鎵ц"+new Date()); +// } - @GetMapping("/getOperationPermissionsByTjNum") - @ApiOperation(value = "(鍒濆椤甸潰 鍜� 鍖荤敓椤甸潰)鏍规嵁浣撴鍙疯幏鍙栨槸鍚﹀彲鎿嶄綔鏉冮檺鎺ュ彛 true鍙搷浣� 鍙嶄箣涓嶅彲") - public AjaxResult getOperationPermissionsByTjNum(@ApiParam(value = "浣撴鍙�") @RequestParam String tjNumber) { + @GetMapping ("/getOperationPermissionsByTjNum") + @ApiOperation (value = "(鍒濆椤甸潰 鍜� 鍖荤敓椤甸潰)鏍规嵁浣撴鍙疯幏鍙栨槸鍚﹀彲鎿嶄綔鏉冮檺鎺ュ彛 true鍙搷浣� 鍙嶄箣涓嶅彲") + public AjaxResult getOperationPermissionsByTjNum(@ApiParam (value = "浣撴鍙�") @RequestParam String tjNumber) { TjOrder order = orderService.getOrderByTjNum(tjNumber); if (null != order) { Integer status = order.getStatus(); @@ -122,17 +145,46 @@ } - @GetMapping("/getCsList") - @ApiOperation(value = "鍒濆鏌ヨ浣撴璁板綍瀹㈡埛鍒楄〃")//0寰�1宸� + + @GetMapping ("/ceshi") + @ApiOperation (value = "娴嬭瘯璋冪敤lis瑙嗗浘鏁版嵁鎺ュ彛") + @RepeatSubmit +// @Transactional + public AjaxResult ceshi() { + List<Map<String, Object>> ccXZxYyLisJgSt = testMapper.getCcXZxYyLisJgSt(); + return AjaxResult.success(ccXZxYyLisJgSt); + } + + + @GetMapping ("/pacs") + @ApiOperation (value = "娴嬭瘯璋冪敤pacs瑙嗗浘鏁版嵁鎺ュ彛") + @RepeatSubmit + public AjaxResult pacs() { + List<Map<String, Object>> ccXZxYyPacsJgSt = testMapper.getCcXZxYyPacsJgSt(); + + List<LtkjExamJcsqd> list = testMapper.getCcXZxYyPacsLtkjExamJcsqd(""); + + log.info(list.toString()); + + List<LtkjExamJcbgd> list1 = testMapper.getCcXZxYyPacsLtkjExamJcbgd(""); + + log.info(list1.toString()); + + return AjaxResult.success(ccXZxYyPacsJgSt); + } + + + @GetMapping ("/getCsList") + @ApiOperation (value = "鍒濆鏌ヨ浣撴璁板綍瀹㈡埛鍒楄〃")//0寰�1宸� @Transactional - public AjaxResult getCsList(@ApiParam(value = "瀹℃牳鐘舵�� 0寰呭鏍� 1宸插鏍�") @RequestParam(required = false) Integer checkStatus, - @ApiParam(value = "椤电爜鏁�(榛樿1)") @RequestParam(defaultValue = "1") Integer page, - @ApiParam(value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam(defaultValue = "10") Integer pageSize, - @ApiParam(value = "浣撴鍗曞彿") @RequestParam(required = false) String tjNumber, - @ApiParam(value = "鍗曚綅") @RequestParam(required = false) Long compId, - @ApiParam(value = "濮撳悕)") @RequestParam(required = false) String name, - @ApiParam(value = "寮�濮嬫椂闂�") @RequestParam(required = false) String beginTime, - @ApiParam(value = "缁撴潫鏃堕棿") @RequestParam(required = false) String endTime) { + public AjaxResult getCsList(@ApiParam (value = "瀹℃牳鐘舵�� 0寰呭鏍� 1宸插鏍�") @RequestParam (required = false) Integer checkStatus, + @ApiParam (value = "椤电爜鏁�(榛樿1)") @RequestParam (defaultValue = "1") Integer page, + @ApiParam (value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam (defaultValue = "10") Integer pageSize, + @ApiParam (value = "浣撴鍗曞彿") @RequestParam (required = false) String tjNumber, + @ApiParam (value = "鍗曚綅") @RequestParam (required = false) Long compId, + @ApiParam (value = "濮撳悕)") @RequestParam (required = false) String name, + @ApiParam (value = "寮�濮嬫椂闂�") @RequestParam (required = false) String beginTime, + @ApiParam (value = "缁撴潫鏃堕棿") @RequestParam (required = false) String endTime) { // DateTime beginTimes = null; // DateTime endTimes = null; @@ -223,9 +275,9 @@ /** * 鍒濆 */ - @GetMapping("/cSWebGetProByTjNumAndOrderId") - @ApiOperation(value = "(鍒濆椤甸潰)鐐瑰嚮浣撴浜哄憳灞曠ず浣撴椤圭洰鎺ュ彛") - public AjaxResult cSWebGetProByTjNumAndOrderId(@ApiParam(value = "浣撴鍙�") @RequestParam String tjNumber) { + @GetMapping ("/cSWebGetProByTjNumAndOrderId") + @ApiOperation (value = "(鍒濆椤甸潰)鐐瑰嚮浣撴浜哄憳灞曠ず浣撴椤圭洰鎺ュ彛") + public AjaxResult cSWebGetProByTjNumAndOrderId(@ApiParam (value = "浣撴鍙�") @RequestParam String tjNumber) { // List<TjOrderRemark> orderRemarkList = orderRemarkService.getTjOrderRemarkListByTjNum(tjNumber); // List<CsProVo> list = new ArrayList<>(); // if (null != orderRemarkList && orderRemarkList.size() > 0) { @@ -254,7 +306,12 @@ // }); // } - List<CsProVo> list = orderRemarkService.cSWebGetProByTjNumAndOrderId(tjNumber); + List<CsProVo> list = getCsProVos(tjNumber,false); + return AjaxResult.success(list); + } + + public List<CsProVo> getCsProVos(String tjNumber,boolean sfzpacs) { + List<CsProVo> list = orderRemarkService.cSWebGetProByTjNumAndOrderId(tjNumber,sfzpacs); if (null != list && list.size() > 0) { list.sort(new Comparator<CsProVo>() { @Override @@ -263,19 +320,19 @@ } }); } - return AjaxResult.success(list); + return list; } /** * 鍒濆 */ - @GetMapping("/confirmOrder") - @ApiOperation(value = "鍒濆(骞朵慨鏀圭姸鎬�)鎺ュ彛") + @GetMapping ("/confirmOrder") + @ApiOperation (value = "鍒濆(骞朵慨鏀圭姸鎬�)鎺ュ彛") @Transactional - public AjaxResult confirmOrder(@ApiParam(value = "tjNumber") @RequestParam String tjNumber, - @ApiParam(value = "鐘舵�� 0鍚屾剰 1鎷掔粷 榛樿鍚屾剰") @RequestParam(defaultValue = "0") Integer status, - @ApiParam(value = "椹冲洖鐞嗙敱") @RequestParam(required = false) String remark) { + public AjaxResult confirmOrder(@ApiParam (value = "tjNumber") @RequestParam String tjNumber, + @ApiParam (value = "鐘舵�� 0鍚屾剰 1鎷掔粷 榛樿鍚屾剰") @RequestParam (defaultValue = "0") Integer status, + @ApiParam (value = "椹冲洖鐞嗙敱") @RequestParam (required = false) String remark) { int num = orderRemarkService.getTjYqOrderRemarkByTjNum(tjNumber); if (num > 0) return AjaxResult.error("璇锋鏌ユ槸鍚﹀瓨鍦ㄦ湭妫�鎴栧欢鏈熼」鐩�"); if (null != tjNumber) { @@ -288,7 +345,7 @@ tjOrder.setConfirmStatus(String.valueOf(status)); if (status == 0) { tjOrder.setStatus(TjConstants.TJ_CHECK); - asyncService.updateCheckType(tjNumber); +// asyncService.updateCheckType(tjNumber); } else { tjOrder.setStatus(TjConstants.TJ_REFUSED); } @@ -298,8 +355,8 @@ confirmLog.setTjNum(tjNumber); confirmLog.setStatus(status); confirmLogService.save(confirmLog); - asyncService.wCScheckSetCustomerLisByRedis(orderService.getCsTjOrderList(tjNumber, 0, null, null, null)); - asyncService.yCScheckSetCustomerLisByRedis(orderService.getCsTjOrderList(tjNumber, 1, null, null, null)); +// asyncService.wCScheckSetCustomerLisByRedis(orderService.getCsTjOrderList(tjNumber, 0, null, null, null)); +// asyncService.yCScheckSetCustomerLisByRedis(orderService.getCsTjOrderList(tjNumber, 1, null, null, null)); return AjaxResult.success("鎿嶄綔鎴愬姛"); } return AjaxResult.error("鎿嶄綔澶辫触"); @@ -313,21 +370,28 @@ /** * 鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛 */ - @GetMapping("/dataSynchronization") - @ApiOperation(value = "鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛") + @GetMapping ("/dataSynchronization") + @ApiOperation (value = "鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛") @RepeatSubmit +// @Transactional public AjaxResult dataSynchronization(@RequestParam String tjNumber) { - //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12 - final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); - final String sfkqdyhis = configService.selectConfigByKey("sfkqdyhis"); - TjOrder order = orderService.getOrderByTjNum(tjNumber); - if(null !=order){ + RLock lock = redissonClient.getLock("lock:check:dataSynchronization:" + tjNumber); + try { + boolean tryLock = lock.tryLock(3L, TimeUnit.SECONDS); + if (tryLock){ + //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12 + final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); - //寮�鍚瓧鍏稿脊绐� - if ("Y".equals(getInfoFromSqlData)) { - tbhyxm(order); - // List<LtkjExamJcsqd> one2 = testMapper.getExamJcsqdTmh(tjNumber); + final String sfkqdyhis = configService.selectConfigByKey("sfkqdyhis"); + final String sfkqdshitulianjie = configService.selectConfigByKey("sfkqdshitulianjie"); + TjOrder order = orderService.getOrderByTjNum(tjNumber); + if (null != order) { + + //寮�鍚瓧鍏稿脊绐� + if ("Y".equals(getInfoFromSqlData)) { + tbhyxm(order); + // List<LtkjExamJcsqd> one2 = testMapper.getExamJcsqdTmh(tjNumber); // if (one2 != null && one2.size() > 0) { // DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); // ltkjExamJcsqdService.saveBatch(one2); @@ -341,101 +405,522 @@ // } // } // } - //鍚屾鍖栭獙椤圭洰 - testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); - //鍚屾妫�鏌ラ」鐩� - testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); - asyncService.updateCheckType(order.getTjNumber()); + //鍚屾鍖栭獙椤圭洰 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); + //鍚屾妫�鏌ラ」鐩� + testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); + asyncService.updateCheckType(order.getTjNumber()); - } - - //寮�鍚拰his瀵规帴 - if(null !=sfkqdyhis && sfkqdyhis.equals("Y")){ - - String baoGaoDan = ltkjHybgdService.getJianYanBaoGaoDan(order.getCardId()); - if(null !=baoGaoDan){ - Date dates = new Date(); - Map<String,Object> map=new HashMap<>(); - map.put("his_registration_id",order.getCardId()); - map.put("ksbm",""); - map.put("pationid",""); - map.put("ksrq",DateUtil.format(DateUtil.beginOfDay(dates), "yyyy-MM-dd HH:mm:ss")); - map.put("jsrq",DateUtil.format(DateUtil.endOfDay(dates), "yyyy-MM-dd HH:mm:ss")); - map.put("pagecount",10); - map.put("page",1); - AjaxResult result = controller.Getlabreportinfo(map); - String result1 = getAjaxResult(result); - JSONObject object = getJSONObject(result1); - String code = object.getStr("ResultCode"); - if(null ==code || !code.equals("0")){ - return AjaxResult.error("鍖栭獙椤圭洰鏆傛椂鏃犵粨鏋�,璇风◢鍚庡悓姝�!!!"); - } - JSONArray data = object.getJSONArray("ResultData"); - for (Object datum : data) { - JSONObject jsonObject = (JSONObject)datum; - LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(order.getCardId(), jsonObject.getStr("JYBGID")); - if(null !=jybgid){ - continue; } - LtkjHysqd hysqd=new LtkjHysqd(); - hysqd.setTjh(order.getCardId()); - hysqd.setTmh(jsonObject.getStr("JYBGID")); - hysqd.setBbbh(jsonObject.getStr("BBDM")); - hysqd.setBbmc(jsonObject.getStr("BBMC")); - hysqd.setXmid(jsonObject.getStr("JYXMDM")); - hysqd.setXmmc(jsonObject.getStr("JYXMMC")); - hysqd.setSqsj(jsonObject.getStr("SQRQ")); - hysqd.setSqys(jsonObject.getStr("SQRBH")); - hysqd.setJgsj(jsonObject.getStr("JYBGRQ")); - hysqd.setSqrxm(jsonObject.getStr("SQRXM")); - hysqd.setSqdh(jsonObject.getStr("SQDBH")); - if (ltkjHysqdService.save(hysqd)) { - Map<String,Object> hashMap=new HashMap<>(); - hashMap.put("jybgid",hysqd.getTmh()); - AjaxResult bgdres = controller.Getlabdetailinfo(hashMap); - String result2 = getAjaxResult(bgdres); - JSONObject object1 = getJSONObject(result2); - String code1 = object1.getStr("ResultCode"); - if(null ==code1 || !code1.equals("0")){ - return AjaxResult.error("鍖栭獙椤圭洰鏆傛椂鏃犵粨鏋�,璇风◢鍚庡悓姝�!!!"); - } - JSONArray datas = object1.getJSONArray("ResultData"); - for (Object o : datas) { - JSONObject js = (JSONObject)o; + + //寮�鍚拰his瀵规帴 + if (null != sfkqdyhis && sfkqdyhis.equals("Y")) { + + List<String> baoGaoDans = ltkjHybgdService.getJianYanBaoGaoDan(order.getCardId()); + List<String> jianChaBaoGaoDan = ltkjHybgdService.getJianChaBaoGaoDan(order.getCardId()); + //鍚屾妫�楠� + if (null != baoGaoDans && baoGaoDans.size() > 0) { + Date dates = new Date(); + Map<String, Object> map = new HashMap<>(); + map.put("his_registration_id", order.getCardId()); + map.put("ksbm", ""); + map.put("pationid", ""); + map.put("ksrq", DateUtil.format(DateUtil.beginOfDay(order.getCreateTime()), "yyyy-MM-dd HH:mm:ss")); + map.put("jsrq", DateUtil.format(DateUtil.endOfDay(dates), "yyyy-MM-dd HH:mm:ss")); + map.put("pagecount", 10); + map.put("page", 1); + AjaxResult result = controller.Getlabreportinfo(map); + String result1 = getAjaxResult(result); + JSONObject object = getJSONObject(result1); + String code = object.getStr("ResultCode"); + if (null == code || !code.equals("0")) { + return AjaxResult.error("鍖栭獙椤圭洰鏆傛椂鏈嚭缁撴灉,璇风◢鍚庡悓姝�!!!"); + } + JSONArray data = object.getJSONArray("ResultData"); + + for (Object datum : data) { + JSONObject jsonObject = (JSONObject) datum; + LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(order.getCardId(), jsonObject.getStr("JYBGID")); + if (null != jybgid) { + ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(order.getCardId(), jsonObject.getStr("JYBGID")); + ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(jybgid.getTmh()); + } + LtkjHysqd hysqd = new LtkjHysqd(); + hysqd.setTjh(order.getCardId()); + hysqd.setTmh(jsonObject.getStr("JYBGID")); + hysqd.setBbbh(jsonObject.getStr("BBDM")); + hysqd.setBbmc(jsonObject.getStr("BBMC")); + hysqd.setXmid(jsonObject.getStr("JYXMDM")); + hysqd.setXmmc(jsonObject.getStr("JYXMMC")); + hysqd.setSqsj(jsonObject.getStr("SQRQ")); + hysqd.setSqys(jsonObject.getStr("SQRBH")); + hysqd.setJgsj(jsonObject.getStr("JYBGRQ")); + hysqd.setSqrxm(jsonObject.getStr("SQRXM")); + hysqd.setSqdh(jsonObject.getStr("SQDBH")); + hysqd.setShrdm(jsonObject.getStr("JYYSBH")); + hysqd.setShrxm(jsonObject.getStr("JYYSQM")); + hysqd.setJybgjg(jsonObject.getStr("JYBGJG")); + if (ltkjHysqdService.save(hysqd)) { + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("jybgid", hysqd.getTmh()); + AjaxResult bgdres = controller.Getlabdetailinfo(hashMap); + String result2 = getAjaxResult(bgdres); + JSONObject object1 = getJSONObject(result2); + String code1 = object1.getStr("ResultCode"); + if (null != code1 && code1.equals("0")) { + JSONArray datas = object1.getJSONArray("ResultData"); + for (Object o : datas) { + JSONObject js = (JSONObject) o; // ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(jsonObject.getStr("JYBGID")); - LtkjHybgd bgd=new LtkjHybgd(); - bgd.setTmh(hysqd.getTmh()); - bgd.setJcxmid(js.getStr("JCZBDM")); - bgd.setJcxm(js.getStr("JCZBMC")); - bgd.setTdh(js.getStr("")); - bgd.setJyjg(js.getStr("JCZBJG")); - bgd.setJgdw(js.getStr("JLDW")); - bgd.setFwzdz(js.getStr("")); - bgd.setFwzgz(js.getStr("")); - bgd.setFwz(js.getStr("CKZFW")); - bgd.setJysj(js.getStr("BGRQ")); - bgd.setJyys(js.getStr("JCRBH")); - bgd.setShsj(js.getStr("BGRQ")); - bgd.setShsj(js.getStr("BGRQ")); - bgd.setShys(js.getStr("SHRBH")); - bgd.setYcbz(js.getStr("YCTS")); + LtkjHybgd bgd = new LtkjHybgd(); + bgd.setTmh(hysqd.getTmh()); + bgd.setJcxmid(js.getStr("JCZBDM")); + bgd.setJcxm(js.getStr("JCZBMC")); + bgd.setTdh(js.getStr("")); + bgd.setJyjg(js.getStr("JCZBJG")); + bgd.setJgdw(js.getStr("JLDW")); + bgd.setFwzdz(js.getStr("")); + bgd.setFwzgz(js.getStr("")); + bgd.setFwz(js.getStr("CKZFW")); + bgd.setJysj(js.getStr("BGRQ")); + bgd.setJyys(js.getStr("JCRBH")); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShys(js.getStr("SHRBH")); + bgd.setShysmc(js.getStr("SHRXM")); + bgd.setYcbz(js.getStr("YCTS")); // bgd.setTpurl(js.getStr("")); - ltkjHybgdService.save(bgd); + ltkjHybgdService.save(bgd); + } + } + + Map<String, Object> fbhashMap = new HashMap<>(); + fbhashMap.put("jybgid", hysqd.getTmh()); + AjaxResult fbres = controller.Getlabgermrepinfo(fbhashMap); + String ajaxResult = getAjaxResult(fbres); + JSONObject fbobject = getJSONObject(ajaxResult); + String fbcode = fbobject.getStr("ResultCode"); + if (null != fbcode && fbcode.equals("0")) { + JSONArray datas = fbobject.getJSONArray("ResultData"); + for (Object o : datas) { + JSONObject js = (JSONObject) o; + LtkjHybgd bgd = new LtkjHybgd(); + bgd.setTmh(hysqd.getTmh()); + bgd.setJcxmid(hysqd.getXmid()); + bgd.setJcxm(hysqd.getXmmc()); + bgd.setTdh(js.getStr("")); + bgd.setJyjg(js.getStr("JCJG")); + bgd.setJgdw("/"); + bgd.setFwzdz("/"); + bgd.setFwzgz("/"); + bgd.setFwz("/"); + bgd.setJysj(js.getStr("BGRQ")); + bgd.setJyys(hysqd.getSqrxm()); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShys(hysqd.getShrdm()); + bgd.setShysmc(hysqd.getShrxm()); + ltkjHybgdService.save(bgd); + } + } + + } + } + //鍚屾鍖栭獙椤圭洰 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); } + + /*鍚屾妫�鏌� his鎺ュ彛*/ + if (null != jianChaBaoGaoDan && jianChaBaoGaoDan.size() > 0) { + Map<String, Object> maps = new HashMap<>(); + maps.put("his_registration_id", order.getCardId()); + maps.put("ksbm", "浣撴涓績"); + maps.put("pagecount", 100); + maps.put("page", 1); +// AjaxResult results = service.getHISDataNew("Getexamreportinfo", maps); + + LambdaQueryWrapper<HisApiConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, "Getexamreportinfo"); + HisApiConfig hisApiConfig = hisApiConfigService.getOne(lambdaQueryWrapper); + + + /*鍚屾妫�鏌� his瀛樺偍杩囩▼*/ + AjaxResult results = jcsqdService.getTjJcProByHisCall("浣撴涓績", order.getCardId(), "''", 100, 1, "'1'"); + + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + DynamicDataSourceContextHolder.clearDataSourceType(); + + log.info("妫�鏌ラ」鐩煡璇㈣繑鍥炲��: " + results.toString()); + + if (Integer.parseInt(results.get("code").toString()) == 200) { + List<Map<String, Object>> datas = (List<Map<String, Object>>) results.get("data"); + if (null != datas && datas.size() > 0) { + jcsqdService.deletedLtkjJcsqdByTjhAndTmh(order.getCardId()); + jcbgdService.deletedLtkjJcbgdByTjhAndTmh(order.getCardId()); + for (Map<String, Object> objectMap : datas) { + //淇濆瓨鍏ュ弬鍑哄弬 +// service.save((JSONObject)objectMap,"Getexamreportinfo",hisApiConfig,JSONUtil.toJsonStr(maps)); + service.save(JSONUtil.parseObj(objectMap), "Getexamreportinfo", hisApiConfig, JSONUtil.toJsonStr(maps)); + + + LtkjExamJcbgd jcbgd = new LtkjExamJcbgd(); + jcbgd.setTjh(order.getCardId()); + if (null != objectMap.get("JCBGID") || !objectMap.get("JCBGID").equals("")) + jcbgd.setTmh(objectMap.get("JCBGID").toString()); + + if (null != objectMap.get("JCXMDM") || !objectMap.get("JCXMDM").equals("")) + jcbgd.setXmdm(objectMap.get("JCXMDM").toString()); + + if (null != objectMap.get("JCXMMC") || !objectMap.get("JCXMMC").equals("")) + jcbgd.setXmmc(objectMap.get("JCXMMC").toString()); + + if (null != objectMap.get("JCXMJG") || !objectMap.get("JCXMJG").equals("")) + jcbgd.setBgNr(objectMap.get("JCXMJG").toString()); + + if (null != objectMap.get("reporturl") || !objectMap.get("reporturl").equals("")) + jcbgd.setBgUrl(objectMap.get("reporturl").toString()); + + if (null != objectMap.get("SHYSQM") || !objectMap.get("SHYSQM").equals("")) + jcbgd.setShysxm(objectMap.get("SHYSQM").toString()); + + if (null != objectMap.get("SHYSBH") || !objectMap.get("SHYSBH").equals("")) + jcbgd.setShysdm(objectMap.get("SHYSBH").toString()); + + if (null != objectMap.get("YXZD") || !objectMap.get("YXZD").equals("")) + jcbgd.setYxzd(objectMap.get("YXZD").toString()); + + if (null != objectMap.get("YXBX") || !objectMap.get("YXBX").equals("")) { + if (objectMap.get("YXBX").toString().equals("null")) { + jcbgd.setYxbx("鏈寮傚父"); + } else { + jcbgd.setYxbx(objectMap.get("YXBX").toString()); + } + } + if (null != objectMap.get("SJJLSJ") || !objectMap.get("SJJLSJ").equals("")) + jcbgd.setZdsj(objectMap.get("SJJLSJ").toString()); + + if (null != objectMap.get("JCBW") || !objectMap.get("JCBW").equals("")) + jcbgd.setJcbw(objectMap.get("JCBW").toString()); + + if (null != objectMap.get("SQRQSJ") || !objectMap.get("SQRQSJ").equals("")) + jcbgd.setSqsj(objectMap.get("SQRQSJ").toString()); + + jcbgdService.save(jcbgd); + } + jcsqdService.saveLtkjExamJcsqd(order.getCardId()); + + int maxRetries=3; + for (int attempt = 0; attempt < maxRetries; attempt++) { + try { + testMapper.updateDetailByTjJcCall(order.getCardId(), + String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); + break; + } catch (Exception e) { + if (attempt==maxRetries-1){ + throw e; + } + try { + Thread.sleep(1000); + } catch (InterruptedException ignored) { + } + } + } + }else { + return AjaxResult.error("妫�鏌ラ」鐩殏鏃舵湭鍑虹粨鏋�,璇风◢鍚庡悓姝�!!!"); + } + } + } + return AjaxResult.success("鍚屾鎴愬姛"); } + else if(null !=sfkqdshitulianjie && sfkqdshitulianjie.equalsIgnoreCase("Y")){ + List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(order.getTjNumber()); + if(null != hysqdList && !hysqdList.isEmpty()){ + for (LtkjHysqd hysqd : hysqdList) { + 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> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh()); + ltkjHybgdService.saveBatch(hybgdList); + } + } + DynamicDataSourceContextHolder.clearDataSourceType(); + } + List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(order.getTjNumber()); + if(null !=jcsqdList && !jcsqdList.isEmpty()){ + jcsqdService.deletedLtkjJcsqdByTjhAndTmh(order.getCardId()); + jcbgdService.deletedLtkjJcbgdByTjhAndTmh(order.getCardId()); + jcsqdService.saveBatch(jcsqdList); + List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(order.getCardId()); + if(null != jcbgdList && !jcbgdList.isEmpty())jcbgdService.saveBatch(jcbgdList); + DynamicDataSourceContextHolder.clearDataSourceType(); + } +// String tjNumber1 = order.getTjNumber(); +// log.info("鏌ヨ鍑烘潵鐨勪綋妫�鍙锋槸: " + tjNumber1); +// log.info("浼犺繃鏉ョ殑鐨勪綋妫�鍙锋槸: "+tjNumber); + Map<String,Object> map=new HashMap<>(); + map.put("tjnum",tjNumber); + testMapper.tjUpdateDetatilByVi(map); + }else { + //鍖栭獙 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); + } + //妫�鏌� + return AjaxResult.success("鍚屾鎴愬姛"); } - //鍚屾鍖栭獙椤圭洰 - testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); - //鍚屾妫�鏌ラ」鐩� - testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId()); - asyncService.updateCheckType(order.getTjNumber()); + return AjaxResult.error("鏈煡鍒拌浜哄憳浣撴璁板綍"); } + return AjaxResult.error("璇ヤ汉鍛樻暟鎹鍦ㄥ悓姝ヤ腑锛岃绋嶇瓑"); + } catch (InterruptedException e) { + e.printStackTrace(); + return AjaxResult.error("璇ヤ汉鍛樻暟鎹鍦ㄥ悓姝ヤ腑锛岃绋嶇瓑"); + }finally { + lock.unlock(); + } + } + + /** + * 鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛 + */ + @GetMapping ("/dataSynchronizationApi") + @ApiOperation (value = "鍚屾sql server鏁版嵁鍒版湰鍦版暟鎹簱鏁版嵁鎺ュ彛") + @RepeatSubmit +// @Transactional + public AjaxResult dataSynchronizationApi(@RequestParam String tjNumber) { + RLock lock = redissonClient.getLock("lock:check:dataSynchronization:" + tjNumber); + try { + boolean tryLock = lock.tryLock(3L, TimeUnit.SECONDS); + if (tryLock){ + String doctorId = configService.selectConfigByKey("request_default_check_doctorId"); + //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12 + final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); + + final String sfkqdyhis = configService.selectConfigByKey("sfkqdyhis"); + TjOrder order = orderService.getOrderByTjNum(tjNumber); + if (null != order) { + + //寮�鍚瓧鍏稿脊绐� + if ("Y".equals(getInfoFromSqlData)) { + tbhyxm(order); + //鍚屾鍖栭獙椤圭洰 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId); + //鍚屾妫�鏌ラ」鐩� + testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId); + asyncService.updateCheckType(order.getTjNumber()); + + } + //寮�鍚拰his瀵规帴 + if (null != sfkqdyhis && sfkqdyhis.equals("Y")) { + List<String> baoGaoDans = ltkjHybgdService.getJianYanBaoGaoDan(order.getCardId()); + List<String> jianChaBaoGaoDan = ltkjHybgdService.getJianChaBaoGaoDan(order.getCardId()); + //鍚屾妫�楠� + if (null != baoGaoDans && !baoGaoDans.isEmpty()) { + Date dates = new Date(); + Map<String, Object> map = new HashMap<>(); + map.put("his_registration_id", order.getCardId()); + map.put("ksbm", ""); + map.put("pationid", ""); + map.put("ksrq", DateUtil.format(DateUtil.beginOfDay(order.getCreateTime()), "yyyy-MM-dd HH:mm:ss")); + map.put("jsrq", DateUtil.format(DateUtil.endOfDay(dates), "yyyy-MM-dd HH:mm:ss")); + map.put("pagecount", 10); + map.put("page", 1); + AjaxResult result = controller.Getlabreportinfo(map); + String result1 = getAjaxResult(result); + JSONObject object = getJSONObject(result1); + String code = object.getStr("ResultCode"); + if (null == code || !code.equals("0")) { + return AjaxResult.error("鍖栭獙椤圭洰鏆傛椂鏈嚭缁撴灉,璇风◢鍚庡悓姝�!!!"); + } + JSONArray data = object.getJSONArray("ResultData"); + for (Object datum : data) { + JSONObject jsonObject = (JSONObject) datum; + boolean isInsertHysqd = false; + LtkjHysqd hysqd = new LtkjHysqd(); + hysqd.setTjh(order.getCardId()); + hysqd.setTmh(jsonObject.getStr("JYBGID")); + hysqd.setBbbh(jsonObject.getStr("BBDM")); + hysqd.setBbmc(jsonObject.getStr("BBMC")); + hysqd.setXmid(jsonObject.getStr("JYXMDM")); + hysqd.setXmmc(jsonObject.getStr("JYXMMC")); + hysqd.setSqsj(jsonObject.getStr("SQRQ")); + hysqd.setSqys(jsonObject.getStr("SQRBH")); + hysqd.setJgsj(jsonObject.getStr("JYBGRQ")); + hysqd.setSqrxm(jsonObject.getStr("SQRXM")); + hysqd.setSqdh(jsonObject.getStr("SQDBH")); + hysqd.setShrdm(jsonObject.getStr("JYYSBH")); + hysqd.setShrxm(jsonObject.getStr("JYYSQM")); + hysqd.setJybgjg(jsonObject.getStr("JYBGJG")); + QueryWrapper<LtkjHysqd> queryWrapper = new QueryWrapper<>(hysqd); + List<LtkjHysqd> list = ltkjHysqdService.list(queryWrapper); + if (list.isEmpty()) + isInsertHysqd = true; + if (isInsertHysqd){ + saveHysqd(hysqd); + }else { + saveHybgd(hysqd); + } + } + //鍚屾鍖栭獙椤圭洰 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId); + } + /*鍚屾妫�鏌� his鎺ュ彛*/ + if (null != jianChaBaoGaoDan && jianChaBaoGaoDan.size() > 0) { + Map<String, Object> maps = new HashMap<>(); + maps.put("his_registration_id", order.getCardId()); + maps.put("ksbm", "浣撴涓績"); + maps.put("pagecount", 100); + maps.put("page", 1); + LambdaQueryWrapper<HisApiConfig> lambdaQueryWrapper = new LambdaQueryWrapper<>(); + lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, "Getexamreportinfo"); + HisApiConfig hisApiConfig = hisApiConfigService.getOne(lambdaQueryWrapper); + /*鍚屾妫�鏌� his瀛樺偍杩囩▼*/ + AjaxResult results = jcsqdService.getTjJcProByHisCall("浣撴涓績", order.getCardId(), "''", 100, 1, "'1'"); + DynamicDataSourceContextHolder.clearDataSourceType(); + log.info("妫�鏌ラ」鐩煡璇㈣繑鍥炲��: " + results.toString()); + if (Integer.parseInt(results.get("code").toString()) == 200) { + List<Map<String, Object>> datas = (List<Map<String, Object>>) results.get("data"); + if (null != datas && !datas.isEmpty()) { + jcsqdService.deletedLtkjJcsqdByTjhAndTmh(order.getCardId()); + jcbgdService.deletedLtkjJcbgdByTjhAndTmh(order.getCardId()); + for (Map<String, Object> objectMap : datas) { + //淇濆瓨鍏ュ弬鍑哄弬 + service.save(JSONUtil.parseObj(objectMap), "Getexamreportinfo", hisApiConfig, JSONUtil.toJsonStr(maps)); + LtkjExamJcbgd jcbgd = new LtkjExamJcbgd(); + jcbgd.setTjh(order.getCardId()); + if (null != objectMap.get("JCBGID") || !objectMap.get("JCBGID").equals("")) + jcbgd.setTmh(objectMap.get("JCBGID").toString()); + if (null != objectMap.get("JCXMDM") || !objectMap.get("JCXMDM").equals("")) + jcbgd.setXmdm(objectMap.get("JCXMDM").toString()); + if (null != objectMap.get("JCXMMC") || !objectMap.get("JCXMMC").equals("")) + jcbgd.setXmmc(objectMap.get("JCXMMC").toString()); + if (null != objectMap.get("JCXMJG") || !objectMap.get("JCXMJG").equals("")) + jcbgd.setBgNr(objectMap.get("JCXMJG").toString()); + if (null != objectMap.get("reporturl") || !objectMap.get("reporturl").equals("")) + jcbgd.setBgUrl(objectMap.get("reporturl").toString()); + if (null != objectMap.get("SHYSQM") || !objectMap.get("SHYSQM").equals("")) + jcbgd.setShysxm(objectMap.get("SHYSQM").toString()); + if (null != objectMap.get("SHYSBH") || !objectMap.get("SHYSBH").equals("")) + jcbgd.setShysdm(objectMap.get("SHYSBH").toString()); + if (null != objectMap.get("YXZD") || !objectMap.get("YXZD").equals("")) + jcbgd.setYxzd(objectMap.get("YXZD").toString()); + if (null != objectMap.get("YXBX") || !objectMap.get("YXBX").equals("")) { + if (objectMap.get("YXBX").toString().equals("null")) { + jcbgd.setYxbx("鏈寮傚父"); + } else { + jcbgd.setYxbx(objectMap.get("YXBX").toString()); + } + } + if (null != objectMap.get("SJJLSJ") || !objectMap.get("SJJLSJ").equals("")) + jcbgd.setZdsj(objectMap.get("SJJLSJ").toString()); + if (null != objectMap.get("JCBW") || !objectMap.get("JCBW").equals("")) + jcbgd.setJcbw(objectMap.get("JCBW").toString()); + if (null != objectMap.get("SQRQSJ") || !objectMap.get("SQRQSJ").equals("")) + jcbgd.setSqsj(objectMap.get("SQRQSJ").toString()); + jcbgdService.save(jcbgd); + } + jcsqdService.saveLtkjExamJcsqd(order.getCardId()); + testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId); + }else { + return AjaxResult.error("妫�鏌ラ」鐩殏鏃舵湭鍑虹粨鏋�,璇风◢鍚庡悓姝�!!!"); + } + } + } + return AjaxResult.success("鍚屾鎴愬姛"); + } + //鍖栭獙 + testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId); + //妫�鏌� + jcsqdService.saveLtkjExamJcsqd(order.getCardId()); + return AjaxResult.success("鍚屾鎴愬姛"); + } + return AjaxResult.error("鏈煡鍒拌浜哄憳浣撴璁板綍"); + } + return AjaxResult.error("璇ヤ汉鍛樻暟鎹鍦ㄥ悓姝ヤ腑锛岃绋嶇瓑"); + } catch (InterruptedException e) { + e.printStackTrace(); + return AjaxResult.error("璇ヤ汉鍛樻暟鎹鍦ㄥ悓姝ヤ腑锛岃绋嶇瓑"); + } finally { + lock.unlock(); } - return AjaxResult.success("鍚屾鎴愬姛"); + } + + private void saveHysqd(LtkjHysqd hysqd) { + if (ltkjHysqdService.save(hysqd)) { + saveHybgd(hysqd); } - return AjaxResult.error(); + } + + private void saveHybgd(LtkjHysqd hysqd) { + Map<String, Object> hashMap = new HashMap<>(); + hashMap.put("jybgid", hysqd.getTmh()); + AjaxResult bgdres = controller.Getlabdetailinfo(hashMap); + String result2 = getAjaxResult(bgdres); + JSONObject object1 = getJSONObject(result2); + String code1 = object1.getStr("ResultCode"); + if (null != code1 && code1.equals("0")) { + JSONArray datas = object1.getJSONArray("ResultData"); + for (Object o : datas) { + JSONObject js = (JSONObject) o; +// ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(jsonObject.getStr("JYBGID")); + LtkjHybgd bgd = new LtkjHybgd(); + bgd.setTmh(hysqd.getTmh()); + bgd.setJcxmid(js.getStr("JCZBDM")); + bgd.setJcxm(js.getStr("JCZBMC")); + bgd.setTdh(js.getStr("")); + bgd.setJyjg(js.getStr("JCZBJG")); + bgd.setJgdw(js.getStr("JLDW")); + bgd.setFwzdz(js.getStr("")); + bgd.setFwzgz(js.getStr("")); + bgd.setFwz(js.getStr("CKZFW")); + bgd.setJysj(js.getStr("BGRQ")); + bgd.setJyys(js.getStr("JCRBH")); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShys(js.getStr("SHRBH")); + bgd.setShysmc(js.getStr("SHRXM")); + bgd.setYcbz(js.getStr("YCTS")); +// bgd.setTpurl(js.getStr("")); + QueryWrapper<LtkjHybgd> queryWrapper = new QueryWrapper<>(bgd); + List<LtkjHybgd> list = ltkjHybgdService.list(queryWrapper); + if (list.isEmpty()) + ltkjHybgdService.save(bgd); + } + } + + Map<String, Object> fbhashMap = new HashMap<>(); + fbhashMap.put("jybgid", hysqd.getTmh()); + AjaxResult fbres = controller.Getlabgermrepinfo(fbhashMap); + String ajaxResult = getAjaxResult(fbres); + JSONObject fbobject = getJSONObject(ajaxResult); + String fbcode = fbobject.getStr("ResultCode"); + if (null != fbcode && fbcode.equals("0")) { + JSONArray datas = fbobject.getJSONArray("ResultData"); + for (Object o : datas) { + JSONObject js = (JSONObject) o; + LtkjHybgd bgd = new LtkjHybgd(); + bgd.setTmh(hysqd.getTmh()); + bgd.setJcxmid(hysqd.getXmid()); + bgd.setJcxm(hysqd.getXmmc()); + bgd.setTdh(js.getStr("")); + bgd.setJyjg(js.getStr("JCJG")); + bgd.setJgdw("/"); + bgd.setFwzdz("/"); + bgd.setFwzgz("/"); + bgd.setFwz("/"); + bgd.setJysj(js.getStr("BGRQ")); + bgd.setJyys(hysqd.getSqrxm()); + bgd.setShsj(js.getStr("BGRQ")); + bgd.setShys(hysqd.getShrdm()); + bgd.setShysmc(hysqd.getShrxm()); + QueryWrapper<LtkjHybgd> queryWrapper = new QueryWrapper<>(bgd); + List<LtkjHybgd> list = ltkjHybgdService.list(queryWrapper); + if (list.isEmpty()) + ltkjHybgdService.save(bgd); + } + } } //灏嗘柟娉曡繑鍥炲�艰В鏋愭垚json鏍煎紡 @@ -474,17 +959,17 @@ /** * 鏌ヨ浣撴璁板綍瀹㈡埛鍒楄〃 */ - @GetMapping("/getList") - @ApiOperation(value = "鏌ヨ浣撴璁板綍瀹㈡埛鍒楄〃")//0寰�1宸� + @GetMapping ("/getList") + @ApiOperation (value = "鏌ヨ浣撴璁板綍瀹㈡埛鍒楄〃")//0寰�1宸� // @PreAuthorize("@ss.hasPermi('check:check:getList')") - public AjaxResult getList(@ApiParam(value = "瀹℃牳鐘舵��0寰呭鏍�1宸插鏍�") @RequestParam(required = false) Integer checkStatus, - @ApiParam(value = "椤电爜鏁�(榛樿1)") @RequestParam(defaultValue = "1") Integer page, - @ApiParam(value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam(defaultValue = "10") Integer pageSize, - @ApiParam(value = "浣撴鍗曞彿") @RequestParam(required = false) String tjNumber, - @ApiParam(value = "鍗曚綅") @RequestParam(required = false) Long compId, - @ApiParam(value = "濮撳悕)") @RequestParam(required = false) String name, - @ApiParam(value = "寮�濮嬫椂闂�") @RequestParam(required = false) String beginTime, - @ApiParam(value = "缁撴潫鏃堕棿") @RequestParam(required = false) String endTime) { + public AjaxResult getList(@ApiParam (value = "瀹℃牳鐘舵��0寰呭鏍�1宸插鏍�") @RequestParam (required = false) Integer checkStatus, + @ApiParam (value = "椤电爜鏁�(榛樿1)") @RequestParam (defaultValue = "1") Integer page, + @ApiParam (value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam (defaultValue = "10") Integer pageSize, + @ApiParam (value = "浣撴鍗曞彿") @RequestParam (required = false) String tjNumber, + @ApiParam (value = "鍗曚綅") @RequestParam (required = false) Long compId, + @ApiParam (value = "濮撳悕)") @RequestParam (required = false) String name, + @ApiParam (value = "寮�濮嬫椂闂�") @RequestParam (required = false) String beginTime, + @ApiParam (value = "缁撴潫鏃堕棿") @RequestParam (required = false) String endTime) { // String config = configService.selectConfigByKey("tj_confirm"); // DateTime beginTimes = null; // DateTime endTimes = null; @@ -584,6 +1069,119 @@ return AjaxResult.success(orderService.getCunChuGuoChengCustomerList(tjNumber, page, pageSize, checkStatus, value, beginTime, endTime, name)); } + + + @GetMapping ("/getBghsList") + @ApiOperation (value = "鎶ュ憡鏍告敹椤甸潰鏌ヨ鎺ュ彛")//0寰�1宸� +// @PreAuthorize("@ss.hasPermi('check:check:getList')") + public AjaxResult getBghsList(@ApiParam (value = "椤电爜鏁�(榛樿1)") @RequestParam (defaultValue = "1") Integer page, + @ApiParam (value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam (defaultValue = "10") Integer pageSize, + @ApiParam (value = "浣撴鍗曞彿") @RequestParam (required = false) String tjNumber, + @ApiParam (value = "鍗曚綅") @RequestParam (required = false) Long compId, + @ApiParam (value = "濮撳悕)") @RequestParam (required = false) String name, + @ApiParam (value = "寮�濮嬫椂闂�") @RequestParam (required = false) String beginTime, + @ApiParam (value = "缁撴潫鏃堕棿") @RequestParam (required = false) String endTime) { + // String config = configService.selectConfigByKey("tj_confirm"); +// DateTime beginTimes = null; +// DateTime endTimes = null; +// if (null != beginTime && null != endTime) { +// beginTimes = DateUtil.beginOfDay(DateUtil.parse(beginTime)); +// endTimes = DateUtil.endOfDay(DateUtil.parse(endTime)); +// } +// asyncService.checkSetCustomerLisByRedis(config); +// //鍒濆鍖栦綋妫�璁㈠崟琛� +// List<TjOrder> orderList = null; +// List<TjCustomer> customerList = new ArrayList<>(); +// Map<String, Object> map = new HashMap<>(); +// +// //濮撳悕鏌ヨ +// if (null != name && !"".equals(name)) { +// List<TjCustomer> list = customerService.getTjCustomerList(name); +// if (null != list && list.size() > 0) { +// List<TjCustomer> lists = new ArrayList<>(); +// for (TjCustomer customer : list) { +// if ("Y".equals(config)) { +// orderList = orderService.getCsTjOrderListByCusId1(customer.getCusId()); +// } else { +// orderList = orderService.getTjOrderListByCusId(customer.getCusId()); +// } +// if (null != orderList && orderList.size() > 0) { +// for (TjOrder tjOrder : orderList) { +// customer.setTjNumber(tjOrder.getTjNumber()); +// customer.setTjStatus(Long.valueOf(tjOrder.getCheckStatus())); +// customer.setOrderId(tjOrder.getOrderId()); +// customer.setTjTime(tjOrder.getFinishTime()); +// customer.setFinishTime(tjOrder.getFinishTime()); +// customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); +// customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); +// customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); +// customer.setConfirmStatus(String.valueOf(tjOrder.getStatus())); +// customer.setTjCategory(tjOrder.getTjCategory()); +// if (tjOrder.getFirmId().equals("0")) { +// customer.setTjCompName(null); +// } else { +// customer.setTjCompName(compService.selectDictCompByDrugManufacturerId(tjOrder.getFirmId()).getCnName()); +// } +// lists.add(customer); +// } +// } +// } +// List<TjCustomer> customers = null; +// if (lists.size() > 0) { +// customers = lists.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); +// } +// map.put("customers", customers); +// map.put("total", lists.size()); +// return AjaxResult.success(map); +// } +// return AjaxResult.success("鏆傛棤鏁版嵁"); +// } +// +// //鏉′欢鏌ヨ +// if (null != tjNumber || null != compId || (null != beginTime && null != endTime)) { +// //鍒ゆ柇鏄惁寮�鍚垵瀹� +// if ("Y".equals(config)) { +// orderList = orderService.getCsTjOrderList1(tjNumber, checkStatus, compId, beginTimes, endTimes); +// } else { +// orderList = orderService.getTjOrderList(tjNumber, checkStatus, compId, beginTimes, endTimes); +// } +// return getResult(page, pageSize, orderList, customerList, map); +// } +// +// List<TjCustomer> customers = null; +// if (null != checkStatus && checkStatus == 0) { +// customers = redisCache.getCacheMapValue("check", "ws"); +// } +// if (null != checkStatus && checkStatus == 1) { +// customers = redisCache.getCacheMapValue("check", "ys"); +// } +// if (customers != null && customers.size() > 0) { +//// asyncService.addRedis(customers); +// List<TjCustomer> customerLists = customers.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList()); +// map.put("customers", customerLists); +// map.put("total", customers.size()); +// return AjaxResult.success(map); +// } else { +// //鍒ゆ柇鏄惁寮�鍚垵瀹� +// if ("Y".equals(config)) { +// orderList = orderService.getCsTjOrderList1(tjNumber, checkStatus, compId, beginTimes, endTimes); +// } else { +// orderList = orderService.getTjOrderList(tjNumber, checkStatus, compId, beginTimes, endTimes); +// } +// return getResult(page, pageSize, orderList, customerList, map); +// } + + String value = String.valueOf(compId); + if (tjNumber == null) tjNumber = ""; + if (compId == null) value = ""; + if (name == null) name = ""; + if (beginTime == null) beginTime = ""; + if (endTime == null) endTime = ""; + return AjaxResult.success(orderService.getgetBghsList(tjNumber, page, pageSize, value, beginTime, endTime, name)); + } + + + /** * 鏍规嵁浣撴璁㈠崟鍙疯幏鍙栦綋妫�璇︽儏淇℃伅鎺ュ彛 * @@ -592,15 +1190,19 @@ * @param checkStatus * @return */ - @PutMapping("/getTjdetailList") - @ApiOperation(value = "鏍规嵁浣撴璁㈠崟鍙疯幏鍙栦綋妫�璇︽儏淇℃伅(骞朵慨鏀圭姸鎬�)鎺ュ彛") + @PutMapping ("/getTjdetailList") + @ApiOperation (value = "鏍规嵁浣撴璁㈠崟鍙疯幏鍙栦綋妫�璇︽儏淇℃伅(骞朵慨鏀圭姸鎬�)鎺ュ彛") // @PreAuthorize("@ss.hasPermi('check:check:getTjdetailList')") - public AjaxResult getTjdetailList(@ApiParam(value = "浣撴tjNumber") @RequestParam String tjNumber, - @ApiParam(value = "鎬绘寤鸿") @RequestParam(required = false) String advice, - @ApiParam(value = "瀹℃牳鐘舵��0寰呭鏍�1宸插鏍�") @RequestParam Integer checkStatus) { + public AjaxResult getTjdetailList(@ApiParam (value = "浣撴tjNumber") @RequestParam String tjNumber, + @ApiParam (value = "鎬绘寤鸿") @RequestParam (required = false) String advice, + @ApiParam (value = "瀹℃牳鐘舵��0寰呭鏍�1宸插鏍�") @RequestParam Integer checkStatus) { - int num = orderRemarkService.getTjYqOrderRemarkByTjNum(tjNumber); - if (num > 0) return AjaxResult.error("鏈夊欢鏈熼」鐩殏涓嶈兘鐢熸垚鎶ュ憡!!!"); + String config = configService.selectConfigByKey("sfjcwjhyqxm"); + if(null != config && config.equalsIgnoreCase("Y")){ + int num = orderRemarkService.getTjYqOrderRemarkByTjNum(tjNumber); + if (num > 0) return AjaxResult.error("瀛樺湪鏈鎴栧欢鏈熼」鐩殏涓嶈兘鐢熸垚鎶ュ憡!!!"); + } + if (null != tjNumber) { Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId()); SysUser sysUser = userService.getById(userId); @@ -619,10 +1221,10 @@ if (null != customer) { customer.setCusNumber(customer.getCusNumber() + 1); if (customerService.updateById(customer)) { - LambdaQueryWrapper<TbTransition> wqq = new LambdaQueryWrapper<>(); - wqq.eq(TbTransition::getCusId, customer.getCusIdcard()); - wqq.eq(TbTransition::getCardId, customer.getCardId()); - transitionService.remove(wqq); +// LambdaQueryWrapper<TbTransition> wqq = new LambdaQueryWrapper<>(); +// wqq.eq(TbTransition::getCusId, customer.getCusIdcard()); +// wqq.eq(TbTransition::getCardId, customer.getCardId()); +// transitionService.remove(wqq); asyncService.updateCheckType(tjNumber); return AjaxResult.success("鎿嶄綔鎴愬姛"); } @@ -643,14 +1245,15 @@ * @param tjNumber * @return */ - @GetMapping("/updateCheckType") - @ApiOperation(value = "鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏鈥斺�斺�斺�旈潪鍖栭獙椤圭洰") - public AjaxResult updateCheckType(@ApiParam(value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { + @GetMapping ("/updateCheckType") + @ApiOperation (value = "鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏鈥斺�斺�斺�旈潪鍖栭獙椤圭洰") + public AjaxResult updateCheckType(@ApiParam (value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { // if (redisCache.hasKey("updateCheckType" + tjNumber)) { // List<Map<String, Object>> cacheMapValue = redisCache.getCacheMapValue("updateCheckType" + tjNumber, tjNumber); // return AjaxResult.success(cacheMapValue); // } - return getAjaxResult(tjNumber); +// return getAjaxResult(tjNumber); + return getResult(tjNumber); } private AjaxResult getAjaxResult(String tjNumber) { @@ -689,19 +1292,29 @@ if (null != tjOrderDetails && tjOrderDetails.size() > 0) { for (TjOrderDetail tjOrderDetail : tjOrderDetails) { final TjProject byId = projectService.selectTjProjectByProId(tjOrderDetail.getProId()); + String metering = null; if (null == byId) { detailService.removeById(tjOrderDetail.getOrderDetailId()); } else { + metering = byId.getProMetering(); tjOrderDetail.setProject(byId); } List<TjStandard> list2 = tjStandardService.getTjStandardListByProId(String.valueOf(tjOrderDetail.getProId())); if (list2.size() == 0) { - tjOrderDetail.setStandard(new TjStandard()); + TjStandard standard = new TjStandard(); + if (StrUtil.isNotBlank(metering)) + standard.setCompany(metering); + tjOrderDetail.setStandard(standard); } else if (list2.size() == 1) { - tjOrderDetail.setStandard(list2.get(0)); + TjStandard standard = list2.get(0); + if (StrUtil.isNotBlank(metering) && StrUtil.isBlank(standard.getCompany())) + standard.setCompany(metering); + tjOrderDetail.setStandard(standard); } else { final int ageType = StringUtils.getAgeType(DateUtil.ageOfNow(customer.getCusBrithday())); TjStandard tjStandard1 = tjStandardService.getListBySexAndType(customer.getCusSex(), ageType, String.valueOf(tjOrderDetail.getProId())); + if (StrUtil.isNotBlank(metering) && StrUtil.isBlank(tjStandard1.getCompany())) + tjStandard1.setCompany(metering); tjOrderDetail.setStandard(tjStandard1); } } @@ -741,9 +1354,9 @@ * @param tjNumber * @return */ - @GetMapping("/updateCheckTypeHuaYan") - @ApiOperation(value = "鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏鈥斺�斺�斺�斿寲楠岄」鐩�") - public AjaxResult updateCheckTypeHuaYan(@ApiParam(value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { + @GetMapping ("/updateCheckTypeHuaYan") + @ApiOperation (value = "鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏鈥斺�斺�斺�斿寲楠岄」鐩�") + public AjaxResult updateCheckTypeHuaYan(@ApiParam (value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { // asyncService.updateCheckType(tjNumber); List<Map<String, Object>> list = new ArrayList<>(); TjOrder one = orderService.getOrderByTjNum(tjNumber); @@ -751,9 +1364,9 @@ if (one == null) { return AjaxResult.error("鏆傛棤鏁版嵁锛侊紒"); } - final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); - if(null !=getInfoFromSqlData && getInfoFromSqlData.equals("Y")) - tbhyxm(one); +// final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); +// if(null !=getInfoFromSqlData && getInfoFromSqlData.equals("Y")) +// tbhyxm(one); // TjCustomer customer = customerService.getById(one.getUserId()); List<TjOrderRemark> remarkList = orderRemarkService.addHuaYanTable(tjNumber); List<TjOrderDetail> tjOrderDetails = detailService.addHuaYanTable(tjNumber); @@ -765,12 +1378,35 @@ parent.put("checkAdvice", one.getCheckAdvice()); parent.put("parent", remark.getProName()); parent.put("parentId", remark.getProId().toString()); - List<TjOrderDetail> dels=new ArrayList<>(); + List<TjOrderDetail> dels = new ArrayList<>(); if (null != tjOrderDetails && tjOrderDetails.size() > 0) { for (TjOrderDetail tjOrderDetail : tjOrderDetails) { - if(remark.getProId().equals(tjOrderDetail.getProId())){ - if(null !=tjOrderDetail.getYcbz() && !tjOrderDetail.getYcbz().equals("")){ - tjOrderDetail.setProResult(tjOrderDetail.getProResult()+" ["+tjOrderDetail.getYcbz()+"]"); + if (remark.getProId().equals(tjOrderDetail.getProId())) { + String ckfw = tjOrderDetail.getStanId(); + if (StrUtil.isNotBlank(tjOrderDetail.getProAdvice())) { + ckfw = ckfw.replace(tjOrderDetail.getProAdvice().trim(), ""); + } + if (StrUtil.isNotBlank(ckfw)) { + try { + Integer.parseInt(tjOrderDetail.getYcbz()); + String[] split = ckfw.split("-"); + BigDecimal min = new BigDecimal(split[0]); + BigDecimal max = new BigDecimal(split[1]); + String proResult = tjOrderDetail.getProResult(); + BigDecimal jyjgval = new BigDecimal(proResult); + if (jyjgval.compareTo(min) < 0) { + tjOrderDetail.setYcbz("鈫�"); + } else if (jyjgval.compareTo(max) > 0) { + tjOrderDetail.setYcbz("鈫�"); + } else { + tjOrderDetail.setYcbz(""); + } + } catch (NumberFormatException ignored) { + ignored.printStackTrace(); + } + } + if (null != tjOrderDetail.getYcbz() && !tjOrderDetail.getYcbz().equals("")) { + tjOrderDetail.setProResult(tjOrderDetail.getProResult() + " [" + tjOrderDetail.getYcbz() + "]"); } dels.add(tjOrderDetail); } @@ -782,7 +1418,7 @@ } else { parent.put("parentAdvice", null); } - if(dels.size()==0){ + if (dels.size() == 0) { continue; } parent.put("sons", dels); @@ -802,10 +1438,117 @@ } - @GetMapping("/getTm") - @ApiOperation(value = "鑾峰彇鏉$爜") + @GetMapping ("/updateHYANDCGCheckType") + @ApiOperation (value = "鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏鈥斺�斺�斺�斿父瑙勫拰鍖栭獙椤圭洰") + public AjaxResult updateHYANDCGCheckType(@ApiParam (value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { + return getResult(tjNumber); + } + + private AjaxResult getResult(String tjNumber) { + asyncService.updateCheckType(tjNumber); + List<Map<String, Object>> list = new ArrayList<>(); + TjOrder one = orderService.getOrderByTjNum(tjNumber); + + if (one == null) { + return AjaxResult.error("鏆傛棤鏁版嵁锛侊紒"); + } +// final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); +// if(null !=getInfoFromSqlData && getInfoFromSqlData.equals("Y")) +// tbhyxm(one); +// TjCustomer customer = customerService.getById(one.getUserId()); + List<TjOrderRemark> remarkList = orderRemarkService.addHuaYanAndCgTable(tjNumber); + List<TjOrderDetail> tjOrderDetails = detailService.addHuaYanAndCgTable(tjNumber); + + + if (null != remarkList && remarkList.size() > 0) { + for (TjOrderRemark remark : remarkList) { + Map<String, Object> parent = new HashMap<>(); + parent.put("checkAdvice", one.getCheckAdvice()); + parent.put("parent", remark.getProName()); + parent.put("parentId", remark.getProsId()); + parent.put("xmlb", remark.getXmlb()); + parent.put("", remark.getXmlb()); + List<TjOrderDetail> dels = new ArrayList<>(); + if (null != tjOrderDetails && tjOrderDetails.size() > 0) { + for (TjOrderDetail tjOrderDetail : tjOrderDetails) { + if (remark.getProsId().equals(tjOrderDetail.getProsId())) { + String ckfw = tjOrderDetail.getStanId(); + if (null !=ckfw && StrUtil.isNotBlank(tjOrderDetail.getProAdvice())) { + ckfw = ckfw.replace(tjOrderDetail.getProAdvice().trim(), ""); + } + if (StrUtil.isNotBlank(ckfw)) { + try { + if (ckfw != null && ckfw.contains("-")) { + Integer.parseInt(tjOrderDetail.getYcbz()); + String[] split = ckfw.split("-"); + BigDecimal min = new BigDecimal(split[0]); + BigDecimal max = new BigDecimal(split[1]); + String proResult = tjOrderDetail.getProResult(); + if(null !=proResult){ + BigDecimal jyjgval = new BigDecimal(proResult); + if (jyjgval.compareTo(min) < 0) { + tjOrderDetail.setYcbz("鈫�"); + } else if (jyjgval.compareTo(max) > 0) { + tjOrderDetail.setYcbz("鈫�"); + } else if(proResult.contains("闃�")) { + tjOrderDetail.setYcbz(""); + }else { + tjOrderDetail.setYcbz(""); + } + if (null != tjOrderDetail.getYcbz() && !tjOrderDetail.getYcbz().equals("")) { + tjOrderDetail.setProResult(tjOrderDetail.getProResult() + " [" + tjOrderDetail.getYcbz() + "]"); + } + }else { + tjOrderDetail.setYcbz(""); + } + }else { + if (tjOrderDetail.getProResult() != null && tjOrderDetail.getProResult().contains("闃�")) tjOrderDetail.setYcbz(""); + + if (tjOrderDetail.getProResult() != null && tjOrderDetail.getProResult().contains("闃�")) tjOrderDetail.setYcbz("鈫�"); + } + } catch (NumberFormatException ignored) { + ignored.printStackTrace(); + } + }else { + tjOrderDetail.setYcbz(""); + tjOrderDetail.setProResult(tjOrderDetail.getProResult()); + } + + dels.add(tjOrderDetail); + } + } + String summary = remark.getSummary(); + if (null != summary) { + String[] split = summary.split(";"); + parent.put("parentAdvice", tjAdviceService.getAdviceStringByIds(split)); + } else { + parent.put("parentAdvice", null); + } + if (dels.size() == 0) { + continue; + } + parent.put("sons", dels); + parent.put("remark", remark.getRemark()); + parent.put("jgbx", remark.getJgbx()); + if (remark.getDoctorName() != null) { + parent.put("doctorName", remark.getDoctorName()); + } + + list.add(parent); + } else { + return AjaxResult.success("璇ュ鎴锋病鏈変綋妫�椤圭洰鏁版嵁"); + } + } + return AjaxResult.success(list); + } + return AjaxResult.success("璇ュ鎴锋病鏈変綋妫�椤圭洰鏁版嵁锛�"); + } + + + @GetMapping ("/getTm") + @ApiOperation (value = "鑾峰彇鏉$爜") // @PreAuthorize("@ss.hasPermi('check:check:getTm')") - public AjaxResult getTm(@ApiParam(value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { + public AjaxResult getTm(@ApiParam (value = "瀹㈡埛浣撴鍙�") @RequestParam String tjNumber) { return AjaxResult.success(tjNumber); } @@ -814,8 +1557,8 @@ * * @return */ - @PostMapping("/checkUpdateOrderRemark") - @ApiOperation(value = "鎬绘淇敼澶囨敞鎺ュ彛") + @PostMapping ("/checkUpdateOrderRemark") + @ApiOperation (value = "鎬绘淇敼澶囨敞鎺ュ彛") public AjaxResult checkUpdateOrderRemark(@RequestBody List<UpdateOrderRemarkVo> updateOrderRemarkVos) { if (null != updateOrderRemarkVos && updateOrderRemarkVos.size() > 0) { for (UpdateOrderRemarkVo remarkVo : updateOrderRemarkVos) { -- Gitblit v1.8.0