提交代码

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/controller/DgAssetsInvestigationController.java

@@ -46,7 +46,7 @@ public class DgAssetsInvestigationController {
         String CustomerNumberOrName=assetsInvestigationRequest.getCustomerNumberOrName();
         Integer status=assetsInvestigationRequest.getStatus();
         //获取当前登录用户userId
-        //String userId = dgApplyAmountInfoController.getUserId();
+        // String userId = dgApplyAmountInfoController.getUserId();
         String userId = "5";
         //根据角色查询资产部调查列表
         String roleIds = RedisUtil.get("dq:userRole:" + userId);

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/controller/DgProcessController.java

@@ -17,4 +17,5 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/dg-process")
 public class DgProcessController {
 
+
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/DgGuaranteeLetterAssignUserMapper.java

@@ -8,6 +8,8 @@ import com.daqing.framework.domain.guarantee.DgGuaranteeLetterAssignUser;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * <p>
  * 担保函记录 Mapper 接口
@@ -19,6 +21,6 @@ import org.apache.ibatis.annotations.Param;
 @Mapper
 public interface DgGuaranteeLetterAssignUserMapper extends BaseMapper<DgGuaranteeLetterAssignUser> {
 
-    IPage<GuaranteeLetterListResponse> pageByCondition(Page page, @Param("userId") Integer userId, @Param("roleId") Integer roleId, @Param("status") Integer status, @Param("customerNumberOrName") String customerNumberOrName);
+    IPage<GuaranteeLetterListResponse> pageByCondition(Page page, Integer userId, List<String> roleIdList, Integer status, String customerNumberOrName);
 
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/DgPaymentConfirmationConsiderMapper.java

@@ -7,6 +7,8 @@ import com.daqing.financial.guarantee.model.response.PaymentConfirmationListResp
 import com.daqing.framework.domain.guarantee.DgPaymentConfirmationConsider;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
+
 /**
  * <p>
  * 回款确认 Mapper 接口
@@ -18,5 +20,6 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface DgPaymentConfirmationConsiderMapper extends BaseMapper<DgPaymentConfirmationConsider> {
 
-    IPage<PaymentConfirmationListResponse> pageByCondition(Page page, Integer roleId, Integer status, String customerNumberOrName);
+    IPage<PaymentConfirmationListResponse> pageByCondition(Page page, List<String> roleIdList, Integer status, String customerNumberOrName);
+
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/request/GuaranteeLetterQueryRequest.java

@@ -18,15 +18,10 @@ public class GuaranteeLetterQueryRequest {
     @ApiModelProperty(value = "每页记录数,默认显示10条")
     private Integer size = 10;
 
-    @ApiModelProperty(value = "流程状态：1->审核中、2->拒绝、3->已审核")
+    @ApiModelProperty(value = "审核状态：（1审核中 、2已审核、4已驳回）")
     private Integer status;
 
     @ApiModelProperty(value = "业务编号/客户名称")
     private String CustomerNumberOrName;
 
-    @ApiModelProperty(value = "用户ID")
-    private Integer userId;
-
-    @ApiModelProperty(value = "角色ID")
-    private Integer roleId;
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/request/GuaranteeLetterUpdateStatusRequest.java

@@ -12,18 +12,6 @@ import lombok.Data;
 @Data
 public class GuaranteeLetterUpdateStatusRequest {
 
-    @ApiModelProperty(value = "当前用户")
-    private Integer currentUser;
-
-    @ApiModelProperty(value = "当前用户角色")
-    private Integer currentUserRole;
-
-    @ApiModelProperty(value = "a角用户")
-    private Integer aUser;
-
-    @ApiModelProperty(value = "b角用户")
-    private Integer bUser;
-
     @ApiModelProperty(value = "业务id")
     private Integer businessId;
 

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/request/LoanNoticeQueryRequest.java

@@ -20,13 +20,10 @@ public class LoanNoticeQueryRequest {
     @ApiModelProperty(value = "每页记录数,默认显示10条")
     private Integer size = 10;
 
-    @ApiModelProperty(value = "流程状态：1->审核中、2->拒绝、3->已审核")
+    @ApiModelProperty(value = "审核状态：（1审核中 、2已审核、4已驳回）")
     private Integer status;
 
     @ApiModelProperty(value = "业务编号/客户名称")
     private String CustomerNumberOrName;
 
-    @NotNull
-    @ApiModelProperty(value = "角色ID")
-    private Integer roleId;
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/request/PaymentConfirmationQueryRequest.java

@@ -20,14 +20,10 @@ public class PaymentConfirmationQueryRequest {
     @ApiModelProperty(value = "每页记录数,默认显示10条")
     private Integer size = 10;
 
-    @ApiModelProperty(value = "流程状态：1->审核中、2->拒绝、3->已审核")
+    @ApiModelProperty(value = "审核状态：（1审核中 、2已审核、4已驳回）")
     private Integer status;
 
     @ApiModelProperty(value = "业务编号/客户名称")
     private String CustomerNumberOrName;
 
-    @NotNull
-    @ApiModelProperty(value = "角色ID")
-    private Integer roleId;
-
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/DgGuaranteeLetterAssignUserServiceImpl.java

@@ -16,12 +16,19 @@ import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
 import com.daqing.framework.domain.guarantee.DgPaymentConfirmationConsider;
 import com.daqing.framework.model.StatusCode;
 import com.daqing.framework.model.response.PromptSuccess;
+import com.daqing.framework.util.RedisUtil;
 import com.daqing.framework.utils.PageUtils;
-import com.sun.xml.internal.bind.v2.TODO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Arrays;
+import java.util.List;
+import java.util.spi.CurrencyNameProvider;
 
 /**
  * <p>
@@ -41,18 +48,35 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
     @Autowired
     private DgLoanCommitteeConsiderMapper dgLoanCommitteeConsiderMapper;
 
+
+    /**
+     * 获取当前登录用户信息
+     */
+    private String getUserId(){
+        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        String token = request.getHeader("token");
+        return RedisUtil.get("dq:token:"+token);
+    }
+
     @Override
     public PageUtils queryPage(GuaranteeLetterQueryRequest guaranteeLetterQueryRequest) {
         //取出条件
         Integer page = guaranteeLetterQueryRequest.getPage();
         Integer size = guaranteeLetterQueryRequest.getSize();
         Integer status = guaranteeLetterQueryRequest.getStatus();
-        //a角和b角根据用户id查询，经理根据角色id查询
-        Integer userId = guaranteeLetterQueryRequest.getUserId();
-        Integer roleId = guaranteeLetterQueryRequest.getRoleId();
         String customerNumberOrName = guaranteeLetterQueryRequest.getCustomerNumberOrName();
-        //分页条件查询
-        IPage<GuaranteeLetterListResponse> guaranteeLetterVO = baseMapper.pageByCondition(new Page(page,size),userId,roleId,status,customerNumberOrName);
+        //获取当前登录用户id
+        Integer userId = Integer.parseInt(this.getUserId());
+
+        //获取当前用户拥有的角色ids
+        String roleIds = RedisUtil.get("dq:userRole:" + userId);
+        IPage<GuaranteeLetterListResponse> guaranteeLetterVO = null;
+        if(roleIds != null) {
+            String[] ids = roleIds.split(",");
+            List<String> roleIdList = Arrays.asList(ids);
+            //分页条件查询
+            guaranteeLetterVO = baseMapper.pageByCondition(new Page(page,size),userId,roleIdList,status,customerNumberOrName);
+        }
 
         return new PageUtils(guaranteeLetterVO);
     }
@@ -75,20 +99,26 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
         Integer status = guaranteeLetterUpdateStatusRequest.getStatus();
 
         String auditOpinion = guaranteeLetterUpdateStatusRequest.getAuditOpinion();
-        Integer aUser = guaranteeLetterUpdateStatusRequest.getAUser();
-        Integer bUser = guaranteeLetterUpdateStatusRequest.getBUser();
-        Integer currentUser = guaranteeLetterUpdateStatusRequest.getCurrentUser();
-        Integer currentUserRole = guaranteeLetterUpdateStatusRequest.getCurrentUserRole();
+        //获取当前登录用户id
+        Integer currentUser = Integer.parseInt(this.getUserId());
+        //获取当前用户拥有的角色ids
+        String roleIds = RedisUtil.get("dq:userRole:" + currentUser);
+        List<String> roleIdList = null;
+        if(roleIds != null) {
+            String[] ids = roleIds.split(",");
+            roleIdList = Arrays.asList(ids);
+        }
 
         //*************************************************根据角色更新数据************************************************
 
         //角色不为空
-        if (currentUserRole!=null){
+        if (roleIdList!=null){
+
             //角色为法规部经理则生成担保函操作和驳回操作
-            if (PromptSuccess.FG_JL_ID.equals(currentUserRole)){
+            if (roleIdList.contains(PromptSuccess.FG_JL_ID)){
                 //更新之前,获取此数据的审批状态，如果审批状态为驳回，则更新ab角用户数据，如果审批状态为审批中，则添加ab角用户数据
                 QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
-                queryWrapperTemp.eq("business_id",businessId).eq("role_id",currentUserRole);
+                queryWrapperTemp.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
                 DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
                 Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
 
@@ -96,7 +126,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                 if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -111,12 +141,12 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                     if (i > 0){
                         //添加a角
                         DgGuaranteeLetterAssignUser guaranteeLetterUser = new DgGuaranteeLetterAssignUser();
-                        guaranteeLetterUser.setUserId(aUser);
+                        guaranteeLetterUser.setRoleId(PromptSuccess.DB_A_ID);
                         guaranteeLetterUser.setBusinessId(businessId);
                         guaranteeLetterUser.setCompanyId(companyId);
                         baseMapper.insert(guaranteeLetterUser);
                         //添加b角
-                        guaranteeLetterUser.setUserId(bUser);
+                        guaranteeLetterUser.setRoleId(PromptSuccess.DB_B_ID);
                         int insert = baseMapper.insert(guaranteeLetterUser);
                         //更新成功，返回操作结果
                         log.info(insert > 0 ? "法规部经理成功生成担保函" : "法规部经理生成担保函失败");
@@ -128,7 +158,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                 if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -142,7 +172,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                         //更新a角
                         //根据业务id查询A用户数据
                         QueryWrapper<DgGuaranteeLetterAssignUser> guaranteeLetterAssignUserQueryWrapperA = new QueryWrapper<>();
-                        guaranteeLetterAssignUserQueryWrapperA.eq("business_id",businessId).eq("user_id",aUser);
+                        guaranteeLetterAssignUserQueryWrapperA.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
                         DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserA = baseMapper.selectOne(guaranteeLetterAssignUserQueryWrapperA);
                         dgGuaranteeLetterAssignUserA.setStatus(StatusCode.SP_IN_REVIEW);
                         dgGuaranteeLetterAssignUserA.setOperatingStatus(StatusCode.CZ_ON_HAND);
@@ -153,7 +183,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                         //更新b角
                         //根据业务id查询B用户数据
                         QueryWrapper<DgGuaranteeLetterAssignUser> guaranteeLetterAssignUserQueryWrapperB = new QueryWrapper<>();
-                        guaranteeLetterAssignUserQueryWrapperB.eq("business_id",businessId).eq("user_id",bUser);
+                        guaranteeLetterAssignUserQueryWrapperB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
                         DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserB = baseMapper.selectOne(guaranteeLetterAssignUserQueryWrapperB);
                         dgGuaranteeLetterAssignUserB.setStatus(StatusCode.SP_IN_REVIEW);
                         dgGuaranteeLetterAssignUserB.setOperatingStatus(StatusCode.CZ_ON_HAND);
@@ -170,7 +200,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                 if (StatusCode.SP_REJECT.equals(status)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -196,10 +226,10 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
             }
 
             //角色为资产部经理则确认担保函操作和驳回操作
-            if (PromptSuccess.ZC_JL_ID.equals(currentUserRole)){
+            if (roleIdList.contains(PromptSuccess.ZC_JL_ID)){
                 //更新之前,获取此数据的审批状态，如果审批状态为驳回，则更新回款确认数据，如果审批状态为审批中，则添加回款确认数据
                 QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
-                queryWrapperTemp.eq("business_id",businessId).eq("role_id",currentUserRole);
+                queryWrapperTemp.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
                 DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
                 Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
 
@@ -207,7 +237,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                 if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -236,7 +266,7 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                 if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -263,12 +293,11 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                     }
                 }
 
-
                 //驳回操作，更新数据及更新AB用户数据
                 if (StatusCode.SP_REJECT.equals(status)){
                     //根据角色及业务id查询需要更新数据
                     QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapper = new QueryWrapper<>();
-                    queryWrapper.eq("business_id",businessId).eq("role_id",currentUserRole);
+                    queryWrapper.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
                     DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapper);
                     //操作用户为当前用户
                     guaranteeLetterAssignUser.setUserId(currentUser);
@@ -277,21 +306,21 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                     guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
                     //根据当前用户更新审核状态和操作状态及审核意见
                     int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                    //更新成功，更新AB用户数据
+                    //更新成功，更新AB角数据
                     if (i > 0){
-                        //根据业务id查询A用户数据
+                        //根据业务id查询A角数据
                         QueryWrapper<DgGuaranteeLetterAssignUser> guaranteeLetterAssignUserQueryWrapperA = new QueryWrapper<>();
-                        guaranteeLetterAssignUserQueryWrapperA.eq("business_id",businessId).eq("user_id",aUser);
+                        guaranteeLetterAssignUserQueryWrapperA.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
                         DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserA = baseMapper.selectOne(guaranteeLetterAssignUserQueryWrapperA);
                         //审批状态为已驳回，操作状态为待处理
                         dgGuaranteeLetterAssignUserA.setStatus(StatusCode.SP_REJECT);
                         dgGuaranteeLetterAssignUserA.setOperatingStatus(StatusCode.CZ_ON_HAND);
-                        //更新a用户操作业务数据
+                        //更新a角操作业务数据
                         baseMapper.updateById(dgGuaranteeLetterAssignUserA);
 
-                        //根据业务id查询B用户数据
+                        //根据业务id查询B角数据
                         QueryWrapper<DgGuaranteeLetterAssignUser> guaranteeLetterAssignUserQueryWrapperB = new QueryWrapper<>();
-                        guaranteeLetterAssignUserQueryWrapperB.eq("business_id",businessId).eq("user_id",bUser);
+                        guaranteeLetterAssignUserQueryWrapperB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
                         DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserB = baseMapper.selectOne(guaranteeLetterAssignUserQueryWrapperB);
                         //审批状态为已驳回，操作状态为待处理
                         dgGuaranteeLetterAssignUserB.setStatus(StatusCode.SP_REJECT);
@@ -304,232 +333,237 @@ public class DgGuaranteeLetterAssignUserServiceImpl extends ServiceImpl<DgGuaran
                     }
                 }
             }
-        }
 
-        //*********************************************角色为空根据用户更新数据*********************************************
-
-        //当前用户为a角用户
-        if (currentUser.equals(aUser)){
-            //更新之前,获取此用户数据的审批状态，如果审批状态为驳回，则更新资产部经理数据，如果审批状态为审批中，则添加资产部经理数据
-            QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
-            queryWrapperTemp.eq("business_id",businessId).eq("user_id",aUser);
-            DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
-            Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
-
-            //首次a角用户确认担保函，检查b角用户是否确认担保函
-            if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",aUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-                //获取公司id
-                Integer companyId = guaranteeLetterAssignUser.getCompanyId();
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "首次a角用户确认担保函更新成功" : "首次a角用户确认担保函更新失败");
-                //更新成功后，判断b角用户是否确认
-                if (i > 0){
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
-                    //查询b用户的审核状态
-                    tempB.eq("business_id",businessId).eq("user_id",bUser).select("status");
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
-                    Integer bStatus = dgGuaranteeLetterAssignUser.getStatus();
-                    //b用户审核通过，添加资产部经理数据
-                    if (StatusCode.SP_REVIEWED.equals(bStatus)){
-                        DgGuaranteeLetterAssignUser ZCJLGuaranteeLetterAssign = new DgGuaranteeLetterAssignUser();
-                        ZCJLGuaranteeLetterAssign.setBusinessId(businessId);
-                        ZCJLGuaranteeLetterAssign.setCompanyId(companyId);
-                        ZCJLGuaranteeLetterAssign.setRoleId(PromptSuccess.ZC_JL_ID);
-                        int insert = baseMapper.insert(ZCJLGuaranteeLetterAssign);
-                        //添加成功，返回操作结果
-                        log.info(insert > 0 ? "资产部经理添加成功" : "资产部经理添加失败");
-                        return insert > 0;
+
+            //角色为a角确认担保函操作和驳回操作
+            if (roleIdList.contains(PromptSuccess.DB_A_ID)){
+                //更新之前,获取此用户数据的审批状态，如果审批状态为驳回，则更新资产部经理数据，如果审批状态为审批中，则添加资产部经理数据
+                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
+                queryWrapperTemp.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
+                DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
+                Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
+
+                //首次a角用户确认担保函，检查b角用户是否确认担保函
+                if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setUserId(currentUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+                    //获取公司id
+                    Integer companyId = guaranteeLetterAssignUser.getCompanyId();
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "首次a角用户确认担保函更新成功" : "首次a角用户确认担保函更新失败");
+                    //更新成功后，判断b角用户是否确认
+                    if (i > 0){
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
+                        //查询b用户的审核状态
+                        tempB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID).select("status");
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
+                        Integer bStatus = dgGuaranteeLetterAssignUser.getStatus();
+                        //b用户审核通过，添加资产部经理数据
+                        if (StatusCode.SP_REVIEWED.equals(bStatus)){
+                            DgGuaranteeLetterAssignUser ZCJLGuaranteeLetterAssign = new DgGuaranteeLetterAssignUser();
+                            ZCJLGuaranteeLetterAssign.setBusinessId(businessId);
+                            ZCJLGuaranteeLetterAssign.setCompanyId(companyId);
+                            ZCJLGuaranteeLetterAssign.setRoleId(PromptSuccess.ZC_JL_ID);
+                            int insert = baseMapper.insert(ZCJLGuaranteeLetterAssign);
+                            //添加成功，返回操作结果
+                            log.info(insert > 0 ? "资产部经理添加成功" : "资产部经理添加失败");
+                            return insert > 0;
+                        }
                     }
                 }
-            }
 
-            //驳回后a角用户再次确认担保函，检查b角用户是否确认担保函
-            if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",aUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "驳回后a角用户确认担保函更新成功" : "驳回后a角用户确认担保函更新失败");
-                //更新成功后，判断b角用户是否确认
-                if (i > 0){
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
-                    //查询b用户的审核状态
-                    tempB.eq("business_id",businessId).eq("user_id",bUser).select("status");
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
-                    Integer bStatus = dgGuaranteeLetterAssignUser.getStatus();
-                    //b用户审核通过，更新资产部经理数据
-                    if (StatusCode.SP_REVIEWED.equals(bStatus)){
-                        QueryWrapper<DgGuaranteeLetterAssignUser> queryZCJLUser = new QueryWrapper<>();
-                        queryZCJLUser.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
-                        DgGuaranteeLetterAssignUser letterAssignUserZCJL = baseMapper.selectOne(queryZCJLUser);
-                        //清空审批意见
-                        letterAssignUserZCJL.setAuditOpinion("");
-                        letterAssignUserZCJL.setStatus(StatusCode.SP_IN_REVIEW);
-                        letterAssignUserZCJL.setStatus(StatusCode.CZ_ON_HAND);
-                        int update = baseMapper.updateById(letterAssignUserZCJL);
-                        //更新成功，返回操作结果
-                        log.info(update > 0 ? "资产部经理更新成功" : "资产部经理更新失败");
-                        return update > 0;
+                //驳回后a角用户再次确认担保函，检查b角用户是否确认担保函
+                if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "驳回后a角用户确认担保函更新成功" : "驳回后a角用户确认担保函更新失败");
+                    //更新成功后，判断b角用户是否确认
+                    if (i > 0){
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
+                        //查询b用户的审核状态
+                        tempB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID).select("status");
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
+                        Integer bStatus = dgGuaranteeLetterAssignUser.getStatus();
+                        //b用户审核通过，更新资产部经理数据
+                        if (StatusCode.SP_REVIEWED.equals(bStatus)){
+                            QueryWrapper<DgGuaranteeLetterAssignUser> queryZCJLUser = new QueryWrapper<>();
+                            queryZCJLUser.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
+                            DgGuaranteeLetterAssignUser letterAssignUserZCJL = baseMapper.selectOne(queryZCJLUser);
+                            //清空审批意见
+                            letterAssignUserZCJL.setAuditOpinion("");
+                            letterAssignUserZCJL.setStatus(StatusCode.SP_IN_REVIEW);
+                            letterAssignUserZCJL.setStatus(StatusCode.CZ_ON_HAND);
+                            int update = baseMapper.updateById(letterAssignUserZCJL);
+                            //更新成功，返回操作结果
+                            log.info(update > 0 ? "资产部经理更新成功" : "资产部经理更新失败");
+                            return update > 0;
+                        }
                     }
                 }
-            }
 
-            //a角驳回操作，更新a角数据及b角数据及返回上一流程
-            if (StatusCode.SP_REJECT.equals(status)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",aUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REJECT);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "a角用户驳回担保函更新成功" : "a角用户驳回担保函更新失败");
-                //更新成功后，更新b角数据及更新法规部经理数据
-                if (i > 0){
-                    //更新b用户的审核状态为驳回
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
-                    tempB.eq("business_id",businessId).eq("user_id",bUser);
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserB = baseMapper.selectOne(tempB);
-                    dgGuaranteeLetterAssignUserB.setStatus(StatusCode.SP_REJECT);
-                    baseMapper.updateById(dgGuaranteeLetterAssignUserB);
-
-                    //更新法规部经理的审核状态为驳回，操作状态为待处理
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempFG = new QueryWrapper<>();
-                    tempFG.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserFG = baseMapper.selectOne(tempFG);
-                    dgGuaranteeLetterAssignUserFG.setStatus(StatusCode.SP_REJECT);
-                    dgGuaranteeLetterAssignUserFG.setOperatingStatus(StatusCode.CZ_ON_HAND);
-                    int update = baseMapper.updateById(dgGuaranteeLetterAssignUserFG);
-                    //添加成功，返回操作结果
-                    log.info(update > 0 ? "a角驳回更新成功" : "a角驳回更新失败");
-                    return update > 0;
+                //a角驳回操作，更新a角数据及b角数据及返回上一流程
+                if (StatusCode.SP_REJECT.equals(status)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setUserId(currentUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REJECT);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "a角用户驳回担保函更新成功" : "a角用户驳回担保函更新失败");
+                    //更新成功后，更新b角数据及更新法规部经理数据
+                    if (i > 0){
+                        //更新b用户的审核状态为驳回
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
+                        tempB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserB = baseMapper.selectOne(tempB);
+                        dgGuaranteeLetterAssignUserB.setStatus(StatusCode.SP_REJECT);
+                        baseMapper.updateById(dgGuaranteeLetterAssignUserB);
+
+                        //更新法规部经理的审核状态为驳回，操作状态为待处理
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempFG = new QueryWrapper<>();
+                        tempFG.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserFG = baseMapper.selectOne(tempFG);
+                        dgGuaranteeLetterAssignUserFG.setStatus(StatusCode.SP_REJECT);
+                        dgGuaranteeLetterAssignUserFG.setOperatingStatus(StatusCode.CZ_ON_HAND);
+                        int update = baseMapper.updateById(dgGuaranteeLetterAssignUserFG);
+                        //添加成功，返回操作结果
+                        log.info(update > 0 ? "a角驳回更新成功" : "a角驳回更新失败");
+                        return update > 0;
+                    }
                 }
             }
-        }
 
-        //当前用户为b角用户
-        if (currentUser.equals(bUser)){
-            //更新之前,获取此用户数据的审批状态，如果审批状态为驳回，则更新资产部经理数据，如果审批状态为审批中，则添加资产部经理数据
-            QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
-            queryWrapperTemp.eq("business_id",businessId).eq("user_id",bUser);
-            DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
-            Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
-
-            //首次b角用户确认担保函，检查a角用户是否确认担保函
-            if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",bUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-                //获取公司id
-                Integer companyId = guaranteeLetterAssignUser.getCompanyId();
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "首次b角用户确认担保函更新成功" : "首次b角用户确认担保函更新失败");
-                //更新成功后，判断a角用户是否确认
-                if (i > 0){
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
-                    //查询a用户的审核状态
-                    tempB.eq("business_id",businessId).eq("user_id",aUser).select("status");
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
-                    Integer aStatus = dgGuaranteeLetterAssignUser.getStatus();
-                    //a用户审核通过，添加资产部经理数据
-                    if (StatusCode.SP_REVIEWED.equals(aStatus)){
-                        DgGuaranteeLetterAssignUser ZCJLGuaranteeLetterAssign = new DgGuaranteeLetterAssignUser();
-                        ZCJLGuaranteeLetterAssign.setBusinessId(businessId);
-                        ZCJLGuaranteeLetterAssign.setCompanyId(companyId);
-                        ZCJLGuaranteeLetterAssign.setRoleId(PromptSuccess.ZC_JL_ID);
-                        int insert = baseMapper.insert(ZCJLGuaranteeLetterAssign);
-                        //添加成功，返回操作结果
-                        log.info(insert > 0 ? "资产部经理添加成功" : "资产部经理添加失败");
-                        return insert > 0;
+
+            //角色为b角确认担保函操作和驳回操作
+            if (roleIdList.contains(PromptSuccess.DB_B_ID)){
+                //更新之前,获取此用户数据的审批状态，如果审批状态为驳回，则更新资产部经理数据，如果审批状态为审批中，则添加资产部经理数据
+                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperTemp = new QueryWrapper<>();
+                queryWrapperTemp.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
+                DgGuaranteeLetterAssignUser guaranteeLetterAssignUserTemp = baseMapper.selectOne(queryWrapperTemp);
+                Integer approveStatus = guaranteeLetterAssignUserTemp.getStatus();
+
+                //首次b角用户确认担保函，检查a角用户是否确认担保函
+                if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_IN_REVIEW.equals(approveStatus)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setUserId(currentUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+                    //获取公司id
+                    Integer companyId = guaranteeLetterAssignUser.getCompanyId();
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "首次b角用户确认担保函更新成功" : "首次b角用户确认担保函更新失败");
+                    //更新成功后，判断a角用户是否确认
+                    if (i > 0){
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
+                        //查询a用户的审核状态
+                        tempB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID).select("status");
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
+                        Integer aStatus = dgGuaranteeLetterAssignUser.getStatus();
+                        //a用户审核通过，添加资产部经理数据
+                        if (StatusCode.SP_REVIEWED.equals(aStatus)){
+                            DgGuaranteeLetterAssignUser ZCJLGuaranteeLetterAssign = new DgGuaranteeLetterAssignUser();
+                            ZCJLGuaranteeLetterAssign.setBusinessId(businessId);
+                            ZCJLGuaranteeLetterAssign.setCompanyId(companyId);
+                            ZCJLGuaranteeLetterAssign.setRoleId(PromptSuccess.ZC_JL_ID);
+                            int insert = baseMapper.insert(ZCJLGuaranteeLetterAssign);
+                            //添加成功，返回操作结果
+                            log.info(insert > 0 ? "资产部经理添加成功" : "资产部经理添加失败");
+                            return insert > 0;
+                        }
                     }
                 }
-            }
 
-            //驳回后b角用户再次确认担保函，检查a角用户是否确认担保函
-            if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",bUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "驳回后b角用户确认担保函更新成功" : "驳回后b角用户确认担保函更新失败");
-                //更新成功后，判断a角用户是否确认
-                if (i > 0){
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
-                    //查询a用户的审核状态
-                    tempB.eq("business_id",businessId).eq("user_id",aUser).select("status");
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
-                    Integer aStatus = dgGuaranteeLetterAssignUser.getStatus();
-                    //a用户审核通过，更新资产部经理数据
-                    if (StatusCode.SP_REVIEWED.equals(aStatus)){
-                        QueryWrapper<DgGuaranteeLetterAssignUser> queryZCJLUser = new QueryWrapper<>();
-                        queryZCJLUser.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
-                        DgGuaranteeLetterAssignUser letterAssignUserZCJL = baseMapper.selectOne(queryZCJLUser);
-                        //清空审批意见
-                        letterAssignUserZCJL.setAuditOpinion("");
-                        letterAssignUserZCJL.setStatus(StatusCode.SP_IN_REVIEW);
-                        letterAssignUserZCJL.setStatus(StatusCode.CZ_ON_HAND);
-                        int update = baseMapper.updateById(letterAssignUserZCJL);
-                        //更新成功，返回操作结果
-                        log.info(update > 0 ? "资产部经理更新成功" : "资产部经理更新失败");
-                        return update > 0;
+                //驳回后b角用户再次确认担保函，检查a角用户是否确认担保函
+                if (StatusCode.SP_REVIEWED.equals(status) && StatusCode.SP_REJECT.equals(approveStatus)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REVIEWED);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "驳回后b角用户确认担保函更新成功" : "驳回后b角用户确认担保函更新失败");
+                    //更新成功后，判断a角用户是否确认
+                    if (i > 0){
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempB = new QueryWrapper<>();
+                        //查询a用户的审核状态
+                        tempB.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID).select("status");
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUser = baseMapper.selectOne(tempB);
+                        Integer aStatus = dgGuaranteeLetterAssignUser.getStatus();
+                        //a用户审核通过，更新资产部经理数据
+                        if (StatusCode.SP_REVIEWED.equals(aStatus)){
+                            QueryWrapper<DgGuaranteeLetterAssignUser> queryZCJLUser = new QueryWrapper<>();
+                            queryZCJLUser.eq("business_id",businessId).eq("role_id",PromptSuccess.ZC_JL_ID);
+                            DgGuaranteeLetterAssignUser letterAssignUserZCJL = baseMapper.selectOne(queryZCJLUser);
+                            //清空审批意见
+                            letterAssignUserZCJL.setAuditOpinion("");
+                            letterAssignUserZCJL.setStatus(StatusCode.SP_IN_REVIEW);
+                            letterAssignUserZCJL.setStatus(StatusCode.CZ_ON_HAND);
+                            int update = baseMapper.updateById(letterAssignUserZCJL);
+                            //更新成功，返回操作结果
+                            log.info(update > 0 ? "资产部经理更新成功" : "资产部经理更新失败");
+                            return update > 0;
+                        }
                     }
                 }
-            }
 
