wechat.module

<?php

/**
 * @file
 * Wechat public open platform integration.
 */

include_once 'wechat_request_message_types.inc';
include_once 'wechat_response_message_types.inc';
include_once 'include/wechat_user.inc';
include_once 'include/wechat_request_message.inc';
include_once 'include/wechat_response_message.inc';

/**
 * Implementation of hook_menu().
 */
function wechat_menu() {
  $items['wechat'] = array(
    'title' => 'wechat',
    'description' => 'wechat callback',
    'page callback' => 'wechat_callback',
    'access callback' => TRUE,
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );
  // Top level "Wechat" container.
  $items['admin/wechat'] = array(
    'title' => 'Wechat',
    'description' => 'Administer your wechat.',
    'page callback' => 'system_admin_menu_block_page',
    'access arguments' => array('access administration pages'),
    'file path' => drupal_get_path('module', 'system'),
    'file' => 'system.admin.inc',
    'weight' => -7,
    );
  $items['admin/wechat/config'] = array(
    'title' => 'Configuration',
    'description' => 'Configure settings for your wechat.',
    'page callback' => 'system_admin_menu_block_page',
    'access arguments' => array('access administration pages'),
    'type' => MENU_NORMAL_ITEM,
    'weight' => 50,
    'file path' => drupal_get_path('module', 'system'),
    'file' => 'system.admin.inc',
    );  
  $items['admin/wechat/config/default'] = array(
    'title' => 'Config Wechat',
    'description' => 'Wechat configuration.',
    'access arguments' => array('access administration pages'),
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_config_form'),
    'type' => MENU_NORMAL_ITEM,
    'file' => 'wechat.admin.inc',
    );
  $items['admin/wechat/config/default-message'] = array(
    'title' => 'Config default message',
    'access arguments' => array('access administration pages'),
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_default_message_config_form'),
    'type' => MENU_NORMAL_ITEM,
    'file' => 'wechat.admin.inc',
    'weight' => 1,
    ); 
  $items['admin/wechat/config/update-menu'] = array(
    'title' => 'Update menu',
    'access arguments' => array('access administration pages'),
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_update_menu_form'),
    'type' => MENU_NORMAL_ITEM,
    'file' => 'wechat.admin.inc',
    'weight' => 1,
    );   
  /* login with wechat */
  $items['wechat/login'] = array(
    'title' => t('Wechat Login'),
    'page callback' => 'wechat_login',
    'access arguments' => array('access content'),
    'type' => MENU_NORMAL_ITEM,
    'file' => 'wechat.pages.inc',
    );
  // $items['wechat/auth'] = array(
  //   'title' => 'Wechat Auth',
  //   'page callback' => 'wechat_auth',
  //   'access arguments' => array('access content'),
  //   'type' => MENU_CALLBACK,
  //   'file' => 'wechat.pages.inc',
  // );
  $items['user/%user/wechat-binding'] = array(
    'title' => 'Wechat binding',
    'page callback' => 'wechat_user_binding_from_drupal',
    'page arguments' => array(1),
    'access callback' => TRUE,
    'type' => MENU_LOCAL_TASK,
    'file' => 'wechat.pages.inc',
    );
  // $items['wechat/binding'] = array(
  //   'title' => 'Account binding',
  //   'page callback' => 'wechat_user_binding_from_wechat',
  //   'access arguments' => array('access content'),
  //   'type' => MENU_CALLBACK,
  //   'file' => 'wechat.pages.inc',
  // );
  $items['wechat-binding'] = array(
    'title' => 'Wechat binding',
    'page callback' => 'wechat_binding_from_wechat',
    'access arguments' => array('access content'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );  
  $items['admin/wechat/user'] = array(
    'title' => 'wechat users',
    'page callback' => 'wechat_get_user_list',
    'access arguments' => array('access administration pages'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );
  $items['admin/wechat/user/update/%'] = array(
    'title' => 'update wechat user info',
    'page callback' => 'wechat_update_user_info',
    'page arguments' => array(4),
    'access arguments' => array('access administration pages'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );
  $items['admin/wechat/groups'] = array(
    'title' => 'wechat groups',
    'page callback' => 'wechat_get_groups',
    'access arguments' => array('access administration pages'),
    'type' => MENU_NORMAL_ITEM,
    'file' => 'wechat.pages.inc',
    );
  $items['admin/wechat/group/add'] = array(
    'title' => 'Create wechat group',
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_group_add_form'),
    'access arguments' => array('access administration pages'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );
  $items['admin/wechat/group/edit/%/%'] = array(
    'title' => 'Create wechat group',
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_group_edit_form', 4, 5),
    'access arguments' => array('access administration pages'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );
  $items['admin/wechat/group/member/update/%'] = array(
    'title' => 'Update user group',
    'page callback' => 'drupal_get_form',
    'page arguments' => array('wechat_group_member_update_form', 5),
    'access arguments' => array('access administration pages'),
    'type' => MENU_CALLBACK,
    'file' => 'wechat.pages.inc',
    );  
  foreach (wechat_response_message_get_types() as $type) {
    $type_url_str = str_replace('_', '-', $type->type);
    $items['response-message/add/' . $type_url_str] = array(
      'title' => $type->label,
      'title callback' => 'check_plain',
      'page callback' => 'wechat_response_message_add',
      'page arguments' => array($type->type),
      'access arguments' => array('administer wechat request message'),
      //'description' => $type->description,
      'file' => 'wechat.admin.inc',
      );
  }  
  return $items;
}


// hook_theme
function wechat_theme(){
  return array(
    'wechat_text' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_text',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    'wechat_music' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_music',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    'wechat_image' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_image',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    'wechat_news' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_news',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    'wechat_video' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_video',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    'wechat_voice' => array(
      'variables' => array(),
      'template' =>  'templates/wechat_voice',
      'path' => drupal_get_path('module', 'wechat'),
      ),
    );
}

function wechat_check_signature() {
  $signature = $_GET["signature"];
  $timestamp = $_GET["timestamp"];
  $nonce = $_GET["nonce"];

  $token = variable_get('wechat_token', '');
  $tmp_arr = array($token, $timestamp, $nonce);
  sort($tmp_arr);
  $tmp_str = implode( $tmp_arr );
  $tmp_str = sha1( $tmp_str );

  if ( $tmp_str == $signature ) {
    return TRUE;
  }
  else {
    return FALSE;
  }
}
function wechat_build_request_message($request_data) {
  //转换回来
  $xml_obj = (object)$request_data;
  //watchdog('wechat', '123456789'); 
  $message = entity_create('wechat_request_message', array('msg_type' => $xml_obj->MsgType));
  $message_wrapper = entity_metadata_wrapper('wechat_request_message', $message);
  $message_wrapper->to_user_name->set($xml_obj->ToUserName);
  $message_wrapper->from_user_name->set($xml_obj->FromUserName);
  $message_wrapper->create_time->set(time());
  //$message->data = array('test' => '123456');
  if ($xml_obj->MsgType == 'event') {
    $message_wrapper->msg_id->set('');
  }
  else {
    $message_wrapper->msg_id->set($xml_obj->MsgId);
  }
  
  if ($xml_obj->MsgType == 'text') {
    $message_wrapper->wechat_content->set($xml_obj->Content);
  }
  elseif ($xml_obj->MsgType == 'image') {
    $message_wrapper->wechat_pic_url->set($xml_obj->PicUrl);
    $message_wrapper->wechat_media_id->set($xml_obj->MediaId);
    $we_obj = wechat_init_obj_with_access_token();
    $image = $we_obj->getMedia($xml_obj->MediaId);
    if (!empty($image)) {
      $dir_uri = file_stream_wrapper_get_instance_by_uri('public://');
      $realpath = $dir_uri->realpath();
      $image_dir = 'public://wechat/request/images';
      $return = file_prepare_directory($image_dir);
      if (empty($return)) {
        drupal_mkdir('public://wechat/request/images', 0777, TRUE);
      }
      $filename = $realpath . "/wechat/request/images/". $message_wrapper->msg_id->value() . ".jpg";
      file_put_contents($filename, $image);

      $uri = 'public://wechat/request/images/'. $message_wrapper->msg_id->value() . ".jpg";
      $file = new StdClass;
      $file->uid = 1;
      $file->filename = $message_wrapper->msg_id . ".jpg";
      $file->uri = $uri;
      $file->filemime = file_get_mimetype($uri);
      // This is gagged because some uris will not support it.
      $file->filesize = @filesize($uri);
      $file->timestamp = REQUEST_TIME;
      $file->status = FILE_STATUS_PERMANENT;
      $file->is_new = TRUE;
      $file = file_save($file);
	  //watchdog('wechat', 'file:' . $file->fid);
      $message_wrapper->wechat_image->file = $file;
    }	
  }
  elseif ($xml_obj->MsgType == 'voice') {
    $message_wrapper->wechat_media_id->set($xml_obj->MediaId);
	//watchdog('wechat', 'Recognition:' . $xml_obj->Recognition);
    $message_wrapper->wechat_format->set($xml_obj->Format);
    if (!empty($xml_obj->Recognition)) {
      $message_wrapper->wechat_recognition->set($xml_obj->Recognition);
    }
    else{
      $message_wrapper->wechat_recognition->set("");	
    }
    $we_obj = wechat_init_obj_with_access_token();
    $voice = $we_obj->getMedia($xml_obj->MediaId);
	//watchdog('wechat', 'Recognition:' . $xml_obj->Recognition);
    if (!empty($voice)) {
	  //watchdog('wechat', 'Recognition123:' . $xml_obj->Recognition);
      $dir_uri = file_stream_wrapper_get_instance_by_uri('public://');
      $realpath = $dir_uri->realpath();
      $voice_dir = 'public://wechat/request/voices';
      $return = file_prepare_directory($voice_dir);
      if (empty($return)) {
        drupal_mkdir('public://wechat/request/voices', 0777, TRUE);
      } 
      $filename = $realpath . "/wechat/request/voices/". $message_wrapper->msg_id->value() . "." . $xml_obj->Format;
      file_put_contents($filename, $voice);

      $uri = 'public://wechat/request/voices/'. $message_wrapper->msg_id->value() . "." . $xml_obj->Format;
      $file = new StdClass;
      $file->uid = 1;
      $file->filename = basename($uri);
      $file->uri = $uri;
      $file->filemime = file_get_mimetype($uri);
      // This is gagged because some uris will not support it.
      $file->filesize = @filesize($uri);
      $file->timestamp = REQUEST_TIME;
      $file->status = FILE_STATUS_PERMANENT;
      $file->is_new = TRUE;
      $file = file_save($file);
	  //watchdog('wechat', 'file:' . $file->fid);
      $message_wrapper->wechat_voice->file = $file;
    }
  }
  elseif ($xml_obj->MsgType == 'video') {
    $message_wrapper->wechat_media_id->set($xml_obj->MediaId);
    $message_wrapper->wechat_thumb_media_id->set($xml_obj->ThumbMediaId);
    $we_obj = wechat_init_obj_with_access_token();
    //$video = $we_obj->getMedia($xml_obj->MediaId);
	/*
    if (!empty($video)) {
      $filename = "/data/www/html/weixin/sites/default/files/wechat/request/videos/". $message_wrapper->msg_id->value() . ".mp4";
      file_put_contents($filename, $video);

      $uri = 'public://wechat/request/videos/'. $message_wrapper->msg_id->value() . ".mp4";
      $file = new StdClass;
      $file->uid = 1;
      $file->filename = basename($uri);
      $file->uri = $uri;
      $file->filemime = file_get_mimetype($uri);
      // This is gagged because some uris will not support it.
      $file->filesize = @filesize($uri);
      $file->timestamp = REQUEST_TIME;
      $file->status = FILE_STATUS_PERMANENT;
      $file->is_new = TRUE;
      $file = file_save($file);
	  //watchdog('wechat', 'file:' . $file->fid);
	  $message_wrapper->wechat_video->file = $file;
    }	
	*/
  } 
  elseif ($xml_obj->MsgType == 'location') {
    $message_wrapper->wechat_location_x->set($xml_obj->Location_X);
    $message_wrapper->wechat_location_y->set($xml_obj->Location_Y);
    $message_wrapper->wechat_scale->set($xml_obj->Scale);
    $message_wrapper->wechat_label->set($xml_obj->Label);
  } 
  elseif ($xml_obj->MsgType == 'link') {
    $message_wrapper->wechat_title->set($xml_obj->Title);
    $message_wrapper->wechat_description->set($xml_obj->Description);
    $message_wrapper->wechat_url->set($xml_obj->Url);
  }  
  elseif ($xml_obj->MsgType == 'event') {
    //watchdog('wechat', '123456');
    $message_wrapper->wechat_event->set($xml_obj->Event);
	//watchdog('wechat', '123456789:' . $xml_obj->EventKey);
    if (isset($xml_obj->EventKey) && !empty($xml_obj->EventKey)) {
      $message_wrapper->wechat_event_key->set($xml_obj->EventKey);
    }
    if (isset($xml_obj->Ticket)) {
      $message_wrapper->wechat_ticket->set($xml_obj->Ticket);
    }
    if (isset($xml_obj->Latitude)) {
      $message_wrapper->wechat_latitude->set($xml_obj->Latitude);
    }
    if (isset($xml_obj->Longitude)) {
      $message_wrapper->wechat_longitude->set($xml_obj->Longitude);
    }
    if (isset($xml_obj->Precision)) {
      $message_wrapper->wechat_precision->set($xml_obj->Precision);
    }
    if (isset($xml_obj->ScanCodeInfo)) {
     // $message_wrapper->wechat_scantype->set($xml_obj->ScanCodeInfo->ScanType);
      $scan_code_info = (array)$xml_obj->ScanCodeInfo;
      if(isset($scan_code_info['ScanType'])){
       $message_wrapper->wechat_scantype->set($scan_code_info['ScanType']);
     }
     if(isset($scan_code_info['ScanResult'])){
       $message_wrapper->wechat_scanresult->set($scan_code_info['ScanResult']);
     }	  
      //watchdog('wechat', '1234:'. var_export($xml_obj->ScanCodeInfo->ScanType[0],true));
      //watchdog('wechat', '123456:'. var_export($scan_code_info,true));
   }

 }   
 $message_wrapper->save(true);
 $message = $message_wrapper->value();
 return $message;
}

function wechat_build_response_message($request_message) {
  //转换回来
  $request_message_wrapper = entity_metadata_wrapper('wechat_request_message', $request_message);
  $response_message = entity_create('wechat_response_message', array('msg_type' => 'text'));
  $response_message_wrapper = entity_metadata_wrapper('wechat_response_message', $response_message);
  $response_message_wrapper->to_user_name->set($request_message_wrapper->from_user_name->value());
  $response_message_wrapper->from_user_name->set($request_message_wrapper->to_user_name->value());
  $response_message_wrapper->create_time->set(REQUEST_TIME);
  $response_message_wrapper->rm_id->set($request_message->id);
  //我们这里设置一个save标记，其它模块同构后面的钩子可以修改这个值，它表示保存相应消息到数据库中。也可以不保存。
  $response_message->save = TRUE;
  
  module_invoke_all('wechat_build_response_message', $response_message, $request_message);
  //default reply.
  $wechat_content = $response_message_wrapper->wechat_content->value();
  if ($response_message->msg_type == 'text' && empty($wechat_content)) {
    if ($request_message->msg_type == 'event') {
      if ($request_message_wrapper->wechat_event->value() == 'subscribe') {
        //watchdog('wechat', '123456'); 
        $default_message_content = variable_get("wechat_follow_message", variable_get("wechat_default_message", 'Hi, WeChat!'));
        $response_message_wrapper->wechat_content->set($default_message_content); 
      }
      elseif ($request_message_wrapper->wechat_event->value() == 'CLICK') {
        $event = array();
        $event['key'] = $request_message_wrapper->wechat_event_key->value();
        if($event['key'] == 'userbinding'){
          $default_message_content = "点击链接绑定用户：";
          $default_message_content .= l('绑定账号', 'wechat/binding', array('query' => array('openid' => $request_message->from_user_name), 'absolute' => TRUE));
          $response_message_wrapper->wechat_content->set($default_message_content);   
        }else{
          $default_message_content = _wechat_menu_default_message($event);
          $response_message_wrapper->wechat_content->set($default_message_content);
        }
      }
    }
    $wechat_content = $response_message_wrapper->wechat_content->value();
    if (empty($wechat_content)) {
      $default_message_content = variable_get("wechat_default_message", "Hi, WeChat!");
      $response_message_wrapper->wechat_content->set($default_message_content);
    }
  }
  //The saved Flag default to TRUE. we could change it through hook_wechat_build_response_message.
  if (isset($response_message->save)) {
    $response_message_wrapper->save(true);
  }
  return $response_message;
}


function wechat_response_message_obj_to_xml(WechatResponseMessage $message) {
  $message_wrapper = entity_metadata_wrapper('wechat_response_message', $message);
  $request_time = REQUEST_TIME;
  $to_user_name = $message_wrapper->to_user_name->value();
  $from_user_name = $message_wrapper->from_user_name->value();
  $result_str = "";
  if ($message->msg_type == 'text') {
    $result_str = theme('wechat_text', array(
      'to_user_name' => $to_user_name,
      'from_user_name' => $from_user_name,
      'request_time' => $request_time,
      'content' =>  $message_wrapper->wechat_content->value(),
      ));
  }
  elseif ($message->msg_type == 'image') {
    $result_str = theme('wechat_image', array(
      'to_user_name' => $to_user_name,
      'from_user_name' => $from_user_name,
      'request_time' => $request_time,
      'media_id' =>  $message_wrapper->wechat_media_id->value(),
      ));
  }
  elseif ($message->msg_type == 'voice') {
    $result_str = theme('wechat_voice', array(
      'to_user_name' => $to_user_name,
      'from_user_name' => $from_user_name,
      'request_time' => $request_time,
      'media_id' =>  $message_wrapper->wechat_media_id->value(),
      ));
  }
  elseif ($message->msg_type == 'video') {
    $result_str = theme('wechat_video', array(
      'to_user_name' => $to_user_name,
      'from_user_name' => $from_user_name,
      'request_time' => $request_time,
      'media_id' =>  $message_wrapper->wechat_media_id->value(),
      'thumb_media_id' => $message_wrapper->wechat_thumb_media_id->value(),
      ));
  } 
  elseif ($message->msg_type == 'music') {

    $result_str = theme('wechat_music', array(
      'to_user_name' => $to_user_name,
      'from_user_name' => $from_user_name,
      'request_time' => $request_time,
      'title' =>  $message_wrapper->wechat_title->value(),
      'description' =>  $message_wrapper->wechat_description->value(),
      'music_url' => $message_wrapper->wechat_music_url->value(),
      'hq_music_url' => $message_wrapper->wechat_hq_music_url->value(),
      'thumb_media_id' => $message_wrapper->wechat_thumb_media_id->value(),
      ));
  } 
  elseif ($message->msg_type == 'news') {
    $articles = $message_wrapper->wechat_article->value();
    $article_count = count($articles);
    $result_str = "<xml>";
    $result_str .= "<ToUserName><![CDATA[" . $to_user_name . "]]></ToUserName>";
    $result_str .= "<FromUserName><![CDATA[" . $from_user_name . "]]></FromUserName>";
    $result_str .= "<CreateTime>" . $request_time . "</CreateTime>";
    $result_str .= "<MsgType><![CDATA[news]]></MsgType>";
    $result_str .= "<ArticleCount>" . $article_count . "</ArticleCount>";
    $result_str .= "<Articles>";
    $position = 0;
    foreach ($articles as $article) {
      $article_item = wechat_build_news_article($article, $position++);
      $result_str .= "<item>";
      $result_str .= "<Title><![CDATA[" . $article_item['title'] . "]]></Title>"; 
      $result_str .= "<Description><![CDATA[" . $article_item['description'] . "]]></Description>";
      $result_str .= "<PicUrl><![CDATA[" . $article_item['picurl'] . "]]></PicUrl>";
      $result_str .= "<Url><![CDATA[" . $article_item['url'] . "]]></Url>";
      $result_str .= "</item>";

    }
    //此处循环
    $result_str .= "</Articles>";
    $result_str .= "</xml>";

  }
  //允许其它模块实现新的相应消息转XML
  foreach (module_implements("wechat_response_message_obj_to_xml") as $module) {
    $function = $module . '_' . "wechat_response_message_obj_to_xml";
    if (function_exists($function)) {
     $result_str = $function($message);
   }
 }

 return $result_str;
}

function wechat_response_message_obj_to_json(WechatResponseMessage $message) {
  $message_wrapper = entity_metadata_wrapper('wechat_response_message', $message);
  $request_time = REQUEST_TIME;
  $to_user_name = $message_wrapper->to_user_name->value();
  $result_json = '{"touser":"' . $to_user_name . '",';
  
  if ($message->msg_type == 'text') {
    $result_json .= '"msgtype":"text",';
    $content = $message_wrapper->wechat_content->value();
    $result_json .= '"text":{"content":"' . $content . '"}}';
  }
  elseif ($message->msg_type == 'image') {
    $result_json .= '"msgtype":"image",';
    $media_id = $message_wrapper->wechat_media_id->value();
    $result_json .= '"image":{"media_id":"' . $media_id . '"}}';
  }
  elseif ($message->msg_type == 'voice') {
    $result_json .= '"msgtype":"voice",';
    $media_id = $message_wrapper->wechat_media_id->value();
    $result_json .= '"voice":{"media_id":"' . $media_id . '"}}';
  } 
  elseif ($message->msg_type == 'video') {
    $result_json .= '"msgtype":"video",';
    $media_id = $message_wrapper->wechat_media_id->value();
    $thumb_media_id = $message_wrapper->wechat_thumb_media_id->value();
    $result_json .= '"video":{"media_id":"' . $media_id . '","thumb_media_id":"' . $thumb_media_id . '"}}';
  }
  elseif ($message->msg_type == 'music') {
    $result_json .= '"msgtype":"music",';
    $title = $message_wrapper->wechat_title->value();
    $description = $message_wrapper->wechat_description->value();
    $music_url = $message_wrapper->wechat_music_url->value();
    $hq_music_url = $message_wrapper->wechat_hq_music_url->value();
    $thumb_media_id = $message_wrapper->wechat_thumb_media_id->value();
    $result_json .= '"music":{';
    $result_json .= '"title":"' . $title . '",';
    $result_json .= '"description":"' . $description . '",';
    $result_json .= '"musicurl":"' . $music_url . '",';
    $result_json .= '"hqmusicurl":"' . $hq_music_url . '",';
    $result_json .= '"thumb_media_id":"' . $thumb_media_id . '"';
    $result_json .= '}}';
  }
  elseif ($message->msg_type == 'news') {
    $result_json .= '"msgtype":"news",';
    //Todo

  }  
  return $result_json;
}

function wechat_response_message_obj_to_array(WechatResponseMessage $message) {
  $message_wrapper = entity_metadata_wrapper('wechat_response_message', $message);
  $request_time = REQUEST_TIME;
  $to_user_name = $message_wrapper->to_user_name->value();
  $result_array = array();
  $result_array["touser"] = $to_user_name;
  
  if ($message->msg_type == 'text') {
    $result_array["msgtype"] = "text";
    $content = $message_wrapper->wechat_content->value();
    $result_array["text"] = array(
      "content" => $content
      );
  }
  elseif ($message->msg_type == 'image') {
    $result_array["msgtype"] = "image";
    $media_id = $message_wrapper->wechat_media_id->value();
    $image_fid = $message_wrapper->wechat_image->file->fid->value();
    if ( empty($media_id) && !empty($image_fid)) {
      $media_id = wechat_upload_media($image_fid, 'image');
	  /*
	  $file = file_load($image_fid);
      $uri = $file->uri;
	  $realpath = drupal_realpath($uri);
      $filename = '@' . $realpath;
      //print debug($filename);
      $we_obj = wechat_init_obj_with_access_token();
	  $data = array(
	    'media' => $filename,
	  );
	  $result  = $we_obj->uploadMedia($data, 'image');
	  //print debug($result);
      if (!empty($result['media_id']))	{
        $media_id = $result['media_id'];
      } */
    }
    //$result_json .= '"image":{"media_id":"' . $media_id . '"}}';
    $result_array["image"] = array(
      "media_id" => $media_id
      );
  }
  elseif ($message->msg_type == 'voice') {
    $result_array["msgtype"] = "voice";
    $media_id = $message_wrapper->wechat_media_id->value();
    $voice_fid = $message_wrapper->wechat_voice->file->fid->value();
    if ( empty($media_id) && !empty($voice_fid)) {
      $media_id = wechat_upload_media($voice_fid, 'voice');
    }
    $result_array["voice"] = array(
      "media_id" => $media_id
      );	
  } 
  elseif ($message->msg_type == 'video') {
   $result_array["msgtype"] = "video";
   $media_id = $message_wrapper->wechat_media_id->value();
   $video_fid = $message_wrapper->wechat_video->file->fid->value();
   if ( empty($media_id) && !empty($video_fid)) {
    $media_id = wechat_upload_media($video_fid, 'video');
  }
  $result_array["video"] = array(
    "media_id" => $media_id
    );
}
elseif ($message->msg_type == 'music') {
    //$result_json .= '"msgtype":"music",';
	$result_array["msgtype"] = "music";
  $title = $message_wrapper->wechat_title->value();
  $description = $message_wrapper->wechat_description->value();
  $music_url = $message_wrapper->wechat_music_url->value();
  $hq_music_url = $message_wrapper->wechat_hq_music_url->value();
  $thumb_media_id = $message_wrapper->wechat_thumb_media_id->value();
  $result_array["music"] = array(
    "title" => $title,
    "description" => $description,
    "musicurl" => $music_url,
    "hqmusicurl" => $hq_music_url,
    "thumb_media_id" => $thumb_media_id,
    );
}
elseif ($message->msg_type == 'news') {
    //$result_json .= '"msgtype":"news",';
  $result_array["msgtype"] = "news";
  $result_array["news"]['articles'] = array();
  $articles = $message_wrapper->wechat_article->value();
  if (!empty($articles)) {
    $position = 0;
    foreach ($articles as $article) {
	    //drupal_set_message('123:' . $article_nid);
      $article_item = wechat_build_news_article($article, $position++);
      $result_array["news"]['articles'][] = $article_item;
    }
  }
	//print debug($article_nids);
    //Todo

}  
return $result_array;
}



/**
 * Implement hook_entity_info().
 */
function wechat_entity_info() {
  $return = array(
    'wechat_request_message' => array(
      'label' => t('wechat request message'),
      'plural label' => t('wechat request messages'),
      'description' => t('wechat request message entity.'),
      'entity class' => 'WechatRequestMessage',
      'controller class' => 'EntityAPIController',
      'base table' => 'wechat_request_message',
      'fieldable' => TRUE,
      'view modes' => array(
        'full' => array(
          'label' => t('wechat request message'),
          'custom settings' => FALSE,
          ),
        ),
      'entity keys' => array(
        'id' => 'id',
        'bundle' => 'msg_type',
        'label' => 'label',
        ),
      'bundles' => array(),
      'bundle keys' => array(
        'bundle' => 'type',
        ),
      'uri callback' => 'entity_class_uri',
      'label callback' => 'entity_class_label',
      'access callback' => 'wechat_request_message_access',
      'module' => 'wechat',
      'metadata controller class' => 'WechatRequestMessageMetadataController'
      ),
    );

  // Add bundle info but bypass entity_load() as we cannot use it here.
$types = db_select('wechat_request_message_type', 'w')
->fields('w')
->execute()
->fetchAllAssoc('type');

foreach ($types as $type => $info) {
  $return['wechat_request_message']['bundles'][$type] = array(
    'label' => $info->label,
    'admin' => array(
      'path' => 'admin/wechat/config/request-messages/manage/%wechat_request_message_type',
      'real path' => 'admin/wechat/config/request-messages/manage/' . $type,
      'bundle argument' => 5,
      'access arguments' => array('administer wechat request message'),
      ),
    );
}

$return['wechat_request_message_type'] = array(
  'label' => t('Wechat request message type'),
  'plural label' => t('Wechat request message types'),
  'description' => t('Wechat request message types of wechat request message.'),
  'entity class' => 'WechatRequestMessageType',
  'controller class' => 'EntityAPIControllerExportable',
  'base table' => 'wechat_request_message_type',
  'fieldable' => FALSE,
  'bundle of' => 'wechat_request_message',
  'exportable' => TRUE,
  'entity keys' => array(
    'id' => 'id',
    'name' => 'type',
    'label' => 'label',
    ),
  'access callback' => 'wechat_request_message_type_access',
  'module' => 'wechat',
    // Enable the entity API's admin UI.
  'admin ui' => array(
    'path' => 'admin/wechat/config/request-messages',
    'file' => 'wechat.admin.inc',
    'controller class' => 'WechatRequestMessageTypeUIController',
    ),
  );

$return['wechat_response_message'] = array(

  'label' => t('wechat response message'),
  'plural label' => t('wechat response messages'),
  'description' => t('wechat response message entity.'),
  'entity class' => 'WechatResponseMessage',
  'controller class' => 'EntityAPIController',
  'base table' => 'wechat_response_message',
  'fieldable' => TRUE,
  'view modes' => array(
    'full' => array(
      'label' => t('wechat response message'),
      'custom settings' => FALSE,
      ),
    ),
  'entity keys' => array(
    'id' => 'id',
    'bundle' => 'msg_type',
    'label' => 'label',
    ),
  'bundles' => array(),
  'bundle keys' => array(
    'bundle' => 'type',
    ),
  'uri callback' => 'entity_class_uri',
  'label callback' => 'entity_class_label',
  'access callback' => 'wechat_response_message_access',
  'module' => 'wechat',
  'metadata controller class' => 'WechatResponseMessageMetadataController'

  );

  // Add bundle info but bypass entity_load() as we cannot use it here.
$types = db_select('wechat_response_message_type', 'w')
->fields('w')
->execute()
->fetchAllAssoc('type');

foreach ($types as $type => $info) {
  $return['wechat_response_message']['bundles'][$type] = array(
    'label' => $info->label,
    'admin' => array(
      'path' => 'admin/wechat/config/response-messages/manage/%wechat_response_message_type',
      'real path' => 'admin/wechat/config/response-messages/manage/' . $type,
      'bundle argument' => 5,
      'access arguments' => array('administer wechat response message'),
      ),
    );
}

$return['wechat_response_message_type'] = array(
  'label' => t('Wechat response message type'),
  'plural label' => t('Wechat response message types'),
  'description' => t('Wechat response message types of wechat response message.'),
  'entity class' => 'WechatResponseMessageType',
  'controller class' => 'EntityAPIControllerExportable',
  'base table' => 'wechat_response_message_type',
  'fieldable' => FALSE,
  'bundle of' => 'wechat_response_message',
  'exportable' => TRUE,
  'entity keys' => array(
    'id' => 'id',
    'name' => 'type',
    'label' => 'label',
    ),
  'access callback' => 'wechat_response_message_type_access',
  'module' => 'wechat',
    // Enable the entity API's admin UI.
  'admin ui' => array(
    'path' => 'admin/wechat/config/response-messages',
    'file' => 'wechat.admin.inc',
    'controller class' => 'WechatResponseMessageTypeUIController',
    ),
  ); 

$return['wechat_user'] = array(
  'label' => t('Wechat user'),
  'plural label' => t('Wechat users'),
  'description' => t('Wechat users.'),
  'entity class' => 'WechatUser',
  'controller class' => 'EntityAPIController',
  'base table' => 'wechat_user',
  'fieldable' => TRUE,
  'entity keys' => array(
    'id' => 'unionid',
    ),
  'access callback' => 'wechat_wechatuser_access',
  'module' => 'wechat',
  'metadata controller class' => 'WechatUserMetadataController',
  'bundles' => array(
   'wechat_user' => array(
     'label' => t('Wechat user'),
     'admin' => array(
      'path' => 'admin/wechat/wechat-users',
      'access arguments' => array('administer users'),
      ),
     ),
   ),
  );  

return $return;
}
/**
 * Implements hook_permission().
 */
function wechat_permission() {
  $permissions = array(
    'administer wechat request message' => array(
      'title' => t('Administer wechat request message'),
      'description' => t('Edit and view all wechat request message entity.'),
      ),  
    );
  return $permissions;  
}

/**
 * Determines whether the given user has access to a wechat_request_message.
 *
 * @param $op
 *   The operation being performed. One of 'view', 'update', 'create', 'delete'
 *   or just 'edit' (being the same as 'create' or 'update').
 * @param $message
 *   Optionally a message to check access for. If nothing is
 *   given, access for all message is determined.
 * @param $account
 *   The user to check for. Leave it to NULL to check for the global user.
 * @return boolean
 *   Whether access is allowed or not.
 */
function wechat_request_message_access($op, $message = NULL, $account = NULL) {
  if (user_access('administer wechat request message', $account)) {
    return TRUE;
  }
  return TRUE;
}

/**
 * Determines whether the given user has access to a wechat_request_message.
 *
 * @param $op
 *   The operation being performed. One of 'view', 'update', 'create', 'delete'
 *   or just 'edit' (being the same as 'create' or 'update').
 * @param $message
 *   Optionally a message to check access for. If nothing is
 *   given, access for all message is determined.
 * @param $account
 *   The user to check for. Leave it to NULL to check for the global user.
 * @return boolean
 *   Whether access is allowed or not.
 */
function wechat_request_message_type_access($op, $message_type = NULL, $account = NULL) {
  if (user_access('administer wechat request message', $account)) {
    return TRUE;
  }
  return TRUE;
}

/**
 * Fetch a wechat request message object. 
 *
 * @param $id
 *   Integer specifying the wechat request message id.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   A fully-loaded $wechat_request_message object or FALSE if it cannot be loaded.
 *
 * @see breadcrumb2_load_multiple()
 */
function wechat_request_message_load($id, $reset = FALSE) {
  $request_messages = wechat_request_message_load_multiple(array($id), array(), $reset);
  return reset($request_messages);
}


/**
 * Load multiple wechat request messages based on certain conditions.
 *
 * @param $ids
 *   An array of wechat request message IDs.
 * @param $conditions
 *   An array of conditions to match against the {wechat_request_message} table.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   An array of wechat request message objects, indexed by bid.
 *
 * @see entity_load()
 * @see wechat_request_message_load()
 */
function wechat_request_message_load_multiple($ids = array(), $conditions = array(), $reset = FALSE) {
  return entity_load('wechat_request_message', $ids, $conditions, $reset);
}

/**
 * Deletes a wechat request message.
 */
function wechat_request_message_delete(WechatRequestMessage $message) {
  $message->delete();
}


/**
 * Delete multiple wechat request messages.
 *
 * @param $ids
 *   An array of wechat request message IDs.
 */
function wechat_request_message_delete_multiple(array $ids) {
  entity_get_controller('wechat_request_message')->delete($ids);
}


/**
 * Create a wechat request message object.
 */
function wechat_request_message_create($values = array()) {
  return new WechatRequestMessage($values);
}


/**
 * Saves a wechat request message to the database.
 *
 * @param $message
 *   The wechat request message object.
 */
function wechat_request_message_save(WechatRequestMessage $message) {
  return $message->save();
}

/**
 * URI callback for wechat request message
 */
function wechat_request_message_uri(WechatRequestMessage $message) {
  return array(
    'path' => 'message/' . $message->id,
    );
}

/**
 * Menu argument loader; Load a wechat_request_message type by string.
 *
 * @param $type
 *   The machine-readable name of a wechat_request_message type to load.
 * @return
 *   A wechat_request_message type array or FALSE if $type does not exist.
 */
function wechat_request_message_type_load($type) {
  return wechat_request_message_get_types($type);
}

/**
 * Gets an array of all wechat_request_message types, keyed by the type name.
 *
 * @param $type_name
 *   If set, the type with the given name is returned.
 * @return WechatRequestMessageType[]
 *   Depending whether $type isset, an array of wechat_request_message types or a single one.
 */
function wechat_request_message_get_types($type_name = NULL) {
  $types = entity_load_multiple_by_name('wechat_request_message_type', isset($type_name) ? array($type_name) : FALSE);
  return isset($type_name) ? reset($types) : $types;
}

/**
 * Saves a wechat_request_message type to the db.
 */
function wechat_request_message_type_save(WechatRequestMessageType $type) {
  $type->save();
}

/**
 * Deletes a wechat_request_message type from.
 */
function wechat_request_message_type_delete(WechatRequestMessageType $type) {
  $type->delete();
}


/**
 * Menu argument loader; Load a wechat_response_message type by string.
 *
 * @param $type
 *   The machine-readable name of a wechat_response_message type to load.
 * @return
 *   A wechat_response_message type array or FALSE if $type does not exist.
 */
function wechat_response_message_type_load($type) {
  return wechat_response_message_get_types($type);
}

/**
 * Gets an array of all wechat_response_message types, keyed by the type name.
 *
 * @param $type_name
 *   If set, the type with the given name is returned.
 * @return ProfileType[]
 *   Depending whether $type isset, an array of wechat_response_message types or a single one.
 */
function wechat_response_message_get_types($type_name = NULL) {
  $types = entity_load_multiple_by_name('wechat_response_message_type', isset($type_name) ? array($type_name) : FALSE);
  return isset($type_name) ? reset($types) : $types;
}

/**
 * Saves a wechat_response_message type to the db.
 */
function wechat_response_message_type_save(WechatResponseMessageType $type) {
  $type->save();
}

/**
 * Deletes a wechat_response_message type from.
 */
function wechat_response_message_type_delete(WechatResponseMessageType $type) {
  $type->delete();
}


/**
 * Determines whether the given user has access to a wechat_response_message.
 *
 * @param $op
 *   The operation being performed. One of 'view', 'update', 'create', 'delete'
 *   or just 'edit' (being the same as 'create' or 'update').
 * @param $message
 *   Optionally a message to check access for. If nothing is
 *   given, access for all message is determined.
 * @param $account
 *   The user to check for. Leave it to NULL to check for the global user.
 * @return boolean
 *   Whether access is allowed or not.
 */
function wechat_response_message_access($op, $message = NULL, $account = NULL) {
  if (user_access('administer wechat response message', $account)) {
    return TRUE;
  }
  return TRUE;
}

/**
 * Determines whether the given user has access to a wechat_response_message.
 *
 * @param $op
 *   The operation being performed. One of 'view', 'update', 'create', 'delete'
 *   or just 'edit' (being the same as 'create' or 'update').
 * @param $message
 *   Optionally a message to check access for. If nothing is
 *   given, access for all message is determined.
 * @param $account
 *   The user to check for. Leave it to NULL to check for the global user.
 * @return boolean
 *   Whether access is allowed or not.
 */
function wechat_response_message_type_access($op, $message_type = NULL, $account = NULL) {
  if (user_access('administer wechat response message', $account)) {
    return TRUE;
  }
  return TRUE;
}

/**
 * Fetch a wechat request message object. 
 *
 * @param $id
 *   Integer specifying the wechat request message id.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   A fully-loaded $wechat_response_message object or FALSE if it cannot be loaded.
 *
 * @see breadcrumb2_load_multiple()
 */
function wechat_response_message_load($id, $reset = FALSE) {
  $response_messages = wechat_response_message_load_multiple(array($id), array(), $reset);
  return reset($response_messages);
}


/**
 * Load multiple wechat request messages based on certain conditions.
 *
 * @param $ids
 *   An array of wechat request message IDs.
 * @param $conditions
 *   An array of conditions to match against the {wechat_request_message} table.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   An array of wechat request message objects, indexed by bid.
 *
 * @see entity_load()
 * @see breadcrumb2_load()
 */
function wechat_response_message_load_multiple($ids = array(), $conditions = array(), $reset = FALSE) {
  return entity_load('wechat_response_message', $ids, $conditions, $reset);
}

/**
 * Deletes a wechat request message.
 */
function wechat_response_message_delete(WechatResponseMessage $message) {
  $message->delete();
}


/**
 * Delete multiple wechat request messages.
 *
 * @param $ids
 *   An array of wechat request message IDs.
 */
function wechat_response_message_delete_multiple(array $ids) {
  entity_get_controller('wechat_request_message')->delete($ids);
}


/**
 * Create a wechat request message object.
 */
function wechat_response_message_create($values = array()) {
  return new WechatResponseMessage($values);
}


/**
 * Saves a wechat request message to the database.
 *
 * @param $message
 *   The wechat request message object.
 */
function wechat_response_message_save(WechatResponseMessage $message) {
  return $message->save();
}

/**
 * URI callback for wechat_response_message
 */
function wechat_response_message_uri(WechatResponseMessage $message) {
  return array(
    'path' => 'response-message/' . $message->id,
    );
}


/**
 * hook menu form
 */
function wechat_form_menu_edit_item_alter(&$form, $form_state) {
  $item = $form['original_item']['#value'];
  _wechat_menu_form_alter($form, $item, $form);
}

/**
 * Add the menu attributes to a menu item edit form.
 *
 * @param $form
 *   The menu item edit form passed by reference.
 * @param $item
 *   The optional existing menu item for context.
 */
function _wechat_menu_form_alter(array &$form, array $item = array(), array &$complete_form) {
  // Restrict access to the new form elements.
  if ($item['menu_name'] !== 'wechat') {
    return;
  }
  
  $form['link_path']['#default_value'] = 'node';
  $form['options']['#tree'] = TRUE;
  $form['options']['#weight'] = 50;
  $parent_options = $form['parent']['#options'];
  $parent_options_new = array();
  foreach($parent_options as $key=>$value){
    if (substr($key,0,6) == 'wechat') {
      $parent_options_new[$key]	= $value;
    }
  }
  $form['parent']['#options'] = $parent_options_new;
  $form['link_path']['#access'] = FALSE;
  $form['description']['#access'] = FALSE;
  $form['enabled']['#access'] = FALSE;
  $form['expanded']['#access'] = FALSE;
  $form['weight']['#access'] = FALSE;
  
  //print debug($form['parent']);
  // Unset the previous value so that the new values get saved.
  unset($form['options']['#value']['attributes']);

  $form['options']['attributes'] = array(
    '#type' => 'fieldset',
    '#title' => 'WeChat Menu Config',
    '#collapsible' => FALSE,
    '#collapsed' => FALSE,
    '#tree' => TRUE,
    );
  $menu_type_options = array(
    'click' => t('点击推事件'),
    'view' => t('跳转URL'),
    'scancode_push' => t('扫码推事件'),
    'scancode_waitmsg' => t('扫码推事件且弹出“消息接收中”提示框'),
    'pic_sysphoto' => t('弹出系统拍照发图'),
    'pic_photo_or_album' => t('弹出拍照或者相册发图'),
    'pic_weixin' => t('弹出微信相册发图器'),
    'location_select' => t('弹出地理位置选择器'),
    );
  $form['options']['attributes']['wechat_type'] = array(
    '#type' => 'radios',
    '#title' => t('Menu Type'),
    '#default_value' => isset($item['options']['attributes']['wechat_type']) ? $item['options']['attributes']['wechat_type'] : 'click',
    //'#options' => array('click' => t('Click'), 'view' => t('View')),
    '#options' => $menu_type_options,
    //'#description' => t('Click: 点击推事件, View: 跳转URL, .'),
    '#required' => TRUE,
    );
  $form['options']['attributes']['wechat_key'] = array(
    '#type' => 'textfield',
    '#title' => t('Menu KEY'),
    '#description' => t('Key for the menu clicked event'),
    '#default_value' => isset($item['options']['attributes']['wechat_key']) ? $item['options']['attributes']['wechat_key'] : '',
    '#states' => array(
      'visible' => array(
        ':input[name="options[attributes][wechat_type]"]' => array(
          array('value' => 'click'),
          array('value' => 'scancode_push'),
          array('value' => 'scancode_waitmsg'),
          array('value' => 'pic_sysphoto'),
          array('value' => 'pic_photo_or_album'),
          array('value' => 'pic_weixin'),
          array('value' => 'location_select'),
          ),
        ),
      ),
    );
  $form['options']['attributes']['wechat_default_message'] = array(
    '#type' => 'textarea',
    '#title' => t('Menu Default Message'),
    '#description' => t('Send this message on menu clicked if no other module take action'),
    '#default_value' => isset($item['options']['attributes']['wechat_default_message']) ? $item['options']['attributes']['wechat_default_message'] : '',
    '#states' => array(
      'visible' => array(
        ':input[name="options[attributes][wechat_type]"]' => array('value' => 'click'),
        ),
      ),
    );
  $form['options']['attributes']['wechat_url'] = array(
    '#type' => 'textfield',
    '#title' => t('Menu Open URL'),
    '#maxlength' => 512,
    '#description' => t('Open this URL if menu type is view.'),
    '#default_value' => isset($item['options']['attributes']['wechat_url']) ? $item['options']['attributes']['wechat_url'] : '',
    '#states' => array(
      'visible' => array(
        ':input[name="options[attributes][wechat_type]"]' => array('value' => 'view'),
        ),
      ),
    );
  $form['#validate'][] = '_wechat_menu_form_validate';
}

function _wechat_menu_form_validate($form, &$form_state) {
  if ($form_state['values']['options']['attributes']['wechat_type'] != 'view') {
    if (empty($form_state['values']['options']['attributes']['wechat_key'])) {
      form_set_error('wechat_key', t('Menu KEY is required'));
    }
  }
  elseif ($form_state['values']['options']['attributes']['wechat_type'] == 'view') {
    if (!valid_url($form_state['values']['options']['attributes']['wechat_url'], TRUE)) {
      form_set_error('wechat_url', t('Please enter a url.'));
    }
  }
}


/**
 * init wechat object
 */
function _wechat_init_obj() {
  $we_obj = &drupal_static(__FUNCTION__);
  if (!isset($we_obj)) {
    module_load_include('php', 'wechat', 'sdk/wechat.class');
    $options = array(
      'token' => variable_get('wechat_token', ""),
      'appid' => variable_get('wechat_appid', ""),
      'appsecret' => variable_get('wechat_appsecret', ""),
      );
    $we_obj = new Wechat($options);
  }
  return $we_obj;
}
/**
 * init wechat object for desktop
 */
function _wechat_desktop_init_obj() {
  $we_desktop_obj = &drupal_static(__FUNCTION__);
  if (!isset($we_desktop_obj)) {
    module_load_include('php', 'wechat', 'sdk/wechat_desktop.class');
    $options = array(
      // 'token' => variable_get('wechat_token', ""),
      'appid' => variable_get('wechat_desktop_appid', ""),
      'appsecret' => variable_get('wechat_desktop_appsecret', ""),
      );
    $we_desktop_obj = new WechatDesktop($options);
  }
  return $we_desktop_obj;
}

/**
 * init wechat object
 */
function wechat_init_obj_with_access_token() {
  $we_obj = _wechat_init_obj();
  //由于我们使用的wechat SDK，目前没有setAccessToken($access_token)，所以我们这里只能委屈一下了
  $access_token = wechat_get_access_token();
  $we_obj->checkAuth('', '', $access_token);
  return $we_obj;
}

/**
 * user login by uid
 */
function _wechat_user_login($uid) {
  global $user;
  $user = user_load($uid);
  drupal_session_regenerate();
}

/**
 * hook_user_load
 */
function wechat_user_load($users) {
  $result = db_query('SELECT * FROM {wechat_user} WHERE uid IN (:uids)', array(':uids' => array_keys($users)));
  foreach ($result as $record) {
    $users[$record->uid]->wechat = $record;
  }
}

/**
 * load user by wechat unionid
 */
function wechat_get_user_by_unionid($unionid) {
  $result = db_query("SELECT * FROM {wechat_user} WHERE unionid=:unionid", array(':unionid' => $unionid));
  if (!$result) {
    return FALSE;
  }
  $authmap = $result->fetchAssoc();
  if (!empty($authmap['uid'])) {
    return user_load($authmap['uid']);
  }
  return FALSE;
}


/**
 * Login user and get user openid
 */
function wechat_snsapi_base($path, $onerror='') {
  $we_obj = _wechat_init_obj();
  $auth_url = $we_obj->getOauthRedirect(url('wechat/auth', array('absolute' => TRUE, 'query' => array('destination' => $path, 'onerror' => $onerror))), 1, 'snsapi_base');
  drupal_goto($auth_url);
}

function wechat_snsapi_userinfo($path, $onerror) {
  $we_obj = _wechat_init_obj();
  $auth_url = $we_obj->getOauthRedirect(url('wechat/auth', array('absolute' => TRUE, 'query' => array('destination' => $path, 'onerror' => $onerror))), 2, 'snsapi_userinfo');
  drupal_goto($auth_url);
}

function wechat_user_info($openid, $mobile = true){
  if ($mobile) {
    $we_obj = _wechat_init_obj();
  //由于我们使用的wechat SDK，目前没有setAccessToken($access_token)，所以我们这里只能委屈一下了
    $access_token = wechat_get_access_token();
    $we_obj->checkAuth('', '', $access_token);
    $user_info = $we_obj->getUserInfo($openid);
  }else{
    $we_obj = _wechat_desktop_init_obj();
    $user_info = $we_obj->getUserInfo($openid);
  }
  return $user_info;
}
/**
 * connect user with wechat account
 */
function wechat_connect_user($uid, $user_info, $mobile = true) {
  $query = db_select('wechat_user', 'o');
  $query->condition('o.unionid', $user_info['unionid'], '=');
  $query->fields('o', array('uid', 'unionid', 'wp_openid', 'open_openid', 'subscribe', 'nickname', 'sex', 'province', 'city', 'country', 'headimgurl', 'subscribe_time'));
  $query->range(0, 1);
  $result = $query->execute();
  if ($result->rowCount()) {
     // $record = $result->fetchAssoc();
   $wechat_user = array(
    'uid' => $uid,
    'nickname' => $user_info['nickname'],
    'subscribe' => (int)(isset($user_info['subscribe']) ? $user_info['subscribe'] : ''),
    'headimgurl' => $user_info['headimgurl'],
    );
   $openid_key = $mobile ? 'wp_openid' : 'open_openid';
   $wechat_user[$openid_key] = $user_info['openid'];
   $primary_key = array('unionid');
   return   $num_updated = db_update('wechat_user')->fields($wechat_user)->condition('unionid', $user_info['unionid'], '=')->execute();
   }else{
      // insert
    $wechat_user = array(
      'unionid' => $user_info['unionid'],
      'uid' => $uid,
      'subscribe' => (int)(isset($user_info['subscribe']) ? $user_info['subscribe'] : ''),
      'nickname' => $user_info['nickname'],
      'sex' => $user_info['sex'],
      'province' => $user_info['province'],
      'city' => $user_info['city'],
      'country' => $user_info['country'],
      'headimgurl' => $user_info['headimgurl'],
      'subscribe_time' => time(),
      );
    $openid_key = $mobile ? 'wp_openid' : 'open_openid';
    $wechat_user[$openid_key] = $user_info['openid'];
    return db_insert('wechat_user')->fields($wechat_user)->execute();
  }
}

function wechat_get_access_token($appid='', $appsecret='') {
  $access_token = FALSE;
  if (empty($appid)) {
    $appid = variable_get('wechat_appid', "");
  }
  
  if (!empty($appsecret)) {
    $appsecret =variable_get('wechat_appsecret', "");
  }
  
  $access_token_object = db_query("SELECT * FROM {wechat_access_token} WHERE app_id=:appid", array(':appid' => $appid))->fetchObject();
  $current = time();
  //print debug($access_token_object);
  if (isset($access_token_object->token)) { 
    $expire = $access_token_object->expire;
    $create_time = $access_token_object->create_time;
    if ($create_time + $expire - 30 > $current) {
      $access_token = $access_token_object->token;
      //drupal_set_message('reuse:123');
      return $access_token;
    }
  }
  //drupal_set_message('createnew:123');
  $we_obj = _wechat_init_obj();
  $access_token = $we_obj->checkAuth($appid, $appsecret);

  if (!empty($access_token)) {
    db_delete('wechat_access_token')
    ->condition('app_id', $appid)
    ->execute();

    $query = db_insert('wechat_access_token')->fields(array('app_id', 'token', 'expire', 'create_time'));
    $query->values(array(
      'app_id' => $appid,
      'token' => $access_token,
      'expire' => 3600,
      'create_time' => $current,
      ));
    $query->execute();
  }
  return $access_token;
}

/**
 * Implementation of hook_wechat_build_response_message().
 */
function wechat_wechat_build_response_message($response_message, $request_message) {
  //这里主要是实现用户绑定。
  //watchdog('wechat', '进入hook_wechat_build_response_message'); 
  $request_message_wrapper = entity_metadata_wrapper('wechat_request_message', $request_message);
  $response_message_wrapper = entity_metadata_wrapper('wechat_response_message', $response_message);
  if ($request_message->msg_type == 'event') {
    //watchdog('wechat', '进入event'); 
    //用户关注我们的情况
    if ($request_message_wrapper->wechat_event->value() == 'subscribe') {
      $uid = 0;
      $openid = $request_message->from_user_name;
      $user_info = wechat_user_info($openid, $mobile = true);
      $result = wechat_connect_user($uid, $user_info);
    }
    if ($request_message_wrapper->wechat_event->value() == 'unsubscribe') {
      $openid = $request_message->from_user_name;
      db_query('delete FROM {wechat_user} WHERE wp_openid=:wp_openid', array(':wp_openid' => $openid));
    }	
    //用户扫描二维码，绑定账号
    $wechat_event = $request_message_wrapper->wechat_event->value();

    //watchdog('wechat', 'wechat_event:' .$wechat_event); 
    //注意，这里返回的是大写的SCAN，原来用的小写，不行
    if ($request_message_wrapper->wechat_event->value() == 'SCAN') {
      //watchdog('wechat', '进入scan');
      $event_key = $request_message_wrapper->wechat_event_key->value();
      //watchdog('wechat', 'event_key：' . $event_key);
      if (!empty($event_key)) {
        $uid = $event_key;
        $openid = $request_message->from_user_name;
        $user_info = wechat_user_info($openid, $mobile = true);
        $result = wechat_connect_user($uid, $user_info);
        if (!empty($result)) {
          $message_content = t('已将您的微信号，与系统用户绑定，系统用户Id：') . $uid;
          $response_message_wrapper->wechat_content->set($message_content);            
        }
        else {
          $message_content = t('未能将您的微信号，与系统用户绑定，尝试绑定的系统用户Id：') . $uid;
          $response_message_wrapper->wechat_content->set($message_content); 
        }
      }
    }
  }
}

/**
 * Implements hook_views_api().
 */
function wechat_views_api() {
  return array(
    'api' => 3,
    'path' => drupal_get_path('module', 'wechat') . '/views',
    );
}

function wechat_upload_media($fid, $type) {
  $file = file_load($fid);
  $media_id = NULL;
  $uri = $file->uri;
  $realpath = drupal_realpath($uri);
  $filename = '@' . $realpath;
  //print debug($filename);
  $we_obj = wechat_init_obj_with_access_token();
  $data = array(
    'media' => $filename,
    );
  $result  = $we_obj->uploadMedia($data, $type);
  //print debug($result);
  if (!empty($result['media_id']))	{
    $media_id = $result['media_id'];
  }
  return $media_id;
}

function wechat_build_news_article($node, $position=0){
  $article_item = array(
    'title' => "",
    
    +'description' => "",
    'url' => "",
    'picurl' => "",
    );
  //$node = node_load($nid);
  $node_wrapper = entity_metadata_wrapper('node', $node); 
  $article_item['title'] = $node->title;
  $article_item['url'] = url('node/' . $node->nid, array('absolute' => TRUE));
  if (!empty($node_wrapper->body->value)) {
    try{
      $content = $node_wrapper->body->value->value(array('decode' => TRUE));
      $content = substr($content, 0, 600);
      $article_item['description'] = $content;
    }
    catch(Exception $e){}
  }
  if (isset($node_wrapper->field_image)) {
    $field_image = $node_wrapper->field_image->value(); 
  }
  if (!empty($field_image)) {
    $article_item['picurl'] = $node_wrapper->field_image->file->url->value();
  }
  
  drupal_alter('wechat_news_article', $article_item, $node, $position);
  return $article_item;
  
}


/**
 * Determines whether the given user has access to a wechat_response_message.
 *
 * @param $op
 *   The operation being performed. One of 'view', 'update', 'create', 'delete'
 *   or just 'edit' (being the same as 'create' or 'update').
 * @param $wechat_user
 *   Optionally a wechat_user to check access for. If nothing is
 *   given, access for all wechat_user is determined.
 * @param $account
 *   The user to check for. Leave it to NULL to check for the global user.
 * @return boolean
 *   Whether access is allowed or not.
 */
function wechat_wechatuser_access($op, $wechat_user = NULL, $account = NULL) {
  if (user_access('administer wechat user', $account)) {
    return TRUE;
  }
  return TRUE;
}

/**
 * Fetch a wechat request message object. 
 *
 * @param $openid
 *   wechat user openid.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   A fully-loaded $wechat_user object or FALSE if it cannot be loaded.
 *
 * @see wechat_user_load_multiple()
 */
function wechat_wechatuser_load($unionid, $reset = FALSE) {
  $wechat_users = wechat_wechatuser_load_multiple(array($unionid), array(), $reset);
  return reset($wechat_users);
}

function wechat_wechatuser_load_by_wp_openid($wp_openid){
  $query = new EntityFieldQuery();
  $query->entityCondition('entity_type', 'wechat_user')->propertyCondition('wp_openid', $wp_openid);
  $result = $query->execute();
  if (isset($result['wechat_user'])) {
    $news_items_nids = array_keys($result['wechat_user']);
    $news_items = entity_load('wechat_user', $news_items_nids);
  }
  return $news_items;
}

function wechat_wechatuser_load_by_open_openid($open_openid){
  $query = new EntityFieldQuery();
  $query->entityCondition('entity_type', 'wechat_user')->propertyCondition('open_openid', $open_openid);
  $result = $query->execute();
  if (isset($result['wechat_user'])) {
    $news_items_nids = array_keys($result['wechat_user']);
    $news_items = entity_load('wechat_user', $news_items_nids);
  }
  return $news_items;
}

/**
 * Load multiple wechat user based on certain conditions.
 *
 * @param $openids
 *   An array of wechat user openids.
 * @param $conditions
 *   An array of conditions to match against the {wechat_user} table.
 * @param $reset
 *   A boolean indicating that the internal cache should be reset.
 * @return
 *   An array of wechat user objects, indexed by openid.
 *
 * @see entity_load()
 * @see wechat_user_load()
 */
function wechat_wechatuser_load_multiple($unionids = array(), $conditions = array(), $reset = FALSE) {
  return entity_load('wechat_user', $unionids, $conditions, $reset);
}

/**
 * Deletes a wechat user.
 */
function wechat_wechatuser_delete(WechatUser $wechat_user) {
  $wechat_user->delete();
}


/**
 * Delete multiple wechat users.
 *
 * @param $unionids
 *   An array of wechat user unionids.
 */
function wechat_wechatuser_delete_multiple(array $unionids) {
  entity_get_controller('wechat_user')->delete($unionids);
}


/**
 * Create a wechat user object.
 */
function wechat_wechatuser_create($values = array()) {
  return new WechatUser($values);
}


/**
 * Saves a wechat user to the database.
 *
 * @param $wechat_user
 *   The wechat user object.
 */
function wechat_wechatuser_save(WechatUser $wechat_user) {
  return $wechat_user->save();
}

/**
 * URI callback for wechat_response_message
 */
function wechat_wechatuser_uri(WechatUser $wechat_user) {
  return array(
    'path' => 'wechat-user/' . $wechat_user->wp_openid,
    );
}

/**
 * Implementation of hook_wechat_request_message_insert().
 */
function wechat_wechat_request_message_insert($request_message) {

  $request_message_wrapper = entity_metadata_wrapper('wechat_request_message', $request_message);  
  $openid = $request_message->from_user_name;
  $wechatuser = wechat_wechatuser_load_by_wp_openid($openid);
  if(empty($wechatuser)){
    $uid = 0;
    $user_info = wechat_user_info($openid, $mobile = true);
    $result = wechat_connect_user($uid, $user_info);    
  }
}

/**
 * Implementation of hook_wechat_request_message_insert().
 */
function wechat_wechatuser_sex_options_list() {
  return array('1'=>t('男'), '2'=>t('女'), '0'=>t('未知') );
}


function wechat_form_alter(&$form, &$form_state, $form_id){
  global $base_url;
  // die('unhappy!');
  switch($form_id) {  
      case 'user_login': // the value we stole from the rendered form  
      case 'user_register_form': // the value we stole from the rendered form  
      drupal_add_css(drupal_get_path('module', 'wechat') . '/wechat.css');
      $form['cutomtext'] = array(
        '#type' => 'item',
        '#markup' => '<div class="wechat_login_desktop"> <a href="'  . $base_url . '/wechat/login'. '"><img src="' .  $base_url . '/' . drupal_get_path('module', 'wechat') . '/icon48_wx_button.png' .  '" alt=""></a> </div>',
        '#weight' => 1, // Adjust so that you can place it whereever 
        );
      $form['wechat_binding'] = array(
        '#type' => 'item',
        '#markup' => '<div class="wechat_login_mobile"> <a href="'  . $base_url . '/wechat-binding'. '"><img src="' .  $base_url . '/' . drupal_get_path('module', 'wechat') . '/icon48_wx_button.png' .  '" alt=""></a> </div>',
        '#weight' => 1, // Adjust so that you can place it whereever 
        );      
      break;  
    }  
  }

/* 
* load wechat session, get user openid. 
*/
function load_wechat_session($mobile = true){
// if this is wechat callback, and set session
  if (isset($_GET['code']) && (! isset($_SESSION['unionid']))) {
  // if (isset($_GET['code'])) {
    set_token($mobile);
  }
// if not set wechat session, then set it 
  if (! isset($_SESSION['unionid']) ) {
    get_code($mobile);
  }
}

/*
* mobile brower build code request url. 
*/ 
function get_code($mobile){
  $actual_link = "http://$_SERVER[HTTP_HOST]$_SERVER[REQUEST_URI]";    
  if ($mobile) {
    $we_obj = _wechat_init_obj();
    $auth_url = $we_obj->getOauthRedirect($actual_link, 'hello', 'snsapi_userinfo');
  }else{
    $we_desktop_obj = _wechat_desktop_init_obj();
    $auth_url = $we_desktop_obj->getOauthLoginRedirect($actual_link, 'hello', 'snsapi_login');
  }
  drupal_goto($auth_url);
}

function set_token($mobile){
  $we_obj = _wechat_init_obj();
  if ($mobile) {
    $we_obj = _wechat_init_obj();
    $access_data = $we_obj->getOauthAccessToken();
  }else{
    $we_desktop_obj = _wechat_desktop_init_obj();
    $access_data = $we_desktop_obj->getOauthAccessToken();
  }
    // error_log(print_r($access_data, true));
  $accessToken =  $access_data['access_token'];
  $openid =  $access_data['openid'];
  // $unionid =  empty($access_data['unionid']) ? '' : $access_data['unionid'];
  // get user_info
  $user_info = wechat_user_info($openid, $mobile);
  $_SESSION['unionid'] = $user_info['unionid']; 
  $_SESSION['wechat_user_info'] = $user_info;
  if ($mobile) {
    $_SESSION['wp_openid'] = $openid;
    $_SESSION['wp_access_token'] = $accessToken;
    $_SESSION['device_type'] = 'mobile';
  }else{
    $_SESSION['open_openid'] = $openid;
    $_SESSION['open_access_token'] = $accessToken;
    $_SESSION['device_type'] = 'desktop';
  }
}


// hook_user_delete
// when delete user, also should delete record in wechat_user
function wechat_user_delete($account){
  db_delete('wechat_user')
  ->condition('uid', $account->uid)
  ->execute();
}

function is_mobile($device_type){
  switch ($device_type) {
    case 'mobile':
      return true;
      break;
    
    case 'desktop':
      return false;
      break;
  }
}