From 6c914caa1e16d709d16c39b6ae55bd8b5c8f0283 Mon Sep 17 00:00:00 2001
From: leutu <leutu@qq.com>
Date: 星期二, 20 八月 2024 09:54:50 +0800
Subject: [PATCH] 使用本地时间戳，避免时间不同步无法推送数据
---
src/main/java/com/skyline/electricity/timer/SchedulerTask.java | 13 ++-----------
1 files changed, 2 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/skyline/electricity/timer/SchedulerTask.java b/src/main/java/com/skyline/electricity/timer/SchedulerTask.java
index 1e83b54..a1a1e7c 100644
--- a/src/main/java/com/skyline/electricity/timer/SchedulerTask.java
+++ b/src/main/java/com/skyline/electricity/timer/SchedulerTask.java
@@ -1,15 +1,5 @@
package com.skyline.electricity.timer;
-import org.apache.http.client.ClientProtocolException;
-import org.apache.http.client.config.RequestConfig;
-import org.apache.http.client.entity.UrlEncodedFormEntity;
-import org.apache.http.client.methods.CloseableHttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.message.BasicNameValuePair;
-import org.apache.http.protocol.HTTP;
-import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.*;
import org.springframework.context.annotation.*;
import org.springframework.beans.factory.annotation.*;
@@ -93,11 +83,12 @@
List<RetInfo> rlist = new ArrayList<>();
list.stream().forEach(r->rlist.add(JSONObject.parseObject(r,RetInfo.class))) ;
if( list != null && list.size() > 0){
+ System.out.println("scheduled....push size:"+list.size());
webSocketController.sendAllMessage(JSONObject.toJSONString(rlist));
}
// System.out.println( "websocket status ..["+JSONObject.toJSONString(rlist)+"]" );
//鎺ㄩ�佹姤璀︿俊鎭�
- pushIM(rlist);
+ //pushIM(rlist);
}
/**
--
Gitblit v1.9.3