队列任务- Java

进口org.json.JSONArray;进口org.json.JSONObject;进口java.io.File;进口java.io.FileNotFoundException;进口java.net.URI;进口java.net.http.HttpClient;进口java.net.http.HttpRequest;进口java.net.http.HttpRequest.BodyPublisher;进口java.net.http.HttpResponse;进口java.nio.charset.StandardCharsets;进口java.util.Base64;进口java.util.concurrent.CompletableFuture;进口java.util.concurrent.ExecutionException;进口java.util.concurrent.TimeUnit;进口java.util.concurrent.TimeoutException;

私人静态无效队列(){HttpClient客户机= HttpClient. newhttpclient ();//如果使用URL到文件字符串fileURL =“https://demo.leadtools.com/images/cloud_samples/ocr1气管无名动脉瘘管的- 4.”；字符串uploadUrl = String.format(“还是?fileurl = % s”, fileURL);结果结果= postAsync(uploadUrl，零、客户端);//如果上传文件为多部分内容://文件uploadFile = new文件("path/to/ File ");// String uploadUrl = "UploadFile";// Results Results = postAsync(uploadUrl, uploadFile, client);如果(results.getStatusCode() == 200) {//服务返回的唯一IDSystem.out.println (服务返回的唯一ID:+ results.getData ());checkFileForVerification (results.getData(),客户端);｝其他的｛System.out.println ("请求失败，响应如下"+ results.getStatusCode ());｝｝

私人静态无效queueExtractText(字符串id, HttpClient客户机){//文件中要标记进行处理的第一页intfirstPage = 1;//发送一个-1的值将指示服务应该处理文件中的所有页面。intlastPage = -1;字符串recognitionUrl = String.format(“认可/ ExtractText吗?珍宝= % s&lastPage = % s&guid = % s”， firstPage, lastPage, id);结果结果= postAsync(recognitionUrl，零、客户端);如果(results.getStatusCode() == 200) {queueConversion (id、客户);｝其他的｛System.out.println ("请求失败，响应如下"+ results.getStatusCode ());｝｝

私人静态无效queueConversion(String id, HttpClient client) {//文件中要标记进行处理的第一页intfirstPage = 1;//发送一个-1的值将指示服务应该处理文件中的所有页面。intlastPage = -1;//文件输出格式对应的枚举。对于这个脚本，我们将转换为tif。intfileFormat = 4;字符串conversionUrl = String.format(“转换/转换?珍宝= % s&lastPage = % s&guid = % s&format = % s”， firstPage, lastPage, id, fileFormat);结果结果= postAsync(conversionUrl，零、客户端);如果(results.getStatusCode() == 200) {运行(id、客户);｝其他的｛System.out.println ("转换请求未能与以下响应排队:"+ results.getStatusCode ());｝｝

私人静态无效运行(HttpClient客户端){字符串uploadUrl = String.format(“跑?id = % s "、身份证);结果结果= postAsync(uploadUrl，零、客户端);如果(results.getStatusCode() == 200) {查询(id、客户端);｝其他的｛System.out.println ("请求失败，响应如下"+ results.getStatusCode ());｝｝

私人静态无效checkFileForVerification(字符串id, HttpClient客户端){字符串queryUrl = String.format(“查询?id = % s "、身份证);结果结果;JSONObject returnedData;intfileStatus = 0;做｛试一试｛结果= postAsync(queryUrl，零、客户端);returnedData =新JSONObject (results.getData ());fileStatus =返回数据。getint (“FileStatus”）;thread . sleep (500);｝抓(InterruptedException e) {/ / e.printStackTrace ();｝｝而(fileStatus = 0 || fileStatus == 123);如果(fileStatus == 122)｛queueExtractText (id、客户);｝其他的｛System.out.println ("文件状态验证失败:"+ fileStatus);｝｝

私人静态无效查询(HttpClient客户端){字符串queryUrl = String.format(“查询?id = % s "、身份证);结果结果;JSONObject returnedData;intfileStatus = 0;做｛试一试｛结果= postAsync(queryUrl，零、客户端);returnedData =新JSONObject (results.getData ());fileStatus =返回数据。getint (“FileStatus”）;如果(fileStatus != 200) Thread.sleep(5000);｝抓(InterruptedException e) {returnedData =新JSONObject ();/ / e.printStackTrace ();｝｝而(|| fileStatus == 100 || fileStatus == 123);System.out.println ("文件已完成处理，返回代码:"+ fileStatus);如果(fileStatus != 200) {返回；｝parseJson (returnedData.get (“RequestData”) .toString ());｝

私人静态无效parseJson(String json) {JSONArray requestArray =新JSONArray (json);为(对象requestObject: requestArray) {如果(requestObject运算符JSONObject) {JSONObject requestReturn = (JSONObject) requestObject;System.out.println (“服务类型:”+ requestReturn.getString (“ServiceType”));System.out.println (返回的数据:“）;如果(requestReturn.get (“ServiceType”) .toString () .equals (“转换”)) {JSONArray urlArray =新JSONArray (requestReturn.get (“url”) .toString ());为(对象obj: urlArray) {System.out.println (obj.toString ());｝｝其他的｛System.out.println (requestReturn.get (“数据”) .toString ());｝System.out.println ("******************************************"）;｝｝｝

私人静态postAsync(字符串路径，对象主体，HttpClient客户端){字符串AppId =“替换为应用程序ID”；密码=“替换为应用程序密码”；字符串authHeader =“基本”+新字符串(Base64.getEncoder()。编码(AppId +”:“+密码).getBytes (StandardCharsets.UTF_8)));字符串hostedServicesUrl =“https://azure.leadtools.com/api/”；BodyPublisher thisBody = httprequest .BodyPublisher . ofstring (“零”）;如果(身体运算符BodyPublisher) {thisBody = (BodyPublisher) body;｝其他的如果(身体运算符文件){试一试｛thisBody = HttpRequest.BodyPublishers.ofFile(((File) body).toPath());｝抓(FileNotFoundException e) {/ / e.printStackTrace ();｝｝HttpRequest request = HttpRequest. newbuilder (). post (thisBody).uri (URI。创建(hostedServicesUrl +路径).header (“接受”，“application / json”）.header (“授权”authHeader).header (“内容类型”，“文本/普通”）.build ();CompletableFuture> result =客户端。(请求,HttpResponse.BodyHandlers.ofString是以());结果结果=新结果();results.setData (＂＂）;results.setStatusCode (0);试一试｛results.setData (result.thenApply (HttpResponse::身体)。(5, TimeUnit.SECONDS));results.setStatusCode (result.thenApply (HttpResponse:: statusCode)。(5, TimeUnit.SECONDS));｝抓(InterruptedException | ExecutionException | TimeoutException e) {e.printStackTrace ();｝返回结果;｝

私人静态类结果{私人字符串数据;私人intstatusCode;公共字符串getData() {返回数据;｝公共无效setData(字符串数据){这.data =数据;｝公共intgetStatusCode () {返回statusCode;｝公共无效setStatusCode (intstatusCode) {这.statusCode = statusCode;｝｝