更新设置逻辑,先实时表设置set表后set表更新

whycxzp

2023-12-06 e34d5e400b85d59d48d4b427ebbb4ebd6cb0a6a1

更新设置逻辑,先实时表设置set表后set表更新

 src/main/java/com/whyc/mapper/CKPowerDevRtMapper.java

@@ -1,6 +1,9 @@
package com.whyc.mapper;

import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSet;

public interface CKPowerDevRtMapper extends CustomMapper<CKPowerDevRt>{

    CKPowerDevRtSet getForSet();
}

 src/main/java/com/whyc/mapper/CKPowerDevSignalMapper.java

@@ -1,6 +1,9 @@
package com.whyc.mapper;

import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignal;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignalSet;

public interface CKPowerDevSignalMapper extends CustomMapper<CKPowerDevSignal>{

    CKPowerDevSignalSet getForSet();
}

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

@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.mapper.CKPowerDevRtMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSet;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -22,4 +23,8 @@
        query.last(" limit 1");
        return mapper.selectOne(query);
    }

    public CKPowerDevRtSet getForSet() {
        return mapper.getForSet();
    }
}

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

@@ -1,12 +1,15 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.constant.CMD_Constant;
import com.whyc.dto.Response;
import com.whyc.mapper.CKPowerDevRtSetMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSet;
import com.whyc.util.OpCmdUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -17,7 +20,12 @@
    @Resource
    private CKPowerDevRtSetMapper mapper;

    @Autowired
    private CKPowerDevRtService rtService;

    public Response update(CKPowerDevRtSet set) {
        //查询rt表数据并设置到set表
        updateDataFromRtToSet();
        //更新电源设备设置
        mapper.update(set,null);
        //读取opCmd返回是否成功
@@ -25,4 +33,9 @@
        return OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_SetACDCARK_Telemetry,20,null);
    }

    private void updateDataFromRtToSet() {
        CKPowerDevRtSet set = rtService.getForSet();
        mapper.update(set,null);
    }

}

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

@@ -5,6 +5,7 @@
import com.whyc.mapper.CKPowerDevSignalMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignal;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignalSet;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -24,4 +25,8 @@
        query.last(" limit 1");
        return mapper.selectOne(query);
    }

    public CKPowerDevSignalSet getForSet() {
        return mapper.getForSet();
    }
}

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

@@ -7,6 +7,7 @@
import com.whyc.mapper.CKPowerDevSignalSetMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignalSet;
import com.whyc.util.OpCmdUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -17,10 +18,20 @@
    @Resource
    private CKPowerDevSignalSetMapper mapper;

    @Autowired
    private CKPowerDevSignalService signalService;

    public Response update(CKPowerDevSignalSet set) {
        //查询signal表数据并设置到set表
        updateDataFromSignalToSet();
        mapper.update(set,null);
        //读取opCmd返回是否成功
        QueryWrapper<CKPowerDevSignalSet> query = Wrappers.query();
        return OpCmdUtil.getOpStatus(mapper, query, CMD_Constant.CMD_SetACDCARK_Signal,20,null);
    }

    private void updateDataFromSignalToSet() {
        CKPowerDevSignalSet set = signalService.getForSet();
        mapper.update(set,null);
    }
}

 src/main/resources/mapper/CKPowerDevRtMapper.xml

New file
@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.CKPowerDevRtMapper" >


    <select id="getForSet" resultType="com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRtSet">
        select * from db_ckpwrdev_data_rt.tb_ckpowerdev_rt limit 1
    </select>
</mapper>

 src/main/resources/mapper/CKPowerDevSignalMapper.xml

New file
@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.CKPowerDevSignalMapper" >


    <select id="getForSet" resultType="com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignalSet">
        select * from db_ckpwrdev_data_rt.tb_ckpowerdev_signal limit 1
    </select>
</mapper>