<?php

namespace App\Services;

use App\Facades\CommonService;
use App\Facades\WechatService;
use App\Http\Controllers\H5\OrderController;
use App\Jobs\UnfreezeCommission;
use App\Models\Group;
use App\Models\GroupUser;
use App\Models\OfflineOrder;
use App\Models\Order;
use App\Models\PartnerCommission;
use App\Models\PartnerWallet;
use App\Models\ServiceRole;
use App\Models\ServiceRoleOrder;
use App\Models\ServiceRoleUser;
use App\Models\ServiceUser;
use App\Models\ServiceUserBindRole;
use App\Models\User;
use Exception;
use Illuminate\Support\Facades\DB;
use cccdl\yunxin_sdk\Im\Team;
use Illuminate\Support\Facades\Log;

class OfflineOrderService
{
    public function createOfflineOrder(array $data, $user_id = 0)
    {
        // 是否是隐私用户
        if (isset($data["is_privacy"])) {
            User::where("id", $user_id)->update(["is_privacy" => $data["is_privacy"]]);
        }

        // 创建订单
        $tradeNo = CommonService::getTradeNO();
        $order = Order::create([
            'user_id' => $user_id,
            'type' => 'SERVICE',
            'type_id' => 1,
            'price' => $data['price'],
            'pay_status' => 'PAID',
            'trade_no' => $tradeNo,
            'name' => $data['name'],
            'area_code' => $data['area_code'] ?? 86,
            "status" => Order::NOTSTART_STATUS,
            "service_status" => "NOINFO",
            //            'mobile' => aesDecryptCBC($data['mobile']),
            'mobile' => ctype_digit($data['mobile']) ? $data['mobile'] : aesDecryptCBC($data['mobile']),
            'agency_id' => $data['agency_id'] ?? null,
            'desc' => '友福健康服务',
            'is_hook' => 1,
            "payment_id" => $data["payment_id"] ?? 1,
            "check_pay_status" => $data["check_pay_status"] ?? 0,
            "check_pay_img" => $data["check_pay_img"] ?? null,
            "sign_type" => (isset($data["check_pay_status"]) && $data["check_pay_status"] == 1) ? 1 : 0,
        ]);

        $contract_no = 0;
        if (isset($data['contract_no']) && !empty($data['contract_no'])) {
            $contract_no = $data['contract_no'];
        }
        if ($contract_no == 0 && !empty($order->mobile)) {
            $contract_no = $order->mobile;
        }
        // 创建线下订单
        $offline_order = OfflineOrder::create([
            'order_id' => $order->id,
            'name' => $order->name,
            'area_code' => $data['area_code'] ?? 86,
            'mobile' => $order->mobile,
            'contract_no' => $contract_no,
            'pay_type' => $data['pay_type'] ?? 1,
            'bank_name' => $data['bank_name'] ?? null,
            'bank_num' => $data['bank_num'] ?? null,
            'agency_id' => $data['agency_id'] ?? null,
            'price' => $order->price ?? 0,
            "operate_user_id" => auth()->id(),
            "operate_user_name" => auth()->user()->name,
        ]);

        //创建群记录
        $chat_id = $data['chat_id'] ?? null;
        Group::create(['name' => $order->name . '服务群', 'order_id' => $order->id, 'chat_id' => $chat_id]);

        if (config('app.env') == 'production') {
            //生成用户绑定二维码
            $scene = 'order_id=' . $order->id;
            $page = 'pages/offlineOrder/bindUser';
            $qrcode = WechatService::getMPQrcode($scene, $page);
            //更新线下订单信息
            $offline_order->bind_qrcode = $qrcode;
            $offline_order->save();
        }

        $this->insertRoleData($chat_id, $order->id);

        DB::commit();
        return $offline_order;

    }

