作者归档 清心醉

<?php
class crc{

private $SerialNumber = 1; //自增加
private $SerialNumberXOR = 254; //自减少

function issleep($time = 1){
    sleep($time);
}

private $binFile = '';
private $getSocketData = ''; //获取的16进制数据
function setBinFile($str){
    $this->binFile .=$str;
}
function getBinFile($str){
    $this->binFile .=$str;
    //$this->getSocketData .=$str;
}

function CreateSetLogFile($file){
    $file = SET_FILE;
    if($this->binFile){
        $hexstr = str_replace(" ","",$this->binFile);
        $data = pack('H*', $hexstr);
        file_put_contents($file, $data, true);
    }

    //因为获取的是16进制 所以直接写入16进制文件
    $getfile = GET_FILE;
    if($this->getSocketData){
        //$hexstr = str_replace(" ","",$this->getSocketData);
        //$data = pack('H*', $hexstr);
        file_put_contents($getfile, $this->getSocketData, true);
    }
}

public $str = array();
function setlog($str){
    $this->str[] = $str;
    $str = $str."\r\n";
    echo iconv('utf-8','gbk//IGNORE',$str);
}

function chaString($string){
    $str = '';
    for($i=0;$i<strlen($string);$i++){
        $str .= $this->getByteData($i, $string);
    }
    return $str;
}

function getByteData($k,$str){
    if($k%2==0){
        return " ".$str[$k];
    } else {
        return $str[$k];
    }
}
//字符串转16进制
function strToHex($str){
    $hex="";
    for($i=0;$i<strlen($str);$i++)
        $hex.=dechex(ord($str[$i]));
        $hex=strtoupper($hex);
        return $hex;
}
//16进制转字符串
function hexToStr($hex){
    $str="";
    for($i=0;$i<strlen($hex)-1;$i+=2)
        $str.=chr(hexdec($hex[$i].$hex[$i+1]));
        return $str;
}

function crc16($string) {
    $crc = 0xA28C;
    for ($x = 0; $x < strlen ($string); $x+=2) {
        $sys = '';
        if(isset($string[$x]) && isset($string[$x+1])){
            $sys = $string[$x].$string[$x+1];
        } else {
            continue;
        }
        //echo "sys = ". $sys."\r\n";
        $sys = hexdec($sys);

        $crc  ^= $sys;
        for ($y = 0; $y < 8; $y++) {
            $lbs = $crc & 0x0001;
            $crc >>=1;
            if($lbs == 1){
                $crc ^= 0x8408;
            }
        }
    }
    $crc ^=0xFFFF;
    return $crc;
}


private function dechexSerialNumber(){
    $str = dechex($this->SerialNumber);
    $str = $this->setHeadZero($str);
    $this->SerialNumber++;
    return $str;
}
private function dechexSerialNumberXOR(){
    $str = dechex($this->SerialNumberXOR);
    $str = $this->setHeadZero($str);
    $this->SerialNumberXOR--;
    return $str;
}

//前补0
private function setHeadZero($str,$max = 2){
    $leng = strlen($str);
    for($i=$leng;$i<$max;$i++){
        $str = "0".$str;
    }
    return $str;
}
//后补0
private function setEndZero($str,$max = 4){
    $leng = strlen($str);
    for($i=$leng;$i<$max;$i++){
        $str = $str."0";
    }
    return $str;
}


public function getdata($packet){
    $data = array();
    $data[0] = '6D';
    $data[1] = 'AC';
    $data[2] = $this->dechexSerialNumber();
    $data[3] = $this->dechexSerialNumberXOR();
    $packetNum = count($packet); //Packet Length
    $packetNum = dechex($packetNum);
    $packetNum = $this->setHeadZero($packetNum,4); //因为高字节要在前,比如包长度=10 那么实际就是0010,高低位转换就是10 00
    //数据包长度高低位
    $data[4] = substr($packetNum, 2,2);
    $data[5] = substr($packetNum, 0,2);

    //指令开始 协议头
    $command = '';

    for($i=0;$i<count($data);$i++){
        $command = $command.$this->setHeadZero($data[$i])." ";
        //$crcString .= $this->setHeadZero($data[$i]);
    }
    $crcString = '';
    //指令内容体
    for($i=0;$i<count($packet);$i++){
        $command = $command.$this->setHeadZero($packet[$i])." ";
        $crcString .= $this->setHeadZero($packet[$i]);
    }
    $crc = '';
    $temp_crc = dechex($this->crc16($crcString));
    $sum = strlen($temp_crc);
    for($i=$sum;$i<4;$i++){
        $temp_crc = "0".$temp_crc;
    }
    $crc = $temp_crc;
    $crc1 = $this->setHeadZero(substr($crc,2,2));
    $crc2 = $this->setHeadZero(substr($crc, 0,2));
    $command = $command.$crc1. " ".$crc2;
    $commandArray = array();
    return $command;
}

private function heightlow($readInt){
    $byte1 = (($readInt & 0xff));
    $byte2 = (($readInt & 0xff00) >> 8);
    // 拼装成 "高字节在后，低字节在前"的格式
    $realint = ($byte1 & 0xff) << 0 | ($byte2 & 0xff) << 8;
    //echo $byte1." = ".$byte2."\r\n";
    return $realint;
}
//更新
public function getUpdatePacket(){
    $data[0] = 26; //command
    $data[1] = 11; //type
    //p2-p9
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    return $data;
}
//握手
public function getHandshake(){
    $data[0] = 20; //command
    $data[1] = 11; //type
    //p2-p9
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    return $data;
}

private $falshAddress = 64;
private $defaultFalshAddress = 64; //falsh默认的10进制地址

private function getFalshAddress($zizeng = true){
    $falshAddress = $this->falshAddress;
    if($zizeng == true){
        $this->falshAddress = $this->falshAddress+2;
    }
    return dechex($falshAddress);
}
//跳转到Application
public function runApp(){
    $data[0] = 21;
    $data[1] = 11;
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    return $data;
}

//校验falsh
public function checkFalsh($res){
    $data[0] = 25;
    $data[1] = 12; 
    //p2-p9
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    $data[3] = dechex($this->defaultFalshAddress);

    //大小 = 224*0x200;
    $data[10] = dechex($this->defaultFalshAddress);
    $data[11] = 56;
    $data[12] = 00;
    $data[13] = 00;
    //dechex(224*0x200);
    return $data;
}
//擦除
public function getRemove(){
    $data[0] = 24; //command
    $data[1] = 12; //type
    //p2-p9
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    $data[3] = $this->getFalshAddress(false);
    //大小 = 224*0x200;
    $data[10] = dechex($this->defaultFalshAddress);
    $data[11] = 56;
    $data[12] = 00;
    $data[13] = 00;
    //dechex(224*0x200);
    return $data;
}
//下载
public function getUpload($arr){
    $data[0] = 22; //command
    $data[1] = 12; //type
    //p2-p9
    for($i=2;$i<=9;$i++){
        $data[$i] = 00;
    }
    $data[3] = $this->getFalshAddress(); //dechex();
    $array = explode(" ",$arr);
    for($i=0;$i<count($array);$i++){
        if(!empty($array[$i])){
            $data[] = $array[$i];
        }
    }
    return $data;
}

}

