package com.hx.phip.service.consultation.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hx.common.dao.CommonDao;
import com.hx.common.service.CommonService;
import com.hx.exception.TipsException;
import com.hx.mybatisTool.SqlSentence;
import com.hx.phiappt.common.PlatformConstants;
import com.hx.phiappt.constants.tool.UserInfoTool;
import com.hx.phiappt.dao.mapper.*;
import com.hx.phiappt.model.*;
import com.hx.phip.service.SystemParameterService;
import com.hx.phip.service.consultation.ConsultationRecordService;
import com.hx.util.StringUtils;
import com.hz.his.dto.consultation.ConsultAppearancePlanVo;
import com.hz.his.dto.consultation.ConsultRecordDto;
import com.hz.his.dto.consultation.ConsultTreatProjectVo;
import com.platform.exception.PlatTipsException;
import com.platform.resultTool.PlatformCode;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

@Service
@Transactional
public class ConsultationRecordServiceImpl implements ConsultationRecordService {

    @Resource
    private ConsultationRecordMapper consultationRecordMapper;
    @Resource
    private CommonDao commonDao;
    @Resource
    private ConsultationTreatProjectMapper consultationTreatProjectMapper;
    @Resource
    private ConsultationRecommendedProjectMapper consultationRecommendedProjectMapper;
    @Resource
    private ProjectMapper projectMapper;
    @Resource
    private ConsultationAppearancePlanMapper appearancePlanMapper;

    @Override
    public String insertOrEdit(ConsultRecordDto consultRecordDto, SystemParameterService systemParameterService, CommonService commonService) {

        //咨询信息部分
        ConsultationRecord consultationRecord = new ConsultationRecord();
        if (!StringUtils.isEmpty(consultationRecord.getContent()) && consultRecordDto.getContent().equals("")) {
            consultRecordDto.setContent(null);
        }
        BeanUtils.copyProperties(consultRecordDto,consultationRecord);

        if(StringUtils.isEmpty(consultationRecord.getId())){
            if (consultationRecordMapper.insert(consultationRecord) != 1) {
                throw new PlatTipsException(PlatformCode.ERROR_TIPS, "新增咨询记录失败!");
            }

            // 添加咨询用户日志
            User user = commonDao.selectOneByKey(UserMapper.class, consultationRecord.getUserId());
            if (user != null) {
                String opEmployeeId = null;
                SysAdmin opSysAdmin = null;
                if (BaseEntity.NO.equals(consultationRecord.getAdminType())) {
                    opEmployeeId = consultationRecord.getAdminId();
                } else {
                    opSysAdmin = commonDao.selectOneByKey(SysAdminMapper.class, consultationRecord.getAdminId());
                }
                // 用户日志
                JSONArray logArray = new JSONArray();
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("key", "(新版)添加咨询记录");
                logArray.add(jsonObject);
                // 记录编号
                String recordNo = systemParameterService.createUSLGNo(user.getId(), user.getCIQ());

                //操作平台类型
                String opType = null;
                if(consultRecordDto.getAdminType() == 1){
                    opType = PlatformConstants.TYPE_PLATFORM_PHIS;
                }else if(consultRecordDto.getAdminType() == 0){
                    opType = PlatformConstants.TYPE_PLATFORM_HIS;
                }
                // 添加用户日志
                UserInfoTool.addUserUpdateLog(commonService, opType, user, user.getShopId(), opEmployeeId, opSysAdmin, null, "(新版)添加咨询记录", logArray, null, recordNo);
            }
        }else {
            if (consultationRecordMapper.updateAll(consultationRecord) != 1) {
                throw new PlatTipsException(PlatformCode.ERROR_TIPS, "更新咨询记录失败!");
            }
        }

        //推荐项目
        if (!StringUtils.isEmpty(consultRecordDto.getRecommendProjectIds())) {
            List<String> recommendIdList = new ArrayList<>();
            for (String s:consultRecordDto.getRecommendProjectIds().split(",")) {
                recommendIdList.add(s);
            }
            handleRecommendPro(recommendIdList,consultationRecord.getId(), consultRecordDto.getUserId());
        }

        //治疗项目
        if (!StringUtils.isEmpty(consultRecordDto.getTreatProjectIds())) {
            List<String> treatIdList = new ArrayList<>();
            for (String s:consultRecordDto.getTreatProjectIds().split(",")) {
                treatIdList.add(s);
            }
            handleTreatPro(treatIdList,consultationRecord.getId(), consultRecordDto.getUserId());
        }

        //预约项目
        preProjectHandle(consultationRecord.getId(),consultationRecord.getUserId(),consultRecordDto.getPreProjectList());
        //颜值规划
        appearancePlanHandle(consultationRecord.getId(),consultRecordDto.getAppearancePlanList());

        return consultationRecord.getId();
    }


