点播音频入库

徐近程
1 parent 57d8fefe
Showing 6 changed files with 866 additions and 1 deletions
src/main/java/com/cnlive/shenhe/api/AudioControllerApi.java
src/main/java/com/cnlive/shenhe/entity/ShyAudio.java
src/main/java/com/cnlive/shenhe/mapper/ShyAudioMapper.java
src/main/java/com/cnlive/shenhe/serviceImpl/AudioServiceImpl.java
src/main/resources/application.properties
src/main/resources/mapper/ShyAudioMapper.xml
+package com.cnlive.shenhe.api;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.bean.ErrorEnum;
+import com.cnlive.shenhe.bean.ResponseBean;
+import com.cnlive.shenhe.entity.ShyAudio;
+import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.util.Date;
+
+/**
+ * @Author: xujincheng
+ * @Date: 2020/6/5 13:33
+ * @Description: 音频送审接口
+ */
+@Controller
+@RequestMapping("/api/audio")
+public class AudioControllerApi {
+
+    private static Logger logger = LoggerFactory.getLogger(AudioControllerApi.class);
+
+    @Autowired
+    AudioServiceImpl audioService;
+
+    /**
+     * 音频入库
+     *
+     * @param
+     * @multiplecategory 获取栏目分类
+     * @audioClipsName 获取音频上传人的id
+     * @soure 音频来源
+     * @audioId 音频id
+     * @audioTitle 音频标题
+     * @audioUrl 音频url
+     * @audioCoverUrl 封面图
+     * @audioIntro 音频简介
+     * @audioTag 音频标签
+     * @audioKeyword 音频关键字
+     * @uploadTime 上传时间
+     * @priority 优先级（1-热点 0-非热点）
+     * @callback 回调函数
+     * @spId spId
+     * @bucketName 存储空间名
+     * @bucketType 金山或七牛
+     * @duration 时长
+     * @uploader 上传人
+     * @contactInfo 联系方式
+     * @extendField 扩展字段
+     */
+    @PostMapping("/import")
+    @ResponseBody
+    public ResponseBean importAudio(String param) {
+        logger.info("点播音频入库，param=====" + param);
+        ShyAudio shyAudio = JSONObject.parseObject(param, ShyAudio.class);
+        ShyAudio audioMsg = audioService.getAudioMsg(shyAudio.getAudioId());
+        if (audioMsg != null) {
+            shyAudio.setId(audioMsg.getId());
+            shyAudio.setUpdateTime(new Date());
+            audioService.updateAudioMsg(shyAudio);
+        }
+        shyAudio.setCreateTime(new Date());
+        audioService.importAudioMsg(shyAudio);
+        return new ResponseBean(ErrorEnum.SUCCESS);
+    }
+
+}
+package com.cnlive.shenhe.entity;
+
+import java.util.Date;
+import javax.persistence.*;
+
+@Table(name = "shy_audio")
+public class ShyAudio {
+    @Id
+    private Integer id;
+
+    /**
+     * 获取栏目分类
+     */
+    private String multiplecategory;
+
+    /**
+     * 获取音频上传人的id
+     */
+    @Column(name="audioClipsName")
+    private String audioClipsName;
+
+    /**
+     * 音频来源
+     */
+    private Integer soure;
+
+    /**
+     * 音频id
+     */
+    @Column(name="audioId")
+    private String audioId;
+
+    /**
+     * 音频标题
+     */
+    @Column(name="audioTitle")
+    private String audioTitle;
+
+    /**
+     * 音频url
+     */
+    @Column(name="audioUrl")
+    private String audioUrl;
+
+    /**
+     * 封面图
+     */
+    @Column(name="audioCoverUrl")
+    private String audioCoverUrl;
+
+    /**
+     * 音频简介
+     */
+    @Column(name="audioIntro")
+    private String audioIntro;
+
+    /**
+     * 音频标签
+     */
+    @Column(name="audioTag")
+    private String audioTag;
+
+    /**
+     * 音频关键字
+     */
+    @Column(name="audioKeyword")
+    private String audioKeyword;
+
+    /**
+     * 上传时间
+     */
+    @Column(name="uploadTime")
+    private Date uploadTime;
+
+    private Integer priority;
+
+    /**
+     * 回调函数
+     */
+    private String callback;
+
+    /**
+     * spId
+     */
+    @Column(name="spId")
+    private Integer spId;
+
+    /**
+     * 存储空间名
+     */
+    @Column(name="bucketName")
+    private String bucketName;
+
+    /**
+     * 1:金山；2:七牛
+     */
+    @Column(name="bucketType")
+    private Integer bucketType;
+
+    /**
+     * 音频时长，单位s
+     */
+    private Integer duration;
+
+    /**
+     * 上传人
+     */
+    private String uploader;
+
+    /**
+     * 联系方式
+     */
+    @Column(name="contactInfo")
+    private String contactInfo;
+
+    /**
+     * 扩展字段
+     */
+    @Column(name="extendField")
+    private String extendField;
+
+    /**
+     * 审核员id
+     */
+    private String auditor_id;
+
+    /**
+     * 常用审核意见
+     */
+    private String attr_tags;
+
+    /**
+     * 拒绝理由
+     */
+    private String msg;
+
+    /**
+     * 1:免审，2:机审，3:人工审
+     */
+    private Integer shenhe_type;
+
+    /**
+     * 0.未审核,1:已审核,2.拒绝
+     */
+    private Integer state;
+
+    /**
+     * 创建时间
+     */
+    @Column(name="createTime")
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    @Column(name="updateTime")
+    private Date updateTime;
+
+    /**
+     * ：未领取；1：已领取
+     */
+    private Integer receive;
+
+    /**
+     * 领取人id
+     */
+    private String receive_user_id;
+
+    /**
+     * @return id
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     * @param id
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    /**
+     * 获取获取栏目分类
+     *
+     * @return multiplecategory - 获取栏目分类
+     */
+    public String getMultiplecategory() {
+        return multiplecategory;
+    }
+
+    /**
+     * 设置获取栏目分类
+     *
+     * @param multiplecategory 获取栏目分类
+     */
+    public void setMultiplecategory(String multiplecategory) {
+        this.multiplecategory = multiplecategory;
+    }
+
+    /**
+     * 获取获取音频上传人的id
+     *
+     * @return audioClipsName - 获取音频上传人的id
+     */
+    public String getAudioClipsName() {
+        return audioClipsName;
+    }
+
+    /**
+     * 设置获取音频上传人的id
+     *
+     * @param audioClipsName 获取音频上传人的id
+     */
+    public void setAudioClipsName(String audioClipsName) {
+        this.audioClipsName = audioClipsName;
+    }
+
+    /**
+     * 获取音频来源
+     *
+     * @return soure - 音频来源
+     */
+    public Integer getSoure() {
+        return soure;
+    }
+
+    /**
+     * 设置音频来源
+     *
+     * @param soure 音频来源
+     */
+    public void setSoure(Integer soure) {
+        this.soure = soure;
+    }
+
+    /**
+     * 获取音频id
+     *
+     * @return audioId - 音频id
+     */
+    public String getAudioId() {
+        return audioId;
+    }
+
+    /**
+     * 设置音频id
+     *
+     * @param audioId 音频id
+     */
+    public void setAudioId(String audioId) {
+        this.audioId = audioId;
+    }
+
+    /**
+     * 获取音频标题
+     *
+     * @return audioTitle - 音频标题
+     */
+    public String getAudioTitle() {
+        return audioTitle;
+    }
+
+    /**
+     * 设置音频标题
+     *
+     * @param audioTitle 音频标题
+     */
+    public void setAudioTitle(String audioTitle) {
+        this.audioTitle = audioTitle;
+    }
+
+    /**
+     * 获取音频url
+     *
+     * @return audioUrl - 音频url
+     */
+    public String getAudioUrl() {
+        return audioUrl;
+    }
+
+    /**
+     * 设置音频url
+     *
+     * @param audioUrl 音频url
+     */
+    public void setAudioUrl(String audioUrl) {
+        this.audioUrl = audioUrl;
+    }
+
+    /**
+     * 获取封面图
+     *
+     * @return audioCoverUrl - 封面图
+     */
+    public String getAudioCoverUrl() {
+        return audioCoverUrl;
+    }
+
+    /**
+     * 设置封面图
+     *
+     * @param audioCoverUrl 封面图
+     */
+    public void setAudioCoverUrl(String audioCoverUrl) {
+        this.audioCoverUrl = audioCoverUrl;
+    }
+
+    /**
+     * 获取音频简介
+     *
+     * @return audioIntro - 音频简介
+     */
+    public String getAudioIntro() {
+        return audioIntro;
+    }
+
+    /**
+     * 设置音频简介
+     *
+     * @param audioIntro 音频简介
+     */
+    public void setAudioIntro(String audioIntro) {
+        this.audioIntro = audioIntro;
+    }
+
+    /**
+     * 获取音频标签
+     *
+     * @return audioTag - 音频标签
+     */
+    public String getAudioTag() {
+        return audioTag;
+    }
+
+    /**
+     * 设置音频标签
+     *
+     * @param audioTag 音频标签
+     */
+    public void setAudioTag(String audioTag) {
+        this.audioTag = audioTag;
+    }
+
+    /**
+     * 获取音频关键字
+     *
+     * @return audioKeyword - 音频关键字
+     */
+    public String getAudioKeyword() {
+        return audioKeyword;
+    }
+
+    /**
+     * 设置音频关键字
+     *
+     * @param audioKeyword 音频关键字
+     */
+    public void setAudioKeyword(String audioKeyword) {
+        this.audioKeyword = audioKeyword;
+    }
+
+    /**
+     * 获取上传时间
+     *
+     * @return uploadTime - 上传时间
+     */
+    public Date getUploadTime() {
+        return uploadTime;
+    }
+
+    /**
+     * 设置上传时间
+     *
+     * @param uploadTime 上传时间
+     */
+    public void setUploadTime(Date uploadTime) {
+        this.uploadTime = uploadTime;
+    }
+
+    /**
+     * @return priority
+     */
+    public Integer getPriority() {
+        return priority;
+    }
+
+    /**
+     * @param priority
+     */
+    public void setPriority(Integer priority) {
+        this.priority = priority;
+    }
+
+    /**
+     * 获取回调函数
+     *
+     * @return callback - 回调函数
+     */
+    public String getCallback() {
+        return callback;
+    }
+
+    /**
+     * 设置回调函数
+     *
+     * @param callback 回调函数
+     */
+    public void setCallback(String callback) {
+        this.callback = callback;
+    }
+
+    /**
+     * 获取spId
+     *
+     * @return spId - spId
+     */
+    public Integer getSpId() {
+        return spId;
+    }
+
+    /**
+     * 设置spId
+     *
+     * @param spId spId
+     */
+    public void setSpId(Integer spId) {
+        this.spId = spId;
+    }
+
+    /**
+     * 获取存储空间名
+     *
+     * @return bucketName - 存储空间名
+     */
+    public String getBucketName() {
+        return bucketName;
+    }
+
+    /**
+     * 设置存储空间名
+     *
+     * @param bucketName 存储空间名
+     */
+    public void setBucketName(String bucketName) {
+        this.bucketName = bucketName;
+    }
+
+    /**
+     * 获取1:金山；2:七牛
+     *
+     * @return bucketType - 1:金山；2:七牛
+     */
+    public Integer getBucketType() {
+        return bucketType;
+    }
+
+    /**
+     * 设置1:金山；2:七牛
+     *
+     * @param bucketType 1:金山；2:七牛
+     */
+    public void setBucketType(Integer bucketType) {
+        this.bucketType = bucketType;
+    }
+
+    /**
+     * 获取音频时长，单位s
+     *
+     * @return duration - 音频时长，单位s
+     */
+    public Integer getDuration() {
+        return duration;
+    }
+
+    /**
+     * 设置音频时长，单位s
+     *
+     * @param duration 音频时长，单位s
+     */
+    public void setDuration(Integer duration) {
+        this.duration = duration;
+    }
+
+    /**
+     * 获取上传人
+     *
+     * @return uploader - 上传人
+     */
+    public String getUploader() {
+        return uploader;
+    }
+
+    /**
+     * 设置上传人
+     *
+     * @param uploader 上传人
+     */
+    public void setUploader(String uploader) {
+        this.uploader = uploader;
+    }
+
+    /**
+     * 获取联系方式
+     *
+     * @return contactInfo - 联系方式
+     */
+    public String getContactInfo() {
+        return contactInfo;
+    }
+
+    /**
+     * 设置联系方式
+     *
+     * @param contactInfo 联系方式
+     */
+    public void setContactInfo(String contactInfo) {
+        this.contactInfo = contactInfo;
+    }
+
+    /**
+     * 获取扩展字段
+     *
+     * @return extendField - 扩展字段
+     */
+    public String getExtendField() {
+        return extendField;
+    }
+
+    /**
+     * 设置扩展字段
+     *
+     * @param extendField 扩展字段
+     */
+    public void setExtendField(String extendField) {
+        this.extendField = extendField;
+    }
+
+    /**
+     * 获取审核员id
+     *
+     * @return auditor_id - 审核员id
+     */
+    public String getAuditor_id() {
+        return auditor_id;
+    }
+
+    /**
+     * 设置审核员id
+     *
+     * @param auditor_id 审核员id
+     */
+    public void setAuditor_id(String auditor_id) {
+        this.auditor_id = auditor_id;
+    }
+
+    /**
+     * 获取常用审核意见
+     *
+     * @return attr_tags - 常用审核意见
+     */
+    public String getAttr_tags() {
+        return attr_tags;
+    }
+
+    /**
+     * 设置常用审核意见
+     *
+     * @param attr_tags 常用审核意见
+     */
+    public void setAttr_tags(String attr_tags) {
+        this.attr_tags = attr_tags;
+    }
+
+    /**
+     * 获取拒绝理由
+     *
+     * @return msg - 拒绝理由
+     */
+    public String getMsg() {
+        return msg;
+    }
+
+    /**
+     * 设置拒绝理由
+     *
+     * @param msg 拒绝理由
+     */
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    /**
+     * 获取1:免审，2:机审，3:人工审
+     *
+     * @return shenhe_type - 1:免审，2:机审，3:人工审
+     */
+    public Integer getShenhe_type() {
+        return shenhe_type;
+    }
+
+    /**
+     * 设置1:免审，2:机审，3:人工审
+     *
+     * @param shenhe_type 1:免审，2:机审，3:人工审
+     */
+    public void setShenhe_type(Integer shenhe_type) {
+        this.shenhe_type = shenhe_type;
+    }
+
+    /**
+     * 获取0.未审核,1:已审核,2.拒绝
+     *
+     * @return state - 0.未审核,1:已审核,2.拒绝
+     */
+    public Integer getState() {
+        return state;
+    }
+
+    /**
+     * 设置0.未审核,1:已审核,2.拒绝
+     *
+     * @param state 0.未审核,1:已审核,2.拒绝
+     */
+    public void setState(Integer state) {
+        this.state = state;
+    }
+
+    /**
+     * 获取创建时间
+     *
+     * @return createTime - 创建时间
+     */
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    /**
+     * 设置创建时间
+     *
+     * @param createTime 创建时间
+     */
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    /**
+     * 获取修改时间
+     *
+     * @return updateTime - 修改时间
+     */
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    /**
+     * 设置修改时间
+     *
+     * @param updateTime 修改时间
+     */
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    /**
+     * 获取：未领取；1：已领取
+     *
+     * @return receive - ：未领取；1：已领取
+     */
+    public Integer getReceive() {
+        return receive;
+    }
+
+    /**
+     * 设置：未领取；1：已领取
+     *
+     * @param receive ：未领取；1：已领取
+     */
+    public void setReceive(Integer receive) {
+        this.receive = receive;
+    }
+
+    /**
+     * 获取领取人id
+     *
+     * @return receive_user_id - 领取人id
+     */
+    public String getReceive_user_id() {
+        return receive_user_id;
+    }
+
+    /**
+     * 设置领取人id
+     *
+     * @param receive_user_id 领取人id
+     */
+    public void setReceive_user_id(String receive_user_id) {
+        this.receive_user_id = receive_user_id;
+    }
+}
 \ No newline at end of file
