主要有基站注册--数据上传--数据处理--修改温度--反馈等功能

huimv-smart-incubator/huimv-smart-incubator-data/huimv-smart-incubator-data.iml

@@ -0,0 +1,141 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
+  <component name="FacetManager">
+    <facet type="jpa" name="JPA">
+      <configuration>
+        <setting name="validation-enabled" value="true" />
+        <setting name="provider-name" value="Hibernate" />
+        <datasource-mapping />
+        <naming-strategy-map />
+      </configuration>
+    </facet>
+    <facet type="Spring" name="Spring">
+      <configuration />
+    </facet>
+    <facet type="web" name="Web">
+      <configuration>
+        <webroots />
+        <sourceRoots>
+          <root url="file://$MODULE_DIR$/src/main/java" />
+          <root url="file://$MODULE_DIR$/src/main/resources" />
+        </sourceRoots>
+      </configuration>
+    </facet>
+  </component>
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_8">
+    <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" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-web:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-logging:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: ch.qos.logback:logback-classic:1.2.4" level="project" />
+    <orderEntry type="library" name="Maven: ch.qos.logback:logback-core:1.2.4" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.logging.log4j:log4j-to-slf4j:2.14.1" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.logging.log4j:log4j-api:2.14.1" level="project" />
+    <orderEntry type="library" name="Maven: org.slf4j:jul-to-slf4j:1.7.32" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.annotation:jakarta.annotation-api:1.3.5" level="project" />
+    <orderEntry type="library" name="Maven: org.yaml:snakeyaml:1.28" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-json:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-databind:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml.jackson.module:jackson-module-parameter-names:2.12.4" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-tomcat:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.tomcat.embed:tomcat-embed-core:9.0.50" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.tomcat.embed:tomcat-embed-websocket:9.0.50" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-web:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-beans:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-webmvc:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-aop:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-context:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-expression:5.3.9" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-starter-test:2.5.3" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-test:2.5.3" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.springframework.boot:spring-boot-test-autoconfigure:2.5.3" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: com.jayway.jsonpath:json-path:2.5.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: net.minidev:json-smart:2.4.7" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: net.minidev:accessors-smart:2.4.7" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.ow2.asm:asm:9.1" level="project" />
+    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.32" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.xml.bind:jakarta.xml.bind-api:2.3.3" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.activation:jakarta.activation-api:1.2.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.assertj:assertj-core:3.19.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.hamcrest:hamcrest:2.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.jupiter:junit-jupiter:5.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.jupiter:junit-jupiter-api:5.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.apiguardian:apiguardian-api:1.1.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.opentest4j:opentest4j:1.2.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.platform:junit-platform-commons:1.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.jupiter:junit-jupiter-params:5.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.jupiter:junit-jupiter-engine:5.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.junit.platform:junit-platform-engine:1.7.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.mockito:mockito-core:3.9.0" level="project" />
+    <orderEntry type="library" name="Maven: net.bytebuddy:byte-buddy:1.10.22" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: net.bytebuddy:byte-buddy-agent:1.10.22" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.objenesis:objenesis:3.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.mockito:mockito-junit-jupiter:3.9.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.skyscreamer:jsonassert:1.5.0" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: com.vaadin.external.google:android-json:0.0.20131108.vaadin1" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-core:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-jcl:5.3.9" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.springframework:spring-test:5.3.9" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.xmlunit:xmlunit-core:2.8.2" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: mysql:mysql-connector-java:8.0.26" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-data-jpa:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-aop:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.aspectj:aspectjweaver:1.9.7" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-jdbc:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: com.zaxxer:HikariCP:4.0.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-jdbc:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.transaction:jakarta.transaction-api:1.3.3" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.persistence:jakarta.persistence-api:2.2.3" level="project" />
+    <orderEntry type="library" name="Maven: org.hibernate:hibernate-core:5.4.32.Final" level="project" />
+    <orderEntry type="library" name="Maven: org.jboss.logging:jboss-logging:3.4.2.Final" level="project" />
+    <orderEntry type="library" name="Maven: org.javassist:javassist:3.27.0-GA" level="project" />
+    <orderEntry type="library" name="Maven: antlr:antlr:2.7.7" level="project" />
+    <orderEntry type="library" name="Maven: org.jboss:jandex:2.2.3.Final" level="project" />
+    <orderEntry type="library" name="Maven: com.fasterxml:classmate:1.5.1" level="project" />
+    <orderEntry type="library" name="Maven: org.dom4j:dom4j:2.1.3" level="project" />
+    <orderEntry type="library" name="Maven: org.hibernate.common:hibernate-commons-annotations:5.1.2.Final" level="project" />
+    <orderEntry type="library" name="Maven: org.glassfish.jaxb:jaxb-runtime:2.3.4" level="project" />
+    <orderEntry type="library" name="Maven: org.glassfish.jaxb:txw2:2.3.4" level="project" />
+    <orderEntry type="library" name="Maven: com.sun.istack:istack-commons-runtime:3.0.12" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: com.sun.activation:jakarta.activation:1.2.2" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.data:spring-data-jpa:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.data:spring-data-commons:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-orm:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-tx:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework:spring-aspects:5.3.9" level="project" />
+    <orderEntry type="library" name="Maven: org.projectlombok:lombok:1.18.20" level="project" />
+    <orderEntry type="library" name="Maven: com.baomidou:mybatis-plus-boot-starter:3.4.2" level="project" />
+    <orderEntry type="library" name="Maven: com.baomidou:mybatis-plus:3.4.2" level="project" />
+    <orderEntry type="library" name="Maven: com.baomidou:mybatis-plus-extension:3.4.2" level="project" />
+    <orderEntry type="library" name="Maven: com.baomidou:mybatis-plus-core:3.4.2" level="project" />
+    <orderEntry type="library" name="Maven: com.baomidou:mybatis-plus-annotation:3.4.2" level="project" />
+    <orderEntry type="library" name="Maven: com.github.jsqlparser:jsqlparser:4.0" level="project" />
+    <orderEntry type="library" name="Maven: org.mybatis:mybatis:3.5.6" level="project" />
+    <orderEntry type="library" name="Maven: org.mybatis:mybatis-spring:2.0.5" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-autoconfigure:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.commons:commons-lang3:3.12.0" level="project" />
+    <orderEntry type="library" name="Maven: commons-lang:commons-lang:2.6" level="project" />
+    <orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.62" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: junit:junit:4.13.2" level="project" />
+    <orderEntry type="library" scope="TEST" name="Maven: org.hamcrest:hamcrest-core:2.2" level="project" />
+    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-validation:2.5.3" level="project" />
+    <orderEntry type="library" name="Maven: org.apache.tomcat.embed:tomcat-embed-el:9.0.50" level="project" />
+    <orderEntry type="library" name="Maven: org.hibernate.validator:hibernate-validator:6.2.0.Final" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.validation:jakarta.validation-api:2.0.2" level="project" />
+    <orderEntry type="library" name="Maven: cn.hutool:hutool-all:5.7.7" level="project" />
+  </component>
+</module>

huimv-smart-incubator/huimv-smart-incubator-data/pom.xml

@@ -0,0 +1,35 @@
+<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>huimv-smart-incubator</artifactId>
+        <groupId>con.huimv</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>huimv-smart-incubator-data</artifactId>
+
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>commons-lang</groupId>
+            <artifactId>commons-lang</artifactId>
+            <version>2.6</version>
+        </dependency>
+    </dependencies>
+
+
+
+
+
+
+</project>

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/HuimvSmartincubatorDataAcquisitionApplication.java

@@ -0,0 +1,38 @@
+package cim.huimv.incubator;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@EnableScheduling     //开启定时任务
+@SpringBootApplication
+public class HuimvSmartincubatorDataAcquisitionApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(HuimvSmartincubatorDataAcquisitionApplication.class, args);
+    }
+
+
+
+
+    //**********************************************************************
+    //运行在41服务器
+    //端口8021
+    //数据库在公司本地
+
+
+
+
+
+
+}
+
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/autoconfigure/MybatisPlusConfiguration.java

@@ -0,0 +1,28 @@
+package cim.huimv.incubator.autoconfigure;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @Author yinhao
+ * @Date 2021/4/27 9:01
+ * @Description
+ */
+@Configuration
+public class MybatisPlusConfiguration {
+
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
+        return interceptor;
+    }
+
+//    @Bean
+//    public ConfigurationCustomizer configurationCustomizer() {
+//        return configuration -> configuration.setUseDeprecatedExecutor(false);
+//    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/AgeStageTempController.java

