| | |
| | | Integer battIndex = dataSetList.get(0).getBattIndex(); |
| | | List<Integer> monNumList = dataSetList.stream().map(CKPowerDevBattRtDataSet::getMonNum).collect(Collectors.toList()); |
| | | //获取实时表数据并写入set表 |
| | | List<CKPowerDevBattRtData> rtDataList = dataService.getMonList(battIndex,monNumList); |
| | | //List<CKPowerDevBattRtData> rtDataList = dataService.getMonList(battIndex,monNumList); |
| | | List<CKPowerDevBattRtData> rtDataList = dataService.getAllMonList(battIndex); |
| | | CKPowerDevBattRtState state = stateService.get(battIndex); |
| | | CkpowerdevBattRsalarm rsAlarm = rsAlarmService.get(); |
| | | |
| | |
| | | //1.刷新rsAlarmSet,rtdataSet,rtState告警实时数据<指定默认刷第一组数据> |
| | | rsAlarmSetService.updateDataFromDataAndStateAndRsAlarmToSetHrStop(); |
| | | //设置state_set表 |
| | | mapper.update(stateSet,null); |
| | | UpdateWrapper stateRtWrapper=new UpdateWrapper(); |
| | | stateRtWrapper.eq("batt_index",0); |
| | | mapper.update(stateSet,stateRtWrapper); |
| | | //发送命令 |
| | | UpdateWrapper wrapper=new UpdateWrapper(); |
| | | wrapper.set("op_cmd",CMD_Constant.CMD_SetBattAlarm); |
| | | rsalarmSetMapper.update(null,wrapper); |
| | | //读取opCmd返回是否成功 |
| | | QueryWrapper<CkpowerdevBattRsalarmSet> query = Wrappers.query(); |
| | | Response opStatus = OpCmdUtil.getOpStatus(rsalarmSetMapper,query, CMD_Constant.CMD_SetBattAlarm,20,null); |
| | |
| | | rsAlarmSetService.updateDataFromDataAndStateAndRsAlarmToSetHrStop(); |
| | | //设置data_set表 |
| | | rtDataSetMapper.updateBatchInRsAlarm(setDto.getDataSetList()); |
| | | //发送命令 |
| | | UpdateWrapper wrapper=new UpdateWrapper(); |
| | | wrapper.set("op_cmd",CMD_Constant.CMD_SetBattAlarm); |
| | | rsalarmSetMapper.update(null,wrapper); |
| | | //读取opCmd返回是否成功 |
| | | QueryWrapper<CkpowerdevBattRsalarmSet> query = Wrappers.query(); |
| | | Response opStatus = OpCmdUtil.getOpStatus(rsalarmSetMapper,query, CMD_Constant.CMD_SetBattAlarm,20,null); |