From ed8c7a5effd0d423ce1118b680ecdca6fe732609 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期三, 02 七月 2025 16:43:13 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.11.205:9000/r/P2022036_Service

---
 src/main/java/com/lf/server/controller/show/ApplyController.java |  199 ++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 161 insertions(+), 38 deletions(-)

diff --git a/src/main/java/com/lf/server/controller/show/ApplyController.java b/src/main/java/com/lf/server/controller/show/ApplyController.java
index cbefd1c..3d6f7c2 100644
--- a/src/main/java/com/lf/server/controller/show/ApplyController.java
+++ b/src/main/java/com/lf/server/controller/show/ApplyController.java
@@ -2,16 +2,23 @@
 
 import com.lf.server.annotation.SysLog;
 import com.lf.server.controller.all.BaseController;
+import com.lf.server.entity.all.HttpStatus;
 import com.lf.server.entity.all.ResponseMsg;
+import com.lf.server.entity.all.StaticData;
 import com.lf.server.entity.ctrl.DownloadReqEntity;
+import com.lf.server.entity.data.DownloadEntity;
 import com.lf.server.entity.show.ApplyEntity;
 import com.lf.server.entity.show.FlowEntity;
 import com.lf.server.entity.sys.UserEntity;
 import com.lf.server.helper.AesHelper;
 import com.lf.server.helper.StringHelper;
+import com.lf.server.helper.WebHelper;
 import com.lf.server.service.data.DownloadService;
 import com.lf.server.service.show.ApplyService;
+import com.lf.server.service.show.FlowService;
+import com.lf.server.service.sys.DownlogService;
 import com.lf.server.service.sys.TokenService;
+import com.lf.server.service.sys.UserService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -20,6 +27,7 @@
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import java.sql.Timestamp;
 import java.util.List;
 
@@ -27,7 +35,7 @@
  * 鏁版嵁鐢宠
  * @author WWW
  */
-@Api(tags = "杩愮淮绠$悊\\鏁版嵁鐢宠")
+@Api(tags = "缁煎悎灞曠ず\\鏁版嵁鐢宠")
 @RestController
 @RequestMapping("/apply")
 public class ApplyController extends BaseController {
@@ -35,43 +43,55 @@
     ApplyService applyService;
 
     @Autowired
+    FlowService flowService;
+
+    @Autowired
     TokenService tokenService;
+
+    @Autowired
+    UserService userService;
+
+    @Autowired
+    DownlogService downlogService;
+
+    @Autowired
+    DownloadService downloadService;
 
     @SysLog()
     @ApiOperation(value = "鎻掑叆鏁版嵁鐢宠")
     @ApiImplicitParams({
-            @ApiImplicitParam(name = "reqEntity", value = "璇锋眰涓嬭浇瀹炰綋", dataType = "DownloadReqEntity", paramType = "body")
+            @ApiImplicitParam(name = "dr", value = "璇锋眰涓嬭浇瀹炰綋", dataType = "DownloadReqEntity", paramType = "body")
     })
     @ResponseBody
     @PostMapping(value = "/insertApply")
-    public ResponseMsg<Object> insertApply(@RequestBody DownloadReqEntity reqEntity, HttpServletRequest req) {
+    public ResponseMsg<Object> insertApply(@RequestBody DownloadReqEntity dr, HttpServletRequest req) {
         try {
-            if (null == reqEntity || StringHelper.isEmpty(reqEntity.getPwd())) {
-                return fail("瀵嗙爜涓嶈兘涓虹┖");
-            }
-            if (null == reqEntity.getTabs() || null == reqEntity.getEntities() || reqEntity.getTabs().size() != reqEntity.getEntities().size()) {
+            if (null == dr || null == dr.getEntities() || dr.getEntities().isEmpty()) {
                 return fail("璇烽�夋嫨瑕佷笅杞界殑瀹炰綋鍚�");
             }
-            if (null == reqEntity.getIds() || reqEntity.getIds().isEmpty()) {
-                return fail("璇烽�夋嫨鍗曚綅ID");
+            if (StringHelper.isEmpty(dr.getPwd())) {
+                return fail("瀵嗙爜涓嶈兘涓虹┖");
             }
-            reqEntity.setWkt(AesHelper.decrypt(reqEntity.getWkt()));
-            if (StringHelper.isEmpty(reqEntity.getWkt())) {
-                return fail("璇烽�夋嫨瑕佷笅杞界殑WKT鑼冨洿");
-            }
-            if (!DownloadService.decryptPwd(reqEntity)) {
-                return fail("瀵嗙爜瑙e瘑澶辫触", null);
-            }
-            if (!StringHelper.checkPwdValid(reqEntity.getPwd())) {
+            dr.setPwd(AesHelper.decrypt(dr.getPwd()));
+            if (StringHelper.isPwdInvalid(dr.getPwd())) {
                 return fail("瀵嗙爜涓嶇鍚堣姹�");
+            }
+            if (!StringHelper.isEmpty(dr.getWkt())) {
+                dr.setWkt(AesHelper.decrypt(dr.getWkt()));
+            }
+            if (null == dr.getTabs() || dr.getTabs().isEmpty()) {
+                return fail("璇烽�夋嫨瑕佷笅杞界殑琛ㄥ悕");
+            }
+            if (null == dr.getDepcodes() || dr.getDepcodes().isEmpty()) {
+                return fail("璇烽�夋嫨寰呯敵璇风殑鍗曚綅缂栫爜(澶氫釜浠ラ�楀彿闅斿紑)");
             }
 
             UserEntity ue = tokenService.getCurrentUser(req);
-            int rows = applyService.insertApply(ue, reqEntity);
+            int rows = applyService.insertApply(ue, dr);
 
             return success(rows);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
         }
     }
 
@@ -81,7 +101,7 @@
             @ApiImplicitParam(name = "uname", value = "鐢ㄦ埛鍚�", dataType = "String", paramType = "query", example = "鍛�"),
             @ApiImplicitParam(name = "status", value = "鐘舵��", dataType = "Integer", paramType = "query", example = "0"),
             @ApiImplicitParam(name = "start", value = "寮�濮嬫椂闂�", dataType = "Timestamp", paramType = "query", example = "2022-12-09 09:00:00"),
-            @ApiImplicitParam(name = "end", value = "缁撴潫鏃堕棿", dataType = "Timestamp", paramType = "query", example = "2022-12-25 17:00:00"),
+            @ApiImplicitParam(name = "end", value = "缁撴潫鏃堕棿", dataType = "Timestamp", paramType = "query", example = "2022-12-31 23:00:00"),
             @ApiImplicitParam(name = "pageSize", value = "姣忛〉鏉℃暟", dataType = "Integer", paramType = "query", example = "10"),
             @ApiImplicitParam(name = "pageIndex", value = "鍒嗛〉鏁帮紙浠�1寮�濮嬶級", dataType = "Integer", paramType = "query", example = "1")
     })
@@ -102,7 +122,7 @@
 
             return success(count, rs);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
         }
     }
 
@@ -116,39 +136,73 @@
 
             return success(rows);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
         }
     }
 
     @SysLog()
     @ApiOperation(value = "鏌ヨ娴佺▼")
     @ApiImplicitParams({
-            @ApiImplicitParam(name = "applyId", value = "鏁版嵁鐢宠ID", dataType = "Integer", paramType = "query", example = "1")
+            @ApiImplicitParam(name = "applyid", value = "鏁版嵁鐢宠ID", dataType = "Integer", paramType = "query", example = "1")
     })
     @GetMapping(value = "/selectFlows")
