';
//        print_r($stations);
//        die();
        if($stations){
            $sql = "SELECT pile_id FROM pile  where owner=:owner ";
            $piles = Yii::$app->db->createCommand($sql, [':owner' => self::$Owner])->queryAll();
            if($piles)
                $piles=self::formArr($piles);
            self::insertPile($stations,$piles);
            $zhanList=Zhanlist::find()->select(['zhan_id'])->where(['supplier'=>self::$Owner])->asArray()->all();
            if(!empty($zhanList)){
                $aa=[];
                foreach ($zhanList as $k=>$v){
                    $aa[]=$v['zhan_id'];
                }
                $zhanList=$aa;
            }

            $cityCode=static::getCityCode();

            self::insertStation($stations,$cityCode,$zhanList);

            $page=$stations['PageCount'];
            //所有页信息
            for($i=2;$i<=$page;$i++){
                $data2=self::getStationDate($i);
                $da2 = self::CurlSend($url, $data2, $token);
                $da2=self::decryptString($da2['Data']);
                $da2=json_decode($da2,true);
                if($da2)
                    self::insertStation($da2,$cityCode,$zhanList);
                self::insertPile($da2,$piles);
            }
        }
    }
    static function padZero($str){
        $len=strlen(substr($str,strpos($str,'.')+1));
        $len=16-$len;
        for($i=0;$i<$len;$i++){
            $str.=0;
        }
        return $str;
    }
    static function pushCheck($fileName='change_status.txt'){
        $authorization=Yii::$app->request->headers->get('Authorization');
        $params=file_get_contents('php://input');
        $params=json_decode($params,true);
//        if(!empty($fileName))
//        self::writeLog($fileName,$params);
        $auths=explode(' ',trim($authorization));
        $auth=$auths[count($auths)-1];

        $checkParams=self::checkParams($params);
        if($checkParams!=2)
            return ['Msg'=>$checkParams.'为空','Ret'=>4003,'Data'=>['Status'=>1]];

        $re=self::fillParams($params['OperatorID']);
        if($re==1)
            return ['Msg'=>'OperatorID不存在','Ret'=>4003,'Data'=>['Status'=>1]];

        if($auth){
            if(self::checkToken($auth)==1)
                return self::encodeData(['Status'=>1],4002,'Token过期或者无效');
            $checkSig=self::checkSig($params['OperatorID'],$params);
            if($checkSig==1)
                return self::encodeData(['Status'=>1],4001,'签名错误');

            $data=self::decryptString($params['Data']);
            $data=json_decode($data,true);
//            if(!empty($fileName))
//            self::writeLog($fileName,$data);
            return ['code'=>200,'data'=>$data];
        }
        return self::encodeData(['Status'=>1],4002,'Bearer 未添加');
    }
    static function writeLog($name,$arr){
        if(is_array($arr)){
            if (@$_SERVER["HTTP_X_FORWARDED_FOR"])
                $ip = $_SERVER["HTTP_X_FORWARDED_FOR"];
            else if (@$_SERVER["HTTP_CLIENT_IP"])
                $ip = $_SERVER["HTTP_CLIENT_IP"];
            else if (@$_SERVER["REMOTE_ADDR"])
                $ip = $_SERVER["REMOTE_ADDR"];
            else if (@getenv("HTTP_X_FORWARDED_FOR"))
                $ip = getenv("HTTP_X_FORWARDED_FOR");
            else if (@getenv("HTTP_CLIENT_IP"))
                $ip = getenv("HTTP_CLIENT_IP");
            else if (@getenv("REMOTE_ADDR"))
                $ip = getenv("REMOTE_ADDR");
            else
                $ip = $_SERVER['REMOTE_ADDR'];
            $pushTime=['logTime'=>date('Y-m-d H:i:s',time()),'ip'=>$ip];
            $arr=array_merge($pushTime,$arr);
            $sub_dir=date('Y-m-d');
            $dir=Yii::getAlias('@app').'/../../../'.$sub_dir.'/'.$name;
            self::setFile($arr,$dir,true);
        }
    }
    public static function initeStatus(){
        $redis=Common::createRedis();
        $datas=Zhanlist::find()->select(['zhan_id'])->where(['supplier'=>self::$Owner])->asArray()->all();
        $token=self::getToken(2);
        self::$url=self::$url.'query_station_status';
        $data=[];
        foreach ($datas as $k=>$v){
            $data[]=$v['zhan_id'];
            $i=$k+1;
            if($i%25==0){
                $dd=self::statusDate($data);
                $da = self::CurlSend(self::$url, $dd,$token);
                $decode = self::decryptString($da['Data']);
                $decode = json_decode($decode, true);
                if($decode){
                    foreach ($decode['StationStatusInfos'] as $v1){

                        foreach ($v1['ConnectorStatusInfos'] as $v2){
                            $key=self::$Owner.'--'.$v2['ConnectorID'];
                            $value=$v2['Status'];
                            $redis->set($key,$value);
                        }
                    }
                }
                $data=[];
            }
        }
        if($data){
            $dd=self::statusDate($data);
            $da = self::CurlSend(self::$url, $dd,$token);
            $decode = self::decryptString($da['Data']);
            $decode = json_decode($decode, true);
            if($decode){
                if($decode['StationStatusInfos']){
                    foreach ($decode['StationStatusInfos'] as $v1){
                        if(empty($decode['ConnectorStatusInfos']))
                            continue;
                        foreach ($v1['ConnectorStatusInfos'] as $v2){
                            $key=self::$Owner.$v2['ConnectorID'];
                            $value=$v2['Status'];
                            $redis->set($key,$value);
                        }
                    }
                }
            }
        }
    }
    public static function statusDate($id){
        $datetime= date('YmdHis');
        $kk['StationIDs']=$id;
        $en = self::encryptString(json_encode($kk));
        $sig= self::$OperatorID . $en . $datetime . "0002";
        $s= self::hmac_md5($sig);
        $rr['OperatorID'] = self::$OperatorID;
        $rr['Data']= $en;
        $rr['TimeStamp']= $datetime;
        $rr['Seq']= '0002';
        $rr['Sig'] = $s;
        return $rr;
    }
}