Merge branch 'master' of https://git.myitsol.com/hanv/service-campaign

src/main/java/com/viettel/campaign/model/ccms_full/CampaignCustomer.java

@@ -12,11 +12,14 @@ import java.util.Date;
 @Getter
 @Setter
 public class CampaignCustomer {
+
     @Id
+    @GeneratedValue(generator = "CAMPAIGN_CUSTOMER_SEQ")
+    @SequenceGenerator(name = "CAMPAIGN_CUSTOMER_SEQ", sequenceName = "CAMPAIGN_CUSTOMER_SEQ", allocationSize = 1)
     @Basic(optional = false)
     @NotNull
-    @Column(name = "CAMPAIGN_CUSTOMERLIST_ID")
-    private Long campaignCustomerListId;
+    @Column(name = "CAMPAIGN_CUSTOMER_ID")
+    private Long campaignCustomerId;
     @Column(name = "CAMPAIGN_ID")
     private Long campaignId;
     @Column(name = "CUSTOMER_ID")

src/main/java/com/viettel/campaign/model/ccms_full/CampaignCustomerListColumn.java

+package com.viettel.campaign.model.ccms_full;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+
+@Entity
+@Table(name = "CAMPAIGN_CUSTOMERLIST_COLUMN")
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+public class CampaignCustomerListColumn implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @Id
+    @GeneratedValue(generator = "CAMPAIGN_CUS_LIST_COLUMN_SEQ")
+    @SequenceGenerator(name = "CAMPAIGN_CUS_LIST_COLUMN_SEQ", sequenceName = "CAMPAIGN_CUS_LIST_COLUMN_SEQ", allocationSize = 1)
+    @NotNull
+    @Column(name = "CAMPAIGN_CUS_LIST_COLUMN_ID")
+    private Long campaignCusListColId;
+
+    @Column(name = "COMPANY_SITE_ID")
+    private Long companySiteId;
+
+    @Column(name = "CAMPAIGN_ID")
+    private Long campaignId;
+
+    @Size(max = 200)
+    @Column(name = "COLUMN_NAME")
+    private String columnName;
+
+    @Column(name = "ORDER_INDEX")
+    private Long orderIndex;
+
+    @Column(name = "CUSTOMIZE_FIELD_ID")
+    private Long customizeFieldId;
+
+    @Size(max = 200)
+    @Column(name = "CUSTOMIZE_FIELD_TITLE")
+    private String customizeFieldTitle;
+}

src/main/java/com/viettel/campaign/repository/ccms_full/CampaignCustomerRepository.java

@@ -5,10 +5,12 @@ import com.viettel.campaign.model.ccms_full.CampaignCustomer;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
+@Repository
 @Transactional(DataSourceQualify.CCMS_FULL)
 public interface CampaignCustomerRepository extends JpaRepository<CampaignCustomer, Long>, CampaignCustomerRepositoryCustom {
     @Query(value = "SELECT COUNT(*) " +
@@ -33,4 +35,6 @@ public interface CampaignCustomerRepository extends JpaRepository<CampaignCustom
             "  AND cc.recall_time <= SYSDATE\n" +
             "  AND cc.recall_time + interval :apParam MINUTE >= SYSDATE", nativeQuery = true)
     List<CampaignCustomer> getCustomerRecallDate(@Param("campaignId") Long campaignId, @Param("agentId") Long agentId, @Param("companySiteId") Long companySiteId, @Param("apParam") String apParam);
+
+    CampaignCustomer findCampaignCustomerByCampaignCustomerId(Long id);
 }

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

@@ -22,4 +22,8 @@ public interface CampaignRepositoryCustom {
     ResultDTO findCustomerListReallocation(CampaignRequestDTO dto);
     //hungtt
     ResultDTO reallocationCustomer(CampaignRequestDTO dto);
+    //hungtt
+    ResultDTO getListFieldsNotShow(CampaignRequestDTO dto);
+    //hungtt
+    ResultDTO getListFieldsToShow(CampaignRequestDTO dto);
 }

src/main/java/com/viettel/campaign/repository/ccms_full/ScenarioAnswerRepository.java

@@ -2,8 +2,12 @@ package com.viettel.campaign.repository.ccms_full;
 
 import com.viettel.campaign.model.ccms_full.ScenarioAnswer;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 /**
  * @author anhvd_itsol
  */
@@ -11,4 +15,13 @@ import org.springframework.stereotype.Repository;
 
 @Repository
 public interface ScenarioAnswerRepository extends JpaRepository<ScenarioAnswer, Long> {
+
+    List<ScenarioAnswer> findByScenarioQuestionIdAndCompanySiteIdAndStatus(Long scenarioQuestionId, Long companySiteId, Short status);
+
+    @Query(value="SELECT MAX(orderIndex) FROM ScenarioAnswer WHERE scenarioQuestionId = :scenarioQuestionId AND companySiteId = :companySiteId AND status = 1")
+    Long getMaxAnswerOrderId(@Param("scenarioQuestionId") Long scenarioQuestionId, @Param("companySiteId") Long companySiteId);
+
+    Integer deleteScenarioAnswersByScenarioQuestionId(Long scenarioQuestionId);
+
+    ScenarioAnswer findScenarioAnswerByScenarioAnswerId(Long scenarioAnswerId);
 }

src/main/java/com/viettel/campaign/repository/ccms_full/ScenarioQuestionRepository.java

