From 936e2c79cd741472a6acfe28d730eb644b082cf7 Mon Sep 17 00:00:00 2001
From: zhaowenxuan <chacca165@163.com>
Date: 星期一, 21 十月 2024 14:22:19 +0800
Subject: [PATCH] 修改体检类型

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java |  364 +++++++++++++++++++++++++++++----------------------
 1 files changed, 204 insertions(+), 160 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
index ed5e2fd..2f3b4d1 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
@@ -12,6 +12,7 @@
 import java.util.*;
 import java.util.List;
 import java.util.concurrent.*;
+import java.util.concurrent.locks.ReentrantLock;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import javax.annotation.Resource;
@@ -56,6 +57,7 @@
 import com.ltkj.hosp.hisDto.OutpinimpapplyDto;
 import com.ltkj.hosp.hisDto.OutpinmedicapplyDto;
 import com.ltkj.hosp.mapper.TestMapper;
+import com.ltkj.hosp.mapper.TjSamplingMapper;
 import com.ltkj.hosp.pacsDto.SavePacsApply;
 import com.ltkj.hosp.service.*;
 import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail;
@@ -77,6 +79,7 @@
 import com.ltkj.web.controller.his.*;
 import com.ltkj.web.controller.lis.LisApiMethod;
 import com.ltkj.web.controller.pacs.PacsApiMethodService;
+import com.ltkj.web.controller.service.TjSysAsyncServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -88,6 +91,8 @@
 import org.springframework.http.HttpRequest;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.transaction.annotation.Isolation;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import org.springframework.util.DigestUtils;
@@ -208,6 +213,10 @@
     private HisPDFUtil hisPDFUtil;
     @Value("${path.reportServer}")
     private String urlValue;
+    @Autowired
+    private ITjSamplingService samplingService;
+    @Autowired
+    private TjSamplingMapper tjSamplingMapper;
 
     //灏嗘柟娉曡繑鍥炲�艰В鏋愭垚json鏍煎紡
     public JSONObject getJSONObject(String builder) {
@@ -874,9 +883,14 @@
     /**
      * 浣撴绛惧埌鐧昏鎺ュ彛
      */
+
+
+    ReentrantLock lock = new ReentrantLock();
+
     @PostMapping
     @ApiOperation(value = "浣撴绛惧埌鐧昏鎺ュ彛")
-    @Transactional  //(鍒囨崲鏁版嵁搴撳嚭閿欙紝鎵�浠ユ敞閲�)
+//    @Transactional  //(鍒囨崲鏁版嵁搴撳嚭閿欙紝鎵�浠ユ敞閲�)
+    @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED)
     public AjaxResult addOrderAndDetail(@RequestBody TjOrder tjOrder) throws Exception {
         Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId());
         SysUser sysUser = userService.getById(userId);
@@ -898,7 +912,6 @@
             transitionService.deletedTbTransitionListByCusIdAndTjNum(tjCustomer.getCusIdcard(), tjCustomer.getCardId());
             return AjaxResult.error("涓嶅彲閲嶅鐧昏");
         }
-
         TjFlowingWater tjFlowingWater = new TjFlowingWater();
         LambdaQueryWrapper<TjReservation> wq1 = new LambdaQueryWrapper<>();
         wq1.eq(TjReservation::getIdCard, tjCustomer.getCusIdcard());
@@ -908,9 +921,9 @@
         if (null != tjReservation) {
             tjOrder.setReservationId(tjReservation.getId());
             mallOrder = mallOrderService.getOne(new LambdaQueryWrapper<MallOrder>().eq(MallOrder::getReservationId, tjReservation.getId()));
-//            if (DateUtil.endOfDay(new Date()).before(tjReservation.getReservationTime())) {
-//                return AjaxResult.error("鏈埌棰勭害鏃堕棿");
-//            }
+            //            if (DateUtil.endOfDay(new Date()).before(tjReservation.getReservationTime())) {
+            //                return AjaxResult.error("鏈埌棰勭害鏃堕棿");
+            //            }
             if (DateUtil.endOfDay(DateUtil.offsetDay(tjReservation.getReservationTime(), tjReservation.getYxts())).before(new Date())) {
                 tjReservation.setIsExpire(1);
                 tjReservationService.updateById(tjReservation);
@@ -926,7 +939,7 @@
                 tjOrder.setGroupId(tjReservation.getGroupingId());
                 tjOrder.setFirmDeptId(tjReservation.getPacId());
             }
-//            if (null != tjReservation.getDepartmentId()) tjOrder.setFirmDeptId(tjReservation.getDepartmentId());
+            //            if (null != tjReservation.getDepartmentId()) tjOrder.setFirmDeptId(tjReservation.getDepartmentId());
             tjReservation.setIsExpire(1);
             tjReservationService.updateById(tjReservation);
             if (null != tjReservation.getTeamNo()) {
@@ -935,9 +948,7 @@
                 tjOrder.setTjType("2");
             }
         }
