Package com.bytedesk.wechat.work.kefu.message

Class WeChatWorkMessageApiService

java.lang.Object

com.bytedesk.wechat.work.kefu.message.WeChatWorkMessageApiService

@Service
public class WeChatWorkMessageApiService
extends Object

企业微信客服消息服务实现类 https://developer.work.weixin.qq.com/document/path/94670

Author:

jackning

Field Summary

Fields

Modifier and Type	Field	Description
private final HttpRestService	httpRestService
private final MessageRestService	messageRestService
private final IMessageSendService	messageSendService
private final RedisWeChatWorkService	redisWeChatWorkService
private final SpringAIServiceRegistry	springAIServiceRegistry
private final ThreadRestService	threadRestService
private final UidUtils	uidUtils
private final UploadRestService	uploadRestService
private final VisitorRestService	visitorRestService
private final WeChatWorkCustomerService	weChatWorkCustomerService
private final WeChatWorkKefuServicerService	weChatWorkKefuServicerService
private final WeChatWorkSessionApiService	weChatWorkKfSessionService
private final WeChatWorkTokenService	weChatWorkTokenService
private final WeChatWorkUploadService	weChatWorkUploadService

Constructor Summary

Constructors

Constructor	Description
WeChatWorkMessageApiService()

Method Summary

Modifier and Type	Method	Description
private VisitorRequest	buildVisitorRequest(WeChatWorkCustomerResponse customerResponse, WeChatWorkMessageResponse.WeChatWorkMessage message, String corpId, String appSecret, String workgroupUid, String orgUid)	根据企业微信客户详情构建访客请求对象
private String	getAvailableServicerUserId(String corpId, String appSecret, String openKfid)	获取可用的接待人员ID
private void	processBusinessCardMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理名片消息
private void	processCalendarMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理日程消息
private void	processChannelsMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理视频号消息
private void	processChannelsShopOrderMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理视频号订单消息
private void	processChannelsShopProductMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理视频号商品消息
private void	processEnterSessionEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理进入会话事件
private void	processEventMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理事件消息
private void	processFileMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理文件消息
private void	processImageMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理图片消息
private void	processLinkMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理链接消息
private void	processLocationMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理位置消息
private void	processMeetingMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理会议消息
private void	processMergedMsgMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理聊天记录消息
void	processMessage(WeChatWorkMessageResponse.WeChatWorkMessage message, String corpId, String appSecret, String workgroupUid, String orgUid)	处理单个消息
void	processMessages(List<WeChatWorkMessageResponse.WeChatWorkMessage> messages, String corpId, String appSecret, String workgroupUid, String orgUid)	处理消息
private void	processMiniprogramMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理小程序消息
private void	processMsgmenuMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理菜单消息
private void	processMsgSendFailEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理消息发送失败事件
private void	processNoteMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理笔记消息
private void	processRejectCustomerMsgSwitchChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理拒收客户消息变更事件
private void	processServicerRecallMsgEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理接待人员撤回消息事件
private void	processServicerStatusChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理接待人员状态变更事件
private void	processSessionStatusChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理会话状态变更事件
private void	processTextMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理文本消息
private void	processUserRecallMsgEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理用户撤回消息事件
private void	processVideoMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理视频消息
void	processVisitorMessage(WeChatWorkMessageResponse.WeChatWorkMessage message, String corpId, String appSecret, String workgroupUid, String orgUid)	处理访客消息，包括获取访客详情、创建或更新访客信息、请求会话
private void	processVoiceMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)	处理语音消息
private void	sendEventWelcomeMessage(String msgCode, String corpId, String appSecret, String content)	发送事件响应欢迎消息
WeChatWorkSessionResponse	sendMsgmenuMessage(WeChatWorkMessageResponse.WeChatWorkMessage message, ThreadProtobuf thread, String corpId, String appSecret, String content)	发送菜单消息给企业微信客户
private void	sendSessionMessage(WeChatWorkMessageResponse.WeChatWorkMessage message, ThreadProtobuf thread, String corpId, String appSecret, String content)	发送会话消息
WeChatWorkSessionResponse	sendTextMessage(WeChatWorkMessageResponse.WeChatWorkMessage message, ThreadProtobuf thread, String corpId, String appSecret, String content)	发送文本消息给企业微信客户
private void	sendToCustomerService(WeChatWorkMessageResponse.WeChatWorkMessage message, VisitorResponse visitor, ThreadProtobuf thread, String workgroupUid, String orgUid)	将企业微信客服消息发送到客服系统
WeChatWorkMessageResponse	syncMsg(String corpId, String appSecret, String cursor, String token, Integer limit, Integer voiceFormat, String openKfid, String workgroupUid, String orgUid)	从企业微信服务器同步消息 weChatWorkKfMessageService.syncMsg(corpID, appSecret, null, tokenRef[0], 1000, 0, openKfIdRef[0]);

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

