路泰科技体检后端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zjh
2024-12-06 c42f62b32bac302a7ac9fcde7489f7c5fc6e11aa 
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java


@@ -63,7 +63,7 @@


 */


@RestController


@RequestMapping ("/check")


@Api (tags = "总检医师相关接口")


@Api (tags = "AAAAAAAAAAAA总检医师相关接口")


@Slf4j


public class TjCheckController {


    @Resource


@@ -121,6 +121,13 @@


    @Autowired


    private RedissonClient redissonClient;






//    public void  csdsrw() throws InterruptedException {


//        log.info("定时任务开始执行"+new Date());


//        Thread.sleep(1000*5);


//        log.info("定时任务结束执行"+new Date());


//    }




    @GetMapping ("/getOperationPermissionsByTjNum")


    @ApiOperation (value = "(初审页面  和 医生页面)根据体检号获取是否可操作权限接口  true可操作  反之不可")


    public AjaxResult getOperationPermissionsByTjNum(@ApiParam (value = "体检号") @RequestParam String tjNumber) {


@@ -135,6 +142,35 @@


            }


        }


        return AjaxResult.success(false);


    }








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


    }






@@ -348,6 +384,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 +624,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.equalsIgnoreCase("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 +680,8 @@


        }


    }








    /**


     * 同步sql server数据到本地数据库数据接口


     */


@@ -630,6 +694,7 @@


        try {


            boolean tryLock = lock.tryLock(3L, TimeUnit.SECONDS);


            if (tryLock){


                String doctorId = configService.selectConfigByKey("request_default_check_doctorId");


                //根据配置调取存储过程 将临时表数据存入预约表2023.12.12


                final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");




@@ -641,9 +706,9 @@


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


                        tbhyxm(order);


                        //同步化验项目


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


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


                        //同步检查项目


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


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


                        asyncService.updateCheckType(order.getTjNumber());




                    }


@@ -699,7 +764,7 @@


                                }


                            }


                            //同步化验项目


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


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


                        }


                        /*同步检查 his接口*/


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


@@ -757,7 +822,7 @@


                                        jcbgdService.save(jcbgd);


                                    }


                                    jcsqdService.saveLtkjExamJcsqd(order.getCardId());


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


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


                                }else {


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


                                }


@@ -766,7 +831,7 @@


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


                    }


                    //化验


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


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


                    //检查


                    jcsqdService.saveLtkjExamJcsqd(order.getCardId());


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


@@ -1132,8 +1197,12 @@


                                      @ApiParam (value = "总检建议") @RequestParam (required = false) String advice,


                                      @ApiParam (value = "审核状态0待审核1已审核") @RequestParam Integer checkStatus) {




        int num = orderRemarkService.getTjYqOrderRemarkByTjNum(tjNumber);


        if (num > 0) return AjaxResult.error("有延期项目暂不能生成报告!!!");


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


        if(null != config && config.equalsIgnoreCase("Y")){


            int num = orderRemarkService.getTjYqOrderRemarkByTjNum(tjNumber);


            if (num > 0) return AjaxResult.error("存在未检或延期项目暂不能生成报告!!!");


        }




        if (null != tjNumber) {


            Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId());


            SysUser sysUser = userService.getById(userId);