write log from job

src/main/java/com/viettel/campaign/job/CampaignJob.java

 package com.viettel.campaign.job;
 
-import com.viettel.campaign.model.ccms_full.Campaign;
-import com.viettel.campaign.model.ccms_full.Customer;
-import com.viettel.campaign.model.ccms_full.CustomerTime;
-import com.viettel.campaign.model.ccms_full.ProcessConfig;
-import com.viettel.campaign.service.CampaignService;
-import com.viettel.campaign.service.CustomerService;
-import com.viettel.campaign.service.CustomerTimeService;
-import com.viettel.campaign.service.ProcessConfigService;
+import com.viettel.campaign.model.ccms_full.*;
+import com.viettel.campaign.service.*;
 import com.viettel.campaign.utils.DateTimeUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -42,6 +36,9 @@ public class CampaignJob {
     @Autowired
     private CustomerService customerService;
 
+    @Autowired
+    private UserActionLogService userActionLogService;
+
 //    @Scheduled(fixedRate = 5000)
 //    @Transactional( propagation = Propagation.REQUIRED)
     public void process() {
@@ -74,6 +71,8 @@ public class CampaignJob {
                             campaign.setStatus(2L);
                             campaign.setCampaignStart(new Date());
                             campaignService.updateProcess(campaign);
+                            //write log
+                            saveLog(campaign, 1);
                         });
 
                         log.info("Cap nhat thoi gian thuc hien tien trinh cho siteId ... #{}", p.getSiteId());
@@ -93,6 +92,8 @@ public class CampaignJob {
                             campaign.setStatus(4L);
                             campaign.setCampaignEnd(new Date());
                             campaignService.updateProcess(campaign);
+                            //write log
+                            saveLog(campaign, 2);
                         });
 
                         log.info("Cap nhat thoi gian thuc hien tien trinh cho siteId ... #{}", p.getSiteId());
@@ -129,5 +130,16 @@ public class CampaignJob {
         });
     }
 
+    private void saveLog(Campaign c, int t){
+        UserActionLog log = new UserActionLog();
+        log.setAgentId(1L);
+        log.setSessionId("-1");
+        log.setStartTime(new Date());
+        log.setActionType(t == 1 ? 13L : 14L);
+        log.setObjectId(c.getCampaignId());
+        log.setCompanySiteId(c.getCompanySiteId());
+        userActionLogService.save(log);
+    }
+
 
 }

src/main/java/com/viettel/campaign/model/ccms_full/UserActionLog.java

+package com.viettel.campaign.model.ccms_full;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author hanv_itsol
+ * @project campaign
+ */
+
+@Entity
+@Table(name = "USER_ACTION_LOG")
+@Data
+public class UserActionLog implements Serializable {
+
+    @Id
+    @NotNull
+    @Column(name = "AGENT_ID")
+    private Long agentId;
+
+    @Column(name = "COMPANY_SITE_ID")
+    private Long companySiteId;
+
+    @Column(name = "SESSION_ID")
+    private String sessionId;
+
+    @Column(name = "START_TIME")
+    private Date startTime;
+
+    @Column(name = "END_TIME")
+    private Date endTime;
+
+    @Column(name = "ACTION_TYPE")
+    private Long actionType;
+
+    @Column(name = "DESCRIPTION")
+    private String description;
+
+    @Column(name = "OBJECT_ID")
+    private  Long objectId;
+}

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

 package com.viettel.campaign.service;
 
+import com.viettel.campaign.model.ccms_full.UserActionLog;
+
 /**
- * @author anhvd_itsol
+ * @author hanv_itsol
+ * @project campaign
  */
 public interface UserActionLogService {
 
+    void save(UserActionLog log);
 }

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

 package com.viettel.campaign.service.impl;
 
+import com.viettel.campaign.config.DataSourceQualify;
+import com.viettel.campaign.model.ccms_full.UserActionLog;
+import com.viettel.campaign.repository.ccms_full.UserActionLogRepository;
 import com.viettel.campaign.service.UserActionLogService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -11,4 +15,13 @@ import org.springframework.transaction.annotation.Transactional;
 @Service
 @Transactional(rollbackFor = Exception.class)
 public class UserActionLogServiceImpl implements UserActionLogService {
+
+    @Autowired
+    UserActionLogRepository userActionLogRepository;
+
+    @Override
+    @Transactional(DataSourceQualify.CCMS_FULL)
+    public void save(UserActionLog log) {
+        userActionLogRepository.save(log);
+    }
 }