<?php
/**
 * This service file is part of item.
 *
 * @author   ctexthuang
 * @contact  ctexthuang@qq.com
 */

declare(strict_types=1);

namespace App\Service\Api\Coupon;

use App\Constants\Common\CouponCode;
use App\Exception\ErrException;
use App\Extend\DateUtil;
use App\Model\CouponDispenseLog;
use App\Model\CouponDispenseUser;
use App\Model\UserCoupon;
use App\Service\Api\BaseService;
use Hyperf\DbConnection\Db;
use Hyperf\Di\Annotation\Inject;

class HomePopupsService extends BaseService
{
    /**
     * @var CouponDispenseLog
     */
    #[Inject]
    protected CouponDispenseLog $couponDispenseLogModel;

    /**
     * @var UserCoupon
     */
    #[Inject]
    protected UserCoupon $userCouponModel;

    /**
     * @var array|array[]
     */
    protected array $res = [
        'can_receive_ids' => [],
        'coupon_info' => []
    ];

    /**
     * @return array
     */
    public function handle(): array
    {
        $data = $this->couponDispenseLogModel->getNoReceiveCount();

        if (empty($data)) return $this->return->success('success',$this->res);

        $allDispenseIds = $this->userCouponModel->getReceiveCountByUserIds($this->userId,$data);

        $canReceive = array_unique(array_diff($data,$allDispenseIds));

        if (empty($canReceive)) return $this->return->success('success',$this->res);

        $this->getInfo($canReceive);

        return $this->return->success('success',$this->res);
    }

