You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2179 lines
81 KiB
2179 lines
81 KiB
<?php
|
|
namespace apps\wechat\controllers;
|
|
|
|
use apps\base\controllers\BackendController;
|
|
|
|
class AdminController extends BackendController
|
|
{
|
|
|
|
protected $weObj = '';
|
|
|
|
protected $wechat_id = 0;
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
L(require(ROOT_PATH . 'source/language/zh_cn/wechat.php'));
|
|
$this->assign('lang', array_change_key_case(L()));
|
|
require_once(BASE_PATH . 'apps/base/utils/function.php');
|
|
// 默认微信公众号
|
|
$this->wechat_id = 1;
|
|
// 查找公众号
|
|
$condition['id'] = $this->wechat_id;
|
|
$mpInfo = $this->model->table('wechat')->field('*')->where($condition)->find();
|
|
if (empty($mpInfo)) {
|
|
$data = array(
|
|
'id' => $this->wechat_id,
|
|
'time' => time(),
|
|
'type' => 2,
|
|
'status' => 1,
|
|
'default_wx' => 1
|
|
);
|
|
$this->model->table('wechat')->data($data)->insert();
|
|
$this->redirect(U('modify'));
|
|
}
|
|
// 获取配置信息
|
|
$this->get_config();
|
|
}
|
|
|
|
/**
|
|
* 我的公众号
|
|
*/
|
|
public function actionIndex()
|
|
{
|
|
$this->redirect(U('modify'));
|
|
/*
|
|
* $list = $this->model->table('wechat')
|
|
* ->order('sort asc, id asc')
|
|
* ->select();
|
|
* if($list){
|
|
* foreach($list as $key=>$val){
|
|
* if($val['type'] == 2){
|
|
* $list[$key]['manage_url'] = U('mass_message', array('wechat_id'=>$val['id']));
|
|
* }
|
|
* else{
|
|
* $list[$key]['manage_url'] = U('reply_subscribe', array('wechat_id'=>$val['id']));
|
|
* }
|
|
* }
|
|
* }
|
|
* $l = sprintf(L('wechat_register'), '<a href=' . U('append') . '>');
|
|
*
|
|
* $this->assign('wechat_register', $l);
|
|
* $this->assign('list', $list);
|
|
* $this->display();
|
|
*/
|
|
}
|
|
|
|
/**
|
|
* 设置公众号为默认
|
|
*/
|
|
/*
|
|
* public function set_default()
|
|
* {
|
|
* $id = I('get.id');
|
|
* if (empty($id)) {
|
|
* $this->message('请选择公众号', NULL, 'error');
|
|
* }
|
|
* // 取消默认
|
|
* $data['default_wx'] = 0;
|
|
* $this->model->table('wechat')
|
|
* ->data($data)
|
|
* ->where('1')
|
|
* ->update();
|
|
* // 设置默认
|
|
* $data1['default_wx'] = 1;
|
|
* $this->model->table('wechat')
|
|
* ->data($data1)
|
|
* ->where('id = ' . $id)
|
|
* ->update();
|
|
*
|
|
* $this->redirect(U('index'));
|
|
* }
|
|
*/
|
|
|
|
/**
|
|
* 新增公众号
|
|
*/
|
|
public function actionAppend()
|
|
{
|
|
$this->redirect(U('index'));
|
|
/*
|
|
* if (IS_POST) {
|
|
* $data = I('post.data', '', 'trim,htmlspecialchars');
|
|
* $data['time'] = time();
|
|
* // 验证数据
|
|
* $result = Check::rule(array(
|
|
* Check::must($data['name']),
|
|
* L('must_name')
|
|
* ), array(
|
|
* Check::must($data['orgid']),
|
|
* L('must_id')
|
|
* ), array(
|
|
* Check::must($data['token']),
|
|
* L('must_token')
|
|
* ));
|
|
* if ($result !== true) {
|
|
* $this->message($result, NULL, 'error');
|
|
* }
|
|
* // 更新数据
|
|
* $this->model->table('wechat')
|
|
* ->data($data)
|
|
* ->insert();
|
|
* $this->redirect(U('wechat/index'));
|
|
* }
|
|
* $this->display();
|
|
*/
|
|
}
|
|
|
|
/**
|
|
* 修改公众号
|
|
*/
|
|
public function actionModify()
|
|
{
|
|
$condition['id'] = $this->wechat_id;
|
|
if (IS_POST) {
|
|
$data = I('post.data', '', 'trim,htmlspecialchars');
|
|
// 验证数据
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($data['name'], 1)){
|
|
$this->message(L('must_name'), NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($data['orgid'], 1)){
|
|
$this->message(L('must_id'), NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($data['token'], 1)){
|
|
$this->message(L('must_token'), NULL, 2);
|
|
}
|
|
// 更新数据
|
|
$this->model->table('wechat')->data($data)->where($condition)->update();
|
|
$this->redirect(U('modify'));
|
|
}
|
|
$data = $this->model->table('wechat')->where($condition)->find();
|
|
$data['url'] = '';
|
|
if($data){
|
|
$data['url'] = U('wechat/index/index', array('orgid'=>$data['orgid']), true);
|
|
}
|
|
|
|
|
|
$this->assign('data', $data);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 删除公众号
|
|
*/
|
|
/*
|
|
* public function delete()
|
|
* {
|
|
* $condition['id'] = intval($_GET['id']);
|
|
* $this->model->table('wechat')
|
|
* ->where($condition)
|
|
* ->delete();
|
|
* $this->redirect(U('wechat/index'));
|
|
* }
|
|
*/
|
|
|
|
/**
|
|
* 公众号菜单
|
|
*/
|
|
public function actionMenuList()
|
|
{
|
|
$list = $this->model->table('wechat_menu')->where(array('wechat_id'=>$this->wechat_id))->order('sort asc')->select();
|
|
$result = array();
|
|
if (is_array($list)) {
|
|
foreach ($list as $vo) {
|
|
if ($vo['pid'] == 0) {
|
|
$vo['val'] = ($vo['type'] == 'click') ? $vo['key'] : $vo['url'];
|
|
$sub_button = array();
|
|
foreach ($list as $val) {
|
|
$val['val'] = ($val['type'] == 'click') ? $val['key'] : $val['url'];
|
|
if ($val['pid'] == $vo['id']) {
|
|
$sub_button[] = $val;
|
|
}
|
|
}
|
|
$vo['sub_button'] = $sub_button;
|
|
$result[] = $vo;
|
|
}
|
|
}
|
|
}
|
|
$this->assign('list', $result);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 编辑菜单
|
|
*/
|
|
public function actionMenuEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$id = I('post.id');
|
|
$data = I('post.data');
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
if ('click' == $data['type']) {
|
|
if (empty($data['key'])) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('menu_keyword') . L('empty')
|
|
)));
|
|
}
|
|
$data['url'] = '';
|
|
} else {
|
|
if (empty($data['url'])) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('menu_url') . L('empty')
|
|
)));
|
|
}
|
|
if(strpos($data['url'], 'http://') === false){
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('menu_url') . L('link_err')
|
|
)));
|
|
}
|
|
$data['key'] = '';
|
|
}
|
|
// 编辑
|
|
if (! empty($id)) {
|
|
$this->model->table('wechat_menu')->data($data)->where(array('id'=>$id))->update();
|
|
} else {
|
|
// 添加
|
|
$this->model->table('wechat_menu')->data($data)->insert();
|
|
}
|
|
|
|
exit(json_encode(array(
|
|
'status' => 1,
|
|
'msg' => L('attradd_succed')
|
|
)));
|
|
}
|
|
$id = I('get.id');
|
|
$info = array();
|
|
// 顶级菜单
|
|
$top_menu = $this->model->table('wechat_menu')->where(array('pid'=>0, 'wechat_id'=>$this->wechat_id))->select();
|
|
if (! empty($id)) {
|
|
$info = $this->model->table('wechat_menu')->where(array('id'=>$id))->find();
|
|
// 顶级菜单
|
|
$top_menu = $this->model->query("SELECT * FROM {pre}wechat_menu WHERE id <> $id AND pid = 0 AND wechat_id = $this->wechat_id");
|
|
}
|
|
|
|
$this->assign('top_menu', $top_menu);
|
|
$this->assign('info', $info);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 删除菜单
|
|
*/
|
|
public function actionMenuDel()
|
|
{
|
|
$id = I('get.id');
|
|
if (empty($id)) {
|
|
$this->message(L('menu_select_del'), NULL, 'error');
|
|
}
|
|
$minfo = $this->model->table('wechat_menu')->field('id, pid')->where(array('id'=>$id))->find();
|
|
// 顶级栏目
|
|
if ($minfo['pid'] == 0) {
|
|
$this->model->table('wechat_menu')->where(array('pid'=>$minfo['id']))->delete();
|
|
}
|
|
$this->model->table('wechat_menu')->where(array('id'=>$minfo['id']))->delete();
|
|
$this->message(L('drop') . L('success'), U('menu_list'));
|
|
}
|
|
|
|
/**
|
|
* 生成自定义菜单
|
|
*/
|
|
public function actionSysMenu()
|
|
{
|
|
$list = $this->model->table('wechat_menu')->where(array('status'=>1, 'wechat_id'=>$this->wechat_id))->order('sort asc')->select();
|
|
if (empty($list)) {
|
|
$this->message('请至少添加一个自定义菜单', NULL, 2);
|
|
}
|
|
$data = array();
|
|
if (is_array($list)) {
|
|
foreach ($list as $val) {
|
|
if ($val['pid'] == 0) {
|
|
$sub_button = array();
|
|
foreach ($list as $v) {
|
|
if ($v['pid'] == $val['id']) {
|
|
$sub_button[] = $v;
|
|
}
|
|
}
|
|
$val['sub_button'] = $sub_button;
|
|
$data[] = $val;
|
|
}
|
|
}
|
|
}
|
|
$menu_list = array();
|
|
foreach ($data as $key => $val) {
|
|
if (empty($val['sub_button'])) {
|
|
$menu_list['button'][$key]['type'] = $val['type'];
|
|
$menu_list['button'][$key]['name'] = $val['name'];
|
|
if ('click' == $val['type']) {
|
|
$menu_list['button'][$key]['key'] = $val['key'];
|
|
} else {
|
|
$menu_list['button'][$key]['url'] = html_out($val['url']);
|
|
}
|
|
} else {
|
|
$menu_list['button'][$key]['name'] = $val['name'];
|
|
foreach ($val['sub_button'] as $k => $v) {
|
|
$menu_list['button'][$key]['sub_button'][$k]['type'] = $v['type'];
|
|
$menu_list['button'][$key]['sub_button'][$k]['name'] = $v['name'];
|
|
if ('click' == $v['type']) {
|
|
$menu_list['button'][$key]['sub_button'][$k]['key'] = $v['key'];
|
|
} else {
|
|
$menu_list['button'][$key]['sub_button'][$k]['url'] = html_out($v['url']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
/*
|
|
* $data = array( 'button'=>array( array('type'=>'click', 'name'=>"今日歌曲", 'key'=>'MENU_KEY_MUSIC'), array('type'=>'view', 'name'=>"歌手简介", 'url'=>'http://www.qq.com/'), array('name'=>"菜单", 'sub_button'=>array(array('type'=>'click', 'name'=>'hello world', 'key'=>'MENU_KEY_MENU'))) ) );
|
|
*/
|
|
|
|
$rs = $this->weObj->createMenu($menu_list);
|
|
if (empty($rs)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
$this->message(L('menu_create') . L('success'), U('menu_list'));
|
|
}
|
|
|
|
/**
|
|
* 关注用户列表
|
|
*/
|
|
public function actionSubscribeList()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('subscribe_list', $filter), 10);
|
|
|
|
$total = $this->model->table('wechat_user')->where(array('wechat_id'=>$this->wechat_id, 'subscribe'=>1))->order('subscribe_time desc')->count();
|
|
$sql = 'SELECT u.*, g.name, us.user_name FROM {pre}wechat_user u LEFT JOIN {pre}wechat_user_group g ON u.groupid = g.group_id LEFT JOIN {pre}users us ON us.user_id = u.ect_uid where u.subscribe = 1 and u.wechat_id = ' . $this->wechat_id . ' group by u.uid order by u.subscribe_time desc limit ' . $offset;
|
|
$list = $this->model->query($sql);
|
|
if (empty($list)) {
|
|
$list = array();
|
|
}
|
|
// 分组
|
|
$where1['wechat_id'] = $this->wechat_id;
|
|
$group_list = $this->model->table('wechat_user_group')->field('id, group_id, name, count')->where($where1)->order('id, sort desc')->select();
|
|
|
|
|
|
$this->assign('page', $this->pageShow($total));
|
|
$this->assign('list', $list);
|
|
$this->assign('group_list', $group_list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 关注用户列表搜索
|
|
*/
|
|
public function actionSubscribeSearch()
|
|
{
|
|
$keywords = I('post.keywords') ? I('post.keywords') : I('get.keywords');
|
|
$group_id = I('get.group_id');
|
|
$where = '';
|
|
$where1 = '';
|
|
if (! empty($keywords)) {
|
|
$where = ' and (u.nickname like "%' . $keywords . '%" or u.province like "%' . $keywords . '%" or u.city like "%' . $keywords . '%")';
|
|
}
|
|
if (isset($_GET['group_id']) && $group_id >= 0) {
|
|
$where = ' and u.groupid = ' . $group_id;
|
|
}
|
|
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$filter['group_id'] = ! empty($group_id) ? $group_id : 0;
|
|
$filter['k'] = $keywords;
|
|
$offset = $this->pageLimit(U('subscribe_search', $filter), 10);
|
|
|
|
$sql = 'SELECT count(*) as number FROM {pre}wechat_user u LEFT JOIN {pre}wechat_user_group g ON u.groupid = g.group_id LEFT JOIN {pre}users us ON us.user_id = u.ect_uid where u.subscribe = 1 and u.wechat_id = ' . $this->wechat_id . $where . ' order by u.subscribe_time desc';
|
|
$total = $this->model->query($sql);
|
|
|
|
$sql1 = 'SELECT u.*, g.name, us.user_name FROM {pre}wechat_user u LEFT JOIN {pre}wechat_user_group g ON u.groupid = g.group_id LEFT JOIN {pre}users us ON us.user_id = u.ect_uid where u.subscribe = 1 and u.wechat_id = ' . $this->wechat_id . $where . ' group by u.uid order by u.subscribe_time desc limit ' . $offset;
|
|
$list = $this->model->query($sql1);
|
|
|
|
// 分组
|
|
$where2['wechat_id'] = $this->wechat_id;
|
|
$group_list = $this->model->table('wechat_user_group')->field('id, group_id, name, count')->where($where2)->order('id, sort desc')->select();
|
|
|
|
$this->assign('page', $this->pageShow($total['number']));
|
|
$this->assign('list', $list);
|
|
$this->assign('group_list', $group_list);
|
|
$this->display('admin_subscribelist');
|
|
}
|
|
|
|
/**
|
|
* 移动关注用户分组
|
|
*/
|
|
public function actionSubscribeMove()
|
|
{
|
|
if (IS_POST) {
|
|
if (empty($this->wechat_id)) {
|
|
$this->message(L('wechat_empty'), NULL, 'error');
|
|
}
|
|
$group_id = I('post.group_id');
|
|
$openid = I('post.id');
|
|
if (is_array($openid)) {
|
|
foreach ($openid as $v) {
|
|
// 微信端移动用户
|
|
$this->weObj->updateGroupMembers($group_id, $v);
|
|
// 数据处理
|
|
$this->model->table('wechat_user')->data(array('groupid'=>$group_id))->where(array('openid'=>$v))->update();
|
|
}
|
|
$this->message(L('sub_move_sucess'), U('subscribe_list'));
|
|
} else {
|
|
$this->message(L('select_please'), NULL, 2);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 同步粉丝（直接插入数据，不能直接执行）
|
|
*/
|
|
public function actionSysfans(){
|
|
//微信用户
|
|
$wechat_user = $this->weObj->getUserList();
|
|
foreach($wechat_user['data']['openid'] as $v){
|
|
$info = $this->weObj->getUserInfo($v);
|
|
$info['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_user')->data($info)->insert();
|
|
}
|
|
$this->redirect(U('subscribe_list', array('wechat_id'=>$this->wechat_id)));
|
|
}
|
|
|
|
/**
|
|
* 更新用户信息
|
|
*/
|
|
public function actionSubscribeUpdate()
|
|
{
|
|
if (empty($this->wechat_id)) {
|
|
$this->message(L('wechat_empty'), NULL, 2);
|
|
}
|
|
// 本地数据
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$local_user = $this->model->table('wechat_user')->field('openid')->where($where)->select();
|
|
if (empty($local_user)) {
|
|
$local_user = array();
|
|
}
|
|
$user_list = array();
|
|
foreach ($local_user as $v) {
|
|
$user_list[] = $v['openid'];
|
|
}
|
|
// 微信端数据
|
|
$wechat_user = $this->weObj->getUserList();
|
|
|
|
if ($wechat_user['total'] <= 10000) {
|
|
$wechat_user_list = $wechat_user['data']['openid'];
|
|
} else {
|
|
$num = ceil($wechat_user['total'] / 10000);
|
|
$wechat_user_list = $wechat_user['data']['openid'];
|
|
for ($i = 0; $i <= $num; $i ++) {
|
|
$wechat_user1 = $this->weObj->getUserList($wechat_user['next_openid']);
|
|
$wechat_user_list = array_merge($wechat_user_list, $wechat_user1['data']['openid']);
|
|
}
|
|
}
|
|
// 数据对比
|
|
foreach ($local_user as $val) {
|
|
// 数据在微信端存在
|
|
if (in_array($val['openid'], $wechat_user_list)) {
|
|
$info = $this->weObj->getUserInfo($val['openid']);
|
|
$where1['openid'] = $val['openid'];
|
|
$this->model->table('wechat_user')->data($info)->where($where1)->update();
|
|
} else {
|
|
$where2['openid'] = $val['openid'];
|
|
$data['subscribe'] = 0;
|
|
$this->model->table('wechat_user')->data($data)->where($where2)->update();
|
|
}
|
|
}
|
|
// 数据不存在
|
|
foreach ($wechat_user_list as $vs) {
|
|
if (! in_array($vs, $user_list)) {
|
|
$info = $this->weObj->getUserInfo($vs);
|
|
$info['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_user')->data($info)->insert();
|
|
}
|
|
}
|
|
|
|
$this->redirect(U('subscribe_list'));
|
|
}
|
|
|
|
/**
|
|
* 发送客服消息
|
|
*/
|
|
public function actionSendCustomMessage()
|
|
{
|
|
if (IS_POST) {
|
|
$data = I('post.data');
|
|
$openid = I('post.openid');
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($openid, 1)){
|
|
exit(json_encode(array('status' => 0, 'msg' => L('select_openid'))));
|
|
}
|
|
if(!$form->isEmpty($data['msg'], 1)){
|
|
exit(json_encode(array('status' => 0, 'msg' => L('message_content') . L('empty'))));
|
|
}
|
|
$data['send_time'] = time();
|
|
$data['iswechat'] = 1;
|
|
// 微信端发送消息
|
|
$msg = array(
|
|
'touser' => $openid,
|
|
'msgtype' => 'text',
|
|
'text' => array(
|
|
'content' => $data['msg']
|
|
)
|
|
);
|
|
$rs = $this->weObj->sendCustomMessage($msg);
|
|
if (empty($rs)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg
|
|
)));
|
|
}
|
|
// 添加数据
|
|
$this->model->table('wechat_custom_message')
|
|
->data($data)
|
|
->insert();
|
|
|
|
exit(json_encode(array(
|
|
'status' => 1
|
|
)));
|
|
}
|
|
$uid = I('get.uid');
|
|
$openid = I('get.openid');
|
|
if($openid){
|
|
$where['openid'] = $openid;
|
|
}
|
|
else{
|
|
$where['uid'] = $uid;
|
|
}
|
|
$info = $this->model->table('wechat_user')->field('uid, nickname, openid')->where($where)->find();
|
|
|
|
$this->assign('info', $info);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 客服消息列表
|
|
*/
|
|
public function actionCustomMessageList()
|
|
{
|
|
$uid = I('get.uid');
|
|
if (empty($uid)) {
|
|
$this->message(L('select_openid'), NULL, 2);
|
|
}
|
|
$nickname = $this->model->table('wechat_user')->field('nickname')->where(array('uid'=>$uid))->one();
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$filter['uid'] = $uid;
|
|
$offset = $this->pageLimit(U('custom_message_list', $filter), 10);
|
|
$total = $this->model->table('wechat_custom_message')->where(array('uid'=>$uid))->order('send_time desc')->count();
|
|
$list = $this->model->table('wechat_custom_message')
|
|
->field('msg, send_time, iswechat')
|
|
->where(array('uid'=>$uid))
|
|
->order('send_time desc, id desc')
|
|
->limit($offset)
|
|
->select();
|
|
|
|
$this->assign('page', $this->pageShow($total));
|
|
$this->assign('list', $list);
|
|
$this->assign('nickname', $nickname);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 分组管理
|
|
*/
|
|
public function actionGroupsList()
|
|
{
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$local_list = $this->model->table('wechat_user_group')
|
|
->where($where)
|
|
->order('id, sort desc')
|
|
->select();
|
|
|
|
$this->assign('list', $local_list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 同步分组
|
|
*/
|
|
public function actionSysGroups()
|
|
{
|
|
if (empty($this->wechat_id)) {
|
|
$this->message(L('wechat_empty'), NULL, 2);
|
|
}
|
|
// 微信端分组列表
|
|
$list = $this->weObj->getGroup();
|
|
if (empty($list)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
// 本地分组
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_user_group')->where($where)->delete();
|
|
foreach ($list['groups'] as $key => $val) {
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$data['group_id'] = $val['id'];
|
|
$data['name'] = $val['name'];
|
|
$data['count'] = $val['count'];
|
|
$this->model->table('wechat_user_group')->data($data)->insert();
|
|
}
|
|
$this->redirect(U('subscribe_list'));
|
|
}
|
|
|
|
/**
|
|
* 添加、编辑分组
|
|
*/
|
|
public function actionGroupsEdit()
|
|
{
|
|
if (empty($this->wechat_id)) {
|
|
$this->message(L('wechat_empty'), NULL, 'error');
|
|
}
|
|
if (IS_POST) {
|
|
$name = I('post.name');
|
|
$id = I('post.id', 0, 'intval');
|
|
$group_id = I('post.group_id');
|
|
if (empty($name)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('group_name') . L('empty')
|
|
)));
|
|
}
|
|
$data['name'] = $name;
|
|
if (! empty($id)) {
|
|
// 微信端更新
|
|
$rs = $this->weObj->updateGroup($group_id, $name);
|
|
if (empty($rs)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg
|
|
)));
|
|
}
|
|
// 数据更新
|
|
$where['id'] = $id;
|
|
$this->model->table('wechat_user_group')
|
|
->data($data)
|
|
->where($where)
|
|
->update();
|
|
} else {
|
|
// 微信端新增
|
|
$rs = $this->weObj->createGroup($name);
|
|
if (empty($rs)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg
|
|
)));
|
|
}
|
|
// 数据新增
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_user_group')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
exit(json_encode(array(
|
|
'status' => 1
|
|
)));
|
|
}
|
|
$id = I('get.id', 0, 'intval');
|
|
$group = array();
|
|
if (! empty($id)) {
|
|
$where['id'] = $id;
|
|
$group = $this->model->table('wechat_user_group')
|
|
->field('id, group_id, name')
|
|
->where($where)
|
|
->find();
|
|
}
|
|
|
|
$this->assign('group', $group);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 渠道二维码
|
|
*/
|
|
public function actionQrcodeList()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('qrcode_list', $filter), 10);
|
|
$total = $this->model->query("SELECT count(*) as count FROM {pre}wechat_qrcode WHERE username is null AND wechat_id = $this->wechat_id ORDER BY sort ASC");
|
|
$list = $this->model->query("SELECT * FROM {pre}wechat_qrcode WHERE username is null AND wechat_id = $this->wechat_id ORDER BY sort ASC");
|
|
|
|
$this->assign('page', $this->pageShow($total['count']));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 编辑二维码
|
|
*/
|
|
public function actionQrcodeEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$data = I('post.data');
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
// 验证数据
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($data['function'], 1)){
|
|
$this->message(L('qrcode_function'). L('empty'), NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($data['scene_id'], 1)){
|
|
$this->message(L('qrcode_scene_value'). L('empty'), NULL, 2);
|
|
}
|
|
|
|
$rs = $this->model->table('wechat_qrcode')
|
|
->where(array('scene_id'=>$data['scene_id']))
|
|
->count();
|
|
if ($rs > 0) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('qrcode_scene_limit')
|
|
)));
|
|
}
|
|
$this->model->table('wechat_qrcode')
|
|
->data($data)
|
|
->insert();
|
|
exit(json_encode(array(
|
|
'status' => 1
|
|
)));
|
|
}
|
|
$id = I('get.id', 0, 'intval');
|
|
if (! empty($id)) {
|
|
$status = I('get.status', 0, 'intval');
|
|
$this->model->table('wechat_qrcode')
|
|
->data(array('status'=>$status))
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
$this->redirect(U('qrcode_list'));
|
|
}
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 扫码引荐
|
|
*/
|
|
public function actionShareList()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('share_list', $filter), 10);
|
|
$total = $this->model->query("SELECT count(*) as count FROM {pre}wechat_qrcode WHERE username is not null AND wechat_id = $this->wechat_id ORDER BY sort ASC");
|
|
$list = $this->model->query("SELECT * FROM {pre}wechat_qrcode WHERE username is not null AND wechat_id = $this->wechat_id ORDER BY sort ASC");
|
|
|
|
// 成交量
|
|
if ($list) {
|
|
foreach ($list as $key => $val) {
|
|
$list[$key]['share_account'] = $this->model->table('affiliate_log')
|
|
->field('sum(money)')
|
|
->where(array('separate_type'=>0, 'user_id'=>$val['scene_id']))
|
|
->one();
|
|
}
|
|
}
|
|
$this->assign('page', $this->pageShow($total['count']));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 编辑二维码
|
|
*/
|
|
public function actionShareEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$data = I('post.data');
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
// 验证数据
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($data['username'], 1)){
|
|
$this->message(L('share_name'). L('empty'), NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($data['scene_id'], 1)){
|
|
$this->message(L('share_userid'). L('empty'), NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($data['function'], 1)){
|
|
$this->message(L('qrcode_function'). L('empty'), NULL, 2);
|
|
}
|
|
|
|
$rs = $this->model->table('wechat_qrcode')
|
|
->where(array('scene_id'=>$data['scene_id']))
|
|
->count();
|
|
if ($rs > 0) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('qrcode_scene_limit')
|
|
)));
|
|
}
|
|
|
|
if (empty($data['expire_seconds'])) {
|
|
$data['type'] = 1;
|
|
} else {
|
|
$data['type'] = 0;
|
|
}
|
|
$this->model->table('wechat_qrcode')
|
|
->data($data)
|
|
->insert();
|
|
exit(json_encode(array(
|
|
'status' => 1
|
|
)));
|
|
}
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 删除二维码
|
|
*/
|
|
public function actionQrcodeDel()
|
|
{
|
|
$id = I('get.id', 0, 'intval');
|
|
if (empty($id)) {
|
|
$this->message(L('select_please') . L('qrcode'), NULL, 2);
|
|
}
|
|
$this->model->table('wechat_qrcode')
|
|
->where(array('id'=>$id))
|
|
->delete();
|
|
$url = isset($_SERVER['HTTP_REFERER']) ? $_SERVER['HTTP_REFERER'] : U('qrcode_list');
|
|
$this->message(L('qrcode') . L('drop') . L('success'), $url);
|
|
}
|
|
|
|
/**
|
|
* 更新并获取二维码
|
|
*/
|
|
public function actionQrcodeGet()
|
|
{
|
|
$id = I('get.id', 0, 'intval');
|
|
if (empty($id)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('select_please') . L('qrcode')
|
|
)));
|
|
}
|
|
$rs = $this->model->table('wechat_qrcode')
|
|
->field('type, scene_id, expire_seconds, qrcode_url, status')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
if (empty($rs['status'])) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => '二维码已禁用，请重新启用！'
|
|
)));
|
|
}
|
|
if (empty($rs['qrcode_url'])) {
|
|
// 获取二维码ticket
|
|
$ticket = $this->weObj->getQRCode((int) $rs['scene_id'], $rs['type'], $rs['expire_seconds']);
|
|
if (empty($ticket)) {
|
|
exit(json_encode(array(
|
|
'status' => 0,
|
|
'msg' => L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg
|
|
)));
|
|
}
|
|
$data['ticket'] = $ticket['ticket'];
|
|
$data['expire_seconds'] = $ticket['expire_seconds'];
|
|
$data['endtime'] = time() + $ticket['expire_seconds'];
|
|
// 二维码地址
|
|
$qrcode_url = $this->weObj->getQRUrl($ticket['ticket']);
|
|
$data['qrcode_url'] = $qrcode_url;
|
|
|
|
$this->model->table('wechat_qrcode')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
} else {
|
|
$qrcode_url = $rs['qrcode_url'];
|
|
}
|
|
|
|
$this->assign('qrcode_url', $qrcode_url);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 图文回复(news)
|
|
*/
|
|
public function actionArticle()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('article', $filter), 12);
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$where['type'] = 'news';
|
|
$total = $this->model->table('wechat_media')->where($where)->count();
|
|
|
|
$list = $this->model->table('wechat_media')
|
|
->field('id, title, file, content, add_time, sort, article_id')
|
|
->where($where)
|
|
->order('sort asc, add_time desc')
|
|
->limit($offset)
|
|
->select();
|
|
foreach ((array) $list as $key => $val) {
|
|
// 多图文
|
|
if (! empty($val['article_id'])) {
|
|
$id = explode(',', $val['article_id']);
|
|
foreach ($id as $v) {
|
|
$list[$key]['articles'][] = $this->model->table('wechat_media')
|
|
->field('id, title, file, add_time')
|
|
->where(array('id'=>$v))
|
|
->find();
|
|
}
|
|
}
|
|
$list[$key]['content'] = sub_str(strip_tags(html_out($val['content'])), 100);
|
|
}
|
|
$this->assign('page', $this->pageShow($total));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 图文回复编辑
|
|
*/
|
|
public function actionArticleEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$id = I('post.id');
|
|
$data = I('post.data');
|
|
$data['content'] = I('post.content');
|
|
$pic_path = I('post.file_path');
|
|
|
|
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($data['title'], 1)){
|
|
$this->message(L('title') . L('empty'), NULL, 2);
|
|
}
|
|
|
|
if(!$form->isEmpty($data['content'], 1)){
|
|
$this->message(L('content') . L('empty'), NULL, 2);
|
|
}
|
|
/*if(!empty($data['link']) && !$form->isUrl($data['link'], 1)){
|
|
$this->message(L('link_err'), NULL, 2);
|
|
}*/
|
|
// 封面处理
|
|
if ($_FILES['pic']['name']) {
|
|
$result = $this->ectouchUpload('pic', 'article_pic');
|
|
if ($result['error'] > 0) {
|
|
$this->message($result['message'], NULL, 2);
|
|
}
|
|
$data['file'] = str_replace(ROOT_PATH, '', $result['message']['pic']['savepath']) . $result['message']['pic']['savename'];
|
|
$data['file_name'] = $result['message']['pic']['name'];
|
|
$data['size'] = $result['message']['pic']['size'];
|
|
} else {
|
|
$data['file'] = $pic_path;
|
|
}
|
|
if(!$form->isEmpty($data['file'], 1)){
|
|
$this->message(L('please_upload'), NULL, 2);
|
|
}
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$data['type'] = 'news';
|
|
|
|
if (! empty($id)) {
|
|
// 删除图片
|
|
if ($pic_path != $data['file']) {
|
|
@unlink(ROOT_PATH . $pic_path);
|
|
}
|
|
$data['edit_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
} else {
|
|
$data['add_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
$this->message(L('wechat_editor') . L('success'), U('article'));
|
|
}
|
|
$id = I('get.id');
|
|
if (! empty($id)) {
|
|
$article = $this->model->table('wechat_media')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
$this->assign('article', $article);
|
|
}
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 多图文回复编辑
|
|
*/
|
|
public function actionArticleEditNews()
|
|
{
|
|
if (IS_POST) {
|
|
$id = I('post.id');
|
|
$article_id = I('post.article');
|
|
$data['sort'] = I('post.sort');
|
|
if (is_array($article_id)) {
|
|
$data['article_id'] = implode(',', $article_id);
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$data['type'] = 'news';
|
|
|
|
if (! empty($id)) {
|
|
$data['edit_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
} else {
|
|
$data['add_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
|
|
$this->redirect(U('article'));
|
|
} else {
|
|
$this->message('请重新添加', NULL, 2);
|
|
}
|
|
}
|
|
$id = I('get.id');
|
|
if (! empty($id)) {
|
|
$rs = $this->model->table('wechat_media')
|
|
->field('article_id, sort')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
if (! empty($rs['article_id'])) {
|
|
$articles = array();
|
|
$art = explode(',', $rs['article_id']);
|
|
foreach ($art as $key => $val) {
|
|
$articles[] = $this->model->table('wechat_media')
|
|
->field('id, title, file, add_time')
|
|
->where(array('id'=>$val))
|
|
->find();
|
|
}
|
|
$this->assign('articles', $articles);
|
|
}
|
|
$this->assign('sort', $rs['sort']);
|
|
}
|
|
|
|
$this->assign('id', $id);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 单图文列表供多图文选择
|
|
*/
|
|
public function actionArticlesList()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('articles_list', $filter), 4);
|
|
$total = $this->model->query("SELECT count(*) as count FROM {pre}wechat_media WHERE wechat_id = $this->wechat_id and type = 'news' and article_id is NULL");
|
|
// 图文信息
|
|
$article = $this->model->query("SELECT id, title, file, content, add_time FROM {pre}wechat_media WHERE wechat_id = $this->wechat_id and type = 'news' and article_id is NULL ORDER BY sort ASC, add_time DESC limit $offset");
|
|
if (! empty($article)) {
|
|
foreach ($article as $k => $v) {
|
|
$article[$k]['content'] = sub_str(strip_tags(html_out($v['content'])), 100);
|
|
}
|
|
}
|
|
|
|
$this->assign('page', $this->pageShow($total['count']));
|
|
$this->assign('article', $article);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 多图文回复清空
|
|
*/
|
|
public function actionArticleNewsDel()
|
|
{
|
|
$id = I('get.id');
|
|
if (! empty($id)) {
|
|
$this->model->table('wechat_media')
|
|
->data('article_id = 0')
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
}
|
|
$this->redirect(U('article_edit_news'));
|
|
}
|
|
|
|
/**
|
|
* 图文回复删除
|
|
*/
|
|
public function actionArticleDel()
|
|
{
|
|
$id = I('get.id');
|
|
$pic = $this->model->table('wechat_media')
|
|
->field('file')
|
|
->where(array('id'=>$id))
|
|
->one();
|
|
if (empty($id)) {
|
|
$this->message(L('select_please') . L('article'), NULL, 'error');
|
|
}
|
|
$this->model->table('wechat_media')
|
|
->where(array('id'=>$id))
|
|
->delete();
|
|
if (! empty($pic)) {
|
|
@unlink(ROOT_PATH . $pic);
|
|
}
|
|
|
|
$this->redirect(U('article'));
|
|
}
|
|
|
|
/**
|
|
* 图片管理(image)
|
|
*/
|
|
public function actionPicture()
|
|
{
|
|
if (IS_POST) {
|
|
if ($_FILES['pic']['name']) {
|
|
$result = $this->ectouchUpload('pic', 'article_pic');
|
|
if ($result['error'] > 0) {
|
|
$this->message($result['message'], NULL, 2);
|
|
}
|
|
$data['file'] = str_replace(ROOT_PATH, '', $result['message']['pic']['savepath']) . $result['message']['pic']['savename'];
|
|
$data['thumb'] = str_replace(ROOT_PATH, '', $result['message']['pic']['savepath']) . 'thumb_' . $result['message']['pic']['savename'];
|
|
$data['file_name'] = $result['message']['pic']['name'];
|
|
$data['size'] = $result['message']['pic']['size'];
|
|
$data['type'] = 'image';
|
|
$data['add_time'] = time();
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->insert();
|
|
|
|
$this->redirect(U('picture'));
|
|
}
|
|
}
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('picture', $filter), 12);
|
|
|
|
$total = $this->model->query("SELECT count(*) as count FROM {pre}wechat_media WHERE wechat_id = $this->wechat_id and file is NOT NULL and (type = 'image' or type = 'news')");
|
|
$list = $this->model->query("SELECT id, file, file_name, thumb, size FROM {pre}wechat_media WHERE wechat_id = $this->wechat_id and file is NOT NULL and (type = 'image' or type = 'news') order by add_time desc, sort asc limit $offset");
|
|
if (empty($list)) {
|
|
$list = array();
|
|
}
|
|
foreach ($list as $key => $val) {
|
|
if ($val['size'] > (1024 * 1024)) {
|
|
$list[$key]['size'] = round(($val['size'] / (1024 * 1024)), 1) . 'MB';
|
|
} else {
|
|
$list[$key]['size'] = round(($val['size'] / 1024), 1) . 'KB';
|
|
}
|
|
}
|
|
$this->assign('page', $this->pageShow($total['count']));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 语音
|
|
*/
|
|
public function actionVoice()
|
|
{
|
|
if (IS_POST) {
|
|
if ($_FILES['voice']['name']) {
|
|
$result = $this->ectouchUpload('voice', 'voice');
|
|
if ($result['error'] > 0) {
|
|
$this->message($result['message'], NULL, 2);
|
|
}
|
|
$data['file'] = str_replace(ROOT_PATH, '', $result['message']['voice']['savepath']) . $result['message']['voice']['savename'];
|
|
$data['file_name'] = $result['message']['voice']['name'];
|
|
$data['size'] = $result['message']['voice']['size'];
|
|
;
|
|
$data['type'] = 'voice';
|
|
$data['add_time'] = time();
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->insert();
|
|
|
|
//$url = $_SERVER['HTTP_REFERER'];
|
|
$url = U('voice');
|
|
$this->redirect($url);
|
|
}
|
|
}
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('voice', $filter), 12);
|
|
$total = $this->model->table('wechat_media')
|
|
->where(array('wechat_id'=>$this->wechat_id, 'type'=>'voice'))
|
|
->count();
|
|
|
|
$list = $this->model->table('wechat_media')
|
|
->field('id, file, file_name, size')
|
|
->where(array('wechat_id'=>$this->wechat_id, 'type'=>'voice'))
|
|
->order('add_time desc, sort asc')
|
|
->limit($offset)
|
|
->select();
|
|
if (empty($list)) {
|
|
$list = array();
|
|
}
|
|
foreach ($list as $key => $val) {
|
|
if ($val['size'] > (1024 * 1024)) {
|
|
$list[$key]['size'] = round(($val['size'] / (1024 * 1024)), 1) . 'MB';
|
|
} else {
|
|
$list[$key]['size'] = round(($val['size'] / 1024), 1) . 'KB';
|
|
}
|
|
}
|
|
|
|
$this->assign('page', $this->pageShow($total));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 视频
|
|
*/
|
|
public function actionVideo()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('video', $filter), 12);
|
|
$total = $this->model->table('wechat_media')
|
|
->where(array('wechat_id'=>$this->wechat_id, 'type'=>'video'))->count();
|
|
|
|
$list = $this->model->table('wechat_media')
|
|
->field('id, file, file_name, size')
|
|
->where(array('wechat_id'=>$this->wechat_id, 'type'=>'video'))
|
|
->order('add_time desc, sort asc')
|
|
->limit($offset)
|
|
->select();
|
|
if (empty($list)) {
|
|
$list = array();
|
|
}
|
|
foreach ($list as $key => $val) {
|
|
if ($val['size'] > (1024 * 1024)) {
|
|
$list[$key]['size'] = round(($val['size'] / (1024 * 1024)), 1) . 'MB';
|
|
} else {
|
|
$list[$key]['size'] = round(($val['size'] / 1024), 1) . 'KB';
|
|
}
|
|
}
|
|
|
|
$this->assign('page', $this->pageShow($total));
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 视频编辑
|
|
*/
|
|
public function actionVideoEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$data = I('post.data');
|
|
$id = I('post.id');
|
|
|
|
if (empty($data['file']) || empty($data['file_name']) || empty($data['size'])) {
|
|
$this->message('请上传视频', NULL, 'error');
|
|
}
|
|
if (empty($data['title'])) {
|
|
$this->message('请填写标题', NULL, 'error');
|
|
}
|
|
$data['type'] = 'video';
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
if (! empty($id)) {
|
|
$data['edit_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
} else {
|
|
$data['add_time'] = time();
|
|
$this->model->table('wechat_media')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
|
|
$this->redirect(U('video'));
|
|
}
|
|
$id = I('get.id');
|
|
if (! empty($id)) {
|
|
$video = $this->model->table('wechat_media')
|
|
->field('id, file, file_name, size, title, content')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
|
|
$this->assign('video', $video);
|
|
}
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 视频上传webuploader
|
|
*/
|
|
public function actionVideoUpload()
|
|
{
|
|
if (IS_POST && ! empty($_FILES['file']['name'])) {
|
|
$vid = I('post.vid');
|
|
if (! empty($vid)) {
|
|
$file = $this->model->table('wechat_media')
|
|
->field('file')
|
|
->where(array('id'=>$vid))
|
|
->one();
|
|
if (file_exists(ROOT_PATH . $file)) {
|
|
@unlink(ROOT_PATH . $file);
|
|
}
|
|
}
|
|
$result = $this->ectouchUpload('file', 'video');
|
|
if ($result['error'] > 0) {
|
|
$data['errcode'] = 1;
|
|
$data['errmsg'] = $result['message'];
|
|
echo json_encode($data);
|
|
exit();
|
|
}
|
|
$data['errcode'] = 0;
|
|
$data['file'] = str_replace(ROOT_PATH, '', $result['message']['file']['savepath']) . $result['message']['file']['savename'];
|
|
$data['file_name'] = $result['message']['file']['name'];
|
|
$data['size'] = $result['message']['file']['size'];
|
|
|
|
echo json_encode($data);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 素材编辑
|
|
*/
|
|
public function actionMediaEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$id = I('post.id');
|
|
$pic_name = I('post.file_name');
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($id, 1)){
|
|
$this->message('请选择', NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($pic_name, 1)){
|
|
$this->message('请输入名称', NULL, 2);
|
|
}
|
|
$data['file_name'] = $pic_name;
|
|
$data['edit_time'] = time();
|
|
$num = $this->model->table('wechat_media')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
|
|
exit(json_encode(array(
|
|
'status' => $num
|
|
)));
|
|
}
|
|
$id = I('get.id');
|
|
$pic = $this->model->table('wechat_media')
|
|
->field('id, file_name')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
if (empty($pic)) {
|
|
$url = $_SERVER['HTTP_REFERER'];
|
|
$this->redirect($url);
|
|
}
|
|
$this->assign('pic', $pic);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 素材删除
|
|
*/
|
|
public function actionMediaDel()
|
|
{
|
|
$id = I('get.id');
|
|
if (empty($id)) {
|
|
$this->message('请选择', NULL, 'error');
|
|
}
|
|
$pic = $this->model->table('wechat_media')
|
|
->field('file, thumb')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
if (! empty($pic)) {
|
|
$this->model->table('wechat_media')
|
|
->where(array('id'=>$id))
|
|
->delete();
|
|
}
|
|
if (file_exists(ROOT_PATH . $pic['file'])) {
|
|
@unlink(ROOT_PATH . $pic['file']);
|
|
}
|
|
if (file_exists(ROOT_PATH . $pic['thumb'])) {
|
|
@unlink(ROOT_PATH . $pic['thumb']);
|
|
}
|
|
$url = $_SERVER['HTTP_REFERER'];
|
|
$this->redirect($url);
|
|
}
|
|
|
|
/**
|
|
* 下载
|
|
*/
|
|
public function actionDownload()
|
|
{
|
|
$id = I('get.id');
|
|
$pic = $this->model->table('wechat_media')
|
|
->field('file, file_name')
|
|
->where(array('id'=>$id))
|
|
->find();
|
|
$filename = ROOT_PATH . $pic['file'];
|
|
if (file_exists($filename)) {
|
|
\libraries\Http::download($filename, $pic['file_name']);
|
|
} else {
|
|
$this->message('文件不存在', NULL, 'error');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 群发消息列表
|
|
*/
|
|
public function actionMassList()
|
|
{
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$offset = $this->pageLimit(U('mass_list', $filter), 10);
|
|
$total = $this->model->table('wechat_mass_history')
|
|
->where(array('wechat_id'=>$this->wechat_id))
|
|
->count();
|
|
$this->assign('page', $this->pageShow($total));
|
|
|
|
$list = $this->model->table('wechat_mass_history')
|
|
->field('id, media_id, type, status, send_time, totalcount, sentcount, filtercount, errorcount')
|
|
->where(array('wechat_id'=>$this->wechat_id))
|
|
->order('send_time desc')
|
|
->limit($offset)
|
|
->select();
|
|
foreach ((array) $list as $key => $val) {
|
|
$media = $this->model->table('wechat_media')
|
|
->field('title, content, file, article_id')
|
|
->where(array('id'=>$val['media_id']))
|
|
->find();
|
|
if (! empty($media['article_id'])) {
|
|
// 多图文
|
|
$artids = explode(',', $media['article_id']);
|
|
$artinfo = $this->model->table('wechat_media')
|
|
->field('title, content, file')
|
|
->where(array('id'=>$artids[0]))
|
|
->find();
|
|
} else {
|
|
$artinfo = $media;
|
|
}
|
|
if ('news' == $val['type']) {
|
|
$artinfo['type'] = '图文消息';
|
|
}
|
|
$artinfo['content'] = strip_tags(html_out($artinfo['content']));
|
|
$list[$key]['artinfo'] = $artinfo;
|
|
}
|
|
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 群发消息
|
|
*/
|
|
public function actionMassMessage()
|
|
{
|
|
if (IS_POST) {
|
|
$group_id = I('post.group_id', '', 'intval');
|
|
$media_id = I('post.media_id');
|
|
if ((empty($group_id) && $group_id !== 0) || empty($media_id)) {
|
|
$this->message('请选择用户分组或者选择要发送的信息', NULL, 2);
|
|
}
|
|
|
|
$article = array();
|
|
$article_info = $this->model->table('wechat_media')
|
|
->field('id, title, author, file, is_show, digest, content, link, type, article_id')
|
|
->where(array('id'=>$media_id))
|
|
->find();
|
|
// 多图文
|
|
if (! empty($article_info['article_id'])) {
|
|
$articles = explode(',', $article_info['article_id']);
|
|
foreach ($articles as $key => $val) {
|
|
$artinfo = $this->model->table('wechat_media')
|
|
->field('title, author, file, is_show, digest, content, link')
|
|
->where(array('id'=>$val))
|
|
->find();
|
|
//$artinfo['content'] = strip_tags(html_out($artinfo['content']));
|
|
// 上传多媒体文件
|
|
$rs = $this->weObj->uploadMedia(array(
|
|
'media' => '@' . ROOT_PATH . $artinfo['file']
|
|
), 'image');
|
|
if (empty($rs)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
// 重组数据
|
|
$article[$key]['thumb_media_id'] = $rs['media_id'];
|
|
$article[$key]['author'] = $artinfo['author'];
|
|
$article[$key]['title'] = $artinfo['title'];
|
|
$article[$key]['content_source_url'] = $artinfo['link'];
|
|
$article[$key]['content'] = html_out($artinfo['content']);
|
|
$article[$key]['digest'] = $artinfo['digest'];
|
|
$article[$key]['show_cover_pic'] = $artinfo['is_show'];
|
|
}
|
|
} else {
|
|
// 单图文
|
|
// 上传多媒体文件
|
|
$rs = $this->weObj->uploadMedia(array(
|
|
'media' => '@' . ROOT_PATH . $article_info['file']
|
|
), 'image');
|
|
if (empty($rs)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
//$article_info['content'] = strip_tags(html_out($article_info['content']));
|
|
// 重组数据
|
|
$article[0]['thumb_media_id'] = $rs['media_id'];
|
|
$article[0]['author'] = $article_info['author'];
|
|
$article[0]['title'] = $article_info['title'];
|
|
$article[0]['content_source_url'] = $article_info['link'];
|
|
$article[0]['content'] = html_out($article_info['content']);
|
|
$article[0]['digest'] = $article_info['digest'];
|
|
$article[0]['show_cover_pic'] = $article_info['is_show'];
|
|
}
|
|
$article_list = array(
|
|
'articles' => $article
|
|
);
|
|
// 图文消息上传
|
|
$rs1 = $this->weObj->uploadArticles($article_list);
|
|
if (empty($rs1)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
// $rs1 = array('type'=>'image', 'media_id'=>'joUuDBc-9-sJp1U6vZpWYKiaS5XskqxJxGMm5HBf9q9Zs7DoKlSXVKUR3JIsfW_7', 'created_at'=>'1407482934');
|
|
// 根据分组进行群发sendGroupMassMessage
|
|
$massmsg = array(
|
|
'filter' => array(
|
|
'is_to_all' => false,
|
|
'group_id' => $group_id
|
|
),
|
|
'mpnews' => array(
|
|
'media_id' => $rs1['media_id']
|
|
),
|
|
'msgtype' => 'mpnews'
|
|
);
|
|
$rs2 = $this->weObj->sendGroupMassMessage($massmsg);
|
|
if (empty($rs2)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
|
|
// 数据处理
|
|
$msg_data['wechat_id'] = $this->wechat_id;
|
|
$msg_data['media_id'] = $article_info['id'];
|
|
$msg_data['type'] = $article_info['type'];
|
|
$msg_data['send_time'] = time();
|
|
$msg_data['msg_id'] = $rs2['msg_id'];
|
|
$id = $this->model->table('wechat_mass_history')
|
|
->data($msg_data)
|
|
->insert();
|
|
|
|
$this->message('群发任务已启动，不过一般需要较长的时间才能全部发送完毕，请耐心等待', U('mass_message'));
|
|
}
|
|
// 分组信息
|
|
$groups = $this->model->table('wechat_user_group')
|
|
->field('group_id, name')
|
|
->where(array('wechat_id'=> $this->wechat_id))
|
|
->order('group_id')
|
|
->select();
|
|
// 图文信息
|
|
$article = $this->model->table('wechat_media')
|
|
->field('id, title, file, content, article_id, add_time')
|
|
->where(array('wechat_id'=>$this->wechat_id, 'type'=>'news'))
|
|
->order('sort asc, add_time desc')
|
|
->select();
|
|
foreach ((array) $article as $key => $val) {
|
|
if (! empty($val['article_id'])) {
|
|
$id = explode(',', $val['article_id']);
|
|
foreach ($id as $v)
|
|
$article[$key]['articles'][] = $this->model->table('wechat_media')
|
|
->field('id, title, file, add_time')
|
|
->where(array('id'=>$v))
|
|
->find();
|
|
}
|
|
$article[$key]['content'] = strip_tags(html_out($val['content']));
|
|
}
|
|
$this->assign('groups', $groups);
|
|
$this->assign('article', $article);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 群发消息删除
|
|
*/
|
|
public function actionMassDel()
|
|
{
|
|
$id = I('get.id');
|
|
$msg_id = $this->model->table('wechat_mass_history')
|
|
->field('msg_id')
|
|
->where(array('id'=>$id))
|
|
->one();
|
|
if (empty($msg_id)) {
|
|
$this->message('消息不存在', NULL, 2);
|
|
}
|
|
$rs = $this->weObj->deleteMassMessage($msg_id);
|
|
if (empty($rs)) {
|
|
$this->message(L('errcode') . $this->weObj->errCode . L('errmsg') . $this->weObj->errMsg, NULL, 2);
|
|
}
|
|
|
|
$data['status'] = 'send success(已删除)';
|
|
$this->model->table('wechat_mass_history')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
$this->redirect(U('mass_list'));
|
|
}
|
|
|
|
/**
|
|
* ajax获取图文信息
|
|
*/
|
|
public function actionGetArticle()
|
|
{
|
|
if (IS_AJAX) {
|
|
$data = I('post.article');
|
|
$article = array();
|
|
if (is_array($data)) {
|
|
$id = implode(',', $data);
|
|
$article = $this->model->query("SELECT id, title, file, link, content, add_time FROM {pre}wechat_media WHERE id in ($id) ORDER BY sort asc, add_time desc");
|
|
foreach ($article as $key => $val) {
|
|
$article[$key]['add_time'] = date('Y年m月d日', $val['add_time']);
|
|
$article[$key]['content'] = html_out($val['content']);
|
|
}
|
|
}
|
|
echo json_encode($article);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 自动回复
|
|
*/
|
|
public function actionAutoReply()
|
|
{
|
|
// 素材数据
|
|
$type = I('get.type');
|
|
if (! empty($type)) {
|
|
// 分页
|
|
$filter['page'] = '{page}';
|
|
$filter['type'] = $type;
|
|
$offset = $this->pageLimit(U('auto_reply', $filter), 5);
|
|
if ('image' == $type) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and file is NOT NULL and (type = "image" or type="news")';
|
|
$list = $this->model->query('SELECT id, file, file_name, size, add_time, type FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '.$offset);
|
|
} elseif ('voice' == $type) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and file is NOT NULL and type = "voice"';
|
|
$list = $this->model->query('SELECT id, file, file_name, size, add_time, type FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '.$offset);
|
|
} elseif ('video' == $type) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and file is NOT NULL and type = "video"';
|
|
$list = $this->model->query('SELECT id, file, file_name, size, add_time, type FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '.$offset);
|
|
} elseif ('voice' == $type) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and file is NOT NULL and type = "voice"';
|
|
$list = $this->model->query('SELECT id, file, file_name, size, add_time, type FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '.$offset);
|
|
} elseif ('video' == $type) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and file is NOT NULL and type = "video"';
|
|
$list = $this->model->query('SELECT id, file, file_name, size, add_time, type FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '.$offset);
|
|
} elseif ('news' == $type) {
|
|
$offset = $this->pageLimit(U('auto_reply', $filter), 6);
|
|
// 只显示单图文
|
|
$no_list = I('get.no_list', 0, 'intval');
|
|
$this->assign('no_list', $no_list);
|
|
if (! empty($no_list)) {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and type="news" and article_id is NULL';
|
|
} else {
|
|
$where = 'wechat_id = ' . $this->wechat_id . ' and type="news"';
|
|
}
|
|
$list = $this->model->query('SELECT id, title, file, file_name, size, content, add_time, type, article_id FROM {pre}wechat_media WHERE '.$where.' ORDER BY add_time DESC limit '. $offset);
|
|
foreach ((array) $list as $key => $val) {
|
|
if (! empty($val['article_id'])) {
|
|
$id = explode(',', $val['article_id']);
|
|
foreach ($id as $v)
|
|
$list[$key]['articles'][] = $this->model->table('wechat_media')
|
|
->field('id, title, file, add_time')
|
|
->where(array('id'=>$v))
|
|
->find();
|
|
}
|
|
$list[$key]['content'] = sub_str(strip_tags(html_out($val['content'])), 100);
|
|
}
|
|
}
|
|
foreach ((array) $list as $key => $val) {
|
|
if ($val['size'] > (1024 * 1024)) {
|
|
$list[$key]['size'] = round(($val['size'] / (1024 * 1024)), 1) . 'MB';
|
|
} else {
|
|
$list[$key]['size'] = round(($val['size'] / 1024), 1) . 'KB';
|
|
}
|
|
}
|
|
|
|
$total = $this->model->query("SELECT count(*) as count FROM {pre}wechat_media WHERE $where ORDER BY add_time DESC");
|
|
$this->assign('page', $this->pageShow($total['count']));
|
|
$this->assign('list', $list);
|
|
$this->assign('type', $type);
|
|
$this->display();
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 关注回复(subscribe)
|
|
*/
|
|
public function actionReplySubscribe()
|
|
{
|
|
if (IS_POST) {
|
|
$content_type = I('post.content_type');
|
|
if ($content_type == 'text') {
|
|
$data['content'] = I('post.content');
|
|
$data['media_id'] = 0;
|
|
} else {
|
|
$data['media_id'] = I('post.media_id');
|
|
$data['content'] = '';
|
|
}
|
|
$data['type'] = 'subscribe';
|
|
if (is_array($data) && (! empty($data['media_id']) || ! empty($data['content']))) {
|
|
$where['type'] = $data['type'];
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$id = $this->model->table('wechat_reply')
|
|
->field('id')
|
|
->where($where)
|
|
->one();
|
|
if (! empty($id)) {
|
|
$this->model->table('wechat_reply')
|
|
->data($data)
|
|
->where($where)
|
|
->update();
|
|
} else {
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_reply')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
$this->redirect(U('reply_subscribe'));
|
|
} else {
|
|
$this->message('请填写内容', NULL, 2);
|
|
}
|
|
}
|
|
// 自动回复数据
|
|
$subscribe = $this->model->table('wechat_reply')
|
|
->where(array('type'=>'subscribe', 'wechat_id'=>$this->wechat_id))
|
|
->find();
|
|
if (! empty($subscribe['media_id'])) {
|
|
$subscribe['media'] = $this->model->table('wechat_media')
|
|
->field('file, type, file_name')
|
|
->where(array('id'=>$subscribe['media_id']))
|
|
->find();
|
|
}
|
|
$this->assign('subscribe', $subscribe);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 消息回复(msg)
|
|
*/
|
|
public function actionReplyMsg()
|
|
{
|
|
if (IS_POST) {
|
|
$content_type = I('post.content_type');
|
|
if ($content_type == 'text') {
|
|
$data['content'] = I('post.content');
|
|
$data['media_id'] = 0;
|
|
} else {
|
|
$data['media_id'] = I('post.media_id');
|
|
$data['content'] = '';
|
|
}
|
|
$data['type'] = 'msg';
|
|
if (is_array($data) && (! empty($data['media_id']) || ! empty($data['content']))) {
|
|
$where['type'] = $data['type'];
|
|
$where['wechat_id'] = $this->wechat_id;
|
|
$id = $this->model->table('wechat_reply')
|
|
->field('id')
|
|
->where($where)
|
|
->one();
|
|
if (! empty($id)) {
|
|
$this->model->table('wechat_reply')
|
|
->data($data)
|
|
->where($where)
|
|
->update();
|
|
} else {
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$this->model->table('wechat_reply')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
$this->redirect(U('reply_msg'));
|
|
} else {
|
|
$this->message('请填写内容', NULL, 2);
|
|
}
|
|
}
|
|
// 自动回复数据
|
|
$msg = $this->model->table('wechat_reply')
|
|
->where(array('type'=>'msg', 'wechat_id'=>$this->wechat_id))
|
|
->find();
|
|
if (! empty($msg['media_id'])) {
|
|
$msg['media'] = $this->model->table('wechat_media')
|
|
->field('file, type, file_name')
|
|
->where(array('id'=>$msg['media_id']))
|
|
->find();
|
|
}
|
|
$this->assign('msg', $msg);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 关键词自动回复
|
|
*/
|
|
public function actionReplyKeywords()
|
|
{
|
|
$list = $this->model->table('wechat_reply')
|
|
->field('id, rule_name, content, media_id, reply_type')
|
|
->where(array('type'=>'keywords', 'wechat_id'=>$this->wechat_id))
|
|
->order('add_time desc')
|
|
->select();
|
|
foreach ((array) $list as $key => $val) {
|
|
// 内容不是文本
|
|
if (! empty($val['media_id'])) {
|
|
$media = $this->model->table('wechat_media')
|
|
->field('title, file, file_name, type, content, add_time, article_id')
|
|
->where(array('id'=>$val['media_id']))
|
|
->find();
|
|
$media['content'] = strip_tags(html_out($media['content']));
|
|
if (! empty($media['article_id'])) {
|
|
$artids = explode(',', $media['article_id']);
|
|
foreach ($artids as $v) {
|
|
$list[$key]['medias'][] = $this->model->table('wechat_media')
|
|
->field('title, file, add_time')
|
|
->where(array('id'=>$v))
|
|
->find();
|
|
}
|
|
} else {
|
|
$list[$key]['media'] = $media;
|
|
}
|
|
}
|
|
$keywords = $this->model->table('wechat_rule_keywords')
|
|
->field('rule_keywords')
|
|
->where(array('rid'=>$val['id']))
|
|
->order('id desc')
|
|
->select();
|
|
$list[$key]['rule_keywords'] = $keywords;
|
|
// 编辑关键词时显示
|
|
if (! empty($keywords)) {
|
|
$rule_keywords = array();
|
|
foreach ($keywords as $k => $v) {
|
|
$rule_keywords[] = $v['rule_keywords'];
|
|
}
|
|
$rule_keywords = implode(',', $rule_keywords);
|
|
$list[$key]['rule_keywords_string'] = $rule_keywords;
|
|
}
|
|
}
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 关键词回复添加规则
|
|
*/
|
|
public function actionRuleEdit()
|
|
{
|
|
if (IS_POST) {
|
|
$id = I('post.id');
|
|
$content_type = I('post.content_type');
|
|
$rule_keywords = I('post.rule_keywords');
|
|
// 主表数据
|
|
$data['rule_name'] = I('post.rule_name');
|
|
$data['media_id'] = I('post.media_id');
|
|
$data['content'] = I('post.content');
|
|
$data['reply_type'] = $content_type;
|
|
if ($content_type == 'text') {
|
|
$data['media_id'] = 0;
|
|
} else {
|
|
$data['content'] = '';
|
|
}
|
|
|
|
$form = new \libraries\Form();
|
|
if(!$form->isEmpty($data['rule_name'], 1)){
|
|
$this->message('请填写规则名称', NULL, 2);
|
|
}
|
|
if(!$form->isEmpty($rule_keywords, 1)){
|
|
$this->message('请至少填写1个关键词', NULL, 2);
|
|
}
|
|
if (empty($data['content']) && empty($data['media_id'])) {
|
|
$this->message('请填写或选择回复内容', NULL, 'error');
|
|
}
|
|
$data['type'] = 'keywords';
|
|
if (! empty($id)) {
|
|
$this->model->table('wechat_reply')
|
|
->data($data)
|
|
->where(array('id'=>$id))
|
|
->update();
|
|
$this->model->table('wechat_rule_keywords')
|
|
->where(array('rid'=>$id))
|
|
->delete();
|
|
} else {
|
|
$data['add_time'] = time();
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$id = $this->model->table('wechat_reply')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
// 编辑关键词
|
|
$rule_keywords = explode(',', $rule_keywords);
|
|
foreach ($rule_keywords as $val) {
|
|
$kdata['rid'] = $id;
|
|
$kdata['rule_keywords'] = $val;
|
|
$this->model->table('wechat_rule_keywords')
|
|
->data($kdata)
|
|
->insert();
|
|
}
|
|
$this->redirect(U('reply_keywords'));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 关键词回复规则删除
|
|
*/
|
|
public function actionReplyDel()
|
|
{
|
|
$id = I('get.id');
|
|
if (empty($id)) {
|
|
$this->message('请选择', NULL, 'error');
|
|
}
|
|
$this->model->table('wechat_reply')
|
|
->where(array('id'=>$id))
|
|
->delete();
|
|
$this->redirect(U('reply_keywords'));
|
|
}
|
|
|
|
/**
|
|
* 素材管理
|
|
*/
|
|
public function actionMediaList()
|
|
{
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 提醒设置
|
|
*/
|
|
public function actionRemind()
|
|
{
|
|
if (IS_POST) {
|
|
$command = I('post.command');
|
|
$data = I('post.data');
|
|
$config = I('post.config');
|
|
$info = Check::rule(array(
|
|
Check::must($command),
|
|
'关键词不正确'
|
|
));
|
|
if ($info !== true) {
|
|
$this->message($info, NULL, 'error');
|
|
}
|
|
if (! empty($config)) {
|
|
$data['config'] = serialize($config);
|
|
}
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$num = $this->model->table('wechat_extend')
|
|
->where('command = "' . $command . '" and wechat_id = ' . $this->wechat_id)
|
|
->count();
|
|
if ($num > 0) {
|
|
$this->model->table('wechat_extend')
|
|
->data($data)
|
|
->where('command = "' . $command . '" and wechat_id = ' . $this->wechat_id)
|
|
->update();
|
|
} else {
|
|
$data['command'] = $command;
|
|
$this->model->table('wechat_extend')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
|
|
$this->redirect($_SERVER['HTTP_REFERER']);
|
|
}
|
|
|
|
$order_remind = $this->model->table('wechat_extend')
|
|
->field('name, enable, config')
|
|
->where('command = "order_remind" and wechat_id = ' . $this->wechat_id)
|
|
->find();
|
|
if ($order_remind['config']) {
|
|
$order_remind['config'] = unserialize($order_remind['config']);
|
|
}
|
|
$pay_remind = $this->model->table('wechat_extend')
|
|
->field('name, enable, config')
|
|
->where('command = "pay_remind" and wechat_id = ' . $this->wechat_id)
|
|
->find();
|
|
if ($pay_remind['config']) {
|
|
$pay_remind['config'] = unserialize($pay_remind['config']);
|
|
}
|
|
$send_remind = $this->model->table('wechat_extend')
|
|
->field('name, enable, config')
|
|
->where('command = "send_remind" and wechat_id = ' . $this->wechat_id)
|
|
->find();
|
|
if ($send_remind['config']) {
|
|
$send_remind['config'] = unserialize($send_remind['config']);
|
|
}
|
|
$register_remind = $this->model->table('wechat_extend')
|
|
->field('name, enable, config')
|
|
->where('command = "register_remind" and wechat_id = ' . $this->wechat_id)
|
|
->find();
|
|
if ($register_remind['config']) {
|
|
$register_remind['config'] = unserialize($register_remind['config']);
|
|
}
|
|
$this->assign('order_remind', $order_remind);
|
|
$this->assign('pay_remind', $pay_remind);
|
|
$this->assign('send_remind', $send_remind);
|
|
$this->assign('register_remind', $register_remind);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 多客服设置
|
|
*/
|
|
public function actionCustomerService()
|
|
{
|
|
$command = 'kefu';
|
|
if (IS_POST) {
|
|
$data = I('post.data');
|
|
$config = I('post.config');
|
|
|
|
if (! empty($config)) {
|
|
$data['config'] = serialize($config);
|
|
}
|
|
$num = $this->model->table('wechat_extend')
|
|
->where(array('command'=>$command, 'wechat_id'=>$this->wechat_id))
|
|
->count();
|
|
if ($num > 0) {
|
|
$this->model->table('wechat_extend')
|
|
->data($data)
|
|
->where(array('command'=>$command, 'wechat_id'=>$this->wechat_id))
|
|
->update();
|
|
} else {
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$data['command'] = $command;
|
|
$data['name'] = '多客服';
|
|
$this->model->table('wechat_extend')
|
|
->data($data)
|
|
->insert();
|
|
}
|
|
|
|
$this->redirect($_SERVER['HTTP_REFERER']);
|
|
}
|
|
|
|
$customer_service = $this->model->table('wechat_extend')
|
|
->field('name, enable, config')
|
|
->where(array('command'=>$command, 'wechat_id'=>$this->wechat_id))
|
|
->find();
|
|
if ($customer_service['config']) {
|
|
$customer_service['config'] = unserialize($customer_service['config']);
|
|
}
|
|
$this->assign('customer_service', $customer_service);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 添加多客服
|
|
*/
|
|
public function actionAddKf(){
|
|
$account = 'test@gh_1ca465561479';
|
|
$nickname = 'test';
|
|
$password = '123123';
|
|
$rs = $this->weObj->addKFAccount($account, $nickname, $password);
|
|
echo $this->weObj->errMsg;
|
|
dump($rs);
|
|
|
|
|
|
}
|
|
|
|
/**
|
|
* 模板消息
|
|
*/
|
|
public function actionTemplate()
|
|
{
|
|
$list = $this->model->table('wechat_template')->order('id desc')->select();
|
|
if ($list) {
|
|
foreach ($list as $key => $val) {
|
|
$list[$key]['add_time'] = local_date('Y-m-d H:i:s', $val['add_time']);
|
|
}
|
|
}
|
|
$this->assign('list', $list);
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 编辑模板消息
|
|
*/
|
|
public function actionEditTemplate(){
|
|
if(IS_AJAX){
|
|
$id = I('post.id');
|
|
$data = I('post.data');
|
|
if(empty($data['title'])){
|
|
exit(json_encode(array('status'=>0, 'msg'=>'模板消息标题或者模板编号不能为空')));
|
|
}
|
|
$un_code = $this->model->table('wechat_template')->where(array('code'=>$data['code']))->count();
|
|
if($id){
|
|
if(un_code > 1){
|
|
exit(json_encode(array('status'=>0, 'msg'=>'模板消息编号已存在,必须唯一')));
|
|
}
|
|
$this->db->table('wechat_template')->data($data)->where(array('id'=>$id))->update();
|
|
}
|
|
else{
|
|
if(un_code > 0){
|
|
exit(json_encode(array('status'=>0, 'msg'=>'模板消息编号已存在,必须唯一')));
|
|
}
|
|
$data['add_time'] = time();
|
|
$data['status'] = 0;
|
|
$data['wechat_id'] = $this->wechat_id;
|
|
$id = $this->db->table('wechat_template')->data($data)->insert();
|
|
}
|
|
if($id){
|
|
exit(json_encode(array('status'=>1)));
|
|
}
|
|
else{
|
|
exit(json_encode(array('status'=>0, 'msg'=>'添加失败')));
|
|
}
|
|
}
|
|
$id = I('get.id');
|
|
if($id){
|
|
$template = $this->model->table('wechat_template')->where(array('id'=>$id))->find();
|
|
$this->assign('template', $template);
|
|
}
|
|
|
|
$this->display();
|
|
}
|
|
|
|
/**
|
|
* 开关按钮
|
|
*/
|
|
public function actionSwitch()
|
|
{
|
|
$id = I('get.id');
|
|
$status = I('get.status');
|
|
if(empty($id)){
|
|
$this->message('请选择模板消息', NULL, 'error');
|
|
}
|
|
//开启模板消息
|
|
if(1 == $status){
|
|
$template = $this->model->table('wechat_template')->field('template_id, code')->where(array('id'=>$id))->find();
|
|
if(empty($template['template_id'])){
|
|
$template_id = $this->weObj->addTemplateMessage($template['code']);
|
|
if(!$template_id){
|
|
$this->message($this->weObj->errMsg, NULL, 'error');
|
|
}
|
|
$this->model->table('wechat_template')->data(array('template_id'=>$template_id))->where(array('id'=>$id))->update();
|
|
}
|
|
}
|
|
$this->model->table('wechat_template')->data(array('status'=>$status))->where(array('id'=>$id))->update();
|
|
$this->redirect(U('template'));
|
|
}
|
|
|
|
/**
|
|
* 获取配置信息
|
|
*/
|
|
private function get_config()
|
|
{
|
|
$without = array(
|
|
'index',
|
|
'append',
|
|
'modify',
|
|
'delete',
|
|
'set_default'
|
|
);
|
|
if (! in_array(ACTION_NAME, $without)) {
|
|
$id = $this->wechat_id; // I('get.wechat_id', 0, 'intval');
|
|
if (! empty($id)) {
|
|
session('wechat_id', $id);
|
|
} else {
|
|
$id = session('wechat_id') ? session('wechat_id') : 0;
|
|
}
|
|
|
|
$status = $this->model->table('wechat')->field('status')->where(array('id'=>$id))->one();
|
|
if (empty($status)) {
|
|
$this->message(L('open_wechat'), NULL, 'error');
|
|
}
|
|
$this->wechat_id = session('wechat_id');
|
|
if (! empty($this->wechat_id)) {
|
|
// 公众号配置信息
|
|
$where['id'] = $this->wechat_id;
|
|
$wechat = $this->model->table('wechat')->field('token, appid, appsecret, type')->where($where)->find();
|
|
if (empty($wechat)) {
|
|
$wechat = array();
|
|
}
|
|
$config = array();
|
|
$config['token'] = $wechat['token'];
|
|
$config['appid'] = $wechat['appid'];
|
|
$config['appsecret'] = $wechat['appsecret'];
|
|
|
|
$this->weObj = new \vendor\Wechat($config);
|
|
$this->assign('type', $wechat['type']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|