Commit 7a9decc5 authored by 年畅's avatar 年畅 🛀

fix

parent 14c952c8
...@@ -2309,7 +2309,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean { ...@@ -2309,7 +2309,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean {
List<OrderComment> converted = new ArrayList<>(list.size()); List<OrderComment> converted = new ArrayList<>(list.size());
list.forEach(each -> { list.forEach(each -> {
Order order = historyDataOrderDao.selectByOrderNo(each.getOrderNo(), each.getUserId()); Order order = orderDao.selectByOrderNo(each.getOrderNo(), each.getUserId());
if (order != null) { if (order != null) {
Integer bizType = order.getBizType(); Integer bizType = order.getBizType();
...@@ -2324,7 +2324,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean { ...@@ -2324,7 +2324,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean {
if (!CollectionUtils.isEmpty(converted)) { if (!CollectionUtils.isEmpty(converted)) {
List<List<OrderComment>> partition = Lists.partition(converted, 200); List<List<OrderComment>> partition = Lists.partition(converted, 200);
for (List<OrderComment> group : partition) { for (List<OrderComment> group : partition) {
historyDataCommentDao.replaceList(group); newCommentDao.replaceList(group);
logger.info("[comment_replace]group:{}", group.stream().map(OrderComment::getOrderNo).collect(Collectors.toList())); logger.info("[comment_replace]group:{}", group.stream().map(OrderComment::getOrderNo).collect(Collectors.toList()));
} }
} }
...@@ -2460,7 +2460,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean { ...@@ -2460,7 +2460,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean {
List<OrderItemComment> converted = new ArrayList<>(list.size()); List<OrderItemComment> converted = new ArrayList<>(list.size());
list.forEach(each -> { list.forEach(each -> {
Order order = historyDataOrderDao.selectByOrderNo(each.getOrderNo(), each.getUserId()); Order order = orderDao.selectByOrderNo(each.getOrderNo(), each.getUserId());
if (order != null) { if (order != null) {
each.setBizType(each.getBizType()); each.setBizType(each.getBizType());
each.setOrderType(order.getOrderType()); each.setOrderType(order.getOrderType());
...@@ -2472,7 +2472,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean { ...@@ -2472,7 +2472,7 @@ public class TempOrderRoutingServiceImpl implements InitializingBean {
if (!CollectionUtils.isEmpty(converted)) { if (!CollectionUtils.isEmpty(converted)) {
List<List<OrderItemComment>> partition = Lists.partition(converted, 200); List<List<OrderItemComment>> partition = Lists.partition(converted, 200);
for (List<OrderItemComment> group : partition) { for (List<OrderItemComment> group : partition) {
historyDataItemCommentDao.replaceList(group); newItemCommentDao.replaceList(group);
searchCommentManager.batchIndex(group, CommonConstants.ES_ORDER_COMMENTS_INDEX); searchCommentManager.batchIndex(group, CommonConstants.ES_ORDER_COMMENTS_INDEX);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment