package com.ld.igds.protocol.fzzy.analysis;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.common.CoreDeviceService;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.protocol.fzzy.ServerUtils;
|
import com.ld.igds.protocol.fzzy.command.BaseRemoteImpl;
|
import com.ld.igds.protocol.fzzy.dto.ReMessage;
|
import com.ld.igds.protocol.fzzy.resp.Response3102;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
/**
|
* 设备操作类
|
*/
|
@Slf4j
|
@Component(AnalysisDevice.BEAN_ID)
|
public class AnalysisDevice extends BaseRemoteImpl {
|
|
public static final String BEAN_ID = "fzzy.analysisDevice";
|
|
@Autowired
|
private CoreDeviceService deviceService;
|
@Autowired
|
private NotifyWebInvoker notifyInvoker;
|
|
|
public void analysis3101(ReMessage reMessage, DeviceSer ser) {
|
log.debug("-DO NOTHING-");
|
//DO NOTHING
|
}
|
|
/**
|
* 设备状态
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis3102(ReMessage reMessage, DeviceSer ser) {
|
|
List<Response3102> responseList = JSONObject.parseArray(reMessage.getContent(), Response3102.class);
|
|
|
if(null == responseList || responseList.isEmpty()){
|
log.error("控制柜----->>>>平台：解析返回出现问题，没有返回设备列表");
|
return;
|
}
|
|
String status;
|
for (Response3102 resp : responseList) {
|
status = ServerUtils.analysisDeviceStatus(resp.getDeviceId(), resp.getStatus());
|
log.info("解析控制柜返回设备状态-解析后---{}--{}---{}--{}", ser.getCompanyId(), ser.getId(), resp.getDeviceId(), status);
|
ServerUtils.add2StatusMap(ser.getCompanyId(), ser.getId(), resp.getDeviceId(), status);
|
}
|
deviceService.updateStatus(ser.getCompanyId(), ser.getId(), ServerUtils.getStatusMap());
|
|
notifyInvoker.notifyAnalysisStatusSuccess(ser.getCompanyId(), ser.getId(), OrderRespEnum.MSG_SUCCESS, "设备状态查询成功并完成解析！");
|
}
|
|
public void analysis3103(ReMessage message, DeviceSer ser) {
|
//DO NOTHING
|
}
|
|
public void analysis3201(ReMessage message, DeviceSer ser) {
|
//DO NOTHING
|
}
|
|
|
}
|
