anhvd accept merge

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

@@ -18,9 +18,7 @@ public interface CampaignAgentRepository extends JpaRepository<CampaignAgent, Lo
     @Query(value = "SELECT campaign_agent_seq.nextval FROM DUAL", nativeQuery = true)
     Long getNextSeqId();
 
-    @Modifying
-    @Query("UPDATE CampaignAgent SET status = :status WHERE agentId = :agentId AND campaignId = :campaignId")
-    void updateCampaignAgentSetStatus(@Param("agentId") Long agentId, @Param("campaignId") Long campaignId, @Param("status") Integer status);
+    List<CampaignAgent> findByCampaignIdAndAgentId(Long campaignId, Long agentId);
 
     @Modifying
     @Query("delete from CampaignAgent c where c.campaignAgentId in (:p_campaign_agent_id)")

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

@@ -12,26 +12,25 @@ import org.springframework.stereotype.Repository;
 import java.util.List;
 
 @Repository
-public interface CampaignCfgRepository extends JpaRepository<CampaignCfg, Long>{
+public interface CampaignCfgRepository extends JpaRepository<CampaignCfg, Long> {
 
     @Query("FROM CampaignCfg u WHERE u.status = 1 AND u.completeValue NOT IN (1,2,3,4)")
     Page<CampaignCfg> findAll(Pageable pageable);
 
-
     @Query("FROM CampaignCfg WHERE completeName LIKE concat('%', :name, '%') ")
     List<CampaignCfg> findByName(@Param("name") String name, Pageable pageable);
 
     List<CampaignCfg> findByCompleteNameContains(String name, Pageable pageable);
 
     @Modifying
-    @Query("update CampaignCfg c set c.status = 0  where c.campaignCompleteCodeId in (:p_ids) and c.companySiteId=:p_company_site_id" )
+    @Query("update CampaignCfg c set c.status = 0  where c.campaignCompleteCodeId in (:p_ids) and c.companySiteId=:p_company_site_id")
     int deletedList(@Param("p_ids") List<Long> p_ids, @Param("p_company_site_id") Long p_company_site_id);
 
-
     List<CampaignCfg> findCampaignCompleteCodesByCompanySiteId(Long companySiteId);
 
-    @Query(value="SELECT max(completeValue) FROM CampaignCfg WHERE companySiteId = :companySiteId GROUP BY companySiteId")
+    @Query(value = "SELECT max(completeValue) FROM CampaignCfg WHERE companySiteId = :companySiteId GROUP BY companySiteId")
     Short findByMaxCompanySiteId(Long companySiteId);
+
     @Modifying
     @Query("update CampaignCfg c set c.status = 0 where c.campaignCompleteCodeId=:p_campaignCompleteCode_list_id and c.companySiteId=:p_company_site_id")
     int deleteCampaignCompleteCodeBy(@Param("p_campaignCompleteCode_list_id") Long p_campaignCompleteCode_list_id, @Param("p_company_site_id") Long p_company_site_id);
@@ -39,6 +38,9 @@ public interface CampaignCfgRepository extends JpaRepository<CampaignCfg, Long>{
     @Query(value = "FROM CampaignCfg WHERE status = 1 AND completeValue = :completeValue AND completeType = :completeType AND companySiteId = :companySiteId")
     List<CampaignCfg> getCustomerStatus(@Param("completeValue") String completeValue, @Param("completeType") Short completeType, @Param("companySiteId") Long companySiteId);
 
+    @Query(value = "FROM CampaignCfg WHERE status = 1 AND completeType = :completeType AND companySiteId = :companySiteId")
+    List<CampaignCfg> getCustomerStatusByType(@Param("completeType") Short completeType, @Param("companySiteId") Long companySiteId);
+
     @Query(value = "FROM CampaignCfg WHERE status = 1 AND completeValue <> :completeValue AND completeType = :completeType AND companySiteId = :companySiteId")
     List<CampaignCfg> getCustomerStatusWithoutValue(@Param("completeValue") String completeValue, @Param("completeType") Short completeType, @Param("companySiteId") Long companySiteId);
 

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

@@ -21,7 +21,4 @@ public interface CampaignExecuteRepository {
     List<ContactCustResultDTO> getInteractiveResult(CampaignRequestDTO dto, Pageable pageable);
 
     List<ContactCustResultDTO> getExcelInteractiveResult(CampaignRequestDTO dto);
-
-    List<ContactCustResultDTO> getContactCustById(CampaignRequestDTO dto);
-    //</editor-fold: hungtt>
 }

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

 package com.viettel.campaign.repository.ccms_full;
 
+import com.viettel.campaign.config.DataSourceQualify;
 import com.viettel.campaign.model.ccms_full.TimeRangeDialMode;
 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;
 
@@ -13,13 +15,21 @@ import java.util.List;
  */
 
 @Repository
+@Transactional(DataSourceQualify.CCMS_FULL)
 public interface TimeRangeDialModeRepository extends JpaRepository<TimeRangeDialMode, Long> {
 
     List<TimeRangeDialMode> findTimeRangeDialModeByCampaignIdAndCompanySiteId(Long campaignId, Long companySiteId);
 
-    @Query(value = "SELECT * FROM TIME_RANGE_DIAL_MODE r " +
-            "WHERE r.CAMPAIGN_ID = :campaignId AND r.COMPANY_SITE_ID = :companySiteId AND TO_CHAR(r.START_TIME,'HH24:MI:SS') <= TO_CHAR(SYSDATE,'HH24:MI:SS')", nativeQuery = true)
-    TimeRangeDialMode findDialModeAtCurrent(@Param("campaignId") Long campaignId, @Param("companySiteId") Long companySiteId);
+    @Query(value = "SELECT * " +
+            "FROM (SELECT Z.* " +
+            "      FROM TIME_ZONE_DIAL_MODE Z INNER JOIN CAMPAIGN C ON Z.CAMPAIGN_ID = C.CAMPAIGN_ID " +
+            "      WHERE Z.COMPANY_SITE_ID = :companySiteId " +
+            "        AND Z.CAMPAIGN_ID = :campaignId " +
+            "        AND TO_DATE(START_TIME, 'YYYY/MM/DD') <= TO_DATE(SYSDATE, 'YYYY/MM/DD') " +
+            "        AND TO_DATE((to_char(SYSDATE, 'YYYY/MM/DD') || ' ' || Z.HOUR || ':' || Z.MINUTE || ':00'), 'YYYY/MM/DD HH24:MI:SS') <= SYSDATE " +
+            "      ORDER BY TO_DATE((to_char(SYSDATE, 'YYYY/MM/DD') || ' ' || Z.HOUR || ':' || Z.MINUTE || ':00'), 'YYYY/MM/DD HH24:MI:SS') DESC " +
+            "     ) WHERE ROWNUM = 1", nativeQuery = true)
+    TimeRangeDialMode findDialModeAtCurrent(@Param("companySiteId") Long companySiteId, @Param("campaignId") Long campaignId);
 
     void deleteAllByCampaignIdAndCompanySiteId(Long campaignId, Long companySiteId);
 }

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

 package com.viettel.campaign.repository.ccms_full;
 
+import com.viettel.campaign.config.DataSourceQualify;
 import com.viettel.campaign.model.ccms_full.TimeZoneDialMode;
 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;
 
@@ -13,12 +15,19 @@ import java.util.List;
  */
 
 @Repository
+@Transactional(DataSourceQualify.CCMS_FULL)
 public interface TimeZoneDialModeRepository extends JpaRepository<TimeZoneDialMode, Long> {
 
     List<TimeZoneDialMode> findTimeZoneDialModeByCampaignIdAndCompanySiteId(Long campaignId, Long companySiteId);
 
-    @Query(value = "SELECT * FROM TIME_ZONE_DIAL_MODE z " +
-            "WHERE z.CAMPAIGN_ID = :campaignId AND z.COMPANY_SITE_ID = :companySiteId AND concat(z.HOUR, ':', z.MINUTE) <= TO_CHAR(SYSDATE,'HH24:MI')", nativeQuery = true)
+    @Query(value = "SELECT * " +
+            "FROM (SELECT R.* " +
+            "      FROM TIME_RANGE_DIAL_MODE R " +
+            "      WHERE R.CAMPAIGN_ID = 11 " +
+            "        AND R.COMPANY_SITE_ID = 662691 " +
+            "        AND TO_DATE(R.START_TIME, 'YYYY/MM/DD HH24:MI:SS') <= TO_DATE(SYSDATE, 'YYYY/MM/DD HH24:MI:SS') " +
+            "      ORDER BY R.START_TIME DESC " +
+            "     ) WHERE ROWNUM = 1", nativeQuery = true)
     TimeZoneDialMode findDialModeAtCurrent(@Param("campaignId") Long campaignId, @Param("companySiteId") Long companySiteId);
 
     void deleteAllByCampaignIdAndCompanySiteId(Long campaignId, Long companySiteId);

src/main/java/com/viettel/campaign/repository/ccms_full/impl/CampaignExecuteRepositoryImp.java

@@ -443,11 +443,6 @@ public class CampaignExecuteRepositoryImp implements CampaignExecuteRepository {
         return list;
     }
 
-    @Override
-    public List<ContactCustResultDTO> getContactCustById(CampaignRequestDTO dto) {
-        return null;
-    }
-
     private boolean isLower24Hour(Date createTime) {
         Date currTime = new Date();
         long diffMilSec = currTime.getTime() - createTime.getTime();

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

 package com.viettel.campaign.service;
 
+import com.viettel.campaign.model.ccms_full.ContactCustResult;
 import com.viettel.campaign.web.dto.*;
 import com.viettel.campaign.web.dto.request_dto.CampaignRequestDTO;
 import com.viettel.econtact.filter.UserSession;
@@ -20,9 +21,6 @@ public interface CampaignExecuteService {
 
     XSSFWorkbook exportInteractiveResult(CampaignRequestDTO dto) throws IOException;
 
-    List<ContactCustResultDTO> getContactCustById(CampaignRequestDTO dto);
-    //</editor-fold>
-
     ResultDTO searchCampaignExecute(CampaignRequestDTO requestDto, String xAuthToken);
 
     ResultDTO getExecuteCampaign(CampaignRequestDTO requestDto);
@@ -50,4 +48,8 @@ public interface CampaignExecuteService {
     ResultDTO getCustomerRecall(Long campaignId, Long customerId);
 
     ResultDTO getCustomerInfor(Long companySiteId, Long customerId, Long campaignId);
+
+    ResultDTO createListContacQuestResult(List<ContactQuestResultDTO> dtoList);
+
+    String getDialModeAtCurrent(Long campaignId, Long companySiteId);
 }

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

@@ -334,8 +334,13 @@ public class CampaignCfgServiceImpl implements CampaignCfgService {
     @Transactional(DataSourceQualify.CCMS_FULL)
     public ResultDTO getListStatus(String completeValue, Short completeType, Long companySiteId) {
         ResultDTO resultDTO = new ResultDTO();
+        List<CampaignCfg> list = new ArrayList<>();
+
         try {
-            List<CampaignCfg> list = completeCodeRepository.getCustomerStatus(completeValue, completeType, companySiteId);
+            if (completeValue == null || completeValue.equalsIgnoreCase("null"))
+                list = completeCodeRepository.getCustomerStatusByType(completeType, companySiteId);
+            else
+                list = completeCodeRepository.getCustomerStatus(completeValue, completeType, companySiteId);
 
             resultDTO.setListData(list);
             resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);

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

@@ -2,9 +2,7 @@ package com.viettel.campaign.service.impl;
 
 import com.viettel.campaign.config.DataSourceQualify;
 import com.viettel.campaign.model.acd_full.Agents;
-import com.viettel.campaign.model.ccms_full.CampaignCustomer;
-import com.viettel.campaign.model.ccms_full.ContactCustResult;
-import com.viettel.campaign.model.ccms_full.ReceiveCustLog;
+import com.viettel.campaign.model.ccms_full.*;
 import com.viettel.campaign.repository.acd_full.AgentsRepository;
 import com.viettel.campaign.repository.ccms_full.*;
 import com.viettel.campaign.service.CampaignExecuteService;
@@ -20,7 +18,6 @@ import org.modelmapper.ModelMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -71,6 +68,9 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
     @Autowired
     CampaignCustomerListColumnRepository campaignCustomerListColumnRepository;
 
+    @Autowired
+    ContactQuestResultRepository contactQuestResultRepository;
+
     public CampaignExecuteServiceImp() throws NoSuchAlgorithmException {
     }
 
@@ -235,12 +235,6 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
         return workbook;
     }
 
-    @Override
-    @Transactional(DataSourceQualify.CCMS_FULL)
-    public List<ContactCustResultDTO> getContactCustById(CampaignRequestDTO dto) {
-        return campaignExecuteRepository.getContactCustById(dto);
-    }
-
     private void writeCellContent(Row row, CellStyle rowStyle, int colNo, Object content) {
         Cell cell = row.createCell(colNo);
         if (content == null) {
@@ -288,27 +282,30 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
     @Override
     public ResultDTO getExecuteCampaign(CampaignRequestDTO requestDto) {
         ResultDTO result = new ResultDTO();
+        String dialMode = getDialModeAtCurrent(Long.parseLong(requestDto.getCompanySiteId()), Long.parseLong(requestDto.getCampaignId()));
 
         try {
-            Agents agents = agentsRepository.findByAgentId(requestDto.getAgentId());
-            //TimeZoneDialMode zoneDialMode = zoneDialModeRepository.findDialModeAtCurrent(Long.parseLong(requestDto.getCampaignId()), Long.parseLong(requestDto.getCompanySiteId()));
-            //TimeRangeDialMode rangeDialMode = rangeDialModeRepository.findDialModeAtCurrent(Long.parseLong(requestDto.getCampaignId()), Long.parseLong(requestDto.getCompanySiteId()));
-            if (agents.getUserStatus().equalsIgnoreCase("CALLOUT") && agents.getCampaignSystemStatus().equalsIgnoreCase("LOGOUT")) {
-                //if (zoneDialMode != null && zoneDialMode.getDialMode().equals(0) || rangeDialMode != null && rangeDialMode.getDialMode().equals(0))
             // update acd_full.agents table
-                Agents a = new Agents();
-                a = agents;
-                a.setAgentId(requestDto.getAgentId());
-                a.setCampaignSystemStatus("AVAILABLE");
-                a.setCurrentCampaignId(Long.parseLong(requestDto.getCampaignId()));
-                a.setUpdateDate(new Date());
-                agentsRepository.save(a);
+            Agents agents = agentsRepository.findByAgentId(requestDto.getAgentId());
+            agents.setAgentId(requestDto.getAgentId());
+            agents.setCampaignSystemStatus("AVAILABLE");
+            agents.setCurrentCampaignId(Long.parseLong(requestDto.getCampaignId()));
+            agents.setUpdateDate(new Date());
+            Agents a1 = agentsRepository.save(agents);
+
             // update ccms_full.campaign_agent table
-                campaignAgentRepository.updateCampaignAgentSetStatus(Long.parseLong(requestDto.getAgentId()), Long.parseLong(requestDto.getCampaignId()), 1);
+            List<CampaignAgent> ca = campaignAgentRepository.findByCampaignIdAndAgentId(Long.parseLong(requestDto.getCampaignId()), Long.parseLong(requestDto.getAgentId()));
+            for (CampaignAgent item : ca) {
+                item.setStatus(1);
             }
+            List<CampaignAgent> ca1 = campaignAgentRepository.saveAll(ca);
 
+            result.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            result.setDescription(Constants.ApiErrorDesc.SUCCESS);
         } catch (Exception e) {
             e.printStackTrace();
+            result.setErrorCode(Constants.ApiErrorCode.ERROR);
+            result.setDescription(Constants.ApiErrorDesc.ERROR);
         }
 
         return result;
@@ -317,6 +314,7 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
     @Override
     public ResultDTO getCustomer(CampaignCustomerDTO dto) {
         ResultDTO result = new ResultDTO();
+        String dialMode = getDialModeAtCurrent(dto.getCompanySiteId(), dto.getCampaignId());
 
         //Agents agents = agentsRepository.findByAgentId(dto.getAgentId());
         //TimeZoneDialMode zoneDialMode = zoneDialModeRepository.findDialModeAtCurrent(Long.parseLong(dto.getCampaignId()), Long.parseLong(dto.getCompanySiteId()));
@@ -529,7 +527,12 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
 
         try {
             agentsRepository.updateAgentLogoutFromCampaign(dto.getAgentId(), "LOGOUT");
-            campaignAgentRepository.updateCampaignAgentSetStatus(Long.parseLong(dto.getAgentId()), Long.parseLong(dto.getCampaignId()), 0);
+            // update ccms_full.campaign_agent table
+            List<CampaignAgent> ca = campaignAgentRepository.findByCampaignIdAndAgentId(Long.parseLong(dto.getCampaignId()), Long.parseLong(dto.getAgentId()));
+            for (CampaignAgent item : ca) {
+                item.setStatus(1);
+            }
+            List<CampaignAgent> ca1 = campaignAgentRepository.saveAll(ca);
 
             result.setErrorCode(Constants.ApiErrorCode.SUCCESS);
             result.setDescription(Constants.ApiErrorDesc.SUCCESS);
@@ -685,4 +688,44 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
         }
         return resultDTO;
     }
+
+    @Override
+    public ResultDTO createListContacQuestResult(List<ContactQuestResultDTO> dtoList) {
+        ResultDTO resultDTO = new ResultDTO();
+        List<ContactQuestResult> lstContactQuestResult = new ArrayList<>();
+        for (ContactQuestResultDTO item : dtoList) {
+            lstContactQuestResult.add(modelMapper.map(item, ContactQuestResult.class));
+        }
+
+        try {
+            List<ContactQuestResult> dataReturn = contactQuestResultRepository.saveAll(lstContactQuestResult);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+            resultDTO.setListData(dataReturn);
+        } catch (Exception e) {
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+        }
+
+        return resultDTO;
+    }
+
+    @Override
+    public String getDialModeAtCurrent(Long campaignId, Long companySiteId) {
+        // 0: manual, 1- Preview, 2-Progressive, 3-Super Progressive, 4- Predictive
+        try {
+            TimeRangeDialMode lstTimeRange = rangeDialModeRepository.findDialModeAtCurrent(companySiteId, campaignId);
+            TimeZoneDialMode lstTimeZone = zoneDialModeRepository.findDialModeAtCurrent(companySiteId, campaignId);
+
+            if (lstTimeRange.getTimeRangeDialModeId() != null) {
+                return lstTimeRange.getDialMode().toString();
+            } else if (lstTimeZone.getTimeZoneDialModeId() != null) {
+                return lstTimeZone.getDialMode().toString();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return "-1";
+    }
 }

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

@@ -1758,9 +1758,8 @@ public class CustomerServiceImpl implements CustomerService {
         Map<String, Object> params = new HashMap<>();
         try {
             StringBuilder sb = new StringBuilder();
-            sb.append(" select distinct name value, value key from customize_field_option_value a");
-            sb.append(" inner join customize_field_object b on a.field_option_value_id = b.field_option_value_id");
-            sb.append(" where a.field_option_id = :p_field_id");
+            sb.append(" select distinct name value, field_option_value_id key from customize_field_option_value");
+            sb.append(" where field_option_id = :p_field_id");
 
             params.put("p_field_id", campaignCustomerDTO.getField());
 
@@ -1824,29 +1823,7 @@ public class CustomerServiceImpl implements CustomerService {
         return query;
     }
 
-//        params.put('1', ["AND","AGE",">=","30"] )
-//        lst.push(params);
-//        StringBuilder sql = "Select ..... WHERE 1 = 1 "
-//        for(lst){
-//            String[] data = lst[i].value
-//            sql.append(data[0] + data[1] + data[2] + data[3]);
-//        }
-
-
-//    Map<String, String> params = new HashMap<>();
-
 
-    //    public ResultDTO searchCustomize(List<CustomizeFields> customizeFields) {
-//        Map<String, CustomizeRequestDTo> hashCustomer = new HashMap<>();
-//        CustomizeRequestDTo customizeRequestDTo = new CustomizeRequestDTo();
-//        hashCustomer.put("1", customizeRequestDTo);
-//        hashCustomer.put("2", customizeRequestDTo);
-//        hashCustomer.put("3", customizeRequestDTo);
-//        StringBuilder sb = new StringBuilder();
-//        sb.append("");
-//        sb.append("");
-//        sb.append("");
-//        sb.append("");
     @Override
     public ResultDTO listCustomizeFields(CustomizeFieldsDTO customizeFields) {
         ResultDTO resultDTO = new ResultDTO();
@@ -1870,50 +1847,8 @@ public class CustomerServiceImpl implements CustomerService {
                 datafill.setCustomizeFieldId(Long.parseLong(cf[x][0]));
                 datafill.setTitle(cf[x][1]);
                 datafill.setType(cf[x][2]);
-
-
-
                 lstCustomizeFields.add(datafill);
             }
-
-//        try {
-//            stringBuilder.append(" with column_name_temp as (");
-//            stringBuilder.append("    select 'CUSTOMER_ID customerId'  , from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("    select 'CUSTOMER_NAME customerName' , from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'CUSTOMER_TYPE customerType'  , from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'NAME name'   , from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'CURRENT_ADDRESS currentAddress',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'PLACE_OF_BIRTH placeOfBirth',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'DATE_OF_BIRTH dateOfBirth',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'MOBILE_NUMBER mobileNumber',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'EMAIL email',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'USERNAME username',  from user_tab_columns, dual");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append("     select 'CUSTOMER_TYPE customerType',  from user_tab_columns, dual");
-//            stringBuilder.append("     where table_name = 'CUSTOMER'");
-//            stringBuilder.append(" )");
-//
-//            stringBuilder.append(" select * from column_name_temp");
-//            stringBuilder.append(" union all");
-//            stringBuilder.append(" select title columnName, 0 isFix ");
-//            stringBuilder.append(" from customize_fields, dual");
-//            stringBuilder.append(" where function_code = 'CUSTOMER'");
-//            stringBuilder.append("     and site_id = :p_company_site_id");
-//            stringBuilder.append("     and STATUS = 1");
-//            stringBuilder.append("   and active = 1 ");
-//            params.put("p_company_site_id", customizeFields.getSiteId());
-//            params.put("p_customer_id", customizeFields.getCustomerId());
-//            LOGGER.info("SQL statement: " + stringBuilder);
-//            list = namedParameterJdbcTemplate.query(stringBuilder.toString(), params, BeanPropertyRowMapper.newInstance(CustomizeFielObjectDTO.class));
             resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
             resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
             resultDTO.setListData(lstCustomizeFields);
@@ -1936,12 +1871,6 @@ public class CustomerServiceImpl implements CustomerService {
         Session session = sessionFactory.openSession();
         session.beginTransaction();
 
-//        if (DataUtil.isNullOrZero(SiteId)) {
-//            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
-//            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
-//            return resultDTO;
-//        }
-
         try {
             StringBuilder sb = new StringBuilder();
 
@@ -1965,60 +1894,63 @@ public class CustomerServiceImpl implements CustomerService {
             sb.append("    FROM CUSTOMER C");
             sb.append("  INNER JOIN CUSTOMIZE_FIELD_OBJECT CFO ON C.CUSTOMER_ID = CFO.OBJECT_ID");
             sb.append("   INNER JOIN CUSTOMIZE_FIELDS CF ON CF.CUSTOMIZE_FIELD_ID = CFO.CUSTOMIZE_FIELDS_ID\n" +
-                    "   WHERE 1 = 1");
-            sb.append("     AND CFO.STATUS = 1");
-            sb.append("   AND ACTIVE = 1 ");
+                    "   WHERE ");
+            sb.append("  CFO.STATUS = 1");
+            sb.append("   AND CF.ACTIVE = 1 ");
             sb.append("  AND  CF.FUNCTION_CODE = 'CUSTOMER' ");
 
             List<CustomerQueryDTO> customerDTOList = campaignCustomerDTO.getListQuery();
-//            sb.append(
-//                    customerDTOList.get(0).getField() + " "
-//                            + customerDTOList.get(0).getOperator() + " "
-//                            + customerDTOList.get(0).getCondition() + " ");
-//            for (int i = 1; i < campaignCustomerDTO.getListQuery().size(); i++) {
-//                sb.append(campaignCustomerDTO.getListQuery().get(i).getJoin() + "  "
-//                        + campaignCustomerDTO.getListQuery().get(i).getField() + "  "
-//                        + campaignCustomerDTO.getListQuery().get(i).getOperator() + "  "
-//                        + campaignCustomerDTO.getListQuery().get(i).getCondition() + "  ");
+
+
             for (CustomerQueryDTO query : customerDTOList) {
-//                if (query.getJoin() == null) {
-//                    sb.append("AND ");
-//                } else {
-//                    sb.append(query.getJoin() + " ");
-//                }
-//                sb.append(query.getField() + " ");
-//                sb.append(query.getOperator() + " ");
+                if (query.getJoin() == null) {
+                    sb.append("AND ");
+                } else {
+                    sb.append(query.getJoin() + " ");
 //               if ("like".equals(query.getOperator()) || "not like".equals(query.getOperator())) {
 //                    sb.append("%"+ query.getCondition() + "% ");
 //               } else {
 //                  sb.append(query.getCondition());
 //              }
-                // LIKE NOT
-
-                if (query.getField() == -1) {
-                    sb.append(query.getJoin() + " C.CUSTOMER_ID " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -2) {
-                    sb.append(query.getJoin() + "C.NAME " + query.getOperator() + " '%" + query.getCondition() + "% ");
-                } else if (query.getField() == -3) {
-                    sb.append(query.getJoin() + " C.COMPANY_NAME " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -4) {
-                    sb.append(query.getJoin() + " C.GENDER " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -5) {
-                    sb.append(query.getJoin() + " C.CURRENT_ADDRESS " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -6) {
-                    sb.append(query.getJoin() + " C.PLACE_OF_BIRTH " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -7) {
-                    sb.append(query.getJoin() + " C.DATE_OF_BIRTH " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -8) {
-                    sb.append(query.getJoin() + " C.MOBILE_NUMBER " + query.getOperator() + " %" + query.getCondition() + "% ");
-                } else if (query.getField() == -9) {
-                    sb.append(query.getJoin() + " C.EMAIL " + query.getOperator() + " %" + query.getCondition() + "%' ");
-                } else if (query.getField() == -10) {
-                    sb.append(query.getJoin() + " C.USER_NAME " + query.getOperator() + " %" + query.getCondition() + "%' ");
-                } else if (query.getField() == -11) {
-                    sb.append(query.getJoin() + " C.CUSTOMER_TYPE " + query.getOperator() + " %" + query.getCondition() + "% ");
                 }
 
+                switch (query.getField() + "") {
+                    case "-1":
+                        sb.append(" C.CUSTOMER_ID " + query.getOperator()  + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-2":
+                        sb.append(" C.NAME " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-3":
+                        sb.append(" C.COMPANY_NAME " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-4":
+                        sb.append(" C.GENDER " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-5":
+                        sb.append(" C.CURRENT_ADDRESS " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-6":
+                        sb.append( " C.PLACE_OF_BIRTH " + query.getOperator() + "to_date(" + query.getCondition() + ", 'dd/mm/yyyy')");
+                        break;
+                    case "-7":
+                        sb.append(" C.DATE_OF_BIRTH " + query.getOperator() + "to_date(" + query.getCondition() + ", 'dd/mm/yyyy')");
+                        break;
+                    case "-8":
+                        sb.append(" C.MOBILE_NUMBER " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-9":
+                        sb.append(" C.EMAIL " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-10":
+                        sb.append(" C.USER_NAME " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                    case "-11":
+                        sb.append(" C.CUSTOMER_TYPE " + query.getOperator() + " '%" + query.getCondition() + "%' ");
+                        break;
+                }
+
+
             }
             SQLQuery query = session.createSQLQuery(sb.toString());
             query.addScalar("customerId", new LongType());

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

@@ -243,6 +243,7 @@ public class DataUtil {
         }
         return sb.toString();
     }
+
 //    public static void main(String[] args) {
 ////        Date rs = DataUtil.toDatefromStringFormat("20170702", "yyyyMMdd");
 ////        System.out.println(rs);
@@ -263,5 +264,8 @@ public class DataUtil {
     public static boolean isNullOrZero(Short value) {
         return (value == null || value.equals(Short.parseShort("0")));
     }
-    public static boolean isNullOrZero(Integer value) { return (value == null || value.equals(Integer.parseInt("0"))); }
+
+    public static boolean isNullOrZero(Integer value) {
+        return (value == null || value.equals(Integer.parseInt("0")));
+    }
 }

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

 package com.viettel.campaign.web.rest;
 
+import com.viettel.campaign.model.ccms_full.ContactQuestResult;
 import com.viettel.campaign.service.CampaignExecuteService;
 import com.viettel.campaign.utils.RedisUtil;
 import com.viettel.campaign.web.dto.*;
@@ -20,6 +21,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.OutputStream;
+import java.util.List;
 
 @RestController
 @RequestMapping("/ipcc/campaign/execute")
@@ -163,4 +165,19 @@ public class CampaignExecuteController {
         ResultDTO result = campaignExecuteService.getCustomerRecall(campaignId, customerId);
         return new ResponseEntity<>(result, HttpStatus.OK);
     }
+
+    @PostMapping("/createListContactQuestResult")
+    @ResponseBody
+    public ResponseEntity<ResultDTO> createListContactQuestResult(@RequestBody List<ContactQuestResultDTO> dtoList) {
+        ResultDTO result = null;
+        //ResultDTO result = campaignExecuteService.createListContacQuestResult(dtoList);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @GetMapping("/getDialModeAtCurrent")
+    @ResponseBody
+    public ResponseEntity getDialModeAtCurrent(@RequestParam("companySiteId") Long companySiteId, @RequestParam("campaignId") Long campaignId) {
+        String result = campaignExecuteService.getDialModeAtCurrent(companySiteId, campaignId);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
 }