commit

src/main/java/com/viettel/campaign/mapper/CampaignAgentsMapper.java

+package com.viettel.campaign.mapper;
+
+import com.viettel.campaign.model.ccms_full.CampaignAgent;
+import com.viettel.campaign.web.dto.CampaignAgentsDTO;
+
+public class CampaignAgentsMapper extends BaseMapper<CampaignAgent, CampaignAgentsDTO> {
+    @Override
+    public CampaignAgentsDTO toDtoBean(CampaignAgent campaignAgent) {
+        CampaignAgentsDTO obj = new CampaignAgentsDTO();
+        obj.setAgentId(campaignAgent.getAgentId());
+        obj.setCampaignAgentId(campaignAgent.getCampaignAgentId());
+        obj.setCampaignId(campaignAgent.getCampaignId());
+        obj.setCompanySiteId(campaignAgent.getCompanySiteId());
+        obj.setFilterType(campaignAgent.getFilterType());
+        obj.setReSchedule(campaignAgent.getReSchedule());
+        obj.setStatus(campaignAgent.getStatus());
+        return obj;
+    }
+
+    @Override
+    public CampaignAgent toPersistenceBean(CampaignAgentsDTO dtoBean) {
+        CampaignAgent obj = new CampaignAgent();
+        obj.setAgentId(dtoBean.getAgentId());
+        obj.setCampaignAgentId(dtoBean.getCampaignAgentId());
+        obj.setCampaignId(dtoBean.getCampaignId());
+        obj.setCompanySiteId(dtoBean.getCompanySiteId());
+        obj.setFilterType(dtoBean.getFilterType());
+        obj.setReSchedule(dtoBean.getReSchedule());
+        obj.setStatus(dtoBean.getStatus());
+        return obj;
+    }
+}

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

+package com.viettel.campaign.repository.ccms_full;
+
+import com.viettel.campaign.model.ccms_full.CampaignAgent;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface CampaignAgentsRepository extends JpaRepository<CampaignAgent, Long> {
+}

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

 package com.viettel.campaign.service;
 
+import com.viettel.campaign.web.dto.CampaignAgentsDTO;
 import com.viettel.campaign.web.dto.ResultDTO;
 
 public interface AgentsService {
     ResultDTO getAgentsByAgentId(String agentId);
 
     ResultDTO getAllAgentsByCompanySiteId(int page, int pageSize, Long companySiteId);
+
+    ResultDTO getAllAgentsSelectedByCompanySiteId(int page, int pageSize, Long companySiteId, Long campaignId);
+
+    ResultDTO createCampaignAgents(CampaignAgentsDTO campaignAgentsDTO);
 }

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

 package com.viettel.campaign.service.impl;
 
+import com.viettel.campaign.mapper.CampaignAgentsMapper;
 import com.viettel.campaign.model.acd_full.Agents;
+import com.viettel.campaign.model.ccms_full.CampaignAgent;
 import com.viettel.campaign.repository.acd_full.AgentsRepository;
+import com.viettel.campaign.repository.ccms_full.CampaignAgentsRepository;
 import com.viettel.campaign.service.AgentsService;
 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.web.dto.CampaignAgentsDTO;
 import com.viettel.campaign.web.dto.ResultDTO;
 import com.viettel.campaign.web.dto.VSAUsersDTO;
 import org.hibernate.SQLQuery;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
 import org.hibernate.transform.Transformers;
-import org.hibernate.type.DateType;
-import org.hibernate.type.LongType;
-import org.hibernate.type.ShortType;
-import org.hibernate.type.StringType;
+import org.hibernate.type.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.*;
 import org.springframework.stereotype.Service;