@@ -14,11 +14,13 @@ import java.util.List;
 
 @Repository
 public interface ScenarioQuestionRepository extends JpaRepository<ScenarioQuestion, Long> {
-    List<ScenarioQuestion> findScenarioQuestionsByScenarioIdAndCampaignIdAndCompanySiteIdAndStatus(Long scenarioId, Long campaignId, Long companySiteId, Short status);
+    List<ScenarioQuestion> findScenarioQuestionsByScenarioIdAndCampaignIdAndCompanySiteIdAndStatusOrderByOrderIndex(Long scenarioId, Long campaignId, Long companySiteId, Short status);
 
     @Query(value="SELECT MAX(orderIndex) FROM ScenarioQuestion WHERE scenarioId = :scenarioId AND campaignId = :campaignId AND companySiteId = :companySiteId AND status = 1")
     Long getMaxOrderId(@Param("scenarioId") Long scenarioId, @Param("campaignId") Long campaignId, @Param("companySiteId") Long companySiteId);
 
     @Query(value = "SELECT COUNT(1) FROM ScenarioQuestion WHERE code = :code AND scenarioId = :scenarioId AND campaignId = :campaignId AND companySiteId = :companySiteId AND status = 1")
     Integer countDuplicateQuestionCode(@Param("code") String code, @Param("scenarioId") Long scenarioId, @Param("campaignId") Long campaignId, @Param("companySiteId") Long companySiteId);
+
+    ScenarioQuestion findScenarioQuestionByScenarioQuestionId(Long scenarioQuestionId);
 }

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

@@ -52,5 +52,9 @@ public interface CampaignService {
     ResultDTO findCustomerListReallocation(CampaignRequestDTO dto);
 
     ResultDTO reallocationCustomer(CampaignRequestDTO dto);
+
+    ResultDTO getListFieldsNotShow(CampaignRequestDTO dto);
+
+    ResultDTO getListFieldsToShow(CampaignRequestDTO dto);
     //</editor-fold>
 }

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

