gaoyixia/application/common/model/Activity.php

<?php
namespace app\common\model;
use app\common\service\Elastic;
use app\common\service\UserSynth;
use think\Model;
// 活动
class Activity extends Model
{
    // 主办方信息
    public function sponsor()
    {
        return $this->belongsTo('ActivitySponsor','sponsor_id')->where('status',1)->where('is_deleted',0);
    }

    // 价格设置
    public function priceList()
    {
        return $this->hasMany('ActivityPrice','act_id')->where('is_deleted',0);
    }
    // 报名模板
    public function templateInfo()
    {
        return $this->hasOne('ActivityTemplate','template_id')->where('status',1)->where('is_deleted',0);
    }



    public static function getAuth($user_id,$app_name,$app_logo)
    {
        $ret_val = [];
        if(!$user_id) return ['app_name'=>$app_name,'app_logo'=>$app_logo];
        $user_info = User::where('id',$user_id)->field('name,headimg')->find();
        $ret_val['app_name']  = $user_info ? $user_info->name : '';
        $ret_val['app_logo']  = $user_info ? $user_info->headimg : '';
        return $ret_val;
    }

    // es数据添加或更新
    public static function esAdd($id,$info = [])
    {
        if(empty($info)) $info = self::where('id',$id)->find()->toArray();
        $index = config('text.es_index');
        $properties  =  Elastic::getProperties($index);
        $body_field = array_keys($properties);
        $data = [];
        foreach ($body_field as $v) {
            if($v == 'module'){
                $data[$v] = 'activity';
            }else if( $v == 'level'){
                $data[$v] = 0;
            }else{
                $data[$v] = isset($info[$v]) ? $info[$v]:'';
            }
        }
        $data['create_at']    = isset($info['create_at'])   ? strtotime($info['create_at']) : time();
        $data['release_time'] = isset($info['release_time']) ? strtotime($info['release_time']) : time();
        return Elastic::add($index,'activity_'.$info['id'],$data);
    }

    //活动取消
    public static function activityCancel($act_id)
    {
        $act_title = static::where('id',$act_id)->value('title');
        $order_list = ActivityApply::field('id')->where('act_id',$act_id)->where('pay_state',1)->where('refund_state','<>','5')->select()->toArray();
        foreach ($order_list as $order_info) {
            $info_url =  'https://'.$_SERVER['HTTP_HOST'].'/dist/#/activity_order_info?id='.$order_info['id'];
            $message = '很抱歉，由于不可抗因素，您报名的《'.$act_title."》活动主办方已取消，您支付的有效金额已原来返回，订单对应所有门票已失效，给您带来的不
便，敬请谅解!期待与您再次相遇!";//点击<a href=\"$info_url\">查看详情</a>";
            $res = \app\common\service\Activity::orderRefundApply($order_info['id'],2,1);
            // 退款
            if($res['code'] == 200 && $order_info['pay_type'] != 9) {
                ActivityApply::where('id',$order_info['id'])->update(['refund_state'=>2]);
                \app\common\service\Activity::orderRefundMoney($order_info['id'],$message);
            }else if($order_info['pay_type'] == 9) {
                UserMessage::sendUserMessage($order_info['user_id'],'activity',4,2,0,$order_info['id'],$message,$order_info['id']);
            }
            ActivityApplyItem::where('apply_id',$order_info['id'])->update(['status'=>3]);
        }

    }

    //  活动变更
    public static function activityChange($id,$title,$extend = [])
    {
        if(isset($extend['end_time']) &&  strtotime($extend['end_time']) <  time()) return false;
        $all_list = ActivityApplyItem::where(['act_id'=>$id,'sh_status'=>1,'is_hx'=>0])->group('phone')->select();
        foreach ($all_list  as $v) {
            try {
                // 短信通知
                if($v['phone_pre'] == '86' && $v['phone']) UserSynth::phoneMessageSend($v['phone'],2,['ActivityName'=>$title, 'time'=>$extend['start_time'], 'adress'=>$extend['address']]);
                // 邮件通知
                if( $v['email']) UserSynth::emailSend($v['email'],$title);
            }catch (\Exception $e) {

            }

        }

    }



}