开发音频、频道service接口

王言钊
1 parent 0ec1ebad
Showing 54 changed files with 345 additions and 85 deletions
src/main/java/com/cnlive/shenhe/api/AudioControllerApi.java
src/main/java/com/cnlive/shenhe/api/AvsampleCallBackControllerApi.java
src/main/java/com/cnlive/shenhe/api/ChannelControllerApi.java
src/main/java/com/cnlive/shenhe/api/CommentsControllerApi.java
src/main/java/com/cnlive/shenhe/api/ContentControllerApi.java
src/main/java/com/cnlive/shenhe/api/LiveApplyControllerApi.java
src/main/java/com/cnlive/shenhe/api/LiveControllerApi.java
src/main/java/com/cnlive/shenhe/api/ShyActivityControllerApi.java
src/main/java/com/cnlive/shenhe/api/TopicControllerApi.java
src/main/java/com/cnlive/shenhe/api/VideosControllerApi.java
src/main/java/com/cnlive/shenhe/api/YiDunControllerApi.java
src/main/java/com/cnlive/shenhe/controller/AudioController.java
src/main/java/com/cnlive/shenhe/controller/ChannelController.java
src/main/java/com/cnlive/shenhe/controller/CommentsController.java
src/main/java/com/cnlive/shenhe/controller/ContentController.java
src/main/java/com/cnlive/shenhe/controller/EmailController.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/controller/NotSpeakController.java
src/main/java/com/cnlive/shenhe/controller/ShyActivityController.java
@@ -7,8 +7,8 @@ import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyAudio;
 import com.cnlive.shenhe.entity.ShyYidun;
 import com.cnlive.shenhe.enums.TextLabels;
