zjh 2024/07/19-2

zjh

2024-07-19 2f9691b8de0e2800f22ce96768aacfd129f02b3c

zjh 2024/07/19-2

 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java

@@ -320,8 +320,11 @@
    @GetMapping ("/dataSynchronization")
    @ApiOperation (value = "同步sql server数据到本地数据库数据接口")
    @RepeatSubmit
    @Transactional
//    @Transactional
    public AjaxResult dataSynchronization(@RequestParam String tjNumber) {



        //根据配置调取存储过程 将临时表数据存入预约表2023.12.12
        final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData");

@@ -377,10 +380,7 @@
                        return AjaxResult.error("化验项目暂时无结果,请稍后同步!!!");
                    }
                    JSONArray data = object.getJSONArray("ResultData");
//                    int size = data.size();
//                    if(size>0){
//
//                     }

                    for (Object datum : data) {
                        JSONObject jsonObject = (JSONObject) datum;
                        LtkjHysqd jybgid = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(order.getCardId(), jsonObject.getStr("JYBGID"));
@@ -549,6 +549,7 @@
                asyncService.updateCheckType(order.getTjNumber());
            }
            return AjaxResult.success("同步成功");
//            return AjaxResult.error("化验项目暂时无结果,请稍后同步!!!");
        }
        return AjaxResult.error();
    }

 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/LtkjExamJcsqdMapper.java

@@ -8,6 +8,7 @@
import com.ltkj.hosp.sqlDomain.LtkjExamJcsqd;
import com.ltkj.hosp.sqlDomain.LtkjHysqd;
import org.apache.ibatis.annotations.*;
import org.springframework.beans.factory.annotation.Qualifier;

import java.util.List;
import java.util.Map;
@@ -39,13 +40,7 @@


    @DataSource(value = DataSourceType.SLAVE_HIS)
    @Select(" exec usp_his_getexamreportinfo\n" +
            "        ${ksmc},\n" +
            "        ${brid},\n" +
            "        ${str_in},\n" +
            "        ${pagecount},\n" +
            "        ${page},\n" +
            "        ${status}")
    @Qualifier (value = "slaveHisDataSource")
    List<Map<String, Object>> getTjJcProByHisCall(@Param("ksmc") String ksmc,
                                                  @Param("str_in")String strIn,
                                                  @Param("brid")String brid,

 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/LtkjExamJcsqdServiceImpl.java

@@ -5,6 +5,7 @@
import com.ltkj.hosp.mapper.LtkjExamJcsqdMapper;
import com.ltkj.hosp.service.LtkjExamJcsqdService;
import com.ltkj.hosp.sqlDomain.LtkjExamJcsqd;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.core.JdbcTemplate;
@@ -28,6 +29,7 @@
 * @date 2023-08-30
 */
@Service
@Slf4j
public class LtkjExamJcsqdServiceImpl extends ServiceImpl<LtkjExamJcsqdMapper, LtkjExamJcsqd> implements LtkjExamJcsqdService {

    @Resource
@@ -58,43 +60,46 @@
        mapper.saveLtkjExamJcsqd(tjh);
    }

//    @Override
//    public AjaxResult getTjJcProByHisCall(String ksmc,String strIn,String brid,int pagecount,int page,String status) {
//        List<Map<String, Object>> tjJcProByHisCall = mapper.getTjJcProByHisCall(ksmc,strIn,brid,pagecount,page,status);
//        return AjaxResult.success().put("data",tjJcProByHisCall);
//    }


    @Override
    public AjaxResult getTjJcProByHisCall(String ksmc,String strIn,String brid,int pagecount,int page,String status) {
        String sql="{exec usp_his_getexamreportinfo(?,?,?,?,?,?)}";
        Connection connection = null;
        List<Map<String,Object>> list=new ArrayList<>();
        try {
            connection = dataSource.getConnection();
            CallableStatement call = connection.prepareCall(sql);
            call.setString(1,ksmc);
            call.setString(2,strIn);
            call.setString(3,brid);
            call.setInt(4,pagecount);
            call.setInt(5,page);
            call.setString(6,status);
            call.execute();
            ResultSet query = call.executeQuery();
            ResultSetMetaData data = query.getMetaData();
            int count = data.getColumnCount();
            while (query.next()) {
                Map<String,Object>map=new HashMap<>();
                for (int i = 0; i < count; i++) {
                    String s = data.getColumnLabel(i);
                    Object object = query.getObject(i);
                    map.put(s,object);
        List<Map<String, Object>> tjJcProByHisCall = mapper.getTjJcProByHisCall(ksmc,strIn,brid,pagecount,page,status);
        return AjaxResult.success().put("data",tjJcProByHisCall);
                }
                list.add(map);
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return AjaxResult.success().put("data",list);
    }


//    @Override
//    public AjaxResult getTjJcProByHisCall(String ksmc,String strIn,String brid,int pagecount,int page,String status) {
//        String sql="{exec usp_his_getexamreportinfo(?,?,?,?,?,?)}";
//        Connection connection = null;
//        List<Map<String,Object>> list=new ArrayList<>();
//        try {
//            connection = dataSource.getConnection();
//            CallableStatement call = connection.prepareCall(sql);
//            call.setString(1,ksmc);
//            call.setString(2,strIn);
//            call.setString(3,brid);
//            call.setInt(4,pagecount);
//            call.setInt(5,page);
//            call.setString(6,status);
//            call.execute();
//            ResultSet query = call.executeQuery();
//            log.info("查询检查报告 ResultSet:   "+query.toString());
//            ResultSetMetaData data = query.getMetaData();
//            log.info("查询检查报告 ResultSetMetaData:   "+data.toString());
//            int count = data.getColumnCount();
//            while (query.next()) {
//                Map<String,Object>map=new HashMap<>();
//                for (int i = 0; i < count; i++) {
//                    String s = data.getColumnLabel(i);
//                    Object object = query.getObject(i);
//                    map.put(s,object);
//                }
//                list.add(map);
//            }
//        } catch (SQLException throwables) {
//            throwables.printStackTrace();
//        }
//        log.info("查询检查报告返回值:   "+list.toString());
//        return AjaxResult.success().put("data",list);
//    }
}

 ltkj-hosp/src/main/resources/mapper/hosp/LtkjExamJcsqdMapper.xml

@@ -4,15 +4,15 @@
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ltkj.hosp.mapper.LtkjExamJcsqdMapper">

<!--    <select id="getTjJcProByHisCall" parameterType="java.util.Map" statementType="CALLABLE" resultType="java.util.Map">-->
<!--        exec usp_his_getexamreportinfo-->
<!--        #{ksmc},-->
<!--        #{brid},-->
<!--        #{str_in},-->
<!--        #{pagecount},-->
<!--        #{page},-->
<!--        #{status}-->
<!--    </select>-->
    <select id="getTjJcProByHisCall" parameterType="java.lang.String" statementType="CALLABLE" resultType="java.util.Map">
        exec usp_his_getexamreportinfo
        ${ksmc},
        ${brid},
        ${str_in},
        ${pagecount},
        ${page},
        ${status}
    </select>


<!--    <select id="getTjJcProByHisCall" parameterType="java.util.Map" statementType="CALLABLE" resultType="java.util.Map">-->