From ca3827c9af536b0797e4b16e5040d235356286f4 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期四, 24 八月 2023 15:43:46 +0800
Subject: [PATCH] 仓库加入流程字段
---
service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java | 35 ++++++++++++++++++++++++++++++++++-
1 files changed, 34 insertions(+), 1 deletions(-)
diff --git a/service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java b/service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java
index 7383ec6..bf93719 100644
--- a/service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java
+++ b/service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java
@@ -1,12 +1,16 @@
package com.java110.user.smo.impl;
import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.dto.owner.OwnerAppUserDto;
import com.java110.intf.user.IInitializeOwnerInnerServiceSMO;
+import com.java110.intf.user.IOwnerAppUserV1InnerServiceSMO;
import com.java110.user.dao.IInitializeOwneServiceDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
+import java.util.ArrayList;
+import java.util.List;
import java.util.Map;
/**
@@ -20,14 +24,43 @@
@RestController
public class InitializeOwnerInnerServiceSMOImpl extends BaseServiceSMO implements IInitializeOwnerInnerServiceSMO {
+
+ public static final int DEFAULT_ROW = 200;
+
@Autowired
private IInitializeOwneServiceDao initializeOwnerServiceDaoImpl;
+
+ @Autowired
+ private IOwnerAppUserV1InnerServiceSMO ownerAppUserV1InnerServiceSMOImpl;
+
@Override
public int deleteBuildingOwner(@RequestBody Map communityId) {
int deleteFast = initializeOwnerServiceDaoImpl.deleteBuildingOwner(communityId);
//todo 鍒犻櫎 涓氫富缁戝畾鏁版嵁
- //initializeOwnerServiceDaoImpl.deleteUser(communityId);
+
+ OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
+ ownerAppUserDto.setCommunityId(communityId.get("communityId").toString());
+ int count = ownerAppUserV1InnerServiceSMOImpl.queryOwnerAppUsersCount(ownerAppUserDto);
+ int page = (int) Math.floor(count / DEFAULT_ROW);
+ List<String> userIds = null;
+ for (int pageIndex = 1; pageIndex < page + 1; pageIndex++) {
+ ownerAppUserDto = new OwnerAppUserDto();
+ ownerAppUserDto.setPage(pageIndex);
+ ownerAppUserDto.setRow(DEFAULT_ROW);
+ ownerAppUserDto.setCommunityId(communityId.get("communityId").toString());
+ List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserV1InnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
+ if (ownerAppUserDtos == null || ownerAppUserDtos.size() < 1) {
+ continue;
+ }
+ userIds = new ArrayList<>();
+ for (OwnerAppUserDto tmpOwnerAppUserDto : ownerAppUserDtos) {
+ userIds.add(tmpOwnerAppUserDto.getUserId());
+ }
+ communityId.put("userIds", userIds.toArray(new String[userIds.size()]));
+ initializeOwnerServiceDaoImpl.deleteUser(communityId);
+
+ }
initializeOwnerServiceDaoImpl.deleteOwnerAppUser(communityId);
return deleteFast;
}
--
Gitblit v1.8.0