package com.ld.igds.three.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.common.CoreDeviceService;
|
import com.ld.igds.common.CoreThreeService;
|
import com.ld.igds.common.dto.DepotSerData;
|
import com.ld.igds.constant.DeviceType;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.request.ExeDevice;
|
import com.ld.igds.io.response.DeviceControlResponse;
|
import com.ld.igds.models.Device;
|
import com.ld.igds.models.ThreeConf;
|
import com.ld.igds.temp.dto.TempParam;
|
import com.ld.igds.temp.manager.TempControlManager;
|
import com.ld.igds.three.ThreeCodeEnum;
|
import com.ld.igds.three.ThreeConstant;
|
import com.ld.igds.three.data.Data3001;
|
import com.ld.igds.three.data.ThreeResponse;
|
import com.ld.igds.three.param.Param4001;
|
import com.ld.igds.three.param.ThreeRequest;
|
import com.ld.igds.three.service.ThreeService;
|
import com.ld.igds.three.util.ThreeRespUtil;
|
import com.ld.igds.verb.dto.VerbParam;
|
import com.ld.igds.verb.manager.VerbManager;
|
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;
|
|
/**
|
* 4001-单个设备操作接口实现
|
*
|
* @author chen
|
*/
|
@Service
|
public class ThreeServiceImpl4001 implements ThreeService {
|
|
@Autowired
|
private CoreCommonService commonService;
|
@Autowired
|
private CoreThreeService coreThreeService;
|
@Autowired
|
private CoreDeviceService deviceService;
|
@Autowired
|
private VerbManager verbManager;
|
@Autowired
|
private TempControlManager tempManager;
|
|
@Override
|
public String getInterfaceId() {
|
return ThreeConstant.API_THREE_4001;
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public ThreeResponse<Object> execute(ThreeRequest<JSONObject> req) {
|
//转化请求参数
|
Param4001 param = JSONObject.parseObject(req.getData().toString(), Param4001.class);
|
|
//判断uid
|
if (StringUtils.isEmpty(param.getUid())) {
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1005, req);
|
}
|
|
//根据uid获取三维配置信息
|
ThreeConf three = coreThreeService.getCacheThreeConfById(req.getCompanyId(), param.getUid());
|
if (three == null) {
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询到此uid的配置信息，请联系管理员！", req);
|
}
|
|
//获取uid对应的设备信息
|
Device device = getDevice(three, req.getCompanyId());
|
|
if(device == null){
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1111, "未查询到此uid的配置信息，请联系管理员！", req);
|
}
|
|
ExeDevice exeDevice = new ExeDevice();
|
exeDevice.setId(device.getId());
|
exeDevice.setCompanyId(device.getCompanyId());
|
exeDevice.setDepotId(device.getDepotId());
|
exeDevice.setPassCode(device.getPassCode());
|
exeDevice.setName(device.getName());
|
exeDevice.setSerId(device.getSerId());
|
exeDevice.setType(device.getType());
|
exeDevice.setLink(device.getLink());
|
|
DeviceControlResponse response;
|
//判断设备类型，是否是空调
|
if(DeviceType.TYPE_05.getCode().equals(device.getType())){
|
//空调设备操作执行
|
TempParam tempParam = new TempParam();
|
|
//设置空调设备的目标参数
|
List<ExeDevice> list = new ArrayList<>();
|
list.add(exeDevice);
|
tempParam.setDeviceList(list);
|
tempParam.setTargetStatus(param.getStatus());
|
tempParam.setTargetTemp(param.getTemp());
|
tempParam.setDepotId(device.getDepotId());
|
tempParam.setCompanyId(device.getCompanyId());
|
|
response = tempManager.tempControl(tempParam);
|
|
}else {
|
//非空调设备操作执行
|
VerbParam verbParam = new VerbParam();
|
List<ExeDevice> list = new ArrayList<>();
|
|
//设置非空调设备的目标参数
|
exeDevice.setTargetStatus(param.getStatus());
|
list.add(exeDevice);
|
verbParam.setDepotId(list.get(0).getDepotId());
|
verbParam.setCompanyId(list.get(0).getCompanyId());
|
verbParam.setDeviceList(list);
|
|
response = verbManager.controlDevice(verbParam);
|
}
|
|
//判断是否执行成功
|
if (OrderRespEnum.ORDER_ERROR.getCode().equals(response.getCode())) {
|
return ThreeRespUtil.error(ThreeCodeEnum.CODE_1004, response.getMsg(), req);
|
} else {
|
Data3001 data = new Data3001();
|
data.setUid(three.getUid());
|
data.setName(device.getName());
|
data.setType(device.getType());
|
device = getDevice(three, req.getCompanyId());
|
data.setStatus(device.getStatusName());
|
return ThreeRespUtil.success(data, req);
|
}
|
}
|
|
/**
|
* 根据三维配置信息，获取对应设备信息
|
* @param three
|
* @param companyId
|
* @return
|
*/
|
private Device getDevice(ThreeConf three, String companyId){
|
|
//根据仓库编码获取分机
|
List<String> depotList = new ArrayList<>();
|
depotList.add(three.getDepotId());
|
List<DepotSerData> depotSerList = commonService.getCacheDepotSerByDepots(companyId, depotList);
|
|
//存放分机获取的设备信息
|
List<Device> deviceList = new ArrayList<>();
|
|
//根据分机获取设备，存入deviceList
|
for (DepotSerData depotSerData : depotSerList) {
|
List<Device> tempList = deviceService.getCacheDeviceBySerId(
|
depotSerData.getCompanyId(), depotSerData.getSerId());
|
deviceList.addAll(tempList);
|
}
|
|
if(deviceList.isEmpty()){
|
return null;
|
}
|
for (Device device : deviceList) {
|
if(device.getId().equals(three.getDeviceId())){
|
return device;
|
}
|
}
|
return null;
|
}
|
}
|
