修改 join宽表 bug

src/main/java/com/platomix/userprofile/handler/FlatTagHandler.java

@@ -135,14 +135,14 @@ public class FlatTagHandler {
 //					_shellToCluster(new ShellCommond(clickhouseDbCluster[i],i==0,false,builder.toString()));
 //				}else{
 					builder.append("echo 'select ")
-							.appendLn(_dealSelectColumnSql(columnList))
+							.append(_dealSelectColumnSql(columnList))
 							.append(String.format(" from ads.%s where THEMONTH_V = toString(%s) %s' | ",TagKit.getTagTempTable(tempTableName,month),month,userIdSql))
 							.append(String.format(" curl %s:8123?database=ads -u%s:%s -d @- | ",clickhouseDbEtl,clickhouseUserName,clickhousePassWord))
 							.append(String.format(" docker run -i --rm yandex/clickhouse-client --host %s --port 9007 --user %s --password %s --input_format_allow_errors_num=100",clickhouseDbCluster[i],clickhouseUserName,clickhousePassWord))
 							.append(String.format(" --query='INSERT INTO ads.%s( ",cluTableName))
 							.append(String.join(",", columnList))
-							.appendLn(") FORMAT TabSeparated'");
-					_shellToCluster(new ShellCommond(clickhouseDbCluster[i],i==0,false,builder.toString()));
+							.append(" ) FORMAT TabSeparated'");
+					_shellToCluster(new ShellCommond(clickhouseDbCluster[i],false,false,builder.toString()));
 //				}
 			}
 		} catch (IOException | InterruptedException e) {
@@ -279,10 +279,10 @@ public class FlatTagHandler {
 	 */
 	private static boolean _handleComplain(StrBuilder sqlBuilder, String columnName) {
 		if(columnName.contains("`TAG_COMPLAIN`")) {
-			sqlBuilder.append("ifNull("+columnName+", 'B112_22_001') as `TAG_COMPLAIN`,");
+			sqlBuilder.append("ifNull("+columnName+", '\"'\"'B112_22_001'\"'\"') as `TAG_COMPLAIN`,");
 			return true;
 		}else if(columnName.contains("`TAG_COMPLAIN_C`")) {
-			sqlBuilder.append("ifNull("+columnName+", '0次') as `TAG_COMPLAIN_C`,");
+			sqlBuilder.append("ifNull("+columnName+", '\"'\"'0次'\"'\"') as `TAG_COMPLAIN_C`,");
 			return true;
 		}
 		return false;