【住院慰问】模块适配通用文件上传接口相关接口功能改造

ruoyi-zzb/src/main/java/com/ruoyi/zzb/dbjz/controller/DbjzController.java

@@ -1,20 +1,15 @@
 package com.ruoyi.zzb.dbjz.controller;
 
 import com.alibaba.fastjson.JSONObject;
-import com.ruoyi.common.config.RuoYiConfig;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.zzb.common.bean.RspResult;
-import com.ruoyi.zzb.common.domain.BaseFileInfo;
-import com.ruoyi.zzb.common.utils.SnowflakeIdGenerator;
 import com.ruoyi.zzb.dbjz.domain.DbjzApplyInfo;
-import com.ruoyi.zzb.dbjz.domain.DbjzFileSetDTO;
 import com.ruoyi.zzb.dbjz.service.DbjzService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
-import java.util.List;
 
 @Slf4j
 @RestController
@@ -29,7 +24,7 @@ public class DbjzController {
      * @param
      * @return
      */
-    @PostMapping("/saveOrUpdate")
+    /*@PostMapping("/saveOrUpdate")
     public JSONObject saveOrUpdate(DbjzApplyInfo dbjzApplyInfo, DbjzFileSetDTO dbjzFileSetDTO){
         try {
             // 文件上传路径
@@ -54,7 +49,7 @@ public class DbjzController {
             log.error("【大病救助】申请信息保存/修改失败", e);
             return RspResult.error("【大病救助】申请信息保存/修改失败 - " + e.getMessage());
         }
-    }
+    }*/
 
     @PostMapping("/approve")
     public JSONObject approve(@RequestBody JSONObject reqBody){
@@ -100,4 +95,29 @@ public class DbjzController {
         }
     }
 
+
+    /**
+     * 保存/修改一条【大病救助】申请信息记录
+     * @param
+     * @return
+     */
+    @PostMapping("/saveOrUpdate")
+    public JSONObject saveOrUpdate(@RequestBody DbjzApplyInfo dbjzApplyInfo){
+        try {
+            SysUser user = SecurityUtils.getLoginUser().getUser();
+            if(null != user){
+                String applyFormId = dbjzApplyInfo.getApplyFormId();
+                if(StringUtils.isBlank(applyFormId)){
+                    return RspResult.error("applyFormId参数为空");
+                }
+                boolean optFlag = dbjzService.saveOrUpdateDbjzApplyInfo(dbjzApplyInfo, user);
+                return optFlag? RspResult.success(true) : RspResult.error("【大病救助】申请信息保存/修改失败");
+            }
+            return RspResult.error("用户信息为空，【大病救助】申请信息无法保存/修改");
+        } catch (Exception e){
+            log.error("【大病救助】申请信息保存/修改失败", e);
+            return RspResult.error("【大病救助】申请信息保存/修改失败 - " + e.getMessage());
+        }
+    }
+
 }

ruoyi-zzb/src/main/java/com/ruoyi/zzb/dbjz/service/DbjzService.java

@@ -128,7 +128,7 @@ public class DbjzService {
                 baseFileInfoMapper.batchInsertBaseFileInfos(baseFileInfoList);
                 log.info("【大病救助】申请信息、文件信息均修改成功  申请单ID：{}", applyFormIdExist);
             } else {
-                throw new RuntimeException("数据库【大病救助】申请信息记录未修改  applyFormId：" + applyFormIdExist);
+                throw new RuntimeException("数据库【大病救助】申请信息记录未修改  申请单ID：" + applyFormIdExist);
             }
         }
     }
@@ -225,4 +225,44 @@ public class DbjzService {
     }
 
 
