diff --git a/src/main/java/com/kiisoo/ic/synchronous/service/BackDisposeService.java b/src/main/java/com/kiisoo/ic/synchronous/service/BackDisposeService.java index c31d9f0..1d5f00e 100644 --- a/src/main/java/com/kiisoo/ic/synchronous/service/BackDisposeService.java +++ b/src/main/java/com/kiisoo/ic/synchronous/service/BackDisposeService.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; import com.kiisoo.ic.common.DisruptorCallackI; import com.kiisoo.ic.common.DisruptorDataI; import com.kiisoo.ic.customer.CustomerService; +import com.kiisoo.ic.synchronous.entity.TurnBackDTO; import com.kiisoo.ic.synchronous.entity.TurnBackVO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -17,6 +18,8 @@ public class BackDisposeService implements DisruptorCallackI { @Override public void handel(DisruptorDataI dataMsg) throws Exception { TurnBackVO channelStateOrderDTO = (TurnBackVO)dataMsg; - channelStateOrderDTO.getTurnBackDTOS().forEach(customerService::turnBack); + for (TurnBackDTO turnBackDTO : channelStateOrderDTO.getTurnBackDTOS()) { + customerService.turnBack(turnBackDTO); + } } }