From 75e50e0966d7165e04100a713267ece438482e19 Mon Sep 17 00:00:00 2001
From: leutu <leutu@qq.com>
Date: 星期二, 13 八月 2024 18:17:27 +0800
Subject: [PATCH] 推送代码忘记去掉注释，另外schederTask注意时间戳同步
---
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