....

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

@@ -1,19 +1,28 @@
-package cn.com.qmth.examcloud.task.dao;
-
-import java.util.List;
-
-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> {
-
-	List<DataSyncEntity> findTop10ByComponentOrderById(String component);
-
-}
+package cn.com.qmth.examcloud.task.dao;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+
+import cn.com.qmth.examcloud.task.dao.entity.DataSyncEntity;
+
+@Repository
+public interface DataSyncRepo
+		extends
+			JpaRepository<DataSyncEntity, Long>,
+			JpaSpecificationExecutor<DataSyncEntity> {
+
+	List<DataSyncEntity> findTop10ByComponentOrderById(String component);
+
+	@Transactional
+	@Modifying
+	@Query("update DataSyncEntity set syncNum = syncNum+1 where id=:id")
+	void increaseSyncNum(@Param("id") Long id);
+
+}

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

@@ -51,6 +51,14 @@ public class DataSyncEntity extends JpaEntity {
 	 */
 	private int syncNum;
 
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
 	public String getComponent() {
 		return component;
 	}

examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/DataSyncTask.java

@@ -64,6 +64,7 @@ public class DataSyncTask extends AbstractTask {
 				if (result) {
 					dataSyncRepo.delete(cur);
 				} else {
+					dataSyncRepo.increaseSyncNum(cur.getId());
 					throw new StatusException("T-102001", "同步失败");
 				}