api上行接收测温数据接口

pom.xml

@@ -35,7 +35,13 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-openfeign</artifactId>
         </dependency>
-
+        <!-- utils -->
+        <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.75</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

src/main/java/com/chinaitop/depot/grainAPI/controller/GrainDataSynController.java

@@ -0,0 +1,45 @@
+package com.chinaitop.depot.grainAPI.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.chinaitop.depot.grainAPI.entity.TestData;
+import com.chinaitop.depot.grainAPI.service.TestDataService;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description: 库端到云端数据同步接口 test_data
+ * @create 2021-11-02 16:13
+ */
+@RestController
+@RequestMapping(value = "/testData")
+public class GrainDataSynController {
+    private final static Logger logger = LoggerFactory.getLogger(GrainDataSynController.class);
+
+    @Resource
+    private TestDataService testDataService;
+
+    @PostMapping("/housesToCouldTemperData")
+    public void housesToCouldTemperData(@RequestBody String grainJson) {
+        logger.info("testData: {}", grainJson);
+        try {
+            if (StringUtils.isNotBlank(grainJson)) {
+                List<TestData> testData = JSONArray.parseArray(grainJson, TestData.class);
+                testDataService.saveBatch(testData);
+            }
+        } catch (Exception e) {
+            logger.info("testData数据保存失败: {}", grainJson);
+            e.printStackTrace();
+        }
+    }
+
+}

src/main/java/com/chinaitop/depot/grainAPI/controller/GrainLayerDataSynController.java

@@ -0,0 +1,43 @@
+package com.chinaitop.depot.grainAPI.controller;
+
+import com.alibaba.fastjson.JSONArray;
+import com.chinaitop.depot.grainAPI.entity.TestDataLayer;
+import com.chinaitop.depot.grainAPI.service.TestDataLayerService;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description: 测温数据子表库到云数据同步
+ * @create 2021-11-03 13:52
+ */
+@RestController
+@RequestMapping(value = "/testDataLayer")
+public class GrainLayerDataSynController {
+    private final static Logger logger = LoggerFactory.getLogger(GrainLayerDataSynController.class);
+    @Resource
+    private TestDataLayerService testDataLayerService;
+
+    @PostMapping("/housesToCouldTemperData")
+    public void housesToCouldTemperData(@RequestBody String grainJson) {
+        logger.info("testDataLayer: {}", grainJson);
+        try {
+            if (StringUtils.isNotBlank(grainJson)) {
+                List<TestDataLayer> testDataLayer = JSONArray.parseArray(grainJson, TestDataLayer.class);
+                testDataLayerService.saveBatch(testDataLayer);
+            }
+        } catch (Exception e) {
+            logger.info("testDataLayerDataInfo保存失败: {}", grainJson);
+            e.printStackTrace();
+        }
+    }
+
+}

src/main/java/com/chinaitop/depot/grainAPI/controller/GrainWarningDataSynController.java

@@ -0,0 +1,43 @@
+package com.chinaitop.depot.grainAPI.controller;
+
+import com.alibaba.fastjson.JSONArray;
+import com.chinaitop.depot.grainAPI.entity.TestWarningData;
+import com.chinaitop.depot.grainAPI.service.TestWarningDataService;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description: 接收库端粮情报警数据到云端
+ * @create 2021-11-03 16:26
+ */
+@RestController
+@RequestMapping(value = "/testWarningData")
+public class GrainWarningDataSynController {
+    private final static Logger logger = LoggerFactory.getLogger(GrainWarningDataSynController.class);
+    @Resource
+    private TestWarningDataService testWarningDataService;
+
+    @PostMapping("/housesToCouldTemperData")
+    public void housesToCouldTemperData(@RequestBody String grainJson) {
+        logger.info("testWarningData: {}", grainJson);
+        try {
+            if (StringUtils.isNotBlank(grainJson)) {
+                List<TestWarningData> testWarningData = JSONArray.parseArray(grainJson, TestWarningData.class);
+                testWarningDataService.saveBatch(testWarningData);
+            }
+        } catch (Exception e) {
+            logger.info("testWarningData保存失败: {}", grainJson);
+            e.printStackTrace();
+        }
+    }
+
+}

src/main/java/com/chinaitop/depot/grainAPI/entity/Points.java

