灯光控制项目

huimv-lamp/.idea/.gitignore

@@ -0,0 +1,2 @@
+# Default ignored files
+/workspace.xml

huimv-lamp/.idea/compiler.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CompilerConfiguration">
+    <annotationProcessing>
+      <profile name="Maven default annotation processors profile" enabled="true">
+        <sourceOutputDir name="target/generated-sources/annotations" />
+        <sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
+        <outputRelativeToContentRoot value="true" />
+        <module name="huimv-lamp" />
+      </profile>
+    </annotationProcessing>
+  </component>
+  <component name="JavacSettings">
+    <option name="ADDITIONAL_OPTIONS_OVERRIDE">
+      <module name="huimv-lamp" options="-parameters" />
+    </option>
+  </component>
+</project>

huimv-lamp/.idea/inspectionProfiles/Project_Default.xml

@@ -0,0 +1,36 @@
+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="JavaDoc" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="TOP_LEVEL_CLASS_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="INNER_CLASS_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="METHOD_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="@return@param@throws or @exception" />
+        </value>
+      </option>
+      <option name="FIELD_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="IGNORE_DEPRECATED" value="false" />
+      <option name="IGNORE_JAVADOC_PERIOD" value="true" />
+      <option name="IGNORE_DUPLICATED_THROWS" value="false" />
+      <option name="IGNORE_POINT_TO_ITSELF" value="false" />
+      <option name="myAdditionalJavadocTags" value="date" />
+    </inspection_tool>
+  </profile>
+</component>

huimv-lamp/.idea/misc.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ExternalStorageConfigurationManager" enabled="true" />
+  <component name="MavenProjectsManager">
+    <option name="originalFiles">
+      <list>
+        <option value="$PROJECT_DIR$/pom.xml" />
+      </list>
+    </option>
+  </component>
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" project-jdk-name="1.8" project-jdk-type="JavaSDK">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>

huimv-lamp/.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/.." vcs="Git" />
+  </component>
+</project>

huimv-lamp/huimv-lamp.iml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_5">
+    <output url="file://$MODULE_DIR$/target/classes" />
+    <output-test url="file://$MODULE_DIR$/target/test-classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

huimv-lamp/pom.xml

@@ -0,0 +1,133 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.7.2</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.huimv</groupId>
+    <artifactId>huimv-lamp</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>huimv-lamp</name>
+    <description>Demo project for Spring Boot</description>
+    <properties>
+        <java.version>1.8</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <!-- netty -->
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.45.Final</version>
+        </dependency>
+        <!-- lombok -->
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.16.18</version>
+            <scope>provided</scope>
+        </dependency>
+        <!-- JPA -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <!-- mysql -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+
+
+        <!--Mybatis-Plus生成器依赖-->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-generator</artifactId>
+            <!--            <version>3.3.1.tmp</version>-->
+            <version>3.3.2</version>
+        </dependency>
+
+        <!--freemarker 模板引擎(没有用原生的模板引擎)-->
+        <dependency>
+            <groupId>org.freemarker</groupId>
+            <artifactId>freemarker</artifactId>
+            <version>2.3.31</version>
+        </dependency>
+
+        <!--mybits-plus-->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <!--            <version>3.4.2</version>-->
+            <version>3.4.3.4</version>
+        </dependency>
+        <!--        <dependency>-->
+        <!--            <groupId>com.baomidou</groupId>-->
+        <!--            <artifactId>mybatis-plus</artifactId>-->
+        <!--            <version>3.5.1</version>-->
+        <!--        </dependency>-->
+        <!-- mybatis-plus-extension -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-extension</artifactId>
+            <version>3.5.2</version>
+        </dependency>
+        <!-- 连接池 -->
+        <dependency>
+            <!--自动配置-->
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+            <version>1.1.14</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.velocity</groupId>
+            <artifactId>velocity-engine-core</artifactId>
+            <version>2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-freemarker</artifactId>
+        </dependency>
+
+        <!-- JPA -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <!-- mysql -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+<!--                <version>2.6.2</version>-->
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-resources-plugin</artifactId>
+                <version>2.6</version>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