-            //b角驳回操作，更新b角数据及a角数据及返回上一流程
-            if (StatusCode.SP_REJECT.equals(status)){
-                QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
-                queryWrapperUser.eq("business_id",businessId).eq("user_id",bUser);
-                DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
-                guaranteeLetterAssignUser.setStatus(StatusCode.SP_REJECT);
-                guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
-                guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
-                //根据当前用户更新审核状态和操作状态及审核意见
-                int i = baseMapper.updateById(guaranteeLetterAssignUser);
-                log.info(i > 0 ? "b角用户驳回担保函更新成功" : "b角用户驳回担保函更新失败");
-                //更新成功后，更新a角数据及更新法规部经理数据
-                if (i > 0){
-                    //更新a用户的审核状态为驳回
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempA = new QueryWrapper<>();
-                    tempA.eq("business_id",businessId).eq("user_id",aUser);
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserA = baseMapper.selectOne(tempA);
-                    dgGuaranteeLetterAssignUserA.setStatus(StatusCode.SP_REJECT);
-                    baseMapper.updateById(dgGuaranteeLetterAssignUserA);
-
-                    //更新法规部经理的审核状态为驳回，操作状态为待处理
-                    QueryWrapper<DgGuaranteeLetterAssignUser> tempFG = new QueryWrapper<>();
-                    tempFG.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
-                    DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserFG = baseMapper.selectOne(tempFG);
-                    dgGuaranteeLetterAssignUserFG.setStatus(StatusCode.SP_REJECT);
-                    dgGuaranteeLetterAssignUserFG.setOperatingStatus(StatusCode.CZ_ON_HAND);
-                    int update = baseMapper.updateById(dgGuaranteeLetterAssignUserFG);
-                    //添加成功，返回操作结果
-                    log.info(update > 0 ? "b角驳回更新成功" : "b角驳回更新失败");
-                    return update > 0;
+                //b角驳回操作，更新b角数据及a角数据及返回上一流程
+                if (StatusCode.SP_REJECT.equals(status)){
+                    QueryWrapper<DgGuaranteeLetterAssignUser> queryWrapperUser = new QueryWrapper<>();
+                    queryWrapperUser.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_B_ID);
+                    DgGuaranteeLetterAssignUser guaranteeLetterAssignUser = baseMapper.selectOne(queryWrapperUser);
+                    guaranteeLetterAssignUser.setUserId(currentUser);
+                    guaranteeLetterAssignUser.setStatus(StatusCode.SP_REJECT);
+                    guaranteeLetterAssignUser.setOperatingStatus(StatusCode.CZ_PROCESSED);
+                    guaranteeLetterAssignUser.setAuditOpinion(auditOpinion);
+                    //根据当前用户更新审核状态和操作状态及审核意见
+                    int i = baseMapper.updateById(guaranteeLetterAssignUser);
+                    log.info(i > 0 ? "b角用户驳回担保函更新成功" : "b角用户驳回担保函更新失败");
+                    //更新成功后，更新a角数据及更新法规部经理数据
+                    if (i > 0){
+                        //更新a用户的审核状态为驳回
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempA = new QueryWrapper<>();
+                        tempA.eq("business_id",businessId).eq("role_id",PromptSuccess.DB_A_ID);
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserA = baseMapper.selectOne(tempA);
+                        dgGuaranteeLetterAssignUserA.setStatus(StatusCode.SP_REJECT);
+                        baseMapper.updateById(dgGuaranteeLetterAssignUserA);
+
+                        //更新法规部经理的审核状态为驳回，操作状态为待处理
+                        QueryWrapper<DgGuaranteeLetterAssignUser> tempFG = new QueryWrapper<>();
+                        tempFG.eq("business_id",businessId).eq("role_id",PromptSuccess.FG_JL_ID);
+                        DgGuaranteeLetterAssignUser dgGuaranteeLetterAssignUserFG = baseMapper.selectOne(tempFG);
+                        dgGuaranteeLetterAssignUserFG.setStatus(StatusCode.SP_REJECT);
+                        dgGuaranteeLetterAssignUserFG.setOperatingStatus(StatusCode.CZ_ON_HAND);
+                        int update = baseMapper.updateById(dgGuaranteeLetterAssignUserFG);
+                        //添加成功，返回操作结果
+                        log.info(update > 0 ? "b角驳回更新成功" : "b角驳回更新失败");
+                        return update > 0;
+                    }
                 }
             }
         }
