tubn campaign execute insert scenario

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);

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;
@@ -49,4 +50,6 @@ public interface CampaignExecuteService {
     ResultDTO getCustomerRecall(Long campaignId, Long customerId);
 
     ResultDTO getCustomerInfor(Long companySiteId, Long customerId, Long campaignId);
+
+    ResultDTO createListContacQuestResult(List<ContactQuestResultDTO> dtoList);
 }

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

@@ -4,6 +4,7 @@ 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.ContactQuestResult;
 import com.viettel.campaign.model.ccms_full.ReceiveCustLog;
 import com.viettel.campaign.repository.acd_full.AgentsRepository;
 import com.viettel.campaign.repository.ccms_full.*;
@@ -66,6 +67,9 @@ public class CampaignExecuteServiceImp implements CampaignExecuteService {
     @Autowired
     CampaignCustomerListColumnRepository campaignCustomerListColumnRepository;
 
+    @Autowired
+    ContactQuestResultRepository contactQuestResultRepository;
+
     //<editor-fold: hungtt>
     @Override
     @Transactional(DataSourceQualify.CCMS_FULL)
@@ -670,4 +674,25 @@ 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;
+    }
 }

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,12 @@ 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);
+    }
 }