话费分账逻辑

app/command/HuafeiOrderIndependentAccount.php

@@ -0,0 +1,87 @@
+<?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 HuafeiOrderIndependentAccount extends Command
+{
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('huafei-order-independent-account')
+            ->setDescription('话费订单分账');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        // @todo 精彩生活区订单分账
+        $this->doHuafeiOrderIndependentAccount();
+    }
+
+    /**
+     * 会员专区、精彩生活区订单分账
+     *
+     * @param $merId
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    private function doHuafeiOrderIndependentAccount($timeLimit = 1)
+    {
+        $dst_mer_id = systemConfig('mer_365');
+
+        // 商户信息
+        $merchants = [];
+
+        $time = time();
+        // 订单状态（0：待发货；1：待收货；2：待评价；3：已完成；4已申请退款；-1：已退款）5未支付 6已取消'
+        $status = [2];
+        // 普通订单
+        $cursor = Db::table('rrx_store_order')->where('is_independentaccount', 0)->whereIn('status', $status)->cursor();
+
+        /** @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) {
+                $merchants['496'] = Db::name('merchant')->where('mer_id', 496)->find();
+                $order_huafei_hf = Db::name('order_huafei_hf')->where('order_no', $value['order_sn'])->find();
+                if(!$order_huafei_hf) continue;
+                $value['mer_id'] = 496;
+                $order_huafei_hf['mer_id'] = 496;
+
+                // 分账账号 496：表示{会员专区}账户，分账到{会员专区}账户
+                $independentAccount = $storeOrderRepository->getIndependentAccountHuafei($order_huafei_hf, $dst_mer_id, $merchants['496']['hf_member_id']);
+
+                // @todo 预分账处理 分账到{会员专区}账户，故：hf_platform_member_id 为入账账户
+                $isSuccessed = $storeOrderRepository->prepareExecuteIndependentAccountHuafei(
+                    $value, $order_huafei_hf, $independentAccount['api_key'], $independentAccount['hf_platform_member_id'], '', $value['pay_price'], 0
+                );
+
+                if ($isSuccessed) {
+                    Db::name("log")->insert(array('data' => '话费-订单分账：' . json_encode($value, JSON_FORCE_OBJECT)));//日志记录
+                    Db::table('rrx_store_order')->where('order_sn', $value['order_sn'])->update(['is_independentaccount' => 1]);
+                }
+            }
+        }
+    }
+
+}

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

@@ -10547,6 +10547,40 @@ class StoreOrderRepository extends BaseRepository
         return compact('hf_member_id', 'hf_platform_member_id', 'api_key');
     }
 
+
+    /**
+     * 获取分账账号信息话费专用
+     *
+     * @param $order
+     * @param $dst_mer_id
+     * @param $alhf_member_id
+     * @return array
+     */
+    public function getIndependentAccountHuafei($order, $dst_mer_id, $alhf_member_id)
+    {
+        if ($order['pay_type'] == 1) {
+            $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;
+
+            // 平台特殊账户
+            $hf_platform_member_id = Db::name('merchant_member')->where(['mer_id' => $dst_mer_id, 'type' => $type])->value('member_id');
+        } else {
+            //支付宝
+            $hf_member_id = $alhf_member_id;
+            $api_key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
+
+            // 平台特殊账户
+            $hf_platform_member_id = Db::name('merchant_member')->where(['mer_id' => $dst_mer_id, 'type' => 1])->value('member_id');
+        }
+
+        return compact('hf_member_id', 'hf_platform_member_id', 'api_key');
+    }
+
+
+
+
+
     /**
      * 预分账处理
      *
@@ -10599,6 +10633,63 @@ class StoreOrderRepository extends BaseRepository
         return false;
     }
 
+
+
+
+    /**
+     * 预分账处理话费专用
+     *
+     * @param $order
+     * @param $api_key
+     * @param $hf_member_id
+     * @param $hf_platform_member_id
+     * @param $merchant_profit
+     * @param $platform_profit
+     * @param $dst_mer_id
+     * @return bool
+     * @throws DbException
+     */
+    public function prepareExecuteIndependentAccountHuafei($order, $group_order, $api_key, $hf_member_id, $hf_platform_member_id, $merchant_profit, $platform_profit, $dst_mer_id = 0)
+    {
+        $members[] = [
+            'member_id' => $hf_member_id,
+            'amount' => $merchant_profit,
+            'fee_flag' => 'Y'
+        ];
+        if (!empty($hf_platform_member_id) && ($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'], $dst_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;
+    }
+
+
+
+
     /**
      * 记录分账订单
      *