-        //鐢熸垚浣撴鍙�
-        String tjNumber = (SecurityUtils.getUsername() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
-        tjOrder.setTjNumber(tjNumber);
+
         if (null != tjOrder.getPhoto()) {
             File file = new File(tjOrder.getPhoto());
             if (file.isFile()) {
@@ -964,146 +975,152 @@
             tjOrder.setFinishTime(new Date());
             tjOrder.setCheckStatus(1);
             tjOrder.setStatus(TjConstants.TJ_WAIT);
-//            tjFlowingWater.setPayStasus(1L);
+            //            tjFlowingWater.setPayStasus(1L);
         }
-//        else {
         tjFlowingWater.setPayStasus(0L);
-//        }
-        if (tjOrderService.save(tjOrder)) {
 
-            //淇濆瓨鏀惰揣鍦板潃
-            if ("2".equals(tjOrder.getGetType())) {
-                final TjReportGetAddress address = tjOrder.getAddAddress();
-                if (address != null) {
-                    address.setTjNumber(tjNumber);
-                    tjReportGetAddressService.save(address);
-                }
-            }
-            Long cusNumber = tjCustomer.getCusNumber();
-            cusNumber += 1;
-            tjCustomer.setCusNumber(cusNumber);
-            BigDecimal discount = BigDecimal.valueOf(Double.parseDouble(tjOrder.getTjFlowingWater().getDiscount()));
+        try {
+            boolean b = lock.tryLock(3, TimeUnit.MINUTES);
+            if (b) {
+                //鐢熸垚浣撴鍙�
+                String tjNumber = (SecurityUtils.getUsername() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
+                tjOrder.setTjNumber(tjNumber);
 
-            if ("1".equals(tjOrder.getTjType())) {
-                if (null != tjReservation && tjReservation.getPayType() == 1) {
-                    tjFlowingWater.setPayStasus(3L);
-                }
-            }
-
-            //璋冪敤SQL server鎷垮彇鏀惰垂鎯呭喌
-            //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12
-            final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");
-            final String isPay = configService.selectConfigByKey("isPay");
-            if ("Y".equals(getInfoFromSqlData)) {
-                LtkjMiddleHead middleHead = headService.getMiddleHeadByPartId(tjCustomer.getCardId());
-                if (null != middleHead) {
-                    tjFlowingWater.setPayStasus(1L);
-                }
-            }
-            tjFlowingWater.setOrderId(tjOrder.getOrderId());
-            Date date1 = new Date(System.currentTimeMillis());
-            String s1 = SecurityUtils.getUsername() + new SimpleDateFormat("yyMMddHHmmssSSS").format(date1);
-            tjFlowingWater.setWaterId(PinyinUtil.getFirstLetter(tjCustomer.getCusName(), "").toUpperCase() + s1);
-
-
-            tjFlowingWater.setCopeWith(tjOrder.getTjFlowingWater().getCopeWith());
-            tjFlowingWater.setPaidIn(tjOrder.getTjFlowingWater().getPaidIn());
-            tjFlowingWater.setDiscount(tjOrder.getTjFlowingWater().getDiscount());
-
-            if (isPay.equals("true")) {
-                if (null != mallOrder) {
-                    if (mallOrder.getOrderStatus().equals(201L)) {
-                        tjFlowingWater.setCopeWith(mallOrder.getActualPrice());
-                        tjFlowingWater.setPaidIn(mallOrder.getActualPrice());
-                        tjFlowingWater.setDiscount(String.valueOf(1));
-                        tjFlowingWater.setPayStasus(1L);
-                        tjFlowingWater.setPayType(3L);
-                        MallCheckLog checkLog = new MallCheckLog();
-                        checkLog.setCheckBy(sysUser.getNickName());
-                        checkLog.setUserId(mallOrder.getUserId());
-                        checkLog.setConsignee(mallOrder.getConsignee());
-                        checkLog.setIdCard(mallOrder.getIdCard());
-                        checkLog.setOrderId(String.valueOf(mallOrder.getId()));
-                        checkLog.setOrderSn(mallOrder.getOrderSn());
-                        checkLog.setCheckTime(new Date());
-                        checkLog.setShipSn("HX" + s1);
-                        mallCheckLogService.save(checkLog);
-                        mallOrder.setOrderStatus(301L);
-                        mallOrderService.updateById(mallOrder);
+                if (tjOrderService.save(tjOrder)) {
+                    //淇濆瓨鏀惰揣鍦板潃
+                    if ("2".equals(tjOrder.getGetType())) {
+                        final TjReportGetAddress address = tjOrder.getAddAddress();
+                        if (address != null) {
+                            address.setTjNumber(tjNumber);
+                            tjReportGetAddressService.save(address);
+                        }
                     }
-                } else {
+                    Long cusNumber = tjCustomer.getCusNumber();
+                    cusNumber += 1;
+                    tjCustomer.setCusNumber(cusNumber);
+                    BigDecimal discount = BigDecimal.valueOf(Double.parseDouble(tjOrder.getTjFlowingWater().getDiscount()));
+
+                    if ("1".equals(tjOrder.getTjType())) {
+                        if (null != tjReservation && tjReservation.getPayType() == 1) {
+                            tjFlowingWater.setPayStasus(3L);
+                        }
+                    }
+
+                    //璋冪敤SQL server鎷垮彇鏀惰垂鎯呭喌
+                    //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12
+                    final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");
+                    final String isPay = configService.selectConfigByKey("isPay");
+                    if ("Y".equals(getInfoFromSqlData)) {
+                        LtkjMiddleHead middleHead = headService.getMiddleHeadByPartId(tjCustomer.getCardId());
+                        if (null != middleHead) {
+                            tjFlowingWater.setPayStasus(1L);
+                        }
+                    }
+                    tjFlowingWater.setOrderId(tjOrder.getOrderId());
+                    Date date1 = new Date(System.currentTimeMillis());
+                    String s1 = SecurityUtils.getUsername() + new SimpleDateFormat("yyMMddHHmmssSSS").format(date1);
+                    tjFlowingWater.setWaterId(PinyinUtil.getFirstLetter(tjCustomer.getCusName(), "").toUpperCase() + s1);
+
+
                     tjFlowingWater.setCopeWith(tjOrder.getTjFlowingWater().getCopeWith());
                     tjFlowingWater.setPaidIn(tjOrder.getTjFlowingWater().getPaidIn());
                     tjFlowingWater.setDiscount(tjOrder.getTjFlowingWater().getDiscount());
-//                    tjFlowingWater.setPayStasus(0L);
-                }
-            }
-            if (tjFlowingWaterService.save(tjFlowingWater)) {
-                tjOrder.setTjSerialNumber(String.valueOf(tjFlowingWater.getTjSerialNumber()));
-                tjOrderService.updateById(tjOrder);
-            }
 
-            //淇敼姣忛」鐨勫師浠风幇浠� //淇敼涓存椂琛ㄤ綋妫�鍙�
-            transitionService.updateTbTransitionPriceByCusId(tjCustomer.getCusIdcard(), discount, tjOrder.getTjNumber());
-
-            /*璋冪敤his鎺ュ彛*/
-            String config = configService.selectConfigByKey("sfkqdyhis");
-            if (null != config && config.equals("Y")) {
-                AjaxResult result = hisApiMethod.HisApiMethods(tjCustomer, tjOrder);
-                if (!result.get("code").toString().equals("200")) {
-                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-                    Object jzh = result.get("jzh");
-                    if (null != jzh && null != jzh.toString()) {
-                        hisApiMethod.ZfHisApiMethod(jzh.toString());
+                    if (isPay.equals("true")) {
+                        if (null != mallOrder) {
+                            if (mallOrder.getOrderStatus().equals(201L)) {
+                                tjFlowingWater.setCopeWith(mallOrder.getActualPrice());
+                                tjFlowingWater.setPaidIn(mallOrder.getActualPrice());
+                                tjFlowingWater.setDiscount(String.valueOf(1));
+                                tjFlowingWater.setPayStasus(1L);
+                                tjFlowingWater.setPayType(3L);
+                                MallCheckLog checkLog = new MallCheckLog();
+                                checkLog.setCheckBy(sysUser.getNickName());
+                                checkLog.setUserId(mallOrder.getUserId());
+                                checkLog.setConsignee(mallOrder.getConsignee());
+                                checkLog.setIdCard(mallOrder.getIdCard());
+                                checkLog.setOrderId(String.valueOf(mallOrder.getId()));
+                                checkLog.setOrderSn(mallOrder.getOrderSn());
+                                checkLog.setCheckTime(new Date());
+                                checkLog.setShipSn("HX" + s1);
+                                mallCheckLogService.save(checkLog);
+                                mallOrder.setOrderStatus(301L);
+                                mallOrderService.updateById(mallOrder);
+                            }
+                        } else {
+                            tjFlowingWater.setCopeWith(tjOrder.getTjFlowingWater().getCopeWith());
+                            tjFlowingWater.setPaidIn(tjOrder.getTjFlowingWater().getPaidIn());
+                            tjFlowingWater.setDiscount(tjOrder.getTjFlowingWater().getDiscount());
+                            //                    tjFlowingWater.setPayStasus(0L);
+                        }
                     }
-                    log.info("璇ョ櫥璁颁汉鎸傚彿澶辫触, 灏辫瘖鍙蜂负: " + tjOrder.getCardId());
-                    return AjaxResult.error("鎸傚彿澶辫触!" + result.get("msg").toString());
+                    if (tjFlowingWaterService.save(tjFlowingWater)) {
+                        tjOrder.setTjSerialNumber(String.valueOf(tjFlowingWater.getTjSerialNumber()));
+                        tjOrderService.updateById(tjOrder);
+                    }
+
+                    //淇敼姣忛」鐨勫師浠风幇浠� //淇敼涓存椂琛ㄤ綋妫�鍙�
+                    transitionService.updateTbTransitionPriceByCusId(tjCustomer.getCusIdcard(), discount, tjOrder.getTjNumber());
+
+                    /*璋冪敤his鎺ュ彛*/
+                    String config = configService.selectConfigByKey("sfkqdyhis");
+                    if (null != config && config.equals("Y")) {
+                        AjaxResult result = hisApiMethod.HisApiMethods(tjCustomer, tjOrder);
+                        if (!result.get("code").toString().equals("200")) {
+                            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                            Object jzh = result.get("jzh");
+                            if (null != jzh && null != jzh.toString()) {
+                                hisApiMethod.ZfHisApiMethod(jzh.toString());
+                            }
+                            log.info("璇ョ櫥璁颁汉鎸傚彿澶辫触, 灏辫瘖鍙蜂负: " + tjOrder.getCardId());
+                            return AjaxResult.error("鎸傚彿澶辫触!" + result.get("msg").toString());
+                        }
+
+                        log.info("璇ョ櫥璁颁汉鐨刪is灏辫瘖鍙锋槸: " + tjOrder.getCardId());
+                        //鍥綋
+                        if ("1".equals(tjOrder.getTjType())) {
+                            asyncService.ttextracted(tjOrder, tjCustomer, sysUser, tjReservation, tjFlowingWater);
+                        }
+                        //涓汉
+                        if ("2".equals(tjOrder.getTjType())) {
+                            //asyncService.newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
+                            newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
+                        }
+                        // 鏌ヨ 瀵规帴Lis銆丳acs鐢宠濡傛灉绫诲瀷鍖呭惈鍦ㄩ厤缃唴鍒欎娇鐢ㄥ鎺is銆乸acs
+                        if (lisApiMethod.isUseLisAndPacsRegister(tjOrder)) {
+                            // 杩欐槸涓婇潰涓汉鏂规硶寮曞叆鏁版嵁
+                            newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
+                            AjaxResult ajaxResult = hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder, sysUser, result);
+                            if (!ajaxResult.get("code").toString().equals("200")) return ajaxResult;
+                        }else {
+                            hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
+                        }
+//                        hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
+                        return AjaxResult.success(tjNumber);
+                    } else {
+                        tjCustomer.setCardId(tjOrder.getTjNumber());
+                        tjCustomerService.updateById(tjCustomer);
+                        transitionService.updateCardIdByTjNumAndIdCard(tjCustomer.getCusIdcard(), tjOrder.getTjNumber(), tjOrder.getTjNumber());
+                        tjOrder.setCardId(tjOrder.getTjNumber());
+                        tjOrderService.updateById(tjOrder);
+                    }
+
+                    //鍥綋
+                    if ("1".equals(tjOrder.getTjType())) {
+                        asyncService.ttextracted(tjOrder, tjCustomer, sysUser, tjReservation, tjFlowingWater);
+                    }
+                    //涓汉
+                    if ("2".equals(tjOrder.getTjType())) {
+                        //asyncService.newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
+                        newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
+                    }
+                    return AjaxResult.success(tjNumber);
                 }
 
-                log.info("璇ョ櫥璁颁汉鐨刪is灏辫瘖鍙锋槸: " + tjOrder.getCardId());
-                //鍥綋
-                if ("1".equals(tjOrder.getTjType())) {
-                    asyncService.ttextracted(tjOrder, tjCustomer, sysUser, tjReservation, tjFlowingWater);
-                }
-                //涓汉
-                if ("2".equals(tjOrder.getTjType())) {
-                    //asyncService.newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
-                    newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
-                }
-                // 鏌ヨ 瀵规帴Lis銆丳acs鐢宠濡傛灉绫诲瀷鍖呭惈鍦ㄩ厤缃唴鍒欎娇鐢ㄥ鎺is銆乸acs
-//                String useLisAndPacsRegisterDictTeam = configService.selectConfigByKey("use_lis_and_pacs_register_dict_team");
-//                String[] split = useLisAndPacsRegisterDictTeam.split(",");
-//                List<String> list = Arrays.asList(split);
-//                if (list.contains(tjOrder.getTjType())) {
-//                    List<TbTransition> detailList = tbTransitionService.getTbTransitionListByCusId(tjCustomer.getCusIdcard(),tjOrder.getCardId());
-//                    pacsApiMethodService.save(tjOrder,tjCustomer,detailList);
-//                    lisApiMethod.save(tjOrder,tjCustomer,detailList);
-//                }else {
-//                    hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
-//                }
-
-                hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
-
-                return AjaxResult.success(tjNumber);
-            } else {
-                tjCustomer.setCardId(tjOrder.getTjNumber());
-                tjCustomerService.updateById(tjCustomer);
-                transitionService.updateCardIdByTjNumAndIdCard(tjCustomer.getCusIdcard(), tjOrder.getTjNumber(), tjOrder.getTjNumber());
-                tjOrder.setCardId(tjOrder.getTjNumber());
-                tjOrderService.updateById(tjOrder);
+                return AjaxResult.error();
             }
-
-
-            //鍥綋
-            if ("1".equals(tjOrder.getTjType())) {
-                asyncService.ttextracted(tjOrder, tjCustomer, sysUser, tjReservation, tjFlowingWater);
-            }
-            //涓汉
-            if ("2".equals(tjOrder.getTjType())) {
-                //asyncService.newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
-                newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
-            }
-            return AjaxResult.success(tjNumber);
+        } finally {
+            lock.unlock();
         }
         return AjaxResult.error();
     }
@@ -1116,7 +1133,7 @@
         SysUser sysUser = UserHoder.getLoginUser().getUser();
         List<String> cusIds = daoDto.getCusIds();
         ArrayList<String> tjNumbers = new ArrayList<>();
-        if (null != cusIds && cusIds.size() > 0) {
+        if (null != cusIds && !cusIds.isEmpty()) {
             ExecutorService threadPools = Executors.newFixedThreadPool(cusIds.size());
             for (String cusId : cusIds) {
                 threadPools.execute(new Runnable() {
@@ -1129,7 +1146,7 @@
             LambdaQueryWrapper<TjCustomer> wq = new LambdaQueryWrapper<>();
             wq.in(TjCustomer::getCusIdcard, cusIds);
             List<Long> list = tjCustomerService.list(wq).stream().map(TjCustomer::getCusId).collect(Collectors.toList());
-            if (list.size() > 0) {
+            if (!list.isEmpty()) {
 //                ExecutorService threadPool = Executors.newFixedThreadPool(list.size());
                 ThreadPoolTaskExecutor executor = threadPoolConfig.threadPoolTaskExecutor();
                 for (Long aLong : list) {
@@ -2541,6 +2558,7 @@
             customer.setCardId("0");
             tjCustomerService.updateById(customer);
             String configByKey = configService.selectConfigByKey("sfkqdyhis");
+            tjSamplingMapper.deleteByTjNumAndCusId(tjNum,order.getUserId());
             if (configByKey.equals("Y")) {
 
                 HashMap<String, Object> hisRequestParams = new HashMap<>();
@@ -2559,7 +2577,7 @@
                         return AjaxResult.error("鎾ら攢澶辫触,璇ヤ汉鍛樺凡缂磋垂,璇峰厛閫�璐�!");
                     }
                 }
-                boolean zfHisApiMethods = hisApiMethod.ZfHisApiMethods(null, order);
+                boolean zfHisApiMethods = hisApiMethod.ZfHisApiMethods(null, order, lisApiMethod.isUseLisAndPacsRegister(order));
                 if (zfHisApiMethods) {
                     return AjaxResult.success("鎾ら攢鎴愬姛");
                 } else {
@@ -2568,7 +2586,6 @@
                 }
 
             }
-            return AjaxResult.success("鎾ら攢鎴愬姛!!!");
         }
         return AjaxResult.success("绛惧埌璁板綍涓嶅瓨鍦�!");
     }
@@ -2705,7 +2722,9 @@
     @Transactional
     public AjaxResult revokeTjOrderByTjCardId(@RequestParam @ApiParam(value = "灏辫瘖鍙�") String cardId) {
 
-        TjOrder order = new TjOrder();
+        LambdaQueryWrapper<TjOrder> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(TjOrder::getCardId, cardId);
+        TjOrder order = tjOrderService.getOne(queryWrapper);
         order.setCardId(cardId);
         String configByKey = configService.selectConfigByKey("sfkqdyhis");
         if (configByKey.equals("Y")) {
@@ -2725,7 +2744,7 @@
                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                 return AjaxResult.error("鎾ら攢澶辫触,闂ㄨ瘖鎮h�呰垂鐢ㄦ竻鍗曚俊鎭笉涓虹┖");
             } else {
-                boolean zfHisApiMethods = hisApiMethod.ZfHisApiMethods(null, order);
+                boolean zfHisApiMethods = hisApiMethod.ZfHisApiMethods(null, order, lisApiMethod.isUseLisAndPacsRegister(order));
                 if (zfHisApiMethods) {
                     return AjaxResult.success("鎾ら攢鎴愬姛", map);
                 } else {
@@ -2795,10 +2814,11 @@
 
     @PostMapping("/revokeBlProByBldhAndTjh")
     @ApiOperation(value = "鏍规嵁琛ュ綍鍗曞彿鍜屼綋妫�鍙峰垹闄よ褰�")
-    @Transactional
+//    @Transactional
     public AjaxResult revokeBlProByBldhAndTjh(@RequestBody TjProBlDto dto) {
 
         if (null == dto.getBldhs() || dto.getBldhs().size() == 0) {
+            log.info("璇烽�夋嫨瑕佹挙閿�鐨勮ˉ褰曢」鐩�");
             return AjaxResult.error("璇烽�夋嫨瑕佹挙閿�鐨勮ˉ褰曢」鐩�");
         }
 
@@ -2806,42 +2826,66 @@
         if (null != order) {
             String configByKey = configService.selectConfigByKey("sfkqdyhis");
             if (null != configByKey && configByKey.equals("Y")) {
+                log.info("dto鐨勬暟鎹槸" + JSONUtil.toJsonStr(dto));
                 HashMap<String, Object> hisRequestParams = new HashMap<>();
                 hisRequestParams.put("patientId", order.getCardId());
                 AjaxResult queryPay = hisApiGetMethodService.getHISDataNew("QueryPay", hisRequestParams);
+                log.info("queryPay ->{}",JSONUtil.toJsonStr(queryPay));
                 if (Integer.parseInt(queryPay.get("code").toString()) == 200) {
                     List<Map<String, String>> data = (List<Map<String, String>>) queryPay.get("data");
-                    BigDecimal cateFeeAll = BigDecimal.ZERO;
-                    List<String> advIds = new ArrayList<>();
-                    for (Map<String, String> datum : data) {
-                        String advId = datum.get("Adv_Id").split("_")[1];
-                        BigDecimal cateFee = new BigDecimal(datum.get("CateFee"));
-                        cateFeeAll = cateFeeAll.add(cateFee);
-                        advIds.add(advId);
+                    log.info("data鐨勬暟鎹槸" + JSONUtil.toJsonStr(data));
+//                    BigDecimal cateFeeAll = BigDecimal.ZERO;
+//                    List<String> advIds = new ArrayList<>();
+                    List<LtkjJianchajianyanTree> buLuXmXinXi = tjOrderService.getBuLuXmXinXi(dto.getBldhs(), order.getCardId());
+                    log.info("buLuXmXinXi鐨勫�间负:==========" + buLuXmXinXi);
+                    if (null != buLuXmXinXi && !buLuXmXinXi.isEmpty()) {
+                        for (Map<String, String> datum : data) {
+                            for (LtkjJianchajianyanTree tree : buLuXmXinXi) {
+                                String advId = datum.get("Adv_Id").split("_")[1];
+                                log.info("advid鐨勫�间负:==========" + advId);
+                                log.info("tree鐨勫�间负:==========" + advId);
+                                BigDecimal cateFee = new BigDecimal(datum.get("CateFee"));
+                                log.info("cateFee鐨勫�间负:==========" + cateFee);
+                                log.info("tree.getFyhj()鐨勫�间负:==========" + tree.getFyhj());
+                                if (tree.getSqdh().equals(advId) && cateFee.compareTo(new BigDecimal(tree.getFyhj())) == 0) {
+                                    log.info("璇ラ」鐩凡缂磋垂涓嶅彲鎾ら攢");
+                                    return AjaxResult.error("璇ラ」鐩凡缂磋垂涓嶅彲鎾ら攢!!!");
+                                }
+                            }
+                        }
                     }
-                    if (advIds.containsAll(dto.getBldhs()) && cateFeeAll.compareTo(BigDecimal.ZERO) != 0) {
-                        return AjaxResult.error("鏀归」鐩凡缂磋垂涓嶅彲鎾ら攢!!!");
-                    }
-
                 }
+
                 boolean b = hisApiMethod.ZfBlXm(dto.getBldhs(), order);
                 if (!b) {
                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+                    log.info("鎾ら攢澶辫触,璋冪敤浣滃簾鍑虹幇澶辫触");
                     return AjaxResult.error("鎾ら攢澶辫触,璋冪敤浣滃簾鍑虹幇澶辫触");
                 }
             }
-            for (String bldh : dto.getBldhs()) {
-                remarkService.deleteTjOrderDetailByjxbz(bldh);
-                tjOrderDetailService.deleteTjOrderDetailByjxbz(bldh);
-                tjFlowingWaterService.deleteTjOrderDetailByjxbz(bldh);
-                transitionService.deleteTjOrderDetailByjxbz(bldh);
-                blService.remove(new LambdaQueryWrapper<TjProBl>().eq(TjProBl::getTjh, dto.getTjh()).eq(TjProBl::getBldh, bldh));
+            try {
+                extracted(dto,order);
+            } catch (Exception e) {
+                log.info("鎾ら攢澶辫触,鍒犻櫎琛ㄥけ璐�");
+                return AjaxResult.error("鎾ら攢澶辫触,鍒犻櫎琛ㄥけ璐�!");
             }
             return AjaxResult.success();
         }
         return AjaxResult.error();
     }
 
+//    @Transactional(propagation =Propagation.REQUIRES_NEW)
+    public void extracted(TjProBlDto dto,TjOrder order) {
+        for (String bldh : dto.getBldhs()) {
+            remarkService.deleteTjOrderDetailByjxbz(bldh);
+            tjOrderDetailService.deleteTjOrderDetailByjxbz(bldh);
+            tjFlowingWaterService.deleteTjOrderDetailByjxbz(bldh);
+            transitionService.deleteTjOrderDetailByjxbz(bldh);
+            blService.remove(new LambdaQueryWrapper<TjProBl>().eq(TjProBl::getTjh, dto.getTjh()).eq(TjProBl::getBldh, bldh));
+        }
+        tjSamplingMapper.deleteByTjNumAndCusIdAndJxbz(dto.getTjh(),order.getUserId(),dto.getBldhs());
+    }
+
 
     @PostMapping("/addYaoPinShenQing")
     @ApiOperation(value = "鑽搧淇℃伅鐢宠")

--
Gitblit v1.8.0