会员标签4.0

src/main/java/com/gic/spark/entity/request/TagConsumeChannelRequest.java

@@ -9,13 +9,13 @@ import java.util.List;
  */
 public class TagConsumeChannelRequest extends AbstractFilterRequest{
 
-    private List<String> ChannelVals;
+    private List<Integer> ChannelVals;
 
-    public List<String> getChannelVals() {
+    public List<Integer> getChannelVals() {
         return ChannelVals;
     }
 
-    public void setChannelVals(List<String> channelVals) {
+    public void setChannelVals(List<Integer> channelVals) {
         ChannelVals = channelVals;
     }
 }

src/main/java/com/gic/spark/tag/TagValueParser.java

@@ -281,14 +281,20 @@ public class TagValueParser {
 
     private static AbstractFilterRequest getConsumeChannelRequest(List<TagConditionValDTO> conditionValDTOList) {
         TagConsumeChannelRequest request = new TagConsumeChannelRequest();
+        List<Integer> channelList=new ArrayList();
         for (TagConditionValDTO conditionValDTO : conditionValDTOList) {
             if (Pattern.compile("flag").matcher(conditionValDTO.getKey()).find()) {
                 setStatisticsTypeHandle(request, conditionValDTO.getKey(), conditionValDTO.getVal());
             } else {
                 String[] vals=conditionValDTO.getVal().split(",");
-                request.setChannelVals(Arrays.asList(vals));
+                if(null!=vals){
+                    for (String val : vals) {
+                        channelList.add(Integer.valueOf(val));
+                    }
+                }
             }
         }
+        request.setChannelVals(channelList);
         return request;
     }