@@ -32,7 +32,7 @@ public interface CustomerService {
 
     ResultDTO getAllCustomerList(int page, int pageSize, String sort, Long companySiteId);
 
-    ResultDTO createCustomerList(CustomerListDTO customerListDTO);
+    ResultDTO createCustomerList(CustomerListDTO customerListDTO, String userName);
 
     ResultDTO updateCustomerList(CustomerListDTO customerListDTO);
 

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

 package com.viettel.campaign.service;
 
+import com.viettel.campaign.web.dto.ResultDTO;
+import com.viettel.campaign.web.dto.ScenarioAnswerDTO;
+
 /**
  * @author anhvd_itsol
  */
 
 public interface ScenarioAnswerService {
+    ResultDTO findByScenarioQuestionCompany(Long scenarioQuestionId, Long companySiteId);
+
+    Long getMaxAnswerOrderId(Long scenarioQuestionId, Long companySiteId);
+
+    ResultDTO delete(ScenarioAnswerDTO scenarioAnswerDTO);
 }

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

@@ -15,4 +15,6 @@ public interface ScenarioQuestionService {
     Long getMaxOrderId(Long scenarioId, Long campaignId, Long companySiteId);
 
     Integer countDuplicateQuestionCode(String code, Long scenarioId, Long campaignId, Long companySiteId);
+
+    ResultDTO delete(ScenarioQuestionDTO scenarioQuestionDTO);
 }

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

@@ -2,7 +2,11 @@ package com.viettel.campaign.service;
 
 import com.viettel.campaign.model.ccms_full.Scenario;
 import com.viettel.campaign.web.dto.ResultDTO;
+import com.viettel.campaign.web.dto.ScenarioAnswerDTO;
 import com.viettel.campaign.web.dto.ScenarioDTO;
+import com.viettel.campaign.web.dto.ScenarioQuestionDTO;
+
+import java.util.List;
 
 /**
  * @author anhvd_itsol
@@ -11,4 +15,6 @@ import com.viettel.campaign.web.dto.ScenarioDTO;
 public interface ScenarioService {
     Scenario findScenarioByCampaignIdAndCompanySiteId(Long campaignId, Long companySiteId);
     ResultDTO update(ScenarioDTO scenario);
+
+    ResultDTO sortQuestionAndAnswer(ScenarioDTO scenarioDTO);
 }

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

 package com.viettel.campaign.service.impl;
 
 import com.viettel.campaign.config.DataSourceQualify;
-import com.viettel.campaign.model.ccms_full.ApParam;
-import com.viettel.campaign.model.ccms_full.Campaign;
-import com.viettel.campaign.model.ccms_full.TimeRangeDialMode;
-import com.viettel.campaign.model.ccms_full.TimeZoneDialMode;
+import com.viettel.campaign.model.ccms_full.*;
 //import com.viettel.campaign.model.UserActionLog;
 import com.viettel.campaign.repository.ccms_full.*;
 //import com.viettel.campaign.repository.UserActionLogRepository;
@@ -61,6 +58,9 @@ public class CampaignServiceImpl implements CampaignService {
     @Autowired
     ApParamRepository apParamRepository;
 
+    @Autowired
+    ScenarioRepository scenarioRepository;
+
     @Override
     @Transactional(DataSourceQualify.CCMS_FULL)
     public ResultDTO search(CampaignRequestDTO requestDto) {
@@ -151,6 +151,14 @@ public class CampaignServiceImpl implements CampaignService {
                 });
                 timeZoneDialModeRepository.saveAll(lstTimeZoneModeToInser);
             }
+
+            Scenario scenario = new Scenario();
+            scenario.setCampaignId(campaignId);
+            scenario.setCode(campaignId + "_" + "01");
+            scenario.setCreateTime(new Date());
+            scenario.setCompanySiteId(campaign.getCompanySiteId());
+            scenarioRepository.save(scenario);
+
             resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
             resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
             resultDTO.setData(campaignResult);
@@ -382,9 +390,9 @@ public class CampaignServiceImpl implements CampaignService {
         ResultDTO resultDTO = new ResultDTO();
         List<TimeZoneDialModeDTO> lstTimeZone = dto.getLstTimeZone();
         List<TimeRangeDialModeDTO> lstTimeRange = dto.getLstTimeRange();
-//        Campaign campaignEntity = modelMapper.map(dto, Campaign.class);
         Campaign campaignEntity = new Campaign();
         campaignEntity.setCampaignId(dto.getCampaignId());
+        campaignEntity.setCampaignCode(dto.getCampaignCode());
         campaignEntity.setContent(dto.getContent());
         campaignEntity.setCustomerNumber(dto.getCustomerNumber());
         campaignEntity.setStartTime(dto.getStartTime());
@@ -450,6 +458,74 @@ public class CampaignServiceImpl implements CampaignService {
         return campaignRepositoryCustom.reallocationCustomer(dto);
     }
 
+    // hungtt
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public ResultDTO getListFieldsNotShow(CampaignRequestDTO dto) {
+        Locale locale = Locale.forLanguageTag("vi");
+        Map<String, String> mapColumn = new HashMap<>();
+        mapColumn = setMapData(mapColumn, locale);
+        ResultDTO resultDTO = campaignRepositoryCustom.getListFieldsNotShow(dto);
+        List<FieldsToShowDTO> list = (List<FieldsToShowDTO>)resultDTO.getListData();
+        for (FieldsToShowDTO fieldsToShowDTO : list) {
+            if (fieldsToShowDTO.getIsFix()) {
+                fieldsToShowDTO.setColumnTitle(mapColumn.get(fieldsToShowDTO.getColumnName()));
+            } else {
+                fieldsToShowDTO.setColumnTitle(fieldsToShowDTO.getColumnName());
+            }
+        }
+        resultDTO.setListData(list);
+        return resultDTO;
+    }
+
+
+    // hungtt
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public ResultDTO getListFieldsToShow(CampaignRequestDTO dto) {
+        Locale locale = Locale.forLanguageTag("vi");
+        Map<String, String> mapColumn = new HashMap<>();
+        mapColumn = setMapData(mapColumn, locale);
+        ResultDTO resultDTO = campaignRepositoryCustom.getListFieldsToShow(dto);
+        List<FieldsToShowDTO> list = (List<FieldsToShowDTO>)resultDTO.getListData();
+        for (FieldsToShowDTO fieldsToShowDTO : list) {
+            if (fieldsToShowDTO.getIsFix()) {
+                fieldsToShowDTO.setColumnTitle(mapColumn.get(fieldsToShowDTO.getColumnName()));
+            } else {
+                fieldsToShowDTO.setColumnTitle(fieldsToShowDTO.getColumnName());
+            }
+        }
+        resultDTO.setListData(list);
+        return resultDTO;
+    }
+
+    // hungtt
+    private Map<String, String> setMapData(Map<String, String> mapColumn, Locale locale) {
+        mapColumn.put("CUSTOMER_ID", BundleUtils.getLangString("CUSTOMER_ID", locale));
+        mapColumn.put("CODE", BundleUtils.getLangString("CODE", locale));
+        mapColumn.put("NAME", BundleUtils.getLangString("NAME", locale));
+        mapColumn.put("DESCRIPTION", BundleUtils.getLangString("DESCRIPTION", locale));
+        mapColumn.put("COMPANY_NAME", BundleUtils.getLangString("COMPANY_NAME", locale));
+        mapColumn.put("CUSTOMER_IMG", BundleUtils.getLangString("CUSTOMER_IMG", locale));
+        mapColumn.put("CREATE_DATE", BundleUtils.getLangString("CREATE_DATE", locale));
+        mapColumn.put("UPDATE_DATE", BundleUtils.getLangString("UPDATE_DATE", locale));
+        mapColumn.put("STATUS", BundleUtils.getLangString("STATUS", locale));
+        mapColumn.put("CREATE_BY", BundleUtils.getLangString("CREATE_BY", locale));
+        mapColumn.put("UPDATE_BY", BundleUtils.getLangString("UPDATE_BY", locale));
+        mapColumn.put("SITE_ID", BundleUtils.getLangString("SITE_ID", locale));
+        mapColumn.put("GENDER", BundleUtils.getLangString("GENDER", locale));
+        mapColumn.put("CURRENT_ADDRESS", BundleUtils.getLangString("CURRENT_ADDRESS", locale));
+        mapColumn.put("PLACE_OF_BIRTH", BundleUtils.getLangString("PLACE_OF_BIRTH", locale));
+        mapColumn.put("DATE_OF_BIRTH", BundleUtils.getLangString("DATE_OF_BIRTH", locale));
+        mapColumn.put("MOBILE_NUMBER", BundleUtils.getLangString("MOBILE_NUMBER", locale));
+        mapColumn.put("USERNAME", BundleUtils.getLangString("USERNAME", locale));
+        mapColumn.put("AREA_CODE", BundleUtils.getLangString("AREA_CODE", locale));
+        mapColumn.put("CALL_ALLOWED", BundleUtils.getLangString("CALL_ALLOWED", locale));
+        mapColumn.put("EMAIL_ALLOWED", BundleUtils.getLangString("EMAIL_ALLOWED", locale));
+        mapColumn.put("SMS_ALLOWED", BundleUtils.getLangString("SMS_ALLOWED", locale));
+        mapColumn.put("IPCC_STATUS", BundleUtils.getLangString("IPCC_STATUS", locale));
+        return mapColumn;
+    }
     private String generateCampaignCode(String campaignType, Short chanel) {
         int year = Calendar.getInstance().get(Calendar.YEAR);
         String maxIndexStr = campaignRepositoryCustom.getMaxCampaignIndex();

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

@@ -8,17 +8,16 @@ import com.viettel.campaign.model.ccms_full.CustomerContact;
 import com.viettel.campaign.model.ccms_full.CustomerList;
 import com.viettel.campaign.repository.ccms_full.*;
 import com.viettel.campaign.service.CustomerService;
-import com.viettel.campaign.utils.Constants;
-import com.viettel.campaign.utils.DataUtil;
-import com.viettel.campaign.utils.HibernateUtil;
-import com.viettel.campaign.utils.SQLBuilder;
+import com.viettel.campaign.utils.*;
 import com.viettel.campaign.web.dto.*;
 import com.viettel.campaign.web.dto.request_dto.CustomerDetailRequestDTO;
 import com.viettel.campaign.web.dto.request_dto.CustomerRequestDTO;
 import com.viettel.campaign.web.dto.request_dto.SearchCustomerRequestDTO;
+import com.viettel.econtact.filter.UserSession;
 import org.apache.poi.ss.usermodel.*;
 import org.apache.poi.xssf.usermodel.XSSFSheet;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.eclipse.jetty.client.HttpRequest;
 import org.hibernate.SQLQuery;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
@@ -39,6 +38,7 @@ import org.springframework.util.ResourceUtils;
 import javax.persistence.EntityManager;
 import javax.persistence.PersistenceContext;
 import javax.persistence.Query;
+import javax.servlet.http.HttpServletRequest;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
 import java.util.*;
@@ -579,15 +579,18 @@ public class CustomerServiceImpl implements CustomerService {
 
     @Override
     @Transactional(DataSourceQualify.CCMS_FULL)
-    public ResultDTO createCustomerList(CustomerListDTO customerListDTO) {
+    public ResultDTO createCustomerList(CustomerListDTO customerListDTO, String userName) {
         ResultDTO resultDTO = new ResultDTO();
         CustomerListMapper customerListMapper = new CustomerListMapper();
         CustomerList customerList = new CustomerList();
+
         try {
             if (customerListDTO != null) {
                 // insert
                 CustomerList findCustomer = customerListRepository.findByCustomerListCode(customerListDTO.getCustomerListCode());
                 if (findCustomer == null) {
+                    customerListDTO.setCreateBy(userName);
+
                     customerList = customerListMapper.toPersistenceBean(customerListDTO);
                     customerListRepository.save(customerList);
 

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

 package com.viettel.campaign.service.impl;
 
+import com.viettel.campaign.config.DataSourceQualify;
+import com.viettel.campaign.model.ccms_full.Campaign;
+import com.viettel.campaign.model.ccms_full.CampaignLog;
+import com.viettel.campaign.model.ccms_full.ScenarioAnswer;
+import com.viettel.campaign.repository.ccms_full.CampaignLogRepository;
+import com.viettel.campaign.repository.ccms_full.CampaignRepository;
+import com.viettel.campaign.repository.ccms_full.ScenarioAnswerRepository;
 import com.viettel.campaign.service.ScenarioAnswerService;
+import com.viettel.campaign.utils.Constants;
+import com.viettel.campaign.web.dto.ResultDTO;
+import com.viettel.campaign.web.dto.ScenarioAnswerDTO;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+import java.util.List;
 
 /**
  * @author anhvd_itsol
  */
 
 @Service
+@Transactional(rollbackFor = Exception.class)
 public class ScenarioAnswerServiceImpl implements ScenarioAnswerService {
+    private static final Logger logger = LogManager.getLogger(ScenarioQuestionServiceImpl.class);
+
+    @Autowired
+    ScenarioAnswerRepository scenarioAnswerRepository;
+
+    @Autowired
+    CampaignRepository campaignRepository;
+
+    @Autowired
+    CampaignLogRepository campaignLogRepository;
+
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public ResultDTO findByScenarioQuestionCompany(Long scenarioQuestionId, Long companySiteId) {
+        ResultDTO resultDTO = new ResultDTO();
+        try {
+            List<ScenarioAnswer> lst = scenarioAnswerRepository.findByScenarioQuestionIdAndCompanySiteIdAndStatus(scenarioQuestionId, companySiteId, (short) 1);
+            resultDTO.setData(lst);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+        } catch(Exception ex) {
+            logger.error(ex.getMessage(), ex);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+        }
+        return resultDTO;
+    }
+
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public Long getMaxAnswerOrderId(Long scenarioQuestionId, Long companySiteId) {
+        try {
+            return scenarioAnswerRepository.getMaxAnswerOrderId(scenarioQuestionId, companySiteId);
+        }catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+        }
+        return null;
+    }
+
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public ResultDTO delete(ScenarioAnswerDTO scenarioAnswerDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignLog campaignLog;
+        try {
+            //find campaign
+            Campaign campaign = campaignRepository.findByCampaignId(scenarioAnswerDTO.getCampaignId());
+            if(campaign != null) {
+                if (campaign.getStatus() == 0L || campaign.getStatus() == 1L) {
+                    scenarioAnswerRepository.deleteById(scenarioAnswerDTO.scenarioAnswerId);
+                    campaignLog = new CampaignLog();
+                    campaignLog.setCompanySiteId(scenarioAnswerDTO.getCompanySiteId());
+                    campaignLog.setCreateTime(new Date());
+                    campaignLog.setAgentId(null);
+                    campaignLog.setTableName("SCENARIO_ANSWER");
+                    campaignLog.setDescription("Xoa cau tra loi");
+                    campaignLog.setCampaignId(scenarioAnswerDTO.getCampaignId());
+                    campaignLog.setCustomerId(scenarioAnswerDTO.getScenarioAnswerId());
+                    campaignLogRepository.save(campaignLog);
+                }
+                else {
+                    ScenarioAnswer answer = scenarioAnswerRepository.findScenarioAnswerByScenarioAnswerId(scenarioAnswerDTO.getScenarioAnswerId());
+                    answer.setStatus((short) 0);
+                    answer.setDeleteTime(new Date());
+                    scenarioAnswerRepository.save(answer);
+
+                    campaignLog = new CampaignLog();
+                    campaignLog.setCompanySiteId(scenarioAnswerDTO.getCompanySiteId());
+                    campaignLog.setCreateTime(new Date());
+                    campaignLog.setAgentId(null);
+                    campaignLog.setTableName("SCENARIO_ANSWER");
+                    campaignLog.setDescription("Chinh sua tra loi");
+                    campaignLog.setCampaignId(scenarioAnswerDTO.getCampaignId());
+                    campaignLog.setCustomerId(scenarioAnswerDTO.getScenarioAnswerId());
+                    campaignLogRepository.save(campaignLog);
+                }
+                resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+                resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+            }
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+        }
+        return resultDTO;
+    }
 }

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

