2024 年最新使用 ntwork 框架搭建企业微信机器人详细教程

NTWORK 概述

基于 PC 企业微信的 api 接口，支持收发文本、群@、名片、图片、文件、视频、链接卡片等。

下载安装 ntwork

pip install ntwork

国内源安装

pip install -i https://pypi.tuna.tsinghua.edu.cn/simple ntwork

企业微信版本下载

官方下载：https://dldir1.qq.com/wework/work_weixin/WeCom_4.0.8.6027.exe

简单基础案例

import sys
import ntwork

wework = ntwork.WeWork()

# 打开pc企业微信, smart: 是否管理已经登录的企业微信`在这里插入代码片`
wework.open(smart=True)

# 等待登录
wework.wait_login()

# 向文件助手发送一条消息
wework.send_text(conversation_id="FILEASSIST", content="hello, NtWork")

try:
    while True:
        pass
except KeyboardInterrupt:
    ntwork.exit_()
    sys.exit()

获取联系人列表、群列表

# -*- coding: utf-8 -*-
import sys
import ntwork

wework = ntwork.WeWork()

# 打开pc企业微信, smart: 是否管理已经登录的微信
wework.open(smart=True)

# 等待登录
wework.wait_login()

# 获取内部(同事)列表并输出
contacts = wework.get_inner_contacts()
print("内部(同事)联系人列表: ")
print(contacts)

# 获取外部(客户)列表并输出
contacts = wework.get_external_contacts()
print("外部(客户)联系人列表: ")
print(contacts)


# 获取群列表并输出
rooms = wework.get_rooms()
print("群列表: ")
print(rooms)


try:
    while True:
        pass
except KeyboardInterrupt:
    ntwork.exit_()
    sys.exit()

监听消息自动回复

import sys
import ntwork

wework = ntwork.WeWork()

# 打开pc企业微信, smart: 是否管理已经登录的微信
wework.open(smart=True)


# 注册消息回调
@wework.msg_register(ntwork.MT_RECV_TEXT_MSG)
def on_recv_text_msg(wework_instance: ntwork.WeWork, message):
    data = message["data"]
    sender_user_id = data["sender"]
    self_user_id = wework_instance.get_login_info()["user_id"]
    conversation_id: str = data["conversation_id"]

    # 判断消息不是自己发的并且不是群消息时，回复对方
    if sender_user_id != self_user_id and not conversation_id.startswith("R:"):
        wework_instance.send_text(conversation_id=conversation_id, 
                                  content=f"你发送的消息是: {data['content']}")


try:
    while True:
        pass
except KeyboardInterrupt:
    ntwork.exit_()
    sys.exit()

使用 fastapi 框架

通过 fastapi 的 swagger 在线文档可以很方便的管理 ntwork 接口：案例

常见问题解决方案

版本不匹配异常

如果出现ntwork.exception.WeWorkVersionNotMatchError异常异常, 请确认是否安装github上指定的企业微信版本，如果确认已经安装，还是报错，可以在代码中添加以下代码，跳过微信版本检测

import ntwork
ntwork.set_wework_exe_path(wework_version='4.0.8.6027')

账号克隆登录

新建一些 ntwork.wework 实例，然后调用 open 方法。

import ntwork

# 多开3个微信
for i in range(3):
    wework = ntwork.WeWork()
    wework.open(smart=False)

更完善的多实例管理查看 fastapi_example例子

如何监听输出所有的消息

# 注册监听所有消息回调
import ntwork


@wework.msg_register(ntwork.MT_ALL)
def on_recv_text_msg(wework_instance: ntwork.WeWork, message):
    print("########################")
    print(message)

完全例子查看examples/msg_register_all.py

如何关闭 ntwork 日志

os.environ['NTWORK_LOG'] = "ERROR" 要在import ntwork前执行

# -*- coding: utf-8 -*-
import os
import sys
import time
os.environ['NTWORK_LOG'] = "ERROR"

import ntwork

如何关闭 cmd 窗口

先使用pip install pywin32 安装pywin32模块, 然后在代码中添加以下代码， 完整例子查看examples/cmd_close_event.py

import sys
import ntwork
import win32api

def on_exit(sig, func=None):
    ntwork.exit_()
    sys.exit()


# 当关闭cmd窗口时
win32api.SetConsoleCtrlHandler(on_exit, True)

Pyinstaller 打包 exe

使用 pyinstaller 打包 ntwork 项目，需要添加 --collect-data=ntwork 选项

打包成单个 exe 程序

