标签:directory ffffff range 服务端 特殊情况 字典 rtm 查询 ***
本文主要介绍,如何通过企业微信API向AD域账号即将过期的用户推送消息,以提醒用户尽快修改密码。1、AD域控制器Dsquery命令
2、认识企业微信用户信息JSON数据结构
3、Python JSON数据结构解释和取值
4、Python 字典数据结构赋值取值
4、企业微信消息推送API接口的使用
@TOC
首先,你需要部署一台AD域控制器。dsquery仅在DC和GC上运行有效,且可以是只读的DC或GC
在Windows Server系统中,域控制器(domain controller , DC)是一个在Windows服务器域中的接受安全认证请求(登录, 检查权限, 等)的服务器。是一台装有活动目服务的计算机(我们经常说到的DC服务器)
包含森林中所有对象信息的特殊目录数据库
全局编录是存储林中所有 Active Directory 对象的副本的域控制器。全局编录存储林中主持域的目录中所有对象的完全副本,以及林中所有其他域中所有对象的部分副本
全局编录中包含的所有域对象的部分副本是用户搜索操作中最常使用的部分。作为其架构定义的一部分,这些属性被标记为包含到全局编录中。在全局编录中存储所有域对象的最常搜索的属性,可以为用户提供高效的搜索,而不会以不必要的域控制器参考影响网络性能。
在林中的初始域控制器上,会自动创建全局编录。可以向其他域控制器添加全局编录功能,或者将全局编录的默认位置更改到另一个域控制器上。
全局编录允许用户在林中的所有域中搜索目录信息,而不论数据存储在何处。执行林内的搜索时可获得最大的速度并使用最小的网络通信。
dsquery user -stalepwd 173 -o upn -limit 0
其中:dsquery user
表示查询用户-stalepwd 173
表示最后一次修改密码时间>173天,假使密码有效期180天,获取7天后即将过期的账号列表。-o upn
表示输出格式为upn-limit 0
指定传回符合搜寻条件的对象数目,如果值是 0,将传回所有符合的对象。如果不指定此参数,根据默认将只显示前 100 个结果。
dsquery命令是AD域控管理中常用的一个查询命令,更多详细信息可以参考:
【逗老师带你学IT】AD域控 Dsquery 查询命令实例汇总
查询出的结果如下图所示,接下来我们要对这个信息进行处理,并转换成企业微信的UserID:
企业微信API文档原文写的很详细,清晰,易懂。本文会直接注明各接口在开发者文档中的位置,需要更多信息可以直接参考开发者文档,原文链接如下:
企业微信开发文档【服务端API】
文档位置:
开发指南>获取access_token
获取access_token是调用企业微信API接口的第一步,相当于创建了一个登录凭证,其它的业务API接口,都需要依赖于access_token来鉴权调用者身份。
接口定义:
请求方式: GET(HTTPS)
请求地址: https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=ID&corpsecret=SECRET
注:此处标注大写的单词ID和SECRET,为需要替换的变量,根据实际获取值更新。其它接口也采用相同的标注,不再说明。
参数 | 必须 | 说明 |
---|---|---|
corpid | 是 | 企业ID,获取方式参考:术语说明-corpid |
corpsecret | 是 | 应用的凭证密钥,获取方式参考:术语说明-secret |
{
"errcode": 0,
"errmsg": "ok",
"access_token": "accesstoken000001",
"expires_in": 7200
}
CORPID="ww078964********a08b1"
CORPSECRET="EHH***********************19Kw"
def gettoken():
try:
headers = {"Content-Type": "text/plain"}
request = requests.get(url="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+CORPID+"&corpsecret="+CORPSECRET,headers=headers)
request=json.loads(request.text)
access_token=request[‘access_token‘]
#提取JSON结构体中access_token字段值
except Exception as err:
raise err
else:
return access_token
上面的Python示例中使用到了JSON数据结构的取值,Python自带一个很方便的JSON解释器,开局一句import json
之后
json_data=json.loads(JSON数据原文)
value=json_data[‘取值的字段名‘]
即可得到想要的字段的值
文档位置:
通讯录管理>成员管理>读取成员
在通讯录同步助手中此接口可以读取企业通讯录的所有成员信息,而自建应用可以读取该应用设置的可见范围内的成员信息。
接口定义:
请求方式: GET(HTTPS)
请求地址: https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN&userid=USERID
参数 | 必须 | 说明 |
---|---|---|
access_token | 是 | 调用接口凭证 |
userid | 是 | 成员UserID。对应管理端的帐号,企业内必须唯一。不区分大小写,长度为1~64个字节 |
文档位置:
通讯录管理>成员管理>获取部门成员详情
接口定义:
请求方式: GET(HTTPS)
请求地址: https://qyapi.weixin.qq.com/cgi-bin/user/list?access_token=ACCESS_TOKEN&department_id=DEPARTMENT_ID&fetch_child=FETCH_CHILD
参数 | 必须 | 说明 |
---|---|---|
access_token | 是 | 调用接口凭证 |
department_id | 是 | 获取的部门id,根部门ID为1 |
fetch_child | 否 | 1/0:是否递归获取子部门下面的成员 |
参数 | 说明 |
---|---|
errcode | 返回码 |
errmsg | 对返回码的文本描述内容 |
userlist | 成员列表 |
userid | 成员UserID。对应管理端的帐号 |
name | 成员名称,此字段从2019年12月30日起,对新创建第三方应用不再返回,2020年6月30日起,对所有历史第三方应用不再返回,后续第三方仅通讯录应用可获取,第三方页面需要通过通讯录展示组件来展示名字 |
mobile | 手机号码,第三方仅通讯录应用可获取 |
department | 成员所属部门id列表,仅返回该应用有查看权限的部门id |
order | 部门内的排序值,32位整数,默认为0。数量必须和department一致,数值越大排序越前面。 |
position | 职务信息;第三方仅通讯录应用可获取 |
gender | 性别。0表示未定义,1表示男性,2表示女性 |
邮箱,第三方仅通讯录应用可获取 | |
is_leader_in_dept | 表示在所在的部门内是否为上级;第三方仅通讯录应用可获取 |
avatar | 头像url。第三方仅通讯录应用可获取 |
thumb_avatar | 头像缩略图url。第三方仅通讯录应用可获取 |
telephone | 座机。第三方仅通讯录应用可获取 |
alias | 别名;第三方仅通讯录应用可获取 |
status | 激活状态: 1=已激活,2=已禁用,4=未激活,5=退出企业。已激活代表已激活企业微信或已关注微工作台(原企业号)。未激活代表既未激活企业微信又未关注微工作台(原企业号)。 |
extattr | 扩展属性,第三方仅通讯录应用可获取 |
qr_code | 员工个人二维码,扫描可添加为外部联系人;第三方仅通讯录应用可获取 |
external_profile | 成员对外属性,字段详情见对外属性;第三方仅通讯录应用可获取 |
external_position | 对外职务。 第三方仅通讯录应用可获取 |
address | 地址,第三方仅通讯录应用可获取 |
hide_mobile | 是否隐藏手机号 |
english_name | 英文名 |
open_userid | 全局唯一。对于同一个服务商,不同应用获取到企业内同一个成员的open_userid是相同的,最多64个字节。仅第三方应用可获取 |
main_department | 主部门 |
需要注意的是,之后我们通过推送信息API发送消息的时候,用户信息UserID字段与AD域控中的email或者CN Name字段大概率是不同的。在本例中,仅email字段可以做到完全一致。因此,我们的思路是,通过email查找企业微信用户的UserID,并使用该UserID向用户发送信息。
{
"errcode": 0,
"errmsg": "ok",
"userlist": [{
"userid": "zhangsan",
"name": "李四",
"department": [1, 2],
"order": [1, 2],
"position": "后台工程师",
"mobile": "13800000000",
"gender": "1",
"email": "zhangsan@gzdev.com",
"is_leader_in_dept": [1, 0],
"avatar": "http://wx.qlogo.cn/mmopen/ajNVdqHZLLA3WJ6DSZUfiakYe37PKnQhBIeOQBO4czqrnZDS79FH5Wm5m4X69TBicnHFlhiafvDwklOpZeXYQQ2icg/0",
"thumb_avatar": "http://wx.qlogo.cn/mmopen/ajNVdqHZLLA3WJ6DSZUfiakYe37PKnQhBIeOQBO4czqrnZDS79FH5Wm5m4X69TBicnHFlhiafvDwklOpZeXYQQ2icg/100",
"telephone": "020-123456",
"alias": "jackzhang",
"status": 1,
"address": "广州市海珠区新港中路",
"hide_mobile" : 0,
"english_name" : "jacky",
"open_userid": "xxxxxx",
"main_department": 1,
"extattr": {
"attrs": [
{
"type": 0,
"name": "文本名称",
"text": {
"value": "文本"
}
},
{
"type": 1,
"name": "网页名称",
"web": {
"url": "http://www.test.com",
"title": "标题"
}
}
]
},
"qr_code": "https://open.work.weixin.qq.com/wwopen/userQRCode?vcode=xxx",
"external_position": "产品经理",
"external_profile": {
"external_corp_name": "企业简称",
"external_attr": [{
"type": 0,
"name": "文本名称",
"text": {
"value": "文本"
}
},
{
"type": 1,
"name": "网页名称",
"web": {
"url": "http://www.test.com",
"title": "标题"
}
},
{
"type": 2,
"name": "测试app",
"miniprogram": {
"appid": "wx8bd80126147dFAKE",
"pagepath": "/index",
"title": "miniprogram"
}
}
]
}
}]
}
def user_dict(access_token):
try:
user_dict=dict()
headers = {"Content-Type": "text/plain"}
request = requests.get(url="https://qyapi.weixin.qq.com/cgi-bin/user/list?access_token="+access_token+"&department_id=1&fetch_child=1",headers=headers)
request=json.loads(request.text)
all_user_list=request[‘userlist‘]
for user in all_user_list:
#敲黑板,此处用到二级JSON取值
userid=user[‘userid‘]
username=user[‘name‘]
email=user[‘email‘]
email_fix=email.find("@")
CNname=email[:email_fix]
user_dict[CNname]=[userid,username,email]
except Exception as err:
raise err
else:
return user_dict
#返回一个字典格式的结构体,字典内嵌一个list,结构示例如下:
‘CNname(邮箱前缀)‘: [‘userid‘, ‘username‘, ‘email‘]
‘zhaoxy12149‘: [‘ZhaoXiaoYun‘, ‘花和尚‘, ‘zhaoxy12149@csdn.com‘]
上面的Python示例中使用到了字典的赋值,字典数据结构对于大量的记录可以快速进行查找,避免使用list等结构查找数据时需要频繁的for循环。user_dict=dict()
语句使用dict()
创建一个空的字典
对于添加、修改已有记录,直接对字典的主键赋值即可。主键已经存在则会修改已有记录,主键不存在则会创建新的记录。
user_dict[’AAA‘]=‘AAA_Value‘
注意,字典中记录的值,可以是字符串,也可以是list等其他数据结构。非常灵活。
#输入CNname为邮箱前缀格式
def userid(user_dict,CNname):
try:
get_userid=get_username=get_email=‘N/A‘
get_userid=user_dict[CNname][0]
get_username=user_dict[CNname][1]
get_email=user_dict[CNname][2]
#字典的value为一个list,分别获取list的0、1、2号元素
except Exception as err:
print("Get userid failed with CNname:"+CNname)
raise err
else:
return get_userid,get_username,get_email
上面的Python示例中使用到了字典数据结构的取值
对于字典的数据结构,假使有如下字典:
person = {‘name‘:‘xiaoming‘, ‘age‘:18}
最简单的一种方式:person[‘name‘]
即可得到name的value,值为“xiaoming”
另外一种方式:person.get(‘name‘)
也可以得到name的value。
两种方式的区别为,第一种如果键查不到抛异常,第二种查不到赋值为空,第二种方式也可以设置返回默认值。
文档位置:
消息推送>发送应用消息
应用支持推送文本、图片、视频、文件、图文等类型。
接口定义:
请求方式: POST(HTTPS)
请求地址: https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=ACCESS_TOKEN
参数 | 必须 | 说明 |
---|---|---|
access_token | 是 | 调用接口凭证 |
企业微信消息推送支持推送以下格式的消息:
文本消息
图片消息
语音消息
视频消息
文件消息
文本卡片消息
图文消息
图文消息(mpnews)
markdown消息
小程序通知消息
任务卡片消息
{
"touser" : "UserID1|UserID2|UserID3",
"toparty" : "PartyID1|PartyID2",
"totag" : "TagID1 | TagID2",
"msgtype" : "text",
"agentid" : 1,
"text" : {
"content" : "你的快递已到,请携带工卡前往邮件中心领取。\n出发前可查看<a href=\"http://work.weixin.qq.com\">邮件中心视频实况</a>,聪明避开排队。"
},
"safe":0,
"enable_id_trans": 0,
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
参数 | 必须 | 说明 |
---|---|---|
touser | 否 | 指定接收消息的成员,成员ID列表(多个接收者用‘|’分隔,最多支持1000个)。特殊情况:指定为@all”,则向该企业应用的全部成员发送 |
toparty | 否 | 指定接收消息的部门,部门ID列表,多个接收者用‘|’分隔,最多支持100个。当touser为”@all”时忽略本参数 |
totag | 否 | 指定接收消息的标签,标签ID列表,多个接收者用‘|’分隔,最多支持100个。当touser为”@all”时忽略本参数 |
agentid | 是 | 企业应用的id,整型。企业内部开发,可在应用的设置页面查看查看方式;第三方服务商,可通过接口获取企业授权信息获取该参数值. |
touser、toparty、totag
不能同时为空,后面不再强调。
以下为一个markdown格式的请求代码示例
class post:
def message(access_token,agentid,userid,username):
try:
headers = {"Content-Type": "text/plain"}
data={
"touser" : userid,
"msgtype": "markdown",
"agentid" : agentid,
"markdown": {
"content": ‘‘‘**<font color="warning">【重要提示】</font>**
>亲爱的**‘‘‘+username+‘‘‘**,您好:
>
>您的域账号密码即将过期,域账号密码有效期为180天
>
>请及时访问[**erp.csdn.com**](https://erp.csdn.com/Password.html)修改您的域账号密码。
>
>密码过期未修改会导致您无法连接集团WIFI,***,以及无法登陆各种业务系统!
>
>忘记域账号密码,请通过以下路径自助重置:
>**ERP系统->新建申请->自助账号密码重置->AD域密码重置**‘‘‘
},
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
request = requests.post(url="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="+access_token,headers=headers,json=data)
except Exception as err:
raise err
else:
return request.text
消息效果:
import json
import requests
import os
CORPID="ww0******08b1"
AGENTID="1*******2"
CORPSECRET="EHHs2FC********************DHDJ19Kw"
def read_file_as_str(file_path):
# 判断路径文件存在
if not os.path.isfile(file_path):
raise TypeError(file_path + " does not exist")
all_the_text = open(file_path).read()
# print type(all_the_text)
return all_the_text
def gettoken():
try:
headers = {"Content-Type": "text/plain"}
request = requests.get(url="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+CORPID+"&corpsecret="+CORPSECRET,headers=headers)
request=json.loads(request.text)
access_token=request[‘access_token‘]
except Exception as err:
raise err
else:
return access_token
class weixin:
class get:
def userid(user_dict,CNname):
try:
get_userid=get_username=get_email=‘N/A‘
get_userid=user_dict[CNname][0]
get_username=user_dict[CNname][1]
get_email=user_dict[CNname][2]
except Exception as err:
print("Get userid failed with CNname:"+CNname)
raise err
else:
return get_userid,get_username,get_email
def userinfo_verbose(access_token,userid):
try:
headers = {"Content-Type": "text/plain"}
request = requests.get(url="https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token="+access_token+"&userid="+userid,headers=headers)
except Exception as err:
raise err
else:
return request.text
def user_dict(access_token):
try:
user_dict=dict()
headers = {"Content-Type": "text/plain"}
request = requests.get(url="https://qyapi.weixin.qq.com/cgi-bin/user/list?access_token="+access_token+"&department_id=1&fetch_child=1",headers=headers)
request=json.loads(request.text)
all_user_list=request[‘userlist‘]
for user in all_user_list:
userid=user[‘userid‘]
username=user[‘name‘]
email=user[‘email‘]
email_fix=email.find("@")
CNname=email[:email_fix]
user_dict[CNname]=[userid,username,email]
except Exception as err:
raise err
else:
return user_dict
class post:
def message(access_token,agentid,userid,username):
try:
headers = {"Content-Type": "text/plain"}
data={
"touser" : userid,
"msgtype": "markdown",
"agentid" : agentid,
"markdown": {
"content": ‘‘‘**<font color="warning">【重要提示】</font>**
>亲爱的**‘‘‘+username+‘‘‘**,您好:
>
>您的域账号密码即将过期,域账号密码有效期为180天
>
>请及时访问[**erp.csdn.com**](https://erp.csdn.com/Password.html)修改您的域账号密码。
>
>密码过期未修改会导致您无法连接集团WIFI,***,以及无法登陆各种业务系统!
>
>忘记域账号密码,请通过以下路径自助重置:
>**ERP系统->新建申请->自助账号密码重置->AD域密码重置**‘‘‘
},
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
request = requests.post(url="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="+access_token,headers=headers,json=data)
except Exception as err:
raise err
else:
return request.text
def main():
try:
command=os.popen("dsquery user -stalepwd 173 -o upn -limit 0")
#使用OS功能调用Windows系统命令行
user_list_file=command.read()
#读取OS系统命令行的回显
user_list_file=user_list_file.replace(‘""\n‘,‘‘).replace(‘"‘,‘‘).replace(‘@csdn.com‘,‘‘)
sent_user_list=user_list_file.split("\n")
#将原始数据格式化成list结构
access_token=gettoken()
#获取access_token
user_dict=weixin.get.user_dict(access_token)
#读取全员信息
for i in range(len(sent_user_list)-1):
try:
userid,username,email=weixin.get.userid(user_dict,sent_user_list[i])
except Exception as err:
print(err)
else:
print(userid,username,email)
sent_result=weixin.post.message(access_token,AGENTID,userid,username)
except Exception as err:
print(err)
if __name__ == ‘__main__‘:
main()
往期回顾:
【逗老师带你学IT】Google Admin服务账号+API管理G suit内所有网域用户
【逗老师带你学IT】PRTG监控系统通过企业微信推送图文混排告警消息
【逗老师带你学IT】PRTG HTTP API获取指定传感器流量图表图片
【逗老师带你学IT】PRTG监控系统合并多个传感器通道数据
【逗老师带你学IT】PRTG监控系统通过企业微信推送告警消息
【逗老师带你学IT】PRTG监控系统配合树莓派采集企业内部无线网络质量
【逗老师带你学IT】vMware ESXi 6.7合并第三方硬件驱动
【逗老师带你学IT】Kiwi Syslog Server安装和配置教程
【逗老师带你学IT】Kiwi Syslog Web Access与Active Directory集成认证
【逗老师带你学IT】vMware ESXi 6.7合并第三方硬件驱动
【逗老师带你学IT】Windows Server Network Policy Service(NPS)记账与审计
【逗老师带你学IT】Windows Server NPS服务构建基于AD域控的radius认证
【逗老师带你学IT】AD域控和freeradius集成认证环境,PAP,MSCHAPV2
【逗老师带你学IT】深信服SSL远程接入与深信服行为审计同步登陆用户信息
标签:directory ffffff range 服务端 特殊情况 字典 rtm 查询 ***
原文地址:https://blog.51cto.com/1737585/2549118