From 6b5b93eb5bb49db929afe3e5919cd6e30e6384ba Mon Sep 17 00:00:00 2001
From: Caps <452713115@qq.com>
Date: Mon, 27 Apr 2020 22:11:22 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E5=B9=BF=E7=AE=A1=E7=90=86=E9=9B=B6?=
 =?UTF-8?q?=E5=94=AE=E5=85=AC=E5=8F=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kiisoo/ic/synchronous/service/BackDisposeService.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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