前言
最近在做项目中，要求在后台管理中有企业微信管理的相关功能。相关准备工作，需要准备好企业微信账号，添加自建应用，获得相应功能的权限，以及agentid、secre等。
参考文档：
企业微信开发文档
功能实现
因功能接口比较多，这里以“客户敏感词”为例，以下为“敏感词”管理功能实现。
1 想法思路
企业微信接口有请求次数限制，后台操作频繁，避免多次请求企业微信接口，也为了相应速度考虑，我这里考虑将输入进行入库处理。每次新建敏感词，企业微信“新增敏感词”接口请求成功后，将数据添加到数据库，编辑和删除同理。这样敏感词列表、查看敏感词就可以减少对企业微信接口的请求。
2 注意事项
（1）敏感词这里需要依赖通讯录中的成员和部门，因此需要先开发这两个模块之后，再进行敏感词功能开发（成员和部门也做了入库处理，所以在下面代码中，我也是直接查询数据库的内容）；
（2）access_token 有三种：通讯录access_token、联系人access_token以及自建应用 access_token，要根据接口需要，看需要哪一种access_token，否则就会报错。敏感词这里使用的是自建应用 access_token。
（3）要记得添加IP白名单。
3 代码实现
InterceptController.php
<?php
// +-----------------------xiaozhe-----------------------------------------------
namespace app\wework\controller;
use cmf\controller\AdminBaseController;
use app\wework\service\InterceptService;
use app\wework\service\WechatInterceptApi;
use app\wework\model\InterceptModel;
use app\wework\model\WeUserModel;
use app\admin\model\AdminMenuModel;
class InterceptController extends AdminBaseController
{
// 敏感词列表
public function index()
{
// 接口请求敏感词列表
// $wxinterceptApi = new WechatInterceptApi();
// $list = $wxinterceptApi->getInterceptRuleList();
// echo "<pre>";
// print_r($list);
// exit;
$param = $this->request->param();
$interceptService = new InterceptService();
$data = $interceptService->getList($param);
$data->appends($param);
$this->assign('keyword', isset($param['keyword']) ? $param['keyword'] : '');
$this->assign('lists', $data->items());
$this->assign('page', $data->render());
return $this->fetch();
}
// 新增敏感词
public function add()
{
if ($this->request->isPost()) {
$data = $this->request->param();
$interceptModel = new InterceptModel();
$data['create_time'] = time();
$data['user_id'] = cmf_get_current_admin_id();
$data['group_id'] = 0;
if ($data['applicable_type'] == 2) {
// 选择员工的话，是员工名
$userModel = new WeUserModel();
$userList = $userModel->whereIn('userid',$data['applicable_range'])->column("userid","department_id");
$group_arr = array_unique(array_keys($userList));
$applicable_range['user_list'] = implode(",",$userList);
$applicable_range['department_list'] = implode(",",$group_arr);
$data['applicable_range'] = json_encode($applicable_range,JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
} else {
$userModel = new WeUserModel();
$userList = $userModel->whereIn('department_id',$data['applicable_range'])->column("userid");
$applicable_range['user_list'] = implode(",",$userList);
$applicable_range['department_list'] = $data['applicable_range'];
$data['applicable_range'] = json_encode($applicable_range,JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
}
if (!empty($data['semantics_list'])) {
$data['semantics_list'] = implode(",",$data['semantics_list']);
}
// 敏感词接口新增
$user_list = !empty($applicable_range['user_list']) ? explode(",",$applicable_range['user_list']) : [];
$department_list = explode(",",$applicable_range['department_list']);
$wx_intercept = array(
'rule_name' => $data['rule_name'],
'word_list' => explode(",",$data['word_list']),
'semantics_list' => explode(",",$data['semantics_list']),
'intercept_type' => $data['intercept_type'],
'applicable_range' => array(
'user_list' => $user_list,
'department_list' => $department_list
)
);
$wxinterceptApi = new WechatInterceptApi();
$res = $wxinterceptApi->addInterceptRule($wx_intercept);
if ($res['errcode'] != 0) {
$this->error($res['errmsg'], url("Intercept/index"));
}
$data['rule_id'] = $res['rule_id'];
$result = $interceptModel->save($data);
if ($result) {
$this->success('添加成功！', url("Intercept/index"));
} else {
$this->error('添加失败！', url("Intercept/index"));
}
}
return $this->fetch();
}
// 编辑敏感词
public function edit()
{
if ($this->request->isPost()) {
$data = $this->request->param();
$id = $data['id'] ?? 0;
unset($data['id']);
if ($data['applicable_type'] == 2) {
// 选择员工的话，是员工名
$userModel = new WeUserModel();
$userList = $userModel->whereIn('userid',$data['applicable_range'])->column("userid","department_id");
$group_arr = array_unique(array_keys($userList));
$applicable_range['user_list'] = implode(",",$userList);
$applicable_range['department_list'] = implode(",",$group_arr);
$data['applicable_range'] = json_encode($applicable_range,JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
} else {
$userModel = new WeUserModel();
$userList = $userModel->whereIn('department_id',$data['applicable_range'])->column("userid");
$applicable_range['user_list'] = implode(",",$userList);
$applicable_range['department_list'] = $data['applicable_range'];
$data['applicable_range'] = json_encode($applicable_range,JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
}
$update_info = $data;
$interceptModel = new InterceptModel();
// 敏感词接口编辑
// 查询原来的数据
$rule_info = $interceptModel->field("rule_id,applicable_range")->where("id",$id)->find();
$old_add_applicable_range = json_decode($rule_info['applicable_range'],true);
$old_user_list = !empty($old_add_applicable_range['user_list']) ? explode(",",$old_add_applicable_range['user_list']) : [];
$old_department_list = !empty($old_add_applicable_range['department_list']) ? explode(",",$old_add_applicable_range['department_list']) : [];
$user_list = !empty($applicable_range['user_list']) ? explode(",",$applicable_range['user_list']) : [];
$department_list = explode(",",$applicable_range['department_list']);
$wx_intercept = array(
'rule_id' => $rule_info['rule_id'],
'rule_name' => $update_info['rule_name'],
'word_list' => explode(",",$update_info['word_list']),
'extra_rule' => array(
'semantics_list' => $data['semantics_list'],
),
'intercept_type' => $data['intercept_type'],
'add_applicable_range' => array(
'user_list' => $user_list,
'department_list' => $department_list
),
'remove_applicable_range' => array(
'user_list' => $old_user_list,
'department_list' => $old_department_list
)
);
$wxinterceptApi = new WechatInterceptApi();
$res = $wxinterceptApi->updateInterceptRule($wx_intercept);
if ($res['errcode'] != 0) {
$this->error($res['errmsg'], url("Intercept/index"));
}
if (!empty($update_info['semantics_list'])) {
$update_info['semantics_list'] = implode(",",$update_info['semantics_list']);
}
$result = $interceptModel->where("id",$id)->update($update_info);
if ($result) {
$this->success('编辑成功！', url("Intercept/index"));
} else {
$this->error('编辑失败！', url("Intercept/index"));
}
}
$id = $this->request->param('id', 0, 'intval');
if (empty($id)) {
$this->error('请求参数有误！');
}
// 查询敏感词信息
$interceptService = new InterceptService();
$info = $interceptService->getInfo($id);
// 接口请求敏感词详情
// $wxinterceptApi = new WechatInterceptApi();
// $list = $wxinterceptApi->getInterceptRuleInfo(['rule_id'=>$info['rule_id']]);
// echo "<pre>";
// print_r($list);
// exit;
$this->assign('info',$info);
return $this->fetch();
}
// 删除敏感词
public function delete()
{
$param = $this->request->param();
$interceptModel = new InterceptModel();
if (isset($param['id'])) {
$id = $this->request->param('id', 0, 'intval');
$rule_info = $interceptModel->field("rule_id")->where("id",$id)->find();
$wxinterceptApi = new WechatInterceptApi();
$wx_res = $wxinterceptApi->deleteInterceptRule(['rule_id'=>$rule_info['rule_id']]);
if ($wx_res['errcode'] == 0) {
$result = $interceptModel->where('id', $id)->delete();
$this->success("删除成功！");
} else {
$this->error("删除失败！");
}
}
}
public function checkWorker()
{
$param = $this->request->param();
$applicable_type = $param['type'] ?? 1;
$applicable_range = $param['value'] ?? "";
$interceptService = new InterceptService();
$result = $interceptService->getWorkerList($param);
$this->assign('menus', $result);
$this->assign('applicable_range', explode(",",$applicable_range));
$this->assign('applicable_type',$applicable_type);
return $this->fetch();
}
}
InterceptService.php
<?php
// +----------------------------------------------------------------------
// xiaozhe
// +----------------------------------------------------------------------
namespace app\wework\service;
use app\wework\model\InterceptModel;
use app\wework\model\DepartModel;
use app\wework\model\WeUserModel;
use think\db\Query;
class InterceptService
{
public function getList($filter)
{
$field = 'a.id,a.rule_name,a.word_list,a.intercept_type,a.applicable_type,a.user_id,a.create_time,a.update_time,u.user_nickname';
$interceptModel = new InterceptModel();
$result = $interceptModel
->alias("a")
->leftJoin("user u","a.user_id = u.id")
->field($field)
->where(function (Query $query) use ($filter) {
$keyword = empty($filter['keyword']) ? '' : $filter['keyword'];
if (!empty($keyword)) {
$query->where('a.title', 'like', "%$keyword%");
}
})
->paginate(15);
return $result;
}
public function getInfo($id)
{
$interceptModel = new InterceptModel();
$info = $interceptModel->where("id",$id)->find();
if (!empty($info['semantics_list'])) {
$info['semantics_list'] = explode(",",$info['semantics_list']);
}
if (!empty($info['applicable_range'])) {
$info['applicable_range'] = json_decode($info['applicable_range'],true);
$info['user_count'] = count(explode(",",$info['applicable_range']['user_list']));
$info['depart_count'] = count(explode(",",$info['applicable_range']['department_list']));
if ($info['applicable_type'] == 1) {
// 部门
$info['applicable_range_value'] = $info['applicable_range']['department_list'];
} else {
// 员工
$userModel = new WeUserModel();
$userIds = $userModel->whereIn("userid",$info['applicable_range']['user_list'])->whereIn("department_id",$info['applicable_range']['department_list'])->column("userid");
$info['applicable_range_value'] = implode(",",$userIds);
}
}
return $info;
}
public function getWorkerList($filter)
{
$type = $filter['type'];
switch ($type) {
case 1:
// 部门
$departmentModel = new DepartModel();
$newList = $departmentModel->field("department_id as id,name,parentid as parent_id")->select()->toArray();
break;
case 2:
// 员工
$userModel = new WeUserModel();
$newList = $userModel->field("userid as id,name")->select()->toArray();
break;
default:
// code...
break;
}
return $newList;
}
}
WechatInterceptApi.php
<?php
// +----------------------------------------------------------------------
// | xiaozhe
// +----------------------------------------------------------------------
namespace app\wework\service;
use app\wework\model\ConfigModel;
use think\Db;
/**
* 企业微信接口
**/
class WechatInterceptApi
{
/**
* 获取通讯录access_token
**/
public function getStaffAccessToken(){
$cache_key = 'staff_access_token';
$res = cache($cache_key);
if(empty($res)){
// 读取配置
$WeworkConfigModel = new ConfigModel();
$info = $WeworkConfigModel->where("id",1)->find();
$response = cmf_curl_get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={$info['corpid']}&corpsecret={$info['user_secret']}");
$arr = json_decode($response, true);
if($arr['errcode'] !== 0){
return '';
}
cache($cache_key, $arr['access_token'], 6900);
}
return $res;
}
/**
* 获取客户联系人access_token
**/
static public function getCustomerAccessToken(){
$cache_key = 'customer_access_token';
$res = cache($cache_key);
if(empty($res)){
$WeworkConfigModel = new ConfigModel();
$info = $WeworkConfigModel->where("id",1)->find();
$response = cmf_curl_get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={$info['corpid']}&corpsecret={$info['customer_secret']}");
$arr = json_decode($response, true);
if($arr['errcode'] !== 0){
return '';
}
cache($cache_key, $arr['access_token'], 6900);
}
return $res;
}
/**
* 获取自建应用 access_token
**/
public function getSelfappAccessToken(){
$cache_key = 'selfapp_access_token';
$res = cache($cache_key);
if(empty($res)){
$WeworkConfigModel = new ConfigModel();
$info = $WeworkConfigModel->where("id",1)->find();
$response = cmf_curl_get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={$info['corpid']}&corpsecret={$info['corpsecret']}");
$arr = json_decode($response, true);
if($arr['errcode'] !== 0){
return '';
}
cache($cache_key, $arr['access_token'], 6900);
}
return $res;
}
// 获取敏感词列表
public function getInterceptRuleList()
{
$token = self::getSelfappAccessToken();
$res = cmf_curl_get("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_intercept_rule_list?access_token=".$token,array());
$resp_arr = json_decode($res, 1);
return $resp_arr;
}
// 新增敏感词
public function addInterceptRule($filter)
{
$token = self::getSelfappAccessToken();
$res = self::curl_post("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_intercept_rule?access_token=".$token,
json_encode($filter)
);
$resp_arr = json_decode($res, 1);
return $resp_arr;
}
// 获取敏感词详情
public function getInterceptRuleInfo($filter)
{
$token = self::getSelfappAccessToken();
$res = self::curl_post("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_intercept_rule?access_token=".$token,
json_encode($filter)
);
$resp_arr = json_decode($res, 1);
return $resp_arr;
}
// 修改敏感词规则
public function updateInterceptRule($filter)
{
$token = self::getSelfappAccessToken();
$res = self::curl_post("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/update_intercept_rule?access_token=".$token,
json_encode($filter)
);
$resp_arr = json_decode($res, 1);
return $resp_arr;
}
// 删除敏感词
public function deleteInterceptRule($filter)
{
$token = self::getSelfappAccessToken();
$res = self::curl_post("https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_intercept_rule?access_token=".$token,
json_encode($filter)
);
$resp_arr = json_decode($res, 1);
return $resp_arr;
}
public function curl_post($url,$data){
$curl = curl_init(); // 启动一个CURL会话
curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 0); // 从证书中检查SSL加密算法是否存在
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); // 使用自动跳转
curl_setopt($curl, CURLOPT_AUTOREFERER, 1); // 自动设置Referer
curl_setopt($curl, CURLOPT_POST, 1); // 发送一个常规的Post请求
curl_setopt($curl, CURLOPT_POSTFIELDS,$data); // Post提交的数据包
curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
curl_setopt($curl, CURLOPT_HEADER, 0); // 显示返回的Header区域内容
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); // 获取的信息以文件流的形式返回
$result = curl_exec($curl); // 执行操作
return $result;
}
}（前端代码我就不放了哈，自行写一哈）
实现效果
敏感词列表
新增敏感词
编辑敏感词
