| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023 |
- <?php
- // +----------------------------------------------------------------------
- // | Fanwe 方维直播系统
- // +----------------------------------------------------------------------
- // | Copyright (c) 2011 http://www.fanwe.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Author: 云淡风轻(1956838968@qq.com)
- // +----------------------------------------------------------------------
- define("EMPTY_ERROR",1); //未填写的错误
- define("FORMAT_ERROR",2); //格式错误
- define("EXIST_ERROR",3); //已存在的错误
- define("ACCOUNT_NO_EXIST_ERROR",1); //帐户不存在
- define("ACCOUNT_PASSWORD_ERROR",2); //帐户密码错误
- define("ACCOUNT_NO_VERIFY_ERROR",3); //帐户未激活
- /**
- * 生成会员数据
- * @param $user_data 提交[post或get]的会员数据
- * @param $mode 处理的方式,注册或保存
- * 返回:data中返回出错的字段信息,包括field_name, 可能存在的field_show_name 以及 error 错误常量
- * $update_status后台更新标示字段
- */
- function save_user_wpk($user_data,$mode='INSERT',$update_status)
- {
- //开始数据验证
- $res = array('status'=>1,'info'=>'','data'=>''); //用于返回的数据
- if($user_data['mobile']!=''&&!check_mobile(trim($user_data['mobile'])))
- {
- $res['error'] = '手机格式错误:'.$user_data['mobile'];
- $res['status'] = 0;
- return $res;
- }
- if($user_data['mobile1']!=''&&!check_mobile(trim($user_data['mobile1'])))
- {
- $res['error'] = '备用手机格式错误:'.$user_data['mobile1'];
- $res['status'] = 0;
- return $res;
- }
- /*$exit_id = $GLOBALS['db']->getOne("select id from ".DB_PREFIX."user where mobile = '".trim($user_data['mobile'])."'");
- if($user_data['mobile']!=''&& $exit_id && $exit_id!=$user_data['id'])
- {
- //$field_item['field_name'] = 'mobile';
- //$field_item['error'] = EXIST_ERROR;
- //$res['status'] = 0;
- //$res['data'] = $field_item;
- $res['error'] = '手机号已存在';
- $res['status'] = 0;
- return $res;
- }*/
- if($user_data['identify_number']!=''&& !isCreditNo($user_data['identify_number']) &&$update_status!=1)
- {
- $res['error'] = '请填写正确的身份证号码';
- $res['status'] = 0;
- return $res;
- }
- //验证结束开始插入数据
- $user_data['nick_name'] = htmlspecialchars_decode($user_data['nick_name']);
- if(trim($user_data['nick_name'])!=''){
- $user['nick_name'] = trim($user_data['nick_name']);
- //检查昵称
- if(strlen($user['nick_name'])>60){
- $res['error'] = "昵称太长";
- $res['status'] =0;
- return $res;
- }
- }
- if($user_data['create_time']||$user_data['id']){
- $user['update_time'] = get_gmtime();
- }else{
- $user['create_time'] = get_gmtime();
- }
- //禁播
- if(isset($user_data['is_ban']))
- $user['is_ban'] = intval($user_data['is_ban']);
- if(intval($user_data['is_ban'])){
- $user['ban_time'] = 0;
- }else{
- if(isset($user_data['ban_time'])){
- $ban_time = strim($user_data['ban_time']);
- $user['ban_time'] = $ban_time!=''?to_timespan($ban_time):0;
- }
- }
- //机器人
- if(isset($user_data['is_robot'])){
- $user['is_robot'] = intval($user_data['is_robot']);
- }
- if(isset($user_data['user_level']))
- $user['user_level'] = intval($user_data['user_level']);
- if(isset($user_data['is_authentication']))
- $user['is_authentication'] = intval($user_data['is_authentication']);
- if(isset($user_data['authentication_type']))
- $user['authentication_type'] = strim($user_data['authentication_type']);
- if(isset($user_data['identify_number']))
- $user['identify_number'] = strim($user_data['identify_number']);
- if(isset($user_data['authentication_name']))
- $user['authentication_name'] = strim($user_data['authentication_name']);
- if(isset($user_data['contact']))
- $user['contact'] = strim($user_data['contact']);
- if(isset($user_data['from_platform']))
- $user['from_platform'] = strim($user_data['from_platform']);
- if(isset($user_data['wiki']))
- $user['wiki'] = strim($user_data['wiki']);
- if(isset($user_data['province']))
- $user['province'] = $user_data['province'];
- if(isset($user_data['city']))
- $user['city'] = $user_data['city'];
- if(isset($user_data['sex']))
- $user['sex'] = intval($user_data['sex']);
- if(isset($user_data['is_edit_sex']))
- $user['is_edit_sex'] = intval($user_data['is_edit_sex']);
- if(isset($user_data['intro']))
- $user['intro'] = strim($user_data['intro']);
- $head_image = strim($user_data['head_image']);
- if($head_image){
- $user['head_image'] = del_domain_url($head_image);
- }
- $thumb_head_image = strim($user_data['thumb_head_image']);
- if($thumb_head_image){
- $user['thumb_head_image'] = del_domain_url($thumb_head_image);
- }
- if(isset($user_data['signature']))
- $user['signature'] = htmlspecialchars_decode(trim($user_data['signature']));
- if(isset($user_data['job']))
- $user['job'] = htmlspecialchars_decode(trim($user_data['job']));
-
- if(isset($user_data['job_age']))
- $user['job_age'] = htmlspecialchars_decode(trim($user_data['job_age']));
-
- if($user_data['birthday']!=''){
- $user['birthday'] = $user_data['birthday'];
- }
- if(isset($user_data['emotional_state']))
- $user['emotional_state']=strim($user_data['emotional_state']);
- if(isset($user_data['identify_hold_image']))
- $user['identify_hold_image']=strim($user_data['identify_hold_image']);
- if(isset($user_data['identify_positive_image']))
- $user['identify_positive_image']=strim($user_data['identify_positive_image']);
- if(isset($user_data['identify_nagative_image']))
- $user['identify_nagative_image']=strim($user_data['identify_nagative_image']);
- if(isset($user_data['v_explain']))
- $user['v_explain']=strim($user_data['v_explain']);
- if(isset($user_data['user_type']))
- $user['user_type'] = intval($user_data['user_type']);
- if(isset($user_data['score']))
- $user['score'] = intval($user_data['score']);
- //验证结束开始插入数据(这里没写user模块写不进去)
- //会员状态
- if(intval($user_data['is_effect'])!=0)
- {
- $user['is_effect'] = $user_data['is_effect'];
- }else{
- $user['is_effect'] =1;
- }
- if(isset($user_data['mobile']) && strim($user_data['mobile'])){
- $user['mobile'] = strim($user_data['mobile']);
- }
- if(isset($user_data['v_explain']) && strim($user_data['v_explain'])){
- $user['v_explain'] = strim($user_data['v_explain']);
- }
- if(isset($user_data['v_icon']) && strim($user_data['v_icon'])){
- $user['v_icon'] = strim($user_data['v_icon']);
- }
- if(isset($user_data['authent_list_id']) && strim($user_data['authent_list_id'])){
- $user['authent_list_id'] = strim($user_data['authent_list_id']);
- }
- if(isset($user_data['is_authentication'])){
- if(intval($user_data['is_authentication'])==3 || intval($user_data['is_authentication'])==1 || intval($user_data['is_authentication'])==0){
- $user['v_icon'] = '';
- $user['v_explain'] = '';
- }
- }
- if(isset($user_data['is_admin']))
- $user['is_admin'] = intval($user_data['is_admin']);
- if(isset($user_data['user_status']))
- $user['user_status'] = intval($user_data['user_status']);
- if(isset($user_data['user_source']))
- $user['user_source'] = intval($user_data['user_source']);
- if(isset($user_data['user_net_worth']))
- $user['user_net_worth'] = intval($user_data['user_net_worth']);
- if(isset($user_data['sign_status']))
- $user['sign_status'] = intval($user_data['sign_status']);
- if(isset($user_data['sign_time']))
- $user['sign_time'] = intval($user_data['sign_time']);
- if(isset($user_data['birth_place']))
- $user['birth_place'] = strim($user_data['birth_place']);
- if(isset($user_data['postal_address']))
- $user['postal_address'] = strim($user_data['postal_address']);
- if(isset($user_data['consignee_name']))
- $user['consignee_name'] = strim($user_data['consignee_name']);
- if(isset($user_data['consignee_code']))
- $user['consignee_code'] = strim($user_data['consignee_code']);
- if(isset($user_data['phone_number']))
- $user['phone_number'] = strim($user_data['phone_number']);
- if(isset($user_data['facsimile_code']))
- $user['facsimile_code'] = strim($user_data['facsimile_code']);
- if(isset($user_data['assistant_name']))
- $user['assistant_name'] = strim($user_data['assistant_name']);
- if(isset($user_data['assistant_mobile']))
- $user['assistant_mobile'] = strim($user_data['assistant_mobile']);
- if(isset($user_data['assistant_wx_num']))
- $user['assistant_wx_num'] = strim($user_data['assistant_wx_num']);
- if(isset($user_data['assistant_email']))
- $user['assistant_email'] = strim($user_data['assistant_email']);
- if(isset($user_data['mobile1']))
- $user['mobile1'] = strim($user_data['mobile1']);
- if(isset($user_data['wx_num']))
- $user['wx_num'] = strim($user_data['wx_num']);
- if(isset($user_data['wx_num1']))
- $user['wx_num1'] = strim($user_data['wx_num1']);
- if(isset($user_data['qq_num']))
- $user['qq_num'] = strim($user_data['qq_num']);
- if(isset($user_data['email']))
- $user['email'] = strim($user_data['email']);
- if(isset($user_data['member_type']))
- $user['member_type'] = intval($user_data['member_type']);
- if(isset($user_data['source_url']))
- $user['source_url'] = strim($user_data['source_url']);
- if(isset($user_data['pid']))
- $user['pid'] = intval($user_data['pid']);
- if(isset($user_data['company']))
- $user['company'] = strim($user_data['company']);
- if(isset($user_data['company_address']))
- $user['company_address'] = strim($user_data['company_address']);
- if(isset($user_data['income_range']))
- $user['income_range'] = intval($user_data['income_range']);
- if(isset($user_data['interest']))
- $user['interest'] = strim($user_data['interest']);
- if(isset($user_data['interest_content']))
- $user['interest_content'] = strim($user_data['interest_content']);
- if(isset($user_data['speciality']))
- $user['speciality'] = strim($user_data['speciality']);
- if(isset($user_data['education']))
- $user['education'] = intval($user_data['education']);
- if(isset($user_data['school']))
- $user['school'] = trim($user_data['school']);
- if(isset($user_data['is_agent']))
- $user['is_agent'] = intval($user_data['is_agent']);
- if(isset($user_data['is_canal']))
- $user['is_canal'] = intval($user_data['is_canal']);
- if(isset($user_data['is_star_share']))
- $user['is_star_share'] = intval($user_data['is_star_share']);
- if(isset($user_data['real_name']))
- $user['real_name'] = strim($user_data['real_name']);
- if(isset($user_data['business_card']))
- $user['business_card'] = strim($user_data['business_card']);
- if(isset($user_data['work_card']))
- $user['work_card'] = strim($user_data['work_card']);
- if(isset($user_data['work_contract']))
- $user['work_contract'] = strim($user_data['work_contract']);
- if($mode == 'INSERT')
- {
- $user['code'] = ''; //默认不使用code, 该值用于其他系统导入时的初次认证
- }
- else
- {
- $user['code'] = $GLOBALS['db']->getOne("select code from ".DB_PREFIX."user where id =".$user_data['id']);
- }
- if($mode == 'INSERT')
- {
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $user['id'] = $user_id;
- $user['user_pwd']= md5(rand(100000,999999));
- $where = '';
- }
- else
- {
- $where = "id=".intval($user_data['id']);
- }
- if($GLOBALS['db']->autoExecute(DB_PREFIX."user",$user,$mode,$where))
- {
- if($mode == 'INSERT')
- {
- $user_id = $user['id'];
- }
- else
- {
- $user_id = $user_data['id'];
- //user_deal_to_reids(array($user_id));
- }
- }
- $res['data'] = $user_id;
- return $res;
- }
- function save_mobile_user($user_data,$mode='INSERT')
- {
- //开始数据验证
- $res = array('status'=>1,'info'=>'','data'=>''); //用于返回的数据
- if(!check_mobile(trim($user_data['mobile'])))
- {
- $field_item['field_name'] = 'mobile';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($user_data['mobile']!=''&&$GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."user where mobile = '".trim($user_data['mobile'])."'")>0)
- {
- /*$field_item['field_name'] = 'mobile';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;*/
- $res['data'] = $GLOBALS['db']->getOne("select id from ".DB_PREFIX."user where mobile = '".trim($user_data['mobile'])."'");
- $res['status'] = 1;
- return $res;
- }
- //检查验证码
- if(trim($user_data['verify_coder'])=='')
- {
- $field_item['field_name'] = 'verify_coder';
- $field_item['error'] = EMPTY_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($GLOBALS['db']->getOne("SELECT count(*) FROM ".DB_PREFIX."mobile_verify_code WHERE mobile=".trim($user_data['mobile'])." AND verify_code='".trim($user_data['verify_coder'])."'")==0)
- {
- $field_item['field_name'] = 'verify_coder';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- //验证结束开始插入数据
- $user['nick_name'] = htmlspecialchars_decode($user_data['nick_name']);
- if($user_data['create_time']){
- $user['update_time'] = get_gmtime();
- }else{
- $user['create_time'] = get_gmtime();
- }
- //禁播
- $user['is_ban'] = intval($user_data['is_ban']);
- if(intval($user_data['is_ban'])){
- $user['ban_time'] = 0;
- }else{
- $ban_time = strim($user_data['ban_time']);
- $user['ban_time'] = $ban_time!=''?to_timespan($ban_time):0;
- }
- $user['is_authentication'] = intval($user_data['is_authentication']);
- $user['authentication_type'] = strim($user_data['authentication_type']);
- $user['authentication_name'] = strim($user_data['authentication_name']);
- $user['contact'] = strim($user_data['contact']);
- $user['from_platform'] = strim($user_data['from_platform']);
- $user['wiki'] = strim($user_data['wiki']);
- if(strim($user_data['province'])=='')
- $user['province'] = '火星';
- else
- $user['province'] = $user_data['province'];
- $user['city'] = $user_data['city'];
- if(isset($user_data['sex'])){
- if(intval($user_data['sex'])){
- $user['sex'] = intval($user_data['sex']);
- }else{
- $user['sex']=1;
- }
- }else{
- $user['sex']=1;
- }
- $user['intro'] = strim($user_data['intro']);
- if(strim($user_data['head_image'])){
- $user['head_image'] = strim($user_data['head_image']);
- }
- $user['identify_hold_image']=strim($user_data['identify_hold_image']);
- $user['identify_positive_image']=strim($user_data['identify_positive_image']);
- $user['identify_nagative_image']=strim($user_data['identify_nagative_image']);
- $user['v_explain']=strim($user_data['v_explain']);
- $user['user_type'] = intval($user_data['user_type']);
- if(strim($user_data['emotional_state'])=='')
- $user['emotional_state'] ='保密';
- if(isset($user_data['signature']))
- $user['signature'] = htmlspecialchars_decode(trim($user_data['signature']));
- if(strim($user_data['job'])=='')
- $user['job'] ='主播';
- else
- $user['job'] = htmlspecialchars_decode(trim($user_data['job']));
- //验证结束开始插入数据(这里没写user模块写不进去)
- //会员状态
- if(intval($user_data['is_effect'])!=0)
- {
- $user['is_effect'] = $user_data['is_effect'];
- }else{
- $user['is_effect'] =1;
- }
- $user['user_level'] = 1;
- $user['login_type'] = 2;
- $user['is_remind'] = 1;
- //临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $user['diamonds'] = 1000000;
- }
-
- if(strim($user_data['mobile'])){
- $user['mobile'] = strim($user_data['mobile']);
- }
- if($mode == 'INSERT')
- {
- $user['code'] = ''; //默认不使用code, 该值用于其他系统导入时的初次认证
- }
- else
- {
- $user['code'] = $GLOBALS['db']->getOne("select code from ".DB_PREFIX."user where id =".$user_data['id']);
- }
- if($mode == 'INSERT')
- {
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $user['id'] = $user_id;
- $user['user_pwd']= md5(rand(100000,999999));
- $where = '';
- }
- else
- {
- $where = "id=".intval($user_data['id']);
- }
- if($GLOBALS['db']->autoExecute(DB_PREFIX."user",$user,$mode,$where))
- {
- if($mode == 'INSERT')
- {
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //$user_id =$GLOBALS['db']->insert_id();
- $ridis_data = $user_redis->reg_data($user);
- //redis临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $ridis_data['diamonds'] = 1000000;
- }
-
- $user_redis->insert_db($user_id,$ridis_data);
- //===========add end ===========
- //$GLOBALS['msg']->manage_msg('MSG_MEMBER_REMIDE',$user_id,array('type'=>'会员注册','content'=>'您于 '.get_client_ip() ."注册成功!"));
- }
- else
- {
- $user_id = $user_data['id'];
- }
- }
- $res['data'] = $user_id;
- return $res;
- }
- function update_mobile_user($user_data,$mode='INSERT')
- {
- //开始数据验证
- $res = array('status'=>1,'error'=>'','data'=>''); //用于返回的数据
- if(trim($user_data['id'])=='')
- {
- $res['status'] = 0;
- $field_item['error']='用户编号不能为空';
- return $res;
- }
- if($GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."user where id = '".trim($user_data['id'])."'")<=0)
- {
- $res['status'] = 0;
- $field_item['error'] = '用户不存在!';
- return $res;
- }
- $GLOBALS['db']->query("set names 'utf8mb4'");
- //验证结束开始插入数据
- if(isset($user_data['nick_name']))
- $user['nick_name']= htmlspecialchars_decode($user_data['nick_name']);
-
- $user['update_time'] = get_gmtime();
- if(isset($user_data['sex'])){
- $user['sex'] = intval($user_data['sex']);
- }else{
- $user['sex'] = 1;
- }
-
- if(isset($user_data['head_image']))
- $user['head_image'] = trim($user_data['head_image']);
- if(isset($user_data['thumb_head_image']))
- $user['thumb_head_image'] = trim($user_data['thumb_head_image']);
- //验证结束开始插入数据(这里没写user模块写不进去)
- $where = "id=".intval($user_data['id']);
- if($GLOBALS['db']->autoExecute(DB_PREFIX."user",$user,$mode,$where))
- {
- $user_id = $user_data['id'];
- es_cookie::set("nick_name",$user['nick_name'],3600*24*30);
- }
- $res['data'] = $user_id;
- //更新redis
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/BaseRedisService.php');
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- $user_redis->update_db($user_id,$user);
- return $res;
- }
- /**
- * 删除会员以及相关数据
- * @param integer $id
- */
- function delete_user($id)
- {
- $result = 1;
- if($result>0)
- {
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."user_consignee where user_id = ".$id);
- $GLOBALS['db']->query("delete from ".DB_PREFIX."user_log where user_id = ".$id);
- $GLOBALS['db']->query("delete from ".DB_PREFIX."user_refund where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."user_weibo where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."user_consignee where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."referrals where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_comment where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_focus_log where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_log where user_id = ".$id);
- $GLOBALS['db']->query("delete from ".DB_PREFIX."deal_msg_list where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_order where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_log where user_id = ".$id);
- //$GLOBALS['db']->query("delete from ".DB_PREFIX."deal_support_log where user_id = ".$id);
- $GLOBALS['db']->query("delete from ".DB_PREFIX."payment_notice where user_id = ".$id);
- $GLOBALS['db']->query("delete from ".DB_PREFIX."user where id =".$id); //删除会员
- }
- }
- /**
- * 会员资金积分变化操作函数
- * @param array $data 包括 diamonds
- * @param integer $user_id
- * @param string $log_msg 日志内容
- * @param array $param 要插入的数组
- */
- function modify_account($data,$user_id,$log_msg='',$param=array())
- {
- /*$diamonds=intval($data['diamonds']);
- if ($diamonds < 0){
- $diamonds = abs($diamonds);
- $sql = "update ".DB_PREFIX."user set diamonds = diamonds - ".$diamonds." where diamonds >= ".$diamonds." and id =".$user_id;
- $log_msg1 = '扣除钻石';
- }else{
- $sql = "update ".DB_PREFIX."user set diamonds = diamonds + ".$diamonds." where id =".$user_id;
- $log_msg1 = '增加钻石';
- }*/
- $money = floatval($data['money']);
- if ($money < 0){
- $money = abs($money);
- $sql = "update ".DB_PREFIX."user set money = money - ".$money." where money >= ".$money." and id =".$user_id;
- $log_msg1 = '扣除钻石';
- }else{
- $sql = "update ".DB_PREFIX."user set money = money + ".$money." where id =".$user_id;
- $log_msg1 = '增加钻石';
- }
- if($log_msg==''){
- $log_msg = $log_msg1;
- }
- $GLOBALS['db']->query($sql);
- if($GLOBALS['db']->affected_rows()){
- //user_deal_to_reids(array($user_id));
- //写入日志
- account_log($data,$user_id,$log_msg,$param);
- return true;
- }else{
- return false;
- }
- }
- /**
- * 处理cookie的自动登录
- * @param $user_name_or_email 用户名或邮箱
- * @param $user_md5_pwd md5加密过的密码
- */
- function auto_do_login_user($user_id,$user_md5_pwd)
- {
- $user_data = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where id='".$user_id."' and is_effect = 1");
- if($user_data)
- {
- if(md5($user_data['user_pwd']."_EASE_COOKIE")==$user_md5_pwd)
- {
- //登录成功自动检测关于会员等级
- //user_leverl_syn($user_data);//$user_data 要包括会员id,会员等级,会员信用值
- //成功
- //$build_count = $GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."deal where is_delete = 0 and is_effect = 1 and user_id = ".$user_data['id']);
- //$focus_count = $GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."deal_focus_log where user_id = ".$user_data['id']);
- //$support_count = $GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."deal_support_log where user_id = ".$user_data['id']);
- $login_root = login_prompt($user_data['id']);
- es_session::set("first_login",$login_root['first_login']);
- es_session::set("new_level",$login_root['new_level']);
- es_session::set("user_info",$user_data);
- $GLOBALS['user_info'] = $user_data;
- //$GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".get_client_ip()."',login_time= ".get_gmtime().",build_count = $build_count,support_count = $support_count,focus_count = $focus_count where id =".$user_data['id']);
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".get_client_ip()."',login_time= '".to_date(get_gmtime(),'Y-m-d H:i:s')."' where id =".$user_data['id']);
- //更新redis
- /*fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- $user =array();
- $user_id = $user_data['id'];
- $user['login_ip'] = get_client_ip();
- $user['login_time'] = to_date(get_gmtime());
- $user_redis->update_db($user_id,$user);*/
- }
- }
- }
- /**
- * 手机登录
- * @param $user_id_or_mobile 手机号
- * @param $verify_code 短信验证码
- *
- */
- function do_login_user($user_id_or_mobile,$verify_code)
- {
- $result = array('status'=>0,'info'=>'','is_lack'=>0);
- $user_id_or_mobile=strim($user_id_or_mobile);
- $verify_code=strim($verify_code);
- if($verify_code==''){
- $result['info'] = "请输入验证码";
- return $result;
- }
- if($user_id_or_mobile!=''){
- if($user_id_or_mobile!='13888888888'){
- if(!check_mobile(trim($user_id_or_mobile)))
- {
- $result['info'] = '手机格式错误';
- return $result;
- }
- if($GLOBALS['db']->getOne("SELECT count(*) FROM ".DB_PREFIX."mobile_verify_code WHERE mobile=".$user_id_or_mobile." AND verify_code='".$verify_code."'")==0){
- $result['info'] = "手机验证码出错";
- return $result;
- }
- }elseif($user_id_or_mobile=='13888888888' && $verify_code !='8888'){
- $result['info'] = "手机验证码出错";
- return $result;
- }
- }else{
- $result['info'] = "请输入手机号";
- return $result;
- }
- $user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where (id='".$user_id_or_mobile."' or mobile = '".$user_id_or_mobile."' ) and login_type = 2");
- $user_id = intval($user['id']);
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- if ($user_id > 0){
- //登录成功自动检测关于会员等级
- $user_data = $user_redis->getRow_db($user_id);
- if(!$user_data){
- $ridis_data = $user_redis->reg_data($user);
- $user_redis->insert_db($user_id,$ridis_data);
- $user_data = $user_redis->getRow_db($user_id);
- }
- }
- if(!$user_data)
- {
- $data['mobile'] = $user_id_or_mobile;
- $data['verify_coder'] = $verify_code;
- $result = save_mobile_user($data);
- $user_data = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where id='".$result['data']."'");
- if(empty($user_data['nick_name'])){
- $update['nick_name']=$result['data'];
- $where = "id=".intval($result['data']);
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$update,UPDATE,$where);
- $user_data['nick_name']=$result['data'];
- }
- $result['user'] = $user_data;
- }
- else
- {
- $result['user'] = $user_data;
- }
- if($user_data['is_effect'] != 1){
- $result['info'] = "帐户已被禁用";
- }
- else
- {
- $result['status'] =1;
- //更新等级
- user_leverl_syn($user_data);
- $login_time = get_gmtime();
- $user_data['login_time'] = $login_time;
- //设置cookie
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- es_cookie::set("nick_name",$user_data['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_data['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_data['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",es_session::id(),3600*24*30);
-
- //设置session
- es_session::set("user_info",$user_data);
- $GLOBALS['user_info'] = $user_data;
- //修改登录时间之前,获取上一次登录时间,每日首次登录赠送积分
- $login_root = login_prompt($user_data['id']);
- $result['first_login'] = $login_root['first_login'];
- $result['new_level'] = $login_root['new_level'];
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".get_client_ip()."',login_time= '".to_date($login_time)."' where id =".$user_data['id']);
- $user_new = $user_redis->getRow_db($user_data['id']);
- if($user_new){
- $user_redis->update_db($user_data['id'],array("login_time"=>to_date($login_time)));
- }
- //登录成功 同步信息
- accountimport($user_data);
- //$GLOBALS['msg']->manage_msg('MSG_MEMBER_REMIDE',$GLOBALS['user_info']['id'],array('type'=>'会员登录','content'=>'您的帐号 '.$GLOBALS['user_info']['user_name'].' 于 '.get_client_ip() ." 登录!"));
- }
- if($user_data['nick_name']==''||$user_data['head_image']==''){
- $result['is_lack'] = 1;
- }
- $result['user_info']['user_id'] =$user_data['id'];
- $result['user_info']['nick_name'] =$user_data['nick_name']?$user_data['nick_name']:'';
- $result['user_info']['mobile'] =$user_data['mobile']?$user_data['mobile']:'';
- $result['user_info']['head_image'] =get_spec_image($user_data['head_image']);
- return $result;
- }
- /**
- * 登出,返回 array('status'=>'',data=>'',msg=>'') msg存放整合接口返回的字符串
- */
- function loginout_user()
- {
- $result = array('status'=>1,'info'=>'','data'=>''); //用于返回的数据
- $user_info = es_session::get("user_info");
- if(!$user_info)
- {
- return false;
- }
- else
- {
- //清除cookie
- es_cookie::set("client_ip",'',0);
- es_cookie::set("nick_name",'',0);
- es_cookie::set("user_id",'',0);
- es_cookie::set("user_pwd",'',0);
- es_cookie::set("is_agree",'',0);
- es_cookie::set("PHPSESSID2",'',0);
- //清除session
- es_session::delete("user_info");
- $GLOBALS['user_info']='';
- //写入日志
- //$GLOBALS['msg']->manage_msg('MSG_MEMBER_REMIDE',$user_info['id'],array('type'=>'会员登出','content'=>'您的帐号 '.$user_info['user_name'].' 于 '.get_client_ip() ." 登出!"));
- return $result;
- }
- }
- /**
- * 验证会员数据
- */
- function check_user($field_name,$field_data)
- {
- delete_mobile_verify_code();
- //开始数据验证
- $user_data[$field_name] = $field_data;
- $res = array('status'=>1,'info'=>'','data'=>''); //用于返回的数据
- if(trim($user_data['user_name'])==''&&$field_name=='user_name')
- {
- $field_item['field_name'] = 'user_name';
- $field_item['error'] = EMPTY_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if(mb_strlen(trim($user_data['user_name']))<4&&$field_name=='user_name')
- {
- $field_item['field_name'] = 'user_name';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($field_name=='user_name'&&$GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."user where user_name = '".trim($user_data['user_name'])."' and id <> ".intval($user_data['id']))>0)
- {
- $field_item['field_name'] = 'user_name';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if(app_conf("USER_VERIFY")!=2||$user_data['email']!=''){
- if($field_name=='email'&&$GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."user where email = '".trim($user_data['email'])."' and id <> ".intval($user_data['id']))>0)
- {
- $field_item['field_name'] = 'email';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($field_name=='email'&&trim($user_data['email'])=='')
- {
- $field_item['field_name'] = 'email';
- $field_item['error'] = EMPTY_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($field_name=='email'&&!check_email(trim($user_data['email'])))
- {
- $field_item['field_name'] = 'email';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- }
- if($field_name=='mobile'&&!check_mobile(trim($user_data['mobile'])))
- {
- $field_item['field_name'] = 'mobile';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($field_name=='mobile'&&$user_data['mobile']!=''&&$GLOBALS['db']->getOne("select count(*) from ".DB_PREFIX."user where mobile = '".trim($user_data['mobile'])."' and id <> ".intval($user_data['id']))>0)
- {
- $field_item['field_name'] = 'mobile';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if($field_name=='verify_coder'&&(app_conf("USER_VERIFY")==2||app_conf("USER_VERIFY")==4)){
- if(strim($_REQUEST['verify_coder'])==''){
- $field_item['field_name'] = 'verify_coder';
- $field_item['error'] = EMPTY_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if(!check_verify_coder(trim($_REQUEST['verify_coder']))){
- $field_item['field_name'] = 'verify_coder';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- $check_code_sql="SELECT count(*) FROM ".DB_PREFIX."mobile_verify_code WHERE mobile=".strim($_REQUEST['mobile'])." AND verify_code='".trim($_REQUEST['verify_coder'])."'";
- if($GLOBALS['db']->getOne($check_code_sql)==0)
- {
- $field_item['field_name'] = 'verify_coder';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- }
- if($field_name=='verify_coder_email'&&(app_conf("USER_VERIFY")==1||app_conf("USER_VERIFY")==4)){
- if(strim($_REQUEST['verify_coder_email'])==''){
- $field_item['field_name'] = 'verify_coder_email';
- $field_item['error'] = EMPTY_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- if(!check_verify_coder(trim($_REQUEST['verify_coder_email']))){
- $field_item['field_name'] = 'verify_coder_email';
- $field_item['error'] = FORMAT_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- $check_code_sql="SELECT count(*) FROM ".DB_PREFIX."mobile_verify_code WHERE email='".strim($_REQUEST['email'])."' AND verify_code='".trim($_REQUEST['verify_coder_email'])."'";
- if($GLOBALS['db']->getOne($check_code_sql)==0)
- {
- $field_item['field_name'] = 'verify_coder_email';
- $field_item['error'] = EXIST_ERROR;
- $res['status'] = 0;
- $res['data'] = $field_item;
- return $res;
- }
- }
- return $res;
- }
- /**
- * 会员资金积分变化操作函数
- * @param array $data 包括 money
- * @param integer $user_id
- * @param string $log_msg 日志内容
- * @param array $param 要插入的数组
- */
- function modify_account_ben($data,$user_id,$log_msg='',$param=array())
- {
- $user_money=$GLOBALS['db']->getOne("select money from ".DB_PREFIX."user where id=".$user_id);
- $money=$data['money'];
- if(($user_money+$money)>=0){
- if(floatval($data['money'])!=0)
- {
- $sql = "update ".DB_PREFIX."user set money = money + ".floatval($data['money'])." where id =".$user_id;
- $GLOBALS['db']->query($sql);
- }
- if(floatval($data['ben_money'])!=0){
- licai_log($data,$user_id);
- }
- elseif(floatval($data['money'])!=0)
- {
- $log_info['log_info'] = $log_msg;
- $log_info['log_time'] = get_gmtime();
- $adm_session = es_session::get(md5(app_conf("AUTH_KEY")));
- $user_info = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where is_effect = 1 and id = ".$user_id);
- $adm_id = intval($adm_session['adm_id']);
- if($adm_id!=0)
- {
- $log_info['log_admin_id'] = $adm_id;
- }
- if(is_array($param)&&count($param)>0){
- foreach($param as $k=>$v){
- $log_info[$k] = $v;
- }
- }
- $log_info['money'] = floatval($data['money']);
- $log_info['user_id'] = $user_id;
- $GLOBALS['db']->autoExecute(DB_PREFIX."user_log",$log_info);
- }
- return true;
- }else{
- return false;
- }
- }
- /*
- * 获取用户信息
- * @param $field_data 会员ID
- * @param $field_name 查询的字段名称
- */
- function get_user_info($field_name,$field_data){
- //$get_user_sql= "select * from ".DB_PREFIX."user where id=".$field_data;
- $get_user_info = $GLOBALS['db']->getOne("select $field_name from ".DB_PREFIX."user where id=".$field_data);
- return $get_user_info;
- }
- /**
- * 获取QQ好友资料
- *
- * @param object $sdk OpenApiV3 Object
- * @param string $openid openid
- * @param string $openkey openkey
- * @param string $pf 平台
- * @return array 好友资料数组
- */
- function get_qq_user_info($sdk, $openid, $openkey, $pf)
- {
- $params = array(
- 'openid' => $openid,
- 'openkey' => $openkey,
- 'pf' => $pf,
- );
- $script_name = '/v3/user/get_info';
- return $sdk->api($script_name, $params,'post');
- }
- function wxxMakeUser($wx_info){
- if($wx_info['unionid']!=""||$wx_info['openid']!=""){
- $has_user = false;
- if($wx_info['unionid'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_unionid = '".$wx_info['unionid']."' and login_type = 0 ");
- if(!$has_user && $wx_info['openid'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_openid='".$wx_info['openid']."' and login_type = 0 ");
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //===========add end ===========
- if(!$has_user){
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $data=array();
- $data['id'] = $user_id ;
- $GLOBALS['db']->query("set names 'utf8mb4'");
- $data['nick_name']= htmlspecialchars_decode($wx_info['nickname']);
- $data['user_name']= htmlspecialchars_decode($wx_info['nickname']);
- $data['is_effect'] = 1;
- if($wx_info['headimgurl']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ( $wx_info['headimgurl']));
- $data['head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- $data['wx_openid']= $wx_info['openid'];
- $data['wx_unionid']= $wx_info['unionid'];
- $data['create_time']= NOW_TIME;
- $data['user_pwd']= md5(rand(100000,999999));
- $data['login_ip'] = CLIENT_IP;
- $data['synchronize'] = 0;
- $data['emotional_state'] ='保密';
- $data['province'] = '火星';
- $data['job'] = '主播';
- $data['user_level'] = 1;
- $data['login_type'] = 0;
- $data['is_remind'] = 1;
- if(intval(es_cookie::get("REFERRAL_USER"))>0){
- $data['pid'] = intval(es_cookie::get("REFERRAL_USER"));
- }
- //临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $data['diamonds'] = 1000000;
- }
-
- if($wx_info['sex']==1){
- $data['sex'] = 1;
- }elseif($wx_info['sex']==2){
- $data['sex'] = 2;
- }else{
- $data['sex'] = 1;
- }
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$data);
- //===========add start ===========
- $ridis_data = $user_redis->reg_data($data);
- //redis临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $ridis_data['diamonds'] = 1000000;
- }
- $user_redis->insert_db($user_id,$ridis_data);
- $user_info = $data;
- //===========add end ===========
- }else{
- if($has_user['is_effect'] != 1){
- $return['status'] = 0;
- $return['error'] = "帐户已被禁用";
- $return['data'] =$has_user['id'];
- return $return;
- }else{
- $user_info = $has_user;
- //===========add end ===========
- }
- }
- es_session::set("user_info", $user_info);
- //设置session过期时间一个月
- es_session::setGcMaxLifetime('2592000');
- //file_put_contents(APP_ROOT_PATH."/public/condition.txt", print_r(es_session::get("user_info"),1),FILE_APPEND);
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- //es_cookie::set("login_time",NEW_TIME,3600*24*30);
- es_cookie::set("nick_name",$user_info['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_info['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_info['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",es_session::id(),3600*24*30);
- if($user_info['id']!=''){
- //登录成功 同步信息
- accountimport($user_info);
- //修改登录时间之前,获取上一次登录时间,每日首次登录赠送积分
- $login_root = login_prompt($user_info['id']);
- $return['first_login'] = $login_root['first_login'];
- $return['new_level'] = $login_root['new_level'];
- $now_time = NOW_TIME;
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".CLIENT_IP."',login_time='".to_date($now_time,"Y-m-d H:i:s")."',wx_unionid = '".$wx_info['unionid']."' where id =".$user_info['id']);
- //===========add start ===========
- $data =array();
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $data['wx_unionid'] = $wx_info['unionid'];
- $user_redis->update_db($user_info['id'],$data);
- $m_config = load_auto_cache("m_config");//初始化手机端配置
- //判断昵称是否包含敏感词汇
- if($m_config['name_limit']==1) {
- //登录过滤铭感词汇
- $nick_name = $user_info['nick_name'];
- $limit_sql = $GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name");
- //判断用户名是否含有铭感词汇,如果包含,替换
- if ($GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name WHERE '$nick_name' like concat('%',name,'%')")) {
- $user_info['nick_name'] = str_replace($limit_sql, '*', $nick_name);
- }
- $name = $user_info['nick_name'];
- $id = $user_info['id'];
- //更新数据库
- $sql = "update " . DB_PREFIX . "user set nick_name = '$name',sex={$data['sex']} where id=" . $id;
- $GLOBALS['db']->query($sql);
- //更新redis
- user_deal_to_reids(array($id));
- }
- $return['status'] = 1;
- $return['error'] = "微信登录成功";
- $return['data'] = $user_info['id'];
- $return['user_id'] = $user_info['id'];
- $return['nick_name'] = $user_info['nick_name'];
- $return['is_agree'] = intval($user_info['is_agree']);//是否同意直播协议 0 表示不同意 1表示同意
- $return['user_info']['user_id'] =$user_info['id'];
- $return['user_info']['nick_name'] =$user_info['nick_name'];
- $return['user_info']['mobile'] =$user_info['mobile'];
- $return['user_info']['head_image'] =get_spec_image($user_info['head_image']);
- }else{
- $return['status'] = 0;
- $return['error'] = "微信登录失败";
- $return['data'] =$user_info['id'];
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "未获取用户授权";
- }
- return $return;
- }
-
- //微信登陆
- function wxMakeUser($wx_info){
- if($wx_info['unionid']!=""||$wx_info['openid']!=""){
- $has_user = false;
- if($wx_info['unionid'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_unionid = '".$wx_info['unionid']."'");
- if(!$has_user && $wx_info['openid'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_openid='".$wx_info['openid']."'");
- if(!$has_user){
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $data=array();
- $data['id'] = $user_id ;
- $GLOBALS['db']->query("set names 'utf8mb4'");
- $data['nick_name']= htmlspecialchars_decode($wx_info['nickname']);
- $data['user_name']= htmlspecialchars_decode($wx_info['nickname']);
- $data['is_effect'] = 1;
- if($wx_info['headimgurl']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ( $wx_info['headimgurl']));
- $data['head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- $data['wx_openid']= $wx_info['openid'];
- $data['wx_unionid']= $wx_info['unionid'];
- $data['create_time']= NOW_TIME;
- $data['user_pwd']= md5(rand(100000,999999));
- $data['login_ip'] = CLIENT_IP;
- $data['synchronize'] = 0;
- $data['emotional_state'] ='保密';
- $data['province'] = '火星';
- $data['job'] = '主播';
- $data['user_level'] = 1;
- $data['login_type'] = 0;
- $data['is_remind'] = 1;
-
- if($wx_info['sex']==1){
- $data['sex'] = 1;
- }elseif($wx_info['sex']==2){
- $data['sex'] = 2;
- }else{
- $data['sex'] = 1;
- }
-
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$data);
- //同步微店,生成数据
- fanwe_require(APP_ROOT_PATH.'Fanwewd.php');
- $fanwewd=new Fanwewd();
- $shop_user_id=$fanwewd->createUser($user_id, $data['nick_name']);
- //$fanwewd->getUserLoginUrl($shop_user_id);
-
- $data['shop_user_id'] = $shop_user_id;
- $sql=" update ".DB_PREFIX."user set shop_user_id=".$shop_user_id." where id=".$user_id;
- $GLOBALS['db']->query($sql);
-
- $user_info = $data;
- }else{
- if($has_user['is_effect'] != 1){
- $return['status'] = 0;
- $return['error'] = "帐户已被禁用";
- $return['data'] =$has_user['id'];
- return $return;
- }else{
- $user_info = $has_user;
- }
-
- }
- es_session::set("user_info", $user_info);
- es_session::setGcMaxLifetime('2592000');
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- es_cookie::set("nick_name",$user_info['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_info['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_info['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",es_session::id(),3600*24*30);
-
- if($user_info['id']!=''){
-
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".CLIENT_IP."',login_time='".to_date($now_time,"Y-m-d H:i:s")."',wx_unionid = '".$wx_info['unionid']."' where id =".$user_info['id']);
- //===========add start ===========
- $data =array();
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $data['wx_unionid'] = $wx_info['unionid'];
-
- $m_config = load_auto_cache("m_config");//初始化手机端配置
- //判断昵称是否包含敏感词汇
- if($m_config['name_limit']==1) {
- //登录过滤铭感词汇
- $nick_name = $user_info['nick_name'];
- $limit_sql = $GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name");
- //判断用户名是否含有铭感词汇,如果包含,替换
- if ($GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name WHERE '$nick_name' like concat('%',name,'%')")) {
- $user_info['nick_name'] = str_replace($limit_sql, '*', $nick_name);
- }
- $name = $user_info['nick_name'];
- $id = $user_info['id'];
- //更新数据库
- $sql = "update " . DB_PREFIX . "user set nick_name = '$name',sex={$data['sex']} where id=" . $id;
- $GLOBALS['db']->query($sql);
- }
-
- $return['status'] = 1;
- $return['error'] = "微信登录成功";
- $return['data'] = $user_info['id'];
-
- $return['user_id'] = $user_info['id'];
- $return['nick_name'] = $user_info['nick_name'];
- $return['is_agree'] = intval($user_info['is_agree']);//是否同意直播协议 0 表示不同意 1表示同意
-
- $return['user_info']['user_id'] =$user_info['id'];
- $return['user_info']['nick_name'] =$user_info['nick_name'];
- $return['user_info']['mobile'] =$user_info['mobile'];
- $return['user_info']['head_image'] =get_spec_image($user_info['head_image']);
-
- }else{
- $return['status'] = 0;
- $return['error'] = "微信登录失败";
- $return['data'] =$user_info['id'];
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "未获取用户授权";
- }
- return $return;
-
- }
-
- //
- function qqMakeUser($qq_info){
- if($qq_info['openid']!=""){
- $has_user = false;
- if($qq_info['openid'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where qq_openid='".$qq_info['openid']."' ");
- //性别
- if($qq_info['gender']=='男'){
- $sex =1;
- }elseif($qq_info['gender']=='女'){
- $sex =2;
- }else{
- $sex =1;
- }
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //===========add end ===========
- if(!$has_user){
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $data=array();
- $data['id'] = $user_id ;
- $data['nick_name']= htmlspecialchars_decode($qq_info['nickname']);
- $data['is_effect'] = 1;
- if($qq_info['figureurl_qq_2']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ($qq_info['figureurl_qq_2']));
- $data['head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['head_image']= get_domain().'/app/theme/demo/images/defaulthead.png';
- }
- if($qq_info['figureurl_qq_1']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ($qq_info['figureurl_qq_1']));
- $data['thumb_head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['thumb_head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- $data['sex']= $sex;
- $data['province']= $qq_info['province'];
- $data['city']= $qq_info['city'];
- $data['qq_openid']= $qq_info['openid'];
- $data['create_time']= NOW_TIME;
- $data['user_pwd']= md5(rand(100000,999999));
- $data['login_ip'] = CLIENT_IP;
- $data['synchronize'] = 0;
- $data['emotional_state'] ='保密';
- if($data['city']==''&&$data['province']==''){
- $data['province'] = '火星';
- }
- $data['job'] = '主播';
- $data['user_level'] = 1;
- $data['login_type'] = 1;
- $data['is_remind'] = 1;//默认开通推送
- //临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $data['diamonds'] = 1000000;
- }
- $has_user_info = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where qq_openid='".$qq_info['openid']."' ");
- if(intval($has_user_info['id'])==0){
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$data);
- $user_info = $data;
- }else{
- $user_info = $has_user_info;
- }
-
- //===========add start ===========
- $ridis_data = $user_redis->reg_data($data);
- //redis临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $ridis_data['diamonds'] = 1000000;
- }
- $user_redis->insert_db($user_id,$ridis_data);
- //===========add end ===========
- }else{
- if($has_user['is_effect'] != 1){
- $return['status'] = 0;
- $return['error'] = "帐户已被禁用";
- $return['data'] =$has_user['id'];
- return $return;
- }else{
- $user_info = $has_user;
- //===========add end ===========
- }
- }
- es_session::set("user_info", $user_info);
- //设置session过期时间一个月
- es_session::setGcMaxLifetime('2592000');
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- es_cookie::set("nick_name",$user_info['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_info['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_info['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",es_session::id(),3600*24*30);
- if($user_info['id']!=''){
- //登录成功 同步信息
- accountimport($user_info);
- //修改登录时间之前,获取上一次登录时间,每日首次登录赠送积分
- $login_root = login_prompt($user_info['id']);
- $return['first_login'] = $login_root['first_login'];
- $return['new_level'] = $login_root['new_level'];
- $now_time = NOW_TIME;
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".CLIENT_IP."',login_time='".to_date($now_time,"Y-m-d H:i:s")."',qq_openid = '".$qq_info['openid']."' where id =".$user_info['id']);
- //===========add start ===========
- $data =array();
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $data['qq_openid'] = $qq_info['openid'];
- $user_redis->update_db($user_info['id'],$data);
- $m_config = load_auto_cache("m_config");//初始化手机端配置
- //判断昵称是否包含敏感词汇
- if($m_config['name_limit']==1) {
- //登录过滤铭感词汇
- $nick_name = $user_info['nick_name'];
- $limit_sql = $GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name");
- //判断用户名是否含有铭感词汇,如果包含,替换
- if ($GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name WHERE '$nick_name' like concat('%',name,'%')")) {
- $user_info['nick_name'] = str_replace($limit_sql, '*', $nick_name);
- }
- $name = $user_info['nick_name'];
- $id = $user_info['id'];
- //更新数据库
- $sql = "update " . DB_PREFIX . "user set nick_name = '$name',sex={$sex} where id=" . $id;
- $GLOBALS['db']->query($sql);
- //更新redis
- user_deal_to_reids(array($id));
- }
- $return['status'] = 1;
- $return['error'] = "QQ登录成功";
- $return['data'] = $user_info['id'];
- $return['user_id'] = $user_info['id'];
- $return['nick_name'] = $user_info['nick_name'];
- $return['is_agree'] = intval($user_info['is_agree']);//是否同意直播协议 0 表示不同意 1表示同意
- $return['user_info']['user_id'] =$user_info['id'];
- $return['user_info']['nick_name'] =$user_info['nick_name'];
- $return['user_info']['mobile'] =$user_info['mobile'];
- $return['user_info']['head_image'] =get_spec_image($user_info['head_image']);
- }
- else{
- $return['status'] = 0;
- $return['error'] = "QQ登录失败";
- $return['data'] ='';
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "未获取用户授权";
- }
- return $return;
- }
- //
- function sinaMakeUser($sina_info){
- if($sina_info['sina_id']!=""){
- $has_user = false;
- if($sina_info['sina_id'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where sina_id='".$sina_info['sina_id']."' ");
- //性别
- if($sina_info['gender']=='m'){
- $sex =1;
- }elseif($sina_info['gender']=='f'){
- $sex =2;
- }else{
- $sex =1;
- }
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //===========add end ===========
- if(!$has_user){
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $data=array();
- $data['id'] = $user_id ;
- $GLOBALS['db']->query("set names 'utf8mb4'");
- $data['nick_name']= htmlspecialchars_decode($sina_info['screen_name']);
- $data['is_effect'] = 1;
- if($sina_info['avatar_hd']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ($sina_info['avatar_hd']));
- $data['head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- if($sina_info['avatar_large']!=''){
- $root = get_image_path();
- $save_name= get_gmtime().$user_id.".jpg";
- $image_file_domain = ".".$root['save_rec_Path'].$save_name;
- $image_file =$root['savePath'].$save_name;
- ini_set('default_socket_timeout', 1);
- @file_put_contents ( $image_file, file_get_contents ($sina_info['avatar_large']));
- $data['thumb_head_image']= $image_file_domain;
- if($GLOBALS['distribution_cfg']['OSS_TYPE']&&$GLOBALS['distribution_cfg']['OSS_TYPE']!='NONE')
- {
- syn_to_remote_image_server($image_file_domain);
- }
- }else{
- $data['thumb_head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- $data['sex']=$sex;
- $data['sina_id']= $sina_info['sina_id'];
- $data['create_time']= NOW_TIME;
- $data['user_pwd']= md5(rand(100000,999999));
- $data['login_ip'] = CLIENT_IP;
- $data['synchronize'] = 0;
- $data['emotional_state'] ='保密';
- $data['province'] = '火星';
- $data['job'] = '主播';
- $data['user_level'] = 1;
- $data['login_type'] = 3;
- $data['is_remind'] = 1;//默认开通推送
- //临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $data['diamonds'] = 1000000;
- }
-
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$data);
- $user_info = $data;
- //===========add start ===========
- $ridis_data = $user_redis->reg_data($data);
- //redis临时测试
- if(defined('OPEN_TEST')&&OPEN_TEST==1){
- $ridis_data['diamonds'] = 1000000;
- }
- $user_redis->insert_db($user_id,$ridis_data);
- //===========add end ===========
- }else{
- if($has_user['is_effect'] != 1){
- $return['status'] = 0;
- $return['error'] = "帐户已被禁用";
- $return['data'] =$has_user['id'];
- return $return;
- }else{
- $user_info = $has_user;
- //===========add end ===========
- }
- }
- es_session::set("user_info", $user_info);
- //设置session过期时间一个月
- es_session::setGcMaxLifetime('2592000');
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- es_cookie::set("nick_name",$user_info['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_info['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_info['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",es_session::id(),3600*24*30);
- if($user_info['id']!=''){
- //登录成功 同步信息
- accountimport($user_info);
- //修改登录时间之前,获取上一次登录时间,每日首次登录赠送积分
- $login_root = login_prompt($user_info['id']);
- $return['first_login'] = $login_root['first_login'];
- $return['new_level'] = $login_root['new_level'];
- $now_time = NOW_TIME;
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".CLIENT_IP."',login_time='".to_date($now_time,"Y-m-d H:i:s")."',sina_id = '".$sina_info['sina_id']."' where id =".$user_info['id']);
- //===========add start ===========
- $data =array();
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $data['sina_id'] = $sina_info['sina_id'];
- $user_redis->update_db($user_info['id'],$data);
- //登录过滤铭感词汇
- $m_config = load_auto_cache("m_config");//初始化手机端配置
- //判断昵称是否包含敏感词汇
- if($m_config['name_limit']==1) {
- $nick_name = $user_info['nick_name'];
- $limit_sql = $GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name");
- //判断用户名是否含有铭感词汇,如果包含,替换
- if ($GLOBALS['db']->getCol("SELECT name FROM " . DB_PREFIX . "limit_name WHERE '$nick_name' like concat('%',name,'%')")) {
- $user_info['nick_name'] = str_replace($limit_sql, '*', $nick_name);
- }
- $name = $user_info['nick_name'];
- $id = $user_info['id'];
- //更新数据库
- $sql = "update " . DB_PREFIX . "user set nick_name = '$name',sex={$sex} where id=" . $id;
- $GLOBALS['db']->query($sql);
- //更新redis
- user_deal_to_reids(array($id));
- }
- $return['status'] = 1;
- $return['error'] = "登录成功";
- $return['data'] = $user_info['id'];
- $return['user_id'] = $user_info['id'];
- $return['nick_name'] = $user_info['nick_name'];
- $return['is_agree'] = intval($user_info['is_agree']);//是否同意直播协议 0 表示不同意 1表示同意
- $return['user_info']['user_id'] =$user_info['id'];
- $return['user_info']['nick_name'] =$user_info['nick_name'];
- $return['user_info']['mobile'] =$user_info['mobile'];
- $return['user_info']['head_image'] =get_spec_image($user_info['head_image']);
- }
- else{
- $return['status'] = 0;
- $return['error'] = "登录失败";
- $return['data'] ='';
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "未获取用户授权";
- }
- return $return;
- }
- // 购物直播SDK
- function sdkMakeUser($sdk_user_info){
- if($sdk_user_info['shop_user_id']!=""){
- $has_user = false;
- if($sdk_user_info['shop_user_id'])
- $has_user = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where shop_user_id='".$sdk_user_info['shop_user_id']."' ");
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //===========add end ===========
- $now_time = NOW_TIME;
- if(!$has_user){
- //需要通过接口的方式,获得一个新用户id
- $user_id = get_max_user_id(0);
- $data=array();
- $data['id'] = $user_id ;
- $GLOBALS['db']->query("set names 'utf8mb4'");
- $data['nick_name']= htmlspecialchars_decode($sdk_user_info['nick_name']);
- $data['is_effect'] = 1;
- if($sdk_user_info['head_image']!=''){
- $data['head_image']= $sdk_user_info['head_image'];
- }else{
- $data['head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- if($sdk_user_info['thumb_head_image']!=''){
- $data['thumb_head_image']= $sdk_user_info['thumb_head_image'];
- }else{
- $data['thumb_head_image']= get_domain().'/theme/images/defaulthead.png';
- }
- $data['sex']= $sdk_user_info['sex'];
- $data['is_shop']= $sdk_user_info['is_shop'];
- $data['shop_user_id']= $sdk_user_info['shop_user_id'];
- $data['create_time']= NOW_TIME;
- $data['user_pwd']= md5(rand(100000,999999));
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $data['synchronize'] = 0;
- $data['emotional_state'] ='保密';
- $data['province'] = '火星';
- $data['job'] = '主播';
- $data['user_level'] = 1;
- $data['login_type'] = 4;
- $data['is_remind'] = 1;//默认开通推送
- $GLOBALS['db']->autoExecute(DB_PREFIX."user",$data);
- $user_info = $data;
- //===========add start ===========
- $ridis_data = $user_redis->reg_data($data);
- $user_redis->insert_db($user_id,$ridis_data);
- //===========add end ===========
- }else{
- if($has_user['is_effect'] != 1){
- $return['status'] = 0;
- $return['error'] = "帐户已被禁用";
- $return['data'] =$has_user['id'];
- return $return;
- }else{
- $user_id = $has_user['id'];
- $user_info = $has_user;
- $GLOBALS['db']->query("update ".DB_PREFIX."user set login_ip = '".CLIENT_IP."',login_time='".to_date(NOW_TIME,"Y-m-d H:i:s")."' where id =".$user_id);
- //===========add start ===========
- $data =array();
- $data['login_ip'] = CLIENT_IP;
- $data['login_time'] = to_date($now_time);
- $user_redis->update_db($user_id,$data);
- //===========add end ===========
- }
- }
- //es_session::set_sessid($sdk_user_info['session_id']);
- es_session::set("user_info", $user_info);
- //设置session过期时间一个月
- es_session::setGcMaxLifetime('2592000');
- if($user_info['id']!=''){
- //登录成功 同步信息
- accountimport($user_info);
- $return['status'] = 1;
- $return['error'] = "登录成功";
- $return['video_user_id'] = $user_info['id'];
- $return['session_id'] = $sdk_user_info['session_id'];
- //设置cookie
- es_cookie::set("client_ip",CLIENT_IP,3600*24*30);
- es_cookie::set("nick_name",$user_info['nick_name'],3600*24*30);
- es_cookie::set("user_id",$user_info['id'],3600*24*30);
- es_cookie::set("user_pwd",md5($user_info['user_pwd']."_EASE_COOKIE"),3600*24*30);
- es_cookie::set("PHPSESSID2",$sdk_user_info['session_id'],3600*24*30);
- es_session::set("user_id", $has_user['id']);
- es_session::set("user_pwd", md5($has_user['user_pwd']."_EASE_COOKIE"));
- }
- else{
- $return['status'] = 0;
- $return['error'] = "登录失败";
- $return['data'] ='';
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "请填写购物系统用户ID";
- }
- return $return;
- }
- //同步登陆信息
- function accountimport($user_info){
- if($user_info['synchronize'] == 0){
- require_once(APP_ROOT_PATH.'system/tim/TimApi.php');
- $api = createTimAPI();
- $ret = $api->account_import((string)$user_info['id'], (string)$user_info['nick_name'], get_spec_image($user_info['head_image']));
- if($ret['ErrorCode']==0){
- $GLOBALS['db']->query("update ".DB_PREFIX."user set synchronize = 1 where id =".intval($user_info['id']));
- }
- //更新redis
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/BaseRedisService.php');
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- $user_id = $user_info['id'];
- $user = array();
- $user['synchronize'] = 1;
- $user_redis->update_db($user_id,$user);
- }else{
-
- }
- }
- //更新微信opendid
- function wxUser_update($wx_info,$user_id){
- $m_config = load_auto_cache("m_config");//初始化手机端配置
- if($wx_info['unionid']!=""||$wx_info['openid']!=""){
- $has_wx_info = false;
- if($wx_info['unionid'])
- $has_wx_info = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_unionid = '".$wx_info['unionid']."' and id=".$user_id);
- if(!$has_wx_info && $wx_info['openid'])
- $has_wx_info = $GLOBALS['db']->getRow("select * from ".DB_PREFIX."user where wx_openid='".$wx_info['openid']."' and id=".$user_id);
- //===========add start ===========
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- //===========add end ===========
- if(!$has_wx_info){
- $status = $GLOBALS['db']->query("update ".DB_PREFIX."user set wx_openid = '".$wx_info['openid']."',wx_unionid = '".$wx_info['unionid']."' where id =".$user_id);
- //===========add start ===========
- $data =array();
- $data['wx_openid'] = $wx_info['openid'];
- $data['wx_unionid'] = $wx_info['unionid'];
- $user_redis->update_db($user_id,$data);
- }else{
- /*$return['status'] = 0;
- $return['error'] = "wx_openid已存在,无法写入!";
- return $return;*/
- $status = 1;
- }
- if($status){
- //登录成功 同步信息
- $return['status'] = 1;
- $return['error'] = "您已成功绑定微信,请手动关注".$m_config['subscription'];
- $user_info= $GLOBALS['db']->getRow("select subscribe,wx_openid,mobile from ".DB_PREFIX."user where id=".$user_id);
- $return['subscribe'] =$user_info['subscribe'];
- if($user_info['wx_openid']!='')
- $return['binding_wx'] = 1;
- else
- $return['binding_wx'] = 0;
- if($user_info['mobile']!='')
- $return['mobile_exist'] = 1;
- else
- $return['mobile_exist'] = 0;
- }else{
- $return['status'] = 0;
- $return['error'] = "账号绑定微信失败";
- }
- }else{
- $return['status'] = 0;
- $return['error'] = "未获取用户授权";
- }
- return $return;
- }
- /**
- * 会员日志变化操作函数
- * @param array $data 包括 diamonds
- * @param integer $user_id
- * @param string $log_msg 日志内容
- * @param array $param 要插入的数组
- */
- function account_log($data,$user_id,$log_msg='',$param=array())
- {
- if($user_id>0&&$log_msg!=''){
- //写入日志
- $type = intval($param['type'])>0?$param['type']:0;
- $diamonds = abs($data['diamonds'])?abs($data['diamonds']):0;
- $ticket = intval($data['ticket'])?intval($data['ticket']):0;
- $score = intval($data['score'])?intval($data['score']):0;
- $video_id = intval($data['video_id'])?intval($data['video_id']):0;
- if(intval($param['is_admin'])){
- $adm_session = es_session::get(md5(conf("AUTH_KEY")));
- $adm_id = intval($adm_session['adm_id']);
- }else{
- $adm_id = 0;
- }
- $money = floatval($data['money']);
- $user_log = array();
- $user_log['log_info'] =$log_msg;
- $user_log['log_time'] =get_gmtime();
- $user_log['log_admin_id'] =$adm_id;
- $user_log['user_id'] =$user_id;
- $user_log['type'] =$type;
- $user_log['diamonds'] =$diamonds;
- $user_log['ticket'] =$ticket;
- $user_log['score'] =$score;
- $user_log['video_id'] =$video_id;
- $user_log['money'] = $money;
- $where = " id =".$user_id;
- $GLOBALS['db']->autoExecute(DB_PREFIX."user_log",$user_log,'INSERT',$where);
- }
- }
- //获得用户头像存储路劲
- function get_image_path(){
- $dir_name = to_date(get_gmtime(),"Ym");
- if (!is_dir(APP_ROOT_PATH."public/attachment/".$dir_name)) {
- @mkdir(APP_ROOT_PATH."public/attachment/".$dir_name);
- @chmod(APP_ROOT_PATH."public/attachment/".$dir_name, 0777);
- }
- $dir_name = $dir_name."/".to_date(get_gmtime(),"d");
- if (!is_dir(APP_ROOT_PATH."public/attachment/".$dir_name)) {
- @mkdir(APP_ROOT_PATH."public/attachment/".$dir_name);
- @chmod(APP_ROOT_PATH."public/attachment/".$dir_name, 0777);
- }
- $dir_name = $dir_name."/".to_date(get_gmtime(),"H");
- if (!is_dir(APP_ROOT_PATH."public/attachment/".$dir_name)) {
- @mkdir(APP_ROOT_PATH."public/attachment/".$dir_name);
- @chmod(APP_ROOT_PATH."public/attachment/".$dir_name, 0777);
- }
- $save_rec_Path = "/public/attachment/".$dir_name."/origin/"; //上传时先存放原图
- $savePath = APP_ROOT_PATH."public/attachment/".$dir_name."/origin/"; //绝对路径
- if (!is_dir(APP_ROOT_PATH."public/attachment/".$dir_name."/origin/")) {
- @mkdir(APP_ROOT_PATH."public/attachment/".$dir_name."/origin/");
- @chmod(APP_ROOT_PATH."public/attachment/".$dir_name."/origin/", 0777);
- }
- $root['save_rec_Path'] = $save_rec_Path;
- $root['savePath'] = $savePath;
- return $root;
- }
- //支付宝认证更新user
- function AuthentAlipayUser($user_data){
-
- //开始数据验证
- $res = array('status'=>1,'error'=>'','data'=>''); //用于返回的数据
- if(trim($user_data['id'])=='')
- {
- $res['status'] = 0;
- $res['error']='用户编号不能为空';
- return $res;
- }
-
- if(isset($user_data['alipay_user_id']))
- $user['alipay_user_id']= $user_data['alipay_user_id'];
-
- if(isset($user_data['alipay_name']))
- $user['alipay_name']= $user_data['alipay_name'];
-
- if(isset($user_data['alipay_authent_token']))
- $user['alipay_authent_token']= $user_data['alipay_authent_token'];
-
- if(isset($user_data['v_type']))
- $user['v_type']= $user_data['v_type'];
-
- $user_id = intval($user_data['id']);
-
- $where = "id=".$user_id;
- if(intval($GLOBALS['db']->getOne("select id from fanwe_user where v_type=3 and id=".$user_id." and alipay_authent_token <>''")))
- {
- $res['status'] = 0;
- $res['error']='用户支付宝已认证';
- return $res;
- }
-
- if($GLOBALS['db']->autoExecute(DB_PREFIX."user",$user,'UPDATE',$where))
- {
- //更新redis
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/BaseRedisService.php');
- fanwe_require(APP_ROOT_PATH.'mapi/lib/redis/UserRedisService.php');
- $user_redis = new UserRedisService();
- $user_redis->update_db($user_id,$user);
- $res['status'] = 1;
- $res['error']='认证成功!';
- }
-
- return $res;
- }
- ?>
|