From 7f3690545448c0421abb6697f1fccf551ce51071 Mon Sep 17 00:00:00 2001
From: maxiangong <298222784@qq.com>
Date: Mon, 15 Jun 2026 16:19:44 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=A8=E7=94=B5=E7=9B=91=E6=8E=A7=E6=B6=88?=
=?UTF-8?q?=E6=81=AF=E6=8F=90=E9=86=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../BsEnergyCoreUseWarningProcessor.java | 27 +
.../energy/feign/IBsEnergyCoreUseClient.java | 5 +
.../springblade/system/feign/ISysClient.java | 476 +++++++++---------
.../system/feign/ISysClientFallback.java | 5 +
.../energy/feign/BsEnergyCoreUseClient.java | 5 +
.../service/IBsEnergyCoreUseService.java | 5 +-
.../impl/BsEnergyCoreUseServiceImpl.java | 89 +++-
.../mapper/OemSettlementApprovalMapper.xml | 20 +-
.../springblade/system/feign/SysClient.java | 7 +
9 files changed, 392 insertions(+), 247 deletions(-)
create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/energy/BsEnergyCoreUseWarningProcessor.java
diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/energy/BsEnergyCoreUseWarningProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/energy/BsEnergyCoreUseWarningProcessor.java
new file mode 100644
index 000000000..70100ebd1
--- /dev/null
+++ b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/energy/BsEnergyCoreUseWarningProcessor.java
@@ -0,0 +1,27 @@
+package org.springblade.job.processor.energy;
+
+import jakarta.annotation.Resource;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.energy.feign.IBsEnergyCoreUseClient;
+import org.springframework.stereotype.Component;
+import tech.powerjob.worker.core.processor.ProcessResult;
+import tech.powerjob.worker.core.processor.TaskContext;
+import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
+
+@Component
+@Data
+@Slf4j
+public class BsEnergyCoreUseWarningProcessor implements BasicProcessor {
+
+ @Resource
+ private IBsEnergyCoreUseClient client;
+
+ @Override
+ public ProcessResult process(TaskContext context) throws Exception {
+ log.info("开始用电监控预警...");
+ client.warning();
+ log.info("结束用电监控预警...");
+ return new ProcessResult(true);
+ }
+}
diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/energy/feign/IBsEnergyCoreUseClient.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/energy/feign/IBsEnergyCoreUseClient.java
index 17df2f2b8..5b9804dd8 100644
--- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/energy/feign/IBsEnergyCoreUseClient.java
+++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/energy/feign/IBsEnergyCoreUseClient.java
@@ -13,10 +13,15 @@ public interface IBsEnergyCoreUseClient {
String API_PREFIX = "/feign/client/bs-energy-core-use";
String UPDATE_USED = API_PREFIX + "/update-used";
String SAVE_HISTORY_REC = API_PREFIX + "/save-history-rec";
+ String WARNING = API_PREFIX + "/warning";
@GetMapping(UPDATE_USED)
void updateUsed(@RequestParam String type);
@GetMapping(SAVE_HISTORY_REC)
void saveHistoryRec();
+ @GetMapping(WARNING)
+ void warning();
+
+
}
diff --git a/blade-service-api/blade-system-api/src/main/java/org/springblade/system/feign/ISysClient.java b/blade-service-api/blade-system-api/src/main/java/org/springblade/system/feign/ISysClient.java
index ecb0f0467..7eb0f83d2 100644
--- a/blade-service-api/blade-system-api/src/main/java/org/springblade/system/feign/ISysClient.java
+++ b/blade-service-api/blade-system-api/src/main/java/org/springblade/system/feign/ISysClient.java
@@ -40,266 +40,276 @@ import java.util.List;
* @author Chill
*/
@FeignClient(
- value = AppConstant.APPLICATION_SYSTEM_NAME,
- fallback = ISysClientFallback.class
+ value = AppConstant.APPLICATION_SYSTEM_NAME,
+ fallback = ISysClientFallback.class
)
public interface ISysClient {
- String API_PREFIX = "/feign/client/system";
- String MENU = API_PREFIX + "/menu";
- String DEPT = API_PREFIX + "/dept";
- String DEPT_CODE = API_PREFIX + "/dept-code";
- String DEPT_IDS = API_PREFIX + "/dept-ids";
- String DEPT_IDS_FUZZY = API_PREFIX + "/dept-ids-fuzzy";
- String DEPT_NAME = API_PREFIX + "/dept-name";
- String DEPT_NAMES = API_PREFIX + "/dept-names";
- String DEPT_CHILD = API_PREFIX + "/dept-child";
- String POST = API_PREFIX + "/post";
- String POST_IDS = API_PREFIX + "/post-ids";
- String POST_IDS_FUZZY = API_PREFIX + "/post-ids-fuzzy";
- String POST_NAME = API_PREFIX + "/post-name";
- String POST_NAMES = API_PREFIX + "/post-names";
- String ROLE = API_PREFIX + "/role";
- String ROLE_IDS = API_PREFIX + "/role-ids";
- String ROLE_NAME = API_PREFIX + "/role-name";
- String ROLE_NAMES = API_PREFIX + "/role-names";
- String ROLE_ALIAS = API_PREFIX + "/role-alias";
- String ROLE_ALIASES = API_PREFIX + "/role-aliases";
- String TENANT = API_PREFIX + "/tenant";
- String TENANT_ID = API_PREFIX + "/tenant-id";
- String TENANT_PACKAGE = API_PREFIX + "/tenant-package";
- String PARAM = API_PREFIX + "/param";
- String PARAM_VALUE = API_PREFIX + "/param-value";
- String REGION = API_PREFIX + "/region";
+ String API_PREFIX = "/feign/client/system";
+ String MENU = API_PREFIX + "/menu";
+ String DEPT = API_PREFIX + "/dept";
+ String DEPT_CODE = API_PREFIX + "/dept-code";
+ String DEPT_IDS = API_PREFIX + "/dept-ids";
+ String DEPT_IDS_FUZZY = API_PREFIX + "/dept-ids-fuzzy";
+ String DEPT_NAME = API_PREFIX + "/dept-name";
+ String DEPT_NAMES = API_PREFIX + "/dept-names";
+ String DEPT_CHILD = API_PREFIX + "/dept-child";
+ String POST = API_PREFIX + "/post";
+ String POST_IDS = API_PREFIX + "/post-ids";
+ String POST_IDS_FUZZY = API_PREFIX + "/post-ids-fuzzy";
+ String POST_NAME = API_PREFIX + "/post-name";
+ String POST_NAMES = API_PREFIX + "/post-names";
+ String ROLE = API_PREFIX + "/role";
+ String ROLE_IDS = API_PREFIX + "/role-ids";
+ String ROLE_NAME = API_PREFIX + "/role-name";
+ String ROLE_NAMES = API_PREFIX + "/role-names";
+ String ROLE_ALIAS = API_PREFIX + "/role-alias";
+ String ROLE_ALIASES = API_PREFIX + "/role-aliases";
+ String TENANT = API_PREFIX + "/tenant";
+ String TENANT_ID = API_PREFIX + "/tenant-id";
+ String TENANT_PACKAGE = API_PREFIX + "/tenant-package";
+ String PARAM = API_PREFIX + "/param";
+ String PARAM_VALUE = API_PREFIX + "/param-value";
+ String REGION = API_PREFIX + "/region";
+ String LIST_ALL_USER_BY_ROLE_ALIAS = API_PREFIX +"/list-all-user-by-role-alias";
- /**
- * 获取菜单
- *
- * @param id 主键
- * @return Menu
- */
- @GetMapping(MENU)
- R