package com.lyms.talkonlineweb.controller;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.lyms.talkonlineweb.domain.*;
import com.lyms.talkonlineweb.result.BaseResponse;
import com.lyms.talkonlineweb.service.*;
import com.lyms.talkonlineweb.util.Constant;
import com.lyms.talkonlineweb.util.JwtUtils;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.BindingResult;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 患者管理
*/
@RestController
@RequestMapping("pat")
@Log4j2
public class PatientController {
@Autowired
private LymsPatientService lymsPatientService;//患者
@Autowired
private LymsPcaseService lymsPcaseService;//病例
@Autowired
private LymsIllnessService lymsIllnessService;//疾病
@Autowired
private LymsTkcardService lymsTkcardService;//问诊记录
@Autowired
private PatientInfoService patientInfoService;//患者视图
@Autowired
private LymsTcardService lymsTcardService;//问诊卡信息
@Autowired
private LymsLogsService lymsLogsService;//日志记录
@Autowired
private HXService hxService;
//医院
@Autowired
private LymsHospitalService lymsHospitalService;
//医生
@Autowired
private LymsDoctorService lymsDoctorService;
//关注
@Autowired
private LymsAttentionService lymsAttentionService;
/**
* 获取患者列表
* @param patientInfo
* @param current
* @param size
* @return
*/
@GetMapping("sltPatientLst")
public BaseResponse sltPatientLst(PatientInfo patientInfo, int current, int size,@RequestParam(required = false) Integer qtype){
BaseResponse baseResponse=new BaseResponse();
Page<PatientInfo> page=new Page<>(current,size);
QueryWrapper<PatientInfo> queryWrapper = Wrappers.query(patientInfo);
if (Objects.nonNull(qtype) &&qtype==1){//从小程序购买
queryWrapper.inSql("id","SELECT t.`pid` FROM lyms_tcard t WHERE t.`fid`=1");
}
if (Objects.nonNull(qtype) && qtype==2){//从医院购买
queryWrapper.inSql("id","SELECT t.`pid` FROM lyms_tcard t WHERE t.`fid`=2");
}
Page<PatientInfo> patientPagePage=patientInfoService.page(page, queryWrapper);
List<PatientInfo> pLst=patientInfoService.list(queryWrapper);
int daiCnt=pLst.parallelStream().mapToInt(PatientInfo::getCcnt).sum();//待使用数量
List<Integer> pids=pLst.parallelStream().map(PatientInfo::getId).collect(Collectors.toList());
LymsTcard tcard=new LymsTcard();
QueryWrapper<LymsTcard> tWrapper = Wrappers.query(tcard);
if(pids.size()==0){
pids.add(-1);
}
tWrapper.in("pid",pids);
int sum=lymsTcardService.list(tWrapper).parallelStream().mapToInt(LymsTcard::getCnt).sum();
log.error("统计需要改动数据结构:daiCnt:{} sum:{}",daiCnt,sum);
baseResponse.setObject(patientPagePage);
return baseResponse;
}
/**
* 保存或更新患者信息
* @param patient
* @return
*/
@PostMapping("savePatient")
public BaseResponse savePatient(@Validated LymsPatient patient, BindingResult result, LymsPcase pcase, String illness){
BaseResponse baseResponse=new BaseResponse();
log.info(">>>>>>>>>>>>>>>登记病例");
baseResponse.setErrormsg("");
LymsPatient patient2=lymsPatientService.getOne(Wrappers.query(patient).eq("idno",patient.getIdno()));
if(patient2==null){
patient.setCreatedtime(new Date());
}else{
patient.setId(patient2.getId());
patient.setUpdatedtime(new Date());
}
if(result.hasErrors()){
baseResponse.setErrorcode(1);
result.getAllErrors().forEach(e->{
baseResponse.setErrormsg(baseResponse.getErrormsg()+e.getDefaultMessage());
});
baseResponse.setErrorcode(1);
return baseResponse;
}
boolean f=lymsPatientService.saveOrUpdate(patient);
// 添加病例
pcase.setCreatedby(patient.getCreatedby());
pcase.setPid(patient.getId());
pcase.setCreatedtime(new Date());
f=lymsPcaseService.saveOrUpdate(pcase);
String[] iArr=illness.split(",");
log.info(patient);
log.info(pcase);
Map param=new HashMap();
for (int i = 0; i < iArr.length; i++) {
LymsIllness ness=new LymsIllness();
ness.setCreatedby(patient.getCreatedby());
ness.setPcid(pcase.getPcid());
ness.setIid(Integer.parseInt(iArr[i]));
ness.setCreatedtime(new Date());
param.clear();
param.put("pcid",pcase.getPcid());
param.put("iid",iArr[i]);
List<LymsIllness> iLst=lymsIllnessService.listByMap(param);
if(iLst.size()>0){
ness.setId(iLst.get(0).getId());
}
f=lymsIllnessService.saveOrUpdate(ness);
log.info(ness.toString());
}
//需要添加医院购买卡记录
LymsTcard tcard=new LymsTcard();
tcard.setCnt(patient.getCcnt());
tcard.setPcid(pcase.getPcid());
tcard.setPid(patient.getId());
tcard.setFid(2);
param.clear();
param.put("pcid",pcase.getPcid());
List<LymsTcard> tLst=lymsTcardService.listByMap(param);
if(tLst.size()>0){
tcard.setId(tLst.get(0).getId());
tcard.setUpdatedby(pcase.getUpdatedby());
tcard.setUpdatedTime(new Date());
}else{
tcard.setCreatedby(patient.getCreatedby());
tcard.setCreatedtime(new Date());
}
lymsTcardService.saveOrUpdate(tcard);
baseResponse.setErrorcode(f==true?0:1);
return baseResponse;
}
/**
* 删除患者
* @param id
* @return
*/
@GetMapping("delPatient")
public BaseResponse delPatient(int id){
BaseResponse baseResponse=new BaseResponse();
boolean f=lymsPatientService.removeById(id);
baseResponse.setErrorcode(f==true?0:1);
return baseResponse;
}
/**
* 删除患者病例ID
* @param pcid
* @return
*/
@GetMapping("delPcase")
public BaseResponse delPcase(int pcid){
BaseResponse baseResponse=new BaseResponse();
boolean f=lymsPcaseService.removeById(pcid);
baseResponse.setErrorcode(f==true?0:1);
return baseResponse;
}
/**
* 患者登录
* @param patient
* @return
*/
@PostMapping("loginPatient")
public BaseResponse loginPatient(@RequestBody LymsPatient patient){
BaseResponse baseResponse=new BaseResponse();
List<LymsPatient> dLst=lymsPatientService.list(Wrappers.query(patient));
baseResponse.setErrorcode(1);
if (dLst.size()>0) {
patient=dLst.get(0);
patient.setPpasswd(null);
baseResponse.setObject(patient);
String jwt = JwtUtils.createJWT("1", patient.getIdno(), Constant.JWT_TTL);
Map<String,Object> map=new HashMap<>();
map.put("patient",patient);
map.put("token",jwt);
patient.setIslogin(1);
if(patient.getHxid()==null ){
JSONObject json=hxService.addUser(patient.getIdno(),Constant.COMMON_PASSWD,patient.getPname());
JSONArray rArr=json.getJSONArray("entities");
if(rArr.size()>0){
patient.setHxid(rArr.getJSONObject(0).getString("uuid"));
}
}
lymsPatientService.update().update(patient);
baseResponse.setErrorcode(0);
baseResponse.setObject(map);
LymsLogs logEntity=new LymsLogs();
logEntity.setFunc("loginPatient");
logEntity.setLogDate(new Date());
logEntity.setMessage(String.format("login:%s name:%s",patient.getIdno(),patient.getPname()));
lymsLogsService.save(logEntity);
}
return baseResponse;
}
/**
* 查询单个患者信息
* @param patientInfo
* @return
*/
@GetMapping("queryPatient")
public BaseResponse queryPatient(PatientInfo patientInfo){
BaseResponse baseResponse=new BaseResponse();
PatientInfo patientInfo2=patientInfoService.getOne(Wrappers.query(patientInfo));
baseResponse.setObject(patientInfo2);
return baseResponse;
}
/**
* 传入患者id，获取病历对应的医院列表
* @param lymsPcase
* @return
*/
@GetMapping("getPatientHospitals")
public BaseResponse getPatientHospitals(LymsPcase lymsPcase){
BaseResponse baseResponse = new BaseResponse();
List<LymsPcase> pcases =lymsPcaseService.list(Wrappers.query(lymsPcase));
baseResponse.setObject(pcases);
return baseResponse;
}
/**
* 查询患者在某个医院的详细诊断病历
* 需要传入患者id和医院id
* @param pid 患者id
* @param hid 医院id
* @return
*/
@GetMapping("getPatientHospitalPcase")
public BaseResponse getPatientHospitalPcase(int pid,int hid,
@RequestParam(required = false) String keyword){
BaseResponse baseResponse = new BaseResponse();
Map data = new HashMap(5);
LymsPatient patient = lymsPatientService.getById(pid);
//患者基本信息
data.put("patient",patient);
//医院信息
LymsHospital hospital = lymsHospitalService.getById(pid);
data.put("hospital",hospital);
List<Integer> ilist = new ArrayList<>();
if (StringUtil.isNotEmpty(keyword)){
LambdaQueryWrapper<LymsIllness> iwrapper = new QueryWrapper().lambda();
iwrapper.like(LymsIllness::getIname, keyword);
List<LymsIllness> illnesses = lymsIllnessService.list(iwrapper);
if (CollectionUtils.isNotEmpty(illnesses)){
illnesses.stream().forEach(i -> {
ilist.add(i.getPcid());
});
}
}
//查询患者的就诊记录
LambdaQueryWrapper<LymsPcase> wrapper = new QueryWrapper().lambda();
wrapper.eq(LymsPcase::getPid, pid);
wrapper.eq(LymsPcase::getHid, hid);
if (StringUtil.isNotEmpty(keyword)){
wrapper.and(i -> i.like(LymsPcase::getDname, keyword).or().like(LymsPcase::getDtname, keyword));
if (CollectionUtils.isNotEmpty(ilist)){
wrapper.or(i -> i.in(LymsPcase::getPcid, ilist));
}
}
wrapper.orderByDesc(LymsPcase::getCreatedtime);
List<LymsPcase> lymsPcaseList = lymsPcaseService.list(wrapper);
List<PatientPcaseResult> pcases = new ArrayList<>();
if (CollectionUtils.isNotEmpty(lymsPcaseList)){
lymsPcaseList.forEach(destModel -> {
PatientPcaseResult result = new PatientPcaseResult();
result.setPid(destModel.getPid());
result.setDepartName(destModel.getDname());
result.setDoctorName(destModel.getDtname());
result.setCardNo(patient.getIdno());
result.setPatientName(patient.getPname());
result.setCcnt(patient.getCcnt());
result.setPhxid(patient.getHxid());
LymsDoctor doctor = lymsDoctorService.getById(destModel.getDtid());
result.setDhxid(doctor.getHxid());
result.setDtid(destModel.getDtid());
result.setCreatedby(DateUtil.getYyyyMmDdHhMmSs(destModel.getCreatedtime()));
pcases.add(result);
});
}
data.put("pcases",pcases);
baseResponse.setObject(data);
return baseResponse;
}
/**
* 通过患者id查询患者的基本信息
* @param lymsPatient
* @return
*/
@GetMapping("getPatientBaseInfo")
public BaseResponse getPatientBaseInfo(LymsPatient lymsPatient){
BaseResponse baseResponse = new BaseResponse();
Map data = new HashMap(6);
LymsPatient patients = lymsPatientService.getById(lymsPatient.getId());
//查询患者的就诊记录
LambdaQueryWrapper<LymsPcase> wrapper = new QueryWrapper().lambda();
wrapper.eq(LymsPcase::getPid, lymsPatient.getId());
wrapper.orderByDesc(LymsPcase::getCreatedtime);
List<LymsPcase> lymsPcaseList = lymsPcaseService.list(wrapper);
data.put("pid",patients.getId());
data.put("pname",patients.getPname());
data.put("psex",patients.getSex());
data.put("birth",patients.getBirth());
if (CollectionUtils.isNotEmpty(lymsPcaseList))
{
data.put("mobile",lymsPcaseList.get(0).getMobile());
}
baseResponse.setObject(data);
return baseResponse;
}
/**
* 更新患者信息
* @param request
* @return
*/
@PutMapping("updatePatientInfo")
public BaseResponse updatePatientInfo(@RequestBody PatientInfoRequest request){
BaseResponse baseResponse=new BaseResponse();
LymsPatient patients = lymsPatientService.getById(request.getPid());
patients.setBirth(request.getBirth());
patients.setPname(request.getPname());
patients.setSex(request.getPsex());
lymsPatientService.updateById(patients);
//查询患者的就诊记录
LambdaQueryWrapper<LymsPcase> wrapper = new QueryWrapper().lambda();
wrapper.eq(LymsPcase::getPid, request.getPid());
wrapper.orderByDesc(LymsPcase::getCreatedtime);
List<LymsPcase> lymsPcaseList = lymsPcaseService.list(wrapper);
if (CollectionUtils.isNotEmpty(lymsPcaseList))
{
lymsPcaseList.forEach(lymsPcase -> {
lymsPcase.setMobile(request.getMobile());
lymsPcaseService.updateById(lymsPcase);
});
}
return baseResponse;
}
/**
* 患者的问诊记录接口
* @param lymsTkrecord 传入患者id参数
* @return
*/
@GetMapping("getPatienttkrecord")
public BaseResponse getPatienttkrecord(LymsTkrecord lymsTkrecord){
BaseResponse baseResponse = new BaseResponse();
LymsPatient patients = lymsPatientService.getById(lymsTkrecord.getPid());
//查询患者的就诊记录
LambdaQueryWrapper<LymsTkrecord> wrapper = new QueryWrapper().lambda();
wrapper.eq(LymsTkrecord::getPid, lymsTkrecord.getPid());
wrapper.orderByDesc(LymsTkrecord::getCreatedtime);
List<LymsTkrecord> lymsTkrecords = lymsTkcardService.list(wrapper);
List<Map> list = new ArrayList<>();
if (CollectionUtils.isNotEmpty(lymsTkrecords))
{
for(LymsTkrecord record : lymsTkrecords)
{
LymsPcase pcase = lymsPcaseService.getById(record.getPcid());
Map data = new HashMap(20);
data.put("hospitalName",pcase.getHname());
data.put("hospitalLevel","");
data.put("doctorName",pcase.getDtname());
data.put("departName",pcase.getDname());
data.put("doctorLevel","");
data.put("patientName",patients.getPname());
StringBuilder sb = new StringBuilder();
LambdaQueryWrapper<LymsIllness> iwrapper = new QueryWrapper().lambda();
iwrapper.like(LymsIllness::getPcid, pcase.getPcid());
List<LymsIllness> illnesses = lymsIllnessService.list(iwrapper);
if (CollectionUtils.isNotEmpty(illnesses))
{
illnesses.forEach(lymsIllness -> {
sb.append(lymsIllness.getIname());
sb.append(" ");
});
}
data.put("iname",sb.toString());
data.put("createTime",DateUtil.getDateTime(record.getCreatedtime(),DateUtil.YYYY_MM_DD));
data.put("stat",record.getStat());
list.add(data);
}
}
baseResponse.setObject(list);
return baseResponse;
}
/**
* 查询患者关注的医生记录
* @param lymsAttention 传入患者id参数
* @return
*/
@GetMapping("getPatientAttentions")
public BaseResponse getPatientAttentions(LymsAttention lymsAttention){
BaseResponse baseResponse = new BaseResponse();
//查询患者的关注医生记录
LambdaQueryWrapper<LymsAttention> wrapper = new QueryWrapper().lambda();
wrapper.eq(LymsAttention::getPid, lymsAttention.getPid());
wrapper.orderByDesc(LymsAttention::getCreatedtime);
List<LymsAttention> lymsAttentions = lymsAttentionService.list(wrapper);
List<Map> list = new ArrayList<>();
if (CollectionUtils.isNotEmpty(lymsAttentions))
{
for(LymsAttention attention : lymsAttentions)
{
LymsDoctor doctor = lymsDoctorService.getById(attention.getDid());
Map data = new HashMap(20);
data.put("doctorName",doctor.getDname());
data.put("departName",doctor.getDdname());
data.put("doctorLevel","");
data.put("hospitalName",doctor.getHname());
data.put("hospitalLevel","");
data.put("doctorDesc",doctor.getIntro());
list.add(data);
}
}
baseResponse.setObject(list);
return baseResponse;
}
}