From 22d83c7b874b41451de13901f084a17d2b9ad3af Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期五, 30 八月 2024 21:35:52 +0800
Subject: [PATCH] 用户同步服务
---
se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java | 58 +++++++++++++++++++++++++++++
se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java | 32 ++++++++++++----
2 files changed, 82 insertions(+), 8 deletions(-)
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
new file mode 100644
index 0000000..191be7b
--- /dev/null
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/IsimUserService.java
@@ -0,0 +1,58 @@
+package com.se.system.service.impl;
+
+import com.se.system.api.domain.SysUser;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * ISIM鐢ㄦ埛鏈嶅姟
+ *
+ * @author WWW
+ * @date 2024-08-30
+ */
+@Slf4j
+@Service
+@SuppressWarnings("ALL")
+public class IsimUserService {
+ public void insertUser(SysUser user) {
+ try {
+ System.out.println("insertUser");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+
+ public void insertUsers(List<SysUser> list) {
+ try {
+ System.out.println("insertUsers");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+
+ public void updateUser(SysUser user) {
+ try {
+ System.out.println("updateUser");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+
+ public void deleteUser(SysUser user) {
+ try {
+ System.out.println("deleteUser");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+
+ public void deleteUsers(List<SysUser> list) {
+ try {
+ System.out.println("deleteUsers");
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
+}
diff --git a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
index fb8fa56..e795be0 100644
--- a/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
+++ b/se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java
@@ -5,30 +5,42 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
import java.util.List;
+import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
- * 寮傛鏈嶅姟
+ * 鐢ㄦ埛鍚屾鏈嶅姟
*
* @author WWW
- * @date 2024-08-25
+ * @date 2024-08-30
*/
@Slf4j
@Service
@SuppressWarnings("ALL")
public class SyncUserService {
+ @Resource
+ IsimUserService isimUserService;
+
public void insertUser(SysUser user) {
- //
+ // supplyAsync-甯﹁繑鍥炲�硷紝runAsync-鏃犺繑鍥炲��
+ CompletableFuture.runAsync(() -> {
+ isimUserService.insertUser(user);
+ });
}
public void insertUsers(List<SysUser> list) {
- //
+ CompletableFuture.runAsync(() -> {
+ isimUserService.insertUsers(list);
+ });
}
public void updateUser(SysUser user) {
- //
+ CompletableFuture.runAsync(() -> {
+ isimUserService.updateUser(user);
+ });
}
public void updateUserStatus(SysUser user) {
@@ -36,14 +48,18 @@
}
public void deleteUser(SysUser user) {
- //
+ CompletableFuture.runAsync(() -> {
+ isimUserService.deleteUser(user);
+ });
}
public void deleteUsers(List<SysUser> list) {
- //
+ CompletableFuture.runAsync(() -> {
+ isimUserService.deleteUsers(list);
+ });
}
- public void asyncCall() {
+ private void asyncCall() {
try {
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.execute(new Runnable() {
--
Gitblit v1.9.3