提交

直播功能开发

b2b2c/b2b2c-config-starter/pay-slodon-starter/src/main/resources/wx_cert/证书使用说明.txt

@@ -0,0 +1,18 @@
+欢迎使用微信支付！
+附件中的三份文件（证书pkcs12格式、证书pem格式、证书密钥pem格式）,为接口中强制要求时需携带的证书文件。
+证书属于敏感信息，请妥善保管不要泄露和被他人复制。
+不同开发语言下的证书格式不同，以下为说明指引：
+    证书pkcs12格式（apiclient_cert.p12）
+        包含了私钥信息的证书文件，为p12(pfx)格式，由微信支付签发给您用来标识和界定您的身份
+        部分安全性要求较高的API需要使用该证书来确认您的调用身份
+        windows上可以直接双击导入系统，导入过程中会提示输入证书密码，证书密码默认为您的商户号（如：1900006031）
+    证书pem格式（apiclient_cert.pem）
+        从apiclient_cert.p12中导出证书部分的文件，为pem格式，请妥善保管不要泄漏和被他人复制
+        部分开发语言和环境，不能直接使用p12文件，而需要使用pem，所以为了方便您使用，已为您直接提供
+        您也可以使用openssl命令来自己导出：openssl pkcs12 -clcerts -nokeys -in apiclient_cert.p12 -out apiclient_cert.pem
+    证书密钥pem格式（apiclient_key.pem）
+        从apiclient_cert.p12中导出密钥部分的文件，为pem格式
+        部分开发语言和环境，不能直接使用p12文件，而需要使用pem，所以为了方便您使用，已为您直接提供
+        您也可以使用openssl命令来自己导出：openssl pkcs12 -nocerts -in apiclient_cert.p12 -out apiclient_key.pem
+备注说明：  
+        由于绝大部分操作系统已内置了微信支付服务器证书的根CA证书,  2018年3月6日后, 不再提供CA证书文件（rootca.pem）下载 

b2b2c/b2b2c-core/src/main/java/com/slodon/b2b2c/core/util/HttpClientUtil.java

@@ -131,17 +131,30 @@ public class HttpClientUtil {
     }
 
     /**
-     * post请求json
-     *
+     * post请求json 原本
+     *  提交类型是表单，由于是旧代码不敢修改 application/x-www-form-urlencoded
      * @param url
      * @param json
      * @return
      * @throws Exception
      */
+    @Deprecated
     public static String sendJsonPost(String url, String json) throws Exception {
         return sendPost(url, json, "application/x-www-form-urlencoded");
     }
 