    /////////////////////////////////////////////////

    public Project getProjectById(String projectId) {

        Project project = commonDao.selectOneByKey(ProjectMapper.class, projectId);
        return project;

    }



    //---------------------------------------------------------------------

    /**处理治疗项目*/
    public void handleTreatPro(List<String> treatProjectIds,String recordId,String userId){

        SqlSentence sqlSentence = new SqlSentence();
        StringBuffer sql = new StringBuffer();
        Map<String, Object> values = new HashMap<>();
        sqlSentence.setM(values);
        //存储需要删除的数据
        Map<String, ConsultationTreatProject> delMap = new HashMap<>();

        values.put("recordId", recordId);
        values.put("type", ConsultationTreatProject.PROJECT_TYPE_TREAT);
        values.put("userId", userId);

        String sqlStr = "select * from consultation_treat_project where consultationRecordId = #{m.recordId} and isDel = 0 and userId = #{m.userId} and type = #{m.type}";

        //原本的数据
        sql.append(sqlStr);
        sqlSentence.setSqlSentence(sql.toString());
        List<ConsultationTreatProject> treatProjectList = consultationTreatProjectMapper.selectList(sqlSentence);
        if (treatProjectList != null && treatProjectList.size() != 0) {
            delMap = treatProjectList.stream().collect(Collectors.toMap(ConsultationTreatProject::getId, Function.identity()));
        }

        //当前的项目数据
        List<ConsultationTreatProject> thisTreatProjectList = null;
        if (treatProjectIds != null && treatProjectIds.size() > 0) {
            sql.delete(0, sql.length());
            sql.append(sqlStr).append(" and projectId in ( ");
            for (String proId : treatProjectIds) {
                sql.append("'").append(proId).append("',");
            }
            sql.delete(sql.length()-1, sql.length()).append(" ) ");
            sqlSentence.setSqlSentence(sql.toString());
            thisTreatProjectList = consultationTreatProjectMapper.selectList(sqlSentence);
        }

        //不存在则新增
        if(thisTreatProjectList == null || thisTreatProjectList.size() <=0){
            for (String proId : treatProjectIds) {
                Project project = getProjectById(proId);
                if (project == null) {
                    throw new TipsException("找不到项目信息！");
                }
                ConsultationTreatProject treatPro= new ConsultationTreatProject(userId, project.getId(), project.getName(), recordId, ConsultationTreatProject.PROJECT_TYPE_TREAT);
                if (consultationTreatProjectMapper.insert(treatPro) != 1) {
                    throw new TipsException("新增治疗项目信息信息失败！");
                }
            }
        }else {
            for (ConsultationTreatProject treatPro : thisTreatProjectList) {
                //如果存在，表示没有变动
                if (delMap != null && delMap.size() != 0 && delMap.containsKey(treatPro.getId())) {
                    delMap.remove(treatPro.getId());
                    continue;
                }

                Project project = getProjectById(treatPro.getProjectId());
                if (project == null) {
                    throw new TipsException("找不到项目信息！");
                }

                //不存在则更新
                treatPro = new ConsultationTreatProject(userId, project.getId(), project.getName(), recordId, ConsultationTreatProject.PROJECT_TYPE_TREAT);
                if (consultationTreatProjectMapper.insert(treatPro) != 1) {
                    throw new TipsException("新增治疗项目信息信息失败！");
                }

            }
            if (delMap != null && delMap.size() != 0) {
                //删除
                for (Map.Entry<String, ConsultationTreatProject> entry : delMap.entrySet()) {
                    if (consultationTreatProjectMapper.deleteById(entry.getValue().getId()) != 1) {
                        throw new TipsException("删除治疗项目失败！");
                    }
                }
            }
        }
    }


    /**预约项目*/
    public void preProjectHandle(String recordId,String userId,List<ConsultTreatProjectVo> preProjectList){

        //先删除旧的
        consultationTreatProjectMapper.deleteByRecordId(recordId,ConsultationTreatProject.PROJECT_TYPE_PRE);

        if(preProjectList == null || preProjectList.size() == 0){
            return;
        }

        ConsultationTreatProject consultationTreatProject;
        Project project;
        for(ConsultTreatProjectVo consultTreatProjectVo:preProjectList){
            if(StringUtils.isEmpty(consultTreatProjectVo.getProjectId())){
                throw new PlatTipsException(PlatformCode.ERROR_PARAMETER_NULL,"预约项目标识不能空！");
            }
            project = projectMapper.selectOneByKey(consultTreatProjectVo.getProjectId());
            if(project == null){
                throw new PlatTipsException(PlatformCode.ERROR_TIPS,"预约项目标识错误！");
            }
            consultationTreatProject = new ConsultationTreatProject(userId,project.getId(),project.getName(),recordId,ConsultationTreatProject.PROJECT_TYPE_PRE);
            consultationTreatProjectMapper.insert(consultationTreatProject);
        }
    }

