update codes

src/main/java/com/gmei/data/ctr/sink/CtrEstimateTagMysqlSink.java

@@ -185,56 +185,74 @@ public class CtrEstimateTagMysqlSink extends RichSinkFunction<DeviceCurrentEstim
             }
             String platFirstDemands = deviceCurrentEstimateTagPlat.getPlatFirstDemands();
             if(StringUtils.isNotBlank(platFirstDemands)){
-                if(platFirstDemandsObject.keySet().contains(platFirstDemands)){
-                    Long aLong = platFirstDemandsObject.getLong(platFirstDemands);
-                    platFirstDemandsObject.put(platFirstDemands,aLong + 1);
-                }else{
-                    platFirstDemandsObject.put(platFirstDemands,1);
+                String[] splits = platFirstDemands.split(",");
+                for (String splict: splits) {
+                    if(platFirstDemandsObject.keySet().contains(splict)){
+                        Long aLong = platFirstDemandsObject.getLong(splict);
+                        platFirstDemandsObject.put(splict,aLong + 1);
+                    }else{
+                        platFirstDemandsObject.put(splict,1);
+                    }
                 }
             }
             String platFirstPositions = deviceCurrentEstimateTagPlat.getPlatFirstPositions();
             if(StringUtils.isNotBlank(platFirstPositions)){
-                if(platFirstPositionsObject.keySet().contains(platFirstPositions)){
-                    Long aLong = platFirstPositionsObject.getLong(platFirstPositions);
-                    platFirstPositionsObject.put(platFirstPositions,aLong + 1);
-                }else{
-                    platFirstPositionsObject.put(platFirstPositions,1);
+                String[] splits = platFirstPositions.split(",");
+                for (String split: splits) {
+                    if(platFirstPositionsObject.keySet().contains(split)){
+                        Long aLong = platFirstPositionsObject.getLong(split);
+                        platFirstPositionsObject.put(split,aLong + 1);
+                    }else{
+                        platFirstPositionsObject.put(split,1);
+                    }
                 }
             }
             String platFirstSolutions = deviceCurrentEstimateTagPlat.getPlatFirstSolutions();
             if(StringUtils.isNotBlank(platFirstSolutions)){
-                if(platFirstSolutionsObject.keySet().contains(platFirstSolutions)){
-                    Long aLong = platFirstSolutionsObject.getLong(platFirstSolutions);
-                    platFirstSolutionsObject.put(platFirstSolutions,aLong + 1);
-                }else{
-                    platFirstSolutionsObject.put(platFirstSolutions,1);
+                String[] splits = platFirstSolutions.split(",");
+                for (String split: splits) {
+                    if(platFirstSolutionsObject.keySet().contains(split)){
+                        Long aLong = platFirstSolutionsObject.getLong(split);
+                        platFirstSolutionsObject.put(split,aLong + 1);
+                    }else{
+                        platFirstSolutionsObject.put(split,1);
+                    }
                 }
             }
             String platSecondDemands = deviceCurrentEstimateTagPlat.getPlatSecondDemands();
             if(StringUtils.isNotBlank(platSecondDemands)){
-                if(platSecondDemandsObject.keySet().contains(platSecondDemands)){
-                    Long aLong = platSecondDemandsObject.getLong(platSecondDemands);
-                    platSecondDemandsObject.put(platSecondDemands,aLong + 1);
-                }else{
-                    platSecondDemandsObject.put(platSecondDemands,1);
+                String[] splits = platSecondDemands.split(",");
+                for (String split : splits) {
+                    if(platSecondDemandsObject.keySet().contains(split)){
+                        Long aLong = platSecondDemandsObject.getLong(split);
+                        platSecondDemandsObject.put(split,aLong + 1);
+                    }else{
+                        platSecondDemandsObject.put(split,1);
+                    }
                 }
             }
             String platSecondPositions = deviceCurrentEstimateTagPlat.getPlatSecondPositions();
             if(StringUtils.isNotBlank(platSecondPositions)){
-                if(platSecondPositionsObject.keySet().contains(platSecondPositions)){
-                    Long aLong = platSecondPositionsObject.getLong(platSecondPositions);
-                    platSecondPositionsObject.put(platSecondPositions,aLong + 1);
-                }else{
-                    platSecondPositionsObject.put(platSecondPositions,1);
+                String[] splits = platSecondPositions.split(",");
+                for (String split : splits) {
+                    if(platSecondPositionsObject.keySet().contains(split)){
+                        Long aLong = platSecondPositionsObject.getLong(split);
+                        platSecondPositionsObject.put(split,aLong + 1);
+                    }else{
+                        platSecondPositionsObject.put(split,1);
+                    }
                 }
             }
             String platSecondSolutions = deviceCurrentEstimateTagPlat.getPlatSecondSolutions();
             if(StringUtils.isNotBlank(platSecondSolutions)){
-                if(platSecondSolutionsObject.keySet().contains(platSecondSolutions)){
-                    Long aLong = platSecondSolutionsObject.getLong(platSecondSolutions);
-                    platSecondSolutionsObject.put(platSecondSolutions,aLong + 1);
-                }else{
-                    platSecondSolutionsObject.put(platSecondSolutions,1);
+                String[] splits = platSecondSolutions.split(",");
+                for (String split : splits) {
+                    if(platSecondSolutionsObject.keySet().contains(split)){
+                        Long aLong = platSecondSolutionsObject.getLong(split);
+                        platSecondSolutionsObject.put(split,aLong + 1);
+                    }else{
+                        platSecondSolutionsObject.put(split,1);
+                    }
                 }
             }
             if(isExist){