package com.ld.igds.weather;
|
|
import com.ld.igds.models.WeatherInfo;
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.SpringUtil;
|
import com.ld.igds.utils.CRC16Util;
|
import com.ld.io.api.IoMsgConsumer;
|
import com.ld.io.api.IoSession;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
|
/**
|
* @Desc: 收到终端请求信息
|
* @author: Andy
|
* @update-time: 2023/4/23
|
*/
|
@Slf4j
|
public class MsgConsumer implements IoMsgConsumer {
|
|
private CoreWeatherService coreWeatherService;
|
|
@Override
|
public void consume(IoSession session, byte[] bytes) {
|
|
String strMsg = BytesUtil.bytesToString(bytes) + ServerUtils.MSG_END;
|
|
// 二次调整报文
|
if (!strMsg.startsWith(ServerUtils.MSG_START)) {
|
strMsg = strMsg.substring(strMsg.indexOf(ServerUtils.MSG_START));
|
}
|
|
String defaultCompanyId = ContextUtil.getDefaultCompanyId();
|
|
|
if (null == coreWeatherService) {
|
coreWeatherService = SpringUtil.getBean(CoreWeatherService.class);
|
}
|
|
WeatherInfo weatherInfo = coreWeatherService.getCacheWeather(defaultCompanyId);
|
|
|
String returnMsg = this.builderMsg(weatherInfo);
|
if(null == weatherInfo){
|
log.info("-------------返回气象信息----{}:{}={}", session.getAddress(), session.getPort(), returnMsg);
|
}else{
|
log.info("-------------返回气象信息---气象时间={}---{}:{}={}",weatherInfo.getUpdateTime(), session.getAddress(), session.getPort(), returnMsg);
|
}
|
|
|
|
WeatherServerEngine.push(session, BytesUtil.hexStrToBytes(returnMsg));
|
}
|
|
private String builderMsg(WeatherInfo weatherInfo) {
|
StringBuffer sb = new StringBuffer(ServerUtils.MSG_START);
|
|
//气象地址
|
int val = 1;
|
sb.append(BytesUtil.intToHexStr1(val));
|
|
//功能码
|
val = 2;
|
sb.append(BytesUtil.intToHexStr1(val));
|
|
|
if (null == weatherInfo) {
|
val = 0;
|
//长度信息 = 0
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//校验
|
val = calcCrc16(sb.toString());
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//结尾
|
sb.append(ServerUtils.MSG_END);
|
return sb.toString();
|
}
|
|
|
//长度 =10
|
val = 10;
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//温度
|
val = getInfo(weatherInfo, "WD");
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//湿度
|
val = getInfo(weatherInfo, "SD");
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//风向
|
val = getInfo(weatherInfo, "FX");
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//风力
|
val = getInfo(weatherInfo, "FL");
|
sb.append(BytesUtil.intToHexStr(val));
|
|
//天气
|
val = getInfo(weatherInfo, "TQ");
|
sb.append(BytesUtil.intToHexStr(val));
|
|
|
//校验
|
val = calcCrc16(sb.toString());
|
sb.append(BytesUtil.intToHexStr(val));
|
|
|
sb.append(ServerUtils.MSG_END);
|
return sb.toString();
|
}
|
|
private int getInfo(WeatherInfo weatherInfo, String tag) {
|
int val = -100;
|
String info = null;
|
try {
|
if ("WD".equals(tag)) {
|
info = weatherInfo.getTemp();
|
if (StringUtils.isNotEmpty(info)) {
|
info = info.replace("℃", "");
|
val = Integer.valueOf(info);
|
}
|
}
|
|
if ("SD".equals(tag)) {
|
info = weatherInfo.getHumidity();
|
if (StringUtils.isNotEmpty(info)) {
|
info = info.replace("%", "");
|
val = Integer.valueOf(info);
|
}
|
}
|
|
if ("FX".equals(tag)) {
|
val = 0;
|
info = weatherInfo.getWindDirection();
|
if (StringUtils.isNotEmpty(info)) {
|
if ("静风".equals(info)) return 0;
|
if ("北风".equals(info)) return 1;
|
if ("东北风".equals(info)) return 2;
|
if ("东风".equals(info)) return 3;
|
if ("东南风".equals(info)) return 4;
|
if ("南风".equals(info)) return 5;
|
if ("西南风".equals(info)) return 6;
|
if ("西风".equals(info)) return 7;
|
if ("西北风".equals(info)) return 8;
|
}
|
}
|
|
if ("FL".equals(tag)) {
|
val = 0;
|
info = weatherInfo.getWindSpeed();
|
if (StringUtils.isNotEmpty(info)) {
|
info = info.replace("级", "");
|
val = Integer.valueOf(info);
|
}
|
}
|
|
if ("TQ".equals(tag)) {
|
val = 0;
|
info = weatherInfo.getWeather();
|
if (StringUtils.isNotEmpty(info)) {
|
if (info.indexOf("阴") >= 0) return 1;
|
if (info.indexOf("雷雨") >= 0) return 7;
|
if (info.indexOf("雨") >= 0) return 2;
|
if (info.indexOf("多云") >= 0) return 3;
|
if (info.indexOf("冰雹") >= 0) return 4;
|
if (info.indexOf("雾") >= 0) return 5;
|
if (info.indexOf("沙") >= 0) return 6;
|
if (info.indexOf("雪") >= 0) return 8;
|
}
|
}
|
|
} catch (Exception e) {
|
log.error("----------气象信息转换异常-------{}-----{}", tag, e.getMessage());
|
return val;
|
}
|
return val;
|
}
|
|
|
public int calcCrc16(String hexStr) {
|
return CRC16Util.calcCrc16(BytesUtil.hexStrToBytes(hexStr));
|
}
|
|
}
|
