feign调用

jeecg-module-event/src/main/java/org/jeecg/runProcess/controller/RunProcessController.java

@@ -3,23 +3,16 @@ package org.jeecg.runProcess.controller;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.jeecg.cmaq.service.CmaqService;
+import org.jeecg.sync.service.CmaqService;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
 import org.jeecg.engineering.service.EngineeringService;
-import org.jeecg.modules.base.entity.DoseFactor;
 import org.jeecg.modules.base.entity.Engineering;
 import org.jeecg.runProcess.VO.RunProcessParamVO;
 import org.jeecg.runProcess.service.RunProcessService;
 import org.jeecg.wrf.service.WrfService;
 import org.springframework.web.bind.annotation.*;
 
-import java.io.BufferedWriter;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-
 /**
 * @Description: 运行过程
 * @Author: jeecg-boot

jeecg-module-event/src/main/java/org/jeecg/runProcess/service/impl/RunProcessServiceImpl.java

@@ -3,7 +3,7 @@ package org.jeecg.runProcess.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.RequiredArgsConstructor;
 import org.jeecg.baseAPI.service.BaseAPIService;
-import org.jeecg.cmaq.service.CmaqService;
+import org.jeecg.sync.service.CmaqService;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.constant.EventConstants;
 import org.jeecg.common.properties.EventServerProperties;

jeecg-module-event/src/main/java/org/jeecg/sync/controller/CmaqController.java

@@ -1,19 +1,15 @@
-package org.jeecg.cmaq.controller;
+package org.jeecg.sync.controller;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.extern.slf4j.Slf4j;
-import org.jeecg.cmaq.service.CmaqService;
+import org.jeecg.sync.service.CmaqService;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.modules.base.entity.Cmaq;
-import org.jeecg.wrf.service.WrfService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.List;
-
 /**
  * @Description: CMAQ
  * @Author: jeecg-boot

jeecg-module-event/src/main/java/org/jeecg/sync/service/CmaqService.java

@@ -1,4 +1,4 @@
-package org.jeecg.cmaq.service;
+package org.jeecg.sync.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import org.jeecg.modules.base.entity.Cmaq;

jeecg-module-event/src/main/java/org/jeecg/sync/service/impl/CmaqServiceImpl.java

@@ -1,8 +1,8 @@
-package org.jeecg.cmaq.service.impl;
+package org.jeecg.sync.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.jeecg.cmaq.service.CmaqService;
+import org.jeecg.sync.service.CmaqService;
 import org.jeecg.common.exception.JeecgBootException;
 import org.jeecg.modules.base.entity.Cmaq;
 import org.jeecg.modules.base.mapper.CmaqMapper;

jeecg-module-large-screen/pom.xml

@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.jeecgframework.boot</groupId>
+        <artifactId>jeecg-boot-parent</artifactId>
+        <version>3.8.1</version>
+    </parent>
+
+    <artifactId>jeecg-module-large-screen</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>jeecg-boot-base-core</artifactId>
+            <version>${jeecgboot.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-openfeign-core</artifactId>
+        </dependency>
+    </dependencies>
+</project>

jeecg-module-large-screen/src/main/java/org/jeecg/sync/controller/SyncFeignController.java

@@ -0,0 +1,30 @@
+package org.jeecg.sync.controller;
+
+import io.swagger.v3.oas.annotations.Operation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.sync.feign.SyncFeignClient;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Description: 大屏
+ * @Author: jeecg-boot
+ * @Date:   2022-12-19
+ * @Version: V1.0
+ */
+@RestController
+@RequestMapping("/syncFeign")
+@Slf4j
+@RequiredArgsConstructor
+public class SyncFeignController {
+
+    private final SyncFeignClient syncFeignClient;
+
+    @Operation(summary = "大屏-同步记录")
+    @GetMapping(value = "/syncList")
+    public Result<?> queryPageList(){
+        return syncFeignClient.list();
+    }
+
+}

jeecg-module-large-screen/src/main/java/org/jeecg/sync/feign/SyncFeignClient.java

@@ -0,0 +1,12 @@
+package org.jeecg.sync.feign;
+
+import org.jeecg.common.api.vo.Result;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+@FeignClient(value = "jeecg-sync")
+public interface SyncFeignClient {
+
+    @GetMapping(value = "/stasSyncRecord/list")
+    Result<?> list();
+}

jeecg-server-cloud/jeecg-large-screen-start/pom.xml

