Update CollageOrderServiceImpl.java

order-application-service/src/main/java/cn/freemud/service/impl/CollageOrderServiceImpl.java

@@ -46,6 +46,8 @@ import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
 
 @Service
 @Slf4j
@@ -128,12 +130,21 @@ public class CollageOrderServiceImpl implements CollageOrderService {
         GroupBuyRequest.PayList payList = new GroupBuyRequest.PayList();
         List<GroupBuyRequest.UserInfo> userInfoList = new ArrayList<>();
 
-        List<OrderSettlementResp> orderSettlementDetailList = order.getOrderSettlementDetailList();
+        List<QueryOrdersResponse.DataBean.OrderBean.ProductBean> productList = order.getProductList();
 
-        GroupBuyRequest.UserInfo groupBuyUserInfo = new GroupBuyRequest.UserInfo();
-        groupBuyUserInfo.setOpenid("oORZK5A8hrejg0uBVSlkpv-KPgv4");
-        groupBuyUserInfo.setAmount(1);
-        userInfoList.add(groupBuyUserInfo);
+        // 群收款支付用户userId列表
+        List<String> payerUserIdList = productList.stream().filter(product -> !userInfo.getMemberId().equals(product.getUserId())).map(QueryOrdersResponse.DataBean.OrderBean.ProductBean::getUserId).distinct().collect(Collectors.toList());
+
+        GroupBuyRequest.UserInfo groupBuyUserInfo;
+        for (String payerUserId : payerUserIdList) {
+            Long amount = productList.stream().filter(product -> payerUserId.equals(product.getUserId())).map(QueryOrdersResponse.DataBean.OrderBean.ProductBean::getSalePrice).reduce(Long::sum).get();
+
+            groupBuyUserInfo = new GroupBuyRequest.UserInfo();
+            // TODO 新增openid值传入
+            groupBuyUserInfo.setOpenid("oORZK5A8hrejg0uBVSlkpv-KPgv4");
+            groupBuyUserInfo.setAmount(Integer.parseInt(String.valueOf(amount)));
+            userInfoList.add(groupBuyUserInfo);
+        }
 
         payList.setUser_info(userInfoList);
         groupBuyRequest.setPay_list(payList);