精彩生活区-订单分账：向支付机构发起分账功能

app/command/GreatLifeOrderIndependentAccount.php

@@ -0,0 +1,305 @@
+<?php
+
+namespace app\command;
+
+use app\common\model\store\order\StoreOrder;
+use app\common\model\user\UserCertification;
+use app\common\repositories\merchant\order\OrderGzcRepository;
+use app\common\repositories\merchant\order\OrderMerchantRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
+use app\common\repositories\store\order\StoreOrderStatusRepository;
+use app\common\repositories\user\UserBillRepository;
+use app\common\repositories\user\UserRepository;
+use Carbon\Carbon;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\facade\Db;
+use think\facade\Log;
+
+class GreatLifeOrderIndependentAccount extends Command
+{
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('great-life-order-independent-account')
+            ->setDescription('精彩生活区订单分账');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        // @todo 精彩生活区订单分账
+        $this->doGreatLifeOrderIndependentAccount();
+    }
+
+
+    /**
+     * 精彩生活区订单分账
+     *
+     * @param $timeLimit
+     * @param $merId
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function doGreatLifeOrderIndependentAccount($timeLimit = 30, $merId = 439)
+    {
+        $time = time();
+        // 订单状态（0：待发货；1：待收货；2：待评价；3：已完成；4已申请退款；-1：已退款）5未支付 6已取消'
+        $status = [2,3];
+        // 已支付、未结算
+        $where = [
+            'paid' => 1, 'gzc' => 0, 'mer_id' => $merId, 'is_del' => 0, 'is_system_del' => 0
+        ];
+        // 普通订单
+        $cursor = Db::table('rrx_store_order')->where($where)->where('pay_type', 'in', '1,2,4')->whereIn('status', $status)->cursor();
+
+        $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
+        $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
+        $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
+        // 商户信息
+        $merchant = Db::name('merchant')->where('mer_id', $merId)->find();
+
+        /** @var StoreOrderRepository $storeOrderRepository */
+        $storeOrderRepository = app()->make(StoreOrderRepository::class);
+
+        foreach ($cursor as $key => $value) {
+            $settlement_period_time = strtotime($value['create_time']) + $timeLimit * 24 * 3600;
+            // @todo 下单后第{$timeLimit}天后可分账
+            if ($settlement_period_time >= $time) {
+                // 成本价
+                $cost = $value['cost'];
+                // 利润金额
+                $con_pri = $value['con_pri'];
+                $group_order = Db::name('store_group_order')->alias('sgo')->where('sgo.group_order_id', $value['group_order_id'])->find();
+
+                // @todo 预分账处理
+                $isSuccessed = $storeOrderRepository->prepareExecuteIndependentAccount($value, $group_order, $merchant, $value['cost'], $value['con_pri']);
+
+                Db::name("log")->insert(array('data' => '精彩生活区-订单分账：' . json_encode($value,JSON_FORCE_OBJECT)));//日志记录
+
+//                Db::transaction(function () use ($certification, $online, $pension, $OrderGzcRepository, $OrderMerchantRepository, $StoreOrderRepository) {
+//                    //新增入账明细记录
+//                    $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
+//                    $create    = [
+//                        'uid'          => $online['uid'],
+//                        'platform_no'  => $orderId,
+//                        'account_type' => $online['pay_type'] == 1 ? 3 : 2,
+//                        'user_name'    => $certification['user_name'],
+//                        'mobile'       => $certification['mobile'],
+//                        'user_card'    => $certification['user_card'],
+//                        'pension'      => $pension,
+//                        'order_type'   => 2,
+//                        'out_trade_no' => $online['order_sn']
+//                    ];
+//                    $test_user = Db::name('user')->where('uid', $online['uid'])->value('test_user');
+//                    $check     = Db::name("gzc_logs")->where("out_trade_no", $online['order_sn'])->where("order_type", 2)->count();
+//                    if ($test_user == 0 && $check <= 0) {
+//                        $OrderGzcRepository->create($create);
+//                    }
+//                    $order                  = StoreOrder::getInstance()->find($online['order_id']);
+//                    $order->gzc             = 1;
+//                    $order->save();
+//                });
+            }
+        }
+
+        // 普通订单（红包，积分，京东，佣金，复购金，养老金，贡献值）
+//        $cursor = Db::table('rrx_store_order')->where('paid', 1)->where('is_settlement', 0)->where('pay_type', 'in', '0,1,2,4')->cursor();
+//        $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
+//        $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
+//        $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
+//        foreach ($cursor as $online) {
+//            $status = $StoreOrderStatusRepository->getWhere(['order_id' => $online['order_id'], 'change_type' => 'take']);
+//            if ($online['mer_id'] == 496) {
+//                if (!in_array($online['status'], [0, 1, 2, 3])) {
+//                    continue;
+//                }
+//                if (time() < strtotime($online['pay_time']) + 3600 * 24) {
+//                    Log::info('还没有到收货后' . $timeLimit . '天');
+//                    continue;
+//                }
+//            } else {
+//                if (!in_array($online['status'], [2, 3])) {
+//                    continue;
+//                }
+//                if (Carbon::now()->modify("-{$timeLimit} days")->lt($status->change_time ?? $status['change_time'])) {
+//                    Log::info('还没有到收货后' . $timeLimit . '天');
+//                    continue;
+//                }
+//            }
+//
+//            $StoreOrderRepository = app()->make(StoreOrderRepository::class);
+//            Db::transaction(function () use ($online, $StoreOrderRepository) {
+//                $order = StoreOrder::getInstance()->find($online['order_id']);
+//                $order->is_settlement   = 1;
+//                $order->settlement_time = date('Y-m-d H:i:s');
+//                $order->save();
+//
+//                // 结算积分
+//                $user_sign_score_list = Db::name('user_sign_score')
+//                    ->where('status', -1)
+//                    ->where('order_id', $online['order_id'])
+//                    ->whereIn('type', [1, 2])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_sign_score_list as $user_sign_score) {
+//                    // 修改积分
+//                    Db::name('user')
+//                        ->where('uid', $user_sign_score['uid'])
+//                        ->inc('score', (float)$user_sign_score['reward_socre'])
+//                        ->update();
+//                    Db::name('user_sign_score')
+//                        ->where('status', -1)
+//                        ->where('id', $user_sign_score['id'])
+//                        ->update([
+//                            'status'          => 1,
+//                            'settlement_time' => date('Y-m-d H:i:s')
+//                        ]);
+//                }
+//
+//                // 结算红包
+//                $user_sign_hongbao_list = Db::name('user_sign_hongbao')
+//                    ->where('status', -1)
+//                    ->where('order_id', $online['order_id'])
+//                    ->whereIn('type', [1, 2])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_sign_hongbao_list as $user_sign_hongbao) {
+//                    // 修改红包
+//                    Db::name('user')
+//                        ->where('uid', $user_sign_hongbao['uid'])
+//                        ->inc('hongbao', (float)$user_sign_hongbao['number'])
+//                        ->update();
+//                    Db::name('user_sign_hongbao')
+//                        ->where('status', -1)
+//                        ->where('id', $user_sign_hongbao['id'])
+//                        ->update([
+//                            'status'          => 1,
+//                            'settlement_time' => date('Y-m-d H:i:s')
+//                        ]);
+//                }
+//
+//
+//                // 结算京豆
+//                $user_sign_jingdou_list = Db::name('user_sign_jingdou')
+//                    ->where('status', -1)
+//                    ->where('order_id', $online['order_id'])
+//                    ->whereIn('type', [1, 2])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_sign_jingdou_list as $user_sign_jingdou) {
+//                    // 修改京豆
+//                    Db::name('user')
+//                        ->where('uid', $user_sign_jingdou['uid'])
+//                        ->inc('jingdou', (float)$user_sign_jingdou['number'])
+//                        ->update();
+//                    Db::name('user_sign_jingdou')
+//                        ->where('status', -1)
+//                        ->where('id', $user_sign_jingdou['id'])
+//                        ->update([
+//                            'status'          => 1,
+//                            'settlement_time' => date('Y-m-d H:i:s')
+//                        ]);
+//                }
+//
+//
+//
+//                // 结算复购金
+//                $user_sign_fugou_list = Db::name('user_sign_fugou')
+//                    ->where('status', -1)
+//                    ->where('order_id', $online['order_id'])
+//                    ->whereIn('type', [1, 2])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_sign_fugou_list as $user_sign_fugou) {
+//                    // 修改复购金
+//                    Db::name('user')
+//                        ->where('uid', $user_sign_fugou['uid'])
+//                        ->inc('fugou', (float)$user_sign_fugou['number'])
+//                        ->update();
+//                    Db::name('user_sign_fugou')
+//                        ->where('status', -1)
+//                        ->where('id', $user_sign_fugou['id'])
+//                        ->update([
+//                            'status'          => 1,
+//                            'settlement_time' => date('Y-m-d H:i:s')
+//                        ]);
+//                }
+//
+//
+//                // 结算贡献值
+//                $user_sign_gongxian_list = Db::name('user_sign_gongxian')
+//                    ->where('status', -1)
+//                    ->where('order_id', $online['order_id'])
+//                    ->whereIn('type', [1, 2])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_sign_gongxian_list as $user_sign_gongxian) {
+//                    // 修改贡献值
+//                    Db::name('user')
+//                        ->where('uid', $user_sign_gongxian['uid'])
+//                        ->inc('contribute', (float)$user_sign_gongxian['number'])
+//                        ->update();
+//                    Db::name('user_sign_gongxian')
+//                        ->where('status', -1)
+//                        ->where('id', $user_sign_gongxian['id'])
+//                        ->update([
+//                            'status'          => 1,
+//                            'settlement_time' => date('Y-m-d H:i:s')
+//                        ]);
+//                }
+//
+//
+//                // 结算佣金
+//                $user_bill_list = Db::name('user_bill')
+//                    ->where('status', 0)
+//                    ->where('commission_type','<>', 5)
+//                    ->where([ 'link_id' => $online['order_id'], 'order_sn' => $online['order_sn']])
+//                    ->select()
+//                    ->toArray();
+//                foreach ($user_bill_list as $user_bill) {
+//                    if ($user_bill['commission_type'] != 5) {
+//                        if (in_array($user_bill['commission_type'], [7,12,19])) {
+//                            Db::name("merchant")
+//                                ->where("mer_id", $user_bill['mer_id'])
+//                                ->inc('brokerage_price', (float)$user_bill['number'])
+//                                ->update();
+//                        } else {
+//                            Db::name('user')
+//                                ->where('uid', $user_bill['uid'])
+//                                ->inc('brokerage_price', (float)$user_bill['number'])
+//                                ->update();
+//                        }
+//                    }
+//                    if ($online['pay_type'] == 0 && $user_bill['commission_type'] == 5) {
+//                    } else {
+//                        // 虚拟支付的养老金不修改不结算
+//                        Db::name('user_bill')
+//                            ->where('status', 0)
+//                            ->where('bill_id', $user_bill['bill_id'])
+//                            ->update([
+//                                'status'    => 1,
+//                                'take_time' => time()
+//                            ]);
+//                    }
+//                    if ($online['pay_type'] == 0 && $user_bill['commission_type'] == 5) {
+//                    } else {
+//                        // 虚拟支付的养老金不修改不结算
+//                        Db::name('user_bill')
+//                            ->where('status', 0)
+//                            ->where('bill_id', $user_bill['bill_id'])
+//                            ->update([
+//                                'status'    => 1,
+//                                'take_time' => time()
+//                            ]);
+//                    }
+//                }
+//                //按角色结算
+//                $StoreOrderRepository->close_order($online['order_id']);
+//            });
+//        }
+    }
+
+}

