更新

whycxzp

2023-12-20 022c4c7f652f3bcde6466de6fb1e30ca73091d4a

更新

 src/main/java/com/whyc/pojo/db_ckpwrdev_data_rt/CKPowerDevHrTestParam.java

@@ -4,10 +4,12 @@
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import io.swagger.models.auth.In;
import lombok.Data;

/**
 * 核容测试遥测量
 */
@Data
@TableName(schema = "db_ckpwrdev_data_rt",value = "tb_ckpowerdev_hrtestparam")
public class CKPowerDevHrTestParam {


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

@@ -20,12 +20,23 @@
    @Autowired
    private CKPwrDevInfService ckPwrDevInfService;

    public List<CKPowerDevBattRtData> getList() {
    /**
     * 首页只显示1组,目前只有1组
     * 但是其他地方,均按多组处理
     * @return
     */
    public List<CKPowerDevBattRtData> getList(Integer index) {
        //查询有单体数量
        CKPwrDevInf ckPwrDevInf = ckPwrDevInfService.get();

        QueryWrapper<CKPowerDevBattRtData> query = Wrappers.query();
        query.eq("batt_index",0);
        if(index!=null) {
            if(index == -1){ //首页查询使用,只查询组1
                query.eq("batt_index", 0);
            }else {
                query.eq("batt_index", index);
            }
        }
        query.le("mon_num",ckPwrDevInf.getBattMonCount());
        return mapper.selectList(query);
    }

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

@@ -15,4 +15,8 @@
    public void update(CKPowerDevBattRtDataSet set) {
        mapper.update(set,null);
    }

    public void updateBatch(CKPowerDevBattRtDataSet set) {
        mapper.update(set,null);
    }
}

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

@@ -7,15 +7,15 @@
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevBattRtStateSetMapper;
import com.whyc.mapper.CKPowerDevBattSetLogMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtDataSet;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtStateSet;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattSetLog;
import com.whyc.pojo.db_ckpwrdev_data_rt.*;
import com.whyc.util.OpCmdUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;

@Service
@@ -36,18 +36,21 @@
    @Autowired
    private CKPowerDevBattRtDataService dataService;

    @Autowired
    private CKPowerDevBattRtStateService stateService;

    public Response update(BattRtSetDto set) {
        CKPowerDevBattRtDataSet dataSet = set.getDataSet();
        CKPowerDevBattRtStateSet stateSet = set.getStateSet();
        updateDataFromDataAndStateToSet();
        updateDataFromDataAndStateToSet(dataSet.getBattIndex());
        //设置state_set表,与李军沟通确定,组端和单体设置,都采用设置下面这个cmd值.因为单体和组端会一起设置
        stateSet.setOpCmd(CMD_Constant.CMD_SetBatt1MonData);
        mapper.update(stateSet,null);
        //设置data_set表
        //设置data_set表 TODO 待确定是设置单体时 所有单体还是某个单体
        dataSetService.update(dataSet);
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevBattRtStateSet> query = Wrappers.query();
        Response opStatus =OpCmdUtil.getOpStatus(mapper, query, set.getStateSet().getOpCmd(),20,set.getStateSet().getBattIndex());
        Response opStatus =OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_SetBatt1MonData,20,set.getStateSet().getBattIndex());
        if(opStatus.getData()!=null && (boolean)opStatus.getData()) { //成功
            //记录日志
            Date now = new Date();
@@ -64,7 +67,21 @@
        return opStatus;
    }

    private void updateDataFromDataAndStateToSet() {
        //TODO
    private void updateDataFromDataAndStateToSet(Integer battIndex) {
        List<CKPowerDevBattRtData> rtDataList = dataService.getList(battIndex);
        CKPowerDevBattRtState state = stateService.get();

        //属性迁移
        List<CKPowerDevBattRtDataSet> rtSetDataList = new LinkedList<>();
        CKPowerDevBattRtStateSet stateSet = new CKPowerDevBattRtStateSet();
        for (CKPowerDevBattRtData temp : rtDataList) {
            CKPowerDevBattRtDataSet set = new CKPowerDevBattRtDataSet();
            BeanUtils.copyProperties(temp,set);
            rtSetDataList.add(set);
        }
        BeanUtils.copyProperties(state,stateSet);
        //rt表数据更新到set表中 TODO 待确定是设置单体时 所有单体还是某个单体
        //dataSetService.update();

    }
}

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

@@ -2,9 +2,12 @@

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.constant.CMD_Constant;
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevHrTestParamMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtStateSet;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevHrTestParam;
import com.whyc.util.OpCmdUtil;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -22,7 +25,9 @@
    }

    public Response update(CKPowerDevHrTestParam set) {
        set.setOpCmd(CMD_Constant.CMD_GetBattDisParam);
        mapper.update(set,null);
        return new Response().set(1,"设置完成");
        QueryWrapper<CKPowerDevHrTestParam> query = Wrappers.query();
        return OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_GetBattDisParam,20,null);
    }
}

 src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java

@@ -71,7 +71,7 @@
                        CKPowerDevRt ckPowerDevRt = ckPowerDevRtService.get();
                        CKPowerDevSignal ckPowerDevSignal = ckPowerDevSignalService.get();
                        CKPowerDevBattRtState ckPowerDevBattRtState = ckPowerDevBattRtStateService.get();
                        List<CKPowerDevBattRtData> ckPowerDevBattRtData = ckPowerDevBattRtDataService.getList();
                        List<CKPowerDevBattRtData> ckPowerDevBattRtData = ckPowerDevBattRtDataService.getList(-1);
                        session.getBasicRemote().sendObject(new Response<>().setV(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,ckPowerDevBattRtData,new Date(),"查询完成"));
                        sleep(4000);
                    }