@@ -0,0 +1,78 @@
+package com.chinaitop.depot.grainAPI.entity;
+
+import java.math.BigDecimal;
+
+public class Points {
+    private BigDecimal temp;
+
+    private String x;
+
+    private String y;
+
+    private String z;
+
+    /**
+     * 温度值 单位：摄氏度；坏点值以250表示；精确到小数点后1位；
+     * @return temp 温度值 单位：摄氏度；坏点值以250表示；精确到小数点后1位；
+     */
+    public BigDecimal getTemp() {
+        return temp;
+    }
+
+    /**
+     * 温度值 单位：摄氏度；坏点值以250表示；精确到小数点后1位；
+     * @param temp 温度值 单位：摄氏度；坏点值以250表示；精确到小数点后1位；
+     */
+    public void setTemp(BigDecimal temp) {
+        this.temp = temp;
+    }
+
+    /**
+     * 测温点在仓内的X坐标代表长度 代表列
+     * @return X 测温点在仓内的X坐标代表长度 代表列
+     */
+    public String getX() {
+        return x;
+    }
+
+    /**
+     * 测温点在仓内的X坐标代表长度 代表列
+     * @param x 测温点在仓内的X坐标代表长度 代表列
+     */
+    public void setX(String x) {
+        this.x = x == null ? null : x.trim();
+    }
+
+    /**
+     * 测温点在仓内的Y坐标宽度方向 代表行
+     * @return Y 测温点在仓内的Y坐标宽度方向 代表行
+     */
+    public String getY() {
+        return y;
+    }
+
+    /**
+     * 测温点在仓内的Y坐标宽度方向 代表行
+     * @param y 测温点在仓内的Y坐标宽度方向 代表行
+     */
+    public void setY(String y) {
+        this.y = y == null ? null : y.trim();
+    }
+
+    /**
+     * 测温点在仓内的Z坐标高度
+     * @return Z 测温点在仓内的Z坐标高度
+     */
+    public String getZ() {
+        return z;
+    }
+
+    /**
+     * 测温点在仓内的Z坐标高度
+     * @param z 测温点在仓内的Z坐标高度
+     */
+    public void setZ(String z) {
+        this.z = z == null ? null : z.trim();
+    }
+
+}

src/main/java/com/chinaitop/depot/grainAPI/entity/TestData.java

@@ -0,0 +1,56 @@
+package com.chinaitop.depot.grainAPI.entity;
+
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Collections;
+import java.util.Date;
+import java.util.List;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("t_testdata")
+public class TestData implements Serializable {
+    private static final long serialVersionUID = -5327933225976489891L;
+
+    @TableId("id")
+    private String id;
+    @TableField("org_id")
+    private String orgId;
+    @TableField("storehouse")
+    private String storehouse;
+    @TableField("house")
+    private String house;
+    @TableField("t_time")
+    private Date time;
+    @TableField("intemp")
+    private BigDecimal intemp;
+    @TableField("inh")
+    private BigDecimal inh;
+    @TableField("outtemp")
+    private BigDecimal outtemp;
+    @TableField("outh")
+    private BigDecimal outh;
+    @TableField("t_max")
+    private BigDecimal max;
+    @TableField("t_min")
+    private BigDecimal min;
+    @TableField("t_avg")
+    private BigDecimal avg;
+    @TableField("data_source")
+    private String dataSource;
+    @TableField("ilq_yq")
+    private String ilqYq;
+    @TableField("t_points")
+    private String tPoints;
+//    private List<Points> points = Collections.emptyList();
+
+}

src/main/java/com/chinaitop/depot/grainAPI/entity/TestDataLayer.java

@@ -0,0 +1,49 @@
+package com.chinaitop.depot.grainAPI.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 13:54
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("t_testdata_layer")
+public class TestDataLayer implements Serializable {
+    private static final long serialVersionUID = -8849961676301983242L;
+
+    @TableId("id")
+    private String id;
+    @TableField("org_id")
+    private String orgId;
+    @TableField("lq_id")
+    private String lqId;
+    @TableField("lhouse")
+    private String lhouse;
+    @TableField("ltime")
+    private Date ltime;
+    @TableField("layernumber")
+    private Integer layernumber;
+    @TableField("lz")
+    private String lz;
+    @TableField("lmax")
+    private BigDecimal lmax;
+    @TableField("lmin")
+    private BigDecimal lmin;
+    @TableField("lavg")
+    private BigDecimal lavg;
+    @TableField("data_source")
+    private String dataSource;
+
+}

src/main/java/com/chinaitop/depot/grainAPI/entity/TestWarningData.java

