ball/app/api/service/DouYinService.php

<?php

namespace app\api\service;

use app\adminapi\logic\external\ExternalConsultationLogic;
use app\common\model\Config;
use app\common\model\external\DouyinOrder;
use app\common\model\external\ExternalConsultation;
use app\common\model\external\ExternalConsultationOrder;
use app\common\model\goods\Goods;
use app\common\model\user\User;
use app\common\model\user\UserAuth;
use app\common\model\works\ServiceWork;
use app\common\service\ConfigService;
use app\common\service\FileService;
use think\facade\Db;
use think\facade\Log;

class DouYinService
{
    protected static int $terminal = \app\common\enum\user\UserTerminalEnum::DOUYIN;
    protected static int $external_platform_id = 7;
    public static function register(array $params)
    {
        $userSn = User::createUserSn();
        $params['password'] = !empty($params['password'])?$params['password']:rand(100000,999999);
        $passwordSalt = \think\facade\Config::get('project.unique_identification');
        $password = create_password($params['password'], $passwordSalt);
        $avatar = ConfigService::get('default_image', 'user_avatar');
        $user = User::create([
            'sn' => $userSn,
            'avatar' => $avatar,
            'nickname' => '用户' . $userSn,
            'account' => $params['account'],
            'mobile' => !empty($params['mobile'])?$params['mobile']:'',
            'password' => $password,
            'channel' => self::$terminal,
            'user_type' => $params['user_type']??0,
        ]);

        return $user;
    }
    public static function phoneLogin(array $params)
    {
        try {
            $where = ['mobile' => $params['mobile']];
            $params['account'] = $params['mobile'];
            $user = User::where($where)->findOrEmpty();
            if ($user->isEmpty()) {
                //直接注册用户
                $params['channel'] = self::$terminal;
                $user = self::register($params);
            }
            //更新登录信息
            $user->login_time = time();
            $user->login_ip = request()->ip();
            $user->save();

            $userInfo = UserTokenService::setToken($user->id, self::$terminal);

            //返回登录信息
            $avatar = $user->avatar ?: Config::get('project.default_image.user_avatar');
            $avatar = FileService::getFileUrl($avatar);

            return [
                'nickname' => $userInfo['nickname'],
                'sn' => $userInfo['sn'],
                'mobile' => $userInfo['mobile'],
                'avatar' => $avatar,
                'token' => $userInfo['token'],
            ];
        } catch (\Exception $e) {
            throw new \Exception($e->getMessage());
        }
    }

    /**
     * 提交订单
     * @param array $params
     * @return array|false
     */
    public static function submitOrder($params)
    {
        Db::startTrans();
        try {

            $goods = Goods::findOrEmpty($params['goods_id']);
            if($goods->isEmpty()){
                throw new \Exception('产品不存在！');
            }
            if(empty($params['user_info']['mobile'])){
                throw new \Exception('请先补充您的联系方式后在提交订单');
            }
            // TODO tmp防抖1m
            $isExist = DouyinOrder::where(['user_id'=>$params['user_id'],'goods_id'=>$goods['goods_id']])->where('create_time','>',(time() - 60))->findOrEmpty();
            if(!$isExist->isEmpty()){
                throw new \Exception('请勿重复下单！');
            }
            $quantity = $params['quantity']??1;
            //生成订单
            $create_data = [
                'user_id' => $params['user_id'],
                'mobile' => $params['user_info']['mobile'],
                'title' => $goods['goods_name'],

                'goods_id'=>$goods['goods_id'],
                'unit_price' => $goods['service_fee'],
                'quantity' => $quantity,
                'total_amount' => $goods['service_fee'] * $quantity,
                'order_number' => generate_sn(DouyinOrder::class, 'order_number'),
            ];
            $order = DouyinOrder::create($create_data);
            Db::commit();
            return $order['id'];
        } catch (\Exception $e) {
            Db::rollback();
            throw new \Exception($e->getMessage());
        }
    }

    public static function payNotify($params)
    {
            Log::write($params,JSON_UNESCAPED_UNICODE);

            // 查询抖音订单是否完成支付

            if ($params['trade_state'] === 'SUCCESS') {
                $transaction_id = '';
                $paid_amount = '';
                $out_trade_no = $params['out_trade_no'];
                $order = DouyinOrder::where('order_number', $out_trade_no)->findOrEmpty();
                if(!$order->isEmpty()){
                    // 更新充值订单状态
                    $order->transaction_id = $transaction_id;
                    $order->order_status = 2;
                    $order->pay_time = time();
                    $order->paid_amount = $paid_amount;

                    $user = User::where('id',$order->user_id)->findOrEmpty()->toArray();
                    $form_detail = [
                        'user_name' => $user['real_name']??'',
                        'mobile' => $user['mobile'],
                        'transaction_id' => $transaction_id,
                        'out_trade_no' => $out_trade_no,
                        'paid_amount' => $paid_amount,
                    ];
                    $consultation = ExternalConsultation::create([
                        'external_platform_id' => self::$external_platform_id,
                        'form_detail' => $form_detail,
                        'user_name' => $user['real_name']??'',
                        'mobile' => $user['mobile'],
                        'goods_id' => $order->goods_id,
                        'amount' => $paid_amount
                    ]);
                    $order->consultation_id = $consultation['id'];
                    $order->save();
                    return true;
                }
            }
            return false;
    }
    public static function reservation($params)
    {
        // $params['order_number']
        Db::startTrans();
        try {
            $order = DouyinOrder::where('order_number', $params['order_number'])->findOrEmpty();
            if(!$order->isEmpty()){
                $consultation = ExternalConsultation::where('id', $order->consultation_id)->findOrEmpty()->toArray();
                $consultation['user_address'] = $params['user_address'];
                $consultation['lon'] = $params['lon'];
                $consultation['lat'] = $params['lat'];
                $consultation['appointment_time'] = $params['appointment_time'];
                $result = ExternalConsultationLogic::order($consultation);
                if (false === $result) {
                    throw new \Exception('预约失败');
                }
                $consultationOrder = ExternalConsultationOrder::where('consultation_id', $order->consultation_id)->where('goods_id', $order->goods_id)->where('amount', $order->paid_amount)
                    ->findOrEmpty()->toArray();
                $work_status = ServiceWork::where('id', $consultationOrder['work_id'])->value('work_status');
                $order->work_id = $consultationOrder['work_id'];
                $order->fulfillment_status = $work_status;
                $order->save();
            }
            Db::commit();
            return $order['id'];
        } catch (\Exception $e) {
            Db::rollback();
            throw new \Exception($e->getMessage());
        }
    }

}