+
         //一个判断都不走，直接返回false
         log.info("《《《《《数据更新失败，请确保数据完整》》》》》");
         return false;

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/DgPaymentConfirmationConsiderServiceImpl.java

@@ -8,6 +8,7 @@ import com.daqing.financial.guarantee.mapper.DgLoanNoticeMapper;
 import com.daqing.financial.guarantee.mapper.DgPaymentConfirmationConsiderMapper;
 import com.daqing.financial.guarantee.model.request.PaymentConfirmationQueryRequest;
 import com.daqing.financial.guarantee.model.request.PaymentConfirmationUpdateRequest;
+import com.daqing.financial.guarantee.model.response.GuaranteeLetterListResponse;
 import com.daqing.financial.guarantee.model.response.PaymentConfirmationListResponse;
 import com.daqing.financial.guarantee.service.IDgPaymentConfirmationConsiderService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -16,10 +17,17 @@ import com.daqing.framework.domain.guarantee.DgLoanNotice;
 import com.daqing.framework.domain.guarantee.DgPaymentConfirmationConsider;
 import com.daqing.framework.model.StatusCode;
 import com.daqing.framework.model.response.PromptSuccess;
+import com.daqing.framework.util.RedisUtil;
 import com.daqing.framework.utils.PageUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Arrays;