pyinstaller -F --collect-data=ntwork main.py

将所有的依赖文件打包到一个目录中

pyinstaller -y --collect-data=ntwork main.py

打包 fastapi_example 示例，需要添加 --paths=. --collect-data=ntchat

pyinstaller -F --paths=. --collect-data=ntchat main.py

登录日志预览

2024-04-12 00:45:21,949 - WeWorkManager - INFO - initialize wework, version: 4.0.8.6027
2024-04-12 00:45:21,949 - WeWorkManager - DEBUG - new wework instance
2024-04-12 00:45:21,982 - WeWorkInstance - INFO - open wework pid: 57024
2024-04-12 00:45:23,671 - WeWorkManager - DEBUG - accept client_id: 1
2024-04-12 00:45:26,225 - WeWorkInstance - DEBUG - on recv message: {'data': {'account': '', 'acctid': 'WangPaiGeGe', 'avatar': 'https://wework.qpic.cn/wwpic3az/457956_UJkq5TJkTfCnA5x_1712341231/0', 'corp_id': '1970325052533916', 'document_root': 'C:\\Users\\Administrator\\Documents\\WXWork\\1688856738534700', 'email': '', 'job_name': '', 'mobile': '19561983930', 'nickname': '', 'pid': 57024, 'position': '', 'sex': 1, 'user_id': '1688856738534700', 'username': '王牌哥哥'}, 'type': 11026}
2024-04-12 00:45:26,241 - WeWorkInstance - INFO - login success, name: 王牌哥哥

私聊自动回复案例

import sys
import ntwork

wework = ntwork.WeWork()

# 打开 pc 企业微信, smart: 是否管理已经登录的微信
wework.open(smart=True)


# 注册消息回调
@wework.msg_register(ntwork.MT_RECV_TEXT_MSG)
def on_recv_text_msg(wework_instance: ntwork.WeWork, message):
    data = message["data"]
    sender_user_id = data["sender"]
    self_user_id = wework_instance.get_login_info()["user_id"]
    conversation_id: str = data["conversation_id"]

    # 判断消息不是自己发的并且不是群消息时，回复对方
    if sender_user_id != self_user_id and not conversation_id.startswith("R:"):
        wework_instance.send_text(conversation_id=conversation_id, content=f"你发送的消息是: {data['content']}")


try:
    while True:
        pass
except KeyboardInterrupt:
    ntwork.exit_()
    sys.exit()

消息属性

私聊消息属性说明

{
	'appinfo': 'CAQQiZrgsAYYpMv0mZmAgAMgyIKKUw==',
	'at_list': [],
	'content': '我喜欢你',
	'content_type': 0,
	'conversation_id': 'S:1688856625489316_1688856738534700',
	'is_pc': 0,
	'local_id': '34',
	'receiver': '1688856738534700',
	'send_time': '1712852233',
	'sender': '1688856625489316',
	'sender_name': '唤醒手腕',
	'server_id': '1000235'
}

群聊消息属性说明

{
	'appinfo': 'CAQQiKTgsAYYpMv0mZmAgAMg99ak/Ak=',
	'at_list': [],
	'content': '我喜欢你',
	'content_type': 0,
	'conversation_id': 'R:1970325052533916',
	'is_pc': 0,
	'local_id': '41',
	'receiver': '1688856738534700',
	'send_time': '1712853512',
	'sender': '1688856625489316',
	'sender_name': '唤醒手腕',
	'server_id': '1000258'
}

案例：故障离线表格统计

读取故障数据源码

import re

# 假设这是你的消息体字符串
test_message = """  
【故障位置】化州西收费站97车道
【故障情况】不能缴费
【填报人】唤醒手腕
"""


def analysis_repair_data(message):
    # 定义正则表达式模式，用于匹配每个字段
    pattern = r"【故障位置】(.*)\n【故障情况】(.*)\n【填报人】(.*)"

    # 使用re.search来查找匹配项
    match = re.search(pattern, message, re.DOTALL)

    if match:
        fault_location = match.group(1).strip()  # 提取故障位置
        fault_situation = match.group(2).strip()  # 提取故障情况
        reporter = match.group(3).strip()  # 提取填报人

        return {"fault_location": fault_location,
                "fault_situation": fault_situation,
                "reporter": reporter
                }
    else:
        return False

读取维修数据源码

import re

# 假设这是你的消息体字符串
test_message = """  
【故障编号】 
【维修情况】已修复  
【维修人】xxx  
"""


