| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @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); |
|---|
| | | |
|---|
| | | 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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //查询库区信息行政区划码 |
|---|
| | | List<Api1102> api1102List = api1102Rep.findPushData(kqdm); |
|---|
| | | //封装数据 |
|---|
| | | SH2023PullReqDto reqData = new SH2023PullReqDto();; |
|---|
| | | |
|---|
| | | reqData.setName(conf.getUserName()); |
|---|
| | | reqData.setPwd(conf.getAppCode()); |
|---|
| | | |
|---|
| | | log.info("拉取共享数据请求信息=" + JSON.toJSONString(reqData)); |
|---|
| | | |
|---|
| | | String url = conf.getApiUrl().replace("UPLOAD", "Shared"); |
|---|
| | | SH2023PullRespDto responseDto = SH2023HttpClientUtil.postPullData(url + inteId, JSON.toJSONString(reqData)); |
|---|
| | | |
|---|
| | | apiLog.setStatus(responseDto.getRetcode() == 200 ? 0 : responseDto.getRetcode()); |
|---|
| | | apiLog.setResult(responseDto.getRetMsg()); |
|---|
| | | apiLogRep.save(apiLog); |
|---|
| | | ResponseDto resd = new ResponseDto(); |
|---|
| | | resd.setSuccess(responseDto.getRetcode() == 200 ? 0 : responseDto.getRetcode()); |
|---|
| | | resd.setMsg(responseDto.getRetMsg()); |
|---|
| | | resd.setData(responseDto.getData()); |
|---|
| | | return resd; |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error(e.getMessage(), e); |
|---|
| | | return new ResponseDto(99, e.getMessage()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 转为JSON |
|---|
| | | * |
|---|
| | |
|---|
| | | api1109.setWjl(JSON.toJSONString(map)); |
|---|
| | | //上海市平台文件名称规则：库区编码_业务流水号_分类码_顺序码.jpg，例如：91310114703439394M001_142211080101_GL_00.jpg |
|---|
| | | api1109.setWjmc(getWjmc(api1109.getWjlx(), api1109.getWjmc())); |
|---|
| | | //业务类型 |
|---|
| | | api1109.setYwdh(getYwdh(api1109.getWjlx(), api1109.getWjmc())); |
|---|
| | | //设置空属性为默认值 |
|---|
| | | changeObject(api1109); |
|---|
| | | return api1109; |
|---|
| | |
|---|
| | | //合同审核人不能为空或填无 |
|---|
| | | if (StringUtils.isEmpty(api1201.getShr())) { |
|---|
| | | api1201.setShr("审批人"); |
|---|
| | | } |
|---|
| | | //设置购销方式,默认客户统一信用码为空，则为产销，反之为竞价；(1-定向；2-竞价；3-产销) |
|---|
| | | api1201.setGxfs("2"); |
|---|
| | | if(StringUtils.isEmpty(api1201.getKhtyshxydm())){ |
|---|
| | | api1201.setGxfs("3"); |
|---|
| | | } |
|---|
| | | //设置空属性为默认值 |
|---|
| | | changeObject(api1201); |
|---|
| | |
|---|
| | | } |
|---|
| | | return wjmc; |
|---|
| | | } |
|---|
| | | private String getYwdh(String wjlx, String wjmc) { |
|---|
| | | String ywdh = ""; |
|---|
| | | String[] s = wjmc.split("_"); |
|---|
| | | if ("2".equals(wjlx) || "3".equals(wjlx)) { |
|---|
| | | ywdh = s[1]; |
|---|
| | | } |
|---|
| | | return ywdh; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private Object changeObject(Object object) { |
|---|
| | | // 使用反射获取属性列表 vo为实体对象名 |
|---|
| | |
|---|
| | | } |
|---|
| | | return object; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
