路泰科技体检后端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhaowenxuan
2025-03-07 0ebc42ccd16d2e8ea1a5d815253021c91cc2836f 
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java


@@ -1,5 +1,6 @@


package com.ltkj.web.controller.system;




import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;


import javax.annotation.Resource;


@@ -10,7 +11,10 @@


import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.extra.pinyin.PinyinUtil;


import cn.hutool.json.JSONArray;


import cn.hutool.json.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.ltkj.common.core.redis.RedisCache;


import com.ltkj.common.utils.IdUtils;


@@ -18,6 +22,7 @@


import com.ltkj.hosp.domain.*;


import com.ltkj.hosp.service.*;


import com.ltkj.system.service.ISysConfigService;


import com.ltkj.web.controller.his.HisApiMethod;


import com.ltkj.web.controller.lis.LisApiMethod;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


@@ -68,6 +73,14 @@


    private ISysConfigService configService;


    @Autowired


    private SamplingServiceApi samplingService;


    @Autowired


    private HisApiMethod hisApiMethod;


    @Autowired


    private LtkjJianchajianyanTreeService treeService;


    @Autowired


    private TbLisSqService tbLisSqService;


    @Autowired


    private LtkjJfxmgljyxmzdService jfxmgljyxmzdService;




    /**


     * 查询体检采样管理列表


@@ -208,6 +221,7 @@


    public AjaxResult getCusList(@RequestParam(defaultValue = "1") @ApiParam(value = "0是1否") Integer isSignFor,


                                 @RequestParam(required = false) @ApiParam(value = "体检号") String tjNum,


                                 @RequestParam(required = false) @ApiParam(value = "客户姓名") String name,


                                 @RequestParam(required = false) @ApiParam(value = "单位") String dw,


                                 @ApiParam(value = "页码数(默认1)") @RequestParam(defaultValue = "1") Integer pageNum,


                                 @ApiParam(value = "显示条数(默认10)") @RequestParam(defaultValue = "10") Integer pageSize,


                                 @ApiParam(value = "开始时间") @RequestParam(required = false) String beginTime,


@@ -221,6 +235,17 @@


            wrapper.like(TjSampling::getCusName, name);


        if (null != beginTime && null != endTime && StrUtil.isNotBlank(beginTime) && StrUtil.isNotBlank(endTime))


            wrapper.between(TjSampling::getApplicationTime, beginTime, endTime);


        if (StrUtil.isNotBlank(dw)){


            LambdaQueryWrapper<TjOrder> wqq=new LambdaQueryWrapper<>();


            wqq.like(TjOrder::getFirmId,dw);


            wqq.select(TjOrder::getTjNumber);


            List<TjOrder> orderList = orderService.list(wqq);


            if(null !=orderList && !orderList.isEmpty()){


                List<String> list = orderList.stream().map(TjOrder::getTjNumber).collect(Collectors.toList());


                wrapper.in(TjSampling::getTjNum, list);


            }


        }




        wrapper.groupBy(TjSampling::getCusId);


        wrapper.orderByDesc(TjSampling::getCreateTime);


//        wrapper.last("LIMIT " + (pageNum - 1) * pageSize + "," + pageSize);


@@ -230,6 +255,8 @@


        for (TjSampling tjSampling : list) {


            TjCustomer customer = customerService.getById(tjSampling.getCusId());


            if(null !=customer){


                TjOrder order = orderService.getOrderByTjNum(tjSampling.getTjNum());


                customer.setCompName(order.getFirmName());


                customer.setCusName(customer.getCusName());


                customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone()));


                customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard()));


@@ -257,6 +284,76 @@


        if (tjNumber == null || StrUtil.isBlank(tjNumber))


            return AjaxResult.error("参数错误,未传参数");


        LambdaQueryWrapper<TjSampling> wrapper = new LambdaQueryWrapper<>();


        String config = configService.selectConfigByKey("sfkqdyhis");


        if (config.equals("Y")){


//            LambdaQueryWrapper<TjSampling> wrapper6 = new LambdaQueryWrapper<>();


//            wrapper6.eq(TjSampling::getTjNum, tjNumber);


//            wrapper6.eq(TjSampling::getIsSignFor,isSignFor);


//            wrapper6.and(i -> i.isNull(TjSampling::getParentId).or().eq(TjSampling::getIsMerge,1));


//            wrapper6.isNull(TjSampling::getJyxh);


//            List<TjSampling> list1 = tjSamplingService.list(wrapper6);


//            if (!list1.isEmpty()){


            if (true){


                LambdaQueryWrapper<TjOrder> wrapper1 = new LambdaQueryWrapper<>();


                wrapper1.eq(TjOrder::getTjNumber,tjNumber);


                TjOrder tjOrder = orderService.getOne(wrapper1);


                hisApiMethod.Getlabreginfoinfo(tjOrder.getCardId(),new SimpleDateFormat("yyyy-MM-dd").format(tjOrder.getCreateTime()));


            LambdaQueryWrapper<TbLisSq> wrapper2 = new LambdaQueryWrapper<>();


            wrapper2.eq(TbLisSq::getCardId,tjOrder.getCardId());


            List<TbLisSq> list = tbLisSqService.list(wrapper2);


            for (TbLisSq lisSq : list) {


                if (!lisSq.getSqdbh().contains("jk"))


                    continue;


                String jyxmdm = lisSq.getJyxmdm();


                LambdaQueryWrapper<TjProject> wrapper4 = new LambdaQueryWrapper<>();


                wrapper4.eq(TjProject::getLisXmbm,jyxmdm);


                TjProject project = projectService.getOne(wrapper4);


                if (project != null){


                    LambdaUpdateWrapper<TjSampling> wrapper5 = new LambdaUpdateWrapper<>();


                    String jyxh = "";


                    if (StrUtil.isNotBlank(lisSq.getJyxhHb()))


                        jyxh = lisSq.getJyxhHb();


                    else jyxh = lisSq.getJyxh();


                    wrapper5.set(TjSampling::getJyxh,jyxh);


                    wrapper5.set(TjSampling::getJyxmdm,lisSq.getJyxmdm());


                    wrapper5.eq(TjSampling::getProId,project.getProParentId());


                    wrapper5.eq(TjSampling::getTjNum,tjNumber);


                    tjSamplingService.update(wrapper5);


                }


            }




//                JSONArray array = hisApiMethod.Getlabreginfoinfo(tjOrder.getCardId());


//                if (array != null && !array.isEmpty()){


//                    for (Object o : array) {


//                        JSONObject jsonObject = (JSONObject) o;


//                        String sqdh = jsonObject.getStr("sqdh");


//                        String jyxh = jsonObject.getStr("jyxh");


//                        LambdaQueryWrapper<LtkjJianchajianyanTree> wrapper2 = new LambdaQueryWrapper<>();


//                        wrapper2.eq(LtkjJianchajianyanTree::getCardId,tjOrder.getCardId());


//                        wrapper2.eq(LtkjJianchajianyanTree::getType,"检验");


//                        wrapper2.eq(LtkjJianchajianyanTree::getSqdh,sqdh);


//                        List<LtkjJianchajianyanTree> list = treeService.list(wrapper2);


//                        List<String> hisXms = list.stream().map(LtkjJianchajianyanTree::getHisXmdm).collect(Collectors.toList());


//                        LambdaQueryWrapper<TjProject> wrapper3 = new LambdaQueryWrapper<>();


//                        wrapper3.in(TjProject::getHisXmbm,hisXms);


//                        wrapper3.ne(TjProject::getProParentId,0);


//                        wrapper3.groupBy(TjProject::getProParentId);


//                        List<Long> proParentIds = projectService.list(wrapper3).stream().map(TjProject::getProParentId).collect(Collectors.toList());


//                        LambdaQueryWrapper<TjProject> wrapper4 = new LambdaQueryWrapper<>();


//                        wrapper4.in(TjProject::getProId,proParentIds);


//                        List<Long> proIds = projectService.list(wrapper4).stream().map(TjProject::getProId).collect(Collectors.toList());


//                        LambdaUpdateWrapper<TjSampling> wrapper5 = new LambdaUpdateWrapper<>();


//                        wrapper5.set(TjSampling::getJyxh,jyxh);


//                        wrapper5.in(TjSampling::getProId,proIds);


//                        wrapper5.eq(TjSampling::getTjNum,tjNumber);


//                        tjSamplingService.update(wrapper5);


//                    }


//                }


            }


        }




//        if (config.equals("Y"))


//            wrapper.eq(TjSampling::getJyxh,"");


        wrapper.eq(TjSampling::getTjNum, tjNumber);


        wrapper.eq(TjSampling::getIsSignFor,isSignFor);


        wrapper.and(i -> i.isNull(TjSampling::getParentId).or().eq(TjSampling::getIsMerge,1));


@@ -264,6 +361,7 @@


//        if (isSignFor == 1)


//            wrapper.eq(TjSampling::getIsApply,0);


        wrapper.orderByDesc(TjSampling::getIsMerge);




        List<TjSampling> list = tjSamplingService.list(wrapper);


        if (list.isEmpty()){


            logger.info("jtNum ->{}",tjNumber);


@@ -280,16 +378,17 @@


        if (list.size() >= 2) {


            // 进行合并


            List<String> stringList = list.stream().map(TjSampling::getId).collect(Collectors.toList());


            log.info("提取id ->{}",stringList);


//            log.info("提取id ->{}",stringList);


            for (String s : stringList) {


                if (tjSamplingService.isMergeItem(s) != 0) {


                    list.removeIf(item -> Objects.equals(item.getId(), s));


                }


            }


            String lis_tmh_prefix = configService.selectConfigByKey("make_lis_tmh_prefix");


            Map<String, List<TjSampling>> map = list.stream().filter(i->StrUtil.isNotBlank(i.getSpecimenTypeCode())).collect(Collectors.groupingBy(item -> item.getSpecimenTypeCode()));


            for (Map.Entry<String, List<TjSampling>> entry : map.entrySet()) {


                List<TjSampling> entryValue = entry.getValue();


                tjSamplingService.mergeCaiYangTran(entryValue.stream().map(TjSampling::getId).collect(Collectors.toList()));


                tjSamplingService.mergeCaiYangTran(entryValue.stream().map(TjSampling::getId).collect(Collectors.toList()),lis_tmh_prefix);


            }


        }


        wrapper = new LambdaQueryWrapper<>();


@@ -311,7 +410,8 @@


    @PostMapping("/mergeCaiYang")


    @ApiOperation(value = "采样登记合并项目接口")


    public AjaxResult mergeCaiYang(@RequestBody List<String> ids) {


        return tjSamplingService.mergeCaiYangTran(ids);


        String lis_tmh_prefix = configService.selectConfigByKey("make_lis_tmh_prefix");


        return tjSamplingService.mergeCaiYangTran(ids,lis_tmh_prefix);


    }






@@ -396,6 +496,6 @@


    public AjaxResult confirmSampling(@RequestBody List<String> ids) {


        String config = configService.selectConfigByKey("sfkqdyhis");


        String mergeRequest = configService.selectConfigByKey("use_lis_pacs_is_auto_merge_request");


        return samplingService.confirm(ids,config,mergeRequest);


        return samplingService.confirmApi(ids,config,mergeRequest);


    }


}