package com.fzzy.protocol.fzzy.analysis;
|
|
import com.fzzy.api.Constant;
|
import com.fzzy.api.data.ApiCommonDevice;
|
import com.fzzy.gateway.GatewayUtils;
|
import com.fzzy.gateway.entity.GatewayDevice;
|
import com.fzzy.gateway.service.GatewayDeviceService;
|
import com.fzzy.protocol.fzzy.builder.ObjectCommandBuilder;
|
import com.fzzy.protocol.fzzy.builder.SimpleCommandBuilder;
|
import com.fzzy.protocol.fzzy.cmd.BaseRemoteImpl;
|
import com.fzzy.protocol.fzzy.data.ReMessage;
|
import com.fzzy.protocol.fzzy.data.SendMessage;
|
import com.fzzy.protocol.fzzy.resp.Response1001;
|
import com.fzzy.protocol.fzzy.server.ServerUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
|
/**
|
* 系统类协议解析
|
*/
|
@Slf4j
|
@Component(AnalysisSystem.BEAN_ID)
|
public class AnalysisSystem extends BaseRemoteImpl {
|
|
public static final String BEAN_ID = "fzzy.analysisSystem";
|
|
|
@Resource
|
private GatewayDeviceService gatewayDeviceService;
|
|
|
public void analysis1001(ReMessage reMessage) {
|
|
//获取到登陆信息，执行设备信息整理
|
ApiCommonDevice device = Constant.getCommonDeviceCache(reMessage.getSn());
|
if (null == device) {
|
device = new ApiCommonDevice();
|
}
|
device.setIp(reMessage.getIp());
|
device.setPort(reMessage.getPort());
|
device.setSn(reMessage.getSn());
|
device.setId(reMessage.getIedId());
|
device.setOnlineTime(new Date());
|
device.setCode("SUCCESS");
|
Constant.updateCache(device);
|
|
//更新设备在线
|
gatewayDeviceService.onlineByCommonDevice(device);
|
|
|
//返回当前系统时间
|
Response1001 response = new Response1001();
|
response.setTime(DateFormatUtils.format(new Date(), "yyyyMMddHHmmss"));
|
|
ObjectCommandBuilder commandBuilder = ObjectCommandBuilder.getInstance();
|
SendMessage message = commandBuilder.buildMessage(reMessage, ServerUtils.FUNCTION_1001, response);
|
send(message);
|
|
log.info("控制柜----->>>平台，控制柜登陆解析完成-报文-{}", reMessage);
|
}
|
|
public void analysis1003(ReMessage reMessage, ApiCommonDevice ser) {
|
}
|
|
public void analysis1004(ReMessage reMessage, ApiCommonDevice ser) {
|
}
|
|
public void analysis1005(ReMessage reMessage, ApiCommonDevice ser) {
|
//直接返回
|
SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
|
SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_1005);
|
send(message);
|
}
|
|
public void analysis1006(ReMessage reMessage, ApiCommonDevice ser) {
|
|
//TODO
|
}
|
|
public void analysis1007(ReMessage reMessage, ApiCommonDevice ser) {
|
|
log.info("控制柜----->>>平台：控制柜仓库状态信息同步完成-控制柜={}", ser.getIp());
|
}
|
|
public void analysis1008(ReMessage message, ApiCommonDevice ser) {
|
|
}
|
|
public void analysis1009(ReMessage message, ApiCommonDevice ser) {
|
|
}
|
|
public void analysis1010(ReMessage reMessage, ApiCommonDevice ser) {
|
log.info("控制柜----->>>平台：控制柜仓库配置信息同步完成-控制柜={}", ser.getIp());
|
}
|
}
|
