public function bindPhoneCode($param = null)
 {
     if (isset($param)) {
         $post_data = $param;
         $exit_type = 'array';
     } else {
         $post_data = I('post.');
         $exit_type = 'json';
     }
     wlog('/share/weixinLog/artisans/58_phone.log', $post_data['phone']);
     $access_token = $post_data['access_token'];
     $this->_checkToken($access_token);
     if (!$this->_access_token) {
         return $this->returnJsonData($exit_type, 10002);
         //没有权限
     }
     $phone = $post_data['phone'];
     if (empty($phone)) {
         return $this->returnJsonData($exit_type, 300);
     }
     if (!check_phone($phone)) {
         return $this->returnJsonData($exit_type, 10003);
         //手机号格式有误
     }
     $now_time = date('Y-m-d H:i:s');
     $rand_code = mt_rand('100000', '999999');
     $data['CouponsId'] = 1;
     $data['Phone'] = $phone;
     $data['CodeNum'] = $rand_code;
     $data['Source'] = 1;
     $data['IsUse'] = 0;
     $data['CreateTime'] = $now_time;
     $where = array('Source' => 1, 'Phone' => $phone);
 }

 public function GetResponse()
 {
     wlog(get_class($this), "I Requests sent. Reading responses...");
     $reply = "";
     // MAIN PROGRAM LOOP
     while ($reply .= $this->oApi->readRequestBinary()) {
         // append to data left from previous request
         // if the last character isn't the EOT character, then this contains a part response
         //print ".";
         if ($reply[strlen($reply) - 1] != chr(10)) {
             $nlpos = strrpos($reply, chr(10));
             if ($nlpos !== false) {
                 // has a full response plus a part response
                 // process the full response sub string
                 $aResponses = explode(chr(10), trim(substr($reply, 0, $nlpos + 1)));
                 $reply = substr($reply, $nlpos + 1);
                 // keep the part response
             }
             // else it is only part of another response so leave $reply set
         } else {
             // is simply a full response, so process it
             $aResponses = explode(chr(10), trim($reply));
             $reply = "";
         }
         // now parse each message one at a time
         foreach ($aResponses as $response) {
             $rid = substr($response, 0, strpos($response, chr(31)));
             $response = substr($response, strpos($response, chr(31)) + 1);
             $this->ParseResponse($rid, $response);
         }
     }
     // while
 }

 /**
  * 数据列表
  */
 public function lists()
 {
     if (IS_POST) {
         $username = PUT('username');
         $map = array();
         $map['username'] = array('like', "%{$username}%");
         $map['b.realname'] = array('like', "%{$username}%");
         $map['b.nickname'] = array('like', "%{$username}%");
         $map['b.id_number'] = array('like', "%{$username}%");
         $map['b.company'] = array('like', "%{$username}%");
         $map['_logic'] = 'or';
         $size = PUT('size', 10);
         $page = PUT('p');
         $count = $this->model->alias('a')->join('__USER_INFO__ b on a.id=b.user_id', 'LEFT')->where($map)->where($map)->count();
         $items = $this->model->alias('a')->join('__USER_INFO__ b on a.id=b.user_id', 'LEFT')->field('a.id,username,login_count,last_login_time,register_time,updated,status,portrait,realname,nickname,cat_id,name_cert,sex,age,birthday,id_number,email,company,work_status,alternative_phone')->where($map)->page($page, $size)->order('id desc')->select();
         $result['status'] = true;
         $result['count'] = $count;
         $result['size'] = $size;
         $result['page'] = $page;
         $result['items'] = $items;
         wlog('user', $result);
         $this->ajaxReturn($result);
     } else {
         $this->display();
     }
 }

 /**
  * 跳转
  */
 public function jump()
 {
     $p = I('p');
     $url = U('Log/jump', '', false);
     wlog('url', $url);
     $this->redirect($url, array('p' => $p));
 }

 public function DecodeResponse(&$sMessage)
 {
     $aMessage = explode(chr(31), $sMessage);
     $key = "fid_exchange_id";
     for ($i = 0; $i < count($aMessage); $i++) {
         switch ($this->aFieldTypes[$aMessage[$i]]) {
             case $key:
             case "fid_exchange_symbol":
             case "fid_exchange_country":
             case "fid_text":
                 $aFields[$this->aFieldTypes[$aMessage[$i]]] = $aMessage[++$i];
                 break;
             default:
                 $i++;
                 break;
         }
     }
     // check that key exists
     if (array_key_exists($key, $aFields)) {
         // It exists
         $this->aaExchanges[$aFields[$key]] = $aFields;
     } else {
         // THIS SHOULD NEVER HAPPEN!
         wlog(get_class($this), "W Exchange message failed to decode. Response was: " . $sMessage);
     }
 }

 /**
  * 执行mysql query()操作
  * @param string $sql
  * @return mixed
  */
 public function query($sql)
 {
     // 是否记录 SQL log
     if (true == C('sql_log')) {
         wlog('SQL-Log', $sql);
     }
     $error_msg = '';
     $_key = strtolower(substr($sql, 0, 6));
     if ($_key == 'select') {
         $rs = sqlite_query($this->db, $sql, SQLITE_BOTH, $error_msg);
     } else {
         $rs = sqlite_exec($this->db, $sql, $error_msg);
     }
     if (!empty($rs)) {
         $GLOBALS['run_dbquery_count']++;
         return $rs;
     } else {
         if (C('show_errors')) {
             show_error('执行sqlite_query()出现错误: ' . $error_msg . '<br />原SQL: ' . $sql);
         } else {
             exit('db_sqlite2::query() error.');
         }
     }
     //return false;
 }