def analysis_solve_data(message):
    # 定义正则表达式模式，用于匹配每个字段
    pattern = r"""  
    【故障编号】(.*)  
    【维修情况】(.*)  
    【维修人】(.*)  
    """
    pattern = re.compile(pattern, re.DOTALL | re.VERBOSE)

    # 使用re.search来查找匹配项
    match = pattern.search(message)

    if match:
        serial = match.group(1).strip()  # 提取故障编号
        repair_situation = match.group(2).strip()  # 提取维修情况
        repair_person = match.group(3).strip()  # 提取维修人
        return {"serial": serial,
                "repair_situation": repair_situation,
                "repair_person": repair_person
                }
    else:
        return False

更新离线 Excel 表格源码

from datetime import datetime

from openpyxl.reader.excel import load_workbook

# 加载工作簿
wb = load_workbook(filename='故障维修登记表.xlsx')
# 选择活动工作表或者通过名字选择工作表
ws = wb.active  # 使用活动工作表


def insert_new_note(repair_data):
    # 获取行数
    row_count = ws.max_row
    now = datetime.now()
    # 使用f-string格式化时间
    formatted_time = f"{now:%Y%m%d-%H%M%S}"
    data = {
        "index": row_count,
        "serial": formatted_time,
        "fault_location": repair_data['fault_location'],
        "fault_situation": repair_data['fault_situation'],
        "reporter": repair_data['reporter'],
        "repair_situation": "",
        "repair_person": ""
    }
    row_num = row_count + 1
    ws.cell(row=row_num, column=1).value = data['index']
    ws.cell(row=row_num, column=2).value = data['serial']
    ws.cell(row=row_num, column=3).value = data['fault_location']
    ws.cell(row=row_num, column=4).value = data['fault_situation']
    ws.cell(row=row_num, column=5).value = data['reporter']
    ws.cell(row=row_num, column=6).value = data['repair_situation']
    ws.cell(row=row_num, column=7).value = data['repair_person']

    # 保存工作簿到文件
    wb.save("故障维修登记表.xlsx")
    return data['serial']


def finish_old_note(solve_data):
    target_name = solve_data['serial']
    # 遍历所有行，查找目标值
    state = False
    for index, row in enumerate(ws.iter_rows(values_only=True)):
        if row[1] == "编号":
            continue
        if row[1] == target_name:  # 假设"Name"在第一列
            # 找到目标行后，修改该行的数据
            # 这里假设我们要修改的是第二列的数据，将其改为"New Value"
            ws.cell(row=(index + 1), column=6).value = solve_data['repair_situation']
            ws.cell(row=(index + 1), column=7).value = solve_data['repair_person']
            state = True
            wb.save("故障维修登记表.xlsx")
            break  # 找到后就退出循环
    if state:
        return solve_data['serial']
    else:
        return False

主程序 app.py 源码

# -*- coding: utf-8 -*-
import sys
from datetime import datetime

import ntwork

from read_repair_data import analysis_repair_data
from read_solve_data import analysis_solve_data
from update_excel import insert_new_note, finish_old_note

wework = ntwork.WeWork()

# 打开 pc 企业微信, smart: 是否管理已经登录的微信
wework.open(smart=True)


# 注册消息回调
@wework.msg_register(ntwork.MT_RECV_TEXT_MSG)
def on_recv_text_msg(wework_instance: ntwork.WeWork, message):
    data = message["data"]

    if data['content'][0:1] != "【":
        return

    sender_user_id = data["sender"]
    self_user_id = wework_instance.get_login_info()["user_id"]
    conversation_id: str = data["conversation_id"]

    # 判断消息不是自己发的并且不是群消息时，回复对方
    if sender_user_id != self_user_id and conversation_id.startswith("R:"):
        insert_data = analysis_repair_data(data['content'])
        if insert_data:
            serial = insert_new_note(insert_data)
            now = datetime.now()
            # 使用f-string格式化时间
            formatted_time = f"{now:%Y-%m-%d %H:%M:%S}"
            print(f"【反馈结果】【{formatted_time}】请注意存在新的反馈：{serial}")
            wework_instance.send_text(conversation_id=conversation_id, content=f"【反馈结果】反馈成功\n【故障编号】{serial}")
        insert_data = analysis_solve_data(data['content'])
        if insert_data:
            serial = finish_old_note(insert_data)
            if serial:
                # 使用f-string格式化时间
                now = datetime.now()
                formatted_time = f"{now:%Y-%m-%d %H:%M:%S}"
                print(f"【维修结果】【{formatted_time}】请注意存在新的维修：{serial}")
                wework_instance.send_text(conversation_id=conversation_id, content=f"【维修结果】维修成功\n【故障编号】{str(serial)}")
            else:
                wework_instance.send_text(conversation_id=conversation_id, content=f"【操作警告】故障编号不存在！")


