websocket更新

whyczh

2022-03-03 019c65d0fbe4ee204671055ef81074e3d595b5b8

websocket更新

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

@@ -28,6 +28,7 @@
import java.util.List;

@Service
@Transactional
public class BattalarmDataService {

    @Resource

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

@@ -7,6 +7,7 @@
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.HashMap;
@@ -37,6 +38,7 @@
    @Resource
    private PwrdevAlarmMapper pwrdevAlarmMapper;

    @Transactional
    public Response getDataMap(int uId){

        Map dataMap = new HashMap();

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

@@ -42,7 +42,7 @@
        AlarmPar alarmPar = ActionUtil.getGson().fromJson(message, AlarmPar.class);
        thread = new Thread("Thread_battAlarmData") {
            public void run() {
                while (runFlag) {
                while (runFlag&&!isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {

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

@@ -42,7 +42,7 @@
    public synchronized void onMessage(Session session, String uId){
        thread = new Thread("Thread_battAlarmFoot") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -48,7 +48,7 @@
        thread = new Thread("Thread_battDischargePlan") {
            public void run() {

                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -42,7 +42,7 @@
        BattScrapPar battScrapPar = ActionUtil.getGson().fromJson(message, BattScrapPar.class);
        thread = new Thread("Thread_battScrap") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -43,7 +43,7 @@
        BattSparePar battSparePar = ActionUtil.getGson("yyyy-MM-dd").fromJson(message, BattSparePar.class);
        thread = new Thread("Thread_battSpare") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -47,7 +47,7 @@
        DevAlarmPar alarmPar = ActionUtil.getGson().fromJson(message, DevAlarmPar.class);
        thread = new Thread("Thread_devAlarmData") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -51,7 +51,7 @@
        Fbs9100State stateParam = ActionUtil.getGson().fromJson(msg, Fbs9100State.class);
        this.thread = new Thread("Thread_DeviceWorkState") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -54,7 +54,7 @@
        FbsStatePar fbsStatePar= ActionUtil.getGson().fromJson(message,FbsStatePar.class);
        thread = new Thread("Thread_FbsState") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -45,7 +45,7 @@
    public void onMessage(Session session, String uId){
        thread = new Thread("Thread_homePage") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {

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

@@ -47,7 +47,7 @@
        PwrdevAlarm pwrdevAlarm = ActionUtil.getGson().fromJson(message, PwrdevAlarm.class);
        thread = new Thread("Thread_powerAlarmRt") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {

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

@@ -41,7 +41,7 @@
    public void onMessage(Session session, String deviceId){
        thread = new Thread("Thread_PowerRT") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {

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

@@ -39,7 +39,7 @@
    public synchronized void onMessage(Session session,String message){
        thread = new Thread("Thread_processSurvey") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -45,7 +45,7 @@
        PwrdevAlarm pwrdevAlarm = ActionUtil.getGson().fromJson(message, PwrdevAlarm.class);
        thread = new Thread("Thread_pwrAlarm") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -47,7 +47,7 @@
    public synchronized void onMessage(Session session, String uId){
        thread = new Thread("Thread_powerAlarmTimeout") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(), true);
                    try {

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

@@ -143,7 +143,7 @@
        realTimePar.setDevType(realTimePar.getDevId()/100000);
        thread = new Thread("Thread_RealTime") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {

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

@@ -52,7 +52,7 @@
        RealTimePar realTimePar= ActionUtil.getGson().fromJson(message,RealTimePar.class);
        thread = new Thread("Thread_RealTime") {
            public void run() {
                while (runFlag) {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
                    threadFlagMap.put(thread.getId(),true);
                    try {