anhvd commit campaign mng service

src/main/java/com/viettel/campaign/repository/CampaignRepositoryCustom.java

@@ -10,4 +10,5 @@ import java.util.List;
 public interface CampaignRepositoryCustom {
     List<CampaignDTO> searchCampaignExecute(String agentId, Pageable pageable);
     ResultDTO search(CampaignRequestDTO requestDto);
+    ResultDTO findByCompanySiteId(CampaignRequestDTO requestDTO);
 }

src/main/java/com/viettel/campaign/repository/impl/CampaignRepositoryImpl.java

@@ -5,7 +5,6 @@ import com.viettel.campaign.utils.*;
 import com.viettel.campaign.web.dto.CampaignDTO;
 import com.viettel.campaign.web.dto.ResultDTO;
 import com.viettel.campaign.web.dto.request_dto.CampaignRequestDTO;
-import org.bouncycastle.util.test.FixedSecureRandom;
 import org.hibernate.SQLQuery;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
@@ -62,6 +61,11 @@ public class CampaignRepositoryImpl implements CampaignRepositoryCustom {
         Session session = sessionFactory.openSession();
         session.beginTransaction();
 
+        if(DataUtil.isNullOrEmpty(requestDto.getCompanySiteId())) {
+            result.setErrorCode(Constants.ApiErrorCode.ERROR);
+            result.setDescription(Constants.ApiErrorDesc.ERROR);
+            return result;
+        }
         try {
             StringBuilder sqlStr = new StringBuilder();
             sqlStr.append(SQLBuilder.getSqlQueryById(SQLBuilder.SQL_MODULE_CAMPAIGN_MNG, "search-campaign-by-params"));
@@ -77,11 +81,11 @@ public class CampaignRepositoryImpl implements CampaignRepositoryCustom {
             if (!DataUtil.isNullOrEmpty(requestDto.getFromDateFr())) {
                 sqlStr.append(" AND TO_DATE(a.START_TIME, 'DD/MM/YYYY') >= :p_frDateFr");
             }
-            if (!DataUtil.isNullOrEmpty(requestDto.getFromDateTo())) {
-                sqlStr.append(" AND TO_DATE(a.START_TIME, 'DD/MM/YYYY') <= :p_frDateTo");
-            }
             if (!DataUtil.isNullOrEmpty(requestDto.getToDateFr())) {
-                sqlStr.append(" AND TO_DATE(a.END_TIME, 'DD/MM/YYYY') >= :p_toDateFr");
+                sqlStr.append(" AND TO_DATE(a.START_TIME, 'DD/MM/YYYY') <= :p_toDateFr");
+            }
+            if (!DataUtil.isNullOrEmpty(requestDto.getFromDateTo())) {
+                sqlStr.append(" AND TO_DATE(a.END_TIME, 'DD/MM/YYYY') >= :p_frDateTo");
             }
             if (!DataUtil.isNullOrEmpty(requestDto.getToDateTo())) {
                 sqlStr.append(" AND TO_DATE(a.END_TIME, 'DD/MM/YYYY') <= :p_toDateTo");
@@ -126,6 +130,8 @@ public class CampaignRepositoryImpl implements CampaignRepositoryCustom {
                         + "%");
             }
 
+            query.setParameter("p_company_site_id", requestDto.getCompanySiteId());
+
             if (requestDto.getStatus() != null && requestDto.getStatus() > 0) {
                 query.setParameter("p_status", requestDto.getStatus());
             }
@@ -193,6 +199,67 @@ public class CampaignRepositoryImpl implements CampaignRepositoryCustom {
         return result;
     }
 
+    @Override
+    public ResultDTO findByCompanySiteId(CampaignRequestDTO requestDto) {
+        ResultDTO result = new ResultDTO();
+        SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
+
+        Session session = sessionFactory.openSession();
+        session.beginTransaction();
+
+        if(DataUtil.isNullOrEmpty(requestDto.getCompanySiteId())) {
+            result.setErrorCode(Constants.ApiErrorCode.ERROR);
+            result.setDescription(Constants.ApiErrorDesc.ERROR);
+            return result;
+        }
+        try {
+            StringBuilder sqlStr = new StringBuilder();
+            sqlStr.append(" SELECT CAMPAIGN_ID campaignId, " +
+                    "       CAMPAIGN_CODE campaignCode, " +
+                    "       CAMPAIGN_NAME campaignName, " +
+                    "       START_TIME startTime," +
+                    "       END_TIME endTime, " +
+                    "       STATUS status " +
+                    " FROM CAMPAIGN" +
+                    " WHERE COMPANY_SITE_ID = :p_company_site_id AND STATUS <> -1 ");
+            sqlStr.append(" ORDER BY START_TIME DESC ");
+            SQLQuery query = session.createSQLQuery(sqlStr.toString());
+            query.setParameter("p_company_site_id", requestDto.getCompanySiteId());
+
+            query.addScalar("campaignId", new BigDecimalType());
+            query.addScalar("campaignCode", new StringType());
+            query.addScalar("campaignName", new StringType());
+            query.addScalar("startTime", new DateType());
+            query.addScalar("endTime", new DateType());
+            query.addScalar("status", new ShortType());
+
+            query.setResultTransformer(Transformers.aliasToBean(CampaignDTO.class));
+            int count = 0;
+            List<CampaignDTO> list = query.list();
+            if (list.size() > 0) {
+                count = query.list().size();
+            }
+            Pageable pageable = buildPageable(requestDto);
+            if (pageable != null) {
+                query.setFirstResult(pageable.getPageNumber() * pageable.getPageSize());
+                query.setMaxResults(pageable.getPageSize());
+            }
+            List<CampaignDTO> data = query.list();
+            Page<CampaignDTO> dataPage = new PageImpl<>(data, pageable, count);
+            result.setData(dataPage);
+            result.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            result.setDescription(Constants.ApiErrorDesc.SUCCESS);
+            session.close();
+
+            return result;
+        }catch (Exception ex) {
+            session.close();
+        }
+        result.setErrorCode(Constants.ApiErrorCode.ERROR);
+        result.setDescription(Constants.ApiErrorDesc.ERROR);
+        return result;
+    }
+
     private Pageable buildPageable(CampaignRequestDTO obj) {
         Pageable pageable = null;
         if(DataUtil.isNullOrEmpty(obj.getSort())){

src/main/java/com/viettel/campaign/service/CampaignService.java

@@ -9,4 +9,5 @@ import java.util.Map;
 public interface CampaignService {
     Map searchCampaignExecute(int page, int pageSize, String sort, String agentId);
     ResultDTO search(CampaignRequestDTO requestDto);
+    ResultDTO findByCompanySiteId(CampaignRequestDTO requestDTO);
 }

src/main/java/com/viettel/campaign/service/impl/CampaignServiceImpl.java

 package com.viettel.campaign.service.impl;
 
+import com.viettel.campaign.model.Campaign;
 import com.viettel.campaign.repository.CampaignRepository;
 import com.viettel.campaign.web.dto.CampaignDTO;
 
@@ -42,4 +43,13 @@ public class CampaignServiceImpl implements CampaignService {
     public ResultDTO search(CampaignRequestDTO requestDto) {
         return campaignRepository.search(requestDto);
     }
+
+    @Override
+    public ResultDTO findByCompanySiteId(CampaignRequestDTO requestDTO) {
+        requestDTO.setCompanySiteId("663192");
+        requestDTO.setPage(0);
+        requestDTO.setPageSize(10);
+        Pageable pageable = PageRequest.of(requestDTO.getPage(), requestDTO.getPageSize(), null);
+        return campaignRepository.findByCompanySiteId(requestDTO);
+    }
 }

src/main/java/com/viettel/campaign/service/impl/CampaignServiceImpl.java~HEAD

-package com.viettel.campaign.service.impl;
-
-<<<<<<< HEAD:src/main/java/com/viettel/campaign/service/CampaignServiceImpl.java
-import com.viettel.campaign.repository.CampaignRepository;
-import com.viettel.campaign.web.dto.CampaignDTO;
-=======
-import com.viettel.campaign.dto.CampaignDTO;
-import com.viettel.campaign.dto.ResultDTO;
-import com.viettel.campaign.dto.request_dto.CampaignRequestDTO;
-import com.viettel.campaign.model.Campaign;
-import com.viettel.campaign.repository.CampaignRepository;
-import com.viettel.campaign.service.CampaignService;
->>>>>>> anhvd_campaign_mng:src/main/java/com/viettel/campaign/service/impl/CampaignServiceImpl.java
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.PageRequest;
-import org.springframework.data.domain.Pageable;
-import org.springframework.data.domain.Sort;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-@Service
-public class CampaignServiceImpl implements CampaignService {
-
-    @Autowired(required=true)
-    CampaignRepository campaignRepository;
-
-    @Override
-    public Map searchCampaignExecute(int page, int pageSize, String sort, String agentId) {
-        Map result = new HashMap();
-        List<CampaignDTO> lst = new ArrayList<>();
-
-        Pageable pageable = PageRequest.of(page, pageSize, Sort.by(sort));
-        lst = campaignRepository.searchCampaignExecute(agentId, pageable);
-
-        result.put("totalItem", lst.size());
-        result.put("data", lst);
-
-        return result;
-    }
-
-    @Override
-    public ResultDTO search(CampaignRequestDTO requestDto) {
-        return campaignRepository.search(requestDto);
-    }
-}

src/main/java/com/viettel/campaign/web/dto/request_dto/CampaignRequestDTO.java

@@ -4,8 +4,6 @@ import com.viettel.campaign.web.dto.BaseDTO;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.util.Date;
-
 /**
  * @author anhvd_itsol
  */
@@ -25,4 +23,5 @@ public class CampaignRequestDTO extends BaseDTO {
     Long numOfCusTo;
     Short type;
     Short chanel;
+    String companySiteId;
 }

src/main/java/com/viettel/campaign/web/rest/controller/CampaignController.java

 package com.viettel.campaign.web.rest.controller;
 
+import com.viettel.campaign.model.Campaign;
 import com.viettel.campaign.service.CampaignService;
 import com.viettel.campaign.web.dto.ResultDTO;
 import com.viettel.campaign.web.dto.request_dto.CampaignRequestDTO;
@@ -7,11 +8,9 @@ import org.apache.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.data.domain.Page;
 
+import java.util.List;
 import java.util.Map;
 
 @RestController
@@ -37,4 +36,9 @@ public class CampaignController {
         return new ResponseEntity<>(result, HttpStatus.OK);
     }
 
+    @RequestMapping(value = "/findByCompanySiteId", method = RequestMethod.POST)
+    public ResultDTO findByCompanySiteId(CampaignRequestDTO dto) {
+        return campaignService.findByCompanySiteId(dto);
+    }
+
 }

src/main/resources/sql/campaign-mng/search-campaign-by-params.sql

@@ -30,3 +30,5 @@ LEFT JOIN (SELECT cc.campaign_id, count(*) AS SLKHDoNotCall_Khoa
         GROUP BY cc.CAMPAIGN_ID) d
 ON d.CAMPAIGN_ID = a.CAMPAIGN_ID
 WHERE 1 = 1
+AND COMPANY_SITE_ID = :p_company_site_id
+AND a.STATUS <> -1