代码修改

common/common-entity/src/main/java/com/yihu/jw/entity/patient/PatientRestTime.java

@@ -0,0 +1,47 @@
package com.yihu.jw.entity.patient;
import com.yihu.jw.entity.IdEntityWithCreateTime;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
/**
 * Created by yeshijie on 2023/3/22.
 */
@Entity
@Table(name = "wlyy_patient_rest_time")
public class PatientRestTime extends IdEntityWithCreateTime {
    private String patient;//居民code
    private String type;//类型 1早餐时间 2午餐时间 3晚餐时间 4入睡时间
    private String restTime;//作息时间
    @Column(name = "patient")
    public String getPatient() {
        return patient;
    }
    public void setPatient(String patient) {
        this.patient = patient;
    }
    @Column(name = "type")
    public String getType() {
        return type;
    }
    public void setType(String type) {
        this.type = type;
    }
    @Column(name = "rest_time")
    public String getRestTime() {
        return restTime;
    }
    public void setRestTime(String restTime) {
        this.restTime = restTime;
    }
}

common/common-entity/src/main/java/com/yihu/jw/entity/util/TransforSqlUtl.java

@@ -245,4 +245,11 @@ public class TransforSqlUtl {
        return encryptStr;
    }
    public static String wlyy_patient_rehabilitation_planAll(String sql){
        String str = "*,CAST(AES_DECRYPT(from_base64(name),'jkzl2021ZJXL*#%a') AS CHAR ) AS name,CAST(AES_DECRYPT(from_base64(create_user_name),'jkzl2021ZJXL*#%a') AS CHAR ) AS create_user_name,CAST(AES_DECRYPT(from_base64(update_user_name),'jkzl2021ZJXL*#%a') AS CHAR ) AS update_user_name";
        if (dbEncrypt){
            sql = sql.replace("*",str);
        }
        return sql;
    }
}

common/common-rest-model/src/main/java/com/yihu/jw/restmodel/web/endpoint/EnvelopRestEndpoint.java