+    /**
+     * post请求json 新的
+     *
+     * @param url
+     * @param json
+     * @return
+     * @throws Exception
+     */
+    public static String sendJsonPostNew(String url, String json) throws Exception {
+        return sendPost(url, json, "application/json");
+    }
+
     public static String sendPost(String url, String content, String type) throws ClientProtocolException {
         CloseableHttpClient client = null;
         CloseableHttpResponse resp = null;

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/enums/WxLiveUrlEnum.java

@@ -0,0 +1,36 @@
+package com.slodon.b2b2c.enums;
+
+public enum WxLiveUrlEnum {
+    ADD_LIVE("创建直播间","https://api.weixin.qq.com/wxaapi/broadcast/room/create?access_token="),
+    GET_LIVE_LIST("获取直播间列表","https://api.weixin.qq.com/wxa/business/getliveinfo?access_token="),
+    GET_LIVE_PLAYBACK("获取直播间回放","https://api.weixin.qq.com/wxa/business/getliveinfo?access_token="),
+    ADD_LIVE_GOODS("直播间导入商品","https://api.weixin.qq.com/wxaapi/broadcast/room/addgoods?access_token="),
+    DEL_LIVE("删除直播间","https://api.weixin.qq.com/wxaapi/broadcast/room/deleteroom?access_token="),
+    EDIT_LIVE("编辑直播间","https://api.weixin.qq.com/wxaapi/broadcast/room/editroom?access_token="),
+    GET_PUSH_LIVE("获取直播间推流地址","https://api.weixin.qq.com/wxaapi/broadcast/room/getpushurl?access_token=")
+    ;
+
+    private String explain;
+    private String url;
+
+    WxLiveUrlEnum(String explain, String url) {
+        this.explain = explain;
+        this.url = url;
+    }
+
+    public String getExplain() {
+        return explain;
+    }
+
+    public void setExplain(String explain) {
+        this.explain = explain;
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/dto/LiveBroadcastDto.java

@@ -0,0 +1,50 @@
+package com.slodon.b2b2c.live.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveBroadcastDto implements Serializable {
+    @ApiModelProperty("直播间id")
+    private String roomId;
+    @ApiModelProperty(value = "直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "背景图，填入mediaID（mediaID获取后，三天内有效）",required = true)
+    private String coverImg;
+    @ApiModelProperty(value = "直播计划开始时间（开播时间需要在当前时间的10分钟后 并且 开始时间不能在 6 个月后）",required = true)
+    private Long startTime;
+    @ApiModelProperty(value = "直播计划结束时间（开播时间和结束时间间隔不得短于30分钟，不得超过24小时）",required = true)
+    private Long endTime;
+    @ApiModelProperty(value = "主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符",required = true)
+    private String anchorName;
+    @ApiModelProperty(value = "主播微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证,",required = true)
+    private String anchorWechat;
+    @ApiModelProperty("主播副号微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证 ")
+    private String subAnchorWechat;
+    @ApiModelProperty("创建者微信号，不传入则此直播间所有成员可见。传入则此房间仅创建者、管理员、超管、直播间主播可见")
+    private String createrWechat;
+    @ApiModelProperty(value = "分享图，填入mediaID",required = true)
+    private String shareImg;
+    @ApiModelProperty(value = "购物直播频道封面图，填入mediaID",required = true)
+    private String feedsImg;
+    @ApiModelProperty("是否开启官方收录 【1: 开启，0：关闭】，默认开启收录")
+    private Integer isFeedsPublic;
+    @ApiModelProperty(value = "直播间类型 【1: 推流，0：手机直播】",required = true)
+    private Integer type;
+    @ApiModelProperty(value = "是否关闭点赞 【0：开启，1：关闭】（若关闭，观众端将隐藏点赞按钮，直播开始后不允许开启）",required = true)
+    private Integer closeLike;
+    @ApiModelProperty(value = "是否关闭货架 【0：开启，1：关闭】（若关闭，观众端将隐藏商品货架，直播开始后不允许开启）",required = true)
+    private Integer closeGoods;
+    @ApiModelProperty(value = "是否关闭评论 【0：开启，1：关闭】（若关闭，观众端将隐藏评论入口，直播开始后不允许开启）",required = true)
+    private Integer closeComment;
+    @ApiModelProperty("是否关闭回放 【0：开启，1：关闭】默认关闭回放（直播开始后允许开启）")
+    private Integer closeReplay;
+    @ApiModelProperty("是否关闭分享 【0：开启，1：关闭】默认开启分享（直播开始后不允许修改）")
+    private Integer closeShare;
+    @ApiModelProperty("是否关闭客服 【0：开启，1：关闭】 默认关闭客服（直播开始后允许开启）")
+    private Integer closeKf;
+
+
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/dto/LiveBroadcastEditDto.java

@@ -0,0 +1,50 @@
+package com.slodon.b2b2c.live.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveBroadcastEditDto implements Serializable {
+    @ApiModelProperty("直播间id")
+    private Integer id;
+    @ApiModelProperty(value = "直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "背景图，填入mediaID（mediaID获取后，三天内有效）",required = true)
+    private String coverImg;
+    @ApiModelProperty(value = "直播计划开始时间（开播时间需要在当前时间的10分钟后 并且 开始时间不能在 6 个月后）",required = true)
+    private Long startTime;
+    @ApiModelProperty(value = "直播计划结束时间（开播时间和结束时间间隔不得短于30分钟，不得超过24小时）",required = true)
+    private Long endTime;
+    @ApiModelProperty(value = "主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符",required = true)
+    private String anchorName;
+    @ApiModelProperty(value = "主播微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证,",required = true)
+    private String anchorWechat;
+    @ApiModelProperty("主播副号微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证 ")
+    private String subAnchorWechat;
+    @ApiModelProperty("创建者微信号，不传入则此直播间所有成员可见。传入则此房间仅创建者、管理员、超管、直播间主播可见")
+    private String createrWechat;
+    @ApiModelProperty(value = "分享图，填入mediaID",required = true)
+    private String shareImg;
+    @ApiModelProperty(value = "购物直播频道封面图，填入mediaID",required = true)
+    private String feedsImg;
+    @ApiModelProperty("是否开启官方收录 【1: 开启，0：关闭】，默认开启收录")
+    private Integer isFeedsPublic;
+    @ApiModelProperty(value = "直播间类型 【1: 推流，0：手机直播】",required = true)
+    private Integer type;
+    @ApiModelProperty(value = "是否关闭点赞 【0：开启，1：关闭】（若关闭，观众端将隐藏点赞按钮，直播开始后不允许开启）",required = true)
+    private Integer closeLike;
+    @ApiModelProperty(value = "是否关闭货架 【0：开启，1：关闭】（若关闭，观众端将隐藏商品货架，直播开始后不允许开启）",required = true)
+    private Integer closeGoods;
+    @ApiModelProperty(value = "是否关闭评论 【0：开启，1：关闭】（若关闭，观众端将隐藏评论入口，直播开始后不允许开启）",required = true)
+    private Integer closeComment;
+    @ApiModelProperty("是否关闭回放 【0：开启，1：关闭】默认关闭回放（直播开始后允许开启）")
+    private Integer closeReplay;
+    @ApiModelProperty("是否关闭分享 【0：开启，1：关闭】默认开启分享（直播开始后不允许修改）")
+    private Integer closeShare;
+    @ApiModelProperty("是否关闭客服 【0：开启，1：关闭】 默认关闭客服（直播开始后允许开启）")
+    private Integer closeKf;
+
+
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/example/LiveBroadcastExample.java

@@ -0,0 +1,66 @@
+package com.slodon.b2b2c.live.example;
+
+import com.slodon.b2b2c.core.response.PagerInfo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveBroadcastExample implements Serializable {
+    @ApiModelProperty("直播间id")
+    private String roomId;
+    @ApiModelProperty(value = "直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "背景图，填入mediaID（mediaID获取后，三天内有效）",required = true)
+    private String coverImg;
+    @ApiModelProperty(value = "直播计划开始时间（开播时间需要在当前时间的10分钟后 并且 开始时间不能在 6 个月后）",required = true)
+    private Long startTime;
+    @ApiModelProperty(value = "直播计划结束时间（开播时间和结束时间间隔不得短于30分钟，不得超过24小时）",required = true)
+    private Long endTime;
+    @ApiModelProperty(value = "主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符",required = true)
+    private String anchorName;
+    @ApiModelProperty(value = "主播微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证,",required = true)
+    private String anchorWechat;
+    @ApiModelProperty("主播副号微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证 ")
+    private String subAnchorWechat;
+    @ApiModelProperty("创建者微信号，不传入则此直播间所有成员可见。传入则此房间仅创建者、管理员、超管、直播间主播可见")
+    private String createrWechat;
+    @ApiModelProperty(value = "分享图，填入mediaID",required = true)
+    private String shareImg;
+    @ApiModelProperty(value = "购物直播频道封面图，填入mediaID",required = true)
+    private String feedsImg;
+    @ApiModelProperty("是否开启官方收录 【1: 开启，0：关闭】，默认开启收录")
+    private Integer isFeedsPublic;
+    @ApiModelProperty(value = "直播间类型 【1: 推流，0：手机直播】",required = true)
+    private Integer type;
+    @ApiModelProperty(value = "是否关闭点赞 【0：开启，1：关闭】（若关闭，观众端将隐藏点赞按钮，直播开始后不允许开启）",required = true)
+    private Integer closeLike;
+    @ApiModelProperty(value = "是否关闭货架 【0：开启，1：关闭】（若关闭，观众端将隐藏商品货架，直播开始后不允许开启）",required = true)
+    private Integer closeGoods;
+    @ApiModelProperty(value = "是否关闭评论 【0：开启，1：关闭】（若关闭，观众端将隐藏评论入口，直播开始后不允许开启）",required = true)
+    private Integer closeComment;
+    @ApiModelProperty("是否关闭回放 【0：开启，1：关闭】默认关闭回放（直播开始后允许开启）")
+    private Integer closeReplay;
+    @ApiModelProperty("是否关闭分享 【0：开启，1：关闭】默认开启分享（直播开始后不允许修改）")
+    private Integer closeShare;
+    @ApiModelProperty("是否关闭客服 【0：开启，1：关闭】 默认关闭客服（直播开始后允许开启）")
+    private Integer closeKf;
+
+    //=====================mybatis需要字段============================
+    /**
+     * 排序条件，条件之间用逗号隔开，如果不传则按照goodsId倒序排列
+     */
+    private String orderBy;
+
+    /**
+     * 分组条件
+     */
+    private String groupBy;
+
+    /**
+     * 分页信息
+     */
+    private PagerInfo pager;
+
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/pojo/LiveBroadcast.java

@@ -0,0 +1,50 @@
+package com.slodon.b2b2c.live.pojo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LiveBroadcast implements Serializable {
+    @ApiModelProperty("直播间id")
+    private String roomId;
+    @ApiModelProperty(value = "直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "背景图，填入mediaID（mediaID获取后，三天内有效）",required = true)
+    private String coverImg;
+    @ApiModelProperty(value = "直播计划开始时间（开播时间需要在当前时间的10分钟后 并且 开始时间不能在 6 个月后）",required = true)
+    private Long startTime;
+    @ApiModelProperty(value = "直播计划结束时间（开播时间和结束时间间隔不得短于30分钟，不得超过24小时）",required = true)
+    private Long endTime;
+    @ApiModelProperty(value = "主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符",required = true)
+    private String anchorName;
+    @ApiModelProperty(value = "主播微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证,",required = true)
+    private String anchorWechat;
+    @ApiModelProperty("主播副号微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证 ")
+    private String subAnchorWechat;
+    @ApiModelProperty("创建者微信号，不传入则此直播间所有成员可见。传入则此房间仅创建者、管理员、超管、直播间主播可见")
+    private String createrWechat;
+    @ApiModelProperty(value = "分享图，填入mediaID",required = true)
+    private String shareImg;
+    @ApiModelProperty(value = "购物直播频道封面图，填入mediaID",required = true)
+    private String feedsImg;
+    @ApiModelProperty("是否开启官方收录 【1: 开启，0：关闭】，默认开启收录")
+    private Integer isFeedsPublic = 1;
+    @ApiModelProperty(value = "直播间类型 【1: 推流，0：手机直播】",required = true)
+    private Integer type;
+    @ApiModelProperty(value = "是否关闭点赞 【0：开启，1：关闭】（若关闭，观众端将隐藏点赞按钮，直播开始后不允许开启）",required = true)
+    private Integer closeLike;
+    @ApiModelProperty(value = "是否关闭货架 【0：开启，1：关闭】（若关闭，观众端将隐藏商品货架，直播开始后不允许开启）",required = true)
+    private Integer closeGoods;
+    @ApiModelProperty(value = "是否关闭评论 【0：开启，1：关闭】（若关闭，观众端将隐藏评论入口，直播开始后不允许开启）",required = true)
+    private Integer closeComment;
+    @ApiModelProperty("是否关闭回放 【0：开启，1：关闭】默认关闭回放（直播开始后允许开启）")
+    private Integer closeReplay = 1;
+    @ApiModelProperty("是否关闭分享 【0：开启，1：关闭】默认开启分享（直播开始后不允许修改）")
+    private Integer closeShare = 0;
+    @ApiModelProperty("是否关闭客服 【0：开启，1：关闭】 默认关闭客服（直播开始后允许开启）")
+    private Integer closeKf = 1;
+
+
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/live/vo/LivesVO.java

@@ -0,0 +1,16 @@
+package com.slodon.b2b2c.live.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class LivesVO {
+    @ApiModelProperty("直播间id")
+    private String roomId;
+    @ApiModelProperty(value = "直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符",required = true)
+    private String name;
+    @ApiModelProperty(value = "主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符",required = true)
+    private String anchorName;
+}

b2b2c/b2b2c-entity/src/main/java/com/slodon/b2b2c/video/example/VideoSettingExample.java

@@ -0,0 +1,30 @@
+package com.slodon.b2b2c.video.example;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class VideoSettingExample implements Serializable {
+    /**
+     * 配置名称
+     */
+    private String name;
+    /**
+     * 配置主题，前端展示使用
+     */
+    private String title;
+    /**
+     * 配置值
+     */
+    private String value;
+    /**
+     * 配置描述
+     */
+    private String description;
+    /**
+     * 类型，1-字符串，2-图片，3-固定不能修改，4-开关
+     */
+    private Integer type;
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/controller/live/LiveBroadController.java

@@ -0,0 +1,265 @@
+package com.slodon.b2b2c.controller.live;
+
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.slodon.b2b2c.core.controller.BaseController;
+import com.slodon.b2b2c.core.response.JsonResult;
+import com.slodon.b2b2c.core.response.PageVO;
+import com.slodon.b2b2c.core.response.PagerInfo;
+import com.slodon.b2b2c.core.response.SldResponse;
+import com.slodon.b2b2c.core.util.AssertUtil;
+import com.slodon.b2b2c.core.util.HttpClientUtil;
+import com.slodon.b2b2c.core.util.WebUtil;
+import com.slodon.b2b2c.enums.WxLiveUrlEnum;
+import com.slodon.b2b2c.live.dto.LiveBroadcastDto;
+import com.slodon.b2b2c.live.dto.LiveBroadcastEditDto;
+import com.slodon.b2b2c.live.example.LiveBroadcastExample;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
+import com.slodon.b2b2c.live.vo.LivesVO;
+import com.slodon.b2b2c.model.live.LiveBroadModel;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.beanutils.PropertyUtils;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Api(tags = "admin-微信直播管理")
+@RestController
+@Slf4j
+@RequestMapping("v3/live/broad")
+public class LiveBroadController extends BaseController {
+    private final String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=";//获取access_token地址
+
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+    @Resource
+    private LiveBroadModel liveBroadModel;
+
+    private String getToken() throws Exception {
+        String appId = stringRedisTemplate.opsForValue().get("login_wx_mini_appid");
+        String secret = stringRedisTemplate.opsForValue().get("login_wx_mini_appsecret");
+        String access_token_resp = HttpClientUtil.httpGet(ACCESS_TOKEN_URL + appId + "&secret=" + secret);
+        String access_token = JSON.parseObject(access_token_resp).getString("access_token");
+        AssertUtil.notEmpty(access_token, "微信认证失败");
+        System.out.println("结果access_token: "+access_token);
+        return access_token;
+    }
+
+//    @ApiOperation("添加临时素材")
+//    @PostMapping("/mediaUpload")
+//    public JsonResult mediaUpload(HttpServletRequest request, @RequestBody LiveBroadcastDto liveBroadcastDto) {
+//        try {
+//            String access_token = getToken();
+//            //校验
+//            String url = "https://api.weixin.qq.com/wxaapi/broadcast/room/create?access_token="+access_token;
+//            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(liveBroadcastDto));
+//            JSONObject jsonObject = JSONObject.parseObject(reStr);
+//            String errCode = jsonObject.getString("errcode");
+//            if (!"0".equals(errCode)){
+//                log.warn("直播间添加失败原因："+reStr);
+//                return SldResponse.success("添加失败");
+//            }
+//            liveBroadcastDto.setRoomId(String.valueOf(jsonObject.get("roomId")));
+//            liveBroadModel.broadcastRoomCreate(liveBroadcastDto);
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//        }
+//        return SldResponse.success("添加成功");
+//    }
+
+    @ApiOperation("添加直播间")
+    @PostMapping("/wxBroadcastRoomCreate")
+    public JsonResult wxBroadcastRoomCreate(HttpServletRequest request, @RequestBody LiveBroadcastDto liveBroadcastDto) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.ADD_LIVE.getUrl()+access_token;
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(liveBroadcastDto));
+            JSONObject jsonObject = JSONObject.parseObject(reStr);
+            String errCode = jsonObject.getString("errcode");
+            if (!"0".equals(errCode)){
+                log.warn("直播间添加失败原因："+reStr);
+                return SldResponse.success("添加失败");
+            }
+            liveBroadcastDto.setRoomId(String.valueOf(jsonObject.get("roomId")));
+            liveBroadModel.broadcastRoomCreate(liveBroadcastDto);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("添加成功");
+    }
+
+    @ApiOperation("获取直播列表")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "name", value = "直播名称", paramType = "query"),
+            @ApiImplicitParam(name = "pageSize", value = "分页大小", defaultValue = "20", paramType = "query"),
+            @ApiImplicitParam(name = "current", value = "当前页面位置", defaultValue = "1", paramType = "query")
+    })
+    @GetMapping("/list")
+    public JsonResult<PageVO<LivesVO>> getList(HttpServletRequest request, String name) {
+        PagerInfo pager = WebUtil.handlerPagerInfo(request);
+        LiveBroadcastExample example = new LiveBroadcastExample();
+        example.setName(name);
+        List<LiveBroadcast> livesList = liveBroadModel.getLivesList(example, pager);
+        List<LivesVO> livesVOS = new ArrayList<>();
+        if (!CollectionUtils.isEmpty(livesList)) {
+            livesList.forEach(node->{
+                LivesVO vo = new LivesVO();
+                vo.setName(node.getName());
+                vo.setAnchorName(node.getAnchorName());
+                vo.setRoomId(node.getRoomId());
+                livesVOS.add(vo);
+            });
+        }
+        return SldResponse.success(new PageVO<>(livesVOS, pager));
+    }
+
+    @ApiOperation("获取直播间列表及直播间信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "start", value = "起始房间，0表示从第1个房间开始拉取", paramType = "query"),
+            @ApiImplicitParam(name = "limit", value = "每次拉取的房间数量，建议100以内", paramType = "query")
+    })
+    @GetMapping("/wxGetLiveInfoList")
+    public JsonResult wxGetLiveInfoList(HttpServletRequest request, Integer start,Integer limit) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.GET_LIVE_LIST.getUrl()+access_token;
+            Map map = new HashMap();
+            map.put("start",start);
+            map.put("limit",limit);
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(map));
+            return SldResponse.success(reStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("查询失败");
+    }
+
+    @ApiOperation("获取直播间回放")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "roomId", value = "房间ID", paramType = "query"),
+            @ApiImplicitParam(name = "start", value = "起始房间，0表示从第1个房间开始拉取", paramType = "query"),
+            @ApiImplicitParam(name = "limit", value = "每次拉取的房间数量，建议100以内", paramType = "query")
+    })
+    @GetMapping("/wxGetLivePlayback")
+    public JsonResult wxGetLivePlayback(HttpServletRequest request,Integer roomId, Integer start,Integer limit) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.GET_LIVE_PLAYBACK.getUrl()+access_token;
+            Map map = new HashMap();
+            map.put("action","get_replay");
+            map.put("room_id",roomId);
+            map.put("start",start);
+            map.put("limit",limit);
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(map));
+            return SldResponse.success(reStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("查询失败");
+    }
+
+    @ApiOperation("直播间导入商品")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "ids", value = "[商品 ID]", paramType = "query"),
+            @ApiImplicitParam(name = "roomId", value = "房间ID", paramType = "query"),
+    })
+    @GetMapping("/wxAddLiveGoods")
+    public JsonResult wxAddLiveGoods(HttpServletRequest request,Integer[] ids,Integer roomId) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.ADD_LIVE_GOODS.getUrl()+access_token;
+            Map map = new HashMap();
+            map.put("ids",ids);
+            map.put("roomId",roomId);
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(map));
+            return SldResponse.success(reStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("查询失败");
+    }
+
+    @ApiOperation("删除直播间")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "roomId", value = "房间ID", paramType = "query"),
+    })
+    @GetMapping("/wxDelLive")
+    public JsonResult wxDelLive(HttpServletRequest request,Integer roomId) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.DEL_LIVE.getUrl()+access_token;
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(new HashMap<>().put("id",roomId)));
+            return SldResponse.success(reStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("查询失败");
+    }
+
+    @ApiOperation("编辑直播间")
+    @PostMapping("/wxBroadcastRoomEdit")
+    public JsonResult wxBroadcastRoomEdit(HttpServletRequest request, @RequestBody LiveBroadcastEditDto liveBroadcastEditDto) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.EDIT_LIVE.getUrl()+access_token;
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(liveBroadcastEditDto));
+            JSONObject jsonObject = JSONObject.parseObject(reStr);
+            String errCode = jsonObject.getString("errcode");
+            if (!"0".equals(errCode)){
+                log.warn("直播间编辑失败原因："+reStr);
+                return SldResponse.success("编辑失败");
+            }
+            LiveBroadcast live_broadcast = new LiveBroadcast();
+            PropertyUtils.copyProperties(live_broadcast,liveBroadcastEditDto);
+            live_broadcast.setRoomId(String.valueOf(liveBroadcastEditDto.getId()));
+            liveBroadModel.broadcastRoomEdit(live_broadcast);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("编辑成功");
+    }
+
+    @ApiOperation("获取直播间推流地址")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "roomId", value = "房间ID", paramType = "query"),
+    })
+    @GetMapping("/wxGetPushUrl")
+    public JsonResult wxGetPushUrl(HttpServletRequest request,Integer roomId) {
+        try {
+            String access_token = getToken();
+            //校验
+            String url = WxLiveUrlEnum.GET_PUSH_LIVE.getUrl()+access_token;
+            String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(new HashMap<>().put("id",roomId)));
+            return SldResponse.success(reStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SldResponse.success("查询失败");
+    }
+
+    public static void main(String[] args) {
+        Map map = new HashMap();
+        map.put("start",1);
+        map.put("limit",10);
+        System.out.println(JSON.toJSONString(map));
+    }
+
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/controller/video/admin/AdminVideoSettingController.java

@@ -1,21 +1,30 @@
 package com.slodon.b2b2c.controller.video.admin;
 
 
+import com.alibaba.fastjson.JSON;
 import com.slodon.b2b2c.core.controller.BaseController;
 import com.slodon.b2b2c.core.response.JsonResult;
 import com.slodon.b2b2c.core.response.SldResponse;
 import com.slodon.b2b2c.core.util.AssertUtil;
+import com.slodon.b2b2c.core.util.HttpClientUtil;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
 import com.slodon.b2b2c.model.system.BillModel;
 import com.slodon.b2b2c.model.video.AdminVideoSettingModel;
 import com.slodon.b2b2c.video.pojo.VideoSetting;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import javax.imageio.ImageIO;
+import java.awt.image.BufferedImage;
+import java.io.PrintWriter;
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.util.List;
 
 @Api(tags = "admin-直播管理")
@@ -39,4 +48,76 @@ public class AdminVideoSettingController extends BaseController {
         return SldResponse.success();
     }
 
+    public static void main(String[] args) throws Exception {
+        final String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=";//获取access_token地址
+        String access_token_resp = HttpClientUtil.httpGet(ACCESS_TOKEN_URL + "wx43aba958092afe0c" + "&secret=" + "647d35cc24fc7996003168d44ea91a43");
+        String access_token = JSON.parseObject(access_token_resp).getString("access_token");
+        AssertUtil.notEmpty(access_token, "微信认证失败");
+        System.out.println("结果access_token: "+access_token);
+        String url = "https://api.weixin.qq.com/wxaapi/broadcast/room/create?access_token="+access_token;
+        LiveBroadcast t = new LiveBroadcast();
+        t.setName("测试直播间");
+        t.setCoverImg("Oftl3yAWV5lJIHHMpprnVi5Ad8nnQtGmkbYgspS1mJxMqPSzJlV3cZPOq-V6_yo8");
+        t.setStartTime(System.currentTimeMillis()/1000+700);
+        t.setEndTime(System.currentTimeMillis()/1000+5000);
+        t.setAnchorName("主播昵称");
+        t.setAnchorWechat("feiskyend");
+        t.setShareImg("Oftl3yAWV5lJIHHMpprnVlJvIjvSoldaVmDE5-hzb46CdTAEO3GhyvoJZsGGkA6z");
+        t.setFeedsImg("Oftl3yAWV5lJIHHMpprnVgmkSTWNVnNTCCM6FvfZQqG8nlAiiSSY4ssBzLFXro4E");
+        t.setType(1);
+        t.setCloseLike(0);
+        t.setCloseGoods(0);
+        t.setCloseComment(0);
+        System.out.println("json: "+JSON.toJSONString(t));
+
+        String reStr = HttpClientUtil.sendJsonPostNew(url,JSON.toJSONString(t));
+        System.out.println("结果： "+reStr);
+        /*System.out.println(System.currentTimeMillis()+1800000);
+        System.out.println(System.currentTimeMillis()+3600000);*/
+       /* //定义接收数据
+        JSONObject result = new JSONObject();
+
+        HttpPost httpPost = new HttpPost(url);
+        CloseableHttpClient client = HttpClients.createDefault();
+//请求参数转JOSN字符串
+        StringEntity entity = new StringEntity(t.toString(), "UTF-8");
+        entity.setContentEncoding("UTF-8");
+        entity.setContentType("application/json");
+        httpPost.setEntity(entity);
+        try {
+            HttpResponse response = client.execute(httpPost);
+            if (response.getStatusLine().getStatusCode() == 200) {
+                result = JSON.parseObject(EntityUtils.toString(response.getEntity(), "UTF-8"));
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+            result.put("error", "连接错误！");
+        }
+        System.out.println(result.toJSONString());*/
+    }
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+
+    private BufferedImage get(String jsonStr) throws Exception {
+        final String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=";//获取access_token地址
+        String appId = stringRedisTemplate.opsForValue().get("login_wx_mini_appid");
+        String secret = stringRedisTemplate.opsForValue().get("login_wx_mini_appsecret");
+
+        //获取小程序 access_token
+        String access_token_resp = HttpClientUtil.httpGet(ACCESS_TOKEN_URL + appId + "&secret=" + secret);
+        String access_token = JSON.parseObject(access_token_resp).getString("access_token");
+        AssertUtil.notEmpty(access_token, "微信认证失败");
+
+        URL url = new URL("https://api.weixin.qq.com/wxaapi/broadcast/room/create?access_token=" + access_token);
+        HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
+        httpURLConnection.setRequestMethod("POST");// 提交模式
+        httpURLConnection.setDoOutput(true);
+        httpURLConnection.setDoInput(true);
+        PrintWriter printWriter = new PrintWriter(httpURLConnection.getOutputStream());
+        //构造json参数
+        printWriter.write(jsonStr);
+        printWriter.flush();
+
+        return ImageIO.read(httpURLConnection.getInputStream());
+    }
 }

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/dao/write/live/LiveBroadWriteMapper.java

