付款记录

@@ -17,6 +17,9 @@ public interface SellerOrderGoodsMapper {
 
     SellerOrderGoods selectByPrimaryKey(Integer id);
 
+
+    List<SellerOrderGoods> selectByUidAndStatus(@Param("uid") Integer uid, @Param("status") Integer status);
+
     List<SellerOrderGoods> selectByUidAndAttributesDesc(@Param("uid") Integer uid, @Param("status") Integer status, @Param("list") List<Integer> attributes);
 
     List<SellerEarnestStatistics> selectEarnestMoneyByUid(@Param("list") List<Integer> uid);

@@ -62,6 +62,16 @@
   </select>
 
 
+
+  <select id="selectByUidAndStatus"  resultMap="BaseResultMap">
+    select
+    <include refid="Base_Column_List" />
+    from seller_order_goods
+    where uid = #{uid,jdbcType=INTEGER}
+    and status= #{status,jdbcType=INTEGER}
+  </select>
+
+
   <select id="selectByUidAndAttributesDesc"  resultMap="BaseResultMap">
     select
     sog.uid, sog.id

@@ -91,6 +91,23 @@ public class OrderHelpController {
 
     }
 
+
+    @IgnoreSignature
+    @IgnoreSession
+    @RequestMapping(value = "/orderPay")
+    public ApiResponse orderPay(@RequestParam(value = "uids") List<Integer> uids){
+
+        storedSellerService.orderPay(uids);
+        return new ApiResponse.ApiResponseBuilder()
+                .code(200)
+                .message("插入订单的付款记录")
+                .build();
+
+    }
+
+
+
+
     @Autowired
     private IPaymentService paymentService;
 

@@ -13,6 +13,11 @@ import java.util.Map;
  */
 public interface IStoredSellerService {
 
+    /**
+     * 增加orderPay记录
+     * @param uids
+     */
+    public void orderPay(List<Integer> uids);
 
     boolean isStoredSeller(Integer uid);
 

@@ -383,6 +383,62 @@ public class StoreSellerServiceImpl implements IStoredSellerService {
     @Autowired
     SellerOrderMetaMapper sellerOrderMetaMapper;
 
+
+    @Autowired
+    OrdersPayMapper ordersPayMapper;
+
+
+    /**
+     * 增加orderPay记录
+     * @param uids
+     */
+    public void orderPay(List<Integer> uids){
+
+        // 查询卖家正在上架中的商品 & 支付方式是11 & orderspay中没有记录
+
+        for (Integer uid : uids){
+            scriptLogger.info("[] start orderPay....", uid);
+            List<SellerOrderGoods> sellerOrderGoodsList = sellerOrderGoodsMapper.selectByUidAndStatus(uid, SkupStatus.CAN_SELL.getCode());
+
+            if (CollectionUtils.isEmpty(sellerOrderGoodsList)){
+                scriptLogger.info("[] no need orderPay....can sell goods not exist", uid);
+                continue;
+            }
+
+            // 过滤出 支付方式是11的
+            List<SellerOrder> sellerOrders = sellerOrderMapper.selectBySkups(sellerOrderGoodsList.stream().map(SellerOrderGoods::getId).collect(Collectors.toList()));
+            List<SellerOrder> walletSellerOrders = sellerOrders.stream().filter(x->x.getPayment()==11).collect(Collectors.toList());
+
+            if (CollectionUtils.isEmpty(walletSellerOrders)){
+                scriptLogger.info("[] no need orderPay....can sell goods not wallet", uid);
+                continue;
+            }
+
+
+            for (SellerOrder sellerOrder : walletSellerOrders){
+
+                OrdersPay ordersPaydb = ordersPayMapper.selectOrdersPay(sellerOrder.getOrderCode(), uid);
+                if (ordersPaydb != null){
+                    scriptLogger.info("[] no need orderPay []", uid, sellerOrder.getOrderCode());
+                    continue;
+                }
+                OrdersPay ordersPay = new OrdersPay();
+                ordersPay.setPayOrderCode(String.valueOf(sellerOrder.getOrderCode()));
+                ordersPay.setAmount(sellerOrder.getEarnestMoney());
+                ordersPay.setOrderCode(sellerOrder.getOrderCode());
+                ordersPay.setUid(uid);
+                ordersPay.setPayment(11);
+                ordersPay.setSerialNo(String.valueOf(sellerOrder.getOrderCode()));
+                ordersPayMapper.insertSelective(ordersPay);
+                scriptLogger.info("[] do orderPay []", uid, sellerOrder.getOrderCode());
+            }
+            scriptLogger.info("[] end process orderPay....", uid);
+
+        }
+
+
+    }
+
     /**
      * 将原来的超级卖家降级
      */