功能完善

liuhaonan

2022-02-15 fa3ece9c09af10534a5d08e49d6c6ce0dde1c4f9

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

@@ -1,9 +1,16 @@
package com.sandu.ximon.admin.controller;

import com.sandu.common.domain.ResponseVO;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.util.ResponseUtil;
import com.sandu.ximon.admin.manager.iot.frame.FrameBuilder;
import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.request.AirDataReqInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.AtmoFunctionCode;
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.service.AirDataService;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.bo.AirDataBo;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.*;

@@ -18,20 +25,39 @@
public class AirDataController {
    private final AirDataService airDataService;

    @GetMapping
    public ResponseVO<Object> listAirData() {
        List<AirData> list = airDataService.listAirData();
    /**
     * 查询大气数据模糊查询
     *
     * @param keyword 关键字
     * @return
     */
    @GetMapping("/listAirData")
    public ResponseVO<Object> listAirDataByKeyword(BaseConditionVO baseConditionVO, @RequestParam(required = false) String keyword) {
        List<AirDataBo> list = airDataService.listAirDataByKeyword(baseConditionVO, keyword);
        return ResponseUtil.successPage(list);
    }

    /**
     * 查询大气设备MAC地址
     *
     * @return
     */
    @GetMapping("/listAirEquipmentMAC")
    public ResponseVO<Object> listAirEquipmentMAC() {
        List<String> list = airDataService.listAirEquipmentMAC();
        return ResponseUtil.successPage(list);
        return ResponseUtil.success(list);
    }

    @PostMapping("/updateAirEquipmentInfo")
    public ResponseVO<Object> updataAirEquipmentInfo(@RequestBody List<String> listMac) {

        IRequestFrame build = FrameBuilder.builderA5().innerFrame(new AirDataReqInnerFrame())
                .orderType(AtmoFunctionCode.QueryHeartBeat.getCode()).build();
//A5Frame frame=new A5Frame(AtmoFunctionCode.QueryHeartBeat.getCode(),build);

        CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(listMac.get(0), build);

        return ResponseUtil.success(commonFrame);
    }

}