wangwei %!s(int64=6) %!d(string=hai) anos
pai
achega
636cd56ca0

+ 11 - 0
examcloud-task-api-provider/src/main/java/cn/com/qmth/examcloud/task/api/provider/DataSyncCloudServiceProvider.java

@@ -97,6 +97,17 @@ public class DataSyncCloudServiceProvider extends ControllerSupport
 	public SyncExamStudentResp syncExamStudent(@RequestBody SyncExamStudentReq req) {
 		cn.com.qmth.examcloud.commons.api.request.SyncExamStudentReq r = new cn.com.qmth.examcloud.commons.api.request.SyncExamStudentReq();
 		r.setSyncType(req.getSyncType());
+		r.setCourseCode(req.getCourseCode());
+		r.setCourseLevel(req.getCourseLevel());
+		r.setCourseName(req.getCourseName());
+		r.setExamId(req.getExamId());
+		r.setExamName(req.getExamName());
+		r.setId(req.getId());
+		r.setIdentityNumber(req.getIdentityNumber());
+		r.setPaperType(req.getPaperType());
+		r.setRootOrgId(req.getRootOrgId());
+		r.setStudentCode(req.getStudentCode());
+		r.setStudentName(req.getStudentName());
 
 		dataSyncService.syncExamStudent(r);
 		SyncExamStudentResp resp = new SyncExamStudentResp();

+ 24 - 1
examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/ExamStudentImportDataProcessingTask.java

@@ -33,7 +33,9 @@ import cn.com.qmth.examcloud.core.basic.api.response.GetOrgResp;
 import cn.com.qmth.examcloud.core.basic.api.response.SaveStudentResp;
 import cn.com.qmth.examcloud.examwork.api.ExamCloudService;
 import cn.com.qmth.examcloud.examwork.api.ExamStudentCloudService;
+import cn.com.qmth.examcloud.examwork.api.bean.ExamStudentBean;
 import cn.com.qmth.examcloud.examwork.api.request.SaveExamStudentReq;
+import cn.com.qmth.examcloud.examwork.api.response.SaveExamStudentResp;
 import cn.com.qmth.examcloud.task.base.AbstractTask;
 import cn.com.qmth.examcloud.task.base.ScheduleJob;
 import cn.com.qmth.examcloud.task.base.TaskTracker;
@@ -42,6 +44,7 @@ import cn.com.qmth.examcloud.task.dao.ExamStudentTempRepo;
 import cn.com.qmth.examcloud.task.dao.entity.ExamStudentImportEntity;
 import cn.com.qmth.examcloud.task.dao.entity.ExamStudentTempEntity;
 import cn.com.qmth.examcloud.task.dao.enums.ExamStudentImportStatus;
+import cn.com.qmth.examcloud.task.service.DataSyncService;
 
 /**
  * 考生导入-文件解析
@@ -82,6 +85,9 @@ public class ExamStudentImportDataProcessingTask extends AbstractTask {
 	@Autowired
 	ExamStudentCloudService examStudentCloudService;
 
+	@Autowired
+	DataSyncService dataSyncService;
+
 	@Override
 	public void run(ScheduleJob scheduleJob) throws Exception {
 
@@ -275,7 +281,24 @@ public class ExamStudentImportDataProcessingTask extends AbstractTask {
 			sReq.setGrade(entity.getGrade());
 			sReq.setInfoCollector(entity.getInfoCollector());
 
-			examStudentCloudService.saveExamStudent(sReq);
+			SaveExamStudentResp saveExamStudentResp = examStudentCloudService.saveExamStudent(sReq);
+			ExamStudentBean examStudentBean = saveExamStudentResp.getExamStudentBean();
+
+			cn.com.qmth.examcloud.commons.api.request.SyncExamStudentReq r = new cn.com.qmth.examcloud.commons.api.request.SyncExamStudentReq();
+			r.setSyncType("update");
+			r.setCourseCode(examStudentBean.getCourseCode());
+			r.setCourseLevel(examStudentBean.getCourseLevel());
+			r.setCourseName(examStudentBean.getCourseName());
+			r.setExamId(examStudentBean.getExamId());
+			r.setExamName(examStudentBean.getExamName());
+			r.setId(examStudentBean.getId());
+			r.setIdentityNumber(examStudentBean.getIdentityNumber());
+			r.setPaperType(examStudentBean.getPaperType());
+			r.setRootOrgId(examStudentBean.getRootOrgId());
+			r.setStudentCode(examStudentBean.getStudentCode());
+			r.setStudentName(examStudentBean.getStudentName());
+
+			dataSyncService.syncExamStudent(r);
 
 			entity.setStudentId(studentId);
 			entity.setStatusCode("200");