update codes

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

-package com.gmei.data.ctr.bean;
-
-/**
- * @ClassName DeviceCurrentEstimatePfrTmp
- * @Author apple
- * @Date 2020/3/31
- * @Version V1.0
- **/
-public class CtrPfrRctBean {
-    private String deviceId;
-    private String statisticsType;
-    private String statisticsTypeId;
-    private String projectPfr;
-    private String firstDemandsPfr;
-    private String firstPositionsPfr;
-    private String firstSolutionsPfr;
-    private String secondDemandsPfr;
-    private String secondPositionsPfr;
-    private String secondSolutionsPfr;
-    private String lastUpdateTime;
-
-    public CtrPfrRctBean(String deviceId, String statisticsType, String statisticsTypeId, String projectPfr,
-                         String firstDemandsPfr, String firstPositionsPfr, String firstSolutionsPfr,
-                         String secondDemandsPfr, String secondPositionsPfr, String secondSolutionsPfr, String lastUpdateTime) {
-        this.deviceId = deviceId;
-        this.statisticsType = statisticsType;
-        this.statisticsTypeId = statisticsTypeId;
-        this.projectPfr = projectPfr;
-        this.firstDemandsPfr = firstDemandsPfr;
-        this.firstPositionsPfr = firstPositionsPfr;
-        this.firstSolutionsPfr = firstSolutionsPfr;
-        this.secondDemandsPfr = secondDemandsPfr;
-        this.secondPositionsPfr = secondPositionsPfr;
-        this.secondSolutionsPfr = secondSolutionsPfr;
-        this.lastUpdateTime = lastUpdateTime;
-    }
-
-    public CtrPfrRctBean() {
-    }
-
-    public String getDeviceId() {
-        return deviceId;
-    }
-
-    public void setDeviceId(String deviceId) {
-        this.deviceId = deviceId;
-    }
-
-    public String getStatisticsType() {
-        return statisticsType;
-    }
-
-    public void setStatisticsType(String statisticsType) {
-        this.statisticsType = statisticsType;
-    }
-
-    public String getStatisticsTypeId() {
-        return statisticsTypeId;
-    }
-
-    public void setStatisticsTypeId(String statisticsTypeId) {
-        this.statisticsTypeId = statisticsTypeId;
-    }
-
-    public String getProjectPfr() {
-        return projectPfr;
-    }
-
-    public void setProjectPfr(String projectPfr) {
-        this.projectPfr = projectPfr;
-    }
-
-    public String getFirstDemandsPfr() {
-        return firstDemandsPfr;
-    }
-
-    public void setFirstDemandsPfr(String firstDemandsPfr) {
-        this.firstDemandsPfr = firstDemandsPfr;
-    }
-
-    public String getFirstPositionsPfr() {
-        return firstPositionsPfr;
-    }
-
-    public void setFirstPositionsPfr(String firstPositionsPfr) {
-        this.firstPositionsPfr = firstPositionsPfr;
-    }
-
-    public String getFirstSolutionsPfr() {
-        return firstSolutionsPfr;
-    }
-
-    public void setFirstSolutionsPfr(String firstSolutionsPfr) {
-        this.firstSolutionsPfr = firstSolutionsPfr;
-    }
-
-    public String getSecondDemandsPfr() {
-        return secondDemandsPfr;
-    }
-
-    public void setSecondDemandsPfr(String secondDemandsPfr) {
-        this.secondDemandsPfr = secondDemandsPfr;
-    }
-
-    public String getSecondPositionsPfr() {
-        return secondPositionsPfr;
-    }
-
-    public void setSecondPositionsPfr(String secondPositionsPfr) {
-        this.secondPositionsPfr = secondPositionsPfr;
-    }
-
-    public String getSecondSolutionsPfr() {
-        return secondSolutionsPfr;
-    }
-
-    public void setSecondSolutionsPfr(String secondSolutionsPfr) {
-        this.secondSolutionsPfr = secondSolutionsPfr;
-    }
-
-    public String getLastUpdateTime() {
-        return lastUpdateTime;
-    }
-
-    public void setLastUpdateTime(String lastUpdateTime) {
-        this.lastUpdateTime = lastUpdateTime;
-    }
-
-    @Override
-    public String toString() {
-        return "DeviceCurrentEstimatePfrTmp{" +
-                "deviceId='" + deviceId + '\'' +
-                ", statisticsType='" + statisticsType + '\'' +
-                ", statisticsTypeId='" + statisticsTypeId + '\'' +
-                ", projectPfr='" + projectPfr + '\'' +
-                ", firstDemandsPfr='" + firstDemandsPfr + '\'' +
-                ", firstPositionsPfr='" + firstPositionsPfr + '\'' +
-                ", firstSolutionsPfr='" + firstSolutionsPfr + '\'' +
-                ", secondDemandsPfr='" + secondDemandsPfr + '\'' +
-                ", secondPositionsPfr='" + secondPositionsPfr + '\'' +
-                ", secondSolutionsPfr='" + secondSolutionsPfr + '\'' +
-                ", lastUpdateTime='" + lastUpdateTime + '\'' +
-                '}';
-    }
-}

