|  | @ -25,6 +25,8 @@ public class DataHandling {
 | 
	
		
			
				|  |  |     private static final int thread = 10;
 | 
	
		
			
				|  |  |     private static final ObjectMapper objectMapper = new ObjectMapper();
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |     private static final String token = "ffd13e62-e67a-45b3-9c33-cc3d935fab30";
 | 
	
		
			
				|  |  | 
 | 
	
		
			
				|  |  |     public static void main(String [] args) {
 | 
	
		
			
				|  |  |         start();
 | 
	
		
			
				|  |  |     }
 | 
	
	
		
			
				|  | @ -58,7 +60,7 @@ public class DataHandling {
 | 
	
		
			
				|  |  |                             System.getProperty("java.io.tmpdir") + java.io.File.separator + filePath.substring(filePath.lastIndexOf("/") + 1),
 | 
	
		
			
				|  |  |                             null, null);*/
 | 
	
		
			
				|  |  |                         Map<String, String> header = new HashMap<>();
 | 
	
		
			
				|  |  |                         header.put("token", "ae416ecb-c944-4e01-a8fa-98f1d7c9535f");
 | 
	
		
			
				|  |  |                         header.put("token", token);
 | 
	
		
			
				|  |  |                         String _id = data.get("_id").toString();
 | 
	
		
			
				|  |  |                         file = HttpUtils.download("http://jksr.srswjw.gov.cn:1235/gateway/pack-mgr/api/v1.0/packages/download/" + _id,
 | 
	
		
			
				|  |  |                                 System.getProperty("java.io.tmpdir") + File.separator + filePath.substring(filePath.lastIndexOf("/") + 1),
 | 
	
	
		
			
				|  | @ -67,7 +69,7 @@ public class DataHandling {
 | 
	
		
			
				|  |  |                         if (remotePath != null) {
 | 
	
		
			
				|  |  |                             sourceMap.put("remote_path", remotePath);
 | 
	
		
			
				|  |  |                             sourceMap.put("pwd", data.get("pwd"));
 | 
	
		
			
				|  |  |                             sourceMap.put("receive_date", data.get("receive_date"));
 | 
	
		
			
				|  |  |                             sourceMap.put("receive_date", "2018-09-05 13:00:00");
 | 
	
		
			
				|  |  |                             sourceMap.put("org_code", data.get("org_code"));
 | 
	
		
			
				|  |  |                             sourceMap.put("org_name", data.get("org_name"));
 | 
	
		
			
				|  |  |                             sourceMap.put("org_area", data.get("org_area"));
 | 
	
	
		
			
				|  | @ -83,7 +85,7 @@ public class DataHandling {
 | 
	
		
			
				|  |  |                             params.put("index", "json_archives");
 | 
	
		
			
				|  |  |                             params.put("type", "info");
 | 
	
		
			
				|  |  |                             params.put("source", objectMapper.writeValueAsString(sourceMap));
 | 
	
		
			
				|  |  |                             HttpResponse httpResponse = HttpUtils.doPost("http://172.17.110.227:10770/api/v1.0/elasticSearch/index", params, null);
 | 
	
		
			
				|  |  |                             HttpResponse httpResponse = HttpUtils.doPost("http://172.17.110.181:10770/api/v1.0/elasticSearch/index", params, null);
 | 
	
		
			
				|  |  |                             LOGGER.info(httpResponse.getContent());
 | 
	
		
			
				|  |  |                         }
 | 
	
		
			
				|  |  |                     } catch (Exception e) {
 | 
	
	
		
			
				|  | @ -102,14 +104,14 @@ public class DataHandling {
 | 
	
		
			
				|  |  |         Map<String, Object> params = new HashMap<>();
 | 
	
		
			
				|  |  |         params.put("index", "json_archives");
 | 
	
		
			
				|  |  |         params.put("type", "info");
 | 
	
		
			
				|  |  |         params.put("filter", "event_date>=2018-07-01 00:00:00;event_date<2018-08-01 00:00:00;pack_type=1;archive_status=3");
 | 
	
		
			
				|  |  |         params.put("filter", "pack_type=2;archive_status=3;");
 | 
	
		
			
				|  |  |         params.put("sorts", "+event_date");
 | 
	
		
			
				|  |  |         params.put("page", page);
 | 
	
		
			
				|  |  |         params.put("size", size);
 | 
	
		
			
				|  |  |         Map<String, String> header = new HashMap<>();
 | 
	
		
			
				|  |  |         header.put("token", "ae416ecb-c944-4e01-a8fa-98f1d7c9535f");
 | 
	
		
			
				|  |  |         header.put("token", token);
 | 
	
		
			
				|  |  |         try {
 | 
	
		
			
				|  |  |             HttpResponse response = HttpUtils.doGet("http://jksr.srswjw.gov.cn:1235/gateway/dfs/api/v1.0/elasticSearch/pageSort", params, header);
 | 
	
		
			
				|  |  |             HttpResponse response = HttpUtils.doGet("http://jksr.srswjw.gov.cn:1235/gateway/dfs/api/v1.0/elasticSearch/page", params, header);
 | 
	
		
			
				|  |  |             Envelop envelop = objectMapper.readValue(response.getContent(), Envelop.class);
 | 
	
		
			
				|  |  |             return envelop;
 | 
	
		
			
				|  |  |         } catch (Exception e) {
 | 
	
	
		
			
				|  | @ -123,7 +125,7 @@ public class DataHandling {
 | 
	
		
			
				|  |  |         params.put("objectId", "profile");
 | 
	
		
			
				|  |  |         params.put("creator", "Progr1mmer");
 | 
	
		
			
				|  |  |         try {
 | 
	
		
			
				|  |  |             HttpResponse httpResponse = HttpUtils.doUpload("http://172.17.110.227:10770/api/v1.0/fastDfs/upload", params, null, "file", file);
 | 
	
		
			
				|  |  |             HttpResponse httpResponse = HttpUtils.doUpload("http://172.17.110.181:10770/api/v1.0/fastDfs/upload", params, null, "file", file);
 | 
	
		
			
				|  |  |             if (httpResponse.isSuccessFlg()) {
 | 
	
		
			
				|  |  |                 Envelop envelop = objectMapper.readValue(httpResponse.getContent(), Envelop.class);
 | 
	
		
			
				|  |  |                 Map<String, Object> data = (Map<String, Object>) envelop.getObj();
 |