|
|
@ -36,6 +36,7 @@ import org.springblade.core.tool.utils.BeanUtil; |
|
|
|
import org.springframework.amqp.AmqpException; |
|
|
|
import org.springframework.amqp.AmqpException; |
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate; |
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
|
|
|
|
import org.springframework.context.annotation.Lazy; |
|
|
|
import org.springframework.retry.annotation.Backoff; |
|
|
|
import org.springframework.retry.annotation.Backoff; |
|
|
|
import org.springframework.retry.annotation.Retryable; |
|
|
|
import org.springframework.retry.annotation.Retryable; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
@ -43,15 +44,20 @@ import org.springframework.stereotype.Service; |
|
|
|
import java.util.*; |
|
|
|
import java.util.*; |
|
|
|
|
|
|
|
|
|
|
|
@Service |
|
|
|
@Service |
|
|
|
@AllArgsConstructor |
|
|
|
|
|
|
|
@Slf4j |
|
|
|
@Slf4j |
|
|
|
public class DistributionNodeWorkServiceImpl implements IDistributionNodeWorkService { |
|
|
|
public class DistributionNodeWorkServiceImpl implements IDistributionNodeWorkService { |
|
|
|
|
|
|
|
|
|
|
|
private final RabbitTemplate rabbitTemplate; |
|
|
|
@Autowired |
|
|
|
private final FactoryDataMessageSender factoryDataMessageSender; |
|
|
|
private RabbitTemplate rabbitTemplate; |
|
|
|
private final IDistributionDeliveryListService distributionDeliveryListService; |
|
|
|
@Autowired |
|
|
|
private final IDistributionDeliverySelfService distributionDeliverySelfService; |
|
|
|
private FactoryDataMessageSender factoryDataMessageSender; |
|
|
|
private final IDistributionDeliveryTripartiteService distributionDeliveryTripartiteService; |
|
|
|
@Autowired |
|
|
|
|
|
|
|
@Lazy |
|
|
|
|
|
|
|
private IDistributionDeliveryListService distributionDeliveryListService; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
|
|
private IDistributionDeliverySelfService distributionDeliverySelfService; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
|
|
private IDistributionDeliveryTripartiteService distributionDeliveryTripartiteService; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public void planDelivery(DistributionDeliveryListEntity distributionDeliveryListEntity, BladeUser user,BizOperationEnums bizOperation) { |
|
|
|
public void planDelivery(DistributionDeliveryListEntity distributionDeliveryListEntity, BladeUser user,BizOperationEnums bizOperation) { |
|
|
|