@@ -0,0 +1,8 @@
+package com.slodon.b2b2c.dao.write.live;
+
+import com.slodon.b2b2c.core.database.BaseWriteMapper;
+import com.slodon.b2b2c.live.example.LiveBroadcastExample;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
+
+public interface LiveBroadWriteMapper extends BaseWriteMapper<LiveBroadcast, LiveBroadcastExample> {
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/dao/write/video/VideoSettingWriteMapper.java

@@ -0,0 +1,8 @@
+package com.slodon.b2b2c.dao.write.video;
+
+import com.slodon.b2b2c.core.database.BaseReadMapper;
+import com.slodon.b2b2c.video.example.VideoSettingExample;
+import com.slodon.b2b2c.video.pojo.VideoSetting;
+
+public interface VideoSettingWriteMapper extends BaseReadMapper<VideoSetting, VideoSettingExample> {
+}

b2b2c/b2b2c-web/src/main/java/com/slodon/b2b2c/model/live/LiveBroadModel.java

@@ -0,0 +1,54 @@
+package com.slodon.b2b2c.model.live;
+
+import com.slodon.b2b2c.core.response.PagerInfo;
+import com.slodon.b2b2c.dao.write.live.LiveBroadWriteMapper;
+import com.slodon.b2b2c.live.dto.LiveBroadcastDto;
+import com.slodon.b2b2c.live.example.LiveBroadcastExample;
+import com.slodon.b2b2c.live.pojo.LiveBroadcast;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.beanutils.PropertyUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@Slf4j
+public class LiveBroadModel {
+
+    @Autowired
+    private LiveBroadWriteMapper liveBroadWriteMapper;
+
+    public void broadcastRoomCreate(LiveBroadcastDto liveBroadcastDto) {
+
+        LiveBroadcast live_broadcast = new LiveBroadcast();
+        try {
+            PropertyUtils.copyProperties(live_broadcast,liveBroadcastDto);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        liveBroadWriteMapper.insert(live_broadcast);
+    }
+
+    public void broadcastRoomEdit(LiveBroadcast live_broadcast) {
+        liveBroadWriteMapper.updateByPrimaryKeySelective(live_broadcast);
+    }
+
+    /**
+     * 根据条件获取直播公共信息表（SPU）列表
+     *
+     * @param example 查询条件信息
+     * @param pager   分页信息
+     * @return
+     */
+    public List<LiveBroadcast> getLivesList(LiveBroadcastExample example, PagerInfo pager) {
+        List<LiveBroadcast> goodsList;
+        if (pager != null) {
+            pager.setRowsCount(liveBroadWriteMapper.countByExample(example));
+            goodsList = liveBroadWriteMapper.listPageByExample(example, pager.getStart(), pager.getPageSize());
+        } else {
+            goodsList = liveBroadWriteMapper.listByExample(example);
+        }
+        return goodsList;
+    }
+}

b2b2c/b2b2c-web/src/main/resources/mapper/read/Live/LiveBroadReadMapper.xml

@@ -0,0 +1,470 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.slodon.b2b2c.dao.write.live.LiveBroadWriteMapper">
+  <resultMap id="resultMap" type="com.slodon.b2b2c.live.pojo.LiveBroadcast">
+    <id column="roomId" property="roomId" />
+    <result column="name" property="name" />
+    <result column="name" property="name" />
+    <result column="coverImg" property="coverImg" />
+    <result column="startTime" property="startTime" />
+    <result column="endTime" property="endTime" />
+    <result column="anchorName" property="anchorName" />
+    <result column="anchorWechat" property="anchorWechat" />
+    <result column="subAnchorWechat" property="subAnchorWechat" />
+    <result column="createrWechat" property="createrWechat" />
+    <result column="shareImg" property="shareImg" />
+    <result column="feedsImg" property="feedsImg" />
+    <result column="isFeedsPublic" property="isFeedsPublic" />
+    <result column="type" property="type" />
+    <result column="closeLike" property="closeLike" />
+    <result column="closeGoods" property="closeGoods" />
+    <result column="closeComment" property="closeComment" />
+    <result column="closeReplay" property="closeReplay" />
+    <result column="closeShare" property="closeShare" />
+    <result column="closeKf" property="closeKf" />
+  </resultMap>
+
+  <!--除主键外的所有字段，用于插入操作-->
+  <sql id="columns">
+    <trim suffixOverrides=",">
+      <if test="roomId != null">
+        roomId,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="coverImg != null">
+        coverImg,
+      </if>
+      <if test="startTime != null">
+        startTime,
+      </if>
+      <if test="endTime != null">
+        endTime,
+      </if>
+      <if test="anchorName != null">
+        anchorName,
+      </if>
+      <if test="anchorWechat != null">
+        anchorWechat,
+      </if>
+      <if test="subAnchorWechat != null">
+        subAnchorWechat,
+      </if>
+      <if test="createrWechat != null">
+        createrWechat,
+      </if>
+      <if test="shareImg != null">
+        shareImg,
+      </if>
+      <if test="feedsImg != null">
+        feedsImg,
+      </if>
+      <if test="isFeedsPublic != null">
+        isFeedsPublic,
+      </if>
+      <if test="type != null">
+        type,
+      </if>
+      <if test="closeLike != null">
+        closeLike,
+      </if>
+      <if test="closeGoods != null">
+        closeGoods,
+      </if>
+      <if test="closeComment != null">
+        closeComment,
+      </if>
+      <if test="closeReplay != null">
+        closeReplay,
+      </if>
+      <if test="closeShare != null">
+        closeShare,
+      </if>
+      <if test="closeKf != null">
+        closeKf,
+      </if>
+    </trim>
+  </sql>
+  <!--按照主键值进行操作-->
+  <sql id="pkWhere">
+    WHERE roomId = #{primaryKey}
+  </sql>
+  <!--操作条件-->
+  <sql id="whereCondition">
+    <if test="example != null">
+      <trim prefix="WHERE" prefixOverrides="AND|OR">
+        <if test="example.roomId != null">
+          AND roomId = ${example.roomId}
+        </if>
+        <if test="example.name != null">
+          AND name like concat('%',#{example.name},'%')
+        </if>
+        <if test="example.coverImg != null">
+          AND coverImg = ${example.coverImg}
+        </if>
+        <if test="example.startTime != null">
+          AND startTime = ${example.startTime}
+        </if>
+        <if test="example.endTime != null">
+          AND endTime = ${example.endTime}
+        </if>
+        <if test="example.anchorName != null">
+          AND anchorName = ${example.anchorName}
+        </if>
+        <if test="example.anchorWechat != null">
+          AND anchorWechat = ${example.anchorWechat}
+        </if>
+        <if test="example.subAnchorWechat != null">
+          AND subAnchorWechat = ${example.subAnchorWechat}
+        </if>
+        <if test="example.createrWechat != null">
+          AND createrWechat = ${example.createrWechat}
+        </if>
+        <if test="example.shareImg != null">
+          AND shareImg = ${example.shareImg}
+        </if>
+        <if test="example.feedsImg != null">
+          AND feedsImg = ${example.feedsImg}
+        </if>
+        <if test="example.isFeedsPublic != null">
+          AND isFeedsPublic = ${example.isFeedsPublic}
+        </if>
+        <if test="example.type != null">
+          AND type = ${example.type}
+        </if>
+        <if test="example.closeLike != null">
+          AND closeLike = ${example.closeLike}
+        </if>
+        <if test="example.closeGoods != null">
+          AND closeGoods = ${example.closeGoods}
+        </if>
+        <if test="example.closeComment != null">
+          AND closeComment = ${example.closeComment}
+        </if>
+        <if test="example.closeReplay != null">
+          AND closeReplay = ${example.closeReplay}
+        </if>
+        <if test="example.closeShare != null">
+          AND closeShare = ${example.closeShare}
+        </if>
+        <if test="example.closeKf != null">
+          AND closeKf = ${example.closeKf}
+        </if>
+
+      </trim>
+    </if>
+  </sql>
+  <!--排序条件-->
+  <sql id="orderBy">
+    ORDER BY roomId DESC
+  </sql>
+  <sql id="orderByOther">
+    order by ${example.orderBy}
+  </sql>
+  <!--分组条件-->
+  <sql id="groupBy">
+    group by ${example.groupBy}
+  </sql>
+  <!--分页条件-->
+  <sql id="limit">
+    <if test="size != null and size &gt; 0">
+      limit #{startRow},#{size}
+    </if>
+  </sql>
+  <!--查询符合条件的记录数-->
+  <select id="countByExample" parameterType="com.slodon.b2b2c.live.example.LiveBroadcastExample" resultType="java.lang.Integer">
+    SELECT
+      COUNT(*)
+    FROM live_broadcast
+    <include refid="whereCondition" />
+  </select>
+  <!--根据主键查询记录-->
+  <select id="getByPrimaryKey" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_broadcast
+    <include refid="pkWhere" />
+  </select>
+  <!--查询符合条件的记录(所有字段)-->
+  <select id="listByExample" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(所有字段)-->
+  <select id="listPageByExample" resultMap="resultMap">
+    SELECT
+      *
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--查询符合条件的记录(指定字段)-->
+  <select id="listFieldsByExample" resultMap="resultMap">
+    SELECT
+      ${fields}
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(指定字段)-->
+  <select id="listFieldsPageByExample" resultMap="resultMap">
+    SELECT
+      ${fields}
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--根据条件删除记录，可多条删除-->
+  <delete id="deleteByExample">
+    DELETE FROM live_broadcast
+    <include refid="whereCondition" />
+  </delete>
+  <!--根据主键删除记录-->
+  <delete id="deleteByPrimaryKey">
+    DELETE FROM live_broadcast
+    <include refid="pkWhere" />
+  </delete>
+  <!--插入一条记录-->
+  <insert id="insert" keyColumn="id" keyProperty="id" parameterType="com.slodon.b2b2c.live.pojo.LiveBroadcast" useGeneratedKeys="true">
+    INSERT INTO live_broadcast(
+    <include refid="columns" />
+    )
+    VALUES(
+    <trim suffixOverrides=",">
+      <if test="roomId != null">
+        ${roomId},
+      </if>
+      <if test="name != null">
+        ${name},
+      </if>
+      <if test="coverImg != null">
+        ${coverImg},
+      </if>
+      <if test="startTime != null">
+        ${startTime},
+      </if>
+      <if test="endTime != null">
+        ${endTime},
+      </if>
+      <if test="anchorName != null">
+        ${anchorName},
+      </if>
+      <if test="anchorWechat != null">
+        ${anchorWechat},
+      </if>
+      <if test="subAnchorWechat != null">
+        ${subAnchorWechat},
+      </if>
+      <if test="createrWechat != null">
+        ${createrWechat},
+      </if>
+      <if test="shareImg != null">
+        ${shareImg},
+      </if>
+      <if test="feedsImg != null">
+        ${feedsImg},
+      </if>
+      <if test="isFeedsPublic != null">
+        ${isFeedsPublic},
+      </if>
+      <if test="type != null">
+        ${type},
+      </if>
+      <if test="closeLike != null">
+        ${closeLike},
+      </if>
+      <if test="closeGoods != null">
+        ${closeGoods},
+      </if>
+      <if test="closeComment != null">
+        ${closeComment},
+      </if>
+      <if test="closeReplay != null">
+        ${closeReplay},
+      </if>
+      <if test="closeShare != null">
+        ${closeShare},
+      </if>
+      <if test="closeKf != null">
+        ${closeKf},
+      </if>
+
+    </trim>
+    )
+  </insert>
+  <!--按条件更新记录中不为空的字段-->
+  <update id="updateByExampleSelective">
+    UPDATE live_broadcast
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="record.roomId != null">
+        AND roomId = #{record.roomId},
+      </if>
+      <if test="record.name != null">
+        AND name = #{record.name},
+      </if>
+      <if test="record.coverImg != null">
+        AND coverImg = #{record.coverImg},
+      </if>
+      <if test="record.startTime != null">
+        AND startTime = #{record.startTime},
+      </if>
+      <if test="record.endTime != null">
+        AND endTime = #{record.endTime},
+      </if>
+      <if test="record.anchorName != null">
+        AND anchorName = #{record.anchorName},
+      </if>
+      <if test="record.anchorWechat != null">
+        AND anchorWechat = #{record.anchorWechat},
+      </if>
+      <if test="record.subAnchorWechat != null">
+        AND subAnchorWechat = #{record.subAnchorWechat},
+      </if>
+      <if test="record.createrWechat != null">
+        AND createrWechat = #{record.createrWechat},
+      </if>
+      <if test="record.shareImg != null">
+        AND shareImg = #{record.shareImg},
+      </if>
+      <if test="record.feedsImg != null">
+        AND feedsImg = #{record.feedsImg},
+      </if>
+      <if test="record.isFeedsPublic != null">
+        AND isFeedsPublic = #{record.isFeedsPublic},
+      </if>
+      <if test="record.type != null">
+        AND type = #{record.type},
+      </if>
+      <if test="record.closeLike != null">
+        AND closeLike = #{record.closeLike},
+      </if>
+      <if test="record.closeGoods != null">
+        AND closeGoods = #{record.closeGoods},
+      </if>
+      <if test="record.closeComment != null">
+        AND closeComment = #{record.closeComment},
+      </if>
+      <if test="record.closeReplay != null">
+        AND closeReplay = #{record.closeReplay},
+      </if>
+      <if test="record.closeShare != null">
+        AND closeShare = #{record.closeShare},
+      </if>
+      <if test="record.closeKf != null">
+        AND closeKf = #{record.closeKf},
+      </if>
+
+    </trim>
+    <include refid="whereCondition" />
+  </update>
+  <!--按照主键更新记录中不为空的字段-->
+  <update id="updateByPrimaryKeySelective">
+    UPDATE live_broadcast
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="roomId != null">
+        roomId = #{roomId}
+      </if>
+      <if test="name != null">
+        name = #{name}
+      </if>
+      <if test="coverImg != null">
+        coverImg = #{coverImg}
+      </if>
+      <if test="startTime != null">
+        startTime = #{startTime}
+      </if>
+      <if test="endTime != null">
+        endTime = #{endTime}
+      </if>
+      <if test="anchorName != null">
+        anchorName = #{anchorName}
+      </if>
+      <if test="anchorWechat != null">
+        anchorWechat = #{anchorWechat}
+      </if>
+      <if test="subAnchorWechat != null">
+        subAnchorWechat = #{subAnchorWechat}
+      </if>
+      <if test="createrWechat != null">
+        createrWechat = #{createrWechat}
+      </if>
+      <if test="shareImg != null">
+        shareImg = #{shareImg}
+      </if>
+      <if test="feedsImg != null">
+        feedsImg = #{feedsImg}
+      </if>
+      <if test="isFeedsPublic != null">
+        isFeedsPublic = #{isFeedsPublic}
+      </if>
+      <if test="type != null">
+        type = #{type}
+      </if>
+      <if test="closeLike != null">
+        closeLike = #{closeLike}
+      </if>
+      <if test="closeGoods != null">
+        closeGoods = #{closeGoods}
+      </if>
+      <if test="closeComment != null">
+        closeComment = #{closeComment}
+      </if>
+      <if test="closeReplay != null">
+        closeReplay = #{closeReplay}
+      </if>
+      <if test="closeShare != null">
+        closeShare = #{closeShare}
+      </if>
+      <if test="closeKf != null">
+        closeKf = #{closeKf}
+      </if>
+    </trim>
+    WHERE roomId = #{roomId}
+  </update>
+</mapper>

b2b2c/b2b2c-web/src/main/resources/mapper/write/Live/LiveBroadWriteMapper.xml

@@ -0,0 +1,470 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.slodon.b2b2c.dao.write.live.LiveBroadWriteMapper">
+  <resultMap id="resultMap" type="com.slodon.b2b2c.live.pojo.LiveBroadcast">
+    <id column="roomId" property="roomId" />
+    <result column="name" property="name" />
+    <result column="name" property="name" />
+    <result column="coverImg" property="coverImg" />
+    <result column="startTime" property="startTime" />
+    <result column="endTime" property="endTime" />
+    <result column="anchorName" property="anchorName" />
+    <result column="anchorWechat" property="anchorWechat" />
+    <result column="subAnchorWechat" property="subAnchorWechat" />
+    <result column="createrWechat" property="createrWechat" />
+    <result column="shareImg" property="shareImg" />
+    <result column="feedsImg" property="feedsImg" />
+    <result column="isFeedsPublic" property="isFeedsPublic" />
+    <result column="type" property="type" />
+    <result column="closeLike" property="closeLike" />
+    <result column="closeGoods" property="closeGoods" />
+    <result column="closeComment" property="closeComment" />
+    <result column="closeReplay" property="closeReplay" />
+    <result column="closeShare" property="closeShare" />
+    <result column="closeKf" property="closeKf" />
+  </resultMap>
+
+  <!--除主键外的所有字段，用于插入操作-->
+  <sql id="columns">
+    <trim suffixOverrides=",">
+      <if test="roomId != null">
+        roomId,
+      </if>
+      <if test="name != null">
+        name,
+      </if>
+      <if test="coverImg != null">
+        coverImg,
+      </if>
+      <if test="startTime != null">
+        startTime,
+      </if>
+      <if test="endTime != null">
+        endTime,
+      </if>
+      <if test="anchorName != null">
+        anchorName,
+      </if>
+      <if test="anchorWechat != null">
+        anchorWechat,
+      </if>
+      <if test="subAnchorWechat != null">
+        subAnchorWechat,
+      </if>
+      <if test="createrWechat != null">
+        createrWechat,
+      </if>
+      <if test="shareImg != null">
+        shareImg,
+      </if>
+      <if test="feedsImg != null">
+        feedsImg,
+      </if>
+      <if test="isFeedsPublic != null">
+        isFeedsPublic,
+      </if>
+      <if test="type != null">
+        type,
+      </if>
+      <if test="closeLike != null">
+        closeLike,
+      </if>
+      <if test="closeGoods != null">
+        closeGoods,
+      </if>
+      <if test="closeComment != null">
+        closeComment,
+      </if>
+      <if test="closeReplay != null">
+        closeReplay,
+      </if>
+      <if test="closeShare != null">
+        closeShare,
+      </if>
+      <if test="closeKf != null">
+        closeKf,
+      </if>
+    </trim>
+  </sql>
+  <!--按照主键值进行操作-->
+  <sql id="pkWhere">
+    WHERE roomId = #{primaryKey}
+  </sql>
+  <!--操作条件-->
+  <sql id="whereCondition">
+    <if test="example != null">
+      <trim prefix="WHERE" prefixOverrides="AND|OR">
+        <if test="example.roomId != null">
+          AND roomId = ${example.roomId}
+        </if>
+        <if test="example.name != null">
+          AND name like concat('%',#{example.name},'%')
+        </if>
+        <if test="example.coverImg != null">
+          AND coverImg = ${example.coverImg}
+        </if>
+        <if test="example.startTime != null">
+          AND startTime = ${example.startTime}
+        </if>
+        <if test="example.endTime != null">
+          AND endTime = ${example.endTime}
+        </if>
+        <if test="example.anchorName != null">
+          AND anchorName = ${example.anchorName}
+        </if>
+        <if test="example.anchorWechat != null">
+          AND anchorWechat = ${example.anchorWechat}
+        </if>
+        <if test="example.subAnchorWechat != null">
+          AND subAnchorWechat = ${example.subAnchorWechat}
+        </if>
+        <if test="example.createrWechat != null">
+          AND createrWechat = ${example.createrWechat}
+        </if>
+        <if test="example.shareImg != null">
+          AND shareImg = ${example.shareImg}
+        </if>
+        <if test="example.feedsImg != null">
+          AND feedsImg = ${example.feedsImg}
+        </if>
+        <if test="example.isFeedsPublic != null">
+          AND isFeedsPublic = ${example.isFeedsPublic}
+        </if>
+        <if test="example.type != null">
+          AND type = ${example.type}
+        </if>
+        <if test="example.closeLike != null">
+          AND closeLike = ${example.closeLike}
+        </if>
+        <if test="example.closeGoods != null">
+          AND closeGoods = ${example.closeGoods}
+        </if>
+        <if test="example.closeComment != null">
+          AND closeComment = ${example.closeComment}
+        </if>
+        <if test="example.closeReplay != null">
+          AND closeReplay = ${example.closeReplay}
+        </if>
+        <if test="example.closeShare != null">
+          AND closeShare = ${example.closeShare}
+        </if>
+        <if test="example.closeKf != null">
+          AND closeKf = ${example.closeKf}
+        </if>
+
+      </trim>
+    </if>
+  </sql>
+  <!--排序条件-->
+  <sql id="orderBy">
+    ORDER BY roomId DESC
+  </sql>
+  <sql id="orderByOther">
+    order by ${example.orderBy}
+  </sql>
+  <!--分组条件-->
+  <sql id="groupBy">
+    group by ${example.groupBy}
+  </sql>
+  <!--分页条件-->
+  <sql id="limit">
+    <if test="size != null and size &gt; 0">
+      limit #{startRow},#{size}
+    </if>
+  </sql>
+  <!--查询符合条件的记录数-->
+  <select id="countByExample" parameterType="com.slodon.b2b2c.live.example.LiveBroadcastExample" resultType="java.lang.Integer">
+    SELECT
+    COUNT(*)
+    FROM live_broadcast
+    <include refid="whereCondition" />
+  </select>
+  <!--根据主键查询记录-->
+  <select id="getByPrimaryKey" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_broadcast
+    <include refid="pkWhere" />
+  </select>
+  <!--查询符合条件的记录(所有字段)-->
+  <select id="listByExample" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(所有字段)-->
+  <select id="listPageByExample" resultMap="resultMap">
+    SELECT
+    *
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--查询符合条件的记录(指定字段)-->
+  <select id="listFieldsByExample" resultMap="resultMap">
+    SELECT
+    ${fields}
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+  </select>
+  <!--分页查询符合条件的记录(指定字段)-->
+  <select id="listFieldsPageByExample" resultMap="resultMap">
+    SELECT
+    ${fields}
+    FROM live_broadcast
+    <include refid="whereCondition" />
+    <if test="example.groupBy != null">
+      <include refid="groupBy" />
+    </if>
+    <choose>
+      <when test="example.orderBy != null">
+        <include refid="orderByOther" />
+      </when>
+      <otherwise>
+        <include refid="orderBy" />
+      </otherwise>
+    </choose>
+    <include refid="limit" />
+  </select>
+  <!--根据条件删除记录，可多条删除-->
+  <delete id="deleteByExample">
+    DELETE FROM live_broadcast
+    <include refid="whereCondition" />
+  </delete>
+  <!--根据主键删除记录-->
+  <delete id="deleteByPrimaryKey">
+    DELETE FROM live_broadcast
+    <include refid="pkWhere" />
+  </delete>
+  <!--插入一条记录-->
+  <insert id="insert" keyColumn="id" keyProperty="id" parameterType="com.slodon.b2b2c.live.pojo.LiveBroadcast" useGeneratedKeys="true">
+    INSERT INTO live_broadcast(
+    <include refid="columns" />
+    )
+    VALUES(
+    <trim suffixOverrides=",">
+      <if test="roomId != null">
+        ${roomId},
+      </if>
+      <if test="name != null">
+        ${name},
+      </if>
+      <if test="coverImg != null">
+        ${coverImg},
+      </if>
+      <if test="startTime != null">
+        ${startTime},
+      </if>
+      <if test="endTime != null">
+        ${endTime},
+      </if>
+      <if test="anchorName != null">
+        ${anchorName},
+      </if>
+      <if test="anchorWechat != null">
+        ${anchorWechat},
+      </if>
+      <if test="subAnchorWechat != null">
+        ${subAnchorWechat},
+      </if>
+      <if test="createrWechat != null">
+        ${createrWechat},
+      </if>
+      <if test="shareImg != null">
+        ${shareImg},
+      </if>
+      <if test="feedsImg != null">
+        ${feedsImg},
+      </if>
+      <if test="isFeedsPublic != null">
+        ${isFeedsPublic},
+      </if>
+      <if test="type != null">
+        ${type},
+      </if>
+      <if test="closeLike != null">
+        ${closeLike},
+      </if>
+      <if test="closeGoods != null">
+        ${closeGoods},
+      </if>
+      <if test="closeComment != null">
+        ${closeComment},
+      </if>
+      <if test="closeReplay != null">
+        ${closeReplay},
+      </if>
+      <if test="closeShare != null">
+        ${closeShare},
+      </if>
+      <if test="closeKf != null">
+        ${closeKf},
+      </if>
+
+    </trim>
+    )
+  </insert>
+  <!--按条件更新记录中不为空的字段-->
+  <update id="updateByExampleSelective">
+    UPDATE live_broadcast
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="record.roomId != null">
+        AND roomId = #{record.roomId},
+      </if>
+      <if test="record.name != null">
+        AND name = #{record.name},
+      </if>
+      <if test="record.coverImg != null">
+        AND coverImg = #{record.coverImg},
+      </if>
+      <if test="record.startTime != null">
+        AND startTime = #{record.startTime},
+      </if>
+      <if test="record.endTime != null">
+        AND endTime = #{record.endTime},
+      </if>
+      <if test="record.anchorName != null">
+        AND anchorName = #{record.anchorName},
+      </if>
+      <if test="record.anchorWechat != null">
+        AND anchorWechat = #{record.anchorWechat},
+      </if>
+      <if test="record.subAnchorWechat != null">
+        AND subAnchorWechat = #{record.subAnchorWechat},
+      </if>
+      <if test="record.createrWechat != null">
+        AND createrWechat = #{record.createrWechat},
+      </if>
+      <if test="record.shareImg != null">
+        AND shareImg = #{record.shareImg},
+      </if>
+      <if test="record.feedsImg != null">
+        AND feedsImg = #{record.feedsImg},
+      </if>
+      <if test="record.isFeedsPublic != null">
+        AND isFeedsPublic = #{record.isFeedsPublic},
+      </if>
+      <if test="record.type != null">
+        AND type = #{record.type},
+      </if>
+      <if test="record.closeLike != null">
+        AND closeLike = #{record.closeLike},
+      </if>
+      <if test="record.closeGoods != null">
+        AND closeGoods = #{record.closeGoods},
+      </if>
+      <if test="record.closeComment != null">
+        AND closeComment = #{record.closeComment},
+      </if>
+      <if test="record.closeReplay != null">
+        AND closeReplay = #{record.closeReplay},
+      </if>
+      <if test="record.closeShare != null">
+        AND closeShare = #{record.closeShare},
+      </if>
+      <if test="record.closeKf != null">
+        AND closeKf = #{record.closeKf},
+      </if>
+
+    </trim>
+    <include refid="whereCondition" />
+  </update>
+  <!--按照主键更新记录中不为空的字段-->
+  <update id="updateByPrimaryKeySelective">
+    UPDATE live_broadcast
+    <trim prefix="SET" suffixOverrides=",">
+      <if test="roomId != null">
+        roomId = #{roomId}
+      </if>
+      <if test="name != null">
+        name = #{name}
+      </if>
+      <if test="coverImg != null">
+        coverImg = #{coverImg}
+      </if>
+      <if test="startTime != null">
+        startTime = #{startTime}
+      </if>
+      <if test="endTime != null">
+        endTime = #{endTime}
+      </if>
+      <if test="anchorName != null">
+        anchorName = #{anchorName}
+      </if>
+      <if test="anchorWechat != null">
+        anchorWechat = #{anchorWechat}
+      </if>
+      <if test="subAnchorWechat != null">
+        subAnchorWechat = #{subAnchorWechat}
+      </if>
+      <if test="createrWechat != null">
+        createrWechat = #{createrWechat}
+      </if>
+      <if test="shareImg != null">
+        shareImg = #{shareImg}
+      </if>
+      <if test="feedsImg != null">
+        feedsImg = #{feedsImg}
+      </if>
+      <if test="isFeedsPublic != null">
+        isFeedsPublic = #{isFeedsPublic}
+      </if>
+      <if test="type != null">
+        type = #{type}
+      </if>
+      <if test="closeLike != null">
+        closeLike = #{closeLike}
+      </if>
+      <if test="closeGoods != null">
+        closeGoods = #{closeGoods}
+      </if>
+      <if test="closeComment != null">
+        closeComment = #{closeComment}
+      </if>
+      <if test="closeReplay != null">
+        closeReplay = #{closeReplay}
+      </if>
+      <if test="closeShare != null">
+        closeShare = #{closeShare}
+      </if>
+      <if test="closeKf != null">
+        closeKf = #{closeKf}
+      </if>
+    </trim>
+    WHERE roomId = #{roomId}
+  </update>
+</mapper>

b2b2c/b2b2c-web/src/test/com/slodon/b2b2c/controller/job/ScheduleTaskControllerTest.java

@@ -0,0 +1,20 @@
+package com.slodon.b2b2c.controller.job;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class ScheduleTaskControllerTest {
+
+    @Autowired
+    private ScheduleTaskController taskController;
+
+    @Test
+    public void getJobSystemSendStockWarnRemind(){
+        taskController.jobSystemSendStockWarnRemind();
+    }
+}

b2b2c/sql/建表语句.sql

@@ -0,0 +1,23 @@
+DROP TABLE IF EXISTS live_broadcast;
+CREATE TABLE live_broadcast  (
+  roomId varchar(50) NOT NULL COMMENT '房间ID' ,
+  name varchar(50) NOT NULL COMMENT '直播间名字，最短3个汉字，最长17个汉字，1个汉字相当于2个字符',
+  coverImg varchar(50) NOT NULL COMMENT '背景图，填入mediaID（mediaID获取后，三天内有效）；图片 mediaID 的获取，请参考以下文档： https://developers.weixin.qq.com/doc/offiaccount/Asset_Management/New_temporary_materials.html；直播间背景图，图片规则：建议像素1080*1920，大小不超过2M',
+  startTime bigint(20) NOT NULL COMMENT '直播计划开始时间（开播时间需要在当前时间的10分钟后 并且 开始时间不能在 6 个月后）',
+  endTime bigint(20) NOT NULL COMMENT '直播计划结束时间（开播时间和结束时间间隔不得短于30分钟，不得超过24小时）',
+  anchorName varchar(50) NOT NULL COMMENT '主播昵称，最短2个汉字，最长15个汉字，1个汉字相当于2个字符',
+  anchorWechat varchar(50) NOT NULL COMMENT '主播微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证, 小程序二维码链接：https://res.wx.qq.com/op_res/9rSix1dhHfK4rR049JL0PHJ7TpOvkuZ3mE0z7Ou_Etvjf-w1J_jVX0rZqeStLfwh',
+  subAnchorWechat varchar(50)  COMMENT '主播副号微信号，如果未实名认证，需要先前往“小程序直播”小程序进行实名验证, 小程序二维码链接：https://res.wx.qq.com/op_res/9rSix1dhHfK4rR049JL0PHJ7TpOvkuZ3mE0z7Ou_Etvjf-w1J_jVX0rZqeStLfwh',
+  createrWechat varchar(50)  COMMENT '创建者微信号，不传入则此直播间所有成员可见。传入则此房间仅创建者、管理员、超管、直播间主播可见',
+  shareImg varchar(50) NOT NULL COMMENT '分享图，填入mediaID（mediaID获取后，三天内有效）；图片 mediaID 的获取，请参考以下文档： https://developers.weixin.qq.com/doc/offiaccount/Asset_Management/New_temporary_materials.html；直播间分享图，图片规则：建议像素800*640，大小不超过1M；',
+  feedsImg varchar(50) NOT NULL COMMENT '购物直播频道封面图，填入mediaID（mediaID获取后，三天内有效）；图片 mediaID 的获取，请参考以下文档： https://developers.weixin.qq.com/doc/offiaccount/Asset_Management/New_temporary_materials.html; 购物直播频道封面图，图片规则：建议像素800*800，大小不超过100KB；',
+  isFeedsPublic int(11) NOT NULL DEFAULT 1 COMMENT '是否开启官方收录 【1: 开启，0：关闭】，默认开启收录',
+  type  int(11) NOT NULL  COMMENT '直播间类型 【1: 推流，0：手机直播】',
+  closeLike int(11) NOT NULL  COMMENT '是否关闭点赞 【0：开启，1：关闭】（若关闭，观众端将隐藏点赞按钮，直播开始后不允许开启）',
+  closeGoods  int(11) NOT NULL  COMMENT '是否关闭货架 【0：开启，1：关闭】（若关闭，观众端将隐藏商品货架，直播开始后不允许开启）',
+  closeComment  int(11) NOT NULL  COMMENT '是否关闭评论 【0：开启，1：关闭】（若关闭，观众端将隐藏评论入口，直播开始后不允许开启）',
+  closeReplay int(11) NOT NULL DEFAULT 1 COMMENT '是否关闭回放 【0：开启，1：关闭】默认关闭回放（直播开始后允许开启）',
+  closeShare  int(11) NOT NULL DEFAULT 0 COMMENT '是否关闭分享 【0：开启，1：关闭】默认开启分享（直播开始后不允许修改）',
+  closeKf int(11) NOT NULL DEFAULT 1 COMMENT '是否关闭客服 【0：开启，1：关闭】 默认关闭客服（直播开始后允许开启）',
+  PRIMARY KEY (roomId) USING BTREE
+) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '直播信息表' ROW_FORMAT = Dynamic;