try:
    while True:
        pass
except KeyboardInterrupt:
    ntwork.exit_()
    sys.exit()

填报故障真机演示

在这里插入图片描述

维修故障真机演示

在这里插入图片描述

Excel 表格情况预览

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/612217.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

大模型prompt实例：知识库信息质量校验模块

大模型prompt实例：知识库信息质量校验模块

大模型相关目录 大模型，包括部署微调prompt/Agent应用开发、知识库增强、数据库增强、知识图谱增强、自然语言处理、多模态等大模型应用开发内容 从0起步，扬帆起航。 大模型应用向开发路径：AI代理工作流大模型应用开发实用开源项目汇总大模…
阅读更多...
移动应用开发实验四AlarmManager实现闹钟提醒

移动应用开发实验四AlarmManager实现闹钟提醒

实验目的和要求 在Android Studio中，通过AlarmManager实现闹钟提醒。 点击“SET ALARM”后，采用Toast方式提示用于设定的闹钟成功，并包含设定的闹钟启用时间。 当闹钟生效时，采用AlertDialog实现闹钟题型，并通过Ale…
阅读更多...
Linux 进程信号【信号产生】

Linux 进程信号【信号产生】

💓博主CSDN主页:麻辣韭菜💓   ⏩专栏分类：Linux知识分享⏪   🚚代码仓库:Linux代码练习🚚   🌹关注我🫵带你学习更多Linux知识   🔝 目录 前言 信号概念 1. 生活角度的信号 2…
阅读更多...
解决常见的Android问题

解决常见的Android问题

常见问题： 1、查杀： 查杀一般分为两个方向一种是内存不足的查杀，一种的是因为温度限频查杀，统称为内存查杀，两个问题的分析思路不同 1、内存不足查杀： 主要是因为当用户出现后台运行多个APP或者是相机等…
阅读更多...
一文了解spring的aop知识

一文了解spring的aop知识

推荐工具 objectlog 对于重要的一些数据，我们需要记录一条记录的所有版本变化过程，做到持续追踪，为后续问题追踪提供思路。objectlog工具是一个记录单个对象属性变化的日志工具,工具采用spring切面和mybatis拦截器相关技术编写了api依赖包&a…
阅读更多...
【C++进阶】C++中的map和set

【C++进阶】C++中的map和set

一、关联式容器 在初阶阶段，我们已经接触过STL 中的部分容器，比如： vector 、 list 、 deque， forward_list 等，这些容器统称为序列式容器，因为其底层为线性序列的数据结构，里面存储的是元素本…
阅读更多...
Llama 3 是怎么回事?Arena 数据分析

Llama 3 是怎么回事?Arena 数据分析

4 月 18 日,Meta 发布了他们最新的开放权重大型语言模型 Llama 3。从那时起,Llama 3-70B 就在 English Chatbot Arena 排行榜上迅速上升,拥有超过 50,000 次对战。Meta 的这一非凡成就对开源社区来说是个好消息。在这篇博文中,我们旨在深入探讨为什么用户将 Llama 3-70b 与 GPT…
阅读更多...
【第17章】spring-mvc之日志和拦截器

【第17章】spring-mvc之日志和拦截器

文章目录 前言一、整合log4j1. 引入库2. log4j2.xml 二、拦截器1.拦截器类2.注册拦截器 三、过滤器和拦截器顺序总结 前言 【第2章】整合log4j2框架 在前面的spring中已经完成了对日志框架log4j的整合，这里我们直接拿过来用就行。 场景描述：每个接口请…
阅读更多...
JVM基础之垃圾回收

JVM基础之垃圾回收

垃圾回收 1. Base 内存泄漏：不再使用的对象在系统中未被回收 内存溢出：内存泄漏的积累 手动触发垃圾回收：System.gc(),该方法不一定会立即回收垃圾，仅仅是向JVM发送一个垃圾回收请求，具体是否需要垃圾回收由JVM自行…
阅读更多...
Web实时通信的学习之旅：轮询、WebSocket、SSE的区别以及优缺点

Web实时通信的学习之旅：轮询、WebSocket、SSE的区别以及优缺点

