crm_system/Normand/helongcrm/service/common/lib/Mt4Api.php

<?php
namespace common\lib;

use common\helpers\Utils;
use backend\models\Config;
class Mt4Api {

    protected $realip = '';

    protected $port = '';

    public function __construct($realip, $port)
    {
        $this->realip = $realip;
        $this->port = $port;
    }


    public function MQ_Query($query,$real = 0 ){
        $ret='error';
        //---- open socket
        $ptr=@fsockopen($this->realip,$this->port,$errno,$errstr,5);
        /*
        if( $real ){
            $ptr=@fsockopen($this->realip,$this->port,$errno,$errstr,5);
        }else{
            $ptr=@fsockopen($this->demoip,'443',$errno,$errstr,5);
        }
        */
		
        //---- check connection
        if($ptr){
        //---- send request
            if(fputs($ptr,"W$query\nQUIT\n")!=FALSE){
                //---- clear default answer
                $ret='';
                //---- receive answer
                while(!feof($ptr)) {
                    $line=fgets($ptr,128);
                    if($line=="end\r\n") break; 
                    $ret.= $line;
                } 
            }
            fclose($ptr);
        }
        //---- return answer
        return $ret;
    }
    
    public function addAccount($data, $real = 0){
        //字段:
        //INVESTOR   STATUS  ZIPCODE  ID  SEND_REPORTS PHONE_PASSWORD 属性不明 
        $configData = Config::find()->asArray()->one();

        $data['MASTER'] = $configData['mt4_master'];
        $data['IP'] = isset($data['IP']) && trim($data['IP']) != '' ? trim($data['IP']) : Utils::getClientIp();
        $data['GROUP'] = isset($data['GROUP']) ? trim($data['GROUP']) : '';
        $data['NAME'] = isset($data['NAME']) ? trim($data['NAME']) : '';
        $data['PASSWORD'] = isset($data['PASSWORD']) ? trim($data['PASSWORD']) : '';
        $data['INVESTOR'] = isset($data['INVESTOR']) ? trim($data['INVESTOR']) : '';
        $data['EMAIL'] = 'email';
        $data['COUNTRY'] =  'hk';
        $data['STATE'] =  'hk';
        $data['CITY'] = 'hk';
        $data['ADDRESS'] = 'hk';
        $data['PHONE'] = '00000000';
        $data['PHONE_PASSWORD'] = isset($data['PHONE_PASSWORD']) ? trim($data['PHONE_PASSWORD']) : '';
        $data['STATUS'] = '';
        $data['ZIPCODE'] = isset($data['ZIPCODE']) ? trim($data['ZIPCODE']) : '';
        $data['ID'] = isset($data['ID']) ? trim($data['ID']) : '';
        $data['LEVERAGE'] = isset($data['LEVERAGE']) ? trim($data['LEVERAGE']) : '';
        $data['AGENT'] = 0;
        $data['SEND_REPORTS'] = 1;
        $data['DEPOSIT'] = '';
        $data['COMMENT'] = '';
        $data['LOGIN'] = isset($data['LOGIN']) ? $data['LOGIN'] : '';

        // iconv('GB2312', 'UTF-8', $str);
        //iconv('GB2312', 'UTF-8', $str);

        $data['NAME'] = iconv("utf-8", "gbk", $data['NAME']);

        /*
        $query = 'NEWACCOUNT MASTER='.$data['MASTER'].'|IP='.$data['IP'].'|GROUP='.$data['GROUP'].'|NAME='.$data['NAME'].'|PASSWORD='.$data['PASSWORD'].
            '|INVESTOR='.$data['INVESTOR'] .'|EMAIL=email|COUNTRY=hk|STATE=hk|CITY=hk|ADDRESS=hk|COMMENT='.$data['COMMENT'].'|PHONE=000000000|PHONE_PASSWORD='.$data['PHONE_PASSWORD'].'|STATUS=resident|ZIPCODE=000000|ID=10|LEVERAGE='.$data['LEVERAGE'].'|AGENT=0'.
            '|SEND_REPORTS=1|DEPOSIT=0';
        */
        
        //--- prepare query

		$query="NEWACCOUNT MASTER={$data['MASTER']}|IP={$data['IP']}|GROUP={$data['GROUP']}|NAME={$data['NAME']}|".
          "PASSWORD={$data['PASSWORD']}|INVESTOR={$data['INVESTOR']}|EMAIL={$data['EMAIL']}|COUNTRY={$data['COUNTRY']}|".
          "STATE={$data['STATE']}|CITY={$data['CITY']}|ADDRESS={$data['ADDRESS']}|COMMENT={$data['COMMENT']}|".
          "PHONE={$data['PHONE']}|PHONE_PASSWORD={$data['PHONE_PASSWORD']}|STATUS={$data['STATUS']}|ZIPCODE={$data['ZIPCODE']}|".
          "ID={$data['ID']}|LEVERAGE={$data['LEVERAGE']}|AGENT={$data['AGENT']}|SEND_REPORTS={$data['SEND_REPORTS']}|".
          "DEPOSIT={$data['DEPOSIT']}";

		//--- send request

		//echo $query;die;

        $ret = $this->MQ_Query($query, $real);

        $info = $this->qgstr($ret);
        return $info;
    }
    
    //处理api返回的信息 如: OK LOGIN=50010  or ERROR IP is blocked. Please wait 60 secs and try again.  
    
    protected function qgstr($str)
	{
        if( strstr($str, 'OK')){
            $tmp = explode('=', $str);
			$login = str_replace('\r\n', '', $tmp[1]);
			return array('Ret'=>0, 'Obj'=> array('Login' => $login));	
        }else{
            return array('Ret'=>1, 'str'=>$str);
        }
    }
    
}