使用方式:

$filename = “C:\crc\APP-2020-02-05.bin”;
$host = ‘192.168.1.122’;
$port = 502;
define(“SET_FILE”,’C:\crc\log.log’);
define(“GET_FILE”,’C:\crc\getlog.log’);

require_once ‘crc.php’;
$req = new crc();
$res = bin2hex(file_get_contents($filename));
if (!$res){
$req->setlog(“打开更新文件失败”);
return;
}
$req->setlog(“连接设备中…”);
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($sock, SOL_SOCKET, SO_SNDTIMEO,array(‘sec’ => 1, ‘usec’ => 1));
$result = @socket_connect($sock, $host, $port);
if($result == false){
$req->setlog(“设备连接失败”);
return false;
}

//发送数据
function send($sock,$packets,$crc){
$status = socket_last_error($sock);
if($status!=0){
return false;
}
//记录的数据为字符串,实际发送的时候 重新转换成16进制的数据格式
$t = $packets;
$packets = str_split(str_replace(‘ ‘, ”, $packets), 2); //chr(hexdec($packets));
$packet = null;
for($i=0;$isetBinFile($t);
$res = getrec($sock,$crc);
$crc->getBinFile(bin2hex($res));
$crc->setlog(“接收的16进制数据:”.bin2hex($res));
return true;
}

function getrec($socket,$crc){
$rec = null;
$time = time();
$crc->setlog(“接收数据”);
while (@socket_recv($socket, $rec, 4096, 0)) { //设置接收长度最大值缓冲区
if($time+10setlog(“接收数据超时”);
break;
}
return $rec;
}
return false;
}
//

$req->setlog(“设备连接成功”);
$req->setlog(“更新帧”);
$getUpdatePacket = $req->getUpdatePacket(); //更新的包
$packets = $req->getdata($getUpdatePacket);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();
$req->setlog(“握手”);
$getHandshake = $req->getHandshake(); //更新的包
$packets = $req->getdata($getHandshake);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();

$req->setlog(“擦除falsh”);
$getRemove = $req->getRemove();
$packets = $req->getdata($getRemove);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();

$arr = array();
$head = 0;
$end = 1024;
$length = strlen($res);
while(true){
if($length<=0){ break; } $arr[] = substr($res, $head,$end); $head = ($head+1024); $length = ($length-1024); } for($i=0;$isetlog(“第”.($i+1).”次下载数据”);
$str = $req->chaString($arr[$i]);;
$getUpload = $req->getUpload($str);
$packets = $req->getdata($getUpload);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();
}

$req->setlog(“校验falsh”);
$checkfalsh = $req->checkFalsh($res);
$packets = $req->getdata($checkfalsh);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();

$req->setlog(“跳转到Application”);
$runApp = $req->runApp();
$packets = $req->getdata($runApp);
$req->setlog($packets);
if(send($sock, $packets,$req) == false){
$req->setlog(“发送数据”.$packets.”失败”);
}
$req->issleep();

$req->setlog(“执行完成”);
$req->setlog(“创建写入文件”);
$req->CreateSetLogFile(SET_FILE);

说起多线程，一般的人都想到的是用C类语言，或者JAVA来开发

因为我是做PHP为主的，对JAVA了解的少，而用C实际开发项目的经验少，所以入坑了。

在这也简单的来和大家说下：

首先，我们会以CLI的方式来运行SERVER进程，在进程里，读取数据库的设备信息，实现线程的创建。

在这里，PHP基本使用的是Pthread的扩展Thread。

由于项目需要，我们在创建了线程之后，在线程里实现while(true)与设备通讯，获取设备的最新信息。

来说说重点吧：

1：服务器的环境配置，在这里大家一定要特别的注意，一定要用5.6+的ZTS-X64版本，建议使用W_PHP 7.0X或Linux 7.2.X版本，因为这两个版本网上都有最近的线程扩展模块。如果使用的是非ZTS-X64版本，那么很遗憾，线程永远开启不了超过200个。因为进行了多次的模拟测试，包括线程内执行死循环和跑完之后挂起，查看系统的资源使用，如果是X86系统下，因为内存的其他限制（详细的内存有得说了，不一一解释，自行翻资料查看86-64的内存使用哈）；

2：系统版本，一般开发调试，系统的最低要求是Windows7 SP1，LINUX则无限制（但必须都是X64），因为在WINDOWS下跑Thread需要VC2015的扩展支持；如果开发则还使用Windows7的，cmd->winver里查看版本内核是否低于7001,是的话，升级为SP1解决问题；

3：线程安全：现在网上什么ZTS、NTS的说话一大堆，都是老过时的东西，现在的线程安全，都是被人抄来抄去的过期文章！

PHP的Pthread扩展，V2和V3版本有了很大的实际变更，更像多线程的操作优化了；

A：V2版本，虽然实现了多线程，但一样可以通过稀哈操作数据数组，导致频繁的线程操作，导致线程挂起

B：线程内的成员在执行的时候，已经分配了适当的内存空间，也就是说一个空变量，分配了值=int(1)，这时候，是不可能进行=String的操作，更不可以变成数组等，所以在线程内获取的数据资源，需要使用其他TCP端口来接收或者其他更好的操作方法；（这才是更好的理解什么是线程安全ZTS，对内存中的所有分配好的资源，是不可以随意修改的，当然$i=0;$i=1之类的占用相同地址同类型的，还是可以的）

C：线程锁，如果多线程内需要对同一地址的数据进行操作，切忌使用锁，否则同一时间的操作导致线程的异常，也会导致线程中止退出。

D：就是线程的内存占用了，说真的，PHP的线程占用内存还真好，也许是因为我在线程内也有发起TCP请求其他的关系，导致1个线程使用内存都接近了1MB，所以我们能以行参的方式传递参数，就别用成员！数据的销毁也一定要记得！

来一段2000个的线程创建实例吧：

class ThreadMax extends thread{

private $id;

function __construct($id){

$this->id = $id;

}

function run(){

while(true){

//echo “ID=”.$this->id.”\n”; //不执行其他任务工作

sleep(1);

}

}

}

$thread = array();

for($i=1;$i<=2000;$i++){

$thread[$i] = new ThreadMax($i);

}

$default  =0;

while(true){

if($default==0){

for($i=1;$i<=2000;$i++){

$thread[$i]->start();

}

$default = 1;

}

echo “thread All is OK!”;

sleep(10);

}

return;

很多做WEB开发的人都知道，现在做WEB，都需要使用第三方比如支付宝、微信等 。拿国内的ecshop来说吧，我们在添加一个支付宝授权登陆、微信授权登陆，支付宝支付、微信支付的时候，都会需要对不同的模块进行频繁的修改，虽然说也有封装部分的接口，但也不能得尽人意。而且如果后续要对接比如PAYPAY支付、GOOGLE支付等其他第三方支付的时候，会显示出我们写的代码的质量是多么的脆弱，好吧，上正题，本文将从登陆开始，来实现系统化的调用。

该文章作者会大概的阐述自定义

首先我们来定个目标变量，假设支付宝=0，微信=1

//定义第三方接口参数注册
$api = array(
0=>array(
‘extend’=>’AlipayApi’, //接口类名
‘useragent’=>’AlipayClient’,//接口识别用户访问类型
),
1=>array(
‘extend’=>’Weixin’,
‘useragent’=>’MicroMessenger’,
),
);

在这里我们定义好了第三方的接口所需要的信息。

一维代表类型，当然也可以自身在数据库中用户表来进行捆绑识别

二维代表实际参数extend表示需要调用的第三方文件类库，useragent是针对HTML5里识别APP的访问类型。

好吧，我们先从访问开始。

用户在进行HTML登陆的时候，当然也可以对接帐号密码登陆，因为我们都是通过$_SESSION来进行；

class LoginAPI{
function getlogin($user_agent,$store_id){
for ($i=0;$i<count($api);$i++){
if (strpos($user_agent,$api[$i][‘useragent’])){
$login = new $api[$i][‘extend’]();
$url = $login->getLoginApi($store_id);
header(“Location:”.$url);
exit();
}
}
die(“<h1>ERROR</h1>”);
}
}

我们在需要使用的地方，直接实例化LoginAPI，调用方法，附加用户的标识，交由脚本执行。

由于作者实际写的系统是针对HTML5为主，授权登陆我们都知道，需要跳转到支付宝、微信的开放平台的接口，执行实现回调URL；

$url = $login->getLoginApi($store_id);

我们来看看目录结果：

/loginapi.php //授权类

/api/alipay.php  //支付宝类，包括登陆、支付、模板消息

/api/weixin.php //微信类，包括登陆、支付、模板消息

上文的代码中我们没有看到任何实际性的requirce，因为作者使用的是自己写的框架，里面对常用的接口进行过requcie，虽然浪费资源，但能更快效率的进行实例化调用，而且现在大内存时候，也不用去考虑这一块；

好了，回正题，我们来看看调用的实际登陆

/***
* 支付获取请求的URL
* @return string
*/
function getLoginApi($store_id){
$url=’https://openauth.alipay.com/oauth2/publicAppAuthorize.htm?’;
$url.=’app_id=’.$this->appid;
$url.=’&scope=auth_userinfo’;
$url.=’&redirect_uri=’.HTTP_SERVER.’api/alipay.php’;
$url.=’&state=’.$store_id;
return $url;
}

/***
* 微信获取登陆授权
* @param unknown $store_id
* @return string
*/
public function getLoginApi($store_id){
$url =’https://open.weixin.qq.com/connect/oauth2/authorize?’;
$url.=’appid=’.$this->appid;
$url.=’&redirect_uri=’.HTTP_SERVER.’api/weixin.php’;
$url.=’&response_type=code&scope=snsapi_userinfo’;
$url.=’&state=’.$store_id;
$url.=’#wechat_redirect’;
return $url;
}

这样一来，我们如果要添加京东授权登陆，添加对应的class添加对应的功能，然后统一回调写入数据库即可。

至于添加的时候，需要注册到全局的API里面，以方便在for()里实现调用

如此我们打开支付宝、微信，调用的都是同一个方法名，实现同样的效果，不再需要频繁的写switch(),if()来判断用户的登陆类型了。

下文作者将讲解模块化的支付、回调，代码前瞻：

return $this->pay_class[$this->login_type]->Pay($this->store_id,$this->order_id,$this->store_system,$title,$this->money,$this->customer,$this->return_url);

$msg = new wxmsg();#实例化消息模板
$msg->setAccessToken($msg->getAccessToken()); #获取令牌并写入到类成员
$templatelist = $msg->getTemplateList();
if(count($templatelist)<=0){ #如果模板数量小于0，直接中止
return false;
}
for($i=0;$i<count($templatelist);$i++){
if($templatelist[$i][‘title’]==’订单支付成功’){ #如果消息模板中包含订单支付成功，下发通知信息
$openid=’ocbV9wGjFMbfGTUvh89Ro9J-ng7s’;
$productName=’测试的产品’;
$productDescription=’发送时间：’.date(‘Y-m-d H:i:s’);
$return_url = ‘http://www.qingxinzui.com/’;
$money = ‘123.45’;
$data = $msg->SendMsg($openid, $templatelist[$i][‘template_id’], $productName, $productDescription,$return_url,$money);
break;
}
}

然后是类的扩展：：

<?php

/*******
*
* 本类库只提供小心模板下发，不进行模板配置
* 需要设置的模板库为：TM00015
*
* @author IPanYing
*
*/
class wxmsg{

private $appid;
private $appsecret;
private $access_token;

public function __construct(){
$this->appid = ”;
$this->appsecret = ”;
}

public function setAccessToken($access_token){
$this->access_token = $access_token;
}
public function getAccessToken(){
$url = “https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=$this->appid&secret=$this->appsecret”;
$AccessToken = $this->IPanYingGETCURL($url);
if (isset($AccessToken[‘access_token’]) && !empty($AccessToken[‘access_token’])){
return $AccessToken[‘access_token’];
} else {
return false;
}
}

public function getMsgModelName(){
$url = “https://api.weixin.qq.com/cgi-bin/template/get_industry?access_token=$this->access_token”;
return $this->IPanYingGETCURL($url);
}

public function getTemplateList(){
$url=”https://api.weixin.qq.com/cgi-bin/template/get_all_private_template?access_token=$this->access_token”;
$list = $this->IPanYingGETCURL($url);
return $list[‘template_list’];
}

public function SendMsg($openid,$template_id,$producttext,$remarktext,$return_url,$money){
$return_url=’http://www.ipanying.com/’;
$data = array(
‘touser’=>”$openid”,
‘template_id’=>”$template_id”,
‘url’ =>”$return_url”,
‘topcolor’=>’#FF0000’,
‘data’=>array(
‘first’=>array(‘value’=>’尊敬的用户，你的支付订单信息如下：’,’color’=>’#173177′),
‘orderMoneySum’=>array(‘value’=>$money,’color’=>’#173177’),
‘orderProductName’=>array(‘value’=>$producttext,’color’=>’#173177’),
‘Remark’=>array(‘value’=>$remarktext,’color’=>’#173177’)
)
);
$url = “https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=$this->access_token”;
return $this->IPanYingPOSTCURL($url, $data);
}

private function IPanYingGETCURL($url){
$data = file_get_contents($url);
$data = (array)json_decode($data,true);
return $data;
}

private function IPanYingPOSTCURL($url, $data){
//$data = urldecode(json_encode($data));
$data = json_encode($data);
$post = array(
‘http’ =>array(
‘method’ => ‘POST’,
‘header’ => ‘Content-type: application/x-www-form-urlencoded’,
‘content’ => $data
)
);
$context = stream_context_create($post);
$data = file_get_contents($url, false, $context);
$data = (array)json_decode($data,true);
return $data;
}

}

?>

wxmsg-class

<?php
/***
*
#–地图位置计算类库
$ipanying = new ipanying(); //实例化地图类库

#–构造商家数据坐标集
$data =array(
0 =>array(
‘mid’=>’111’,
‘lng’=>’111.111’,
‘lat’=>’22.22’
),
1 =>array(
‘mid’=>’112’,
‘lng’=>’112.112’,
‘lat’=>’23.23’
)
);

#–数据回调URL，把计算出的用户与商家的实际距离进行AJAX请求该URL
$return_url = ‘http://’.$_SERVER[‘HTTP_HOST’].’/ipanying.php’;
echo $ipanyingmap->getUserDir($data, $return_url, ‘color:red’);
*/
class ipanying{

/***
*
* @param unknown $ipanying #–商家地理位置二维数组
* @param unknown $return_url #–计算出的距离的数据AJAX请求URL
* @param unknown $style #–INPUT样式
* @param string $text #–显示的文字，比如没获取之前可以说获取位置，获取成功之后可以是更新位置等
* @param string $key #–KEY密钥
* @return string #–返回一个JS代码的页面字符串
* 注：在return接收页，lng，lat实际为用户的坐标数据，type=’dir’，
* 获取数据之后，销毁POST的lng,lat,type
*/
function getUserDir($ipanying,$return_url,$style,$text=’获取位置’,$key=’您的KEY值’){
$html='<script type=”text/javascript” src=”ipanying.js”></script>’;
$html.=”
<script type=’text/javascript’ src=’http://webapi.amap.com/maps?v=1.3&key=”.$key.”‘></script>
<script>
var usermap, geolocation;
var ipanyingmap_url='”.$return_url.”‘;
function getAddress(){
usermap = new AMap.Map(‘container-ipanying’, {
resizeEnable: true
});

usermap.plugin(‘AMap.Geolocation’, function() {
var geolocation = new AMap.Geolocation({
enableHighAccuracy: true,
timeout: 10000,
buttonOffset: new AMap.Pixel(10, 20),
zoomToAccuracy: true,
buttonPosition:’RB’
});
usermap.addControl(geolocation);
geolocation.getCurrentPosition();
AMap.event.addListener(geolocation, ‘complete’, onComplete);
});
}
//解析定位结果
function onComplete(data) {
var lng = data.position.getLng();
var lat = data.position.getLat();
if(lng==null || lng==undefined || lat==null || lat==undefined){
alert(‘用户坐标为空，无法计算’);
return false;
}
var ipanying = new Array();
“;

#—循环输出商家数据到JS
for($k=0;$k<count($ipanying);$k++){
$html.=”ipanying[$k]=new Array();
ipanying[$k][‘mid’]=”.$ipanying[$k][‘mid’].”;
ipanying[$k][‘dir’] = [“.$ipanying[$k][‘lng’].”,”.$ipanying[$k][‘lat’].”];”;
}

$html.=”
shangjiamaps(ipanying,lng,lat);
} //onComplete结束

function shangjiamaps(lnglats,xdir,ydir){ //位置计算方法
var str =’lng=’+xdir+’&lat=’+ydir;
for (var i = 0; i < lnglats.length; i++) {
var marker = new AMap.Marker({
position: lnglats[i],
//map: map
});
if(xdir == ” || xdir == undefined || xdir==null || ydir == ” || ydir == undefined || ydir==null){
var isadd =’nulls’;
} else {
var islnglat = new AMap.LngLat(xdir,ydir);
var cl = islnglat.distance(lnglats[i][‘dir’]);
var isadd = cl.toFixed(0);
}
str +=’&’+lnglats[i][‘mid’]+’=’+isadd;
//alert(‘距离商家ID’+lnglats[i][‘mid’]+’有’+isadd+’米’);
}
qingxinzui_alert(ipanyingmap_url,str,’dir’);
//alert(str);
}
</script>”;
$html.='<input type=”submit” onclick=”getAddress();” value=”‘.$text.'” style=”‘.$style.'” />’;
return $html;
}
}

if(isset($_POST[‘type’]) && $_POST[‘type’]==’dir’){
//处理回调
unset($_POST[‘type’]; //销毁类型参数

$userlng=$_POST[‘lng’]; //提取用户经度
$userlat=$_POST[‘lat’]; //提取用户纬度
//在这里获取的用户经纬度信息自行保留至SESSION或者COOKIE或者SQL

unset($_POST[‘lng’]); //销毁POST经度
unset($_POST[‘lat’]); //销毁POST纬度
$ipanying = $_POST; //数据给予数组
$text = ”;
foreach($ipanying as $key => $value){
$text.=’用户距离商家ID’.$key.’的直线距离=’.$value.’米 <br \>’;
}
}

扩展类库下载：高德地图距离计算类库PHP版

请尊重开源，转发请注明出处！