数据库配置修改

java/storlead-api/src/main/resources/application.yml

@@ -91,6 +91,7 @@ storlead:
       - packages:
           - com.storlead.trade.service
           - com.storlead.trade.mapper
+          - com.storlead.trade.task
         datasource: trade
       - packages:
           - com.storlead.sales.service

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerAiAnalysisServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.storlead.trade.entity.CustomerAnalysisResultEntity;
 import com.storlead.trade.entity.CustomerCompanyEntity;
@@ -14,6 +17,7 @@ import javax.annotation.Resource;
 import java.util.*;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerAiAnalysisServiceImpl implements CustomerAiAnalysisService {
 
     private static final String AI_ANALYSIS_URL = "http://127.0.0.1:18080/mock/ai/customer/analyze";

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerAnalysisDispatchServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.storlead.framework.common.constant.CommonConstant;
 import com.storlead.trade.constant.CustomerAnalysisConstants;
@@ -25,6 +28,7 @@ import java.util.stream.Collectors;
 
 @Slf4j
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerAnalysisDispatchServiceImpl implements CustomerAnalysisDispatchService {
 
     private static final DateTimeFormatter BATCH_NO_FMT = DateTimeFormatter.BASIC_ISO_DATE;

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerAnalysisResultEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.storlead.trade.entity.CustomerAnalysisResultEntity;
 import com.storlead.trade.mapper.CustomerAnalysisResultEntityMapper;
 import com.storlead.trade.service.CustomerAnalysisResultEntityService;
@@ -10,6 +13,7 @@ import java.util.List;
 import java.util.Map;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerAnalysisResultEntityServiceImpl
         extends MyBaseServiceImpl<CustomerAnalysisResultEntityMapper, CustomerAnalysisResultEntity>
         implements CustomerAnalysisResultEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerBaseEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.storlead.trade.dto.MarketingCampaignCustomerDTO;
@@ -13,6 +16,7 @@ import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerBaseEntityServiceImpl
         extends MyBaseServiceImpl<CustomerBaseEntityMapper, CustomerBaseEntity>
         implements CustomerBaseEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerCompanyEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.storlead.trade.entity.CustomerCompanyEntity;
 import com.storlead.trade.mapper.CustomerCompanyEntityMapper;
 import com.storlead.trade.service.CustomerCompanyEntityService;
@@ -7,6 +10,7 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerCompanyEntityServiceImpl
         extends MyBaseServiceImpl<CustomerCompanyEntityMapper, CustomerCompanyEntity>
         implements CustomerCompanyEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/CustomerEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.storlead.trade.entity.CustomerEntity;
 import com.storlead.trade.mapper.CustomerEntityMapper;
 import com.storlead.trade.service.CustomerEntityService;
@@ -7,5 +10,6 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class CustomerEntityServiceImpl extends MyBaseServiceImpl<CustomerEntityMapper, CustomerEntity> implements CustomerEntityService {
 }

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/LiaisonEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.storlead.trade.entity.LiaisonEntity;
 import com.storlead.trade.mapper.LiaisonEntityMapper;
 import com.storlead.trade.service.LiaisonEntityService;
@@ -7,5 +10,6 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class LiaisonEntityServiceImpl extends MyBaseServiceImpl<LiaisonEntityMapper, LiaisonEntity> implements LiaisonEntityService {
 }

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/MarketingCampaignEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -27,6 +30,7 @@ import java.util.List;
 import java.util.stream.Collectors;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class MarketingCampaignEntityServiceImpl
         extends MyBaseServiceImpl<MarketingCampaignEntityMapper, MarketingCampaignEntity>
         implements MarketingCampaignEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/MarketingCampaignSopDetailServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.storlead.trade.entity.MarketingCampaignSopDetailEntity;
 import com.storlead.trade.mapper.MarketingCampaignSopDetailMapper;
@@ -10,6 +13,7 @@ import org.springframework.stereotype.Service;
  * 营销活动SOP明细 Service实现
  */
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class MarketingCampaignSopDetailServiceImpl
         extends ServiceImpl<MarketingCampaignSopDetailMapper, MarketingCampaignSopDetailEntity>
         implements MarketingCampaignSopDetailService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/SopDetailServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.storlead.trade.entity.SopDetailEntity;
 import com.storlead.trade.mapper.SopDetailMapper;
@@ -12,5 +15,6 @@ import org.springframework.stereotype.Service;
  */
 @Slf4j
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class SopDetailServiceImpl extends ServiceImpl<SopDetailMapper, SopDetailEntity> implements SopDetailService {
 }

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/SopServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -29,6 +32,7 @@ import java.util.stream.Collectors;
  */
 @Slf4j
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class SopServiceImpl extends ServiceImpl<SopMapper, SopEntity> implements SopService {
 
     @Resource

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/TagEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 
 import com.storlead.trade.entity.TagEntity;
 import com.storlead.trade.mapper.TagEntityMapper;
@@ -8,6 +11,7 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class TagEntityServiceImpl
         extends MyBaseServiceImpl<TagEntityMapper, TagEntity>
         implements TagEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/TempalteEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 
 import com.storlead.trade.entity.TemplateEntity;
 import com.storlead.trade.mapper.TemplateEntityMapper;
@@ -8,6 +11,7 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class TempalteEntityServiceImpl
         extends MyBaseServiceImpl<TemplateEntityMapper, TemplateEntity>
         implements TemplateEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/TempalteTagEntityServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 
 import com.storlead.trade.entity.TemplateTagEntity;
 import com.storlead.trade.mapper.TemplateTagEntityMapper;
@@ -8,6 +11,7 @@ import com.storlead.framework.mybatis.service.impl.MyBaseServiceImpl;
 import org.springframework.stereotype.Service;
 
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class TempalteTagEntityServiceImpl
         extends MyBaseServiceImpl<TemplateTagEntityMapper, TemplateTagEntity>
         implements TemplateTagEntityService {

java/storlead-sasa/storlead-trade/src/main/java/com/storlead/trade/service/impl/TradeMessageAssembleServiceImpl.java

@@ -1,5 +1,8 @@
 package com.storlead.trade.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.storlead.framework.common.constant.DSConstants;
+
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
 import com.storlead.message.service.impl.MessageService;
@@ -18,6 +21,7 @@ import java.util.Set;
  */
 @Log4j2
 @Service
+@DS(DSConstants.DATASOURCE_TRADE)
 public class TradeMessageAssembleServiceImpl implements TradeMessageAssembleService {
 
     private static final String[] DEFAULT_CHANNELS = {"site", "wecom", "sms", "mail"};