yanxue/application/admin/controller/weixin/User.php

<?php

namespace app\admin\controller\weixin;

use app\common\controller\Backend;
use Exception;
use think\Db;
use think\exception\PDOException;
use think\exception\ValidateException;
use addons\weixin\library\WechatService;
use app\admin\model\weixin\Reply as WechatReply;

/**
 * 微信用户管理
 *
 * @icon fa fa-circle-o
 */
class User extends Backend
{
    /**
     * User模型对象
     * @var \app\admin\model\weixin\User
     */
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\weixin\User;
    }

    /**
     * 查看
     */
    public function index()
    {
        //当前是否为关联查询
        $this->relationSearch = true;
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }
            list($where, $sort, $order, $offset, $limit) = $this->buildparams();
            $total = $this->model
                    ->with(['fauser'])
                    ->where($where)
                    ->order($sort, $order)
                    ->count();

            $list = $this->model
                    ->with(['fauser'])
                    ->where($where)
                    ->order($sort, $order)
                    ->limit($offset, $limit)
                    ->select();
            $list = collection($list)->toArray();

            $list_tag = $this->model->getTag();
            $list_group = $this->model->getGroup();
            foreach ($list as &$row) {
                if (isset($list_group[$row['groupid']])) {
                    $row['groupid_text'] = $list_group[$row['groupid']]['name'];
                }
                if (!empty($row['tagid_list'])) {
                    $tagid_list_arr = explode(',', $row['tagid_list']);
                    $tagid_list = [];
                    foreach ($tagid_list_arr as $v) {
                        if (isset($list_tag[$v])) {
                            $tagid_list[] = $list_tag[$v]['name'];
                        }
                    }
                    $row['tagid_list_text'] = $tagid_list;
                } else {
                    $row['tagid_list_text'] = ['无'];
                }
            }
            unset($row);
            $result = array("total" => $total, "rows" => $list);

            return json($result);
        }
        return $this->view->fetch();
    }

    /**
     * 推送消息
     * @author Created by Xing <464401240@qq.com>
     */
    public function sendmsg($ids = null)
    {
        $ids = trim($ids, ',');
        if ($this->request->isAjax()) {
            $params = $this->request->post("row/a");
            $params['ids'] = $ids;
            if ($params) {
                $errorLog = [];//发送失败的用户
                $list = $this->model->where(['uid' => ['in', $ids]])->select();
                if (empty($list)) {
                    $this->error('发送失败，参数不正确');
                }
                $model = new \app\admin\model\weixin\Reply;
                foreach ($list as $v) {
                    if ($v['subscribe'] && $v['openid']) {
                        try {
                            switch ($params['type']) {
                                case 'text':
                                    $message = WechatService::textMessage($params['content']);
                                    WechatService::staffService()->message($message)->to($v['openid'])->send();
                                    break;
                                case 'image':
                                    $message = json_decode($model->where('id', $params['image'])->value('data'), true);
                                    $message = WechatService::materialMessage('image', $message['media_id']);
                                    WechatService::staffService()->message($message)->to($v['openid'])->send();
                                    break;
                                case 'news':
                                    $message = $model->where('id', $params['news'])->value('data');
                                    $message = WechatService::newsMessage(json_decode($message, true));
                                    WechatService::staffService()->message($message)->to($v['openid'])->send();
                                    break;
                                default:
                                    $message = json_decode($model->where('id', $params['voice'])->value('data'), true);
                                    $message = WechatService::voiceMessage($message['media_id']);
                                    WechatService::staffService()->message($message)->to($v['openid'])->send();
                                    break;
                            }
                        } catch (\Exception $e) {
                            $errorLog[] = $v['nickname'] . '发送失败，或因为超48小时未互动。';
                        }
                    } else {
                        $errorLog[] = $v['nickname'] . '没有关注发送失败(不是微信公众号用户)';
                    }
                }
                if (!count($errorLog)) {
                    $this->success('全部发送成功');
                }
                $this->success(implode(',', $errorLog) . '，剩余的发送成功');
            }
        }
        //加载当前控制器语言包
        $this->loadlang('weixin/reply/keyword');
        $model = new \app\admin\model\weixin\Reply;
        $this->view->assign("typeList", $model->getTypeList());
        return $this->view->fetch();
    }

    /**
     * 修改用户标签
     */
    public function edit_user_tag($ids = null)
    {
        $row = $this->model->get($ids);
        if (!$row) {
            $this->error(__('No Results were found'));
        }
        if ($this->request->isAjax()) {
            $tagId = $this->request->post('tagid_list');
            if (!$tagId) {
                $this->error('请选择用户标签!');
            }
            if ($tagId) {
                $params['tagid_list'] = $tagId;
                $result = false;
                Db::startTrans();
                try {
                    $result = $row->allowField(true)->save($params);
                    Db::commit();
                } catch (ValidateException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (PDOException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
                if ($result !== false) {
                    $tagId = explode(',', $tagId) ?: [];
                    $tagList = explode(',', $row['tagid_list']) ?: [];
                    foreach ($tagList as $tag) {
                        if ($tag) {
                            WechatService::userTagService()->batchUntagUsers([$row['openid']], $tag);
                        }
                    }
                    foreach ($tagId as $tag) {
                        WechatService::userTagService()->batchTagUsers([$row['openid']], $tag);
                    }
                    $this->success();
                } else {
                    $this->error(__('No rows were updated'));
                }
            }
        }
        $this->view->assign("row", $row);
        return $this->view->fetch();
    }

    /**
     * 修改用户分组
     */
    public function edit_user_group($ids = null)
    {
        $row = $this->model->get($ids);
        if (!$row) {
            $this->error(__('No Results were found'));
        }
        if ($this->request->isAjax()) {
            $group_id = $this->request->post('group_id');
            if (!$group_id) {
                $this->error('请选择用户分组!');
            }
            if ($group_id) {
                $params['groupid'] = $group_id;
                $result = false;
                Db::startTrans();
                try {
                    $result = $row->allowField(true)->save($params);
                    Db::commit();
                } catch (ValidateException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (PDOException $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                } catch (Exception $e) {
                    Db::rollback();
                    $this->error($e->getMessage());
                }
                if ($result !== false) {
                    WechatService::userGroupService()->moveUser($row['openid'], $group_id);
                    $this->success();
                } else {
                    $this->error(__('No rows were updated'));
                }
            }
        }
        $this->view->assign("row", $row);
        return $this->view->fetch();
    }

    /**
     * 标签列表
     */
    public function tag()
    {
        if ($this->request->isAjax()) {
            $list = $this->model->getTag();
            $result = array("total" => count($list), "rows" => array_values($list));
            return json($result);
        }
        return $this->view->fetch();
    }

    /**
     * 添加标签
     */
    public function tagadd()
    {
        if ($this->request->isPost()) {
            $tagName = $this->request->post('name');
            if (!$tagName) {
                $this->error('请输入标签名称!');
            }
            try {
                WechatService::userTagService()->create($tagName);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_tag')->delete();
            $this->success();
        }
        return $this->view->fetch();
    }

    /**
     * 修改标签
     */
    public function tagedit($ids = null)
    {
        $list = $this->model->getTag();
        if (!isset($list[$ids])) {
            $this->error(__('No Results were found'));
        } else {
            $row = $list[$ids];
        }

        if ($this->request->isPost()) {
            $tagName = $this->request->post('name');
            if (!$tagName) {
                $this->error('请输入标签名称!');
            }
            try {
                WechatService::userTagService()->update($ids, $tagName);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_tag')->delete();
            $this->success('修改标签成功!');
        }

        $this->view->assign("row", $row);
        return $this->view->fetch();
    }

    /**
     * 删除标签
     */
    public function tagdel($ids = null)
    {
        if ($this->request->isPost()) {
            try {
                WechatService::userTagService()->delete($ids);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_tag')->delete();
            $this->success('删除标签成功!');
        }
    }

    /**
     * 分组列表
     */
    public function group()
    {
        if ($this->request->isAjax()) {
            $list = $this->model->getGroup();
            $result = array("total" => count($list), "rows" => array_values($list));
            return json($result);
        }
        return $this->view->fetch();
    }

    /**
     * 添加分组
     */
    public function groupadd()
    {
        if ($this->request->isPost()) {
            $tagName = $this->request->post('name');
            if (!$tagName) {
                $this->error('请输入标签名称!');
            }
            try {
                WechatService::userGroupService()->create($tagName);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_group')->delete();
            $this->success();
        }
        return $this->view->fetch();
    }

    /**
     * 修改分组
     */
    public function groupedit($ids = null)
    {
        $list = $this->model->getGroup();
        if (!isset($list[$ids])) {
            $this->error(__('No Results were found'));
        } else {
            $row = $list[$ids];
        }

        if ($this->request->isPost()) {
            $tagName = $this->request->post('name');
            if (!$tagName) {
                $this->error('请输入标签名称!');
            }
            try {
                WechatService::userGroupService()->update($ids, $tagName);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_group')->delete();
            $this->success('修改标签成功!');
        }

        $this->view->assign("row", $row);
        return $this->view->fetch();
    }

    /**
     * 删除分组
     */
    public function groupdel($ids = null)
    {
        if ($this->request->isPost()) {
            try {
                WechatService::userGroupService()->delete($ids);
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            Db::name('weixin_cache')->where('key', 'wechat_group')->delete();
            $this->success('删除标签成功!');
        }
    }
}