function connect($name, $db_type, $params)
{
    global $g_db;
    //try to connect one of connection parameter that works..
    $exceptions = array();
    foreach ($params as $param) {
        try {
            $db = Zend_Db::factory($db_type, $param);
            $db->setFetchMode(Zend_Db::FETCH_OBJ);
            $db->getConnection();
            //profile db via firebug
            if (config()->debug) {
                $profiler = new Zend_Db_Profiler_Firebug('All DB Queries');
                $profiler->setEnabled(true);
                $db->setProfiler($profiler);
            }
            //slog("success $name");
            $g_db[$name] = $db;
            return;
        } catch (Zend_Db_Adapter_Exception $e) {
            // perhaps a failed login credential, or perhaps the RDBMS is not running
            wlog("Couldn't connect to {$name} (trying another connection - if available):: " . $e->getMessage());
            $exceptions[] = $e;
        } catch (Zend_Exception $e) {
            // perhaps factory() failed to load the specified Adapter class
            wlog("Couldn't connect to {$name} (trying another connection - if available):: " . $e->getMessage());
            $exceptions[] = $e;
        }
    }
    $msg = "";
    foreach ($exceptions as $e) {
        $msg .= $e->getMessage() . "\n";
    }
    throw new Exception("Failed to connect to {$name}");
}

 protected function after_select(&$items)
 {
     foreach ($items as &$value) {
         $msg_id = $value['id'];
         $map['status'] = array('in', '1,3,5,7,9,11,13,15');
         if ($value['msg_cat'] == 0) {
             $total = M('User')->where($map)->count();
         } else {
             $map['cat_id'] = $value['msg_cat'];
             $total = M('UserInfo')->where($map)->count();
         }
         $where['status'] = 1;
         $where['msg_id'] = $msg_id;
         $read = M('Msg_read')->where($where)->select();
         $read_count = 0;
         if ($read) {
             foreach ($read as $v) {
                 unset($map);
                 $map = array();
                 $map['user_id'] = $v['user_id'];
                 $map['cat_id'] = $value['msg_cat'];
                 $res = M('UserInfo')->where($map)->find();
                 if ($res) {
                     ++$read_count;
                     wlog('count', $read_count);
                 }
             }
         }
         $value['read'] = $read_count;
         $value['unread'] = $total - $read_count;
         if ($value['unread'] == 0) {
             $value['disable'] = true;
         }
     }
 }

 public function comWlog($log_data = array(), $log_url = '')
 {
     if (empty($log_url)) {
         $log_url = C('WWW_LOG_URL') . ACTION_NAME . date(Ymd) . '.log';
     }
     $this->log_url = $log_url;
     $this->log_dat = $log_data;
     if ($this->log_status) {
         wlog($this->log_url, $this->log_data);
     }
 }

 /**
  * 获取用户中心token
  * @access	public
  * @param	string $url
  * @return	mixed
  */
 public function getUserCenterToken($url)
 {
     if (!$url) {
         return false;
     }
     $post_data = json_encode(array('realm' => 'XXX'));
     $receive = send_curl($url, $post_data);
     $parse_data = json_decode($receive, true);
     if (is_array($parse_data['data']) && $parse_data['data']['access_token']) {
         $token = $parse_data['data']['access_token'];
     } else {
         wlog('/share/weixinLog/artisans/user_center_api/user_center_token' . date('Ymd') . '.log', $parse_data);
     }
     return $token;
 }

 /**
  * 连接数据库
  * @access protected
  * @param string $db_config_name 使用那个数据库连接
  */
 protected function conn($db_config_name = '')
 {
     $db_config_name = $db_config_name ? $db_config_name : $this->db_config_name;
     if (!isset(self::$_db_handle[$db_config_name])) {
         if (true == C('sql_log')) {
             wlog('SQL-Log', '#' . $db_config_name);
         }
         $dbdriver = 'db_' . C('dbdriver');
         include_once FW_PATH . '/dbdrivers/' . $dbdriver . '.class.php';
         self::$_db_handle[$db_config_name] = $this->db = new $dbdriver($db_config_name);
     } else {
         $this->db = self::$_db_handle[$db_config_name];
     }
     return $this->db;
 }

 public function __toString()
 {
     if (C('exception_log')) {
         $str = "\n异常信息:{$this->getMessage()}\n错误文件:{$this->getFile()}\n错误行数:{$this->getLine()}\n异常代码:{$this->getCode()}\n------------------------------";
         wlog('ExceptionLog', $str);
     }
     //ob_start();
     $tpl = C('tpl_exception');
     if (!$tpl) {
         include FW_PATH . '/tpl/ephpException.tpl.php';
     } else {
         include APP_PATH . '/views/public/' . $tpl;
     }
     //return ob_get_clean();
     return '';
 }

 function __construct(array &$settings)
 {
     $this->aaSettings = $settings;
     wLog(get_class($this), " \n--- Loading ---");
     // Check DB Clear settings
     if (!isset($this->aaSettings["DB"]["HOST"], $this->aaSettings["DB"]["USERNAME"], $this->aaSettings["DB"]["PASSWORD"])) {
         wlog(get_class($this), "E  Arggghhhh DB settings not found in INI file!!! Blowing up ungracefully...");
         exit;
     }
     $this->oDatabase = new CDbMssql($this->aaSettings["DB"]["HOST"], $this->aaSettings["DB"]["USERNAME"], $this->aaSettings["DB"]["PASSWORD"]);
     // Check TRADE (P&L) settings
     if (!isset($this->aaSettings["RTDHOST"]["IP"], $this->aaSettings["RTDHOST"]["PORT"])) {
         wlog(get_class($this), "E  Arggghhhh RTDHOST settings not found in INI file!!! Blowing up ungracefully...");
         exit;
     }
     $this->oApi = new CSocketStream($this->aaSettings["RTDHOST"]["IP"], $this->aaSettings["RTDHOST"]["PORT"]);
 }

 /**
  * MYSQL query
  * @param  string $sql
  * @return mixed
  */
 function query($sql)
 {
     #是否记录 SQL log
     if (true == C('sql_log')) {
         wlog('SQL-Log', $sql);
     }
     if (true == ($rs = $this->db->query($sql))) {
         $GLOBALS['run_dbquery_count']++;
         return $rs;
     } else {
         if (C('show_errors')) {
             throw new ephpException('执行mysqli::query()出现错误: ' . $this->db->error . '<br />原SQL: ' . $sql, 2045);
         } else {
             exit('db_mysqli::query() error.');
         }
     }
 }

 public function select_redbag()
 {
     if (I("code")) {
         $code = I("code");
         $shop = D("WeiXinApi");
         $userinfo = $shop->getOAuthAccessToken($code);
         $openid = $userinfo["openid"];
         if (!$openid) {
             wlog('/share/weixinLog/artisans/user_center_api/no_find_openid.log', $userinfo);
             //auth验证没有获取到openid
         }
     } else {
         $openid = $this->reGetOAuthDebug(U('Redbag/' . ACTION_NAME));
     }
     $info = M('ord_submit_info')->where("UserOpenid='%s'", $openid)->order('InfoId desc')->find();
     $pro_id = $info['ProductId'];
     //用户卡券
     $transfer_data['city_id'] = $this->_city_id;
     $transfer_data['pro_id'] = $pro_id;
     $transfer_data['uid'] = $uid;
     $user_card_info = send_curl($this->_user_coupons_url, $transfer_data);
     $parse_data = json_decode($user_card_info, true);
     if ($parse_data['code'] == 200 && $parse_data['code']['data']) {
         $data = $parse_data['code']['data'];
     } else {
         $data = array();
     }
     //卡券列表
     $cardid = $this->_card[$pro_id];
     $num = count($cardid);
     $cardinfo = array();
     for ($i = 0; $i < $num; $i++) {
         $cardinfo = $this->getcard_info($cardid[$i], $openid);
     }
     $card_num = count($cardinfo);
     if ($card_num > 0) {
         $this->assign('status', 200);
     } else {
         $this->assing('status', 500);
     }
     $this->assign('list', array($cardinfo));
     //跳转链接
     $jump_url = U('Craft/selectCard') . '?haoren=1';
     $this->assign('jump_url', $jump_url);
     $this->display(T('Craft/qcs_card'));
 }

 public function indexAction()
 {
     $q = $this->clean($_REQUEST["q"]);
     $this->view->query = $q;
     $recs = array();
     if (isset($_REQUEST["type"])) {
         $type = $_REQUEST["type"];
     } else {
         $type = "all";
     }
     if (isset($_REQUEST["q"]) && $q != "") {
         $recs = $this->dosearch($type, 999, $q, false);
         if (count($recs) == 0) {
             wlog("No search results for query: {$q}");
         }
         $this->view->recs = $recs;
     }
 }

 /**
  * 执行mysql query()操作
  * @param string $sql
  * @return object
  */
 public function query($sql)
 {
     // 是否记录 SQL log
     if (true == C('sql_log')) {
         wlog('SQL-Log', $sql);
     }
     if (true == ($rs = mysql_query($sql, $this->db))) {
         $GLOBALS['run_dbquery_count']++;
         return $rs;
     } else {
         if (C('show_errors')) {
             throw new ephpException('执行mysql::query()出现错误: ' . mysql_error($this->db) . '<br />原SQL: ' . $sql, 2045);
         } else {
             exit('db_mysql::query() error.');
         }
     }
     //return false;
 }

 /**
  * 上传文件
  */
 public function upload($time, $md5, $path, $data, $range, $size, $chunk, $chunks)
 {
     wlog("上传文件", $path . ' ' . json_encode($range) . ' ' . $size);
     if ($this->md5($time, $md5)) {
         if ($data) {
             $paths = dirname($path);
             if (!is_dir($paths)) {
                 mkdirs($paths);
             }
             // $fp = fopen($path,"wb");
             // fseek($fp,$range[0]);
             // fwrite($fp,$data,$range[1] - $range[0]);
             // fclose($fp);
         }
         return true;
     } else {
         return false;
     }
 }

 /**
  * 管理员登陆
  */
 public function login()
 {
     if (IS_POST) {
         $username = PUT('username');
         $password = PUT('password');
         $verify = PUT('verify');
         $result = array();
         //             if(!check_verify($verify)){
         //     $this->error('验证码输入错误！');
         // }else
         $err = Auth::login($username, $password);
         //             wlog('err', $err);
         if ($err < 5) {
             switch ($err) {
                 case 1:
                     $this->error('用户不存在');
                     break;
                 case 2:
                     $this->error('用户已禁用');
                     break;
                 case 3:
                     $this->error('角色已禁用');
                     break;
                 case 4:
                     $this->error('密码错误');
                     break;
             }
         } else {
             $user = $_SESSION['user_auth'];
             action_log('user_login', 'Admin', $user['id'], $user['id']);
             wlog('PUT', PUT());
             $this->success('登陆成功！', U('index'));
             //                 $this->redirect('Index/index','','','登陆成功！');
         }
     } else {
         layout('Common/layout');
         $this->display();
     }
 }

 /**
  * 执行mysql query()操作
  * @param String $sql
  * @return mixed
  */
 public function query($sql)
 {
     // 是否记录 SQL log
     if (true == C('sql_log')) {
         wlog('SQL-Log', $sql);
     }
     $_key = strtolower(substr($sql, 0, 6));
     if ($_key == 'select') {
         $qt = 'query';
     } else {
         $qt = 'exec';
     }
     if (true == ($rs = $this->db->{$qt}($sql))) {
         $GLOBALS['run_dbquery_count']++;
         return $rs;
     } else {
         if (C('show_errors')) {
             show_error('执行sqlite_query()出现错误: ' . $this->db->lastErrorMsg() . '<br />原SQL: ' . $sql);
         } else {
             exit('db_sqlite3::query() error.');
         }
     }
     //return false;
 }