体温监测实体类,控制/服务/数据映射层创建

钟日健

2021-02-27 f19d7d458e175b0e4beb8aec96a541dd3e8ced25

体温监测实体类,控制/服务/数据映射层创建

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/controller/AnimalHeatController.java

New file
@@ -0,0 +1,20 @@
package org.springblade.jfpt.nettyUdpServer.controller;

import lombok.AllArgsConstructor;
import org.springblade.jfpt.nettyUdpServer.service.AnimalHeatService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 体温监测控制层
 * @time 2021-2-25
 */

@RestController
@RequestMapping("animalHeat/animalHeat")
@AllArgsConstructor
public class AnimalHeatController {

    private final AnimalHeatService animalHeatService;

}

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/entity/BladeAnimalHeat.java

New file
@@ -0,0 +1,39 @@
package org.springblade.jfpt.nettyUdpServer.entity;


import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

/**
 * @title 体温数据表
 * @author  arsn
 * @time 2021-2-25
 */
@Data
@TableName("blade_animal_heat")
public class BladeAnimalHeat implements Serializable {

    private static final long serialVersionUID = 4356978043337357357L;
    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;// bigint(20) NOT NULL COMMENT '主键',
    private Integer method;// int(1) NOT NULL COMMENT '方法名: 0 表示 infrared_aiom_picture 图片数据, 1 表示 engine_echo  心跳包    ',
    private String ip;// varchar(63) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '设备IP地址',
    private String picture;// varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '图片url路径',
    @TableField("picture_red")
    private String pictureRed;// varchar(255) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '红外图片url路径',
    @TableField("temp_red")
    private Float tempRed;// float(4,2) DEFAULT NULL COMMENT '当前人员的温度',
    @TableField("person_rect")
    private String personRect;// varchar(63) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '人脸位置二位数组，[left,top,right,bottom]',
    @TableField("person_rect_red")
    private String personRectRed;// varchar(63) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '红外人脸位置二位数组，[left,top,right,bottom]',
    @TableField("create_time")
    private Date createTime;// datetime DEFAULT NULL COMMENT '创建时间',

}

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/handle/UdpServerHandler.java

@@ -1,7 +1,6 @@
package org.springblade.jfpt.nettyUdpServer.handle;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.socket.DatagramPacket;
@@ -11,7 +10,7 @@
import org.springframework.stereotype.Component;

/**
 * Created by wangshikai on 2016/7/18.
 * updHandler udp 服务端数据接收处理
 */
@Component
public class UdpServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/mapper/AnimalHeatMapper.java

New file
@@ -0,0 +1,11 @@
package org.springblade.jfpt.nettyUdpServer.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springblade.jfpt.nettyUdpServer.entity.BladeAnimalHeat;

/**
 * mapper 映射层
 *
 */
public interface AnimalHeatMapper extends BaseMapper<BladeAnimalHeat> {
}

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/server/UdpServer.java

@@ -17,7 +17,7 @@
import java.util.concurrent.Executors;

/**
 * Created by wangshikai on 2016/7/18.
 * updServer udp服务端
 */
public class UdpServer {
    private static Logger LOG = LoggerFactory.getLogger(UdpServer.class);
@@ -73,6 +73,9 @@
    //使用ChannelPipeline实现自定义IO
    //Channel channel;
    public void run() {
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
        //InetSocketAddress socketAddress = new InetSocketAddress("s16s652780.51mypc.cn", 21403);
        //启动服务
        EventLoopGroup workerGroup = new NioEventLoopGroup();
@@ -107,7 +110,7 @@
            ChannelFuture f = b.bind(port).sync();
            //获取channel通道
            //channel=f.channel();
            System.out.println("UDP Server 启动！");
                    System.out.println("UDP Server 启动,端口:"+port);
            // 等待服务器 socket 关闭 。
            // 这不会发生，可以优雅地关闭服务器。
            f.channel().closeFuture().sync();
@@ -119,5 +122,8 @@
            workerGroup.shutdownGracefully();
        }
    }
            });
        thread.start();
    }

}

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/service/AnimalHeatService.java

New file
@@ -0,0 +1,7 @@
package org.springblade.jfpt.nettyUdpServer.service;

/**
 * 体温监测服务层接口层
 */
public interface AnimalHeatService {
}

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyUdpServer/service/impl/AnimalHeatServiceImpl.java

New file
@@ -0,0 +1,17 @@
package org.springblade.jfpt.nettyUdpServer.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.jfpt.nettyUdpServer.entity.BladeAnimalHeat;
import org.springblade.jfpt.nettyUdpServer.mapper.AnimalHeatMapper;
import org.springblade.jfpt.nettyUdpServer.service.AnimalHeatService;
import org.springframework.stereotype.Service;


@Service
public class AnimalHeatServiceImpl extends ServiceImpl<AnimalHeatMapper, BladeAnimalHeat> implements AnimalHeatService {
    @Override
    public boolean save(BladeAnimalHeat entity) {
        return false;
    }

}