update codes

src/main/java/com/gmei/data/monitor/operator/PortraitMonitorShdOperator.java

@@ -172,10 +172,12 @@ public class PortraitMonitorShdOperator implements BaseOperator{
                         ++count;
                     }
                 }
+                if(count > 0){
                     String currentTimeStr = DateUtils.getCurrentTimeStr(date);
                     TblMonitorPortraitShd tblMonitorPortraitShd = new TblMonitorPortraitShd(key.getField(0), count, currentTimeStr);
                     out.collect(tblMonitorPortraitShd);
                 }
+            }
         });
         process.print();
         process.addSink(new PortraitShdMysqlSink(outJdbcUrl,maxRetry,retryInteral))

src/main/java/com/gmei/data/monitor/operator/PortraitMonitorSucOperator.java

@@ -83,15 +83,17 @@ public class PortraitMonitorSucOperator implements BaseOperator{
                     long currentTimestamp = DateUtils.getCurrentTimestamp(date);
                     long tenMinitesAgoTimestamp = DateUtils.getTenMinitesAgoTimestamp(date);
                     for (GmPortraitResult element : elements) {
-                        long logTime = Long.valueOf(element.getLog_time());
+                        long logTime = Long.valueOf(Math.round(Double.valueOf(element.getLog_time())));
                         if(logTime >= tenMinitesAgoTimestamp && logTime <= currentTimestamp){
                             ++ count;
                         }
                     }
+                    if(count > 0){
                         String currentTimeStr = DateUtils.getCurrentTimeStr(date);
                         TblMonitorPortraitSuc tblMonitorPortraitSuc = new TblMonitorPortraitSuc(key.getField(0), count, currentTimeStr);
                         out.collect(tblMonitorPortraitSuc);
                     }
+                }
             })
             .addSink(new PortraitSucMysqlSink(outJdbcUrl,maxRetry,retryInteral))
             .setParallelism(parallelism);