Browse Source

Merge branch 'refs/heads/chenglong' into dev

dist.1.3.0
chenlong 2 months ago
parent
commit
8244d05843
  1. 3
      blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java

3
blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/service/impl/MtOrderLogFailRetryServiceImpl.java

@ -9,6 +9,7 @@ import com.logpm.factory.mt.service.MtOrderLogFailRetryService;
import com.logpm.factory.props.MtFactoryProperties; import com.logpm.factory.props.MtFactoryProperties;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springblade.common.annotations.LogpmAsync;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -54,7 +55,7 @@ public class MtOrderLogFailRetryServiceImpl implements MtOrderLogFailRetryServic
protected final Integer SIGN_TYPE = 6; protected final Integer SIGN_TYPE = 6;
@Async @LogpmAsync("asyncExecutor")
@Override @Override
public void retry(List<MtOrderLogEntity> waitData){ public void retry(List<MtOrderLogEntity> waitData){
waitData.forEach(this::executeRetry); waitData.forEach(this::executeRetry);

Loading…
Cancel
Save