gaoyixia/application/common/service/UserSynth.php

<?php
namespace app\common\service;
use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use app\common\model\ActivityApplyItem;
use app\common\model\ArticleIntro;
use app\common\model\BillApply;
use app\common\model\BillHeader;
use app\common\model\DatumIntro;
use app\common\model\DeliveryAddress;
use app\common\model\SupplierGoods;
use app\common\model\UserSearch;
use app\common\model\UserVitality;
use app\common\model\VideoIntro;
use think\cache\driver\Redis;
use think\Db;
use Dm\Request\V20151123 as Dm;
/**
 * 会员身综合管理
 * Class UserIdentity
 */
class UserSynth extends SerBase
{
    public static  $ret_val = ['code' => 200 , 'msg'=>'ok','extend'=>''];
    // 会员活跃度
    public static function vitality($user_id,$type)
    {
        if($type === false) return false;
        $type++;
        $redis = new Redis();
        $check_key = date('Y-m-d').'_'.$user_id;
        // 当天是否登录
        if(!$redis->get($check_key)) {
            $redis->set($check_key,86400);
            $year = date('Y');
            $month = date('m');
            $day = date('d');
            $vitality_info= [
                'user_id'=>$user_id,
                'year'=>$year,
                'month'=>$month,
                'day'=>$day,
                'day_time'=>date('Y-m-d'),
                'create_at'=>date('Y-m-d H:i:s'),
                'type'=>$type
            ];
            UserVitality::create($vitality_info);
        }
    }


    /**
     * 创建申请发票申请记录【申请开票】
     * @param $user_id
     * @param $order_id
     * @param $order_type 订单类型
     * @param $bill_info  发票抬头id||发票详情
     * @param $add_id     售货地址id
     * @param $send_type  物流类型1点子发票2纸质发票
     * @param $remark     备注
     * @param $order_pay  订单是否完成支付
     * @return array
     */
    public static function buildBillApply($user_id, $order_id, $order_type,$bill_info,$add_id,$send_type,$remark,$order_pay = 1)
    {
        $order_table = [
            1=>'level_order',// 会员订单
            2=>'store_order',// 商品订单
            3=>'activity_apply',// 活动订单
        ];
        Db::startTrans();
        try {
            $apply_info = [
                'order_id' => $order_id,
                'table_name' => $order_table[$order_type],
                'user_id' => $user_id,
                'remark' => $remark,
                'send_type' =>  $send_type,
                'order_type' => $order_type,
                'create_at' => date("Y-m-d H:i:s"),
                'order_pay' => $order_pay,
            ];
            if($add_id) {
                $add_info = DeliveryAddress::field('id,pro_name,city_name,county_name,mer_name,detail,phone,name')->where('user_id',$user_id)->where('id',$add_id)->find();
                $apply_info['address_info'] = json_encode($add_info->toArray());
            }

            if(is_array($bill_info)){
                $apply_info['header']  = $bill_info['header'];
                $apply_info['type']  = $bill_info['type'];
                $apply_info['email']  =$bill_info['email'];
               // $apply_info['bank']  = $bill_info['bank'];
               // $apply_info['card_no']  = $bill_info['card_no'];
               // $apply_info['phone']  = $bill_info['phone'];
                $apply_info['identify_number']  = $bill_info['identify_number'];
               // $apply_info['address']  = $bill_info['address'];
            }else if($bill_info){
                $bill_header = BillHeader::where('id',$bill_info) ->where('user_id',$user_id)->find();
                if(empty($bill_header)) self::exception('发票抬头有误');
                $apply_info['header']  = $bill_header->header;
                $apply_info['email']  = $bill_header->email;
                $apply_info['type']  = $bill_header->type;
                $apply_info['identify_number']  = $bill_header->identify_number;
            }
            $order_info = Db::name($order_table[$order_type])
                ->where('user_id',$user_id)
                ->where('pay_state',1)
                ->where('id',$order_id)
                ->find();
            if(empty($order_info) && $order_type != 3)self::exception('订单有误');

            $check_info = BillApply::where('user_id',$user_id)
                ->where('order_id',$order_id)
                ->where('is_deleted',0)
                ->where('table_name',$order_table[$order_type])
                ->find();
            if(!empty($check_info) &&  $check_info->status == 1) self::exception('已开票');
            $apply_info = BillApply::create($apply_info);
            static::$ret_val['extend'] = $apply_info->id ;
            Db::commit();
        }catch (\Exception $e) {
            Db::rollback();
            static::$ret_val['code'] = 201 ;
            static::$ret_val['msg'] = $e->getMessage();
        }
        return static::$ret_val;
    }


