微调
This commit is contained in:
@@ -150,16 +150,23 @@ public class SocketFreqConverterService {
|
|||||||
public void handleRead(String converterChannelTag, String msg) {
|
public void handleRead(String converterChannelTag, String msg) {
|
||||||
FreqConverterRespDTO respDTO = JSON.parseObject(msg, FreqConverterRespDTO.class);
|
FreqConverterRespDTO respDTO = JSON.parseObject(msg, FreqConverterRespDTO.class);
|
||||||
|
|
||||||
switch (FormalTestManager.freqConverterStep) {
|
if (respDTO.getCode() != 0) {
|
||||||
case CMD_INIT_SERIAL:
|
SocketDataMsg socketDataMsg = new SocketDataMsg();
|
||||||
handleInitSerial(converterChannelTag, respDTO);
|
socketDataMsg.setRequestId(FormalTestManager.freqConverterStep.getValue());
|
||||||
break;
|
socketDataMsg.setCode(respDTO.getCode());
|
||||||
case CMD_GET_DEVICE_STATUS:
|
WebServiceManager.sendMsg(this.userId, JSON.toJSONString(socketDataMsg));
|
||||||
handleGetDeviceStatus(converterChannelTag, respDTO);
|
} else {
|
||||||
break;
|
switch (FormalTestManager.freqConverterStep) {
|
||||||
case CMD_CLOSE_SERIAL:
|
case CMD_INIT_SERIAL:
|
||||||
handleCloseSerial(converterChannelTag, respDTO);
|
handleInitSerial(converterChannelTag, respDTO);
|
||||||
break;
|
break;
|
||||||
|
case CMD_GET_DEVICE_STATUS:
|
||||||
|
handleGetDeviceStatus(converterChannelTag, respDTO);
|
||||||
|
break;
|
||||||
|
case CMD_CLOSE_SERIAL:
|
||||||
|
handleCloseSerial(converterChannelTag, respDTO);
|
||||||
|
break;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -266,6 +273,7 @@ public class SocketFreqConverterService {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* 如果变频器已停止,则清除共享的运行时状态
|
* 如果变频器已停止,则清除共享的运行时状态
|
||||||
|
*
|
||||||
* @param currentUserId 当前用户ID
|
* @param currentUserId 当前用户ID
|
||||||
*/
|
*/
|
||||||
private void clearStateIfStopped(String currentUserId) {
|
private void clearStateIfStopped(String currentUserId) {
|
||||||
|
|||||||
Reference in New Issue
Block a user