+package com.cnlive.shenhe.mapper;
+
+import com.cnlive.shenhe.entity.ShyAudio;
+import org.apache.ibatis.annotations.Param;
+import tk.mybatis.mapper.common.Mapper;
+
+
+public interface ShyAudioMapper extends Mapper<ShyAudio> {
+
+    /**
+     * 查询音频记录是否存在
+     *
+     * @param audioId 音频id
+     * @return
+     */
+    ShyAudio getAudioMsg(@Param(value = "audioId") String audioId);
+
+}
 \ No newline at end of file
+package com.cnlive.shenhe.serviceImpl;
+
+import com.cnlive.shenhe.entity.ShyAudio;
+import com.cnlive.shenhe.mapper.ShyAudioMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author: xujincheng
+ * @Date: 2020/6/8 10:19
+ */
+@Service
+public class AudioServiceImpl {
+
+    @Autowired
+    ShyAudioMapper shyAudioMapper;
+
+    public ShyAudio getAudioMsg(String audioId) {
+        return shyAudioMapper.getAudioMsg(audioId);
+    }
+
+    public int importAudioMsg(ShyAudio ShyAudio) {
+        return shyAudioMapper.insertSelective(ShyAudio);
+    }
+
+    public int updateAudioMsg(ShyAudio ShyAudio) {
+        return shyAudioMapper.updateByPrimaryKeySelective(ShyAudio);
+    }
+}
@@ -32,7 +32,7 @@ spring.thymeleaf.cache=false
 #\u6253\u5370\u8fd0\u884c\u65f6\u7684sql
 #logging.level.com.cnlive.shenhe.mapper=debug
  
