ShyActivityControllerApi.java 2.21 KB
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.service.ShyActivityService;
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;

/**
 * @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 ShyActivityService shyActivityService;

    @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);
        logger.info("封装对象为:{}", JSON.toJSON(shyActivity));
        // 根据id查询是否存在
        Boolean shyActivityObj = shyActivityService.selectById(id);
        // 如果对象不存在,就直接添加
        if (shyActivityObj) {
            Boolean result = shyActivityService.insertShyActivity(shyActivity);
            if (result) {
                return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "当前活动添加成功");
            }
            return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "当前活动添加失败,请重试");
        }
        // 如果对象存在,就直接返回错误码
        return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "当前活动id已存在,请更换id重试");
    }
}