Merge branch 'master_chw_publish' into dev-chw

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/contant/enumerate/AccountTypeEnum.java

@@ -11,6 +11,7 @@ public enum AccountTypeEnum {
     OUT_DEPOSIT(202, "所有押金"),
     OUT_PART_DEPOSIT(203, "部分押金（扣除该扣除的 + 保留违章预备金）"),
     OUT_RESIDUE_DEPOSIT(204, "剩余押金（扣除该扣除的）"),
+    OUT_RESIDUE_ORDER(205, "部分订单退款"),
     ;
     /**
      * 编码

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/contant/enumerate/DeductionTypeEnum.java

@@ -18,6 +18,7 @@ public enum DeductionTypeEnum {
     VIOLATE_TRAFFIC_DEDUCT(401, "违章扣款"),
     VIOLATE_TRAFFIC_KEEP(402, "违章扣款保留金"),
     OTHER_DELAY_SAFE(501, "其他费用-延迟用车不记免赔"),
+    OTHER_PUBLISH_REJECTED(502, "其他费用-申请调车接单被拒绝退款"),
     ;
     /**
      * 编码

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderAccountBiz.java

@@ -47,6 +47,7 @@ import java.util.*;
 
 import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_FALSE;
 import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
+import static com.xxfc.platform.order.contant.enumerate.AccountTypeEnum.OUT_RESIDUE_ORDER;
 import static com.xxfc.platform.order.pojo.account.OrderAccountDeduction.ORIGIN_DEPOSIT;
 import static com.xxfc.platform.order.pojo.account.OrderAccountDeduction.ORIGIN_ORDER_DEPOSIT;
 import static com.xxfc.platform.order.pojo.pay.NotifyUrlDTO.PAY_WAY_ALI;
@@ -218,6 +219,31 @@ public class OrderAccountBiz extends BaseBiz<OrderAccountMapper,OrderAccount> {
         return refundAmount;
     }
 
+
+    /**
+     * 调车发布 退款流程
+     * @param baseOrder 基础订单信息
+     * @param refundDesc 退款描述
+     * @param originalRefundAmount 原退款金额
+     * @param deductAmount 扣除金额
+     */
+    public void publishRefundProcess(BaseOrder baseOrder, String refundDesc, BigDecimal originalRefundAmount, BigDecimal deductAmount) {
+        BigDecimal refundAmount = BigDecimal.ZERO.add(originalRefundAmount);
+
+        if(null != deductAmount) {
+            refundAmount = originalRefundAmount.subtract(deductAmount);
+        }
+
+        BigDecimal finalRefundAmount = refundAmount;
+        OrderAccountDetail oad = new OrderAccountDetail(){{
+           setOriginOrderAmount(originalRefundAmount);
+           setOrderAmount(finalRefundAmount);
+        }};
+        OrderAccountDeduction violateDeduction = initDeduction(deductAmount, refundDesc, DeductionTypeEnum.OTHER_PUBLISH_REJECTED, OrderAccountDeduction.ORIGIN_ORDER);
+        oad.getDeductions().add(violateDeduction);
+        refundSubProcess(baseOrder, refundDesc, originalRefundAmount, refundAmount, OUT_RESIDUE_ORDER.getCode(), RefundStatusEnum.ALL.getCode(), oad);
+    }
+
     /**
      * 退款子流程
      * @param baseOrder 基础订单信息

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/entity/VehiclePublishGoods.java

@@ -45,6 +45,11 @@ public class VehiclePublishGoods implements Serializable {
     private Integer number;
 
 
+	@Column(name = "receive_number")
+	@ApiModelProperty(value = "已接数量")
+	private Integer receiveNumber;
+
+
 	@Column(name = "receive_amount")
 	@ApiModelProperty(value = "接单者服务费（单个商品）")
 	private BigDecimal receiveAmount;

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehiclePublishGoodsBiz.java

@@ -64,6 +64,20 @@ public class VehiclePublishGoodsBiz extends BaseBiz<VehiclePublishGoodsMapper, V
     }
 
 
+    public List<VehiclePublishGoods> getListByPublishId(Integer publishId){
+        return  mapper.groupGoodsIdList(publishId);
+    }
+
+    public  void  updReceiveNumber(Integer publishId){
+        List<VehiclePublishGoods> list = getListByPublishId(publishId);
+        if (CollectionUtils.isNotEmpty(list)){
+            for (VehiclePublishGoods publishGoods : list){
+                updateSelectiveById(publishGoods);
+            }
+        }
+    }
+
+
 
 
 

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehiclePublishReceiveBiz.java

@@ -214,11 +214,13 @@ public class VehiclePublishReceiveBiz extends BaseBiz<VehiclePublishReceiveMappe
             addVehicleUseTime(publishReceiveDTO);
             VehicleReceiveRefundDTO receiveRefundDTO = new VehicleReceiveRefundDTO();
             receiveRefundDTO.setOrderNoStr(orderNoStr);
+            publishGoodsBiz.updReceiveNumber(publishId);
             sendQueue(receiveRefundDTO);
         }else if (type == 1){
             if (status.equals( VehiclePublishReceiveDTO.PAY)){
                 vehiclePublishBiz.updWaitConfirmNumber(number,publishId);
                 addVehicleUseTime(publishReceiveDTO);
+                publishGoodsBiz.updReceiveNumber(publishId);
             }
         }
     }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/VehiclePublishGoodsMapper.java

@@ -4,6 +4,8 @@ package com.xxfc.platform.vehicle.mapper;
 import com.xxfc.platform.vehicle.entity.VehiclePublishGoods;
 import com.xxfc.platform.vehicle.pojo.dto.VehiclePublishFindDTO;
 import com.xxfc.platform.vehicle.pojo.vo.VehiclePublishGoodsVo;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 import tk.mybatis.mapper.additional.idlist.SelectByIdListMapper;
 import tk.mybatis.mapper.common.Mapper;
 
@@ -17,4 +19,13 @@ public interface VehiclePublishGoodsMapper extends Mapper<VehiclePublishGoods>,
 
     List<VehiclePublishGoodsVo> selectListByOrderNo(VehiclePublishFindDTO publishFindDTO);
 
+    @Select("SELECT r.publish_goods_id as id,IFNULL(COUNT(r.id)) as receiveNumber  FROM vehicle_publish_receive r \n" +
+            "\n" +
+            "LEFT JOIN vehicle_publish_goods  g ON r.publish_goods_id = g.id\n" +
+            "\n" +
+            "WHERE g.publish_id=#{publishId} and r.`status` in (1,3) and r.is_del = 0\n" +
+            "\n" +
+            "GROUP BY r.publish_goods_id")
+    List<VehiclePublishGoods> groupGoodsIdList(@Param("publishId") Integer publishId );
+
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/resources/mapper/VehiclePublishMapper.xml

@@ -14,6 +14,9 @@
             <if test="companyId != null and companyId > 0">
                 AND  p.`company_id`= #{companyId}
             </if>
+            <if test="publishId != null and publishId > 0">
+                AND  p.`id`= #{publishId}
+            </if>
             <if test="goodsType != null ">
                 AND  p.`goods_type`= #{goodsType}
             </if>