package com.sandu.ximon.admin.controller;
|
|
import com.sandu.common.domain.ResponseVO;
|
import com.sandu.common.object.BaseConditionVO;
|
import com.sandu.common.security.annotation.AnonymousAccess;
|
import com.sandu.common.util.ResponseUtil;
|
import com.sandu.ximon.admin.manager.iot.amqp.processor.AirDataProcessor;
|
import com.sandu.ximon.admin.manager.iot.frame.A5Frame;
|
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.A5OrderEnum;
|
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
|
import com.sandu.ximon.admin.security.PermissionConfig;
|
import com.sandu.ximon.admin.service.AirDataService;
|
import com.sandu.ximon.dao.bo.AirDataBo;
|
import com.sandu.ximon.dao.enums.MenuEnum;
|
import lombok.AllArgsConstructor;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 大气数据
|
*/
|
@RestController
|
@AllArgsConstructor
|
@RequestMapping("/v1/admin/airdata")
|
public class AirDataController {
|
private final AirDataService airDataService;
|
private PermissionConfig permissionConfig;
|
|
/**
|
* 查询大气数据模糊查询
|
*
|
* @param keyword 关键字
|
* @return
|
*/
|
@GetMapping("/listAirData")
|
public ResponseVO<Object> listAirDataByKeyword(BaseConditionVO baseConditionVO, @RequestParam(required = false) String keyword) {
|
if (!permissionConfig.check(MenuEnum.AIR_DATA_LIST.getCode())) {
|
return ResponseUtil.fail("缺少对应用户权限");
|
}
|
List<AirDataBo> list = airDataService.listAirDataByKeyword(baseConditionVO, keyword);
|
return ResponseUtil.successPage(list);
|
}
|
|
@PostMapping("/updateAirEquipmentInfo")
|
public ResponseVO<Object> updataAirEquipmentInfo(@RequestBody List<String> listMac) {
|
if (!permissionConfig.check(MenuEnum.AIR_DATA_UPDATE.getCode())) {
|
return ResponseUtil.fail("缺少对应用户权限");
|
}
|
AirDataReqInnerFrame airDataReqInnerFrame = new AirDataReqInnerFrame();
|
A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_ATMOSPHERE_DATA.getCode(), airDataReqInnerFrame);
|
System.out.println(a5Frame + " --------a5Frame");
|
|
List<String> success = new ArrayList<>();
|
List<String> failed = new ArrayList<>();
|
|
listMac.parallelStream().forEach(macStr -> {
|
try {
|
CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(macStr, a5Frame);
|
System.out.println(commonFrame + " -----------commonFrame");
|
AirDataProcessor.getInstance().process("a1JsfPG4iKW", macStr, commonFrame);
|
if (commonFrame != null) {
|
success.add(macStr);
|
} else {
|
failed.add(macStr);
|
}
|
} catch (Exception e) {
|
failed.add(macStr);
|
}
|
});
|
|
Map<String, List> resultMap = new HashMap<>();
|
resultMap.put("success", success);
|
resultMap.put("failed", failed);
|
|
return ResponseUtil.success(resultMap);
|
}
|
|
}
|