-    public ResponseMsg<Object> selectFlows(Integer applyId) {
+    public ResponseMsg<Object> selectFlows(Integer applyid) {
         try {
-            List<FlowEntity> rs = applyService.selectFlows(applyId);
+            List<FlowEntity> rs = applyService.selectFlows(applyid);
 
             return success(rs);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
         }
     }
 
     @SysLog()
     @ApiOperation(value = "搴熷純鐢宠")
     @ApiImplicitParams({
-            @ApiImplicitParam(name = "applyId", value = "鏁版嵁鐢宠ID", dataType = "Integer", paramType = "query", example = "1")
+            @ApiImplicitParam(name = "applyid", value = "鏁版嵁鐢宠ID", dataType = "Integer", paramType = "query", example = "1")
     })
-    @GetMapping(value = "/deleteForDiscard")
-    public ResponseMsg<Object> deleteForDiscard(Integer applyId) {
+    @GetMapping(value = "/updateForDiscard")
+    public ResponseMsg<Object> updateForDiscard(Integer applyid, HttpServletRequest req) {
         try {
-            //
+            ApplyEntity applyEntity = applyService.selectById(applyid);
+            if (null == applyEntity) {
+                return fail("鎵句笉鍒版暟鎹敵璇�");
+            }
+            if (!(applyEntity.getStatus() >= -1 && applyEntity.getStatus() <= StaticData.NINE)) {
+                return fail("璇ユ暟鎹敵璇锋棤娉曞簾寮�");
+            }
 
-            return success(null);
+            UserEntity ue = tokenService.getCurrentUser(req);
+            int rows = applyService.updateForDiscard(ue.getId(), applyid);
+
+            return success(rows);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
+        }
+    }
+
+    @SysLog()
+    @ApiOperation(value = "閲嶆柊鎻愪氦")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "applyid", value = "鏁版嵁鐢宠ID", dataType = "Integer", paramType = "query", example = "1")
+    })
+    @GetMapping(value = "/updateForResubmit")
+    public ResponseMsg<Object> updateForResubmit(Integer applyid, HttpServletRequest req) {
+        try {
+            ApplyEntity applyEntity = applyService.selectById(applyid);
+            if (null == applyEntity) {
+                return fail("鎵句笉鍒版暟鎹敵璇�");
+            }
+            if (-1 != applyEntity.getStatus()) {
+                return fail("璇ユ暟鎹敵璇锋棤闇�閲嶆柊鎻愪氦");
+            }
+
+            UserEntity ue = tokenService.getCurrentUser(req);
+            int rows = applyService.updateForResubmit(ue.getId(), applyid);
+
+            return success(rows);
+        } catch (Exception ex) {
+            return fail(ex, null);
         }
     }
 