    /**颜值规划*/
    public void appearancePlanHandle(String recordId,List<ConsultAppearancePlanVo> appearancePlanList){

        //先删除旧的
        appearancePlanMapper.deleteByRecordId(recordId);

        if(appearancePlanList == null || appearancePlanList.size() == 0){
            return;
        }

        ConsultationAppearancePlan consultationAppearancePlan;
        for(ConsultAppearancePlanVo consultAppearancePlanVo:appearancePlanList){
            consultationAppearancePlan = new ConsultationAppearancePlan(consultAppearancePlanVo.getDetails(),recordId);
            appearancePlanMapper.insert(consultationAppearancePlan);
        }
    }


    //处理推荐项目
    public void handleRecommendPro(List<String> recommendProjectIds,String recordId,String userId){

        SqlSentence sqlSentence = new SqlSentence();
        StringBuffer sql = new StringBuffer();
        Map<String, Object> values = new HashMap<>();
        sqlSentence.setM(values);
        //存储需要删除的数据
        Map<String, ConsultationRecommendedProject> delMap = new HashMap<>();

        values.put("recordId", recordId);
        values.put("userId", userId);

        String sqlStr = "select * from consultation_recommended_project where consultationRecordId = #{m.recordId} and isDel = 0 and userId = #{m.userId} ";

        //原本的数据
        sql.append(sqlStr);
        sqlSentence.setSqlSentence(sql.toString());
        List<ConsultationRecommendedProject> recommendProjectList = consultationRecommendedProjectMapper.selectList(sqlSentence);
        if (recommendProjectList != null && recommendProjectList.size() != 0) {
            delMap = recommendProjectList.stream().collect(Collectors.toMap(ConsultationRecommendedProject::getId, Function.identity()));
        }

        List<ConsultationRecommendedProject> thisRecommendProjectList = null;
        if(recommendProjectIds!= null && recommendProjectIds.size() > 0){
            sql.delete(0,sql.length());
            sql.append(sqlStr).append(" and projectId in ( ");
            for (String proId: recommendProjectIds) {
                sql.append("'").append(proId).append("',");
            }
            sql.delete(sql.length()-1, sql.length()).append(" ) ");
            sqlSentence.setSqlSentence(sql.toString());
            thisRecommendProjectList = consultationRecommendedProjectMapper.selectList(sqlSentence);
        }

        if(thisRecommendProjectList== null || thisRecommendProjectList.size() <=0 ){
            for (String proId: recommendProjectIds) {
                Project project = getProjectById(proId);
                if(project == null){
                    throw new TipsException("找不到推荐项目信息！");
                }

                //不存在则更新
                ConsultationRecommendedProject recommendedProject = new ConsultationRecommendedProject(userId,project.getId(), project.getName(), recordId);
                if (consultationRecommendedProjectMapper.insert(recommendedProject) != 1) {
                    throw new TipsException("新增推荐项目息信息失败！");
                }
            }
        }else {
            for (ConsultationRecommendedProject recommendedProject: thisRecommendProjectList) {
                //如果存在，表示没有变动
                if (delMap != null && delMap.size() != 0 && delMap.containsKey(recommendedProject.getId())) {
                    delMap.remove(recommendedProject.getId());
                    continue;
                }

                Project project = getProjectById(recommendedProject.getProjectId());
                if(project == null){
                    throw new TipsException("找不到推荐项目信息！");
                }

                //不存在则更新
                recommendedProject = new ConsultationRecommendedProject(userId,project.getId(), project.getName(), recordId);
                if (consultationRecommendedProjectMapper.insert(recommendedProject) != 1) {
                    throw new TipsException("新增推荐项目息信息失败！");
                }
            }

            if (delMap != null && delMap.size() != 0) {
                //删除
                for (Map.Entry<String, ConsultationRecommendedProject> entry : delMap.entrySet()) {
                    if (consultationRecommendedProjectMapper.deleteById(entry.getValue().getId()) != 1) {
                        throw new TipsException("删除推荐项目息失败！");
                    }
                }
            }
        }


    }

}