| | |
| | | import com.se.system.api.domain.SysUser; |
| | | import lombok.SneakyThrows; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | |
| | | import java.util.concurrent.ExecutorService; |
| | | import java.util.concurrent.Executors; |
| | | |
| | | /** |
| | | * 用户同步服务 |
| | | * |
| | | * @author WWW |
| | | * @date 2024-08-30 |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | @SuppressWarnings("ALL") |
| | | public class SyncUserService { |
| | | private static final Logger log = LoggerFactory.getLogger(SyncUserService.class); |
| | | |
| | | @Resource |
| | | IsimUserService isimUserService; |
| | | |
| | | public void insertUser(SysUser user) { |
| | | // supplyAsync-带返回值,runAsync-无返回值 |
| | | CompletableFuture.runAsync(() -> { |
| | | isimUserService.insertUser(user); |
| | | }); |
| | |
| | | }); |
| | | } |
| | | |
| | | public void updateUserStatus(SysUser user) { |
| | | updateUser(user); |
| | | public void updateUsers(List<SysUser> list) { |
| | | CompletableFuture.runAsync(() -> { |
| | | isimUserService.updateUsers(list); |
| | | }); |
| | | } |
| | | |
| | | public void deleteUser(SysUser user) { |