package com.care.common.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.care.common.cache.RedisKeyConstant;
import com.care.common.cache.RedisUtil;
import com.care.common.entity.*;
import com.care.common.enums.*;
import com.care.common.mapper.CareEventOrderMapper;
import com.care.common.service.*;
import com.care.common.vo.order.EventStaVO;
import org.apache.commons.compress.utils.Lists;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;

/**
 * 事件定单表(CareEventOrder)表服务实现类
 *
 * @author makejava
 * @since 2021-05-21 00:08:29
 */
@Service
public class CareEventOrderServiceImpl extends ServiceImpl<CareEventOrderMapper, CareEventOrder> implements CareEventOrderService {

    @Resource
    private CareEventOrderHandleHisService careEventOrderHandleHisService;
    @Resource
    private CareHouseContactService careHouseContactService;
    @Resource
    private CareOlderService careOlderService;
    @Resource
    private CareEventOrderOlderService careEventOrderOlderService;
    @Resource
    private CareEventOrderChambService careEventOrderChambService;
    @Resource
    private CareEventOrderContactStatusService careEventOrderContactStatusService;
    @Resource
    private CareHouseService careHouseService;
    @Resource
    private CareDeviceService careDeviceService;

    @Resource
    private CareSysUserService careSysUserService;
    @Resource
    private RedisUtil redisUtil;
    @Resource
    private SmsSendService smsSendService;
    @Resource
    private CareHouseOlderRelService careHouseOlderRelService;

    /**
     * 统计事件数量
     *
     * @param orgId
     * @param stationId
     * @return
     */
    @Override
    public EventStaVO statOrder(Long orgId, Long stationId) {
        return this.baseMapper.statOrder(orgId,stationId);
    }

