anhvd commit scenario services

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

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/ScenarioQuestionServiceImpl.java

 package com.viettel.campaign.service.impl;
 
 import com.viettel.campaign.config.DataSourceQualify;
-import com.viettel.campaign.model.ccms_full.CampaignLog;
-import com.viettel.campaign.model.ccms_full.Scenario;
-import com.viettel.campaign.model.ccms_full.ScenarioQuestion;
+import com.viettel.campaign.model.ccms_full.*;
 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.repository.ccms_full.ScenarioQuestionRepository;
 import com.viettel.campaign.service.ScenarioQuestionService;
 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.ScenarioQuestionDTO;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -17,6 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
@@ -35,6 +37,12 @@ public class ScenarioQuestionServiceImpl implements ScenarioQuestionService {
     @Autowired
     CampaignLogRepository campaignLogRepository;
 
+    @Autowired
+    ScenarioAnswerRepository scenarioAnswerRepository;
+
+    @Autowired
+    CampaignRepository campaignRepository;
+
     @Autowired
     ModelMapper modelMapper;
 
@@ -43,7 +51,7 @@ public class ScenarioQuestionServiceImpl implements ScenarioQuestionService {
     public ResultDTO findByScenarioIdAndCampaignIdAndCompanySiteId(Long scenarioId, Long campaignId, Long companySiteId) {
         ResultDTO resultDTO = new ResultDTO();
         try {
-            List<ScenarioQuestion> lst = scenarioQuestionRepository.findScenarioQuestionsByScenarioIdAndCampaignIdAndCompanySiteIdAndStatus(scenarioId, campaignId, companySiteId, (short)1);
+            List<ScenarioQuestion> lst = scenarioQuestionRepository.findScenarioQuestionsByScenarioIdAndCampaignIdAndCompanySiteIdAndStatusOrderByOrderIndex(scenarioId, campaignId, companySiteId, (short) 1);
             resultDTO.setData(lst);
             resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
             resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
@@ -59,12 +67,39 @@ public class ScenarioQuestionServiceImpl implements ScenarioQuestionService {
     @Transactional(DataSourceQualify.CCMS_FULL)
     public ResultDTO add(ScenarioQuestionDTO scenarioQuestionDTO) {
         ResultDTO resultDTO = new ResultDTO();
+        List<ScenarioAnswerDTO> lstAnswers = new ArrayList<>();
+        List<ScenarioAnswer> lstAnswersToInsert = new ArrayList<>();
         try {
             ScenarioQuestion scenarioQuestion = modelMapper.map(scenarioQuestionDTO, ScenarioQuestion.class);
             scenarioQuestion.setCreateTime(new Date());
             scenarioQuestion.setStatus((short) 1);
             scenarioQuestionRepository.save(scenarioQuestion);
 
+            if (scenarioQuestionDTO.getLstAnswers().size() > 0) {
+                lstAnswers = scenarioQuestionDTO.getLstAnswers();
+                lstAnswers.forEach(item -> {
+                    item.setCode(scenarioQuestion.getScenarioQuestionId() + "_" + item.getOrderIndex());
+                    item.setScenarioQuestionId(scenarioQuestion.getScenarioQuestionId());
+                    item.setCreateTime(new Date());
+                    item.setStatus((short) 1);
+                    ScenarioAnswer answer = modelMapper.map(item, ScenarioAnswer.class);
+                    lstAnswersToInsert.add(answer);
+                });
+                scenarioAnswerRepository.saveAll(lstAnswersToInsert);
+                CampaignLog campaignLogAnswer = new CampaignLog();
+                campaignLogAnswer.setCompanySiteId(scenarioQuestion.getCompanySiteId());
+                campaignLogAnswer.setCreateTime(new Date());
+                campaignLogAnswer.setAgentId(null);
+                campaignLogAnswer.setTableName("SCENARIO_ANSWER");
+                campaignLogAnswer.setColumnName(null);
+                campaignLogAnswer.setPreValue(null);
+                campaignLogAnswer.setPostValue(null);
+                campaignLogAnswer.setDescription("Them moi cau tra loi rieng le");
+                campaignLogAnswer.setCampaignId(scenarioQuestion.getCampaignId());
+                campaignLogAnswer.setCustomerId(scenarioQuestion.getScenarioQuestionId());
+                campaignLogRepository.save(campaignLogAnswer);
+            }
+
             CampaignLog campaignLog = new CampaignLog();
             campaignLog.setCompanySiteId(scenarioQuestion.getCompanySiteId());
             campaignLog.setCreateTime(new Date());
@@ -92,7 +127,8 @@ public class ScenarioQuestionServiceImpl implements ScenarioQuestionService {
     @Transactional(DataSourceQualify.CCMS_FULL)
     public Long getMaxOrderId(Long scenarioId, Long campaignId, Long companySiteId) {
         try {
-            return scenarioQuestionRepository.getMaxOrderId(scenarioId, campaignId, companySiteId);
+            Long index = scenarioQuestionRepository.getMaxOrderId(scenarioId, campaignId, companySiteId);
+            if(index == null) return 0L; else return index;
         }catch (Exception ex) {
             logger.error(ex.getMessage(), ex);
         }
@@ -104,9 +140,86 @@ public class ScenarioQuestionServiceImpl implements ScenarioQuestionService {
     public Integer countDuplicateQuestionCode(String code, Long scenarioId, Long campaignId, Long companySiteId) {
         try {
             return scenarioQuestionRepository.countDuplicateQuestionCode(code, scenarioId, campaignId, companySiteId);
-        }catch (Exception ex) {
+        } catch (Exception ex) {
             logger.error(ex.getMessage(), ex);
         }
         return null;
     }
+
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public ResultDTO delete(ScenarioQuestionDTO scenarioQuestionDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignLog campaignLog;
+        try {
+            //find campaign
+            Campaign campaign = campaignRepository.findByCampaignId(scenarioQuestionDTO.getCampaignId());
+            if (campaign != null) {
+                if (campaign.getStatus() == 0L || campaign.getStatus() == 1L) {
+                    //delete question by questionId
+                    scenarioQuestionRepository.deleteById(scenarioQuestionDTO.getScenarioQuestionId());
+                    campaignLog = new CampaignLog();
+                    campaignLog.setCompanySiteId(scenarioQuestionDTO.getCompanySiteId());
+                    campaignLog.setCreateTime(new Date());
+                    campaignLog.setTableName("SCENARIO_QUESTION");
+                    campaignLog.setDescription("Xoa cau hoi");
+                    campaignLog.setCampaignId(scenarioQuestionDTO.getCampaignId());
+                    campaignLog.setCustomerId(scenarioQuestionDTO.getScenarioQuestionId());
+                    campaignLogRepository.save(campaignLog);
+
+                    //delete answer by questionId
+                    scenarioAnswerRepository.deleteScenarioAnswersByScenarioQuestionId(scenarioQuestionDTO.getScenarioQuestionId());
+                    campaignLog = new CampaignLog();
+                    campaignLog.setCompanySiteId(scenarioQuestionDTO.getCompanySiteId());
+                    campaignLog.setCreateTime(new Date());
+                    campaignLog.setTableName("SCENARIO_ANSWER");
+                    campaignLog.setDescription("Xoa cau tra loi");
+                    campaignLog.setCampaignId(scenarioQuestionDTO.getCampaignId());
+                    campaignLog.setCustomerId(scenarioQuestionDTO.getScenarioQuestionId());
+                    campaignLogRepository.save(campaignLog);
+                } else {
+                    //get and update status question
+                    ScenarioQuestion scenarioQuestion = scenarioQuestionRepository.findScenarioQuestionByScenarioQuestionId(scenarioQuestionDTO.getScenarioQuestionId());
+                    scenarioQuestion.setStatus((short) 0);
+                    scenarioQuestion.setDeleteTime(new Date());
+                    scenarioQuestionRepository.save(scenarioQuestion);
+
+                    campaignLog = new CampaignLog();
+                    campaignLog.setCompanySiteId(scenarioQuestionDTO.getCompanySiteId());
+                    campaignLog.setCreateTime(new Date());
+                    campaignLog.setTableName("SCENARIO_QUESTION");
+                    campaignLog.setDescription("Chinh sua cau hoi");
+                    campaignLog.setCampaignId(scenarioQuestionDTO.getCampaignId());
+                    campaignLog.setCustomerId(scenarioQuestionDTO.getScenarioQuestionId());
+                    campaignLogRepository.save(campaignLog);
+
+                    List<ScenarioAnswer> lstAnswer = scenarioAnswerRepository.findByScenarioQuestionIdAndCompanySiteIdAndStatus(scenarioQuestion.getScenarioQuestionId(),
+                            scenarioQuestion.getCompanySiteId(), (short) 1);
+                    if(lstAnswer.size() > 0) {
+                        lstAnswer.forEach(answer -> {
+                            answer.setStatus((short) 0);
+                            answer.setDeleteTime(new Date());
+
+                            CampaignLog log = new CampaignLog();
+                            log.setCompanySiteId(scenarioQuestionDTO.getCompanySiteId());
+                            log.setCreateTime(new Date());
+                            log.setTableName("SCENARIO_ANSWER");
+                            log.setDescription("Chinh sua cau tra loi");
+                            log.setCampaignId(scenarioQuestionDTO.getCampaignId());
+                            log.setCustomerId(answer.getScenarioAnswerId());
+                            campaignLogRepository.save(log);
+                        });
+                    }
+                }
+                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/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/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