src/main/java/com/gmei/data/ctr/main/TestCtrPfrCrtMain.java

 package com.gmei.data.ctr.main;
 
 import com.gmei.data.ctr.operator.CtrPfrCrtOperator;
-import com.gmei.data.ctr.operator.CtrPfrRctOperator;
 import com.gmei.data.ctr.source.MaidianKafkaSource;
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.streaming.api.datastream.DataStream;

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

 package com.gmei.data.ctr.source;
 
 import com.alibaba.druid.pool.DruidDataSource;
+import com.gmei.data.ctr.bean.CtrPfrCrtBean;
+import com.gmei.data.ctr.bean.CtrPfrCrtEtlBean;
 import com.gmei.data.ctr.bean.CtrPfrRctEtlBean;
 import com.gmei.data.ctr.bean.CtrPfrRctBean;
 import com.gmei.data.ctr.common.Constants;
@@ -28,7 +30,7 @@ import static java.util.concurrent.Executors.newFixedThreadPool;
  * @Date 2020/3/29
  * @Version V1.0
  **/
-public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, CtrPfrRctBean> {
+public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrCrtEtlBean, CtrPfrCrtBean> {
     private String jerryJdbcUrl;
     private String jerryUsername;
     private String jerryPassword;
@@ -54,20 +56,20 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
         dataSource.setMaxActive(20);
     }
     @Override
-    public void asyncInvoke(CtrPfrRctEtlBean ctrPfrRctEtlBean, ResultFuture<CtrPfrRctBean> resultFuture) throws Exception {
-        Future<CtrPfrRctBean> future = executorService.submit(() -> {
-            return queryFromMySql(ctrPfrRctEtlBean);
+    public void asyncInvoke(CtrPfrCrtEtlBean ctrPfrCrtEtlBean, ResultFuture<CtrPfrCrtBean> resultFuture) throws Exception {
+        Future<CtrPfrCrtBean> future = executorService.submit(() -> {
+            return queryFromMySql(ctrPfrCrtEtlBean);
         });
-        CompletableFuture.supplyAsync(new Supplier<CtrPfrRctBean>() {
+        CompletableFuture.supplyAsync(new Supplier<CtrPfrCrtBean>() {
             @Override
-            public CtrPfrRctBean get() {
+            public CtrPfrCrtBean get() {
                 try {
                     return future.get();
                 } catch (Exception e) {
                     return null;
                 }
             }
-        }).thenAccept((CtrPfrRctBean dbResult) ->{
+        }).thenAccept((CtrPfrCrtBean dbResult) ->{
             resultFuture.complete(Collections.singleton(dbResult));
         });
     }
@@ -81,11 +83,11 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
         }
     }
 
-    private CtrPfrRctBean queryFromMySql(CtrPfrRctEtlBean ctrPfrRctEtlBean)  {
-        CtrPfrRctBean dcept = null;
-        String statisticsType = ctrPfrRctEtlBean.getStatisticsType();
-        String deviceId = ctrPfrRctEtlBean.getDeviceId();
-        String statisticsTypeId = ctrPfrRctEtlBean.getStatisticsTypeId();
+    private CtrPfrCrtBean queryFromMySql(CtrPfrCrtEtlBean ctrPfrCrtEtlBean)  {
+        CtrPfrCrtBean dcept = null;
+        String statisticsType = ctrPfrCrtEtlBean.getStatisticsType();
+        String deviceId = ctrPfrCrtEtlBean.getDeviceId();
+        String statisticsTypeId = ctrPfrCrtEtlBean.getStatisticsTypeId();
         if(statisticsType != null && deviceId!= null && statisticsTypeId != null){
             String sql = "";
             if("service".equals(statisticsType)){
@@ -102,7 +104,7 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
                         "from strategy_answer_tagv3_info where content_id = '%s'",statisticsTypeId);
             }
             if(StringUtils.isNotBlank(sql)){
-                dcept = findTagInfo(sql, ctrPfrRctEtlBean);
+                dcept = findTagInfo(sql, ctrPfrCrtEtlBean);
                 if(null != dcept){
                     Date date = new Date();
                     dcept.setDeviceId(deviceId);
@@ -115,8 +117,8 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
         return dcept;
     }
 
-    private CtrPfrRctBean findTagInfo(String sql, CtrPfrRctEtlBean ctrPfrRctEtlBean){
-        CtrPfrRctBean ctrPfrRctBean = null;
+    private CtrPfrCrtBean findTagInfo(String sql, CtrPfrCrtEtlBean ctrPfrCrtEtlBean){
+        CtrPfrCrtBean ctrPfrCrtBean = null;
         Connection connection = null;
         PreparedStatement stmt = null;
         ResultSet rs = null;
@@ -125,14 +127,14 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
             stmt = connection.prepareStatement(sql);
             rs = stmt.executeQuery();
             while(rs.next()){
-                ctrPfrRctBean = new CtrPfrRctBean();
-                ctrPfrRctBean.setProjectPfr(rs.getString("project_tags"));
-                ctrPfrRctBean.setFirstDemandsPfr(rs.getString("first_demands"));
-                ctrPfrRctBean.setFirstPositionsPfr(rs.getString("first_positions"));
-                ctrPfrRctBean.setFirstSolutionsPfr(rs.getString("first_solutions"));
-                ctrPfrRctBean.setSecondDemandsPfr(rs.getString("second_demands"));
-                ctrPfrRctBean.setSecondPositionsPfr(rs.getString("second_positions"));
-                ctrPfrRctBean.setSecondSolutionsPfr(rs.getString("second_solutions"));
+                ctrPfrCrtBean = new CtrPfrCrtBean();
+                ctrPfrCrtBean.setProjectPfr(rs.getString("project_tags"));
+                ctrPfrCrtBean.setFirstDemandsPfr(rs.getString("first_demands"));
+                ctrPfrCrtBean.setFirstPositionsPfr(rs.getString("first_positions"));
+                ctrPfrCrtBean.setFirstSolutionsPfr(rs.getString("first_solutions"));
+                ctrPfrCrtBean.setSecondDemandsPfr(rs.getString("second_demands"));
+                ctrPfrCrtBean.setSecondPositionsPfr(rs.getString("second_positions"));
+                ctrPfrCrtBean.setSecondSolutionsPfr(rs.getString("second_solutions"));
             }
         } catch (Exception e){
             e.printStackTrace();
@@ -151,6 +153,6 @@ public class JrAsyncPfrCrtSource extends RichAsyncFunction<CtrPfrRctEtlBean, Ctr
                 e.printStackTrace();
             }
         }
-        return ctrPfrRctBean;
+        return ctrPfrCrtBean;
     }
 }
\ No newline at end of file