消息推送接口

src/main/java/com/gyee/frame/controller/comm/FullPushMsgController.java

@@ -2,7 +2,12 @@ package com.gyee.frame.controller.comm;
 
 
 import com.gyee.frame.common.domain.AjaxResult;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
 
@@ -11,6 +16,13 @@ import org.springframework.web.bind.annotation.RestController;
 public class FullPushMsgController {
 
 
+    /**
+     * 推送消息
+     * @return
+     */
+    @GetMapping("/pushmsg")
+    @ResponseBody
+    @ApiOperation(value = "推送全场重要信息", notes = "推送全场重要信息")
     public AjaxResult pushmsg () {
 
 

src/main/java/com/gyee/frame/service/comm/FullPushMsgService.java

@@ -0,0 +1,26 @@
+package com.gyee.frame.service.comm;
+
+
+import com.gyee.frame.model.benchmarking.PowerCompareDetail;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 推送全场重要消息
+ */
+@Service
+public class FullPushMsgService {
+
+
+
+    public List<Map> pushmsg() {
+
+
+
+
+        return null;
+    }
+}

src/main/java/com/gyee/frame/service/export/GoldenService.java

@@ -123,8 +123,8 @@ public class GoldenService {
         WindpowerstationExample example = new WindpowerstationExample();
         example.createCriteria().andIdLike("%_FDC%");
         List<Windpowerstation> lists = windpowerstationService.selectByExample(example);
-        beginOfDate = 1635696000000L;
-        endOfDate = 1637596800000L;
+//        beginOfDate = 1635696000000L;
+//        endOfDate = 1637596800000L;
         for(int i :val){
             for (Windpowerstation station: lists) {
                 getTemplateHistory1(station.getCode(),station.getAddress(),beginOfDate,endOfDate,i*60);

src/main/java/com/gyee/frame/util/excel/FileUtils.java

@@ -105,7 +105,7 @@ public class FileUtils {
         if ("path".equals(tag)){
             sb.append(exportConfig.getExportpath()).append("\\");
         }else {
-            sb.append("http:\\10.155.32.4:8087").append("\\excel\\");
+            sb.append("http:\\10.155.32.4:8070").append("\\zhfx\\excel\\");
         }
 
         sb.append(month).append("\\");

src/main/java/com/gyee/frame/websocket/MyConstant.java

@@ -1,9 +0,0 @@
-package com.gyee.frame.websocket;
-
-/**
- * @descrition:websocket常量
- * @author:wang
- * @date:2021-11-10
- */
-public class MyConstant {
-}

src/main/java/com/gyee/frame/websocket/WebsocketConfig.java

@@ -1,52 +0,0 @@
-package com.gyee.frame.websocket;
-
-import org.springframework.context.annotation.Configuration;
-import org.springframework.messaging.simp.config.MessageBrokerRegistry;
-import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
-import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
-import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
-
-
-/**
- * @descrition:websocket配置类
- * @autho：wang
- * @date:2021-11-10
- */
-@Configuration
-@EnableWebSocketMessageBroker
-public class WebsocketConfig  implements WebSocketMessageBrokerConfigurer {
-
-    /**
-     * 注册stomp端点，主要是起到连接作用
-     *
-     * @param stompEndpointRegistry
-     */
-    @Override
-    public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
-        stompEndpointRegistry
-                .addEndpoint("/sis_service")  //端点名称
-                //.setHandshakeHandler() 握手处理，主要是连接的时候认证获取其他数据验证等
-                //.addInterceptors() 拦截处理，和http拦截类似
-                .setAllowedOrigins("*");//跨域
-        // .withSockJS(); //使用sockJS1
-
-    }
-
-    /**
-     * 注册相关服务
-     *
-     * @param registry
-     */
-    @Override
-    public void configureMessageBroker(MessageBrokerRegistry registry) {
-
-        //topic用来广播
-        registry.enableSimpleBroker("/topic", "/queue");
-        //客户端名称前缀
-        registry.setApplicationDestinationPrefixes("/app");
-        //用户名称前
-        registry.setUserDestinationPrefix("/user");
-    }
-
-
-}

src/main/java/com/gyee/frame/websocket/WebsocketController.java

@@ -1,37 +0,0 @@
-package com.gyee.frame.websocket;
-
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.messaging.MessageHeaders;
-import org.springframework.messaging.simp.SimpMessagingTemplate;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.Map;
-
-
-/**
- * @descrition:
- * @author:wang
- * @date:2021-11-10
- */
-@RestController
-public class WebsocketController {
-
-    @Autowired
-    private SimpMessagingTemplate messagingTemplate;
-
-
-    /**
-     * @param distination    订阅地址
-     * @param messageBody    发送内容
-     * @param messageHeaders 头信息，自定义的头信息即可，无需添加id，ts
-     * @return
-     * @author wang
-     * @date 2021-11-10
-     * @description: 向订阅地址发送消息(不区分用户), 可增加head头信息
-     */
-    public void sendToAll(String distination, Object messageBody, Map<String, Object> messageHeaders) {
-        MessageHeaders xMessageHeaders = new MessageHeaders(messageHeaders);
-        messagingTemplate.convertAndSend(distination, messageBody, xMessageHeaders);
-    }
-}

src/main/java/com/gyee/frame/websocket/WebsocketHeartbeat.java

@@ -1,35 +0,0 @@
-package com.gyee.frame.websocket;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @descrition:心跳
- * @autho:wang
- * @date:2021-11-10
- */
-@Component
-public class WebsocketHeartbeat {
-
-
-    @Autowired
-    private WebsocketController websocketController;
-    private Logger logger = LoggerFactory.getLogger(this.getClass());
-
-    /**
-     * 按一定频率执行的定时任务
-     */
-    @Scheduled(fixedRate = 50000)
-    public void scheduled1() {
-        Map<String, Object> header = new HashMap<>();
-        header.put("data-type", "heartbeat");
-        websocketController.sendToAll("/topic/heartbeat-data", System.currentTimeMillis(), header);
-    }
-
-}