新增sick扫码枪

web/src/main/java/com/zhehekeji/web/config/ConfigProperties.java

@@ -33,6 +33,8 @@ public class ConfigProperties {
 
     private LightSource lightSource;
 
+    private Sensor sensor;
+
 
     @Data
     public static class CameraConfig{
@@ -70,4 +72,9 @@ public class ConfigProperties {
         private Integer type;
         private String info;
     }
+
+    @Data
+    public static class Sensor{
+        private Integer type;
+    }
 }

web/src/main/java/com/zhehekeji/web/controller/SensorController.java

@@ -0,0 +1,31 @@
+package com.zhehekeji.web.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.zhehekeji.common.util.HttpUtil;
+import com.zhehekeji.core.pojo.Result;
+import com.zhehekeji.core.util.Assert;
+import com.zhehekeji.web.pojo.IndexVO;
+import com.zhehekeji.web.service.sick.SickConnMap;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+
+@Api( tags = "传感器")
+@RequestMapping(value = "/sensor")
+@RestController()
+@Slf4j
+public class SensorController {
+
+    @GetMapping("/start")
+    @ApiOperation(value = "sick扫码枪开始扫")
+    public Result userCenter() {
+        SickConnMap.write(1);
+        return Result.success();
+    }
+}

web/src/main/java/com/zhehekeji/web/entity/SensorGun.java

@@ -0,0 +1,20 @@
+package com.zhehekeji.web.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+
+@Data
+public class SensorGun {
+
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    private Integer streetId;
+
+    private Integer direction;
+
+    private String ip;
+
+    private Integer port;
+}

web/src/main/java/com/zhehekeji/web/mapper/SensorGunMapper.java

@@ -0,0 +1,7 @@
+package com.zhehekeji.web.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zhehekeji.web.entity.SensorGun;
+
+public interface SensorGunMapper extends BaseMapper<SensorGun> {
+}

web/src/main/java/com/zhehekeji/web/service/InitService.java

@@ -10,9 +10,11 @@ import com.zhehekeji.web.lib.joyware.JoywareCameraControlModuleImpl;
 import com.zhehekeji.web.lib.joyware.JoywareLoginModuleImpl;
 import com.zhehekeji.web.lib.joyware.NetSDKLib;
 import com.zhehekeji.web.mapper.CameraMapper;
+import com.zhehekeji.web.mapper.SensorGunMapper;
 import com.zhehekeji.web.mapper.StreetMapper;
 import com.zhehekeji.web.service.ksec.KsecNettyClient;
 import com.zhehekeji.web.service.robotic.NettyClient;
+import com.zhehekeji.web.service.sick.SickNettyClient;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
@@ -107,7 +109,6 @@ public class InitService implements ApplicationRunner {
             }
         }
         TaskDelayExecutor.runMp4DownloadExecutor();
-
     }
 
     class loginThread extends Thread{

web/src/main/java/com/zhehekeji/web/service/sick/SickClientHandler.java

@@ -0,0 +1,47 @@
+package com.zhehekeji.web.service.sick;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ *    与PLC心跳 处理
+ *
+ * @author Administrator
+ *
+ */
+@Slf4j
+public class SickClientHandler extends ChannelInboundHandlerAdapter {
+
+    private SickNettyClient nettyClient;
+
+    private Integer sensorId;
+
+    public SickClientHandler(Integer sensorId, SickNettyClient nettyClient){
+
+        this.nettyClient = nettyClient;
+        this.sensorId = sensorId;
+    }
+
+    /**
+     * 建立连接时
+     */
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        log.info("sensorId:{}连接成功",sensorId);
+        SickConnMap.conn(sensorId,ctx);
+        ctx.fireChannelActive();
+    }
+
+    /**
+     * 关闭连接时
+     */
+    @Override
+    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+        log.info("sensorId:{} closed",sensorId);
+        SickConnMap.disConn(sensorId);
+        log.info(" streetId reconnect......");
+        //nettyClient.reconnect(sensorId);
+    }
+
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickConnMap.java