@@ -0,0 +1,61 @@
+package com.chinaitop.depot.grainAPI.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 16:29
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("t_warning_threshold_history")
+public class TestWarningData implements Serializable {
+    private static final long serialVersionUID = -1227845637988750898L;
+
+    @TableId("id")
+    private String id;
+    @TableField("org_id")
+    private String orgId;
+    @TableField("v_cf_code")
+    private String vCfCode;
+    @TableField("w_module")
+    private String wModule;
+    @TableField("w_name")
+    private String wName;
+    @TableField("w_threshold")
+    private BigDecimal wThreshold;
+    @TableField("threshold")
+    private BigDecimal threshold;
+    @TableField("w_state")
+    private Integer wState;
+    @TableField("w_time")
+    private Date wTime;
+    @TableField("w_update_time")
+    private Date wUpdateTime;
+    @TableField("data_source")
+    private String dataSource;
+    @TableField("w_remark")
+    private String wRemark;
+    @TableField("is_send")
+    private String isSend;
+    @TableField("w_mode")
+    private String wMode;
+    @TableField("w_warning")
+    private String wWarning;
+    @TableField("updatetime")
+    private Date updatetime;
+
+
+
+}

src/main/java/com/chinaitop/depot/grainAPI/mapper/TestDataLayerMapper.java

@@ -0,0 +1,14 @@
+package com.chinaitop.depot.grainAPI.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.chinaitop.depot.grainAPI.entity.TestDataLayer;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 14:03
+ */
+@Repository
+public interface TestDataLayerMapper extends BaseMapper<TestDataLayer> {
+}

src/main/java/com/chinaitop/depot/grainAPI/mapper/TestDataMapper.java

@@ -0,0 +1,14 @@
+package com.chinaitop.depot.grainAPI.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.chinaitop.depot.grainAPI.entity.TestData;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-02 16:54
+ */
+@Repository
+public interface TestDataMapper extends BaseMapper<TestData> {
+}

src/main/java/com/chinaitop/depot/grainAPI/mapper/TestWarningDataMapper.java

@@ -0,0 +1,14 @@
+package com.chinaitop.depot.grainAPI.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.chinaitop.depot.grainAPI.entity.TestWarningData;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 16:49
+ */
+@Repository
+public interface TestWarningDataMapper extends BaseMapper<TestWarningData> {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/TestDataLayerService.java

@@ -0,0 +1,12 @@
+package com.chinaitop.depot.grainAPI.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.chinaitop.depot.grainAPI.entity.TestDataLayer;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 14:00
+ */
+public interface TestDataLayerService extends IService<TestDataLayer> {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/TestDataService.java

@@ -0,0 +1,12 @@
+package com.chinaitop.depot.grainAPI.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.chinaitop.depot.grainAPI.entity.TestData;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-02 16:42
+ */
+public interface TestDataService extends IService<TestData> {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/TestWarningDataService.java

@@ -0,0 +1,12 @@
+package com.chinaitop.depot.grainAPI.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.chinaitop.depot.grainAPI.entity.TestWarningData;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 16:46
+ */
+public interface TestWarningDataService extends IService<TestWarningData> {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/impl/TestDataLayerServiceImpl.java

@@ -0,0 +1,16 @@
+package com.chinaitop.depot.grainAPI.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.grainAPI.entity.TestDataLayer;
+import com.chinaitop.depot.grainAPI.mapper.TestDataLayerMapper;
+import com.chinaitop.depot.grainAPI.service.TestDataLayerService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 14:01
+ */
+@Service
+public class TestDataLayerServiceImpl extends ServiceImpl<TestDataLayerMapper, TestDataLayer> implements TestDataLayerService {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/impl/TestDataServiceImpl.java

@@ -0,0 +1,16 @@
+package com.chinaitop.depot.grainAPI.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.grainAPI.entity.TestData;
+import com.chinaitop.depot.grainAPI.mapper.TestDataMapper;
+import com.chinaitop.depot.grainAPI.service.TestDataService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-02 16:52
+ */
+@Service
+public class TestDataServiceImpl extends ServiceImpl<TestDataMapper, TestData> implements TestDataService {
+}

src/main/java/com/chinaitop/depot/grainAPI/service/impl/TestWarningDataServiceImpl.java

@@ -0,0 +1,16 @@
+package com.chinaitop.depot.grainAPI.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.grainAPI.entity.TestWarningData;
+import com.chinaitop.depot.grainAPI.mapper.TestWarningDataMapper;
+import com.chinaitop.depot.grainAPI.service.TestWarningDataService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2021-11-03 16:46
+ */
+@Service
+public class TestWarningDataServiceImpl extends ServiceImpl<TestWarningDataMapper, TestWarningData> implements TestWarningDataService {
+}

src/main/resources/mapper/grainAPI/TestDataLayerMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.chinaitop.depot.grainAPI.mapper.TestDataLayerMapper">
+
+
+</mapper>

src/main/resources/mapper/grainAPI/TestDataMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.chinaitop.depot.grainAPI.mapper.TestDataMapper">
+
+</mapper>

src/main/resources/mapper/grainAPI/TestWarningDataMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.chinaitop.depot.grainAPI.mapper.TestWarningDataMapper">
+
+
+</mapper>