|
@@ -4,6 +4,7 @@ import com.github.microservice.auth.client.content.ResultContent;
|
|
import com.zhongshu.payment.client.model.order.v2.CreateOrder2Model;
|
|
import com.zhongshu.payment.client.model.order.v2.CreateOrder2Model;
|
|
import com.zhongshu.payment.client.model.order.v2.VerificationModel;
|
|
import com.zhongshu.payment.client.model.order.v2.VerificationModel;
|
|
import com.zhongshu.payment.client.service.v2.OrderService2;
|
|
import com.zhongshu.payment.client.service.v2.OrderService2;
|
|
|
|
+import com.zhongshu.payment.client.service.v2.PaymentService2;
|
|
import lombok.Data;
|
|
import lombok.Data;
|
|
import lombok.extern.log4j.Log4j2;
|
|
import lombok.extern.log4j.Log4j2;
|
|
import org.springframework.batch.core.Job;
|
|
import org.springframework.batch.core.Job;
|
|
@@ -26,6 +27,9 @@ public class StandarVerificationJob {
|
|
ThreadLocal<ResultContent> resultContent = new ThreadLocal<>();
|
|
ThreadLocal<ResultContent> resultContent = new ThreadLocal<>();
|
|
|
|
|
|
ThreadLocal<VerificationModel> parameter = new ThreadLocal<>();
|
|
ThreadLocal<VerificationModel> parameter = new ThreadLocal<>();
|
|
|
|
+
|
|
|
|
+ @Autowired
|
|
|
|
+ PaymentService2 paymentService2;
|
|
@Resource
|
|
@Resource
|
|
private StepBuilderFactory stepBuilderFactory;
|
|
private StepBuilderFactory stepBuilderFactory;
|
|
|
|
|
|
@@ -39,7 +43,9 @@ public class StandarVerificationJob {
|
|
public Step standardVerificationStep() {
|
|
public Step standardVerificationStep() {
|
|
return stepBuilderFactory.get("standardVerificationStep")
|
|
return stepBuilderFactory.get("standardVerificationStep")
|
|
.tasklet((contribution, chunkContext) -> {
|
|
.tasklet((contribution, chunkContext) -> {
|
|
- getResultContent().set(orderService2.verification(getParameter().get()));
|
|
|
|
|
|
+ VerificationModel verificationModel = getParameter().get();
|
|
|
|
+ getResultContent().set(orderService2.verification(verificationModel));
|
|
|
|
+ paymentService2.subOrdersConfirm(verificationModel.getId(),verificationModel.getShopId());
|
|
return RepeatStatus.FINISHED;
|
|
return RepeatStatus.FINISHED;
|
|
})
|
|
})
|
|
.build();
|
|
.build();
|