+    /**
+     * 保存/修改一条【大病救助】申请信息
+     * @return
+     */
+    @Transactional
+    public boolean saveOrUpdateDbjzApplyInfo(DbjzApplyInfo dbjzApplyInfo, SysUser user){
+        String applyFormId = dbjzApplyInfo.getApplyFormId();
+        QueryWrapper<DbjzApplyInfo> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("APPLY_FORM_ID", applyFormId);
+        DbjzApplyInfo dbDbjzApplyInfo = dbjzApplyInfoMapper.selectById(applyFormId);
+        // 如果当前申请信息对象dbjzApplyInfo的申请单ID在数据库中不存在（前端生成），代表是新增操作
+        if(dbDbjzApplyInfo == null){
+            // 设置当前登录的用户信息
+            dbjzApplyInfo.setCreateUserId(String.valueOf(user.getUserId()));
+            dbjzApplyInfo.setCreateUserName(user.getNickName());
+            dbjzApplyInfo.setCreateUserPoliceNo(user.getPoliceNo());
+            // 插入申请信息
+            dbjzApplyInfo.setApplyFormId(applyFormId);
+            int insertRows = dbjzApplyInfoMapper.insert(dbjzApplyInfo);
+            if(insertRows > 0){
+                log.info("【大病救助】申请信息保存成功  申请单ID：{}", applyFormId);
+                return true;
+            } else {
+                throw new RuntimeException("数据库【大病救助】申请信息记录未插入  申请单ID：" + applyFormId);
+            }
+        } else {   // 修改操作
+            // 根据申请单ID和dbjzApplyInfo对象中的当前属性值去修改当前申请记录
+            UpdateWrapper<DbjzApplyInfo> updateWrapper = new UpdateWrapper<>();
+            updateWrapper.eq("APPLY_FORM_ID", applyFormId);
+            int updateRows = dbjzApplyInfoMapper.update(dbjzApplyInfo, updateWrapper);
+            if(updateRows > 0){
+                log.info("【大病救助】申请信息修改成功  申请单ID：{}", applyFormId);
+                return true;
+            } else {
+                throw new RuntimeException("数据库【大病救助】申请信息记录未修改  申请单ID：" + applyFormId);
+            }
+        }
+    }
+
+
 }

ruoyi-zzb/src/main/java/com/ruoyi/zzb/hybz/controller/HybzController.java

@@ -10,6 +10,7 @@ import com.ruoyi.zzb.common.domain.BaseFileInfo;
 import com.ruoyi.zzb.hybz.domain.HybzApplyInfo;
 import com.ruoyi.zzb.hybz.domain.HybzFileSetDTO;
 import com.ruoyi.zzb.hybz.service.HybzService;
+import com.ruoyi.zzb.zyww.domain.ZywwApplyInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -102,6 +103,31 @@ public class HybzController {
     }
 
 
+    /**
+     * 保存/修改一条【会员保障】申请信息记录
+     * @param
+     * @return
+     */
+    @PostMapping("/saveOrUpdate")
+    public JSONObject saveOrUpdate(@RequestBody HybzApplyInfo hybzApplyInfo){
+        try {
+            SysUser user = SecurityUtils.getLoginUser().getUser();
+            if(null != user){
+                String applyFormId = hybzApplyInfo.getApplyFormId();
+                if(StringUtils.isBlank(applyFormId)){
+                    return RspResult.error("applyFormId参数为空");
+                }
+                boolean optFlag = hybzService.saveOrUpdateHybzApplyInfo(hybzApplyInfo, user);
+                return optFlag? RspResult.success(true) : RspResult.error("【会员保障】申请信息保存/修改失败");
+            }
+            return RspResult.error("用户信息为空，【会员保障】申请信息无法保存/修改");
+        } catch (Exception e){
+            log.error("【会员保障】申请信息保存/修改失败", e);
+            return RspResult.error("【会员保障】申请信息保存/修改失败 - " + e.getMessage());
+        }
+    }
+
+
 
 
 

ruoyi-zzb/src/main/java/com/ruoyi/zzb/hybz/service/HybzService.java

@@ -136,7 +136,7 @@ public class HybzService {
                 baseFileInfoMapper.batchInsertBaseFileInfos(baseFileInfoList);
                 log.info("【会员保障】申请信息、文件信息均修改成功  申请单ID：{}", applyFormIdExist);
             } else {
-                throw new RuntimeException("数据库【会员保障】申请信息记录未修改  applyFormId：" + applyFormIdExist);
+                throw new RuntimeException("数据库【会员保障】申请信息记录未修改  申请单ID：" + applyFormIdExist);
             }
         }
 
@@ -235,4 +235,44 @@ public class HybzService {
     }
 
 
