fix:删除无用Netty Handler

smsb-modules/smsb-netty/src/main/java/com/inspur/netty/handler/DeviceRunInfoHandler.java

@@ -1,50 +0,0 @@
-package com.inspur.netty.handler;
-
-import com.inspur.device.domain.SmsbDeviceRunInfo;
-import com.inspur.device.domain.vo.SmsbDeviceVo;
-import com.inspur.device.mapper.SmsbDeviceRunInfoMapper;
-import com.inspur.device.service.ISmsbDeviceService;
-import com.inspur.device.service.impl.SmsbDeviceServiceImpl;
-import com.inspur.netty.message.receive.ReceiveMessageType;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
-import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.utils.SpringUtils;
-
-/**
- * 设备运行信息处理器
- *
- * @author lihao16
- */
-@Slf4j
-public class DeviceRunInfoHandler extends ChannelInboundHandlerAdapter {
-
-    private static final SmsbDeviceRunInfoMapper smsbDeviceRunInfoMapper = SpringUtils.getBean(SmsbDeviceRunInfoMapper.class);
-
-    private static final ISmsbDeviceService smsbDeviceService = SpringUtils.getBean(SmsbDeviceServiceImpl.class);
-
-    @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        String message = (String) msg;
-
-        if (message.contains(ReceiveMessageType.DEVICE_RUN_INFO.getValue())) {
-            log.info("DeviceRunInfoHandler : receive device run info message :{}", message);
-            String[] messageArray = message.split("/");
-            String identifier = messageArray[0];
-            SmsbDeviceVo smsbDeviceVo = smsbDeviceService.getDeviceByIdentifier(identifier);
-            if (null == smsbDeviceVo) {
-                return;
-            }
-            SmsbDeviceRunInfo smsbDeviceRunInfo = new SmsbDeviceRunInfo();
-            buildSmsbDeviceRunInfo(smsbDeviceRunInfo, messageArray, smsbDeviceVo);
-            smsbDeviceRunInfoMapper.insert(smsbDeviceRunInfo);
-        } else {
-            ctx.fireChannelRead(message);
-        }
-    }
-
-    private void buildSmsbDeviceRunInfo(SmsbDeviceRunInfo smsbDeviceRunInfo, String[] messageArray, SmsbDeviceVo smsbDeviceVo) {
-
-    }
-
-}

smsb-modules/smsb-netty/src/main/java/com/inspur/netty/handler/OTACheckReplayHandler.java

@@ -1,46 +0,0 @@
-package com.inspur.netty.handler;
-
-import com.inspur.device.domain.SmsbOtaRecord;
-import com.inspur.device.mapper.SmsbOtaRecordMapper;
-import com.inspur.netty.message.receive.ReceiveMessageType;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
-import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.utils.SpringUtils;
-
-/**
- * 设备OTA check replay handler
- *
- * @author lihao16
- */
-@Slf4j
-public class OTACheckReplayHandler extends ChannelInboundHandlerAdapter {
-
-    private static final SmsbOtaRecordMapper smsbOtaRecordMapper = SpringUtils.getBean(SmsbOtaRecordMapper.class);
-
-
-    @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        String message = (String) msg;
-        // 处理/ota/check/replay消息
-        if (message.contains(ReceiveMessageType.DEVICE_CHECK_OTA_REPLAY.getValue())) {
-            log.info("OTACheckReplayHandler : receive OTA check replay message :{}", message);
-            Long recordId = Long.valueOf(message.split("/")[4]);
-            Integer status = Integer.parseInt(message.split("/")[5]);
-            updateOTARecordStatus(recordId, status);
-            /*String heartbeatReplay = identifier + PushMessageType.CONTENT_DOWNLOAD_STATUS_REPLAY.getValue();
-            ByteBuf byteBuf = Unpooled.copiedBuffer(heartbeatReplay + NettyConstants.DATA_PACK_SEPARATOR, Charset.forName("utf-8"));
-            ctx.channel().writeAndFlush(byteBuf);*/
-
-        } else {
-            ctx.fireChannelRead(message);
-        }
-    }
-
-    private void updateOTARecordStatus(Long recordId, Integer status) {
-        SmsbOtaRecord smsbOtaRecord = new SmsbOtaRecord();
-        smsbOtaRecord.setId(recordId);
-        smsbOtaRecord.setOtaStatus(status);
-        smsbOtaRecordMapper.updateById(smsbOtaRecord);
-    }
-}