@@ -243,7 +243,9 @@ class Base_Controller extends CI_Controller {
$sendData = $funcode.$version.'01'.$manucode.$data;
$sendData .= crc16(pack('H*',$sendData));
// var_dump($sendData);die;
- return lampMqttCmd('/IDCOL/CmdInput/'.$address,'/IDCOL/CmdOutput/'.$address,pack('H*',$sendData),$timeout);
+ $seq = '9'.substr($funcode,-1);
+ $seq = strtolower($seq);
+ return lampMqttCmd('/IDCOL/CmdInput/'.$address,'/IDCOL/CmdOutput/'.$address,pack('H*',$sendData),$timeout,$seq);
}
// 根据设备地址获取制造商
@@ -118,7 +118,7 @@ function lampMqttCmd($sendTopic,$backTopic,$sendData,$timeout = 5,$seq = ''){
$true = $mqtt->proc();
if (!empty($seq) && $true != 1){
$res = unpack('H*', $true['msg']);
- if (substr($res[1], 0,4) != strtolower($seq) && substr(substr($res[1], 0,4), -2).substr(substr($res[1], 0,4), 0,2) != strtolower($seq)) $true = 1;
+ if (substr($res[1], 0,2) != strtolower($seq)) $true = 1;
if (time() - $t >= $timeout) {
return '';