Unverified Commit 6d31f088 authored by Pradyumna's avatar Pradyumna Committed by GitHub
Browse files

Merge pull request #364 from manjudr/merge-fix

SB-24505 - Collection summary agg api issue fix 
parents 3f651403 eb55422c
master 4.0.0_RC4 4.1.0-loadtest-fixes SB-25890 SB-25890-1 bootcamp collection-csv dependabot/maven/course-mw/course-actors-common/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/course-actors-common/org.postgresql-postgresql-42.4.1 dependabot/maven/course-mw/enrolment-actor/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-cassandra-utils/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-notification/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-platform-core/actor-core/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-platform-core/actor-util/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-platform-core/auth-verifier/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-platform-core/common-util/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 dependabot/maven/course-mw/sunbird-util/sunbird-platform-core/common-util/org.apache.kafka-kafka-clients-0.10.2.2 dependabot/maven/service/com.fasterxml.jackson.core-jackson-databind-2.12.7.1 helmchart release-3.9.0 release-4.0.0 release-4.1.0 release-4.2.0 release-4.4.0 release-4.5.0 release-4.6.0 release-4.8.0 release-4.9.0 release-5.0.0 release-5.0.1 release-5.0.2 release-5.1.0 release-5.2.0 release-5.2.1 release-5.3.0 release-5.3.1 release-5.4.0 release-5.3.1_RC1 release-5.3.0_RC1 release-5.2.0_RC2 release-5.2.0_RC1 release-5.1.0_RC2 release-5.1.0_RC1 release-5.0.1_RC3 release-5.0.1_RC2 release-5.0.1_RC1 release-5.0.0_RC6 release-5.0.0_RC5 release-5.0.0_RC4 release-5.0.0_RC3 release-5.0.0_RC2 release-5.0.0_RC1 release-4.9.0_RC4 release-4.9.0_RC3 release-4.9.0_RC2 release-4.9.0_RC1 release-4.8.0_RC2 release-4.8.0_RC1 release-4.6.0_RC10 release-4.6.0_RC9 release-4.6.0_RC8 release-4.6.0_RC7 release-4.6.0_RC6 release-4.6.0_RC5 release-4.6.0_RC4 release-4.6.0_RC3 release-4.6.0_RC2 release-4.6.0_RC1 release-4.5.0_RC4 release-4.5.0_RC3 release-4.5.0_RC2 release-4.5.0_RC1 release-4.4.0_RC3 release-4.4.0_RC2 release-4.4.0_RC1 release-4.2.0_RC1 release-4.1.0_RC4 release-4.1.0_RC3 release-4.1.0_RC2 release-4.1.0_RC1 release-4.0.0_RC7 release-4.0.0_RC6 release-4.0.0_RC5 release-4.0.0_RC4 release-4.0.0_RC3 release-4.0.0_RC2 release-4.0.0_RC1 release-3.9.0_RC7 release-3.9.0_RC6 release-3.9.0_RC5
No related merge requests found
Showing with 21 additions and 12 deletions
+21 -12
package org.sunbird.aggregate
import java.util
import com.google.gson.Gson
import com.mashape.unirest.http.Unirest
import javax.inject.Inject
import javax.ws.rs.core.MediaType
import org.apache.commons.lang3.StringUtils
......@@ -18,9 +18,10 @@ import org.sunbird.common.request.{Request, RequestContext}
import org.sunbird.learner.actors.coursebatch.dao.CourseBatchDao
import org.sunbird.learner.actors.coursebatch.dao.impl.CourseBatchDaoImpl
import org.sunbird.learner.util.{JsonUtil, Util}
import java.math.BigDecimal
import java.text.SimpleDateFormat
import java.util.Date
import scala.collection.JavaConverters._
class CollectionSummaryAggregate @Inject()(implicit val cacheUtil: RedisCacheUtil) extends BaseActor {
......@@ -221,17 +222,25 @@ class CollectionSummaryAggregate @Inject()(implicit val cacheUtil: RedisCacheUti
def getDate(requestContext: RequestContext, date: String, courseId: String, batchId: String): String = {
val dateTimeFormate = DateTimeFormat.forPattern("yyyy-MM-dd")
val sd = new SimpleDateFormat("yyyy-MM-dd");
// When endate is null in the table considering default date as 7
val defaultEndDate = sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC).minusDays(7))))
val nofDates = date.replaceAll("[^0-9]", "")
val endDate = sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC).plusDays(1)))) // Adding 1 Day extra
val startDate = if (!StringUtils.equalsIgnoreCase(date, "ALL")) {
sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC).minusDays(nofDates.toInt))))
val defaultStartDate = sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC))))
val defaultEndDate = sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC).plusDays(1)))) // Adding 1 Day extra
if (StringUtils.equalsIgnoreCase(date, "ALL")) {
val batchOldStartDate: String = Option(courseBatchDao.readById(courseId, batchId, requestContext).getOldStartDate).map(date => if (date.nonEmpty) date else defaultStartDate).getOrElse(defaultStartDate)
val batchOldEndDate: String = Option(courseBatchDao.readById(courseId, batchId, requestContext).getOldEndDate).map(date => if (date.nonEmpty) date else defaultEndDate).getOrElse(defaultEndDate)
val batchLatestStartDate: Date = courseBatchDao.readById(courseId, batchId, requestContext).getStartDate
val batchLatestEndDate: Date = courseBatchDao.readById(courseId, batchId, requestContext).getEndDate
val startDate: String = Option(batchLatestStartDate).map(date => sd.format(date)).getOrElse(batchOldStartDate)
val endDate: String = Option(batchLatestEndDate).map(date => sd.format(date)).getOrElse(batchOldEndDate)
s"$startDate/$endDate"
} else {
val batchEndDate = courseBatchDao.readById(courseId, batchId, requestContext).getEndDate
logger.debug(requestContext, s"BatchId: $batchId, CourseId: $courseId, EndDate" + batchEndDate)
Option(batchEndDate).map(date => if (date == null) defaultEndDate else date).getOrElse(defaultEndDate)
val nofDates = date.replaceAll("[^0-9]", "")
val batchStartDate: String = sd.format(sd.parse(dateTimeFormate.print(DateTime.now(DateTimeZone.UTC).minusDays(nofDates.toInt))))
s"$batchStartDate/$defaultEndDate"
}
s"$startDate/$endDate"
}
}
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment