Quellcode durchsuchen

修改定时调度

humuyu vor 3 Jahren
Ursprung
Commit
2e8f3255de

+ 24 - 0
eladmin-system/src/main/java/me/zhengjie/application/admin/job/CochainJob.java

@@ -0,0 +1,24 @@
+package me.zhengjie.application.admin.job;
+
+import org.springframework.stereotype.Component;
+
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+
+import me.zhengjie.application.admin.service.OrderCochainService;
+
+@Component
+public class CochainJob {
+	OrderCochainService cochainService;
+
+	/**
+	 * 调用第三方上链接口
+	 */
+	@XxlJob("jobCochain")
+	public void jobCochain() {
+		XxlJobHelper.log("Generate jobCochain beginning ......");
+		cochainService.chainEvidence();
+		XxlJobHelper.log("Generate end beginning ......");
+	}
+
+}

+ 2 - 2
eladmin-system/src/main/java/me/zhengjie/application/admin/service/OrderCochainService.java

@@ -3,6 +3,6 @@ package me.zhengjie.application.admin.service;
 import me.zhengjie.base.plus.AbstractService;
 import me.zhengjie.dao.mybatis.entity.OrderCochainEntity;
 
-public interface OrderCochainService extends AbstractService<OrderCochainEntity>{
-
+public interface OrderCochainService extends AbstractService<OrderCochainEntity> {
+	public void chainEvidence();
 }

+ 1 - 8
eladmin-system/src/main/java/me/zhengjie/application/admin/service/impl/OrderCochainServiceImpl.java

@@ -91,7 +91,7 @@ public class OrderCochainServiceImpl extends AbstractServiceImpl<IOrderCochainDa
 		UPLOAD_FILE_PATH = downloadPath;
 	}
 
-	private void chainEvidence()  {
+	public void chainEvidence()  {
 
 		QueryWrapper<OrderCochainEntity> qw = new QueryWrapper<>();
 		qw = qw.lt("count", 3).in("status", 0, 2).orderByAsc("create_time").last("limit 1");
@@ -187,13 +187,6 @@ public class OrderCochainServiceImpl extends AbstractServiceImpl<IOrderCochainDa
 		}
 	}
 
-	/**
-	 * 调用第三方上链接口
-	 */
-	@XxlJob("cochain")
-	public void jobCochain() {
-		 chainEvidence();
-	}
 
 	/**
 	 * 通过文件路径上传

+ 1 - 0
eladmin-system/src/main/java/me/zhengjie/dao/mybatis/entity/ContractOrderEntity.java

@@ -68,6 +68,7 @@ public class ContractOrderEntity implements Serializable {
 
     @TableField("contract_attachment")
     private String contractAttachment;
+    
     @QueryWapper(QueryKeyword.LIKE)
     @TableField("name")
     private String name;