package com.ltkj.hosp.service.impl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ltkj.common.core.domain.AjaxResult;
|
import com.ltkj.hosp.mapper.LtkjExamJcsqdMapper;
|
import com.ltkj.hosp.service.LtkjExamJcsqdService;
|
import com.ltkj.hosp.sqlDomain.LtkjExamJcsqd;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
|
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
|
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.sql.DataSource;
|
import java.sql.*;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 病种+意见Service业务层处理
|
*
|
* @author ltkj_赵佳豪&李格
|
* @date 2023-08-30
|
*/
|
@Service
|
public class LtkjExamJcsqdServiceImpl extends ServiceImpl<LtkjExamJcsqdMapper, LtkjExamJcsqd> implements LtkjExamJcsqdService {
|
|
@Resource
|
private LtkjExamJcsqdMapper mapper;
|
|
@Qualifier(value = "slaveHisDataSource")
|
@Autowired
|
private DataSource dataSource;
|
|
|
@Override
|
public LtkjExamJcsqd getLtkjJcsqdByTjhAndTmh(String tjh, String tmh) {
|
return mapper.getLtkjJcsqdByTjhAndTmh(tjh,tmh);
|
}
|
|
@Override
|
public void deletedLtkjJcsqdByTjhAndTmh(String tjh, String tmh) {
|
mapper.deletedLtkjJcsqdByTjhAndTmh(tjh,tmh);
|
}
|
|
@Override
|
public List<LtkjExamJcsqd> getLtkjJcsqdByTjh(String tjh) {
|
return mapper.getLtkjJcsqdByTjh(tjh);
|
}
|
|
@Override
|
public void saveLtkjExamJcsqd(String tjh) {
|
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.add(map);
|
}
|
} catch (SQLException throwables) {
|
throwables.printStackTrace();
|
}
|
return AjaxResult.success().put("data",list);
|
}
|
}
|