+    /**
+     * 保存/修改一条【会员保障】申请信息
+     * @return
+     */
+    @Transactional
+    public boolean saveOrUpdateHybzApplyInfo(HybzApplyInfo hybzApplyInfo, SysUser user){
+        String applyFormId = hybzApplyInfo.getApplyFormId();
+        QueryWrapper<HybzApplyInfo> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("APPLY_FORM_ID", applyFormId);
+        HybzApplyInfo dbHybzApplyInfo = hybzApplyInfoMapper.selectOne(queryWrapper);
+        // 如果当前申请信息对象hybzApplyInfo的申请单ID在数据库中不存在（前端生成），代表是新增操作
+        if(dbHybzApplyInfo == null){
+            // 设置当前登录的用户信息
+            hybzApplyInfo.setCreateUserId(String.valueOf(user.getUserId()));
+            hybzApplyInfo.setCreateUserName(user.getNickName());
+            hybzApplyInfo.setCreateUserPoliceNo(user.getPoliceNo());
+            // 插入申请信息
+            hybzApplyInfo.setApplyFormId(applyFormId);
+            int insertRows = hybzApplyInfoMapper.insert(hybzApplyInfo);
+            if(insertRows > 0){
+                log.info("【会员保障】申请信息保存成功  申请单ID：{}", applyFormId);
+                return true;
+            } else {
+                throw new RuntimeException("数据库【会员保障】申请信息记录未插入  申请单ID：" + applyFormId);
+            }
+        } else {   // 修改操作
+            // 根据申请单ID和hybzApplyInfo对象中的当前属性值去修改当前申请记录
+            UpdateWrapper<HybzApplyInfo> updateWrapper = new UpdateWrapper<>();
+            updateWrapper.eq("APPLY_FORM_ID", applyFormId);
+            int updateRows = hybzApplyInfoMapper.update(hybzApplyInfo, updateWrapper);
+            if(updateRows > 0){
+                log.info("【会员保障】申请信息修改成功  申请单ID：{}", applyFormId);
+                return true;
+            } else {
+                throw new RuntimeException("数据库【会员保障】申请信息记录未修改  申请单ID：" + applyFormId);
+            }
+        }
+    }
+
+
 }

ruoyi-zzb/src/main/java/com/ruoyi/zzb/zyww/service/ZywwService.java

@@ -106,9 +106,6 @@ public class ZywwService {
     }
 
 
-
-
-
     /**
      * 保存/修改一条【住院慰问】申请信息并且批量插入/修改与【住院慰问】申请信息相关联的文件信息
      * @return
@@ -145,7 +142,7 @@ public class ZywwService {
                 baseFileInfoMapper.batchInsertBaseFileInfos(baseFileInfoList);
                 log.info("【住院慰问】申请信息、文件信息均修改成功  申请单ID：{}", applyFormIdExist);
             } else {
-                throw new RuntimeException("数据库【住院慰问】申请信息记录未修改  applyFormId：" + applyFormIdExist);
+                throw new RuntimeException("数据库【住院慰问】申请信息记录未修改  申请单ID：" + applyFormIdExist);
             }
         }
     }
@@ -157,7 +154,9 @@ public class ZywwService {
     @Transactional
     public boolean saveOrUpdateZywwApplyInfo(ZywwApplyInfo zywwApplyInfo, SysUser user){
         String applyFormId = zywwApplyInfo.getApplyFormId();
-        ZywwApplyInfo dbZywwApplyInfo = zywwApplyInfoMapper.selectById(applyFormId);
+        QueryWrapper<ZywwApplyInfo> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("APPLY_FORM_ID", applyFormId);
+        ZywwApplyInfo dbZywwApplyInfo = zywwApplyInfoMapper.selectOne(queryWrapper);
         // 如果当前申请信息对象zywwApplyInfo的申请单ID在数据库中不存在（前端生成），代表是新增操作
         if(dbZywwApplyInfo == null){
             // 设置当前登录的用户信息
@@ -182,7 +181,7 @@ public class ZywwService {
                 log.info("【住院慰问】申请信息修改成功  申请单ID：{}", applyFormId);
                 return true;
             } else {
-                throw new RuntimeException("数据库【住院慰问】申请信息记录未修改  applyFormId：" + applyFormId);
+                throw new RuntimeException("数据库【住院慰问】申请信息记录未修改  申请单ID：" + applyFormId);
             }
         }
     }