    public function getOrderList($keywords = '', $status = '', $agency_id = '', $page_size = 15)
    {
        $orders = OfflineOrder::with([
            'main_order' => function ($order) {
                $order->with([
                    'service_role' => function ($serviceRole) {
                        $serviceRole->with(['serviceUser:user_id,name,mobile'])->select('order_id', 'role_id', 'user_id');
                    }
                ]);
            },
            "main_order.user:id,name,mobile,avatar,is_privacy",
            'agency:id,name,mobile',
            'order_commission' => function ($commission) {
                $commission->with(['service_user:user_id,name,mobile'])->select('id', 'order_id', 'role', 'user_id');
            },
            'agreement:order_id,number,sign_date,quota_id',
            'agreement.quotaInfo:id,agency_id,collaborator_id,num',
            'agreement.quotaInfo.collaboratorInfo:id,avatar,name,mobile',
            'agreement.quotaInfo.agencyInfo:id,grade,pro_id,city_id,province,city'
        ])
            ->when($keywords, function ($query) use ($keywords) {
                $query->where(function ($query) use ($keywords) {
                    $query->where('name', 'like', '%' . $keywords . '%')->orWhere('mobile', 'like', '%' . $keywords . '%');
                });
            })
            ->when(!empty($status), function ($query) use ($status) {
                $query->whereHas('main_order', function ($query) use ($status) {
                    $query->where('status', $status);
                });
            })
            //            ->when($agency_id,function ($query) use ($agency_id) {
//                $query->where('agency_id',$agency_id);
//            })
            ->when($agency_id, function ($query) use ($agency_id) {
                return $query->whereHas('agreement.quotaInfo', function ($q) use ($agency_id) {
                    $q->where('agency_id', $agency_id);
                });
            })
            ->orderByDesc('id');
        $is_export = request()->input('is_export');
        if ($is_export) {
            $orders = $orders->get();
            return $orders;
        }
        $orders = $orders->paginate($page_size);
        return $orders;
    }

    /**
     * 更新线下订单
     * @param array $data
     * @return void
     * @throws \Exception
     */
    public function updateOfflineOrder(array $data, $order_id)
    {
        //获取订单状态
        $offline_order = OfflineOrder::with('main_order')->findOrFail($order_id);
        if ($offline_order->main_order->status != 'NOTSTART')
            throw new \Exception('订单已开始服务,不可修改');

        // 计算佣金
//        $commission_type = $data['subcommission_type'];
//        $commission_val  = $data['subcommission_val'];
//        $data['commission_amount'] = $this->getCommissionAmount($commission_type,$commission_val,$offline_order->price);

        try {
            DB::beginTransaction();
            //更新线下订单
            $offline_order->update($data);
            //更新对应主订单
            $order_data = [
                'name' => $offline_order->name,
                'mobile' => $offline_order->mobile,
                'price' => $offline_order->price,
                'agency_id' => $offline_order->agency_id,
            ];

            $offline_order->main_order()->update($order_data);
            DB::commit();

            return $offline_order;
        } catch (\Exception $exception) {
            DB::rollBack();
            throw new \Exception($exception->getMessage(), $exception->getCode());
        }
    }

    private function getCommissionAmount($type, $val, $price)
    {
        // 计算佣金
        if ($type === 1) {
            // 比例分佣
            $commission_percentage = bcdiv($val, 100, 4);
            $commission_amount = bcmul($price, $commission_percentage, 2);
        } else {
            // 固定金额
            $commission_amount = $val;
        }
        return $commission_amount;
    }

    /**
     * 查看是否存在角色数据,存在则绑定角色
     * @param $chat_id
     * @param $order_id
     */
    public function insertRoleData($chat_id, $order_id, $service_user_id = null)
    {
        if ($service_user_id) {
            $service_user = ServiceUser::where("user_id", $service_user_id)->first();
        } else {
            //查看是否绑定企业微信
            $work_wechat_user = session('work_wechat_user');
            $work_user_id = $work_wechat_user['raw']['userid'] ?? 0;
            $service_user = ServiceUser::where("work_user_id", $work_user_id)->first();
        }
        if ($service_user) {
            $roleIds = ServiceUserBindRole::where('chat_id', $chat_id)
                ->where('user_id', $service_user->user_id)
                ->select('role_id')
                ->get()->toArray();
            //如果存在数据,则绑定订单
            if ($roleIds) {
                foreach ($roleIds as $value) {
                    $ServiceRoleOrder = new ServiceRoleOrder();
                    $ServiceRoleUser = new ServiceRoleUser();
                    $ServiceRoleOrder->insertRoleOrder($value['role_id'], $service_user, $order_id);
                    $ServiceRoleUser->insertRoleUserData($service_user, $value['role_id']);
                }
            }
        }
    }

