package com.fzzy.push.gd2022;
|
|
import com.alibaba.fastjson.JSON;
|
import com.fzzy.api.Constant;
|
import com.fzzy.api.data.ApiParam;
|
import com.fzzy.api.data.PushProtocol;
|
import com.fzzy.api.dto.ResponseDto;
|
import com.fzzy.api.entity.ApiConfs;
|
import com.fzzy.api.entity.ApiLog;
|
import com.fzzy.api.service.ApiCommonService;
|
import com.fzzy.api.service.ApiRemoteService;
|
import com.fzzy.api.utils.*;
|
import com.fzzy.api.view.repository.ApiLogRep;
|
import com.fzzy.push.gd2022.dto.*;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* @author vince.xu
|
* @Title: ApiService
|
* @ProjectName igds-api
|
* @Description: 上传数据服务类
|
* @date 2022-9-216:27
|
*/
|
@Slf4j
|
@Data
|
@Service
|
public class GD2022ApiRemoteService2022 implements ApiRemoteService {
|
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
private ApiCommonService apiCommonService;
|
|
@Autowired
|
private ApiLogRep apiLogRep;
|
|
@Override
|
public String getProtocol() {
|
return PushProtocol.SB_GD_2022.getCode();
|
}
|
|
@Override
|
public ResponseDto pushData(ApiParam param, ApiConfs conf, Object data) {
|
String inteId = param.getInteId();
|
String kqdm = param.getKqdm();
|
String bizId = param.getBizId();
|
|
try {
|
|
if (null == conf) {
|
conf = apiCommonService.getConf(kqdm);
|
}
|
//获取TOKEN
|
GD2022AuthToken token = getGD2022AuthToken(conf);
|
|
//添加LOGO
|
ApiLog apiLog = new ApiLog();
|
apiLog.setId(ContextUtil.getUUID());
|
apiLog.setInteId(inteId);
|
String jsonData = getJsonData(inteId, data, conf.getApiUrl(), token);
|
inteId = getInteId(inteId);
|
if(StringUtils.isEmpty(inteId)){
|
ResponseDto responseDto = new ResponseDto(99, "没有获取到接口", bizId);
|
apiLog.setStatus(99);
|
apiLog.setResult("没有获取到接口");
|
apiLogRep.save(apiLog);
|
return responseDto;
|
}
|
apiLog.setData(jsonData);
|
apiLog.setKqdm(kqdm);
|
apiLog.setUploadTime(new Date());
|
|
if (conf == null) {
|
ResponseDto responseDto = new ResponseDto(99, "没有获取到上传配置", bizId);
|
apiLog.setStatus(99);
|
apiLog.setResult("没有获取到上传配置");
|
apiLogRep.save(apiLog);
|
return responseDto;
|
}
|
if (null == token) {
|
ResponseDto responseDto = new ResponseDto(99, "没有获取到TOKEN信息", bizId);
|
apiLog.setStatus(99);
|
apiLog.setResult("没有获取到TOKEN信息");
|
apiLogRep.save(apiLog);
|
return responseDto;
|
}
|
|
Map<String, Object> map = new HashMap<>();
|
GD2022ResponseDto responseDto = GD2022HttpClientUtil.postPushData(conf.getApiUrl() + inteId,jsonData,conf, token);
|
responseDto.setBizId(bizId);
|
apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
|
apiLog.setResult(responseDto.getMsg());
|
apiLogRep.save(apiLog);
|
ResponseDto resd= new ResponseDto();
|
resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
|
resd.setMsg(responseDto.getMsg());
|
//updateGD2022AuthToken(responseDto,conf, token);
|
return resd;
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
return new ResponseDto(99, e.getMessage());
|
}
|
}
|
|
@Override
|
public ResponseDto pushData(ApiParam param, Object data) {
|
return pushData(param, null, data);
|
}
|
|
|
// /**
|
// * @Desc: 国标自定义方法
|
// * @author: Andy
|
// * @update-time: 2022/10/10
|
// */
|
// public GD2022ResponseDto pushData(String inteId, String kqdm, String bizId, Object data) {
|
// ApiConfs conf = apiCommonService.getConf(kqdm);
|
//
|
// ApiParam param = new ApiParam(conf);
|
//
|
// param.setInteId(inteId);
|
// param.setInteCategory(inteId.substring(0, 2));
|
// param.setBizId(bizId);
|
//
|
// return pushData(param, conf, data);
|
// }
|
|
|
// /**
|
// * 单条上传数据
|
// *
|
// * @param inteId
|
// * @param data
|
// * @return
|
// */
|
// public ResponseDto pushData(String inteId, ApiParent data) {
|
// try {
|
// //获取配置
|
// ApiConfs conf = apiCommonService.getConf(data.getKqdm());
|
// //获取TOKEN
|
// GD2022AuthToken token = getGD2022AuthToken(conf);
|
//
|
// //添加LOGO
|
// ApiLog apiLog = new ApiLog();
|
// apiLog.setId(ContextUtil.getUUID());
|
// if (!Constant.API_CODE_1109.equals(inteId)) {
|
// apiLog.setData(JSON.toJSONString(data));
|
// }
|
// apiLog.setInteId(inteId);
|
// apiLog.setKqdm(data.getKqdm());
|
// apiLog.setUploadTime(new Date());
|
//
|
// if (conf == null) {
|
// GD2022ResponseDto responseDto = new GD2022ResponseDto(99, "没有获取到上传配置", data.getBizId());
|
// apiLog.setStatus(99);
|
// apiLog.setResult("没有获取到上传配置");
|
// apiLogRep.save(apiLog);
|
// return responseDto;
|
// }
|
// if (null == token) {
|
// GD2022ResponseDto responseDto = new GD2022ResponseDto(99, "没有获取到TOKEN信息", data.getBizId());
|
// apiLog.setStatus(99);
|
// apiLog.setResult("没有获取到TOKEN信息");
|
// apiLogRep.save(apiLog);
|
// return responseDto;
|
// }
|
//
|
// Map<String, Object> map = new HashMap<>();
|
// GD2022ResponseDto responseDto = GD2022HttpClientUtil.postPushData(conf.getApiUrl() + inteId,JSON.toJSONString(data),conf, token);
|
// responseDto.setBizId(data.getBizId());
|
// apiLog.setStatus(responseDto.getSuccess());
|
// apiLog.setResult(responseDto.getMsg());
|
//
|
// apiLogRep.save(apiLog);
|
//
|
// updateGD2022AuthToken(responseDto, token);
|
//
|
// return responseDto;
|
// } catch (Exception e) {
|
// log.error(e.getMessage(), e);
|
// return new ResponseDto(99, e.getMessage());
|
// }
|
// }
|
|
/**
|
* 代码调整
|
*
|
* @param conf
|
* @return
|
*/
|
public GD2022AuthToken getGD2022AuthToken(ApiConfs conf) {
|
try {
|
String key = RedisConst.buildKey(RedisConst.KYE_TOKEN, conf.getKqdm());
|
|
GD2022AuthToken token = (GD2022AuthToken) redisUtil.get(key);
|
if (null != token) return token;
|
|
//从新获取TOKEN
|
Map<String, Object> map = new HashMap<>();
|
map.put("appid", conf.getUserName());
|
// map.put("appkey", EncryptUtil.encryptHex(conf.getPassword(),conf.getPublicKey()));
|
map.put("appkey", AESUtils.encrypt(conf.getPassword(),conf.getPublicKey()));
|
GD2022ResponseDto<GD2022AuthToken> responseDto = GD2022HttpClientUtil.postGetToken(conf.getApiUrl() + "sfrz",map);
|
token = new GD2022AuthToken();
|
|
updateGD2022AuthToken(responseDto, conf,token);
|
|
return token;
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
return null;
|
}
|
}
|
|
private void updateGD2022AuthToken(GD2022ResponseDto<GD2022AuthToken> dto, ApiConfs conf, GD2022AuthToken token) {
|
String key = RedisConst.buildKey(RedisConst.KYE_TOKEN, conf.getKqdm());
|
|
if (null == dto) {
|
// redisUtil.set(key, token, 170);
|
return;
|
}
|
|
if (dto.getCode() != 200) {
|
return;
|
} else {
|
GD2022AuthToken token1 = dto.getData();
|
token.setAccess_token(token1.getAccess_token());
|
token.setAppid(token1.getAppid());
|
redisUtil.set(key, token, 60 * 119);
|
}
|
}
|
|
private String getJsonData(String inteId , Object data, String url, GD2022AuthToken authToken) throws Exception {
|
if(Constant.API_CODE_1101.equals(inteId)){
|
Api1101 api1101 = new Api1101();
|
BeanUtils.copyProperties(data,api1101);
|
return JSON.toJSONString(api1101);
|
}else if(Constant.API_CODE_1109.equals(inteId)){
|
//封装数据
|
Api1109 api1109 = new Api1109();
|
BeanUtils.copyProperties(data,api1109);
|
|
if (null == authToken) {
|
return JSON.toJSONString(api1109);
|
}
|
//先上传文件,获取文件id
|
GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1109.getWjdz());
|
//设置上传文件id
|
api1109.setFileStorageId((String) responseDto.getData());
|
return JSON.toJSONString(api1109);
|
}else if(Constant.API_CODE_1208.equals(inteId)){
|
Api1208 api1208 = new Api1208();
|
BeanUtils.copyProperties(data,api1208);
|
return JSON.toJSONString(api1208);
|
}else if(Constant.API_CODE_1307.equals(inteId)){
|
//封装数据
|
Api1307 api1307 = new Api1307();
|
BeanUtils.copyProperties(data,api1307);
|
|
if (null == authToken) {
|
return JSON.toJSONString(api1307);
|
}
|
//先上传文件,获取文件id
|
GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1307.getWjdz());
|
//设置上传文件id
|
api1307.setFileStorageId((String) responseDto.getData());
|
return JSON.toJSONString(api1307);
|
}else if(Constant.API_CODE_1308.equals(inteId)){
|
//封装数据
|
Api1308 api1308 = new Api1308();
|
BeanUtils.copyProperties(data,api1308);
|
|
if (null == authToken) {
|
return JSON.toJSONString(api1308);
|
}
|
//先上传文件,获取文件id
|
GD2022ResponseDto responseDto = GD2022HttpClientUtil.postUploadData(url, authToken, api1308.getWjdz());
|
//设置上传文件id
|
api1308.setFileStorageId((String) responseDto.getData());
|
return JSON.toJSONString(api1308);
|
}else{
|
return JSON.toJSONString(data);
|
}
|
}
|
|
|
private String getInteId(String inteId){
|
switch (inteId){
|
case "1101":
|
return ApiCodeConstant.API_CODE_DWXX;
|
case "1102":
|
return ApiCodeConstant.API_CODE_KQXX;
|
case "1103":
|
return ApiCodeConstant.API_CODE_CFXX;
|
case "1104":
|
return ApiCodeConstant.API_CODE_AJXX;
|
case "1105":
|
return ApiCodeConstant.API_CODE_HWXX;
|
case "1106":
|
return ApiCodeConstant.API_CODE_YGXX;
|
case "1107":
|
return ApiCodeConstant.API_CODE_SBXX;
|
case "1108":
|
return ApiCodeConstant.API_CODE_YJXX;
|
case "1109":
|
return ApiCodeConstant.API_CODE_WJXX;
|
case "1110":
|
return ApiCodeConstant.API_CODE_KQTCFDWBZ;
|
case "1111":
|
return ApiCodeConstant.API_CODE_KQTSPJKSBDWBZ;
|
case "1112":
|
return ApiCodeConstant.API_CODE_RYXX;
|
case "1113":
|
return "";
|
case "1201":
|
return ApiCodeConstant.API_CODE_HTXX;
|
case "1202":
|
return ApiCodeConstant.API_CODE_LSRKXX;
|
case "1203":
|
return ApiCodeConstant.API_CODE_RKJYXX;
|
case "1204":
|
return ApiCodeConstant.API_CODE_RKJSXX;
|
case "1205":
|
return ApiCodeConstant.API_CODE_LSCKXX;
|
case "1206":
|
return ApiCodeConstant.API_CODE_LSCKJS;
|
case "1207":
|
return ApiCodeConstant.API_CODE_DCXX;
|
case "1208":
|
return ApiCodeConstant.API_CODE_LSKC;
|
case "1209":
|
return ApiCodeConstant.API_CODE_SYD;
|
case "1210":
|
return ApiCodeConstant.API_CODE_XZZBD;
|
case "1211":
|
return ApiCodeConstant.API_CODE_ZMKCXX;
|
case "1212":
|
return ApiCodeConstant.API_CODE_KHXX;
|
case "1301":
|
return ApiCodeConstant.API_CODE_AQGL;
|
case "1302":
|
return ApiCodeConstant.API_CODE_WSDJC;
|
case "1303":
|
return ApiCodeConstant.API_CODE_HCJC;
|
case "1304":
|
return ApiCodeConstant.API_CODE_QTJC;
|
case "1305":
|
return ApiCodeConstant.API_CODE_TFZY;
|
case "1306":
|
return ApiCodeConstant.API_CODE_XZZY;
|
case "1307":
|
return ApiCodeConstant.API_CODE_CNSPTX;
|
case "1308":
|
return ApiCodeConstant.API_CODE_SPJKYCSJGJJBXX;
|
case "1309":
|
return ApiCodeConstant.API_CODE_WGYJXX;
|
case "1310":
|
return ApiCodeConstant.API_CODE_ZZSJ;
|
case "1401":
|
return ApiCodeConstant.API_CODE_CBGM;
|
case "1402":
|
return ApiCodeConstant.API_CODE_CBJHXX;
|
case "1403":
|
return ApiCodeConstant.API_CODE_LHJHXX;
|
case "1404":
|
return ApiCodeConstant.API_CODE_LHJHMXXX;
|
case "1405":
|
return "";
|
case "1501":
|
return ApiCodeConstant.API_CODE_CWBBXX;
|
case "1502":
|
return ApiCodeConstant.API_CODE_CWBBXX;
|
case "1503":
|
return ApiCodeConstant.API_CODE_CWBBXX;
|
default:
|
return inteId;
|
}
|
}
|
}
|
