package com.zcloud.service.firemanager.impl;

import java.util.*;

import javax.annotation.Resource;

import com.alibaba.fastjson.JSONObject;
import com.zcloud.mapper.datasource.firemanager.FireChangeLogMapper;
import com.zcloud.util.*;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.zcloud.entity.Page;
import com.zcloud.entity.PageData;
import com.zcloud.entity.system.Dictionaries;
import com.zcloud.mapper.datasource.firemanager.FireDeviceMapper;
import com.zcloud.service.firemanager.FireDeviceService;
import com.zcloud.service.firemanager.FirePointService;
import com.zcloud.service.firemanager.FireRegionService;
import com.zcloud.service.system.DepartmentService;
import com.zcloud.service.system.DictionariesService;
import com.zcloud.service.system.UsersService;

/**
 * 说明：消防器材 作者：wangxuan 官网：www.zcloudchina.com
 */
@Service
public class FireDeviceServiceImpl implements FireDeviceService {

    @Resource
    private FireDeviceMapper fireDeviceMapper;
    @Resource
    private FireChangeLogMapper fireChangeLogMapper;
    @Resource
    private FireRegionService fireRegionService;
    @Resource
    private FirePointService firePointService;
    @Resource
    private DictionariesService dictionariesService;
    @Resource
    private UsersService usersService;

    @Resource
    private InitPageDataUtil initPageDataUtil;

    @Resource
    private DepartmentService departmentService;

    @Override
    public List<PageData> list(Page page) {
        return fireDeviceMapper.datalistPage(page);
    }

    @Override
    public PageData findById(PageData pd) {
        return fireDeviceMapper.findById(pd);
    }

