Merge branch 'tubn'

# Conflicts:
#	.idea/workspace.xml
#	service-campaign.iml
#	src/main/java/com/viettel/campaign/repository/ApParamRepository.java
#	src/main/java/com/viettel/campaign/service/ApParamService.java
#	src/main/java/com/viettel/campaign/web/controller/KafkaController.java
#	src/main/resources/application.yml

.gitignore

+target/
+/.idea/
+logs/
\ No newline at end of file

.idea/compiler.xml

@@ -14,4 +14,9 @@
       <module name="service-campaign" target="1.8" />
     </bytecodeTargetLevel>
   </component>
+  <component name="JavacSettings">
+    <option name="ADDITIONAL_OPTIONS_OVERRIDE">
+      <module name="service-campaign" options="-parameters" />
+    </option>
+  </component>
 </project>
\ No newline at end of file

.idea/libraries/Maven__log4j_log4j_1_2_16.xml

-<component name="libraryTable">
-  <library name="Maven: log4j:log4j:1.2.16">
-    <CLASSES>
-      <root url="jar://$MAVEN_REPOSITORY$/log4j/log4j/1.2.16/log4j-1.2.16.jar!/" />
-    </CLASSES>
-    <JAVADOC>
-      <root url="jar://$MAVEN_REPOSITORY$/log4j/log4j/1.2.16/log4j-1.2.16-javadoc.jar!/" />
-    </JAVADOC>
-    <SOURCES>
-      <root url="jar://$MAVEN_REPOSITORY$/log4j/log4j/1.2.16/log4j-1.2.16-sources.jar!/" />
-    </SOURCES>
-  </library>
-</component>
\ No newline at end of file

pom.xml

@@ -152,6 +152,11 @@
             <artifactId>spring-security-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>log4j</groupId>
+            <artifactId>log4j</artifactId>
+            <version>1.2.17</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>

src/main/java/com/viettel/campaign/controller/ApParamController.java

+package com.viettel.campaign.controller;
+
+import com.viettel.campaign.model.ApParam;
+import com.viettel.campaign.service.ApParamService;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@Controller
+@RequestMapping("/ipcc/apParam")
+public class ApParamController {
+
+    private static final Logger LOGGER = Logger.getLogger(CustomerController.class);
+
+    @Autowired(required = true)
+    ApParamService apParamService;
+
+    @GetMapping(path = "/findAlls")
+    @ResponseBody
+    public ResponseEntity listAllCustomer(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort) {
+        Iterable<ApParam> listCustomer = apParamService.getAllParams(page, pageSize, sort);
+        if (listCustomer == null) {
+            return new ResponseEntity(HttpStatus.NO_CONTENT);
+        }
+        return new ResponseEntity(listCustomer.iterator(), HttpStatus.OK);
+    }
+
+    @PostMapping(path = "/findByName")
+    @ResponseBody
+    public ResponseEntity searchParamByName(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort, @RequestParam(name = "parName") String parName) {
+        List<ApParam> lst = apParamService.getParamByName(page, pageSize, sort, parName);
+        if (lst.isEmpty())
+            return new ResponseEntity<>(HttpStatus.NO_CONTENT);
+
+        return new ResponseEntity(lst, HttpStatus.OK);
+    }
+}

src/main/java/com/viettel/campaign/controller/CampaignCompleteCodeController.java

+package com.viettel.campaign.controller;
+
+import com.viettel.campaign.dto.CampaignCompleteCodeDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.service.CampaignCompleteCodeService;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+@Controller
+@RequestMapping("/ipcc/completeCode")
+public class CampaignCompleteCodeController {
+
+    private static final Logger LOGGER = Logger.getLogger(CustomerController.class);
+
+    @Autowired
+    CampaignCompleteCodeService completeCodeService;
+
+    @GetMapping("/findAll")
+    @ResponseBody
+    public ResponseEntity findAllCompleteCode(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort) {
+        Map result = completeCodeService.listAllCompleteCode(page, pageSize, sort);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @GetMapping("/findCompleteCodeByName")
+    @ResponseBody
+    public ResponseEntity findAllCompleteCodeName(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort, @RequestParam("name") String name) {
+        Map result = completeCodeService.listCompleteCodeByName(page, pageSize, sort, name);
+        return new ResponseEntity(result, HttpStatus.OK);
+    }
+
+    @PostMapping("/create")
+    @ResponseBody
+    public ResultDTO createCompleteCode(@RequestBody @Valid CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO result = new ResultDTO();
+        //LogUtil logUtil = new LogUtil();
+        //logUtil.initKpiLog("createCust")
+        try {
+            //LOGGER.info("Returning createCustomer: start");
+            result = completeCodeService.createCompleteCode(completeCodeDTO);
+            //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);
+        }
+        return result;
+    }
+
+    @PostMapping("/update")
+    @ResponseBody
+    public ResultDTO updateCompleteCode(@RequestBody @Valid CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO result = new ResultDTO();
+        //LogUtil logUtil = new LogUtil();
+        //logUtil.initKpiLog("createCust");
+        try {
+            //LOGGER.info("Returning createCustomer: start");
+            result = completeCodeService.updateCompleteCode(completeCodeDTO);
+            //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);
+        }
+        return result;
+    }
+
+    @PostMapping("/delete")
+    @ResponseBody
+    public ResultDTO deleteCompleteCode(@RequestBody @Valid CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO result = new ResultDTO();
+        result = completeCodeService.deleteCompleteCode(completeCodeDTO);
+        return result;
+    }
+}

src/main/java/com/viettel/campaign/controller/CustomerController.java

+package com.viettel.campaign.controller;
+
+import com.viettel.campaign.dto.CustomerDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.service.CustomerService;
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.Map;
+
+@Controller
+@RequestMapping("/ipcc/customer")
+public class CustomerController {
+
+    private static final Logger LOGGER = Logger.getLogger(CustomerController.class);
+
+    @Autowired(required=true)
+    CustomerService customerService;
+
+    @GetMapping("/findAll")
+    @ResponseBody
+    public ResponseEntity findAllCustomer(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort) {
+        Map result = customerService.listAllCustomer(page, pageSize, sort);
+        return new ResponseEntity<>(result, HttpStatus.OK);
+    }
+
+    @GetMapping("/findCustomerByName")
+    @ResponseBody
+    public ResponseEntity findAllCustomerName(@RequestParam("page") int page, @RequestParam("pageSize") int pageSize, @RequestParam("sort") String sort, @RequestParam("name") String name) {
+        Map result = customerService.listCustByName(page, pageSize, sort, name);
+        return new ResponseEntity(result, HttpStatus.OK);
+    }
+
+    @PostMapping(value = "/create")
+    @ResponseBody
+    public ResultDTO createCust(@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);
+        }
+        return result;
+    }
+}

src/main/java/com/viettel/campaign/dto/ApParamDTO.java

+package com.viettel.campaign.dto;
+
+public class ApParamDTO extends BaseDTO {
+
+    private Long apParamId;
+    private String parType;
+    private String parName;
+    private String parValue;
+    private String parCode;
+    private Long description;
+    private  Long isDelete;
+    private  Long isDefault;
+    private  Long enableEdit;
+    private  Long siteId;
+
+    public Long getApParamId() {
+        return apParamId;
+    }
+
+    public void setApParamId(Long apParamId) {
+        this.apParamId = apParamId;
+    }
+
+    public String getParType() {
+        return parType;
+    }
+
+    public void setParType(String parType) {
+        this.parType = parType;
+    }
+
+    public String getParName() {
+        return parName;
+    }
+
+    public void setParName(String parName) {
+        this.parName = parName;
+    }
+
+    public String getParValue() {
+        return parValue;
+    }
+
+    public void setParValue(String parValue) {
+        this.parValue = parValue;
+    }
+
+    public String getParCode() {
+        return parCode;
+    }
+
+    public void setParCode(String parCode) {
+        this.parCode = parCode;
+    }
+
+    public Long getDescription() {
+        return description;
+    }
+
+    public void setDescription(Long description) {
+        this.description = description;
+    }
+
+    public Long getIsDelete() {
+        return isDelete;
+    }
+
+    public void setIsDelete(Long isDelete) {
+        this.isDelete = isDelete;
+    }
+
+    public Long getIsDefault() {
+        return isDefault;
+    }
+
+    public void setIsDefault(Long isDefault) {
+        this.isDefault = isDefault;
+    }
+
+    public Long getEnableEdit() {
+        return enableEdit;
+    }
+
+    public void setEnableEdit(Long enableEdit) {
+        this.enableEdit = enableEdit;
+    }
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+}

src/main/java/com/viettel/campaign/dto/BaseDTO.java

+package com.viettel.campaign.dto;
+
+import java.io.Serializable;
+
+public class BaseDTO implements Serializable {
+
+    protected String keySet;
+
+    public  String getKeySet(){
+        return keySet;
+    }
+
+    public void setKeySet(String keySet) {
+        this.keySet = keySet;
+    }
+}