@@ -0,0 +1,169 @@
+ package cim.huimv.incubator.controller;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.AgeStageTempEntity;
+import cim.huimv.incubator.mapper.AgeStageTempDao;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.AgeStageTempService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+
+ /**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/agestagetemp")
+public class AgeStageTempController {
+    @Autowired
+    private AgeStageTempService ageStageTempService;
+
+
+     @Autowired
+     private AgeStageTempDao ageStageTempDao  ;
+    //修改温度设定
+
+
+     @RequestMapping("/updatevalue")
+     public R updatetemp(HttpServletRequest request,
+                                      @RequestParam(name = "temp") Double temp
+                                    ) throws IOException {
+
+         LambdaQueryWrapper<AgeStageTempEntity> wrapper1 = Wrappers.lambdaQuery();
+         wrapper1.eq(AgeStageTempEntity::getId, 1 );
+         AgeStageTempEntity ageStageTempEntity = ageStageTempDao.selectOne(wrapper1);
+         ageStageTempEntity.setTemp(temp);
+         ageStageTempService.updateById(ageStageTempEntity);
+         return R.ok().put("page",ageStageTempEntity );
+     }
+
+
+
+
+
+
+     @RequestMapping("/list001")
+     public void  list(HttpServletRequest request) {
+
+         for (int i = 1; i < 600  ;i++) {
+
+
+             AgeStageTempEntity ageStageTempEntity = new AgeStageTempEntity();
+             ageStageTempEntity.setAge(i);
+             ageStageTempEntity.setCreateTime(new Date());
+             ageStageTempEntity.setRemark("ceshi");
+             if (0<i&i<100){
+                 ageStageTempEntity.setTemp(24.5);
+                 ageStageTempEntity.setStage(1);
+                 ageStageTempService.save(ageStageTempEntity);
+             }
+             if (100<i&i<200){
+                 ageStageTempEntity.setTemp(25.5);
+                 ageStageTempEntity.setStage(2);
+                 ageStageTempService.save(ageStageTempEntity);
+             }
+             if (200<i &i<300){
+                 ageStageTempEntity.setTemp(26.5);
+                 ageStageTempEntity.setStage(3);
+                 ageStageTempService.save(ageStageTempEntity);
+             }
+             if (300<i&i<600){
+                 ageStageTempEntity.setTemp(27.5);
+                 ageStageTempEntity.setStage(4);
+                 ageStageTempService.save(ageStageTempEntity);
+             }
+
+
+         }
+
+
+
+
+
+
+     }
+
+
+
+
+
+
+
+
+
+
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = ageStageTempService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		AgeStageTempEntity ageStageTemp = ageStageTempService.getById(id);
+
+        return R.ok().put("ageStageTemp", ageStageTemp);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody AgeStageTempEntity ageStageTemp){
+		ageStageTempService.save(ageStageTemp);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody AgeStageTempEntity ageStageTemp){
+		ageStageTempService.updateById(ageStageTemp);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		ageStageTempService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/CollectorRegisterController.java

@@ -0,0 +1,85 @@
+ package cim.huimv.incubator.controller;
+
+import java.util.Arrays;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.CollectorRegisterService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/collectorregister")
+public class CollectorRegisterController {
+    @Autowired
+    private CollectorRegisterService collectorRegisterService;
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = collectorRegisterService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		CollectorRegisterEntity collectorRegister = collectorRegisterService.getById(id);
+
+        return R.ok().put("collectorRegister", collectorRegister);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody CollectorRegisterEntity collectorRegister){
+		collectorRegisterService.save(collectorRegister);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody CollectorRegisterEntity collectorRegister){
+		collectorRegisterService.updateById(collectorRegister);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		collectorRegisterService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/EnvDampnessValueController.java

@@ -0,0 +1,85 @@
+ package cim.huimv.incubator.controller;
+
+import java.util.Arrays;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.EnvDampnessValueEntity;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.EnvDampnessValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/envdampnessvalue")
+public class EnvDampnessValueController {
+    @Autowired
+    private EnvDampnessValueService envDampnessValueService;
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = envDampnessValueService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		EnvDampnessValueEntity envDampnessValue = envDampnessValueService.getById(id);
+
+        return R.ok().put("envDampnessValue", envDampnessValue);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody EnvDampnessValueEntity envDampnessValue){
+		envDampnessValueService.save(envDampnessValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody EnvDampnessValueEntity envDampnessValue){
+		envDampnessValueService.updateById(envDampnessValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		envDampnessValueService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/EnvTempValueController.java

@@ -0,0 +1,85 @@
+ package cim.huimv.incubator.controller;
+
+import java.util.Arrays;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.EnvTempValueEntity;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.EnvTempValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/envtempvalue")
+public class EnvTempValueController {
+    @Autowired
+    private EnvTempValueService envTempValueService;
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = envTempValueService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		EnvTempValueEntity envTempValue = envTempValueService.getById(id);
+
+        return R.ok().put("envTempValue", envTempValue);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody EnvTempValueEntity envTempValue){
+		envTempValueService.save(envTempValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody EnvTempValueEntity envTempValue){
+		envTempValueService.updateById(envTempValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		envTempValueService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/IncubatorDataController.java

@@ -0,0 +1,111 @@
+ package cim.huimv.incubator.controller;
+
+import java.text.ParseException;
+import java.util.Arrays;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.IncubatorDataEntity;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.IncubatorDataService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/incubatordata")
+public class IncubatorDataController {
+    @Autowired
+    private IncubatorDataService incubatorDataService;
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = incubatorDataService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+    @RequestMapping("/list_deatils")
+    public R listDeatils(@RequestParam Map<String, Object> params) throws ParseException {
+        Map queryDetailsMap = incubatorDataService.queryDetails(params);
+        return R.ok().put("page", queryDetailsMap);
+    }
+
+
+
+
+
+
+    //根据耳标电量查询
+    @RequestMapping("/findByConditions")
+    public R findByFarmId( @RequestParam Map<String, Object> params  ) throws ParseException {
+        PageUtils byConditions = incubatorDataService.findByConditions(params);
+
+        return R.ok().put("page", byConditions);
+
+    }
+
+
+
+
+
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		IncubatorDataEntity incubatorData = incubatorDataService.getById(id);
+
+        return R.ok().put("incubatorData", incubatorData);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody IncubatorDataEntity incubatorData){
+		incubatorDataService.save(incubatorData);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody IncubatorDataEntity incubatorData){
+		incubatorDataService.updateById(incubatorData);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		incubatorDataService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/controller/SetTempValueController.java

@@ -0,0 +1,84 @@
+ package cim.huimv.incubator.controller;
+
+import java.util.Arrays;
+import java.util.Map;
+
+import cim.huimv.incubator.entity.SetTempValueEntity;
+import cim.huimv.incubator.result.R;
+import cim.huimv.incubator.service.SetTempValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@RestController
+@RequestMapping("management/settempvalue")
+public class SetTempValueController {
+    @Autowired
+    private SetTempValueService setTempValueService;
+
+    /**
+     * 列表
+     */
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params){
+        PageUtils page = setTempValueService.queryPage(params);
+
+        return R.ok().put("page", page);
+    }
+
+
+    /**
+     * 信息
+     */
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Integer id){
+		SetTempValueEntity setTempValue = setTempValueService.getById(id);
+
+        return R.ok().put("setTempValue", setTempValue);
+    }
+
+    /**
+     * 保存
+     */
+    @RequestMapping("/save")
+    public R save(@RequestBody SetTempValueEntity setTempValue){
+		setTempValueService.save(setTempValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 修改
+     */
+    @RequestMapping("/update")
+    public R update(@RequestBody SetTempValueEntity setTempValue){
+		setTempValueService.updateById(setTempValue);
+
+        return R.ok();
+    }
+
+    /**
+     * 删除
+     */
+    @RequestMapping("/delete")
+    public R delete(@RequestBody Integer[] ids){
+		setTempValueService.removeByIds(Arrays.asList(ids));
+
+        return R.ok();
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/AgeStageTempEntity.java

@@ -0,0 +1,52 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("age_stage_temp")
+public class AgeStageTempEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 
+	 */
+	private Integer age;
+	/**
+	 * 
+	 */
+	private Integer stage;
+	/**
+	 * 
+	 */
+	private Double temp;
+	/**
+	 * 
+	 */
+	private Date createTime;
+	/**
+	 * 
+	 */
+	private String remark;
+	/**
+	 * 
+	 */
+	private String remark1;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/CollectorRegisterEntity.java

@@ -0,0 +1,100 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("collector_register")
+public class CollectorRegisterEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 记录id(主键)
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 设备编码
+	 */
+	private String deviceCode;
+	/**
+	 * 盒子的芯片编码
+	 */
+	private String registeCode;
+	/**
+	 * 地县编码
+	 */
+	private String countyCode;
+	/**
+	 * 区县名
+	 */
+	private String countyName;
+	/**
+	 * 牧场编码
+	 */
+	private String farmCode;
+	/**
+	 * 牧场名称
+	 */
+	private String farmName;
+	/**
+	 * 动物种类
+	 */
+	private Integer typeF;
+	/**
+	 * 阶段
+	 */
+	private Integer stage;
+	/**
+	 * 猪舍id
+	 */
+	private Integer pigpenId;
+	/**
+	 * 单元id
+	 */
+	private Integer unitId;
+	/**
+	 * 上传服务器地址
+	 */
+	private String serverIp;
+	/**
+	 * 端口
+	 */
+	private Integer port;
+	/**
+	 * 注册时间
+	 */
+	private Date registerTime;
+	/**
+	 * 最后上传时间
+	 */
+	private Date lastTime;
+	/**
+	 * 网络通信状态 1:正常、0:异常
+	 */
+	private Integer networkStatus;
+	/**
+	 * 采集状态 默认值 1  1.正常 2.异常
+	 */
+	private Integer acqStatus;
+	/**
+	 * 注销状态 1:正常、0:注销
+	 */
+	private Integer canStatus;
+	/**
+	 * 删除状态 1:正常、0:注销
+	 */
+	private Integer delStatus;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/EnvDampnessValueEntity.java

@@ -0,0 +1,60 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("env_dampness_value")
+public class EnvDampnessValueEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 
+	 */
+	private String head;
+	/**
+	 * 
+	 */
+	private Integer cmd;
+	/**
+	 * 
+	 */
+	private String serious;
+	/**
+	 * 
+	 */
+	private String value;
+	/**
+	 * 
+	 */
+	private String check;
+	/**
+	 * 
+	 */
+	private String tail;
+	/**
+	 * 
+	 */
+	private String remark;
+	/**
+	 * 
+	 */
+	private Date createTime;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/EnvTempValueEntity.java

@@ -0,0 +1,61 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("env_temp_value")
+public class EnvTempValueEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 
+	 */
+	private String head;
+	private String deviceCode;
+	/**
+	 * 
+	 */
+	private Integer cmd;
+	/**
+	 * 
+	 */
+	private Date createTime;
+	/**
+	 * 
+	 */
+	private String serious;
+	/**
+	 * 
+	 */
+	private String value;
+	/**
+	 * 
+	 */
+	private String chexk;
+	/**
+	 * 
+	 */
+	private String tail;
+	/**
+	 * 
+	 */
+	private String remark;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/IncubatorDataEntity.java

@@ -0,0 +1,72 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("incubator_data")
+public class IncubatorDataEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 
+	 */
+	private String head;
+	/**
+	 * 
+	 */
+	private String deviceCode;
+	/**
+	 * 
+	 */
+	private String nodeCode;
+	/**
+	 * 
+	 */
+	private Integer cmd;
+	/**
+	 * 
+	 */
+	private Double tempValue;
+	/**
+	 * 
+	 */
+	private Integer nightRank;
+	/**
+	 * 
+	 */
+	private Integer nowAge;
+	/**
+	 * 
+	 */
+	private Date createTime;
+	/**
+	 * 
+	 */
+	private String checkCode;
+	/**
+	 * 
+	 */
+	private String tail;
+	/**
+	 * 
+	 */
+	private String remark;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/entity/SetTempValueEntity.java

@@ -0,0 +1,64 @@
+package cim.huimv.incubator.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Data
+@TableName("set_temp_value")
+public class SetTempValueEntity implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 
+	 */
+	@TableId
+	private Integer id;
+	/**
+	 * 
+	 */
+	private Double setValue;
+	/**
+	 * 
+	 */
+	private String deviceCode;
+	/**
+	 * 
+	 */
+	private Date createTime;
+	/**
+	 * 
+	 */
+	private Double beforValue;
+	/**
+	 * 
+	 */
+	private Integer age;
+	/**
+	 * 
+	 */
+	private Integer stage;
+	/**
+	 * 
+	 */
+	private String back1;
+	/**
+	 * 
+	 */
+	private String back2;
+	/**
+	 * 
+	 */
+	private String back3;
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/AgeStageTempDao.java

@@ -0,0 +1,22 @@
+package cim.huimv.incubator.mapper;
+
+
+import cim.huimv.incubator.entity.AgeStageTempEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+
+
+@Mapper
+@Repository
+public interface AgeStageTempDao extends BaseMapper<AgeStageTempEntity> {
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/CollectorRegisterDao.java

@@ -0,0 +1,20 @@
+package cim.huimv.incubator.mapper;
+
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Mapper
+@Repository
+public interface CollectorRegisterDao extends BaseMapper<CollectorRegisterEntity> {
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/EnvDampnessValueDao.java

@@ -0,0 +1,18 @@
+package cim.huimv.incubator.mapper;
+
+
+import cim.huimv.incubator.entity.EnvDampnessValueEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Mapper
+public interface EnvDampnessValueDao extends BaseMapper<EnvDampnessValueEntity> {
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/EnvTempValueDao.java

@@ -0,0 +1,17 @@
+package cim.huimv.incubator.mapper;
+
+import cim.huimv.incubator.entity.EnvTempValueEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Mapper
+public interface EnvTempValueDao extends BaseMapper<EnvTempValueEntity> {
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/IncubatorDataDao.java

@@ -0,0 +1,18 @@
+package cim.huimv.incubator.mapper;
+
+
+import cim.huimv.incubator.entity.IncubatorDataEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Mapper
+public interface IncubatorDataDao extends BaseMapper<IncubatorDataEntity> {
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/mapper/SetTempValueDao.java

@@ -0,0 +1,18 @@
+package cim.huimv.incubator.mapper;
+
+
+import cim.huimv.incubator.entity.SetTempValueEntity;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 
+ * 
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Mapper
+public interface SetTempValueDao extends BaseMapper<SetTempValueEntity> {
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/result/R.java

@@ -0,0 +1,58 @@
+package cim.huimv.incubator.result;
+
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class R extends HashMap<String, Object> {
+
+    private static final long serialVersionUID = 1L;
+
+    public R() {
+        put("code", 0);
+        put("msg", "success");
+    }
+
+    public static R error() {
+        return error(500, "未知异常，请联系管理员");
+    }
+
+    public static R error(String msg) {
+        return error(500, msg);
+    }
+
+    public static R error(int code, String msg) {
+        R r = new R();
+        r.put("code", code);
+        r.put("msg", msg);
+        return r;
+    }
+
+    public static R ok(String msg) {
+        R r = new R();
+        r.put("msg", msg);
+        return r;
+    }
+
+    public static R ok(Map<String, Object> map) {
+        R r = new R();
+        r.putAll(map);
+        return r;
+    }
+
+    public static R ok() {
+        return new R();
+    }
+
+    @Override
+    public R put(String key, Object value) {
+        super.put(key, value);
+        return this;
+    }
+
+    public static void main(String[] args) {
+        R r = new R();
+        System.out.println(r);
+
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/result/RRException.java

@@ -0,0 +1,48 @@
+package cim.huimv.incubator.result;
+
+public class RRException extends RuntimeException {
+	private static final long serialVersionUID = 1L;
+	
+    private String msg;
+    private int code = 500;
+    
+    public RRException(String msg) {
+		super(msg);
+		this.msg = msg;
+	}
+	
+	public RRException(String msg, Throwable e) {
+		super(msg, e);
+		this.msg = msg;
+	}
+	
+	public RRException(String msg, int code) {
+		super(msg);
+		this.msg = msg;
+		this.code = code;
+	}
+	
+	public RRException(String msg, int code, Throwable e) {
+		super(msg, e);
+		this.msg = msg;
+		this.code = code;
+	}
+
+	public String getMsg() {
+		return msg;
+	}
+
+	public void setMsg(String msg) {
+		this.msg = msg;
+	}
+
+	public int getCode() {
+		return code;
+	}
+
+	public void setCode(int code) {
+		this.code = code;
+	}
+	
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/result/RRExceptionHandler.java

@@ -0,0 +1,116 @@
+/**
+ * Copyright (c) 2016-2019 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有，侵权必究！
+ */
+
+package cim.huimv.incubator.result;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.dao.DuplicateKeyException;
+import org.springframework.validation.FieldError;
+import org.springframework.validation.ObjectError;
+import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.MissingServletRequestParameterException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.springframework.web.servlet.NoHandlerFoundException;
+
+/**
+ * 异常处理器
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+@RestControllerAdvice
+public class RRExceptionHandler {
+	private Logger logger = LoggerFactory.getLogger(getClass());
+
+	/**
+	 * 处理自定义异常
+	 */
+	@ExceptionHandler(RRException.class)
+	public R handleRRException(RRException e){
+		R r = new R();
+		r.put("code", e.getCode());
+		r.put("msg", e.getMessage());
+		logger.error(e.getMsg(),e);
+		return r;
+	}
+
+	@ExceptionHandler(NoHandlerFoundException.class)
+	public R handlerNoFoundException(Exception e) {
+		logger.error(e.getMessage(), e);
+		return R.error(404, "路径不存在，请检查路径是否正确");
+	}
+
+	@ExceptionHandler(DuplicateKeyException.class)
+	public R handleDuplicateKeyException(DuplicateKeyException e){
+		logger.error(e.toString());
+		String message = e.getCause().getMessage();
+		String[] s = message.split(" ");
+		return R.error(600,s[2].replace("'","") + " 已经存在!");
+	}
+
+//	@ExceptionHandler(AuthorizationException.class)
+//	public R handleAuthorizationException(AuthorizationException e){
+//		logger.error(e.getMessage(), e);
+//		return R.error("没有权限，请联系管理员授权");
+//	}
+//
+//	@ExceptionHandler(value = LimitAccessException.class)
+//	public R handleLimitAccessException(LimitAccessException e) {
+//		logger.error("LimitAccessException", e);
+//		return  R.error(429,e.getMessage());
+//	}
+
+	//当校验失败时，会抛出MethodArgumentNotValidException
+	//输出错误原因到前端
+	@ExceptionHandler(MethodArgumentNotValidException.class)
+	public R handleMethodArgumentNotValidException(MethodArgumentNotValidException ex) {
+		logger.error(ex.getMessage(),ex);
+		StringBuilder sb = new StringBuilder();
+		for(ObjectError error : ex.getBindingResult().getAllErrors()){
+			if(error instanceof FieldError){
+				FieldError e = (FieldError) error;
+				sb.append(e.getField()).append(e.getDefaultMessage()).append(" ");
+			}
+		}
+		return R.error(1001,sb.toString());
+	}
+
+//	@ExceptionHandler(ConstraintViolationException.class)
+//	public R handleConstraintViolationException(ConstraintViolationException e) {
+//		logger.error(e.getMessage(),e);
+//		StringBuilder sb = new StringBuilder();
+//		e.getConstraintViolations().forEach(constraintViolation -> sb.append(constraintViolation.getMessage()).append(" "));
+//		return R.error(1001,sb.toString().substring(0,sb.length() - 1));
+//	}
+
+	@ExceptionHandler(MissingServletRequestParameterException.class)
+	public R handMissingServletRequestParameterException(MissingServletRequestParameterException e) {
+		logger.error(e.getMessage(),e);
+		return R.error(1001,e.getMessage());
+	}
+
+	@ExceptionHandler(DataIntegrityViolationException.class)
+	public R handDataIntegrityViolationException(DataIntegrityViolationException e) {
+		logger.error(e.getMessage(),e);
+		return R.error(1001,e.getCause().getMessage());
+	}
+
+	@ExceptionHandler(HttpRequestMethodNotSupportedException.class)
+	public R handHttpRequestMethodNotSupportedException(HttpRequestMethodNotSupportedException e) {
+		logger.error(e.getMessage(), e);
+		return R.error(1001, e.getMessage());
+	}
+	@ExceptionHandler(Exception.class)
+	public R handleException(Exception e){
+		logger.error(e.getMessage(), e);
+		return R.error();
+	}
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/AgeStageTempService.java

@@ -0,0 +1,21 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.AgeStageTempEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface AgeStageTempService extends IService<AgeStageTempEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/CollectorRegisterService.java

@@ -0,0 +1,20 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface CollectorRegisterService extends IService<CollectorRegisterEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/EnvDampnessValueService.java

@@ -0,0 +1,20 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.EnvDampnessValueEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface EnvDampnessValueService extends IService<EnvDampnessValueEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/EnvTempValueService.java

@@ -0,0 +1,22 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.EnvTempValueEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface EnvTempValueService extends IService<EnvTempValueEntity> {
+
+    default PageUtils queryPage(Map<String, Object> params) {
+        return null;
+    }
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/IncubatorDataService.java

@@ -0,0 +1,26 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.IncubatorDataEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+
+import java.text.ParseException;
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface IncubatorDataService extends IService<IncubatorDataEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+
+
+    Map<String ,Object>    queryDetails( Map<String, Object> params) throws ParseException;
+
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/SetTempValueService.java

@@ -0,0 +1,21 @@
+package cim.huimv.incubator.service;
+
+import cim.huimv.incubator.entity.SetTempValueEntity;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+
+import java.util.Map;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+public interface SetTempValueService extends IService<SetTempValueEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+}
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/AgeStageTempServiceImpl.java

@@ -0,0 +1,35 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.AgeStageTempEntity;
+import cim.huimv.incubator.mapper.AgeStageTempDao;
+import cim.huimv.incubator.service.AgeStageTempService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("ageStageTempService")
+public class AgeStageTempServiceImpl extends ServiceImpl<AgeStageTempDao, AgeStageTempEntity> implements AgeStageTempService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<AgeStageTempEntity> page = this.page(
+                new Query<AgeStageTempEntity>().getPage(params),
+                new QueryWrapper<AgeStageTempEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/CollectorRegisterServiceImpl.java

@@ -0,0 +1,35 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import cim.huimv.incubator.mapper.CollectorRegisterDao;
+import cim.huimv.incubator.service.CollectorRegisterService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+import java.util.Map;
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("collectorRegisterService")
+public class CollectorRegisterServiceImpl extends ServiceImpl<CollectorRegisterDao, CollectorRegisterEntity> implements CollectorRegisterService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<CollectorRegisterEntity> page = this.page(
+                new Query<CollectorRegisterEntity>().getPage(params),
+                new QueryWrapper<CollectorRegisterEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/EnvDampnessValueServiceImpl.java

@@ -0,0 +1,35 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.EnvDampnessValueEntity;
+import cim.huimv.incubator.mapper.EnvDampnessValueDao;
+import cim.huimv.incubator.service.EnvDampnessValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("envDampnessValueService")
+public class EnvDampnessValueServiceImpl extends ServiceImpl<EnvDampnessValueDao, EnvDampnessValueEntity> implements EnvDampnessValueService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<EnvDampnessValueEntity> page = this.page(
+                new Query<EnvDampnessValueEntity>().getPage(params),
+                new QueryWrapper<EnvDampnessValueEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/EnvTempValueServiceImpl.java

@@ -0,0 +1,35 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.EnvTempValueEntity;
+import cim.huimv.incubator.mapper.EnvTempValueDao;
+import cim.huimv.incubator.service.EnvTempValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("envTempValueService")
+public class EnvTempValueServiceImpl extends ServiceImpl<EnvTempValueDao, EnvTempValueEntity> implements EnvTempValueService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<EnvTempValueEntity> page = this.page(
+                new Query<EnvTempValueEntity>().getPage(params),
+                new QueryWrapper<EnvTempValueEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/IncubatorDataServiceImpl.java

@@ -0,0 +1,144 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import cim.huimv.incubator.entity.IncubatorDataEntity;
+import cim.huimv.incubator.mapper.IncubatorDataDao;
+import cim.huimv.incubator.service.IncubatorDataService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import cim.huimv.incubator.socket.eartagrecive.util.StringUtilsWork;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.stereotype.Service;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("incubatorDataService")
+public class IncubatorDataServiceImpl extends ServiceImpl<IncubatorDataDao, IncubatorDataEntity> implements IncubatorDataService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<IncubatorDataEntity> page = this.page(
+                new Query<IncubatorDataEntity>().getPage(params),
+                new QueryWrapper<IncubatorDataEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+
+
+    @Override
+    public Map<String, Object> queryDetails(Map<String, Object> params) throws ParseException {
+
+        String starttime = (String) params.get("startTime");
+        String endtime = (String) params.get("endTime");
+        DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        //格式化传入的时间
+        Date startTime = fmt.parse(starttime);
+        Date   endTime = fmt.parse(endtime);
+        System.out.println("yangdi"+starttime+endtime);
+        LambdaQueryWrapper<IncubatorDataEntity> lambdaQuery = Wrappers.lambdaQuery();
+        //时间
+        lambdaQuery.between(IncubatorDataEntity::getCreateTime,startTime, endTime);
+        List<IncubatorDataEntity> incubatorDataEntities = baseMapper.selectList(lambdaQuery);
+        //生成平均温度 -----如果刚刚转舍就没办法操作了---数据不会立马出来需要等
+        //这样，时间轴
+        Map<String ,Object>    map1 = new HashMap<>();
+        List<String> timeList = new ArrayList<>();
+        List<Double>  tempList = new ArrayList<>();
+        for (IncubatorDataEntity data : incubatorDataEntities) {
+            timeList.add(fmt.format(data.getCreateTime()));
+            tempList.add(data.getTempValue());
+            //sleeptime.add(data.getSleepStatus());    用来存睡眠状态了
+        }
+        map1.put("time",timeList);
+        map1.put("temp",tempList);
+        //对time循环--用contains来处理稍微快一点
+        //map1.put("averangeTemp",averange);
+        //关于耳标存在的位置的信息，这里需要做记录，如果发生位置迁移那么需要将位置迁移信息记录到一张表中
+        return map1;
+    }
+
+}
+ /*   @Override
+    public PageUtils findByConditions(Map<String, Object> params) throws ParseException {
+        String farmID = (String) params.get("farmID");//牧场编码
+        String starttime = (String) params.get("starttime");//开始时间
+        String endtime = (String) params.get("endtime");//结束时间
+        String eartagNo = (String) params.get("eartagNo");//耳标号
+        String dayAge = (String) params.get("dayAge");//配标日龄
+        String highEartagTemp = (String) params.get("highEartagTemp");//耳标温度
+        String lowEartagTemp = (String) params.get("lowEartagTemp");//耳标温度
+        String highEnvTemp = (String) params.get("highEnvTemp");//环境温度
+        String lowEnvTemp = (String) params.get("lowEnvTemp");//环境温度
+        String deviceCode = (String) params.get("deviceCode");//采集器编码
+        String bat = (String) params.get("bat");//电量
+        String dayAge2 = (String) params.get("dayage2");//日龄
+
+        System.out.println("采集器+condition---"+deviceCode+"耳标号"+eartagNo);
+        //只要首页限制在第一页，其余的不需要的
+
+        LambdaQueryWrapper<IncubatorDataEntity> wrapper = Wrappers.lambdaQuery();
+
+        if(StringUtilsWork.isNotBlank(starttime)&StringUtilsWork.isNotBlank(endtime)) {
+            System.out.println(starttime+"***shijian**"+endtime);
+            DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            //格式化传入的时间
+            Date startTime = fmt.parse(starttime);
+            Date endTime = fmt.parse(endtime);
+            System.out.println("yangdi" + starttime + endtime);
+            //过滤时间
+            wrapper.between(IncubatorDataEntity::getCreateTime, startTime, endTime);
+        }
+
+        wrapper.orderByDesc( IncubatorDataEntity::getId );
+
+         List<IncubatorDataEntity> records;
+        IPage<IncubatorDataEntity>  page;
+
+       if(StringUtilsWork.isNotBlank(eartagNo)){
+            System.out.println("有耳标号，展示耳标所有数据");
+            page = this.page((new Query<IncubatorDataEntity>().getPage(params)),wrapper);
+            records = page.getRecords();  //获取信息
+
+        }else{
+            System.out.println("没有耳标号，展示最新");
+            wrapper.groupBy(EartagDataEntity::getEartagNo);
+            page = baseMapper.page(new Query<EartagDataEntity>().getPage(params), wrapper);
+            records = page.getRecords();  //获取信息
+        }
+
+
+    page = this.page((new Query<IncubatorDataEntity>().getPage(params)),wrapper);
+    records = page.getRecords();  //获取信息
+
+        //拼接栋舍信息在里面
+        for (IncubatorDataEntity record : records)
+
+        }
+        return  new PageUtils(page);
+    }
+*/
+
+
+
+
+
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/service/impl/SetTempValueServiceImpl.java

@@ -0,0 +1,35 @@
+package cim.huimv.incubator.service.impl;
+
+import cim.huimv.incubator.entity.SetTempValueEntity;
+import cim.huimv.incubator.mapper.SetTempValueDao;
+import cim.huimv.incubator.service.SetTempValueService;
+import cim.huimv.incubator.socket.eartagrecive.util.PageUtils;
+import cim.huimv.incubator.socket.eartagrecive.util.Query;
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+/**
+ * 
+ *
+ * @author yinhao
+ * @version ${version}
+ * @date 2021-08-11 18:05:50
+ */
+@Service("setTempValueService")
+public class SetTempValueServiceImpl extends ServiceImpl<SetTempValueDao, SetTempValueEntity> implements SetTempValueService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        IPage<SetTempValueEntity> page = this.page(
+                new Query<SetTempValueEntity>().getPage(params),
+                new QueryWrapper<SetTempValueEntity>()
+        );
+
+        return new PageUtils(page);
+    }
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/Server.java

@@ -0,0 +1,43 @@
+package cim.huimv.incubator.socket;
+
+import cim.huimv.incubator.socket.eartagrecive.service.IClientDataPacketService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+@Component
+public class Server implements CommandLineRunner {
+
+    @Autowired
+    private IClientDataPacketService iClientDataPacketService;
+
+    @Override
+    public void run(String... args) throws Exception {
+        try {
+
+            // 初始化服务端socket连接， 并监听8888端口的socket请求
+            ServerSocket serverSocket = new ServerSocket(8899);
+
+            System.out.println("****** I am Server, now begin to wait the client ******");
+
+            int count = 0;
+            // 处理socket请求
+            Socket socket = null;
+            while (true) {
+                socket = serverSocket.accept();
+                ServerThread serverThread = new ServerThread(socket, iClientDataPacketService);
+                System.out.println("client host address is: " + socket.getInetAddress().getHostAddress());
+                serverThread.start();
+                count++;
+                System.out.println("now client count is: " + count);
+
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/ServerThread.java

@@ -0,0 +1,79 @@
+package cim.huimv.incubator.socket;
+
+
+import cim.huimv.incubator.socket.eartagrecive.service.IClientDataPacketService;
+
+import java.io.*;
+import java.net.Socket;
+import java.text.ParseException;
+
+//@Component
+public class ServerThread extends Thread {
+
+    private Socket socket;
+   // @Autowired
+    private IClientDataPacketService iClientDataPacketService;
+
+    public ServerThread(Socket socket,IClientDataPacketService iClientDataPacketService) {
+        this.socket = socket;
+        this.iClientDataPacketService = iClientDataPacketService;
+    }
+
+    @Override
+    public void run() {
+        InputStream inputStream = null;
+        InputStreamReader inputStreamReader = null;
+        BufferedReader bufferedReader = null;
+        OutputStream outputStream = null;
+        PrintWriter printWriter = null;
+
+        try {
+
+            // server接收消息
+            inputStream = socket.getInputStream();
+            inputStream = socket.getInputStream();
+            byte[] b = new byte[1024];
+            inputStream.read(b);
+            String packet = new String(b);
+
+            int i = packet.indexOf("+", packet.indexOf("+") + 1);
+            //int ver = Integer.parseInt(packet.substring(i + 1, i + 2));
+            outputStream = socket.getOutputStream();
+            packet = packet.trim();
+            // 处理数据包
+             String ss = iClientDataPacketService.handleClientSendPacket(packet);
+
+            outputStream.write(ss.getBytes());
+
+            socket.shutdownInput();
+
+        } catch (IOException | ParseException e) {
+            e.printStackTrace();
+        } finally {
+            // 关闭资源
+            try {
+                if (printWriter != null) {
+                    printWriter.close();
+                }
+                if (outputStream != null) {
+                    outputStream.close();
+
+                }
+                if (bufferedReader != null) {
+                    bufferedReader.close();
+                }
+                if (inputStreamReader != null) {
+                    inputStreamReader.close();
+                }
+                if (inputStream != null) {
+                    inputStream.close();
+                }
+                if (socket != null) {
+                    socket.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/constant/ImportanteConfig.java

@@ -0,0 +1,14 @@
+package cim.huimv.incubator.socket.eartagrecive.constant;
+
+/**
+ * @Author Anchor
+ * @Date 2021/7/30 13:47
+ * //重要的参数配置，包括定时任务等
+ * @Version 1.0.1
+ */
+public class ImportanteConfig {
+
+
+
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/service/IClientDataPacketService.java

@@ -0,0 +1,14 @@
+package cim.huimv.incubator.socket.eartagrecive.service;
+
+import java.text.ParseException;
+
+
+public interface IClientDataPacketService {
+
+    // 解析客户端数据包
+    public String handleClientSendPacket(String clientMessage) throws ParseException;
+
+
+
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/service/impl/ClientDataPacketServiceImpl.java

@@ -0,0 +1,85 @@
+package cim.huimv.incubator.socket.eartagrecive.service.impl;
+
+
+import cim.huimv.incubator.socket.eartagrecive.service.IClientDataPacketService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.ParseException;
+
+/**
+ * @Project : huimv.ql
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+
+@Service
+@Slf4j
+public class ClientDataPacketServiceImpl implements IClientDataPacketService {
+
+    @Autowired
+    private ReceivePackageSerivce receivePackageSerivce;
+
+    @Autowired
+    private SendPackageService sendPackageService;
+
+    //现在没有判断了，数据直接处理.上传的数据单一，只有耳标数据
+    @Override
+    public String handleClientSendPacket(String clientMessageTxt) throws ParseException {
+        if (clientMessageTxt == null || clientMessageTxt.isEmpty()) {
+            log.error("本地提交数据包为空.");
+            return  "null"    ;
+        }
+        String matcher = "[+]";
+        String[] clientMessageArray = clientMessageTxt.split(matcher);
+        String cmd = clientMessageArray[2];
+        String  stranger_cmd = clientMessageArray[3];
+
+        String  codHead = clientMessageArray[0];  //zj----hm----两种情况
+        log.info("本次执行命令>>" + cmd);
+        System.out.println(clientMessageTxt.toString());
+        StringBuilder echoResultSb = new StringBuilder();
+        // 校验后边再做；
+        //现在加一个判断  分为  hm和 zj
+       // hm+9599+87021538+5+274+0+100+20210811172946+0+end
+
+
+
+
+
+        if (Integer.parseInt(cmd) == 1) {
+            // 绑定序列号返回的设备id
+            System.out.println("处理1命令");
+            return sendPackageService.getDeviceId(clientMessageArray);
+        } else if (Integer.parseInt(cmd) == 2) {
+            System.out.println("处理2命令");
+            // 处理获取服务器时间
+            return sendPackageService.getServerDateTime(clientMessageArray);
+        } else if (Integer.parseInt(cmd) == 3) {
+            System.out.println("处理3命令");
+            // 处理心跳包
+            return sendPackageService.getHeartbeatBag(clientMessageArray);
+        } else if (Integer.parseInt(cmd) == 4) {
+            // 处理温度上传
+            return receivePackageSerivce.handleEartagTemperature(clientMessageArray);
+        } else if (Integer.parseInt(stranger_cmd)== 5) {
+            // 处理湿度上传
+            return receivePackageSerivce.handleEartagDampness(clientMessageArray);
+        } /*else if (Integer.parseInt(cmd) == 6) {     //不会出现等于6了。数据到此为止，为6的换成了zj
+            // 处理耳标数据
+            System.out.println("处理耳标数据");
+            System.out.println(clientMessageTxt);
+            return receivePackageSerivce.handleEartagData(clientMessageArray).toString();
+       }*/
+        else {
+            log.error("出错：当前命令cmd>>[" + cmd + "]未做任何处理.");
+            return  "null";
+        }
+        }
+    }
+
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/service/impl/ReceivePackageSerivce.java

@@ -0,0 +1,383 @@
+package cim.huimv.incubator.socket.eartagrecive.service.impl;
+
+import cim.huimv.incubator.entity.AgeStageTempEntity;
+import cim.huimv.incubator.entity.EnvTempValueEntity;
+import cim.huimv.incubator.entity.IncubatorDataEntity;
+import cim.huimv.incubator.mapper.AgeStageTempDao;
+import cim.huimv.incubator.service.EnvTempValueService;
+import cim.huimv.incubator.service.IncubatorDataService;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.text.DecimalFormat;
+import java.text.NumberFormat;
+import java.text.ParseException;
+import java.util.Date;
+
+;
+
+/**
+ * @Project : huimv.ql
+ * @Package : com.huimv.biosafety.uface.controller
+ * @Description : TODO
+ * @Version : 1.0
+ * @Author : ZhuoNing
+ * @Create : 2020-12-25
+ **/
+@Slf4j
+@Component
+public class ReceivePackageSerivce {
+
+@Autowired
+
+private IncubatorDataService incubatorDataService;
+    @Autowired
+
+    private EnvTempValueService envTempValueService ;
+
+    @Autowired
+
+    private AgeStageTempDao ageStageTempDao  ;
+
+
+
+
+
+
+
+    public String handleEartagData(String[] clientMessageArray) throws ParseException {
+      /*  log.info("开始添加耳标数据......");
+        String  head = clientMessageArray[0];           //命令头
+        String device_code = clientMessageArray[1];      //采集器ID
+        String eartag_no  = clientMessageArray[2];         //版本号
+        String bat = clientMessageArray[3];        //耳标号
+        String ear_temp = clientMessageArray[4];  //耳标帧序号
+        String env_temp = clientMessageArray[5];
+        int exercise = Integer.parseInt(clientMessageArray[6]);         //运动量
+        //重启次数
+        String rssi  = clientMessageArray[7];           //信号强度
+        String  time = clientMessageArray[8];           //采集时间
+        String prepare_field= clientMessageArray[9];    //耳标温度
+
+        String[] split = prepare_field.split("#");//1.0#1.0#9314   --耳标版本--网关版本--电阻值（用来计算环境温度）
+        String  check = clientMessageArray[10];          //校验码
+        String  tail  = clientMessageArray[11];          //命令尾
+        EartagDataEntity eartagDataEntity = new EartagDataEntity();
+
+        eartagDataEntity.setHead(head);   //命令头
+        eartagDataEntity.setDeviceCode(device_code); //采集器ID
+         eartagDataEntity.setVersion(split[0]);  //耳标版本
+         eartagDataEntity.setCommand(split[1]);  //网关版本
+
+        eartagDataEntity.setEartagNo(eartag_no);  //耳标号
+       // eartagDataEntity.setFrameSerialNo(Integer.parseInt(frame_serial_no));   //耳标帧序号
+        eartagDataEntity.setBat(Integer.parseInt(bat));   //电池 电量
+        DecimalFormat df = new DecimalFormat("####0.00");
+        double setEarTemp11 = Double.parseDouble(df.format(ln(Integer.parseInt(split[2]))));
+        eartagDataEntity.setEarTemp(Double.parseDouble( df.format( ln(Integer.parseInt(split[2]))))) ;  //ntc转环境温度
+        eartagDataEntity.setEnvTemp(  Double.parseDouble(new DecimalFormat("#,##0.00").format(( Double.parseDouble(env_temp)/100))));   //环境温度--转doubbo
+        //System.out.println( ln(Integer.parseInt(prepare_field)));//----25.001
+        System.out.println(Double.parseDouble(env_temp)/100);
+
+        eartagDataEntity.setExercise(exercise);//运动量
+       //eartagDataEntity.setRebootTimes(Integer.parseInt(reboot_times));  //重启次数
+        eartagDataEntity.setRssi(Integer.parseInt(rssi));//信号强度
+        eartagDataEntity.setTime( DateUtilsPublic.parseDateTime(DateUtilsPublic.buildDateTimeString(time)) ); //采集时间
+        eartagDataEntity.setPrepareField(prepare_field); //预留字段 4
+        eartagDataEntity.setChk(check); //校验码
+        eartagDataEntity.setTail(tail);//命令尾
+       //判断年猪表中是否有这一只耳标的数据   //栋舍这个字段在注册表中没有登记，在
+        LambdaQueryWrapper<CollectorRegisterEntity> wrapper1 = Wrappers.lambdaQuery();
+        wrapper1.eq(CollectorRegisterEntity::getDeviceCode, device_code );
+        CollectorRegisterEntity collectorRegisterEntity = collectorRegisterDao.selectOne(wrapper1);
+        if (collectorRegisterEntity==null){//设备没注册就不让他存，基础信息都没有
+            System.out.println("设备登记表中没有此设备信息，请先注册");
+            return "设备登记表中没有此设备信息，请先注册";
+        }
+
+       //查看这个耳标绑定的基站编码
+        LambdaQueryWrapper<EartagRegisterEntity> wrapper3 = Wrappers.lambdaQuery();
+        wrapper3.eq(EartagRegisterEntity::getEartagNo, eartag_no );
+        EartagRegisterEntity eartagRegisterEntity = eartagRegisterDao.selectOne(wrapper3);
+        System.out.println( "zhece xinxi "+eartagRegisterEntity+"ooo"+eartag_no+"ooo"+device_code);
+
+       // String deviceCode = eartagRegisterEntity.getDeviceCode();//---获取这个基站的编码
+       // System.out.println(deviceCode);
+
+        //wendu cha dayu 8
+      *//*  if(Double.parseDouble(env_temp)/100==0){
+            //与注册表不同，，不存
+            System.out.println("丢弃");
+            return "hm+6+0+6+end";
+        }*//*
+        System.out.println("存储");
+        //日龄
+        eartagDataEntity.setDayAge2(eartagRegisterEntity.getAge());
+        //上传设备发生了变化，      转舍信息进行存储
+        //在接受数据的时候加一条记录迁移信息的数据到一个新表中，方便查找
+        eartagDataEntity.setStage(collectorRegisterEntity.getStage()); //获取阶段
+        eartagDataEntity.setPigpen(String.valueOf(collectorRegisterEntity.getPigpenId())); //获取猪舍ID
+        eartagDataEntity.setFarmCode(collectorRegisterEntity.getFarmCode());//获取牧场编码
+         //关于两个日龄的处理--不应该是直接增加，应该是判断上一条的“日”和当前是否相同 ，相同不增加，不相同增加
+
+
+        LambdaQueryWrapper<EartagDataEntity> wrapper = Wrappers.lambdaQuery();
+        wrapper.eq(EartagDataEntity::getEartagNo, eartag_no ).orderByDesc( EartagDataEntity::getId ).last( "limit 1");
+        EartagDataEntity   lastEarTagDate = eartagDataDao.selectOne(wrapper);
+        //返回的数据在这里为空--说明这个是第一次上传--需要存储一条device_code 为空的注册表
+       if(lastEarTagDate==null){//上一条为空，存转舍
+           LambdaQueryWrapper<EartagRegisterEntity> wrapper4 = Wrappers.lambdaQuery();
+           wrapper4.eq(EartagRegisterEntity::getEartagNo, eartag_no );
+           EartagRegisterEntity eartagRegisterEntity1 = eartagRegisterDao.selectOne(wrapper4);
+
+           MovePigpenEntity movePigpenEntity = new MovePigpenEntity();
+           movePigpenEntity.setDeviceCode(device_code);
+           movePigpenEntity.setEartagNo(eartag_no);
+           movePigpenEntity.setMoveDate(DateUtilsPublic.parseDateTime(DateUtilsPublic.buildDateTimeString(time)));
+           movePigpenEntity.setStage(collectorRegisterEntity.getStage());
+           movePigpenService.save(movePigpenEntity);
+           if(eartagRegisterEntity1==null){
+             //说明之前没有注册过--现在注册一下--设备ID的设置留给定时任务
+               EartagRegisterEntity eartagRegisterEntity2 = new EartagRegisterEntity();
+               eartagRegisterEntity2.setAge(0);
+               eartagRegisterEntity2.setDeviceCode(null);
+               eartagRegisterEntity2.setEartagNo(eartag_no);
+               eartagRegisterEntity2.setFarmCode(null);//定时任务获取到机器ID后处理
+               eartagRegisterEntity2.setPigpen( null);
+               eartagRegisterEntity2.setRegisterDate(new Date());
+               eartagRegisterEntity2.setStage(null);
+               eartagRegisterService.save(eartagRegisterEntity2);//存储一条还没有处理的数据
+           }
+
+           //第一次上传的数据----注册表肯定没有这只耳标的信息
+         *//*  eartagDataEntity.setDayAge (0);  //佩标日龄----默认值，第一次有数据上传就是默认值
+           eartagDataEntity.setDayAge2(50); //日龄----默认第50天佩戴耳标*//*
+           eartagDataEntity.setExercise(exercise);
+           eartagDataEntity.setSportGap(2);
+           eartagDataService.save(eartagDataEntity);
+           return "hm+6+0+6+end";
+     }
+
+        if(!eartagRegisterEntity.getDeviceCode().equals(device_code) ){
+            //与注册表不同，，不存
+            System.out.println("丢弃");
+            return "hm+6+0+6+end";
+
+        }
+
+
+      if( Double.parseDouble(new DecimalFormat("#,##0.00").format(( Double.parseDouble(env_temp)/100))) <1.0){
+          //与注册表不同，，不存
+          System.out.println("丢弃环境温度为0");
+          return "hm+6+0+6+end";
+      }
+
+
+        if( device_code.equals("112007239999996")){
+            //这个基站的数据不要了
+            System.out.println("丢弃环境温度为0");
+            return "hm+6+0+6+end";
+        }
+
+//202007239999123
+
+        //上一条不为空---而且判断是存储注册表device-code
+        //存储转舍信息--还要判断新的设备阶段和老的设备阶段是否相同，如果相同就不存储转舍信息
+        if(!lastEarTagDate.getDeviceCode().equals(device_code)){
+           *//* LambdaQueryWrapper<EartagRegisterEntity> wrapper4 = Wrappers.lambdaQuery();
+            wrapper4.eq(EartagRegisterEntity::getEartagNo, eartag_no );
+            EartagRegisterEntity eartagRegisterEntity1 = eartagRegisterDao.selectOne(wrapper4);//查到注册信息--有可能为空的
+            String deviceCode = eartagRegisterEntity1.getDeviceCode();
+            if ( StringUtilsWork.isNotBlank(deviceCode) ) {//如果耳标注册表的绑定机器ID为空就不存储转舍信息
+                System.out.println("之前=" + lastEarTagDate.getDeviceCode() + "现在" + device_code);
+                System.out.println(lastEarTagDate.getDeviceCode().equals(device_code));
+                 //上一阶段的
+                if(!lastEarTagDate.getStage().equals(collectorRegisterEntity.getStage())) {  //不相等，---判断阶段是否相同--阶段也不相同--增加转舍信息
+
+                    MovePigpenEntity movePigpenEntity = new MovePigpenEntity();
+                    movePigpenEntity.setDeviceCode(device_code);
+                    movePigpenEntity.setEartagNo(eartag_no);
+                    movePigpenEntity.setMoveDate(DateUtilsPublic.parseDateTime(DateUtilsPublic.buildDateTimeString(time)));
+                    movePigpenEntity.setStage(collectorRegisterEntity.getStage());
+                    movePigpenService.save(movePigpenEntity);
+                }
+            }*//*
+        }
+        Integer exercise1 = lastEarTagDate.getExercise();
+        eartagDataEntity.setSportGap(exercise - exercise1);//存储区间运动量
+        //获取当前时间的 “天”---判断天的情况
+        int dayNow= Integer.parseInt(String.format("%td", DateUtilsPublic.parseDateTime(DateUtilsPublic.buildDateTimeString(time))));   //当前上传数据的天
+        int dayLastData= Integer.parseInt(String.format("%td",lastEarTagDate.getTime()));     //当前的天
+        System.out.println("当天时间="+dayNow+"----上一条时间"+dayLastData);
+
+
+
+
+           if( dayNow == dayLastData){
+               //若相等，沿用上一条的日龄和配标日龄
+               eartagDataEntity.setDayAge (lastEarTagDate.getDayAge());  //佩标日龄
+               eartagDataEntity.setDayAge2(lastEarTagDate.getDayAge2()); //日龄
+            }else {
+               //有数据，若 “日” 不相等是否应该增加一天
+               eartagDataEntity.setDayAge (lastEarTagDate.getDayAge()+1 );  //佩标日龄
+               eartagDataEntity.setDayAge2(lastEarTagDate.getDayAge2()+1 ); //日龄
+           }
+
+           //设置最后一次上传时间
+        collectorRegisterEntity.setLastTime(new Date());
+        collectorRegisterService.updateById(collectorRegisterEntity);
+
+        eartagDataService.save(eartagDataEntity);*/
+        return "hm+6+0+6+end";
+    }
+
+
+
+
+    public static void main(String[] args) {
+        DecimalFormat df = new DecimalFormat("####0.00");
+
+        System.out.println(df.format(23.00000));
+    }
+
+    public static  double getTwoDecimal(double num) {
+        DecimalFormat   dFormat = new DecimalFormat("#.00");
+        String yearString = dFormat.format(num);
+        return  Double.parseDouble(yearString);
+
+    }
+
+
+
+    public static  double  m1(double num ) {
+        BigDecimal bg = new BigDecimal(num);
+        return  bg.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
+    }
+
+
+
+
+    public static String swapHex(String src) {
+        StringBuilder target = new StringBuilder();
+        for (int i = src.length() - 1; i > 0; i -= 2) {
+            target.append(src.substring(i - 1, i + 1));
+        }
+        return target.toString();
+    }
+    public static String numberFormater(double d) {
+        DecimalFormat nf = new DecimalFormat();
+        nf.setMaximumFractionDigits(2);
+        return nf.format(d);
+    }
+    public static double A = 0.00335396319311466;
+    public static double B = 0.000256376549039663;
+    public static double C = 0.00000248933580817244;
+    public static double D = 0.0000000753805242068686;
+    public static double E = -0.0000000204758173596178;
+
+    //保留一位小数
+    public static double changeDouble(Double dou) {
+        NumberFormat nf = new DecimalFormat("0.0 ");
+        dou = Double.parseDouble(nf.format(dou));
+        return dou;
+    }
+
+
+
+    //温度转换
+    public static double ln(int rv) {
+        int R_REF = 10000;
+        double ln = Math.log((double) rv / R_REF);
+        //保留一位小数
+        return changeDouble(1 / (A + B * ln + C * Math.pow(ln, 2) + D * Math.pow(ln, 3) + E * Math.pow(ln, 4)) - 273.15)+0.001;
+    }
+
+    public String handleEartagDampness(String[] clientMessageArray) throws ParseException {
+
+
+        //hm+9599+87021538+5+278+0+100+20210811172918+0+end
+
+        String header = clientMessageArray[0];//hm
+        String deviceId = clientMessageArray[1];//9599
+        String cmd = clientMessageArray[3];//5
+        String node_code = clientMessageArray[2];//87021538
+        String temp_value = clientMessageArray[4];//278
+        String night_rank = clientMessageArray[5];//0 暖光登记
+        String now_age = clientMessageArray[6];//当前日龄
+        String time = clientMessageArray[7]; //shijian 20210811172918
+        String checkCode = clientMessageArray[8]; //check
+        String tail = clientMessageArray[9]; //tail
+        IncubatorDataEntity incubatorDataEntity = new IncubatorDataEntity();
+
+        incubatorDataEntity.setCheckCode(checkCode);
+        incubatorDataEntity.setCmd(Integer.valueOf(cmd));
+        incubatorDataEntity.setCreateTime(new Date());
+        incubatorDataEntity.setDeviceCode(deviceId);
+        incubatorDataEntity.setHead(header);
+        incubatorDataEntity.setNowAge(Integer.valueOf(now_age));
+        incubatorDataEntity.setNightRank(Integer.valueOf(night_rank));
+        incubatorDataEntity.setNodeCode(node_code);
+        incubatorDataEntity.setRemark("ceshi");
+        incubatorDataEntity.setTempValue(Double.valueOf(temp_value)/10);
+        incubatorDataEntity.setTail(tail);
+        incubatorDataService.save(incubatorDataEntity);
+
+
+   //返回的数据做文章--温度的设置---查对应日龄的温度  100---用第一条来计算温度.修改的就是第一条温度
+        LambdaQueryWrapper<AgeStageTempEntity> wrapper1 = Wrappers.lambdaQuery();
+        wrapper1.eq(AgeStageTempEntity::getId, 1 );
+        System.out.println(now_age);
+        AgeStageTempEntity ageStageTempEntity = ageStageTempDao.selectOne(wrapper1);
+        System.out.println(ageStageTempEntity);
+         Integer a = (int) (ageStageTempEntity.getTemp()*10);
+
+        System.out.println("五号命令返回+"+"hm+5+"+node_code+"+0+5+"+a+"+6+end" );
+        return  "hm+5+"+node_code+"+0+5+"+a+"+6+end";
+    }
+
+
+
+
+
+    /**
+     * @Method : _handleEartagTemperature
+     * @Description : 处理网关温度
+     * @Params : [clientMessageArray]
+     * @Return : java.lang.String
+     * @Author : ZhuoNing
+     * @Date : 2021/1/15
+     * @Time : 17:46
+     */
+    public String handleEartagTemperature(String[] clientMessageArray) throws ParseException {
+        System.out.println("环境温度上传");
+
+
+
+        String header = clientMessageArray[0];
+        String device_code = clientMessageArray[1];
+        String cmd = clientMessageArray[2];
+        String serialNo = clientMessageArray[3];
+        String temp_value = clientMessageArray[4];
+        String timestamp = clientMessageArray[5];
+        String checkCode = clientMessageArray[6];
+        String tail = clientMessageArray[7];
+     //hm+158+3+1+289+20170208152300+6+end
+        EnvTempValueEntity envTempValueEntity = new EnvTempValueEntity();
+        envTempValueEntity.setCmd(Integer.valueOf(cmd));
+        envTempValueEntity.setChexk(checkCode);
+        envTempValueEntity.setHead(header);
+        envTempValueEntity.setDeviceCode(device_code);
+        envTempValueEntity.setCreateTime(new Date());
+        envTempValueEntity.setRemark("环境温度");
+        envTempValueEntity.setValue(String.valueOf(Double.valueOf(temp_value)/10));
+        envTempValueEntity.setSerious(serialNo);
+        envTempValueEntity.setTail(tail);
+        envTempValueService.save(envTempValueEntity);
+    return "hm+4+0+7+end";
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/service/impl/SendPackageService.java

@@ -0,0 +1,85 @@
+package cim.huimv.incubator.socket.eartagrecive.service.impl;
+
+
+import cim.huimv.incubator.entity.CollectorRegisterEntity;
+import cim.huimv.incubator.mapper.CollectorRegisterDao;
+import cim.huimv.incubator.socket.eartagrecive.util.DateUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+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 SendPackageService {
+
+    @Autowired
+    private CollectorRegisterDao collectorRegisterDao;
+
+    /**
+     * @Method      : _handleGetDeviceId
+     * @Description : 获取设备id
+     * @Params      : [clientMessageArray]
+     * @Return      : java.lang.String
+     * @Author      : ZhuoNing
+     * @Date        : 2021/1/15
+     * @Time        : 17:41
+     */
+    public String getDeviceId(String[] clientMessageArray) {
+        String serialNo = clientMessageArray[1];
+        System.out.println("serialNo>>"+serialNo);
+        // 查询机器id 没有查询了，取消
+        // String jqid = jqidService.findDeviceIdByJQcode(serialNo);
+        // hm+202007239999123+4+1+243+20210729161101+0+end
+        LambdaQueryWrapper<CollectorRegisterEntity> wrapper1 = Wrappers.lambdaQuery();
+        wrapper1.eq(CollectorRegisterEntity::getRegisteCode, serialNo );
+        CollectorRegisterEntity collectorRegisterEntity = collectorRegisterDao.selectOne(wrapper1);
+        System.out.println("芯片编码为====>"+serialNo);
+        //520---站点ID--现在随便写
+         if(collectorRegisterEntity==null){
+             //注册失败的标志
+             return    "hm+1+1+158+123+8+end";
+             //         hm+1+0+158+123+8+end
+         }
+        System.out.println("进入注册"+"hm+1+0+"+collectorRegisterEntity.getDeviceCode()+"+123+8+end");
+        return "hm+1+0+"+collectorRegisterEntity.getDeviceCode()+"+123+8+end";
+    }
+
+    /**
+     * @Method      : _handleGetServerDateTime
+     * @Description : 获取获取服务器日期时间
+     * @Params      : [clientMessageArray]
+     * @Return      : java.lang.Strin
+     * @Author      : ZhuoNing
+     * @Date        : 2021/1/15
+     * @Time        : 17:38
+     */
+    public String getServerDateTime(String[] clientMessageArray) {
+        //
+        String formatNow = DateUtil.getNowWithDigital();
+       // hm+2+20170203094133+4+end
+        return "hm+2+"+formatNow+"+4+end";
+    }
+
+
+    /**
+     * @Method      : _handleGetHeartbeatBag
+     * @Description : 获取心跳包
+     * @Params      : [clientMessageArray]
+     * @Return      : java.lang.String
+     *
+     * @Author      : ZhuoNing
+     * @Date        : 2021/1/15
+     * @Time        : 17:38
+     */
+    public String getHeartbeatBag(String[] clientMessageArray) {
+        return "hm+3+0+6+end";
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/DateUtil.java

@@ -0,0 +1,81 @@
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Locale;
+
+public class DateUtil {
+
+    public DateUtil() {
+    }
+
+    public static String getNowWithDigital() {
+        Date now = new Date();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        return sdf.format(now).replaceAll("-", "").replaceAll(" ", "").replaceAll(":", "");
+    }
+
+
+    public static String buildDateTimeString(String formatContent) {
+        String year = formatContent.substring(0, 4);
+        String month = formatContent.substring(4, 6);
+        String day = formatContent.substring(6, 8);
+        String hour = formatContent.substring(8, 10);
+        String minute = formatContent.substring(10, 12);
+        String seconds = formatContent.substring(12, 14);
+        StringBuilder dateTimeSb = new StringBuilder();
+        return dateTimeSb.append(year).append("-").append(month).append("-").append(day).append(" ").append(hour).append(":").append(minute).append(":").append(seconds).toString();
+    }
+
+    public static String buildDateString(String formatContent) {
+        String year = formatContent.substring(0, 4);
+        String month = formatContent.substring(4, 6);
+        String day = formatContent.substring(6, 8);
+        String dateTime = year + "-" + month + "-" + day;
+        return dateTime;
+    }
+
+    public static String formatDateTime(String date) {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:SS");
+        return sdf.format(date);
+    }
+
+    public static Date parseDateTime(String date) throws ParseException {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        return sdf.parse(date);
+    }
+
+    public String getToday() {
+        DateFormat df3 = DateFormat.getDateInstance(2, Locale.CHINA);
+        return df3.format(new Date());
+    }
+
+    public static void main(String[] args) {
+         DateUtil dateUtil=new DateUtil();
+        System.out.println(dateUtil.getToday());
+         String a = dateUtil.getToday();
+        System.out.println(a);
+
+
+
+    }
+
+    public String formatDate(Date date) {
+        DateFormat df3 = DateFormat.getDateInstance(2, Locale.CHINA);
+        return df3.format(date);
+    }
+
+
+
+    public String beforeTime(int times) {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(11, calendar.get(11) - times);
+        String endTime = sdf.format(calendar.getTime());
+        System.out.println("提前3小时：" + endTime);
+        return endTime;
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/DateUtilsPublic.java

@@ -0,0 +1,259 @@
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Locale;
+
+/**
+ * 日期转换工具
+ * @author guojian
+ */
+public class DateUtilsPublic {
+
+	public static final String DATE_FORMAT = "yyyy-MM-dd";
+
+	public static final String DATE_FORMAT_NUMBER = "yyyyMMdd";
+	public static final String DATE_FORMAT_NUMBER_MONTH = "yyyyMM";
+
+	public static final String DATETIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
+	public static final String TIME_FORMAT = "HH:mm:ss";
+
+	public static final String GREENWICH_TIME = "1970-01-01 00:00:00";
+
+	public static String formatDate(Date date, String pattern) {
+		SimpleDateFormat sdf = new SimpleDateFormat(pattern);
+		try {
+			return sdf.format(date);
+		} catch (Exception e) {
+			return null;
+		}
+	}
+
+
+	public static void main(String[] args) {
+		int   a = Integer.parseInt(String .format("%td", new Date()));
+		System.out.println(a);
+
+	}
+
+
+
+
+//改一下，传进来date  处理完之后返回date
+	public static String addDateStringHour(String day, int hour) {
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Date date = null;
+		try {
+			date = format.parse(day);
+		} catch (Exception ex) {
+			ex.printStackTrace();
+		}
+		if (date == null)
+			return "";
+		System.out.println("front:" + format.format(date)); //显示输入的日期
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(date);
+		cal.add(Calendar.HOUR, hour);// 24小时制
+		date = cal.getTime();
+		System.out.println("after:" + format.format(date));  //显示更新后的日期
+		cal = null;
+		return format.format(date);
+
+
+	}
+
+
+
+	//改一下，传进来date  处理完之后返回date
+	public static Date addDateHour(Date datein, int hour) {
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Date date = null;
+		/*try {
+			date = format.parse(day);
+		} catch (Exception ex) {
+			ex.printStackTrace();
+		}*/
+		//System.out.println("front:" +format.format(datein)); //显示输入的日期
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(datein);
+		cal.add(Calendar.HOUR, hour);// 24小时制
+		date = cal.getTime();
+		//System.out.println("after:" + format.format(date));  //显示更新后的日期
+		cal = null;
+		return  date ;
+	}
+
+
+		//过去五秒
+	public static Date getPassedsecond(){
+		Calendar c = Calendar.getInstance();
+		c.setTime(new Date());
+		c.add(Calendar.SECOND, - 5);
+		return c.getTime();
+	}
+
+	public static String stampToTime(String s) throws Exception{
+		String res;
+		SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		long lt = new Long(s);
+		//将时间戳转换为时间
+		Date date = new Date(lt);
+       //将时间调整为yyyy-MM-dd HH:mm:ss时间样式
+		res = simpleDateFormat.format(date);
+		return res;
+
+	}
+
+
+	//过去一天
+	public static Date getPassedDay(){
+		Calendar c = Calendar.getInstance();
+		c.setTime(new Date());
+		c.add(Calendar.HOUR, - 1);
+		return c.getTime();
+	}
+
+
+	//过去七天
+	public static Date getPassedWeek(){
+		SimpleDateFormat format = new SimpleDateFormat(DATETIME_FORMAT);
+		Calendar c = Calendar.getInstance();
+		c.setTime(new Date());
+		c.add(Calendar.DATE, - 7);
+		return c.getTime();
+	}
+
+	//过去三十天
+	public static Date getPassedMonth(){
+		Calendar c = Calendar.getInstance();
+		c.setTime(new Date());
+		c.add(Calendar.DATE, - 30);
+		return c.getTime();
+	}
+
+	//指定时间的周一
+	public static String getWeekFirstStr(Date time) {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 设置时间格式
+		return sdf.format(getThisWeekMonday(time));
+	}
+
+	//获取指定日期当月的第一天
+	public static String getMonthFirstStr(Date time){
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+		Calendar calendar = Calendar.getInstance();
+		calendar.setTime(time);
+		calendar.set(Calendar.DAY_OF_MONTH, 1);
+		calendar.add(Calendar.MONTH, 0);
+		return sdf.format(calendar.getTime());
+	}
+
+	public static Date geLastWeekMonday(Date date) {
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(getThisWeekMonday(date));
+		cal.add(Calendar.DATE, -7);
+		return cal.getTime();
+	}
+
+
+	public static String dateToString( Date datetime) {
+      SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+      String dateString = formatter.format(datetime);
+      return dateString;
+}
+
+	public static Date getNextWeekMonday(Date date) {
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(getThisWeekMonday(date));
+		cal.add(Calendar.DATE, 7);
+		return cal.getTime();
+	}
+
+	public static Date getThisWeekMonday(Date date) {
+		Calendar cal = Calendar.getInstance();
+		cal.setTime(date);
+		// 获得当前日期是一个星期的第几天
+		int dayWeek = cal.get(Calendar.DAY_OF_WEEK);
+		if (1 == dayWeek) {
+			cal.add(Calendar.DAY_OF_MONTH, -1);
+		}
+		// 设置一个星期的第一天，按中国的习惯一个星期的第一天是星期一
+		cal.setFirstDayOfWeek(Calendar.MONDAY);
+		// 获得当前日期是一个星期的第几天
+		int day = cal.get(Calendar.DAY_OF_WEEK);
+		// 根据日历的规则，给当前日期减去星期几与一个星期第一天的差值
+		cal.add(Calendar.DATE, cal.getFirstDayOfWeek() - day);
+		return cal.getTime();
+	}
+
+	public static String getNowWithDigital() {
+		Date now = new Date();
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		return sdf.format(now).replaceAll("-", "").replaceAll(" ", "").replaceAll(":", "");
+	}
+
+	public static String buildDateTimeString(String formatContent) {
+		String year = formatContent.substring(0, 4);
+		String month = formatContent.substring(4, 6);
+		String day = formatContent.substring(6, 8);
+		String hour = formatContent.substring(8, 10);
+		String minute = formatContent.substring(10, 12);
+		String seconds = formatContent.substring(12, 14);
+		StringBuilder dateTimeSb = new StringBuilder();
+		return dateTimeSb.append(year).append("-").append(month).append("-").append(day).append(" ").append(hour).append(":").append(minute).append(":").append(seconds).toString();
+	}
+
+	public static String buildDateString(String formatContent) {
+		String year = formatContent.substring(0, 4);
+		String month = formatContent.substring(4, 6);
+		String day = formatContent.substring(6, 8);
+		String dateTime = year + "-" + month + "-" + day;
+		return dateTime;
+	}
+
+	public static String formatDateTime(String date) {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:SS");
+		return sdf.format(date);
+	}
+
+	public static Date parseDateTime(String date) throws ParseException {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		return sdf.parse(date);
+	}
+
+
+	public String getToday() {
+		DateFormat df3 = DateFormat.getDateInstance(2, Locale.CHINA);
+		return df3.format(new Date());
+	}
+
+	public String formatDate(Date date) {
+		DateFormat df3 = DateFormat.getDateInstance(2, Locale.CHINA);
+		return df3.format(date);
+	}
+
+
+	public String beforeTime(int times) {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Calendar calendar = Calendar.getInstance();
+		calendar.set(11, calendar.get(11) - times);
+		String endTime = sdf.format(calendar.getTime());
+		System.out.println("提前3小时：" + endTime);
+		return endTime;
+	}
+
+
+	//判断日是否相同
+	public   static  Boolean  dayIsSame( Date date1 , Date  date2) {
+		int   a = Integer.parseInt(String .format("%td", date1));
+		int   b = Integer.parseInt(String .format("%td", date2));
+		Boolean result = a==b;
+		return result;
+	}
+
+
+
+
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/PageUtils.java

@@ -0,0 +1,110 @@
+/**
+ * Copyright (c) 2016-2019 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有，侵权必究！
+ */
+
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 分页工具类
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+public class PageUtils implements Serializable {
+	private static final long serialVersionUID = 1L;
+	/**
+	 * 总记录数
+	 */
+	private int totalCount;
+	/**
+	 * 每页记录数
+	 */
+	private int pageSize;
+	/**
+	 * 总页数
+	 */
+	private int totalPage;
+	/**
+	 * 当前页数
+	 */
+	private int currPage;
+	/**
+	 * 列表数据
+	 */
+	private List<?> list;
+	
+	/**
+	 * 分页
+	 * @param list        列表数据
+	 * @param totalCount  总记录数
+	 * @param pageSize    每页记录数
+	 * @param currPage    当前页数
+	 */
+	public PageUtils(List<?> list, int totalCount, int pageSize, int currPage) {
+		this.list = list;
+		this.totalCount = totalCount;
+		this.pageSize = pageSize;
+		this.currPage = currPage;
+		this.totalPage = (int)Math.ceil((double)totalCount/pageSize);
+	}
+
+	/**
+	 * 分页
+	 */
+	public PageUtils(IPage<?> page) {
+		this.list = page.getRecords();
+		this.totalCount = (int)page.getTotal();
+		this.pageSize = (int)page.getSize();
+		this.currPage = (int)page.getCurrent();
+		this.totalPage = (int)page.getPages();
+	}
+
+	public int getTotalCount() {
+		return totalCount;
+	}
+
+	public void setTotalCount(int totalCount) {
+		this.totalCount = totalCount;
+	}
+
+	public int getPageSize() {
+		return pageSize;
+	}
+
+	public void setPageSize(int pageSize) {
+		this.pageSize = pageSize;
+	}
+
+	public int getTotalPage() {
+		return totalPage;
+	}
+
+	public void setTotalPage(int totalPage) {
+		this.totalPage = totalPage;
+	}
+
+	public int getCurrPage() {
+		return currPage;
+	}
+
+	public void setCurrPage(int currPage) {
+		this.currPage = currPage;
+	}
+
+	public List<?> getList() {
+		return list;
+	}
+
+	public void setList(List<?> list) {
+		this.list = list;
+	}
+	
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/Query.java

@@ -0,0 +1,84 @@
+/**
+ * Copyright (c) 2016-2019 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有，侵权必究！
+ */
+
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.metadata.OrderItem;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.apache.commons.lang.StringUtils;
+
+import java.util.Map;
+
+/**
+ * 查询参数
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+public class Query<T> {
+
+    public IPage<T> getPage(Map<String, Object>  params) {
+        return this.getPage(params, null, false);
+    }
+
+    public IPage<T> getPageEartag(Map<String, Object>  params) {
+        return this.getPage(params, "id", true);
+    }
+
+    public IPage<T> getPage(Map<String, Object> params, String defaultOrderField, boolean isAsc) {
+        //分页参数
+        long curPage = 1;
+        long limit = 10;
+
+        System.out.println("fenye"+params.get("page"));
+        System.out.println("fenyesize"+params.get("limit"));
+
+        if(params.get(Constant.PAGE) != null){
+            curPage = Long.parseLong((String)params.get(Constant.PAGE));
+        }
+        if(params.get(Constant.LIMIT) != null){
+            limit = Long.parseLong((String)params.get(Constant.LIMIT));
+        }
+
+
+        //分页对象
+       Page<T> page = new Page<>(curPage, limit);
+
+        //分页参数
+     //   params.put(Constant.PAGE, page);
+
+        //排序字段
+        //防止SQL注入（因为sidx、order是通过拼接SQL实现排序的，会有SQL注入风险）
+        String orderField = SQLFilter.sqlInject((String)params.get(Constant.ORDER_FIELD));
+        String order = (String)params.get(Constant.ORDER);
+
+
+        //前端字段排序
+        if(StringUtils.isNotEmpty(orderField) && StringUtils.isNotEmpty(order)){
+            if(Constant.ASC.equalsIgnoreCase(order)) {
+                return  page.addOrder(OrderItem.asc(orderField));
+            }else {
+                return page.addOrder(OrderItem.desc(orderField));
+            }
+        }
+
+        //没有排序字段，则不排序
+        if(StringUtils.isBlank(defaultOrderField)){
+            return page;
+        }
+
+        //默认排序
+        if(isAsc) {
+            page.addOrder(OrderItem.asc(defaultOrderField));
+        }else {
+            page.addOrder(OrderItem.desc(defaultOrderField));
+        }
+
+        return page;
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/Result.java

@@ -0,0 +1,73 @@
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+import java.io.Serializable;
+
+/**
+ * 描述
+ *
+ * @author 三国的包子
+ * @version 1.0
+ * @package entity *
+ * @since 1.0
+ */
+public class Result<T> implements Serializable {
+    private boolean flag;//是否成功
+    private Integer code;//返回码
+    private String message;//返回消息
+    private T data;//返回数据
+
+    public Result(boolean flag, Integer code, String message, Object data) {
+        this.flag = flag;
+        this.code = code;
+        this.message = message;
+        this.data = (T) data;
+    }
+
+    public Result(boolean flag, Integer code, String message) {
+        this.flag = flag;
+        this.code = code;
+        this.message = message;
+    }
+
+    public Result() {
+        this.flag = true;
+        this.code = StatusCode.OK;
+        this.message = "操作成功!";
+    }
+
+
+
+
+
+    public boolean isFlag() {
+        return flag;
+    }
+
+    public void setFlag(boolean flag) {
+        this.flag = flag;
+    }
+
+    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 T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/SQLFilter.java

@@ -0,0 +1,52 @@
+/**
+ * Copyright (c) 2016-2019 人人开源 All rights reserved.
+ *
+ * https://www.renren.io
+ *
+ * 版权所有，侵权必究！
+ */
+
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+
+
+import cim.huimv.incubator.result.RRException;
+import org.apache.commons.lang.StringUtils;
+
+/**
+ * SQL过滤
+ *
+ * @author Mark sunlightcs@gmail.com
+ */
+public class SQLFilter {
+
+    /**
+     * SQL注入过滤
+     * @param str  待验证的字符串
+     */
+    public static String sqlInject(String str){
+        if(StringUtils.isBlank(str)){
+            return null;
+        }
+        //去掉'|"|;|\字符
+        str = StringUtils.replace(str, "'", "");
+        str = StringUtils.replace(str, "\"", "");
+        str = StringUtils.replace(str, ";", "");
+        str = StringUtils.replace(str, "\\", "");
+
+        //转换成小写
+        str = str.toLowerCase();
+
+        //非法字符
+        String[] keywords = {"master", "truncate", "insert", "select", "delete", "update", "declare", "alter", "drop"};
+
+        //判断是否包含非法字符
+        for(String keyword : keywords){
+            if(str.indexOf(keyword) != -1){
+                throw new RRException("包含非法字符");
+            }
+        }
+
+        return str;
+    }
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/StatusCode.java

@@ -0,0 +1,14 @@
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+/**
+ * 返回码
+ */
+public class StatusCode {
+    public static final int OK = 20000;//成功
+    public static final int ERROR = 20001;//失败
+    public static final int LOGINERROR = 20002;//用户名或密码错误
+    public static final int ACCESSERROR = 20003;//权限不足
+    public static final int REMOTEERROR = 20004;//远程调用失败
+    public static final int REPERROR = 20005;//重复操作
+    public static final int NOTFOUNDERROR = 20006;//没有对应的抢购数据
+}

huimv-smart-incubator/huimv-smart-incubator-data/src/main/java/cim/huimv/incubator/socket/eartagrecive/util/StringUtilsWork.java

@@ -0,0 +1,60 @@
+package cim.huimv.incubator.socket.eartagrecive.util;
+
+/**
+ * @Author Anchor
+ * @Date 2021/7/30 13:17
+ * @Version 1.0.1
+ */
+public class StringUtilsWork {
+
+    public static boolean isEmpty(String str) {
+        return str == null || str.length() == 0;
+    }
+
+    public static boolean isNotEmpty(String str) {
+        return !isEmpty(str);
+    }
+
+    public static boolean isBlank(String str) {
+        int strLen;
+        if (str != null && (strLen = str.length()) != 0) {
+            for(int i = 0; i < strLen; ++i) {
+                if (!Character.isWhitespace(str.charAt(i))) {
+                    return false;
+                }
+            }
+
+            return true;
+        } else {
+            return true;
+        }
+    }
+
+    public static boolean isNotBlank(String str) {
+        return !isBlank(str);
+    }
+
+    public static void main(String[] args) {
+
+
+        String a =null;
+        String b ="";
+
+        System.out.println(isBlank(a));
+        System.out.println(isBlank(b));
+
+        System.out.println(isNotBlank(a));
+
+        System.out.println(isNotBlank(b));
+
+    }
+
+
+
+
+}
+
+
+
+
+

huimv-smart-incubator/huimv-smart-incubator-data/src/main/resources/application-dev.yml

@@ -0,0 +1,55 @@
+server:
+  port: 8211
+
+spring:
+  datasource:
+    url: jdbc:mysql://115.238.57.190:3306/huimv_incubator_controll?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:
+    #    hibernate:
+    #      ddl-auto: update  #validate
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    show-sql: true
+  servlet:
+    multipart:
+      max-file-size: 100MB
+      max-request-size: 1000MB
+    # jackson时间格式化
+  jackson:
+    time-zone: GMT+8
+    date-format: yyyy-MM-dd HH:mm:ss
+  mvc:
+    view:
+      prefix: /
+      suffix: .html
+  main:
+    allow-bean-definition-overriding: true
+#  redis:
+#    database: 0
+#    host: 124.71.192.190
+#    port: 6379
+#    password: hm123456
+#    jedis:
+#      pool:
+#        max-active: 20
+#        max-wait: -1
+#        max-idle: 10
+#        min-idle: 0
+#    timeout: 5000
+
+# mybatis-plus相关配置
+mybatis-plus:
+  type-aliases-package: com.huimv.*.entity
+  global-config:
+    banner: false
+    db-config:
+      id-type: auto
+  #原生配置
+  configuration:
+    map-underscore-to-camel-case: true
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: 'null'
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

huimv-smart-incubator/huimv-smart-incubator-data/src/main/resources/application.properties

@@ -0,0 +1,4 @@
+spring.profiles.active=dev
+#spring.profiles.active=prod
+
+

huimv-smart-incubator/huimv-smart-incubator-data/target/classes/application-dev.yml

@@ -0,0 +1,55 @@
+server:
+  port: 8211
+
+spring:
+  datasource:
+    url: jdbc:mysql://115.238.57.190:3306/huimv_incubator_controll?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:
+    #    hibernate:
+    #      ddl-auto: update  #validate
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    show-sql: true
+  servlet:
+    multipart:
+      max-file-size: 100MB
+      max-request-size: 1000MB
+    # jackson时间格式化
+  jackson:
+    time-zone: GMT+8
+    date-format: yyyy-MM-dd HH:mm:ss
+  mvc:
+    view:
+      prefix: /
+      suffix: .html
+  main:
+    allow-bean-definition-overriding: true
+#  redis:
+#    database: 0
+#    host: 124.71.192.190
+#    port: 6379
+#    password: hm123456
+#    jedis:
+#      pool:
+#        max-active: 20
+#        max-wait: -1
+#        max-idle: 10
+#        min-idle: 0
+#    timeout: 5000
+
+# mybatis-plus相关配置
+mybatis-plus:
+  type-aliases-package: com.huimv.*.entity
+  global-config:
+    banner: false
+    db-config:
+      id-type: auto
+  #原生配置
+  configuration:
+    map-underscore-to-camel-case: true
+    cache-enabled: false
+    call-setters-on-nulls: true
+    jdbc-type-for-null: 'null'
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

huimv-smart-incubator/huimv-smart-incubator-data/target/classes/application.properties

@@ -0,0 +1,4 @@
+spring.profiles.active=dev
+#spring.profiles.active=prod
+
+