zjh20250215

zjh

2025-02-15 dc3cb5dea834cde14d1b527c22b35f1d5faebd5a

 ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java

@@ -17,6 +17,7 @@
import com.ltkj.common.utils.IdUtils;
import com.ltkj.common.utils.StringUtils;
import com.ltkj.framework.config.MatchUtils;
import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;
import com.ltkj.hosp.domain.*;
import com.ltkj.hosp.hisDto.*;
import com.ltkj.hosp.mapper.TjSamplingMapper;
@@ -248,7 +249,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void ttextracted(TjOrder tjOrder, TjCustomer tjCustomer, SysUser sysUser, TjReservation tjReservation, TjFlowingWater tjFlowingWater) {

        tjAskMedicalHistoryService.updateTjAskMedicalHistoryByCusId(tjOrder.getTjNumber(), sysUser.getNickName(), String.valueOf(sysUser.getUserId()), String.valueOf(tjCustomer.getCusId()));
@@ -360,7 +361,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void collectFees(TjOrder order, List<TjConsumables> list2, List<TbTransition> tbTransitionList, SysUser sysUser, String discount) {
//        orderRemarkService.deletedOrderRemarkByTjNum(order.getTjNumber());
//        redisCache.deleteObject("getOrderDetailByProParentId" + order.getTjNumber());
@@ -543,7 +544,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void abandonCheck(String tjNumber, TjOrder tjOrder, List<TjOrderDetail> list, SysUser sysUser) {
        for (TjOrderDetail tjOrderDetail : list) {
            LambdaQueryWrapper<TjProject> wq1 = new LambdaQueryWrapper<>();
@@ -584,8 +585,11 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void updateOrdeltile(List<TjOrderDetail> tjOrderDetailList, SysUser sysUser, TjOrder order,TjOrderRemark orderRemark) {
        String currentDataSource = DynamicDataSourceContextHolder.getDataSourceType();
        log.info("异步线程中的数据源: {}", currentDataSource);

        String deptname="";
        TjProject tjProject = projectService.getById(orderRemark.getProId());
        if(null !=tjProject){
@@ -651,7 +655,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void updateOrdeltile2(TjOrderDetail detail, SysUser sysUser) {
//        for (TjOrderDetail detail : tjOrderDetailList) {
        detail.setTjStatus(1L);
@@ -666,7 +670,7 @@
    }

    @Override
//    @Async("async")
//    //@Async("async")
//    @Transactional
    public Boolean iundividualCharges(TjFlowingWater tjFlowingWater, TjOrder order, TjCustomer customer, SysUser sysUser,String jxbz) {
        Date dates = new Date();
@@ -1809,7 +1813,7 @@
                        if (samplings.size() >= 2){
                            // 进行合并
                            List<String> stringList = samplings.stream().map(TjSampling::getId).collect(Collectors.toList());
                            log.info("提取id ->{}",stringList);
//                            log.info("提取id ->{}",stringList);
                            for (int i = 0; i < stringList.size(); i++) {
                                String s = stringList.get(i);
                                if (tjSamplingService.isMergeItem(s) != 0) {
@@ -2254,7 +2258,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void dockerSetCustomerLisByRedis(List<Long> ksproList, String ksId) {

        List<TjCustomer> yjAjaxResult = getYjAjaxResult(ksproList);
@@ -2264,14 +2268,14 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void dockerSetYjCustomerByRedis(Long orderId, Long ksId) {
        //已检(单个存入)0未检,1已检
        getDgYjAjaxResult(orderId, ksId);
    }

    @Override
    @Async("async")
    //@Async("async")
    public void dockerSetWjCustomerByRedis(Long orderId, Long ksId) {

        //未检(单个存入)0未检,1已检
@@ -2279,7 +2283,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void checkSetCustomerLisByRedis(String config) {
        List<TjCustomer> wsResult = getWsResult(config);
        List<TjCustomer> ysResult = getYsResult(config);
@@ -2289,7 +2293,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void wCScheckSetCustomerLisByRedis(List<TjOrder> orderList) {
        List<TjCustomer> customerList = new ArrayList<>();
        if (null != orderList && orderList.size() > 0) {
@@ -2324,7 +2328,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void yCScheckSetCustomerLisByRedis(List<TjOrder> orderList) {
        List<TjCustomer> customerList = new ArrayList<>();
        if (null != orderList && orderList.size() > 0) {
@@ -2360,7 +2364,7 @@


    @Override
    @Async("async")
    //@Async("async")
    public void tjRefund(List<TjProject> refundPros, String tjNum) {
        for (TjProject refundPro : refundPros) {
            LambdaQueryWrapper<TjProject> wq0 = new LambdaQueryWrapper<>();
@@ -2381,14 +2385,14 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void saveSampling() {
        redisCache.setCacheMapValue("sampling", "yqs", getYWqsResult(0));
        redisCache.setCacheMapValue("sampling", "wqs", getYWqsResult(1));
    }

    @Override
    @Async("async")
    //@Async("async")
    public void tjGoutAsync(List<QjDomainVo> domainVos, SysUser sysUser, Set<String> list) {
        Integer day = 0;
        for (QjDomainVo domainVo : domainVos) {
@@ -2470,7 +2474,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void addRedisTransitionPac(String cusId, Long pacId, List<TjPackageProject> ppList) {
        for (TjPackageProject tjPackageProject : ppList) {
            TjProject project = projectService.getById(tjPackageProject.getProId());
@@ -2509,7 +2513,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void saveRedisTransitionByPacId(String cusId,String cardId, Long pacId, List<Long> proIds) {
        if (null != pacId) {
            transitionService.saveRedisTransitionByPacId(cusId,cardId ,pacId);
@@ -2520,7 +2524,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void addRedisTransitionPro(String cusId, List<Long> proIds) {
        for (Long proId : proIds) {
            if (null != transitionService.getTbTransitionListByCusIdAndPacIdAndProId(cusId, String.valueOf(proId)) && transitionService.getTbTransitionListByCusIdAndPacIdAndProId(cusId, String.valueOf(proId)).size() > 0) {
@@ -2562,7 +2566,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getTjPackageList() {

        //男人
@@ -2576,7 +2580,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void addNewReservationConfirm(List<TjReservation> rightList) {
        if (null != rightList && rightList.size() > 0) {
            for (TjReservation reservation : rightList) {
@@ -2611,7 +2615,7 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void saveNewReservationConfirm(List<TjReservation> rightList) {
        if (null != rightList && rightList.size() > 0) {
            //创建线程池
@@ -2638,14 +2642,14 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void updateCheckType(String tjNum) {
        redisCache.setCacheMapValue("updateCheckType" + tjNum, tjNum, getAjaxResult(tjNum));
        redisCache.setHashKeyExpireTime("updateCheckType" + tjNum, 7L, TimeUnit.DAYS);
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getPrintOrderList(List<TjOrder> list) {

        redisCache.setCacheMapValue("getPrintOrderList", "0", extracted(0, list));
@@ -2654,14 +2658,14 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getDictSfxms() {
        List<DictSfxm> dictSfxm = getDictSfxm();
        redisCache.setCacheObject("getDictSfxms", dictSfxm);
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getOrderDetailByProParentId(String tjNumber, Map<String, Object> map, String proParentId) {
        if (null != map && !map.isEmpty()) {
            redisCache.setCacheMapValue("getOrderDetailByProParentId" + tjNumber, proParentId, map);
@@ -2673,13 +2677,13 @@
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getLineChart() {
        redisCache.setCacheObject("getLineChart", getLineCharts());
    }

    @Override
    @Async("async")
    //@Async("async")
    public void getPieChart() {
        redisCache.setCacheObject("getPieChart", getPieCharts());
    }