更新数据

haoban-manage3-service/src/test/java/InteractRecordTest.java

@@ -40,6 +40,9 @@ import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
 import java.util.*;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @Author MUSI
@@ -133,7 +136,8 @@ public class InteractRecordTest {
     }
 
     @Test
-    public void fixOrderChannelCode() {
+    public void fixOrderChannelCode() throws Exception{
+        ExecutorService executorService = Executors.newFixedThreadPool(10);
         InteractRecordQO interactRecordQO = new InteractRecordQO();
         interactRecordQO.setPageNum(1);
         interactRecordQO.setPageSize(100000);
@@ -143,9 +147,10 @@ public class InteractRecordTest {
         Page<InteractRecordBO> interactRecordBOPage = interactRecordService.queryInteractRecordPage(interactRecordQO);
         List<InteractRecordBO> result = interactRecordBOPage.getResult();
         for (InteractRecordBO interactRecordBO : result) {
+            executorService.execute(()->{
                 InteractRecordExtendInfoBO extendInfo = interactRecordBO.getExtendInfo();
                 if (extendInfo == null) {
-                continue;
+                    return;
                 }
                 List<InteractRecordExtendInfoBO.ExtendOrderInfo> extendOrderInfos = extendInfo.getExtendOrderInfos();
                 for (InteractRecordExtendInfoBO.ExtendOrderInfo extendOrderInfo : extendOrderInfos) {
@@ -183,6 +188,8 @@ public class InteractRecordTest {
                 update.setId(interactRecordBO.getId());
                 update.setExtendInfo(extendInfo);
                 interactRecordService.saveOrUpdateInteractRecord(update);
+            });
         }
+        executorService.awaitTermination(10, TimeUnit.HOURS);
     }
 }