contrast_ai/framework/builtin/chats/processor.php

<?php
/**
 * [WeEngine System] Copyright (c) 2014 WE7.CC
 * WeEngine is NOT a free software, it under the license terms, visited http://www.we7.cc/ for more details.
 */
defined('IN_IA') or exit('Access Denied');

class ChatsModuleProcessor extends WeModuleProcessor {
	public $priority = 255;

	public function begin($expire = 300) {
		$this->beginContext($expire);
		return true;
	}

	public function end() {
		$this->respText('系统消息：公众号关闭了对话功能！');
		$this->endContext();
		return;
	}

	public function respond() {
		global $_W;
		$msgtype = $this->message['type'];
		
		$allow = array('text', 'image', 'location', 'link', 'trace');
		if (!in_array($msgtype, $allow)) {
			return $this->respText('抱歉,系统仅支持 文字，图片，地理位置，链接类型的消息！');
		}
		$close = 0;
		if ('text' == $msgtype) {
			$content = $this->message['content'];
			if ('关闭' == $content) {
				$content = '<span class="text-danger">系统消息：粉丝关闭了对话</span>';
				$close = 1;
			}
		} elseif ('image' == $msgtype) {
			$content = $this->message['picurl'];
		} elseif ('location' == $msgtype) {
			$content = iserializer(array(
				'location_x' => $this->message['location_x'],
				'location_y' => $this->message['location_y'],
				'scale' => $this->message['scale'],
			));
		} elseif ('link' == $msgtype) {
			$content = $this->message['url'];
		}
		if (!empty($content)) {
			$insert = array(
				'uniacid' => $_W['uniacid'],
				'acid' => $_W['acid'],
				'openid' => $_W['openid'],
				'msgtype' => $msgtype,
				'flag' => 2,
				'content' => $content,
				'createtime' => TIMESTAMP,
			);
			table('mc_chats_record')->fill($insert)->save();
		}
		$this->refreshContext(300);
		if (1 == $close) {
			$this->endContext();
			return $this->respText('您成功关闭回话。');
		}
		return $this->respText('');
	}
}