增加活动导入Api接口

王言钊
1 parent 7de26c70
Showing 5 changed files with 86 additions and 2 deletions
src/main/java/com/cnlive/shenhe/api/ShyActivityControllerApi.java
src/main/java/com/cnlive/shenhe/controller/LiveController.java
src/main/java/com/cnlive/shenhe/mapper/ShyActivityMapper.java
src/main/java/com/cnlive/shenhe/serviceImpl/ShyActivityImpl.java
src/main/resources/mapper/ShyActivityMapper.xml
+package com.cnlive.shenhe.api;
+
+import com.alibaba.fastjson.JSON;
+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 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: yan-zhao-wang
+ * @DateTime: 2022-06-14 9:18
+ * 活动导入Api接口
+ */
+@Controller
+@RequestMapping("/api/activity")
+public class ShyActivityControllerApi {
+
+    private static Logger logger = LoggerFactory.getLogger(ShyActivityControllerApi.class);
+
+    @Autowired
+    private ShyActivityImpl shyActivityImpl;
+
+    @PostMapping("/import")
+    @ResponseBody
+    public ResponseBean insterShyActivity(String param) {
+        logger.info("活动添加,param====={}", param);
+        // 转换JSON对象
+        JSONObject json = JSONObject.parseObject(param);
+        Integer id = json.getInteger("id");
+        String activity = json.getString("activity");
+        // 封装对象
+        ShyActivity shyActivity = new ShyActivity();
+        shyActivity.setId(id);
+        shyActivity.setActivity(activity);
+        shyActivity.setCreate_time(new Date());
+        shyActivity.setUpdate_time(new Date());
+        shyActivity.setExempt_from_trial(0);
+        logger.info("封装对象为,{}", JSON.toJSON(shyActivity));
+        // 根据id查询是否存在
+        ShyActivity shyActivityObj = shyActivityImpl.selectById(id);
+        // 如果对象不存在，就直接添加
+        if (shyActivityObj == null) {
+            int result = shyActivityImpl.insertShyActivity(shyActivity);
+            if (result > 0) {
+                return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "当前活动添加成功");
+            }
+            return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "当前活动添加失败，请重试");
+        }
+        // 如果对象不存在，就直接返回错误码
+        return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "当前活动id已存在,请更换id重试");
+    }
+}
@@ -259,8 +259,8 @@ public class LiveController extends BaseController {
     }
  
     /**
-     * 打回(审核拒绝)
-     *
+     * 打回(审核通过、拒绝、强制下线)
+     * status 3、4、6
      * @param ids
      * @param msg
      * @param session
@@ -9,5 +9,17 @@ import java.util.List;
 public interface ShyActivityMapper extends Mapper<ShyActivity> {
  
  
+    /**
+     * 根据免审状态查询
+     * @param exempt_from_trial
+     * @return
+     */
     List<Integer> selectAllByExempt_from_trial(@Param("exempt_from_trial") Integer exempt_from_trial);
+
+    /**
+     * 根据id查询是否存在该对象
+     * @param id
+     * @return
+     */
+    ShyActivity selectById(@Param("id")Integer id);
 }
 \ No newline at end of file
@@ -123,5 +123,12 @@ public class ShyActivityImpl {
         List<ShyActivity> shyActivities = shyActivityMapper.selectAll();
         return shyActivities;
     }
+    /**
+     * 根据id查询单个对象
+     */
+    public ShyActivity selectById(Integer id){
+        ShyActivity shyActivity = shyActivityMapper.selectById(id);
+        return shyActivity;
+    }
  
 }
@@ -14,6 +14,9 @@
   <select id="selectAllByExempt_from_trial" resultType="java.lang.Integer">
     select id from shy_activity where exempt_from_trial=${exempt_from_trial};
   </select>
+    <select id="selectById" resultType="com.cnlive.shenhe.entity.ShyActivity">
+      select * from shy_activity where id=${id}
+    </select>
  
  
 </mapper>
 \ No newline at end of file