diff --git a/app/common/logic/CapitalFlowLogic.php b/app/common/logic/CapitalFlowLogic.php
index 361ee124c..a49be021e 100644
--- a/app/common/logic/CapitalFlowLogic.php
+++ b/app/common/logic/CapitalFlowLogic.php
@@ -40,7 +40,7 @@ class CapitalFlowLogic extends BaseLogic
         $model->amount = $amount;
         if($type){
             $model->before_balance = $this->user['purchase_funds'];
-            $model->balance =  bcsub($this->user['purchase_funds'], $amount, 2);
+            $model->balance =  bcadd($this->user['purchase_funds'], $amount, 2);
         }else{
             $model->before_balance = $this->user['now_money'];
             $model->balance = bcadd($this->user['now_money'], $amount, 2);
diff --git a/app/common/logic/PayNotifyLogic.php b/app/common/logic/PayNotifyLogic.php
index 7d626adc1..8e82076eb 100644
--- a/app/common/logic/PayNotifyLogic.php
+++ b/app/common/logic/PayNotifyLogic.php
@@ -426,12 +426,15 @@ class PayNotifyLogic extends BaseLogic
             $orderRe->remarks = '';
             $orderRe->save();
             $purchase_funds = User::where('id',$orderRe['uid'])->value('purchase_funds');
+            $user =  User::where('id',$orderRe['uid'])->find();
+            $capitalFlowDao = new CapitalFlowLogic($user);
             if($purchase_funds >= $orderRe['price']){
                 User::where('id',$orderRe['uid'])->dec('purchase_funds',$orderRe['price'])->update();
+                $capitalFlowDao->userExpense('user_order_purchase_pay', 'order', $orderRe['id'], $orderRe['pay_price'], '', 1, $orderRe['store_id']);
             }else{
                 User::where('id',$orderRe['uid'])->dec('purchase_funds',$purchase_funds)->update();
+                $capitalFlowDao->userExpense('user_order_purchase_pay', 'order', $orderRe['id'], $purchase_funds, '', 1, $orderRe['store_id']);
             }
-
             self::descUserSing($orderRe);
             return true;
         }