package cn.besteam.modules.medical.service.impl;

import cn.besteam.modules.medical.dto.MwWarningRecordDealDTO;
import cn.besteam.modules.medical.entity.MwMessage;
import cn.besteam.modules.medical.entity.MwWarningRecord;
import cn.besteam.modules.medical.entity.MwWarningRecordDeal;
import cn.besteam.modules.medical.mapper.MwWarningRecordDealMapper;
import cn.besteam.modules.medical.service.IMwMessageService;
import cn.besteam.modules.medical.service.IMwWarningRecordDealService;
import cn.besteam.modules.medical.service.IMwWarningRecordService;
import cn.besteam.modules.medical.vo.MwNoticeVO;
import cn.besteam.modules.medical.vo.MwWarningRecordDealVO;
import cn.besteam.modules.shiro.authc.util.EnvUtils;
import cn.besteam.modules.system.biz.AliSmsService;
import cn.besteam.modules.system.entity.SysDepartment;
import cn.besteam.modules.system.service.ISysDepartmentService;
import cn.besteam.modules.system.service.ISysUserRoleService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import java.util.HashMap;
import java.util.Map;

/**
 * @Description: 预警消息处理
 * @author： besteam
 * @date：   2022-02-15
 * @version： V1.0
 */
@Service
public class MwWarningRecordDealServiceImpl extends ServiceImpl<MwWarningRecordDealMapper, MwWarningRecordDeal> implements IMwWarningRecordDealService {
    @Autowired
    private IMwMessageService mwMessageService;
    @Autowired
    private IMwWarningRecordService mwWarningRecordService;
    @Autowired
    private ISysUserRoleService sysUserRoleService;
    @Autowired
    private AliSmsService aliSmsService;
    @Autowired
    private ISysDepartmentService sysDepartmentService;



    @Override
    public IPage<MwWarningRecordDealVO> queryPageList(Integer pageNo, Integer pageSize, MwWarningRecordDealDTO mwWarningRecordDealDTO) {
        Page<MwWarningRecordDealVO> page = new Page<>(pageNo, pageSize);
        IPage<MwWarningRecordDealVO> result = baseMapper.queryPageList(page, mwWarningRecordDealDTO);
        return result;
    }

    @Override
    public Boolean add(MwWarningRecordDeal mwWarningRecordDeal) {
        if(mwWarningRecordDeal.getWarningRecordId()!=null) {
            String[] warningRecordIds=mwWarningRecordDeal.getWarningRecordId().split(",");
            for(String warningRecordId_:warningRecordIds) {
                Integer warningRecordId = Integer.valueOf(warningRecordId_.trim());
                MwWarningRecord mwWarningRecord = mwWarningRecordService.getById(warningRecordId);
                if (mwWarningRecordDeal.getType() == 1) {//提醒
                    String content = "";
                    String userIds = "";
                    String userPhones = "";
                    Integer hospitalId = 0;
                    Integer count = mwWarningRecordService.count(new QueryWrapper<MwWarningRecord>()
                            .eq("hospital_id", mwWarningRecord.getHospitalId())
                            .eq("status", 1));
                    hospitalId = mwWarningRecord.getHospitalId();
                    SysDepartment sysDepartment = sysDepartmentService.getById(hospitalId);
                    if(sysDepartment!=null){
                        content = sysDepartment.getDepartName()+"，温馨提醒，您有" + count + "条预警未处理，请及时处理！";
                    }else {
                        content = "温馨提醒，您有" + count + "条预警未处理，请及时处理！";
                    }

                    if (mwWarningRecord != null) {
                        hospitalId = mwWarningRecord.getHospitalId();
                        //温馨提醒，您有X条预警未处理，请及时处理！
                        if (mwWarningRecordDeal.getRemindWay() != null
                                && mwWarningRecordDeal.getRemindWay().contains("1")) {//短信
                            if (mwWarningRecord.getLevel() == 2) {//2等级预警通知一级预警人员
                                userPhones = sysUserRoleService.getUserPhoneList("23", hospitalId);//一级预警人员
                            } else if (mwWarningRecord.getLevel() == 3) {//3等级预警通知一二级预警人员
                                userPhones = sysUserRoleService.getUserPhoneList("23,24", hospitalId);//一，二级预警人员
                            }
                            Map<String, String> param = new HashMap<>();
                            //todo 短信发送通知消息
                            //aliSmsService.sendMessage(userPhones, param);

                        } else if (mwWarningRecordDeal.getRemindWay() != null
                                && mwWarningRecordDeal.getRemindWay().contains("2")) {//通知消息
                            MwMessage mwMessage = new MwMessage();
                            mwMessage.setTitle("预警提醒");
                            mwMessage.setPromulgator(EnvUtils.getUser().getName());
                            if (mwWarningRecord != null && mwWarningRecord.getLevel() == 2) {//2等级预警通知一级预警人员
                                userIds = sysUserRoleService.getUserIdList("23", hospitalId);//一级预警人员
                            } else if (mwWarningRecord != null && mwWarningRecord.getLevel() == 3) {//3等级预警通知一二级预警人员
                                userIds = sysUserRoleService.getUserIdList("23,24", hospitalId);//一，二级预警人员
                            }
                            mwMessage.setUserId(userIds);
                            mwMessage.setContent(content);
                            mwMessage.setWarningRecordId(warningRecordId);
                            mwMessage.setStatus(0);
                            mwMessageService.save(mwMessage);
                        }

                    }
                    mwWarningRecord.setSuperviseCount(mwWarningRecord.getSuperviseCount() + 1);
                    mwWarningRecordService.updateById(mwWarningRecord);
                } else {
                    mwWarningRecord.setMessageCount(mwWarningRecord.getMessageCount() + 1);
                    mwWarningRecordService.updateById(mwWarningRecord);
                }
                mwWarningRecordDeal.setWarningRecordId(warningRecordId+"");
                this.baseMapper.insert(mwWarningRecordDeal);
            }
        }

        return true ;
    }
}