zhaowenxuan
2024-12-04 b549ebd775297e3c64981ded8741af4dd6e42f39
ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java
@@ -138,6 +138,35 @@
    }
    @GetMapping ("/ceshi")
    @ApiOperation (value = "测试调用lis视图数据接口")
    @RepeatSubmit
//    @Transactional
    public AjaxResult ceshi() {
        List<Map<String, Object>> ccXZxYyLisJgSt = testMapper.getCcXZxYyLisJgSt();
        return AjaxResult.success(ccXZxYyLisJgSt);
    }
    @GetMapping ("/pacs")
    @ApiOperation (value = "测试调用pacs视图数据接口")
    @RepeatSubmit
    public AjaxResult pacs() {
        List<Map<String, Object>> ccXZxYyPacsJgSt = testMapper.getCcXZxYyPacsJgSt();
        List<LtkjExamJcsqd> list = testMapper.getCcXZxYyPacsLtkjExamJcsqd("");
        log.info(list.toString());
        List<LtkjExamJcbgd> list1 = testMapper.getCcXZxYyPacsLtkjExamJcbgd("");
        log.info(list1.toString());
        return AjaxResult.success(ccXZxYyPacsJgSt);
    }
    @GetMapping ("/getCsList")
    @ApiOperation (value = "初审查询体检记录客户列表")//0待1已
    @Transactional
@@ -348,6 +377,7 @@
                final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");
                final String sfkqdyhis = configService.selectConfigByKey("sfkqdyhis");
                final String sfkqdshitulianjie = configService.selectConfigByKey("sfkqdshitulianjie");
                TjOrder order = orderService.getOrderByTjNum(tjNumber);
                if (null != order) {
@@ -587,24 +617,49 @@
                                            }
                                        }
                                    }
                                }else {
                                    return AjaxResult.error("检查项目暂时未出结果,请稍后同步!!!");
                                }
                            }
                        }
                        return AjaxResult.success("同步成功");
                        //同步检查项目给redis缓存现在不用了
//                asyncService.updateCheckType(order.getTjNumber());
                    }
                    //化验
                    testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId());
                    //检查
//            jcsqdService.saveLtkjExamJcsqd(order.getCardId());
                    else if(null !=sfkqdshitulianjie && sfkqdshitulianjie.equals("Y")){
                        List<LtkjHysqd> hysqdList = testMapper.getCcXZxYyLtkjHysqdByLisVi(order.getTjNumber());
                        if(null != hysqdList && !hysqdList.isEmpty()){
                            for (LtkjHysqd hysqd : hysqdList) {
                                LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
                                if (null != jybgid) {
                                    ltkjHysqdService.deletedLtkjHysqdByTjhAndTmh(hysqd.getTjh(),hysqd.getTmh());
                                    ltkjHybgdService.deletedLtkjHybgdByTjhAndTmh(hysqd.getTmh());
                                }
                                if (ltkjHysqdService.save(hysqd)) {
                                    List<LtkjHybgd> hybgdList = testMapper.getCcXZxYyLtkjHybgdByLisVi(hysqd.getTmh());
                                    ltkjHybgdService.saveBatch(hybgdList);
                                }
                            }
                            DynamicDataSourceContextHolder.clearDataSourceType();
                        }
//                        List<LtkjExamJcsqd> jcsqdList = testMapper.getCcXZxYyPacsLtkjExamJcsqd(order.getTjNumber());
//                        if(null !=jcsqdList && !jcsqdList.isEmpty()){
//                            jcsqdService.deletedLtkjJcsqdByTjhAndTmh(order.getCardId());
//                            jcbgdService.deletedLtkjJcbgdByTjhAndTmh(order.getCardId());
//                            jcsqdService.saveBatch(jcsqdList);
//                            List<LtkjExamJcbgd> jcbgdList = testMapper.getCcXZxYyPacsLtkjExamJcbgd(order.getCardId());
//                            if(null != jcbgdList && !jcbgdList.isEmpty())jcbgdService.saveBatch(jcbgdList);
//                            DynamicDataSourceContextHolder.clearDataSourceType();
//                        }
                        String tjNumber1 = order.getTjNumber();
                        log.info("查询出来的体检号是: " + tjNumber1);
                        log.info("传过来的的体检号是: "+tjNumber);
                        Map<String,Object> map=new HashMap<>();
                        map.put("tjnum",tjNumber);
                        testMapper.tjUpdateDetatilByVi(map);
                    }else {
                        //化验
                        testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()), order.getTjNumber(), UserHoder.getLoginUser().getUserId());
                    }
                  //检查
                    return AjaxResult.success("同步成功");
                }
                return AjaxResult.error("未查到该人员体检记录");
@@ -618,6 +673,8 @@
        }
    }
    /**
     * 同步sql server数据到本地数据库数据接口
     */