@@ -29,6 +30,9 @@ public class AgentsServiceImpl implements AgentsService {
     @Autowired
     AgentsRepository agentsRepository;
 
+    @Autowired
+    CampaignAgentsRepository campaignAgentsRepository;
+
     @Override
     public ResultDTO getAgentsByAgentId(String agentId) {
         ResultDTO result = new ResultDTO();
@@ -130,4 +134,112 @@ public class AgentsServiceImpl implements AgentsService {
 
         return resultDTO;
     }
+
+    @Override
+    public ResultDTO getAllAgentsSelectedByCompanySiteId(int page, int pageSize, Long companySiteId, Long campaignId) {
+        ResultDTO resultDTO = new ResultDTO();
+        SessionFactory sessionFactory = HibernateUtil.getSessionFactory();
+
+        Session session = sessionFactory.openSession();
+        session.beginTransaction();
+
+        if (DataUtil.isNullOrZero(companySiteId)) {
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+            return resultDTO;
+        }
+
+        try {
+            StringBuilder sqlStrBuilder = new StringBuilder();
+            sqlStrBuilder.append(SQLBuilder.getSqlQueryById(SQLBuilder.SQL_MODULE_CAMPAIGN_MNG, "campaign-agents-by-params"));
+
+            sqlStrBuilder.append(" RIGHT JOIN CAMPAIGN_AGENT b on a.USER_ID = b.AGENT_ID");
+            sqlStrBuilder.append(" WHERE 1 = 1");
+            sqlStrBuilder.append(" AND b.COMPANY_SITE_ID = :p_company_site_id");
+            sqlStrBuilder.append(" AND b.CAMPAIGN_ID = :p_campaign_id");
+            sqlStrBuilder.append(" ORDER BY a.FULL_NAME ASC");
+
+            SQLQuery query = session.createSQLQuery(sqlStrBuilder.toString());
+
+            query.setParameter("p_company_site_id", companySiteId);
+            query.setParameter("p_campaign_id", campaignId);
+
+            query.addScalar("userId", new LongType());
+            query.addScalar("userName", new StringType());
+            query.addScalar("status", new ShortType());
+            query.addScalar("fullName", new StringType());
+            query.addScalar("userTypeId", new LongType());
+            query.addScalar("createDate", new DateType());
+            query.addScalar("description", new StringType());
+            query.addScalar("staffCode", new StringType());
+            query.addScalar("managerId", new LongType());
+            query.addScalar("locationId", new LongType());
+            query.addScalar("deptId", new LongType());
+            query.addScalar("deptLevel", new StringType());
+            query.addScalar("posId", new LongType());
+            query.addScalar("deptName", new StringType());
+            query.addScalar("groupId", new LongType());
+            query.addScalar("siteId", new LongType());
+            query.addScalar("companySiteId", new LongType());
+            query.addScalar("agentType", new ShortType());
+            query.addScalar("mobileNumber", new StringType());
+            query.addScalar("facebookId", new StringType());
+            query.addScalar("loginType", new ShortType());
+            query.addScalar("googleId", new StringType());
+            query.addScalar("email", new StringType());
+            query.addScalar("availableTicket", new LongType());
+            query.addScalar("userKazooId", new StringType());
+            query.addScalar("filterType", new ShortType());
+
+            query.setResultTransformer(Transformers.aliasToBean(VSAUsersDTO.class));
+            int count = 0;
+            List<VSAUsersDTO> dtoList = query.list();
+            if (dtoList.size() > 0) {
+                count = query.list().size();
+            }
+
+            Pageable pageable = PageRequest.of(page, pageSize);
+            if (pageable != null) {
+                query.setFirstResult(pageable.getPageNumber() * pageable.getPageSize());
+                query.setMaxResults(pageable.getPageSize());
+            }
+
+            List<VSAUsersDTO> data = query.list();
+            Page<VSAUsersDTO> dataPage = new PageImpl<>(data, pageable, count);
+            resultDTO.setData(dataPage);
+            resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+            resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+        } catch (Exception e) {
+            resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+            resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+        } finally {
+            session.close();
+        }
+
+        return resultDTO;
+    }
+
+    @Override
+    public ResultDTO createCampaignAgents(CampaignAgentsDTO campaignAgentsDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignAgentsMapper campaignAgentsMapper = new CampaignAgentsMapper();
+        CampaignAgent campaignAgent = new CampaignAgent();
+        try {
+            if (campaignAgentsDTO != null) {
+                // insert
+                campaignAgent = campaignAgentsMapper.toPersistenceBean(campaignAgentsDTO);
+                campaignAgentsRepository.save(campaignAgent);
+
+                resultDTO.setErrorCode(Constants.ApiErrorCode.SUCCESS);
+                resultDTO.setDescription(Constants.ApiErrorDesc.SUCCESS);
+            } else {
+                resultDTO.setErrorCode(Constants.ApiErrorCode.ERROR);
+                resultDTO.setDescription(Constants.ApiErrorDesc.ERROR);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return resultDTO;
+    }
 }

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

+package com.viettel.campaign.web.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class CampaignAgentsDTO extends BaseDTO {
+    Long campaignAgentId;
+    Long campaignId;
+    Long agentId;
+    Short filterType;
+    Integer status;
+    Long companySiteId;
+    Long reSchedule;
+}

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

 package com.viettel.campaign.web.rest;
 
 import com.viettel.campaign.service.AgentsService;
+import com.viettel.campaign.web.dto.CampaignAgentsDTO;
 import com.viettel.campaign.web.dto.ResultDTO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -9,6 +10,8 @@ import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import javax.validation.Valid;
+
 @RestController
 @RequestMapping("/ipcc/agents")
 @CrossOrigin
@@ -32,4 +35,19 @@ public class AgentsController {
         ResultDTO result = agentsService.getAllAgentsByCompanySiteId(page, pageSize, companySiteId);
         return new ResponseEntity<>(result, HttpStatus.OK);
     }
+
+    @GetMapping("/findAllSelected")
+    @ResponseBody
+    public ResponseEntity<ResultDTO> listAgentsSelectedByCompanySiteId(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("companySiteId") Long companySiteId, @RequestParam("campaignId") Long campaignId) {
+        ResultDTO result = agentsService.getAllAgentsSelectedByCompanySiteId(page, pageSize, companySiteId, campaignId);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @PostMapping("/createCampaignAgents")
+    @ResponseBody
+    public ResultDTO createCustomerList(@RequestBody @Valid CampaignAgentsDTO campaignAgentsDTO) {
+        ResultDTO result = new ResultDTO();
+        result = agentsService.createCampaignAgents(campaignAgentsDTO);
+        return result;
+    }
 }

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

 package com.viettel.campaign.web.rest;
 
-import com.viettel.campaign.web.dto.CustomerContactDTO;
-import com.viettel.campaign.web.dto.CustomerDTO;
-import com.viettel.campaign.web.dto.CustomerListDTO;
-import com.viettel.campaign.web.dto.ResultDTO;
+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;