cumulative beneficiary.

Author: Mandar-Beehyv

NMSReportingSuite/src/main/java/com/beehyv/nmsreporting/controller/UserController.java

@@ -1444,6 +1444,7 @@ public ResponseEntity<Long> getCumulativeBeneficiaries(){
 
 
         Long cumulativeJoinedSubscription = kilkariCallReportDao.getCumulativeJoinedSubscription(locationId, locationType, toDate);
+        LOGGER.info("cumulativecount:{},date:{},locationType:{},locationId:{}",cumulativeJoinedSubscription,toDate,locationType,locationId);
         return ResponseEntity.ok(cumulativeJoinedSubscription);
 //        Long ashaStarted = 0L;
 //        Long ashaCompleted = 0L;

NMSReportingSuite/src/main/java/com/beehyv/nmsreporting/dao/impl/KilkariCallReportDaoImpl.java

@@ -4,13 +4,15 @@
 import com.beehyv.nmsreporting.dao.KilkariCallReportDao;
 import com.beehyv.nmsreporting.model.KilkariCalls;
 import org.hibernate.Criteria;
+import org.hibernate.Query;
 import org.hibernate.criterion.Order;
 import org.hibernate.criterion.Projections;
 import org.hibernate.criterion.Restrictions;
 import org.springframework.stereotype.Repository;
 
 import java.util.Date;
 import java.util.List;
+import java.util.logging.Logger;
 
 /**
  * Created by beehyv on 11/10/17.
@@ -51,20 +53,29 @@ public  KilkariCalls getKilkariCallreport(Integer locationId, String locationTyp
 
     @Override
     public Long getCumulativeJoinedSubscription(Long locationId, String locationType, Date toDate) {
-        Criteria criteria = createEntityCriteria();
+        String hql;
 
         if (locationId == 0 && "State".equalsIgnoreCase(locationType)) {
-            criteria.add(Restrictions.eq("locationType", locationType));
+            String sql = "SELECT COALESCE(SUM(CAST(total_beneficiaries AS SIGNED)), 0) " +
+                    "FROM agg_kilkari_call_report " +
+                    "WHERE location_type = :locationType AND date = (SELECT date FROM agg_kilkari_call_report ORDER BY date DESC LIMIT 1)";
+            Query query = getSession().createSQLQuery(sql);
+            query.setParameter("locationType", locationType);
+//            query.setParameter("toDate", toDate);
+            Long result = ((Number) query.uniqueResult()).longValue();
+            return result != null ? result : 0L;
         } else {
-            criteria.add(Restrictions.eq("locationId", locationId));
-            criteria.add(Restrictions.eq("locationType", locationType));
+            String sql = "SELECT COALESCE(SUM(CAST(total_beneficiaries AS SIGNED)), 0) " +
+                    "FROM agg_kilkari_call_report " +
+                    "WHERE location_id = :locationId AND location_type = :locationType AND date = (SELECT date FROM agg_kilkari_call_report ORDER BY date DESC LIMIT 1)";
+            Query query = getSession().createSQLQuery(sql);
+            query.setParameter("locationId", locationId);
+            query.setParameter("locationType", locationType);
+//            query.setParameter("toDate", toDate);
+            Long result = ((Number) query.uniqueResult()).longValue();
+            return result != null ? result : 0L;
         }
-        criteria.add(Restrictions.eq("date", toDate));
 
-        criteria.setProjection(Projections.sum("uniqueBeneficiaries"));
-
-        Long result = (Long) criteria.uniqueResult();
-        return result != null ? result : 0L;
     }
 }