weChatWorkTokenService

private final WeChatWorkTokenService weChatWorkTokenService

httpRestService

private final HttpRestService httpRestService

weChatWorkCustomerService

private final WeChatWorkCustomerService weChatWorkCustomerService

visitorRestService

private final VisitorRestService visitorRestService

weChatWorkKfSessionService

private final WeChatWorkSessionApiService weChatWorkKfSessionService

messageSendService

private final IMessageSendService messageSendService

springAIServiceRegistry

private final SpringAIServiceRegistry springAIServiceRegistry

uidUtils

private final UidUtils uidUtils

threadRestService

private final ThreadRestService threadRestService

redisWeChatWorkService

private final RedisWeChatWorkService redisWeChatWorkService

messageRestService

private final MessageRestService messageRestService

weChatWorkKefuServicerService

private final WeChatWorkKefuServicerService weChatWorkKefuServicerService

weChatWorkUploadService

private final WeChatWorkUploadService weChatWorkUploadService

uploadRestService

private final UploadRestService uploadRestService

Constructor Details

WeChatWorkMessageApiService

public WeChatWorkMessageApiService()

Method Details

syncMsg

public WeChatWorkMessageResponse syncMsg(String corpId,
 String appSecret,
 String cursor,
 String token,
 Integer limit,
 Integer voiceFormat,
 String openKfid,
 String workgroupUid,
 String orgUid)

从企业微信服务器同步消息 weChatWorkKfMessageService.syncMsg(corpID, appSecret, null, tokenRef[0], 1000, 0, openKfIdRef[0]);

Parameters:

cursor - 上一次调用时返回的next_cursor，第一次拉取可以不填， 若不填，从最近3天内最早的消息开始返回

token - 回调事件返回的token字段，10分钟内有效

limit - 期望请求的数据量，默认值和最大值都为1000

voiceFormat - 语音消息类型，0-Amr 1-Silk，默认0

openKfid - 指定拉取某个客服账号的消息

Returns:

同步消息结果

processMessages

public void processMessages(List<WeChatWorkMessageResponse.WeChatWorkMessage> messages,
 String corpId,
 String appSecret,
 String workgroupUid,
 String orgUid)

处理消息

Parameters:

messages - 消息列表

corpId - 企业ID

appSecret - 应用密钥

processMessage

public void processMessage(WeChatWorkMessageResponse.WeChatWorkMessage message,
 String corpId,
 String appSecret,
 String workgroupUid,
 String orgUid)

处理单个消息

Parameters:

message - 单个消息

corpId - 企业ID

appSecret - 应用密钥

processTextMessage

private void processTextMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理文本消息

processImageMessage

private void processImageMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理图片消息

processVoiceMessage

private void processVoiceMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理语音消息

processVideoMessage

private void processVideoMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理视频消息

processFileMessage

private void processFileMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理文件消息

processLocationMessage

private void processLocationMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理位置消息

processLinkMessage

private void processLinkMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理链接消息

processBusinessCardMessage

private void processBusinessCardMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理名片消息

processMiniprogramMessage

private void processMiniprogramMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理小程序消息

processMsgmenuMessage

private void processMsgmenuMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理菜单消息

processEventMessage

private void processEventMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理事件消息

processEnterSessionEvent

private void processEnterSessionEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理进入会话事件

processMsgSendFailEvent

private void processMsgSendFailEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理消息发送失败事件

processServicerStatusChangeEvent

private void processServicerStatusChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理接待人员状态变更事件

processSessionStatusChangeEvent

private void processSessionStatusChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理会话状态变更事件

