路泰科技体检后端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zjh
2023-12-27 0c13ff7e333b2800fa4fd8802d6e9e515cfb372c 
 ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java


@@ -1,16 +1,20 @@


package com.ltkj.web.controller.sqlserver;




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


import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.ObjectMapper;


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


import com.ltkj.common.core.domain.AjaxResult;


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


import com.ltkj.common.enums.DataSourceType;


import com.ltkj.framework.datasource.DynamicDataSourceContextHolder;


import com.ltkj.hosp.domain.TjCustomer;


import com.ltkj.hosp.domain.TjOrder;


import com.ltkj.hosp.domain.TjOrderRemark;


import com.ltkj.hosp.service.*;


import com.ltkj.hosp.sqlDomain.*;


import com.ltkj.hosp.mapper.TestMapper;


import com.ltkj.system.service.ISysDeptService;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import org.checkerframework.checker.units.qual.A;


@@ -23,6 +27,8 @@


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




import javax.annotation.Resource;


import java.sql.ResultSet;


import java.sql.SQLException;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


@@ -34,7 +40,7 @@




@RestController


@RequestMapping("/sqlserver/getdata")


@Api(tags = "获取从库数据")


@Api(tags = "AAAAAAAAAAA获取从库数据")


public class TjSqlController extends BaseController {


    @Resource


    private TestMapper testMapper;


@@ -58,6 +64,8 @@


    @Autowired


    public RedisTemplate<Object,Object> redisTemplate;


    @Resource


    private ITjCustomerService tjCustomerService;


    @Resource


    private RedisCache redisCache;


    @Resource


    private TjAsyncService asyncService;


@@ -65,9 +73,41 @@


    private ITjOrderRemarkService remarkService;


    @Resource


    private ITjOrderService orderService;


    @Resource


    private ISysDeptService deptService;




    @GetMapping("/getTjHyBgList")


    @ApiOperation(value = "查询lis数据库项目信息接口")


    public AjaxResult getTjHyBgList(@RequestParam(required = false)String pacCode,


                                    @RequestParam(required = false)String pacName,


                                    @RequestParam(required = false)String pacRemark) {


        List<Map<String, Object>> maps = testMapper.getTjHyBgList(pacCode,pacName,pacRemark);


        DynamicDataSourceContextHolder.clearDataSourceType();


        return AjaxResult.success(maps);


    }






    @GetMapping("/newGetTjPat")


    @ApiOperation(value = "新的查询体检信息接口")


    public AjaxResult newGetTjPat(@RequestParam(required = false)String pacCode,


                                  @RequestParam(required = false)String pacName,


                                  @RequestParam(required = false)String pacRemark) {


        List<Map<String, Object>> maps = testMapper.newGetTjPat(pacCode,pacName,pacRemark);


        DynamicDataSourceContextHolder.clearDataSourceType();


        return AjaxResult.success(maps);


    }










    @GetMapping("/getRedisValue")


    @ApiOperation(value = "测试redis模糊查询")


    public AjaxResult getRedisValue() {


    public AjaxResult getRedisValue(@RequestParam int aa,


                                    @RequestParam(defaultValue = "1") Integer page,


                                    @RequestParam(defaultValue = "10") Integer pageSize,


                                    @RequestParam(required = false) String deptId,


                                    @RequestParam(required = false) String tjName,


                                    @RequestParam(required = false) String tjNum) throws SQLException, JsonProcessingException {


//        long start = System.currentTimeMillis();


//        //需要匹配的key


//        ScanOptions options = ScanOptions.scanOptions()


@@ -88,19 +128,33 @@


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


//        map.put("result",result);


//        map.put("scan扫描共耗时：{} ms key数量：{}",System.currentTimeMillis()-start+result.size());


        List<TjOrderRemark> list = remarkService.list(new LambdaQueryWrapper<TjOrderRemark>().ne(TjOrderRemark::getType,2).groupBy(TjOrderRemark::getTjNumber));


        for (TjOrderRemark remark : list) {


            TjOrder orderByTjNum = orderService.getOrderByTjNum(remark.getTjNumber());


            if(null !=orderByTjNum){


                asyncService.dockerSetWjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());


                asyncService.dockerSetYjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());


            }


        }


        return AjaxResult.success();


//        List<TjOrderRemark> list = remarkService.list(new LambdaQueryWrapper<TjOrderRemark>().ne(TjOrderRemark::getType,2).groupBy(TjOrderRemark::getTjNumber));


//        for (TjOrderRemark remark : list) {


//            TjOrder orderByTjNum = orderService.getOrderByTjNum(remark.getTjNumber());


//            if(null !=orderByTjNum){


//                asyncService.dockerSetWjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());


//                asyncService.dockerSetYjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());


//            }


//        }


