populate userIds field

Author: skyhit

src/main/java/com/appirio/service/challengefeeder/api/UserIdData.java

@@ -0,0 +1,25 @@
+package com.appirio.service.challengefeeder.api;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
+import lombok.Getter;
+import lombok.Setter;
+
+public class UserIdData {
+
+	/**
+     * The challengeId field
+     */
+    @Getter
+    @Setter
+    @JsonIgnore
+    private Long challengeId;
+    
+    /**
+     * The user Id field
+     */
+    @Getter
+    @Setter
+    private Long userId;
+
+}

src/main/java/com/appirio/service/challengefeeder/api/challengelisting/ChallengeListingData.java

@@ -6,15 +6,13 @@
 import java.util.Date;
 import java.util.List;
 
-import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.appirio.service.challengefeeder.api.challengelisting.EventData;
 import com.appirio.service.challengefeeder.api.FileTypeData;
 import com.appirio.service.challengefeeder.api.IdentifiableData;
 import com.appirio.service.challengefeeder.api.PhaseData;
-import com.appirio.service.challengefeeder.api.challengelisting.WinnerData;
 import com.appirio.service.challengefeeder.helper.CustomDateDeserializer;
 import com.appirio.supply.constants.SubTrack;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 
 import lombok.Getter;
 import lombok.Setter;
@@ -437,6 +435,13 @@ public class ChallengeListingData extends IdentifiableData {
     @Setter
     private Long challengeId;
 
+    /**
+     *  The userIds field
+     */
+    @Getter
+    @Setter
+    private List<Long> userIds;
+    
     /**
      * Setter for {@link #subTrack}
      * @param subTrack

src/main/java/com/appirio/service/challengefeeder/dao/ChallengeListingFeederDAO.java

@@ -6,6 +6,7 @@
 import java.util.List;
 import java.util.Map;
 
+import com.appirio.service.challengefeeder.api.UserIdData;
 import com.appirio.service.challengefeeder.api.challengelisting.ChallengeListingData;
 import com.appirio.service.challengefeeder.api.challengelisting.EventData;
 import com.appirio.service.challengefeeder.api.challengelisting.WinnerData;
@@ -60,4 +61,13 @@ public interface ChallengeListingFeederDAO {
      */
     @SqlQueryFile("sql/challenge-feeder/get_winners_for_challenge_listing.sql")
     List<WinnerData> getWinnersForChallengeListing(@ApiQueryInput QueryParameter queryParameter);
+    
+    /**
+     * Get user Id
+     *
+     * @param queryParameter the queryParameter to use
+     * @return the List<UserIdData> result
+     */
+    @SqlQueryFile("sql/challenge-feeder/get_challenge-userids.sql")
+    List<UserIdData> getChallengeUserIds(@ApiQueryInput QueryParameter queryParameter);
 }

src/main/java/com/appirio/service/challengefeeder/manager/ChallengeListingFeederManager.java

@@ -18,6 +18,7 @@
 import com.appirio.service.challengefeeder.api.FileTypeData;
 import com.appirio.service.challengefeeder.api.PhaseData;
 import com.appirio.service.challengefeeder.api.PrizeData;
+import com.appirio.service.challengefeeder.api.UserIdData;
 import com.appirio.service.challengefeeder.api.challengelisting.ChallengeListingData;
 import com.appirio.service.challengefeeder.api.challengelisting.EventData;
 import com.appirio.service.challengefeeder.api.challengelisting.WinnerData;
@@ -161,6 +162,9 @@ public void pushChallengeFeeder(ChallengeFeederParam param) throws SupplyExcepti
 
         List<Map<String, Object>> checkpointsSubmissions = this.challengeListingFeederDAO.getCheckpointsSubmissions(queryParameter);
         List<Map<String, Object>> groupIds = this.challengeFeederDAO.getGroupIds(queryParameter);
+        
+        List<UserIdData> userIds = this.challengeListingFeederDAO.getChallengeUserIds(queryParameter);
+        associateAllUserIds(challenges, userIds);
 
         // set other field
         for (ChallengeListingData data : challenges) {
@@ -374,4 +378,28 @@ private static void associateAllPhases(List<ChallengeListingData> challenges, Li
             aPhase.setFixedStartTime(null);
         }
     }
+    
+    
+    /**
+     * Associate all user ids
+     *
+     * @param challenges the challenges to use
+     * @param userIds the userIds to use
+     */
+    private static void associateAllUserIds(List<ChallengeListingData> challenges, List<UserIdData> userIds) {
+        for (UserIdData item : userIds) {
+            for (ChallengeListingData challenge : challenges) {
+                if (challenge.getId().equals(item.getChallengeId())) {
+                    if (challenge.getUserIds() == null) {
+                        challenge.setUserIds(new ArrayList<Long>());
+                    }
+                    challenge.getUserIds().add(item.getUserId());
+                    break;
+                }
+            }
+        }
+        for (UserIdData item : userIds) {
+            item.setChallengeId(null);
+        }
+    }
 }

src/main/resources/sql/challenge-feeder/get_challenge-userids.properties

@@ -0,0 +1,2 @@
+filter.challengeIds.template=p.project_id in (<challengeIds>)
+filter.challengeIds.type=List

src/main/resources/sql/challenge-feeder/get_challenge-userids.sql

@@ -0,0 +1,6 @@
+SELECT distinct
+         p.project_id AS challengeId,
+         r.user_id AS userId
+  FROM RESOURCE r
+  INNER JOIN project p ON p.project_id = r.project_id
+  WHERE p.project_category_id NOT IN (27,37) AND {filter}