路泰科技体检后端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zjh
2025-02-26 263413a9ade62a8501acbbc60157d48ca51a9f9d 
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java


@@ -49,6 +49,7 @@




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.text.Collator;


import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;


@@ -56,6 +57,8 @@


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;


import static org.jeecg.modules.jmreport.dyndb.util.b.a;


import static org.jeecg.modules.jmreport.dyndb.util.b.e;




/**


 * @Author: 西安路泰科技有限公司/赵佳豪


@@ -122,6 +125,10 @@


    private RedissonClient redissonClient;


    @Autowired


    private ITjRulesService rulesService;


    @Autowired


    private ITjProAdvicerulesService tjProAdvicerulesService;


    @Autowired


    private TjOrderYcxmService ycxmService;






    @GetMapping ("/ceshicc")


@@ -553,7 +560,7 @@


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


@@ -561,7 +568,15 @@






                            /*同步检查 his存储过程*/


                            AjaxResult results = jcsqdService.getTjJcProByHisCall("体检中心", order.getCardId(), "''", 100, 1, "'1'");




                            String jctbfs = configService.selectConfigByKey("jctbfs");


                            AjaxResult results =null;


                            if (jctbfs.equalsIgnoreCase("Y")){


                                results = service.getHISDataNew("Getexamreportinfo", maps);


                            }else{


                                results = jcsqdService.getTjJcProByHisCall("体检中心", order.getCardId(), "''", 100, 1, "'1'");


                            }






                            DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());


                            DynamicDataSourceContextHolder.clearDataSourceType();


@@ -724,9 +739,9 @@


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


                        tbhyxm(order);


                        //同步化验项目


                        testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


//                        testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


                        //同步检查项目


                        testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


//                        testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


                        asyncService.updateCheckType(order.getTjNumber());




                    }


@@ -771,6 +786,7 @@


                                hysqd.setShrdm(jsonObject.getStr("JYYSBH"));


                                hysqd.setShrxm(jsonObject.getStr("JYYSQM"));


                                hysqd.setJybgjg(jsonObject.getStr("JYBGJG"));


                                hysqd.setCreateTime(new Date());


                                QueryWrapper<LtkjHysqd> queryWrapper = new QueryWrapper<>(hysqd);


                                List<LtkjHysqd> list = ltkjHysqdService.list(queryWrapper);


                                if (list.isEmpty())


@@ -782,10 +798,10 @@


                                }


                            }


                            //同步化验项目


                            testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


//                            testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


                        }


                        /*同步检查 his接口*/


                        if (null != jianChaBaoGaoDan && jianChaBaoGaoDan.size() > 0) {


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


                            Map<String, Object> maps = new HashMap<>();


                            maps.put("his_registration_id", order.getCardId());


                            maps.put("ksbm", "体检中心");


@@ -795,7 +811,13 @@


                            lambdaQueryWrapper.eq(HisApiConfig::getApiMethod, "Getexamreportinfo");


                            HisApiConfig hisApiConfig = hisApiConfigService.getOne(lambdaQueryWrapper);


                            /*同步检查 his存储过程*/


                            AjaxResult results = jcsqdService.getTjJcProByHisCall("体检中心", order.getCardId(), "''", 100, 1, "'1'");


                            String jctbfs = configService.selectConfigByKey("jctbfs");


                            AjaxResult results =null;


                            if (jctbfs.equalsIgnoreCase("Y")){


                                results = service.getHISDataNew("Getexamreportinfo", maps);


                            }else{


                                results = jcsqdService.getTjJcProByHisCall("体检中心", order.getCardId(), "''", 100, 1, "'1'");


                            }


                            DynamicDataSourceContextHolder.clearDataSourceType();


                            log.info("检查项目查询返回值:      " + results.toString());


                            if (Integer.parseInt(results.get("code").toString()) == 200) {


@@ -837,10 +859,11 @@


                                            jcbgd.setJcbw(objectMap.get("JCBW").toString());


                                        if (null != objectMap.get("SQRQSJ") || !objectMap.get("SQRQSJ").equals(""))


                                            jcbgd.setSqsj(objectMap.get("SQRQSJ").toString());


                                            jcbgd.setCreateTime(new Date());


                                        jcbgdService.save(jcbgd);


                                    }


                                    jcsqdService.saveLtkjExamJcsqd(order.getCardId());


                                    testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


//                                    testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


                                }else {


                                    return AjaxResult.error("检查项目暂时未出结果,请稍后同步!!!");


                                }


