超时退款改动

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinRefundsStatusServiceImpl.java

@@ -7,6 +7,7 @@ import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
+import com.liquidnet.service.kylin.dto.param.RefundApplyParam;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
@@ -213,16 +214,18 @@ public class KylinRefundsStatusServiceImpl {
     }
 
     public Boolean orderTicketRefunding(
-            KylinOrderTickets orderInfo, String orderTicketsId, List<String> ticketEntityIds
+            KylinOrderTickets orderInfo, String orderTicketsId,
+            double RefundPriceExpress,
+            List<String> ticketEntityIds, List<Double> entitiesPrice
     ) {
         // 基础数据
-        String authId = "overtime";
-        String authName = "system";
-        String reason = "支付超时自动退款";
+        String authId = "";
+        String authName = "system_overtime_order_refund";
+        String reason = "订单支付超时自动退款";
         // 本次退款票总金额
-        double RefundPriceExpress = orderInfo.getPriceExpress().doubleValue();
-        double entitiesPriceSum = orderInfo.getPriceActual().doubleValue() - RefundPriceExpress;
+        double entitiesPriceSum = entitiesPrice.stream().mapToDouble(Double::doubleValue).sum();
 
+        // TODO: 2021/5/27 事物 and 部分退款
         // 更新数据
         // 订单状态表 和 缓存
         KylinOrderTicketStatus orderStatusTable = new KylinOrderTicketStatus();
@@ -263,7 +266,7 @@ public class KylinRefundsStatusServiceImpl {
 
         // 退款明细
         KylinOrderRefunds kylinOrderRefunds = new KylinOrderRefunds();
-        String orderRefundsId = IDGenerator.nextSnowId().toString();
+        String orderRefundsId = IDGenerator.nextSnowId();
         kylinOrderRefunds.setOrderRefundsId(orderRefundsId);
         kylinOrderRefunds.setOrderTicketsId(orderTicketsId);
 
@@ -278,7 +281,8 @@ public class KylinRefundsStatusServiceImpl {
         kylinOrderRefunds.setPrice(BigDecimal.valueOf(entitiesPriceSum));
         kylinOrderRefunds.setPriceExpress(BigDecimal.valueOf(RefundPriceExpress));
         kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY);
-        kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_AUTO);
+
+        kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY);
         kylinOrderRefunds.setApplicantId(authId);
         kylinOrderRefunds.setApplicantName(authName);
         kylinOrderRefunds.setApplicantAt(LocalDateTime.now());
