From 7f43b901477b6cd3fb5e45dcb7b5eacb9e4ef152 Mon Sep 17 00:00:00 2001 From: swj <1211312234@qq.com> Date: Wed, 17 Aug 2022 18:39:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=8A=A0iot=E5=AD=90=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/launch/LauncherServiceImpl.java | 1 - .../lab-iot-api.iml} | 17 ++- lab-service-api/lab-iot-api/pom.xml | 18 +++ .../org/springblade/iot/entry/Sensor.java | 63 +++++++++ lab-service-api/pom.xml | 1 + lab-service/lab-iot/pom.xml | 54 +++++++- .../org/springblade/iot/IotApplication.java | 23 ++++ .../iot/controller/SensorController.java | 88 +++++++++++++ .../springblade/iot/mapper/SensorMapper.java | 15 +++ .../iot/service/ISensorService.java | 13 ++ .../iot/service/impl/SensorServiceImpl.java | 22 ++++ .../springblade/iot/utils/ReadModBusUtil.java | 120 ++++++++++++++++++ .../lims/mapper/ContractMapper.java | 1 - lab-service/pom.xml | 1 + 14 files changed, 428 insertions(+), 9 deletions(-) rename lab-service-api/{lab-file-api/lab-file-api.iml => lab-iot-api/lab-iot-api.iml} (97%) create mode 100644 lab-service-api/lab-iot-api/pom.xml create mode 100644 lab-service-api/lab-iot-api/src/main/java/org/springblade/iot/entry/Sensor.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/IotApplication.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/controller/SensorController.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/mapper/SensorMapper.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/service/ISensorService.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/service/impl/SensorServiceImpl.java create mode 100644 lab-service/lab-iot/src/main/java/org/springblade/iot/utils/ReadModBusUtil.java diff --git a/lab-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java b/lab-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java index d82aabe..13dd238 100644 --- a/lab-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java +++ b/lab-common/src/main/java/org/springblade/common/launch/LauncherServiceImpl.java @@ -1,7 +1,6 @@ package org.springblade.common.launch; -import org.springblade.common.constant.LauncherConstant; import org.springblade.core.auto.service.AutoService; import org.springblade.core.launch.service.LauncherService; import org.springblade.core.launch.utils.PropsUtil; diff --git a/lab-service-api/lab-file-api/lab-file-api.iml b/lab-service-api/lab-iot-api/lab-iot-api.iml similarity index 97% rename from lab-service-api/lab-file-api/lab-file-api.iml rename to lab-service-api/lab-iot-api/lab-iot-api.iml index b03083f..0cd55b6 100644 --- a/lab-service-api/lab-file-api/lab-file-api.iml +++ b/lab-service-api/lab-iot-api/lab-iot-api.iml @@ -7,21 +7,24 @@ + + + + - - + + + + - - - @@ -46,7 +49,6 @@ - @@ -137,6 +139,8 @@ + + @@ -157,6 +161,7 @@ + diff --git a/lab-service-api/lab-iot-api/pom.xml b/lab-service-api/lab-iot-api/pom.xml new file mode 100644 index 0000000..f1873c3 --- /dev/null +++ b/lab-service-api/lab-iot-api/pom.xml @@ -0,0 +1,18 @@ + + + + lab-service-api + org.springblade + 2.8.1.RELEASE + + 4.0.0 + + lab-iot-api + ${project.artifactId} + ${bladex.project.version} + jar + + + \ No newline at end of file diff --git a/lab-service-api/lab-iot-api/src/main/java/org/springblade/iot/entry/Sensor.java b/lab-service-api/lab-iot-api/src/main/java/org/springblade/iot/entry/Sensor.java new file mode 100644 index 0000000..6854844 --- /dev/null +++ b/lab-service-api/lab-iot-api/src/main/java/org/springblade/iot/entry/Sensor.java @@ -0,0 +1,63 @@ +/* + * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * + * Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * Neither the name of the dreamlu.net developer nor the names of its + * contributors may be used to endorse or promote products derived from + * this software without specific prior written permission. + * Author: Chill 庄骞 (smallchill@163.com) + */ +package org.springblade.iot.entry; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.springblade.core.mp.base.BaseEntity; +import org.springframework.format.annotation.DateTimeFormat; + +import java.time.LocalDateTime; + +/** + * 数采配置实体类 + * + * @author swj + * @since 2022年8月17日16:29:15 + */ +@Data +@TableName("t_sensor_base") +@EqualsAndHashCode(callSuper = true) +@ApiModel(value = "Sensor对象", description = "数采配置") +public class Sensor extends BaseEntity { + + @ApiModelProperty(value = "传感器名称") + private String name; + + @ApiModelProperty(value = "plc设备的ip") + private String ip; + + @ApiModelProperty(value = "信息名称(如：302更衣室压差)") + private String signalName; + + @ApiModelProperty(value = "数据类型(REAL->float)") + private String dataType; + + @ApiModelProperty(value = "寄存器地址") + private String registerAddress; + + @TableField(exist = false) + @ApiModelProperty(value = "单前的实时数据") + private String currData; + + private static final long serialVersionUID = 1L; +} diff --git a/lab-service-api/pom.xml b/lab-service-api/pom.xml index 1cbbd49..5e9c63b 100644 --- a/lab-service-api/pom.xml +++ b/lab-service-api/pom.xml @@ -27,6 +27,7 @@ lab-monitor-api lab-lims-report-api lab-file-api + lab-iot-api diff --git a/lab-service/lab-iot/pom.xml b/lab-service/lab-iot/pom.xml index 5792fd9..b68b1e0 100644 --- a/lab-service/lab-iot/pom.xml +++ b/lab-service/lab-iot/pom.xml @@ -10,7 +10,59 @@ 4.0.0 lab-iot - 2.8.1.RELEASE + ${project.artifactId} + ${bladex.project.version} + jar + + + + + + cn.hutool + hutool-all + 5.6.5 + + + + org.springblade + blade-starter-swagger + + + + org.springblade + blade-core-boot + + + + org.springblade + lab-iot-api + ${bladex.project.version} + + + + + + + com.spotify + dockerfile-maven-plugin + + ${docker.username} + ${docker.password} + ${docker.registry.url}/${docker.namespace}/${project.artifactId} + ${project.version} + true + + target/${project.build.finalName}.jar + + false + + + + org.apache.maven.plugins + maven-antrun-plugin + + + \ No newline at end of file diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/IotApplication.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/IotApplication.java new file mode 100644 index 0000000..e4bea2d --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/IotApplication.java @@ -0,0 +1,23 @@ + +package org.springblade.iot; + +import org.springblade.common.constant.LauncherConstant; +import org.springblade.core.cloud.feign.EnableBladeFeign; +import org.springblade.core.launch.BladeApplication; +import org.springframework.cloud.client.SpringCloudApplication; + +/** + * Iot启动器 + * @author swj + * @date 2022年8月17日15:21:251 + */ +@EnableBladeFeign +@SpringCloudApplication +public class IotApplication { + + public static void main(String[] args) { + BladeApplication.run(LauncherConstant.APPLICATION_IOT_NAME, IotApplication.class, args); + } + +} + diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/controller/SensorController.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/controller/SensorController.java new file mode 100644 index 0000000..89f0af5 --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/controller/SensorController.java @@ -0,0 +1,88 @@ + +package org.springblade.iot.controller; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.annotations.ApiParam; +import lombok.AllArgsConstructor; +import org.springblade.core.boot.ctrl.BladeController; +import org.springblade.core.mp.support.Condition; +import org.springblade.core.mp.support.Query; +import org.springblade.core.secure.utils.AuthUtil; +import org.springblade.core.tool.api.R; +import org.springblade.core.tool.utils.Func; +import org.springblade.iot.entry.Sensor; +import org.springblade.iot.service.ISensorService; +import org.springframework.web.bind.annotation.*; + +import java.util.Date; + +/** + * 物品申领表 控制器 + * + * @author swj + * @since 2022年8月17日16:35:34 + */ +@RestController +@AllArgsConstructor +@RequestMapping("/sensor") +@Api(value = "", tags = "") +public class SensorController extends BladeController { + + private final ISensorService service; + + /** + * 分页 + */ + @GetMapping("/list") + @ApiOperationSupport(order = 2) + public R list(Sensor entry, Query query) { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.orderByDesc(Sensor::getCreateTime); + IPage page = service.page(Condition.getPage(query), wrapper); + return R.data(page); + } + + /** + * 更改 + */ + @PostMapping("/update") + @ApiOperation(value = "更改", notes = "更改") + public R update(@RequestBody Sensor entry) { + return R.data(service.updateById(entry)); + } + + /** + * 新增 + */ + @PostMapping("/insert") + @ApiOperation(value = "新增", notes = "新增") + public R insert(@RequestBody Sensor entry) { + entry.setCreateTime(new Date()); + entry.setUpdateTime(new Date()); + entry.setCreateUser(AuthUtil.getUserId()); + entry.setUpdateUser(AuthUtil.getUserId()); + return R.data(service.save(entry)); + } + + /** + * 删除 + */ + @PostMapping("/deleteByIds") + @ApiOperation(value = "逻辑删除", notes = "传入ids") + public R deleteByIds(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) { + return R.status(service.deleteLogic(Func.toLongList(ids))); + } + + /** + * 根据id获取对应的Sensor + */ + @GetMapping("/getSensor") + public Sensor getReagent(String id) { + Sensor sensor = service.getById(id); + return sensor; + } +} diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/mapper/SensorMapper.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/mapper/SensorMapper.java new file mode 100644 index 0000000..46175ab --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/mapper/SensorMapper.java @@ -0,0 +1,15 @@ + +package org.springblade.iot.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.springblade.iot.entry.Sensor; + +/** + * + * + * @author swj + * @since 2022年8月17日16:37:29 + */ +public interface SensorMapper extends BaseMapper { + +} diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/service/ISensorService.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/service/ISensorService.java new file mode 100644 index 0000000..8e6f16c --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/service/ISensorService.java @@ -0,0 +1,13 @@ + +package org.springblade.iot.service; + + +import org.springblade.core.mp.base.BaseService; +import org.springblade.iot.entry.Sensor; + +/** + * @author swj + * @since 2022年8月17日16:39:35 + */ +public interface ISensorService extends BaseService { +} diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/service/impl/SensorServiceImpl.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/service/impl/SensorServiceImpl.java new file mode 100644 index 0000000..2d5eb1c --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/service/impl/SensorServiceImpl.java @@ -0,0 +1,22 @@ + +package org.springblade.iot.service.impl; + + +import lombok.AllArgsConstructor; +import org.springblade.core.mp.base.BaseServiceImpl; +import org.springblade.iot.entry.Sensor; +import org.springblade.iot.mapper.SensorMapper; +import org.springblade.iot.service.ISensorService; +import org.springframework.stereotype.Service; + + +/** + * @author swj + * @since 2022年8月17日16:39:58 + */ +@Service +@AllArgsConstructor +public class SensorServiceImpl extends BaseServiceImpl implements ISensorService { + + private final SensorMapper sensorMapper; +} diff --git a/lab-service/lab-iot/src/main/java/org/springblade/iot/utils/ReadModBusUtil.java b/lab-service/lab-iot/src/main/java/org/springblade/iot/utils/ReadModBusUtil.java new file mode 100644 index 0000000..7da74ed --- /dev/null +++ b/lab-service/lab-iot/src/main/java/org/springblade/iot/utils/ReadModBusUtil.java @@ -0,0 +1,120 @@ +package org.springblade.iot.utils; + +import com.serotonin.modbus4j.ModbusFactory; +import com.serotonin.modbus4j.ModbusMaster; +import com.serotonin.modbus4j.exception.ModbusInitException; +import com.serotonin.modbus4j.exception.ModbusTransportException; +import com.serotonin.modbus4j.ip.IpParameters; +import com.serotonin.modbus4j.msg.ReadHoldingRegistersRequest; +import com.serotonin.modbus4j.msg.ReadHoldingRegistersResponse; + +import java.util.ArrayList; +import java.util.List; + +/** + * @author swj + */ +public class ReadModBusUtil { + + static ModbusFactory modbusFactory; + + static { + if (modbusFactory == null) { + modbusFactory = new ModbusFactory(); + } + } + + public static void main(String[] args) throws InterruptedException { + // 1.获取tcp协议的主机(上位机) + ModbusMaster master = getTcpMaster("192.168.1.217", 502, 1); + // 2.初始化 + try { + master.init(); + while (0 == 0) { + // 3.读取保持寄存器数据 + readHoldingRegistersTest(master, 1, 0, 10); + Thread.sleep(1000L); + } + } catch (ModbusInitException e) { + e.printStackTrace(); + } finally { + // 销毁连接 + master.destroy(); + } + } + + /** + * 2 + */ + public static ModbusMaster getTcpMaster(String ip, int port, int salveId) { + IpParameters params = new IpParameters(); + params.setHost(ip); + if (port == 0) { + params.setPort(502); + } else { + params.setPort(port); + } + ModbusMaster tcpMaster = modbusFactory.createTcpMaster(params, true); + return tcpMaster; + } + + /** + * 3.读取保持寄存器上的内容 + * + * @param master 主站 + * @param slaveId 从站地址 + * @param start 起始地址的偏移量 + * @param len 待读寄存器的个数 + */ + private static void readHoldingRegistersTest(ModbusMaster master, int slaveId, int start, int len) { + try { + ReadHoldingRegistersRequest request = new ReadHoldingRegistersRequest(slaveId, start, len); + ReadHoldingRegistersResponse response = (ReadHoldingRegistersResponse) master.send(request); + if (response.isException()) { + System.out.println("Exception response: message=" + response.getExceptionMessage()); + } else { + byte[] data = response.getData(); + List floats = byteArrayToFloatList(data); + System.out.println("floats:" + floats); + } + } catch (ModbusTransportException e) { + e.printStackTrace(); + } + } + + /** + * 4.将byte类型的arr转换成float + */ + public static List byteArrayToFloatList(byte[] bytes){ + // index：0 1 2 3 + // byte：1-2 3-4 5-6 7-8 + // byte：2-1 4-3 6-5 8-7 + // 高低位转换操作：同一 + for (int i = 0; i < bytes.length; i++) { + if (i + 1 < bytes.length && i % 2 == 0) { + byte temp = bytes[i]; + bytes[i] = bytes[i + 1]; + bytes[i + 1] = temp; + } + } + List d = new ArrayList<>(bytes.length / 8); + byte[] doubleBuffer = new byte[4]; + for(int j = 0; j < bytes.length; j += 4) { + System.arraycopy(bytes, j, doubleBuffer, 0, doubleBuffer.length); + d.add(bytes2Float(doubleBuffer)); + } + return d; + } + + /** + * 5.将byte数组数据转换成float + */ + public static float bytes2Float(byte[] arr) { + int accum = 0; + accum = accum|(arr[0] & 0xff) << 0; + accum = accum|(arr[1] & 0xff) << 8; + accum = accum|(arr[2] & 0xff) << 16; + accum = accum|(arr[3] & 0xff) << 24; + return Float.intBitsToFloat(accum); + } +} diff --git a/lab-service/lab-lims/src/main/java/org/springblade/lims/mapper/ContractMapper.java b/lab-service/lab-lims/src/main/java/org/springblade/lims/mapper/ContractMapper.java index e432341..2259d72 100644 --- a/lab-service/lab-lims/src/main/java/org/springblade/lims/mapper/ContractMapper.java +++ b/lab-service/lab-lims/src/main/java/org/springblade/lims/mapper/ContractMapper.java @@ -3,7 +3,6 @@ package org.springblade.lims.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.springblade.lims.entry.Contract; -import org.springblade.lims.entry.Reagent; /** * diff --git a/lab-service/pom.xml b/lab-service/pom.xml index 56e1bd0..038e2f2 100644 --- a/lab-service/pom.xml +++ b/lab-service/pom.xml @@ -25,6 +25,7 @@ lab-repair lab-monitor lab-file + lab-iot