huimv-lamp/src/main/java/com/huimv/lamp/HuimvLampApplication.java

@@ -0,0 +1,18 @@
+package com.huimv.lamp;
+
+import com.huimv.lamp.server.EartagServer2;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ApplicationContext;
+
+@SpringBootApplication
+@MapperScan("com.huimv.lamp.mapper")
+public class HuimvLampApplication {
+
+    public static void main(String[] args) throws InterruptedException {
+        ApplicationContext applicationContext = SpringApplication.run(HuimvLampApplication.class, args);
+        applicationContext.getBean(EartagServer2.class).run();
+    }
+
+}

huimv-lamp/src/main/java/com/huimv/lamp/controller/LampController.java

@@ -0,0 +1,44 @@
+package com.huimv.lamp.controller;
+
+
+import com.huimv.lamp.service.LampService;
+import com.huimv.lamp.utils.Result;
+import com.huimv.lamp.utils.ResultCode;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author zn
+ * @since 2022-08-02
+ */
+@CrossOrigin
+@RestController
+@RequestMapping("/lamp")
+public class LampController {
+    @Autowired
+    private LampService lampService;
+
+    @PostMapping("/getLightness")
+    public Result getLightness(){
+        Integer lightness = lampService.getLighteness();
+        return new Result(ResultCode.SUCCESS,lightness);
+    }
+
+    @PostMapping("/updateLightness")
+    public Result updateLightness(@RequestBody Map<String, Object> params){
+        Integer lightness = 0;
+        if(params.get("lightness") != null){
+            lightness = Integer.parseInt(params.get("lightness")+"");
+        }
+        //
+        lampService.updateLightness(lightness);
+        return new Result(ResultCode.SUCCESS);
+    }
+}
+

huimv-lamp/src/main/java/com/huimv/lamp/dao/entity/LampEntity.java

@@ -0,0 +1,31 @@
+package com.huimv.lamp.dao.entity;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Entity
+@Data
+@Accessors(chain = true)
+@Table(name = "lamp")
+public class LampEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false)
+    private Integer id;
+
+    @Column(name = "chip_id")
+    private String chipId;
+
+    @Column(name = "device_code")
+    private String deviceCode;
+
+    @Column(name = "lightness")
+    private Integer lightness;
+
+}

huimv-lamp/src/main/java/com/huimv/lamp/dao/repo/LampRepo.java

@@ -0,0 +1,12 @@
+package com.huimv.lamp.dao.repo;
+
+import com.huimv.lamp.dao.entity.LampEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+public interface LampRepo extends JpaRepository<LampEntity, Integer>, JpaSpecificationExecutor<LampEntity> {
+
+    @Query(nativeQuery = true,value="SELECT * FROM lamp limit 1")
+    LampEntity getLightness();
+}

huimv-lamp/src/main/java/com/huimv/lamp/mapper/LampMapper.java

@@ -0,0 +1,17 @@
+package com.huimv.lamp.mapper;
+
+import com.huimv.lamp.pojo.Lamp;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author zn
+ * @since 2022-08-02
+ */
+public interface LampMapper extends BaseMapper<Lamp> {
+
+    Lamp selectOne2();
+}

huimv-lamp/src/main/java/com/huimv/lamp/mapper/xml/LampMapper.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.huimv.lamp.mapper.LampMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.huimv.lamp.pojo.Lamp">
+        <id column="id" property="id" />
+        <result column="chip_id" property="chipId" />
+        <result column="device_code" property="deviceCode" />
+        <result column="lightness" property="lightness" />
+    </resultMap>
+
+    <!-- 通用查询结果列 -->
+    <sql id="Base_Column_List">
+        id, chip_id, device_code, lightness
+    </sql>
+    <select id="selectOne2" resultType="com.huimv.lamp.pojo.Lamp">
+        select * from lamp limit 1;
+    </select>
+
+
+</mapper>

huimv-lamp/src/main/java/com/huimv/lamp/pojo/Lamp.java

@@ -0,0 +1,34 @@
+package com.huimv.lamp.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.Version;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author zn
+ * @since 2022-08-02
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class Lamp implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+      @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    private String chipId;
+
+    private String deviceCode;
+
+    private Integer lightness;
+
+
+}