@@ -157,12 +211,37 @@
     @ApiImplicitParams({
             @ApiImplicitParam(name = "flowId", value = "鐢宠娴佺▼ID", dataType = "Integer", paramType = "query", example = "1")
     })
-    public ResponseMsg<Object> updateForSubmit(Integer flowId) {
+    @GetMapping(value = "/updateForSubmit")
+    public ResponseMsg<Object> updateForSubmit(Integer flowId, HttpServletRequest req) {
         try {
+            FlowEntity flowEntity = flowService.selectById(flowId);
+            if (null == flowEntity) {
+                return fail("鎵句笉鍒扮敵璇锋祦绋�");
+            }
+            if (flowEntity.getStatus() != 0) {
+                return fail("璇ョ敵璇锋祦绋嬫棤闇�鎻愪氦");
+            }
 
-            return success(null);
+            ApplyEntity applyEntity = applyService.selectById(flowEntity.getApplyid());
+            if (null == applyEntity) {
+                return fail("鎵句笉鍒版暟鎹敵璇�");
+            }
+            if (!(applyEntity.getStatus() >= 0 && applyEntity.getStatus() <= StaticData.NINE)) {
+                return fail("璇ユ暟鎹敵璇锋棤闇�鎵撳洖");
+            }
+
+            UserEntity ue = tokenService.getCurrentUser(req);
+            int rows = applyService.updateForSubmit(ue.getId(), applyEntity.getId(), flowEntity.getId());
+
+            applyEntity = applyService.selectById(applyEntity.getId());
+            if (StaticData.I10 == applyEntity.getStatus()) {
+                UserEntity user = userService.selectUser(applyEntity.getUserid());
+                applyService.zipDbData(user, applyEntity);
+            }
+
+            return success(rows);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
         }
     }
 
@@ -171,12 +250,56 @@
     @ApiImplicitParams({
             @ApiImplicitParam(name = "flowId", value = "鐢宠娴佺▼ID", dataType = "Integer", paramType = "query", example = "1")
     })
-    public ResponseMsg<Object> updateForReject(Integer flowId) {
+    @GetMapping(value = "/updateForReject")
+    public ResponseMsg<Object> updateForReject(Integer flowId, HttpServletRequest req) {
         try {
+            FlowEntity flowEntity = flowService.selectById(flowId);
+            if (null == flowEntity) {
+                return fail("鎵句笉鍒扮敵璇锋祦绋�");
+            }
+            if (flowEntity.getStatus() != 0) {
+                return fail("璇ョ敵璇锋祦绋嬫棤闇�鎵撳洖");
+            }
 
-            return success(null);
+            ApplyEntity applyEntity = applyService.selectById(flowEntity.getApplyid());
+            if (null == applyEntity) {
+                return fail("鎵句笉鍒版暟鎹敵璇�");
+            }
+            if (!(applyEntity.getStatus() >= 0 && applyEntity.getStatus() <= StaticData.NINE)) {
+                return fail("璇ユ暟鎹敵璇锋棤闇�鎵撳洖");
+            }
+
+            UserEntity ue = tokenService.getCurrentUser(req);
+            Integer rows = applyService.updateForReject(ue.getId(), applyEntity.getId(), flowEntity.getId());
+
+            return success(rows);
         } catch (Exception ex) {
-            return fail(ex.getMessage(), null);
+            return fail(ex, null);
+        }
+    }
+
+    @SysLog()
+    @ApiOperation(value = "涓嬭浇鏂囦欢")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "guid", value = "鏂囦欢GUID", dataType = "String", paramType = "query")
+    })
+    @ResponseBody
+    @GetMapping(value = "/downloadFile")
+    public void downloadFile(String guid, HttpServletRequest req, HttpServletResponse res) {
+        try {
+            DownloadEntity de = downloadService.selectByGuid(guid);
+            if (null == de) {
+                WebHelper.writeInfo(HttpStatus.NOT_FOUND, "鏂囦欢涓嶅瓨鍦�", res);
+                return;
+            }
+
+            UserEntity ue = tokenService.getCurrentUser(req);
+            downlogService.updateInfos(ue, de, req);
+
+            String filePath = downloadService.getDownloadFilePath(de);
+            WebHelper.download(filePath, de.getName(), res);
+        } catch (Exception ex) {
+            WebHelper.writeInfo(HttpStatus.ERROR, ex.getMessage(), res);
         }
     }
 }

--
Gitblit v1.9.3