@@ -296,10 +300,10 @@ public class KylinRefundsStatusServiceImpl {
         // 退款入场人表
         KylinOrderRefundEntities kylinOrderRefundEntities = new KylinOrderRefundEntities();
         for (int i = 0; i <= ticketEntityIds.size() - 1; i++) {
-            String orderRefundsEntitiesId = IDGenerator.nextSnowId().toString();
+            String orderRefundsEntitiesId = IDGenerator.nextSnowId();
             kylinOrderRefundEntities.setOrderRefundsEntitiesId(orderRefundsEntitiesId);
             kylinOrderRefundEntities.setOrderRefundsId(orderRefundsId);
-            kylinOrderRefundEntities.setRefundPrice(BigDecimal.valueOf(entitiesPriceSum / ticketEntityIds.size()));
+            kylinOrderRefundEntities.setRefundPrice(BigDecimal.valueOf(entitiesPrice.get(i)));
             kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
             kylinOrderRefundEntities.setCreatedAt(LocalDateTime.now());
             int rowsR = kylinOrderRefundsEntitiesMapper.insert(kylinOrderRefundEntities);

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/OrderRefundsCallbackServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.constant.KylinTableStatusConst;
+import com.liquidnet.service.kylin.dao.KylinOrderTicketEntitiesDao;
 import com.liquidnet.service.kylin.dto.param.RefundApplyParam;
 import com.liquidnet.service.kylin.dto.param.RefundCallbackParam;
 import com.liquidnet.service.kylin.entity.KylinOrderRefunds;
@@ -18,6 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
@@ -101,26 +103,56 @@ public class OrderRefundsCallbackServiceImpl extends ServiceImpl<KylinOrderRefun
         KylinOrderTickets orderInfo = kylinOrderTicketsMapper.selectOne(
                 new QueryWrapper<KylinOrderTickets>().eq("order_tickets_id", orderTicketsId)
         );
-
-        // 查询订单入场人
-        List<KylinOrderTicketEntities> EntitiesList = kylinOrderTicketEntitiesMapper.selectList(
-                new QueryWrapper<KylinOrderTicketEntities>()
-                        .eq("order_id", orderTicketsId)
-                        .eq("is_payment", KylinTableStatusConst.ENTITIES_IS_PAYMENT1)
-        );
-        List<String> ticketEntityIds = EntitiesList.stream().map(KylinOrderTicketEntities -> KylinOrderTicketEntities.getOrderTicketEntitiesId()).collect(Collectors.toList());
-        // 该订单正在退款或已有退款
-        int refundingCount = kylinOrderRefundsMapper.selectRefundingCount(
+        // 传的快递费不能大于实际的快递费=（支付的快递费-已退的快递费）
+        Double refundPriceExpressSum = kylinOrderRefundsMapper.RefundPriceExpressSum(// 已退快递费
                 orderTicketsId,
-                KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL,
-                ticketEntityIds
+                KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL
         );
-        if (refundingCount > 0) {
-            return false;
+        if (null == refundPriceExpressSum) {
+            refundPriceExpressSum = 0.0;
+        }
+        Double RefundPriceExpress = orderInfo.getPriceExpress().doubleValue() - refundPriceExpressSum;
+
+        // 查询订单入场人
+        List<KylinOrderTicketEntitiesDao> entitiesListTemp = kylinOrderTicketEntitiesMapper.getRefundEntitiesList(orderTicketsId);
+        List<KylinOrderTicketEntitiesDao> entitiesList = new ArrayList<>();
+
+        if(entitiesListTemp.size() > 0) {
+            double priceActual = orderInfo.getPriceActual().doubleValue();
+            double priceExpress = orderInfo.getPriceExpress().doubleValue();
+            int allEntitiesCount = kylinOrderTicketEntitiesMapper.selectCount(// 总入场人数量 排出未付款的 用来计算单入场人的价格
+                    new QueryWrapper<KylinOrderTicketEntities>()
+                            .eq("order_id", orderInfo.getOrderTicketsId())
+                            .ne("is_payment", KylinTableStatusConst.ENTITIES_IS_PAYMENT0)
+            );
+            double onePrice = (priceActual - priceExpress) / allEntitiesCount;//单价
+            for (KylinOrderTicketEntitiesDao entities : entitiesListTemp) {
+                Double refundedPrice = kylinOrderTicketEntitiesMapper.getRefundEntitiesPrice(//已退 包含退款中
+                        orderInfo.getOrderTicketsId(),
+                        KylinTableStatusConst.ORDER_REFUND_STATUS_CANCEL,
+                        entities.getOrderTicketEntitiesId()
+                );
+                double canRefundedPrice;
+                if (null != refundedPrice) {
+                    canRefundedPrice = onePrice - refundedPrice;
+                } else {
+                    canRefundedPrice = onePrice;
+                }
+                entities.setCanRefundedPrice(BigDecimal.valueOf(canRefundedPrice));
+                if (canRefundedPrice > 0) { // 退款中但是可退款金额为0不展示
+                    entitiesList.add(entities);
+                }
+            }
         }
 
+        List<String> ticketEntityIds = entitiesList.stream().map(KylinOrderTicketEntities -> KylinOrderTicketEntities.getOrderTicketEntitiesId()).collect(Collectors.toList());
+        List<Double> entitiesPrice = entitiesList.stream().map(KylinOrderTicketEntities -> KylinOrderTicketEntities.getCanRefundedPrice().doubleValue()).collect(Collectors.toList());
+
+
         boolean res = kylinRefundsStatusServiceImpl.orderTicketRefunding(
-                orderInfo, orderTicketsId, ticketEntityIds
+                orderInfo, orderTicketsId,
+                RefundPriceExpress,
+                ticketEntityIds, entitiesPrice
         );
         if (res) {
             return true;