疾病更新前判断三师疾病是否被修改

src/main/java/com/yihu/wlyy/repository/patient/PatientDiseaseDao.java

@@ -23,6 +23,14 @@ public interface PatientDiseaseDao extends PagingAndSortingRepository<PatientDis
     */
    List<PatientDisease> findByPatient(String patient);
    /**
     * 根据居民code获取居民疾病
     *
     * @param patient
     * @return
     */
    List<PatientDisease> findByPatientAndSignType(String patient,String signType);
    /**
     * 根据居民code获取居民疾病
     *

src/main/java/com/yihu/wlyy/service/app/disease/PatientDiseaseService.java

@@ -56,6 +56,16 @@ public class PatientDiseaseService extends BaseService {
        return patientDiseaseDao.findByPatient(patient);
    }
    /**
     * 根据居民code查询疾病
     *
     * @param patient 居民code
     * @return
     */
    public List<PatientDisease> getPatientDiseaseSs(String patient) {
        return patientDiseaseDao.findByPatientAndSignType(patient,"1");
    }
    /**
     * 更新患者疾病表
     *

src/main/java/com/yihu/wlyy/web/doctor/patient/PatientDiseaseController.java

@@ -13,17 +13,18 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Arrays;
import java.util.List;
/**
 * 患者疾病控制器
 *
 * <p>
 * Created by lyr on 2016/09/09.
 */
@RestController
@RequestMapping(value = "/doctor/patient")
@Api(description = "患者疾病")
public class PatientDiseaseController extends BaseController{
public class PatientDiseaseController extends BaseController {
    @Autowired
    PatientDiseaseService patientDiseaseService;
@@ -37,20 +38,20 @@ public class PatientDiseaseController extends BaseController{
     * @return
     */
    @RequestMapping(value = "/disease")
    public String getPatientDisease(String patient){
        try{
            if(StringUtils.isEmpty(patient)){
                return error(-1,"患者不能为空");
    public String getPatientDisease(String patient) {
        try {
            if (StringUtils.isEmpty(patient)) {
                return error(-1, "患者不能为空");
            }
            if(StringUtils.isEmpty(redisTemplate.opsForValue().get("disease:" + patient))) {
            if (StringUtils.isEmpty(redisTemplate.opsForValue().get("disease:" + patient))) {
                List<PatientDisease> diseases = patientDiseaseService.getPatientDisease(patient);
                return write(200,"查询成功","data",new JSONArray(diseases));
            }else{
                return write(200,"查询成功","data",new JSONArray(redisTemplate.opsForValue().get("disease:" + patient)));
                return write(200, "查询成功", "data", new JSONArray(diseases));
            } else {
                return write(200, "查询成功", "data", new JSONArray(redisTemplate.opsForValue().get("disease:" + patient)));
            }
        }catch (Exception e){
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1,"查询失败");
            return error(-1, "查询失败");
        }
    }
@@ -62,16 +63,36 @@ public class PatientDiseaseController extends BaseController{
     * @return
     */
    @RequestMapping(value = "/disease_update")
    public String updatePatientDisease(String patient,String disease){
        try{
            if(patientDiseaseService.updatePatientDisease(patient,disease)){
                return write(200,"更新成功");
            }else{
                return error(-1,"更新失败");
    public String updatePatientDisease(String patient, String disease) {
        try {
            List<PatientDisease> diseases = patientDiseaseService.getPatientDiseaseSs(patient);
            if (diseases != null && diseases.size() > 0) {
                List<String> dis = Arrays.asList(disease.split(","));
                if (dis != null && dis.size() > 0) {
                    int flag = 0;
                    for(PatientDisease dise : diseases){
                        if(dis.contains(dise.getDel())){
                            flag++;
                        }
                    }
                    if(flag != diseases.size()){
                        return error(-1, "三师签约疾病不能更改");
                    }
                } else {
                    return error(-1, "三师签约疾病不能更改");
                }
            }
            if (patientDiseaseService.updatePatientDisease(patient, disease)) {
                return write(200, "更新成功");
            } else {
                return error(-1, "更新失败");
            }
        }catch (Exception e){
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1,"更新失败");
            return error(-1, "更新失败");
        }
    }
@@ -81,12 +102,12 @@ public class PatientDiseaseController extends BaseController{
     * @return
     */
    @RequestMapping(value = "/to_redis")
    public String updateToRedid(){
        try{
    public String updateToRedid() {
        try {
            patientDiseaseService.updateToRedis();
            return write(200,"更新成功");
        }catch (Exception e){
            return error(-1,"更新失败");
            return write(200, "更新成功");
        } catch (Exception e) {
            return error(-1, "更新失败");
        }
    }
@@ -96,13 +117,13 @@ public class PatientDiseaseController extends BaseController{
     * @return
     */
    @RequestMapping(value = "/to_disease")
    public String updateToDisease(){
        try{
    public String updateToDisease() {
        try {
            patientDiseaseService.updateToDisease();
            return write(200,"更新成功");
        }catch (Exception e){
            return write(200, "更新成功");
        } catch (Exception e) {
            e.printStackTrace();
            return error(-1,"更新失败");
            return error(-1, "更新失败");
        }
    }