云客服的畅聊订单消息发送的FaceBook安卓端终端协议的对接以及获取小号所在服务器是否在线的整合信息发送进行优化

@@ -69,26 +69,33 @@ class TestKafkaSend extends BaseController
  $taskId = Cache::inc('taskId');
  $taskId = Cache::inc('taskId');
  // 缓存taskId与消息ID
  // 缓存taskId与消息ID
  Cache::set('taskId_'.$taskId,array($res['msgId'],$res['theme']), 300);
  Cache::set('taskId_'.$taskId,array($res['msgId'],$res['theme']), 300);
- $data_data = array('type' => $res['type'], 'taskId' => $taskId, 'wxid' => $res['wxid'], 'date' => time(), 'data' => isset($res['data'])?$res['data']:'', 'timeInMillis' => time());
+ // $data_data = array('type' => $res['type'], 'taskId' => $taskId, 'wxid' => $res['wxid'], 'date' => time(), 'data' => isset($res['data'])?$res['data']:'', 'timeInMillis' => time());
+ $data_data = array('type' => $res['type'], 'taskId' => $taskId, 'username' => $res['username'], 'date' => time(), 'data' => isset($res['data'])?$res['data']:'', 'timeInMillis' => time());
+ trace('data_data ->-> : '.json_encode(array($data_data),JSON_UNESCAPED_UNICODE));
  $data = array('data' => json_encode(array($data_data),JSON_UNESCAPED_UNICODE),'type' => 'task');
  $data = array('data' => json_encode(array($data_data),JSON_UNESCAPED_UNICODE),'type' => 'task');
+ trace('data ->-> : '.json_encode($data,JSON_UNESCAPED_UNICODE));
  //取出name对应的服务端ID
  //取出name对应的服务端ID
- $id = $this->isOnline($res['wxid']);
- trace('取出name对应得服务端ID: '.$id,'test_consumer');
+ // $id = $this->isOnline($res['wxid']);
+ // trace('取出name对应得服务端ID: '.$id,'test_consumer');
 
 
- if (!$id) { $isFackbookOnline = true; }
+ // if (!$id) { $isFackbookOnline = true; }
  }
  }
  //打日志组包后的消息
  //打日志组包后的消息
- trace(json_encode(array('id'=>$id, 'message'=>$data),JSON_UNESCAPED_UNICODE),'test_consumer');
+ // trace(json_encode(array('id'=>$id, 'message'=>$data),JSON_UNESCAPED_UNICODE),'test_consumer');
+ trace(json_encode(array($data),JSON_UNESCAPED_UNICODE),'test_consumer');
+ fwrite($client, json_encode(array($data),JSON_UNESCAPED_UNICODE)."\n");
+ // 读取推送结果
+ $res = str_replace("\n","",fread($client, 8192));
  //判断是否存在服务器id
  //判断是否存在服务器id
- if($id){
+ /*if($id){
  // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
  // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
  fwrite($client, json_encode(array('id'=>$id, 'message'=>$data),JSON_UNESCAPED_UNICODE)."\n");
  fwrite($client, json_encode(array('id'=>$id, 'message'=>$data),JSON_UNESCAPED_UNICODE)."\n");
  // 读取推送结果
  // 读取推送结果
  $res = str_replace("\n","",fread($client, 8192));
  $res = str_replace("\n","",fread($client, 8192));
- }else{
+ }*//*else{
  // 判断facebook是否是登录状态进行一系列的判断
  // 判断facebook是否是登录状态进行一系列的判断
- $res = $this->isFackbookOnline($isFackbookOnline, $res);
- }
+ // $res = $this->isFackbookOnline($isFackbookOnline, $res);
+ }*/
  // 打印发送消息返回LOG
  // 打印发送消息返回LOG
  trace($res,'test_consumer');
  trace($res,'test_consumer');
  }else{
  }else{
@@ -96,6 +103,7 @@ class TestKafkaSend extends BaseController
  }
  }
  }
  }
 
 
+ // 发送facebook发送消息请求
  public function isFackbookOnline($isFackbookOnline, $res) {
  public function isFackbookOnline($isFackbookOnline, $res) {
  $result = 'false';
  $result = 'false';
  if ($isFackbookOnline != true) {
  if ($isFackbookOnline != true) {
@@ -157,7 +165,7 @@ class TestKafkaSend extends BaseController
  }
  }
  }
  }
 
 
- // 发送Post请求判断fackbook在线状态
+ // 发送Post请求
  public function postCurl($url, $postdata) {
  public function postCurl($url, $postdata) {
  $header = [
  $header = [
  'Content-Type: application/json',
  'Content-Type: application/json',