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


@@ -1,34 +1,28 @@


package com.ltkj.web.controller.system;




import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;


import javax.annotation.Resource;


import javax.servlet.ServletSecurityElement;


import javax.servlet.http.HttpServletResponse;


import javax.swing.plaf.basic.BasicScrollPaneUI;




import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.extra.pinyin.PinyinUtil;


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;


import com.ltkj.framework.config.MatchUtils;


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;


import io.swagger.annotations.ApiParam;


import lombok.extern.slf4j.Slf4j;


import org.aspectj.weaver.AjAttribute;


import org.springframework.beans.BeanUtils;


import org.springframework.security.access.prepost.PreAuthorize;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.transaction.interceptor.TransactionAspectSupport;


import org.springframework.web.bind.annotation.*;


import com.ltkj.common.annotation.Log;


import com.ltkj.common.core.controller.BaseController;


@@ -68,6 +62,14 @@


    private ISysConfigService configService;


    @Autowired


    private SamplingServiceApi samplingService;


    @Autowired


    private HisApiMethod hisApiMethod;


    @Autowired


    private LtkjJianchajianyanTreeService treeService;


    @Autowired


    private TbLisSqService tbLisSqService;


    @Autowired


    private LtkjJfxmgljyxmzdService jfxmgljyxmzdService;




    /**


     * 查询体检采样管理列表


@@ -195,7 +197,7 @@


     * 获取采样客户列表


     *


     * @param isSignFor


     * @param tjNum


     * @param tjNumber


     * @param name


     * @param pageNum


     * @param pageSize


@@ -206,8 +208,9 @@


    @GetMapping("/getCusList")


    @ApiOperation(value = "获取采样客户列表")


    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 tjNumber,


                                 @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,


@@ -215,13 +218,24 @@


        Page<TjSampling> samplingPage = new Page<>(pageNum, pageSize);


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


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


        if (null != tjNum && StrUtil.isNotBlank(tjNum))


            wrapper.like(TjSampling::getTjNum, tjNum);


        if (null != tjNumber && StrUtil.isNotBlank(tjNumber))


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


        if (null != name && StrUtil.isNotBlank(name))


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


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


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


        wrapper.groupBy(TjSampling::getCusId);


        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::getTjNum);


        wrapper.orderByDesc(TjSampling::getCreateTime);


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


        Page<TjSampling> page = tjSamplingService.page(samplingPage, wrapper);


@@ -230,6 +244,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 +273,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 +350,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,7 +367,7 @@


        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));


@@ -398,6 +485,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);


    }


}