@@ -53,6 +53,7 @@ public abstract class EnvelopRestEndpoint extends BaseRestEndPoint {
        return success(message, 200);
    }
    protected Envelop success(String message, int status) {
        Envelop envelop = new Envelop();
        envelop.setMessage(message);
@@ -477,6 +478,26 @@ public abstract class EnvelopRestEndpoint extends BaseRestEndPoint {
            return null;
        }
    }
    /**
     * 获取被代理人的code
     * @return
     */
    public String getRepresentedUID() {
        try {
            HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
            String userAgent = request.getHeader("userAgent");
            if (org.apache.commons.lang3.StringUtils.isEmpty(userAgent)) {
                userAgent = request.getHeader("User-Agent");
            }
            org.json.JSONObject json = new org.json.JSONObject(userAgent);
            return json.getString("represented");
        } catch (Exception e) {
            return null;
        }
    }
    public String getUID(String patient) {
        try {
            if(StringUtils.isEmpty(patient)){

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/patient/dao/PatientRestTimeDao.java

@@ -0,0 +1,19 @@
package com.yihu.jw.hospital.module.patient.dao;
import com.yihu.jw.entity.patient.PatientRestTime;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.List;
/**
 * Created by yeshijie on 2023/3/22.
 */
public interface PatientRestTimeDao extends PagingAndSortingRepository<PatientRestTime, Long>, JpaSpecificationExecutor<PatientRestTime> {
    @Query("select t from PatientRestTime t where t.patient=?1 order by t.type asc ")
    List<PatientRestTime> findByPatient(String patient);
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/patient/service/PatientRestTimeService.java

@@ -0,0 +1,58 @@
package com.yihu.jw.hospital.module.patient.service;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.entity.patient.PatientRestTime;
import com.yihu.jw.hospital.module.patient.dao.PatientRestTimeDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
 * Created by yeshijie on 2023/3/23.
 */
@Service
public class PatientRestTimeService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private PatientRestTimeDao patientRestTimeDao;
    //获取居民作息时间
    public Map<String,String> getPatientRestTimeMap(String patient){
        synchronized (patient.intern()){
            List<PatientRestTime> restTimeList = patientRestTimeDao.findByPatient(patient);
            if(restTimeList.size()==0){
                //按默认的生成
                List<PatientRestTime> systemList = patientRestTimeDao.findByPatient("system");
                systemList.forEach(one->{
                    PatientRestTime restTime = new PatientRestTime();
                    restTime.setPatient(patient);
                    restTime.setCreateTime(new Date());
                    restTime.setRestTime(one.getRestTime());
                    restTime.setType(one.getType());
                    restTimeList.add(restTime);
                });
                patientRestTimeDao.saveAll(restTimeList);
            }
            Map<String,String> map = restTimeList.stream().collect(Collectors.toMap(PatientRestTime::getType,PatientRestTime::getRestTime));
            return map;
        }
    }
    //修改居民作息时间
    public void updRestTime(String patient,String jsonData){
        List<PatientRestTime> restTimeList = patientRestTimeDao.findByPatient(patient);
        JSONObject json = JSON.parseObject(jsonData);
        for (PatientRestTime restTime:restTimeList){
            restTime.setRestTime(json.getString(restTime.getType()));
        }
        patientRestTimeDao.saveAll(restTimeList);
    }
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/controller/DoctorRehabilitaionInfoController.java

@@ -59,6 +59,8 @@ public class DoctorRehabilitaionInfoController extends EnvelopRestEndpoint {
        }
    }
    @RequestMapping(value = "getDeorsumvergenceCount", method = RequestMethod.GET)
    @ApiOperation("康复下转已下转顶头数据")
    public String getDeorsumvergenceCount() {

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/controller/PatientRehabilitationManageController.java

@@ -0,0 +1,583 @@
package com.yihu.jw.hospital.module.rehabilitation.controller;
/**
 * Created by 刘文彬 on 2018/8/31.
 */
import com.yihu.jw.entity.specialist.rehabilitation.PatientMedicalRecordsDO;
import com.yihu.jw.hospital.module.door.service.WlyyDoorServiceOrderService;
import com.yihu.jw.hospital.module.patient.service.PatientRestTimeService;
import com.yihu.jw.hospital.module.rehabilitation.service.RehabilitationGuidanceService;
import com.yihu.jw.hospital.module.rehabilitation.service.RehabilitationManageService;
import com.yihu.jw.hospital.module.rehabilitation.service.RehabilitationPlanService;
import com.yihu.jw.hospital.prescription.service.DrugsPlanService;
import com.yihu.jw.im.util.ImUtil;
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.apache.commons.lang3.StringUtils;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
/**
 * Created by 刘文彬 on 2018/8/30.
 */
@RestController
@RequestMapping(value = "/patient/specialist/rehabilitation", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(description = "居民端-康复管理")
public class PatientRehabilitationManageController extends EnvelopRestEndpoint {
    @Autowired
    private RehabilitationManageService rehabilitationManageService;
    @Autowired
    private ImUtil imUtill;
    @Autowired
    private RehabilitationPlanService rehabilitationPlanService;
    @Autowired
    private RehabilitationGuidanceService rehabilitationGuidanceService;
    @Autowired
    private WlyyDoorServiceOrderService wlyyDoorServiceOrderService;
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Resource
    private PatientRestTimeService patientRestTimeService;
    @Autowired
    private DrugsPlanService drugsPlanService;
//    @Autowired
//    private GuahaoXMService guahaoXM;//挂号
    @RequestMapping(value = "selectPlanByPatient", method = RequestMethod.GET)
    @ApiOperation("康复管理-根据居民code查找康复计划")
    public String calendarPlanDetailItems(@ApiParam(name = "patient", value = "居民code", required = false)
                                          @RequestParam(value = "patient", required = false) String patient,
                                          @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false)
                                          @RequestParam(value = "status", required = false) Integer status) {
        try {
            List<Map<String, Object>> result = rehabilitationManageService.selectPlanByPatient(patient, status, null, null);
            return write(200, "获取成功", "data", result);
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
    @RequestMapping(value = "patientRehabilitationDetail", method = RequestMethod.GET)
    @ApiOperation("康复管理-微信端-居民详情页")
    public String patientRehabilitationDetail(
            @ApiParam(name = "patient", value = "居民", required = true) @RequestParam(value = "patient", required = false) String patient
    ) {
        try {
            if (StringUtils.isNotBlank(patient)) {
                if (StringUtils.isNoneBlank(getRepresentedUID())) {
                    patient = getRepresentedUID();
                } else {
                    patient = getUID();
                }
            }
            JSONObject result = rehabilitationManageService.patientRehabilitationDetail(patient);
            return write(200, "获取成功！", "data", result);
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "getPatientInfo", method = RequestMethod.GET)
//    @ApiOperation("康复管理-获取居民信息")
//    public String getPatientInfo(@ApiParam(name = "patient", value = "居民信息", required = true)
//                                 @RequestParam(value = "patient", required = true) String patient,
//                                 @ApiParam(name = "planId", value = "计划id", required = true)
//                                 @RequestParam(value = "planId", required = true) String planId) {
//        try {
//            return write(200, "获取成功", "data", rehabilitationManageService.getPatientInfo(planId, patient));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "selectByMedicalCode", method = RequestMethod.GET)
//    @ApiOperation("获取医院病历")
//    public String selectByMedicalCode(@ApiParam(name = "medical", value = "住院code", required = true)
//                                      @RequestParam(value = "medical", required = true) String medical) {
//
//        try {
//            List<PatientMedicalRecordsDO> result = rehabilitationManageService.selectByMedicalCode(medical);
//            try {
//                String sql = "UPDATE `wlyy`.`wlyy_patient_medical_records_rehabilitation` SET `patient_read_status`='1' WHERE (`code`='" + medical + "') ";
//                jdbcTemplate.update(sql);
//            } catch (Exception e) {
//                e.printStackTrace();
//            }
//            return write(200, "获取成功！", "data", result);
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
    @RequestMapping(value = "selectByPatient", method = RequestMethod.GET)
    @ApiOperation("获取居民医院病历列表")
    public String selectByPatient(@ApiParam(name = "patient", value = "居民code", required = true)
                                  @RequestParam(value = "patient", required = true) String patient) {
        try {
            List<PatientMedicalRecordsDO> result = rehabilitationManageService.findByPatient(patient);
            return write(200, "获取成功！", "data", result);
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "getPlantCodeByMedicalRecordsCode", method = RequestMethod.GET)
//    @ApiOperation("根据住院病历获取计划CODE")
//    public String getPlantCodeByMedicalRecordsCode(@ApiParam(name = "code", value = "住院病历CODE", required = true)
//                                                   @RequestParam(value = "code", required = true) String code) {
//        try {
//            return write(200, "获取成功！", "data", rehabilitationManageService.getPlantCodeByMedicalRecordsCode(code));
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "calendarPlanDetail", method = RequestMethod.GET)
//    @ApiOperation("康复管理-康复计划按日历展示")
//    public String calendarPlanDetail(
//            @ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "executeStartTime", required = true) String executeStartTime,
//            @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "executeEndTime", required = true) String executeEndTime,
//            @ApiParam(name = "planId", value = "计划id", required = true) @RequestParam(value = "planId", required = true) String planId,
//            @ApiParam(name = "searchTask", value = "快速查找任务：（1、我的任务，2、健康教育，3、复诊，4、随访）", required = false) @RequestParam(value = "searchTask", required = false) Integer searchTask,
//            @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false) @RequestParam(value = "status", required = false) Integer status) {
//        try {
//            ObjEnvelop objEnvelop = rehabilitationManageService.calendarPlanDetail(executeStartTime, executeEndTime, planId, searchTask, status, null);
//            return write(200, "获取成功", "data",objEnvelop );
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "serviceDoctorList", method = RequestMethod.GET)
//    @ApiOperation("康复管理-微信端居民服务医生列表")
//    public String serviceDoctorList() {
//        try {
//            String loginUserCode = getUID();
//            JSONArray result = rehabilitationManageService.serviceDoctorList(loginUserCode);
//            return write(200, "获取成功！", "data", result);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "calendarPlanDetailList", method = RequestMethod.GET)
//    @ApiOperation("康复管理-康复计划按列表展示")
//    public String calendarPlanDetailList(@ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
//                                         @RequestParam(value = "executeStartTime", required = true) String executeStartTime,
//                                         @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
//                                         @RequestParam(value = "executeEndTime", required = true) String executeEndTime,
//                                         @ApiParam(name = "planId", value = "计划id", required = true)
//                                         @RequestParam(value = "planId", required = true) String planId,
//                                         @ApiParam(name = "searchTask", value = "快速查找任务：（1、我的任务，2、健康教育，3、复诊，4、随访）", required = false)
//                                         @RequestParam(value = "searchTask", required = false) Integer searchTask,
//                                         @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false)
//                                         @RequestParam(value = "status", required = false) Integer status) {
//        try {
//            JSONArray result = rehabilitationManageService.calendarPlanDetailList(executeStartTime, executeEndTime, planId, searchTask, status, null);
//            return write(200, "获取成功", "data", result);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "calendarPlanDetailItems", method = RequestMethod.GET)
//    @ApiOperation("康复管理-康复计划服务项目按列表展示")
//    public String calendarPlanDetailItems(@ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
//                                          @RequestParam(value = "executeStartTime", required = true) String executeStartTime,
//                                          @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
//                                          @RequestParam(value = "executeEndTime", required = true) String executeEndTime,
//                                          @ApiParam(name = "planId", value = "计划id", required = true)
//                                          @RequestParam(value = "planId", required = true) String planId,
//                                          @ApiParam(name = "searchTask", value = "快速查找任务：（1、我的任务，2、健康教育，3、健康指导，4、随访，5、复诊）", required = false)
//                                          @RequestParam(value = "searchTask", required = false) Integer searchTask,
//                                          @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false)
//                                          @RequestParam(value = "status", required = false) Integer status) {
//        try {
//            List<Map<String, Object>> result = rehabilitationManageService.calendarPlanDetailItems(executeStartTime, executeEndTime, planId, searchTask, status, null);
//            return write(200, "获取成功", "data", result);
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "selectByGuidance", method = RequestMethod.GET)
//    @ApiOperation("康复管理-根据计划查询指导留言")
//    public String selectByGuidance(@ApiParam(name = "planId", value = "计划id", required = false)
//                                   @RequestParam(value = "planId", required = true) String planId,
//                                   @ApiParam(name = "itemCode", value = "服务项目code", required = true)
//                                   @RequestParam(value = "itemCode", required = true) String itemCode) {
//
//        try {
//            List<Map<String, Object>> mapList = rehabilitationManageService.selectByGuidance(planId, itemCode);
//            return write(200, "获取成功", "data", mapList);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "selectByPlanDetaiId", method = RequestMethod.GET)
//    @ApiOperation("康复管理-获取操作记录")
//    public String selectByPlanDetaiId(
//            @ApiParam(name = "planId", value = "计划id", required = true) @RequestParam(value = "planId", required = true) String planId,
//            @ApiParam(name = "code", value = "服务项目code", required = true) @RequestParam(value = "code", required = true) String code,
//            @ApiParam(name = "page", value = "", required = false) @RequestParam(value = "page", required = false) Integer page,
//            @ApiParam(name = "pagesize", value = "", required = false) @RequestParam(value = "pagesize", required = false) Integer pagesize) {
//        try {
//            return write(200, "获取成功", "data", rehabilitationManageService.selectByPlanDetaiId(null, planId, code, page, pagesize));//patient,
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
//    @GetMapping(value = "getPatientDrugsPlan")
//    @ApiOperation("获取居民用药计划")
//    public String getPatientDrugsPlan(
//            @ApiParam(name = "patient", value = "居民code", required = true) @RequestParam(value = "patient", required = true) String patient,
//            @ApiParam(name = "startTime", value = "开始时间", required = false) @RequestParam(value = "startTime", required = false) String startTime,
//            @ApiParam(name = "endTime", value = "结束时间", required = false) @RequestParam(value = "endTime", required = false) String endTime
//    ) {
//        try {
//            Map<String, List<Map<String, Object>>> result = drugsPlanService.getPatientDrugsPlan(patient, startTime, endTime);
//            return write(200, "获取成功", "data", result);
//        } catch (Exception e) {
//            return error(-1, e.getMessage());
//        }
//    }
    @GetMapping(value = "getPatientRestTime")
    @ApiOperation("获取居民作息时间")
    public String getPatientRestTime(
            @ApiParam(name = "patient", value = "居民code", required = true) @RequestParam(value = "patient", required = true) String patient
    ) {
        try {
            return write(200, "获取成功", "data", patientRestTimeService.getPatientRestTimeMap(patient));
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
    @PostMapping(value = "updRestTime")
    @ApiOperation("修改居民作息时间")
    public String updRestTime(
            @ApiParam(name = "patient", value = "居民code", required = true) @RequestParam(value = "patient", required = true) String patient,
            @ApiParam(name = "jsonData", value = "作息", required = true) @RequestParam(value = "jsonData", required = true) String jsonData) {
        try {
            patientRestTimeService.updRestTime(patient, jsonData);
            return write(200, "修改成功");
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "getPatientDrugList", method = RequestMethod.GET)
//    @ApiOperation("获取居民出院带药列表")
//    public String getPatientDrugList(@ApiParam(name = "patient", value = "居民Code", required = true)
//                                     @RequestParam(value = "patient", required = true) String patient) {
//        try {
//            return write(200, "获取成功", "data", rehabilitationManageService.getPatientDrugList(patient));
//        } catch (Exception e) {
//            return error(-1,e.getMessage());
//        }
//    }
//    @RequestMapping(value = "sendMessageIm", method = RequestMethod.POST)
//    @ApiOperation("康复管理-扫描二维码发送消息")
//    public String sendMessageIm(@ApiParam(name = "sendId", value = "发送者id") @RequestParam(value = "sendId", required = true) String sendId,
//                                @ApiParam(name = "receiverId", value = "接受者id", required = true) @RequestParam(value = "receiverId", required = true) String receiverId,
//                                @ApiParam(name = "content", value = "内容", required = true) @RequestParam(value = "content", required = true) String content) {
//        try {
//            imUtill.sendMessage(sendId, receiverId, "1", content);
//            rehabilitationManageService.sendMessage(sendId, receiverId, content);//发送康复下转邀请
//            return write(200, "发送成功！");
//        } catch (Exception e) {
//            return error(-1, "发送失败！");
//        }
//    }
//    @RequestMapping(value = "checkAfterQrCode", method = RequestMethod.POST)
//    @ApiOperation("康复管理-居民扫码后验证是否是关联的居民扫码")
//    public String checkAfterQrCode(@ApiParam(name = "planDetailId", value = "康复计划项目明细ID") @RequestParam(value = "planDetailId", required = true) String planDetailId,
//                                   @ApiParam(name = "patientCode", value = "居民端登录的居民code") @RequestParam(value = "patientCode", required = true) String patientCode) {
//        try {
//            JSONObject result = rehabilitationManageService.checkAfterQrCode(planDetailId, patientCode);
//            return write(200, String.valueOf(result.get("message")), "data", result.getJSONObject("obj"));
//        } catch (Exception e) {
//
//            return error(-1, "验证失败");
//        }
//    }
//    @RequestMapping(value = "saveRehabilitationOperateRecord", method = RequestMethod.POST)
//    @ApiOperation("康复管理-新增operateRecord")
//    public String saveRehabilitationOperateRecord(@ApiParam(name = "dataJson", value = "实体json", defaultValue = "{\"rehabilitationDetailId\":\"402803f6657f195301657f4fbd3c0001\",\"patientCode\":\"00\",\"patientName\":\"11\",\"doctorCode\":\"22\",\"doctorName\":\"33\",\"node\":\"jjjjjj\",\"relationRecordType\":\"4\",\"relation_record_code\":\"55\",\"relationRecordImg\":\"666666\",\"status\":\"0\"}") @RequestParam(value = "dataJson", required = true) String dataJson) {
//
//        try {
//            JSONObject result = rehabilitationManageService.saveRehabilitationOperateRecord(dataJson);
//            if (result.getInt("status") == 200) {
//                return write(200, "新增康复计划日志成功！", "data", result.getJSONObject("obj"));
//            } else {
//                return error(-1, result.getString("message"));
//            }
//        } catch (Exception e) {
//
//            return error(-1, "新增康复计划日志失败！");
//        }
//    }
//    @RequestMapping(value = "recentPlanDetailRecord", method = RequestMethod.GET)
//    @ApiOperation("康复管理-近期康复相关记录")
//    public String recentPlanDetailRecord(@ApiParam(name = "patientCode", value = "居民code", required = false)
//                                         @RequestParam(value = "patientCode", required = false) String patientCode,
//                                         @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
//                                         @RequestParam(value = "startTime", required = false) String startTime,
//                                         @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
//                                         @RequestParam(value = "endTime", required = false) String endTime,
//                                         @ApiParam(name = "page", value = "第几页，从1开始", required = true)
//                                         @RequestParam(value = "page", required = false, defaultValue = "1") Integer page,
//                                         @ApiParam(name = "pageSize", value = "每页分页大小", required = true)
//                                         @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize) {
//
//        try {
//            if (!StringUtils.isNotEmpty(patientCode)) {
//                patientCode = getUID();
//            }
//            JSONObject result = rehabilitationManageService.recentPlanDetailRecord(patientCode, startTime, endTime, page, pageSize);
//            return write(200, "获取成功！", "data", result);
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "serviceItemList", method = RequestMethod.GET)
//    @ApiOperation("康复管理-多个康复计划服务项目内容列表")
//    public String serviceItemList(@ApiParam(name = "planDetailIds", value = "康复计划多个服务项目id（多个‘，’分隔）", required = true)
//                                  @RequestParam(value = "planDetailIds", required = true) String planDetailIds) {
//
//        try {
//            JSONArray result = rehabilitationManageService.serviceItemList(planDetailIds, null);
//            return write(200, "获取成功", "data", result);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "serviceItem", method = RequestMethod.GET)
//    @ApiOperation("康复管理-康复计划服务项目确认详情页")
//    public String serviceItem(@ApiParam(name = "planDetailId", value = "康复计划服务项目id", required = true)
//                              @RequestParam(value = "planDetailId", required = true) String planDetailId,
//                              @ApiParam(name = "recordId", value = "记录id", required = false)
//                              @RequestParam(value = "recordId", required = false) String recordId) {
//
//        try {
//            JSONObject result = rehabilitationManageService.serviceItem(planDetailId, null, recordId);
//            return write(200, "获取成功", "data", result);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "planSchedule", method = RequestMethod.GET)
//    @ApiOperation("康复管理-计划总进度")
//    public String planSchedule(@ApiParam(name = "planId", value = "计划id", required = true)
//                               @RequestParam(value = "planId", required = true) String planId,
//                               @ApiParam(name = "patientCode", value = "居民code", required = false)
//                               @RequestParam(value = "patientCode", required = false) String patientCode) {
//
//        try {
//            if (!StringUtils.isNotEmpty(patientCode)) {
//                patientCode = getRepUID();
//            }
//            JSONObject result = rehabilitationManageService.planSchedule(planId, patientCode);
//            try {
//                String sql = "UPDATE `wlyy_specialist`.`wlyy_patient_rehabilitation_plan` SET `patient_read_status`='1' WHERE (`id`='" + planId + "') ";
//                jdbcTemplate.update(sql);
//            } catch (Exception e) {
//                e.printStackTrace();
//            }
//            return write(200, "获取成功！", "data", result);
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "updatePatientImgById", method = RequestMethod.POST)
//    @ApiOperation("更新康复计划居民签名照/证件照")
//    public String updatePatientImgById(@ApiParam(name = "planId", value = "康复计划id", required = true)
//                                       @RequestParam(value = "planId") String planId,
//                                       @ApiParam(name = "patientImg", value = "居民签名/证件照地址")
//                                       @RequestParam(value = "patientImg") String patientImg) {
//
//        try {
//            rehabilitationPlanService.updatePatientImgById(planId, patientImg);
//            return write(200, "更新成功！");
//        } catch (Exception e) {
//
//            return error(-1, "更新失败");
//        }
//    }
//    @RequestMapping(value = "getServiceItemsAfterStop", method = RequestMethod.GET)
//    @ApiOperation("康复管理-已执行项目清单")
//    public String getServiceItemsAfterStop(@ApiParam(name = "planId", value = "康复计划id", required = true)
//                                           @RequestParam(value = "planId", required = true) String planId) {
//
//        try {
//            return write(200, "操作成功！", "data", rehabilitationPlanService.getServiceItemsAfterStop(planId));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "selectByRelationCodeAndGuidance", method = RequestMethod.GET)
//    @ApiOperation("康复管理-根据业务code查找康复指导")
//    public String selectByRelationCodeAndGuidance(@ApiParam(name = "relationCode", value = "业务关联code", required = false)
//                                                  @RequestParam(value = "relationCode", required = false) String relationCode,
//                                                  @ApiParam(name = "patient", value = "居民code", required = false)
//                                                  @RequestParam(value = "patient", required = false) String patient,
//                                                  @ApiParam(name = "doctor", value = "医生code", required = false)
//                                                  @RequestParam(value = "doctor", required = false) String doctor) {
//
//        try {
//            return write(200, "请求成功！", "data", rehabilitationGuidanceService.selectByRelationCode(patient, doctor, relationCode));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
//    @GetMapping(value = "selectRelationCodeAndDoor")
//    @ResponseBody
//    @ApiOperation("业务关联code--上门服务")
//    public String selectRelationCodeAndDoor(@ApiParam(name = "relationCode", value = "业务关联code", required = true)
//                                            @RequestParam String relationCode) {
//        try {
//            return write(200, "请求成功！", "data", wlyyDoorServiceOrderService.selectRelationCode(relationCode));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
    @RequestMapping(value = "selectGuidances", method = RequestMethod.GET)
    @ApiOperation("康复管理-查看指导列表")
    public String selectType(
            @ApiParam(name = "type", value = "康复指导类型", required = false) @RequestParam(value = "type", required = false) Integer type,
            @ApiParam(name = "id", value = "康复指导模板id", required = false) @RequestParam(value = "id", required = false) String id,
            @ApiParam(name = "title", value = "康复指导名称", required = false) @RequestParam(value = "title", required = false) String title,
            @ApiParam(name = "planId", value = "计划id", required = false) @RequestParam(value = "planId", required = false) String planId,
            @ApiParam(name = "page", value = "页码", required = false) @RequestParam(value = "page", required = false) Integer page,
            @ApiParam(name = "pagesize", value = "每页大小", required = false) @RequestParam(value = "pagesize", required = false) Integer pagesize
    ) {
        try {
            return write(200, "请求成功！", "data", rehabilitationGuidanceService.select(title, type, id, planId, page, pagesize));
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "selectPlanDetailByPlanId", method = RequestMethod.GET)
//    @ApiOperation("康复管理-查看其它服务计划")
//    public String selectPlanDetailByPlanId(
//            @ApiParam(name = "planId", value = "计划id", required = true) @RequestParam(value = "planId", required = true) String planId,
//            @ApiParam(name = "planDetailId", value = "计划详情id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
//            @ApiParam(name = "itemId", value = "服务项目code", required = true) @RequestParam(value = "itemId", required = true) String itemId
//    ) {
//
//        try {
//            return write(200, "请求成功！", "data", rehabilitationManageService.selectPlanDetailByPlan(planId, planDetailId, itemId));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
    @GetMapping(value = "selectRelationCode")
    @ResponseBody
    @ApiOperation("业务关联code")
    public String selectRelationCode(
            @ApiParam(name = "relationCode", value = "业务关联code", required = true) @RequestParam String relationCode
    ) {
        try {
            return write(200, "请求成功！", "data", wlyyDoorServiceOrderService.selectRelationCode(relationCode));
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
    @RequestMapping(value = "selectByRelationCode", method = RequestMethod.GET)
    @ApiOperation("康复管理-根据业务code查找康复指导")
    public String selectByRelationCode(
            @ApiParam(name = "relationCode", value = "业务关联code", required = false) @RequestParam(value = "relationCode", required = false) String relationCode,
            @ApiParam(name = "patient", value = "居民code", required = false) @RequestParam(value = "patient", required = false) String patient,
            @ApiParam(name = "doctor", value = "医生code", required = false) @RequestParam(value = "doctor", required = false) String doctor
    ) {
        try {
            return write(200, "请求成功！", "data", rehabilitationGuidanceService.selectByRelationCode(patient, doctor, relationCode));
        } catch (Exception e) {
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "getDiseaseTopicInfo", method = RequestMethod.GET)
//    @ApiOperation("获取居民疾病专题首页相关数据")
//    public String getDiseaseTopicInfo(@ApiParam(name = "patientCode", value = "住院病历CODE", required = true)
//                                      @RequestParam(value = "patientCode", required = true) String patientCode,
//                                      @ApiParam(name = "diseaseType", value = "疾病类型", required = true)
//                                      @RequestParam(value = "diseaseType", required = true) String diseaseType) {
//        try {
//            com.alibaba.fastjson.JSONObject object = new com.alibaba.fastjson.JSONObject();
//            object.put("patientId", getUID());
//            return write(200, "获取成功！", "data", rehabilitationManageService.getDiseaseTopicInfo(object, patientCode, diseaseType));
//        } catch (Exception e) {
//
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "getDiseaseHospital", method = RequestMethod.GET)
//    @ApiOperation("获取入住疾病的医院列表")
//    public String getDiseaseHospital(
//            @ApiParam(name = "diseaseType", value = "疾病类型", required = true) @RequestParam(value = "diseaseType", required = true) String diseaseType,
//            @ApiParam(name = "name", value = "医院名称", required = false) @RequestParam(value = "name", required = false) String name,
//            @ApiParam(name = "page", value = "页码", required = false) @RequestParam(value = "page", required = false) Integer page,
//            @ApiParam(name = "pagesize", value = "每页大小", required = false) @RequestParam(value = "pagesize", required = false) Integer pagesize
//    ) {
//        try {
//            if (page == null) {
//                page = 1;
//            }
//            if (pagesize == null) {
//                pagesize = 15;
//            }
//            return write(200, "获取成功！", "data", rehabilitationManageService.getDiseaseHospital(diseaseType, name, page, pagesize));
//        } catch (Exception e) {
//            return error(-1, "请求失败");
//        }
//    }
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/controller/RehabilitationManageController.java

@@ -42,8 +42,8 @@ public class RehabilitationManageController {
    @PostMapping(value = "synchronizePationSingle")
    @ApiOperation("手动重新下转")
    public MixEnvelop synchronizePationSingle(@ApiParam(name = "id", value = "id", required = true)
                                              @RequestParam(value = "id", required = true) Long id) {
    public MixEnvelop synchronizePationSingle(
            @ApiParam(name = "id", value = "id", required = true) @RequestParam(value = "id", required = true) Long id) {
        try {
            String res = synchronizePatientService.synchronizePationSingle(id);
            if (StringUtils.isBlank(res)) {
@@ -74,7 +74,7 @@ public class RehabilitationManageController {
            return rehabilitationManageService.findRehabilitationPlan(doctorType, doctorCode, diseaseCode, planType, todaybacklog, patientCondition, page, pageSize);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return MixEnvelop.getError(e.getMessage());
        }
    }
@@ -89,89 +89,77 @@ public class RehabilitationManageController {
            return rehabilitationManageService.findRehabilitationPlanDetailList(doctorCode, patientCode);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.calendarPlanDetail)
    @ApiOperation(value = "康复管理-康复计划按日历展示")
    public ObjEnvelop calendarPlanDetail(@ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）")
                                         @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
                                         @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）")
                                         @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
                                         @ApiParam(name = "planId", value = "计划id,多个计划逗号隔开", required = true)
                                         @RequestParam(value = "planId", required = true) String planId,
                                         @ApiParam(name = "searchTask", value = "快速查找任务：（1电话/短信关怀,2康复咨询,3健康监测,4上门服务,5康复指导,6康复随访,7康复复诊）", required = false)
                                         @RequestParam(value = "searchTask", required = false) Integer searchTask,
                                         @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false)
                                         @RequestParam(value = "status", required = false) Integer status,
                                         @ApiParam(name = "doctorCode", value = "医生code（专科医生、家庭医生）", required = false)
                                         @RequestParam(value = "doctorCode", required = false) String doctorCode,
                                         @ApiParam(name = "taskExecutor", value = "任务执行人：0全部；1我的任务：2他人任务", required = false)
                                         @RequestParam(value = "taskExecutor", required = false, defaultValue = "0") String taskExecutor) {
    public ObjEnvelop calendarPlanDetail(
            @ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）") @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
            @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）") @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
            @ApiParam(name = "planId", value = "计划id,多个计划逗号隔开", required = true) @RequestParam(value = "planId", required = true) String planId,
            @ApiParam(name = "searchTask", value = "快速查找任务：（1电话/短信关怀,2康复咨询,3健康监测,4上门服务,5康复指导,6康复随访,7康复复诊）", required = false) @RequestParam(value = "searchTask", required = false) Integer searchTask,
            @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false) @RequestParam(value = "status", required = false) Integer status,
            @ApiParam(name = "doctorCode", value = "医生code（专科医生、家庭医生）", required = false) @RequestParam(value = "doctorCode", required = false) String doctorCode,
            @ApiParam(name = "taskExecutor", value = "任务执行人：0全部；1我的任务：2他人任务", required = false) @RequestParam(value = "taskExecutor", required = false, defaultValue = "0") String taskExecutor
    ) {
        try {
            return rehabilitationManageService.calendarPlanDetail(executeStartTime, executeEndTime, planId, searchTask, status, doctorCode, taskExecutor);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.calendarPlanDetailList)
    @ApiOperation(value = "康复管理-康复计划按列表展示")
    public ObjEnvelop calendarPlanDetailList(@ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）")
                                             @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
                                             @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）")
                                             @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
                                             @ApiParam(name = "planId", value = "计划id,多个计划逗号隔开", required = true)
                                             @RequestParam(value = "planId", required = true) String planId,
                                             @ApiParam(name = "searchTask", value = "快速查找任务：（1电话/短信关怀,2康复咨询,3健康监测,4上门服务,5康复指导,6康复随访,7康复复诊）")
                                             @RequestParam(value = "searchTask", required = false) Integer searchTask,
                                             @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）")
                                             @RequestParam(value = "status", required = false) Integer status,
                                             @ApiParam(name = "doctorCode", value = "医生code（专科医生、家庭医生）")
                                             @RequestParam(value = "doctorCode", required = false) String doctorCode,
                                             @ApiParam(name = "taskExecutor", value = "任务执行人：0全部；1我的任务：2他人任务", required = false)
                                             @RequestParam(value = "taskExecutor", required = false, defaultValue = "0") String taskExecutor) {
    public ObjEnvelop calendarPlanDetailList(
            @ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）") @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
            @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）") @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
            @ApiParam(name = "planId", value = "计划id,多个计划逗号隔开", required = true) @RequestParam(value = "planId", required = true) String planId,
            @ApiParam(name = "searchTask", value = "快速查找任务：（1电话/短信关怀,2康复咨询,3健康监测,4上门服务,5康复指导,6康复随访,7康复复诊）") @RequestParam(value = "searchTask", required = false) Integer searchTask,
            @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）") @RequestParam(value = "status", required = false) Integer status,
            @ApiParam(name = "doctorCode", value = "医生code（专科医生、家庭医生）") @RequestParam(value = "doctorCode", required = false) String doctorCode,
            @ApiParam(name = "taskExecutor", value = "任务执行人：0全部；1我的任务：2他人任务", required = false) @RequestParam(value = "taskExecutor", required = false, defaultValue = "0") String taskExecutor
    ) {
        try {
            return rehabilitationManageService.calendarPlanDetailList(planId, searchTask, status, doctorCode, executeStartTime, executeEndTime, taskExecutor);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.serviceItemList)
    @ApiOperation(value = "康复管理-多个康复计划服务项目内容信息列表")
    public ObjEnvelop serviceItemList(@ApiParam(name = "planDetailIds", value = "多个服务项目id用‘，’分隔", required = true)
                                      @RequestParam(value = "planDetailIds", required = true) String planDetailIds,
                                      @ApiParam(name = "doctorCode", value = "医生code", required = false)
                                      @RequestParam(value = "doctorCode", required = false) String doctorCode) {
    public ObjEnvelop serviceItemList(
            @ApiParam(name = "planDetailIds", value = "多个服务项目id用‘，’分隔", required = true) @RequestParam(value = "planDetailIds", required = true) String planDetailIds,
            @ApiParam(name = "doctorCode", value = "医生code", required = false) @RequestParam(value = "doctorCode", required = false) String doctorCode
    ) {
        try {
            return rehabilitationManageService.serviceItemList(planDetailIds, doctorCode);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.serviceItem)
    @ApiOperation(value = "康复管理-康复计划服务项目确认详情页")
    public ObjEnvelop serviceItem(@ApiParam(name = "planDetailId", value = "服务项目id", required = true)
                                  @RequestParam(value = "planDetailId", required = true) String planDetailId,
                                  @ApiParam(name = "doctorCode", value = "医生code", required = false)
                                  @RequestParam(value = "doctorCode", required = false) String doctorCode,
                                  @ApiParam(name = "recordId", value = "记录id", required = false)
                                  @RequestParam(value = "recordId", required = false) String recordId) {
    public ObjEnvelop serviceItem(
            @ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
            @ApiParam(name = "doctorCode", value = "医生code", required = false) @RequestParam(value = "doctorCode", required = false) String doctorCode,
            @ApiParam(name = "recordId", value = "记录id", required = false) @RequestParam(value = "recordId", required = false) String recordId
    ) {
        try {
            return rehabilitationManageService.serviceItem(planDetailId, doctorCode, recordId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -179,50 +167,38 @@ public class RehabilitationManageController {
    @PostMapping(value = "appointmentConsultation")
    @ApiOperation(value = "康复管理-预约协诊")
    public ObjEnvelop appointmentConsultation(
            @ApiParam(name = "patient", value = "居民姓名", required = true)
            @RequestParam(value = "patient", required = true) String patient,
            @ApiParam(name = "doctor", value = "医生code-家医", required = true)
            @RequestParam(value = "doctor", required = true) String doctor,
            @ApiParam(name = "doctorName", value = "医生姓名", required = true)
            @RequestParam(value = "doctorName", required = true) String doctorName,
            @ApiParam(name = "appointmentDoctor", value = "医生code-专科", required = true)
            @RequestParam(value = "appointmentDoctor", required = true) String appointmentDoctor,
            @ApiParam(name = "appointmentDoctorName", value = "医生姓名", required = true)
            @RequestParam(value = "appointmentDoctorName", required = true) String appointmentDoctorName,
            @ApiParam(name = "sendTime", value = "发送时间", required = true)
            @RequestParam(value = "sendTime", required = true) String sendTime,
            @ApiParam(name = "planDetailId", value = "计划明细id", required = true)
            @RequestParam(value = "planDetailId", required = true) String planDetailId) {
            @ApiParam(name = "patient", value = "居民姓名", required = true) @RequestParam(value = "patient", required = true) String patient,
            @ApiParam(name = "doctor", value = "医生code-家医", required = true) @RequestParam(value = "doctor", required = true) String doctor,
            @ApiParam(name = "doctorName", value = "医生姓名", required = true) @RequestParam(value = "doctorName", required = true) String doctorName,
            @ApiParam(name = "appointmentDoctor", value = "医生code-专科", required = true) @RequestParam(value = "appointmentDoctor", required = true) String appointmentDoctor,
            @ApiParam(name = "appointmentDoctorName", value = "医生姓名", required = true) @RequestParam(value = "appointmentDoctorName", required = true) String appointmentDoctorName,
            @ApiParam(name = "sendTime", value = "发送时间", required = true) @RequestParam(value = "sendTime", required = true) String sendTime,
            @ApiParam(name = "planDetailId", value = "计划明细id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId
    ) {
        try {
            return rehabilitationManageService.appointmentConsultation(patient, doctor, doctorName, appointmentDoctor, appointmentDoctorName, sendTime, planDetailId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @PostMapping(value = SpecialistMapping.rehabilitation.saveGuidanceMessage)
    @ApiOperation(value = "康复管理-保存指导留言")
    public Envelop saveGuidanceMessage(@ApiParam(name = "messageId", value = "消息id", required = true)
                                       @RequestParam(value = "messageId", required = true) String messageId,
//                                       @ApiParam(name = "patientCode", value = "居民code", required = true)
//                                       @RequestParam(value = "patientCode", required = true)String patientCode,
                                       @ApiParam(name = "doctorCode", value = "医生code", required = true)
                                       @RequestParam(value = "doctorCode", required = true) String doctorCode,
                                       @ApiParam(name = "doctorType", value = "医生类型（1、专科医生，2、家庭医生）", required = true)
                                       @RequestParam(value = "doctorType", required = true) Integer doctorType,
                                       @ApiParam(name = "content", value = "聊天内容", required = true)
                                       @RequestParam(value = "content", required = true) String content,
                                       @ApiParam(name = "planDetailId", value = "服务项目id", required = true)
                                       @RequestParam(value = "planDetailId", required = true) String planDetailId,
                                       @ApiParam(name = "contentType", value = "内容类型（1,6,8 - 文本， 2，9- 图片， 3 - 语音， 4-文章， 5,7系统消息。12-语音 18-居民名片， 19-聊天记录）", required = true)
                                       @RequestParam(value = "contentType", required = true) Integer contentType) {
    public Envelop saveGuidanceMessage(
            @ApiParam(name = "messageId", value = "消息id", required = true) @RequestParam(value = "messageId", required = true) String messageId,
            @ApiParam(name = "patientCode", value = "居民code", required = false) @RequestParam(value = "patientCode", required = false) String patientCode,
            @ApiParam(name = "doctorCode", value = "医生code", required = true) @RequestParam(value = "doctorCode", required = true) String doctorCode,
            @ApiParam(name = "doctorType", value = "医生类型（1、专科医生，2、家庭医生）", required = true) @RequestParam(value = "doctorType", required = true) Integer doctorType,
            @ApiParam(name = "content", value = "聊天内容", required = true) @RequestParam(value = "content", required = true) String content,
            @ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
            @ApiParam(name = "contentType", value = "内容类型（1,6,8 - 文本， 2，9- 图片， 3 - 语音， 4-文章， 5,7系统消息。12-语音 18-居民名片， 19-聊天记录）", required = true)
            @RequestParam(value = "contentType", required = true) Integer contentType) {
        try {
            return rehabilitationManageService.saveGuidanceMessage(messageId, doctorCode, doctorType, content, planDetailId, contentType);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
@@ -237,7 +213,6 @@ public class RehabilitationManageController {
            return rehabilitationManageService.updateStatusRehabilitationOperate(status, planDetailId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
@@ -245,21 +220,17 @@ public class RehabilitationManageController {
    @GetMapping(value = SpecialistMapping.rehabilitation.patientRehabilitationDetail)
    @ApiOperation(value = "康复管理-居民详情页")
    public Envelop patientRehabilitationDetail(@ApiParam(name = "patientCode", value = "居民code", required = true)
                                               @RequestParam(value = "patientCode", required = true) String patientCode,
                                               @ApiParam(name = "healthDoctor", value = "健管师医生code", required = false)
                                               @RequestParam(value = "healthDoctor", required = false) String healthDoctor,
                                               @ApiParam(name = "healthDoctorName", value = "健管师医生名称", required = false)
                                               @RequestParam(value = "healthDoctorName", required = false) String healthDoctorName,
                                               @ApiParam(name = "generalDoctor", value = "全科医生code", required = false)
                                               @RequestParam(value = "generalDoctor", required = false) String generalDoctor,
                                               @ApiParam(name = "generalDoctorName", value = "全科医生名称", required = false)
                                               @RequestParam(value = "generalDoctorName", required = false) String generalDoctorName) {
    public Envelop patientRehabilitationDetail(
            @ApiParam(name = "patientCode", value = "居民code", required = true) @RequestParam(value = "patientCode", required = true) String patientCode,
            @ApiParam(name = "healthDoctor", value = "健管师医生code", required = false) @RequestParam(value = "healthDoctor", required = false) String healthDoctor,
            @ApiParam(name = "healthDoctorName", value = "健管师医生名称", required = false) @RequestParam(value = "healthDoctorName", required = false) String healthDoctorName,
            @ApiParam(name = "generalDoctor", value = "全科医生code", required = false) @RequestParam(value = "generalDoctor", required = false) String generalDoctor,
            @ApiParam(name = "generalDoctorName", value = "全科医生名称", required = false) @RequestParam(value = "generalDoctorName", required = false) String generalDoctorName
    ) {
        try {
            return rehabilitationManageService.patientRehabilitationDetail(patientCode, healthDoctor, healthDoctorName, generalDoctor, generalDoctorName);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
@@ -267,93 +238,79 @@ public class RehabilitationManageController {
    @GetMapping(value = SpecialistMapping.rehabilitation.recentPlanDetailRecord)
    @ApiOperation(value = "居民康复计划详情页-近期康复相关记录")
    public Envelop recentPlanDetailRecord(
            @ApiParam(name = "patientCode", value = "居民code", required = true)
            @RequestParam(value = "patientCode", required = true) String patientCode,
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
            @RequestParam(value = "startTime", required = false) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = false)
            @RequestParam(value = "endTime", required = false) String endTime,
            @ApiParam(name = "page", value = "第几页，从1开始", required = true)
            @RequestParam(value = "page", required = false, defaultValue = "1") Integer page,
            @ApiParam(name = "pageSize", value = "每页分页大小", required = true)
            @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize) {
            @ApiParam(name = "patientCode", value = "居民code", required = true) @RequestParam(value = "patientCode", required = true) String patientCode,
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = false) @RequestParam(value = "startTime", required = false) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = false) @RequestParam(value = "endTime", required = false) String endTime,
            @ApiParam(name = "page", value = "第几页，从1开始", required = true) @RequestParam(value = "page", required = false, defaultValue = "1") Integer page,
            @ApiParam(name = "pageSize", value = "每页分页大小", required = true) @RequestParam(value = "pageSize", required = false, defaultValue = "10") Integer pageSize) {
        try {
            return rehabilitationManageService.recentPlanDetailRecord(patientCode, startTime, endTime, page, pageSize);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.serviceDoctorList)
    @ApiOperation(value = "康复管理-医生端居民详情服务医生列表")
    public Envelop serviceDoctorList(@ApiParam(name = "patientCode", value = "居民code", required = true)
                                     @RequestParam(value = "patientCode", required = true) String patientCode,
                                     @ApiParam(name = "healthDoctor", value = "健管师医生code", required = false)
                                     @RequestParam(value = "healthDoctor", required = false) String healthDoctor,
                                     @ApiParam(name = "healthDoctorName", value = "健管师医生名称", required = false)
                                     @RequestParam(value = "healthDoctorName", required = false) String healthDoctorName,
                                     @ApiParam(name = "generalDoctor", value = "全科医生code", required = false)
                                     @RequestParam(value = "generalDoctor", required = false) String generalDoctor,
                                     @ApiParam(name = "generalDoctorName", value = "全科医生名称", required = false)
                                     @RequestParam(value = "generalDoctorName", required = false) String generalDoctorName) {
    public Envelop serviceDoctorList(
            @ApiParam(name = "patientCode", value = "居民code", required = true) @RequestParam(value = "patientCode", required = true) String patientCode,
            @ApiParam(name = "healthDoctor", value = "健管师医生code", required = false) @RequestParam(value = "healthDoctor", required = false) String healthDoctor,
            @ApiParam(name = "healthDoctorName", value = "健管师医生名称", required = false) @RequestParam(value = "healthDoctorName", required = false) String healthDoctorName,
            @ApiParam(name = "generalDoctor", value = "全科医生code", required = false) @RequestParam(value = "generalDoctor", required = false) String generalDoctor,
            @ApiParam(name = "generalDoctorName", value = "全科医生名称", required = false) @RequestParam(value = "generalDoctorName", required = false) String generalDoctorName
    ) {
        try {
            return rehabilitationManageService.serviceDoctorList(patientCode, healthDoctor, healthDoctorName, generalDoctor, generalDoctorName);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.appCalendarPlanDetailList)
    @ApiOperation(value = "康复管理-app端、微信端计划的服务项目列表")
    public ObjEnvelop appCalendarPlanDetailList(@ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                                @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
                                                @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                                @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
                                                @ApiParam(name = "planId", value = "计划id", required = true)
                                                @RequestParam(value = "planId", required = true) String planId,
                                                @ApiParam(name = "searchTask", value = "快速查找任务：（1、我的任务，2、随访，3、复诊，4、健康教育）", required = false)
                                                @RequestParam(value = "searchTask", required = false) Integer searchTask,
                                                @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false)
                                                @RequestParam(value = "status", required = false) Integer status) {
    public ObjEnvelop appCalendarPlanDetailList(
            @ApiParam(name = "executeStartTime", value = "日历开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "executeStartTime", required = false) String executeStartTime,
            @ApiParam(name = "executeEndTime", value = "日历结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "executeEndTime", required = false) String executeEndTime,
            @ApiParam(name = "planId", value = "计划id", required = true) @RequestParam(value = "planId", required = true) String planId,
            @ApiParam(name = "searchTask", value = "快速查找任务：（1、我的任务，2、随访，3、复诊，4、健康教育）", required = false) @RequestParam(value = "searchTask", required = false) Integer searchTask,
            @ApiParam(name = "status", value = "任务状态（0未完成，1已完成，2已预约）", required = false) @RequestParam(value = "status", required = false) Integer status
    ) {
        try {
            return rehabilitationManageService.appCalendarPlanDetailList(planId, searchTask, status, executeStartTime, executeEndTime);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.dailyJob)
    @ApiOperation(value = "每日康复服务通知")
    public ObjEnvelop dailyJob(@ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                               @RequestParam(value = "startTime", required = true) String startTime,
                               @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                               @RequestParam(value = "endTime", required = true) String endTime) {
    public ObjEnvelop dailyJob(
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "startTime", required = true) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "endTime", required = true) String endTime
    ) {
        try {
            return rehabilitationManageService.dailyJob(startTime, endTime);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.tomorrowJob)
    @ApiOperation(value = "明日康复服务通知")
    public ObjEnvelop tomorrowJob(@ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                  @RequestParam(value = "startTime", required = true) String startTime,
                                  @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                  @RequestParam(value = "endTime", required = true) String endTime) {
    public ObjEnvelop tomorrowJob(
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "startTime", required = true) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "endTime", required = true) String endTime
    ) {
        try {
            return rehabilitationManageService.tomorrowJob(startTime, endTime);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -361,33 +318,33 @@ public class RehabilitationManageController {
    @GetMapping(value = SpecialistMapping.rehabilitation.dailyByJob)
    @ApiOperation(value = "每日康复计划提醒")
    public ObjEnvelop dailyByJob(@ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                 @RequestParam(value = "startTime", required = true) String startTime,
                                 @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                 @RequestParam(value = "endTime", required = true) String endTime) {
    public ObjEnvelop dailyByJob(
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "startTime", required = true) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "endTime", required = true) String endTime
    ) {
        try {
            return rehabilitationManageService.dailyByJob(startTime, endTime);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @PostMapping(value = SpecialistMapping.rehabilitation.updateNoteAndImageRehabilitationOperate)
    @ApiOperation(value = "康复计划完成时更新服务完成笔记和图片接口并且确认完成")
    public ObjEnvelop updateNoteAndImageRehabilitationOperate(@ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
                                                              @ApiParam(name = "node", value = "服务完成笔记", required = true) @RequestParam(value = "node", required = false) String node,
                                                              @ApiParam(name = "image", value = "相关记录图片，json格式", required = true) @RequestParam(value = "image", required = false) String image,
                                                              @ApiParam(name = "relationCode", value = "业务code", required = true) @RequestParam(value = "relationCode", required = false) String relationCode,
                                                              @ApiParam(name = "status", value = "是否确认完成 0未确认 1确认", required = true) @RequestParam(value = "status", required = false) String status) {
    public ObjEnvelop updateNoteAndImageRehabilitationOperate(
            @ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
            @ApiParam(name = "node", value = "服务完成笔记", required = true) @RequestParam(value = "node", required = false) String node,
            @ApiParam(name = "image", value = "相关记录图片，json格式", required = true) @RequestParam(value = "image", required = false) String image,
            @ApiParam(name = "relationCode", value = "业务code", required = true) @RequestParam(value = "relationCode", required = false) String relationCode,
            @ApiParam(name = "status", value = "是否确认完成 0未确认 1确认", required = true) @RequestParam(value = "status", required = false) String status
    ) {
        try {
            Map<String, Object> map = rehabilitationManageService.updateNodeAndRelationRecordImg(node, image, status, planDetailId, relationCode);
            return ObjEnvelop.getSuccess(SpecialistMapping.api_success, map);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -402,22 +359,22 @@ public class RehabilitationManageController {
            return MixEnvelop.getSuccess(SpecialistMapping.api_success, rehabilitationManageService.planDetailAfterCall(dataJson));
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return MixEnvelop.getError(e.getMessage());
        }
    }
    @PostMapping(value = SpecialistMapping.rehabilitation.updatePlanDetailStatusById)
    @ApiOperation(value = "康复管理-更新康复计划项目状态")
    public Envelop updatePlanDetailStatusById(@ApiParam(name = "planDetailId", value = "服务项目id", required = true)
                                              @RequestParam(value = "planDetailId", required = true) String planDetailId,
                                              @ApiParam(name = "status", value = "状态", required = true)
                                              @RequestParam(value = "status", required = true) Integer status) {
    public Envelop updatePlanDetailStatusById(
            @ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
            @ApiParam(name = "status", value = "状态", required = true) @RequestParam(value = "status", required = true) Integer status
    ) {
        try {
            return rehabilitationManageService.updatePlanDetailStatusById(status, planDetailId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
@@ -425,16 +382,15 @@ public class RehabilitationManageController {
    @PostMapping(value = SpecialistMapping.rehabilitation.updatePlanDetailExecuteTimeById)
    @ApiOperation(value = "康复管理-修改康复计划项目执行时间")
    public Envelop updatePlanDetailExecuteTimeById(@ApiParam(name = "planDetailId", value = "服务项目id", required = true)
                                                   @RequestParam(value = "planDetailId", required = true) String planDetailId,
                                                   @ApiParam(name = "executeTime", value = "状态", required = true)
                                                   @RequestParam(value = "executeTime", required = true) String executeTime) {
    public Envelop updatePlanDetailExecuteTimeById(
            @ApiParam(name = "planDetailId", value = "服务项目id", required = true) @RequestParam(value = "planDetailId", required = true) String planDetailId,
            @ApiParam(name = "executeTime", value = "状态", required = true) @RequestParam(value = "executeTime", required = true) String executeTime
    ) {
        try {
            Date date = DateUtil.strToDateLong(executeTime);
            return rehabilitationManageService.updatePlanDetailExecuteTimeById(date, planDetailId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return Envelop.getError(e.getMessage());
        }
    }
@@ -442,13 +398,14 @@ public class RehabilitationManageController {
    @GetMapping(value = SpecialistMapping.rehabilitation.planSchedule)
    @ApiOperation(value = "康复管理-计划总进度")
    public ObjEnvelop planSchedule(@ApiParam(name = "planId", value = "计划id", required = true)
                                   @RequestParam(value = "planId", required = true) String planId) {
    public ObjEnvelop planSchedule(
            @ApiParam(name = "planId", value = "计划id", required = true) @RequestParam(value = "planId", required = true) String planId
    ) {
        try {
            return rehabilitationManageService.planSchedule(planId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -461,7 +418,6 @@ public class RehabilitationManageController {
            return rehabilitationManageService.planListByPatient(patientCode);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -474,22 +430,20 @@ public class RehabilitationManageController {
            return rehabilitationManageService.patientCount(doctorCode);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
    @GetMapping(value = SpecialistMapping.rehabilitation.dailyJobReserve)
    @ApiOperation(value = "10天、7天、5天、当天康复服务预约复诊通知")
    public ObjEnvelop dailyJobReserve(@ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                      @RequestParam(value = "startTime", required = true) String startTime,
                                      @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true)
                                      @RequestParam(value = "endTime", required = true) String endTime) {
    public ObjEnvelop dailyJobReserve(
            @ApiParam(name = "startTime", value = "开始时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "startTime", required = true) String startTime,
            @ApiParam(name = "endTime", value = "结束时间（格式：yyyy-MM-dd HH:mm:ss）", required = true) @RequestParam(value = "endTime", required = true) String endTime
    ) {
        try {
            return rehabilitationManageService.dailyJobReserve(startTime, endTime);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -503,13 +457,13 @@ public class RehabilitationManageController {
     */
    @PostMapping(value = SpecialistMapping.rehabilitation.selectByIds)
    @ApiOperation(value = "查询康复服务项目")
    public ObjEnvelop selectByIds(@ApiParam(name = "ids", value = "康复服务套餐明细表ids")
                                  @RequestParam(value = "ids", required = true) String ids) {
    public ObjEnvelop selectByIds(
            @ApiParam(name = "ids", value = "康复服务套餐明细表ids") @RequestParam(value = "ids", required = true) String ids
    ) {
        try {
            return rehabilitationManageService.selectByIds(ids);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }
@@ -522,7 +476,6 @@ public class RehabilitationManageController {
            return rehabilitationManageService.getServiceItemsAfterStop(planId);
        } catch (Exception e) {
            e.printStackTrace();
            //tracer.getCurrentSpan().logEvent(e.getMessage());
            return ObjEnvelop.getError(e.getMessage());
        }
    }

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/dao/RehabilitationGuidanceDao.java

@@ -0,0 +1,15 @@
package com.yihu.jw.hospital.module.rehabilitation.dao;
import com.yihu.jw.entity.rehabilitation.RehabilitationguidanceDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface RehabilitationGuidanceDao extends PagingAndSortingRepository<RehabilitationguidanceDO, Long>, JpaSpecificationExecutor<RehabilitationguidanceDO> {
    @Query("select p from RehabilitationguidanceDO p where p.code = ?1 and p.del=1")
    RehabilitationguidanceDO findByCode(String code);
//    Page<RehabilitationguidanceDO> findByCondition(String sql,PageRequest page);
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/dao/RehabilitationGuidancePatientDao.java

@@ -0,0 +1,17 @@
package com.yihu.jw.hospital.module.rehabilitation.dao;
import com.yihu.jw.entity.rehabilitation.RehabilitationguidancePatientDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.List;
public interface RehabilitationGuidancePatientDao extends PagingAndSortingRepository<RehabilitationguidancePatientDO, Long>, JpaSpecificationExecutor<RehabilitationguidancePatientDO> {
    @Query("select p from RehabilitationguidancePatientDO p where p.patient = ?1 and p.doctor=?2 ")
    List<RehabilitationguidancePatientDO> findByPatientAndDoctor(String patient, String doctor);
    @Query("select p from RehabilitationguidancePatientDO p where  p.relationCode=?1")
    List<RehabilitationguidancePatientDO> findByRelationCode(String relationCode);
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/RehabilitationGuidanceService.java

@@ -0,0 +1,387 @@
package com.yihu.jw.hospital.module.rehabilitation.service;
import com.yihu.jw.doctor.dao.BaseDoctorDao;
import com.yihu.jw.entity.base.doctor.BaseDoctorDO;
import com.yihu.jw.entity.base.patient.BasePatientDO;
import com.yihu.jw.entity.rehabilitation.RehabilitationguidanceDO;
import com.yihu.jw.entity.rehabilitation.RehabilitationguidancePatientDO;
import com.yihu.jw.entity.util.TransforSqlUtl;
import com.yihu.jw.hospital.module.rehabilitation.dao.RehabilitationGuidanceDao;
import com.yihu.jw.hospital.module.rehabilitation.dao.RehabilitationGuidancePatientDao;
import com.yihu.jw.hospital.task.PushMsgTask;
import com.yihu.jw.hospital.utils.WeiXinAccessTokenUtils;
import com.yihu.jw.hospital.utils.WeiXinOpenIdUtils;
import com.yihu.jw.patient.dao.BasePatientDao;
import com.yihu.jw.util.date.DateUtil;
import org.apache.commons.lang3.StringEscapeUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springside.modules.persistence.DynamicSpecifications;
import org.springside.modules.persistence.SearchFilter;
import java.util.*;
/**
 * Created by wangzhinan on 2018/8/29.
 */
@Service
@Transactional
public class RehabilitationGuidanceService {
    private Logger logger = LoggerFactory.getLogger(RehabilitationGuidanceService.class);
    @Autowired
    private RehabilitationGuidanceDao rehabilitationGuidanceDao;
    @Autowired
    private RehabilitationGuidancePatientDao rehabilitationGuidancePatientDao;
    @Autowired
    private BaseDoctorDao doctorDao;
    @Autowired
    private BasePatientDao patientDao;
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private PushMsgTask pushMsgTask;
    @Autowired
    private WeiXinAccessTokenUtils weiXinAccessTokenUtils;
    @Autowired
    private WeiXinOpenIdUtils weiXinOpenIdUtils;
    /**
     * 康复指导类型标题
     *
     * @return
     */
    public List<Map<String, Object>> selectType(String planId) {
        String disease = "";
        if (StringUtils.isNoneBlank(planId)) {
            String sql = "select * from wlyy_specialist.wlyy_patient_rehabilitation_plan where id='" + planId + "' ";
            sql = TransforSqlUtl.wlyy_patient_rehabilitation_planAll(sql);
            Map<String, Object> map = jdbcTemplate.queryForMap(sql);
            if (map.get("disease") != null && StringUtils.isNoneBlank(map.get("disease").toString())) {
                disease = map.get("disease").toString();
            }
        }
        StringBuffer sql = new StringBuffer("select g.type,g.type_name as typeName,COUNT(g.id) as number from wlyy_rehabilitation_guidance g where g.del=1 ");
        if (StringUtils.isNoneBlank(disease)) {
            sql.append("and g.type in ( '").append(disease.replace(",", "','")).append("') ");
        }
        sql.append("group by g.type");
        List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql.toString());
        return mapList;
    }
    /**
     * 查询康复指导列表
     *
     * @param type
     * @param code
     * @param page
     * @param pagesize
     * @return
     */
    public Page<RehabilitationguidanceDO> select(String title, Integer type, String code, String planId, Integer page, Integer pagesize) {
        String disease = "";
        if (StringUtils.isNoneBlank(planId)) {
            String sql = "select * from wlyy_specialist.wlyy_patient_rehabilitation_plan where id='" + planId + "' ";
            sql = TransforSqlUtl.wlyy_patient_rehabilitation_planAll(sql);
            Map<String, Object> map = jdbcTemplate.queryForMap(sql);
            if (map.get("disease") != null && StringUtils.isNoneBlank(map.get("disease").toString())) {
                disease = map.get("disease").toString();
            }
        }
        if (page >= 1) {
            page--;
        }
        if (pagesize <= 0) {
            pagesize = 10;
        }
        StringBuffer sql = new StringBuffer("select * from wlyy_rehabilitation_guidance where 1=1 and del =1 ");
        StringBuffer sqlCounts = new StringBuffer("select count(1) from wlyy_rehabilitation_guidance where 1=1 and del =1 ");
        if (StringUtils.isNoneBlank(code)) {
            sql.append("and code='" + code + "' ");
            sqlCounts.append("and code='" + code + "' ");
        }
        if (type != null) {
            sql.append("and type='" + type + "' ");
            sqlCounts.append("and type='" + type + "' ");
        }
        if (StringUtils.isNoneBlank(title)) {
            sql.append("and title like '%" + title + "%' ");
            sqlCounts.append("and title like '%" + title + "%' ");
        }
        if (StringUtils.isNoneBlank(disease)) {
            sql.append("and type in ( '").append(disease.replace(",", "','")).append("') ");
            sqlCounts.append("and type in ( '").append(disease.replace(",", "','")).append("') ");
        }
        sql.append("order by czrq desc limit " + page * pagesize + "," + (page + 1) * pagesize);
        List<RehabilitationguidanceDO> list = jdbcTemplate.query(sql.toString(), new BeanPropertyRowMapper<>(RehabilitationguidanceDO.class));
        Long totalCount = jdbcTemplate.queryForObject(sqlCounts.toString(), Long.class);
        for (RehabilitationguidanceDO temp : list) {
            String contents = temp.getContent();
            temp.setContent(StringEscapeUtils.unescapeJava(contents));
        }
        PageRequest pageRequest = PageRequest.of(page, pagesize);
        if (list.size() <= 0) {
            return new PageImpl(new ArrayList<>(), pageRequest, 0);
        }
        return new PageImpl(list, pageRequest, totalCount);
    }
    public Page<RehabilitationguidancePatientDO> selectPatientGuidances(String patient, String doctor, String code, Integer page, Integer pagesize) {
        if (page >= 1) {
            page--;
        }
        if (pagesize <= 0) {
            pagesize = 10;
        }
        // 排序
        Sort sort = Sort.by(Sort.Direction.DESC, "czrq");
        // 分页信息
        PageRequest pageRequest = PageRequest.of(page, pagesize, sort);
        // 设置查询条件
        Map<String, SearchFilter> filters = new HashMap<String, SearchFilter>();
        // 指定患者
        if (StringUtils.isNoneBlank(code)) {
            filters.put("code", new SearchFilter("code", SearchFilter.Operator.EQ, code));
        }
        if (StringUtils.isNoneBlank(patient)) {
            filters.put("patient", new SearchFilter("patient", SearchFilter.Operator.EQ, patient));
        }
        if (StringUtils.isNoneBlank(doctor)) {
            filters.put("doctor", new SearchFilter("doctor", SearchFilter.Operator.EQ, doctor));
        }
        Specification<RehabilitationguidancePatientDO> spec = DynamicSpecifications.bySearchFilter(filters.values(), RehabilitationguidancePatientDO.class);
        Page<RehabilitationguidancePatientDO> rehabilitationguidancePatientDOS = rehabilitationGuidancePatientDao.findAll(spec, pageRequest);
        for (RehabilitationguidancePatientDO rehabilitationguidancePatientDO : rehabilitationguidancePatientDOS) {
            BasePatientDO patient1 = patientDao.findById(rehabilitationguidancePatientDO.getPatient()).orElse(null);
            rehabilitationguidancePatientDO.setPhoto(patient1.getPhoto());
        }
        return rehabilitationguidancePatientDOS;
    }
    /**
     * 发送康复指导
     *
     * @param rehabilitationguidancePatientDOS
     * @return
     */
    public List<RehabilitationguidancePatientDO> sendGuidanceToPatient(List<RehabilitationguidancePatientDO> rehabilitationguidancePatientDOS, String planId) throws Exception {
        for (RehabilitationguidancePatientDO rehabilitationguidancePatientDO : rehabilitationguidancePatientDOS) {
            RehabilitationguidanceDO rehabilitationguidanceDO = rehabilitationGuidanceDao.findByCode(rehabilitationguidancePatientDO.getArticle());
            rehabilitationguidanceDO.setUseCount(rehabilitationguidanceDO.getUseCount() + 1);
            rehabilitationGuidanceDao.save(rehabilitationguidanceDO);
            BasePatientDO patient = patientDao.findById(rehabilitationguidancePatientDO.getPatient()).orElse(null);
            BaseDoctorDO doctor = doctorDao.findById(rehabilitationguidancePatientDO.getDoctor()).orElse(null);
            rehabilitationguidancePatientDO.setAttachedTitle(rehabilitationguidanceDO.getTitle());
            if (patient != null) {
                rehabilitationguidancePatientDO.setName(patient.getName());
            }
            if (doctor != null) {
                rehabilitationguidancePatientDO.setDoctorName(doctor.getName());
            }
            rehabilitationguidancePatientDO.setAttachedContent(rehabilitationguidanceDO.getContent());
            rehabilitationguidancePatientDO.setCzrq(new Date());
            rehabilitationguidancePatientDO.setIsRead(0);
            rehabilitationguidancePatientDO.setSendStatus(0);
            rehabilitationguidancePatientDO = rehabilitationGuidancePatientDao.save(rehabilitationguidancePatientDO);
            this.sendSpecialistWeixinMessage(rehabilitationguidancePatientDO.getPatient(), rehabilitationguidancePatientDO.getDoctor(), 1, rehabilitationguidancePatientDO.getArticle(), planId, null);
        }
        return rehabilitationguidancePatientDOS;
    }
    /**
     * 查看发送的康复指导
     *
     * @param patient
     * @param doctor
     * @param relationCode
     * @return
     */
    public List<RehabilitationguidancePatientDO> selectByRelationCode(String patient, String doctor, String relationCode) {
        if (StringUtils.isNoneBlank(relationCode)) {
            return rehabilitationGuidancePatientDao.findByRelationCode(relationCode);
        } else {
            return rehabilitationGuidancePatientDao.findByPatientAndDoctor(patient, doctor);
        }
    }
    /**
     * 康复计划-微信模板发送
     *
     * @param patientCode  居民code
     * @param doctorCode   专科医生code
     * @param type         1康复指导2康复下转3复诊提醒4上门服务提醒5家签提醒
     * @param relationCode 业务关联code
     * @param planId       计划id
     * @throws Exception
     */
    public void sendSpecialistWeixinMessage(String patientCode, String doctorCode, Integer type, String relationCode, String planId, String reservationType) throws Exception {
        //康复指导
        BasePatientDO patient = patientDao.findById(patientCode).orElse(null);
        BaseDoctorDO doctor = doctorDao.findById(doctorCode).orElse(null);
//        SignFamily signFamily = signFamilyDao.findByPatient(patientCode);
        String name = "";
        String doctorName = "";
        String familyDoctorName = "";
        org.json.JSONObject json = new org.json.JSONObject();
        if (patient != null) {
            name = patient.getName();
        }
        if (doctor != null) {
            doctorName = doctor.getName();
        }
//        if (signFamily != null) {
//            familyDoctorName = signFamily.getDoctorName();
//        }
        Integer sendType = null;
        if (type == 1) {
            RehabilitationguidanceDO rehabilitationguidanceDO = rehabilitationGuidanceDao.findByCode(relationCode);
            json.put("toUser", patientCode);
            json.put("first", patient.getName() + "，您好！您的家庭医生发来一篇健康文章！");
            json.put("represented", patientCode);//被代理人
            json.put("id", planId);
            json.put("date", DateUtil.getStringDate());
//            json.put("orgName", doctor.getHospitalName());
            json.put("doctorName", doctor.getName());
            json.put("content", "《" + rehabilitationguidanceDO.getTitle() + "》");
            json.put("remark", "请及时阅读");
            json.put("url", "kfgl/html/plan-item-detail.html?planIds=" + planId + "");
            sendType = 36;
        } else if (type == 2) {
            //反馈处理30
            sendType = 30;
            String sql = "SELECT pr.manage_time as manageTime,pr.is_manage as isManage " +
                    "FROM wlyy_specialist.`wlyy_specialist_patient_relation` pr " +
                    "where pr.doctor = '" + doctorCode + "' and pr.patient = '" + patientCode + "' and pr.sign_status=1 and pr.`status`=1";
            List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
            String manageTime = "";
            for (Map<String, Object> map : mapList) {
                manageTime = DateUtil.dateToStrLong((Date) map.get("manageTime"));
            }
            json.put("first", patient.getName() + "，您好！您已成功签约专科医生“" + doctorName + "”，" + doctorName + "医生（专科医生）和" + familyDoctorName + "（全科医生）将为您提供康复管理服务");
            json.put("toUser", patientCode);
            json.put("represented", patientCode);//被代理人
            json.put("keyword1", manageTime);
            json.put("keyword2", "康复下转");
            json.put("remark", "请及时阅读");
            json.put("relationCode", 1);
            json.put("url", "kfgl/html/recover_manage.html");
        } else if (type == 3) {
            //复诊提醒3
            //更新复诊类型
            if (StringUtils.isNoneBlank(reservationType)) {
                String updSql = "update wlyy_specialist.wlyy_rehabilitation_plan_detail set reservation_type = " + reservationType + " where id = '" + relationCode + "'";
                jdbcTemplate.execute(updSql);
            }
            sendType = 11;//待办事项
            String sql = "select pd.id,pd.execute_time as executeTime from wlyy_specialist.wlyy_rehabilitation_plan_detail pd " +
                    "where pd.id ='" + relationCode + "' and pd.hospital_service_item_id='7' and pd.status <>1 order by pd.execute_time desc ";
            List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
            String excuteTime = "";
            if (mapList != null && mapList.size() != 0) {
                excuteTime = DateUtil.dateToStrLong((Date) mapList.get(0).get("executeTime"));
            }
            if (StringUtils.isNoneBlank(excuteTime)) {
                json.put("first", patient.getName() + "，您好！您的下次复诊时间是[" + excuteTime + "]，请按时安排就诊。您可点击“查看详情”，提前预约就诊");
            } else {
                json.put("first", patient.getName() + "，您好！" + doctor.getName() + "医生提醒您预约复诊。您可点击“查看详情”，提前预约就诊");
            }
            json.put("toUser", patientCode);
            json.put("represented", patientCode);//被代理人
            json.put("keyword1", "复诊预约");
            json.put("keyword2", "" + DateUtil.getStringDate() + "");
            json.put("remark", "请及时阅读");
            json.put("url", "wdyy/html/appointment-register.html");
        } else if (type == 4) {
            //上门服务提醒 4
            sendType = 11;//待办事项
            String sql = "select pd.id,pd.execute_time as executeTime from wlyy_specialist.wlyy_rehabilitation_plan_detail pd " +
                    "where pd.id ='" + relationCode + "' and pd.hospital_service_item_id='4' and pd.status <>1 order by pd.execute_time desc ";
            List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
            String excuteTime = "";
            String detailId = "";
            if (mapList != null && mapList.size() != 0) {
                excuteTime = DateUtil.dateToStrLong((Date) mapList.get(0).get("executeTime"));
            }
            if (StringUtils.isNoneBlank(excuteTime)) {
                json.put("first", patient.getName() + "，您好！您的下次上门诊疗服务时间是[" + excuteTime + "]，请按时预约上门诊疗服务。您可点击“查看详情”，提前预约就诊");
            } else {
                json.put("first", patient.getName() + "，您好！" + doctor.getName() + "医生提醒您预约上门服务。您可点击“查看详情”，提前预约就诊");
            }
            json.put("toUser", patientCode);
            json.put("represented", patientCode);//被代理人
            json.put("keyword1", "上门诊疗服务预约");
            json.put("keyword2", DateUtil.getStringDate());
            json.put("remark", "请及时阅读");
            json.put("url", "smfw/html/toAppointment.html?relationCode=" + relationCode + "");
        } else if (type == 5) {
            //家签提醒 5
            sendType = 11;//待办事项
            String sql = "select pd.id,pd.execute_time as executeTime from wlyy_specialist.wlyy_rehabilitation_plan_detail pd " +
                    "where pd.plan_id ='" + planId + "' and pd.hospital_service_item_id='4' and pd.status <>1 order by pd.execute_time desc ";
            List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
            String excuteTime = "";
            if (mapList != null && mapList.size() != 0) {
                excuteTime = DateUtil.dateToStrLong((Date) mapList.get(0).get("executeTime"));
            }
            json.put("first", patient.getName() + "，您好！为方便为您提供康复管理服务，请先选择合适的社区和家庭医生进行签约");
            json.put("toUser", patientCode);
            json.put("represented", patientCode);//被代理人
            json.put("keyword1", "家庭医生签约");
            json.put("keyword2", DateUtil.getStringDate());
            json.put("remark", "请及时阅读");
            json.put("url", "qygl/html/signing-welcome.html");
        }
        logger.info("微信模板入参:" + sendType + "==" + json.toString());
        if (StringUtils.isNotBlank(patient.getOpenid())) {
            pushMsgTask.putWxMsg(weiXinAccessTokenUtils.getAccessToken(), sendType, patient.getOpenid(), patient.getName(), json);
        } else {
            //发送代理人
            org.json.JSONArray jsonArray = weiXinOpenIdUtils.getAgentOpenId(patient.getId(), patient.getOpenid());
            if (jsonArray != null && jsonArray.length() > 0) {
                for (int i = 0; i < jsonArray.length(); i++) {
                    org.json.JSONObject j = jsonArray.getJSONObject(i);
                    BasePatientDO member = (BasePatientDO) j.get("member");
                    org.json.JSONObject data = json;
                    data.remove("toUser");
                    data.put("toUser", member.getId());
                    data.remove("first");
                    data.put("first", weiXinOpenIdUtils.getTitleMes(patient, j.getInt("relation"), patient.getName()));
                    pushMsgTask.putWxMsg(weiXinAccessTokenUtils.getAccessToken(), sendType, member.getOpenid(), patient.getName(), data);
                }
            }
        }
    }
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/RehabilitationInfoService.java

@@ -653,14 +653,24 @@ public class RehabilitationInfoService {
     * 已下转已接收
     */
    public JSONObject downAndSign(String idcard, String doctorCode, Integer page, Integer pagesize, JSONObject object) {
        String sql2 = "SELECT i.disease_name diseaseName,s.doctor,s.idcard,p.sex, s.patient,CAST(IFNULL(p.birthday,'') AS char ) birthday," +
                " i. STATUS, p. NAME patientName, p.address, CONCAT(s.doctor_name,'(全科医生)' ) AS doctorName, \n" +
                "IFNULL(CONCAT(s.doctor_health_name,'(健管师)'), s.doctor_health_name ) doctorHealthName, s.hospital_name hospitalName, \n" +
                "s.admin_team_code teamCode ,pr.is_manage isManage \n" +
                "FROM wlyy_specialist.wlyy_patient_rehabilitation_plan i, wlyy_sign_family s, wlyy_patient p ,\n" +
                "wlyy_specialist.wlyy_specialist_patient_relation pr \n" +
                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0 AND i.patient = s.patient AND p.code = i.patient AND s.status = 1 \n" +
                "AND s.expenses_status = 1 AND pr.patient=p.code and pr.team_code = i.team_code and pr.`status`>=0 and pr.sign_status=1 and pr.is_manage=1";
//        String sql2 = "SELECT i.disease_name diseaseName,s.doctor,s.idcard,p.sex, s.patient,CAST(IFNULL(p.birthday,'') AS char ) birthday," +
//                " i. STATUS, p. NAME patientName, p.address, CONCAT(s.doctor_name,'(全科医生)' ) AS doctorName, \n" +
//                "IFNULL(CONCAT(s.doctor_health_name,'(健管师)'), s.doctor_health_name ) doctorHealthName, s.hospital_name hospitalName, \n" +
//                "s.admin_team_code teamCode ,pr.is_manage isManage \n" +
//                "FROM wlyy_specialist.wlyy_patient_rehabilitation_plan i, wlyy_sign_family s, wlyy_patient p ,\n" +
//                "wlyy_specialist.wlyy_specialist_patient_relation pr \n" +
//                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0 AND i.patient = s.patient AND p.code = i.patient AND s.status = 1 \n" +
//                "AND s.expenses_status = 1 AND pr.patient=p.code and pr.team_code = i.team_code and pr.`status`>=0 and pr.sign_status=1 and pr.is_manage=1";
        String sql2 = "SELECT i.disease_name diseaseName,p.idcard,p.sex, p.id 'patient',\n" +
                " CAST(IFNULL(p.birthday,'') AS char ) birthday, \n" +
                " i.`status`, p.`name` patientName, p.address,pr.is_manage isManage \n" +
                "FROM wlyy_patient_rehabilitation_plan i \n" +
                " INNER JOIN wlyy_rehabilitation_patient_info q ON q.patient=i.id AND q.sign_status='1' AND i.patient_info_code=q.`code` \n" +
                " INNER JOIN base_patient p ON p.id = i.patient \n" +
                " INNER JOIN wlyy_specialist_patient_relation pr ON pr.patient=p.id \n" +
                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0  AND pr.`status`>=0 and pr.sign_status=1 and pr.is_manage=1 \n";
        if (StringUtils.isNotBlank(idcard)) {
            sql2 += " and  p.idcard like '%" + idcard + "%' ";
        }
@@ -691,14 +701,24 @@ public class RehabilitationInfoService {
     * 已下转已接收
     */
    public JSONObject down(String idcard, String doctorCode, Integer page, Integer pagesize, JSONObject object) {
        String sql2 = "SELECT i.disease_name diseaseName,s.doctor,s.idcard,p.sex, s.patient,CAST(IFNULL(p.birthday,'') AS char ) birthday," +
                " i. STATUS, p. NAME patientName, p.address, CONCAT(s.doctor_name,'(全科医生)' ) AS doctorName, \n" +
                "IFNULL(CONCAT(s.doctor_health_name,'(健管师)'), s.doctor_health_name ) doctorHealthName, s.hospital_name hospitalName, \n" +
                "s.admin_team_code teamCode ,pr.is_manage isManage \n" +
                "FROM wlyy_specialist.wlyy_patient_rehabilitation_plan i, wlyy_sign_family s, wlyy_patient p ,\n" +
                "wlyy_specialist.wlyy_specialist_patient_relation pr \n" +
                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0 AND i.patient = s.patient AND p.code = i.patient AND s.status = 1 \n" +
                "AND s.expenses_status = 1 AND pr.patient=p.code and pr.team_code = i.team_code and pr.`status`>=0 and pr.sign_status=1 ";
//        String sql2 = "SELECT i.disease_name diseaseName,s.doctor,s.idcard,p.sex, s.patient,CAST(IFNULL(p.birthday,'') AS char ) birthday," +
//                " i. STATUS, p. NAME patientName, p.address, CONCAT(s.doctor_name,'(全科医生)' ) AS doctorName, \n" +
//                "IFNULL(CONCAT(s.doctor_health_name,'(健管师)'), s.doctor_health_name ) doctorHealthName, s.hospital_name hospitalName, \n" +
//                "s.admin_team_code teamCode ,pr.is_manage isManage \n" +
//                "FROM wlyy_specialist.wlyy_patient_rehabilitation_plan i, wlyy_sign_family s, wlyy_patient p ,\n" +
//                "wlyy_specialist.wlyy_specialist_patient_relation pr \n" +
//                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0 AND i.patient = s.patient AND p.code = i.patient AND s.status = 1 \n" +
//                "AND s.expenses_status = 1 AND pr.patient=p.code and pr.team_code = i.team_code and pr.`status`>=0 and pr.sign_status=1 ";
        String sql2="SELECT i.disease_name diseaseName,p.idcard,p.sex, p.id 'patient',\n" +
                " CAST(IFNULL(p.birthday,'') AS char ) birthday, i.`status`, p.`name` patientName, p.address, \n" +
                " pr.is_manage isManage \n" +
                "FROM wlyy_patient_rehabilitation_plan i \n" +
                " INNER JOIN base_patient p ON p.id = i.patient\n" +
                " INNER JOIN wlyy_rehabilitation_patient_info q ON q.patient=i.id AND q.sign_status='1' AND i.patient_info_code=q.`code`\n" +
                " INNER JOIN wlyy_specialist_patient_relation pr ON pr.patient=p.id\n" +
                "WHERE i.create_user = '" + doctorCode + "' AND i.status != 0 \n" +
                " and pr.`status`>=0 and pr.sign_status=1  ";
        if (StringUtils.isNotBlank(idcard)) {
            sql2 += " and  p.idcard like '%" + idcard + "%' ";
@@ -965,22 +985,23 @@ public class RehabilitationInfoService {
//        return data;
//    }
    public JSONObject getUnm(String doctor, String patient) {
        String sqlMe = "select d.id,d.plan_id as planId,i.code,i.name,p.patient,d.frequency_code from wlyy_specialist.wlyy_rehabilitation_plan_detail d \n" +
                "LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_specialist.wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_specialist.wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "') \n" +
        String sqlMe = "select d.id,d.plan_id as planId,i.code,i.name,p.patient,d.frequency_code from wlyy_rehabilitation_plan_detail d \n" +
                "LEFT JOIN wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "') \n" +
                "AND d.doctor = '" + doctor + "'  ";//我的任务
        List<Map<String, Object>> listMe = jdbcTemplate.queryForList(sqlMe);
        String sqlAll = "select d.id,d.plan_id as planId,i.code,i.name,p.patient,d.frequency_code from wlyy_specialist.wlyy_rehabilitation_plan_detail d \n" +
                "LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_specialist.wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_specialist.wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "') ";//全部任务
        String sqlAll = "select d.id,d.plan_id as planId,i.code,i.name,p.patient,d.frequency_code from wlyy_rehabilitation_plan_detail d \n" +
                "LEFT JOIN wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "') ";//全部任务
        List<Map<String, Object>> listAll = jdbcTemplate.queryForList(sqlAll);
        String newDetailSql = "select d.id,d.plan_id as planId,i.code,i.name,p.patient,d.frequency_code,r.complete_time createTime, r.doctor_name doctorName \n" +
                "from wlyy_specialist.wlyy_rehabilitation_plan_detail d INNER JOIN wlyy_specialist.wlyy_rehabilitation_operate_records r ON d.id = r.rehabilitation_detail_id\n" +
                "LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_specialist.wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_specialist.wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "')\n" +
                "from wlyy_rehabilitation_plan_detail d \n" +
                "INNER JOIN wlyy_rehabilitation_operate_records r ON d.id = r.rehabilitation_detail_id\n" +
                "LEFT JOIN wlyy_patient_rehabilitation_plan p ON p.id=d.plan_id\n" +
                "LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  \n" +
                "where d.plan_id IN (SELECT id FROM wlyy_patient_rehabilitation_plan WHERE patient ='" + patient + "')\n" +
                " and r.`status`=1 GROUP BY r.complete_time DESC LIMIT 0,1 ";
        newDetailSql = TransforSqlUtl.wlyy_rehabilitation_operate_recordsDoctorName(newDetailSql);
        List<Map<String, Object>> newDetail = jdbcTemplate.queryForList(newDetailSql);

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/RehabilitationManageService.java

@@ -4,14 +4,16 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.yihu.jw.doctor.dao.BaseDoctorDao;
import com.yihu.jw.entity.base.doctor.BaseDoctorDO;
import com.yihu.jw.entity.base.patient.BasePatientDO;
import com.yihu.jw.entity.door.SignFamily;
import com.yihu.jw.entity.specialist.SpecialistPatientRelationDO;
import com.yihu.jw.entity.specialist.rehabilitation.*;
import com.yihu.jw.entity.util.TransforSqlUtl;
import com.yihu.jw.hospital.module.rehabilitation.dao.*;
import com.yihu.jw.hospital.module.specialist.dao.PatientMedicalRecordsRehabilitationDao;
import com.yihu.jw.hospital.module.specialist.dao.SpecialistPatientRelationDao;
import com.yihu.jw.hospital.team.dao.WlyySignFamilyDao;
import com.yihu.jw.im.util.ImUtil;
import com.yihu.jw.patient.dao.BasePatientDao;
import com.yihu.jw.restmodel.web.Envelop;
import com.yihu.jw.restmodel.web.MixEnvelop;
import com.yihu.jw.restmodel.web.ObjEnvelop;
@@ -30,7 +32,6 @@ import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
/**
@@ -61,7 +62,94 @@ public class RehabilitationManageService {
    @Autowired
    BaseDoctorDao doctorDao;
    @Autowired
    WlyySignFamilyDao signFamilyDao;
    BasePatientDao patientDao;
    @Autowired
    private PatientMedicalRecordsRehabilitationDao medicalRecordsRehabilitationDao;
    public List<Map<String, Object>> selectPlanByPatient(String patient, Integer status, String planId, String doctor) {
        if (StringUtils.isNoneBlank(planId)) {
            String planSql = "select p.patient " +
                    " FROM wlyy_patient_rehabilitation_plan p where p.id='" + planId + "' ";
            List<Map<String, Object>> maps = jdbcTemplate.queryForList(planSql);
            if (maps != null && maps.size() != 0) {
                Map<String, Object> map = maps.get(0);
                patient = map.get("patient").toString();
            }
        }
        String sql = "select d.code as doctor,p.create_time as createTime,p.id,d.photo,p.title,d.idcard,YEAR (now()) - YEAR (substring(d.idcard, 7, 8)) AS age," +
                " d.sex,p.name,p.patient,p.disease,d.name as doctorName,d.hospital,d.dept_name as deptName,hospital_name as hospitalName,p.advice_content as adviceContent," +
                "p.medical_records_code as medicalRecordsCode,p.create_time as create_time " +
                " FROM wlyy_patient_rehabilitation_plan p " +
                " LEFT JOIN wlyy_doctor d ON d.code = p.create_user " +
                "WHERE p.patient='" + patient + "'";
        if (status != null) {
            sql += " and p.status =" + status;
        }
        if (StringUtils.isNoneBlank(doctor)) {
            BaseDoctorDO doctor1 = doctorDao.findById(doctor).orElse(null);
            if (doctor1 != null && doctor1.getLevel() == 1) {
                sql += " and p.create_user ='" + doctor + "'";
            }
        }
        sql += " union ";
        sql += " SELECT d.CODE AS doctor," +
                "p.create_time AS createTime," +
                "p.id," +
                "d.photo," +
                "p.title," +
                "d.idcard,YEAR (now())-YEAR (substring(d.idcard,7,8)) AS age," +
                "d.sex,p.name," +
                "p.patient,p.disease," +
                "d.NAME AS doctorName,d.hospital," +
                "d.dept_name AS deptName," +
                "hospital_name AS hospitalName," +
                "p.advice_content AS adviceContent," +
                "p.medical_records_code AS medicalRecordsCode," +
                "p.create_time AS create_time " +
                "FROM " +
                "wlyy_patient_rehabilitation_plan p " +
                "LEFT JOIN wlyy.wlyy_doctor d ON d.CODE=p.create_user" +
                " LEFT JOIN (" +
                "SELECT sr.patient AS patient,sr.team_code AS team_code " +
                "FROM wlyy_specialist_patient_relation sr " +
                "JOIN wlyy.wlyy_doctor_special_share se ON se.special_code=sr.id " +
                "WHERE se.doctor='" + doctor + "' " +
                "AND sr.patient='" + patient + "') d " +
                "ON d.patient=p.patient WHERE " +
                "p.patient='" + patient + "' " +
                "AND d.team_code=p.team_code ";
        sql += " ORDER BY create_time DESC ";
        sql = TransforSqlUtl.wlyy_patient_rehabilitation_planName(sql);
        List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
        int i = 0;
        for (Map<String, Object> map : mapList) {
            String sqlSpecilist = "select * from wlyy_specialist_patient_relation where doctor = '" + map.get("code") + "' and patient ='" + patient + "' and sign_status=1 and status=1";
            sql = TransforSqlUtl.specialistPatientRelationAll(sql);
            List<Map<String, Object>> maps = jdbcTemplate.queryForList(sqlSpecilist);
            map.put("specialist", maps);
//            //判断是否展示出院带药模块
//            if (i == 0) {
//                i++;
//                String hospital = map.get("hospital") + "";
//                String disease = map.get("disease") + "";
//                RehabilitationHospitalDrugSetting drugSetting = drugSettingDao.findByHospital(hospital, disease);
//                if (drugSetting == null) {
//                    map.put("isShowDrug", "0");//不展示
//                } else {
//                    map.put("isShowDrug", "1");//展示
//                }
//            } else {
//                map.put("isShowDrug", "0");//不展示
//            }
        }
        return mapList;
    }
    /**
     * 预约协诊
@@ -104,7 +192,7 @@ public class RehabilitationManageService {
    public MixEnvelop<Map<String, Object>, Map<String, Object>> findRehabilitationPlan(Integer doctorType, String doctorCode, String diseaseCode, Integer planType, Integer todaybacklog, String patientCondition, Integer page, Integer pageSize) throws Exception {
        String sql = " select DISTINCT p.* " +
                " from wlyy_specialist.wlyy_rehabilitation_plan_detail a INNER JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p " +
                " from wlyy_rehabilitation_plan_detail a INNER JOIN wlyy_patient_rehabilitation_plan p " +
                " on a.plan_id = p.id  ";
        if (doctorType == 2) {//家医是根据签约关系过滤
            sql += " INNER JOIN wlyy.wlyy_sign_family f ON f.patient = p.patient \n" +
@@ -213,7 +301,7 @@ public class RehabilitationManageService {
     * @throws Exception
     */
    public ObjEnvelop findRehabilitationPlanDetailList(String currentDoctorCode, String patientCode) throws Exception {
        String sql = " select DISTINCT r.* from wlyy_specialist.wlyy_specialist_patient_relation r join wlyy_patient_rehabilitation_plan p on r.patient=p.patient where r.sign_status ='1' and r.status in('0','1') and r.patient='" + patientCode + "' ";
        String sql = " select DISTINCT r.* from wlyy_specialist_patient_relation r join wlyy_patient_rehabilitation_plan p on r.patient=p.patient where r.sign_status ='1' and r.status in('0','1') and r.patient='" + patientCode + "' ";
        sql = TransforSqlUtl.specialistPatientRelationAll2(sql);
        List<Map<String, Object>> specialistPatientRelationList = jdbcTemplate.queryForList(sql);
        List<Map<String, Object>> resultList = new ArrayList<>();
@@ -229,7 +317,7 @@ public class RehabilitationManageService {
            resultMap.put("healthyCondition", healthyCondition);
            resultMap.put("healthyConditionType", healthyConditionType);
            //专科医生
            String specialistRelationSql = "select r.*,t.name as teamName,h.name as specialistHospitalName from wlyy_specialist.wlyy_specialist_patient_relation r left join " + basedb + ".wlyy_admin_team t on r.team_code=t.id left join " + basedb + ".dm_hospital h on t.org_code=h.code where r.sign_status ='1' and r.status in('0','1') and r.patient='" + patientCode + "' and r.doctor='" + doctorCode + "'";
            String specialistRelationSql = "select r.*,t.name as teamName,h.name as specialistHospitalName from wlyy_specialist_patient_relation r left join " + basedb + ".wlyy_admin_team t on r.team_code=t.id left join " + basedb + ".dm_hospital h on t.org_code=h.code where r.sign_status ='1' and r.status in('0','1') and r.patient='" + patientCode + "' and r.doctor='" + doctorCode + "'";
            specialistRelationSql = TransforSqlUtl.specialistPatientRelationAll2(specialistRelationSql);
            List<Map<String, Object>> specialistRelationList = jdbcTemplate.queryForList(specialistRelationSql);
            Map<String, Object> specialistMap = specialistRelationList.get(0);
@@ -357,7 +445,7 @@ public class RehabilitationManageService {
        for (int i = 1; i < planIdlist.length; i++) {
            planCondition.append(",'" + planIdlist[i] + "'");
        }
        String sql = " select d.* from wlyy_specialist.wlyy_rehabilitation_plan_detail d " +
        String sql = " select d.* from wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id " +
                " where  d.plan_id in (" + planCondition + ") ";
        if (StringUtils.isNotBlank(executeStartTime)) {
@@ -385,7 +473,6 @@ public class RehabilitationManageService {
        sql += " ORDER BY d.execute_time ";
        sql = TransforSqlUtl.wlyy_rehabilitation_plan_detailAll2(sql);
        List<Map<String, Object>> rehabilitationDetailList = jdbcTemplate.queryForList(sql);
//        List<RehabilitationDetailDO> rehabilitationDetailList = rehabilitationDetailDao.findByPlanId(DateUtil.strToDate(executeStartTime),DateUtil.strToDate(executeEndTime),planId);
        Map<String, Map<String, Object>> map = new LinkedHashMap<>();
        for (Map<String, Object> one : rehabilitationDetailList) {
            String executeTime = DateUtil.dateToStr((Date) one.get("execute_time"), DateUtil.YYYY_MM_DD);
@@ -504,7 +591,7 @@ public class RehabilitationManageService {
        for (int i = 1; i < planIdlist.length; i++) {
            planCondition.append(",'" + planIdlist[i] + "'");
        }
        String sql = " select d.*,DATE_FORMAT(d.execute_time,'%Y/%m/%d %H:%i') as executeTime ,i.code,IF(d.followup_detail_type=1,'社区随访（厦心）',i.name) name,1 as flag from wlyy_specialist.wlyy_rehabilitation_plan_detail d " +
        String sql = " select d.*,DATE_FORMAT(d.execute_time,'%Y/%m/%d %H:%i') as executeTime ,i.code,IF(d.followup_detail_type=1,'社区随访（厦心）',i.name) name,1 as flag from wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id  " +
                " where  d.plan_id in (" + planCondition + " )AND  d.execute_time IS NOT NULL  and d.execute_time <>'' ";
        if (searchTask != null) {
@@ -535,7 +622,7 @@ public class RehabilitationManageService {
        sql = TransforSqlUtl.wlyy_rehabilitation_plan_detailAll2(sql);
        List<Map<String, Object>> rehabilitationDetailList = jdbcTemplate.queryForList(sql);
        String planPatientSql = " SELECT p.patient FROM wlyy_specialist.wlyy_patient_rehabilitation_plan p " +
        String planPatientSql = " SELECT p.patient FROM wlyy_patient_rehabilitation_plan p " +
                "INNER JOIN wlyy.wlyy_sign_family f ON p.patient = f.patient  WHERE p.id in (" + planCondition + " ) " +
                "AND f.`status` = 1 AND f.expenses_status = 1 AND  f.doctor = '" + doctorCode + "' ";
        List<Map<String, Object>> patientCodeList = jdbcTemplate.queryForList(planPatientSql);
@@ -559,7 +646,9 @@ public class RehabilitationManageService {
                        " AND sd.dict_name = 'FOLLOWUP_WAY_DICT' WHERE wf.status !=0  AND wf.patient_code = '" + patient + "' order by wf.followup_plan_date desc  ";
                list = jdbcTemplate.queryForList(sfSql);
            }
            if (list != null && list.size() > 0) rehabilitationDetailList.addAll(list);
            if (list != null && list.size() > 0) {
                rehabilitationDetailList.addAll(list);
            }
        }
        return ObjEnvelop.getSuccess(SpecialistMapping.api_success, rehabilitationDetailList);
@@ -581,9 +670,9 @@ public class RehabilitationManageService {
        String planDetailResult = StringUtils.isNotEmpty(planDetailList) ? planDetailList.substring(1) : "";
        String sql = "select i.name,i.code,i.content,d.execute_time,d.hospital_name,d.id,d.status,d.type as detailType,d.expense,d.doctor as executeDoctor," +
                " d.doctor_name as executeDoctorName,p.patient ,p.id AS planId,p.create_user as createDoctor,p.create_user_name as createDoctorName, p.status as planStatus  " +
                " from wlyy_specialist.wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_specialist.wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id " +
                " LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
                " from wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_rehabilitation_service_item i on i.code = d.hospital_service_item_id " +
                " LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
                " where d.id in (" + planDetailResult + ") order BY d.execute_time ASC ";
        sql = TransforSqlUtl.wlyy_patient_rehabilitation_planCreateName(sql);
        sql = TransforSqlUtl.wlyy_rehabilitation_plan_detailDoctorName(sql);
@@ -690,10 +779,10 @@ public class RehabilitationManageService {
                " d.doctor_name as executeDoctorName,p.patient ,p.name as patientName,p.create_user as createDoctor,p.create_user_name as createDoctorName, p.status as planStatus," +
                " p.disease,p.disease_name as diseaseName,p.title as planTitle,d.plan_id as planId,d.relation_code as relationCode,d.frequency_code as frequencyCode,d.remark  " +
                " ,a.appointment_time appointmentTime,a.appointment_doctor appointmentDoctor,a.appointment_doctor_name appointmentDoctorName,d.reservation_type reservationType,d.followup_detail_type followupDetailType " +
                " from wlyy_specialist.wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_specialist.wlyy_rehabilitation_service_item h on d.hospital_service_item_id = h.code " +
                " LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
                " LEFT JOIN wlyy_specialist.wlyy_plan_detail_appointment a on d.id=.a.rehabilitation_plan_detail_id " +
                " from wlyy_rehabilitation_plan_detail d " +
                " LEFT JOIN wlyy_rehabilitation_service_item h on d.hospital_service_item_id = h.code " +
                " LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
                " LEFT JOIN wlyy_plan_detail_appointment a on d.id=.a.rehabilitation_plan_detail_id " +
                " where d.id = '" + planDetailId + "'";
        sql = TransforSqlUtl.wlyy_patient_rehabilitation_planName2(sql);
        sql = TransforSqlUtl.wlyy_patient_rehabilitation_planCreateName(sql);
@@ -820,23 +909,101 @@ public class RehabilitationManageService {
        return ObjEnvelop.getSuccess(SpecialistMapping.api_success, resultMap);
    }
    /**
     * 康复管理居民详情页
     * 康复管理-居民详情页
     *
     * @param patientCode
     * @param healthDoctor
     * @param healthDoctorName
     * @param generalDoctor
     * @param generalDoctorName
     * @return
     * @throws Exception
     */
    public ObjEnvelop patientRehabilitationDetail(String patientCode, String healthDoctor, String healthDoctorName, String generalDoctor, String generalDoctorName) {
        Map<String, Object> resultMap = new HashMap<>();
    public org.json.JSONObject patientRehabilitationDetail(String patientCode) throws Exception {
        //查询居民信息
//        List<SignFamily> list = signFamilyDao.findByPatientAndExpensesStatusAndStatus(patientCode, "1", 1);
        BasePatientDO patient = patientDao.findById(patientCode).orElse(null);
        String healthDoctor = null;
        String healthDoctorName = null;
        String generalDoctor = null;
        String generalDoctorName = null;
        String patientName = null;
        Integer age = null;
        String sex = null;
        String signHospitalName = null;
        org.json.JSONObject json = new org.json.JSONObject();
        String healthyConditionSql = " select  label_name,label from wlyy_sign_patient_label_info where status=1 and patient='" + patientCode + "' and label_type=8";
        List<Map<String, Object>> healthyConditionList = jdbcTemplate.queryForList(healthyConditionSql);
        String healthyCondition = healthyConditionList.size() > 0 ? healthyConditionList.get(0).get("label_name") + "" : "";
        String healthyConditionType = healthyConditionList.size() > 0 ? healthyConditionList.get(0).get("label") + "" : "";
        if (patient != null) {
            healthDoctor = null;
            healthDoctorName = null;
            generalDoctor = null;
            generalDoctorName = null;
//            healthDoctor =      signFamily.getDoctorHealth();
//            healthDoctorName =  signFamily.getDoctorHealthName();
//            generalDoctor =     signFamily.getDoctor();
//            generalDoctorName = signFamily.getDoctorName();
            patientName = patient.getName();
//            signHospitalName = signFamily.getHospitalName();
            ObjEnvelop envelop = patientRehabilitationDetail(patientCode, healthDoctor, healthDoctorName, generalDoctor, generalDoctorName);
            org.json.JSONObject jsonObject = new org.json.JSONObject((Map<String, Object>) envelop.getObj());
            if (envelop.getStatus() == 200) {
                json = jsonObject.getJSONObject("patientInfo");
                json.put("healthyCondition", healthyCondition);
                json.put("healthyConditionType", healthyConditionType);
                json.put("patientName", patientName);
//                json.put("signHospitalName", signHospitalName);
                age = IdCardUtil.getAgeByIdcardOrBirthday(patient.getIdcard(), patient.getBirthday());
                sex = IdCardUtil.getSexForIdcard_new(patient.getIdcard());
                json.put("patientCode", patientCode);
                json.put("patientName", patient.getName());
                json.put("age", age);
                json.put("sex", sex);
                json.put("photo", patient.getPhoto());
                json.put("mobile", patient.getMobile());
                JSONArray jsonArray = jsonObject.getJSONArray("serviceDoctorList");
                String doctorCode = "";
                BaseDoctorDO doctor = null;
                for (int i = 0; i < jsonArray.length(); i++) {
                    doctorCode = jsonArray.getJSONObject(i).get("doctorCode") + "";
                    doctor = doctorDao.findById(doctorCode).orElse(null);
                    jsonArray.getJSONObject(i).put("doctorPhoto", doctor != null ? doctor.getPhoto() : "");
                }
                return jsonObject.put("patientInfo", json);
            }
            throw new Exception("查询失败！");
        } else {
            json = new org.json.JSONObject();
        }
        json.put("healthyCondition", healthyCondition);
        json.put("healthyConditionType", healthyConditionType);
        age = IdCardUtil.getAgeByIdcardOrBirthday(patient.getIdcard(), patient.getBirthday());
        sex = IdCardUtil.getSexForIdcard_new(patient.getIdcard());
        json.put("patientCode", patientCode);
        json.put("patientName", patient.getName());
        json.put("age", age);
        json.put("sex", sex);
        json.put("photo", patient.getPhoto());
        json.put("mobile", patient.getMobile());
        return new org.json.JSONObject().put("patientInfo", json);
    }
    /**
     * 康复管理居民详情页
     * patientCode
     * healthDoctor
     * healthDoctorName
     * generalDoctor
     * generalDoctorName
     */
    public ObjEnvelop patientRehabilitationDetail(String patientCode, String healthDoctor, String healthDoctorName, String generalDoctor, String generalDoctorName) {
        Map<String, Object> resultMap = new HashMap<>();
        //个人基础信息（康复机构）
        String patientInfoSql = " SELECT DISTINCT hospital_name from wlyy_specialist.wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
        String patientInfoSql = " SELECT DISTINCT hospital_name from wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id " +
                " where p.patient='" + patientCode + "' and p.status=1 ";
        List<Map<String, Object>> patientInfoList = jdbcTemplate.queryForList(patientInfoSql);
        Map<String, Object> patientInfo = new HashMap<>();
@@ -881,7 +1048,7 @@ public class RehabilitationManageService {
            serviceDoctorList.add(generalDoctorMap);
        }
        String specialistRelationSql = "select DISTINCT d.doctor,d.doctor_name from wlyy_specialist.wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where d.type=2 and  p.patient='" + patientCode + "'";
        String specialistRelationSql = "select DISTINCT d.doctor,d.doctor_name from wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where d.type=2 and  p.patient='" + patientCode + "'";
        specialistRelationSql = TransforSqlUtl.wlyy_rehabilitation_plan_detailDoctorName2(specialistRelationSql);
        List<Map<String, Object>> specialistRelationList = jdbcTemplate.queryForList(specialistRelationSql);
        for (Map<String, Object> one : specialistRelationList) {
@@ -988,8 +1155,8 @@ public class RehabilitationManageService {
        Map<String, Object> resultMap = new HashMap<>();
        //近期康复相关记录
//        String currentTime = DateUtil.getStringDate();
        String planDetailSql = " select d.*,h.name,h.code,s.complete_time from wlyy_specialist.wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_rehabilitation_service_item h on d.hospital_service_item_id=h.code" +
                " LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id" +
        String planDetailSql = " select d.*,h.name,h.code,s.complete_time from wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_rehabilitation_service_item h on d.hospital_service_item_id=h.code" +
                " LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id" +
                " left join wlyy_rehabilitation_operate_records s on s.rehabilitation_detail_id=d.id " +
                " where d.status=1 and p.patient='" + patientCode + "' and d.frequency_code IS NOT NULL AND d.frequency_code <>'' ";
        if (StringUtils.isNotEmpty(startTime)) {
@@ -1037,8 +1204,8 @@ public class RehabilitationManageService {
            planDetailList.add(map);
        }
        resultMap.put("planDetailList", planDetailList);//康复相关记录列表
        String planDetailCountSql = " select d.status as num from wlyy_specialist.wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_rehabilitation_service_item h on d.hospital_service_item_id=h.code" +
                "  LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where p.patient='" + patientCode + "'";
        String planDetailCountSql = " select d.status as num from wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_rehabilitation_service_item h on d.hospital_service_item_id=h.code" +
                "  LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where p.patient='" + patientCode + "'";
        List<Map<String, Object>> planDetailList2 = jdbcTemplate.queryForList(planDetailCountSql);
        Integer planDetailFinish = 0;
        Integer planDetailUnfinish = 0;
@@ -1159,7 +1326,7 @@ public class RehabilitationManageService {
            serviceDoctorList.add(healthDoctorMap);
        }
        String specialistRelationSql = "select DISTINCT d.doctor,d.doctor_name from wlyy_specialist.wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_specialist.wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where d.type=2 AND d.doctor IS  NOT  NULL and  d.doctor <> ''  and  p.patient='" + patientCode + "'";
        String specialistRelationSql = "select DISTINCT d.doctor,d.doctor_name from wlyy_rehabilitation_plan_detail d LEFT JOIN wlyy_patient_rehabilitation_plan p on d.plan_id=p.id where d.type=2 AND d.doctor IS  NOT  NULL and  d.doctor <> ''  and  p.patient='" + patientCode + "'";
        specialistRelationSql = TransforSqlUtl.wlyy_rehabilitation_plan_detailDoctorName2(specialistRelationSql);
        List<Map<String, Object>> specialistRelationList = jdbcTemplate.queryForList(specialistRelationSql);
        for (Map<String, Object> one : specialistRelationList) {
@@ -1610,7 +1777,7 @@ public class RehabilitationManageService {
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public JSONArray selectPlanServerDoctor(String planId, String doctorCode) throws Exception {
        String sql = "SELECT t.patient,t.create_user FROM wlyy_specialist.wlyy_patient_rehabilitation_plan t  where t.id='" + planId + "'";//专科
        String sql = "SELECT t.patient,t.create_user FROM wlyy_patient_rehabilitation_plan t  where t.id='" + planId + "'";//专科
        List<Map<String, Object>> mapList = jdbcTemplate.queryForList(sql);
        JSONArray array = new JSONArray();
        String patient = "";
@@ -1635,7 +1802,8 @@ public class RehabilitationManageService {
            object.put("idcard", doctor1.getIdcard());
            array.put(object);
        }
        SignFamily signFamily = signFamilyDao.findByPatient(patient);
//        SignFamily signFamily = signFamilyDao.findByPatient(patient);
        SignFamily signFamily = null;
        if (signFamily != null) {
            JSONObject object = new JSONObject();
            BaseDoctorDO doctor = doctorDao.findById(signFamily.getDoctor()).orElse(null);
@@ -1717,8 +1885,8 @@ public class RehabilitationManageService {
    }
    public List<PatientMedicalRecordsDO> findByPatient(String patient) {
        return medicalRecordsRehabilitationDao.findByPatient(patient);
    }
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/specialist/controller/PatientSpecialistController.java

@@ -0,0 +1,166 @@
package com.yihu.jw.hospital.module.specialist.controller;
import com.yihu.jw.hospital.appointment.dao.SpecialDiseaseDao;
import com.yihu.jw.hospital.module.specialist.service.SpecialistService;
import com.yihu.jw.restmodel.web.endpoint.EnvelopRestEndpoint;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
/**
 * Created by Trick on 2018/7/3.
 */
@RestController
@RequestMapping(value = "/patient/specialist", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@Api(description = "患者端-专病管理")
public class PatientSpecialistController extends EnvelopRestEndpoint {
    @Autowired
    private SpecialistService specialistService;
    @Autowired
    private SpecialDiseaseDao specialDiseaseDao;
//    @Autowired
//    private ServerPackageService serverPackageService;
    @RequestMapping(value = "/findPatientTeamList", method = RequestMethod.GET)
    @ApiOperation(value = "获取居民所有专科医生签约信息")
    public String findPatientTeamList(@ApiParam(name = "patient", value = "居民code") @RequestParam(required = true) String patient) {
        try {
            return write(200, "获取成功", "data", specialistService.findPatientTeamList(patient));
        } catch (Exception e) {
            error(e);
            return error(-1, "请求失败");
        }
    }
//    @RequestMapping(value = "/findSpecialistTeamInfo", method = RequestMethod.GET)
//    @ApiOperation(value = "获取专科医生所在团队信息")
//    public String findSpecialistTeamInfo(@ApiParam(name = "doctor", value = "医生code") @RequestParam(required = true)String doctor,
//                                         @ApiParam(name = "teamCode", value = "团队code") @RequestParam(required = true)Long teamCode){
//        try {
//            return write(200, "获取成功", "data", specialistService.findSpecialistTeamInfo(doctor,teamCode));
//        } catch (Exception e) {
//            error(e);
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "/findTeamDiseaseRelation", method = RequestMethod.GET)
//    @ApiOperation(value = "获取团队专病服务信息")
//    public String findTeamDiseaseRelation(@ApiParam(name = "teamCode", value = "团队code") @RequestParam(required = true)Long teamCode) {
//        try {
//            return write(200, "获取成功", "data", specialistService.findTeamDiseaseRelation(teamCode));
//        } catch (Exception e) {
//            error(e);
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "/findPatientDiseaseServerList", method = RequestMethod.GET)
//    @ApiOperation(value = "获取居民专病服务信息")
//    public String findPatientDiseaseServerList(@ApiParam(name = "patient", value = "患者code") @RequestParam(required = true)String patient) {
//        try {
//            return write(200, "获取成功", "data", specialistService.findPatientDiseaseServerList(patient));
//        } catch (Exception e) {
//            error(e);
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "/signSpecialist", method = RequestMethod.POST)
//    @ApiOperation(value = "居民提交专科医生团队签约申请")
//    public String signSpecialist(@ApiParam(name = "patient", value = "患者code") @RequestParam(required = true)String patient,
//                                 @ApiParam(name = "doctor", value = "医生code") @RequestParam(required = true)String doctor,
//                                 @ApiParam(name = "disease", value = "疾病code") @RequestParam(required = true)String disease,
//                                 @ApiParam(name = "teamCode", value = "团队code") @RequestParam(required = true)Long teamCode) throws Exception {
//        try {
//            return write(200, "获取成功", "data", specialistService.signSpecialist(patient,doctor,disease,teamCode));
//        } catch (Exception e) {
//            error(e);
//            return error(-1, "请求失败");
//        }
//    }
//    @RequestMapping(value = "/agreeSpecialistTeam", method = RequestMethod.GET)
//    @ApiOperation(value = "医生审核")
//    public String agreeSpecialistTeam(String state,String relationCode,String remark,Long mesId)throws Exception {
//        try {
//            return write(200, "获取成功", "data", specialistService.agreeSpecialistTeam(getAccessToken(),state, relationCode, remark, mesId, labelcode, doctorcode));
//        } catch (Exception e) {
//            error(e);
//            return error(-1, "请求失败");
//        }
//    }
    /**
     * 根据机构code获取本机构服务项目
     * hospital
     */
//    @RequestMapping(value = "selectHospital1", method = RequestMethod.POST)
//    @ResponseBody
//    @ApiOperation(value = "根据机构code获取本机构服务项目")
//    public String selectHospital1(@RequestParam(name = "hospital",required = false) String hospital){
//        try {
//            return write(200, "查询成功", "data",serverPackageService.selectByHospital1(hospital));
//        } catch (Exception ex) {
//            error(ex);
//            return error(-1, "查询失败");
//        }
//    }
    /**
     * 根据机构code获取本机构服务项目-上门服务
     * hospital
     */
//    @RequestMapping(value = "selectServiceByHospital", method = RequestMethod.POST)
//    @ResponseBody
//    @ApiOperation(value = "根据机构code获取本机构服务项目-上门服务")
//    public String selectServiceByHospital(
//            @RequestParam(name = "hospital",required = false) String hospital,
//            @ApiParam(value = "服务项目名称", name = "serverItemName") @RequestParam(value = "serverItemName", required = false) String serverItemName,
//            @ApiParam(value = "类型", name = "type") @RequestParam(value = "type", required = false) String type,
//            @ApiParam(value = "医生", name = "doctor") @RequestParam(value = "doctor", required = false) String doctor
//    ){
//        try {
//            return write(200, "查询成功", "data",serverPackageService.selectServiceByHospital(hospital,serverItemName,type,getRepUID(),doctor));
//        } catch (Exception ex) {
//            error(ex);
//            return error(-1, "查询失败");
//        }
//    }
//    @RequestMapping(value = "selectServiceTypes", method = RequestMethod.POST)
//    @ResponseBody
//    @ApiOperation(value = "获取服务项目类型-上门服务")
//    public String selectServiceTypes(){
//        try {
//            return write(200, "查询成功", "data",serverPackageService.selectTypes());
//        } catch (Exception ex) {
//            error(ex);
//            return error(-1, "查询失败");
//        }
//    }
//    @RequestMapping(value = "getSpecialDisease", method = RequestMethod.GET)
//    @ApiOperation(value = "获取专科疾病类型")
//    @ResponseBody
//    public String getSpecialDisease() {
//        try {
//            return write(200, "查询成功!", "data", specialDiseaseDao.findByDel("1"));
//        } catch (Exception e) {
//            e.printStackTrace();
//            return write(-1, "查询失败!");
//        }
//    }
}

svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/specialist/service/SpecialistService.java

@@ -626,14 +626,10 @@ public class SpecialistService{
        String sql = "SELECT " +
                " r.id AS relationCode, " +
                " r.patient, r.patient_name as patientName" +
               // AesEncryptUtils.decryptMysql("r.patient_name","patientName") +
//                " r.patient_name AS patientName, " +
                " ,r.team_code,r.sign_date , " +
                " t.`name` AS name," +
                " d.photo," +
                " md.code AS doctor,md.name as doctorName" +
              //  AesEncryptUtils.decryptMysql("md.name","doctorName") +
//                " md.name AS doctorName," +
                ",d.hospital,d.hospital_name " +
                " FROM " +
                " wlyy_specialist_patient_relation r  " +