huimv-lamp/src/main/java/com/huimv/lamp/server/EartagServer2.java

@@ -0,0 +1,74 @@
+package com.huimv.lamp.server;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@Component
+public class EartagServer2 {
+    @Autowired
+    private EartagServerHandler2 serverHandler;
+    //监听端口
+    private int port = 8888;
+    //创建构造方法
+    public EartagServer2(){
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        new EartagServer2().run();
+    }
+/**
+ *
+ * 功能描述: 启动方法前台多个服务  处理多个线程
+ *
+ * @param:
+ * @return:
+ * @auther: LiGang
+ * @date: 2019/3/26 11:31
+ */
+    /**
+     * 启动流程
+     */
+    public void run() throws InterruptedException {
+        //配置服务端线程组
+        EventLoopGroup bossGroup=new NioEventLoopGroup();
+        EventLoopGroup workGroup=new NioEventLoopGroup();
+
+        try{
+            //引导整个server的启动
+            ServerBootstrap serverBootstrap = new ServerBootstrap();
+            serverBootstrap.group(bossGroup,workGroup)
+                    .channel(NioServerSocketChannel.class)    //指定处理的连接类型
+                    .childHandler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel socketChannel) throws Exception {
+                            socketChannel.pipeline().addLast(serverHandler);
+                        }
+                    });
+            System.out.println("# 耳标及采集器设备数据接收服务器已经启动:"+port+"#");
+            System.out.println("# 准备接收数据：");
+            //绑定端口，同步等待成功
+            ChannelFuture cf = serverBootstrap.bind(port).sync();
+            // 等待服务端监听端口关闭
+            cf.channel().closeFuture().sync();
+        }finally {
+            //优雅的退出
+            bossGroup.shutdownGracefully();
+            workGroup.shutdownGracefully();
+        }
+    }
+}

huimv-lamp/src/main/java/com/huimv/lamp/server/EartagServerHandler2.java