    @Override
    @Transactional
    public void updFireDeviceById(PageData pd) {
        fireDeviceMapper.updFireDeviceById(pd);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean delFireDeviceByIds(PageData pd) {
        PageData pageData = fireDeviceMapper.tryDel(pd);
        if ("0".equals(String.valueOf(pageData.get("sum")))) {
            fireDeviceMapper.delFireDeviceByIds(pd);
            return true;
        }
        return false;
    }

    @Override
    @Transactional
    public void saveDeviceInfo(PageData pd) {
        fireDeviceMapper.saveDeviceInfo(pd);
    }

    @Override
    public List<PageData> getDeviceListByPointId(PageData pageData) {
        return fireDeviceMapper.getDeviceListByPointId(pageData);
    }

    @Override
    public PageData getPointCode(PageData pageData) {
        return fireDeviceMapper.getPointCode(pageData);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void doRemoveDeviceHidden(String hiddenId) {
        fireDeviceMapper.doRemoveDeviceHidden(hiddenId);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addHidden4Device(LinkedList<PageData> addHiddenDeviceList) {
        // 对设备添加隐患
        addHiddenDeviceList.forEach(item -> {
            fireDeviceMapper.addHidden4Device(item);
        });
    }

    @Override
    public List<PageData> getStandardIDByDeviceID(PageData queryData) {
        return fireDeviceMapper.getStandardIDByDeviceID(queryData);
    }

    @Override
    public Map<String, Integer> getcodeByCorp(PageData pd) throws Exception {
        Map<String, Integer> map = new HashMap<>();
        List<PageData> list = fireDeviceMapper.listAll(pd);
        for (PageData pageData : list) {
            map.put(pageData.getString("FIRE_DEVICE_CODE"), 0);
        }
        return map;
    }

    @Override
    public Map<String, Object> saveToExcel(List<PageData> listPd) throws Exception {

        PageData pd = new PageData();
        pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
        Map<String, PageData> getquyeListAll = fireRegionService.getAllByCorpIdForExcel(pd); // 获取数据库中的所有消防区域
        Map<String, PageData> getdianweiListAll = firePointService.getAllByCorpIdForExcel(pd); // 获取数据库中的所有消防点位

        Map<String, Dictionaries> getDicMap = dictionariesService.getMapByParId("249151f04fd64132a949fdd430a7b9c5");

        Map<String, String> getCorpDepartAllMap = departmentService.getDepartMapFroExcel(pd); // 这个企业的所有部门
        Map<String, String> getCorpUserAllMap = usersService.getUserMapFroExcel(pd); // 这个企业的所有人员

        for (PageData lpd : listPd) { // 判断必填 等信息 ,如果这里的信息通过,就要 新增信息
            String xfqyName = Tools.isEmpty(lpd.get("var1")) ? "" : Tools.excelHandle(lpd.get("var1"));
            String xfqyBianma = Tools.isEmpty(lpd.get("var2")) ? "" : Tools.excelHandle(lpd.get("var2"));
            String dwName = Tools.isEmpty(lpd.get("var3")) ? "" : Tools.excelHandle(lpd.get("var3"));
            String dwBianma = Tools.isEmpty(lpd.get("var4")) ? "" : Tools.excelHandle(lpd.get("var4"));
            String departName = Tools.isEmpty(lpd.get("var5")) ? "" : Tools.excelHandle(lpd.get("var5"));
            String userName = Tools.isEmpty(lpd.get("var6")) ? "" : Tools.excelHandle(lpd.get("var6"));
            String xfLxName = Tools.isEmpty(lpd.get("var7")) ? "" : Tools.excelHandle(lpd.get("var7"));
            String code = Tools.isEmpty(lpd.get("var8")) ? "" : Tools.excelHandle(lpd.get("var8"));
            String startTime = Tools.isEmpty(lpd.get("var9")) ? "" : Tools.excelHandle(lpd.get("var9"));
            String endTime = Tools.isEmpty(lpd.get("var10")) ? "" : Tools.excelHandle(lpd.get("var10"));
            String REMAKE = Tools.isEmpty(lpd.get("var11")) ? "" : Tools.excelHandle(lpd.get("var11"));

            String departId = "";
            if (getCorpDepartAllMap.containsKey(departName)) {
                departId = getCorpDepartAllMap.get(departName);
            }
            String userID = "";
            if (getCorpUserAllMap.containsKey(userName)) {
                userID = getCorpUserAllMap.get(userName);
            }

            PageData qyPd = new PageData();
            PageData dwPd = new PageData();
            Dictionaries xfLcDic = new Dictionaries();
            if (!getquyeListAll.containsKey(xfqyName + "--" + xfqyBianma)) {
                // 没有的消防区域,增加消防区域
                qyPd = fireRegionService.savaByExcel(xfqyName, xfqyBianma, departId); // 新增这个区域
                getquyeListAll.put(xfqyName + "--" + xfqyBianma, qyPd);
            } else {
                qyPd = getquyeListAll.get(xfqyName + "--" + xfqyBianma);
            }
            if (!getdianweiListAll.containsKey(dwName + "--" + dwBianma + "--" + qyPd.getString("FIRE_REGION_ID"))) { // 这个消防区域没有这个点位
                dwPd = firePointService.saveFroExcel(dwName, dwBianma, qyPd.getString("FIRE_REGION_ID"), departId, userID); // 新增点位
                getdianweiListAll.put(dwName + "--" + dwBianma + "--" + qyPd.getString("FIRE_REGION_ID"), dwPd);
            } else {
                dwPd = getdianweiListAll.get(dwName + "--" + dwBianma + "--" + qyPd.getString("FIRE_REGION_ID"));
            }
            if (getDicMap.containsKey(xfLxName)) {
                xfLcDic = getDicMap.get(xfLxName);
            }
            PageData qc = this.saveFroExcel(qyPd, dwPd, xfLcDic, code, startTime, endTime, REMAKE);
        }
        return null;
    }

    public PageData saveFroExcel(PageData qyPd, PageData dwPd, Dictionaries xfLcDic, String code, String startTime,
                                 String endTime, String REMAKE) {
        PageData pd = new PageData();
        pd.put("FIRE_DEVICE_ID", UuidUtil.get32UUID());
        pd.put("CREATOR", Jurisdiction.getUSER_ID());
        pd.put("OPERATOR", Jurisdiction.getUSER_ID());
        pd.put("CREATTIME", DateUtil.date2Str(new Date()));
        pd.put("OPERATTIME", DateUtil.date2Str(new Date()));
        pd.put("ISDELETE", DateUtil.date2Str(new Date()));

        pd.put("FIRE_DEVICE_CODE", code);
        pd.put("FIRE_REGION_ID", qyPd.getString("FIRE_REGION_ID"));
        pd.put("FIRE_POINT_ID", dwPd.getString("FIRE_POINT_ID"));
        pd.put("FIRE_DEVICE_TYPE_ID", xfLcDic.getBIANMA());
        pd.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
        if (!Tools.isEmpty(startTime)) {
            pd.put("VALIDITY_START_TIME", DateUtil.date2Str(DateUtil.getDateByDayInt(Integer.parseInt(startTime))));
        }
        if (!Tools.isEmpty(endTime)) {
            pd.put("VALIDITY_END_TIME", DateUtil.date2Str(DateUtil.getDateByDayInt(Integer.parseInt(endTime))));
        }
        pd.put("REMAKE", REMAKE);
        pd.put("DEPARTMENT_ID", qyPd.getString("DEPARTMENT_ID"));
        this.saveDeviceInfo(pd);
        return pd;
    }

    @Override
    public PageData getDeviceById(PageData pd) throws Exception {
        return fireDeviceMapper.getDeviceById(pd);
    }

    @Override
    public PageData hasFireDeviceCode(PageData pd) throws Exception {
        // 有设备id  查一下当前的编号与本设备是否相同
        if (Tools.notEmpty(pd.getString("FIRE_DEVICE_ID"))) {
            PageData deviceById = fireDeviceMapper.getDeviceById(pd);
            if (deviceById.getString("FIRE_DEVICE_CODE").equals(pd.getString("FIRE_DEVICE_CODE"))) {
                PageData pageData = new PageData();
                pageData.put("DEVICE_CODE_NUM", "0");
                return pageData;
            }
        }
        // FIRE_DEVICE_CODE
        PageData list = fireDeviceMapper.getDeviceCodeNum(pd);
        return list;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updPointDepAuserByRegId(PageData pageData) {
        fireDeviceMapper.updPointDepAuserByRegId(pageData);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void removeFireDeviceByIds(PageData pd) {
        // 删除设备 但是设备会在其他点检表里用,如果在表里用也删除掉，但是留下记录。
        String DATA_IDS = pd.getString("DATA_IDS");
        if (Tools.notEmpty(DATA_IDS)) {
            String ArrayDATA_IDS[] = DATA_IDS.split(",");
            pd.put("ArrayDATA_IDS", ArrayDATA_IDS);
            List<PageData> fireCheckIdList = fireDeviceMapper.getFireCheckIdByDeciveID(pd);
            StringBuilder stringBuilder = new StringBuilder();
            for (PageData pageData : fireCheckIdList) {
                pageData.put("CARRYINGDATA", JSONObject.toJSONString(pd));
                pageData.put("FIRE_CHANGE_LOG",UuidUtil.get32UUID());
                pageData.put("OPERATE",2);
                pageData.put("OPERATOR",Jurisdiction.getUSER_ID());
                pageData.put("OPERATTIME",DateUtil.date2Str(new Date()));
                pageData.put("OPERATOR_NAME",Jurisdiction.getName());
                stringBuilder.append("删除了编号为：").append(pageData.getString("FIRE_DEVICE_CODE"))
                        .append("。类型为：").append(pageData.getString("FIRE_DEVICE_TYPE_NAME")).append("的消防器材");
                pageData.put("SKETCH",stringBuilder.toString());
                stringBuilder.setLength(0);
            }
            if (fireCheckIdList.size() > 0) {
                fireChangeLogMapper.saveBatch(fireCheckIdList);
                fireDeviceMapper.delDevicePreparedByIds(fireCheckIdList);
            }
            initPageDataUtil.initEdit(pd);
            fireDeviceMapper.deleteAll(pd);
        }
    }

    @Override
    public List<PageData> exportDataList(PageData pd) throws Exception {
        return fireDeviceMapper.exportDataList(pd);
    }

    @Override
    public void batchUpdPointDepAuserByRegId(PageData pd) {
        fireDeviceMapper.batchUpdPointDepAuserByRegId(pd);
    }


}