会员标签4.0

src/main/java/com/gic/spark/datasource/entity/DataSourceSharding.java

@@ -23,8 +23,9 @@ public class DataSourceSharding extends DataSourceEntity {
     private String targetTable;
 
     public DataSourceSharding(String shardingConfig, String targetTable) {
-        sourceType = DataSourceType.MYSQL_SHARDING;
 
+        System.out.println("shardingConfig==>"+shardingConfig+" ,targetTable==>"+targetTable);
+        sourceType = DataSourceType.MYSQL_SHARDING;
         this.shardingConfig = ShardingConfigManager.getInstance().getCurrentShardingConfig(shardingConfig);
         this.targetTable = targetTable;
     }
@@ -39,6 +40,8 @@ public class DataSourceSharding extends DataSourceEntity {
 
     @Override
     public String getSourceKey() {
+        System.out.println("shardingConfig==>"+shardingConfig);
+        System.out.println("name==>"+sourceType.getName()+" ,id==>"+shardingConfig.get_id()+" ,targetTable==>"+targetTable);
         return sourceType.getName() + "_" + shardingConfig.get_id() + "_" + targetTable;
     }
 

src/main/java/com/gic/spark/tag/TagFilterFactory.java

@@ -24,54 +24,54 @@ public class TagFilterFactory {
         TagFilter tagFilter=null;
         switch (tagEsFieldName) {
             //积分信息
-            case TagConstant.TAG_CODE_ACCUMULATED_INTEGRAL:
-                tagFilter= TagAccumulatedIntegralFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_ABOUT_EXPIRE_INTEGRAL:
-                tagFilter= TagAboutExpireIntegralFilter.getInstance();
-                break;
+//            case TagConstant.TAG_CODE_ACCUMULATED_INTEGRAL:
+//                tagFilter= TagAccumulatedIntegralFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_ABOUT_EXPIRE_INTEGRAL:
+//                tagFilter= TagAboutExpireIntegralFilter.getInstance();
+//                break;
 
 
             //卡卷类
             case TagConstant.TAG_CODE_CURRENT_COUPON_NUM:
                 tagFilter= TagCurrentCouponNumFilter.getInstance();
                 break;
-            case TagConstant.TAG_CODE_UNCLAIMED_COUPON:
-                tagFilter= TagCouponFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_GET_NO_CANCEL_COUPON:
-                tagFilter= TagCouponFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_NO_CANCEL_EXPIRES_COUPON:
-                tagFilter= TagCouponFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_CANCEL_COUPON:
-                tagFilter=TagCouponFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_DONATION_IN_COUPON:
-                tagFilter=TagCouponFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_YET_DONATION_COUPON:
-                tagFilter=TagCouponFilter.getInstance();
-                break;
+//            case TagConstant.TAG_CODE_UNCLAIMED_COUPON:
+//                tagFilter= TagCouponFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_GET_NO_CANCEL_COUPON:
+//                tagFilter= TagCouponFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_NO_CANCEL_EXPIRES_COUPON:
+//                tagFilter= TagCouponFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_CANCEL_COUPON:
+//                tagFilter=TagCouponFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_DONATION_IN_COUPON:
+//                tagFilter=TagCouponFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_YET_DONATION_COUPON:
+//                tagFilter=TagCouponFilter.getInstance();
+//                break;
 
 
             //消费统计
-            case TagConstant.TAG_CODE_CONSUMPTION_TIME:
-                tagFilter=TagConsumptionTimeFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_PER_CUSTOMER_TRANSACTION:
-                tagFilter=TagPerCustomerTransactionFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_ASSOCIATED_PURCHASE_RATE:
-                tagFilter=TagAssociatedPurchaseRateFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_AVERAGE_DISCOUNT_FACTOR:
-                tagFilter=TagAverageDiscountFactorFilter.getInstance();
-                break;
-            case TagConstant.TAG_CODE_CONSUMPTION_SLEEP_DAYS:
-                tagFilter=TagConsumptionSleepDaysFilter.getInstance();
-                break;
+//            case TagConstant.TAG_CODE_CONSUMPTION_TIME:
+//                tagFilter=TagConsumptionTimeFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_PER_CUSTOMER_TRANSACTION:
+//                tagFilter=TagPerCustomerTransactionFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_ASSOCIATED_PURCHASE_RATE:
+//                tagFilter=TagAssociatedPurchaseRateFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_AVERAGE_DISCOUNT_FACTOR:
+//                tagFilter=TagAverageDiscountFactorFilter.getInstance();
+//                break;
+//            case TagConstant.TAG_CODE_CONSUMPTION_SLEEP_DAYS:
+//                tagFilter=TagConsumptionSleepDaysFilter.getInstance();
+//                break;
             default:
                 DingtalkMessageUtil.sendAlertMessage("暂未支持的非实时标签: " + tagEsFieldName);
                 break;

src/main/java/com/gic/spark/tag/TagProcess.java

@@ -136,10 +136,11 @@ public class TagProcess {
                         if(null!=tagFilter){
                             tagIdToFilterMap.put(conditionDTO.getTagId(),tagFilter);
                             for(DataSourceEntity sourceEntity:tagFilter.necessarySourceList()){
+                                System.out.println("enterprise_id==>"+entity.enterpriseId);
                                 if(null!=sourceEntity){
                                     System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName());
-                                    System.out.println("SourceKey==>"+sourceEntity.getSourceKey());
-                                    System.out.println("HiveTableName==>"+sourceEntity.getHiveTableName());
+//                                    System.out.println("SourceKey==>"+sourceEntity.getSourceKey());
+//                                    System.out.println("HiveTableName==>"+sourceEntity.getHiveTableName());
                                 }else{
                                     System.out.println("tagEsFieldName==>"+conditionDTO.getTagEsFieldName()+" ,sourceEntity==>"+sourceEntity);
                                 }