    public function AutoServiceJoinGroup($imChatId, $groupId, $orderId, $userId)
    {
        Log::info("自动分配用户订单角色");
        // 主教练id
        $mainCoachRoleId = 1;
        $mainCoachUserId = $this->getOrderService($userId, $mainCoachRoleId);
        Log::info("主教练用户id：" . $mainCoachUserId);
        if ($mainCoachUserId) {
            $this->joinServiceGroup($imChatId, $groupId, $orderId, $mainCoachRoleId, $mainCoachUserId);
        }

        // 客服
        $customerRoleId = 3;
        $customerUserId = $this->getOrderService($userId, $customerRoleId);
        Log::info("客服用户id：" . $customerUserId);
        if ($customerUserId) {
            $this->joinServiceGroup($imChatId, $groupId, $orderId, $customerRoleId, $customerUserId);
        }
    }

    public function joinServiceGroup($imChatId, $groupId, $orderId, $roleId, $userId)
    {
        DB::beginTransaction();
        try {
            // 订单绑定服务人员
            $roleOrder = ServiceRoleOrder::where(["order_id" => $orderId, "user_id" => $userId, "role_id" => $roleId])->first();
            if (empty($roleOrder)) {
                ServiceRoleOrder::create([
                    "order_id" => $orderId,
                    "user_id" => $userId,
                    "role_id" => $roleId
                ]);
            }

            // 服务人员加入群聊
            $groupUser = GroupUser::where(["user_id" => $userId, "group_id" => $groupId])->first();
            if (empty($groupUser)) {
                $roleName = ServiceRole::where("id", $roleId)->value("name");
                GroupUser::create([
                    "user_id" => $userId,
                    "group_id" => $groupId,
                    "status" => 0,
                    "type" => 0,
                    "role_id" => $roleId,
                    "role_name" => $roleName,
                ]);
            }

            $group_info = Group::where('id', $groupId)->first();
            $owner_ac_cid = make_wangyiyun_accid($group_info->owner_id);
            // 加入im群聊
            $user_accid = make_wangyiyun_accid($userId);
            $imTeam = new Team(config('chat.im.app_id'), appSecrt: config('chat.im.app_secret'));
            $imTeam->add($imChatId, $owner_ac_cid, [$user_accid], 0, '邀请进群');

            // 修改群角色
            $map = [];
            $map['role'] = [$roleId];
            $options = ['custom' => json_encode($map)];
            $imTeam->updateTeamNick($imChatId, $owner_ac_cid, $user_accid, $options);
            DB::commit();
        } catch (Exception $e) {
            DB::rollBack();
            Log::error($e->getMessage());
        }
    }

    /**
     * 获取服务人员id(轮训)
     * @param mixed $userId
     * @param mixed $roleId
     * @return void
     */
    public function getOrderService($userId, $roleId): int
    {
        $userIds = [];
        switch ($roleId) {
            case 1:
                if ($userId == 3740 || $userId == 6)
                    return 1;
                $userIds = [218, 178, 175, 176];
                // $userIds = [153, 152, 11043, 1]; // 测试
                break;
            case 3:
                if ($userId == 3740 || $userId == 6)
                    return 7;
                $userIds = [181, 177, 184];
                // $userIds = [7, 3306]; // 测试
                break;
        }

        $serviceUserId = $this->getLastServiceUserId($roleId, $userIds);
        return $serviceUserId;
    }

    public function getLastServiceUserId($roleId, $userIds): int
    {
        $serviceUserId = 0;
        if ($roleId != 1 && $roleId != 3)
            return $serviceUserId;


        if (count($userIds) == 0)
            return $serviceUserId;

        $serviceRoleOrder = ServiceRoleOrder::where("role_id", $roleId)->whereIn("user_id", $userIds)->orderByDesc("id")->first();
        if (!$serviceRoleOrder)
            return $serviceUserId;

        $serviceUserId = $this->findIndex($userIds, $serviceRoleOrder->user_id);
        return $serviceUserId;
    }

    public function findIndex($userIds, $userId): int
    {
        Log::info("查询服务人员id");
        Log::info(json_encode($userIds));
        Log::info($userId);
        if (!in_array($userId, $userIds))
            return $userIds[0];
        foreach ($userIds as $key => $item) {
            if ($item == $userId) {
                if ($key == count($userIds) - 1)
                    return $userIds[0];
                return $userIds[$key + 1];
            }
        }
        return $userIds[0];
    }
}