<?php
// +----------------------------------------------------------------------
// | 麦沃德科技赋能开发者，助力商协会发展
// +----------------------------------------------------------------------
// | Copyright (c) 2017～2024  www.wdsxh.cn    All rights reserved.
// +----------------------------------------------------------------------
// | 沃德商协会系统并不是自由软件，不加密，并不代表开源，未经许可不可自由转售和商用
// +----------------------------------------------------------------------
// | Author: MY WORLD Team <bd@maiwd.cn>   www.maiwd.cn
// +----------------------------------------------------------------------
namespace app\api\controller\wdsxh\activity;

use app\admin\model\wdsxh\activity\ActivityConfig;
use app\api\model\wdsxh\activity\Order;
use app\api\model\wdsxh\activity\Refund;
use app\api\model\wdsxh\member\Member;
use app\api\model\wdsxh\user\Wechat;
use app\api\model\wdsxh\UserWechat;
use app\common\controller\Api;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\exception\ValidateException;

/**
 * Class Activity
 * Desc  活动控制器
 * Create on 2024/3/11 16:24
 * Create by wangyafang
 */
class Activity extends Api
{
    protected $noNeedLogin = ['index','update_activity_state','details','activity_config'];
    protected $noNeedRight = ['*'];
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\api\model\wdsxh\activity\Activity();
    }

    /*
     * desc: 活动列表
     * time: 2024-3-11 16:38
     * */
    public function index()
    {
        if(!$this->request->isGet()) {
            $this->error('请求类型错误');
        }
        $param = $this->request->get();
        $where = [];

        $expired_activity_show = (new ActivityConfig())->value('expired_activity_show');
        if ($expired_activity_show == 1) {
            $where['state'] = array('in',['1','2','3']);
        } else {
            $where['state'] = array('in',['1','2']);
        }

        $where['status'] = array('eq','normal');

        if(isset($param['keywords']) && !empty($param['keywords'])) {
            $where['name'] = array('like','%'.$param['keywords'].'%');
        }
        if(isset($param['state']) && !empty($param['state'])) {
            $where['state'] = array('eq',$param['state']);
        }
        $page = isset($param['page']) ? $param['page'] : '';
        $limit = isset($param['limit']) ? $param['limit'] : 10;
        $count = $this->model->where($where)->count();
        $order = 'weigh desc,id desc';

        $data = $this->model
            ->where($where)
            ->page($page,$limit)
            ->field('id,name,start_time,address,images,organizing_method,activity_auth')
            ->order($order)
            ->select();

        foreach ($data as $k=>&$v) {
            $v->week = $this->getTimeWeek($v['start_time']);
            $v->start_time = date('m/d H:i',$v->start_time);
            $images = explode(',',$v->images);
            $v->images = $images[0];
        }

        $this->success('请求成功',['total'=>$count,'data'=>$data]);
    }

    public function details()
    {
        if(!$this->request->isGet()) {
            $this->error('请求类型错误');
        }
        $id   = $this->request->get('id');
        $activity = $this->model
            ->where('id',$id)
            ->field([
                'id', 'images', 'start_time', 'end_time', 'name', 'fees',
                'state' => 'activity_state', 'contacts', 'mobile',
                'organizing_method', 'url', 'address', 'longitude',
                'latitude', 'content', 'is_verifying', 'refund',
                'apply_time', 'activity_auth', 'points_status', 'points',
                'apply_field_state', 'apply_limit_number', 'non_member_registration_status'
            ])
            ->find();
        if (!$activity) {
            $this->error('活动不存在');
        }

        $data = $activity->toArray();
        // 如果活动未结束，则根据当前时间校验活动状态并更新状态
        if ($data['activity_state'] < 3) {
            $now = time();
            // 当前时间小于报名截止时间，状态流转处于：报名中
            if ($now < $data['apply_time']) $data['actitity_state_trans'] = 1;
            // 当前时间大于等于报名截止时间小于开始时间，状态流转处于：未开始
            if ($now >= $data['apply_time'] && $now < $data['start_time']) $data['actitity_state_trans'] = 2;
            // 当前时间大于等于开始时间小于等于结束时间，状态流转处于：进行中
            if ($now >= $data['start_time'] && $now <= $data['end_time']) {
                $data['actitity_state_trans'] = 3;
                // 如果活动未结束，则根据当前时间校验活动状态并更新状态
                if ($data['activity_state'] != 2) {
                    $activity->state = $data['activity_state'] = 2;
                    $activity->save();
                }
            }
            // 当前时间大于结束时间，状态流转处于：已结束
            if ($now > $data['end_time']) {
                $data['actitity_state_trans'] = 4;
                // 如果活动已结束，则根据当前时间更新状态
                if ($data['activity_state'] != 3) {
                    $activity->state = $data['activity_state'] = 3;
                    $activity->save();
                }
            }
        } else {
            // 活动结束，状态流转就一直处理：已结束
            $data['actitity_state_trans'] = 4;
        }

        if ($this->auth->isLogin()) {
            $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');
            $activityApplyObj = (new \app\api\model\wdsxh\activity\ActivityApply())
                ->where('wechat_id',$wechat_id)
                ->where('activity_id',$id)
                ->order('id desc')
                ->find();
            if (!$activityApplyObj) {
                $data['pay_state'] = '1';
                $data['apply_id'] = '';
                $data['reject'] = '';
            } else {
                $data['check_in_status'] = $activityApplyObj['check_in_status'];
                $data['pay_state'] = $activityApplyObj['state'];
                $data['apply_id'] = $activityApplyObj['id'];
                $activityRefundObj = (new Refund())
                    ->where('activity_id',$id)
                    ->where('wechat_id',$wechat_id)
                    ->where('state','3')
                    ->order('id desc')
                    ->find();
                $data['reject'] = $activityRefundObj ? $activityRefundObj['reject'] : '';
            }
        } else {
            $data['pay_state'] = '1';
            $data['apply_id'] = '';
            $data['reject'] = '';
        }

        if ($data['points_status'] == 2) {
            unset($data['points']);
        }

        $activityApplyModel = new \app\api\model\wdsxh\activity\ActivityApply();
        $data['apply_count'] = $activityApplyModel->where('activity_id', $id)->where('state',2)->count();
        $apply_list = $activityApplyModel->where('activity_id', $id)
            ->where('state',2)
            ->alias('apply')
            ->order('apply.createtime desc')
            ->join('wdsxh_member member', 'member.id = apply.member_id')
            ->field('member.avatar member_avatar')
            ->limit(10)
            ->select();
        if (!empty($apply_list)) {
            foreach ($apply_list as &$v) {
                $v->member_avatar = wdsxh_full_url($v->member_avatar);
            }
        }
        $data['apply_list'] = $apply_list;

        if ($this->auth->isLogin()) {
            $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');
            $activityApplyObj = (new \app\api\model\wdsxh\activity\ActivityApply())
                ->where('activity_id', $id)
                ->where('wechat_id',$wechat_id)
                ->where('state','2')
                ->find();
            if ($activityApplyObj) {
                $apply_status = 1;
            } else {
                $apply_status = 2;
            }
        } else {
            $apply_status = 2;
        }
        $data['apply_status'] = $apply_status;

        if ($this->auth->isLogin()) {
            $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');
            $activityApplyObj = (new \app\api\model\wdsxh\activity\ActivityApply())
                ->where('activity_id', $id)
                ->where('wechat_id',$wechat_id)
                ->where('state','1')
                ->find();
            if ($activityApplyObj && !empty($activityApplyObj['field_data'])) {
                $apply_info_fill_state = 1;
            } else {
                $apply_info_fill_state = 2;
            }
        } else {
            $apply_info_fill_state = 2;
        }
        $data['apply_info_fill_state'] = $apply_info_fill_state;

        if (!empty($data['apply_limit_number']) && $data['apply_limit_number'] > 0) {
            $apply_count = (new \app\api\model\wdsxh\activity\ActivityApply())->where('activity_id', $id)
                ->where('state',2)
                ->count();
            if ($data['apply_limit_number'] > $apply_count) {
                $data['apply_limit_number'] = $data['apply_limit_number'] - $apply_count;
            } else {
                $data['apply_limit_number'] = 0;
            }
        }

        $this->success('请求成功',$data);
    }

    public function getTimeWeek($time, $i = 0) {
        $weekarray = array("日","一", "二", "三", "四", "五", "六");
        $week = $weekarray[date("w",$time)];
        return "周".$week;
    }

    /*
     * desc: 会员活动列表
     * time: 2024-3-11 17:38
     * */
    public function user_index()
    {
        $page=$this->request->param('page',1);
        $limit=$this->request->param('limit',10);
        $payState=$this->request->param('pay_state',0);//报名状态
        $activityState=$this->request->param('activity_state',0);
        try {
            $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');
            $where=array(
                'ActivityApply.wechat_id'=>$wechat_id
            );
            if(!empty($payState)){
                $where['ActivityApply.state'] = $payState;
            }

            $activityMap = array();
            if(!empty($activityState)){
                $activityMap['state']=$activityState;
            }
            $applyModel = new \app\api\model\wdsxh\activity\ActivityApply();
            $count = $applyModel->hasWhere('activity',$activityMap)->where($where)->count();
            $list = $applyModel->hasWhere('activity',$activityMap)->page($page,$limit)->where($where)->order('id desc')->select();
            $activityOrderModel = new Order();

            foreach ($list as $k=>&$v) {
                $v->pay_state = $v->state;
                $activityObj = $this->model->get($v->activity_id);
                $orderObj = $activityOrderModel
                    ->where('activity_id',$v->activity_id)
                    ->where('apply_id',$v->id)
                    ->where('wechat_id',$v->wechat_id)
                    ->where('member_id',$v->member_id)
                    ->order('id desc')
                    ->limit(1)
                    ->find();
                $v->order_no = $orderObj ? $orderObj['order_no'] : '';
                $v->name = $activityObj['name'];
                $images = explode(',',$activityObj['images']);
                $v->images = $images[0];
                $v->week = $this->getTimeWeek($activityObj['start_time']);
                $v->start_time = date('m/d H:i',$activityObj['start_time']);
                $v->address = $activityObj->address;
                $v->fees = $orderObj ? $orderObj['pay_amount'] : '';
                $v->organizing_method = $activityObj['organizing_method'];
                $v->activity_state = $activityObj['state'];
                // 如果活动未结束，则根据当前时间校验活动状态并更新状态
                if ($v->activity_state < 3) {
                    $now = time();
                    // 当前时间小于报名截止时间，状态流转处于：报名中
                    if ($now < $activityObj['apply_time']) $v->actitity_state_trans = 1;
                    // 当前时间大于等于报名截止时间小于开始时间，状态流转处于：未开始
                    if ($now >= $activityObj['apply_time'] && $now < $activityObj['start_time']) $v->actitity_state_trans = 2;
                    // 当前时间大于等于开始时间小于等于结束时间，状态流转处于：进行中
                    if ($now >= $activityObj['start_time'] && $now <= $activityObj['end_time']) {
                        $v->actitity_state_trans = 3;
                        // 如果活动未结束，则根据当前时间校验活动状态并更新状态
                        if ($activityObj['state'] != 2) {
                            $activityObj->state = $v->activity_state = 2;
                            $activityObj->save();
                        }
                    }
                    // 当前时间大于结束时间，状态流转处于：已结束
                    if ($now > $activityObj['end_time']) {
                        $v->actitity_state_trans = 4;
                        // 如果活动已结束，则根据当前时间更新状态
                        if ($activityObj['state'] != 3) {
                            $activityObj->state = $v->activity_state = 3;
                            $activityObj->save();
                        }
                    }
                } else {
                    // 活动结束，状态流转就一直处理：已结束
                    $v->actitity_state_trans = 4;
                }
                $v->refund = $activityObj['refund'];
                $v->url = $activityObj['url'];
                $v->is_verifying = $activityObj['is_verifying'];
                $v->verification_method = $activityObj['verification_method'];

                $v->hidden(['wechat_id','member_id','createtime','state']);
                unset($orderObj);
                unset($activityObj);
            }
            $this->success('请求成功',['total'=>$count,'data'=>$list]);
        } catch (ValidateException|PDOException|Exception $e)  {
            $this->error($e->getMessage());
        }
    }

    /*
     * desc: 申请退款
     * time: 2024-3-11 16:38
     * */
    public function apply_refund()
    {
        if(!$this->request->isPost()) {
            $this->error('请求类型错误');
        }
        $param = $this->request->post();
        $result = $this->validate($param,'app\api\validate\wdsxh\activity\Refund.apply_refund');
        if(true !== $result){
            // 验证失败 输出错误信息
            $this->error($result);
        }

        $activityObj = $this->model->get($param['activity_id']);
        if(!$activityObj){
            $this->error('活动信息不存在');
        }
        if ($activityObj['refund'] == 0) {
            $this->error('此活动无法退款');
        }
        if ($activityObj && $activityObj['state'] == '2') {
            $this->error('活动进行中，无法退款');
        }
        if ($activityObj && $activityObj['state'] == '3') {
            $this->error('活动已结束，无法退款');
        }
        $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');

        $refundModel = new Refund();
        $refundObj = $refundModel->where('activity_id',$param['activity_id'])
            ->where('apply_id',$param['apply_id'])
            ->find();
        if ($refundObj && $refundObj['wechat_id'] != $wechat_id) {
            $this->error('不是此用户下的活动，无法退款');
        }
        $activityApplyObj = (new \app\api\model\wdsxh\activity\ActivityApply())->get($param['apply_id']);
        $orderObj = (new Order())->where('activity_id',$param['activity_id'])
            ->where('apply_id',$param['apply_id'])
            ->where('wechat_id',$wechat_id)
            ->where('member_id',$activityApplyObj['member_id'])
            ->where('paid','2')
            ->order('id desc')
            ->limit(1)
            ->find();
        if (!$orderObj) {
            $this->error('订单支付信息不存在');
        }
        if($orderObj['pay_amount'] == 0.00){
            $this->error('订单0元，无法退款');
        }

        if ($refundObj && $refundObj['state'] == '1') {
            $this->error('已申请退款，请勿重复提交');
        }
        $applyObj = (new \app\api\model\wdsxh\activity\ActivityApply())->get($param['apply_id']);

        if ($refundObj) {
            Db::startTrans();
            try{
                $refundObj->state = '1';
                $refundObj->reject = '';
                $refundObj->save();
                $applyObj->state = '3';
                $applyObj->save();
                // 提交事务
                Db::commit();
            } catch (\Exception $e) {
                // 回滚事务
                Db::rollback();
                $this->error($e->getMessage());
            }
            $this->success('提交成功');
        } else {
            Db::startTrans();
            try{
                $refund_data = array(
                    'activity_id'=> $param['activity_id'],
                    'apply_id'=> $param['apply_id'],
                    'wechat_id' => $activityApplyObj['wechat_id'],
                    'member_id'=>$activityApplyObj['member_id'],
                    'order_id'=>$orderObj['id'],
                );
                $refundModel->data($refund_data);
                $refundModel->allowField(true)->save();
                $applyObj->state = '3';
                $applyObj->save();
                // 提交事务
                Db::commit();
            } catch (\Exception $e) {
                // 回滚事务
                Db::rollback();
                $this->error($e->getMessage());
            }
            $this->success('提交成功');
        }
    }

    /*
     * desc: 参会凭证
     * time: 2024-3-130 9:46
     * */
    public function attendance_voucher()
    {
        if(!$this->request->isGet()) {
            $this->error('请求类型错误');
        }
        $id = $this->request->get('activity_id');
        $activityObj = $this->model
            ->where('id',$id)
            ->field('id,name activity_name,
            address')
            ->find();

        if (!$activityObj) {
            $this->error('活动不存在');
        }

        $wechat_id = (new UserWechat())->where('user_id',$this->auth->id)->value('id');
        $activityArray = $activityObj->toArray();
        $memberObj = (new Member())->where('wechat_id',$wechat_id)
            ->field('name member_name,avatar member_avatar,mobile,
            type,member_level_name,type,company_name,organize_name')
            ->find();
        if ($memberObj) {
            $memberObj->member_avatar = wdsxh_full_url($memberObj->member_avatar);
            $memberArray = $memberObj->toArray();
            $data = array_merge($activityArray,$memberArray);
        } else {
            $memberObj = (new UserWechat())->where('id',$wechat_id)
                ->field('nickname member_name,avatar member_avatar,mobile')
                ->find();


            $memberObj->member_avatar = wdsxh_full_url($memberObj->member_avatar);
            $memberObj['member_level_name'] = '普通用户';
            $memberObj['company_name'] = '';
            $memberObj['organize_name'] = '';
            $memberArray = $memberObj->toArray();
            $data = array_merge($activityArray,$memberArray);
        }


        $data['wechat_id'] = $wechat_id;

        $this->success('请求成功',$data);
    }

    /**
     * Desc 更新活动状态
     * Create on 2025/1/20 15:22
     * Create by wangyafang
     */
    public function update_activity_state()
    {
        $now = time();
        // 更新为进行中状态
        $applyData = $this->model->where('state','1')->where('apply_time','elt',$now)->column('id');
        if (!empty($applyData)) {
            $this->model->where('id','in',$applyData)->update(['state'=>'2']);
        }
        // 更新为已结束状态（遍历更新以触发 afterUpdate 事件）
        $endList = $this->model
            ->where('end_time','elt',$now)
            ->where('state','<>','3')
            ->select();
        if (!empty($endList)) {
            foreach ($endList as $activity) {
                $activity->state = '3';
                $activity->save();
            }
        }

        $this->success('请求成功');
    }

    /**
     * Desc 接龙配置
     * Create on 2025/8/8 10:04
     * Create by wangyafang
     */
    public function activity_config()
    {
        if(!$this->request->isGet()) {
            $this->error('请求类型错误');
        }
        $id = $this->request->get('id');
        if (empty($id)) {
            $this->error('参数错误');
        }
        $activityObj = $this->model->get($id);
        if (!$activityObj) {
            $this->error('活动数据不存在');
        }
        $is_status = $activityObj['activity_auth'];

        if ($is_status == 2){
            if ($this->auth->isLogin()) {
                $user_id = $this->auth->id;
                $wechat_id = (new Wechat())->where('user_id',$user_id)->value('id');
                $current_date = date('Y-m-d',time());
                $member = (new Member())->where('wechat_id',$wechat_id)->where('expire_time','>=',$current_date)->find();
                if ($member) {
                    $is_status = 1;
                }
            }
        }
        $this->success('请求成功',['show_status'=>$is_status]);
    }
}