微信公众号开发之数据库

1.初始化数据库

我用的是新浪SAE上的MYSQL。

官方文档：https://www.sinacloud.com/doc/sae/php/mysql.html#api-shi-yong-shou-ce

2.查询语句

链接数据库：(SAE提供了基于MYSQL模块的SaeMysql类)

$mysql = new SaeMysql();

直接实例化即完成链接操作，无须进行其他操作。

例如：

增加数据：(注意weixin附近的不是单引号，是TAB键上面那个键的值)

$mysql = new SaeMysql();

$sql = "insert into `weixin`(`id`,`title`,`content`) values(null,"haha",:"gaga")";

3.公众号关键词查询

case "text"://文本消息
                    if($keyword == "天气"){
                        $weatherurl="http://api.map.baidu.com/telematics/v3/weather?location=杭州&ak=f6UkU0QqVAhABUeGKSxZBCeb";
                        $apistr = file_get_contents($weatherurl);
                        $apiobj = simplexml_load_string($apistr);
                        $placeobj = $apiobj->results->currentCity;//读取城市名
                        $todayobj = $apiobj->results->weather_data->date;//读取当前时间
                        $weatherobj = $apiobj->results->weather_data->weather;//读取天气
                        $windobj = $apiobj->results->weather_data->wind;//读取风力
                        $temobj = $apiobj->results->weather_data->temperature;//读取温度
                        $pm25obj = $apiobj->results->pm25;//读取pm2.5
                        $contentStr = "{$placeobj}{$todayobj},天气:{$weatherobj},风力:{$windobj},温度:{$temobj},pm2.5:{$pm25obj}.";
                    }else{
                        $mysql = new SaeMysql();
                        $sql = "select * from `weixin` where `title` like '%{$keyword}%'";
                        $data = $mysql->getData($sql);
                        if($data == null){
                            $contentStr = "Hi,海仙日用百货欢迎您!
回复数字'1',了解店铺地址.
回复数字'2',了解商品种类.
"
                            ."回复'天气',获取杭州天气情况.
发送语音消息和地理位置信息,有更多惊喜等着你.";
                        }else{
                            $contentStr = $data[0][content];
                        }
                    }
                    break;

4.识别新老用户

     手机微信客户端传输到微信公众账号的用户信息为加密的openid，保存在变量$fromUsername中，我们可以将$fromUsername保存到数据库中，从而实现CRM（客户关系管理）。

新建数据表crm：

CREATE TABLE  `app_landiljy`.`crm` (
`id` INT NOT NULL AUTO_INCREMENT ,
`user` VARCHAR( 255 ) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL ,
PRIMARY KEY (  `id` )
) ENGINE = INNODB;

先判断是新客户还是老客户，当新客户发送“你好”时，回复“欢迎新朋友”；当老客户发送“你好”时，回复“欢迎老朋友”。

if($keyword == "你好" || $keyword == "您好"){
                        $mysql = new SaeMysql();
                        $sql = "select * from `crm` where `user` = '{$fromUsername}'";
                        $data = $mysql->getData($sql);
                        $user = $data[0][user];
                        if(empty($user)){
                             $sql="insert into `crm`(`id`,`user`) values(null,'{$fromUsername}')";
                             $mysql->runSql($sql);
                             $contentStr = "欢迎新朋友";
                        }else{
                             $contentStr = "欢迎老朋友";
                        }