后台

application/admin/controller/UserOrder.php

@@ -137,7 +137,7 @@ class UserOrder extends Backend
             'status'=>['require','in:1,2'],
         ]);
         Db::startTrans();
-        $order= $this->model->waitRefund()->lock(true)->find($ids);
+        $order= \app\common\model\UserOrder::waitRefund()->lock(true)->find($ids);
         if (!$order){
             $this->error('信息不存在');
         }

application/admin/model/UserOrder.php

@@ -9,6 +9,6 @@ class UserOrder extends \app\common\model\UserOrder
 {
     public function user()
     {
-        return $this->belongsTo('User', 'user_id', 'id', [], 'LEFT')->setEagerlyType(0);
+        return $this->belongsTo(\app\common\model\User::class, 'user_id', 'id', [], 'LEFT')->setEagerlyType(0);
     }
 }

application/common/model/MoneyLog.php

@@ -25,12 +25,14 @@ class MoneyLog Extends Model
     const TYPE_TAKECASH=3;
     const TYPE_SETTLE=4;
     const TYPE_PROFIT=5;
+    const TYPE_REFUND=6;
     public static $types=[
         self::TYPE_ORDER_PAY=>'订单支付',
         self::TYPE_CHARGE=>'充值',
         self::TYPE_TAKECASH=>'提现',
         self::TYPE_SETTLE=>'订单结算',
         self::TYPE_PROFIT=>'盈利',
+        self::TYPE_REFUND=>'退款',
     ];
     public function user(){
         return $this->belongsTo(User::class);
@@ -40,4 +42,20 @@ class MoneyLog Extends Model
     {
         return self::$types[$d['type']]??'-';
     }
+
+/*    protected static function init()
+    {
+        self::afterInsert(function (self $log){
+            #结算的时候新增一条盈利记录
+            if($log['type']==self::TYPE_SETTLE){
+                $order=UserOrder::where('id',$log['order_id'])->find();
+                if($order){
+                    self::create([
+                        'type'=>self::TYPE_PROFIT,
+                        'money'=>$log['money'],
+                    ]);
+                }
+            }
+        });
+    }*/
 }

application/common/model/User.php

@@ -121,20 +121,29 @@ class User extends Model
      * @param int    $user_id 会员ID
      * @param string $memo    备注
      */
-    public static function money($money, $user_id, $type,$memo)
+    public static function money($money, $user_id, $type,$memo='',$extra=[],$changeMoney=true)
     {
         $user = self::lock(true)->find($user_id);
         if ($user && $money != 0) {
-            $before = $user->money;
-            //$after = $user->money + $money;
-            $after = function_exists('bcadd') ? bcadd($user->money, $money, 2) : $user->money + $money;
-            if($after<0){
-                throw_user("余额不足");
+            if($changeMoney){
+                $before = $user->money;
+                //$after = $user->money + $money;
+                $after = function_exists('bcadd') ? bcadd($user->money, $money, 2) : $user->money + $money;
+                if($after<0){
+                    throw_user("余额不足");
+                }
+                //更新会员信息
+                $user->save(['money' => $after]);
             }
-            //更新会员信息
-            $user->save(['money' => $after]);
             //写入日志
-            MoneyLog::create(['user_id' => $user_id,'type'=>$type, 'money' => $money, 'before' => $before, 'after' => $after, 'memo' => $memo]);
+            MoneyLog::create(array_merge([
+                'user_id' => $user_id,
+                'type'=>$type,
+                'money' => $money,
+                'before' => $before??$user->money??0,
+                'after' => $after??$user->money??0,
+                'memo' => $memo,
+            ],$extra));
         }
     }
 

application/common/model/UserOrder.php

@@ -2,7 +2,7 @@
 
 namespace app\common\model;
 
-use think\Collection;
+use app\service\pay_user\PayUser;
 use think\db\Query;
 use think\Model;
 use traits\model\SoftDelete;
@@ -15,6 +15,7 @@ use traits\model\SoftDelete;
  *@property float settle_amount
  *@property array senders
  *@property array settle_info
+ *@property float profit
  */
 class UserOrder extends Model
 {
@@ -190,6 +191,7 @@ class UserOrder extends Model
         if($data['status']==1){
             $this['refund_status']=self::REFUND_STATUS_PASS;
             $this['refund_at']=time();
+            PayUser::getClass()->payment($this['refund_amount'],$this['user'],MoneyLog::TYPE_REFUND,"订单退款",['order_id'=>$this['id']]);
             $this->cancel(self::CT_REFUND,true);
         }elseif($data['status']==2){
             $this['refund_status']=self::REFUND_STATUS_REJECT;
@@ -209,6 +211,11 @@ class UserOrder extends Model
         }
         if($data['status']==1){
             $this['status']=self::STATUS_SET;
+            foreach ($this->currentSenderOrder as $senderOrder){
+                PayUser::getClass()->payment($senderOrder['fee_total'],$senderOrder['user'],MoneyLog::TYPE_SETTLE,"订单[{$this['no']}]结算",['order_id'=>$this['id']]);
+            }
+            #加一个盈利记录
+            User::money($this->profit,0,MoneyLog::TYPE_PROFIT,"订单[{$this['no']}]盈利",['order_id'=>$this['id']],false);
         }elseif($data['status']==2){
             $this['status']=self::STATUS_SET_REJECT;
         }
@@ -403,6 +410,10 @@ class UserOrder extends Model
         }
         return $total;
     }