@@ -2,11 +2,17 @@ package com.viettel.campaign.service.impl;
 
 import com.viettel.campaign.config.DataSourceQualify;
 import com.viettel.campaign.model.ccms_full.Scenario;
+import com.viettel.campaign.model.ccms_full.ScenarioAnswer;
+import com.viettel.campaign.model.ccms_full.ScenarioQuestion;
+import com.viettel.campaign.repository.ccms_full.ScenarioAnswerRepository;
+import com.viettel.campaign.repository.ccms_full.ScenarioQuestionRepository;
 import com.viettel.campaign.repository.ccms_full.ScenarioRepository;
 import com.viettel.campaign.service.ScenarioService;
 import com.viettel.campaign.utils.Constants;
 import com.viettel.campaign.web.dto.ResultDTO;
+import com.viettel.campaign.web.dto.ScenarioAnswerDTO;
 import com.viettel.campaign.web.dto.ScenarioDTO;
+import com.viettel.campaign.web.dto.ScenarioQuestionDTO;
 import org.modelmapper.ModelMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
@@ -15,7 +21,9 @@ import org.springframework.transaction.annotation.Transactional;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.List;
 
 /**
  * @author anhvd_itsol
@@ -29,6 +37,12 @@ public class ScenarioServiceImpl implements ScenarioService {
     @Autowired
     ScenarioRepository scenarioRepository;
 
+    @Autowired
+    ScenarioQuestionRepository questionRepository;
+
+    @Autowired
+    ScenarioAnswerRepository answerRepository;
+
     @Autowired
     ModelMapper modelMapper;
 
@@ -63,4 +77,43 @@ public class ScenarioServiceImpl implements ScenarioService {
         }
         return resultDTO;
     }
+
+    @Override
+    public ResultDTO sortQuestionAndAnswer(ScenarioDTO scenarioDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        try {
+            List<ScenarioQuestionDTO> lstQuestion = scenarioDTO.getLstQuestion();
+            List<ScenarioAnswerDTO> lstAnswer = scenarioDTO.getLstAnswer();
+            List<ScenarioQuestion> questionsToSort = new ArrayList<>();
+            List<ScenarioAnswer> answersToSort = new ArrayList<>();
+            if (lstQuestion.size() > 0) {
+                lstQuestion.forEach(item -> {
+                    ScenarioQuestion question = questionRepository.findScenarioQuestionByScenarioQuestionId(item.getScenarioQuestionId());
+                    if (question != null) {
+                        question.setOrderIndex(item.getOrderIndex());
+                        questionsToSort.add(question);
+                    }
+                });
+                questionRepository.saveAll(questionsToSort);
+            }
+            if (lstAnswer.size() > 0) {
+                lstAnswer.forEach(item -> {
+                    ScenarioAnswer answer = answerRepository.findScenarioAnswerByScenarioAnswerId(item.getScenarioAnswerId());
+                    if (answer != null) {
+                        answer.setOrderIndex(item.getOrderIndex());
+                        answersToSort.add(answer);
+                    }
+                });
+                answerRepository.saveAll(answersToSort);
+            }
+
+            resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+        }
+        return resultDTO;
+    }
 }

src/main/java/com/viettel/campaign/utils/Config.java

 package com.viettel.campaign.utils;
 
-//import com.viettel.security.PassTranformer;
+import com.viettel.security.PassTranformer;
 import org.apache.log4j.Logger;
 
 import java.io.File;

src/main/java/com/viettel/campaign/utils/SQLBuilder.java

@@ -18,23 +18,23 @@ public class SQLBuilder {
     public static final String SQL_MODULE_CAMPAIGN_STATUS_MNG = "campaign-status-mng";
     public static final String SQL_MODULE_CAMPAIGN_CUSTOMER_MNG = "campaign-customer-mng";
 
-//    public static String getSqlQueryById(String module,
-//                                         String queryId) {
-//        File folder = null;
-//        try {
-//            folder = new ClassPathResource(
-//                    "sql" + File.separator + module + File.separator + queryId + ".sql").getFile();
-//
-//            // Read file
-//            if (folder.isFile()) {
-//                String sql = new String(Files.readAllBytes(Paths.get(folder.getAbsolutePath())));
-//                return sql;
-//            }
-//        } catch (IOException e) {
-//            return null;
-//        }
-//        return null;
-//    }
+    public static String getSqlQueryById(String module,
+                                         String queryId) {
+        File folder = null;
+        try {
+            folder = new ClassPathResource(
+                    "sql" + File.separator + module + File.separator + queryId + ".sql").getFile();
+
+            // Read file
+            if (folder.isFile()) {
+                String sql = new String(Files.readAllBytes(Paths.get(folder.getAbsolutePath())));
+                return sql;
+            }
+        } catch (IOException e) {
+            return null;
+        }
+        return null;
+    }
 
     public static Pageable buildPageable(BaseDTO obj) {
         Pageable pageable = null;

src/main/java/com/viettel/campaign/web/dto/CustomerCustomDTO.java

@@ -21,4 +21,8 @@ public class CustomerCustomDTO {
     String ipccStatus;
     String mobileNumber;
     String email;
+    String connectStatus;
+    String connectTime;
+    String customerName;
+    Long campaignCustomerId;
 }

src/main/java/com/viettel/campaign/web/dto/FieldsToShowDTO.java

+package com.viettel.campaign.web.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.io.Serializable;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class FieldsToShowDTO extends BaseDTO implements Serializable {
+
+    private Long campaignCusListColId;
+
+    private Long companySiteId;
+
+    private Long campaignId;
+
+    private String columnName;
+
+    private String columnTitle;
+
+    private Long orderIndex;
+
+    private Long customizeFieldId;
+
+    private String customizeFieldTitle;
+
+    private Boolean isFix;
+}

src/main/java/com/viettel/campaign/web/dto/ScenarioAnswerDTO.java

@@ -3,6 +3,7 @@ package com.viettel.campaign.web.dto;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.io.Serializable;
 import java.util.Date;
 
 /**
@@ -11,7 +12,7 @@ import java.util.Date;
 
 @Getter
 @Setter
-public class ScenarioAnswerDTO {
+public class ScenarioAnswerDTO implements Serializable {
     public Long scenarioAnswerId;
     public Long companySiteId;
     public Long scenarioQuestionId;
@@ -23,4 +24,5 @@ public class ScenarioAnswerDTO {
     public Date createTime;
     public Date deleteTime;
     public Long mappingQuestionId;
+    public Long campaignId;
 }

src/main/java/com/viettel/campaign/web/dto/ScenarioDTO.java

@@ -4,6 +4,7 @@ import lombok.Getter;
 import lombok.Setter;
 
 import java.util.Date;
+import java.util.List;
 
 /**
  * @author anhvd_itsol
@@ -21,5 +22,7 @@ public class ScenarioDTO {
     private Date createTime;
     private Long updateBy;
     private Date updateTime;
+    private List<ScenarioQuestionDTO> lstQuestion;
+    private List<ScenarioAnswerDTO> lstAnswer;
 }
 

src/main/java/com/viettel/campaign/web/dto/ScenarioQuestionDTO.java

@@ -3,7 +3,9 @@ package com.viettel.campaign.web.dto;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.io.Serializable;
 import java.util.Date;
+import java.util.List;
 
 /**
  * @author anhvd_itsol
@@ -11,7 +13,7 @@ import java.util.Date;
 
 @Getter
 @Setter
-public class ScenarioQuestionDTO {
+public class ScenarioQuestionDTO implements Serializable {
     private Long scenarioQuestionId;
     private Long companySiteId;
     private Long campaignId;
@@ -26,4 +28,5 @@ public class ScenarioQuestionDTO {
     private Short isRequire;
     private Short isDefault;
     private Short answerIndex;
+    private List<ScenarioAnswerDTO> lstAnswers;
 }

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

 package com.viettel.campaign.web.dto.request_dto;
 
 import com.viettel.campaign.web.dto.BaseDTO;
+import com.viettel.campaign.web.dto.CustomerCustomDTO;
 import lombok.Getter;
 import lombok.Setter;
 
+import java.util.List;
+
 /**
  * @author anhvd_itsol
  */
