Merge pull request #400 from sunbird-cb/4.8.10-dev

changes seperator from under_score to pipe
sunbird-cb · Jan 4, 2024 · b9bf0bc · b9bf0bc
2 parents ef9a83d + e000288
commit b9bf0bc
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/org/sunbird/karmapoints/service/KarmaPointsServiceImpl.java b/src/main/java/org/sunbird/karmapoints/service/KarmaPointsServiceImpl.java
@@ -69,7 +69,7 @@ public Map<String, Object> fetchKarmaPointsUserCourse(String userId, Map<String,
         String cntxType = (String) filters.get(Constants.CONTEXT_TYPE_CAMEL);
         Map<String, Object> resultMap = new HashMap<>();
         Map<String, Object> propertyMap = new HashMap<>();
-        String key = userId +"_"+cntxType+"_"+ cntxtId;
+        String key = userId +"|"+cntxType+"|"+ cntxtId;
         propertyMap.put(Constants.DB_COLUMN_USER_KARMA_POINTS_KEY, key);
         Map<String, Object> userCourseKpList = cassandraOperation.getRecordsByProperties(Constants.KEYSPACE_SUNBIRD,
                 Constants.TABLE_KARMA_POINTS_LOOK_UP, propertyMap, null, Constants.DB_COLUMN_USER_KARMA_POINTS_KEY);
@@ -99,4 +99,8 @@ public void claimKarmaPoints(ClaimKarmaPointsRequest request) {
         kafkaProducer.push(serverProperties.getClaimKarmaPointsTopic(), karmaPointsDataMap);
         logger.info("UserID and CourseId successfully Published to : " + serverProperties.getClaimKarmaPointsTopic());
     }
+
+    public void fetchKarmaPoints(){
+
+    }
 }