核容装置告警设置修改刷新第一组信息，然后修改告警表数据

whyclxw

2024-01-17 3088bef8cb4f9a2513f96175a4349840719c3ea9

核容装置告警设置修改刷新第一组信息，然后修改告警表数据

 src/main/java/com/whyc/controller/CkpowerdevBattRsalarmSetController.java

@@ -20,7 +20,7 @@
    @Autowired
    private CkpowerdevBattRsalarmSetService service;

    @ApiOperation("实时状态设置")
    @ApiOperation("告警设置")
    @PostMapping("setDevAlm")
    public Response setDevAlm(@RequestBody DevalarmSet almSet){
        return service.setDevAlm(almSet);

 src/main/java/com/whyc/service/CKPowerDevBattRtDataService.java

@@ -56,4 +56,11 @@
        query.in("mon_num",monNumList);
        return mapper.selectList(query);
    }
    //获取默认第一组单体数据刷新至第一组0
    public List<CKPowerDevBattRtData> getDataList_index0() {
        QueryWrapper<CKPowerDevBattRtData> wrapper = Wrappers.query();
        wrapper.eq("batt_index",0);
        wrapper.orderByAsc("mon_num");
        return mapper.selectList(wrapper);
    }
}

 src/main/java/com/whyc/service/CKPowerDevBattRtStateService.java

@@ -27,4 +27,11 @@
        query.last(" limit 1");
        return mapper.selectOne(query);
    }
    //获取rtState默认第一组0表数据更新到set表中
    public CKPowerDevBattRtState getStateLsit_index0(int i) {
        QueryWrapper<CKPowerDevBattRtState> query = Wrappers.query();
        query.eq("batt_index", 0);
        query.last(" limit 1");
        return mapper.selectOne(query);
    }
}

 src/main/java/com/whyc/service/CkpowerdevBattRsalarmSetService.java

@@ -45,19 +45,19 @@
    @Resource
    private CkpowerdevBattRsalarmSetLogService setLogService;

    //实时状态设置
    //告警设置
    public Response setDevAlm(DevalarmSet almSet) {
        List<CKPowerDevBattRtDataSet> dataSetList = almSet.getRtDataSetList();
        Integer battIndex = dataSetList.get(0).getBattIndex();
        //1.刷新rsAlarmSet，rtDataSet，rtStateSet实时数据
        updateDataFromDataAndStateAndRsAlarmToSet(almSet.getRtDataSetList());
        //List<CKPowerDevBattRtDataSet> dataSetList = almSet.getRtDataSetList();
        //Integer battIndex = dataSetList.get(0).getBattIndex();
        //1.刷新rsAlarmSet，rtdataSet,rtState告警实时数据<指定默认刷第一组数据>
        updateDataFromDataAndStateAndRsAlarmToSet();

        //修改rsAlarmSet
        rsalarmSetMapper.update(almSet.getRsAlmSet(),null);
        //设置data_set表
        rtDataSetMapper.updateBatchInRsAlarm(dataSetList);
        //rtDataSetMapper.updateBatchInRsAlarm(dataSetList);
        //设置state_set表
        rtStateSetMapper.update(almSet.getRtStateSet(),null);
        //rtStateSetMapper.update(almSet.getRtStateSet(),null);
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevAlmParam> query = Wrappers.query();
        Response opStatus = OpCmdUtil.getOpStatus(rsalarmSetMapper,query, CMD_Constant.CMD_SetBattAlarm,20,null);
@@ -77,8 +77,29 @@
        }
        return opStatus;
    }

    private void updateDataFromDataAndStateAndRsAlarmToSet(List<CKPowerDevBattRtDataSet> dataSetList) {
    //1.刷新rsAlarmSet，rtdataSet,rtState告警实时数据<指定默认刷第一组数据>
    private void updateDataFromDataAndStateAndRsAlarmToSet() {
        //获取默认第一组单体数据刷新至第一组0
        List<CKPowerDevBattRtData> rtDataList = dataService.getDataList_index0();
        List<CKPowerDevBattRtDataSet> rtSetDataList = new LinkedList<>();
        CKPowerDevBattRtStateSet stateSet = new CKPowerDevBattRtStateSet();
        for (CKPowerDevBattRtData temp : rtDataList) {
            CKPowerDevBattRtDataSet set = new CKPowerDevBattRtDataSet();
            BeanUtils.copyProperties(temp,set);
            rtSetDataList.add(set);
        }
        rtDataSetMapper.updateBatch(rtSetDataList);
        //获取rtState默认第一组0表数据更新到set表中
        CKPowerDevBattRtState state = stateService.getStateLsit_index0(0);
        BeanUtils.copyProperties(state,stateSet);
        updateStateSet(stateSet);
        //获取rsalarm更新到set表中
        CkpowerdevBattRsalarm rsalarm=rsAlarmService.get();
        CkpowerdevBattRsalarmSet rsalarmSet=new CkpowerdevBattRsalarmSet();
        BeanUtils.copyProperties(rsalarm,rsalarmSet);
        updateRsAlarmSet(rsalarmSet);
    }
    private void updateDataFromDataAndStateAndRsAlarmToSet1(List<CKPowerDevBattRtDataSet> dataSetList) {
        Integer battIndex = dataSetList.get(0).getBattIndex();
        List<Integer> monNumList = dataSetList.stream().map(CKPowerDevBattRtDataSet::getMonNum).collect(Collectors.toList());
        //获取rtData数据并写入set表