app登出

whyclxw

2025-02-18 4e8dd5dc42b8625eefc0e558a20bd9b07c8e7600

app登出

 src/main/java/com/whyc/config/ApplLoginOutConifg.java

@@ -8,6 +8,7 @@
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.PostConstruct;
import java.util.Date;

@Configuration
public class ApplLoginOutConifg {
@@ -21,5 +22,10 @@
        UpdateWrapper wrapper=new UpdateWrapper();
        wrapper.gt("num",0);
        mapper.delete(wrapper);
        AppLoginOut app=new AppLoginOut();
        app.setUname("restart");
        app.setSessionid("0");
        app.setCreateTime(new Date());
        mapper.insert(app);
    }
}

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

@@ -83,4 +83,21 @@
        wrapper.set("create_time",new Date());
        mapper.update((AppLoginOut) ActionUtil.objeNull,wrapper);
    }

    public Response checkRestart() {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("uname","restart");
        AppLoginOut app=mapper.selectOne(wrapper);
        remove("restart","0");
        boolean bl=false;
        String msg="";
        if(app!=null){
            bl=true;
            msg="平台服务重启,重新登录";
        }else {
            bl=false;
            msg="";
        }
        return new Response().setII(1,bl,app,msg);
    }
}

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

@@ -1,5 +1,6 @@
package com.whyc.webSocket;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.whyc.config.WebSocketConfig;
import com.whyc.dto.LockRDto;
import com.whyc.dto.Response;
@@ -12,6 +13,7 @@

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

@@ -44,8 +46,10 @@


    @OnOpen
    public void onOpen(Session session) {
    public void onOpen(Session session) throws IOException, EncodeException {
        this.session = session;
        Response res=appLoginOutService.checkRestart();
        session.getBasicRemote().sendObject(res);
    }
    @OnMessage
    public void onMessage(Session session, String message) {