MQTT

zhanzhiqin

2022-10-19 2b9c6e86f1fb2abd7ad7f1a8d74d3fcd515da858

MQTT

 dao/src/main/java/com/sandu/ximon/dao/enums/MenuEnum.java

@@ -64,6 +64,7 @@
    BANNER("微信logo"),
    POLE_LIST("灯杆列表"),
    LIGHT_POLE_HEELING_LIST("灯杆倾斜"),
    MQTT_TEST("MQTT测试"),

    //按钮权限
    ADMIN_ADD("新增管理员"),

 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/MQTTTestController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,73 @@
package com.sandu.ximon.admin.controller;

import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.util.StringUtil;
import com.sandu.common.domain.CommonPage;
import com.sandu.common.domain.ResponseVO;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.util.ResponseUtil;
import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.InvokeParam;
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.param.MonitorParam;
import com.sandu.ximon.admin.security.PermissionConfig;
import com.sandu.ximon.admin.service.PoleService;
import com.sandu.ximon.dao.domain.Pole;
import com.sandu.ximon.dao.enums.MenuEnum;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;

/**
 * MQTT测试
 *
 * @author ZZQ
 * @date 2022/10/19 15:49
 */
@RestController
@AllArgsConstructor
@RequestMapping("/v1/admin/mqtt")
public class MQTTTestController {
    private PermissionConfig permissionConfig;

    /**
     * æ¨¡ç³ŠæŸ¥è¯¢
     *
     * @return
     */
    @GetMapping("/sendRRPC")
    public ResponseVO<Object> listMonitorByKeyword(@RequestParam(value = "poleId", required = false) Long poleId,
                                                   @RequestParam(value = "frameStr", required = false) String frameStr) {
        if (poleId == null) {
            throw new BusinessException("灯杆ID不能为空！");
        }

        if (StringUtil.isEmpty(frameStr)) {
            throw new BusinessException("请求帧数据不能为空！");
        }
        if (!permissionConfig.check(MenuEnum.MQTT_TEST.getCode())) {
            return ResponseUtil.fail("缺少对应用户权限");
        }


        Pole pole = SpringContextHolder.getBean(PoleService.class).getById(poleId);
        if (pole == null) {
            throw new BusinessException("灯杆不存在！");
        }

        if (StringUtil.isEmpty(pole.getDeviceCode())) {
            throw new BusinessException("灯杆MAC不能为空！");
        }

        InvokeParam param = new InvokeParam();
        param.setOperate("1001");
        param.setFrame(frameStr);
        CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(pole.getDeviceCode(), param);
        if (commonFrame == null) {
            throw new BusinessException("请求失败，请重新请求");
        }
        return ResponseUtil.success(commonFrame);
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/frame/inner/report/A5AtmosphereHeartbeatReportInnerFrame.java

@@ -22,8 +22,6 @@
    //  å¿ƒè·³åŒ…数据   58
    private HeartBeatDataPackage heartBeatDataPackage;

    private String originFrame;

    @Override
    public A5AtmosphereHeartbeatReportInnerFrame transformFrame(String hex) {
        //  é•¿åº¦ä¸ä¸€è‡´æ—¶ï¼Œè¿”回null

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/rrpc/BaseInvokeSyncService.java

@@ -51,6 +51,19 @@
    }

    @Override
    public CommonFrame sendRRPC(String deviceName, InvokeParam invokeParam) {
        InvokeThingServiceResponse.Data data = invokeThing(deviceName, invokeParam, false);
        if (data == null) {
            return null;
        }
        String result = data.getResult();
        result = result.replace("\\", "");
        Map map = JSON.parseObject(result, Map.class);
        result = (String) map.get("msg");
        return FrameUtils.transformMessageToFrame(result);
    }

    @Override
    public CommonFrame sendRRPC(String deviceName, IRequestFrame iRequestFrame) {
        InvokeParam param = new InvokeParam();
        param.setOperate("1001");

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/rrpc/topic/ICustomizeTopic.java

@@ -25,6 +25,15 @@
     * å‘送rrpc è¯·æ±‚
     *
     * @param deviceName    è®¾å¤‡å
     * @param invokeParam å¸§å†…容
     * @return è¿”回的解码帧实体类
     */
    CommonFrame sendRRPC(String deviceName, InvokeParam invokeParam);

    /**
     * å‘送rrpc è¯·æ±‚
     *
     * @param deviceName    è®¾å¤‡å
     * @param iRequestFrame ç¼–码帧
     * @return è¿”回的解码帧实体类
     */