-import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
-import com.cnlive.shenhe.serviceImpl.YiDunServiceImpl;
+import com.cnlive.shenhe.service.AudioService;
+import com.cnlive.shenhe.service.serviceImpl.YiDunServiceImpl;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.YiDunAntiFraudUtil;
@@ -37,7 +37,7 @@ public class AudioControllerApi {
     private static EvictingQueue<String> queue = EvictingQueue.create(50);
     @Autowired
-    AudioServiceImpl audioService;
+    AudioService audioService;
     @Autowired
     YiDunServiceImpl yiDunServiceImpl;
     @Autowired
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyVideos;
-import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.VideosServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import org.slf4j.Logger;
@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyChannel;
-import com.cnlive.shenhe.serviceImpl.ChannelServiceImpl;
+import com.cnlive.shenhe.service.ChannelService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -27,7 +27,7 @@ import java.util.List;
 public class ChannelControllerApi {
     private static Logger logger = LoggerFactory.getLogger(ChannelControllerApi.class);
     @Autowired
-    ChannelServiceImpl channelService;
+    ChannelService channelService;
     /**
      * @Auther: liwei
@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyComments;
-import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.CommentsServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import org.slf4j.Logger;
@@ -5,7 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyContent;
-import com.cnlive.shenhe.serviceImpl.ContentServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ContentServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import org.slf4j.Logger;
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyLiveapply;
-import com.cnlive.shenhe.serviceImpl.LiveApplyServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.LiveApplyServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import org.slf4j.Logger;
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyLive;
-import com.cnlive.shenhe.serviceImpl.LiveServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.LiveServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -5,7 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyActivity;
-import com.cnlive.shenhe.serviceImpl.ShyActivityImpl;
+import com.cnlive.shenhe.service.serviceImpl.ShyActivityImpl;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyTopic;
-import com.cnlive.shenhe.serviceImpl.TopicServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.TopicServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.cnlive.shenhe.utils.TransitServiceUtils;
@@ -5,7 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyVideos;
-import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.VideosServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.cnlive.shenhe.utils.HttpUtil;
@@ -2,7 +2,7 @@ package com.cnlive.shenhe.api;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyYidun;
-import com.cnlive.shenhe.serviceImpl.YiDunServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.YiDunServiceImpl;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import com.cnlive.shenhe.utils.HttpClientUtils;
 import com.cnlive.shenhe.utils.YiDunAntiFraudUtil;
@@ -9,9 +9,9 @@ import com.cnlive.shenhe.dto.AudioDTO;
 import com.cnlive.shenhe.entity.ShyAudio;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.AudioService;
+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,7 +51,7 @@ public class AudioController extends BaseController {
     SitesServiceImpl sitesService;
     @Autowired
-    AudioServiceImpl audioService;
+    AudioService audioService;
     @Autowired
     UsersServiceImpl usersService;
@@ -9,9 +9,9 @@ import com.cnlive.shenhe.dto.ChannelDTO;
 import com.cnlive.shenhe.entity.ShyChannel;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.ChannelServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.ChannelService;
+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;
@@ -42,7 +42,7 @@ public class ChannelController extends BaseController {
     @Autowired
     AuditPass pass;
     @Autowired
-    ChannelServiceImpl channelService;
+    ChannelService channelService;
     @Autowired
     UsersServiceImpl usersService;
@@ -10,10 +10,10 @@ import com.cnlive.shenhe.entity.ShyComments;
 import com.cnlive.shenhe.entity.ShyContent;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
-import com.cnlive.shenhe.serviceImpl.ContentServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.CommentsServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ContentServiceImpl;
+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;
@@ -8,9 +8,9 @@ import com.cnlive.shenhe.dto.ContentDTO;
 import com.cnlive.shenhe.entity.ShyContent;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.ContentServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ContentServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -8,8 +8,8 @@ import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.dto.EmailDTO;
 import com.cnlive.shenhe.entity.ShyEmail;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.EmailServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.EmailServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -9,7 +9,7 @@ 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.serviceImpl.*;
+import com.cnlive.shenhe.service.serviceImpl.*;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -9,10 +9,10 @@ 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.serviceImpl.LiveServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
-import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.LiveServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.VideosServiceImpl;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -8,7 +8,7 @@ import com.cnlive.shenhe.dto.NotSpeakDTO;
 import com.cnlive.shenhe.entity.ShyNotspeak;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.*;
+import com.cnlive.shenhe.service.serviceImpl.*;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
 import org.slf4j.Logger;
@@ -5,7 +5,7 @@ import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.dto.ShyActivityDTO;
 import com.cnlive.shenhe.entity.ShyActivity;
-import com.cnlive.shenhe.serviceImpl.ShyActivityImpl;
+import com.cnlive.shenhe.service.serviceImpl.ShyActivityImpl;
 import com.github.pagehelper.PageInfo;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -5,7 +5,7 @@ import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.dto.ShyLogDTO;
 import com.cnlive.shenhe.entity.ShyLog;
-import com.cnlive.shenhe.serviceImpl.ShyLogServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ShyLogServiceImpl;
 import com.github.pagehelper.PageInfo;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -5,7 +5,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.dto.SitesDTO;
 import com.cnlive.shenhe.entity.ShySites;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -7,8 +7,8 @@ import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.dto.TopicDTO;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyTopic;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.TopicServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.TopicServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -7,9 +7,9 @@ import com.cnlive.shenhe.dto.UsersDTO;
 import com.cnlive.shenhe.entity.ShyLog;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.serviceImpl.ShyLogServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ShyLogServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -8,8 +8,8 @@ import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.dto.UsersFreeDTO;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsersfree;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
-import com.cnlive.shenhe.serviceImpl.UsersfreeServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.UsersfreeServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageInfo;
@@ -7,7 +7,7 @@ import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.dto.VideosDTO;
 import com.cnlive.shenhe.entity.*;
-import com.cnlive.shenhe.serviceImpl.*;
+import com.cnlive.shenhe.service.serviceImpl.*;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyAudio;
-import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
+import com.cnlive.shenhe.service.AudioService;
 import com.cnlive.shenhe.utils.CommonConst;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -21,7 +21,7 @@ public class AudioJob {
     private static Logger logger = LoggerFactory.getLogger(AudioJob.class);
     @Autowired
-    AudioServiceImpl audioService;
+    AudioService audioService;
     /**
      * 白名单sp音频通过
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyChannel;
-import com.cnlive.shenhe.serviceImpl.ChannelServiceImpl;
+import com.cnlive.shenhe.service.ChannelService;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.InfoUtil;
 import org.slf4j.Logger;
@@ -26,7 +26,7 @@ public class ChannelJob {
     @Autowired
     InfoUtil infoUtil;
     @Autowired
-    ChannelServiceImpl channelService;
+    ChannelService channelService;
     @Scheduled(fixedRate = 60 * 1000)
     public void updateChannel() {
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyComments;
-import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.CommentsServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyContent;
-import com.cnlive.shenhe.serviceImpl.ContentServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ContentServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -5,9 +5,9 @@ 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.serviceImpl.EmailServiceImpl;
-import com.cnlive.shenhe.serviceImpl.LiveApplyServiceImpl;
-import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
+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;
 import com.cnlive.shenhe.utils.HttpUtil;
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyNotspeak;
-import com.cnlive.shenhe.serviceImpl.NotspeakServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.NotspeakServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyTopic;
-import com.cnlive.shenhe.serviceImpl.TopicServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.TopicServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.InfoUtil;
 import org.slf4j.Logger;
 package com.cnlive.shenhe.job;
 import com.cnlive.shenhe.entity.ShyVideos;
-import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.VideosServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonConstStates;
 import org.slf4j.Logger;
@@ -6,8 +6,8 @@ import com.cnlive.shenhe.entity.ShyContent;
 import com.cnlive.shenhe.entity.ShyYidun;
 import com.cnlive.shenhe.enums.ImageLabels;
 import com.cnlive.shenhe.enums.TextLabels;
-import com.cnlive.shenhe.serviceImpl.ContentServiceImpl;
-import com.cnlive.shenhe.serviceImpl.YiDunServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.ContentServiceImpl;
+import com.cnlive.shenhe.service.serviceImpl.YiDunServiceImpl;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.HttpClientUtils;
 import com.cnlive.shenhe.utils.YiDunAntiFraudUtil;
+package com.cnlive.shenhe.service;
+
+import com.cnlive.shenhe.bean.ResponseBean;
+import com.cnlive.shenhe.dto.AudioDTO;
+import com.cnlive.shenhe.entity.ShyAudio;
+import com.github.pagehelper.PageInfo;
+
+import java.util.List;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-10-31 9:29
+ */
+public interface AudioService {
+    /**
+     * 查询音频记录是否存在
+     *
+     * @param audioId
+     * @return
+     */
+    ShyAudio getAudioMsg(String audioId);
+
+    /**
+     * 导入音频记录
+     *
+     * @param shyAudio
+     * @return
+     */
+    int importAudioMsg(ShyAudio shyAudio);
+
+    /**
+     * 修改音频记录
+     *
+     * @param shyAudio
+     * @return
+     */
+    int updateAudioMsg(ShyAudio shyAudio);
+
+    /**
+     * 根据id查询音频对象
+     *
+     * @param id
+     * @return
+     */
+    ShyAudio selectByPrimaryKey(Integer id);
+
+    /**
+     * 根据音频条件查询符合条件的音频集合
+     *
+     * @param shyAudio
+     * @return
+     */
+    List<ShyAudio> findshyAudio(ShyAudio shyAudio);
+
+    /**
+     * 回调 更新音频和审核状态
+     *
+     * @param shyAudio
+     * @param audioState 视频状态，1通过，2不通过
+     * @return
+     */
+    int updateAudioAndShenhe(ShyAudio shyAudio, int audioState);
+
+    /**
+     * 认领
+     *
+     * @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);
+
+    /**
+     * 回调
+     *
+     * @param shyAudioId
+     * @param msg
+     * @param userId
+     * @return
+     */
+    String repulse(String shyAudioId, String msg, String userId);
+
+    /**
+     * 根据id查询到音频对象进行修改
+     *
+     * @param id
+     * @param auditor_id
+     * @param updater
+     * @param attr_tags
+     * @param state
+     * @param msg
+     * @return
+     */
+    int updateAudio(Integer id, String auditor_id, String updater, String attr_tags, Integer state, String msg);
+
+    /**
+     * 分页查询音频数据
+     *
+     * @param audioDTO
+     * @return
+     */
+    PageInfo<ShyAudio> getListAudios(AudioDTO audioDTO);
+
+    /**
+     * 查看音频详情
+     *
+     * @param id
+     * @return
+     */
+    ShyAudio getDetailsAudio(Integer id);
+
+    /**
+     * 根据条件导出数据excel
+     *
+     * @param audioDTO
+     * @return
+     */
+
+    List<ShyAudio> findByCondition(AudioDTO audioDTO);
+
+    /**
+     * 根据sp、栏目、用户id来判断审核类型
+     *
+     * @param shyAudio
+     */
+    void getShenheType(ShyAudio shyAudio);
+
+    /**
+     * 易盾点播音频过滤
+     * 音频送审时 给了回调地址
+     * 送审类型：1:文本 2:图片 3.网页 4:点播音频
+     *
+     * @param shyAudio
+     */
+    void audioFilter(ShyAudio shyAudio);
+}
+package com.cnlive.shenhe.service;
+
+import com.cnlive.shenhe.dto.ChannelDTO;
+import com.cnlive.shenhe.entity.ShyChannel;
+import com.github.pagehelper.PageInfo;
+
+import java.util.List;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-10-31 9:53
+ */
+public interface ChannelService {
+    /**
+     * 根据条件查询频道集合
+     *
+     * @param shyChannel
+     * @return
+     */
+    List<ShyChannel> findshyChannel(ShyChannel shyChannel);
+
+    /**
+     * 修改频道 返回布尔类型
+     *
+     * @param shyChannel
+     * @return
+     */
+    boolean updateshyChannel(ShyChannel shyChannel);
+
+    /**
+     * 导入频道 返回布尔类型
+     *
+     * @param shyChannel
+     * @return
+     */
+    boolean impotChannel(ShyChannel shyChannel);
+
+    /**
+     * 获取分页、条件查询结果集
+     *
+     * @param channelDTO
+     * @return
+     */
+    PageInfo<ShyChannel> getPage(ChannelDTO channelDTO);
+
+    /**
+     * 获取频道详情
+     *
+     * @param id
+     * @return
+     */
+    ShyChannel getDetailsChannel(Integer id);
+
+    /**
+     * 修改频道状态
+     *
+     * @param ids
+     * @param state
+     * @param userId
+     * @param updater
+     * @param msg
+     * @return
+     */
+    boolean updateState(String ids, Integer state, String userId, String updater, String msg);
+
+    /**
+     * 根据主键查询频道对象
+     *
+     * @param id
+     * @return
+     */
+    ShyChannel selectByPrimaryKey(Integer id);
+
+    /**
+     * 根据主键修改频道对象
+     *
+     * @param channel
+     * @return
+     */
+    int updateByPrimaryKeySelective(ShyChannel channel);
+
+    /**
+     * 获得审核类型
+     *
+     * @param shyChannel
+     */
+    void getShenheType(ShyChannel shyChannel);
+}
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
@@ -7,6 +7,7 @@ import com.cnlive.shenhe.dto.AudioDTO;
 import com.cnlive.shenhe.entity.*;
 import com.cnlive.shenhe.mapper.ShyAudioMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
+import com.cnlive.shenhe.service.AudioService;
 import com.cnlive.shenhe.utils.*;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -26,7 +27,7 @@ import java.util.List;
  * @Date: 2020/6/8 10:19
  */
 @Service
-public class AudioServiceImpl {
+public class AudioServiceImpl implements AudioService {
     private static Logger logger = LoggerFactory.getLogger(AudioServiceImpl.class);
@@ -34,7 +35,7 @@ public class AudioServiceImpl {
     ShyAudioMapper shyAudioMapper;
     @Autowired
-    AudioServiceImpl audioService;
+    AudioService audioService;
     @Autowired
     AuditPass pass;
@@ -55,6 +56,7 @@ public class AudioServiceImpl {
      * @param audioId
      * @return
      */
+    @Override
     public ShyAudio getAudioMsg(String audioId) {
         return shyAudioMapper.getAudioMsg(audioId);
     }
@@ -65,6 +67,7 @@ public class AudioServiceImpl {
      * @param shyAudio
      * @return
      */
+    @Override
     public int importAudioMsg(ShyAudio shyAudio) {
         return shyAudioMapper.insertSelective(shyAudio);
     }
@@ -75,6 +78,7 @@ public class AudioServiceImpl {
      * @param shyAudio
      * @return
      */
+    @Override
     public int updateAudioMsg(ShyAudio shyAudio) {
         return shyAudioMapper.updateByPrimaryKeySelective(shyAudio);
     }
@@ -85,6 +89,7 @@ public class AudioServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyAudio selectByPrimaryKey(Integer id) {
         ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(id);
         return shyAudio;
@@ -96,18 +101,20 @@ public class AudioServiceImpl {
      * @param shyAudio
      * @return
      */
+    @Override
     public List<ShyAudio> findshyAudio(ShyAudio shyAudio) {
         List<ShyAudio> shyAudiolist = shyAudioMapper.selectByRowBounds(shyAudio, new RowBounds(0, 100));
         return shyAudiolist;
     }
     /**
-     * 更新音频和审核状态
+     * 回调 更新音频和审核状态
      *
      * @param shyAudio
      * @param audioState 视频状态，1通过，2不通过
      * @return
      */
+    @Override
     public int updateAudioAndShenhe(ShyAudio shyAudio, int audioState) {
         //修改点播云音频状态
         JSONObject result = pass.audioPass(shyAudio.getAudioId(), audioState, shyAudio.getAttr_tags(), shyAudio.getMsg(), shyAudio.getCallback());
@@ -141,6 +148,7 @@ public class AudioServiceImpl {
      * @param spid
      * @return
      */
+    @Override
     public Integer receive(String ids, Integer num, String userId, Integer spid) {
         Integer n = 0;
         if (CommonUtils.isNotEmpty(ids)) {
@@ -182,6 +190,7 @@ public class AudioServiceImpl {
      * @param userId
      * @return
      */
+    @Override
     public ResponseBean retReceive(String ids, String userId) {
         String[] cids = ids.split(",");
         for (String cid : cids) {
@@ -200,6 +209,7 @@ public class AudioServiceImpl {
         return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "已退领");
     }
+    @Override
     public String repulse(String shyAudioId, String msg, String userId) {
         String showMsg = "";
         ShyAudio shyAudio = audioService.selectByPrimaryKey(Integer.parseInt(shyAudioId));
@@ -243,6 +253,7 @@ public class AudioServiceImpl {
      * @param msg
      * @return
      */
+    @Override
     public int updateAudio(Integer id, String auditor_id, String updater, String attr_tags, Integer state, String msg) {
         ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(id);
         shyAudio.setAuditor_id(auditor_id);
@@ -268,6 +279,7 @@ public class AudioServiceImpl {
      * @param audioDTO
      * @return
      */
+    @Override
     public PageInfo<ShyAudio> getListAudios(AudioDTO audioDTO) {
         Example example = new Example(ShyAudio.class);
         Example.Criteria criteria = example.createCriteria();
@@ -314,7 +326,7 @@ public class AudioServiceImpl {
         return pageInfo;
     }
-
+    @Override
     public ShyAudio getDetailsAudio(Integer id) {
         ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(id);
         if (!shyAudio.getState().equals(CommonConst.AUDIT_INTT)) {
@@ -339,6 +351,7 @@ public class AudioServiceImpl {
      * @param audioDTO
      * @return
      */
+    @Override
     public List<ShyAudio> findByCondition(AudioDTO audioDTO) {
         Example example = new Example(ShyAudio.class);
         Example.Criteria criteria = example.createCriteria();
@@ -384,6 +397,7 @@ public class AudioServiceImpl {
      *
      * @param shyAudio
      */
+    @Override
     public void getShenheType(ShyAudio shyAudio) {
         //获取点播免审sp
         List<Integer> sites = sitesService.getBusinessList(CommonConst.BUSINESS_AUDIO);
@@ -407,6 +421,7 @@ public class AudioServiceImpl {
      * @param shyAudio
      * @return
      */
+    @Override
     public void audioFilter(ShyAudio shyAudio) {
         //调用易盾点播音频检测接口
         JSONObject jsonObject = YiDunAntiFraudUtil.submitAudioOnDemandUrl(shyAudio.getAudioUrl(), yiDun_audio_callback);
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -7,6 +7,7 @@ import com.cnlive.shenhe.entity.ShyChannel;
 import com.cnlive.shenhe.entity.ShyUsers;
 import com.cnlive.shenhe.mapper.ShyChannelMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
+import com.cnlive.shenhe.service.ChannelService;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
@@ -27,7 +28,7 @@ import java.util.List;
  * @Description:
  */
 @Service
-public class ChannelServiceImpl {
+public class ChannelServiceImpl implements ChannelService {
     private static Logger logger = LoggerFactory.getLogger(ChannelServiceImpl.class);
     @Autowired
@@ -46,6 +47,7 @@ public class ChannelServiceImpl {
      * @param shyChannel
      * @return
      */
+    @Override
     public List<ShyChannel> findshyChannel(ShyChannel shyChannel) {
         return shyChannelMapper.selectByRowBounds(shyChannel, new RowBounds(0, 100));
     }
@@ -56,6 +58,7 @@ public class ChannelServiceImpl {
      * @param shyChannel
      * @return
      */
+    @Override
     public boolean updateshyChannel(ShyChannel shyChannel) {
         int result = shyChannelMapper.updateByPrimaryKey(shyChannel);
         if (result == 0) {
@@ -70,6 +73,7 @@ public class ChannelServiceImpl {
      * @param shyChannel
      * @return
      */
+    @Override
     public boolean impotChannel(ShyChannel shyChannel) {
         int result = shyChannelMapper.insertSelective(shyChannel);
         if (result == 0) {
@@ -84,6 +88,7 @@ public class ChannelServiceImpl {
      * @param channelDTO
      * @return
      */
+    @Override
     public PageInfo<ShyChannel> getPage(ChannelDTO channelDTO) {
         logger.info("接受参数对象为，ChannelDTO:{}", JSON.toJSONString(channelDTO));
         Example example = new Example(ShyChannel.class);
@@ -137,6 +142,7 @@ public class ChannelServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyChannel getDetailsChannel(Integer id) {
         ShyChannel comment = shyChannelMapper.selectByPrimaryKey(id);
         if (!comment.getShenhe_status().equals(CommonConst.AUDIT_INTT)) {
@@ -165,6 +171,7 @@ public class ChannelServiceImpl {
      * @param msg
      * @return
      */
+    @Override
     public boolean updateState(String ids, Integer state, String userId, String updater, String msg) {
         boolean success = true;
         String[] channelIds = ids.split(",");
@@ -219,6 +226,7 @@ public class ChannelServiceImpl {
      * @param id
      * @return
      */
+    @Override
     public ShyChannel selectByPrimaryKey(Integer id) {
         ShyChannel shyChannel = shyChannelMapper.selectByPrimaryKey(id);
         return shyChannel;
@@ -230,6 +238,7 @@ public class ChannelServiceImpl {
      * @param channel
      * @return
      */
+    @Override
     public int updateByPrimaryKeySelective(ShyChannel channel) {
         return shyChannelMapper.updateByPrimaryKeySelective(channel);
     }
@@ -239,6 +248,7 @@ public class ChannelServiceImpl {
      *
      * @param shyChannel
      */
+    @Override
     public void getShenheType(ShyChannel shyChannel) {
         //获取直播频道免审sp
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.dto.CommentsDTO;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.cnlive.shenhe.bean.ErrorEnum;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.cnlive.shenhe.dto.ShyLogDTO;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.cnlive.shenhe.dto.SitesDTO;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -188,7 +188,7 @@ public class TopicServiceImpl {
      * @return
      */
     public boolean callback(String id, String msg, Integer state, String userId, String updater) {
-        boolean success = true;
+        boolean success;
         ShyTopic topic = shyTopicMapper.selectByPrimaryKey(Integer.parseInt(id));
         JSONObject params = new JSONObject();
         params.put("topic_id", topic.getTopic_id());
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.cnlive.shenhe.dto.UsersDTO;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.cnlive.shenhe.entity.ShyVideofilter;
 import com.cnlive.shenhe.mapper.ShyVideofilterMapper;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
-package com.cnlive.shenhe.serviceImpl;
+package com.cnlive.shenhe.service.serviceImpl;
 import com.alibaba.fastjson.JSON;
 import com.cnlive.shenhe.entity.ShyYidun;