修改失败订单为失效

src/main/java/com/quantgroup/asset/distribution/controller/RetryController.java

@@ -83,7 +83,17 @@ public class RetryController {
 			redisService.del(lockKey);
 		}
 	}
-
+    @RequestMapping("/updateFaiLog")
+    public String updateFailLogStates (String[] assetNoArr) {
+	    for (String assetNo : assetNoArr) {
+            DistributeFailLog distributeFailLog = distributeFailLogRepository.findByAssetNoAndEnable(assetNo, true);
+            if (distributeFailLog != null) {
+                distributeFailLog.setEnable(false);
+                distributeFailLogRepository.save(distributeFailLog);
+            }
+        }
+        return "ok";
+    }
 
 	private void retryDistributeFailLogList(List<DistributeFailLog> distributeFailLogList) {
 		if (CollectionUtils.isNotEmpty(distributeFailLogList)) {

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IDistributeFailLogRepository.java

 package com.quantgroup.asset.distribution.service.jpa.repository;
 
-import java.sql.Timestamp;
-
+import com.quantgroup.asset.distribution.service.jpa.entity.DistributeFailLog;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-import com.quantgroup.asset.distribution.service.jpa.entity.DistributeFailLog;
+import java.sql.Timestamp;
 
 /**
  * 分发失败Repository
- * @author liwenbin
  *
+ * @author liwenbin
  */
-public interface IDistributeFailLogRepository extends JpaRepository<DistributeFailLog, Long>{
-	
-	/**
-	 * 根据时间查询失败订单
-	 * @param start
-	 * @param end
-	 * @param enable
-	 * @param pageable
-	 * @return
-	 */
-	public Page<DistributeFailLog> findByCreatedAtBetweenAndEnable(Timestamp start, Timestamp end, Boolean enable,Pageable pageable);
+public interface IDistributeFailLogRepository extends JpaRepository<DistributeFailLog, Long> {
+
+    /**
+     * 根据时间查询失败订单
+     *
+     * @param start
+     * @param end
+     * @param enable
+     * @param pageable
+     * @return
+     */
+    public Page<DistributeFailLog> findByCreatedAtBetweenAndEnable(Timestamp start, Timestamp end, Boolean enable, Pageable pageable);
+
+    /**
+     * 根据assentNo查询失败订单
+     *
+     * @param assentNo
+     * @param enable
+     * @return
+     */
+    DistributeFailLog findByAssetNoAndEnable(String assentNo, boolean enable);
 }