    // 获取所有模块设置
    public static function getAllModuleTitle()
    {
        // 视频
        $video  = VideoIntro::field('id,title,IF(id,\'video\',0) module')->with(['videoArr'=>function($query){
            return $query->field('id,title,video_id');
        }])->where(['is_deleted'=>0])->order('id desc')->select()->toArray();
        array_walk($video,function (&$v){
            $v['children'] = $v['video_arr'];
            unset($v['video_arr']);
        });
        // 资料
        $datum  = DatumIntro::with(['urlArr'=>function($query){
            return $query->field('id,title,datum_id');
        }])->where(['is_deleted'=>0])->field('id,title,IF(id,\'datum\',0) module')->order('id desc')->select()->toArray();
        array_walk($datum,function (&$v){
            $v['children'] = $v['url_arr'];
            unset($v['url_arr']);
        });
        // 图文
        $article = ArticleIntro::with(['itemChildren'=>function($query){
            return $query->field('id,title,article_id');
        }])->field('id,title,IF(id,\'article\',0) module')->where(['is_deleted'=>0])->order('id asc')->select()->toArray();
        array_walk($article,function (&$v){
            $v['children'] = $v['item_children'];
            unset($v['item_children']);
        });
        $supplier_goods =  SupplierGoods::alias('g')->field('g.id,g.supplier_id,g.name title,IF(g.id,\'supplier\',0) module')->where(['g.is_deleted'=>0])
            ->leftJoin('Supplier s', 's.id = g.supplier_id')->select()->toArray();
        return array_merge($video,$datum,$article,$supplier_goods);
       // return compact(['video','datum','article','supplier_goods']);
    }

    // 推荐
    public static function getRecommendList($user_id,$module,$page,$page_num)
    {
          $module_set = [
              'press'=>[
                  'type'=> 4,
                  'table'=>'dd_press',
                  'index_field'=>'name',
                  'select_field'=>'a.id,a.title,a.label,a.images,a.read_num,a.transmit_num,a.user_id,a.create_at,IFNULL(is_recommend,0) is_recommend',
              ]
          ];
        $search_log =  UserSearch::getSearchTitle($user_id,$module_set[$module]['type']);
        $search_arr = [];
        $where_str = 'b.id > 0';
        foreach ($search_log as $t){
            $search_arr[] =  " b.$module_set[$module][\"index_field\"] like '".'%'.$t."%'" .' ';
            $search_arr[] =  " b.label like '".'%'.$t."%'" .' ';
        }
        if(!empty($search_arr)) $where_str  =  implode(' OR ',$search_arr);
          switch ($module)
          {
              case "press":

                  break;
          }


    }


