abe状态

whycxzp

2025-04-03 ed96173f09f9bf2898e679f22094c9149216e7af

abe状态

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

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.db_abe_ram.AbeInf;

public interface AbeInfMapper extends CustomMapper<AbeInf> {
}

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

New file
@@ -0,0 +1,25 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.dto.Response;
import com.whyc.mapper.AbeInfMapper;
import com.whyc.mapper.AbeStateMapper;
import com.whyc.pojo.db_abe_ram.AbeInf;
import com.whyc.pojo.db_abe_ram.AbeState;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class AbeInfService {

    @Resource
    private AbeInfMapper mapper;

    public AbeInf get() {
        QueryWrapper<AbeInf> query = Wrappers.query();
        query.last(" limit 1");
        return mapper.selectOne(query);
    }
}

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

@@ -15,8 +15,9 @@
    @Resource
    private AbeRamMapper mapper;

    public Response<AbeRam> get() {
    public Response<AbeRam> get(Integer abeMonId) {
        QueryWrapper<AbeRam> query = Wrappers.query();
        query.eq("mon_id",abeMonId);
        query.last(" limit 1");
        AbeRam abeRam = mapper.selectOne(query);
        return new Response<AbeRam>().set(1,abeRam);

 src/main/java/com/whyc/webSocket/AbeStateSocket.java

@@ -3,8 +3,10 @@
import com.whyc.config.WebSocketConfig;
import com.whyc.dto.PageAlarm;
import com.whyc.dto.Response;
import com.whyc.pojo.db_abe_ram.AbeInf;
import com.whyc.pojo.db_abe_ram.AbeRam;
import com.whyc.pojo.db_abe_ram.AbeState;
import com.whyc.service.AbeInfService;
import com.whyc.service.AbeRamService;
import com.whyc.service.AbeStateService;
import com.whyc.service.BattStationTempAlarmService;
@@ -28,6 +30,8 @@

    private Thread thread;

    private static AbeInfService infService;

    private static AbeRamService ramService;

    private static AbeStateService stateService;
@@ -48,6 +52,11 @@
        AbeStateSocket.stateService = stateService;
    }

    @Autowired
    public void setInfService(AbeInfService infService) {
        AbeStateSocket.infService = infService;
    }

    @OnOpen
    public void onOpen(Session session, EndpointConfig config) {
        this.session = session;
@@ -61,8 +70,9 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                AbeInf inf = infService.get();
                                Response<AbeState> state = stateService.get();
                                Response<AbeRam> ram = ramService.get();
                                Response<AbeRam> ram = ramService.get(inf.getAbeMonId());
                                Map<String, Response> resMap = new HashMap<>();
                                resMap.put("state",state);
                                resMap.put("ram",ram);