@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.jeecgframework.boot</groupId>
+        <artifactId>jeecg-server-cloud</artifactId>
+        <version>3.8.1</version>
+    </parent>
+
+    <artifactId>jeecg-large-screen-start</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>jeecg-boot-starter3-cloud</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>jeecg-system-cloud-api</artifactId>
+            <version>${jeecgboot.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.jeecgframework.boot</groupId>
+            <artifactId>jeecg-module-large-screen</artifactId>
+            <version>${jeecgboot.version}</version>
+        </dependency>
+    </dependencies>
+    <build>
+        <finalName>stas-cloud-data-large-screen</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+</project>

jeecg-server-cloud/jeecg-large-screen-start/src/main/java/org/jeecg/JeecgLargeScreenCloudApplication.java

@@ -0,0 +1,55 @@
+package org.jeecg;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.common.base.BaseMap;
+import org.jeecg.common.constant.GlobalConstants;
+import org.jeecg.common.util.oConvertUtils;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.core.env.Environment;
+import org.springframework.data.redis.core.RedisTemplate;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+@Slf4j
+@SpringBootApplication
+@RequiredArgsConstructor
+@EnableFeignClients
+public class JeecgLargeScreenCloudApplication extends SpringBootServletInitializer implements CommandLineRunner {
+
+    private final RedisTemplate<String, Object> redisTemplate;
+
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
+        return application.sources(JeecgLargeScreenCloudApplication.class);
+    }
+
+    public static void main(String[] args) throws UnknownHostException {
+        ConfigurableApplicationContext application = SpringApplication.run(JeecgLargeScreenCloudApplication.class, args);
+        Environment env = application.getEnvironment();
+        String ip = InetAddress.getLocalHost().getHostAddress();
+        String port = env.getProperty("server.port");
+        String path = oConvertUtils.getString(env.getProperty("server.servlet.context-path"));
+        log.info("\n----------------------------------------------------------\n\t" +
+                "Application STAS-LargeScreen is running! Access URLs:\n\t" +
+                "Local: \t\thttp://localhost:" + port + path + "/doc.html\n" +
+                "External: \thttp://" + ip + ":" + port + path + "/doc.html\n" +
+                "Swagger文档: \thttp://" + ip + ":" + port + path + "/doc.html\n" +
+                "----------------------------------------------------------");
+
+    }
+
+    @Override
+    public void run(String... args) {
+        BaseMap params = new BaseMap();
+        params.put(GlobalConstants.HANDLER_NAME, GlobalConstants.LODER_ROUDER_HANDLER);
+        //刷新网关
+        redisTemplate.convertAndSend(GlobalConstants.REDIS_TOPIC_NAME, params);
+    }
+}

jeecg-server-cloud/jeecg-large-screen-start/src/main/resources/application.yml

@@ -0,0 +1,24 @@
+server:
+  port: 8008
+
+spring:
+  application:
+    name: jeecg-large-screen
+  cloud:
+    nacos:
+      config:
+        server-addr: @config.server-addr@
+        group: @config.group@
+        namespace: @config.namespace@
+        username: @config.username@
+        password: @config.password@
+      discovery:
+        server-addr: ${spring.cloud.nacos.config.server-addr}
+        group: @config.group@
+        namespace: @config.namespace@
+        username: @config.username@
+        password: @config.password@
+  config:
+    import:
+      - optional:nacos:jeecg.yaml
+      - optional:nacos:jeecg-@profile.name@.yaml

jeecg-server-cloud/jeecg-large-screen-start/src/main/resources/logback-spring.xml

@@ -0,0 +1,44 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false">
+	<!--定义日志文件的存储地址 -->
+	<property name="LOG_HOME" value="logs" />
+
+	<!--<property name="COLOR_PATTERN" value="%black(%contextName-) %red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta( %replace(%caller{1}){'\t|Caller.{1}0|\r\n', ''})- %gray(%msg%xEx%n)" />-->
+	<!-- 控制台输出 -->
+	<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+		<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+			<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50}:%L - %msg%n</pattern>-->
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %highlight(%-5level) %cyan(%logger{50}:%L) - %msg%n</pattern>
+		</encoder>
+	</appender>
+
+	<!-- 按照每天生成日志文件 -->
+	<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+			<!--日志文件输出的文件名 -->
+			<FileNamePattern>${LOG_HOME}/stas-large-screen-%d{yyyy-MM-dd}.%i.log</FileNamePattern>
+			<!--日志文件保留天数 -->
+			<MaxHistory>30</MaxHistory>
+			<maxFileSize>10MB</maxFileSize>
+		</rollingPolicy>
+		<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+			<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50}:%L - %msg%n</pattern>
+		</encoder>
+	</appender>
+
+
+	<!--myibatis log configure -->
+	<logger name="com.apache.ibatis" level="TRACE" />
+	<logger name="java.sql.Connection" level="DEBUG" />
+	<logger name="java.sql.Statement" level="DEBUG" />
+	<logger name="java.sql.PreparedStatement" level="DEBUG" />
+
+	<!-- 日志输出级别 -->
+	<root level="INFO">
+		<appender-ref ref="STDOUT" />
+		<appender-ref ref="FILE" />
+	</root>
+
+</configuration>

jeecg-server-cloud/pom.xml

@@ -19,6 +19,7 @@
         <module>jeecg-system-cloud-start</module>
 
         <!-- 监控和测试例子 -->
+        <module>jeecg-large-screen-start</module>
         <module>jeecg-visual</module>
         <module>jeecg-weather-start</module>
         <module>jeecg-event-start</module>

pom.xml

@@ -83,6 +83,7 @@
 
 	<modules>
         <module>jeecg-boot-base-core</module>
+        <module>jeecg-module-large-screen</module>
         <module>jeecg-module-system</module>
         <module>jeecg-module-weather</module>
         <module>jeecg-module-event</module>