开发直播、直播申请service接口

王言钊
1 parent 07228909
Showing 9 changed files with 276 additions and 59 deletions
src/main/java/com/cnlive/shenhe/api/LiveApplyControllerApi.java
src/main/java/com/cnlive/shenhe/api/LiveControllerApi.java
src/main/java/com/cnlive/shenhe/controller/LiveApplyController.java
src/main/java/com/cnlive/shenhe/controller/LiveController.java
src/main/java/com/cnlive/shenhe/job/LiveApplyJob.java
src/main/java/com/cnlive/shenhe/service/LiveApplyService.java
src/main/java/com/cnlive/shenhe/service/LiveService.java
src/main/java/com/cnlive/shenhe/service/serviceImpl/LiveApplyServiceImpl.java
src/main/java/com/cnlive/shenhe/service/serviceImpl/LiveServiceImpl.java
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyLiveapply;
-import com.cnlive.shenhe.service.serviceImpl.LiveApplyServiceImpl;
+import com.cnlive.shenhe.service.LiveApplyService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import org.slf4j.Logger;
@@ -27,7 +27,7 @@ public class LiveApplyControllerApi {
     private static Logger logger = LoggerFactory.getLogger(LiveApplyControllerApi.class);
     @Autowired
-    LiveApplyServiceImpl liveApplyServiceImpl;
+    LiveApplyService liveApplyService;
     @PostMapping("/import")
     @ResponseBody
@@ -64,7 +64,7 @@ public class LiveApplyControllerApi {
         //得到直播活动id去查询是否已有
         shyliveApply.setActivity_id(activityId);
         //查询一下 存在，更新 没有，插入
-        List<ShyLiveapply> listshyLiveApply = liveApplyServiceImpl.findshyLiveApply(shyliveApply);
+        List<ShyLiveapply> listshyLiveApply = liveApplyService.findShyLiveApply(shyliveApply);
         if (listshyLiveApply.size() > 0) {
             ShyLiveapply shyliveApply1 = listshyLiveApply.get(0);
@@ -148,11 +148,11 @@ public class LiveApplyControllerApi {
         //更新时间
         shyliveApply.setUpdated_at(CommonUtils.getCurrentTime());
         //获取审核类型
-        liveApplyServiceImpl.getShenheType(shyliveApply);
+        liveApplyService.getShenheType(shyliveApply);
         if (shyliveApply.getId() == null) {
-            return liveApplyServiceImpl.impotLiveApply(shyliveApply);
+            return liveApplyService.impotLiveApply(shyliveApply);
         } else {
-            return liveApplyServiceImpl.updateshyLiveApply(shyliveApply);
+            return liveApplyService.updateShyLiveApply(shyliveApply);
         }
     }
 }
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyLive;
-import com.cnlive.shenhe.service.serviceImpl.LiveServiceImpl;
+import com.cnlive.shenhe.service.LiveService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -29,7 +29,7 @@ public class LiveControllerApi {
     private static Logger logger = LoggerFactory.getLogger(LiveControllerApi.class);
     @Autowired
-    LiveServiceImpl liveService;
+    LiveService liveService;
     @PostMapping("/import")
     @ResponseBody
@@ -43,30 +43,10 @@ public class LiveControllerApi {
         //获取所有参数
         //直播活动id
         String activityId = json.getString("activityId");
-        //直播活动名称
-        String activityName = json.getString("activityName");
         //直播活动状态
         Integer activityStatus = json.getInteger("activityStatus");
         //直播频道id
         String channelId = json.getString("channelId");
-        //直播频道id
-        String liveType = json.getString("liveType");
-        //rtmp直播流
-        String mp4Url = json.getString("mp4Url");
-        //m3u8直播流
-        String hlsUrl = json.getString("hlsUrl");
-        //spid
-        Integer spId = json.getInteger("spId");
-        //回调地址
-        String callback = json.getString("callback");
-        //优先级
-        Integer isHot = json.getInteger("priority");
-        //封面
-        String coverImgUrl = json.getString("coverImgUrl");
-        //活动描述
-        String activityIntro = json.getString("activityIntro");
-        //回放地址
-        String playbackUrl = json.getString("playbackUrl");
         //开始时间
         String startTime = json.getString("startTime");
         Date timestampStart = null;
@@ -95,7 +75,7 @@ public class LiveControllerApi {
         //得到直播活动id去查询是否已有
         shyLive.setActivity_id(activityId);
         //查询一下 存在，更新 没有，插入
-        List<ShyLive> shyLiveList = liveService.findshyLive(shyLive);
+        List<ShyLive> shyLiveList = liveService.findShyLive(shyLive);
         if (shyLiveList.size() > 0) {
             //更新
             ShyLive shyLive1 = shyLiveList.get(0);
@@ -213,7 +193,7 @@ public class LiveControllerApi {
         if (shyLive.getId() == null) {
             return liveService.impotVideo(shyLive);
         } else {
-            return liveService.updateshyLive(shyLive);
+            return liveService.updateShyLive(shyLive);
         }
     }
 }
@@ -9,7 +9,10 @@ import com.cnlive.shenhe.dto.LiveApplyDTO;
 import com.cnlive.shenhe.entity.ShyLiveapply;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.service.serviceImpl.*;
+import com.cnlive.shenhe.service.LiveApplyService;
+import com.cnlive.shenhe.service.LiveService;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -51,11 +54,11 @@ public class LiveApplyController extends BaseController {
     @Autowired
     SitesServiceImpl sitesService;
     @Autowired
-    LiveServiceImpl liveService;
+    LiveService liveService;
     @Value("${spring.localhost.url}")
     private String localhost_url;//本机地址
     @Autowired
-    LiveApplyServiceImpl liveApplyServiceImpl;
+    LiveApplyService liveApplyService;
     /**
@@ -76,7 +79,7 @@ public class LiveApplyController extends BaseController {
         String[] shyLiveApplyIds = ids.split(",");
         String showMsg = "";
         for (String shyLiveApplyId : shyLiveApplyIds) {
-            ShyLiveapply shyLiveapply = liveApplyServiceImpl.selectByPrimaryKey(Integer.parseInt(shyLiveApplyId));
+            ShyLiveapply shyLiveapply = liveApplyService.selectByPrimaryKey(Integer.parseInt(shyLiveApplyId));
             JSONObject result = null;
             try {
                 result = pass.liveApplyPass(shyLiveapply.getActivity_id(), state + 2, msg, msg, shyLiveapply.getCallback());
@@ -96,7 +99,7 @@ public class LiveApplyController extends BaseController {
                 showMsg = showMsg + "," + shyLiveapply.getActivity_id() + " " + result.getString(" errorMessage");
                 break;
             }
-            int i = liveApplyServiceImpl.updateLiveApply(Integer.parseInt(shyLiveApplyId), userId, "", state, msg);
+            int i = liveApplyService.updateLiveApply(Integer.parseInt(shyLiveApplyId), userId, "", state, msg);
             if (i == 0) {
                 showMsg = showMsg + "," + shyLiveapply.getActivity_id() + " 更新失败";
                 break;
@@ -138,7 +141,7 @@ public class LiveApplyController extends BaseController {
         } else if (CommonUtils.isEmpty(liveApplyDTO.getSp_desc()) && liveApplyDTO.getSpid() == 0) {
             liveApplyDTO.setSpid(null);
         }
-        PageInfo<ShyLiveapply> liveApplyPage = liveApplyServiceImpl.getListLiveApply(liveApplyDTO);
+        PageInfo<ShyLiveapply> liveApplyPage = liveApplyService.getListLiveApply(liveApplyDTO);
         List<ShyLiveapply> list = liveApplyPage.getList();
         if (!list.isEmpty()) {
             for (ShyLiveapply liveApply : list) {
@@ -182,7 +185,7 @@ public class LiveApplyController extends BaseController {
      */
     @GetMapping("/details")
     public Object getDetailsLiveApply(Model model, Integer id) {
-        ShyLiveapply shyLiveapply = liveApplyServiceImpl.getDetailsLiveApply(id);
+        ShyLiveapply shyLiveapply = liveApplyService.getDetailsLiveApply(id);
         //显示spid简称
         ShySites shySites = sitesService.findspidDescByspid(shyLiveapply.getSp_id());
@@ -213,7 +216,7 @@ public class LiveApplyController extends BaseController {
         if (CommonUtils.isNotEmpty(ids)) {
             String[] cids = ids.split(",");
             for (String cid : cids) {
-                ShyLiveapply shyLiveapply = liveApplyServiceImpl.selectByPrimaryKey(Integer.parseInt(cid));
+                ShyLiveapply shyLiveapply = liveApplyService.selectByPrimaryKey(Integer.parseInt(cid));
                 if (CommonUtils.isNotNull(shyLiveapply)) {
                     if (!shyLiveapply.getShenhe_state().equals(CommonConst.RECEIVE_BEFORE)) {
                         return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "您领取的内容中有已被领取或者已经被审核，请检查并重试");
@@ -224,7 +227,7 @@ public class LiveApplyController extends BaseController {
                 }
             }
         }
-        Integer n = liveApplyServiceImpl.receive(ids, num, userId, spid);
+        Integer n = liveApplyService.receive(ids, num, userId, spid);
         return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "认领到" + n + "条内容");
     }
@@ -244,12 +247,12 @@ public class LiveApplyController extends BaseController {
         //在退领操作前先判断是否包含已退领或者已经审核的数据，有则退回检查并重新退领
         String[] cids = ids.split(",");
         for (String cid : cids) {
-            ShyLiveapply shyLiveapply = liveApplyServiceImpl.selectByPrimaryKey(Integer.parseInt(cid));
+            ShyLiveapply shyLiveapply = liveApplyService.selectByPrimaryKey(Integer.parseInt(cid));
             if (!shyLiveapply.getReceive().equals(CommonConst.RECEIVE_AFTER) || !shyLiveapply.getAuditor().equals(userId) || !shyLiveapply.getShenhe_state().equals(CommonConst.AUDIT_INTT)) {
                 return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "退领失败，您选中的内容包含已退领的或已经审核的");
             }
         }
-        return liveApplyServiceImpl.retReceive(ids, userId);
+        return liveApplyService.retReceive(ids, userId);
     }
     /**
@@ -269,7 +272,7 @@ public class LiveApplyController extends BaseController {
         String[] shyLiveIds = ids.split(",");
         String showMsg = "";
         for (String shyLiveId : shyLiveIds) {
-            ShyLiveapply shyLiveapply = liveApplyServiceImpl.selectByPrimaryKey(Integer.parseInt(shyLiveId));
+            ShyLiveapply shyLiveapply = liveApplyService.selectByPrimaryKey(Integer.parseInt(shyLiveId));
             JSONObject result = null;
             try {
                 result = pass.liveApplyPass(shyLiveapply.getActivity_id(), 4, msg, msg, shyLiveapply.getCallback());
@@ -320,7 +323,7 @@ public class LiveApplyController extends BaseController {
         } else if (CommonUtils.isEmpty(liveApplyDTO.getSp_desc()) && liveApplyDTO.getSpid() == 0) {
             liveApplyDTO.setSpid(null);
         }
-        List<ShyLiveapply> liveApplyList = liveApplyServiceImpl.findByCondition(liveApplyDTO);
+        List<ShyLiveapply> liveApplyList = liveApplyService.findByCondition(liveApplyDTO);
         String fileName = "直播申请数据";
@@ -450,7 +453,7 @@ public class LiveApplyController extends BaseController {
         ShyLiveapply shyLiveapply = new ShyLiveapply();
         shyLiveapply.setShenhe_type(CommonConst.AUDIT_TYPE_USER);// 审核类型为人工审
         shyLiveapply.setShenhe_state(CommonConst.AUDIT_INTT);
-        List<ShyLiveapply> liveApplyList = liveApplyServiceImpl.findshyLiveApply(shyLiveapply);
+        List<ShyLiveapply> liveApplyList = liveApplyService.findShyLiveApply(shyLiveapply);
         if (liveApplyList.size() > 0) {
             logger.info("您有" + liveApplyList.size() + "条新的直播申请，请注意查看！");
             map.put("id", "2");// 第二个提示框，避免冲突
@@ -9,7 +9,7 @@ import com.cnlive.shenhe.dto.LiveDTO;
 import com.cnlive.shenhe.entity.ShyLive;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.service.serviceImpl.LiveServiceImpl;
+import com.cnlive.shenhe.service.LiveService;
 import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
 import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
 import com.cnlive.shenhe.service.serviceImpl.VideosServiceImpl;
@@ -57,7 +57,7 @@ public class LiveController extends BaseController {
     @Autowired
     SitesServiceImpl sitesService;
     @Autowired
-    LiveServiceImpl liveService;
+    LiveService liveService;
     @Value("${qn_domain}")
     String qn_domain;
@@ -5,8 +5,8 @@ import com.cnlive.shenhe.entity.ShyEmail;
 import com.cnlive.shenhe.entity.ShyLiveapply;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.mapper.ShyLiveapplyMapper;
+import com.cnlive.shenhe.service.LiveApplyService;
 import com.cnlive.shenhe.service.serviceImpl.EmailServiceImpl;
-import com.cnlive.shenhe.service.serviceImpl.LiveApplyServiceImpl;
 import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -52,7 +52,7 @@ public class LiveApplyJob {
     @Autowired
     SitesServiceImpl sitesService;
     @Autowired
-    LiveApplyServiceImpl liveApplyServiceImpl;
+    LiveApplyService liveApplyService;
     @Autowired
     ShyLiveapplyMapper shyLiveApplyMapper;
@@ -67,10 +67,10 @@ public class LiveApplyJob {
         // 审核类型为免审
         shyLiveApply.setShenhe_type(CommonConst.AUDIT_TYPE_FREE);
         shyLiveApply.setShenhe_state(CommonConst.AUDIT_INTT);
-        List<ShyLiveapply> liveApplyList = liveApplyServiceImpl.findshyLiveApply(shyLiveApply);
+        List<ShyLiveapply> liveApplyList = liveApplyService.findShyLiveApply(shyLiveApply);
         if (liveApplyList.size() > 0) {
             for (ShyLiveapply liveApply : liveApplyList) {
-                liveApplyServiceImpl.updateLiveApply(liveApply.getId(), "", "白名单", CommonConst.AUDIT_SUCCESS, "白名单通过");
+                liveApplyService.updateLiveApply(liveApply.getId(), "", "白名单", CommonConst.AUDIT_SUCCESS, "白名单通过");
             }
         }
     }
@@ -153,7 +153,7 @@ public class LiveApplyJob {
                 liveApply.setEmail_notice_state(notice_state);
                 liveApply.setEmail_notice_msg(notice_msg);
-                liveApplyServiceImpl.updateshyLiveApply(liveApply);
+                liveApplyService.updateShyLiveApply(liveApply);
             }
         }
@@ -171,14 +171,14 @@ public class LiveApplyJob {
         liveApply.setShenhe_state(CommonConst.AUDIT_INTT);
         //已领取
         liveApply.setReceive(CommonConst.RECEIVE_AFTER);
-        List<ShyLiveapply> shyLiveapplyList = liveApplyServiceImpl.findshyLiveApply(liveApply);
+        List<ShyLiveapply> shyLiveapplyList = liveApplyService.findShyLiveApply(liveApply);
         if (shyLiveapplyList.size() > 0) {
             for (ShyLiveapply liveapply : shyLiveapplyList) {
                 logger.info("自动退领的liveApply_id：" + liveapply.getId());
                 //未领取
                 liveapply.setReceive(CommonConst.RECEIVE_BEFORE);
                 liveapply.setAuditor(null);
-                liveApplyServiceImpl.updateshyLiveApply(liveApply);
+                liveApplyService.updateShyLiveApply(liveApply);
             }
         }
     }
+package com.cnlive.shenhe.service;
+
+import com.cnlive.shenhe.bean.ResponseBean;
+import com.cnlive.shenhe.dto.LiveApplyDTO;
+import com.cnlive.shenhe.entity.ShyLiveapply;
+import com.github.pagehelper.PageInfo;
+
+import java.util.List;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-11-02 14:26
+ */
+public interface LiveApplyService {
+    /**
+     * 导入直播申请
+     *
+     * @param shyLiveApply
+     * @return
+     */
+    boolean impotLiveApply(ShyLiveapply shyLiveApply);
+
+    /**
+     * 根据主键id查询直播申请对象
+     *
+     * @param id
+     * @return
+     */
+    ShyLiveapply selectByPrimaryKey(Integer id);
+
+    /**
+     * 根据条件查询直播申请集合
+     *
+     * @param shyLiveApply
+     * @return
+     */
+    List<ShyLiveapply> findShyLiveApply(ShyLiveapply shyLiveApply);
+
+    /**
+     * 修改直播申请对象  返回布尔类型
+     *
+     * @param shyLiveApply
+     * @return
+     */
+    boolean updateShyLiveApply(ShyLiveapply shyLiveApply);
+
+    /**
+     * 修改直播申请对象 返回int类型
+     *
+     * @param id
+     * @param auditor_id
+     * @param updater
+     * @param status
+     * @param msg
+     * @return
+     */
+    int updateLiveApply(Integer id, String auditor_id, String updater, Integer status, String msg);
+
+    /**
+     * 获取分页、条件查询
+     *
+     * @param liveApplyDTO
+     * @return
+     */
+    PageInfo<ShyLiveapply> getListLiveApply(LiveApplyDTO liveApplyDTO);
+
+    /**
+     * 获取直播申请详情
+     *
+     * @param id
+     * @return
+     */
+    ShyLiveapply getDetailsLiveApply(Integer id);
+
+    /**
+     * 认领
+     *
+     * @param ids
+     * @param num
+     * @param userId
+     * @param spid
+     * @return
+     */
+    Integer receive(String ids, Integer num, String userId, Integer spid);
+
+    /**
+     * 退领
+     *
+     * @param ids
+     * @param userId
+     * @return
+     */
+    ResponseBean retReceive(String ids, String userId);
+
+    /**
+     * 根据条件导出数据excel
+     *
+     * @param liveApplyDTO
+     * @return
+     */
+    List<ShyLiveapply> findByCondition(LiveApplyDTO liveApplyDTO);
+
+    /**
+     * 获取审核类型
+     *
+     * @param shyLiveApply
+     */
+    void getShenheType(ShyLiveapply shyLiveApply);
+}
+package com.cnlive.shenhe.service;
+
+import com.cnlive.shenhe.bean.ResponseBean;
+import com.cnlive.shenhe.dto.LiveDTO;
+import com.cnlive.shenhe.entity.ShyLive;
+import com.github.pagehelper.PageInfo;
+
+import java.util.List;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-11-02 14:25
+ */
+public interface LiveService {
+    /**
+     * 直播导入
+     *
+     * @param shyLive
+     * @return
+     */
+    boolean impotVideo(ShyLive shyLive);
+
+    /**
+     * 根据id查询  返回直播对象
+     *
+     * @param id
+     * @return
+     */
+    ShyLive selectByPrimaryKey(Integer id);
+
+    /**
+     * 根据条件查询  返回直播对象集合
+     *
+     * @param shyLive
+     * @return
+     */
+    List<ShyLive> findShyLive(ShyLive shyLive);
+
+    /**
+     * 修改直播对象 返回boolean类型
+     *
+     * @param shyLive
+     * @return
+     */
+    boolean updateShyLive(ShyLive shyLive);
+
+    /**
+     * 根据id查询，修改对象的关键信息 返回int类型
+     *
+     * @param id
+     * @param auditor_id
+     * @param updater
+     * @param activity_status
+     * @param msg
+     * @return
+     */
+    int updateLive(Integer id, String auditor_id, String updater, Integer activity_status, String msg);
+
+    /**
+     * 分页、条件查询、返回分页结果集合
+     *
+     * @param liveDTO
+     * @return
+     */
+    PageInfo<ShyLive> getListLive(LiveDTO liveDTO);
+
+    /**
+     * 根据id获取直播详情信息
+     *
+     * @param id
+     * @return
+     */
+    ShyLive getDetailsLive(Integer id);
+
+    /**
+     * 认领
+     *
+     * @param ids
+     * @param num
+     * @param userId
+     * @param spid
+     * @return
+     */
+    Integer receive(String ids, Integer num, String userId, Integer spid);
+
+    /**
+     * 退领
+     *
+     * @param ids
+     * @param userId
+     * @return
+     */
+    ResponseBean retReceive(String ids, String userId);
+
+    /**
+     * 根据条件导出数据excel
+     *
+     * @param liveDTO
+     * @return
+     */
+    List<ShyLive> findByCondition(LiveDTO liveDTO);
+}
@@ -9,6 +9,7 @@ import com.cnlive.shenhe.entity.ShyLiveapply;
 import com.cnlive.shenhe.entity.ShyUsers;
 import com.cnlive.shenhe.mapper.ShyLiveapplyMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
+import com.cnlive.shenhe.service.LiveApplyService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageHelper;
@@ -30,7 +31,7 @@ import java.util.List;
  * @Description:
  */
 @Service
-public class LiveApplyServiceImpl {
+public class LiveApplyServiceImpl implements LiveApplyService {
     private static Logger logger = LoggerFactory.getLogger(LiveApplyServiceImpl.class);
     @Autowired
@@ -46,6 +47,7 @@ public class LiveApplyServiceImpl {
      * @param shyLiveApply
      * @return
      */
+    @Override
     public boolean impotLiveApply(ShyLiveapply shyLiveApply) {
         int result = shyLiveApplyMapper.insertSelective(shyLiveApply);
         if (result == 0) {
@@ -60,6 +62,7 @@ public class LiveApplyServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyLiveapply selectByPrimaryKey(Integer id) {
         ShyLiveapply shyLiveApply = shyLiveApplyMapper.selectByPrimaryKey(id);
         return shyLiveApply;
@@ -71,7 +74,8 @@ public class LiveApplyServiceImpl {
      * @param shyLiveApply
      * @return
      */
-    public List<ShyLiveapply> findshyLiveApply(ShyLiveapply shyLiveApply) {
+    @Override
+    public List<ShyLiveapply> findShyLiveApply(ShyLiveapply shyLiveApply) {
         List<ShyLiveapply> shyLiveApplylist = shyLiveApplyMapper.selectByRowBounds(shyLiveApply, new RowBounds(0, 100));
         return shyLiveApplylist;
     }
@@ -82,7 +86,8 @@ public class LiveApplyServiceImpl {
      * @param shyLiveApply
      * @return
      */
-    public boolean updateshyLiveApply(ShyLiveapply shyLiveApply) {
+    @Override
+    public boolean updateShyLiveApply(ShyLiveapply shyLiveApply) {
         int i = shyLiveApplyMapper.updateByPrimaryKey(shyLiveApply);
         if (i == 0) {
             return false;
@@ -100,6 +105,7 @@ public class LiveApplyServiceImpl {
      * @param msg
      * @return
      */
+    @Override
     public int updateLiveApply(Integer id, String auditor_id, String updater, Integer status, String msg) {
         ShyLiveapply shyLiveapply = shyLiveApplyMapper.selectByPrimaryKey(id);
         shyLiveapply.setAuditor(auditor_id);
@@ -117,6 +123,7 @@ public class LiveApplyServiceImpl {
      * @param liveApplyDTO
      * @return
      */
+    @Override
     public PageInfo<ShyLiveapply> getListLiveApply(LiveApplyDTO liveApplyDTO) {
         logger.info("接参数列表为，LiveApplyDTO:{}", JSON.toJSONString(liveApplyDTO));
         Example example = new Example(ShyLiveapply.class);
@@ -179,6 +186,7 @@ public class LiveApplyServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyLiveapply getDetailsLiveApply(Integer id) {
         ShyLiveapply shyLiveapply = shyLiveApplyMapper.selectByPrimaryKey(id);
         if (!shyLiveapply.getShenhe_state().equals(CommonConst.RECEIVE_BEFORE)) {
@@ -206,6 +214,7 @@ public class LiveApplyServiceImpl {
      * @param spid
      * @return
      */
+    @Override
     public Integer receive(String ids, Integer num, String userId, Integer spid) {
         Integer n = 0;
         if (CommonUtils.isNotEmpty(ids)) {
@@ -250,6 +259,7 @@ public class LiveApplyServiceImpl {
      * @param userId
      * @return
      */
+    @Override
     public ResponseBean retReceive(String ids, String userId) {
         String[] cids = ids.split(",");
         for (String cid : cids) {
@@ -274,6 +284,7 @@ public class LiveApplyServiceImpl {
      *
      * @return
      */
+    @Override
     public List<ShyLiveapply> findByCondition(LiveApplyDTO liveApplyDTO) {
         Example example = new Example(ShyLiveapply.class);
         Example.Criteria criteria = example.createCriteria();
@@ -332,6 +343,7 @@ public class LiveApplyServiceImpl {
      *
      * @param shyLiveApply
      */
+    @Override
     public void getShenheType(ShyLiveapply shyLiveApply) {
         //获取直播频道免审sp
@@ -8,6 +8,7 @@ import com.cnlive.shenhe.entity.ShyLive;
 import com.cnlive.shenhe.entity.ShyUsers;
 import com.cnlive.shenhe.mapper.ShyLiveMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
+import com.cnlive.shenhe.service.LiveService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -30,7 +31,7 @@ import java.util.List;
  * @Description:
  */
 @Service
-public class LiveServiceImpl {
+public class LiveServiceImpl implements LiveService {
     private static Logger logger = LoggerFactory.getLogger(LiveServiceImpl.class);
     @Autowired
@@ -45,6 +46,7 @@ public class LiveServiceImpl {
      * @param shyLive
      * @return
      */
+    @Override
     public boolean impotVideo(ShyLive shyLive) {
         int result = shyLiveMapper.insertSelective(shyLive);
         if (result == 0) {
@@ -59,6 +61,7 @@ public class LiveServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyLive selectByPrimaryKey(Integer id) {
         ShyLive shyLive = shyLiveMapper.selectByPrimaryKey(id);
         return shyLive;
@@ -70,7 +73,8 @@ public class LiveServiceImpl {
      * @param shyLive
      * @return
      */
-    public List<ShyLive> findshyLive(ShyLive shyLive) {
+    @Override
+    public List<ShyLive> findShyLive(ShyLive shyLive) {
         List<ShyLive> shyLivelist = shyLiveMapper.selectByRowBounds(shyLive, new RowBounds(0, 100));
         return shyLivelist;
     }
@@ -81,7 +85,8 @@ public class LiveServiceImpl {
      * @param shyLive
      * @return
      */
-    public boolean updateshyLive(ShyLive shyLive) {
+    @Override
+    public boolean updateShyLive(ShyLive shyLive) {
         int i = shyLiveMapper.updateByPrimaryKey(shyLive);
         if (i == 0) {
             return false;
@@ -99,6 +104,7 @@ public class LiveServiceImpl {
      * @param msg
      * @return
      */
+    @Override
     public int updateLive(Integer id, String auditor_id, String updater, Integer activity_status, String msg) {
         ShyLive shyLive = shyLiveMapper.selectByPrimaryKey(id);
         shyLive.setAuditor(auditor_id);
@@ -116,6 +122,7 @@ public class LiveServiceImpl {
      * @param liveDTO
      * @return
      */
+    @Override
     public PageInfo<ShyLive> getListLive(LiveDTO liveDTO) {
         logger.info("接受参数对象，LiveDTO:{}", JSON.toJSONString(liveDTO));
         Example example = new Example(ShyLive.class);
@@ -174,6 +181,7 @@ public class LiveServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyLive getDetailsLive(Integer id) {
         ShyLive shyLive = shyLiveMapper.selectByPrimaryKey(id);
         if (!shyLive.getShenhe_state().equals(CommonConst.RECEIVE_BEFORE)) {
@@ -203,6 +211,7 @@ public class LiveServiceImpl {
      * @param spid
      * @return
      */
+    @Override
     public Integer receive(String ids, Integer num, String userId, Integer spid) {
         Integer n = 0;
         if (CommonUtils.isNotEmpty(ids)) {
@@ -243,6 +252,7 @@ public class LiveServiceImpl {
      * @param userId
      * @return
      */
+    @Override
     public ResponseBean retReceive(String ids, String userId) {
         String[] cids = ids.split(",");
         for (String cid : cids) {
@@ -266,6 +276,7 @@ public class LiveServiceImpl {
      *
      * @return
      */
+    @Override
     public List<ShyLive> findByCondition(LiveDTO liveDTO) {
         Example example = new Example(ShyLive.class);
         Example.Criteria criteria = example.createCriteria();