@@ -849,7 +872,7 @@


                        return AjaxResult.success("同步成功");


                    }


                    //化验


                    testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


//                    testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), doctorId);


                    //检查


                    jcsqdService.saveLtkjExamJcsqd(order.getCardId());


                    return AjaxResult.success("同步成功");


@@ -900,6 +923,7 @@


                bgd.setShys(js.getStr("SHRBH"));


                bgd.setShysmc(js.getStr("SHRXM"));


                bgd.setYcbz(js.getStr("YCTS"));


                bgd.setCreateTime(new Date());


//                            bgd.setTpurl(js.getStr(""));


                QueryWrapper<LtkjHybgd> queryWrapper = new QueryWrapper<>(bgd);


                List<LtkjHybgd> list = ltkjHybgdService.list(queryWrapper);


@@ -954,7 +978,7 @@




    private void tbhyxm(TjOrder order) {


        List<LtkjHysqd> one = testMapper.getHysqdByTmh(order.getCardId());


        if (one != null && one.size() > 0) {


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


            for (LtkjHysqd ltkjHysqd : one) {


                ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(ltkjHysqd.getTjh(), ltkjHysqd.getTmh());


                ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(ltkjHysqd.getTmh());


@@ -963,7 +987,7 @@


                    ltkjHysqdService.save(ltkjHysqd);


                    DynamicDataSourceContextHolder.clearDataSourceType();


                    List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh());


                    if (one1 != null && one1.size() > 0) {


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


                        DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());


                        ltkjHybgdService.saveBatch(one1);


                        DynamicDataSourceContextHolder.clearDataSourceType();


@@ -1529,7 +1553,9 @@


                                tjOrderDetail.setProResult(tjOrderDetail.getProResult());


                            }




                            dels.add(tjOrderDetail);


                            if(remark.getOrgType().equals(tjOrderDetail.getOrgType())){


                                dels.add(tjOrderDetail);


                            }


                        }


                    }


                    String summary = remark.getSummary();


@@ -1542,6 +1568,12 @@


                    if (dels.isEmpty()) {


                        continue;


                    }


                    dels=dels.stream().sorted(Comparator.comparing(TjOrderDetail::getProName, Collator.getInstance(Locale.CHINA))).collect(Collectors.toList());


                    dels = dels.stream()


                                .sorted(Comparator.comparingInt(


                                        tjPdfVO -> tjPdfVO.getProName().length() // 根据名字的长度排序


                                ))


                                .collect(Collectors.toList());


                    parent.put("sons", dels);


                    parent.put("remark", remark.getRemark());


                    parent.put("jgbx", remark.getJgbx());


