package com.ld.igds.protocol.bhzn.verb.analysis;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.common.CoreDeviceService;
|
import com.ld.igds.constant.DeviceStatus;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.request.ExeDevice;
|
import com.ld.igds.models.Device;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.protocol.bhzn.verb.command.BaseRemoteImpl;
|
import com.ld.igds.protocol.bhzn.verb.dto.IoMessage;
|
import com.ld.igds.protocol.bhzn.verb.dto.Res247;
|
import com.ld.igds.protocol.bhzn.verb.server.BhznVerbServerUtils;
|
import com.ld.igds.temp.dto.TempParam;
|
import com.ld.igds.util.BytesUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import java.util.ArrayList;
|
import java.util.List;
|
/**
|
* 设备操作类
|
*/
|
@Slf4j
|
@Component(AnalysisDevice.BEAN_ID)
|
public class AnalysisDevice extends BaseRemoteImpl {
|
|
public static final String BEAN_ID = "bhzn.analysisDevice";
|
|
@Autowired
|
private CoreDeviceService deviceService;
|
@Autowired
|
private NotifyWebInvoker notifyInvoker;
|
|
|
|
/**
|
* 设备状态
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis(IoMessage reMessage, DeviceSer ser) {
|
Res247 res247 = JSONObject.parseObject(reMessage.getContentStr(),Res247.class);
|
AnalysisWin(ser,res247.getWin_Str());
|
AnalysisFan(ser,res247.getFan_Str());
|
AnalysisAir(ser,res247.getAir_Str());
|
AnalysisLight(ser,res247.getLight_Str());
|
// BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(),0, "");
|
// }
|
deviceService.updateStatus(ser.getCompanyId(), ser.getId(), BhznVerbServerUtils.getStatusMap());
|
//
|
notifyInvoker.notifyAnalysisStatusSuccess(ser.getCompanyId(), ser.getId(), OrderRespEnum.MSG_SUCCESS, "设备状态查询成功并完成解析！");
|
}
|
|
/**
|
* 解析窗户状态
|
* @param ser
|
* @param winStr
|
*/
|
private void AnalysisWin(DeviceSer ser,Integer[] winStr){
|
if(winStr == null || winStr.length == 0)return;
|
for (int i=1;i<= winStr.length;i++) {
|
BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(),i, getWinStatus(winStr[i-1]));
|
}
|
}
|
/**
|
* 解析风机状态
|
* @param ser
|
* @param fanStr
|
*/
|
private void AnalysisFan(DeviceSer ser,Integer[] fanStr){
|
if(fanStr == null || fanStr.length == 0)return;
|
for (int i=1;i<= fanStr.length;i++) {
|
BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(),i+20, getFanStatus(fanStr[i-1]));
|
}
|
}
|
/**
|
* 解析空调状态
|
* @param ser
|
* @param airStr
|
*/
|
private void AnalysisAir(DeviceSer ser,Integer[] airStr){
|
if(airStr == null || airStr.length == 0)return;
|
Integer s= 0;
|
for (int i=1;i<= airStr.length;i++) {
|
List<Device> devices = deviceService.getCacheDeviceBySerId(ser.getCompanyId(),ser.getId());
|
// 调整缓存
|
if (null == devices || devices.isEmpty())
|
return;
|
// 更新缓存
|
Device temp;
|
s = airStr[i-1];
|
for (int j = 0; j < devices.size(); j++) {
|
if(i == (devices.get(j).getPassCode() - 40)){
|
// 4608 -12 00
|
String hexStr = BytesUtil.intToHexStr(s);
|
for (int k =0;k<4;k++){
|
if(hexStr.length() < 16){
|
hexStr = "0" + hexStr;
|
}
|
}
|
// 12
|
String l = hexStr.substring(4,6);
|
//00
|
String h = hexStr.substring(6,8);
|
String hb = BytesUtil.toBinary8String(BytesUtil.hexToInt(h));
|
//00000000 0000 0 000
|
Integer status = Integer.parseInt(hb.substring(4,5));
|
Integer t = BytesUtil.hexToInt(l);
|
BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(), devices.get(j).getId(), getLightStatus(status));
|
TempParam param = new TempParam();
|
param.setId( devices.get(j).getId());
|
param.setTargetTemp(t+"");
|
param.setTargetStatus(getLightStatus(status));
|
param.setTargetModel("01");
|
List<ExeDevice> exeDeviceList = new ArrayList<>();
|
ExeDevice dev = new ExeDevice();
|
dev.setSerId(ser.getId());
|
exeDeviceList.add(dev);
|
param.setDeviceList(exeDeviceList);
|
param.setCompanyId(ser.getCompanyId());
|
deviceService.updateTempControlInfo(param);
|
|
log.info("空调状态解析完成："+param.toString());
|
//BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(),i+40, getWinStatus(airStr[i]));
|
|
}
|
}
|
}
|
}
|
/**
|
* 解析照明状态
|
* @param ser
|
* @param lightStr
|
*/
|
private void AnalysisLight(DeviceSer ser,Integer[] lightStr){
|
if(lightStr == null || lightStr.length == 0)return;
|
for (int i=1;i<= lightStr.length;i++) {
|
BhznVerbServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(),i+60, getLightStatus(lightStr[i-1]));
|
}
|
}
|
|
private String getWinStatus(Integer s){
|
if(s == null)return DeviceStatus.ZERO.getCode();
|
String hexStr = BytesUtil.intToHexStr(s);
|
for (int i =0;i<4;i++){
|
if(hexStr.length() < 4){
|
hexStr = "0" + hexStr;
|
}
|
}
|
String h = hexStr.substring(0,2);
|
String l = hexStr.substring(2,4);
|
h = BytesUtil.toBinary8String(BytesUtil.hexToInt(h));
|
int kaidu = (BytesUtil.hexToInt(l));
|
String temp = h.substring(6,8);
|
if("00".equals(temp ) && kaidu == 100){
|
return DeviceStatus.OPEN.getCode();
|
}
|
if("00".equals(temp ) && kaidu == 0){
|
return DeviceStatus.CLOSE.getCode();
|
}
|
if("01".equals(temp )){
|
return DeviceStatus.OPEN.getCode();
|
}
|
if("10".equals(temp )){
|
return DeviceStatus.CLOSE.getCode();
|
}
|
|
return DeviceStatus.ZERO.getCode();
|
}
|
private String getFanStatus(Integer s){
|
if(0 == s){
|
return DeviceStatus.CLOSE.getCode();
|
}
|
if(1 == s){
|
return DeviceStatus.OPEN.getCode();
|
}
|
return DeviceStatus.ZERO.getCode();
|
}
|
|
private String getLightStatus(Integer s){
|
if(0 == s){
|
return DeviceStatus.CLOSE.getCode();
|
}
|
if(1 == s){
|
return DeviceStatus.OPEN.getCode();
|
}
|
return DeviceStatus.ZERO.getCode();
|
}
|
|
}
|
