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