+import java.util.List;
 
 /**
  * <p>
@@ -39,17 +47,35 @@ public class DgPaymentConfirmationConsiderServiceImpl extends ServiceImpl<DgPaym
     @Autowired
     private DgGuaranteeLetterAssignUserMapper guaranteeLetterAssignUserMapper;
 
+    /**
+     * 获取当前登录用户信息
+     */
+    private String getUserId(){
+        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        String token = request.getHeader("token");
+        return RedisUtil.get("dq:token:"+token);
+    }
+
     @Override
     public PageUtils queryPage(PaymentConfirmationQueryRequest paymentConfirmationQueryRequest) {
         //取出条件
         Integer page = paymentConfirmationQueryRequest.getPage();
         Integer size = paymentConfirmationQueryRequest.getSize();
         Integer status = paymentConfirmationQueryRequest.getStatus();
-        //a根据角色id查询
-        Integer roleId = paymentConfirmationQueryRequest.getRoleId();
         String customerNumberOrName = paymentConfirmationQueryRequest.getCustomerNumberOrName();
-        //分页条件查询
-        IPage<PaymentConfirmationListResponse> paymentConfirmationVO = baseMapper.pageByCondition(new Page(page,size),roleId,status,customerNumberOrName);
+
+        //获取当前登录用户id
+        Integer userId = Integer.parseInt(this.getUserId());
+
+        //获取当前用户拥有的角色ids
+        String roleIds = RedisUtil.get("dq:userRole:" + userId);
+        IPage<PaymentConfirmationListResponse> paymentConfirmationVO = null;
+        if(roleIds != null) {
+            String[] ids = roleIds.split(",");
+            List<String> roleIdList = Arrays.asList(ids);
+            //分页条件查询
+            paymentConfirmationVO = baseMapper.pageByCondition(new Page(page,size),roleIdList,status,customerNumberOrName);
+        }
 
         return new PageUtils(paymentConfirmationVO);
     }