    /**
     * 更新,不再生成新的告警工单，只作为子事件插入到当前工单的历史记录中
     * @param order
     * @param orderDb
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean saveHisOrder(CareEventOrder order,CareEventOrder orderDb){
//        orderDb.setOrderType(order.getOrderType());
//        this.updateById(orderDb);//更新
        order.setId(orderDb.getId());

        CareEventOrderHandleHis his = new CareEventOrderHandleHis();
        his.setOrgId(order.getOrgId());
        his.setStationId(order.getStationId());
        his.setOrderId(order.getId());
        his.setHouseId(order.getHouseId());
        his.setOrderType(order.getOrderType());
        if (OrderTypeEnum.ZHU_DONG_HU_JIAO.getValue().equals(order.getOrderType()) || OrderTypeEnum.HU_WAI_HU_JIAO.getValue().equals(order.getOrderType())){
            his.setLogType(LogTypeEnum.OLDER_EVENT.getValue());
            his.setLogObjectId(order.getOlderId());
            his.setLogObjectName(order.getOlderName());
            his.setLogResult(OrderTypeEnum.getCodeToName(order.getOrderType()));
            his.setRelationTypeDesc(RelationTypeEnum.OLDER.getName());
        } else {
            his.setLogType(LogTypeEnum.DEV_EVENT.getValue());
            his.setLogObjectId(order.getDevId());
            his.setLogObjectName(order.getDevName());
            his.setLogResult("发生"+OrderTypeEnum.getCodeToName(order.getOrderType()));
            his.setRelationTypeDesc(RelationTypeEnum.HOUSE.getName());
        }
        his.setCreateTime(order.getCreateTime());
        this.careEventOrderHandleHisService.save(his);

        return true;
    }

    /**
     * 新增，生成新的告警事件工单
     * @param order
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean saveOrder(CareEventOrder order){
        this.baseMapper.insert(order);
        CareEventOrderHandleHis his = new CareEventOrderHandleHis();
        his.setOrgId(order.getOrgId());
        his.setStationId(order.getStationId());
        his.setOrderId(order.getId());
        his.setHouseId(order.getHouseId());
        his.setOrderType(order.getOrderType());
        if (OrderTypeEnum.ZHU_DONG_HU_JIAO.getValue().equals(order.getOrderType()) || OrderTypeEnum.HU_WAI_HU_JIAO.getValue().equals(order.getOrderType())){
            his.setLogType(LogTypeEnum.OLDER_EVENT.getValue());
            his.setLogObjectId(order.getOlderId());
            his.setLogObjectName(order.getOlderName());
            his.setLogResult(OrderTypeEnum.getCodeToName(order.getOrderType()));
            his.setRelationTypeDesc(RelationTypeEnum.OLDER.getName());
        }else{
            his.setLogType(LogTypeEnum.DEV_EVENT.getValue());
            his.setLogObjectId(order.getDevId());
            his.setLogObjectName(order.getDevName());
            his.setLogResult("发生"+OrderTypeEnum.getCodeToName(order.getOrderType()));
            his.setRelationTypeDesc(RelationTypeEnum.HOUSE.getName());
        }
        his.setCreateTime(order.getCreateTime());

        addOlderToOrderOlder(order);
        List<CareEventOrderChamb> chambList =  addChamberlainToOrder(order);
        List<CareEventOrderContactStatus> contacts = addContactToOrderContact(order);
        Object switchSms = redisUtil.get(RedisKeyConstant.SWITCH_SMS);
        if (switchSms != null){
            //给联系人发送短信
            CareHouse house = this.careHouseService.getById(order.getHouseId());
            if (CollUtil.isNotEmpty(contacts)){

                contacts.forEach(item ->{
                    boolean smsResult = smsSendService.sendSmsToLianxiren(order.getOrderType(),item.getContactPhone(),house.getName());
                    if (smsResult){
                        CareEventOrderHandleHis his2 = new CareEventOrderHandleHis();
                        his2.setOrgId(item.getOrgId());
                        his2.setStationId(item.getStationId());
                        his2.setOrderId(item.getOrderId());
                        his2.setLogType(LogTypeEnum.SMS.getValue());
                        his2.setLogObjectId(item.getContactId());
                        his2.setLogObjectName(item.getContactName());
                        his2.setLogResult("短信通知");
                        his2.setOpUserRole(UserRoleEnum.SEAT.getValue());
                        his2.setCreateTime(DateUtil.date());
                        his2.setRelationTypeDesc(item.getRelationTypeDesc());
                        this.careEventOrderHandleHisService.save(his2);
                    }
                });
            }
            //给管家发短信
            if (CollUtil.isNotEmpty(chambList)){
                chambList.forEach(item ->{
                    boolean smsResult = smsSendService.sendSmsToLianxiren(order.getOrderType(),item.getPhone(),house.getName());
                    if (smsResult){
                        CareEventOrderHandleHis his2 = new CareEventOrderHandleHis();
                        his2.setOrgId(item.getOrgId());
                        his2.setStationId(item.getStationId());
                        his2.setOrderId(item.getOrderId());
                        his2.setLogType(LogTypeEnum.SMS.getValue());
                        his2.setLogObjectId(item.getChambId());
                        his2.setLogObjectName(item.getChambName());
                        his2.setLogResult("短信通知");
                        his2.setOpUserRole(UserRoleEnum.SEAT.getValue());
                        his2.setCreateTime(DateUtil.date());
                        his2.setRelationTypeDesc("管家");
                        this.careEventOrderHandleHisService.save(his2);
                    }
                });
            }
        }
        this.careEventOrderHandleHisService.save(his);
        return true;
    }


    /**
     * 将老人加入到 工单中
     * @param order
     */
    private void addOlderToOrderOlder(CareEventOrder order){
        QueryWrapper<CareHouseOlderRel> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(CareHouseOlderRel::getHouseId,order.getHouseId());
        List<CareHouseOlderRel> olderRels = this.careHouseOlderRelService.list(queryWrapper);
        if (CollUtil.isNotEmpty(olderRels)){
            List<CareEventOrderOlder>  ceoos = Lists.newArrayList();
            olderRels.forEach(item -> {
                CareOlder careOlder = this.careOlderService.getById(item.getOlderId());
                CareEventOrderOlder ceoo = new CareEventOrderOlder();
                BeanUtil.copyProperties(careOlder,ceoo);
                ceoo.setOrgId(order.getOrgId());
                ceoo.setStationId(order.getStationId());
                ceoo.setOrderId(order.getId());
                ceoo.setOlderId(item.getId());
                if (order.getOlderId() == item.getId()){
                    //主动呼叫
                    ceoo.setIsZhudong(1);
                }else{
                    ceoo.setIsZhudong(0);
                }
                ceoo.setStatus(OrderOlderStatusEnum.WEI_LIAN_XI.getValue());
                ceoo.setCreateTime(order.getCreateTime());
                ceoos.add(ceoo);
            });
            this.careEventOrderOlderService.saveBatch(ceoos);
        }
    }

