package com.hx.phip.controller.consultation;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.TypeReference;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.hx.common.BaseController;
|
import com.hx.common.service.CommonService;
|
import com.hx.mybatis.aes.springbean.VariableAesKey;
|
import com.hx.mybatisTool.SqlSentence;
|
import com.hx.phiappt.common.UserProjectConstants;
|
import com.hx.phiappt.constants.tool.PageUtil;
|
import com.hx.phiappt.constants.tool.user.UserProjectTool;
|
import com.hx.phiappt.dao.mapper.*;
|
import com.hx.phiappt.model.*;
|
import com.hx.phiappt.model.guide.VisitRecord;
|
import com.hx.phiappt.model.user.UserProjectItem;
|
import com.hx.phip.service.SystemParameterService;
|
import com.hx.phip.service.consultation.ConsultationRecordService;
|
import com.hx.util.StringUtils;
|
import com.hz.his.dto.consultation.ConsultAppearancePlanVo;
|
import com.hz.his.dto.consultation.ConsultRecordDto;
|
import com.hz.his.dto.consultation.ConsultTreatProjectVo;
|
import com.platform.exception.PlatTipsException;
|
import com.platform.resultTool.PlatformCode;
|
import com.platform.resultTool.PlatformResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import static com.hx.phiappt.constants.tool.user.UserProjectTool.getStatusName;
|
|
/**
|
* 咨询记录
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/consultation/record")
|
public class ConsultationRecordController extends BaseController {
|
|
@Resource
|
private ConsultationRecordService consultationRecordService;
|
@Resource
|
private SystemParameterService systemParameterService;
|
|
/**
|
* 新增
|
*/
|
@RequestMapping(value = "/addOrUpdate", method = RequestMethod.POST)
|
public PlatformResult addOrEditData(@RequestBody ConsultRecordDto consultRecordDto) {
|
//参数校验
|
checkParams(consultRecordDto);
|
|
if (!StringUtils.isEmpty(consultRecordDto.getId())) {
|
ConsultationRecord consultationRecord = commonService.selectOneByKey(ConsultationRecordMapper.class, consultRecordDto.getId());
|
if (consultationRecord == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "找不到咨询记录！");
|
}
|
consultRecordDto.setCreateTime(consultationRecord.getCreateTime());
|
}
|
|
String id = consultationRecordService.insertOrEdit(consultRecordDto, systemParameterService, commonService);
|
JSONObject data = new JSONObject();
|
data.put("id", id);
|
return PlatformResult.success(data);
|
}
|
|
|
/**
|
* 详情
|
*/
|
@RequestMapping(value = "/detail", method = RequestMethod.POST)
|
public PlatformResult detail(@RequestBody ConsultRecordDto consultRecordDto) {
|
|
if (StringUtils.isEmpty(consultRecordDto.getId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "id为空");
|
}
|
|
SqlSentence sqlSentence = new SqlSentence();
|
StringBuffer sql = new StringBuffer();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
values.put("id",consultRecordDto.getId());
|
sql.append(" SELECT cr.id,cr.consultType, cr.userId, cr.shopId, cr.departmentCode, cr.departmentName , cr.methodCode, cr.methodCodeName, cr.description , CONCAT(COALESCE(cr.content,''), '\\r\\n',COALESCE(cr.remark,'')) AS content, cr.isCanCome , cr.adminType, cr.adminId, cr.adminName, cr.hisId, cr.isVisit , cr.visitType, cr.isPay, cr.payLabelInfo, cr.isDraft, cr.satisfie , cr.faceDoctorId, cr.treatDoctorId, cr.dosageParams, cr.appealDetail, cr.treatPlanQuote , cr.anamnesis, cr.hasTreatProjects, cr.lastTreatDoctorId, cr.lastTreatProjects, cr.facePlan, date_format(cr.createTime, '%Y-%m-%d %H:%i:%s') as createTime,cr.doubt,cr.dissent,cr.budget,cr.interestedActivities,cr.followUpWorks FROM consultation_record cr WHERE cr.isDel = 0 AND cr.id = #{m.id} ");
|
sqlSentence.setSqlSentence(sql.toString());
|
ConsultationRecord consultationRecord = commonService.selectOne(ConsultationRecordMapper.class,sqlSentence);
|
if (consultationRecord == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "找不到咨询记录！");
|
}
|
|
if(consultationRecord.getContent().startsWith("\\r\\n") || StringUtils.isEmpty(consultationRecord.getContent())) {
|
consultationRecord.setContent(null);
|
}
|
|
BeanUtils.copyProperties(consultationRecord, consultRecordDto);
|
|
|
values.put("isDel", BaseEntity.NO);
|
values.put("consultationRecordId", consultationRecord.getId());
|
values.put("userId", consultationRecord.getUserId());
|
|
// 推荐项目列表
|
sql.delete(0, sql.length());
|
sql.append("SELECT crp.projectId,crp.projectName FROM `consultation_recommended_project` AS crp LEFT JOIN project AS pro ON pro.id=crp.projectId WHERE crp.userId=#{m.userId} AND crp.consultationRecordId =#{m.consultationRecordId} AND crp.isDel=#{m.isDel}");
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> recommendedProjectList = commonService.selectListMap(ConsultationRecommendedProjectMapper.class, sqlSentence);
|
consultRecordDto.setRecommendProjectList(recommendedProjectList);
|
|
// 治疗项目
|
sql.delete(0, sql.length());
|
values.put("type", ConsultationTreatProject.PROJECT_TYPE_TREAT);
|
sql.append("SELECT crp.projectId,crp.projectName FROM `consultation_treat_project` AS crp LEFT JOIN project AS pro ON pro.id=crp.projectId WHERE crp.userId=#{m.userId} AND crp.consultationRecordId =#{m.consultationRecordId} AND crp.isDel=#{m.isDel} AND crp.type = #{m.type}");
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> treatProjectList = commonService.selectListMap(ConsultationTreatProjectMapper.class, sqlSentence);
|
consultRecordDto.setTreatProjectList(treatProjectList);
|
|
// 预约项目
|
sql.delete(0, sql.length());
|
values.put("type", ConsultationTreatProject.PROJECT_TYPE_PRE);
|
sql.append("SELECT crp.projectId,crp.projectName FROM consultation_treat_project AS crp LEFT JOIN project AS pro ON pro.id=crp.projectId WHERE crp.userId=#{m.userId} AND crp.consultationRecordId =#{m.consultationRecordId} AND crp.isDel=#{m.isDel} AND crp.type = #{m.type}");
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> preProjectList = commonService.selectListMap(ConsultationTreatProjectMapper.class, sqlSentence);
|
consultRecordDto.setPreProjectList(JSON.parseArray(JSON.toJSONString(preProjectList), ConsultTreatProjectVo.class));
|
|
//颜值规划
|
sql.delete(0, sql.length());
|
sql.append("SELECT cap.details FROM consultation_appearance_plan cap WHERE cap.consultationRecordId =#{m.consultationRecordId} AND cap.isDel=#{m.isDel}");
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> appearancePlan = commonService.selectListMap(ConsultationAppearancePlanMapper.class, sqlSentence);
|
consultRecordDto.setAppearancePlanList(JSON.parseArray(JSON.toJSONString(appearancePlan), ConsultAppearancePlanVo.class));
|
|
//面诊医生
|
Employee faceEmp = commonService.selectOneByKey(EmployeeMapper.class, consultRecordDto.getFaceDoctorId());
|
consultRecordDto.setFaceDoctorName(faceEmp == null ? null : faceEmp.getCnName());
|
|
//治疗医生
|
Employee treatEmp = commonService.selectOneByKey(EmployeeMapper.class, consultRecordDto.getTreatDoctorId());
|
consultRecordDto.setTreatDoctorName(treatEmp == null ? null : treatEmp.getCnName());
|
|
//查询用户顾问名称
|
User user = commonService.selectOneByKey(UserMapper.class, consultRecordDto.getUserId());
|
if (user != null) {
|
if (!StringUtils.isEmpty(user.getHisCorpUserId())) {
|
Employee corpEmp = commonService.selectOneByKey(EmployeeMapper.class, user.getHisCorpUserId());
|
consultRecordDto.setHisCorpUserName(corpEmp == null ? null : corpEmp.getCnName());
|
}
|
//手机号
|
if(StringUtils.isEmpty(user.getTel()) || user.getTel().equals("测试服不存")) {
|
consultRecordDto.setTel("-");
|
}else {
|
consultRecordDto.setTel(user.getTel().substring(0, 3) + "****" + user.getTel().substring(7));
|
}
|
}
|
|
// //返回基本信息
|
// if (StringUtils.isEmpty(consultRecordDto.getContent())) {
|
// sql.delete(0, sql.length());
|
// sql.append(" select * from consultation_record where isDel = 0 and id!= #{m.consultationRecordId} and userId = #{m.userId} order by createTime desc limit 1 ");
|
// sqlSentence.setSqlSentence(sql.toString());
|
// ConsultationRecord consultContent = commonService.selectOne(ConsultationRecordMapper.class, sqlSentence);
|
// consultRecordDto.setContent(consultContent != null ? consultContent.getContent() : null);
|
// }
|
|
//非初复诊返回下面的值
|
if (consultRecordDto.getConsultType() == 2) {
|
if (StringUtils.isEmpty(consultRecordDto.getLastTreatDoctorId())) {
|
//为空 查询上一次的咨询记录的数据 拿到咨询医生 ID、名称
|
Map<String, Object> lastDetail = lastDetail(consultRecordDto.getUserId(), consultRecordDto.getId(),1);
|
if (lastDetail != null) {
|
if (lastDetail.containsKey("treatDoctorId") && lastDetail.get("treatDoctorId") != null && !StringUtils.isEmpty(lastDetail.get("treatDoctorId").toString())) {
|
consultRecordDto.setLastTreatDoctorId(lastDetail.get("treatDoctorId").toString());
|
}
|
|
if (lastDetail.containsKey("treatDoctorName") && lastDetail.get("treatDoctorName") != null && !StringUtils.isEmpty(lastDetail.get("treatDoctorName").toString())) {
|
consultRecordDto.setLastTreatDoctorName(lastDetail.get("treatDoctorName").toString());
|
}
|
}
|
} else {
|
//不为空 则拿取当前的数据
|
consultRecordDto.setLastTreatDoctorId(consultationRecord.getLastTreatDoctorId());
|
Employee docEmp = commonService.selectOneByKey(EmployeeMapper.class, consultationRecord.getLastTreatDoctorId());
|
consultRecordDto.setLastTreatDoctorName(docEmp.getCnName());
|
}
|
|
List<Map<String, Object>> lastTreatProjectList;
|
//为空 查询上一次的咨询记录的数据 拿到上一条记录存储的治疗项目数据
|
if (StringUtils.isEmpty(consultRecordDto.getLastTreatProjects())
|
|| "[]".equals(consultRecordDto.getLastTreatProjects())
|
|| "null".equals(consultRecordDto.getLastTreatProjects())) {
|
|
Map<String, Object> lastDetail = lastDetail(consultRecordDto.getUserId(), consultRecordDto.getId(),1);
|
if (lastDetail.containsKey("lastTreatProject")
|
&& lastDetail.get("lastTreatProject") != null
|
&& !StringUtils.isEmpty(lastDetail.get("lastTreatProject").toString())
|
&& !"[]".equals(lastDetail.get("lastTreatProject").toString())
|
&& !"null".equals(lastDetail.get("lastTreatProject").toString())) {
|
lastTreatProjectList = JSON.parseObject(JSON.toJSONString(lastDetail.get("lastTreatProject")), new TypeReference<List<Map<String, Object>>>() {
|
});
|
consultRecordDto.setLastTreatProjectList(lastTreatProjectList);
|
}
|
} else {
|
//不为空 则拿取当前存储的上一次治疗项目数据
|
lastTreatProjectList = JSON.parseObject(consultRecordDto.getLastTreatProjects(), new TypeReference<List<Map<String, Object>>>() {
|
});
|
consultRecordDto.setLastTreatProjectList(lastTreatProjectList);
|
}
|
}
|
|
JSONObject data = new JSONObject();
|
consultRecordDto.setLastTreatProjects(null);
|
data.put("info", consultRecordDto);
|
|
return PlatformResult.success(data);
|
|
}
|
|
|
/**
|
* 删除
|
*/
|
@RequestMapping(value = "/del", method = RequestMethod.POST)
|
public PlatformResult del(@RequestBody ConsultRecordDto consultRecordDto) {
|
|
if (StringUtils.isEmpty(consultRecordDto.getId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "id为空");
|
}
|
|
ConsultationRecord consultationRecord = commonService.selectOneByKey(ConsultationRecordMapper.class, consultRecordDto.getId());
|
if (consultationRecord == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "找不到咨询记录！");
|
}
|
|
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
values.put("isDel", BaseEntity.NO);
|
values.put("consultationRecordId", consultationRecord.getId());
|
|
sqlSentence.setSqlSentence(" isDel = #{m.isDel} where id = #{m.consultationRecordId} and isDel = 0 ");
|
commonService.updateWhere(ConsultationRecordMapper.class, sqlSentence);
|
|
return PlatformResult.success();
|
|
}
|
|
|
/**
|
* 列表
|
*/
|
@RequestMapping(value = "/user/list", method = RequestMethod.POST)
|
public PlatformResult list(@RequestBody ConsultRecordDto consultRecordDto) {
|
|
if (consultRecordDto == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_BODY_DATA, "数据参数为空");
|
}
|
|
// if (StringUtils.isEmpty(consultRecordDto.getUserId())) {
|
// throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "用户ID为空");
|
// }
|
|
SqlSentence sqlSentence = new SqlSentence();
|
StringBuffer sql = new StringBuffer();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
values.put("key", VariableAesKey.AES_KEY);
|
|
sql.append(" SELECT cr.id, cr.userId, cr.shopId, cr.departmentCode, cr.departmentName , cr.methodCode, cr.methodCodeName ");
|
sql.append(" , cr.description , CONCAT(COALESCE(cr.content,''),'\\r\\n', COALESCE(cr.remark,'')) AS contents, cr.isCanCome , cr.adminType, cr.adminId, cr.adminName");
|
sql.append(" , cr.hisId, cr.isVisit , cr.visitType, cr.isPay, cr.payLabelInfo, cr.isDraft, cr.satisfie , cr.faceDoctorId");
|
sql.append(" , cr.treatDoctorId, cr.dosageParams, cr.appealDetail, cr.treatPlanQuote , cr.anamnesis, cr.hasTreatProjects");
|
sql.append(" , cr.lastTreatDoctorId, cr.lastTreatProjects, cr.facePlan, date_format(cr.createTime, '%Y-%m-%d %H:%i:%s') as createTime ");
|
sql.append(" , u.CIQ, f.cnName AS faceDoctorName ,t.cnName AS treatDoctorName,s.name as shopName,u.name as userName ");
|
sql.append(" ,insert(CONVERT(AES_DECRYPT(UNHEX(u.tel), #{m.key}) , CHAR), 4, 4, '****') as tel");
|
sql.append(" ,uStatistics.recentVisitType,uStatistics.recentVisitStatus,uStatistics.isMakeADeal");
|
sql.append(" ,cr.doubt,cr.dissent,cr.budget,cr.interestedActivities,cr.followUpWorks,cr.userCareer");
|
sql.append(" ,cr.workRest,cr.character,cr.userLike,cr.maritalStatus,cr.preparationPregnancy");
|
sql.append(" ,cr.allergyHistory,cr.diseaseHistory,cr.unanamnesis,cr.anamTreatAgency,cr.anamTreatDoctor");
|
sql.append(" ,cr.anamTreatSatisfaction,cr.estimateMapper,cr.specialSituation");
|
sql.append(" FROM consultation_record cr ");
|
sql.append(" LEFT JOIN user u ON cr.userId = u.id ");
|
sql.append(" LEFT JOIN employee f ON cr.faceDoctorId = f.id");
|
sql.append(" LEFT JOIN employee t ON cr.treatDoctorId = t.id ");
|
sql.append(" LEFT JOIN shop s on cr.shopId = s.id ");
|
sql.append(" LEFT JOIN user_statistics AS uStatistics ON uStatistics.userId = cr.userId ");
|
sql.append(" WHERE cr.isDel = 0 ");
|
|
// 咨询方式代码查找
|
if (!StringUtils.isEmpty(consultRecordDto.getMethodCode())) {
|
sql.append(" AND cr.methodCode=#{m.methodCode}");
|
values.put("methodCode", consultRecordDto.getMethodCode());
|
}
|
|
//用户搜索
|
if (!StringUtils.isEmpty(consultRecordDto.getUserId())) {
|
values.put("userId", consultRecordDto.getUserId());
|
sql.append(" and cr.userId = #{m.userId} ");
|
}
|
|
//时间搜索
|
if (!StringUtils.isEmpty(consultRecordDto.getStartTime())) {
|
values.put("startTime", consultRecordDto.getStartTime());
|
sql.append(" and cr.createTime >= #{m.startTime}");
|
}
|
if (!StringUtils.isEmpty(consultRecordDto.getEndTime())) {
|
sql.append(" and cr.createTime <= #{m.endTime}");
|
values.put("endTime", consultRecordDto.getEndTime());
|
}
|
|
// 用户名查找
|
if (!StringUtils.isEmpty(consultRecordDto.getUserName())) {
|
sql.append(" AND (u.name LIKE #{m.userName} OR u.tel LIKE #{m.userName} OR u.CIQ LIKE #{m.userName} OR u.memberNO LIKE #{m.userName})");
|
values.put("userName", "%" + consultRecordDto.getUserName() + "%");
|
}
|
|
// 关键字搜索
|
if (!StringUtils.isEmpty(consultRecordDto.getKeyWord())) {
|
sql.append(" AND (cr.content LIKE #{m.keyWord} OR cr.description LIKE #{m.keyWord} OR cr.remark LIKE #{m.keyWord})");
|
values.put("keyWord", "%" + consultRecordDto.getKeyWord() + "%");
|
}
|
|
// 咨询师
|
if (!StringUtils.isEmpty(consultRecordDto.getHisCorpUserId())) {
|
sql.append(" AND u.hisCorpUserId=#{m.hisCorpUserId}");
|
values.put("hisCorpUserId", consultRecordDto.getHisCorpUserId());
|
}
|
|
// 电网咨询师
|
if (!StringUtils.isEmpty(consultRecordDto.getInternetCorpUserId())) {
|
sql.append(" AND u.internetCorpUserId=#{m.internetCorpUserId}");
|
values.put("internetCorpUserId", consultRecordDto.getInternetCorpUserId());
|
}
|
|
// 客服
|
if (!StringUtils.isEmpty(consultRecordDto.getChatCorpUserId())) {
|
sql.append(" AND u.chatCorpUserId=#{m.chatCorpUserId}");
|
values.put("chatCorpUserId", consultRecordDto.getChatCorpUserId());
|
}
|
|
// 创建人
|
if (!StringUtils.isEmpty(consultRecordDto.getCreateEmployeeId())) {
|
sql.append(" AND cr.adminId=#{m.createEmployeeId}");
|
values.put("createEmployeeId", consultRecordDto.getCreateEmployeeId());
|
}
|
|
// 创建人部门
|
if (!StringUtils.isEmpty(consultRecordDto.getCreateEmployeePartId())) {
|
// 根据部门查询数据
|
String employeePartQuery = handlerAppendQuery("cr.adminId", consultRecordDto.getCreateEmployeePartId(), 1);
|
// 判断是否有查询数据
|
if (!StringUtils.isEmpty(employeePartQuery)) {
|
sql.append(employeePartQuery);
|
} else {
|
// 未查询到数据处理
|
sql.append(" AND cr.adminId=''");
|
}
|
}
|
|
// 关注活动
|
if (!StringUtils.isEmpty(consultRecordDto.getFocusActivityId())) {
|
// 根据关注活动查询数据
|
String employeePartQuery = handlerAppendQuery("cr.id", consultRecordDto.getFocusActivityId(), 2);
|
// 判断是否有查询数据
|
if (!StringUtils.isEmpty(employeePartQuery)) {
|
sql.append(employeePartQuery);
|
} else {
|
// 未查询到数据处理
|
sql.append(" AND cr.id=''");
|
}
|
}
|
|
// 推荐项目
|
if (!StringUtils.isEmpty(consultRecordDto.getRecommendProjectIds())) {
|
// 根据推荐项目查询数据
|
String employeePartQuery = handlerAppendQuery("cr.id", consultRecordDto.getRecommendProjectIds(), 5);
|
// 判断是否有查询数据
|
if (!StringUtils.isEmpty(employeePartQuery)) {
|
sql.append(employeePartQuery);
|
} else {
|
// 未查询到数据处理
|
sql.append(" AND cr.id=''");
|
}
|
}
|
|
// 治疗项目
|
if (!StringUtils.isEmpty(consultRecordDto.getTreatProjectIds())) {
|
// 根据推荐项目查询数据
|
String employeePartQuery = handlerAppendQuery("cr.id", consultRecordDto.getTreatProjectIds(), 6);
|
// 判断是否有查询数据
|
if (!StringUtils.isEmpty(employeePartQuery)) {
|
sql.append(employeePartQuery);
|
} else {
|
// 未查询到数据处理
|
sql.append(" AND cr.id=''");
|
}
|
}
|
|
// 客户来源一级渠道
|
if (!StringUtils.isEmpty(consultRecordDto.getChannelId())) {
|
sql.append(" AND u.channelId = #{m.channelId} ");
|
values.put("channelId", consultRecordDto.getChannelId());
|
}
|
|
// 客户来源二级渠道
|
if (!StringUtils.isEmpty(consultRecordDto.getChannel2Id())) {
|
sql.append(" AND u.channel2Id = #{m.channel2Id} ");
|
values.put("channel2Id", consultRecordDto.getChannel2Id());
|
}
|
|
|
// 到访类型
|
if (!StringUtils.isEmpty(consultRecordDto.getRecentVisitType())) {
|
sql.append(" AND uStatistics.recentVisitType = #{m.recentVisitType} ");
|
values.put("recentVisitType", consultRecordDto.getRecentVisitType());
|
}
|
|
// 到访状态
|
if (consultRecordDto.getRecentVisitStatus() != null) {
|
sql.append(" AND uStatistics.recentVisitStatus = #{m.recentVisitStatus} ");
|
values.put("recentVisitStatus", consultRecordDto.getRecentVisitStatus());
|
}
|
|
// 是否成交
|
if (consultRecordDto.getIsMakeADeal() != null) {
|
sql.append(" AND uStatistics.isMakeADeal = #{m.isMakeADeal} ");
|
values.put("isMakeADeal", consultRecordDto.getIsMakeADeal());
|
}
|
|
// 是否草稿
|
if (consultRecordDto.getIsDraft() != null) {
|
sql.append(" AND cr.isDraft = #{m.isDraft} ");
|
values.put("isDraft", consultRecordDto.getIsDraft());
|
}
|
|
// 门店查找
|
if (!StringUtils.isEmpty(consultRecordDto.getShopId())) {
|
sql.append(" and cr.shopId=#{m.shopId}");
|
values.put("shopId", consultRecordDto.getShopId());
|
}
|
|
sql.append(" group by cr.id ");
|
sqlSentence.setSqlSentence(sql.toString());
|
PageHelper.startPage(consultRecordDto.getPageNum(), consultRecordDto.getPageSize(), " cr.createTime desc ");
|
List<Map<String, Object>> consultationRecordList = commonService.selectListMap(ConsultationRecordMapper.class, sqlSentence);
|
|
if(consultationRecordList!= null && consultationRecordList.size()>0){
|
|
sql.delete(0, sql.length());
|
sql.append(" select * from consultation_treat_project where consultationRecordId = #{m.recordId} and isDel = 0 ");
|
consultationRecordList.forEach(c -> {
|
values.put("recordId", c.get("id"));
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> treatProjectList = commonService.selectListMap(ConsultationTreatProjectMapper.class, sqlSentence);
|
c.put("treatProjectList", treatProjectList);
|
});
|
|
sql.delete(0, sql.length());
|
sql.append(" select * from consultation_recommended_project where consultationRecordId = #{m.recordId} and isDel = 0 ");
|
consultationRecordList.forEach(c -> {
|
values.put("recordId", c.get("id"));
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> recommendedProjectList = commonService.selectListMap(ConsultationTreatProjectMapper.class, sqlSentence);
|
c.put("recommendedProjectList", recommendedProjectList);
|
});
|
|
//去除返回的数据 出现的换行符号
|
consultationRecordList.forEach(c->{
|
if(c.get("contents").toString().startsWith("\\r\\n") || StringUtils.isEmpty(c.get("contents").toString())) {
|
c.remove("contents");
|
}else {
|
c.put("content",c.get("contents"));
|
c.remove("contents");
|
}
|
});
|
|
}
|
PageInfo<Map<String, Object>> pageInfo = new PageInfo<>(consultationRecordList);
|
return PlatformResult.success(pageInfo);
|
|
}
|
|
/**
|
* 获取上一次的信息
|
*/
|
@RequestMapping(value = "/last/detail", method = RequestMethod.POST)
|
public PlatformResult lastDetail(@RequestBody(required = false) ConsultRecordDto consultRecordDto) {
|
|
if (consultRecordDto == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_BODY_DATA, "数据参数为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getUserId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "用户ID为空");
|
}
|
|
JSONObject data = new JSONObject();
|
data.put("lastInfo", lastDetail(consultRecordDto.getUserId(), null,0));
|
|
return PlatformResult.success(data);
|
|
}
|
|
|
/**
|
* 本次治疗项目或者 上次治疗项目下拉使用 已划扣执行的项目列表
|
*/
|
@RequestMapping("/deduction/project/list")
|
public PlatformResult deductionProjectList(@RequestBody(required = false) ConsultRecordDto consultRecordDto) {
|
|
if (consultRecordDto == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_BODY_DATA, "数据参数为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getUserId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "用户ID为空");
|
}
|
|
PageHelper.startPage(PageUtil.getPageNum(consultRecordDto.getPageNum()),PageUtil.getPageSize(consultRecordDto.getPageSize()));
|
List<Map<String, Object>> list = deductionProjectList(consultRecordDto.getUserId(),consultRecordDto.getUseType(),consultRecordDto.getKeyWord(), commonService);
|
PageInfo<Map<String, Object>> pageInfo = new PageInfo<>(list);
|
|
return PlatformResult.success(pageInfo);
|
|
}
|
|
|
//////////////////////////////////////////////////////
|
|
|
//封装获取上一次咨询的 治疗医生 治疗项目
|
public Map<String, Object> lastDetail(String userId, String detailId,Integer isInfo) {
|
|
SqlSentence sqlSentence = new SqlSentence();
|
StringBuffer sql = new StringBuffer();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
values.put("userId", userId);
|
ConsultationRecord consultationRecord;
|
|
if (!StringUtils.isEmpty(detailId) && isInfo!= null && isInfo == 1) {
|
values.put("id", detailId);
|
sql.delete(0, sql.length());
|
sql.append(" select * from consultation_record where isDel = 0 and userId = #{m.userId} and id!= #{m.id} order by createTime desc limit 1 ");
|
sqlSentence.setSqlSentence(sql.toString());
|
consultationRecord = commonService.selectOne(ConsultationRecordMapper.class, sqlSentence);
|
}else {
|
sql.delete(0, sql.length());
|
sql.append(" select * from consultation_record where isDel = 0 and userId = #{m.userId} order by createTime desc limit 1 ");
|
sqlSentence.setSqlSentence(sql.toString());
|
consultationRecord = commonService.selectOne(ConsultationRecordMapper.class, sqlSentence);
|
}
|
|
Map<String, Object> data = new HashMap<>();
|
if (consultationRecord != null) {
|
values.put("isDel", BaseEntity.NO);
|
values.put("consultationRecordId", consultationRecord.getId());
|
|
//治疗医生
|
Employee docEmp = commonService.selectOneByKey(EmployeeMapper.class, consultationRecord.getTreatDoctorId());
|
data.put("treatDoctorName", docEmp == null ? null : docEmp.getCnName());
|
data.put("treatDoctorId", docEmp == null ? null : docEmp.getId());
|
|
//面诊医生
|
Employee faceEmp = commonService.selectOneByKey(EmployeeMapper.class, consultationRecord.getFaceDoctorId());
|
data.put("faceDoctorName", faceEmp == null ? null : faceEmp.getCnName());
|
data.put("faceDoctorId", faceEmp == null ? null : faceEmp.getId());
|
|
//基本信息
|
// data.put("content", consultationRecord.getContent());
|
|
List<Map<String, Object>> lastTreatProject;
|
if( !StringUtils.isEmpty(consultationRecord.getLastTreatProjects())
|
&& !"[]".equals(consultationRecord.getLastTreatProjects())
|
&& !"null".equals(consultationRecord.getLastTreatProjects())){
|
// 治疗项目
|
lastTreatProject = JSON.parseObject(consultationRecord.getLastTreatProjects(), new TypeReference<List<Map<String, Object>>>() {
|
});
|
data.put("lastTreatProject", lastTreatProject);
|
} else {
|
sql.delete(0, sql.length());
|
sql.append("SELECT crp.projectId as id ,crp.projectName as name FROM `consultation_treat_project` AS crp LEFT JOIN project AS pro ON pro.id=crp.projectId WHERE crp.userId=#{m.userId} AND crp.consultationRecordId =#{m.consultationRecordId} AND crp.isDel=#{m.isDel}");
|
sqlSentence.setSqlSentence(sql.toString());
|
lastTreatProject = commonService.selectListMap(ConsultationTreatProjectMapper.class, sqlSentence);
|
data.put("lastTreatProject", lastTreatProject);
|
}
|
} else {
|
//治疗医生
|
VisitRecord visitRecord = visitRecordInfo(userId);
|
if (visitRecord != null) {
|
data.put("treatDoctorName", StringUtils.isEmpty(visitRecord.getDoctorName()) ? null : visitRecord.getDoctorName());
|
data.put("treatDoctorId", StringUtils.isEmpty(visitRecord.getDoctorId()) ? null : visitRecord.getDoctorId());
|
}
|
|
//面诊医生 参与人员是多个时 拿取第一个数据作为面诊医生
|
List<Map<String, Object>> deductionList = deductionProjectList(userId,null,null, commonService);
|
if (deductionList != null && deductionList.size() != 0) {
|
if (deductionList.get(0).containsKey("deductionSingleId") && !StringUtils.isEmpty(deductionList.get(0).get("deductionSingleId").toString())) {
|
Map<String, Object> deductionJsonEmp = deductionJsonEmp(deductionList.get(0).get("deductionSingleId").toString());
|
if (deductionJsonEmp != null) {
|
if (deductionJsonEmp.containsKey("employeeId") && !StringUtils.isEmpty(deductionJsonEmp.get("employeeId").toString())) {
|
data.put("faceDoctorId", deductionJsonEmp.get("employeeId"));
|
}
|
if (deductionJsonEmp.containsKey("employeeName") && !StringUtils.isEmpty(deductionJsonEmp.get("employeeName").toString())) {
|
data.put("faceDoctorName", deductionJsonEmp.get("employeeName"));
|
}
|
}
|
}
|
}
|
}
|
return data;
|
}
|
|
|
/**
|
* 参数校验
|
*/
|
public void checkParams(ConsultRecordDto consultRecordDto) {
|
|
if (consultRecordDto == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_BODY_DATA, "数据参数为空");
|
}
|
|
if (consultRecordDto.getSatisfie() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "满意度为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getUserId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "用户ID为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getFaceDoctorId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "面诊医生为空");
|
}
|
|
if (consultRecordDto.getConsultType() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "咨询类型为空");
|
}
|
|
if (consultRecordDto.getConsultType() == 1) {
|
if (StringUtils.isEmpty(consultRecordDto.getAppealDetail())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "主要诉求为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getTreatPlanQuote())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "治疗方案&报价为空");
|
}
|
|
if (StringUtils.isEmpty(consultRecordDto.getRecommendProjectIds())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "推荐项目为空");
|
}
|
}
|
|
if (consultRecordDto.getConsultType() == 2) {
|
if (StringUtils.isEmpty(consultRecordDto.getFacePlan())) {
|
throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL, "面诊方案为空");
|
}
|
}
|
}
|
|
|
/**
|
* 处理多个条件查询 拼接Sql
|
**/
|
private String handlerAppendQuery(String fieldName, String keyId, Integer type) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
sqlValue.put("isDel", BaseEntity.NO);
|
sqlValue.put("keyId", keyId);
|
String sql = "";
|
String getId = "";
|
if (type == 1) {
|
// 根据部门名称查询
|
sql = "SELECT DISTINCT empl.id FROM employee AS empl LEFT JOIN employee_role AS erole ON erole.employeeId=empl.id " +
|
"WHERE empl.isDel=#{m.isDel} AND erole.departmentId=#{m.keyId}";
|
getId = "id";
|
} else if (type == 2) {
|
// 根据关注活动查询
|
sql = "SELECT DISTINCT consultationRecordId FROM `consultation_focus_activity` WHERE activityId =#{m.keyId} AND isDel=#{m.isDel}";
|
getId = "consultationRecordId";
|
}
|
// else if(type == 3){
|
// // 根据咨询项目类别查询
|
// sql = "SELECT DISTINCT consultationRecordId FROM `consultation_needed_project` WHERE projectTypeId =#{m.keyId} AND isDel=#{m.isDel}";
|
// getId = "consultationRecordId";
|
// } else if(type == 4){
|
// // 根据潜在项目类别查询
|
// sql = "SELECT DISTINCT consultationRecordId FROM `consultation_potential_project` WHERE projectTypeId =#{m.keyId} AND isDel=#{m.isDel}";
|
// getId = "consultationRecordId";
|
// }
|
else if (type == 5) {
|
// 根据推荐项目查询
|
sql = "SELECT DISTINCT consultationRecordId FROM `consultation_recommended_project` WHERE projectId =#{m.keyId} AND isDel=#{m.isDel}";
|
getId = "consultationRecordId";
|
} else if (type == 6) {
|
// 根据治疗项目查询
|
sql = "SELECT DISTINCT consultationRecordId FROM `consultation_treat_project` WHERE projectId =#{m.keyId} AND isDel=#{m.isDel}";
|
getId = "consultationRecordId";
|
}
|
sqlSentence.sqlSentence(sql, sqlValue);
|
List<Map<String, Object>> mapList = commonService.selectListMap(com.hx.phiappt.dao.mapper.EmployeeMapper.class, sqlSentence);
|
if (mapList != null && mapList.size() > 0) {
|
StringBuilder sqlBuilder = new StringBuilder();
|
sqlBuilder.append(" and ").append(fieldName).append(" in ( ");
|
for (Map<String, Object> mapInfo : mapList) {
|
if (mapInfo != null) {
|
sqlBuilder.append("'").append(mapInfo.get(getId)).append("'").append(",");
|
}
|
}
|
sqlBuilder.delete(sqlBuilder.length() - 1, sqlBuilder.length());
|
sqlBuilder.append(")");
|
return sqlBuilder.toString();
|
}
|
return null;
|
}
|
|
|
/**
|
* 已执行划扣的项目
|
**/
|
public static List<Map<String, Object>> deductionProjectList(String userId,String useType,String keyWord, CommonService commonService) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
values.put("userId", userId);
|
|
StringBuffer sql = new StringBuffer();
|
sql.append(" SELECT dp.deductionSingleId,p.id,p.name,p.specification,upi.id as upiId ");
|
|
if(!StringUtils.isEmpty(useType) && useType.equals("admin")){
|
sql.append(" ,p.unit,p.treatmentItemsNum AS courseCount,p.category,p.price,p.originalPrice,p.coding");
|
}
|
|
sql.append(" FROM user_project_item upi ");
|
sql.append(" LEFT JOIN USER us ON us.id = upi.userId ");
|
sql.append(" LEFT JOIN deduction_project dp ON upi.id = dp.userProjectItemId ");
|
sql.append(" LEFT JOIN project p on upi.goodsId = p.id ");
|
sql.append(" WHERE 1 = 1 AND upi.userId = #{m.userId} ");
|
sql.append(" AND ( upi.effectiveStatus = 3 OR ( upi.effectiveStatus = 1 AND upi.notUsedNum = 0 AND upi.usedNum > 0 ) ");
|
sql.append(" OR ( upi.effectiveStatus = 1 AND upi.usedNum > 0 AND upi.notUsedNum > 0 ) ");
|
sql.append(" OR ( upi.effectiveStatus = 1 AND upi.usedNum <= 0 AND upi.cancelNum < upi.usedTotal AND upi.notUsedNum > 0 )) ");
|
sql.append(" AND upi.isDel = 0 ");
|
|
if (!StringUtils.isEmpty(keyWord)) {
|
sql.append(" and ( p.name like #{m.keyWord} or p.coding like #{m.keyWord} )");
|
values.put("keyWord", "%" + keyWord + "%");
|
}
|
|
sql.append(" GROUP BY upi.id");
|
sql.append(" ORDER BY upi.createTime DESC, upi.goodsName DESC");
|
sqlSentence.setSqlSentence(sql.toString());
|
List<Map<String, Object>> list = commonService.selectListMap(UserProjectItemMapper.class, sqlSentence);
|
if (list != null && list.size() > 0) {
|
//处理状态返回展示
|
for (Map<String, Object> objectMap : list) {
|
// 用户项目信息
|
UserProjectItem userProjectItem = commonService.selectOneByKey(UserProjectItemMapper.class, objectMap.get("upiId"));
|
if (userProjectItem != null) {
|
// 状态
|
Integer status = null;
|
// 待执行 项目有效 已执行数量 <= 0 & 已取消数量<总次数 & 未使用次数 > 0 & 还没过期(暂时不用判断)
|
if (UserProjectConstants.EFF_STATUS_YES == userProjectItem.getEffectiveStatus() && userProjectItem.getUsedNum() <= 0
|
&& userProjectItem.getCancelNum() < userProjectItem.getUsedTotal() && userProjectItem.getNotUsedNum() > 0) {
|
status = UserProjectTool.STATUS_WAIT;
|
}
|
// 执行中 项目有效 已执行数量>0 & 有效可执行次数 > 0 & 还没过期(暂时不用判断)
|
if (status == null && UserProjectConstants.EFF_STATUS_YES == userProjectItem.getEffectiveStatus()
|
&& userProjectItem.getUsedNum() > 0 && userProjectItem.getNotUsedNum() > 0) {
|
status = UserProjectTool.STATUS_USED;
|
}
|
// 已执行 有效可执行次数 = 0 & 已执行数量 > 0
|
if (status == null && (UserProjectConstants.EFF_STATUS_DONE == userProjectItem.getEffectiveStatus() ||
|
(UserProjectConstants.EFF_STATUS_YES == userProjectItem.getEffectiveStatus() &&
|
userProjectItem.getNotUsedNum() == 0 && userProjectItem.getUsedNum() > 0))) {
|
status = UserProjectTool.STATUS_DONE;
|
}
|
// 状态不为空在处理
|
if (status != null) {
|
objectMap.put("status", status);
|
objectMap.put("statusName", getStatusName(status));
|
}
|
}
|
}
|
}
|
return list;
|
}
|
|
|
/**
|
* 划扣参与人 - 治疗医生
|
**/
|
private Map<String, Object> deductionJsonEmp(String deductionSingleId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
values.put("isDel", BaseEntity.NO);
|
values.put("id", deductionSingleId);
|
values.put("roleUniqueStr", "doctor");
|
|
sqlSentence.setSqlSentence("SELECT employeeId,employeeName FROM deduction_join WHERE deductionSingleId=#{m.id} AND isDel=#{m.isDel} and roleUniqueStr = #{m.roleUniqueStr} order by createTime desc limit 1 ");
|
Map<String, Object> subMap = commonService.selectOneMap(DeductionJoinMapper.class, sqlSentence);
|
return subMap;
|
}
|
|
|
/**
|
* 划扣参与人 - 治疗医生
|
**/
|
private VisitRecord visitRecordInfo(String userId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
values.put("userId", userId);
|
sqlSentence.setSqlSentence("select * from v_visit_record where isDel = 0 and userId = #{m.userId} order by createTime desc limit 1");
|
VisitRecord visitRecord = commonService.selectOne(VisitRecordMapper.class, sqlSentence);
|
return visitRecord;
|
}
|
|
|
}
|