文章目录 一、通信机制1、轮询1.1、短轮询1.2、长轮询 2、Websocket3、Server-Sent Events 二、区别1、连接方式2、协议3、兼容性4、安全性5、优缺点5.1、WebSocket 的优点：5.2、WebSocket 的缺点：5.3、SSE 的优点：5.4、SSE 的缺点&#xff1…
阅读更多...
实用的Chrome命令 帮你打开Chrome浏览器的隐藏功能

实用的Chrome命令 帮你打开Chrome浏览器的隐藏功能

前言 Chrome作为主力浏览器，支持相当丰富的第三方扩展，其实浏览器本身也内置了大量实用的命令。许多实用的功能并没有直接显示在Chrome的菜单上。在这篇文章中，我们将介绍几个实用的chrome:// commands。 通过下面整理的 Chrome 命令&#x…
阅读更多...
nginx_01

nginx_01

1.安装 yum install epel-release -y # 安装yum的扩展包 yum install nginx -y systemctl start nginx.service #启动nginx systemctl enable nginx.service # netstat -lntup # 查看端口占用情况 # 可以看到nginx默认占用了80端口 2.nginx配置 # 注意配置文件的语法格式…
阅读更多...
macOS Sonoma 无法打开分段式Dmg文件的解决办法

macOS Sonoma 无法打开分段式Dmg文件的解决办法

在macOS Sonoma 14.X及更高版本的系统中，用户可能会遇到一个棘手的问题：无法直接打开“分段式”DMG（磁盘映像）安装包文件。这种情况通常发生在尝试安装一些大型软件或游戏时，尤其是那些因为文件体积巨大而采用分段压缩…
阅读更多...
开源AI大模型测评网站

开源AI大模型测评网站

1、排行榜 多个 AI 模型的排行榜和详细的性能评估，包括总排行榜、基础能力排行榜、安全类模型排行榜、金融领域应用排行榜、汽车领域应用排行榜以及工业领域应用排行榜 地址：SuperCLUEhttps://www.superclueai.com/ 2.报告合集 内容体系：代表性的数据集、基线(预训练)模型…
阅读更多...
Kivy UI界面

Kivy UI界面

一、版本介绍 Ubuntu：18.04.6 LTS Conda：4.5.12 Python：3.6.15 Kivy：2.0.0 二、安装Kivy # 更新系统包列表 sudo apt-get update# 安装Kivy的依赖项 sudo apt-get install -y python-pip libsdl2-dev libsdl2-image-dev li…
阅读更多...
【JavaWeb】网上蛋糕商城后台-商品管理

【JavaWeb】网上蛋糕商城后台-商品管理

概念 本文讲解和实现网上蛋糕商城的后台管理系统中的商品管理功能。 商品列表 点击后台管理系统的head.jsp头部的“商品管理”功能选项，向服务器发送请求/admin/goods_list 因此需要在servlet包中创建AdminGoodsListServlet类，用于获取商品信息列表 …
阅读更多...
TDM(BPM)-MIMO-FMCW雷达MATLAB仿真

TDM(BPM)-MIMO-FMCW雷达MATLAB仿真

本文通过对车载毫米波雷达信号流程和链路的仿真，建立基本的算法框架，可用于算法性能的验证。并提供基础MATLAB仿真代码，作为分享和参考。 一、信号的产生 车载毫米波雷达广泛使用线性调频连续波雷达，也即发射信号频率随时间线性变…
阅读更多...
C++ | Leetcode C++题解之第79题单词搜索

C++ | Leetcode C++题解之第79题单词搜索

题目&#xff1a; 题解&#xff1a; class Solution { public:bool exist(vector<vector<char>>& board, string word) {rows board.size();cols board[0].size();for(int i 0; i < rows; i) {for(int j 0; j < cols; j) {if (dfs(board, word, i, …
阅读更多...
面向对象设计之套路——设计模式

面向对象设计之套路——设计模式

1、总则 面向对象的分析设计编程思想&#xff0c;通过封装、继承、多态把程序的耦合度降低&#xff0c;用设计模式使得程序更加灵活&#xff0c;容易修改&#xff0c;并且易于复用。 让业务逻辑与界面逻辑分开&#xff0c;让它们的耦合度下降&#xff0c;只有分离&#xff0c;…
阅读更多...
jenkins部署想定报错

jenkins部署想定报错

报错&#xff1a; 解决办法&#xff1a; 登录被编译的设备&#xff0c;清楚旧代码&#xff0c;在重新执行
阅读更多...
最新文章

Copyright @ 2022~2023