-mybatis.mapper-locations=classpath:mapping/*.xml
+mybatis.mapper-locations=classpath:mapper/*.xml
 mybatis.type-aliases-package=com.cnlive.shenhe.entity
 server.port=82
  
+<?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.cnlive.shenhe.mapper.ShyAudioMapper">
+  <resultMap id="BaseResultMap" type="com.cnlive.shenhe.entity.ShyAudio">
+    <!--
+      WARNING - @mbg.generated
+    -->
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="multiplecategory" jdbcType="VARCHAR" property="multiplecategory" />
+    <result column="audioClipsName" jdbcType="VARCHAR" property="audioClipsName" />
+    <result column="soure" jdbcType="INTEGER" property="soure" />
+    <result column="audioId" jdbcType="VARCHAR" property="audioId" />
+    <result column="audioTitle" jdbcType="VARCHAR" property="audioTitle" />
+    <result column="audioUrl" jdbcType="VARCHAR" property="audioUrl" />
+    <result column="audioCoverUrl" jdbcType="VARCHAR" property="audioCoverUrl" />
+    <result column="audioIntro" jdbcType="VARCHAR" property="audioIntro" />
+    <result column="audioTag" jdbcType="VARCHAR" property="audioTag" />
+    <result column="audioKeyword" jdbcType="VARCHAR" property="audioKeyword" />
+    <result column="uploadTime" jdbcType="TIMESTAMP" property="uploadTime" />
+    <result column="priority" jdbcType="INTEGER" property="priority" />
+    <result column="callback" jdbcType="VARCHAR" property="callback" />
+    <result column="spId" jdbcType="INTEGER" property="spId" />
+    <result column="bucketName" jdbcType="VARCHAR" property="bucketName" />
+    <result column="bucketType" jdbcType="INTEGER" property="bucketType" />
+    <result column="duration" jdbcType="INTEGER" property="duration" />
+    <result column="uploader" jdbcType="VARCHAR" property="uploader" />
+    <result column="contactInfo" jdbcType="VARCHAR" property="contactInfo" />
+    <result column="extendField" jdbcType="VARCHAR" property="extendField" />
+    <result column="auditor_id" jdbcType="VARCHAR" property="auditor_id" />
+    <result column="attr_tags" jdbcType="VARCHAR" property="attr_tags" />
+    <result column="msg" jdbcType="VARCHAR" property="msg" />
+    <result column="shenhe_type" jdbcType="INTEGER" property="shenhe_type" />
+    <result column="state" jdbcType="INTEGER" property="state" />
+    <result column="createTime" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="updateTime" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="receive" jdbcType="INTEGER" property="receive" />
+    <result column="receive_user_id" jdbcType="VARCHAR" property="receive_user_id" />
+  </resultMap>
+
+  <select id="getAudioMsg" resultType="com.cnlive.shenhe.entity.ShyAudio">
+    SELECT *
+    FROM shy_audio
+    where audioId = #{audioId,jdbcType=VARCHAR};
+  </select>
+</mapper>
 \ No newline at end of file