[更新]修正微信api类

application/wechat/controller/Api.php

@@ -14,8 +14,12 @@
 
 namespace app\wechat\controller;
 
-use handler\WechatHandler;
+use service\DataService;
+use service\WechatService;
 use think\Controller;
+use think\Db;
+use think\Log;
+use Wechat\WechatReceive;
 
 /**
  * 微信接口控制器
@@ -26,21 +30,234 @@ use think\Controller;
 class Api extends Controller
 {
 
+    /**
+     * 微信openid
+     * @var string
+     */
+    protected $openid;
+
+    /**
+     * 微信消息对象
+     * @var WechatReceive
+     */
+    protected $wechat;
+
     /**
      * 微信消息接口
      * @return string
-     * @throws \Exception
      */
     public function index()
     {
-        if (!extension_loaded('soap')) {
+        // 实例接口对象
-            throw new \Exception('Not support soap.');
+        $this->wechat = &load_wechat('Receive');
+        // 验证接口请求
+        if ($this->wechat->valid() === false) {
+            $msg = "{$this->wechat->errMsg}[{$this->wechat->errCode}]";
+            Log::error($msg);
+            return $msg;
+        }
+        // 获取消息来源用户OPENID
+        $this->openid = $this->wechat->getRev()->getRevFrom();
+        // 获取并同步粉丝信息到数据库
+        $this->_updateFansInfo(true);
+        // 分别执行对应类型的操作
+        switch ($this->wechat->getRev()->getRevType()) {
+            case WechatReceive::MSGTYPE_TEXT:
+                return $this->_keys("WechatKeys#keys#" . $this->wechat->getRevContent());
+            case WechatReceive::MSGTYPE_EVENT:
+                return $this->_event();
+            case WechatReceive::MSGTYPE_IMAGE:
+                return $this->_image();
+            case WechatReceive::MSGTYPE_LOCATION:
+                return $this->_location();
+            default:
+                return 'success';
         }
-        $handler = new WechatHandler();
-        $service = new \SoapServer(null, ['uri' => 'api', 'trace' => 0]);
-        $service->setObject($handler);
-        $service->handle();
     }
 
+    /**
+     * 关键字处理
+     * @param string $keys
+     * @param bool $isForce
+     * @return string
+     */
+    private function _keys($keys, $isForce = false)
+    {
+        list($table, $field, $value) = explode('#', $keys . '##');
+        if (is_array($info = Db::name($table)->where($field, $value)->find()) && isset($info['type'])) {
+            // 数据状态检查
+            if (array_key_exists('status', $info) && empty($info['status'])) {
+                return 'success';
+            }
+            switch ($info['type']) {
+                case 'customservice': // 多客服
+                    $this->wechat->sendCustomMessage(['touser' => $this->openid, 'msgtype' => 'text', 'text' => ['content' => $info['content']]]);
+                    return $this->wechat->transfer_customer_service()->reply(false, true);
+                case 'keys': // 关键字
+                    if (empty($info['content']) && empty($info['name'])) {
+                        return 'success';
+                    }
+                    return $this->_keys('wechat_keys#keys#' . (empty($info['content']) ? $info['name'] : $info['content']));
+                case 'text': // 文本消息
+                    if (empty($info['content']) && empty($info['name'])) {
+                        return 'success';
+                    }
+                    return $this->wechat->text($info['content'])->reply(false, true);
+                case 'news': // 图文消息
+                    if (empty($info['news_id'])) {
+                        return 'success';
+                    }
+                    return $this->_news($info['news_id']);
+                case 'music': // 音频消息
+                    if (empty($info['music_url']) || empty($info['music_title']) || empty($info['music_desc'])) {
+                        return 'success';
+                    }
+                    $media_id = empty($info['music_image']) ? '' : WechatService::uploadForeverMedia($info['music_image'], 'image');
+                    if (empty($media_id)) {
+                        return 'success';
+                    }
+                    return $this->wechat->music($info['music_title'], $info['music_desc'], $info['music_url'], $info['music_url'], $media_id)->reply(false, true);
+                case 'voice': // 语音消息
+                    if (empty($info['voice_url'])) {
+                        return 'success';
+                    }
+                    $media_id = WechatService::uploadForeverMedia($info['voice_url'], 'voice');
+                    if (empty($media_id)) {
+                        return 'success';
+                    }
+                    return $this->wechat->voice($media_id)->reply(false, true);
+                case 'image': // 图文消息
+                    if (empty($info['image_url'])) {
+                        return 'success';
+                    }
+                    $media_id = WechatService::uploadForeverMedia($info['image_url'], 'image');
+                    if (empty($media_id)) {
+                        return 'success';
+                    }
+                    return $this->wechat->image($media_id)->reply(false, true);
+                case 'video': // 视频消息
+                    if (empty($info['video_url']) || empty($info['video_desc']) || empty($info['video_title'])) {
+                        return 'success';
+                    }
+                    $data = ['title' => $info['video_title'], 'introduction' => $info['video_desc']];
+                    $media_id = WechatService::uploadForeverMedia($info['video_url'], 'video', true, $data);
+                    return $this->wechat->video($media_id, $info['video_title'], $info['video_desc'])->reply(false, true);
+            }
+        }
+        if ($isForce) {
+            return 'success';
+        }
+        return $this->_keys('wechat_keys#keys#default', true);
+    }
+
+    /**
+     * 回复图文
+     * @param int $news_id
+     * @return bool|string
+     */
+    protected function _news($news_id = 0)
+    {
+        if (is_array($newsinfo = WechatService::getNewsById($news_id)) && !empty($newsinfo['articles'])) {
+            $newsdata = [];
+            foreach ($newsinfo['articles'] as $vo) {
+                $newsdata[] = [
+                    'Title'       => $vo['title'],
+                    'Description' => $vo['digest'],
+                    'PicUrl'      => $vo['local_url'],
+                    'Url'         => url("@wechat/review", '', true, true) . "?content={$vo['id']}&type=article",
+                ];
+            }
+            return $this->wechat->news($newsdata)->reply(false, true);
+        }
+        return 'success';
+    }
+
+    /**
+     * 事件处理
+     */
+    protected function _event()
+    {
+        $event = $this->wechat->getRevEvent();
+        switch (strtolower($event['event'])) {
+            case 'subscribe': // 粉丝关注事件
+                $this->_updateFansInfo(true);
+                $this->_spread($event['key']);
+                return $this->_keys('wechat_keys#keys#subscribe', true);
+            case 'unsubscribe':// 粉丝取消关注
+                $this->_updateFansInfo(false);
+                return 'success';
+            case 'click': // 点击菜单事件
+                return $this->_keys($event['key']);
+            case 'scancode_push':
+            case 'scancode_waitmsg': // 扫码推事件
+                $scanInfo = $this->wechat->getRev()->getRevScanInfo();
+                if (isset($scanInfo['ScanResult'])) {
+                    return $this->_keys($scanInfo['ScanResult']);
+                }
+                return 'success';
+            case 'scan':
+                if (!empty($event['key'])) {
+                    return $this->_spread($event['key']);
+                }
+                return 'success';
+        }
+        return 'success';
+    }
+
+    /**
+     * 推荐好友扫码关注
+     * @param string $event
+     * @return mixed
+     */
+    private function _spread($event)
+    {
+        $key = preg_replace('|^.*?(\d+).*?$|', '$1', "{$event}");
+        // 检测推荐是否有效
+        $fans = Db::name('WechatFans')->where('id', $key)->find();
+        if (!is_array($fans) || !isset($fans['openid']) || $fans['openid'] === $this->openid) {
+            return false;
+        }
+        // 标识推荐关系
+        $data = ['spread_by' => $fans['openid'], 'spread_at' => date('Y-m-d H:i:s')];
+        Db::name('WechatFans')->where("openid='{$this->openid}' and (spread_openid is null or spread_openid='')")->setField($data);
+        // @todo 推荐成功的奖励
+    }
+
+    /**
+     * 位置事情回复
+     * @return string
+     */
+    private function _location()
+    {
+        return 'success';
+    }
+
+    /**
+     * 图片事件处理
+     */
+    private function _image()
+    {
+        return 'success';
+    }
+
+    /**
+     * 同步粉丝状态
+     * @param bool $subscribe 关注状态
+     */
+    protected function _updateFansInfo($subscribe = true)
+    {
+        if ($subscribe) {
+            $fans = WechatService::getFansInfo($this->openid);
+            if (empty($fans) || empty($fans['subscribe'])) {
+                $wechat = &load_wechat('User');
+                $userInfo = $wechat->getUserInfo($this->openid);
+                $userInfo['subscribe'] = intval($subscribe);
+                WechatService::setFansInfo($userInfo, $wechat->appid);
+            }
+        } else {
+            $data = ['subscribe' => '0', 'appid' => $this->wechat->appid, 'openid' => $this->openid];
+            DataService::save('wechat_fans', $data, ['appid', 'openid']);
+        }
+    }
 
 }