app/common/repositories/store/order/StoreOrderRepository.php

@@ -10499,5 +10499,107 @@ class StoreOrderRepository extends BaseRepository
         Db::name("old_user_log")->insert($inser_data);
     }
 
+    /**
+     * 预分账处理
+     *
+     * @param $order
+     * @param $group_order
+     * @param $merchant
+     * @param $merchant_profit
+     * @param $platform_profit
+     * @return bool
+     * @throws DbException
+     */
+    public function prepareExecuteIndependentAccount($order, $group_order, $merchant, $merchant_profit, $platform_profit, $platform_mer_id = 496)
+    {
+        if ($order['pay_type'] == 1) {
+            //微信
+            if ($group_order['pay_wx'] == 3) {
+                $hf_member_id = Db::name('merchant_member')->where('mer_id', $order['mer_id'])->where("type", 3)->value('member_id');
+                $api_key = 'api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
+                $type = 3;
+            } else {
+                $hf_member_id = Db::name('merchant_member')->where('mer_id', $order['mer_id'])->where("type", 2)->value('member_id');
+                $api_key = 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
+                $type = 2;
+            }
+
+            // 平台特殊账户
+            $hf_platform_member_id = Db::name('merchant_member')->where(['mer_id' => $platform_mer_id, 'type' => $type])->value('member_id');
+        } else {
+            //支付宝
+            $hf_member_id = $merchant['hf_member_id'];
+            $api_key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
+
+            // 平台特殊账户
+            $hf_platform_member_id = Db::name('merchant_member')->where(['mer_id' => $platform_mer_id, 'type' => 1])->value('member_id');
+        }
+
+        $members[] = [
+            'member_id' => $hf_member_id,
+            'amount' => $merchant_profit,
+            'fee_flag' => 'Y'
+        ];
+        if ($platform_profit > 0) {
+            $members[] = [
+                'member_id' => $hf_platform_member_id,
+                'amount' => $platform_profit,
+                'fee_flag' => 'N'
+            ];
+        }
 
+        $requestId = ShouxinyiApiRequest::getOrderNumber('split');
+        $params = [
+            'payment_id' => $group_order['hf_pay_id'],
+            'order_no' => $requestId,
+            'confirm_amt' => $group_order['pay_price'],
+            'div_members' => $members
+        ];
+
+        $params['api_key'] = $api_key;
+
+        // 记录分账订单
+        $this->recordIndependentAccount($order['mer_id'], $platform_mer_id, $group_order, $requestId, $merchant_profit, $platform_profit);
+
+        Db::name("log")->insert(array('data' => '汇付分账参数-----' . json_encode($params, JSON_FORCE_OBJECT)));//日志记录
+        $res = $this->payment_confirm_create_traits($params);
+        Db::name("log")->insert(array('data' => '汇付分账结果-----' . json_encode($res, JSON_FORCE_OBJECT)));//日志记录
+        if ($res['status'] == 'succeeded') {
+            Db::name("store_split_order")->where('requestId', $requestId)->update(['status' => 1, 'hf_pay_id' => $res['id']]);
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * 记录分账订单
+     *
+     * @param $member_id
+     * @param $platform_member_id
+     * @param $group_order
+     * @param $requestId
+     * @param $merchant_profit
+     * @param $platform_profit
+     * @return void
+     */
+    private function recordIndependentAccount($member_id, $platform_member_id, $group_order, $requestId, $merchant_profit, $platform_profit)
+    {
+        $insertData = [
+            [
+                'mid' => $member_id,
+                'requestId' => $requestId,
+                'group_order_id' => $group_order['group_order_sn'],
+                'splitAmount' => $merchant_profit,
+                'status' => 0
+            ],
+            [
+                'mid' => $platform_member_id,
+                'requestId' => $requestId,
+                'group_order_id' => $group_order['group_order_sn'],
+                'splitAmount' => $platform_profit,
+                'status' => 0
+            ],
+        ];
+        Db::name("store_split_order")->insertAll($insertData);
+    }
 }