dq-financial-guarantee/src/main/resources/mapper/guarantee/DgGuaranteeLetterAssignUserMapper.xml

@@ -41,11 +41,12 @@
         left join dg_loan_committee_consider lcc on lau.business_id = lcc.business_id
         left join dg_business_process_status bps on lau.business_id = bps.business_id
         <where>
-            <if test="roleId != null and roleId != ''">
-                AND lau.role_id = #{roleId}
-            </if>
+            lau.role_id in
+            <foreach collection="roleIdList" open="(" separator="," close=")" item="id">
+                #{id}
+            </foreach>
             <if test="userId != null and userId != ''">
-                and lau.user_id = #{userId}
+                AND (lau.user_id = #{userId} or lau.user_id is null)
             </if>
             <if test="customerNumberOrName != null and customerNumberOrName != ''">
                 AND aai.business_code LIKE CONCAT('%',#{customerNumberOrName},'%') OR cc.name LIKE CONCAT('%',#{customerNumberOrName},'%')

dq-financial-guarantee/src/main/resources/mapper/guarantee/DgPaymentConfirmationConsiderMapper.xml

@@ -42,7 +42,13 @@
         left join dg_loan_committee_consider lcc on pcc.business_id = lcc.business_id
         left join dg_business_process_status bps on pcc.business_id = bps.business_id
         <where>
-            AND pcc.role_id = #{roleId}
+            pcc.role_id in
+            <foreach collection="roleIdList" open="(" separator="," close=")" item="id">
+                #{id}
+            </foreach>
+            <if test="userId != null and userId != ''">
+                AND (pcc.user_id = #{userId} or pcc.user_id is null)
+            </if>
             <if test="customerNumberOrName != null and customerNumberOrName != ''">
                 AND aai.business_code LIKE CONCAT('%',#{customerNumberOrName},'%') OR cc.name LIKE CONCAT('%',#{customerNumberOrName},'%')
             </if>