+    /** 结算总的金额 */
+    public function getProfitAttr($v,$data){
+        return bcsub($this['real_amount'],$this->settle_info['fee_total']);
+    }
 
 
 

application/extra/site.php

@@ -50,7 +50,42 @@ return array (
   'order_refund_land' => '20',
   'order_refund_air' => '30',
   'tmap_key' => 'YV7BZ-7IFWV-GWDPV-U2C5Q-2XNT5-MNBY6',
-  'mch_key' => '',
-  'mch_cert' => '',
-  'settle_type' => '1',
+  'mch_key' => 'sadasdasdasdasdasdas',
+  'mch_cert' => '-----BEGIN CERTIFICATE-----
+MIIGNjCCBR6gAwIBAgIQB5xS/QxLmcbJVWLFXwRrfTANBgkqhkiG9w0BAQsFADBf
+MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3
+d3cuZGlnaWNlcnQuY29tMR4wHAYDVQQDExVHZW9UcnVzdCBDTiBSU0EgQ0EgRzEw
+HhcNMjAxMDIwMDAwMDAwWhcNMjExMTIwMjM1OTU5WjBrMQswCQYDVQQGEwJDTjES
+MBAGA1UECAwJ5YyX5Lqs5biCMTMwMQYDVQQKDCrljJfkuqzliJvmlrDkuZDnn6Xk
+v6Hmga/mioDmnK/mnInpmZDlhazlj7gxEzARBgNVBAMMCiouY3Nkbi5uZXQwggEi
+MA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQDSINa8+Vu0XGrqinFxCxiCmIij
+g8eEmOI8Ty3aMZjTKEkPjhHXap6HOXi9V49utfsBXD1Qzc9jzshPQ7Wr6T2U4mM3
+WG9RZx8srfNghexdOrSeGu6t3Nan+dnyhoFpvb6r/k+l7UjSBJJS2NKTr/SmnPVz
+ckD+PZg79LwSijOioQ6sHLxKuEhlS0YK1BPBNs50sjKuIV3aX7pqhruR4cIPNDQJ
+uCv6QzDDlx0hQIlDMJ+7Nn+1uUkqE3wcD3JrasJhMyIIVWMBql3Yj3WB7KpXwk24
+KcTDCds4ON6qsGl9j1IBOihFzeAPSMoicj0JjoOj9rIGXj/OKwrXvUlwOA7tAgMB
+AAGjggLgMIIC3DAfBgNVHSMEGDAWgBSRn14xFa4Qn61gwffBzKpINC8MJjAdBgNV
+HQ4EFgQUUlVPvpmLqBraQQoYFBom6GgJLJMwHwYDVR0RBBgwFoIKKi5jc2RuLm5l
+dIIIY3Nkbi5uZXQwDgYDVR0PAQH/BAQDAgWgMB0GA1UdJQQWMBQGCCsGAQUFBwMB
+BggrBgEFBQcDAjB1BgNVHR8EbjBsMDSgMqAwhi5odHRwOi8vY3JsMy5kaWdpY2Vy
+dC5jb20vR2VvVHJ1c3RDTlJTQUNBRzEuY3JsMDSgMqAwhi5odHRwOi8vY3JsNC5k
+aWdpY2VydC5jb20vR2VvVHJ1c3RDTlJTQUNBRzEuY3JsMEwGA1UdIARFMEMwNwYJ
+YIZIAYb9bAEBMCowKAYIKwYBBQUHAgEWHGh0dHBzOi8vd3d3LmRpZ2ljZXJ0LmNv
+bS9DUFMwCAYGZ4EMAQICMG8GCCsGAQUFBwEBBGMwYTAhBggrBgEFBQcwAYYVaHR0
+cDovL29jc3AuZGNvY3NwLmNuMDwGCCsGAQUFBzAChjBodHRwOi8vY3JsLmRpZ2lj
+ZXJ0LWNuLmNvbS9HZW9UcnVzdENOUlNBQ0FHMS5jcnQwDAYDVR0TAQH/BAIwADCC
+AQQGCisGAQQB1nkCBAIEgfUEgfIA8AB2APZclC/RdzAiFFQYCDCUVo7jTRMZM7/f
+DC8gC8xO8WTjAAABdUUuFtwAAAQDAEcwRQIgVdV2VLLSFbOTlPOxZbGi6aAebVx4
+eEZHsHOjY0iM59ACIQDr4v6cvn3jGSe7A5Ner/xWvin0C1aAZMviEBs5H8r6qQB2
+AFzcQ5L+5qtFRLFemtRW5hA3+9X6R9yhc5SyXub2xw7KAAABdUUuFzEAAAQDAEcw
+RQIhANzNDIqHdTd+49sZ3rTdn4x5tpRwZQNc2pQIxuf545H9AiAKd5o+kQjSsobw
+kx+3MkiZ/quO1yARSG+m4SXFucy3tTANBgkqhkiG9w0BAQsFAAOCAQEACVs0sNjt
+G3JMwvv2gIi+9q99JCsXtWiUUsLs0E5jSiY0LOlkda0h4RKEZZSGh3D88bDinBYW
+8UIBnvISnkd9TjRU/+ihMtq6yjbNTLueSluvyEB3eM+nsC3I/H5W1UQ/YhGixAx6
+rVNVKl2Czm/Af96bZ9TlCL3dBz+Nr4FwRtqBZnfd4LlX1mbv1uTpL19SQtOM1Mi6
+qMSN1vy2zH9c+mRKDcQhlGp4TD3wRteMqj+goJVuGmf4yolbgtCZ9M/iiSI49tdC
+AdO1vXr+IvrFFeLDb0hZMpW8+7OqPI8KtWxRDTgn3w/XKd6h07l+c28OPujJ4k9r
+TeVgbfx+TLDNaw==
+-----END CERTIFICATE-----',
+  'settle_type' => '2',
 );

