package com.ld.igds.m.service;


import com.bstek.bdf2.core.model.DefaultUser;
import com.bstek.bdf2.core.orm.hibernate.HibernateDao;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.dto.DepotData;
import com.ld.igds.m.mapper.ManagerMapper;
import com.ld.igds.models.*;
import com.ld.igds.sec.dto.SecCameraDto;
import com.ld.igds.sec.service.CoreSecCameraService;
import com.ld.igds.sys.service.DicTriggerService;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.weather.CoreWeatherService;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * @author chen
 */
@Component
public class HEmergencyCenterService extends HibernateDao {

    @Autowired
    private ManagerMapper managerMapper;
    @Autowired
    private CoreCommonService coreCommonService;
    @Autowired
    private DicTriggerService coreDicService;
    @Autowired
    private CoreSecCameraService coreSecCameraService;
    @Autowired
    private CoreWeatherService weatherService;

    /**
     * 设置仓库列表显示第一个仓库
     * @return
     */
    public Map<String, Object> getQueryDepot() {
        Map<String, Object> result = new HashMap<>();
        List<Depot> list = coreCommonService.getCacheDepotList(ContextUtil.getCompanyId());
        result.put("depotId", list.get(0).getId());
        return result;
    }

    /**
     * 根据仓库id获取仓库信息和保管员电话
     * @param depotId
     * @return
     */
    public DepotData getDepotData(String depotId){
        String companyId = ContextUtil.getCompanyId();

        //若仓库id为空，则显示第一个仓库信息
        if(StringUtils.isEmpty(depotId)){
            List<Depot> list = coreCommonService.getCacheDepotList(companyId);
            depotId = list.get(0).getId();
        }
        DepotData depotData = new DepotData();
        //缓存获取仓库信息
        List<Depot> depotList = coreCommonService.getCacheDepotList(companyId);
        //遍历集合
        for (Depot depot : depotList) {
            if(depotId.equals(depot.getId())){
                BeanUtils.copyProperties(depot,depotData);
            }
        }
        //查询保管员电话信息
        if(StringUtils.isNotEmpty(depotData.getStoreKeeperName())){
            //根据保管员名称获取保管员信息
            DefaultUser user = managerMapper.getUserByName(depotData.getStoreKeeperName(),companyId);
            if(user != null){
                if(StringUtils.isNotEmpty(user.getMobile())) {
                    //设置保管员电话信息
                    depotData.setStoreKeeperPhone(user.getMobile());
                }
            }
        }
        return depotData;
    }

    /**
     * 获取资产设备信息
     * @param companyId
     * @return
     */
    public Map<String, Object> getAsset(String companyId){
        if(StringUtils.isEmpty(companyId)){
            companyId = ContextUtil.getCompanyId();
        }
        List<OAAsset> assetList = managerMapper.getOAAsset(companyId);
        Map<String, Object> map = new HashMap<>();
        Integer temp = 0;
        for (OAAsset oaAsset : assetList) {
            temp = (Integer) map.get(oaAsset.getCategory());

            if(temp == null){
                map.put(oaAsset.getCategory(), 1);
            }else {
                map.put(oaAsset.getCategory(), temp + 1);
            }
        }
        return map;
    }

    /**
     * 获取消防信息
     * @param companyId
     * @return
     */
    public Map<String, Object> getFire(String companyId){
        if(StringUtils.isEmpty(companyId)){
            companyId = ContextUtil.getCompanyId();
        }
        List<SecFire> fireList = managerMapper.getSecFire(companyId);
        Map<String, Object> map = new HashMap<>();
        Integer temp1 = 0;
        Integer temp2 = 0;
        if(fireList.size() > 0){
            temp1 = (Integer) fireList.size();
            for (SecFire fire : fireList) {
                temp2 += fire.getNumExtinguisher();
            }
        }
        map.put("消防柜数量", temp1);
        map.put("灭火器数量", temp2);
        return map;
    }

    /**
     * 获取粮食数量信息
     * @param companyId
     * @return
     */
    public Map<String, Object> getFoodData(String companyId){
        if (StringUtils.isEmpty(companyId)){
            companyId = ContextUtil.getCompanyId();
        }
        //获取粮食品种字典集合信息
        List<DicTrigger> listFoodVariety = coreDicService.getCacheDicByParent(companyId,
                "FOOD_VARIETY_");

        //获取粮食性质字典集合信息
        List<DicTrigger> listFoodType = coreDicService.getCacheDicByParent(
                companyId, "FOOD_TYPE_");

        //从缓存获取仓库集合信息
        List<Depot> depotList = coreCommonService.getCacheDepotList(companyId);

        Map<String, Object> map = new HashMap<>();

        //品种数量临时变量
        Double temp1 ;
        //遍历粮食品种字典集合
        for (DicTrigger trigger : listFoodVariety) {
            temp1 = 0.0;
            String code1 = trigger.getCode();
            //遍历仓库集合
            for (Depot depot : depotList) {
                //设置品种对应数量累加
                if(code1.equals(depot.getFoodVariety())){
                    temp1 += depot.getStorageReal();
                }
            }
            map.put(trigger.getName(), temp1);
        }

        //性质数量临时变量
        Double temp2 ;
        //遍历粮食性质字典集合
        for (DicTrigger dicTrigger : listFoodType) {
            temp2 = 0.0;
            String code2 = dicTrigger.getCode();
            //遍历仓库集合
            for (Depot depot : depotList) {
                //设置性质对应数量累加
                if(code2.equals(depot.getFoodType())){
                    temp2 += depot.getStorageReal();
                }
            }
            map.put(dicTrigger.getName(), temp2);
        }
        return map;
    }

    /**
     *缓存获取监控设备列表
     * @return
     */
    public List<SecCameraDto> getCameraList() {
        return coreSecCameraService.getAllCacheCamera(ContextUtil.getCompanyId());
    }

    /**
     * 获取摄像头信息
     * @param id
     * @return
     */
    public SecCameraDto getCameraData(String id){
        //缓存中获取监控设备信息
        List<SecCameraDto> list = coreSecCameraService.getAllCacheCamera(ContextUtil.getCompanyId());

        //若id为空，则直接返回集合中第一个设备信息
        if(StringUtils.isEmpty(id)){
            return list.get(0);
        }
        //不为空则遍历集合
        for (SecCameraDto cameraDto : list) {
            if(id.equals(cameraDto.getId())){
                return cameraDto;
            }
        }
        return null;
    }

	public WeatherInfo getWeatherData(String companyId) {
		return weatherService.getCacheWeather(companyId);
	}
}