gaoyixia/application/common/service/UserSynth.php

<?php
namespace app\common\service;
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;

/**
 * 会员身综合管理
 * 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['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()
    {

    }




}