mirror of
https://gitee.com/binary/weixin-java-tools.git
synced 2025-08-23 22:11:40 +08:00
🆕 【企业微信】增加直播相关接口
This commit is contained in:
Wong
Binary Wang
parent
2e4d73e8b7
commit
2175e94158
@ -0,0 +1,125 @@
|
||||
package me.chanjar.weixin.cp.api;
|
||||
|
||||
import lombok.NonNull;
|
||||
import me.chanjar.weixin.common.error.WxErrorException;
|
||||
import me.chanjar.weixin.cp.bean.living.*;
|
||||
|
||||
/**
|
||||
* 企业微信直播接口.
|
||||
* 官方文档：https://work.weixin.qq.com/api/doc/90000/90135/93633
|
||||
*
|
||||
* @author Wang_Wong
|
||||
* @date 2021-12-21
|
||||
*/
|
||||
public interface WxCpLivingService {
|
||||
|
||||
/**
|
||||
* 获取微信观看直播凭证
|
||||
* 请求方式： POST（HTTPS）
|
||||
* 请求地址： https://qyapi.weixin.qq.com/cgi-bin/living/get_living_code?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param openId 用户openid
|
||||
* @param livingId 直播id
|
||||
* @return living_code 微信观看直播凭证
|
||||
* @throws WxErrorException the wx error exception
|
||||
*/
|
||||
String getLivingCode(@NonNull String openId, @NonNull String livingId) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 获取直播详情
|
||||
* 请求方式：GET（HTTPS）
|
||||
* 请求地址：https://qyapi.weixin.qq.com/cgi-bin/living/get_living_info?access_token=ACCESS_TOKEN&livingid=LIVINGID
|
||||
*
|
||||
* @param livingId 直播id
|
||||
* @return 获取的直播详情
|
||||
* @throws WxErrorException the wx error exception
|
||||
*/
|
||||
WxCpLivingInfo getLivingInfo(@NonNull String livingId) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 获取直播观看明细
|
||||
* 通过该接口可以获取所有观看直播的人员统计
|
||||
*
|
||||
* 请求方式：POST（HTTPS）
|
||||
* 请求地址：https://qyapi.weixin.qq.com/cgi-bin/living/get_watch_stat?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param livingId 直播id
|
||||
* @param nextKey 上一次调用时返回的next_key，初次调用可以填”0”
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpWatchStat getWatchStat(@NonNull String livingId, Integer nextKey) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 获取成员直播ID列表
|
||||
* 通过此接口可以获取指定成员的所有直播ID
|
||||
*
|
||||
* 请求方式：POST（HTTPS）
|
||||
* 请求地址：https://qyapi.weixin.qq.com/cgi-bin/living/get_user_all_livingid?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param userId 企业成员的userid
|
||||
* @param cursor 上一次调用时返回的next_cursor，第一次拉取可以不填
|
||||
* @param limit 每次拉取的数据量，默认值和最大值都为100
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpLivingResult.LivingIdResult getUserAllLivingId(@NonNull String userId, String cursor, Integer limit) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 获取跳转小程序商城的直播观众信息
|
||||
* 通过此接口，开发者可获取跳转小程序商城的直播间(“推广产品”直播)观众id、邀请人id及对应直播间id，以打通卖货直播的“人货场”信息闭环。
|
||||
*
|
||||
* 请求方式：POST（HTTPS）
|
||||
* 请求地址：https://qyapi.weixin.qq.com/cgi-bin/living/get_living_share_info?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param wwShareCode "推广产品"直播观众跳转小程序商城时会在小程序path中带上ww_share_code=xxxxx参数
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpLivingShareInfo getLivingShareInfo(@NonNull String wwShareCode) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 创建预约直播
|
||||
* 请求方式： POST（HTTPS）
|
||||
* 请求地址： https://qyapi.weixin.qq.com/cgi-bin/living/create?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param request 创建预约直播请求参数.
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
String livingCreate(WxCpLivingCreateRequest request) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 修改预约直播
|
||||
* 请求方式： POST（HTTPS）
|
||||
* 请求地址： https://qyapi.weixin.qq.com/cgi-bin/living/modify?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param request 修改预约直播请求参数.
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpLivingResult livingModify(WxCpLivingModifyRequest request) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 取消预约直播
|
||||
* 请求方式： POST（HTTPS）
|
||||
* 请求地址： https://qyapi.weixin.qq.com/cgi-bin/living/cancel?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param livingId 直播id，仅允许取消预约状态下的直播id
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpLivingResult livingCancel(@NonNull String livingId) throws WxErrorException;
|
||||
|
||||
/**
|
||||
* 删除直播回放
|
||||
* 请求方式： POST（HTTPS）
|
||||
* 请求地址： https://qyapi.weixin.qq.com/cgi-bin/living/delete_replay_data?access_token=ACCESS_TOKEN
|
||||
*
|
||||
* @param livingId 直播id
|
||||
* @return
|
||||
* @throws WxErrorException
|
||||
*/
|
||||
WxCpLivingResult deleteReplayData(@NonNull String livingId) throws WxErrorException;
|
||||
|
||||
}
|
||||
@ -392,6 +392,13 @@ public interface WxCpService extends WxService {
|
||||
*/
|
||||
WxCpOaService getOaService();
|
||||
|
||||
/**
|
||||
* 获取直播相关接口的服务类对象
|
||||
*
|
||||
* @return the Living service
|
||||
*/
|
||||
WxCpLivingService getLivingService();
|
||||
|
||||
/**
|
||||
* 获取日历相关接口的服务类对象
|
||||
*
|
||||
|
||||
@ -49,6 +49,7 @@ public abstract class BaseWxCpServiceImpl<H, P> implements WxCpService, RequestH
|
||||
private WxCpTagService tagService = new WxCpTagServiceImpl(this);
|
||||
private WxCpAgentService agentService = new WxCpAgentServiceImpl(this);
|
||||
private WxCpOaService oaService = new WxCpOaServiceImpl(this);
|
||||
private WxCpLivingService livingService = new WxCpLivingServiceImpl(this);
|
||||
private WxCpTaskCardService taskCardService = new WxCpTaskCardServiceImpl(this);
|
||||
private WxCpExternalContactService externalContactService = new WxCpExternalContactServiceImpl(this);
|
||||
private WxCpGroupRobotService groupRobotService = new WxCpGroupRobotServiceImpl(this);
|
||||
@ -477,6 +478,11 @@ public abstract class BaseWxCpServiceImpl<H, P> implements WxCpService, RequestH
|
||||
return oaService;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingService getLivingService() {
|
||||
return livingService;
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpOaCalendarService getOaCalendarService() {
|
||||
return this.oaCalendarService;
|
||||
|
||||
@ -0,0 +1,118 @@
|
||||
package me.chanjar.weixin.cp.api.impl;
|
||||
|
||||
import com.google.gson.JsonObject;
|
||||
import com.google.gson.reflect.TypeToken;
|
||||
import lombok.NonNull;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import me.chanjar.weixin.common.error.WxErrorException;
|
||||
import me.chanjar.weixin.common.util.json.GsonHelper;
|
||||
import me.chanjar.weixin.common.util.json.GsonParser;
|
||||
import me.chanjar.weixin.cp.api.WxCpLivingService;
|
||||
import me.chanjar.weixin.cp.api.WxCpService;
|
||||
import me.chanjar.weixin.cp.bean.living.*;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import static me.chanjar.weixin.cp.constant.WxCpApiPathConsts.Living.*;
|
||||
|
||||
/**
|
||||
* 企业微信直播接口实现类.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
* @date 2021-12-21
|
||||
*/
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor
|
||||
public class WxCpLivingServiceImpl implements WxCpLivingService {
|
||||
private final WxCpService cpService;
|
||||
|
||||
@Override
|
||||
public String getLivingCode(String openId, String livingId) throws WxErrorException {
|
||||
final String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(GET_LIVING_CODE);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
jsonObject.addProperty("openid", openId);
|
||||
jsonObject.addProperty("livingid", livingId);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return GsonHelper.getString(GsonParser.parse(responseContent), "living_code");
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingInfo getLivingInfo(String livingId) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(GET_LIVING_INFO) + livingId;
|
||||
String responseContent = this.cpService.get(apiUrl, null);
|
||||
return WxCpGsonBuilder.create()
|
||||
.fromJson(GsonParser.parse(responseContent).get("living_info"),
|
||||
new TypeToken<WxCpLivingInfo>() {
|
||||
}.getType()
|
||||
);
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpWatchStat getWatchStat(String livingId, Integer nextKey) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(GET_WATCH_STAT);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
if (nextKey != null) {
|
||||
jsonObject.addProperty("next_key", String.valueOf(nextKey));
|
||||
}
|
||||
jsonObject.addProperty("livingid", livingId);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return WxCpWatchStat.fromJson(responseContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingResult.LivingIdResult getUserAllLivingId(String userId, String cursor, Integer limit) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(GET_USER_ALL_LIVINGID);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
if (cursor != null) {
|
||||
jsonObject.addProperty("cursor", cursor);
|
||||
}
|
||||
if (limit != null) {
|
||||
jsonObject.addProperty("limit", limit);
|
||||
}
|
||||
jsonObject.addProperty("userid", userId);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return WxCpLivingResult.LivingIdResult.fromJson(responseContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingShareInfo getLivingShareInfo(String wwShareCode) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(GET_LIVING_SHARE_INFO);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
jsonObject.addProperty("ww_share_code", wwShareCode);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return WxCpLivingShareInfo.fromJson(responseContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String livingCreate(WxCpLivingCreateRequest request) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(CREATE);
|
||||
String responseContent = this.cpService.post(apiUrl, request.toJson());
|
||||
return GsonHelper.getString(GsonParser.parse(responseContent), "livingid");
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingResult livingModify(WxCpLivingModifyRequest request) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(MODIFY);
|
||||
String responseContent = this.cpService.post(apiUrl, request.toJson());
|
||||
return WxCpLivingResult.fromJson(responseContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingResult livingCancel(@NonNull String livingId) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(CANCEL);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
jsonObject.addProperty("livingid", livingId);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return WxCpLivingResult.fromJson(responseContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public WxCpLivingResult deleteReplayData(@NonNull String livingId) throws WxErrorException {
|
||||
String apiUrl = this.cpService.getWxCpConfigStorage().getApiUrl(DELETE_REPLAY_DATA);
|
||||
JsonObject jsonObject = new JsonObject();
|
||||
jsonObject.addProperty("livingid", livingId);
|
||||
String responseContent = this.cpService.post(apiUrl, jsonObject.toString());
|
||||
return WxCpLivingResult.fromJson(responseContent);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,86 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.Accessors;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 创建预约直播请求.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
* @date 2021-12-23
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
@Accessors(chain = true)
|
||||
public class WxCpLivingCreateRequest implements Serializable {
|
||||
private static final long serialVersionUID = -4960239393895754138L;
|
||||
|
||||
@SerializedName("anchor_userid")
|
||||
private String anchorUserid;
|
||||
|
||||
@SerializedName("theme")
|
||||
private String theme;
|
||||
|
||||
@SerializedName("living_start")
|
||||
private Long livingStart;
|
||||
|
||||
@SerializedName("living_duration")
|
||||
private Long livingDuration;
|
||||
|
||||
@SerializedName("remind_time")
|
||||
private Long remindTime;
|
||||
|
||||
@SerializedName("description")
|
||||
private String description;
|
||||
|
||||
@SerializedName("type")
|
||||
private Integer type;
|
||||
|
||||
@SerializedName("agentid")
|
||||
private Integer agentId;
|
||||
|
||||
@SerializedName("activity_cover_mediaid")
|
||||
private String activityCoverMediaid;
|
||||
|
||||
@SerializedName("activity_share_mediaid")
|
||||
private String activityShareMediaid;
|
||||
|
||||
@SerializedName("activity_detail")
|
||||
private ActivityDetail activityDetail;
|
||||
|
||||
public static class ActivityDetail implements Serializable {
|
||||
|
||||
@SerializedName("image_list")
|
||||
private String[] imageList;
|
||||
|
||||
@SerializedName("description")
|
||||
private String description;
|
||||
|
||||
public static ActivityDetail fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, ActivityDetail.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static WxCpLivingCreateRequest fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpLivingCreateRequest.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,80 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.Data;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 直播详情信息.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
*/
|
||||
@Data
|
||||
public class WxCpLivingInfo implements Serializable {
|
||||
private static final long serialVersionUID = -5028321625140879571L;
|
||||
|
||||
@SerializedName("theme")
|
||||
private String theme;
|
||||
|
||||
@SerializedName("living_start")
|
||||
private Long livingStart;
|
||||
|
||||
@SerializedName("living_duration")
|
||||
private Long livingDurationme;
|
||||
|
||||
@SerializedName("status")
|
||||
private Integer status;
|
||||
|
||||
@SerializedName("reserve_living_duration")
|
||||
private Long reserveLivingDuration;
|
||||
|
||||
@SerializedName("reserve_start")
|
||||
private Long reserveStart;
|
||||
|
||||
@SerializedName("description")
|
||||
private String description;
|
||||
|
||||
@SerializedName("anchor_userid")
|
||||
private String anchorUserid;
|
||||
|
||||
@SerializedName("main_department")
|
||||
private Long mainDepartment;
|
||||
|
||||
@SerializedName("viewer_num")
|
||||
private Integer viewerNum;
|
||||
|
||||
@SerializedName("comment_num")
|
||||
private Integer commentNum;
|
||||
|
||||
@SerializedName("mic_num")
|
||||
private Integer micNum;
|
||||
|
||||
@SerializedName("open_replay")
|
||||
private Integer openReplay;
|
||||
|
||||
@SerializedName("replay_status")
|
||||
private Integer replayStatus;
|
||||
|
||||
@SerializedName("type")
|
||||
private Integer type;
|
||||
|
||||
@SerializedName("push_stream_url")
|
||||
private String pushStreamUrl;
|
||||
|
||||
@SerializedName("online_count")
|
||||
private Integer onlineCount;
|
||||
|
||||
@SerializedName("subscribe_count")
|
||||
private Integer subscribeCount;
|
||||
|
||||
public static WxCpLivingInfo fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpLivingInfo.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,56 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.Accessors;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 创建预约直播请求.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
* @date 2021-12-23
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
@Accessors(chain = true)
|
||||
public class WxCpLivingModifyRequest implements Serializable {
|
||||
private static final long serialVersionUID = -4960239393895754138L;
|
||||
|
||||
@SerializedName("livingid")
|
||||
private String livingId;
|
||||
|
||||
@SerializedName("theme")
|
||||
private String theme;
|
||||
|
||||
@SerializedName("living_start")
|
||||
private Long livingStart;
|
||||
|
||||
@SerializedName("living_duration")
|
||||
private Long livingDuration;
|
||||
|
||||
@SerializedName("remind_time")
|
||||
private Long remindTime;
|
||||
|
||||
@SerializedName("description")
|
||||
private String description;
|
||||
|
||||
@SerializedName("type")
|
||||
private Integer type;
|
||||
|
||||
public static WxCpLivingModifyRequest fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpLivingModifyRequest.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.Data;
|
||||
import lombok.Getter;
|
||||
import lombok.Setter;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 直播返回对象.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
*/
|
||||
@Data
|
||||
public class WxCpLivingResult implements Serializable {
|
||||
private static final long serialVersionUID = -5028321625140879571L;
|
||||
|
||||
@SerializedName("errcode")
|
||||
private Integer errcode;
|
||||
|
||||
@SerializedName("errmsg")
|
||||
private String errmsg;
|
||||
|
||||
@Getter
|
||||
@Setter
|
||||
public static class LivingIdResult implements Serializable {
|
||||
private static final long serialVersionUID = -5696099236344075582L;
|
||||
|
||||
@SerializedName("next_cursor")
|
||||
private String nextCursor;
|
||||
|
||||
@SerializedName("livingid_list")
|
||||
private String[] livingidList;
|
||||
|
||||
public static LivingIdResult fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, LivingIdResult.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static WxCpLivingResult fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpLivingResult.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,40 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.Data;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 跳转小程序商城的直播观众信息.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
*/
|
||||
@Data
|
||||
public class WxCpLivingShareInfo implements Serializable {
|
||||
private static final long serialVersionUID = -5028321625140879571L;
|
||||
|
||||
private String livingid;
|
||||
|
||||
@SerializedName("viewer_userid")
|
||||
private String viewerUserid;
|
||||
|
||||
@SerializedName("viewer_external_userid")
|
||||
private String viewerExternalUserid;
|
||||
|
||||
@SerializedName("invitor_userid")
|
||||
private String invitorUserid;
|
||||
|
||||
@SerializedName("invitor_external_userid")
|
||||
private String invitorExternalUserid;
|
||||
|
||||
public static WxCpLivingShareInfo fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpLivingShareInfo.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,90 @@
|
||||
package me.chanjar.weixin.cp.bean.living;
|
||||
|
||||
import com.google.gson.annotations.SerializedName;
|
||||
import lombok.Data;
|
||||
import lombok.Getter;
|
||||
import lombok.Setter;
|
||||
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 直播观看明细.
|
||||
*
|
||||
* @author Wang_Wong
|
||||
*/
|
||||
@Data
|
||||
public class WxCpWatchStat implements Serializable {
|
||||
private static final long serialVersionUID = -5028321625140879571L;
|
||||
|
||||
private Integer ending;
|
||||
|
||||
@SerializedName("next_key")
|
||||
private String nextKey;
|
||||
|
||||
@SerializedName("stat_info")
|
||||
private StatInfo statInfo;
|
||||
|
||||
@Getter
|
||||
@Setter
|
||||
public static class StatInfo implements Serializable {
|
||||
private static final long serialVersionUID = -5696099236344075582L;
|
||||
|
||||
@SerializedName("users")
|
||||
private List<WxCpWatchStat.User> users;
|
||||
|
||||
@SerializedName("external_users")
|
||||
private List<WxCpWatchStat.ExternalUser> externalUsers;
|
||||
|
||||
}
|
||||
|
||||
@Getter
|
||||
@Setter
|
||||
public static class User implements Serializable {
|
||||
private static final long serialVersionUID = -5696099236344075582L;
|
||||
|
||||
private String userid;
|
||||
|
||||
@SerializedName("watch_time")
|
||||
private Long watchTime;
|
||||
|
||||
@SerializedName("is_comment")
|
||||
private Integer isComment;
|
||||
|
||||
@SerializedName("is_mic")
|
||||
private Integer isMic;
|
||||
|
||||
}
|
||||
|
||||
@Getter
|
||||
@Setter
|
||||
public static class ExternalUser implements Serializable {
|
||||
private static final long serialVersionUID = -5696099236344075582L;
|
||||
|
||||
private String name;
|
||||
private Integer type;
|
||||
|
||||
@SerializedName("external_userid")
|
||||
private String externalUserid;
|
||||
|
||||
@SerializedName("watch_time")
|
||||
private Long watchTime;
|
||||
|
||||
@SerializedName("is_comment")
|
||||
private Integer isComment;
|
||||
|
||||
@SerializedName("is_mic")
|
||||
private Integer isMic;
|
||||
|
||||
}
|
||||
|
||||
public static WxCpWatchStat fromJson(String json) {
|
||||
return WxCpGsonBuilder.create().fromJson(json, WxCpWatchStat.class);
|
||||
}
|
||||
|
||||
public String toJson() {
|
||||
return WxCpGsonBuilder.create().toJson(this);
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,8 +1,6 @@
|
||||
package me.chanjar.weixin.cp.constant;
|
||||
|
||||
|
||||
import lombok.experimental.UtilityClass;
|
||||
|
||||
/**
|
||||
* <pre>
|
||||
* 企业微信api地址常量类
|
||||
@ -118,6 +116,19 @@ public interface WxCpApiPathConsts {
|
||||
String COPY_TEMPLATE = "/cgi-bin/oa/approval/copytemplate";
|
||||
}
|
||||
|
||||
interface Living {
|
||||
String GET_LIVING_CODE = "/cgi-bin/living/get_living_code";
|
||||
String GET_LIVING_INFO = "/cgi-bin/living/get_living_info?livingid=";
|
||||
String GET_WATCH_STAT = "/cgi-bin/living/get_watch_stat";
|
||||
String GET_LIVING_SHARE_INFO = "/cgi-bin/living/get_living_share_info";
|
||||
String GET_USER_ALL_LIVINGID = "/cgi-bin/living/get_user_all_livingid";
|
||||
|
||||
String CREATE = "/cgi-bin/living/create";
|
||||
String MODIFY = "/cgi-bin/living/modify";
|
||||
String CANCEL = "/cgi-bin/living/cancel";
|
||||
String DELETE_REPLAY_DATA = "/cgi-bin/living/delete_replay_data";
|
||||
}
|
||||
|
||||
interface Tag {
|
||||
String TAG_CREATE = "/cgi-bin/tag/create";
|
||||
String TAG_UPDATE = "/cgi-bin/tag/update";
|
||||
|
||||
@ -0,0 +1,99 @@
|
||||
package me.chanjar.weixin.cp.api;
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import me.chanjar.weixin.common.error.WxErrorException;
|
||||
import me.chanjar.weixin.cp.api.impl.WxCpServiceImpl;
|
||||
import me.chanjar.weixin.cp.bean.living.*;
|
||||
import me.chanjar.weixin.cp.config.WxCpConfigStorage;
|
||||
import me.chanjar.weixin.cp.demo.WxCpDemoInMemoryConfigStorage;
|
||||
import org.eclipse.jetty.util.ajax.JSON;
|
||||
import org.testng.annotations.Test;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* 企业微信直播测试类.
|
||||
* 官方文档：https://open.work.weixin.qq.com/api/doc/90000/90135/93632
|
||||
*
|
||||
* @author Wang_Wong
|
||||
*/
|
||||
@Slf4j
|
||||
public class WxCpLivingTest {
|
||||
|
||||
private static WxCpConfigStorage wxCpConfigStorage;
|
||||
private static WxCpService wxCpService;
|
||||
|
||||
@Test
|
||||
public void test() throws WxErrorException {
|
||||
|
||||
InputStream inputStream = ClassLoader.getSystemResourceAsStream("test-config.xml");
|
||||
WxCpDemoInMemoryConfigStorage config = WxCpDemoInMemoryConfigStorage.fromXml(inputStream);
|
||||
|
||||
wxCpConfigStorage = config;
|
||||
wxCpService = new WxCpServiceImpl();
|
||||
wxCpService.setWxCpConfigStorage(config);
|
||||
|
||||
String livingCode = wxCpService.getLivingService().getLivingCode("o50by5NezHciWnoexJsrI49ILNqI", "lvOQpTDwAAD2MYuOq9y_bmLNMJfbbdGw");
|
||||
log.info(JSON.toString(livingCode));
|
||||
|
||||
// 直播详情
|
||||
WxCpLivingInfo livingInfo = wxCpService.getLivingService().getLivingInfo("lvOQpTDwAAcP9wNOSSxTwpbni-TMPNSg");
|
||||
log.info(livingInfo.toJson());
|
||||
|
||||
// 直播观看明细
|
||||
WxCpWatchStat watchStat = wxCpService.getLivingService().getWatchStat("lvOQpTDwAAcP9wNOSSxTwpbni-TMPNSg", 0);
|
||||
log.info(watchStat.toJson());
|
||||
|
||||
final String watchStateJson = "{\"errcode\":0,\"errmsg\":\"ok\",\"ending\":1,\"next_key\":\"NEXT_KEY\",\"stat_info\":{\"users\":[{\"userid\":\"userid\",\"watch_time\":30,\"is_comment\":1,\"is_mic\":1}],\"external_users\":[{\"external_userid\":\"external_userid1\",\"type\":1,\"name\":\"user name\",\"watch_time\":30,\"is_comment\":1,\"is_mic\":1},{\"external_userid\":\"external_userid2\",\"type\":2,\"name\":\"user_name\",\"watch_time\":30,\"is_comment\":1,\"is_mic\":1}]}}";
|
||||
|
||||
WxCpWatchStat wxCpWatchStat = WxCpWatchStat.fromJson(watchStateJson);
|
||||
log.info(wxCpWatchStat.toJson());
|
||||
|
||||
// 直播观众信息
|
||||
final String livingShareInfo = "{\"errcode\":0,\"errmsg\":\"ok\",\"livingid\":\"livingid\",\"viewer_userid\":\"viewer_userid\",\"viewer_external_userid\":\"viewer_external_userid\",\"invitor_userid\":\"invitor_userid\",\"invitor_external_userid\":\"invitor_external_userid\"}";
|
||||
|
||||
WxCpLivingShareInfo wxCpLivingShareInfo = WxCpLivingShareInfo.fromJson(livingShareInfo);
|
||||
log.info(wxCpLivingShareInfo.toJson());
|
||||
|
||||
// 获取成员直播ID列表
|
||||
WxCpLivingResult.LivingIdResult livingResult = wxCpService.getLivingService().getUserAllLivingId("ChenHu", null, null);
|
||||
log.info(livingResult.toJson());
|
||||
|
||||
String livinglist = "{\"errcode\":0,\"errmsg\":\"ok\",\"next_cursor\":\"next_cursor\",\"livingid_list\":[\"livingid1\",\"livingid2\"]}";
|
||||
WxCpLivingResult.LivingIdResult livingIdResult = WxCpLivingResult.LivingIdResult.fromJson(livinglist);
|
||||
log.info(livingIdResult.toJson());
|
||||
|
||||
|
||||
log.info("{}", new Date().getTime());
|
||||
// 创建预约直播
|
||||
String create = "{\"anchor_userid\":\"ChenHu\",\"theme\":\"theme\",\"living_start\":164037820420,\"living_duration\":3600,\"description\":\"test description\",\"type\":4,\"remind_time\":60,\"activity_cover_mediaid\":\"MEDIA_ID\",\"activity_share_mediaid\":\"MEDIA_ID\",\"activity_detail\":{\"description\":\"活动描述，非活动类型的直播不用传\",\"image_list\":[\"xxxx1\",\"xxxx1\"]}}";
|
||||
WxCpLivingCreateRequest request = WxCpLivingCreateRequest.fromJson(create);
|
||||
String livingId = wxCpService.getLivingService().livingCreate(request);
|
||||
log.info("livingId为：{}", livingId);
|
||||
|
||||
|
||||
String modify = "{\"livingid\": \""+ livingId +"\",\"theme\":\"theme\",\"living_start\":164047820420,\"living_duration\":3600,\"description\":\"描述：description\",\"type\":1,\"remind_time\":60}";
|
||||
WxCpLivingModifyRequest modifyReq = WxCpLivingModifyRequest.fromJson(modify);
|
||||
WxCpLivingResult result = wxCpService.getLivingService().livingModify(modifyReq);
|
||||
log.info("result：{}", result.toJson());
|
||||
|
||||
|
||||
// 取消预约直播
|
||||
// WxCpLivingResult result2 = wxCpService.getLivingService().livingCancel("lvOQpTDwAA0KyLmWZhf_LIENzYIBVD2g");
|
||||
WxCpLivingResult result2 = wxCpService.getLivingService().livingCancel(livingId);
|
||||
log.info("取消预约直播为：{}", result2.toJson());
|
||||
|
||||
|
||||
// 删除直播回放
|
||||
// WxCpLivingResult response = wxCpService.getLivingService().deleteReplayData("lvOQpTDwAAVdCHyXMgSK63TKPfKDII7w");
|
||||
// log.info(response.toJson());
|
||||
|
||||
|
||||
}
|
||||
|
||||
public static void main(String[] args){
|
||||
log.info("{}", new Date().getTime());
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user