用户同步服务

13693261870

2024-08-30 22d83c7b874b41451de13901f084a17d2b9ad3af

用户同步服务

 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);
        }
    }
}

 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() {