@@ -0,0 +1,161 @@
+package com.huimv.lamp.server;
+
+import com.huimv.lamp.service.DataService;
+import com.huimv.lamp.service.LampService;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandler;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.CharsetUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@ChannelHandler.Sharable
+@Component
+@Slf4j
+public class EartagServerHandler2 extends ChannelInboundHandlerAdapter {
+    @Value("${data.input.flow}")
+    private Integer dataInputFlow;
+    @Value("${data.test.input}")
+    private Integer dataTestInput;
+    private StringBuilder askTextSb = null;
+    private int num = 0;
+    @Autowired
+    private DataService dataService;
+    @Autowired
+    private LampService lampService;
+
+    //
+    public void appendClientAsk(String text){
+        if(this.askTextSb == null){
+            askTextSb = new StringBuilder();
+        }
+        askTextSb.append(text);
+    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ByteBuf data = (ByteBuf) msg;
+        String clientAskText = data.toString(CharsetUtil.UTF_8);
+//        System.out.println("客户端消息clientAskText>>"+clientAskText);
+        //保存实例内的客户端请求
+//        appendClientAsk(clientAskText);
+        handleClientMessage(clientAskText,ctx);
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+//        if(askTextSb.toString().indexOf("end") != -1){
+//            // 处理客户端消息
+//            handleClientMessage(askTextSb.toString(),ctx);
+//            //清空重置;
+//            askTextSb.delete(0,askTextSb.length());
+//            num = 0;
+//        }
+    }
+
+    private void handleClientMessage(String askText, ChannelHandlerContext ctx) throws ParseException {
+        String[] dataArray = askText.split("\\+");
+        String cmdHeader = dataArray[0];
+        //芯片id/设备编码
+        String idCode = dataArray[1];
+        String cmd = dataArray[2];
+        Map map = new HashMap();
+        map.put("askText", askText);
+        if (cmdHeader.trim().equalsIgnoreCase("hm")) {
+            //采集器应答数据
+            if (cmd.trim().equalsIgnoreCase("0")) {
+                //不需要处理
+                System.out.println("==>命令0");
+            } else if (cmd.trim().equalsIgnoreCase("1")) {
+                System.out.println("==>命令1请求 askText>>" + askText.trim());
+                //处理获取设备编码命令
+                //{读取设备编码}
+                String deviceCode = dataService.getDeviceCodeByChipId(idCode);
+                log.info("获取设备编码结果,芯片id>>" + idCode + " ,deviceCode>>" + deviceCode);
+                if (deviceCode != null) {
+                    String answer = "hm+1+0+" + deviceCode + "+123+8+end";
+                    log.info(">>命令1设备编码-应答数据>>" + answer);
+                    ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
+                } else {
+                    log.error("检测到未注册的采集器设备,已舍弃请求.");
+                }
+            } else if (cmd.trim().equalsIgnoreCase("2")) {
+                    //处理服务器时间命令
+                    String answer = "hm+2+" + dataService.getNowText() + "+4+end";
+                    log.info(">>命令2服务器时间-应答数据>>" + answer);
+                    ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
+
+            } else if (cmd.trim().equalsIgnoreCase("3")) {
+                System.out.println("==>命令3请求 askText>>" + askText);
+                //处理心跳包命令
+                //{设备心跳应答}
+                String answer = "hm+3+6+end";
+                log.info(">>命令3心跳包-应答数据>>" + answer);
+                ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
+            } else if (cmd.trim().equalsIgnoreCase("4")) {
+                System.out.println("==>命令4请求 askText>>" + askText);
+                //处理设备环境温度命令
+                //{设备环境温度应答}
+                String answer = "hm+4+7+end";
+                log.info(">>命令4环境温度-应答数据>>" + answer);
+                ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
+            } else if (cmd.trim().equalsIgnoreCase("7")) {
+                System.out.println("==>命令7请求 askText>>" + askText);
+                //处理设备环境温度命令
+//                Integer lighteness = dataService.getLighteness(askText);
+//                int lighteness = lampService.getLighteness(askText);
+                //灯光亮度应答
+//                Integer lighteness = 50;
+                Integer lighteness = lampService.getLight();
+                System.out.println("lighteness>>"+lighteness);
+                String answer = "hm+7+"+lighteness+"+0+end";
+                log.info(">>命令7亮度-应答数据>>" + answer);
+                ctx.writeAndFlush(Unpooled.copiedBuffer(answer.getBytes()));
+            } else {
+                System.out.println("==>未知命令");
+                log.error(">>当前数据为非法数据>>" + askText);
+            }
+        } else {
+            System.out.println("==>未知命令");
+            log.error("##当前请求数据为非法数据>>" + askText);
+        }
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        if(cause.getMessage().indexOf("Connection reset") != -1){
+            log.info("相关采集器设备正在重启:"+cause.toString());
+        }
+        ctx.close();
+    }
+
+    //检查无效耳标
+    public boolean checkValidEarmark(String earmark) {
+        if (earmark.trim().equalsIgnoreCase("ffffffffffffffff") || earmark.trim().equalsIgnoreCase("0000000000000000")) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+
+
+}

huimv-lamp/src/main/java/com/huimv/lamp/service/DataService.java

@@ -0,0 +1,41 @@
+package com.huimv.lamp.service;
+
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@Component
+public class DataService {
+
+    public String getDeviceCodeByChipId(String chipId){
+        System.out.println("chipId"+chipId);
+        return "802001";
+    }
+
+    public String getNowText() throws ParseException {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
+        return sdf.format(new Date());
+    }
+
+    //返回亮度
+    public Integer getLighteness(String askText){
+        String[] askTextArray = askText.split(",");
+        String id = askTextArray[1];
+        return 10;
+    }
+
+    public int getLighteness(){
+        return 10;
+    }
+}

huimv-lamp/src/main/java/com/huimv/lamp/service/LampService.java

@@ -0,0 +1,25 @@
+package com.huimv.lamp.service;
+
+import com.huimv.lamp.pojo.Lamp;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author zn
+ * @since 2022-08-02
+ */
+public interface LampService extends IService<Lamp> {
+
+    //返回亮度
+    int getLighteness(String askText);
+
+    //返回亮度
+    Integer getLighteness();
+
+    Boolean updateLightness(Integer lightness);
+
+    int getLight();
+}

huimv-lamp/src/main/java/com/huimv/lamp/service/impl/LampServiceImpl.java

@@ -0,0 +1,77 @@
+package com.huimv.lamp.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huimv.lamp.dao.entity.LampEntity;
+import com.huimv.lamp.dao.repo.LampRepo;
+import com.huimv.lamp.pojo.Lamp;
+import com.huimv.lamp.mapper.LampMapper;
+import com.huimv.lamp.service.LampService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author zn
+ * @since 2022-08-02
+ */
+@Service
+public class LampServiceImpl extends ServiceImpl<LampMapper, Lamp> implements LampService {
+//    @Resource
+    @Autowired
+    private LampMapper lampMapper;
+
+    @Autowired
+    private LampRepo lampRepo;
+
+    //返回亮度
+    @Override
+    public int getLighteness(String askText){
+        Lamp lamp = lampMapper.selectOne2();
+        System.out.println("lamp="+lamp.toString());
+        int lightness = 30;
+        if(lamp != null){
+            lightness = lamp.getLightness();
+        }
+        return lightness;
+    }
+
+    //返回亮度
+    @Override
+    public Integer getLighteness(){
+        QueryWrapper<Lamp> queryWrapper = new QueryWrapper<>();
+        Lamp lamp = lampMapper.selectOne(queryWrapper);
+        Integer lightness = 30;
+        if(lamp != null){
+            lightness = lamp.getLightness();
+        }
+        return lightness;
+    }
+
+    @Override
+    public Boolean updateLightness(Integer lightness) {
+        QueryWrapper<Lamp> queryWrapper = new QueryWrapper<>();
+        Lamp lamp = lampMapper.selectOne(queryWrapper);
+        lamp.setLightness(lightness);
+        Integer rows = lampMapper.updateById(lamp);
+        if(rows > 0){
+            return true;
+        }else{
+            return false;
+        }
+    }
+
+    @Override
+    public int getLight(){
+        LampEntity lampEntity = lampRepo.getLightness();
+        System.out.println("lampEntity>>"+lampEntity.toString());
+        int lightness = 50;
+        if(lampEntity != null){
+            lightness = lampEntity.getLightness();
+        }
+        return lightness;
+    }
+}

huimv-lamp/src/main/java/com/huimv/lamp/utils/Result.java

@@ -0,0 +1,79 @@
+package com.huimv.lamp.utils;
+
+import java.io.Serializable;
+
+public class Result implements Serializable {
+
+    private boolean success;
+    private Integer code;
+    private String message;
+
+    public boolean isSuccess() {
+        return success;
+    }
+
+    public void setSuccess(boolean success) {
+        this.success = success;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public Object getData() {
+        return data;
+    }
+
+    public void setData(Object data) {
+        this.data = data;
+    }
+
+    private Object data;
+
+    //不需要返回数据时使用
+    public Result(ResultCode code) {
+        this.success = code.success;
+        this.code = code.code;
+        this.message = code.message;
+    }
+
+    public Result(ResultCode code, Object data) {
+        this.success = code.success;
+        this.code = code.code;
+        this.message = code.message;
+        this.data = data;
+    }
+
+    public Result(Integer code, String message, boolean success) {
+        this.code = code;
+        this.message = message;
+        this.success = success;
+    }
+
+    /*
+     * 调用ResultCode类封装常用的返回数据
+     */
+    public static Result SUCCESS(){
+        return new Result(ResultCode.SUCCESS);
+    }
+
+    public static Result ERROR(){
+        return new Result(ResultCode.SERVER_ERROR);
+    }
+
+    public static Result FAIL(){
+        return new Result(ResultCode.FAIL);
+    }
+}

huimv-lamp/src/main/java/com/huimv/lamp/utils/ResultCode.java

@@ -0,0 +1,41 @@
+package com.huimv.lamp.utils;
+
+public enum ResultCode {
+    SUCCESS(true,10000,"操作成功！"),
+    //---系统错误返回码-----
+    FAIL(false,10001,"操作失败"),
+    UNAUTHENTICATED(false,10002,"您还未登录"),
+    UNAUTHORISE(false,10003,"权限不足"),
+    SERVER_ERROR(false,99999,"抱歉，系统繁忙，请稍后重试！"),
+
+    //---用户操作返回码  2xxxx----
+    MOBILEORPASSWORDERROR(false,20001,"用户名或密码错误");
+    //---企业操作返回码  3xxxx----
+    //---权限操作返回码----
+    //---其他操作返回码----
+
+    //操作是否成功
+    boolean success;
+    //操作代码
+    int code;
+    //提示信息
+    String message;
+
+    ResultCode(boolean success,int code, String message){
+        this.success = success;
+        this.code = code;
+        this.message = message;
+    }
+
+    public boolean success() {
+        return success;
+    }
+
+    public int code() {
+        return code;
+    }
+
+    public String message() {
+        return message;
+    }
+}

huimv-lamp/src/main/resources/application-dev.yml

@@ -0,0 +1,68 @@
+server:
+  port: 8090
+
+spring:
+  application:
+    name: huimv-eartag2-input
+
+  datasource:
+    url: jdbc:mysql://192.168.1.7:3306/huimv_demo?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+    username: root
+    password: hm123456
+    driver-class-name: com.mysql.cj.jdbc.Driver
+  jpa:
+    show-sql: true
+    database: mysql
+    hibernate:
+      ddl-auto: update
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    open-in-view: true
+
+
+  data:
+    redis:
+      repositories:
+        enabled: false
+
+  #是否缓存空值
+  cache:
+    redis:
+      cache-null-values: false
+
+
+
+    #server:
+#  port: 9110
+#spring:
+#  application:
+#    name: huimv-hy-autoGetData
+#
+#  datasource:
+##    url: jdbc:mysql://47.98.175.112:3306/huimv_ql_farm_haiyan?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    #    url: jdbc:mysql://36.22.189.214:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#        url: jdbc:mysql://192.168.1.7:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    username: root
+#    password: hm123456
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#  jpa:
+#    properties:
+#      hibernate:
+#        enable_lazy_load_no_trans: true
+#    show-sql: true
+#    database: mysql
+#    hibernate:
+#      ddl-auto: update
+#    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+#    open-in-view: true
+management:
+  endpoints:
+    web:
+      exposure:
+        include: "*"   # * 在yaml 文件属于关键字，所以需要加引号
+
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  # mapper.xml文件所存放的位置
+  mapper-locations: classpath*:com/huimv/lamp/mapper/xml/*.xml  # 不加这一行出错：“org.apache.ibatis.binding.BindingException:  Invalid bound statement (not found)”
+#  mapper-locations: classpath:com/huimv/center/mappers/**/*Mapper.xml

huimv-lamp/src/main/resources/application-prod.yml

@@ -0,0 +1,68 @@
+server:
+  port: 8090
+
+spring:
+  application:
+    name: huimv-eartag2-input
+
+  datasource:
+    url: jdbc:mysql://122.112.224.199:3306/huimv_demo?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+    username: root
+    password: hm123456
+    driver-class-name: com.mysql.cj.jdbc.Driver
+  jpa:
+    show-sql: true
+    database: mysql
+    hibernate:
+      ddl-auto: update
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    open-in-view: true
+
+
+  data:
+    redis:
+      repositories:
+        enabled: false
+
+  #是否缓存空值
+  cache:
+    redis:
+      cache-null-values: false
+
+
+
+    #server:
+#  port: 9110
+#spring:
+#  application:
+#    name: huimv-hy-autoGetData
+#
+#  datasource:
+##    url: jdbc:mysql://47.98.175.112:3306/huimv_ql_farm_haiyan?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    #    url: jdbc:mysql://36.22.189.214:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#        url: jdbc:mysql://192.168.1.7:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    username: root
+#    password: hm123456
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#  jpa:
+#    properties:
+#      hibernate:
+#        enable_lazy_load_no_trans: true
+#    show-sql: true
+#    database: mysql
+#    hibernate:
+#      ddl-auto: update
+#    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+#    open-in-view: true
+management:
+  endpoints:
+    web:
+      exposure:
+        include: "*"   # * 在yaml 文件属于关键字，所以需要加引号
+
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  # mapper.xml文件所存放的位置
+  mapper-locations: classpath*:com/huimv/lamp/mapper/xml/*.xml  # 不加这一行出错：“org.apache.ibatis.binding.BindingException:  Invalid bound statement (not found)”
+#  mapper-locations: classpath:com/huimv/center/mappers/**/*Mapper.xml

huimv-lamp/src/main/resources/application.properties

@@ -0,0 +1,31 @@
+spring.profiles.active=prod
+
+#开启健康监控
+management.endpoints.web.exposure.include=*
+
+#########################################################
+###             配置undertow取代tomcat                ###
+#########################################################
+# 是否打开 undertow 日志，默认为 false
+server.undertow.accesslog.enabled=false
+# 设置访问日志所在目录
+server.undertow.accesslog.dir=logs
+# 指定工作者线程的 I/0 线程数，默认为 2 或者 CPU 的个数
+server.undertow.io-threads=
+# 指定工作者线程个数，默认为 I/O 线程个数的 8 倍
+server.undertow.worker-threads=
+# 设置 HTTP POST 内容的最大长度，默认不做限制
+server.undertow.max-http-post-size=0
+
+#########################################################
+###   Actuator Monitor  --   Actuator configuration   ###
+#########################################################
+management.security.enabled=false
+
+# 数据处理流程
+data.input.flow=2
+
+# 是否写入测试数据(1:写入 0:不写入)
+data.test.input=0
+
+

huimv-lamp/target/classes/application-dev.yml

@@ -0,0 +1,68 @@
+server:
+  port: 8090
+
+spring:
+  application:
+    name: huimv-eartag2-input
+
+  datasource:
+    url: jdbc:mysql://192.168.1.7:3306/huimv_demo?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+    username: root
+    password: hm123456
+    driver-class-name: com.mysql.cj.jdbc.Driver
+  jpa:
+    show-sql: true
+    database: mysql
+    hibernate:
+      ddl-auto: update
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    open-in-view: true
+
+
+  data:
+    redis:
+      repositories:
+        enabled: false
+
+  #是否缓存空值
+  cache:
+    redis:
+      cache-null-values: false
+
+
+
+    #server:
+#  port: 9110
+#spring:
+#  application:
+#    name: huimv-hy-autoGetData
+#
+#  datasource:
+##    url: jdbc:mysql://47.98.175.112:3306/huimv_ql_farm_haiyan?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    #    url: jdbc:mysql://36.22.189.214:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#        url: jdbc:mysql://192.168.1.7:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    username: root
+#    password: hm123456
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#  jpa:
+#    properties:
+#      hibernate:
+#        enable_lazy_load_no_trans: true
+#    show-sql: true
+#    database: mysql
+#    hibernate:
+#      ddl-auto: update
+#    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+#    open-in-view: true
+management:
+  endpoints:
+    web:
+      exposure:
+        include: "*"   # * 在yaml 文件属于关键字，所以需要加引号
+
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  # mapper.xml文件所存放的位置
+  mapper-locations: classpath*:com/huimv/lamp/mapper/xml/*.xml  # 不加这一行出错：“org.apache.ibatis.binding.BindingException:  Invalid bound statement (not found)”
+#  mapper-locations: classpath:com/huimv/center/mappers/**/*Mapper.xml

huimv-lamp/target/classes/application-prod.yml

@@ -0,0 +1,68 @@
+server:
+  port: 8090
+
+spring:
+  application:
+    name: huimv-eartag2-input
+
+  datasource:
+    url: jdbc:mysql://122.112.224.199:3306/huimv_demo?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+    username: root
+    password: hm123456
+    driver-class-name: com.mysql.cj.jdbc.Driver
+  jpa:
+    show-sql: true
+    database: mysql
+    hibernate:
+      ddl-auto: update
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    open-in-view: true
+
+
+  data:
+    redis:
+      repositories:
+        enabled: false
+
+  #是否缓存空值
+  cache:
+    redis:
+      cache-null-values: false
+
+
+
+    #server:
+#  port: 9110
+#spring:
+#  application:
+#    name: huimv-hy-autoGetData
+#
+#  datasource:
+##    url: jdbc:mysql://47.98.175.112:3306/huimv_ql_farm_haiyan?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    #    url: jdbc:mysql://36.22.189.214:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#        url: jdbc:mysql://192.168.1.7:3306/huimv_ql_farm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    username: root
+#    password: hm123456
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#  jpa:
+#    properties:
+#      hibernate:
+#        enable_lazy_load_no_trans: true
+#    show-sql: true
+#    database: mysql
+#    hibernate:
+#      ddl-auto: update
+#    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+#    open-in-view: true
+management:
+  endpoints:
+    web:
+      exposure:
+        include: "*"   # * 在yaml 文件属于关键字，所以需要加引号
+
+mybatis-plus:
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  # mapper.xml文件所存放的位置
+  mapper-locations: classpath*:com/huimv/lamp/mapper/xml/*.xml  # 不加这一行出错：“org.apache.ibatis.binding.BindingException:  Invalid bound statement (not found)”
+#  mapper-locations: classpath:com/huimv/center/mappers/**/*Mapper.xml

huimv-lamp/target/classes/application.properties

@@ -0,0 +1,31 @@
+spring.profiles.active=prod
+
+#�����������
+management.endpoints.web.exposure.include=*
+
+#########################################################
+###             ����undertowȡ��tomcat                ###
+#########################################################
+# �Ƿ�� undertow ��־��Ĭ��Ϊ false
+server.undertow.accesslog.enabled=false
+# ���÷�����־����Ŀ¼
+server.undertow.accesslog.dir=logs
+# ָ���������̵߳� I/0 �߳�����Ĭ��Ϊ 2 ���� CPU �ĸ���
+server.undertow.io-threads=
+# ָ���������̸߳�����Ĭ��Ϊ I/O �̸߳����� 8 ��
+server.undertow.worker-threads=
+# ���� HTTP POST ���ݵ���󳤶ȣ�Ĭ�ϲ�������
+server.undertow.max-http-post-size=0
+
+#########################################################
+###   Actuator Monitor  --   Actuator configuration   ###
+#########################################################
+management.security.enabled=false
+
+# ���ݴ�������
+data.input.flow=2
+
+# �Ƿ�д���������(1:д�� 0:��д��)
+data.test.input=0
+
+

huimv-lamp/target/maven-archiver/pom.properties

@@ -0,0 +1,3 @@
+artifactId=huimv-lamp
+groupId=com.huimv
+version=0.0.1-SNAPSHOT

huimv-lamp/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -0,0 +1,14 @@
+com\huimv\lamp\server\EartagServer2$1.class
+com\huimv\lamp\server\EartagServer2.class
+com\huimv\lamp\service\DataService.class
+com\huimv\lamp\utils\ResultCode.class
+com\huimv\lamp\dao\repo\LampRepo.class
+com\huimv\lamp\HuimvLampApplication.class
+com\huimv\lamp\service\LampService.class
+com\huimv\lamp\service\impl\LampServiceImpl.class
+com\huimv\lamp\controller\LampController.class
+com\huimv\lamp\utils\Result.class
+com\huimv\lamp\pojo\Lamp.class
+com\huimv\lamp\mapper\LampMapper.class
+com\huimv\lamp\dao\entity\LampEntity.class
+com\huimv\lamp\server\EartagServerHandler2.class

huimv-lamp/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

@@ -0,0 +1,13 @@
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\HuimvLampApplication.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\utils\Result.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\service\LampService.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\dao\repo\LampRepo.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\server\EartagServer2.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\mapper\LampMapper.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\server\EartagServerHandler2.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\dao\entity\LampEntity.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\pojo\Lamp.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\service\impl\LampServiceImpl.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\service\DataService.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\utils\ResultCode.java
+D:\idea6\huimv.lamp\huimv-lamp\src\main\java\com\huimv\lamp\controller\LampController.java