baseXX/application/admin/controller/wechat/Reply.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------

namespace app\admin\controller\wechat;

use app\admin\controller\AuthController;
use app\admin\model\wechat\WechatReply;
use service\JsonService as Json;
use service\UploadService as Upload;
use think\Request;

/**
 * 关键字管理  控制器
 * Class Reply
 * @package app\admin\controller\wechat
 */
class Reply extends AuthController
{
    public function index()
    {
        if (empty(input('key'))) return $this->failed('请输入参数key');
        if (empty(input('title'))) return $this->failed('请输入参数title');
        $key=input('key');
        switch($key){
            case 'subscribe':
                $title = '编辑关注回复';
                break;
            case 'default':
                $title = '编辑关键字默认回复';
                break;
            default:
                $title = '编辑关键字回复';
                break;
        }

        $replay = WechatReply::where('key', input('key'))->find();
        $replay_arr = $replay ? $replay : [];
        if (isset($replay_arr['data'])) $replay_arr['data'] = json_decode($replay_arr['data'], true);
        $this->assign('replay_arr', json_encode($replay_arr));
        $this->assign('key',$key);
        $this->assign('title', $title);
        return $this->fetch();
    }

    public function one_reply()
    {
        $where = parent::postMore([
            ['key'],
            ['add', 0],
        ], $this->request);
        if (!empty($where['key'])) $replay = WechatReply::where('key', $where['key'])->find();
        $replay_arr = $replay->toArray();
        $replay_arr['code'] = 200;
        $replay_arr['data'] = json_decode($replay_arr['data'], true);
        if (empty($replay_arr)) {
            $replay_arr['code'] = 0;
        }
        if ($where['add'] && empty($where['key'])) {
            $replay_arr['code'] = 0;
        }
        exit(json_encode($replay_arr));
    }

    public function save(Request $request)
    {
        $data = parent::postMore([
            'type',
            'key',
            ['status', 0],
            ['data', []],
        ], $request);
        if (!isset($data['type']) && empty($data['type']))
            return Json::fail('请选择回复类型');
        if (!in_array($data['type'], WechatReply::$reply_type))
            return Json::fail('回复类型有误!');
        if (!isset($data['data']) || !is_array($data['data']))
            return Json::fail('回复消息参数有误!');
        $res = WechatReply::redact($data['data'], $data['key'], $data['type'], $data['status']);
        if (!$res)
            return Json::fail(WechatReply::getErrorInfo());
        else
            return Json::successful('保存成功!', $data);
    }

    public function upload_img(Request $request)
    {
        $name = $request->post('file');
        if (!$name) return Json::fail('请上传图片');
        $res = Upload::image($name, 'wechat/image');
        return $res->status === true ? Json::successful('上传成功', $res->filePath) : Json::fail($res->error);
    }

    public function upload_file(Request $request)
    {
        $name = $request->post('file');
        if (!$name) return Json::fail('请上传声音');
        $autoValidate['size'] = 2097152;
        $res = Upload::file($name, 'wechat/voice', true, $autoValidate);
        return $res->status === true ? Json::successful('上传成功', $res->filePath) : Json::fail($res->error);
    }

    /**
     * 关键字回复
     * */
    public function keyword()
    {
        $where = parent::getMore([
            ['key', ''],
            ['type', ''],
        ], $this->request);
        $this->assign('where', $where);
        $this->assign(WechatReply::getKeyAll($where));
        return $this->fetch();

    }

    /**
     * 添加关键字
     * */
    public function add_keyword()
    {
        $key = input('key');
        if (empty($key)) $key = '';
        $this->assign('key', $key);
        $this->assign('dis', 1);
        $this->assign('replay_arr', json_encode(array()));
        return $this->fetch();
    }

    /**
     * 修改关键字
     * */
    public function info_keyword()
    {
        $key = input('key');
        if (empty($key)) return $this->failed('参数错误,请重新修改');
        $replay = WechatReply::where('key', $key)->find();
       if($replay){
           $replay_arr = $replay->toArray();
           $replay_arr['data'] = json_decode($replay_arr['data'], true);
       }else{
           $replay_arr=[];
       }
        $this->assign('replay_arr', json_encode($replay_arr));
        $this->assign('key', $key);
        $this->assign('dis', 2);
        return $this->fetch('add_keyword');
    }

    /**
     * 保存关键字
     * */
    public function save_keyword(Request $request)
    {
        $data = parent::postMore([
            'key',
            'type',
            ['status', 0],
            ['data', []],
        ], $request);
        if (!isset($data['key']) && empty($data['key']))
            return Json::fail('请输入关键字');
        if (isset($data['key']) && !empty($data['key'])) {
            if (trim($data['key']) == 'subscribe') return Json::fail('请重新输入关键字');
            if (trim($data['key']) == 'default') return Json::fail('请重新输入关键字');
        }
        if (!isset($data['type']) && empty($data['type']))
            return Json::fail('请选择回复类型');
        if (!in_array($data['type'], WechatReply::$reply_type))
            return Json::fail('回复类型有误!');
        if (!isset($data['data']) || !is_array($data['data']))
            return Json::fail('回复消息参数有误!');
        $res = WechatReply::redact($data['data'], $data['key'], $data['type'], $data['status']);
        if (!$res)
            return Json::fail(WechatReply::getErrorInfo());
        else
            return Json::successful('保存成功!', $data);
    }

    /**
     * 删除关键字
     * */
    public function delete($id)
    {
        if (!WechatReply::del($id))
            return Json::fail(WechatReply::getErrorInfo('删除失败,请稍候再试!'));
        else
            return Json::successful('删除成功!');
    }


}