package com.fzzy.igds.api.v1;
|
|
import com.fzzy.igds.api.v1.data.ApiV1Req;
|
import com.fzzy.igds.api.v1.data.ApiV1Resp;
|
import com.fzzy.igds.api.v1.service.*;
|
import com.fzzy.igds.api.v1.util.ApiV1Constant;
|
import com.fzzy.igds.constant.Constant;
|
import com.fzzy.igds.domain.GatewaySer;
|
import com.fzzy.igds.service.GatewaySerService;
|
import com.alibaba.fastjson.JSONObject;
|
import lombok.extern.slf4j.Slf4j;
|
import com.ruoyi.common.utils.StringUtils;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @Description 监管接口解析入口
|
* @Author CZT
|
* @Date 2026/1/7 10:25
|
*/
|
@Slf4j
|
@Controller
|
@RequestMapping("api/igdss/v1")
|
public class ApiV1Controller {
|
|
@Resource
|
private GatewaySerService gatewaySerService;
|
@Resource
|
private ApiV1Service3010 apiV1Service3010;
|
@Resource
|
private ApiV1Service3020 apiV1Service3020;
|
@Resource
|
private ApiV1Service3021 apiV1Service3021;
|
@Resource
|
private ApiV1Service3030 apiV1Service3030;
|
@Resource
|
private ApiV1Service3031 apiV1Service3031;
|
|
|
@PostMapping
|
@ResponseBody
|
public ApiV1Resp<Object> gateway(@RequestBody ApiV1Req<JSONObject> req) {
|
|
log.info("质押监管接口V1，收到库区网关信息={}", req);
|
try {
|
|
//参数校验
|
if (req == null) {
|
return ApiV1Resp.error("参数有误！", req);
|
}
|
|
//校验接口编码和网关SN
|
if (StringUtils.isEmpty(req.getFunctionId()) || StringUtils.isEmpty(req.getSn())) {
|
return ApiV1Resp.error("参数有误！", req);
|
}
|
|
//校验网关是否存在
|
GatewaySer gatewaySer = gatewaySerService.getCacheSerById(null, req.getSn());
|
if (null == gatewaySer) {
|
return ApiV1Resp.error("当前网关<SN=" + req.getSn() + ">暂未添加，请核查！", req);
|
}
|
|
//异步更新网关状态
|
gatewaySerService.updateStatus(gatewaySer, Constant.YN_Y, ApiV1Constant.API_FUNCTION_3010.equals(req.getFunctionId()));
|
|
//解析
|
String functionId = req.getFunctionId();
|
switch (functionId) {
|
case ApiV1Constant.API_FUNCTION_3010:
|
return apiV1Service3010.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3020:
|
return apiV1Service3020.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3021:
|
return apiV1Service3021.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3030:
|
return apiV1Service3030.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3031:
|
return apiV1Service3031.analysis(req, gatewaySer);
|
}
|
|
return ApiV1Resp.error("接口编码<" + functionId + ">不存在，请核查！", req);
|
|
} catch (Exception e) {
|
|
log.info("质押监管接口V1，接口解析异常={}", e.toString());
|
|
return ApiV1Resp.error("解析异常！", req);
|
}
|
|
}
|
|
}
|