processUserRecallMsgEvent

private void processUserRecallMsgEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理用户撤回消息事件

processServicerRecallMsgEvent

private void processServicerRecallMsgEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理接待人员撤回消息事件

processRejectCustomerMsgSwitchChangeEvent

private void processRejectCustomerMsgSwitchChangeEvent(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理拒收客户消息变更事件

processVisitorMessage

public void processVisitorMessage(WeChatWorkMessageResponse.WeChatWorkMessage message,
 String corpId,
 String appSecret,
 String workgroupUid,
 String orgUid)

处理访客消息，包括获取访客详情、创建或更新访客信息、请求会话

Parameters:

message - 企业微信消息

corpId - 企业ID

appSecret - 应用密钥

workgroupUid - 工作组ID

orgUid - 组织ID

buildVisitorRequest

private VisitorRequest buildVisitorRequest(WeChatWorkCustomerResponse customerResponse,
 WeChatWorkMessageResponse.WeChatWorkMessage message,
 String corpId,
 String appSecret,
 String workgroupUid,
 String orgUid)

根据企业微信客户详情构建访客请求对象

Parameters:

customerResponse - 企业微信客户详情

message - 企业微信消息

corpId - 企业ID

Returns:

访客请求对象

sendSessionMessage

private void sendSessionMessage(WeChatWorkMessageResponse.WeChatWorkMessage message,
 ThreadProtobuf thread,
 String corpId,
 String appSecret,
 String content)

发送会话消息

Parameters:

message - 企业微信消息

corpId - 企业ID

appSecret - 应用密钥

content - 消息内容

sendEventWelcomeMessage

private void sendEventWelcomeMessage(String msgCode,
 String corpId,
 String appSecret,
 String content)

发送事件响应欢迎消息

Parameters:

msgCode - 事件消息的code

corpId - 企业ID

appSecret - 应用密钥

content - 消息内容

sendTextMessage

public WeChatWorkSessionResponse sendTextMessage(WeChatWorkMessageResponse.WeChatWorkMessage message,
 ThreadProtobuf thread,
 String corpId,
 String appSecret,
 String content)

发送文本消息给企业微信客户

Parameters:

message - 企业微信消息对象，用于获取openKfid和externalUserid

corpId - 企业ID

appSecret - 应用密钥

content - 要发送的文本内容

Returns:

发送结果，包含消息ID等信息

sendMsgmenuMessage

public WeChatWorkSessionResponse sendMsgmenuMessage(WeChatWorkMessageResponse.WeChatWorkMessage message,
 ThreadProtobuf thread,
 String corpId,
 String appSecret,
 String content)

发送菜单消息给企业微信客户

Parameters:

message - 企业微信消息对象，用于获取openKfid和externalUserid

thread - 线程对象

corpId - 企业ID

appSecret - 应用密钥

content - 机器人回复的文本内容

Returns:

发送结果，包含消息ID等信息

sendToCustomerService

private void sendToCustomerService(WeChatWorkMessageResponse.WeChatWorkMessage message,
 VisitorResponse visitor,
 ThreadProtobuf thread,
 String workgroupUid,
 String orgUid)

将企业微信客服消息发送到客服系统

Parameters:

message - 企业微信消息

visitorId - 访客ID

threadUid - 会话ID

nickname - 访客昵称

avatar - 访客头像URL

getAvailableServicerUserId

private String getAvailableServicerUserId(String corpId,
 String appSecret,
 String openKfid)

获取可用的接待人员ID

Parameters:

corpId - 企业ID

appSecret - 应用密钥

openKfid - 客服账号ID

Returns:

第一个可用的接待人员ID，如果没有则返回null

processChannelsShopProductMessage

private void processChannelsShopProductMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理视频号商品消息

processChannelsShopOrderMessage

private void processChannelsShopOrderMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理视频号订单消息

processMergedMsgMessage

private void processMergedMsgMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理聊天记录消息

processChannelsMessage

private void processChannelsMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理视频号消息

processMeetingMessage

private void processMeetingMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理会议消息

processCalendarMessage

private void processCalendarMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理日程消息

processNoteMessage

private void processNoteMessage(WeChatWorkMessageResponse.WeChatWorkMessage message)

处理笔记消息