From c18db6ffd30d44eee36110ac519dbd87d361a964 Mon Sep 17 00:00:00 2001
From: zhanghb <740323835@qq.com>
Date: Mon, 17 Feb 2025 15:57:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B1=95=E5=9F=BA=E9=87=91=E7=9B=B8?=
 =?UTF-8?q?=E5=85=B3=E5=AE=9E=E7=8E=B0-=E5=A2=9E=E5=8A=A0=E5=8F=91?=
 =?UTF-8?q?=E5=B1=95=E5=9F=BA=E9=87=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mall/mapper/UmsDevelopmentFundMapper.java     | 15 +++++++++++++++
 .../service/impl/OmsPortalOrderServiceImpl.java   | 10 +++++++++-
 2 files changed, 24 insertions(+), 1 deletion(-)

diff --git a/mall-dao/src/main/java/com/buy507/mall/mapper/UmsDevelopmentFundMapper.java b/mall-dao/src/main/java/com/buy507/mall/mapper/UmsDevelopmentFundMapper.java
index d1bddcf..8521bd1 100644
--- a/mall-dao/src/main/java/com/buy507/mall/mapper/UmsDevelopmentFundMapper.java
+++ b/mall-dao/src/main/java/com/buy507/mall/mapper/UmsDevelopmentFundMapper.java
@@ -1,6 +1,7 @@
 package com.buy507.mall.mapper;
 
 import com.buy507.mall.model.UmsDevelopmentFund;
+import org.apache.ibatis.annotations.Insert;
 import org.apache.ibatis.annotations.Select;
 
 import java.math.BigDecimal;
@@ -26,6 +27,20 @@ public interface UmsDevelopmentFundMapper {
      */
     @Select("SELECT SUM(points_total) FROM ums_development_fund")
     Integer getTotalPoints();
+
+    /**
+     * 发展基金现金流水
+     * @param payAmount
+     */
+    @Insert("INSERT INTO ums_development_fund (cash_total, updated_at) VALUES (#{payAmount}, NOW())")
+    void insertCash(BigDecimal payAmount);
+
+    /**
+     * 发展基金积分流水
+     * @param rewardPoints
+     */
+    @Insert("INSERT INTO ums_development_fund (points_total, updated_at) VALUES (#{rewardPoints}, NOW())")
+    void insertPoints(BigDecimal rewardPoints);
 }
 
 
diff --git a/mall-portal/src/main/java/com/buy507/mall/portal/service/impl/OmsPortalOrderServiceImpl.java b/mall-portal/src/main/java/com/buy507/mall/portal/service/impl/OmsPortalOrderServiceImpl.java
index f44d611..da4867b 100644
--- a/mall-portal/src/main/java/com/buy507/mall/portal/service/impl/OmsPortalOrderServiceImpl.java
+++ b/mall-portal/src/main/java/com/buy507/mall/portal/service/impl/OmsPortalOrderServiceImpl.java
@@ -140,6 +140,9 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
 	@Autowired
 	private SmsHomeNewProductMapper homeNewProductMapper;
 
+	@Autowired
+	private UmsDevelopmentFundMapper umsDevelopmentFundMapper;
+
 
     
     @Value("${kuaidi100.url}")
@@ -1788,6 +1791,10 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
 				if (list != null && !list.isEmpty()) {
 					OmsOrder order = list.get(0);
 
+					//获取订单实付金额
+					BigDecimal payAmount = order.getPayAmount();
+					//增加基金现金流水
+					umsDevelopmentFundMapper.insertCash(payAmount);
 					//获取积分专区状态
 					int pointsAreaStatus = orderMapper.selectPointsAreaStatus(outTradeNo);
 					//如果是积分专区的商品则进行积分专区相对应的逻辑
@@ -1807,7 +1814,8 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
 
 							// 更新用户积分
 							memberMapper.updateByPrimaryKey(member);
-
+							//增加基金积分流水
+							umsDevelopmentFundMapper.insertPoints(rewardPoints);
 						}
 						//订单状态：0->待付款；1->待发货；2->已发货；3->已完成；4->已关闭；5->无效订单
 						if (order != null && order.getStatus() == 0) {
-- 
2.36.6