@@ -0,0 +1,45 @@
+package com.zhehekeji.web.service.sick;
+
+import io.netty.channel.ChannelHandlerContext;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+public class SickConnMap {
+
+    private static Map<Integer, ChannelHandlerContext> connChanel = new HashMap<>();
+
+
+
+    public static void conn(Integer id,ChannelHandlerContext channel){
+        connChanel.put(id,channel);
+    }
+
+    public static void disConn(Integer id){
+        connChanel.remove(id);
+    }
+
+    public static ChannelHandlerContext getChannel(Integer id){
+        return connChanel.get(id);
+    }
+
+    /**
+     * 向sick发送开始扫码指令
+     *  return 是否发送成功
+     * @param sensorId
+     */
+    public static Boolean write(Integer sensorId){
+        if(connChanel.get(sensorId) != null){
+            try {
+                connChanel.get(sensorId).channel().writeAndFlush("start");
+                return true;
+            }catch (Exception e){
+                log.error(""+e);
+            }
+        }
+        return false;
+    }
+
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickDecoder.java

@@ -0,0 +1,65 @@
+package com.zhehekeji.web.service.sick;
+
+import com.zhehekeji.web.service.PlcService;
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.LineBasedFrameDecoder;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.nio.charset.StandardCharsets;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+
+@Slf4j
+public class SickDecoder extends LineBasedFrameDecoder {
+
+    private static final Logger tcpLogger = LoggerFactory.getLogger("sick");
+
+    private static Map<Integer,String> OCRMap = new ConcurrentHashMap<>();
+
+    private PlcService plcService;
+    private Integer sensorId;
+
+    public SickDecoder(PlcService plcService,Integer sensorId) {
+        super(1000);
+        this.plcService = plcService;
+        this.sensorId = sensorId;
+    }
+
+    /**
+     * 解析TCP数据包
+     *
+     * @param ctx
+     * @param in
+     * @return
+     * @throws Exception
+     */
+    @Override
+    protected Object decode(ChannelHandlerContext ctx, ByteBuf in) throws Exception {
+        in = (ByteBuf) super.decode(ctx, in);
+        if (in == null) {
+            return null;
+        }
+
+        String code = in.toString(StandardCharsets.UTF_8);
+        code = code.replace("\\n","");
+        if(!code.equals("NoRead")){
+            System.out.println(code);
+            OCRMap.put(sensorId,code);
+            //todo 更改stock
+        }else {
+            log.warn("no read");
+            OCRMap.put(sensorId,null);
+        }
+
+        in.release();
+        ctx.channel().close();
+        return null;
+    }
+
+
+
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickEncoder.java

@@ -0,0 +1,20 @@
+package com.zhehekeji.web.service.sick;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.MessageToByteEncoder;
+
+import java.nio.charset.StandardCharsets;
+
+public class SickEncoder extends MessageToByteEncoder<String> {
+
+    @Override
+    protected void encode(ChannelHandlerContext ctx, String msg, ByteBuf out) throws Exception {
+        if(msg == null){
+            throw new Exception("msg is null");
+        }
+        out.writeBytes(msg.getBytes(StandardCharsets.UTF_8));
+
+
+    }
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickNettyClient.java

@@ -0,0 +1,80 @@
+package com.zhehekeji.web.service.sick;
+
+import com.zhehekeji.web.entity.SensorGun;
+import com.zhehekeji.web.mapper.SensorGunMapper;
+import com.zhehekeji.web.service.PlcService;
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+public class SickNettyClient {
+
+    private static EventLoopGroup group = new NioEventLoopGroup();
+
+    @Resource
+    private SensorGunMapper sensorGunMapper;
+    @Resource
+    private PlcService plcService;
+
+    /**
+     * 重连最大次数
+     */
+    private static int RECONNECT_NUM = 5;
+
+    public void createClient(SensorGun sensorGun) throws InterruptedException {
+        if (StringUtils.isEmpty(sensorGun.getIp()) || sensorGun.getPort() == null) {
+            return;
+        }
+        Bootstrap client = new Bootstrap();
+        client.group(group);
+        client.channel(NioSocketChannel.class);
+        client.handler(new SickNettyClientFilter(sensorGun.getId(),plcService,this));
+        // 连接服务端
+        Channel channel = client.connect(sensorGun.getIp(), sensorGun.getPort()).sync().channel();
+        channel.writeAndFlush("start");
+    }
+
+    /**
+     * 断线重连 尝试 RECONNECT_NUM 次
+     *
+     * @param sensorId
+     */
+    public void reconnect(Integer sensorId) {
+        Boolean isConnected = false;
+        int num = 0;
+        SensorGun sensorGun = sensorGunMapper.selectById(sensorId);
+        if (sensorGun == null) {
+            log.error("reconnect ,sensorGun is null ,id:{}", sensorId);
+            return;
+        }
+        while (num < RECONNECT_NUM && !isConnected) {
+            try {
+                createClient(sensorGun);
+            } catch (Exception e) {
+                //没连上 继续
+                log.error("sensorGun reconnect error num:{}", num);
+                try {
+                    Thread.sleep(5000);
+                } catch (InterruptedException ex) {
+                    ex.printStackTrace();
+                }
+                num++;
+                continue;
+            }
+            isConnected = true;
+        }
+        if (isConnected) {
+            log.info("sensorGun reconnect success");
+        } else {
+            log.error("sensorGun reconnect error .sensorGunId:{},reconnect num:{},ip:{},port:{}", sensorId, num,sensorGun.getIp(),sensorGun.getPort());
+        }
+    }
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickNettyClientFilter.java

@@ -0,0 +1,39 @@
+package com.zhehekeji.web.service.sick;
+
+import com.zhehekeji.web.service.PlcService;
+import com.zhehekeji.web.service.robotic.*;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.handler.timeout.IdleStateHandler;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 客户端过滤器，编解码和心跳的设置
+ *
+ * @author Administrator
+ *
+ */
+public class SickNettyClientFilter extends ChannelInitializer<SocketChannel> {
+
+    private Integer sensorId;
+
+    private PlcService plcService;
+
+    private SickNettyClient nettyClient;
+
+    public SickNettyClientFilter(Integer sensorId, PlcService plcService, SickNettyClient nettyClient){
+        this.sensorId = sensorId;
+        this.plcService = plcService;
+        this.nettyClient = nettyClient;
+    }
+
+    @Override
+    protected void initChannel(SocketChannel ch) throws Exception {
+        ChannelPipeline ph = ch.pipeline();
+        ph.addLast(new SickDecoder(this.plcService,this.sensorId));
+        ph.addLast(new SickClientHandler(sensorId,nettyClient));
+        ph.addLast(new SickEncoder());
+    }
+}

web/src/main/java/com/zhehekeji/web/service/sick/SickSocket.java

@@ -0,0 +1,70 @@
+package com.zhehekeji.web.service.sick;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.*;
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * sick扫码枪
+ */
+@Slf4j
+public class SickSocket {
+
+    public static void main(String[] args) {
+        String code = readOCR("192.168.8.236", 2002);
+        System.out.println(code);
+    }
+
+    public static String readOCR(String ip,int port){
+        Socket socket = new Socket();
+        String code = null;
+        OutputStream os = null;
+        InputStream is = null;
+        try {
+            socket.connect(new InetSocketAddress(ip,port),3000);
+            os = socket.getOutputStream();
+            writeCmd(os);
+            is = socket.getInputStream();
+            code = read(is);
+        } catch (IOException e) {
+            log.error("sick time out,ip:{},info:{}",ip,e);
+        }finally {
+            if(os != null){
+                try {
+                    os.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if(is != null){
+                try {
+                    is.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            try {
+                socket.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+
+            return code;
+        }
+    }
+
+    private static void writeCmd(OutputStream os) throws IOException {
+        String startCmd = "start";
+        byte[]bytes = startCmd.getBytes(StandardCharsets.UTF_8);
+        os.write(bytes);
+    }
+
+    private static String read(InputStream inStream) throws IOException {
+        BufferedReader bd = new BufferedReader(new InputStreamReader(inStream));
+        return bd.readLine();
+    }
+
+}

web/src/main/resources/application-dev.yml

@@ -7,14 +7,14 @@ spring:
     maxWait: 60000
     minEvictableIdleTimeMillis: 300000
     minIdle: 15
-    password: Leaper@123
+    password: ming1234
     poolPreparedStatements: true
     testOnBorrow: true
     testOnReturn: false
     testWhileIdle: false
     timeBetweenEvictionRunsMillis: 60000
     type: com.alibaba.druid.pool.DruidDataSource
-    url: jdbc:mysql://115.236.65.98:12004/lia_duoji?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
+    url: jdbc:mysql://212.129.248.185:3306/lia_duoji?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
     username: root
     validationQuery: SELECT 1 FROM DUAL
 # --------本服务端口号
@@ -54,3 +54,7 @@ videoStyleConfig:
 lightSource:
   type: 1
   info: "{'num':2,'index':0}"
+# -----------扫码枪
+# ------------type 1: sick
+sensor:
+  type: 1

web/src/main/resources/logback-spring.xml

@@ -103,11 +103,37 @@
         </filter>
     </appender>
 
+    <appender name="sickTcpAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <File>${LOG_HOME}/${logName}-sick-tcp.log</File>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_HOME}/${logName}-sick-tcp-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
+            <maxHistory>30</maxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>10MB</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <encoder>
+            <pattern>
+                %d %p (%file:%line\)- %m%n
+            </pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>info</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+    </appender>
+
     <!-- additivity属性为false，表示此logger的打印信息不再向上级传递(注：该值默认为true，logger的日志信息会依次向上级传递，最高级logger为root，如果不加则至少打印2次，本身一次，root一次)-->
     <logger name="tcp" additivity="false" level="INFO">
         <appender-ref ref="tcpAppender"/>
     </logger>
 
+    <logger name="sick" additivity="false" level="INFO">
+        <appender-ref ref="sickTcpAppender"/>
+    </logger>
+
     <logger name="com.zhehekeji.web.mapper" level="DEBUG" />
 
     <!--info和error分开打印，注：ERROR > WARN > INFO > DEBUG > TRACE-->