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.data.Param3030;
|
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.util.StreamUtils;
|
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;
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.nio.charset.StandardCharsets;
|
|
/**
|
* @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 ApiV1Service3022 apiV1Service3022;
|
@Resource
|
private ApiV1Service3030 apiV1Service3030;
|
@Resource
|
private ApiV1Service3031 apiV1Service3031;
|
@Resource
|
private ApiV1Service3032 apiV1Service3032;
|
|
@PostMapping
|
@ResponseBody
|
public ApiV1Resp<Object> gateway(@RequestBody ApiV1Req<Object> req) {
|
|
log.debug("质押监管接口V1，收到库区网关信息={}", req.getFunctionId());
|
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_3022:
|
return apiV1Service3022.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3030:
|
return apiV1Service3030.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3031:
|
return apiV1Service3031.analysis(req, gatewaySer);
|
case ApiV1Constant.API_FUNCTION_3032:
|
return apiV1Service3032.analysis(req, gatewaySer);
|
}
|
|
return ApiV1Resp.error("接口编码<" + functionId + ">不存在，请核查！", req);
|
|
} catch (Exception e) {
|
|
log.info("质押监管接口V1，接口解析异常={}", e.toString());
|
|
return ApiV1Resp.error("解析异常！", req);
|
}
|
|
}
|
|
// @PostMapping
|
// @ResponseBody
|
// public ApiV1Resp<Object> receiveRawRequest(HttpServletRequest request) throws IOException {
|
// // 读取原始请求体
|
// String rawJson = StreamUtils.copyToString(request.getInputStream(), StandardCharsets.UTF_8);
|
// System.out.println("原始请求JSON：" + rawJson);
|
//// System.out.println("第92列字符：" + (rawJson.length() >= 92 ? rawJson.charAt(91) : "长度不足"));
|
// rawJson = cleanInvalidUtf8(rawJson);
|
// ApiV1Req<Object> req = JSONObject.parseObject(rawJson, ApiV1Req.class);
|
//
|
//
|
// log.debug("质押监管接口V1，收到库区网关信息={}", req.getFunctionId());
|
// 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_3022:
|
// return apiV1Service3022.analysis(req, gatewaySer);
|
// case ApiV1Constant.API_FUNCTION_3030:
|
// return apiV1Service3030.analysis(req, gatewaySer);
|
// case ApiV1Constant.API_FUNCTION_3031:
|
// return apiV1Service3031.analysis(req, gatewaySer);
|
// case ApiV1Constant.API_FUNCTION_3032:
|
// return apiV1Service3032.analysis(req, gatewaySer);
|
// }
|
//
|
// return ApiV1Resp.error("接口编码<" + functionId + ">不存在，请核查！", req);
|
//
|
// } catch (Exception e) {
|
//
|
// log.info("质押监管接口V1，接口解析异常={}", e.toString());
|
//
|
// return ApiV1Resp.error("解析异常！", req);
|
// }
|
//// // 后续逻辑...
|
//// return "success";
|
// }
|
|
// 清理无效UTF-8字符和控制字符
|
public static String cleanInvalidUtf8(String json) {
|
if (json == null) return null;
|
// 移除无效UTF-8字节和控制字符（除了换行、回车、制表符）
|
return json.replaceAll("[\\x00-\\x08\\x0B\\x0C\\x0E-\\x1F\\x7F-\\x9F\\xC1]", "");
|
}
|
|
}
|