    /**
     * @param array $canReceive
     * @return void
     */
    private function getInfo(array $canReceive): void
    {
        $list = $this->couponDispenseLogModel->getListByIds($canReceive);
        if (empty($list)) return;

        $destroyDispenseData = [];

        foreach ($list as $item) {
            $endTime = null;
            $validityValue = json_decode($item['validity_time_value'],true);
            switch ($item['validity_time_type']) {
                case CouponCode::VALIDITY_TIME_TYPE_CYCLE:
                    $endTime = date('Y-m-d H:i:s', time() + ($validityValue['day_num'] * DateUtil::DAY));
                    break;
                case CouponCode::VALIDITY_TIME_TYPE_FIX:
                    $endTime = $validityValue['end_time'] ?? null;
                    break;
            }

            //有效期不存在或者到期销毁当前分发逻辑
            if (($endTime ?? date('Y-m-d H:i:s')) < date('Y-m-d H:i:s')) {
                $destroyDispenseData[] = $item['id'];
                continue;
            }

            $oneData = [
                'coupon_template_id' => $item['coupon_template_id'],
                'coupon_name' => $item['coupon_name'],
                'coupon_dispense_id' => $item['id'],
            ];

            $copies = array_map(function () use ($oneData) {
                return $oneData;
            }, array_fill(0, $item['item_count'], null));
            $this->res['coupon_info'] = array_merge($this->res['coupon_info'], $copies);

            $this->res['can_receive_ids'][] = $item['id'];
        }

        if (!empty($destroyDispenseData)) {
            (new CouponDispenseLog)->whereIn('id',$destroyDispenseData)->update([
                'status' => CouponCode::DISPENSE_NULL,
            ]);
        }

//        return $this->res;
    }

//    /**
//     * @param array $data
//     * @return array
//     */
//    private function receive(array $data): array
//    {
//        $list = $this->couponDispenseLogModel->getListByIds($data);
//        if (empty($list)) return [];
//
//        $insertData = [];
//        $appointUpdateData = [];
//        $allUpdateData =[];
//        $destroyDispenseData = [];
//
//        $resCouponData = [];
//
//        foreach ($list as $item) {
//            $validityTime = [];
//            switch ($item['validity_time_type']) {
//                case CouponCode::VALIDITY_TIME_TYPE_CYCLE:
//                    $validityValue = json_decode($item['validity_time_value'],true);
//                    $validityTime = [
//                        'start_time' => date('Y-m-d H:i:s'),
//                        'end_time' => date('Y-m-d H:i:s', time() + ($validityValue['day_num'] * DateUtil::DAY))
//                    ];
//                    break;
//                case CouponCode::VALIDITY_TIME_TYPE_FIX:
//                    $validityTime = json_decode($item['validity_time_value'],true);
//                    break;
//            }
//
//            //有效期不存在或者到期销毁当前分发逻辑
//            if (($validityTime['end_time'] ?? date('Y-m-d H:i:s')) < date('Y-m-d H:i:s')) {
//                $destroyDispenseData[] = $item['id'];
//                continue;
//            }
//
//            $oneData = [
//                'user_id' => $this->userId,
//                'coupon_template_id' => $item['coupon_template_id'],
//                'coupon_name' => $item['coupon_name'],
//                'coupon_dispense_id' => $item['id'],
//                'status' => CouponCode::COUPON_STATUS_UNUSED,
//                'validity_start_time' => $validityTime['start_time'] ?? date('Y-m-d H:i:s', time()),
//                'validity_end_time' => $validityTime['end_time'] ?? date('Y-m-d H:i:s', time()),
//            ];
//
//            $copies = array_map(function () use ($oneData) {
//                return $oneData;
//            }, array_fill(0, $item['item_count'], null));
//            $insertData = array_merge($insertData, $copies);
//
//            $oneData['count'] = $item['item_count'];
//
//            if ($item['appoint_group'] != CouponCode::DISPENSE_APPOINT_GROUP_ALL_PEOPLE) {
//                $appointUpdateData[] = [
//                    'coupon_dispense_id' => $item['id'],
////                    'user_id' => $this->userId,
//                    'receive_count' => $item['receive_count'],
//                    'is_receive' => CouponCode::DISPENSE_STATUS_IS_RECEIVED
//                ];
//            }
//
//            $allUpdateData[] = [
//                'id' => $item['id'],
//                'receive_count' => $item['receive_count'] +$item['item_count'],
//            ];
//
//            $resCouponData[] = $oneData;
//        }
//
//        if (empty($allUpdateData)) return [];
//
//        if (!empty($appointUpdateData)) {
//            $appointList = $this->couponDispenseUserModel->where('user_id',$this->userId)->whereIn('id',array_column($appointUpdateData,'coupon_dispense_id'))->pluck('id','coupon_dispense_id');
//
//            foreach ($appointUpdateData as &$item) {
//                $item['id'] = $appointList[$item['coupon_dispense_id']];
//            }
//        }
//
//        Db::transaction(function () use($allUpdateData,$appointUpdateData,$insertData,$destroyDispenseData) {
//            $appointUpdateFlag = true;
//            if (!empty($appointUpdateData)) {
//                $userUpdateModel = new CouponDispenseUser();
//                foreach (array_chunk($appointUpdateData, 500) as $chunk) {
//                    foreach ($chunk as $item) {
//                        $appointUpdateFlag = $userUpdateModel
//                            ->where('id',$item['id'])
//                            ->update(array_diff_key($item, ['coupon_dispense_id' => null,'id' => null]));
//                        if (!$appointUpdateFlag) break;
//                    }
//                    if (!$appointUpdateFlag) break;
//                }
////                $appointUpdateFlag = (new CouponDispenseUser)->update($appointUpdateData);
//            }
//
//            $destroyDispenseFlag = true;
//            if (!empty($destroyDispenseData)) {
//                $destroyDispenseFlag = (new CouponDispenseLog)->whereIn('id',$destroyDispenseData)->update([
//                    'status' => CouponCode::DISPENSE_NULL,
//                ]);
//            }
//
////            $allUpdateFlag = (new CouponDispenseLog)->update($allUpdateData);
//            $allUpdateFlag = true;
//            $updateModel = new CouponDispenseLog();
//            foreach (array_chunk($allUpdateData, 500) as $chunk) {
//                foreach ($chunk as $item) {
//                    $allUpdateFlag = $updateModel->where('id',$item['id'])->update(array_diff_key($item, ['id' => null]));
//                    if (!$allUpdateFlag) break;
//                }
//                if (!$allUpdateFlag) break;
//            }
//
//            $insertFlag = (new UserCoupon)->insert($insertData);
//
//            if (!$allUpdateFlag || !$appointUpdateFlag || !$insertFlag || !$destroyDispenseFlag) throw new ErrException('领取失败');
//        });
//
//        return $resCouponData;
//    }

//    private function returnNullRes(): array
//    {
//        return $this->return->success();
//    }
}