....

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

@@ -6,6 +6,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import cn.com.qmth.examcloud.commons.base.util.JsonUtil;
 import cn.com.qmth.examcloud.commons.web.support.ControllerSupport;
 import cn.com.qmth.examcloud.task.api.DataSyncCloudService;
 import cn.com.qmth.examcloud.task.api.request.SyncCourseReq;
@@ -16,6 +17,8 @@ import cn.com.qmth.examcloud.task.api.response.SyncCourseResp;
 import cn.com.qmth.examcloud.task.api.response.SyncOrgResp;
 import cn.com.qmth.examcloud.task.api.response.SyncSpecialtyResp;
 import cn.com.qmth.examcloud.task.api.response.SyncStudentResp;
+import cn.com.qmth.examcloud.task.dao.DataSyncRepo;
+import cn.com.qmth.examcloud.task.dao.entity.DataSyncEntity;
 import cn.com.qmth.examcloud.task.service.DataSyncService;
 import cn.com.qmth.examcloud.task.service.bean.CourseInfo;
 import cn.com.qmth.examcloud.task.service.bean.OrgInfo;
@@ -38,12 +41,23 @@ public class DataSyncCloudServiceProvider extends ControllerSupport
 	@Autowired
 	DataSyncService dataSyncService;
 
+	@Autowired
+	DataSyncRepo dataSyncRepo;
+
 	private static final long serialVersionUID = -2880611326177571371L;
 
 	@PostMapping("syncCourse")
 	@Override
 	public SyncCourseResp syncCourse(@RequestBody SyncCourseReq req) {
 		CourseInfo info = new CourseInfo();
+
+		DataSyncEntity entity = new DataSyncEntity();
+		entity.setMethodName("syncCourse");
+		entity.setParamType(CourseInfo.class.getName());
+		entity.setParam(JsonUtil.toJson(info));
+
+		dataSyncRepo.saveAndFlush(entity);
+
 		dataSyncService.syncCourse(info);
 		return null;
 	}
@@ -52,6 +66,14 @@ public class DataSyncCloudServiceProvider extends ControllerSupport
 	@Override
 	public SyncOrgResp syncOrg(@RequestBody SyncOrgReq req) {
 		OrgInfo info = new OrgInfo();
+
+		DataSyncEntity entity = new DataSyncEntity();
+		entity.setMethodName("syncOrg");
+		entity.setParamType(CourseInfo.class.getName());
+		entity.setParam(JsonUtil.toJson(info));
+
+		dataSyncRepo.saveAndFlush(entity);
+
 		dataSyncService.syncOrg(info);
 		return null;
 	}
@@ -60,6 +82,14 @@ public class DataSyncCloudServiceProvider extends ControllerSupport
 	@Override
 	public SyncStudentResp syncStudent(@RequestBody SyncStudentReq req) {
 		StudentInfo info = new StudentInfo();
+
+		DataSyncEntity entity = new DataSyncEntity();
+		entity.setMethodName("syncStudent");
+		entity.setParamType(CourseInfo.class.getName());
+		entity.setParam(JsonUtil.toJson(info));
+
+		dataSyncRepo.saveAndFlush(entity);
+
 		dataSyncService.syncStudent(info);
 		return null;
 	}
@@ -68,6 +98,14 @@ public class DataSyncCloudServiceProvider extends ControllerSupport
 	@Override
 	public SyncSpecialtyResp syncSpecialty(@RequestBody SyncSpecialtyReq req) {
 		SpecialtyInfo info = new SpecialtyInfo();
+
+		DataSyncEntity entity = new DataSyncEntity();
+		entity.setMethodName("syncSpecialty");
+		entity.setParamType(CourseInfo.class.getName());
+		entity.setParam(JsonUtil.toJson(info));
+
+		dataSyncRepo.saveAndFlush(entity);
+
 		dataSyncService.syncSpecialty(info);
 		return null;
 	}

examcloud-task-dao/src/main/java/cn/com/qmth/examcloud/task/dao/DataSyncRepo.java

@@ -0,0 +1,15 @@
+package cn.com.qmth.examcloud.task.dao;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.stereotype.Repository;
+
+import cn.com.qmth.examcloud.task.dao.entity.DataSyncEntity;
+
+@Repository
+public interface DataSyncRepo
+		extends
+			JpaRepository<DataSyncEntity, Long>,
+			JpaSpecificationExecutor<DataSyncEntity> {
+
+}

examcloud-task-dao/src/main/java/cn/com/qmth/examcloud/task/dao/entity/DataSyncEntity.java

@@ -0,0 +1,78 @@
+package cn.com.qmth.examcloud.task.dao.entity;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+import cn.com.qmth.examcloud.commons.web.jpa.JpaEntity;
+
+/**
+ * 数据同步
+ *
+ * @author WANGWEI
+ * @date 2018年8月2日
+ * @Copyright (c) 2018-? http://qmth.com.cn All Rights Reserved.
+ */
+@Entity
+@Table(name = "EC_T_DATA_SYNC")
+public class DataSyncEntity extends JpaEntity {
+
+	private static final long serialVersionUID = 1066874132817953168L;
+
+	@Id
+	@GeneratedValue
+	private Long id;
+
+	private String methodName;
+
+	private String paramType;
+
+	private String param;
+
+	/**
+	 * 同步次数
+	 */
+	private int syncNum;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public String getMethodName() {
+		return methodName;
+	}
+
+	public void setMethodName(String methodName) {
+		this.methodName = methodName;
+	}
+
+	public String getParamType() {
+		return paramType;
+	}
+
+	public void setParamType(String paramType) {
+		this.paramType = paramType;
+	}
+
+	public String getParam() {
+		return param;
+	}
+
+	public void setParam(String param) {
+		this.param = param;
+	}
+
+	public int getSyncNum() {
+		return syncNum;
+	}
+
+	public void setSyncNum(int syncNum) {
+		this.syncNum = syncNum;
+	}
+
+}

examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/impl/DataSyncServiceImpl.java

@@ -15,7 +15,7 @@ import cn.com.qmth.examcloud.task.service.bean.StudentInfo;
  * @date 2018年8月2日
  * @Copyright (c) 2018-? http://qmth.com.cn All Rights Reserved.
  */
-@Service
+@Service("dataSyncService")
 public class DataSyncServiceImpl implements DataSyncService {
 
 	@Override