application/service/AppBegin.php

@@ -0,0 +1,11 @@
+<?php
+namespace app\service;
+
+use app\service\pay_user\PayUser;
+
+class AppBegin{
+    public function run($params){
+        $type=config('site.settle_type');
+        PayUser::setType($type);
+    }
+}

application/service/pay_user/PayUser.php

@@ -0,0 +1,44 @@
+<?php
+namespace app\service\pay_user;
+
+use app\common\model\User;
+
+abstract class PayUser{
+    protected static $types=[
+        1=>PayUserMoney::class,
+        2=>PayUserWechat::class,
+    ];
+    protected static $type;
+
+    /**
+     * @return mixed
+     */
+    public static function getType()
+    {
+        return self::$type;
+    }
+
+    /**
+     * @param mixed $type
+     */
+    public static function setType($type): void
+    {
+        if(!$type){
+            $type=1;
+        }
+        self::$type = $type;
+    }
+
+    /**
+     * @return self
+     */
+    public static function getClass(){
+        static $class;
+        if(!$class){
+            $class=new self::$types[self::$type];
+        }
+        return $class;
+    }
+
+    abstract function payment($amount,User $user,$type,$memo,$extra=[]);
+}

application/service/pay_user/PayUserMoney.php

@@ -0,0 +1,12 @@
+<?php
+namespace app\service\pay_user;
+
+use app\common\model\User;
+
+class PayUserMoney extends PayUser {
+
+    function payment($amount, User $user,$type,$memo='', $extra = [])
+    {
+        $user::money($amount,$user['id'],$type,$memo,$extra);
+    }
+}

application/service/pay_user/PayUserWechat.php

@@ -0,0 +1,30 @@
+<?php
+namespace app\service\pay_user;
+
+use app\common\model\User;
+
+class PayUserWechat extends PayUser {
+
+    function payment($amount, User $user, $type,$memo='', $extra = [])
+    {
+        $extra['no']=order_no('p');
+        $result=payment($user)
+            ->transfer
+            ->toBalance([
+                'partner_trade_no' => $extra['no'], // 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号)
+                'openid' => $user['openid'],
+                'check_name' => 'NO_CHECK', // NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名
+                're_user_name' => '王小帅', // 如果 check_name 设置为FORCE_CHECK，则必填用户真实姓名
+                'amount' => $amount*100, // 企业付款金额，单位为分
+                'desc' => $memo, // 企业付款操作说明信息。必填
+            ]);
+        if ($result['return_code']!='SUCCESS'){
+            throw_user("付款失败：".$result['return_msg']);
+        }
+        if($result['result_code']!='SUCCESS'){
+            throw_user("付款失败：".$result['err_code_des']);
+        }
+        $extra['deal_at']=time();
+        $user::money($amount,$user['id'],$type,$memo,$extra,false);
+    }
+}

application/tags.php

@@ -14,7 +14,9 @@ return [
     // 应用初始化
     'app_init'     => [],
     // 应用开始
-    'app_begin'    => [],
+    'app_begin'    => [
+        \app\service\AppBegin::class,
+    ],
     // 应用调度
     'app_dispatch' => [
         'app\\common\\behavior\\Common',