|
@@ -183,10 +183,16 @@ public class WeComSendMsgJob {
|
|
|
for (CgiReplyBucketData cgiReplyBucketData : cgiReplyBucketDataList) {
|
|
for (CgiReplyBucketData cgiReplyBucketData : cgiReplyBucketDataList) {
|
|
|
// build发送体
|
|
// build发送体
|
|
|
SendAppMsgRequest request = buildSendAppMsgRequest(cgiReplyBucketData, pushStaff, room);
|
|
SendAppMsgRequest request = buildSendAppMsgRequest(cgiReplyBucketData, pushStaff, room);
|
|
|
- // 发送消息
|
|
|
|
|
- CommonResponse<SendAppMsgResponse> response = weComThirdPartyService.sendAppMsg(pushStaff, room, request);
|
|
|
|
|
- // 存储消息
|
|
|
|
|
- saveAppWeComMsg(pushStaff.getId(), cgiReplyBucketData.getMiniVideoId(), request, response);
|
|
|
|
|
|
|
+ try {
|
|
|
|
|
+ // 发送消息
|
|
|
|
|
+ CommonResponse<SendAppMsgResponse> response = weComThirdPartyService.sendAppMsg(pushStaff, room, request);
|
|
|
|
|
+ // 存储消息
|
|
|
|
|
+ saveAppWeComMsg(pushStaff.getId(), cgiReplyBucketData.getMiniVideoId(), request, response);
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ log.error("发送群消息失败,账号名称:{},账号VID:{},群名称:{},视频ID:{},request:{},异常信息:{}",
|
|
|
|
|
+ staff.getName(), staff.getThirdStaffId(), room.getName(),
|
|
|
|
|
+ cgiReplyBucketData.getMiniVideoId(), JSONObject.toJSONString(request), e.getMessage(), e);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|