kly_api/prjcenter/prjKLY/bizcenter/Trader2/fetchMinaOpenid.php

<?php 
defined('ONLY_ONLY_ONLY') or exit('Access Denied');
define('LOG_CATALOG',basename(__FILE__));
try{     
    $subSystem=intval(SUBSYS_CAPITAL2_MINA); 
    $baseUser=bizwx_fetchMinaOpenid($subSystem);
    $FOREND_TOKEN=$baseUser["FOREND_TOKEN"];
    $GPC=input_param_handle(false);    
    $ajaxdata = input_getPostObj();
    $regmode = isset($ajaxdata["regmode"]) ? $ajaxdata["regmode"] : $GPC["regmode"]; 
    if(empty(trim($regmode))){        
        /***UPSERT手机用户对应的业务用户记录**start***/
        $sqlTemp="";
        $sqlParam=array();   
        $sqlParam[":nowtime"]=time();
        $sqlParam[":base_userid"]=$baseUser["id"];           
        $sqlParam[":remark"]="[" . date("Y-m-d H:i:s", time()) . "] 初始化注册 \n";
        $sqlTemp.=" set @handle_id=0; ";
        $sqlTemp.=" select @handle_id:=`id` from biz_trader2 where `base_userid`=:base_userid limit 1;";        
        $sqlTemp.=" insert into biz_trader2 ( `createtime`,`base_userid`,  remark )";
        $sqlTemp.="    select                 :nowtime,    :base_userid,  :remark from dual where ifnull(@handle_id,0)=0 ;";        
        $sqlTemp.=" update biz_trader2 SET `updatetime`=:nowtime, remark=concat(:remark,ifnull(remark,'')) where ifnull(@handle_id,0)!=0 and `base_userid`=:base_userid;";      
        $sqlTemp.=" select @biz_userid:=id from biz_trader2 where `base_userid`=:base_userid limit 1;";
        $sqlTemp.=" update base_user SET `updatetime`=:nowtime, biz_userid=ifnull(@biz_userid,0) where id=:base_userid;";
        $sqlTemp.=" select * from biz_trader2 where `base_userid`=:base_userid limit 1;";
        $dataset=pdo_query3($sqlTemp,$sqlParam);   
        /***UPSERT手机用户对应的业务用户记录**finish***/  
        $bizTrader2=$dataset[count($dataset)-1][0];       
        if(empty($bizTrader2)) throw new GeneralException("","异常");
    }else{
        $bizTrader2=pdo_fetch("select zu.*,bu.id as buid,bu.wxmina_appid,bu.wxmina_openid 
        from biz_trader2 as zu 
        left join base_user as bu on bu.id=zu.base_userid
        where zu.`base_userid`=:base_userid limit 1;",array(":base_userid"=>$baseUser["id"],));
    }  
    $ajaxRes->Result=array(
        "forendToken"=>$FOREND_TOKEN,
        "baseUser"=>$baseUser,
        "bizTrader2"=>$bizTrader2,
    );       
}catch(Throwable $e){
    $friendMsg=get_class($e)=='GeneralException'?$e->friendmsg:$e->getMessage();
    throw new GeneralException("General","获取用户登录信息时发生异常：".$friendMsg,LOG_CATALOG,0,$e);
}