package com.ld.igds.phone.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.common.CoreDeviceService;
import com.ld.igds.common.dto.DepotSerData;
import com.ld.igds.constant.RespCodeEnum;
import com.ld.igds.models.Depot;
import com.ld.igds.models.Device;
import com.ld.igds.phone.constant.PhoneConstant;
import com.ld.igds.phone.dto.*;
import com.ld.igds.phone.param.ParamDevice;
import com.ld.igds.phone.param.PhoneRequest;
import com.ld.igds.phone.service.PhoneService;
import com.ld.igds.phone.util.PhoneRespUtil;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 设备控制-设备列表接口实现
 *
 * @author chen
 */
@Service
public class ServiceImpl5402 implements PhoneService {

    @Autowired
    private CoreCommonService coreCommonService;
    @Autowired
    private CoreDeviceService coreDeviceService;

    @Override
    public String getInterfaceId() {
        return PhoneConstant.API_PHONE_5402;
    }

    @SuppressWarnings("unchecked")
    @Override
    public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser authUser)
            throws Exception {

        //转化对象
        ParamDevice paramDevice = JSONObject.parseObject(req.getData().toString(), ParamDevice.class);

        //查看用户所属部门是否存在
        String deptId = authUser.getDeptId();
        if (StringUtils.isEmpty(deptId)) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "您的账号尚未分配部门/分库，无法查看！");
        }

        //判断登录用户部门是否是顶级部门，是的话默认分配到分库一
        if (deptId.equals(authUser.getCompanyId())) {
            deptId = authUser.getCompanyId() + "_001";
        }

        //创建响应的设备列表信息
        List<DtoDevice> listDevice = new ArrayList<>();
        DtoDevice dtoDevice;
        // 根据仓库缓存获取相同建筑物下的仓库集合
        List<Depot> list = coreCommonService.getCacheCommonBuildingDepot(
                authUser.getCompanyId(), paramDevice.getDepotId());
        // 获取ID信息
        List<String> depotIds = list.stream().map(Depot::getId)
                .collect(Collectors.toList());

        // 根据仓库多个ID获取仓库与分机的关系数据
        List<DepotSerData> depotSerDataList = coreCommonService
                .getCacheDepotSerByDepots(authUser.getCompanyId(), depotIds);

        List<Device> listAll = new ArrayList<Device>();
        List<Device> tempList;
        for (DepotSerData depotSerData : depotSerDataList) {
            tempList = coreDeviceService.getCacheDeviceBySerId(
                    authUser.getCompanyId(), depotSerData.getSerId());
            listAll.addAll(tempList);
        }

        if (listAll.size() > 0) {
            // 循环遍历多个仓的
            List<Device> listResult = listAll
                    .stream()
                    .filter(item -> item.getDepotId().equals(paramDevice.getDepotId())
                                    && (item.getType().equals(paramDevice.getType())
                                    || item.getType().equals(paramDevice.getType1())
                                    || item.getType().equals(paramDevice.getType2())
                                    || item.getType().equals(paramDevice.getType3())
                            )
                    )
                    .collect(Collectors.toList());
            if (listResult.size() > 0) {
                for (Device device : listResult) {
                    dtoDevice = new DtoDevice();
                    dtoDevice.setCompanyId(device.getCompanyId());
                    dtoDevice.setId(device.getId());
                    dtoDevice.setDepotId(device.getDepotId());
                    dtoDevice.setName(device.getName());
                    dtoDevice.setStatus(device.getStatus());
                    dtoDevice.setPassCode(device.getPassCode());
                    dtoDevice.setSerId(device.getSerId());
                    dtoDevice.setType(device.getType());
                    dtoDevice.setLocation(device.getLocation());
                    dtoDevice.setLink(device.getLink());
                    listDevice.add(dtoDevice);
                }
            }
        }

        if(listDevice.isEmpty()){
            return PhoneRespUtil.error(RespCodeEnum.CODE_2000, "该仓库暂无设备信息，请联系管理员！");
        }

        return PhoneRespUtil.success(listDevice, req);
    }

}