From df05fc5ccd9302ccca1e92c2c8ca24c272a658e4 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期三, 13 十一月 2024 16:41:56 +0800
Subject: [PATCH] 1
---
se-modules/se-system/src/main/java/com/se/system/service/impl/SyncUserService.java | 39 +++++++++++++++++++++++++--------------
1 files changed, 25 insertions(+), 14 deletions(-)
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..7d88aba 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,45 +5,56 @@
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
- */
@Slf4j
@Service
@SuppressWarnings("ALL")
public class SyncUserService {
+ @Resource
+ IsimUserService isimUserService;
+
public void insertUser(SysUser user) {
- //
+ 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) {
- updateUser(user);
+ public void updateUsers(List<SysUser> list) {
+ CompletableFuture.runAsync(() -> {
+ isimUserService.updateUsers(list);
+ });
}
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