老游戏消耗

src/main/java/com/qucheng/game/data/oldsystem/ods/DailyCost.java

@@ -96,14 +96,14 @@ public class DailyCost {
                 .build();
 
         MySqlSource<TransportMap> mysqlCDCSource = MySqlSource.<TransportMap>builder()
-                .hostname(props.getProperty("cdc.mysql.backup.host"))
-                .port(StringUtils.isBlank(props.getProperty("cdc.mysql.backup.port")) ? 3306 : Integer.parseInt(props.getProperty("cdc.mysql.backup.port")))
-                .username(props.getProperty("cdc.mysql.backup.username"))
-                .password(props.getProperty("cdc.mysql.backup.password"))
-                .databaseList("ods")
+                .hostname(props.getProperty("cdc.mysql.zx.host"))
+                .port(StringUtils.isBlank(props.getProperty("cdc.mysql.zx.port")) ? 3306 : Integer.parseInt(props.getProperty("cdc.mysql.zx.port")))
+                .username(props.getProperty("cdc.mysql.zx.username"))
+                .password(props.getProperty("cdc.mysql.zx.password"))
+                .databaseList("oceanengine-data-game","advertising-tencent-data-game")
                 .tableList((StringUtils.join(new String[]{
-                        "ods.byte_t_ad_data_day",
-                        "ods.t_gdt_adgroups_data_day",
+                        "oceanengine-data-game.t_ad_data_day",
+                        "advertising-tencent-data-game.t_gdt_adgroups_data_day",
                 }, ",")))
                 .deserializer(new MapDebeziumDeserializationSchema())
                 //5400 和 6400
@@ -132,10 +132,12 @@ public class DailyCost {
             } else {
                 data = transportMap.getAfter();
             }
-            if (dbName.equals("ods")) {
-                if (tableName.equals("byte_t_ad_data_day")) {
+            if (dbName.equals("oceanengine-data-game")) {
+                if (tableName.equals("t_ad_data_day")) {
                     oceanengineCost(operation, data, out);
-                } else if (tableName.equals("t_mp_adgroups_data_day")) {
+                }
+            }else {
+                if (tableName.equals("t_mp_adgroups_data_day")) {
                     tencentMpCost(operation, data, out);
                 } else if (tableName.equals("t_gdt_adgroups_data_day")) {
                     tencentGdtCost(operation, data, out);