优化部分代码

src/main/java/com/platomix/userprofile/handler/core/ActivityJoinTagHandler.java

@@ -6,10 +6,10 @@ package com.platomix.userprofile.handler.core;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 
-import com.platomix.userprofile.enums.DsEnum;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.platomix.userprofile.enums.DsEnum;
 import com.platomix.userprofile.handler.AbstractTagHandler;
 import com.platomix.userprofile.service.UserprofileTagService;
 import com.platomix.userprofile.utils.StrBuilder;
@@ -52,10 +52,4 @@ public class ActivityJoinTagHandler extends AbstractTagHandler {
 		log.info("\n" + sqlBuilder.toString());
 		dynamicExecuteService.execute(DsEnum.clickhouse, sqlBuilder.toString(), "信息化标签生成");
 	}
-	
-	@Override
-	public boolean executeInBatchs() {
-		return false;
-	}
-
 }

src/main/java/com/platomix/userprofile/handler/core/OrderSumDateTagHandler.java

@@ -7,11 +7,10 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import com.platomix.userprofile.enums.DsEnum;
-import com.platomix.userprofile.service.MobileRangeService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.platomix.userprofile.enums.DsEnum;
 import com.platomix.userprofile.handler.AbstractTagHandler;
 import com.platomix.userprofile.model.UserprofileTag;
 import com.platomix.userprofile.service.UserprofileTagService;
@@ -72,7 +71,7 @@ public class OrderSumDateTagHandler extends AbstractTagHandler {
 	
 	@Override
 	public boolean executeInBatchs() {
-		return false;
+		return true;
 	}
 
 }

src/main/java/com/platomix/userprofile/handler/core/UserOrderStateTagHandler.java

@@ -6,12 +6,10 @@ package com.platomix.userprofile.handler.core;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 
-import com.platomix.userprofile.enums.DsEnum;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.platomix.userprofile.enums.DsEnum;
 import com.platomix.userprofile.handler.AbstractTagHandler;
-import com.platomix.userprofile.service.UserprofileTagService;
 import com.platomix.userprofile.utils.StrBuilder;
 
 import lombok.extern.slf4j.Slf4j;
@@ -27,8 +25,8 @@ public class UserOrderStateTagHandler extends AbstractTagHandler {
 	
 	final static String ZT_TABLE_NAME = "ads.ZT_USER_ORDER_STATE";
 	final static long _STEP=50000000L;
-	@Autowired
-	private UserprofileTagService userprofileTagService;
+//	@Autowired
+//	private UserprofileTagService userprofileTagService;
 
 	@Override
 	public void invoke(String month, String mobileLeft, String mobileRight) {
@@ -77,10 +75,6 @@ public class UserOrderStateTagHandler extends AbstractTagHandler {
 	}
 	
 	@Override
-	public boolean executeInBatchs() {
-		return false;
-	}
-	@Override
 	public long calcMobileRangeStep() {
 		return _STEP;
 	}

src/main/java/com/platomix/userprofile/handler/support/ForecastCancelTagManager.java

@@ -9,10 +9,10 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
-import com.platomix.userprofile.enums.DsEnum;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import com.platomix.userprofile.enums.DsEnum;
 import com.platomix.userprofile.service.DynamicExecuteService;
 import com.platomix.userprofile.utils.TagKit;
 
@@ -99,7 +99,7 @@ public class ForecastCancelTagManager {
 	
 	private void _dropPartition(String tableName, String partitionMonth) {
 		String dropSql = "alter table " + tableName + " drop partition '" + partitionMonth + "'";
-//		dynamicExecuteService.execute(DsEnum.clickhouse, dropSql, String.format("drop table [%s] partition[%s] 完成", tableName, partitionMonth));
+		dynamicExecuteService.execute(DsEnum.clickhouse, dropSql, String.format("drop table [%s] partition[%s] 完成", tableName, partitionMonth));
 		try {
 			TimeUnit.SECONDS.sleep(3);
 		} catch (InterruptedException e) {