增加路牌接口

src/main/java/com/zy/bms/controller/lp/LpInfoStateController.java

@@ -1,20 +1,42 @@
 package com.zy.bms.controller.lp;
 
-
+import com.zy.bms.common.ServerResponse;
+import com.zy.bms.entity.lp.LpInfoState;
+import com.zy.bms.service.lp.ILpInfoStateService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
-
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.annotation.Resource;
+
 /**
- * <p>
- * 设备-路牌 前端控制器
- * </p>
+ * 路牌设备
+ * 微信小程序 端接口
  *
- * @author chenyi
- * @since 2021-06-22
+ * @author yang xiao kun
+ * create on 2021/7/16
  */
 @RestController
-@RequestMapping("/builder/lp-info-state")
+@RequestMapping("/bms/api/lpapp")
 public class LpInfoStateController {
+    @Resource
+    private ILpInfoStateService lpInfoStateService;
+
+    /**
+     * 查询所有设备
+     */
+    @GetMapping("list.do")
+    public ServerResponse getListByUserId() {
+        return ServerResponse.success(lpInfoStateService.list());
+    }
+
 
+    /**
+     * 更新唤醒时间和阈值
+     */
+    @PostMapping("update.do")
+    public ServerResponse update(LpInfoState entity) {
+        return ServerResponse.success(lpInfoStateService.updateWakeAndThresh(entity));
+    }
 }

src/main/java/com/zy/bms/entity/lp/LpInfoState.java

@@ -4,7 +4,6 @@ import com.alibaba.fastjson.annotation.JSONField;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
-import lombok.EqualsAndHashCode;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
@@ -17,7 +16,6 @@ import java.time.LocalDateTime;
  * @since 2021-06-22
  */
 @Data
-@EqualsAndHashCode(callSuper = false)
 public class LpInfoState implements Serializable {
 
     private static final long serialVersionUID = 1L;
@@ -101,6 +99,11 @@ public class LpInfoState implements Serializable {
      */
     private Integer mode;
 
+    /**
+     * 状态 0:离线 1:在线
+     */
+    private Integer status;
+
     /**
      * 上传类型
      */

src/main/java/com/zy/bms/mapper/lp/LpInfoStateMapper.java

@@ -3,6 +3,7 @@ package com.zy.bms.mapper.lp;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.zy.bms.entity.lp.LpInfoState;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 import org.springframework.stereotype.Repository;
 
 /**
@@ -17,4 +18,10 @@ import org.springframework.stereotype.Repository;
 @Repository
 public interface LpInfoStateMapper extends BaseMapper<LpInfoState> {
 
+    /**
+     * 更新唤醒时间和阈值
+     *
+     * @param entity 实体类
+     */
+    int updateWakeAndThresh(@Param("entity") LpInfoState entity);
 }

src/main/java/com/zy/bms/service/lp/ILpInfoStateService.java

@@ -12,6 +12,7 @@ import com.zy.bms.entity.lp.LpInfoState;
  * @since 2021-06-22
  */
 public interface ILpInfoStateService extends IService<LpInfoState> {
+
     /**
      * 通过设备ID获取设备信息
      *
@@ -19,4 +20,11 @@ public interface ILpInfoStateService extends IService<LpInfoState> {
      */
     LpInfoState getByOpenNum(String openNum);
 
+
+    /**
+     * 更新唤醒时间和阈值
+     *
+     * @param entity 实体类
+     */
+    boolean updateWakeAndThresh(LpInfoState entity);
 }

src/main/java/com/zy/bms/service/lp/impl/LpInfoStateServiceImpl.java

@@ -3,10 +3,13 @@ package com.zy.bms.service.lp.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.zy.bms.entity.lp.LpInfoState;
 import com.zy.bms.mapper.lp.LpInfoStateMapper;
+import com.zy.bms.service.IPostMqttMsgService;
 import com.zy.bms.service.lp.ILpInfoStateService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+
 /**
  * <p>
  * 设备-路牌 服务实现类
@@ -18,8 +21,20 @@ import org.springframework.stereotype.Service;
 @Service
 public class LpInfoStateServiceImpl extends ServiceImpl<LpInfoStateMapper, LpInfoState> implements ILpInfoStateService {
 
+    @Resource
+    private IPostMqttMsgService postMqttMsgService;
+
     @Override
     public LpInfoState getByOpenNum(String openNum) {
         return baseMapper.selectOne(new QueryWrapper<LpInfoState>().eq("open_num", openNum));
     }
+
+    @Override
+    public boolean updateWakeAndThresh(LpInfoState entity) {
+        if (baseMapper.updateWakeAndThresh(entity) > 0) {
+            postMqttMsgService.setWakeAndThreshLp(entity.getOpenNum(), entity.getWakeInt(), entity.getThresh());
+            return true;
+        }
+        return false;
+    }
 }

src/main/resources/mapper/LpInfoStateMapper.xml

@@ -2,4 +2,11 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.zy.bms.mapper.lp.LpInfoStateMapper">
 
+    <update id="updateWakeAndThresh">
+        UPDATE
+        lp_info_state
+        SET wake_int = #{entity.wakeInt},
+        thresh  = #{entity.thresh}
+        WHERE open_num = #{entity.openNum}
+    </update>
 </mapper>