    // 短信发送
    public static function phoneMessageSend($phone,$key,$data)
    {
        $mud_arr = [];
        $mud_arr[0] = [
            'name'=> '活动举办 会前1天',//模板名称
            'tem_code'=> 'SMS_460985703',// 模板code
            'param' => [
                'ActivityName'=>isset($data['ActivityName']) ? $data['ActivityName'] : '' ,
                'time'=>isset($data['time']) ? $data['time'] : '' ,
                'adress'=>isset($data['adress']) ? $data['adress'] : '' ,
                'url'=> isset($data['url']) ? $data['url'] : '' ,
            ]
        ];
        $mud_arr[1] = [
            'name'=> '免费票有审核，审核成功',//模板名称
            'tem_code'=> 'SMS_460970747',// 模板code
            'param' => [
                'ActivityName'=>isset($data['ActivityName']) ? $data['ActivityName'] : '' ,
                'url'=> isset($data['url']) ? $data['url'] : '' ,
            ]
        ];
        $mud_arr[2] = [
            'name'=> '	后台主动修改时间地点短信短信通知',//模板名称
            'tem_code'=> 'SMS_461030378',// 模板code
            'param' => [
                'ActivityName'=>isset($data['ActivityName']) ? $data['ActivityName'] : '' ,
                'time'=>isset($data['time']) ? $data['time'] : '' ,
                'adress'=>isset($data['adress']) ? $data['adress'] : '' ,
            ]
        ];

        AlibabaCloud::accessKeyClient('LTAI5tJ5p12drZegeWVG33xZ', '82UWAiY5e5wH8tSkRvMtqVoGO0h8SB')->regionId('cn-hangzhou')->asDefaultClient();
        try {
            $result = AlibabaCloud::rpc()
                ->product('Dysmsapi')
                ->version('2017-05-25')
                ->action('SendSms')
                ->method('POST')
                ->host('dysmsapi.aliyuncs.com')
                ->options([
                    'query' => [
                        'RegionId' => "cn-hangzhou",
                        'PhoneNumbers' => $phone,
                        'SignName' => "搞一下汽车电子",
                        'TemplateCode' => $mud_arr[$key]['tem_code'],
                        'TemplateParam' => json_encode($mud_arr[$key]['param']),
                    ],
                ])->request();
            $result = $result->toArray();
            if($result['Code'] != "OK") return ['code'=>201,'msg'=>'发送失败'];
        } catch (ClientException $e) {
            return ['code'=>201,'msg'=>$e->getErrorMessage().PHP_EOL];
        } catch (ServerException $e) {
            return ['code'=>201,'msg'=>$e->getErrorMessage().PHP_EOL];
        }catch (\Exception $e){
            return ['code'=>201,'msg'=>$e->getMessage()];
        }
        return ['code'=>200,'msg'=>'发送成功'];
    }


    // 邮件推送
    public static function emailSend($email,$title)
    {
        require_once env('root_path').'vendor/aliyunmail/aliyun-php-sdk-core/Config.php';
        $iClientProfile = \DefaultProfile::getProfile("cn-hangzhou", "LTAI5tJ5p12drZegeWVG33xZ", "82UWAiY5e5wH8tSkRvMtqVoGO0h8SB");
        $client = new \DefaultAcsClient($iClientProfile);
        $request = new Dm\SingleSendMailRequest();
        $request->setAccountName("gyx@yzm.gyxqcdz.com");
        $request->setFromAlias("活动提示");
        $request->setAddressType(1);
        $request->setTagName("activity");
        $request->setReplyToAddress("true");
        $request->setToAddress($email);
        $request->setSubject("活动提示");
        $html_body = '您报名的活动'.$title.'已发生变更。';
        $request->setHtmlBody($html_body);
        $send_res = $client->getAcsResponse($request);
        return ['code'=>200,'msg'=>'发送成功'];
    }

    //门票邮件推送
    public static function ticketSend($ticket_id)
    {
        $ticket_info = ActivityApplyItem::where('id',$ticket_id)->find()->toArray();
        if(!$ticket_info['email'])['code'=>201,'msg'=>'邮件为空'];
        $email = $ticket_info['email'];
        $title = \app\common\model\Activity::where('id',$ticket_info['act_id'])->value('title');
        require_once env('root_path').'vendor/aliyunmail/aliyun-php-sdk-core/Config.php';
        $iClientProfile = \DefaultProfile::getProfile("cn-hangzhou", "LTAI5tJ5p12drZegeWVG33xZ", "82UWAiY5e5wH8tSkRvMtqVoGO0h8SB");
        $client = new \DefaultAcsClient($iClientProfile);
        $request = new Dm\SingleSendMailRequest();
        $request->setAccountName("gyx@yzm.gyxqcdz.com");
        $request->setFromAlias("活动提示");
        $request->setAddressType(1);
        $request->setTagName("activity");
        $request->setReplyToAddress("true");
        $request->setToAddress($email);
        $request->setSubject("活动提示");

        $act_title = $title;
        $num = 1;
        $qr_code = $ticket_info['qr_code'];

        $html_body = file_get_contents('/ticket_info.php');
        var_dump($html_body);die();
        $request->setHtmlBody($html_body);
        $send_res = $client->getAcsResponse($request);
        return ['code'=>200,'msg'=>'发送成功'];
    }






}