Gb1400Controller.java 2.6 KB
package com.viontech.controller;

import com.alibaba.fastjson.JSONObject;
import com.viontech.constant.SystemConstants;
import com.viontech.service.Gb1400Service;
import com.viontech.utils.Gb1400ResponseUtil;
import com.viontech.utils.JsonMessage;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;

@Slf4j
@RestController
@RequestMapping("/VIID")
public class Gb1400Controller {

    @Resource
    private Gb1400Service gb1400Service;
    /**
     * 批量订阅
     * @param params
     * @return
     */
    @RequestMapping(value = "/Subscribes" ,method = RequestMethod.POST)
    @ResponseBody
    public JSONObject subscribes(@RequestBody String params){
        log.info("收到请求[Subscribes.request]:{}", params);
        JsonMessage vo = gb1400Service.subscribes(params);
        log.info("响应[Subscribes.request]:{}", JSONObject.toJSONString(vo));
        if (SystemConstants.APP_CODE_SUCCESS == vo.getCode()) {
            return Gb1400ResponseUtil.responseStatusListObject((List<JSONObject>) vo.getData());
        } else {
            return Gb1400ResponseUtil.error(1, vo.getMsg(),"/VIID/Subscribes");
        }
    }

    /**
     * 取消订阅
     * @param ID
     * @return
     */
    @RequestMapping(value = "/Subscribes/{ID}" ,method = RequestMethod.PUT)
    @ResponseBody
    public JSONObject unSubscribes(@PathVariable String ID, @RequestBody String params){
        log.info("收到请求[unSubscribes.request]:{}-{}", ID, params);
        JsonMessage vo = gb1400Service.unSubscribes(ID, params);
        log.info("响应[unSubscribes.request]:{}-{}", ID, JSONObject.toJSONString(vo));
        if (SystemConstants.APP_CODE_SUCCESS == vo.getCode()) {
            return Gb1400ResponseUtil.success("/VIID/Subscribes/" + ID);
        } else {
            return Gb1400ResponseUtil.error(1, vo.getMsg(),"/VIID/Subscribes/" + ID);
        }
    }


    /**
     * 注册接口
     * @param params
     * @return
     */
    @RequestMapping(value = "/System/Register" ,method = RequestMethod.POST)
    @ResponseBody
    public JSONObject Register(@RequestBody String params){
        log.info("收到请求[Register.request]:{}", params);
        JsonMessage vo = gb1400Service.registerToMySystem(params);
        log.info("响应[Register.request]:{}", JSONObject.toJSONString(vo));
        if (SystemConstants.APP_CODE_SUCCESS == vo.getCode()) {
            return Gb1400ResponseUtil.success("/VIID/System/Register");
        } else {
            return Gb1400ResponseUtil.error(1, vo.getMsg(),"/VIID/System/Register");
        }
    }
}