@@ -42,4 +45,6 @@ public class CampaignRequestDTO extends BaseDTO {
     String surveyStatus;
     String roleUser;
     String contactCustId;
+    List<CustomerCustomDTO> customerCustomDTOList;
+
 }

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

@@ -212,4 +212,32 @@ public class CampaignController {
         ResultDTO resultDTO = campaignService.updateCampaign(dto);
         return new ResponseEntity<>(resultDTO, HttpStatus.OK);
     }
+
+    @PostMapping("/findCustomerListReallocation")
+    @ResponseBody
+    public ResponseEntity<?> findCustomerListReallocation(@RequestBody CampaignRequestDTO dto) {
+        ResultDTO result = campaignService.findCustomerListReallocation(dto);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @PostMapping("/reallocationCustomer")
+    @ResponseBody
+    public ResponseEntity<?> reallocationCustomer(@RequestBody CampaignRequestDTO dto) {
+        ResultDTO result = campaignService.reallocationCustomer(dto);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @PostMapping("/getListFieldsNotShow")
+    @ResponseBody
+    public ResponseEntity<?> getListFieldsNotShow(@RequestBody CampaignRequestDTO dto) {
+        ResultDTO resultDTO = campaignService.getListFieldsNotShow(dto);
+        return new ResponseEntity<>(resultDTO, HttpStatus.OK);
+    }
+
+    @PostMapping("/getListFieldsToShow")
+    @ResponseBody
+    public ResponseEntity<?> getListFieldsToShow(@RequestBody CampaignRequestDTO dto) {
+        ResultDTO resultDTO = campaignService.getListFieldsToShow(dto);
+        return new ResponseEntity<>(resultDTO, HttpStatus.OK);
+    }
 }

src/main/java/com/viettel/campaign/web/rest/CustomerController.java

 package com.viettel.campaign.web.rest;
 
+import com.viettel.campaign.utils.RedisUtil;
 import com.viettel.campaign.web.dto.*;
 import com.viettel.campaign.service.CustomerService;
 import com.viettel.campaign.web.dto.request_dto.SearchCustomerRequestDTO;
 import com.viettel.campaign.web.dto.request_dto.CustomerRequestDTO;
+import com.viettel.econtact.filter.UserSession;
 import org.apache.log4j.Logger;
 import org.apache.poi.xssf.usermodel.XSSFRow;
 import org.apache.poi.xssf.usermodel.XSSFSheet;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
+import org.springframework.http.*;
 import org.springframework.stereotype.Controller;
 import org.springframework.util.ResourceUtils;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
+import javax.servlet.http.HttpServletRequest;
 import javax.validation.Valid;
 import java.io.File;
 import java.nio.file.Files;
@@ -59,18 +59,7 @@ public class CustomerController {
     @ResponseBody
     public ResultDTO createCustomer(@RequestBody @Valid CustomerDTO customerDTO) {
         ResultDTO result = new ResultDTO();
-        //LogUtil logUtil = new LogUtil();
-        //logUtil.initKpiLog("createCust");
-        try {
-            //LOGGER.info("Returning createCustomer: start");
-            result = customerService.createCustomer(customerDTO);
-            //LOGGER.info("Returning createCustomer:" + result.getErrorCode());
-            //logUtil.endKpiLog(customerDTO, 0, result.getErrorCode(), result.getDetail(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        } catch (Exception e) {
-            result.setErrorCode("-1");
-            LOGGER.error(e);
-            //logUtil.endKpiLog(customerDTO, 1, result.getErrorCode(), e.getMessage(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        }
+        result = customerService.createCustomer(customerDTO);
         return result;
     }
 
@@ -109,40 +98,21 @@ public class CustomerController {
 
     @PostMapping("/createCustomerList")
     @ResponseBody
-    public ResultDTO createCustomerList(@RequestBody @Valid CustomerListDTO customerListDTO) {
+    public ResultDTO createCustomerList(@RequestBody @Valid CustomerListDTO customerListDTO, HttpServletRequest request) {
         ResultDTO result = new ResultDTO();
-        //LogUtil logUtil = new LogUtil();
-        //logUtil.initKpiLog("createCust")
-        try {
-            //LOGGER.info("Returning createCustomer: start");
-            result = customerService.createCustomerList(customerListDTO);
-            //LOGGER.info("Returning createCustomer:" + result.getErrorCode());
-            //logUtil.endKpiLog(customerDTO, 0, result.getErrorCode(), result.getDetail(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        } catch (Exception e) {
-            result.setErrorCode("-1");
-//            LOGGER.error(e);
-            //logUtil.endKpiLog(customerDTO, 1, result.getErrorCode(), e.getMessage(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        }
+
+        String xAuthToken = request.getHeader("X-Auth-Token");
+        UserSession userSession = (UserSession) RedisUtil.getInstance().get(xAuthToken);
+
+        result = customerService.createCustomerList(customerListDTO, userSession.getUserName());
         return result;
-//        return new ResponseEntity<>("", HttpStatus.OK);
     }
 
     @PostMapping("/updateCustomerList")
     @ResponseBody
     public ResultDTO updateCustomerList(@RequestBody @Valid CustomerListDTO customerListDTO) {
         ResultDTO result = new ResultDTO();
-        //LogUtil logUtil = new LogUtil();
-        //logUtil.initKpiLog("createCust");
-        try {
-            //LOGGER.info("Returning createCustomer: start");
-            result = customerService.updateCustomerList(customerListDTO);
-            //LOGGER.info("Returning createCustomer:" + result.getErrorCode());
-            //logUtil.endKpiLog(customerDTO, 0, result.getErrorCode(), result.getDetail(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        } catch (Exception e) {
-            result.setErrorCode("-1");
-//            LOGGER.error(e);
-            //logUtil.endKpiLog(customerDTO, 1, result.getErrorCode(), e.getMessage(), CustomerController.class, customerDTO.getAgentProcess(), this.serverPort);
-        }
+        result = customerService.updateCustomerList(customerListDTO);
         return result;
     }
 

src/main/java/com/viettel/campaign/web/rest/ScenarioAnswerController.java

 package com.viettel.campaign.web.rest;
 
-import org.springframework.web.bind.annotation.CrossOrigin;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import com.viettel.campaign.service.ScenarioAnswerService;
+import com.viettel.campaign.web.dto.ResultDTO;
+import com.viettel.campaign.web.dto.ScenarioAnswerDTO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
 
 /**
  * @author anhvd_itsol
@@ -12,4 +16,25 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/ipcc/campaign/scenario-answer")
 @CrossOrigin
 public class ScenarioAnswerController {
+    @Autowired
+    ScenarioAnswerService scenarioAnswerService;
+
+    @RequestMapping(value = "/findByScenarioQuestionCompany", method= RequestMethod.GET)
+    public ResponseEntity<ResultDTO> findByScenarioQuestionCampaignCompany(@RequestParam Long scenarioQuestionId,
+                                                                           @RequestParam Long companySiteId) {
+        ResultDTO resultDTO = scenarioAnswerService.findByScenarioQuestionCompany(scenarioQuestionId, companySiteId);
+        return new ResponseEntity<>(resultDTO, HttpStatus.OK);
+    }
+
+    @RequestMapping(value = "/get-max-orderId", method = RequestMethod.GET)
+    public Long getMaxOrderId(@RequestParam Long scenarioQuestionId, @RequestParam Long companySiteId)
+    {
+        return scenarioAnswerService.getMaxAnswerOrderId(scenarioQuestionId, companySiteId);
+    }
+
+    @RequestMapping(value="/delete", method = RequestMethod.POST)
+    public ResponseEntity<ResultDTO> deleteQuestion(@RequestBody ScenarioAnswerDTO answerDTO) {
+        ResultDTO resultDTO = scenarioAnswerService.delete(answerDTO);
+        return new ResponseEntity<>(resultDTO, HttpStatus.OK);
+    }
 }

src/main/java/com/viettel/campaign/web/rest/ScenarioController.java

@@ -33,4 +33,10 @@ public class ScenarioController {
         ResultDTO resultDTO = scenarioService.update(scenario);
         return new ResponseEntity<>(resultDTO, HttpStatus.OK);
     }
+
+    @RequestMapping(value = "/sort-question-answer", method = RequestMethod.POST)
+    ResponseEntity<ResultDTO> sortQuestionAndAnswer(@RequestBody ScenarioDTO scenarioDTO) {
+        ResultDTO resultDTO = scenarioService.sortQuestionAndAnswer(scenarioDTO);
+        return new ResponseEntity<>(resultDTO, HttpStatus.OK);
+    }
 }

src/main/resources/application.yml

 server:
-  port: 1111
+  port: 9999
 spring:
   application:
     name: campaign

src/main/resources/i18n/language_en.properties

@@ -39,3 +39,28 @@ campaign.status.2 = Deploy
 campaign.status.3 = Pause   
 campaign.status.4 = Finish   
 campaign.status.5 = Kêt thúc sớm   
+
+#Campaign customer list management
+CUSTOMER_ID = Id khách hàng
+CODE = Mã khách hàng
+NAME = Tên khách hàng
+DESCRIPTION = Mô tả
+COMPANY_NAME = Tên công ty
+CUSTOMER_IMG = Ảnh khách hàng
+CREATE_DATE = Ngày tạo
+UPDATE_DATE = Ngày cập nhật
+STATUS = Trạng thái
+CREATE_BY = Tạo bởi
+UPDATE_BY = Cập nhật bởi
+SITE_ID = Mã công ty
+GENDER = Giới tính
+CURRENT_ADDRESS = Địa chỉ hiện tại
+PLACE_OF_BIRTH = Nơi sinh
+DATE_OF_BIRTH = Ngày sinh
+MOBILE_NUMBER = Số điện thoại
+USERNAME = Tài khoản
+AREA_CODE = Khu vực
+CALL_ALLOWED = CALL_ALLOWED
+EMAIL_ALLOWED = EMAIL_ALLOWED
+SMS_ALLOWED = SMS_ALLOWED
+IPCC_STATUS = IPCC_STATUS

src/main/resources/i18n/language_vi.properties

@@ -42,4 +42,27 @@ campaign.status.3 = Tạm ngừng
 campaign.status.4 = Kêt thúc   
 campaign.status.5 = Kêt thúc sớm   
 
-
+#Campaign customer list management
+CUSTOMER_ID = Id khách hàng
+CODE = Mã khách hàng
+NAME = Tên khách hàng
+DESCRIPTION = Mô tả
+COMPANY_NAME = Tên công ty
+CUSTOMER_IMG = Ảnh khách hàng
+CREATE_DATE = Ngày tạo
+UPDATE_DATE = Ngày cập nhật
+STATUS = Trạng thái
+CREATE_BY = Tạo bởi
+UPDATE_BY = Cập nhật bởi
+SITE_ID = Mã công ty
+GENDER = Giới tính
+CURRENT_ADDRESS = Địa chỉ hiện tại
+PLACE_OF_BIRTH = Nơi sinh
+DATE_OF_BIRTH = Ngày sinh
+MOBILE_NUMBER = Số điện thoại
+USERNAME = Tài khoản
+AREA_CODE = Khu vực
+CALL_ALLOWED = CALL_ALLOWED
+EMAIL_ALLOWED = EMAIL_ALLOWED
+SMS_ALLOWED = SMS_ALLOWED
+IPCC_STATUS = IPCC_STATUS

src/main/resources/sql/campaign-execute/get-execute-interactive.sql

+with campaign_type_list as (
+    select trim (regexp_substr(:p_list_compaign_type, '[^,]+', 1, level)) campaign_type
+    from dual
+    connect by level <= regexp_count(:p_list_compaign_type, ',') +1
+),
+contact_status_list as (
+select trim (regexp_substr(:p_list_contact_status, '[^,]+', 1, level)) contact_status
+from dual
+connect by level <= regexp_count(:p_list_contact_status, ',') +1
+),
+survey_status_list as (
+select trim (regexp_substr(:p_list_survey_status, '[^,]+', 1, level)) survey_status
+from dual
+connect by level <= regexp_count(:p_list_survey_status, ',') +1
+),
+record_status_list as (
+select trim (regexp_substr(:p_list_record_status, '[^,]+', 1, level)) record_status
+from dual
+connect by level <= regexp_count(:p_list_record_status, ',') +1
+),
+campaign_id_list as (
+select trim (regexp_substr(:p_list_campaign_id, '[^,]+', 1, level)) campaign_id
+from dual
+connect by level <= regexp_count(:p_list_campaign_id, ',') +1
+),
+data_temp as (
 select  b.campaign_code campaignCode,
         b.campaign_name campaignName,
         c.user_name userName,
@@ -22,3 +48,18 @@ where a.status <> 0
     and a.create_time <= to_date(:p_date_to, 'DD/MM/YYYY')
     and a.duration_call >= :p_call_time_from
     and a.duration_call <= :p_call_time_to
+    and to_char(a.customer_id) like '%'||:p_customer_id||'%'
+    and b.campaign_type in (select campaign_type from campaign_type_list)
+    and to_char(a.contact_status) in (select contact_status from contact_status_list)
+    and to_char(a.call_status) in (select survey_status from survey_status_list)
+    and to_char(a.status) in (select record_status from record_status_list)
+    and (:p_phone_number is null or to_char(a.phone_number) like '%'||:p_phone_number||'%')
+    and (:p_list_campaign_id is null or b.campaign_code in (select campaign_id from campaign_id_list))
+    and (:p_campaign_name is null or upper(b.campaign_name) like '%'||:p_campaign_name||'%')
+    and (:p_user_name is null or upper(c.user_name) like '%'||:p_user_name||'%')
+),
+data as (
+select a.*, rownum row_ from data_temp a
+)
+select * from data
+where :p_page_size = 0 or (row_ >= ((:p_page_number - 1) * :p_page_size + 1) and row_ < (:p_page_number * :p_page_size + 1))

src/main/resources/sql/campaign-mng/get-list-customer-reallocation.sql

+with contact as (
+    select customer_id, contact
+    from (
+        select * from customer_contact
+        where status = 1
+            and contact_type = 5
+            and is_direct_line = 1
+        order by create_date desc
+    )
+    where rownum = 1
+),
+connect_status as (
+    select complete_value, complete_name
+    from campaign_complete_code
+    where company_site_id = :p_company_site_id
+        and complete_type = 1
+        and complete_value <> 1
+),
+connect_status_list as (
+    select trim (regexp_substr(:p_list_connect_status, '[^,]+', 1, level)) connect_status
+    from dual
+    connect by level <= regexp_count(:p_list_connect_status, ',') +1
+),
+data as (
+    select  a.campaign_customer_id campaignCustomerId,
+            b.name customerName,
+            c.contact mobileNumber,
+            to_char(a.call_time, 'DD/MM/YYYY HH24:MI:SS') connectTime,
+            d.complete_name connectStatus
+    from campaign_customer a
+    left join customer b on a.customer_id = b.customer_id
+    left join contact c on a.customer_id = c.customer_id
+    left join connect_status d on d.complete_value = a.status
+    where a.campaign_id = :p_campaign_id
+        and a.in_campaign_status = 1
+        and a.status in (select connect_status from connect_status_list)
+    order by connectTime desc, customerName
+),
+final_data as (
+    select a.*, rownum row_ from data a
+)
+select * from final_data
+where row_ >= ((:p_page_number - 1) * :p_page_size + 1)
+    and row_ < (:p_page_number * :p_page_size + 1)

src/main/resources/sql/campaign-mng/get-list-fields-not-show.sql

+with column_name_temp as (
+    select column_name columnName, 1 isFix from user_tab_columns, dual
+    where table_name = 'CUSTOMER'
+)
+select * from column_name_temp where columnName not in (select column_name from campaign_customerlist_column)
+union all
+select title columnName, 0 isFix from customize_fields, dual
+where function_code = 'CUSTOMER'
+    and site_id = :p_company_site_id
+    and customize_field_id not in (select customize_field_id from campaign_customerlist_column where campaign_customerlist_column.campaign_id = :p_campaign_id)

src/main/resources/sql/campaign-mng/get-list-fields-to-show.sql

+select to_char(column_name) columnName, 1 isFix from campaign_customerlist_column, dual where campaign_id = :p_campaign_id
+union all
+select customize_field_title columnName, 0 isFix from campaign_customerlist_column where campaign_id = :p_campaign_id