From bb229d0324c082a85b14c72ddf7ef1a46622266d Mon Sep 17 00:00:00 2001
From: 杜洪波 <1074825718@qq.com>
Date: 星期五, 17 四月 2026 09:42:28 +0800
Subject: [PATCH] 定时任务-租户扫描
---
src/main/java/com/product/saas/service/SaasClientService.java | 32 +++++++++++++++++++++++++++++++-
1 files changed, 31 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/product/saas/service/SaasClientService.java b/src/main/java/com/product/saas/service/SaasClientService.java
index 7874513..f989c5b 100644
--- a/src/main/java/com/product/saas/service/SaasClientService.java
+++ b/src/main/java/com/product/saas/service/SaasClientService.java
@@ -2,17 +2,21 @@
import java.util.ArrayList;
import java.util.List;
+import java.util.Set;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import com.product.admin.service.SaasUserService;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
+import com.product.core.message.MessageFactory;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.module.sys.entity.SystemUser;
+import com.product.saas.config.SaasConst;
import com.product.saas.service.idel.ISaasClientService;
import com.product.util.BaseUtil;
@@ -20,11 +24,34 @@
* 绉熸埛淇℃伅
*
*/
-@Service
+@Service("saasClientService")
public class SaasClientService extends AbstractBaseService implements ISaasClientService{
@Autowired
BaseDao baseDao;
+
+ @Autowired
+ MessageFactory messageFactory;
+
+ @Autowired
+ SaasUserService saasUserService;
+
+ /**
+ * 瀹氭椂浠诲姟鎵弿娌℃湁绉熸埛绠＄悊鍛樼殑绉熸埛
+ */
+ public void autoDetectTenant() {
+ DataTableEntity dt = baseDao.listTable(SaasConst.PRODUCT_SYS_CLIENTS, "platform_admin IS NULL OR platform_admin = ''");
+ if (!BaseUtil.dataTableIsEmpty(dt)) {
+ String clientName = BaseUtil.joinObjectArray(dt.getFieldAllValues(SaasConst.CLIENT_NAME), ",");
+
+ Set<String> platformDirector = saasUserService.getPlatformSuperAdmin();
+ // 鍙戦�佹秷鎭粰骞冲彴涓荤
+ messageFactory.sendMessage(String.join(",", platformDirector),
+ "銆�" + clientName + "銆戠瓑绉熸埛娌℃湁骞冲彴绠＄悊鍛�",
+ "绉熸埛缂轰箯骞冲彴绠＄悊鍛�", 1, "5", null,
+ SaasConst.PRODUCT_SYS_CLIENTS, "23432432423", 1, new String[] {"system"}, null);
+ }
+ }
/**
* 绉熸埛鍒楄〃
@@ -81,6 +108,9 @@
FieldSetEntity fseClient = baseDao.getFieldSetEntityBySQL(sql.toString(), new Object[] {uuid}, false);
if(fseClient != null) {
DataTableEntity dtClientChange = baseDao.listTable("product_sys_tenant_change", "client_uuid = ?", new Object[] {uuid});
+ if (!BaseUtil.dataTableIsEmpty(dtClientChange)) {
+ baseDao.loadPromptData(dtClientChange);
+ }
fseClient.addSubDataTable(dtClientChange);
}
return fseClient;
--
Gitblit v1.9.2