websocket接口更新,service的方法添加@Transactional

whyczh

2022-02-25 4a30902d68dfbb00fb62780e96dea7cd00f77549

websocket接口更新,service的方法添加@Transactional

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

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

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.BattGtstateMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -15,6 +17,7 @@
    private BattGtstateMapper mapper;

    //根据电池组id查询储能电池组信息
    @Transactional
    public Response serchByCondition(int battGroupId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("BattGroupId",battGroupId);

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

@@ -5,6 +5,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.BattRsalarmMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -14,6 +15,7 @@
    @Resource
    private BattRsalarmMapper mapper;
    //电池组组端告警
    @Transactional
    public Response getInfo(int battGroupId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("battGroupId",battGroupId);

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

@@ -7,6 +7,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.BattRtalarmMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -16,6 +17,7 @@
    @Resource
    private BattRtalarmMapper mapper;
    //电池告警
    @Transactional
    public Response getInfo(int battGroupId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("battGroupId",battGroupId);

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

@@ -7,11 +7,13 @@
import com.whyc.pojo.BattRtdata;
import com.whyc.pojo.BattRtstate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

@Service
@Transactional
public class BattRtdataService {

    @Resource

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

@@ -13,11 +13,13 @@
import com.whyc.pojo.UserInf;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

@Service
@Transactional
public class BattRtstateService {



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

@@ -4,6 +4,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.Ess3100PcsStateMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -16,6 +17,7 @@


    //查询所有的pcs状态信息
    @Transactional
    public Response searchAll() {
        List list=mapper.selectList(null);
        PageInfo pageInfo=new PageInfo(list);

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

@@ -5,6 +5,7 @@
import com.whyc.mapper.Ess3100SysstateMapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -15,6 +16,7 @@
    private Ess3100SysstateMapper mapper;

    //查询所有的系统状态信息
    @Transactional
    public Response searchAll() {
        List list=mapper.selectList(null);
        PageInfo pageInfo=new PageInfo(list);

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

@@ -5,6 +5,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.Fbs9100ChargerstateMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -14,6 +15,7 @@
    @Resource
    private Fbs9100ChargerstateMapper mapper;
    //获取充电机的实时信息
    @Transactional
    public Response getDataByDevId(int powerDeviceId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("PowerDeviceId",powerDeviceId);

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

@@ -5,6 +5,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.Fbs9100InsulatstateMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -15,6 +16,7 @@
    private Fbs9100InsulatstateMapper mapper;

    //获取绝缘装置的实时信息
    @Transactional
    public Response getDataByDevId(int powerDeviceId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("PowerDeviceId",powerDeviceId);

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

@@ -11,6 +11,8 @@
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import javax.xml.crypto.Data;
import java.text.SimpleDateFormat;
@@ -18,6 +20,7 @@
import java.util.List;

@Service
@Transactional
public class Fbs9100StateService {
    @Resource
    private Fbs9100StateMapper mapper;

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

@@ -6,6 +6,7 @@
import com.whyc.mapper.Fbs9100sFodStateMapper;
import com.whyc.pojo.Fbs9100sFodState;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

@@ -15,6 +16,7 @@
    @Resource
    private Fbs9100sFodStateMapper mapper;
    //获取剩余天数，工作模式，组端电压，峰值电
    @Transactional
    public Response serchByCondition(int battGroupId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("battGroupId",battGroupId);

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

@@ -7,6 +7,7 @@
import com.whyc.pojo.Ld9State;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
@@ -19,6 +20,7 @@
    private Ld9StateMapper mapper;

    //通过设备id查询LD9数据
    @Transactional
    public Response searchByDevId(int devId) {
        PageHelper.startPage(1,1);
        QueryWrapper wrapper=new QueryWrapper();

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

@@ -6,6 +6,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.Li9130BmsStateMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -16,6 +17,7 @@
    @Resource
    private Li9130BmsStateMapper mapper;
    //读取模拟量
    @Transactional
    public Response searchParam(int devId) {
        PageHelper.startPage(1,4);
        QueryWrapper wrapper=new QueryWrapper();

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

@@ -5,6 +5,7 @@
import com.whyc.dto.Response;
import com.whyc.mapper.LithiumDataMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;
@@ -15,6 +16,7 @@
    private LithiumDataMapper mapper;

    //根据电池id查询锂电池信息
    @Transactional
    public Response getInfoByBattGroupId(int battGroupId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("BattGroupId",battGroupId);

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

@@ -10,6 +10,7 @@
import com.whyc.pojo.PwrdevAcdcdata;
import com.whyc.pojo.PwrdevDcdata;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.HashMap;
@@ -17,6 +18,7 @@
import java.util.Map;

@Service
@Transactional
public class PwrdevAcdcdataService {
    @Resource
    private PwrdevAcdcdataMapper mapper;