<?php

namespace app\common\repositories\marketing;

use app\common\dao\marketing\AgentApplyDao;
use app\common\model\marketing\Agent;
use app\common\model\user\User;
use app\common\repositories\BaseRepository;
use app\common\repositories\store\order\StoreOrderCreateRepository;
use app\common\repositories\store\order\StoreOrderRepository;
use app\common\repositories\store\service\StoreServiceRepository;
use app\common\repositories\system\merchant\MerchantRepository;
use crmeb\services\LockService;
use think\facade\Db;

class AgentApplyRepository extends BaseRepository{

    protected $dao;

    public function __construct(AgentApplyDao $dao){
        $this->dao = $dao;
    }
    /**
     * Common: 公共查询模型
     * Author: wu-hui
     * Time: 2024/02/01 14:56
     * @param $search
     * @return \app\common\model\marketing\AgentApply
     */
    public function getSearchModel($search){
        return $this->dao->searchList($search);
    }
    /**
     * Common: 列表获取
     * Author: wu-hui
     * Time: 2024/02/01 15:47
     * @param array $params
     * @param int   $page
     * @param int   $limit
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getList(array $params,int $page,int $limit):array{
        $query = $this->dao->searchList($params);
        $count = $query->count();
        $list = $query->page($page,$limit)->select();

        return compact('count','list');
    }
    // 提交申请信息(同步生成订单)
    public function editApplyInfo($params){
        return Db::transaction(function() use ($params){
            // 生成申请信息
            $applyInfoKeys = array_flip((array)[
                "uid",
                "pid",
                "agent_type",
                "contact_name",
                "contact_phone",
                "province_id",
                "city_id",
                "area_id",
                "street_id",
                "address",
                "mer_name",
                "mer_class_id",
                "mer_type_id",
                "mer_images"
            ]);
            $applyInfo = array_intersect_key($params['data'], $applyInfoKeys);
            // 支付信息
            $payInfo = array_intersect_key($params['data'],array_flip((array)["pay_type","return_url"]));
            $payResult = [];
            // 根据操作类型进行对应的处理
            if($params['agentApplyId'] > 0){
                // 编辑


                debug("开发中......");

                return '成功';
            }
            else{
                // 添加  是否需要支付
                $payMoney = 0;// 默认 无需支付
                $config = app()->make(AgentRepository::class)->getConfig();
                switch ((int)$applyInfo['agent_type']) {
                    case 2: $payMoney = $config['province_money'] ?? 0;break;
                    case 3: $payMoney = $config['field_staff_money'] ?? 0;break;
                    case 4: $payMoney = $config['internal_staff_money'] ?? 0;break;
                    case 5: $payMoney = $config['operator_money'] ?? 0;break;
                    case 6: $payMoney = $config['partner_money'] ?? 0;break;
                    case 7: $payMoney = $config['mer_money'] ?? 0;break;
                    case 8: $payMoney = $config['delivery_money'] ?? 0;break;
                }
                // 判断：是否需要支付  需要支付生成订单并且获取支付信息
                $orderId = 0;// 默认 无需支付、无订单信息
                if((float)$payMoney > 0){
                    $userInfo = $params['user_info'] ?? [];
                    $payInfo['money'] = (float)$payMoney;
                    // 发起支付
                    $groupOrder = app()
                        ->make(LockService::class)
                        ->exec('online_order.create',function() use ($payInfo,$userInfo){
                            $payType = array_search($payInfo['pay_type'],StoreOrderRepository::PAY_TYPE);
                            return app()
                                ->make(StoreOrderCreateRepository::class)
                                ->onlinePayment($payType,$payInfo,$userInfo, 32);
                        });
                    $payResult = app()
                        ->make(StoreOrderRepository::class)
                        ->pay($payInfo['pay_type'],$userInfo,$groupOrder,$payInfo['return_url'],$params['is_app']);
                    // 子订单只存在一个  直接查询即可
                    $orderId = app()->make(StoreOrderRepository::class)
                        ->getSearch([])
                        ->where('group_order_id',$groupOrder->group_order_id)
                        ->value('order_id');
                }
                // 生成申请信息
                $applyInfo['order_id'] = $orderId;
                $this->dao->create($applyInfo);

                return $payResult;
            }
        });
    }
    /**
     * Common: 审核通过
     * Author: wu-hui
     * Time: 2024/02/01 17:10
     * @param $params
     * @return mixed
     */
    public function toExaminePass($params){
        return Db::transaction(function() use ($params){
            // 修改状态
            $this->dao->update($params['id'],['status'=>$params['status']]);
            // 生成代理信息
            $applyInfo = $this->getSearchModel(['id'=>$params['id']])->findOrEmpty()->toArray();
            $keys = array_flip((array)[
                "uid",
                "pid",
                "agent_type",
                "contact_name",
                "contact_phone",
                "province_id",
                "city_id",
                "area_id",
                "street_id",
                "address",
            ]);
            $insertInfo = array_intersect_key($applyInfo, $keys);
            $insertInfo['apply_id'] = $applyInfo['id'];
            $agentId = Agent::insertGetId($insertInfo);
            // 判断：如果是餐厅  生成商户信息
            if((int)$insertInfo['agent_type'] == 7){
                $password         = substr($applyInfo['contact_phone'],-6);
                $config = systemConfig(['broadcast_room_type', 'broadcast_goods_type']);
                $merchant = app()->make(MerchantRepository::class)->createMerchant([
                    'mer_name'     => $applyInfo['mer_name'],
                    'mer_phone'    => $applyInfo['contact_phone'],
                    'mer_account'  => $applyInfo['contact_phone'],
                    'category_id'  => $applyInfo['mer_class_id'],
                    'type_id'      => $applyInfo['mer_type_id'],
                    'real_name'    => $applyInfo['contact_name'],
                    'status'       => 1,
                    'is_audit'     => 1,
                    'is_bro_room'  => $config['broadcast_room_type'] == 1 ? 0 : 1,
                    'is_bro_goods' => $config['broadcast_goods_type'] == 1 ? 0 : 1,
                    'mer_password' => $password,
                    'is_margin'    => $margin['is_margin'] ?? -1,
                    'margin'       => $margin['margin'] ?? 0,
                    'agent_id'     => $agentId
                ]);
                // 存在默认管理员信息  生成管理员
                $staffUserInfo = User::where('uid', $applyInfo['uid'])->findOrEmpty()->toArray();
                $staffData = [
                    'uid'          => $applyInfo['uid'],
                    'nickname'     => $staffUserInfo['nickname'] ?? $staffUserInfo['real_name'],
                    'account'      => $applyInfo['contact_phone'],
                    'pwd'          => $password,
                    'is_open'      => 1,
                    'status'       => 1,
                    'customer'     => 1,
                    'is_verify'    => 1,
                    'is_goods'     => 1,
                    'is_user'      => 1,
                    'staff_manage' => 1,
                    'notify'       => 1,
                    'avatar'       => $staffUserInfo['avatar'] ?? '',
                    'phone'        => $applyInfo['contact_phone'],
                    'sort'         => 1,
                    'mer_id'       => $merchant->mer_id,
                    'is_manage'    => 1
                ];
                app()->make(StoreServiceRepository::class)->createInfo($staffData);
            }

        });
    }


}