package org.springblade.modules.nettyServer;
|
|
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.Channel;
|
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelId;
|
import io.netty.channel.ChannelInboundHandlerAdapter;
|
import io.netty.channel.group.ChannelGroup;
|
import io.netty.channel.group.ChannelMatcher;
|
import io.netty.channel.group.DefaultChannelGroup;
|
import io.netty.util.CharsetUtil;
|
import io.netty.util.concurrent.GlobalEventExecutor;
|
import org.springblade.modules.Netty.entitly.Netty;
|
import org.springblade.modules.Netty.service.nettyService;
|
import org.springblade.modules.alarm.entity.Alarm;
|
import org.springblade.modules.alarm.service.IAlarmService;
|
import org.springblade.modules.alarm.vo.AlarmVO;
|
import org.springblade.modules.catalog.service.catalogService;
|
import org.springblade.modules.equipment.entity.Equipment;
|
import org.springblade.modules.equipment.service.IEquipmentService;
|
import org.springblade.modules.equipment.vo.EquipmentVOS;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.bind.annotation.PostMapping;
|
|
import javax.annotation.PostConstruct;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.regex.Pattern;
|
|
@Component
|
public class ServerHandler extends ChannelInboundHandlerAdapter {
|
|
private String reg_LA ="LA[d]{8}[d|A-F]{12}[d|A-F]{8}[d|A-Z]{2}[d|A-F]{4}[x2A][d|A-F]{6}[#@]";
|
private String reg_LB = "LB[\\d|A-F]{12}[\\x2A].*[#@]";
|
private String reg_LB2 = "LB[\\d|A-F]{6}[\\x2A].*[#@]";
|
private String reg_LD = "LD[d]{8}[d|A-F]{12}:[A-Z]{4}[\\x2A].*[#@]";
|
|
|
private ConcurrentHashMap<String, Channel> sessionChannelMap = new ConcurrentHashMap<String, Channel>();
|
|
@Autowired
|
private catalogService catalogService;
|
|
@Autowired
|
private nettyService nettyService;
|
|
@Autowired
|
private IEquipmentService equipmentService;
|
|
@Autowired
|
private IAlarmService alarmService;
|
|
private static ServerHandler serverHandler;
|
|
@PostConstruct
|
public void init() {
|
serverHandler = this;
|
}
|
/**
|
* 客户端与服务端创建连接的时候调用
|
*/
|
@Override
|
public void channelActive(ChannelHandlerContext ctx) throws Exception {
|
System.out.println("CTX:"+ctx.channel());
|
System.out.println("客户端与服务端连接开始...");
|
// ChannelId id = ctx.channel().id();
|
// String s = id.toString();
|
//NettyConfig.group.add(ctx.channel());
|
}
|
|
/**
|
* 客户端与服务端断开连接时调用
|
*/
|
@Override
|
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
|
System.out.println("客户端与服务端连接关闭...");
|
NettyConfig.group.remove(ctx.channel());
|
}
|
|
/**
|
* 服务端接收客户端发送过来的数据结束之后调用
|
*/
|
@Override
|
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
|
ctx.flush();
|
System.out.println("信息接收完毕...");
|
}
|
|
/**
|
* 工程出现异常的时候调用
|
*/
|
@Override
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
|
cause.printStackTrace();
|
ctx.close();
|
}
|
|
/**
|
* 服务端处理客户端websocket请求的核心方法，这里接收了客户端发来的信息
|
*/
|
@Override
|
public void channelRead(ChannelHandlerContext channelHandlerContext, Object info) throws Exception {
|
System.out.println("接收到了："+info);
|
ByteBuf buf = (ByteBuf) info;
|
byte[] req = new byte[buf.readableBytes()];
|
buf.readBytes(req);
|
String body = new String(req, "UTF-8");
|
String content = body;
|
System.out.println("接收客户端数据:" + body);
|
String ChannelName = content.substring(10, 22);//设备编码
|
String sub = content.substring(23, 27);
|
ConcurrentHashMap<String, Channel> channelHashMap = ChannelMap.getChannelHashMap();
|
if (channelHashMap==null){
|
if (!sub.equals("VIMO")){
|
// 保存当前连接
|
ChannelMap.addChannel(ChannelName,channelHandlerContext.channel());
|
}
|
}
|
else {
|
Channel channel = ChannelMap.getChannelByName(ChannelName);
|
if (channel!=channelHandlerContext.channel()|| channel==null){
|
if (!sub.equals("VIMO")){
|
// 保存当前连接
|
ChannelMap.addChannel(ChannelName,channelHandlerContext.channel());
|
}
|
}
|
}
|
|
List<String> outData = new ArrayList<>();
|
switch (content.substring(0, 2))
|
{
|
case "LA":
|
{
|
String devId = content.substring(10, 22);
|
String fqbm = content.substring(24, 26);
|
List<Map<String, Object>> list = serverHandler.equipmentService.selectInfos(devId);
|
Alarm alarm= new Alarm();
|
alarm.setAlarmType("一键报警");
|
Date day = new Date();
|
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
alarm.setAlarmTime(df.format(day));
|
alarm.setPlace((String) list.get(0).get("streeName"));//事发地址
|
alarm.setDeviceNumber((String) list.get(0).get("deviceNumber"));//设备编号
|
alarm.setAddvcd((String) list.get(0).get("addvcd"));//行政区编码
|
alarm.setJd((String) list.get(0).get("jd"));//经度
|
alarm.setWd((String) list.get(0).get("wd"));//纬度
|
alarm.setJtype("0");
|
if (fqbm.equals("00")){
|
alarm.setWaringType("旁路");
|
}
|
else if(fqbm.equals("01")){
|
alarm.setWaringType("火警");
|
}
|
else if(fqbm.equals("02")){
|
alarm.setWaringType("挟持");
|
}
|
else if(fqbm.equals("03")){
|
alarm.setWaringType("紧急");
|
}
|
else if(fqbm.equals("04")){
|
alarm.setWaringType("救护");
|
}
|
else if(fqbm.equals("05")){
|
alarm.setWaringType("内部");
|
}
|
else if(fqbm.equals("06")){
|
alarm.setWaringType("出入");
|
}
|
else if(fqbm.equals("07")){
|
alarm.setWaringType("周边");
|
}
|
else {
|
alarm.setWaringType("防拆");
|
}
|
serverHandler.alarmService.s(alarm);
|
outData.add("LEOK#@");
|
|
break;
|
}
|
case "LD":
|
{
|
// if (Pattern.matches(content, reg_LD))
|
String deviceNumber = content.substring(10, 22);
|
String keyword = content.substring(23, 27);
|
System.out.println(keyword);
|
switch(keyword)
|
{
|
case "IMEI":
|
{
|
Date d = new Date();
|
SimpleDateFormat sbf = new SimpleDateFormat("MMddHHmm");
|
outData.add("LC8C0470" + sbf.format(d) + "#@" + "LEOK#@");
|
outData.add("LEOK#@");
|
break;
|
}
|
case "SRTC":
|
{
|
Date d = new Date();
|
SimpleDateFormat sbf = new SimpleDateFormat("yyyyMMddHHmmss");
|
outData.add("LEOK#@");
|
outData.add("LC8C0700" + sbf.format(d) + "#@");
|
break;
|
}
|
case "STAS":
|
{
|
outData.add("LEOK#@");
|
outData.add("LC8100001E"+ "#@");
|
break;
|
}
|
case "TEST":
|
{
|
Date d = new Date();
|
SimpleDateFormat sbf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String format = sbf.format(d);
|
serverHandler.equipmentService.updateChannel(format,deviceNumber);
|
outData.add("LEOK#@");
|
outData.add("LEON#@");
|
break;
|
}
|
case "COMM":
|
{
|
outData.add("LEOK#@");
|
break;
|
}
|
default:
|
{
|
outData.add("LEOK#@");
|
break;
|
}
|
}
|
|
break;
|
}
|
case "LB":
|
{
|
outData.add("LEOK#@");
|
break;
|
}
|
}
|
if(outData.size() == 0)
|
{
|
outData.add("LERR#@");
|
}
|
for (int i = 0; i < outData.size(); i++)
|
{
|
channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer(outData.get(i), CharsetUtil.UTF_8));
|
}
|
|
|
// channelHandlerContext.writeAndFlush(Unpooled.copiedBuffer("LEOK#@!", CharsetUtil.UTF_8));
|
//服务端使用这个就能向 每个连接上来的客户端群发消息
|
//NettyConfig.group.writeAndFlush(info);
|
// Iterator<Channel> iterator = NettyConfig.group.iterator();
|
// System.out.println("iterator:"+iterator);
|
// while(iterator.hasNext()){
|
// //打印出所有客户端的远程地址
|
// System.out.println((iterator.next()).remoteAddress());
|
//
|
// }
|
}
|
|
|
}
|
