| | |
|---|
| | | public ResponseVO<Object> updataAirEquipmentInfo(@RequestBody List<String> listMac) { |
|---|
| | | AirDataReqInnerFrame airDataReqInnerFrame = new AirDataReqInnerFrame(); |
|---|
| | | A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_ATMOSPHERE_DATA.getCode(), airDataReqInnerFrame); |
|---|
| | | // WrapResponseCommonFrame<A5AtmosphereHeartbeatReportInnerFrame> wrapResponseCommonFrame = |
|---|
| | | // MainBoardInvokeSyncService.getInstance().sendRRPC(listMac.get(0), a5Frame, A5AtmosphereHeartbeatReportInnerFrame.class); |
|---|
| | | 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); |
|---|
| | | // //测试用的 |
|---|
| | | // String s = "{\"connectType\":\"FE\",\"crc32\":\"8685DF1B\",\"functionCode\":\"A5\",\"orderType\":\"84\",\"payload\":\"F0010022FFFF0101016666640000000000000000419D000000360089000000000002019300008CA14C69\",\"payloadLength\":\"002A\",\"validate\":true}"; |
|---|
| | | // CommonFrame commonFrame1 = JSON.parseObject(s, CommonFrame.class); |
|---|
| | | // AirDataProcessor.getInstance().process("a1JsfPG4iKW",macStr,commonFrame1); |
|---|
| | | AirDataProcessor.getInstance().process("a1JsfPG4iKW",macStr,commonFrame); |
|---|
| | | System.out.println(commonFrame + " -----------commonFrame"); |
|---|
| | | AirDataProcessor.getInstance().process("a1JsfPG4iKW", macStr, commonFrame); |
|---|
| | | if (commonFrame != null) { |
|---|
| | | success.add(macStr); |
|---|
| | | } else { |
|---|
