update codes

bin/start_tag.sh

@@ -27,7 +27,7 @@ $JAR_DIR/ctr-estimate-1.0-SNAPSHOT.jar \
 --retryInteral 3000 \
 --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate-tag/checkpoint' \
 --parallelism 6 \
---startTime '2020-04-04 11:56:00' \
+--startTime '2020-04-04 12:23:00' \
 >> /data/log/ctr-estimate/ctr-estimate-tag.out 2>&1 &
 
 tail -f /data/log/ctr-estimate/ctr-estimate-tag.out

src/main/java/com/gmei/data/ctr/bean/CtrEstimateTagEtl.java

@@ -11,13 +11,13 @@ public class CtrEstimateTagEtl {
     private String estimateType;
     private Integer count;
     private String cardContentType;
-    private String cardId;
+    private Long cardId;
     private String partitionDate;
     private String lastUpdateTime;
     private String type;
     private String keyWord;
 
-    public CtrEstimateTagEtl(String deviceId, String cardContentType, String cardId, String estimateType, Integer count, String partitionDate, String lastUpdateTime,String type,String keyWord) {
+    public CtrEstimateTagEtl(String deviceId, String cardContentType, Long cardId, String estimateType, Integer count, String partitionDate, String lastUpdateTime,String type,String keyWord) {
         this.deviceId = deviceId;
         this.cardContentType = cardContentType;
         this.cardId = cardId;
@@ -48,11 +48,11 @@ public class CtrEstimateTagEtl {
         this.cardContentType = cardContentType;
     }
 
-    public String getCardId() {
+    public Long getCardId() {
         return cardId;
     }
 
-    public void setCardId(String cardId) {
+    public void setCardId(Long cardId) {
         this.cardId = cardId;
     }
 

src/main/java/com/gmei/data/ctr/operator/CtrEstimateTagOperator.java

@@ -82,7 +82,14 @@ public class CtrEstimateTagOperator implements BaseOperator{
                                     }
                                     if (StringUtils.isNotBlank(clId)) {
                                         String cardContentType = paramsObject.getString("card_content_type");
-                                        String cardId = paramsObject.getString("card_id");
+                                        String cardIdStr = paramsObject.getString("card_id");
+                                        Long cardId = 0L;
+                                        try{
+                                            cardId = Long.valueOf(cardIdStr);
+                                        }catch (Exception e){
+                                            e.printStackTrace();
+                                            return false;
+                                        }
                                         if (null != cardContentType && null != cardId) {
                                             if ("service".equals(cardContentType) || "diary".equals(cardContentType) ||
                                                     "tractate".equals(cardContentType) || "answer".equals(cardContentType)) {
@@ -121,7 +128,8 @@ public class CtrEstimateTagOperator implements BaseOperator{
                             }
                             if (StringUtils.isNotBlank(clId)) {
                                 String cardContentType = paramsObject.getString("card_content_type");
-                                String cardId = paramsObject.getString("card_id");
+                                String cardIdStr = paramsObject.getString("card_id");
+                                Long cardId = Long.valueOf(cardIdStr);
                                 ctrEstimateTagEtl.setDeviceId(deviceId);
                                 if (null != cardContentType && null != cardId) {
                                     ctrEstimateTagEtl.setCardId(cardId);

src/main/java/com/gmei/data/ctr/source/TidbMysqlAsyncSource.java

@@ -70,21 +70,21 @@ public class TidbMysqlAsyncSource extends RichAsyncFunction<CtrEstimateTagEtl, D
         if("commodity".equals(type) || "content".equals(type)){
             String sql = null;
             String cardContentType = ctrEstimateTagEtl.getCardContentType();
-            String cardId = ctrEstimateTagEtl.getCardId();
+            Long cardId = ctrEstimateTagEtl.getCardId();
             if("commodity".equals(type) && "service".equals(cardContentType)){
                 sql = String.format("select first_demands,first_positions,first_solutions,second_demands,second_positions,second_solutions,project_tags " +
-                        "from strategy_service_tagv3_info where service_id = '%s'",cardId);
+                        "from strategy_service_tagv3_info where service_id = '%d'",cardId);
             }
             if("content".equals(type)){
                 if("diary".equals(cardContentType)){
                     sql = String.format("select first_demands,first_positions,first_solutions,second_demands,second_positions,second_solutions,project_tags " +
-                            "from strategy_content_tagv3_info where content_id = '%s'",cardId);
+                            "from strategy_content_tagv3_info where content_id = '%d'",cardId);
                 }else if("tractate".equals(cardContentType)){
                     sql = String.format("select first_demands,first_positions,first_solutions,second_demands,second_positions,second_solutions,project_tags " +
-                            "from strategy_tractate_tagv3_info where content_id = '%s'",cardId);
+                            "from strategy_tractate_tagv3_info where content_id = '%d'",cardId);
                 }else if("answer".equals(cardContentType)){
                     sql = String.format("select first_demands,first_positions,first_solutions,second_demands,second_positions,second_solutions,project_tags " +
-                            "from strategy_answer_tagv3_info where content_id = '%s'",cardId);
+                            "from strategy_answer_tagv3_info where content_id = '%d'",cardId);
                 }
             }
             if(StringUtils.isNotBlank(sql)){