Skip to content

G
glinfo-api
提交 3a01765e authored 作者: 林业通's avatar 林业通
浏览文件
操作

温控修改

上级 4a5f5d4e
全部展开 隐藏空白字符变更
内嵌 并排
正在显示 包含 66 行增加 和 116 行删除
appapi/src/main/java/tech/glinfo/enbao/modules/mq/OutletParse.java
浏览文件 @ 3a01765e
...@@ -139,7 +139,7 @@ public class OutletParse implements IParse { ...@@ -139,7 +139,7 @@ public class OutletParse implements IParse {
}else if("1A".equals(datas.get("cmd"))) {//温控响应 }else if("1A".equals(datas.get("cmd"))) {//温控响应
String content = datas.get("content"); String content = datas.get("content");
logger.info("设置温控响应 : {}", content); logger.info("设置温控响应 : {}", content);
String content1 = redisUtils.get(device.getNumbering() + "temp"); /* String content1 = redisUtils.get(device.getNumbering() + "temp");
//设备响应成功之后修改数据，不用等30秒，页面体验好些 //设备响应成功之后修改数据，不用等30秒，页面体验好些
if ("00".equals(content)) { if ("00".equals(content)) {
if (content1 != null) { if (content1 != null) {
...@@ -155,7 +155,7 @@ public class OutletParse implements IParse { ...@@ -155,7 +155,7 @@ public class OutletParse implements IParse {
} }
} }
} }
redisUtils.delete(device.getNumbering() + "temp"); redisUtils.delete(device.getNumbering() + "temp");*/
}else if("20".equals(datas.get("cmd"))) {//事件上报 }else if("20".equals(datas.get("cmd"))) {//事件上报
//保存开关记录 //保存开关记录
......
appapi/src/main/java/tech/glinfo/enbao/modules/mq/SwitchParse.java
浏览文件 @ 3a01765e
...@@ -53,7 +53,7 @@ public class SwitchParse implements IParse { ...@@ -53,7 +53,7 @@ public class SwitchParse implements IParse {
new Thread(() -> { new Thread(() -> {
//检测有没待下发指令 //检测有没待下发指令
String send = redisUtils.get("device:sendtemp1:" + device.getNumbering()); String send = redisUtils.get("device:sendtemp:" + device.getNumbering());
if(send != null) { if(send != null) {
try { try {
Thread.sleep(500); Thread.sleep(500);
...@@ -61,18 +61,7 @@ public class SwitchParse implements IParse { ...@@ -61,18 +61,7 @@ public class SwitchParse implements IParse {
e.printStackTrace(); e.printStackTrace();
} }
mqProducer.sendT(send); mqProducer.sendT(send);
redisUtils.delete("device:sendtemp1:" + device.getNumbering()); redisUtils.delete("device:sendtemp:" + device.getNumbering());
}
//检测有没待下发指令
String send1 = redisUtils.get("device:sendtemp2:" + device.getNumbering());
if(send1 != null) {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
mqProducer.sendT(send1);
redisUtils.delete("device:sendtemp2:" + device.getNumbering());
} }
}).start(); }).start();
...@@ -146,7 +135,7 @@ public class SwitchParse implements IParse { ...@@ -146,7 +135,7 @@ public class SwitchParse implements IParse {
}else if("1A".equals(datas.get("cmd"))) {//温控响应 }else if("1A".equals(datas.get("cmd"))) {//温控响应
String content = datas.get("content"); String content = datas.get("content");
logger.info("设置温控响应 : {}", content); logger.info("设置温控响应 : {}", content);
String content1 = redisUtils.get(device.getNumbering() + "temp"); /* String content1 = redisUtils.get(device.getNumbering() + "temp");
//设备响应成功之后修改数据，不用等30秒，页面体验好些 //设备响应成功之后修改数据，不用等30秒，页面体验好些
if ("00".equals(content)) { if ("00".equals(content)) {
if (content1 != null) { if (content1 != null) {
...@@ -166,7 +155,7 @@ public class SwitchParse implements IParse { ...@@ -166,7 +155,7 @@ public class SwitchParse implements IParse {
} }
} }
} }
redisUtils.delete(device.getNumbering() + "temp"); redisUtils.delete(device.getNumbering() + "temp");*/
}else if("20".equals(datas.get("cmd"))) {//事件上报 }else if("20".equals(datas.get("cmd"))) {//事件上报
//保存开关记录 //保存开关记录
......
appapi/src/main/java/tech/glinfo/enbao/modules/sh/form/ShDeviceTempForm.java
浏览文件 @ 3a01765e
...@@ -17,49 +17,52 @@ public class ShDeviceTempForm { ...@@ -17,49 +17,52 @@ public class ShDeviceTempForm {
@ApiModelProperty(value = "设备ID") @ApiModelProperty(value = "设备ID")
@NotNull(message="设备ID不能为空") @NotNull(message="设备ID不能为空")
private Integer deviceId; private Integer deviceId;
/**
@ApiModelProperty(value = "状态1") * 高温
private Integer status; */
@ApiModelProperty(value = "状态2")
private Integer statusT;
@ApiModelProperty(value = "高温") @ApiModelProperty(value = "高温")
@NotNull(message="高温不能为空")
private Integer tempH; private Integer tempH;
/**
@ApiModelProperty(value = "分钟") * 状态 1开 2关
private Integer minuteH; */
@ApiModelProperty(value = "状态")
@ApiModelProperty(value = "秒") @NotNull(message="状态不能为空")
private Integer secondH; private Integer statusH;
/**
@ApiModelProperty(value = "低温") * 底温
*/
@ApiModelProperty(value = "底温")
@NotNull(message="底温不能为空")
private Integer tempL; private Integer tempL;
/**
@ApiModelProperty(value = "分钟") * 状态 1开 2关
private Integer minuteL; */
@ApiModelProperty(value = "状态")
@ApiModelProperty(value = "秒") @NotNull(message="状态不能为空")
private Integer secondL; private Integer statusL;
/**
* 高温
*/
@ApiModelProperty(value = "高温") @ApiModelProperty(value = "高温")
@NotNull(message="高温不能为空")
private Integer tempHT; private Integer tempHT;
/**
@ApiModelProperty(value = "分钟") * 状态 1开 2关
private Integer minuteHT; */
@ApiModelProperty(value = "状态")
@ApiModelProperty(value = "秒") @NotNull(message="状态不能为空")
private Integer secondHT; private Integer statusHT;
/**
@ApiModelProperty(value = "低温") * 高温
*/
@ApiModelProperty(value = "高温")
@NotNull(message="高温不能为空")
private Integer tempLT; private Integer tempLT;
/**
@ApiModelProperty(value = "分钟") * 状态 1开 2关
private Integer minuteLT; */
@ApiModelProperty(value = "状态")
@ApiModelProperty(value = "秒") @NotNull(message="状态不能为空")
private Integer secondLT; private Integer statusLT;
@ApiModelProperty(value = "开关标识")
private Integer flag;
} }
common/src/main/java/tech/glinfo/enbao/modules/sh/entity/ShDeviceTempEntity.java
浏览文件 @ 3a01765e
...@@ -33,60 +33,32 @@ public class ShDeviceTempEntity implements Serializable { ...@@ -33,60 +33,32 @@ public class ShDeviceTempEntity implements Serializable {
*/ */
private Integer tempH; private Integer tempH;
/** /**
* 分钟 * 状态 1开 2关
*/ */
private Integer minuteH; private Integer statusH;
/** /**
* 秒 * 底温
*/
private Integer secondH;
/**
* 高温
*/ */
private Integer tempL; private Integer tempL;
/** /**
* 分钟 * 状态 1开 2关
*/
private Integer minuteL;
/**
* 秒
*/ */
private Integer secondL; private Integer statusL;
/** /**
* 高温 * 高温
*/ */
private Integer tempHT; private Integer tempHT;
/** /**
* 分钟 * 状态 1开 2关
*/
private Integer minuteHT;
/**
* 秒
*/ */
private Integer secondHT; private Integer statusHT;
/** /**
* 高温 * 高温
*/ */
private Integer tempLT; private Integer tempLT;
/**
* 分钟
*/
private Integer minuteLT;
/**
* 秒
*/
private Integer secondLT;
/**
* 创建时间
*/
private Date createTime;
/**
* 状态 1开 2关
*/
private Integer status;
/** /**
* 状态 1开 2关 * 状态 1开 2关
*/ */
private Integer statusT; private Integer statusLT;
} }
common/src/main/resources/mapper/sh/ShDeviceTempDao.xml
浏览文件 @ 3a01765e
...@@ -8,20 +8,13 @@ ...@@ -8,20 +8,13 @@
<result property="id" column="id"/> <result property="id" column="id"/>
<result property="deviceId" column="device_id"/> <result property="deviceId" column="device_id"/>
<result property="tempH" column="temp_h"/> <result property="tempH" column="temp_h"/>
<result property="minuteH" column="minute_h"/> <result property="statusH" column="status_h"/>
<result property="secondH" column="second_h"/>
<result property="tempL" column="temp_l"/> <result property="tempL" column="temp_l"/>
<result property="minuteL" column="minute_l"/> <result property="statusL" column="status_l"/>
<result property="secondL" column="second_l"/>
<result property="tempHT" column="temp_h_t"/> <result property="tempHT" column="temp_h_t"/>
<result property="minuteHT" column="minute_h_t"/> <result property="statusHT" column="status_h_t"/>
<result property="secondHT" column="second_h_t"/>
<result property="tempLT" column="temp_l_t"/> <result property="tempLT" column="temp_l_t"/>
<result property="minuteLT" column="minute_l_t"/> <result property="statusLT" column="status_l_t"/>
<result property="secondLT" column="second_l_t"/>
<result property="createTime" column="create_time"/>
<result property="status" column="status"/>
<result property="statusT" column="status_t"/>
</resultMap> </resultMap>
......
doc/sql/12-24.sql
浏览文件 @ 3a01765e
...@@ -168,20 +168,13 @@ CREATE TABLE `sh_device_temp` ( ...@@ -168,20 +168,13 @@ CREATE TABLE `sh_device_temp` (
`id` int(11) NOT NULL AUTO_INCREMENT, `id` int(11) NOT NULL AUTO_INCREMENT,
`device_id` int(11) DEFAULT NULL COMMENT '设备ID', `device_id` int(11) DEFAULT NULL COMMENT '设备ID',
`temp_h` int(10) DEFAULT NULL COMMENT '高温', `temp_h` int(10) DEFAULT NULL COMMENT '高温',
`minute_h` int(10) DEFAULT NULL COMMENT '分钟', `status_h` tinyint(2) DEFAULT NULL COMMENT '状态 0关 1开',
`second_h` int(10) DEFAULT NULL COMMENT '秒', `temp_l` int(10) DEFAULT NULL COMMENT '秒',
`temp_l` int(10) DEFAULT NULL COMMENT '高温', `status_l` tinyint(2) DEFAULT NULL COMMENT '状态 0关 1开',
`minute_l` int(10) DEFAULT NULL COMMENT '分钟', `temp_h_t` int(10) DEFAULT NULL COMMENT '分钟',
`second_l` int(10) DEFAULT NULL COMMENT '秒', `status_h_t` tinyint(2) DEFAULT NULL COMMENT '状态 0关 1开',
`temp_h_t` int(10) DEFAULT NULL COMMENT '高温',
`minute_h_t` int(10) DEFAULT NULL COMMENT '分钟',
`second_h_t` int(10) DEFAULT NULL COMMENT '秒',
`temp_l_t` int(10) DEFAULT NULL COMMENT '高温', `temp_l_t` int(10) DEFAULT NULL COMMENT '高温',
`minute_l_t` int(10) DEFAULT NULL COMMENT '分钟', `status_l_t` tinyint(2) DEFAULT NULL COMMENT '状态 0关 1开',
`second_l_t` int(10) DEFAULT NULL COMMENT '秒',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`status` tinyint(2) DEFAULT '2' COMMENT '状态 1开 2关',
`status_t` tinyint(2) DEFAULT '2' COMMENT '状态 1开 2关',
PRIMARY KEY (`id`) USING BTREE, PRIMARY KEY (`id`) USING BTREE,
KEY `sh_device_temp_device_id` (`device_id`) USING BTREE KEY `sh_device_temp_device_id` (`device_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='设备温度控制'; ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='设备温度控制';
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论