php/app/command/GzcAddByBillCommand.php

<?php

namespace app\command;

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\user\UserRepository;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Db;
use think\facade\Log;

class GzcAddByBillCommand extends Command
{
    protected function configure()
    {
        // 配置命令名称及描述
        $this->setName('gzcAddByBill')
            ->setDescription('从bill表中查询未提交到公证处的养老金记录，并提交公证处');
    }

    protected function execute(Input $input, Output $output)
    {
        // 在这里执行任务的具体内容
        $output->writeln('定时任务执行中...');

        $nowTime = time();
        $this->billGzcAdd($nowTime);

        $output->writeln('定时任务执行完成');
    }

    /**
     * 线下支付订单公证处IN10入账
     * @param $nowTime
     * author: php迷途小书童
     * created: 2021/3/20 9:26
     */
    public function billGzcAdd($nowTime)
    {
        $OrderGzcRepository      = app()->make(OrderGzcRepository::class);
        $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
        $StoreOrderRepository    = app()->make(StoreOrderRepository::class);
        $testUserIdList = [];
        /** @var UserRepository $userRepository */
        $userRepository = app()->make(UserRepository::class);
        try {
            $userIdData = $userRepository->selectWhere(['test_user' => 1], 'uid')->toArray();
            if (!empty($userIdData)) {
                $testUserIdList = array_column($userIdData, 'uid');
            }
        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {

        }

        try {
            $cursor = Db::name('user_bill')
                ->where('status', 1)
                ->where('is_gzc', 0)
                ->where('commission_type', 5)
                ->whereNotIn('uid', $testUserIdList)
                ->select();
        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {

        }

        if(!empty($cursor)) {
            foreach ($cursor as $bill) {
                $type_shop = $bill['type_shop'] ?? 0;
                switch ($type_shop){
                    case "0":
                        $online = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
                        break;
                    case "1":
                        $online = Db::table('rrx_order_pdd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "2":
                        $online =  Db::table('rrx_order_vip')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "3":
                        $online = Db::table('rrx_order_su')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "4":
                        $online = '';
                        break;
                    case "5":
                        $online = Db::table('rrx_order_tb')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "6":
                        $online = Db::table('rrx_order_jd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "7":
                        $online = '';
                        break;
                    case "8":
                        $online = '';
                        break;
                    case "9":
                        $online = Db::table('rrx_order_huafei')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                        break;
                    case "10":
                        $online = Db::table('rrx_order_merchant')
                            ->where('uid', $bill['uid'])
                            ->where('out_trade_no', $bill['order_sn'])
                            ->where('paid', 1)
                            ->where('status', 1)
                            ->find();
                        if (!empty($online)) {
                            $online['order_sn'] = $online['out_trade_no'];
                        }
                        break;
                    default:
                        $online = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
                }
                if (!$online) {
                    Log::info($bill['uid'] . '查询不到订单');
                    continue;
                }

                $certification = UserCertification::getInstance()->where('uid', $bill['uid'])->find();
                if (!$certification) {
                    Log::info($online['uid'] . '没有实名认证');
                    continue;
                }

                $pension = $bill['number'] ?? 0;
                if ($pension <= 0) {
                    Log::info($online['order_sn'] . 'pension' . $pension);
                    continue;
                }

                //新增入账明细记录
                $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
                $create    = [
                    'uid'          => $online['uid'],
                    'platform_no'  => $orderId,
                    'account_type' => 1,
                    'user_name'    => $certification['user_name'],
                    'mobile'       => $certification['mobile'],
                    'user_card'    => $certification['user_card'],
                    'pension'      => $pension,
                    'order_type'   => $type_shop,
                    'out_trade_no' => $online['order_sn'],
                    'link_id'=> $bill['bill_id']
                ];
                $test_user = Db::name('user')->where('uid', $online['uid'])->value('test_user');
                $check     = Db::name("gzc_logs")->where("link_id", $bill['bill_id'])->where("order_type", $type_shop)->count();
                if ($test_user == 0 && $check <= 0) {
                    $OrderGzcRepository->create($create);
                    Db::name('user_bill')
                        ->where('bill_id', $bill['bill_id'])
                        ->where('commission_type', 5)
                        ->update([
                            'is_gzc'          => 1,
                            'gzc'             => 1
                        ]);
                }
            }
        }
    }
}