武汉接口调整

czt

3 天以前 1dde554c630e2de8ac7b234e57d4f12d7190f3f9

 src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java

@@ -11,12 +11,15 @@
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.*;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.whhpjl.dto.WhjlPullReqDto;
import com.fzzy.push.whhpjl.dto.WhjlPullRespDto;
import com.fzzy.push.whhpjl.dto.WhjlReqDto;
import com.fzzy.push.whhpjl.dto.WhjlRespDto;
import com.fzzy.otherview.whhpjl.WhjlConstant;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateFormatUtils;
import org.codehaus.jackson.map.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -277,8 +280,107 @@
                return WhjlConstant.API_CODE_CLYSHJ;
            case "1413":
                return WhjlConstant.API_CODE_YSLX;
            case "1414":
                return WhjlConstant.API_CODE_BDZDSB;
            case "2001":
                return WhjlConstant.API_CODE_SHARE_SBFL;
            case "2002":
                return WhjlConstant.API_CODE_SHARE_CPFL;
            case "2003":
                return WhjlConstant.API_CODE_SHARE_JLDW;
            case "2004":
                return WhjlConstant.API_CODE_SHARE_JLGLJG;
            case "2005":
                return WhjlConstant.API_CODE_SHARE_JLGYSXX;
            case "2006":
                return WhjlConstant.API_CODE_SHARE_JLPPXX;
            case "2007":
                return WhjlConstant.API_CODE_SHARE_JLCPXX;
            case "2008":
                return WhjlConstant.API_CODE_SHARE_JLCCJH;
            case "2009":
                return WhjlConstant.API_CODE_SHARE_HTMB;
            case "2010":
                return WhjlConstant.API_CODE_SHARE_ZLJCBZ;
            case "2011":
                return WhjlConstant.API_CODE_SHARE_ZLJCXM;
            case "2012":
                return WhjlConstant.API_CODE_SHARE_YJFAXX;
            case "2013":
                return WhjlConstant.API_CODE_SHARE_SZJZXBG;
            default:
                return inteId;
        }
    }

    @Override
    public ResponseDto pullData(ApiParam param, ApiConfs conf) {
        String inteId = param.getInteId();
        String kqdm = param.getKqdm();

        try {
            if (null == conf) {
                conf = apiCommonService.getConf(kqdm);
            }

            //添加日志
            ApiLog apiLog = new ApiLog();
            apiLog.setId(ContextUtil.getUUID());
            apiLog.setInteId(inteId);
            inteId = getInteId(inteId);

            if (StringUtils.isEmpty(inteId)) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到接口");
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到接口");
                apiLogRep.save(apiLog);
                return responseDto;
            }

            if (conf == null) {
                ResponseDto responseDto = new ResponseDto(99, "没有获取到上传配置");
                apiLog.setStatus(99);
                apiLog.setResult("没有获取到上传配置");
                apiLogRep.save(apiLog);
                return responseDto;
            }

            //封装数据
            WhjlPullReqDto reqData = new WhjlPullReqDto();
            //报文标识ID
            reqData.setId(ContextUtil.getUUID());
            //身份ID
            reqData.setUid(conf.getUserName());
            //应用码
            reqData.setAppcode(conf.getAppCode());
            if(null != param.getStart()){
                reqData.setStarttime(DateFormatUtils.format(param.getStart(), "yyyy-MM-dd HH:mm:ss"));
            }
            if(null != param.getEnd()){
                reqData.setEndtime(DateFormatUtils.format(param.getEnd(), "yyyy-MM-dd HH:mm:ss"));
            }

            //时间戳
            reqData.setTimestamp(Long.valueOf(ContextUtil.getCurTimeMillis()));
            //身份签名，对应用码_授权码_站点编码_报文ID_时间戳进行MD5算法签名
            String accessToken = reqData.getAppcode() +"_" + conf.getPassword() +"_" + reqData.getUid() + "_" + reqData.getId() + "_" + reqData.getTimestamp();
            log.info("身份签名：" + accessToken);
            reqData.setAccesstoken(MyMD5Util.encrypt(accessToken));

            String url = conf.getApiUrl().replace("secure", "share");
            WhjlPullRespDto responseDto = whjl2023HttpClientUtil.postPullData(url + inteId, reqData);
            apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            apiLog.setKqdm(kqdm);
            apiLog.setUploadTime(new Date());

            apiLogRep.save(apiLog);
            ResponseDto resd = new ResponseDto();
            resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
            resd.setData(responseDto.getData());
            return resd;
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return new ResponseDto(99, e.getMessage());
        }
    }
}