        if(null==deptId) deptId="";


        if(null==tjName) tjName="";


        if(null==tjNum) tjNum="";




//        List<Map<String, Object>> map = deptService.getSysDeptYjWjCustomerList(deptId, tjName, tjNum, aa, page, pageSize);


//        List<ResultSet> map = deptService.getSysDeptYjWjCustomerList1(deptId, tjName, tjNum, aa, page, pageSize);


//        ResultSet resultSet = deptService.getSysDeptYjWjCustomerList12(deptId, tjName, tjNum, aa, page, pageSize);


//        while (resultSet.next()){


//            String anInt = resultSet.getString(1);


//            System.out.println(anInt);


//        }




        Map<String,Object> map = deptService.getSysDeptYjWjCustomerList13(deptId, tjName, tjNum, aa, page, pageSize);


        return AjaxResult.success(map);


    }






    @GetMapping("/getMiddleDetail")


    @ApiOperation(value = "查询收费项目详情")


    public AjaxResult getMiddleDetail() {


        List<LtkjMiddleDetail> list = testMapper.getMiddleDetail();


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


@@ -113,6 +167,7 @@






    @GetMapping("/getMiddleHead")


    @ApiOperation(value = "查询收费信息")


    public AjaxResult getMiddleHead() {


        List<LtkjMiddleHead> list = testMapper.getMiddleHead();


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


@@ -123,15 +178,32 @@


        return AjaxResult.success(list);


    }




//    @GetMapping("/getVbjitem")


//    @ApiOperation(value = "查看列表")


//    public AjaxResult getVbjitem() {


//        List<LtkjVbjitem> list = testMapper.getVbjitem();


//        return AjaxResult.success(list);


//    }


    @GetMapping("/getMiddleHeadByPartId")


    @ApiOperation(value = "根据身份证号查询收费信息")


    public AjaxResult getMiddleHeadByPartId(@RequestParam String partId) {


        TjCustomer customer = tjCustomerService.getTjCustomerByCusIdCard(partId);


        LtkjMiddleHead pat = testMapper.getMiddleHeadByPartId(customer.getCardId());


        if (null != pat) {


            List<LtkjMiddleDetail> list = testMapper.getMiddleDetailByFeadId(pat.getFeadId());


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


            LtkjMiddleHead o = headService.getMiddleHeadByPartId(customer.getCardId());


            if(o==null){


                headService.save(pat);


                for (LtkjMiddleDetail ltkjMiddleDetail : list) {


                    middleDetailService.save(ltkjMiddleDetail);


                }


                testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard());


            }


            testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard());


        }


        DynamicDataSourceContextHolder.clearDataSourceType();


        return AjaxResult.success();


    }








    @GetMapping("/getTjPat")


    @ApiOperation(value = "测试getTjPat")


    public AjaxResult getTjPat() {


        List<LtkjTjPat> list = testMapper.getTjPat();


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


@@ -142,6 +214,31 @@


        return AjaxResult.success(list);


    }






    @GetMapping("/getTjPatByIdCard")


    @ApiOperation(value = "根据身份证号测试getTjPat")


    public AjaxResult getTjPatByIdCard(@RequestParam String idCard) {


        LtkjTjPat tjPatByIdCard = testMapper.getTjPatByIdCard(idCard.trim());


        if(null != tjPatByIdCard){


            String fcardNo = tjPatByIdCard.getFcardNo();


            if(null !=fcardNo){


                fcardNo=fcardNo.trim();


                tjPatByIdCard.setFcardNo(fcardNo);


            }


            LtkjTjPat ltkjTjPat = tjvLtkjvtjpatService.getLtkjTjPatByCusIdCard(idCard);


            if(null==ltkjTjPat){


                tjvLtkjvtjpatService.save(tjPatByIdCard);


            }


        }


        DynamicDataSourceContextHolder.clearDataSourceType();


        //再根据身份证号写customer表


        TjCustomer tjCustomer = tjCustomerService.getTjCustomerByCusIdCard(idCard);


        if(null == tjCustomer){


            testMapper.getTjPatByCusId(idCard);


        }


        return AjaxResult.success(tjPatByIdCard);


    }




    @GetMapping("/getExamJcbgd")


    public AjaxResult getExamJcbgd() {


        List<LtkjExamJcbgd> list = testMapper.getExamJcbgd();