|
@@ -168,8 +168,8 @@ public class JinLinPushApiController {
|
|
// System.out.println("档案:"+archiveAutoDtos.size());
|
|
// System.out.println("档案:"+archiveAutoDtos.size());
|
|
// iJiLinArchiveAutoDtoService.saveBatch(archiveAutoDtos);
|
|
// iJiLinArchiveAutoDtoService.saveBatch(archiveAutoDtos);
|
|
|
|
|
|
- Long projId=jlPyProjId;
|
|
|
|
- for (int j = 46; j <47 ; j++) {
|
|
|
|
|
|
+ Long projId=jlHjProjId;
|
|
|
|
+ for (int j = 0; j <100 ; j++) {
|
|
Page<JiLinArchiveAutoDto> pages=iJiLinArchiveAutoDtoService.queryAll(j,500,projId);
|
|
Page<JiLinArchiveAutoDto> pages=iJiLinArchiveAutoDtoService.queryAll(j,500,projId);
|
|
List<JiLinArchiveAutoDto> archiveAutoDtos = pages.getRecords();
|
|
List<JiLinArchiveAutoDto> archiveAutoDtos = pages.getRecords();
|
|
if(archiveAutoDtos.size()<500) {
|
|
if(archiveAutoDtos.size()<500) {
|
|
@@ -180,13 +180,14 @@ public class JinLinPushApiController {
|
|
List<JiLinPushCatalogDto> jiLinPushCatalogDtoList = new ArrayList<>();
|
|
List<JiLinPushCatalogDto> jiLinPushCatalogDtoList = new ArrayList<>();
|
|
List<JiLinPushFileUrlDto> jiLinPushFileUrlDtoList = new ArrayList<>();
|
|
List<JiLinPushFileUrlDto> jiLinPushFileUrlDtoList = new ArrayList<>();
|
|
for (int i = 0; i < archiveAutoDtos.size(); i++) {
|
|
for (int i = 0; i < archiveAutoDtos.size(); i++) {
|
|
|
|
+ String name=StringUtils.deleteWhitespace(archiveAutoDtos.get(i).getName());
|
|
//设置档案案卷
|
|
//设置档案案卷
|
|
JiLinPushTomeDto jiLinPushTomeDto = new JiLinPushTomeDto();
|
|
JiLinPushTomeDto jiLinPushTomeDto = new JiLinPushTomeDto();
|
|
- jiLinPushTomeDto.setPactId(jlPyProjId);
|
|
|
|
|
|
+ jiLinPushTomeDto.setProjId(jlHjProjId);
|
|
jiLinPushTomeDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushTomeDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushTomeDto.setKid(archiveAutoDtos.get(i).getTomeId());
|
|
jiLinPushTomeDto.setKid(archiveAutoDtos.get(i).getTomeId());
|
|
jiLinPushTomeDto.setSortID(archiveAutoDtos.get(i).getNodeId());
|
|
jiLinPushTomeDto.setSortID(archiveAutoDtos.get(i).getNodeId());
|
|
- jiLinPushTomeDto.setTomeSuper(StringUtils.deleteWhitespace(archiveAutoDtos.get(i).getName()));
|
|
|
|
|
|
+ jiLinPushTomeDto.setTomeSuper(name);
|
|
jiLinPushTomeDto.setRecordNum(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushTomeDto.setRecordNum(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushTomeDto.setAddUserName(archiveAutoDtos.get(i).getUpdateUserName());
|
|
jiLinPushTomeDto.setAddUserName(archiveAutoDtos.get(i).getUpdateUserName());
|
|
jiLinPushTomeDto.setAddTime(archiveAutoDtos.get(i).getCreateUserTime());
|
|
jiLinPushTomeDto.setAddTime(archiveAutoDtos.get(i).getCreateUserTime());
|
|
@@ -201,12 +202,12 @@ public class JinLinPushApiController {
|
|
jiLinPushTomeDtoList.add(jiLinPushTomeDto);
|
|
jiLinPushTomeDtoList.add(jiLinPushTomeDto);
|
|
// 设置档案卷内目录
|
|
// 设置档案卷内目录
|
|
JiLinPushCatalogDto jiLinPushCatalogDto = new JiLinPushCatalogDto();
|
|
JiLinPushCatalogDto jiLinPushCatalogDto = new JiLinPushCatalogDto();
|
|
- jiLinPushCatalogDto.setProjId(jlPyProjId);
|
|
|
|
|
|
+ jiLinPushCatalogDto.setProjId(jlHjProjId);
|
|
jiLinPushCatalogDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushCatalogDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushCatalogDto.setKid(archiveAutoDtos.get(i).getCatlogId());
|
|
jiLinPushCatalogDto.setKid(archiveAutoDtos.get(i).getCatlogId());
|
|
jiLinPushCatalogDto.setSortId(archiveAutoDtos.get(i).getNodeId());
|
|
jiLinPushCatalogDto.setSortId(archiveAutoDtos.get(i).getNodeId());
|
|
jiLinPushCatalogDto.setTomeId(archiveAutoDtos.get(i).getTomeId());
|
|
jiLinPushCatalogDto.setTomeId(archiveAutoDtos.get(i).getTomeId());
|
|
- jiLinPushCatalogDto.setFileSuper(StringUtils.deleteWhitespace(archiveAutoDtos.get(i).getName()));
|
|
|
|
|
|
+ jiLinPushCatalogDto.setFileSuper(name);
|
|
jiLinPushCatalogDto.setCatalogRecord(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushCatalogDto.setCatalogRecord(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushCatalogDto.setAmsFileNum("0");
|
|
jiLinPushCatalogDto.setAmsFileNum("0");
|
|
jiLinPushCatalogDto.setFileNum("0");
|
|
jiLinPushCatalogDto.setFileNum("0");
|
|
@@ -221,11 +222,11 @@ public class JinLinPushApiController {
|
|
jiLinPushCatalogDtoList.add(jiLinPushCatalogDto);
|
|
jiLinPushCatalogDtoList.add(jiLinPushCatalogDto);
|
|
//设置档案文件
|
|
//设置档案文件
|
|
JiLinPushFileUrlDto jiLinPushFileUrlDto = new JiLinPushFileUrlDto();
|
|
JiLinPushFileUrlDto jiLinPushFileUrlDto = new JiLinPushFileUrlDto();
|
|
- jiLinPushFileUrlDto.setProjId(jlPyProjId);
|
|
|
|
|
|
+ jiLinPushFileUrlDto.setProjId(jlHjProjId);
|
|
jiLinPushFileUrlDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushFileUrlDto.setPactId(archiveAutoDtos.get(i).getContractId());
|
|
jiLinPushFileUrlDto.setKid(archiveAutoDtos.get(i).getId());
|
|
jiLinPushFileUrlDto.setKid(archiveAutoDtos.get(i).getId());
|
|
jiLinPushFileUrlDto.setCatalogID(archiveAutoDtos.get(i).getCatlogId());
|
|
jiLinPushFileUrlDto.setCatalogID(archiveAutoDtos.get(i).getCatlogId());
|
|
- jiLinPushFileUrlDto.setAnnexName(StringUtils.deleteWhitespace(archiveAutoDtos.get(i).getName()));
|
|
|
|
|
|
+ jiLinPushFileUrlDto.setAnnexName(name);
|
|
jiLinPushFileUrlDto.setTableNumber(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushFileUrlDto.setTableNumber(archiveAutoDtos.get(i).getFileNumber());
|
|
jiLinPushFileUrlDto.setWeaveDate(archiveAutoDtos.get(i).getCreateUserTime());
|
|
jiLinPushFileUrlDto.setWeaveDate(archiveAutoDtos.get(i).getCreateUserTime());
|
|
jiLinPushFileUrlDto.setAnnexPage(archiveAutoDtos.get(i).getPageN());
|
|
jiLinPushFileUrlDto.setAnnexPage(archiveAutoDtos.get(i).getPageN());
|
|
@@ -237,42 +238,42 @@ public class JinLinPushApiController {
|
|
}
|
|
}
|
|
//传输吉林档案案卷的地址
|
|
//传输吉林档案案卷的地址
|
|
String tome=JSONObject.toJSONString(jiLinPushTomeDtoList);
|
|
String tome=JSONObject.toJSONString(jiLinPushTomeDtoList);
|
|
- String tomeMsg=tome+PYCLIENTSECRETKEY;
|
|
|
|
|
|
+ String tomeMsg=tome+HJCLIENTSECRETKEY;
|
|
String tomeUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/tome";
|
|
String tomeUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/tome";
|
|
String tomeSignature = DigestUtils.md5Hex(tomeMsg).toUpperCase();
|
|
String tomeSignature = DigestUtils.md5Hex(tomeMsg).toUpperCase();
|
|
HashMap<String,String> tomeHeaders=new HashMap<>();
|
|
HashMap<String,String> tomeHeaders=new HashMap<>();
|
|
tomeHeaders.put("Content-Type", "application/json");
|
|
tomeHeaders.put("Content-Type", "application/json");
|
|
- tomeHeaders.put("clientId",PYCLIENTID);
|
|
|
|
|
|
+ tomeHeaders.put("clientId",HJCLIENTID);
|
|
tomeHeaders.put("signature",tomeSignature);
|
|
tomeHeaders.put("signature",tomeSignature);
|
|
- tomeHeaders.put("systemId",PYSYSTEMID);
|
|
|
|
|
|
+ tomeHeaders.put("systemId",HJSYSTEMID);
|
|
String tomeBody = HttpUtil.createPost(tomeUrl).addHeaders(tomeHeaders).body(tome).contentType("application/json").execute().body();
|
|
String tomeBody = HttpUtil.createPost(tomeUrl).addHeaders(tomeHeaders).body(tome).contentType("application/json").execute().body();
|
|
System.out.println("第"+(j+1)+"次档案案卷"+tomeBody);
|
|
System.out.println("第"+(j+1)+"次档案案卷"+tomeBody);
|
|
//传输吉林档案卷内目录
|
|
//传输吉林档案卷内目录
|
|
String catLog=JSONObject.toJSONString(jiLinPushCatalogDtoList);
|
|
String catLog=JSONObject.toJSONString(jiLinPushCatalogDtoList);
|
|
- String catLogMsg=catLog+PYCLIENTSECRETKEY;
|
|
|
|
|
|
+ String catLogMsg=catLog+HJCLIENTSECRETKEY;
|
|
String catLogUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/catalog";
|
|
String catLogUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/catalog";
|
|
String catLogSignature = DigestUtils.md5Hex(catLogMsg).toUpperCase();
|
|
String catLogSignature = DigestUtils.md5Hex(catLogMsg).toUpperCase();
|
|
HashMap<String,String> catLogHeaders=new HashMap<>();
|
|
HashMap<String,String> catLogHeaders=new HashMap<>();
|
|
catLogHeaders.put("Content-Type", "application/json");
|
|
catLogHeaders.put("Content-Type", "application/json");
|
|
- catLogHeaders.put("clientId",PYCLIENTID);
|
|
|
|
|
|
+ catLogHeaders.put("clientId",HJCLIENTID);
|
|
catLogHeaders.put("signature",catLogSignature);
|
|
catLogHeaders.put("signature",catLogSignature);
|
|
- catLogHeaders.put("systemId",PYSYSTEMID);
|
|
|
|
|
|
+ catLogHeaders.put("systemId",HJSYSTEMID);
|
|
String catLogBody = HttpUtil.createPost(catLogUrl).addHeaders(catLogHeaders).body(catLog).contentType("application/json").execute().body();
|
|
String catLogBody = HttpUtil.createPost(catLogUrl).addHeaders(catLogHeaders).body(catLog).contentType("application/json").execute().body();
|
|
System.out.println("第"+(j+1)+"次卷内目录"+catLogBody);
|
|
System.out.println("第"+(j+1)+"次卷内目录"+catLogBody);
|
|
|
|
|
|
//传输吉林档案文件
|
|
//传输吉林档案文件
|
|
String annex=JSONObject.toJSONString(jiLinPushFileUrlDtoList);
|
|
String annex=JSONObject.toJSONString(jiLinPushFileUrlDtoList);
|
|
- String annexMsg=annex+PYCLIENTSECRETKEY;
|
|
|
|
|
|
+ String annexMsg=annex+HJCLIENTSECRETKEY;
|
|
String annexUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/annex";
|
|
String annexUrl="https://hgqs.jtyst.jl.gov.cn:6100/dock/openapi/veams/api/doc/annex";
|
|
String annexSignature = DigestUtils.md5Hex(annexMsg).toUpperCase();
|
|
String annexSignature = DigestUtils.md5Hex(annexMsg).toUpperCase();
|
|
HashMap<String,String> annexHeaders=new HashMap<>();
|
|
HashMap<String,String> annexHeaders=new HashMap<>();
|
|
annexHeaders.put("Content-Type", "application/json");
|
|
annexHeaders.put("Content-Type", "application/json");
|
|
- annexHeaders.put("clientId",PYCLIENTID);
|
|
|
|
|
|
+ annexHeaders.put("clientId",HJCLIENTID);
|
|
annexHeaders.put("signature",annexSignature);
|
|
annexHeaders.put("signature",annexSignature);
|
|
- annexHeaders.put("systemId",PYSYSTEMID);
|
|
|
|
|
|
+ annexHeaders.put("systemId",HJSYSTEMID);
|
|
String annexBody = HttpUtil.createPost(annexUrl).addHeaders(annexHeaders).body(annex).contentType("application/json").execute().body();
|
|
String annexBody = HttpUtil.createPost(annexUrl).addHeaders(annexHeaders).body(annex).contentType("application/json").execute().body();
|
|
System.out.println("第"+(j+1)+"次档案文件"+annexBody);
|
|
System.out.println("第"+(j+1)+"次档案文件"+annexBody);
|
|
}
|
|
}
|
|
- System.out.println("蒲烟传输结束");
|
|
|
|
|
|
+ System.out.println("烟长传输结束");
|
|
}
|
|
}
|
|
}
|
|
}
|