推广管理零售公司

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);
+        }
     }
 }