src/main/java/com/viettel/campaign/dto/CampaignCompleteCodeDTO.java

+package com.viettel.campaign.dto;
+
+import java.util.Date;
+
+public class CampaignCompleteCodeDTO extends BaseDTO {
+    private Long campaignCompleteCodeId;
+    private Long campaignId;
+    private String completeValue;
+    private String completeName;
+    private String description;
+    private Short status;
+    private Short completeType;
+    private Short isRecall;
+    private String updateBy;
+    private Date updateAt;
+    private String createBy;
+    private Date createAt;
+    private String campaignType;
+    private Short isFinish;
+    private Long companySiteId;
+    private Short isLock;
+    private Long durationLock;
+
+    public Long getCampaignCompleteCodeId() {
+        return campaignCompleteCodeId;
+    }
+
+    public void setCampaignCompleteCodeId(Long campaignCompleteCodeId) {
+        this.campaignCompleteCodeId = campaignCompleteCodeId;
+    }
+
+    public Long getCampaignId() {
+        return campaignId;
+    }
+
+    public void setCampaignId(Long campaignId) {
+        this.campaignId = campaignId;
+    }
+
+    public String getCompleteValue() {
+        return completeValue;
+    }
+
+    public void setCompleteValue(String completeValue) {
+        this.completeValue = completeValue;
+    }
+
+    public String getCompleteName() {
+        return completeName;
+    }
+
+    public void setCompleteName(String completeName) {
+        this.completeName = completeName;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public Short getStatus() {
+        return status;
+    }
+
+    public void setStatus(Short status) {
+        this.status = status;
+    }
+
+    public Short getCompleteType() {
+        return completeType;
+    }
+
+    public void setCompleteType(Short completeType) {
+        this.completeType = completeType;
+    }
+
+    public Short getIsRecall() {
+        return isRecall;
+    }
+
+    public void setIsRecall(Short isRecall) {
+        this.isRecall = isRecall;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(Date updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(Date createAt) {
+        this.createAt = createAt;
+    }
+
+    public String getCampaignType() {
+        return campaignType;
+    }
+
+    public void setCampaignType(String campaignType) {
+        this.campaignType = campaignType;
+    }
+
+    public Short getIsFinish() {
+        return isFinish;
+    }
+
+    public void setIsFinish(Short isFinish) {
+        this.isFinish = isFinish;
+    }
+
+    public Long getCompanySiteId() {
+        return companySiteId;
+    }
+
+    public void setCompanySiteId(Long companySiteId) {
+        this.companySiteId = companySiteId;
+    }
+
+    public Short getIsLock() {
+        return isLock;
+    }
+
+    public void setIsLock(Short isLock) {
+        this.isLock = isLock;
+    }
+
+    public Long getDurationLock() {
+        return durationLock;
+    }
+
+    public void setDurationLock(Long durationLock) {
+        this.durationLock = durationLock;
+    }
+}

src/main/java/com/viettel/campaign/dto/CustomerDTO.java

+package com.viettel.campaign.dto;
+
+import java.util.Date;
+
+public class CustomerDTO extends BaseDTO {
+
+    private Long customerId;
+    private String code;
+    private String name;
+    private String description;
+    private String companyName;
+    private String customerImg;
+    private Date createDate;
+    private Date updateDate;
+    private String status;
+    private String createBy;
+    private String updateBy;
+    private Long siteId;
+    private Short gender;
+    private String currentAddress;
+    private String placeOfBirth;
+    private Date dateOfBirth;
+    private String mobileNumber;
+    private String email;
+    private String userName;
+    private String areaCode;
+    private Long customerType;
+    private String callAllowed;
+    private Long emailAllowed;
+    private Long smsAllowed;
+    private String ipccStatus;
+
+    public Long getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(Long customerId) {
+        this.customerId = customerId;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public String getCompanyName() {
+        return companyName;
+    }
+
+    public void setCompanyName(String companyName) {
+        this.companyName = companyName;
+    }
+
+    public String getCustomerImg() {
+        return customerImg;
+    }
+
+    public void setCustomerImg(String customerImg) {
+        this.customerImg = customerImg;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+
+    public Short getGender() {
+        return gender;
+    }
+
+    public void setGender(Short gender) {
+        this.gender = gender;
+    }
+
+    public String getCurrentAddress() {
+        return currentAddress;
+    }
+
+    public void setCurrentAddress(String currentAddress) {
+        this.currentAddress = currentAddress;
+    }
+
+    public String getPlaceOfBirth() {
+        return placeOfBirth;
+    }
+
+    public void setPlaceOfBirth(String placeOfBirth) {
+        this.placeOfBirth = placeOfBirth;
+    }
+
+    public Date getDateOfBirth() {
+        return dateOfBirth;
+    }
+
+    public void setDateOfBirth(Date dateOfBirth) {
+        this.dateOfBirth = dateOfBirth;
+    }
+
+    public String getMobileNumber() {
+        return mobileNumber;
+    }
+
+    public void setMobileNumber(String mobileNumber) {
+        this.mobileNumber = mobileNumber;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
+    public String getAreaCode() {
+        return areaCode;
+    }
+
+    public void setAreaCode(String areaCode) {
+        this.areaCode = areaCode;
+    }
+
+    public Long getCustomerType() {
+        return customerType;
+    }
+
+    public void setCustomerType(Long customerType) {
+        this.customerType = customerType;
+    }
+
+    public String getCallAllowed() {
+        return callAllowed;
+    }
+
+    public void setCallAllowed(String callAllowed) {
+        this.callAllowed = callAllowed;
+    }
+
+    public Long getEmailAllowed() {
+        return emailAllowed;
+    }
+
+    public void setEmailAllowed(Long emailAllowed) {
+        this.emailAllowed = emailAllowed;
+    }
+
+    public Long getSmsAllowed() {
+        return smsAllowed;
+    }
+
+    public void setSmsAllowed(Long smsAllowed) {
+        this.smsAllowed = smsAllowed;
+    }
+
+    public String getIpccStatus() {
+        return ipccStatus;
+    }
+
+    public void setIpccStatus(String ipccStatus) {
+        this.ipccStatus = ipccStatus;
+    }
+}

src/main/java/com/viettel/campaign/dto/CustomerListDTO.java

+package com.viettel.campaign.dto;
+
+public class CustomerListDTO extends BaseDTO {
+
+    private String customerListId;
+    private String customerListPK;
+    private String customerSiteId;
+    private String customerListCode;
+    private String customerListName;
+    private String status;
+    private String createBy;
+    private String createAt;
+    private String updateBy;
+    private String updateAt;
+    private String source;
+    private String deptCreate;
+
+    public String getCustomerListId() {
+        return customerListId;
+    }
+
+    public void setCustomerListId(String customerListId) {
+        this.customerListId = customerListId;
+    }
+
+    public String getCustomerListPK() {
+        return customerListPK;
+    }
+
+    public void setCustomerListPK(String customerListPK) {
+        this.customerListPK = customerListPK;
+    }
+
+    public String getCustomerSiteId() {
+        return customerSiteId;
+    }
+
+    public void setCustomerSiteId(String customerSiteId) {
+        this.customerSiteId = customerSiteId;
+    }
+
+    public String getCustomerListCode() {
+        return customerListCode;
+    }
+
+    public void setCustomerListCode(String customerListCode) {
+        this.customerListCode = customerListCode;
+    }
+
+    public String getCustomerListName() {
+        return customerListName;
+    }
+
+    public void setCustomerListName(String customerListName) {
+        this.customerListName = customerListName;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public String getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(String createAt) {
+        this.createAt = createAt;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public String getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(String updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source;
+    }
+
+    public String getDeptCreate() {
+        return deptCreate;
+    }
+
+    public void setDeptCreate(String deptCreate) {
+        this.deptCreate = deptCreate;
+    }
+}

src/main/java/com/viettel/campaign/dto/ResultDTO.java

+package com.viettel.campaign.dto;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class ResultDTO {
+
+    private String errorCode;
+    private String description;
+    private List listData = new ArrayList();
+    private Object data;
+
+    public String getErrorCode() {
+        return errorCode;
+    }
+
+    public void setErrorCode(String errorCode) {
+        this.errorCode = errorCode;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public List getListData() {
+        return listData;
+    }
+
+    public void setListData(List listData) {
+        this.listData = listData;
+    }
+
+    public Object getData() {
+        return data;
+    }
+
+    public void setData(Object data) {
+        this.data = data;
+    }
+}

src/main/java/com/viettel/campaign/dto/TicketSiteDTO.java

+package com.viettel.campaign.dto;
+
+import java.util.Date;
+
+public class TicketSiteDTO extends BaseDTO {
+
+    private Long siteId;
+    private String siteCode;
+    private String siteName;
+    private Date createDate;
+    private String createBy;
+    private Date updateDate;
+    private String updateBy;
+    private Long status;
+    private Long parentId;
+    private String accountKazooId;
+    private Long servicePlanId;
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+
+    public String getSiteCode() {
+        return siteCode;
+    }
+
+    public void setSiteCode(String siteCode) {
+        this.siteCode = siteCode;
+    }
+
+    public String getSiteName() {
+        return siteName;
+    }
+
+    public void setSiteName(String siteName) {
+        this.siteName = siteName;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Long getStatus() {
+        return status;
+    }
+
+    public void setStatus(Long status) {
+        this.status = status;
+    }
+
+    public Long getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(Long parentId) {
+        this.parentId = parentId;
+    }
+
+    public String getAccountKazooId() {
+        return accountKazooId;
+    }
+
+    public void setAccountKazooId(String accountKazooId) {
+        this.accountKazooId = accountKazooId;
+    }
+
+    public Long getServicePlanId() {
+        return servicePlanId;
+    }
+
+    public void setServicePlanId(Long servicePlanId) {
+        this.servicePlanId = servicePlanId;
+    }
+}

src/main/java/com/viettel/campaign/filter/CorsFilter.java

+package com.viettel.campaign.filter;
+
+import org.apache.log4j.Logger;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.*;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+@Component
+public class CorsFilter implements Filter {
+
+    private Logger logger = Logger.getLogger(CorsFilter.class);
+
+    @Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+
+    }
+
+    @Override
+    public void doFilter(ServletRequest req, ServletResponse resp, FilterChain chain) throws IOException, ServletException {
+        HttpServletRequest request = (HttpServletRequest) req;
+        HttpServletResponse response = (HttpServletResponse) resp;
+
+        try {
+            chain.doFilter(req, resp);
+        } catch (Exception e) {
+            logger.error(e.getMessage(), e);
+            response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e.getMessage());
+        }
+    }
+
+    @Override
+    public void destroy() {
+
+    }
+}

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

+package com.viettel.campaign.mapper;
+
+import com.viettel.campaign.dto.ApParamDTO;
+import com.viettel.campaign.model.ApParam;
+
+public class ApParamMapper extends BaseMapper<ApParam, ApParamDTO> {
+
+    @Override
+    public ApParamDTO toDtoBean(ApParam apParam) {
+        ApParamDTO apParamDTO = new ApParamDTO();
+
+        if (apParam != null) {
+            apParamDTO.setApParamId(apParam.getApParamId());
+            apParamDTO.setParType(apParam.getParType());
+            apParamDTO.setParName(apParam.getParName());
+            apParamDTO.setParValue(apParam.getParValue());
+            apParamDTO.setParCode(apParam.getParCode());
+            apParamDTO.setDescription(apParam.getDescription());
+            apParamDTO.setIsDelete(apParam.getIsDelete());
+            apParamDTO.setIsDefault(apParam.getIsDefault());
+            apParamDTO.setEnableEdit(apParam.getEnableEdit());
+            apParamDTO.setSiteId(apParam.getSiteId());
+        }
+
+        return apParamDTO;
+    }
+
+    @Override
+    public ApParam toPersistenceBean(ApParamDTO dtoBean) {
+        ApParam apParam = new ApParam();
+
+        if (dtoBean != null) {
+            apParam.setApParamId(dtoBean.getApParamId());
+            apParam.setParType(dtoBean.getParType());
+            apParam.setParName(dtoBean.getParName());
+            apParam.setParValue(dtoBean.getParValue());
+            apParam.setParCode(dtoBean.getParCode());
+            apParam.setDescription(dtoBean.getDescription());
+            apParam.setIsDelete(dtoBean.getIsDelete());
+            apParam.setIsDefault(dtoBean.getIsDefault());
+            apParam.setEnableEdit(dtoBean.getEnableEdit());
+            apParam.setSiteId(dtoBean.getSiteId());
+        }
+
+        return apParam;
+    }
+}

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

+package com.viettel.campaign.mapper;
+
+import com.viettel.campaign.dto.BaseDTO;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public abstract class BaseMapper<Model extends Object, DTO extends BaseDTO> {
+
+    public abstract DTO toDtoBean(Model model);
+
+    public abstract Model toPersistenceBean(DTO dtoBean);
+
+    public List<DTO> toDtoBean(Iterable<Model> models) {
+        List<DTO> dtoBeans = new ArrayList<>();
+        if (models == null) return dtoBeans;
+        for (Model model : models) {
+            dtoBeans.add(toDtoBean(model));
+        }
+        return dtoBeans;
+    }
+
+    public List<DTO> toDtoBean(List<Model> models) {
+        List<DTO> dtoBeans = new ArrayList<>();
+
+        if (models == null) return dtoBeans;
+        for (Model model : models) {
+            dtoBeans.add(toDtoBean(model));
+        }
+        return dtoBeans;
+    }
+
+    public List<Model> toPersistenceBean(List<DTO> dtoBeans) {
+        List<Model> models = new ArrayList<>();
+        if (dtoBeans == null || dtoBeans.isEmpty()) return models;
+        for (DTO dtoBean : dtoBeans) {
+            models.add(toPersistenceBean(dtoBean));
+        }
+        return models;
+    }
+}

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

+package com.viettel.campaign.mapper;
+
+import com.viettel.campaign.dto.CampaignCompleteCodeDTO;
+import com.viettel.campaign.model.CampaignCompleteCode;
+
+public class CampaignCompleteCodeMapper extends BaseMapper<CampaignCompleteCode, CampaignCompleteCodeDTO> {
+
+    @Override
+    public CampaignCompleteCodeDTO toDtoBean(CampaignCompleteCode entity) {
+        CampaignCompleteCodeDTO dto = new CampaignCompleteCodeDTO();
+
+        if (entity != null) {
+            dto.setCampaignCompleteCodeId(entity.getCampaignCompleteCodeId());
+            dto.setCampaignId(entity.getCampaignId());
+            dto.setCompleteValue(entity.getCompleteValue());
+            dto.setCompleteName(entity.getCompleteName());
+            dto.setDescription(entity.getDescription());
+            dto.setStatus(entity.getStatus());
+            dto.setCompleteType(entity.getCompleteType());
+            dto.setIsRecall(entity.getIsRecall());
+            dto.setUpdateBy(entity.getUpdateBy());
+            dto.setUpdateAt(entity.getUpdateAt());
+            dto.setCreateBy(entity.getCreateBy());
+            dto.setCreateAt(entity.getCreateAt());
+            dto.setCampaignType(entity.getCampaignType());
+            dto.setIsFinish(entity.getIsFinish());
+            dto.setCompanySiteId(entity.getCompanySiteId());
+            dto.setIsLock(entity.getIsLock());
+            dto.setDurationLock(entity.getDurationLock());
+        }
+
+        return dto;
+    }
+
+    @Override
+    public CampaignCompleteCode toPersistenceBean(CampaignCompleteCodeDTO dtoBean) {
+        CampaignCompleteCode entity = new CampaignCompleteCode();
+
+        if (dtoBean != null) {
+            entity.setCampaignCompleteCodeId(dtoBean.getCampaignCompleteCodeId());
+            entity.setCampaignId(dtoBean.getCampaignId());
+            entity.setCompleteValue(dtoBean.getCompleteValue());
+            entity.setCompleteName(dtoBean.getCompleteName());
+            entity.setDescription(dtoBean.getDescription());
+            entity.setStatus(dtoBean.getStatus());
+            entity.setCompleteType(dtoBean.getCompleteType());
+            entity.setIsRecall(dtoBean.getIsRecall());
+            entity.setUpdateBy(dtoBean.getUpdateBy());
+            entity.setUpdateAt(dtoBean.getUpdateAt());
+            entity.setCreateBy(dtoBean.getCreateBy());
+            entity.setCreateAt(dtoBean.getCreateAt());
+            entity.setCampaignType(dtoBean.getCampaignType());
+            entity.setIsFinish(dtoBean.getIsFinish());
+            entity.setCompanySiteId(dtoBean.getCompanySiteId());
+            entity.setIsLock(dtoBean.getIsLock());
+            entity.setDurationLock(dtoBean.getDurationLock());
+        }
+
+        return entity;
+    }
+}

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

+package com.viettel.campaign.mapper;
+
+import com.viettel.campaign.dto.CustomerDTO;
+import com.viettel.campaign.model.Customer;
+
+public class CustomerMapper extends BaseMapper<Customer, CustomerDTO> {
+
+    @Override
+    public CustomerDTO toDtoBean(Customer model) {
+        CustomerDTO obj = new CustomerDTO();
+
+        if (model != null) {
+            obj = new CustomerDTO();
+            obj.setUserName(model.getUserName());
+            obj.setCompanyName(model.getCompanyName());
+            obj.setCurrentAddress(model.getCurrentAddress());
+            obj.setCustomerId(model.getCustomerId());
+            obj.setCustomerImg(model.getCustomerImg());
+            obj.setEmail(model.getEmail());
+            obj.setGender(model.getGender());
+            obj.setMobileNumber(model.getMobileNumber());
+            obj.setName(model.getName());
+            obj.setSiteId(model.getSiteId());
+            obj.setStatus(model.getStatus());
+//            String additionalInfo = "";
+//            if (model.getName() != null && !"".equals(model.getName())) {
+//                additionalInfo += model.getName();
+//            }
+//            if (model.getUserName() != null && !"".equals(model.getUserName())) {
+//                additionalInfo += "".equals(additionalInfo) ? model.getUserName() : " - " + model.getUserName();
+//            }
+//            if (model.getMobileNumber() != null && !"".equals(model.getMobileNumber())) {
+//                additionalInfo += "".equals(additionalInfo) ? model.getMobileNumber() : " - " + model.getMobileNumber();
+//            }
+//            if (model.getEmail() != null && !"".equals(model.getEmail())) {
+//                additionalInfo += "".equals(additionalInfo) ? model.getEmail() : " - " + model.getEmail();
+//            }
+//            obj.setAdditionalInfo(additionalInfo);
+            obj.setAreaCode(model.getAreaCode());
+            obj.setCustomerType(model.getCustomerType());
+            obj.setDescription(model.getDescription());
+        }
+
+        return obj;
+    }
+
+    @Override
+    public Customer toPersistenceBean(CustomerDTO dtoBean) {
+        Customer obj = new Customer();
+
+        if (dtoBean != null) {
+            obj = new Customer();
+            //obj.setCustomerId(dtoBean.getCustomerId() == null ? null : dtoBean.getCustomerId());
+            obj.setCode(dtoBean.getCode());
+            obj.setName(dtoBean.getName());
+            obj.setDescription(dtoBean.getDescription());
+            obj.setCompanyName(dtoBean.getCompanyName());
+            obj.setCustomerImg(dtoBean.getCustomerImg());
+            obj.setCreateDate(dtoBean.getCreateDate());
+            obj.setUpdateDate(dtoBean.getUpdateDate());
+            obj.setStatus(dtoBean.getStatus());
+            obj.setCreateBy(dtoBean.getCreateBy());
+            obj.setUpdateBy(dtoBean.getUpdateBy());
+            obj.setSiteId(dtoBean.getSiteId());
+            obj.setGender(dtoBean.getGender());
+            obj.setCurrentAddress(dtoBean.getCurrentAddress());
+            obj.setPlaceOfBirth(dtoBean.getPlaceOfBirth());
+            obj.setDateOfBirth(dtoBean.getDateOfBirth());
+            obj.setMobileNumber(dtoBean.getMobileNumber());
+            obj.setEmail(dtoBean.getEmail());
+            obj.setUserName(dtoBean.getUserName());
+            obj.setAreaCode(dtoBean.getAreaCode());
+            obj.setCustomerType(dtoBean.getCustomerType());
+            obj.setCallAllowed(dtoBean.getCallAllowed());
+            obj.setEmailAllowed(dtoBean.getEmailAllowed());
+            obj.setSmsAllowed(dtoBean.getSmsAllowed());
+            obj.setIpccStatus(dtoBean.getIpccStatus());
+        }
+
+        return obj;
+    }
+}

src/main/java/com/viettel/campaign/model/ApParam.java

+package com.viettel.campaign.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import javax.xml.bind.annotation.XmlRootElement;
+import java.io.Serializable;
+
+@Entity
+@Table(name = "AP_PARAM")
+public class ApParam implements Serializable {
+
+    @Id
+    @NotNull
+    @Column(name = "AP_PARAM_ID")
+    private Long apParamId;
+
+    @Column(name = "PAR_TYPE")
+    private String parType;
+
+    @Column(name = "PAR_NAME")
+    private String parName;
+
+    @Column(name = "PAR_VALUE")
+    private String parValue;
+
+    @Column(name = "PAR_CODE")
+    private String parCode;
+
+    @Column(name = "DESCRIPTION")
+    private Long description;
+
+    @Column(name = "IS_DELETE")
+    private  Long isDelete;
+
+    @Column(name = "IS_DEFAULT")
+    private  Long isDefault;
+
+    @Column(name = "ENABLE_EDIT")
+    private  Long enableEdit;
+
+    @Column(name = "COMPANY_SITE_ID")
+    private  Long siteId;
+
+    public Long getApParamId() {
+        return apParamId;
+    }
+
+    public void setApParamId(Long apParamId) {
+        this.apParamId = apParamId;
+    }
+
+    public String getParType() {
+        return parType;
+    }
+
+    public void setParType(String parType) {
+        this.parType = parType;
+    }
+
+    public String getParName() {
+        return parName;
+    }
+
+    public void setParName(String parName) {
+        this.parName = parName;
+    }
+
+    public String getParValue() {
+        return parValue;
+    }
+
+    public void setParValue(String parValue) {
+        this.parValue = parValue;
+    }
+
+    public String getParCode() {
+        return parCode;
+    }
+
+    public void setParCode(String parCode) {
+        this.parCode = parCode;
+    }
+
+    public Long getDescription() {
+        return description;
+    }
+
+    public void setDescription(Long description) {
+        this.description = description;
+    }
+
+    public Long getIsDelete() {
+        return isDelete;
+    }
+
+    public void setIsDelete(Long isDelete) {
+        this.isDelete = isDelete;
+    }
+
+    public Long getIsDefault() {
+        return isDefault;
+    }
+
+    public void setIsDefault(Long isDefault) {
+        this.isDefault = isDefault;
+    }
+
+    public Long getEnableEdit() {
+        return enableEdit;
+    }
+
+    public void setEnableEdit(Long enableEdit) {
+        this.enableEdit = enableEdit;
+    }
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+}

src/main/java/com/viettel/campaign/model/CampaignCompleteCode.java

+package com.viettel.campaign.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.Date;
+
+@Entity
+@Table(name = "CAMPAIGN_COMPLETE_CODE")
+public class CampaignCompleteCode implements Serializable {
+
+    @Id
+    @GeneratedValue(generator = "CAMPAIGN_COMPLETE_CODE_SEQ")
+    @SequenceGenerator(name = "CAMPAIGN_COMPLETE_CODE_SEQ", sequenceName = "CAMPAIGN_COMPLETE_CODE_SEQ", allocationSize = 1)
+    @Basic(optional = false)
+    @Column(name = "CAMPAIGN_COMPLETE_CODE_ID")
+    private Long campaignCompleteCodeId;
+    @Column(name = "CAMPAIGN_ID")
+    private Long campaignId;
+    @Column(name = "COMPLETE_VALUE")
+    private String completeValue;
+    @Column(name = "COMPLETE_NAME")
+    private String completeName;
+    @Column(name = "DESCRIPTION")
+    private String description;
+    @Column(name = "STATUS")
+    private Short status;
+    @Column(name = "COMPLETE_TYPE")
+    private Short completeType;
+    @Column(name = "IS_RECALL")
+    private Short isRecall;
+    @Column(name = "UPDATE_BY")
+    private String updateBy;
+    @Column(name = "UPDATE_AT")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date updateAt;
+    @Column(name = "CREATE_BY")
+    private String createBy;
+    @Column(name = "CREATE_AT")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date createAt;
+    @Column(name = "CAMPAIGN_TYPE")
+    private String campaignType;
+    @Column(name = "IS_FINISH")
+    private Short isFinish;
+    @Column(name = "COMPANY_SITE_ID")
+    private Long companySiteId;
+    @Column(name = "IS_LOCK")
+    private Short isLock;
+    @Column(name = "DURATION_LOCK")
+    private Long durationLock;
+
+    public Long getCampaignCompleteCodeId() {
+        return campaignCompleteCodeId;
+    }
+
+    public void setCampaignCompleteCodeId(Long campaignCompleteCodeId) {
+        this.campaignCompleteCodeId = campaignCompleteCodeId;
+    }
+
+    public Long getCampaignId() {
+        return campaignId;
+    }
+
+    public void setCampaignId(Long campaignId) {
+        this.campaignId = campaignId;
+    }
+
+    public String getCompleteValue() {
+        return completeValue;
+    }
+
+    public void setCompleteValue(String completeValue) {
+        this.completeValue = completeValue;
+    }
+
+    public String getCompleteName() {
+        return completeName;
+    }
+
+    public void setCompleteName(String completeName) {
+        this.completeName = completeName;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public Short getStatus() {
+        return status;
+    }
+
+    public void setStatus(Short status) {
+        this.status = status;
+    }
+
+    public Short getCompleteType() {
+        return completeType;
+    }
+
+    public void setCompleteType(Short completeType) {
+        this.completeType = completeType;
+    }
+
+    public Short getIsRecall() {
+        return isRecall;
+    }
+
+    public void setIsRecall(Short isRecall) {
+        this.isRecall = isRecall;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(Date updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(Date createAt) {
+        this.createAt = createAt;
+    }
+
+    public String getCampaignType() {
+        return campaignType;
+    }
+
+    public void setCampaignType(String campaignType) {
+        this.campaignType = campaignType;
+    }
+
+    public Short getIsFinish() {
+        return isFinish;
+    }
+
+    public void setIsFinish(Short isFinish) {
+        this.isFinish = isFinish;
+    }
+
+    public Long getCompanySiteId() {
+        return companySiteId;
+    }
+
+    public void setCompanySiteId(Long companySiteId) {
+        this.companySiteId = companySiteId;
+    }
+
+    public Short getIsLock() {
+        return isLock;
+    }
+
+    public void setIsLock(Short isLock) {
+        this.isLock = isLock;
+    }
+
+    public Long getDurationLock() {
+        return durationLock;
+    }
+
+    public void setDurationLock(Long durationLock) {
+        this.durationLock = durationLock;
+    }
+}

src/main/java/com/viettel/campaign/model/Customer.java

+package com.viettel.campaign.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+import java.util.Date;
+
+@Entity
+@Table(name = "CUSTOMER")
+public class Customer implements Serializable {
+
+    @Id
+    @GeneratedValue(generator = "customer_seq")
+    @SequenceGenerator(name = "customer_seq", sequenceName = "customer_seq", allocationSize = 1)
+    @Basic(optional = false)
+    @NotNull
+    @Column(name = "CUSTOMER_ID")
+    private Long customerId;
+    @Size(max = 1000)
+    @Column(name = "CODE")
+    private String code;
+    @Size(max = 1000)
+    @Column(name = "NAME")
+    private String name;
+    @Size(max = 2000)
+    @Column(name = "DESCRIPTION")
+    private String description;
+    @Size(max = 100)
+    @Column(name = "COMPANY_NAME")
+    private String companyName;
+    @Column(name = "CUSTOMER_IMG")
+    private String customerImg;
+    @Basic(optional = false)
+    @NotNull
+    @Column(name = "CREATE_DATE")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date createDate;
+    @Column(name = "UPDATE_DATE")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date updateDate;
+    @Column(name = "STATUS")
+    private String status;
+    @Size(max = 50)
+    @Column(name = "CREATE_BY")
+    private String createBy;
+    @Size(max = 50)
+    @Column(name = "UPDATE_BY")
+    private String updateBy;
+    @Column(name = "SITE_ID")
+    private Long siteId;
+    @Column(name = "GENDER")
+    private Short gender;
+    @Size(max = 500)
+    @Column(name = "CURRENT_ADDRESS")
+    private String currentAddress;
+    @Size(max = 500)
+    @Column(name = "PLACE_OF_BIRTH")
+    private String placeOfBirth;
+    @Column(name = "DATE_OF_BIRTH")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date dateOfBirth;
+    @Size(max = 20)
+    @Column(name = "MOBILE_NUMBER")
+    private String mobileNumber;
+    @Size(max = 500)
+    @Column(name = "EMAIL")
+    private String email;
+    @Size(max = 200)
+    @Column(name = "USERNAME")
+    private String userName;
+    @Size(max = 25)
+    @Column(name = "AREA_CODE")
+    private String areaCode;
+    @Column(name = "CUSTOMER_TYPE")
+    private Long customerType;
+    @Column(name = "CALL_ALLOWED")
+    private String callAllowed;
+    @Column(name = "EMAIL_ALLOWED")
+    private Long emailAllowed;
+    @Column(name = "SMS_ALLOWED")
+    private Long smsAllowed;
+    @Size(max = 100)
+    @Column(name = "IPCC_STATUS")
+    private String ipccStatus;
+
+    public Long getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(Long customerId) {
+        this.customerId = customerId;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public String getCompanyName() {
+        return companyName;
+    }
+
+    public void setCompanyName(String companyName) {
+        this.companyName = companyName;
+    }
+
+    public String getCustomerImg() {
+        return customerImg;
+    }
+
+    public void setCustomerImg(String customerImg) {
+        this.customerImg = customerImg;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+
+    public Short getGender() {
+        return gender;
+    }
+
+    public void setGender(Short gender) {
+        this.gender = gender;
+    }
+
+    public String getCurrentAddress() {
+        return currentAddress;
+    }
+
+    public void setCurrentAddress(String currentAddress) {
+        this.currentAddress = currentAddress;
+    }
+
+    public String getPlaceOfBirth() {
+        return placeOfBirth;
+    }
+
+    public void setPlaceOfBirth(String placeOfBirth) {
+        this.placeOfBirth = placeOfBirth;
+    }
+
+    public Date getDateOfBirth() {
+        return dateOfBirth;
+    }
+
+    public void setDateOfBirth(Date dateOfBirth) {
+        this.dateOfBirth = dateOfBirth;
+    }
+
+    public String getMobileNumber() {
+        return mobileNumber;
+    }
+
+    public void setMobileNumber(String mobileNumber) {
+        this.mobileNumber = mobileNumber;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
+    public String getAreaCode() {
+        return areaCode;
+    }
+
+    public void setAreaCode(String areaCode) {
+        this.areaCode = areaCode;
+    }
+
+    public Long getCustomerType() {
+        return customerType;
+    }
+
+    public void setCustomerType(Long customerType) {
+        this.customerType = customerType;
+    }
+
+    public String getCallAllowed() {
+        return callAllowed;
+    }
+
+    public void setCallAllowed(String callAllowed) {
+        this.callAllowed = callAllowed;
+    }
+
+    public Long getEmailAllowed() {
+        return emailAllowed;
+    }
+
+    public void setEmailAllowed(Long emailAllowed) {
+        this.emailAllowed = emailAllowed;
+    }
+
+    public Long getSmsAllowed() {
+        return smsAllowed;
+    }
+
+    public void setSmsAllowed(Long smsAllowed) {
+        this.smsAllowed = smsAllowed;
+    }
+
+    public String getIpccStatus() {
+        return ipccStatus;
+    }
+
+    public void setIpccStatus(String ipccStatus) {
+        this.ipccStatus = ipccStatus;
+    }
+}

src/main/java/com/viettel/campaign/model/CustomerList.java

+package com.viettel.campaign.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+import java.util.Date;
+
+@Entity
+@Table(name = "CUSTOMER_LIST")
+public class CustomerList implements Serializable {
+
+    @Id
+    @GeneratedValue(generator = "customer_list_seq")
+    @SequenceGenerator(name = "customer_list_seq", sequenceName = "customer_list_seq", allocationSize = 1)
+    @Basic(optional = false)
+    @NotNull
+    @Column(name = "CUSTOMER_LIST_ID")
+    private Long customerListId;
+    @Column(name = "COMPANY_SITE_ID")
+    private Long customerSiteId;
+    @Size(max = 200)
+    @Column(name = "CUSTOMER_LIST_CODE")
+    private String customerListCode;
+    @Size(max = 500)
+    @Column(name = "CUSTOMER_LIST_NAME")
+    private String customerListName;
+    @NotNull
+    @Column(name = "STATUS")
+    private Short status;
+    @Size(max = 200)
+    @Column(name = "CREATE_BY")
+    private String createBy;
+    @Column(name = "CREATE_AT")
+    private Date createAt;
+    @Size(max = 200)
+    @Column(name = "UPDATE_BY")
+    private String updateBy;
+    @Column(name = "UPDATE_AT")
+    private Date updateAt;
+    @Size(max = 100)
+    @Column(name = "SOURCE")
+    private String source;
+    @Size(max = 100)
+    @Column(name = "DEPT_CREATE")
+    private String deptCreate;
+
+    public Long getCustomerListId() {
+        return customerListId;
+    }
+
+    public void setCustomerListId(Long customerListId) {
+        this.customerListId = customerListId;
+    }
+
+    public Long getCustomerSiteId() {
+        return customerSiteId;
+    }
+
+    public void setCustomerSiteId(Long customerSiteId) {
+        this.customerSiteId = customerSiteId;
+    }
+
+    public String getCustomerListCode() {
+        return customerListCode;
+    }
+
+    public void setCustomerListCode(String customerListCode) {
+        this.customerListCode = customerListCode;
+    }
+
+    public String getCustomerListName() {
+        return customerListName;
+    }
+
+    public void setCustomerListName(String customerListName) {
+        this.customerListName = customerListName;
+    }
+
+    public Short getStatus() {
+        return status;
+    }
+
+    public void setStatus(Short status) {
+        this.status = status;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getCreateAt() {
+        return createAt;
+    }
+
+    public void setCreateAt(Date createAt) {
+        this.createAt = createAt;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getUpdateAt() {
+        return updateAt;
+    }
+
+    public void setUpdateAt(Date updateAt) {
+        this.updateAt = updateAt;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source;
+    }
+
+    public String getDeptCreate() {
+        return deptCreate;
+    }
+
+    public void setDeptCreate(String deptCreate) {
+        this.deptCreate = deptCreate;
+    }
+}

src/main/java/com/viettel/campaign/model/CustomerListMapping.java

+package com.viettel.campaign.model;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+
+@Entity
+@Table(name = "CUSTOMER_LIST_MAPPING")
+public class CustomerListMapping implements Serializable {
+
+    @Id
+    @Column(name = "CUSTOMER_LIST_MAPPING_ID")
+    private Long customerListMappingId;
+    @Column(name = "CUSTOMER_ID")
+    private Long customerId;
+    @Column(name = "COMPANY_SITE_ID")
+    private Long companySiteId;
+    @Column(name = "CUSTOMER_LIST_ID")
+    private Long customerListId;
+
+    public Long getCustomerListMappingId() {
+        return customerListMappingId;
+    }
+
+    public void setCustomerListMappingId(Long customerListMappingId) {
+        this.customerListMappingId = customerListMappingId;
+    }
+
+    public Long getCustomerId() {
+        return customerId;
+    }
+
+    public void setCustomerId(Long customerId) {
+        this.customerId = customerId;
+    }
+
+    public Long getCompanySiteId() {
+        return companySiteId;
+    }
+
+    public void setCompanySiteId(Long companySiteId) {
+        this.companySiteId = companySiteId;
+    }
+
+    public Long getCustomerListId() {
+        return customerListId;
+    }
+
+    public void setCustomerListId(Long customerListId) {
+        this.customerListId = customerListId;
+    }
+}

src/main/java/com/viettel/campaign/model/TicketSite.java

+package com.viettel.campaign.model;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+import java.util.Date;
+
+@Entity
+@Table(name = "TICKET_SITE")
+public class TicketSite implements Serializable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    @Basic(optional = false)
+    @NotNull
+    @Column(name = "SITE_ID")
+    private Long siteId;
+    @Size(max = 400)
+    @Column(name = "SITE_CODE")
+    private String siteCode;
+    @Size(max = 400)
+    @Column(name = "SITE_NAME")
+    private String siteName;
+    @Column(name = "CREATE_DATE")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date createDate;
+    @Size(max = 200)
+    @Column(name = "CREATE_BY")
+    private String createBy;
+    @Column(name = "UPDATE_DATE")
+    @Temporal(TemporalType.TIMESTAMP)
+    private Date updateDate;
+    @Size(max = 200)
+    @Column(name = "UPDATE_BY")
+    private String updateBy;
+    @Column(name = "STATUS")
+    private Long status;
+    @Column(name = "PARENT_ID")
+    private Long parentId;
+    @Size(max = 200)
+    @Column(name = "ACCOUNT_KAZOO_ID")
+    private String accountKazooId;
+    @Column(name = "SERVICE_PLAN_ID")
+    private Long servicePlanId;
+
+    public Long getSiteId() {
+        return siteId;
+    }
+
+    public void setSiteId(Long siteId) {
+        this.siteId = siteId;
+    }
+
+    public String getSiteCode() {
+        return siteCode;
+    }
+
+    public void setSiteCode(String siteCode) {
+        this.siteCode = siteCode;
+    }
+
+    public String getSiteName() {
+        return siteName;
+    }
+
+    public void setSiteName(String siteName) {
+        this.siteName = siteName;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Long getStatus() {
+        return status;
+    }
+
+    public void setStatus(Long status) {
+        this.status = status;
+    }
+
+    public Long getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(Long parentId) {
+        this.parentId = parentId;
+    }
+
+    public String getAccountKazooId() {
+        return accountKazooId;
+    }
+
+    public void setAccountKazooId(String accountKazooId) {
+        this.accountKazooId = accountKazooId;
+    }
+
+    public Long getServicePlanId() {
+        return servicePlanId;
+    }
+
+    public void setServicePlanId(Long servicePlanId) {
+        this.servicePlanId = servicePlanId;
+    }
+}

src/main/java/com/viettel/campaign/repository/ApParamRepository.java

 package com.viettel.campaign.repository;
 
-import com.viettel.campaign.domain.ApParam;
-import org.springframework.stereotype.Repository;
+import com.viettel.campaign.model.ApParam;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 import java.util.List;
 
-/**
- * @author hanv_itsol
- * @project campaign
- */
+public interface ApParamRepository extends JpaRepository<ApParam, Long>, ApParamRepositoryCustom {
 
-@Repository
-public interface ApParamRepository extends BaseRepository<ApParam> {
+    Page<ApParam> findAll(Pageable pageable);
 
-    List<ApParam> findAll();
+    @Query(value = "SELECT p FROM ApParam p WHERE parName LIKE concat('%', :parName, '%') ")
+    List<ApParam> findParamByName(@Param("parName") String parName, Pageable pageable);
 }

src/main/java/com/viettel/campaign/repository/ApParamRepositoryCustom.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.model.ApParam;
+
+import java.util.List;
+
+public interface ApParamRepositoryCustom {
+
+}

src/main/java/com/viettel/campaign/repository/AppParamRepositoryImpl.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.model.ApParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+import java.util.List;
+
+@Repository
+public class AppParamRepositoryImpl implements ApParamRepositoryCustom {
+
+    @Autowired
+    EntityManager entityManager;
+
+    public AppParamRepositoryImpl() {
+
+    }
+}

src/main/java/com/viettel/campaign/repository/CampaignCompleteCodeRepository.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.model.CampaignCompleteCode;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.List;
+
+public interface CampaignCompleteCodeRepository extends JpaRepository<CampaignCompleteCode, Long> {
+
+    Page<CampaignCompleteCode> findAll(Pageable pageable);
+
+    @Query("FROM CampaignCompleteCode WHERE completeName LIKE concat('%', :name, '%') ")
+    List<CampaignCompleteCode> findByName(@Param("name") String Name, Pageable pageable);
+
+    List<CampaignCompleteCode> findByCompleteNameContains(String Name, Pageable pageable);
+}

src/main/java/com/viettel/campaign/repository/CustomerRepository.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.model.Customer;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface CustomerRepository extends JpaRepository<Customer, Long> {
+
+    Page<Customer> findAll(Pageable pageable);
+
+    @Query("FROM Customer WHERE name = ?1")
+    List<Customer> findByName(String firstName, Pageable pageable);
+
+    @Query("SELECT COUNT(0) FROM Customer t WHERE t.mobileNumber = ?1 and t.siteId = ?2 and t.status = 1 ")
+    Long findByMobileNumberAndSiteId(String mobileNumber, Long siteId);
+}

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

 package com.viettel.campaign.service;
 
-import com.viettel.campaign.domain.ApParam;
-import com.viettel.campaign.repository.ApParamRepository;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
+import com.viettel.campaign.dto.ApParamDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.model.ApParam;
 
 import java.util.List;
 
-/**
- * @author hanv_itsol
- * @project campaign
- */
+public interface ApParamService {
 
-@Service
-public class ApParamService {
+    Iterable<ApParam> getAllParams(int page, int pageSize, String sort);
 
-    @Autowired
-    private ApParamRepository apParamRepository;
+    List<ApParam> getParamByName(int page, int pageSize, String sort, String parName);
 
-    public List<ApParam> findAll(){
-        return apParamRepository.findAll();
-    }
+    ResultDTO createApParam(ApParamDTO apParamDTO);
 }

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

+package com.viettel.campaign.service;
+
+import com.viettel.campaign.dto.ApParamDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.mapper.ApParamMapper;
+import com.viettel.campaign.model.ApParam;
+import com.viettel.campaign.repository.ApParamRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class ApParamServiceImpl implements ApParamService {
+
+    @Autowired
+    ApParamRepository apParamRepository;
+
+    @Override
+    public Iterable<ApParam> getAllParams(int page, int pageSize, String sort) {
+        return apParamRepository.findAll(PageRequest.of(page, pageSize, Sort.by(sort)));
+    }
+
+    @Override
+    public List<ApParam> getParamByName(int page, int pageSize, String sort, String parName) {
+        List<ApParam> lst = new ArrayList<>();
+
+        lst = apParamRepository.findParamByName(parName, PageRequest.of(page, pageSize, Sort.by(sort)));
+
+        return lst;
+    }
+
+    @Override
+    public ResultDTO createApParam(ApParamDTO apParamDTO) {
+        ResultDTO result = new ResultDTO();
+        ApParamMapper apParamMapper = new ApParamMapper();
+        ApParam apparam = new ApParam();
+
+        try {
+            if (apParamDTO != null) {
+                apparam = apParamRepository.save(apParamMapper.toPersistenceBean(apParamDTO));
+
+                result.setErrorCode("0");
+                result.setDescription("create apparam");
+                result.setData(apparam);
+            } else {
+                result.setErrorCode("-1");
+                result.setDescription("create apparam FAIL");
+                result.setData(apparam);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+}

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

+package com.viettel.campaign.service;
+
+import com.viettel.campaign.dto.CampaignCompleteCodeDTO;
+import com.viettel.campaign.dto.ResultDTO;
+
+import java.util.Map;
+
+public interface CampaignCompleteCodeService {
+
+    Map listAllCompleteCode(int page, int pageSize, String sort);
+
+    Map listCompleteCodeByName(int page, int pageSize, String sort, String name);
+
+    ResultDTO createCompleteCode(CampaignCompleteCodeDTO completeCodeDTO);
+
+    ResultDTO updateCompleteCode(CampaignCompleteCodeDTO completeCodeDTO);
+
+    ResultDTO deleteCompleteCode(CampaignCompleteCodeDTO completeCodeDTO);
+}

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

+package com.viettel.campaign.service;
+
+import com.viettel.campaign.dto.CampaignCompleteCodeDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.mapper.CampaignCompleteCodeMapper;
+import com.viettel.campaign.model.CampaignCompleteCode;
+import com.viettel.campaign.repository.CampaignCompleteCodeRepository;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+
+@Service
+public class CampaignCompleteCodeServiceImpl implements CampaignCompleteCodeService {
+
+    @Autowired
+    CampaignCompleteCodeRepository completeCodeRepository;
+
+    @Override
+    public Map listAllCompleteCode(int page, int pageSize, String sort) {
+        Map result = new HashMap();
+        Page<CampaignCompleteCode> pg = completeCodeRepository.findAll(PageRequest.of(page, pageSize, Sort.by(sort)));
+        result.put("totalItems", pg.getTotalElements());
+        result.put("data", pg.iterator());
+        return result;
+    }
+
+    @Override
+    public Map listCompleteCodeByName(int page, int pageSize, String sort, String name) {
+        Map result = new HashMap();
+        List<CampaignCompleteCode> lst = new ArrayList<>();
+
+        lst = completeCodeRepository.findByCompleteNameContains(name, PageRequest.of(page, pageSize, Sort.by(sort)));
+
+        result.put("totalItem", lst.size());
+        result.put("customers", lst);
+
+        return result;
+    }
+
+    @Override
+    public ResultDTO createCompleteCode(CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignCompleteCodeMapper compCodeMapper = new CampaignCompleteCodeMapper();
+        Date today = new Date();
+        CampaignCompleteCode compCode = new CampaignCompleteCode();
+
+        try {
+            if (completeCodeDTO != null) {
+                // insert
+                compCode = compCodeMapper.toPersistenceBean(completeCodeDTO);
+                compCode = completeCodeRepository.save(compCode);
+
+                resultDTO.setErrorCode("0");
+                resultDTO.setDescription("Complete Code: " + compCode.getCampaignCompleteCodeId() + " created!");
+            } else {
+                resultDTO.setErrorCode("-2");
+                resultDTO.setDescription("CompleteCodeDTO null");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return resultDTO;
+    }
+
+    @Override
+    public ResultDTO updateCompleteCode(CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignCompleteCodeMapper compCodeMapper = new CampaignCompleteCodeMapper();
+        Date today = new Date();
+        CampaignCompleteCode compCode = new CampaignCompleteCode();
+
+        try {
+            if (completeCodeDTO != null) {
+                // update
+                compCode = compCodeMapper.toPersistenceBean(completeCodeDTO);
+                compCode = completeCodeRepository.save(compCode);
+
+                resultDTO.setErrorCode("0");
+                resultDTO.setDescription("Complete Code: " + compCode.getCampaignCompleteCodeId() + " updated!");
+            } else {
+                resultDTO.setErrorCode("-2");
+                resultDTO.setDescription("CompleteCodeDTO null");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return resultDTO;
+    }
+
+    @Override
+    public ResultDTO deleteCompleteCode(CampaignCompleteCodeDTO completeCodeDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CampaignCompleteCodeMapper compCodeMapper = new CampaignCompleteCodeMapper();
+        Date today = new Date();
+        CampaignCompleteCode compCode = new CampaignCompleteCode();
+
+        try {
+            if (completeCodeDTO != null) {
+                // delete
+                completeCodeRepository.deleteById(completeCodeDTO.getCampaignCompleteCodeId());
+
+                resultDTO.setErrorCode("0");
+                resultDTO.setDescription("Complete Code: " + compCode.getCampaignCompleteCodeId() + " deleted!");
+            } else {
+                resultDTO.setErrorCode("-2");
+                resultDTO.setDescription("CompleteCodeDTO null");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return resultDTO;
+    }
+}

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

+package com.viettel.campaign.service;
+
+import com.viettel.campaign.dto.CustomerDTO;
+import com.viettel.campaign.dto.ResultDTO;
+
+import java.util.Map;
+
+public interface CustomerService {
+
+    Map listAllCustomer(int page, int pageSize, String sort);
+
+    Map listCustByName(int page, int pageSize, String sort, String name);
+
+    ResultDTO createCustomer(CustomerDTO customerDTO);
+}

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

+package com.viettel.campaign.service;
+
+import com.viettel.campaign.dto.CustomerDTO;
+import com.viettel.campaign.dto.ResultDTO;
+import com.viettel.campaign.mapper.CustomerMapper;
+import com.viettel.campaign.model.Customer;
+import com.viettel.campaign.repository.CustomerRepository;
+import com.viettel.campaign.utils.DataUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+import java.util.*;
+
+@Service
+public class CustomerServiceImpl implements CustomerService {
+
+    @Autowired
+    EntityManager entityManager;
+
+    @Autowired
+    CustomerRepository customerRepository;
+
+    @Override
+    public Map listAllCustomer(int page, int pageSize, String sort) {
+        Map result = new HashMap();
+        List<Customer> lst = new ArrayList<>();
+
+        Pageable pageable = PageRequest.of(page, pageSize, Sort.by(sort));
+        Page<Customer> pc = customerRepository.findAll(pageable);
+
+        result.put("totalItem", pc.getTotalElements());
+        result.put("customers", pc.iterator());
+
+        return result;
+    }
+
+    @Override
+    public Map listCustByName(int page, int pageSize, String sort, String name) {
+        Map result = new HashMap();
+        List<Customer> lst = new ArrayList<>();
+
+        Pageable pageable = PageRequest.of(page, pageSize, Sort.by(sort));
+        lst = customerRepository.findByName(name, pageable);
+
+        result.put("totalItem", lst.size());
+        result.put("customers", lst);
+
+        return result;
+    }
+
+    @Override
+    @Transactional
+    public ResultDTO createCustomer(CustomerDTO customerDTO) {
+        ResultDTO resultDTO = new ResultDTO();
+        CustomerMapper customerMapper = new CustomerMapper();
+        Date today = new Date();
+        Customer customer = new Customer();
+
+        try {
+            if (customerDTO != null) {
+                //check trung mobile number
+                Long cusExist = customerRepository.findByMobileNumberAndSiteId(customerDTO.getMobileNumber(), customerDTO.getSiteId());
+                if (cusExist > 0) {
+                    resultDTO.setErrorCode("-7");
+                    resultDTO.setDescription("Mobile number is existed");
+                    return resultDTO;
+                }
+
+                // insert
+                customer = customerMapper.toPersistenceBean(customerDTO);
+                customer.setCreateDate(new Date());
+                customer = customerRepository.save(customer);
+
+                resultDTO.setErrorCode(customer.getCustomerId() + "");
+                resultDTO.setDescription("customer created");
+            } else {
+                resultDTO.setErrorCode("-2");
+                resultDTO.setDescription("customerDTO null");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return resultDTO;
+    }
+
+    public Date getSysdate() {
+        try {
+            Query query = entityManager.createNativeQuery("SELECT to_char(sysdate, 'dd/MM/YYYY hh24:mi:ss') FROM DUAL ");
+            List list = query.getResultList();
+            if (list != null && list.size() > 0) {
+                return DataUtil.convertStringToDateDDMMYYYYHHMISS(DataUtil.safeToString(list.get(0)));
+            }
+        } catch (Exception e) {
+            //logger.info(e.getMessage(), e);
+            e.printStackTrace();
+        }
+        return new Date();
+    }
+}

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

+package com.viettel.campaign.utils;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.math.BigDecimal;
+import java.sql.Clob;
+import java.sql.SQLException;
+import java.text.Format;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+public class DataUtil {
+
+    private static final org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(DataUtil.class);
+
+    public static boolean isNullOrZero(Long value) {
+        return (value == null || value.equals(0L));
+    }
+
+    public static boolean isNullOrEmpty(String value) {
+        return (value == null || value.isEmpty());
+    }
+
+    public static boolean isNullOrZero(BigDecimal value) {
+        return (value == null || value.compareTo(BigDecimal.ZERO) == 0);
+    }
+
+    public static Long safeToLong(Object obj1, Long defaultValue) {
+        Long result = defaultValue;
+        if (obj1 != null) {
+            try {
+                result = Long.parseLong(obj1.toString());
+            } catch (Exception ex) {
+                logger.error(ex.getMessage(), ex);
+            }
+        }
+
+        return result;
+    }
+
+    public static Long safeToLong(Object obj1) {
+        Long result = null;
+        if (obj1 != null) {
+            try {
+                result = Long.parseLong(obj1.toString());
+            } catch (Exception ex) {
+                logger.error(ex.getMessage(), ex);
+            }
+        }
+
+        return result;
+    }
+
+    public static BigDecimal safeToBigDecimal(Object obj1) {
+        BigDecimal result = new BigDecimal(0);
+        if (obj1 != null) {
+            try {
+                result = BigDecimal.valueOf(Long.parseLong(obj1.toString()));
+            } catch (Exception ex) {
+                logger.error(ex.getMessage(), ex);
+            }
+        }
+
+        return result;
+    }
+
+    public static Double safeToDouble(Object obj1) {
+        Double result = null;
+        if (obj1 != null) {
+            try {
+                result = Double.parseDouble(obj1.toString());
+            } catch (Exception ex) {
+                logger.error(ex.getMessage(), ex);
+            }
+        }
+
+        return result;
+    }
+
+    public static Short safeToShort(Object obj1) {
+        Short result = 0;
+        if (obj1 != null) {
+            try {
+                result = Short.parseShort(obj1.toString());
+            } catch (Exception ex) {
+                logger.error(ex.getMessage(), ex);
+            }
+        }
+
+        return result;
+    }
+
+    public static int safeToInt(Object obj1) {
+        int result = 0;
+        if (obj1 == null) {
+            return 0;
+        }
+        try {
+            result = Integer.parseInt(obj1.toString());
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+        }
+
+        return result;
+    }
+
+    public static String safeToString(Object obj1) {
+        if (obj1 == null) {
+            return "";
+        }
+
+        return obj1.toString();
+    }
+
+    public static Date safeToDate(Object obj1) {
+        Date result = null;
+        if (obj1 == null) {
+            return null;
+        }
+        try {
+            result = (Date) obj1;
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+        }
+        return result;
+    }
+
+    public static boolean safeEqual(Long obj1, Long obj2) {
+        if (obj1 == obj2) {
+            return true;
+        }
+        return ((obj1 != null) && (obj2 != null) && (obj1.compareTo(obj2) == 0));
+    }
+
+    public static boolean safeEqual(String obj1, String obj2) {
+        if (obj1 == obj2) {
+            return true;
+        }
+        return ((obj1 != null) && (obj2 != null) && obj1.equals(obj2));
+    }
+
+    public static String convertDateToStringDDMMYYYYHHMISS(Date datetime) {
+        String s = null;
+        if (datetime != null) {
+            Format formatter = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss");
+            s = formatter.format(datetime);
+        }
+        return s;
+    }
+
+    public static Date convertStringToDateDDMMYYYYHHMISS(String str) {
+        Date dateTime = null;
+        try {
+            if (str != null) {
+                SimpleDateFormat formatter = new SimpleDateFormat("dd/MM/yyyy HH:mm:ss");
+                dateTime = formatter.parse(str);
+            }
+        } catch (Exception e) {
+            logger.error(e);
+        }
+        return dateTime;
+    }
+
+    public static String safeToClob(Clob clobValue) {
+        String result = null;
+        if (clobValue != null) {
+            StringBuilder sb = new StringBuilder();
+            try {
+                Reader reader = clobValue.getCharacterStream();
+                BufferedReader br = new BufferedReader(reader);
+                String line;
+                while (null != (line = br.readLine())) {
+                    sb.append(line);
+                }
+                br.close();
+            } catch (SQLException | IOException e) {
+                logger.error(e.getMessage(), e);
+            }
+            result = sb.toString();
+        }
+
+        return result;
+    }
+
+    public static Date toDatefromStringFormat(String value, String format) {
+        Date date = null;
+        try {
+            SimpleDateFormat sdf = new SimpleDateFormat(format);
+            date = sdf.parse(value);
+            if (!value.equals(sdf.format(date))) {
+                date = null;
+            }
+        } catch (Exception ex) {
+            logger.error(ex.getMessage(), ex);
+        }
+        return date;
+    }
+
+    public static boolean isNumber(String strId) {
+        return strId.matches("-?\\d+(\\.\\d+)?");
+    }
+
+    public static boolean isLong(String strId) {
+        return strId.matches("\\d*");
+    }
+
+    public static String standardPhone(String mobilePhone) {
+        if (mobilePhone != null) {
+            if (mobilePhone.startsWith("0")) {
+                mobilePhone = mobilePhone.substring(1, mobilePhone.length());
+            } else if (mobilePhone.startsWith("84")) {
+                mobilePhone = mobilePhone.substring(2, mobilePhone.length());
+            }
+        }
+        return mobilePhone;
+    }
+
+    public static String tohhmmss(Long conferenctime) {
+        String fmt = "0";
+        try {
+            if (conferenctime == 0) {
+                return "0";
+            }
+            // conferencetime: tinh theo s
+            long mmt = conferenctime / 60;
+            long ss = conferenctime % 60;
+            long mm = mmt % 60;
+            long hh = mmt / 60;
+            fmt = replace(hh) + ":" + replace(mm) + ":" + replace(ss);
+        } catch (Exception ex) {
+            logger.error(ex);
+        }
+        return fmt;
+    }
+
+    public static String replace(long m) {
+        String mt = String.valueOf(m);
+        mt = (m >= 10) ? mt : '0' + mt;
+        return mt;
+    }
+
+    public static String getSafeFileName(String input) {
+        StringBuilder sb = new StringBuilder();
+        for (int i = 0; i < input.length(); i++) {
+            char c = input.charAt(i);
+            if (c != '/' && c != '\\' && c != 0) {
+                sb.append(c);
+            }
+        }
+        return sb.toString();
+    }
+//    public static void main(String[] args) {
+////        Date rs = DataUtil.toDatefromStringFormat("20170702", "yyyyMMdd");
+////        System.out.println(rs);
+//        String rs = standardPhoneNew("000953478578358");
+//        System.out.println(rs);
+//    }
+
+    public static String standardPhoneNew(String input) {
+        if (input == null) {
+            return null;
+        }
+        while (input.startsWith("0")) {
+            input = input.substring(1, input.length());
+        }
+        return input;
+    }
+}

src/main/java/com/viettel/campaign/web/controller/KafkaController.java

@@ -6,6 +6,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import org.apache.log4j.Logger;
+
 /**
  * @author hanv_itsol
  * @project service-campaign
@@ -16,6 +18,7 @@ import org.springframework.web.bind.annotation.*;
 public class KafkaController {
 
     private final Sender sender;
+    private static final Logger log = Logger.getLogger(KafkaController.class);
 
     private final Producer producer;
 
@@ -27,13 +30,13 @@ public class KafkaController {
 
     @PostMapping(value = "/publish")
     public void sendMessageToKafkaTopic(@RequestParam("message") String message) {
-        log.info("message: #{}", message);
+        log.info("message: " + message);
         this.producer.sendMessage(message);
     }
 
     @PostMapping(value = "/publish2")
     public void sendMessageToKafkaTopic2(@RequestParam("message") String message) {
-        log.info("message: #{}", message);
+        log.info("message: " + message);
         this.producer.sendMessageTopic2(message);
     }
 

src/main/resources/application.yml

@@ -9,23 +9,21 @@ spring:
     username: CCMS_FULL
     password: CCMS_FULL#123
   jpa:
+    database-platform: org.hibernate.dialect.Oracle10gDialect
     show-sql: true
     generate-ddl: false
     hibernate:
-      ddl-auto: validate
-#  kafka:
-#    consumer:
-#      bootstrap-servers: 192.168.1.201:9092
-#      group-id: group_id
-#      auto-offset-reset: earliest
-#      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-#      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
-#    producer:
-#      bootstrap-servers: 192.168.1.201:9092
-#      key-serializer: org.apache.kafka.common.serialization.StringSerializer
-#      value-serializer: org.apache.kafka.common.serialization.StringSerializer
-logging:
-  config: classpath:logback.xml
-  level:
-    com.viettel.campaign: trace
-#  file: logs/campaign.log
\ No newline at end of file
+      ddl-auto: none
+      naming:
+        physical-strategy: org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl
+  kafka:
+    consumer:
+      bootstrap-servers: 192.168.1.201:9092
+      group-id: group_id
+      auto-offset-reset: earliest
+      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+    producer:
+      bootstrap-servers: 192.168.1.201:9092
+      key-serializer: org.apache.kafka.common.serialization.StringSerializer
+      value-serializer: org.apache.kafka.common.serialization.StringSerializer