    /**
     * 将管家加入到工单当中
     * @param order
     */
    private List<CareEventOrderChamb> addChamberlainToOrder(CareEventOrder order){
        List<CareEventOrderChamb> chambList = Lists.newArrayList();
        CareDevice dev = this.careDeviceService.getById(order.getDevId());
        if (dev != null){
            CareSysUser user = this.careSysUserService.getById(dev.getChambId());
            if (user != null){
                CareEventOrderChamb chamb = new CareEventOrderChamb();
                chamb.setOrgId(user.getOrgId());
                chamb.setStationId(user.getStationId());
                chamb.setOrderId(order.getId());
                chamb.setChambId(user.getId());
                chamb.setChambName(user.getName());
                chamb.setPhone(user.getPhone());
                chamb.setStatus(ChambOrderStatusEnum.TODO.getValue());
                chamb.setHouseId(dev.getHouseId());
                chamb.setCreateTime(order.getCreateTime());
                chamb.setModifyTime(order.getCreateTime());
                this.careEventOrderChambService.save(chamb);
                chambList.add(chamb);
            }
        }
        return chambList;
    }

    /**
     * 将紧急联系人加入到联系人当中
     * @param order
     */
    private List<CareEventOrderContactStatus> addContactToOrderContact(CareEventOrder order){
        List<CareEventOrderContactStatus> orderContactList = Lists.newArrayList();
        List<CareHouseContact> cons = this.careHouseContactService.queryContactByHouseId(order.getHouseId());
        if (CollUtil.isNotEmpty(cons)){
            cons.forEach(item ->{
                CareEventOrderContactStatus orderContactStatus = new CareEventOrderContactStatus();
                orderContactStatus.setOrgId(order.getOrgId());
                orderContactStatus.setStationId(order.getStationId());
                orderContactStatus.setOrderId(order.getId());
                orderContactStatus.setHouseId(order.getHouseId());
                orderContactStatus.setContactRole(UserRoleEnum.CONTACT.getValue());
                orderContactStatus.setContactId(item.getId());
                orderContactStatus.setStatus(ContactorStatusEnum.WEI_LIAN_XI.getValue());
                orderContactStatus.setContactName(item.getContactName());
                orderContactStatus.setContactPhone(item.getContactPhone());
                orderContactStatus.setLongitude(item.getLongitude());
                orderContactStatus.setLatitude(item.getLatitude());
                orderContactStatus.setRelationTypeDesc(RelationTypeEnum.getCodeToName(item.getRelationType()));
                orderContactStatus.setContactLevel(item.getContactLevel());
                orderContactStatus.setCreateTime(order.getCreateTime());
                orderContactStatus.setModifyTime(order.getCreateTime());
                orderContactList.add(orderContactStatus);
            });
            this.careEventOrderContactStatusService.saveBatch(orderContactList);
        }
        return orderContactList;
    }
}