From 44e70ea1f80b048c80eec4a2dc7b3679ac3e3ccb Mon Sep 17 00:00:00 2001 From: 13693261870 <252740454@qq.com> Date: 星期日, 08 一月 2023 17:30:44 +0800 Subject: [PATCH] 1 --- src/main/java/com/lf/server/controller/data/upload/CheckController.java | 63 ++++++++++++++++++++++++++++++- 1 files changed, 61 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/lf/server/controller/data/upload/CheckController.java b/src/main/java/com/lf/server/controller/data/upload/CheckController.java index 8e86041..ac4dd64 100644 --- a/src/main/java/com/lf/server/controller/data/upload/CheckController.java +++ b/src/main/java/com/lf/server/controller/data/upload/CheckController.java @@ -3,6 +3,7 @@ import com.lf.server.annotation.SysLog; import com.lf.server.controller.all.BaseController; import com.lf.server.entity.all.ResponseMsg; +import com.lf.server.entity.all.StaticData; import com.lf.server.entity.ctrl.FmeReqEntity; import com.lf.server.helper.StringHelper; import com.lf.server.service.data.FmeService; @@ -13,6 +14,10 @@ import org.springframework.web.bind.annotation.GetMapping; import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import java.lang.reflect.Method; +import java.util.ArrayList; +import java.util.List; /** * 妫�鏌ユ帶鍒跺櫒 @@ -28,7 +33,7 @@ @ApiImplicitParam(name = "id", value = "浠诲姟ID", dataType = "String", paramType = "query", example = "29db09ee-2aae-4c62-bec0-0b5c5d8084e4") }) @GetMapping(value = "/selectTaskStatus") - public Object selectTaskStatus(String id,HttpServletRequest req) { + public Object selectTaskStatus(String id, HttpServletRequest req) { try { if (StringHelper.isEmpty(id)) { return fail("id涓嶈兘涓虹┖"); @@ -43,6 +48,60 @@ } @SysLog() + @ApiOperation(value = "涓嬭浇璐ㄦ閿欒缁撴灉") + @ApiImplicitParams({ + @ApiImplicitParam(name = "id", value = "浠诲姟ID", dataType = "String", paramType = "query", example = "29db09ee-2aae-4c62-bec0-0b5c5d8084e4") + }) + @GetMapping(value = "/downloadResult") + public void downloadResult(String id, HttpServletRequest req, HttpServletResponse res) { + try { + if (!StringHelper.isEmpty(id)) { + String url = fmeService.getDownloadUrl(id, req); + res.sendRedirect(url); + } + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + } + } + + @SysLog() + @ApiOperation(value = "鎻愪氦鏁版嵁璐ㄦ") + @GetMapping(value = "/uploadChecks") + public ResponseMsg<Object> uploadChecks(FmeReqEntity entity, HttpServletRequest req) { + try { + if (StringHelper.isEmpty(entity.names)) { + return fail("浠诲姟鍚嶇О涓嶈兘涓虹┖"); + } + + List<String> list = new ArrayList<>(); + for (String name : entity.names.split(StaticData.COMMA)) { + String guid = invoke(name, entity, req); + list.add(guid); + } + + return success(list); + } catch (Exception ex) { + return fail(ex.getMessage(), null); + } + } + + /** + * 鏂规硶璋冪敤 + */ + private String invoke(String name, FmeReqEntity entity, HttpServletRequest req) throws Exception { + Method method; + try { + method = FmeService.class.getDeclaredMethod(name, FmeReqEntity.class, HttpServletRequest.class); + } catch (Exception ex) { + throw new Exception(name + "锛岃妫�鏌ユ柟娉曚笉瀛樺湪"); + } + + Object obj = method.invoke(fmeService, entity, req); + + return null == obj ? null : obj.toString(); + } + + /*@SysLog() @ApiOperation(value = "鏌ヨOSGB妫�鏌�") @GetMapping(value = "/selectCheckOsgb") public ResponseMsg<Object> selectCheckOsgb(HttpServletRequest req) { @@ -315,5 +374,5 @@ } catch (Exception ex) { return fail(ex.getMessage(), null); } - } + }*/ } -- Gitblit v1.9.3