增加考试信息同步

exam-work-api/src/main/java/cn/com/qmth/examcloud/service/examwork/service/ExamService.java

@@ -12,6 +12,8 @@ import cn.com.qmth.examcloud.service.examwork.dao.ExamOrgTimeRepo;
 import cn.com.qmth.examcloud.service.examwork.entity.ExamOrgTime;
 import cn.com.qmth.examcloud.service.examwork.enums.ExamType;
 import cn.com.qmth.examcloud.service.examwork.service.rpc.OrgService;
+import cn.com.qmth.examcloud.service.examwork.service.sync.DataSendService;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Example;
 import org.springframework.data.domain.ExampleMatcher;
@@ -23,6 +25,7 @@ import org.springframework.stereotype.Service;
 
 import cn.com.qmth.examcloud.service.examwork.dao.ExamRepo;
 import cn.com.qmth.examcloud.service.examwork.entity.Exam;
+
 import org.springframework.transaction.annotation.Transactional;
 
 /**
@@ -42,6 +45,9 @@ public class ExamService {
 
     @Autowired
     OrgService orgService;
+    
+    @Autowired
+    DataSendService dataSendService;
 
     /**
      * 获取所有考试批次(分页)
@@ -84,6 +90,9 @@ public class ExamService {
      * @return
      */
     public Exam saveExam(Exam exam){
+    	if(exam.getId() != null){
+    		dataSendService.sendExam(exam);
+    	}
         return examRepo.save(exam);
     }
 

exam-work-api/src/main/java/cn/com/qmth/examcloud/service/examwork/service/sync/DataSendService.java

@@ -1,10 +1,26 @@
 package cn.com.qmth.examcloud.service.examwork.service.sync;
 
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-/**
- * Created by songyue on 17/8/3.
- */
+import cn.com.qmth.examcloud.common.dto.em.ExamSync;
+import cn.com.qmth.examcloud.common.util.BeanCopierUtil;
+import cn.com.qmth.examcloud.service.examwork.entity.Exam;
+
+import com.qmth.commons.dataSync.core.service.DataSyncService;
+
 @Service
 public class DataSendService {
+	
+	@Autowired
+    DataSyncService dataSyncService;
+	
+	/**
+	 * 发送exam
+	 * @param exam
+	 */
+	public void sendExam(Exam exam){
+		ExamSync examSync = BeanCopierUtil.copyProperties(exam,ExamSync.class);
+		dataSyncService.send(examSync);
+	}
 }