package com.fzzy.protocol;
|
|
|
import com.fzzy.gateway.data.BaseReqData;
|
import com.fzzy.protocol.data.THDto;
|
import io.netty.channel.Channel;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 协议解析全局常量
|
*/
|
public class ProtocolUtils {
|
|
|
|
|
|
/**
|
* 请求缓存 key = deviceId,value = requData
|
*/
|
private static Map<String, BaseReqData> contextSyncReqMap = new HashMap<>();
|
|
/**
|
* 请求缓存 key = deviceId,value = thDto
|
*/
|
private static Map<String, THDto> contextThMap = new HashMap<>();
|
|
|
//-粮温备用点
|
public static final double ERROR_TEMP = -100;
|
//-粮温故障点
|
public static final double FAULT_TEMP = -101;
|
//-粮温补偿点-针对锥形仓补点使用
|
public static final double ADD_TEMP = -102;
|
|
|
/**
|
* 将执行命令信息存放在缓存
|
*
|
* @param depotId 仓库编码
|
* @param reqData 请求参数信息
|
*/
|
public static void addSyncReq2Map(String depotId, BaseReqData reqData) {
|
contextSyncReqMap.put(depotId, reqData);
|
}
|
|
public static BaseReqData getSyncReq(String depotId) {
|
return contextSyncReqMap.get(depotId);
|
}
|
|
public static void addTh2Map(String deviceId, THDto thDto) {
|
contextThMap.put(deviceId, thDto);
|
}
|
|
public static THDto getCacheTh(String deviceId) {
|
return contextThMap.get(deviceId);
|
}
|
|
}
|