@@ -1575,7 +1607,7 @@


    @PostMapping ("/checkUpdateOrderRemark")


    @ApiOperation (value = "总检修改备注接口")


    public AjaxResult checkUpdateOrderRemark(@RequestBody List<UpdateOrderRemarkVo> updateOrderRemarkVos) {


        if (null != updateOrderRemarkVos && updateOrderRemarkVos.size() > 0) {


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


            for (UpdateOrderRemarkVo remarkVo : updateOrderRemarkVos) {


                LambdaQueryWrapper<TjOrderRemark> wqm = new LambdaQueryWrapper<>();


                wqm.eq(TjOrderRemark::getTjNumber, remarkVo.getTjNumber());


@@ -1631,18 +1663,90 @@


    @ApiOperation (value = "总检查看异常项目接口")


    public AjaxResult getzongjianyishengchakanyichangxiangmu(@RequestParam String tjNum) {


        if (StrUtil.isNotBlank(tjNum)) {


            return zongjianyishengchakanyichangxiangmu(tjNum);


            TjOrder one = orderService.getOrderByTjNum(tjNum);




            if (one == null) {


                return AjaxResult.error("暂无数据！！");


            }




        LambdaQueryWrapper<TjOrderYcxm> wq=new LambdaQueryWrapper<>();


        wq.eq(TjOrderYcxm::getTjh,tjNum);


        List<TjOrderYcxm> list = ycxmService.list(wq);


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


            Collections.reverse(list);


            Map<String, List<TjOrderYcxm>> map = list.stream().collect(Collectors.groupingBy(TjOrderYcxm::getParentName));


            List<Map<String, Object>> maps = new ArrayList<>();


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


                Map<String, Object> parent = new HashMap<>();


                List<TjOrderDetail> dels = new ArrayList<>();


                for (TjOrderYcxm ycxm : entry.getValue()) {


                    TjOrderDetail detail=new TjOrderDetail();


                    detail.setOrderDetailId(Long.valueOf(ycxm.getId()));


                    detail.setProName(ycxm.getJcxm());


                    detail.setProResult(ycxm.getJcjg());


                    detail.setStanId(ycxm.getCkfw());


                    detail.setProAdvice(ycxm.getDw());


                    List<Map<String,Object>> btnrlist=new ArrayList<>();


                    String jynr = ycxm.getJynr();


                    JSONArray array = JSONUtil.parseArray(jynr);


                    for (Object object : array) {


                        Map<String,Object> objectMap=new HashMap<>();


                        JSONObject jsonObject = (JSONObject) object;


                        String bt = jsonObject.getStr("bt");


                        String nr = jsonObject.getStr("nr");


                        objectMap.put("bt",bt);


                        objectMap.put("nr",nr);


                        if(null !=bt || null !=nr) btnrlist.add(objectMap);


                    }


                    detail.setAdvices(btnrlist);


                    dels.add(detail);


                }




                    parent.put("proName",entry.getKey());


                    parent.put("jyjc",entry.getValue().get(0).getJyjc());


                    parent.put("sone",dels);


                    maps.add(parent);


            }


            List<Map<String, Object>> mapList = zongjianyishengchakanyichangxiangmu(tjNum);






            List<Map<String, Object>> collect = mapList.stream()


                    .filter(b -> maps.stream()


                            .noneMatch(a -> a.get("proName").equals(b.get("proName"))))  // 过滤掉在 maps 中存在的相同元素


                    .collect(Collectors.toList());


            if(!collect.isEmpty()){


                maps.addAll(collect);


            }


            if(!maps.isEmpty()){


                List<Map<String, Object>> collect1 = maps.stream()


                        .sorted((map1, map2) -> map2.get("proName").toString().compareTo(map1.get("proName").toString()))


                        .collect(Collectors.toList());


                return AjaxResult.success(collect1);


            }


           return AjaxResult.success(maps);


        }else {


            List<Map<String, Object>> mapList = zongjianyishengchakanyichangxiangmu(tjNum);


//            if(mapList.isEmpty()){


//                return AjaxResult.success("暂无数据");


//            }


            return AjaxResult.success(mapList);


        }




//            return zongjianyishengchakanyichangxiangmu(tjNum);


        }


        return AjaxResult.error();


    }




    private AjaxResult zongjianyishengchakanyichangxiangmu(String tjNumber) {


//        asyncService.updateCheckType(tjNumber);


        TjOrder one = orderService.getOrderByTjNum(tjNumber);


    @GetMapping ("/delzongjianyishengchakanyichangxiangmu")


    @ApiOperation (value = "总检删除异常项目接口")


    public AjaxResult delzongjianyishengchakanyichangxiangmu(@RequestParam String id) {


        ycxmService.removeById(id);


        return AjaxResult.success();


    }




        if (one == null) {


            return AjaxResult.error("暂无数据！！");


        }


    private List<Map<String, Object>> zongjianyishengchakanyichangxiangmu(String tjNumber) {


//        asyncService.updateCheckType(tjNumber);




        List<TjOrderRemark> remarkList = orderRemarkService.getzongjianyishengchakanyichangxiangmu(tjNumber);


        List<TjOrderDetail> tjOrderDetails = detailService.getzongjianyishengchakanyichangxiangmu(tjNumber);


        List<Map<String, Object>> list = new ArrayList<>();


@@ -1654,10 +1758,31 @@


                    for (TjOrderDetail tjOrderDetail : tjOrderDetails) {


                        if (remark.getProsId().equals(tjOrderDetail.getProsId())) {


                            if(null !=tjOrderDetail.getProId()&& null !=tjOrderDetail.getYcbz()){


                                List<Map<String,Object>> maps= rulesService.getyichangxiangmujianyiguize(tjOrderDetail.getProId().toString(),"",tjOrderDetail.getYcbz(),tjNumber);


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


                                    tjOrderDetail.setAdvices(maps);


                                if(!tjOrderDetail.getDeptId().equals("2")){


                                    List<Map<String,Object>> maps= rulesService.getyichangxiangmujianyiguize(tjOrderDetail.getProId().toString()


                                            ,"",tjOrderDetail.getYcbz().replaceAll(" ", ""),tjNumber


                                            ,tjOrderDetail.getProName().replaceAll("[（(][^）)]*[）)]", "")


                                                    .replaceAll("[ 测定检测]","")


                                            ,tjOrderDetail.getProResult());


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


                                        tjOrderDetail.setAdvices(maps);


                                    }


                                }else {


                                    String[] split = tjOrderDetail.getProResult().split("。|,|，");


                                    List<Map<String,Object>> mapList=new ArrayList<>();


                                    for (String s : split) {


                                                s = s.replaceAll("\n", "");


//                                        Map<String,Object> maps= rulesService.getyichangxiangmujianyiguizeJianCha(s);


                                        Map<String,Object> maps= tjProAdvicerulesService.getyichangxiangmujianyiguizeJianCha(remark.getKs(),s,"0");


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


                                            Object bt = maps.get("bt");


                                            Object nr = maps.get("nr");


                                            if(null !=bt || null !=nr) mapList.add(maps);


                                        }


                                    }


                                    tjOrderDetail.setAdvices(mapList);


                                }




                            }




                            dels.add(tjOrderDetail);


@@ -1669,13 +1794,11 @@


                        parent.put("sone",dels);


                        list.add(parent);


                    }


                } else {


                    return AjaxResult.success("该人员无异常项目");


                }


            }


            return AjaxResult.success(list);




        }


        return AjaxResult.success("该人员没有体检项目数据！");


        return list;


    }




    @GetMapping ("/chushenyemianchakanxiangmujieguo")


@@ -1693,5 +1816,25 @@


    }






    @PostMapping ("/addOrderYcXmByTjh")


    @ApiOperation (value = "总检医生页面新增异常项目建议")


    public AjaxResult addOrderYcXmJyByTjh(@RequestBody List<TjOrderYcxm> ycxms) {


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


            String tjh = ycxms.get(0).getTjh();


            if(StringUtils.isNotBlank(tjh)){


                ycxmService.delOrderYcXmJyByTjh(tjh);




                for (TjOrderYcxm ycxm : ycxms) {


                    ycxm.setJynr(JSONUtil.toJsonStr(ycxm.getMap()));


                }


//                List<TjOrderYcxm> collect = ycxms.stream().distinct().collect(Collectors.toList());


                ycxmService.saveBatch(ycxms);


                return AjaxResult.success();


            }


        }


        return AjaxResult.success();


    }








}