合规调查、工作会、贷审会

dq-financial-api/src/main/java/com/daqing/financial/hrms/EmployeeControllerApi.java

@@ -68,4 +68,7 @@ public interface EmployeeControllerApi {
 
     @ApiOperation(value = "查询所有员工id和姓名",notes = "查询所有员工id和姓名")
     ResponseResult listEmployeeName();
+
+    @ApiOperation(value = "给用户赋予一个角色",notes = "给用户赋予一个角色")
+    ResponseResult saveUserRole(Long userId,Long roleId);
 }

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

@@ -2,7 +2,6 @@ package com.daqing.financial.guarantee.controller;
 
 
 import com.daqing.financial.guarantee.service.IDgAuditProcessService;
-import com.daqing.framework.domain.guarantee.DgAuditProcess;
 import com.daqing.framework.model.response.ResponseResult;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -14,7 +13,6 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.List;
 
 /**
  * <p>

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

@@ -4,12 +4,17 @@ package com.daqing.financial.guarantee.controller;
 import com.daqing.financial.guarantee.model.request.DgComplianceInvestigationRequest;
 import com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse;
 import com.daqing.financial.guarantee.service.IDgComplianceInvestigationService;
+import com.daqing.framework.domain.guarantee.DgComplianceInvestigation;
 import com.daqing.framework.model.response.ResponseResult;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
 /**
  * <p>
  * 合规调查 前端控制器
@@ -20,7 +25,7 @@ import org.springframework.web.bind.annotation.*;
  */
 @RestController
 @RequestMapping("/compliance/investigation")
-@Api(value = "合规调查",tags = "合规调查")
+@Api(value = "合规调查", tags = "合规调查")
 public class DgComplianceInvestigationController {
 
     @Autowired
@@ -30,20 +35,61 @@ public class DgComplianceInvestigationController {
      * 列表
      */
     @GetMapping("/list")
-    @ApiOperation(value = "合规调查列表",notes = "合规调查列表",response = DgComplianceInvestigationResponse.class)
+    @ApiOperation(value = "列表", notes = "列表", response = DgComplianceInvestigationResponse.class)
     public ResponseResult list(@RequestParam("page") Integer page,
                                @RequestParam("size") Integer size, DgComplianceInvestigationRequest dgComplianceInvestigationRequest) {
-        return ResponseResult.SUCCESS(iDgComplianceInvestigationService.list(page,size,dgComplianceInvestigationRequest));
+        return ResponseResult.SUCCESS(iDgComplianceInvestigationService.list(page, size, dgComplianceInvestigationRequest));
+    }
+
+    /**
+     * 指派
+     */
+    @GetMapping("/assign")
+    @ApiOperation(value = "指派", notes = "指派")
+    public ResponseResult assign(@RequestParam("iid") Integer iid, @RequestParam("userId") Integer userId) {
+        Boolean result = iDgComplianceInvestigationService.assign(iid, userId);
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
     }
 
     /**
-     * 调查同意
+     * 调查
      */
     @PostMapping("/survey")
-    @ApiOperation(value = "调查",notes = "调查")
+    @ApiOperation(value = "调查", notes = "调查")
-    public ResponseResult survey(@RequestParam("iid") Integer iid,@RequestParam("status") Integer status,
+    public ResponseResult survey(@RequestParam("iid") Integer iid, @RequestParam("status") Integer status,
-                                 @RequestParam("fileUrl") String fileUrl, @RequestParam("auditOpinion") String auditOpinion) {
+                                 @RequestParam("fileUrl") String fileUrl, @RequestParam("opinion") String opinion) {
-        Boolean result = iDgComplianceInvestigationService.survey(iid, fileUrl, auditOpinion,status);
+        Boolean result = iDgComplianceInvestigationService.survey(iid, fileUrl, opinion, status);
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
+    }
+
+    /**
+     * 审核
+     */
+    @ApiOperation(value = "审核", notes = "审核")
+    @PostMapping("/check")
+    public ResponseResult check(@RequestParam("iid") Integer iid, @RequestParam("opinion") String opinion,
+                                @RequestParam("status") Integer status) {
+        Boolean result = iDgComplianceInvestigationService.check(iid, opinion, status);
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
+    }
+
+    /**
+     * 查看
+     */
+    @GetMapping("/query")
+    @ApiOperation(value = "查看", notes = "查看", response = DgComplianceInvestigation.class)
+    public ResponseResult query(@RequestParam("iid") Integer iid) {
+
+        return ResponseResult.SUCCESS(iDgComplianceInvestigationService.query(iid));
+    }
+
+    /**
+     * 导出
+     */
+    @GetMapping("/excelExport")
+    @ApiOperation(value = "导出", notes = "导出")
+    public ResponseResult query(HttpServletResponse response, @RequestParam("ids") List<String> ids){
+        Boolean result = iDgComplianceInvestigationService.excelExport(response, ids);
         return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
     }
 }

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

@@ -1,9 +1,19 @@
 package com.daqing.financial.guarantee.controller;
 
 
-import org.springframework.web.bind.annotation.RequestMapping;
+import com.daqing.financial.guarantee.model.request.DgLoanCommitteeConsiderRequest;
+import com.daqing.financial.guarantee.model.response.DgLoanCommitteeConsiderResponse;
+import com.daqing.financial.guarantee.service.IDgLoanCommitteeConsiderService;
+import com.daqing.financial.guarantee.service.IDgLoanNoticeService;
+import com.daqing.framework.model.response.ResponseResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiModelProperty;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 
-import org.springframework.web.bind.annotation.RestController;
+import javax.validation.Valid;
+import java.util.List;
 
 /**
  * <p>
@@ -14,7 +24,48 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2020-11-05
  */
 @RestController
-@RequestMapping("/dg-loan-committee-consider")
+@RequestMapping("/committee/consider")
+@Api(value = "贷审会", tags = "贷审会")
 public class DgLoanCommitteeConsiderController {
 
+    @Autowired
+    private IDgLoanCommitteeConsiderService dgLoanCommitteeConsiderService;
+
+    /**
+     * 列表
+     */
+    @GetMapping("/list")
+    @ApiOperation(value = "列表", notes = "列表", response = DgLoanCommitteeConsiderResponse.class)
+    public ResponseResult list(@RequestParam("page") Integer page,
+                               @RequestParam("size") Integer size, String codeOrName) {
+        return ResponseResult.SUCCESS(dgLoanCommitteeConsiderService.list(page, size, codeOrName));
+    }
+
+    /**
+     * 审议
+     */
+    @PostMapping("/check")
+    @ApiOperation(value = "审议", notes = "审议")
+    public ResponseResult check(@RequestBody @Valid DgLoanCommitteeConsiderRequest dgLoanCommitteeConsiderRequest) {
+        Boolean result = dgLoanCommitteeConsiderService.check(dgLoanCommitteeConsiderRequest);
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
+    }
+
+    /**
+     * 获取抽取的评委
+     */
+    @GetMapping("/theJudgesDrawn")
+    @ApiOperation(value = "获取抽取的评委", notes = "获取抽取的评委")
+    public ResponseResult theJudgesDrawn(@RequestParam("id") Integer id) {
+        return ResponseResult.SUCCESS(dgLoanCommitteeConsiderService.getJudges(id));
+    }
+
+    /**
+     * 查看
+     */
+    @GetMapping("/query")
+    @ApiModelProperty(value = "查看",notes = "查看")
+    public ResponseResult query(@RequestParam("id") Integer id) {
+        return ResponseResult.SUCCESS(dgLoanCommitteeConsiderService.query(id));
+    }
 }

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

@@ -1,9 +1,16 @@
 package com.daqing.financial.guarantee.controller;
 
 
-import org.springframework.web.bind.annotation.RequestMapping;
+import com.daqing.financial.guarantee.model.request.DgWorkConferenceConsiderRequest;
+import com.daqing.financial.guarantee.service.IDgWorkConferenceConsiderService;
+import com.daqing.framework.model.response.ResponseResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiModelProperty;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 
-import org.springframework.web.bind.annotation.RestController;
+import java.util.List;
 
 /**
  * <p>
@@ -14,7 +21,61 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2020-11-05
  */
 @RestController
-@RequestMapping("/dg-work-conference-consider")
+@RequestMapping("/work/conference")
+@Api(value = "工作会", tags = "工作会")
 public class DgWorkConferenceConsiderController {
 
+    @Autowired
+    private IDgWorkConferenceConsiderService dgWorkConferenceConsiderService;
+
+    /**
+     * 列表
+     */
+    @GetMapping("/list")
+    @ApiOperation(value = "列表", notes = "列表")
+    public ResponseResult list(@RequestParam("page") Integer page,
+                               @RequestParam("size") Integer size, String codeOrName) {
+        return ResponseResult.SUCCESS(dgWorkConferenceConsiderService.list(page, size, codeOrName));
+    }
+
+    /**
+     * 审议
+     */
+    @PostMapping("/check")
+    @ApiOperation(value = "审议", notes = "审议")
+    public ResponseResult check(@RequestBody DgWorkConferenceConsiderRequest dgWorkConferenceConsiderRequest) {
+        Boolean result = dgWorkConferenceConsiderService.check(dgWorkConferenceConsiderRequest.getId(),
+                dgWorkConferenceConsiderRequest.getOpinion(), dgWorkConferenceConsiderRequest.getStatus(),
+                dgWorkConferenceConsiderRequest.getEmpNames());
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
+    }
+
+    /**
+     * 评委抽取
+     */
+    @PostMapping("/theJudgesDrawn")
+    @ApiOperation(value = "评委抽取", notes = "评委抽取")
+    public ResponseResult theJudgesDrawn(@RequestBody DgWorkConferenceConsiderRequest dgWorkConferenceConsiderRequest) {
+        Boolean result = dgWorkConferenceConsiderService.theJudgesDrawn(dgWorkConferenceConsiderRequest.getId(),
+                dgWorkConferenceConsiderRequest.getEmpNames());
+        return result ? ResponseResult.SUCCESS() : ResponseResult.FAIL();
+    }
+
+    /**
+     * 获取所有的审核意见、审核人及时间
+     */
+    @GetMapping("/getAuditOpinion")
+    @ApiOperation(value = "获取所有的审核意见、审核人及时间", notes = "获取所有的审核意见、审核人及时间")
+    public ResponseResult getAuditOpinion(@RequestParam("businessId") Integer businessId) {
+        return ResponseResult.SUCCESS(dgWorkConferenceConsiderService.getAuditOpinion(businessId));
+    }
+
+    /**
+     * 查看
+     */
+    @GetMapping("/query")
+    @ApiOperation(value = "查看", notes = "查看")
+    public ResponseResult query(@RequestParam("id") Integer id) {
+        return ResponseResult.SUCCESS(dgWorkConferenceConsiderService.query(id));
+    }
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/feign/HrmsFeignService.java

@@ -49,6 +49,12 @@ public interface HrmsFeignService {
     @GetMapping("hrms/employee/insertUserRole")
     ResponseResult insertUserRole(@RequestParam("userId") Long userId,@RequestParam("roleId")Long roleId);
 
+    /**
+     * 给用户赋予一个橘色
+     */
+    @GetMapping("hrms/employee/saveUserRole")
+    ResponseResult saveUserRole(@RequestParam("userId") Long userId,@RequestParam("roleId")Long roleId);
+
     @PostMapping("hrms/employee/insertUsrRole")
     ResponseResult insertUsrRole(@RequestBody List<DgGuaranteePO> list);
 }

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

@@ -6,10 +6,12 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.daqing.financial.guarantee.model.request.DgComplianceInvestigationRequest;
 import com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse;
 import com.daqing.framework.domain.guarantee.DgComplianceInvestigation;
+import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.Date;
+import java.util.List;
 
 /**
  * <p>
@@ -23,22 +25,41 @@ import java.util.Date;
 public interface DgComplianceInvestigationMapper extends BaseMapper<DgComplianceInvestigation> {
 
     IPage<DgComplianceInvestigationResponse> list(Page page, @Param("cr") DgComplianceInvestigationRequest dgComplianceInvestigationRequest,
-                                                  @Param("roleId") Integer roleId);
+                                                  @Param("roleIds") List<Integer> roleIds, @Param("userId") Integer userId);
+
+    List<DgComplianceInvestigationResponse> listExcel(@Param("roleIds") List<Integer> roleIds, @Param("userId") Integer userId,
+                                                      @Param("ids") List<Integer> ids);
 
-    IPage<DgComplianceInvestigationResponse> listByUserId(Page page, @Param("cr") DgComplianceInvestigationRequest dgComplianceInvestigationRequest,
+    Boolean survey(@Param("iid") Integer iid, @Param("opinion") String opinion, @Param("date") Date date,
-                                                          @Param("userId") Integer userId,@Param("roleId") Integer roleId);
+                   @Param("userId") Integer userId, @Param("operationStatus") Integer operationStatus,
+                   @Param("auditStatus") Integer auditStatus, @Param("fileUrl") String fileUrl);
 
-    Boolean survey(@Param("iid") Integer iid, @Param("fileUrl") String fileUrl, @Param("surveyOpinion") String surveyOpinion,
+    Boolean uploadAccessory(@Param("businessId") Integer businessId, @Param("fileUrl") String fileUrl);
-                   @Param("date")Date date, @Param("userId") Integer userId, @Param("status") Integer status);
+
+    Boolean updateToAudit(@Param("businessId") Integer businessId, @Param("operationStatus") Integer operationStatus,
+                          @Param("roleId") Integer roleId);
 
     DgComplianceInvestigation getComplianceInvestigation(Integer iid);
 
-    Boolean updateAssign(@Param("iid") Integer iid, @Param("userId") Integer userId);
+    Boolean updateAssign(@Param("iid") Integer iid, @Param("userId") Integer userId,
+                         @Param("auditStatus") Integer auditStatus, @Param("operationStatus") Integer operationStatus);
 
     Boolean assign(@Param("dci") DgComplianceInvestigation dgComplianceInvestigation);
 
-    Boolean insertManager(@Param("dci") DgComplianceInvestigation dgComplianceInvestigation);
+    Boolean check(@Param("iid") Integer iid, @Param("opinion") String opinion,
+                  @Param("date") Date date, @Param("auditStatus") Integer auditStatus,
+                  @Param("operationStatus") Integer operationStatus, @Param("userId") Integer userId);
+
+    Integer getOperationStatusByBusinessId(@Param("businessId") Integer businessId, @Param("roleId") Integer roleId);
+
+    DgComplianceInvestigation queryDgComplianceInvestigation(Integer iid);
+
+    Boolean insertWorkConferenceConsider(@Param("wcc") DgWorkConferenceConsider dgWorkConferenceConsider);
+
+    Boolean updateAuditStatusByBusinessId(@Param("businessId") Integer businessId, @Param("auditStatus") Integer auditStatus);
+
+    Boolean updateOperationStatusById(@Param("id") Integer id, @Param("operationStatus") Integer operationStatus,
+                                      @Param("opinion") String opinion);
 
-    Boolean check(@Param("iid") Integer iid,@Param("auditOpinion") String auditOpinion,
+    Boolean updateBusinessStatusByBusinessId(@Param("businessId") Integer businessId, @Param("businessStatus") Integer businessStatus);
-                  @Param("date") Date date,@Param("status") Integer status);
 }

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

@@ -1,8 +1,18 @@
 package com.daqing.financial.guarantee.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.daqing.financial.guarantee.model.request.DgLoanCommitteeConsiderRequest;
+import com.daqing.financial.guarantee.model.response.AuditOpinionResponse;
+import com.daqing.financial.guarantee.model.response.DgLoanCommitteeConsiderResponse;
 import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
+import com.daqing.framework.domain.guarantee.po.AuditOpinionPO;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
 
 /**
  * <p>
@@ -15,4 +25,27 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface DgLoanCommitteeConsiderMapper extends BaseMapper<DgLoanCommitteeConsider> {
 
+    IPage<DgLoanCommitteeConsiderResponse> list(Page page, @Param("codeOrName") String codeOrName, @Param("roleId") List<Integer> roleId,
+                                                @Param("userId") Integer userId);
+
+    List<DgLoanCommitteeConsiderResponse> excelList(@Param("roleId") List<Integer> roleId, @Param("userId") Integer userId,
+                                                    @Param("ids") List<Integer> ids);
+
+    Boolean check(@Param("lr") DgLoanCommitteeConsiderRequest dgLoanCommitteeConsiderRequest, @Param("userId") Integer userId,
+                  @Param("status") Integer status, @Param("operatingStatus") Integer operatingStatus, @Param("date") Date date);
+
+    Boolean TheJudgesDrawn(@Param("businessId") Integer businessId, @Param("agreePerson") String agreePerson);
+
+    String getJudges(Integer id);
+
+    AuditOpinionPO getAuditOpinion(Integer businessId);
+
+    DgLoanCommitteeConsider query(Integer id);
+
+    DgLoanCommitteeConsider getDgLoanCommitteeConsider(Integer id);
+
+    Boolean updateAuditStatusByBusinessId(@Param("businessId") Integer businessId, @Param("status") Integer status);
+
+    Boolean updateOperationStatusById(@Param("id") Integer id, @Param("operatingStatus") Integer operatingStatus,
+                                      @Param("refuseOpinion") String opinion);
 }

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

@@ -1,8 +1,16 @@
 package com.daqing.financial.guarantee.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
 import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
+import com.daqing.framework.domain.guarantee.po.DgWorkConferencePO;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+import java.util.List;
 
 /**
  * <p>
@@ -15,4 +23,21 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface DgWorkConferenceConsiderMapper extends BaseMapper<DgWorkConferenceConsider> {
 
+    IPage<DgWorkConferencePO> list(Page page, @Param("codeOrName") String codeOrName, @Param("roleIds") List<Integer> roleIds,
+                                   @Param("userId") Integer userId);
+
+    Boolean check(@Param("id") Integer id, @Param("userId") Integer userId, @Param("opinion") String opinion,
+                  @Param("auditStatus") Integer auditStatus, @Param("operationStatus") Integer operationStatus,
+                  @Param("date") Date date, @Param("joinJudge") String joinJudge);
+
+    DgWorkConferenceConsider getWorkConferenceConsider(Integer id);
+
+    Boolean insertLoanCommitteeConsider(@Param("lcc") DgLoanCommitteeConsider dgLoanCommitteeConsider);
+
+    DgWorkConferenceConsider query(Integer id);
+
+    Boolean updateAuditStatusByBusinessId(@Param("businessId") Integer businessId, @Param("auditStatus") Integer auditStatus);
+
+    Boolean updateOperationStatusById(@Param("id") Integer id, @Param("operationStatus") Integer operationStatus,
+                                      @Param("opinion") String opinion);
 }

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

@@ -16,9 +16,9 @@ import java.io.Serializable;
 @ToString
 public class DgComplianceInvestigationRequest implements Serializable {
 
-    @ApiModelProperty("流程状态,0:驳回,1:审批中")
-    private Integer status;
-
     @ApiModelProperty("业务编号或者客户名称")
     private String codeOrName;
+
+    @ApiModelProperty("流程状态")
+    private String status;
 }

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

@@ -0,0 +1,56 @@
+package com.daqing.financial.guarantee.model.request;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 贷审会审议请求参数
+ *
+ * @auther River
+ * @date 2020/11/24 14:27
+ */
+@Data
+@ToString
+public class DgLoanCommitteeConsiderRequest implements Serializable {
+
+    @NotNull(message = "id不能为空")
+    @ApiModelProperty("id")
+    private Integer id;
+
+    @ApiModelProperty("议定事项")
+    private String agreedItems;
+
+    @ApiModelProperty("附加事项")
+    private String additionalItems;
+
+    @ApiModelProperty("贷款金额")
+    private Double loanMoney;
+
+    @ApiModelProperty("贷款期限")
+    private String loanTern;
+
+    @ApiModelProperty("同意")
+    private String agreePerson;
+
+    @ApiModelProperty("不同意")
+    private String disagreePerson;
+
+    @ApiModelProperty("附件")
+    private String fileUrl;
+
+    @ApiModelProperty("操作,1:通过,2:拒绝,3:驳回")
+    private Integer status;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ApiModelProperty("贷审会通过时间")
+    private Date passingTime;
+
+    @ApiModelProperty("拒绝/驳回意见")
+    private String refuseOpinion;
+}

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

@@ -0,0 +1,32 @@
+package com.daqing.financial.guarantee.model.request;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 工作会评委抽取请求参数
+ *
+ * @auther River
+ * @date 2020/11/26 15:16
+ */
+@Data
+@ToString
+public class DgWorkConferenceConsiderRequest implements Serializable {
+
+    @ApiModelProperty("id")
+    private Integer id;
+
+    @ApiModelProperty("审核意见")
+    private String opinion;
+
+    @ApiModelProperty("操作,1:同意,2:拒绝,3:驳回")
+    private Integer status;
+
+    @ApiModelProperty("评委名称")
+    private List<String> empNames;
+
+}

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/response/AuditOpinionResponse.java

@@ -0,0 +1,64 @@
+package com.daqing.financial.guarantee.model.response;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * AB角合规调查等审核意见、审核人、时间
+ *
+ * @auther River
+ * @date 2020/11/25 16:01
+ */
+@Data
+@ToString
+public class AuditOpinionResponse implements Serializable {
+
+    @ApiModelProperty("担保A角调查意见")
+    private String aAuditOpinion;
+
+    @ApiModelProperty("A角姓名")
+    private String aName;
+
+    @ApiModelProperty("A角调查时间")
+    private Date aTime;
+
+    @ApiModelProperty("担保B角调查意见")
+    private String bAuditOpinion;
+
+    @ApiModelProperty("B角姓名")
+    private String bName;
+
+    @ApiModelProperty("B角调查时间")
+    private Date bTime;
+
+    @ApiModelProperty("资产审核意见")
+    private String assetAuditOpinion;
+
+    @ApiModelProperty("资产姓名")
+    private String assetName;
+
+    @ApiModelProperty("资产审核时间")
+    private Date assetTime;
+
+    @ApiModelProperty("信息审核意见")
+    private String messageAuditOpinion;
+
+    @ApiModelProperty("信息姓名")
+    private String messageName;
+
+    @ApiModelProperty("信息审核时间")
+    private Date messageTime;
+
+    @ApiModelProperty("法规审核意见")
+    private String regulationAuditOpinion;
+
+    @ApiModelProperty("法规姓名")
+    private String regulationName;
+
+    @ApiModelProperty("法规审核时间")
+    private Date regulationTime;
+}

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/response/DgComplianceInvestigationResponse.java

@@ -1,9 +1,16 @@
 package com.daqing.financial.guarantee.model.response;
 
+import com.alibaba.excel.annotation.ExcelIgnore;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.metadata.BaseRowModel;
+import com.daqing.framework.utils.excel.ApprovalStatusConverter;
+import com.daqing.framework.utils.excel.BusinessStatusConverter;
+import com.daqing.framework.utils.excel.OperatingStatusConverter;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.ToString;
+import org.springframework.beans.factory.annotation.Autowired;
 
 import java.io.Serializable;
 import java.util.Date;
@@ -16,39 +23,58 @@ import java.util.Date;
  */
 @Data
 @ToString
-public class DgComplianceInvestigationResponse implements Serializable {
+public class DgComplianceInvestigationResponse extends BaseRowModel implements Serializable {
 
-    @ApiModelProperty("id")
+    @ExcelIgnore
-    private Integer id;
+    @ApiModelProperty("合规调查表id")
+    private Integer iId;
 
+    @ExcelProperty(value = "业务编号", index = 0)
     @ApiModelProperty("业务编号")
     private String businessCode;
 
+    @ExcelProperty(value = "客户名称", index = 1)
     @ApiModelProperty("客户名称")
     private String name;
 
+    @ExcelProperty(value = "联系电话", index = 2)
     @ApiModelProperty("联系电话")
     private String phone;
 
+    @ExcelProperty(value = "业务类别", index = 3)
     @ApiModelProperty("业务类别")
     private String businessType;
 
+    @ExcelProperty(value = "金额", index = 4)
     @ApiModelProperty("金额")
     private Double applyAmount;
 
+    @ExcelProperty(value = "期限", index = 5)
     @ApiModelProperty("期限")
     private String applyTime;
 
+    @ExcelProperty(value = "申请日期", index = 6)
     @ApiModelProperty("申请日期")
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
     private Date createTime;
 
-    @ApiModelProperty("状态,0:,1:,2:,3:,4:")
+    @ExcelProperty(value = "操作状态", index = 7, converter = OperatingStatusConverter.class)
-    private Integer status;
+    @ApiModelProperty("操作状态,0:已发起,1:待处理,2:已处理")
+    private Integer operationStatus;
 
-    @ApiModelProperty("合规调查表id")
+    @ExcelProperty(value = "审核状态", index = 8, converter = ApprovalStatusConverter.class)
-    private Integer iId;
+    @ApiModelProperty("审核状态,0:待指派,1:审核中,2:已审核,3:已拒绝,4:已驳回,5:草稿,6:已撤销")
+    private Integer auditStatus;
+
+    @ExcelProperty(value = "业务状态", index = 9, converter = BusinessStatusConverter.class)
+    @ApiModelProperty("业务状态,1->进行中;2->已完成;3->已否决")
+    private Integer businessStatus;
 
+    @ExcelIgnore
     @ApiModelProperty("角色id")
     private Integer roleId;
+
+    @ExcelIgnore
+    @ApiModelProperty("业务id")
+    private Integer businessId;
 }

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/response/DgLoanCommitteeConsiderResponse.java

@@ -0,0 +1,60 @@
+package com.daqing.financial.guarantee.model.response;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 贷审会响应类
+ *
+ * @auther River
+ * @date 2020/11/24 10:22
+ */
+@Data
+@ToString
+public class DgLoanCommitteeConsiderResponse implements Serializable {
+
+    @ApiModelProperty("贷审会表id")
+    private Integer id;
+
+    @ApiModelProperty("业务编号")
+    private String businessCode;
+
+    @ApiModelProperty("客户名称")
+    private String name;
+
+    @ApiModelProperty("联系电话")
+    private String phone;
+
+    @ApiModelProperty("业务类别")
+    private String businessType;
+
+    @ApiModelProperty("金额")
+    private Double applyAmount;
+
+    @ApiModelProperty("期限")
+    private String applyTime;
+
+    @ApiModelProperty("申请日期")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
+    private Date createTime;
+
+    @ApiModelProperty("操作状态,0:已发起,1:待处理,2:已处理")
+    private Integer operatingStatus;
+
+    @ApiModelProperty("审核状态,0:待指派,1:审核中,2:已审核,3:已拒绝,4:已驳回,5:草稿,6:已撤销")
+    private Integer status;
+
+    @ApiModelProperty("业务状态,1->进行中;2->已完成;3->已否决")
+    private Integer businessStatus;
+
+    @ApiModelProperty("角色id")
+    private Integer roleId;
+
+    @ApiModelProperty("业务id")
+    private Integer businessId;
+}

dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/model/response/DgWorkConferenceResponse.java

@@ -0,0 +1,75 @@
+package com.daqing.financial.guarantee.model.response;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 工作会列表响应类
+ *
+ * @auther River
+ * @date 2020/11/23 14:50
+ */
+@ToString
+@Data
+public class DgWorkConferenceResponse implements Serializable {
+
+    @ApiModelProperty("工作会表id")
+    private Integer id;
+
+    @ApiModelProperty("业务编号")
+    private String businessCode;
+
+    @ApiModelProperty("客户名称")
+    private String name;
+
+    @ApiModelProperty("联系电话")
+    private String phone;
+
+    @ApiModelProperty("业务类别")
+    private String businessType;
+
+    @ApiModelProperty("金额")
+    private Double applyAmount;
+
+    @ApiModelProperty("期限")
+    private String applyTime;
+
+    @ApiModelProperty("申请日期")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
+    private Date createTime;
+
+    @ApiModelProperty("A角")
+    private String aRoleName;
+
+    @ApiModelProperty("B角")
+    private String bRoleName;
+
+    @ApiModelProperty("法规监督部")
+    private String regulationName;
+
+    @ApiModelProperty("资产管理部")
+    private String assetName;
+
+    @ApiModelProperty("信息服务部")
+    private String messageName;
+
+    @ApiModelProperty("操作状态,0:已发起,1:待处理,2:已处理")
+    private Integer operationStatus;
+
+    @ApiModelProperty("审核状态,0:待指派,1:审核中,2:已审核,3:已拒绝,4:已驳回,5:草稿,6:已撤销")
+    private Integer auditStatus;
+
+    @ApiModelProperty("业务状态,1->进行中;2->已完成;3->已否决")
+    private Integer businessStatus;
+
+    @ApiModelProperty("角色id")
+    private Integer roleId;
+
+    @ApiModelProperty("业务id")
+    private Integer businessId;
+}

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

@@ -5,6 +5,9 @@ import com.daqing.financial.guarantee.model.request.DgComplianceInvestigationReq
 import com.daqing.framework.domain.guarantee.DgComplianceInvestigation;
 import com.daqing.framework.utils.PageUtils;
 
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
 /**
  * <p>
  * 合规调查 服务类
@@ -19,7 +22,11 @@ public interface IDgComplianceInvestigationService extends IService<DgCompliance
 
     Boolean assign(Integer iid,Integer userId);
 
-    Boolean survey(Integer iid, String fileUrl, String surveyOpinion,Integer status);
+    Boolean survey(Integer iid, String fileUrl, String opinion,Integer status);
+
+    Boolean check(Integer iid,String opinion,Integer status);
+
+    DgComplianceInvestigation query(Integer iid);
 
-    Boolean check(Integer iid,String auditOpinion,Integer status);
+    Boolean excelExport(HttpServletResponse response, List<String> ids);
 }

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

@@ -1,7 +1,11 @@
 package com.daqing.financial.guarantee.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.daqing.financial.guarantee.model.request.DgLoanCommitteeConsiderRequest;
 import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
+import com.daqing.framework.utils.PageUtils;
+
+import java.util.List;
 
 /**
  * <p>
@@ -13,4 +17,11 @@ import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
  */
 public interface IDgLoanCommitteeConsiderService extends IService<DgLoanCommitteeConsider> {
 
+    PageUtils list(Integer page, Integer size, String codeOrName);
+
+    Boolean check(DgLoanCommitteeConsiderRequest dgLoanCommitteeConsiderRequest);
+
+    List<String> getJudges(Integer id);
+
+    DgLoanCommitteeConsider query(Integer id);
 }

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

@@ -1,7 +1,12 @@
 package com.daqing.financial.guarantee.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.daqing.financial.guarantee.model.response.AuditOpinionResponse;
 import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
+import com.daqing.framework.utils.PageUtils;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
 
 /**
  * <p>
@@ -13,4 +18,15 @@ import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
  */
 public interface IDgWorkConferenceConsiderService extends IService<DgWorkConferenceConsider> {
 
+    PageUtils list(Integer page, Integer size, String codeOrName);
+
+    Boolean check(Integer id, String opinion, Integer status, List<String> empNames);
+
+    Boolean theJudgesDrawn(Integer id, List<String> empNames);
+
+    AuditOpinionResponse getAuditOpinion(Integer businessId);
+
+    DgWorkConferenceConsider query(Integer id);
+
+    Boolean excelExport(HttpServletResponse response, List<String> ids);
 }

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

@@ -2,27 +2,37 @@ package com.daqing.financial.guarantee.service.impl;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.daqing.financial.guarantee.feign.HrmsFeignService;
 import com.daqing.financial.guarantee.mapper.DgComplianceInvestigationMapper;
 import com.daqing.financial.guarantee.model.request.DgComplianceInvestigationRequest;
 import com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse;
 import com.daqing.financial.guarantee.service.IDgComplianceInvestigationService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.daqing.financial.guarantee.util.AuditProcessUtil;
+import com.daqing.framework.domain.crms.response.CrmsCode;
 import com.daqing.framework.domain.guarantee.DgComplianceInvestigation;
+import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
 import com.daqing.framework.domain.guarantee.GuaranteeCode;
 import com.daqing.framework.exception.ExceptionCast;
+import com.daqing.framework.model.StatusCode;
 import com.daqing.framework.model.response.CommonCode;
 import com.daqing.framework.model.response.PromptSuccess;
+import com.daqing.framework.model.response.ResponseResult;
 import com.daqing.framework.util.RedisUtil;
 import com.daqing.framework.utils.PageUtils;
+import com.daqing.framework.utils.excel.ExcelUtil;
+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 javax.servlet.http.HttpServletResponse;
+import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * <p>
@@ -36,38 +46,33 @@ import java.util.List;
 public class DgComplianceInvestigationServiceImpl extends ServiceImpl<DgComplianceInvestigationMapper, DgComplianceInvestigation>
         implements IDgComplianceInvestigationService {
 
+    @Autowired
+    private HrmsFeignService hrmsFeignService;
+
     /**
      * 列表
      */
     @Override
     public PageUtils list(Integer page, Integer size, DgComplianceInvestigationRequest dgComplianceInvestigationRequest) {
-        if (page == null || size == null){
+        if (page == null || size == null) {
             page = 1;
             size = 10;
         }
-        String userId = this.getUserId();
+        /*String userId = this.getUserId();
         // 获取当前登录用户的角色id
         String roleIdString = RedisUtil.get("dq:userRole:" + userId);
-        if (roleIdString == null || roleIdString.length() == 0){
+        if (roleIdString == null || roleIdString.length() == 0) {
             ExceptionCast.cast(GuaranteeCode.ROLE_IS_NOT);
         }
-        String[] roleIds = roleIdString.split(",");
+        String[] roleIds = roleIdString.split(",");*/
-        IPage<DgComplianceInvestigationResponse> list = new Page<>();
+        String userId = "1";
+        String[] roleIds = {"70"};
+        List<Integer> roleList = new ArrayList<>();
         for (String roleId : roleIds) {
-            if (Integer.parseInt(roleId) == PromptSuccess.FG_JL_ID || Integer.parseInt(roleId) == PromptSuccess.FG_LD_ID){
+            roleList.add(Integer.parseInt(roleId));
-                // 当前角色都能看到的数据
-                list = this.getBaseMapper().list(new Page(page, size), dgComplianceInvestigationRequest, Integer.parseInt(roleId));
-                // 当前角色和用户同时满足才能看到的数据
-                IPage<DgComplianceInvestigationResponse> listByUserId = this.getBaseMapper().listByUserId(new Page(page, size), dgComplianceInvestigationRequest, Integer.parseInt(userId), Integer.parseInt(roleId));
-                list.getRecords().addAll(listByUserId.getRecords());
-                list.setTotal(list.getRecords().size());
-                list.setSize(list.getTotal() % size == 0 ? list.getTotal() / size : list.getTotal() / size + 1 );
-                break;
-            }else if (Integer.parseInt(roleId) == PromptSuccess.FG_C_ID){
-                list = this.getBaseMapper().listByUserId(new Page(page, size), dgComplianceInvestigationRequest, Integer.parseInt(userId), Integer.parseInt(roleId));
-                break;
-            }
         }
+        IPage<DgComplianceInvestigationResponse> list = this.getBaseMapper().list(new Page(page, size),
+                dgComplianceInvestigationRequest, roleList, Integer.parseInt(userId));
         return new PageUtils(list);
     }
 
@@ -77,17 +82,35 @@ public class DgComplianceInvestigationServiceImpl extends ServiceImpl<DgComplian
     @Transactional
     @Override
     public Boolean assign(Integer iid, Integer userId) {
+        if (iid == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        if (userId == null) {
+            ExceptionCast.cast(GuaranteeCode.COMPLIANCE_USER_NOT_NULL);
+        }
+        // 指派
         DgComplianceInvestigation complianceInvestigation = this.getComplianceInvestigation(iid);
-        complianceInvestigation.setEmpId(userId);
+        complianceInvestigation.setUserId(userId);
+        complianceInvestigation.setRoleId(PromptSuccess.FG_C_ID);
+        complianceInvestigation.setOperationStatus(StatusCode.CZ_ON_HAND);
+        complianceInvestigation.setAuditStatus(StatusCode.SP_IN_REVIEW);
         complianceInvestigation.setCreateTime(new Date());
         complianceInvestigation.setUpdateTime(new Date());
-        complianceInvestigation.setStatus(0);
-        complianceInvestigation.setRoleId(PromptSuccess.FG_C_ID);
         Boolean result = this.getBaseMapper().assign(complianceInvestigation);
-        if (result){
+        if (result) {
-            // 绑定该条数据的指派操作人;在审核进程表中插入一条指派数据;在角色表中插入一条数据,与当前被指派的员工(用户)关联
+            // 绑定该条数据的指派操作人(表示指派完成);
-            String id = this.getUserId();
+            // String id = this.getUserId();
-            this.getBaseMapper().updateAssign(iid, Integer.parseInt(id));
+            String id = "1";
+            Boolean result1 = this.getBaseMapper().updateAssign(iid, Integer.parseInt(id), StatusCode.SP_IN_REVIEW, StatusCode.CZ_PROCESSED);
+            if (result1) {
+                // 在角色表中插入一条数据,与当前被指派的员工(用户)关联
+                ResponseResult responseResult = hrmsFeignService.saveUserRole(userId.longValue(), PromptSuccess.FG_C_ID.longValue());
+                Boolean result2 = (Boolean) responseResult.getData();
+                if (result2) {
+                    // 在审核进程表中插入一条指派成功的数据
+                    return true;
+                }
+            }
         }
         return false;
     }
@@ -95,101 +118,222 @@ public class DgComplianceInvestigationServiceImpl extends ServiceImpl<DgComplian
     /**
      * 调查
      */
+    @Transactional
     @Override
-    public Boolean survey(Integer iid, String fileUrl, String surveyOpinion, Integer status) {
+    public Boolean survey(Integer iid, String fileUrl, String opinion, Integer status) {
-        if (iid == null || status == null){
+        if (iid == null || status == null) {
             ExceptionCast.cast(CommonCode.INVALID_PARAM);
         }
-        String userId = this.getUserId();
+        //String userId = this.getUserId();
+        String userId = "1";
         // 同意
-        if (status == 1){
+        if (status == 1) {
-            if (fileUrl == null || fileUrl.length() == 0){
+            if (fileUrl == null || fileUrl.length() == 0) {
                 ExceptionCast.cast(GuaranteeCode.COMPLIANCE_UPLOAD_NOT_NULL);
             }
-            Boolean result = this.getBaseMapper().survey(iid, fileUrl, surveyOpinion, new Date(), Integer.parseInt(userId), status);
+            // 更新合规调查表调查数据,表示调查完成
-            // 在审核进程中插入一条调查成功数据;在合规调查表中插入一条审核数据
+            Boolean result = this.getBaseMapper().survey(iid, opinion, new Date(), Integer.parseInt(userId),
-            if (result){
+                    StatusCode.CZ_PROCESSED, StatusCode.SP_IN_REVIEW, fileUrl);
-                DgComplianceInvestigation complianceInvestigation = this.getBaseMapper().getComplianceInvestigation(iid);
+            // 上传附件到附件表里
-                complianceInvestigation.setRoleId(PromptSuccess.FG_JL_ID);
+            if (result) {
-                complianceInvestigation.setStatus(0);
+                Boolean result1 = this.getBaseMapper().uploadAccessory(this.getComplianceInvestigation(iid).getBusinessId(), fileUrl);
+                // 更新合规调查表里面的审核数据
+                if (result1) {
+                    Boolean result2 = this.getBaseMapper().updateToAudit(this.getComplianceInvestigation(iid).getBusinessId(),
+                            StatusCode.CZ_ON_HAND, PromptSuccess.FG_JL_ID);
+                    // 在业务流程表中插入一条调查成功的数据
+                    if (result2) {
+                        return true;
+                    }
+                }
+            }
+        }
+        // 驳回
+        if (status == 2) {
+            if (opinion == null || opinion.length() == 0) {
+                ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 审核
+     */
+    @Transactional
+    @Override
+    public Boolean check(Integer iid, String opinion, Integer status) {
+        if (iid == null || status == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        // String userId = this.getUserId();
+        String userId = "1";
+        Integer operationStatus = this.getBaseMapper().getOperationStatusByBusinessId(
+                this.getComplianceInvestigation(iid).getBusinessId(), PromptSuccess.FG_JL_ID);
+        // 待处理,表示业务进行到法规经理审核
+        if (Objects.equals(operationStatus, StatusCode.CZ_ON_HAND)) {
+            // 同意
+            if (status == 1) {
+                Boolean result = this.getBaseMapper().check(iid, opinion, new Date(),
+                        StatusCode.SP_IN_REVIEW, StatusCode.CZ_PROCESSED, Integer.parseInt(userId));
+                if (result) {
+                    // 法规经理完成审核,新增一条法规领导审核数据(借用插入一条调查数据的接口)
+                    DgComplianceInvestigation complianceInvestigation = this.getComplianceInvestigation(iid);
+                    complianceInvestigation.setUserId(null);
+                    complianceInvestigation.setRoleId(PromptSuccess.FG_LD_ID);
+                    complianceInvestigation.setOperationStatus(StatusCode.CZ_ON_HAND);
+                    complianceInvestigation.setAuditStatus(StatusCode.SP_IN_REVIEW);
                     complianceInvestigation.setCreateTime(new Date());
                     complianceInvestigation.setUpdateTime(new Date());
-                complianceInvestigation.setFile(fileUrl);
+                    Boolean result1 = this.getBaseMapper().assign(complianceInvestigation);
-                complianceInvestigation.setSurveyOpinion(surveyOpinion);
+                    if (result1) {
-                return this.getBaseMapper().insertManager(complianceInvestigation);
+                        // 在业务流程表中插入一条法规经理审核成功的数据
+                        return true;
+                    }
                 }
-            return false;
+            }
+            // 驳回
+            if (status == 2) {
+
             }
             // 拒绝
-        if (status == 2){
+            if (status == 3) {
-            if (surveyOpinion == null || surveyOpinion.length() == 0){
+                if (opinion == null || opinion.length() == 0) {
                     ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
                 }
-            Boolean result = this.getBaseMapper().survey(iid, null, surveyOpinion, new Date(), Integer.parseInt(userId), status);
+                // 先改变所有的审核状态为已拒绝
-            if (result){
+                Boolean result = this.getBaseMapper().updateAuditStatusByBusinessId(this.getComplianceInvestigation(iid).getBusinessId(),
-                // 在审核进程表中插入一条拒绝数据,流程结束
+                        StatusCode.SP_REFUSE);
+                if (result) {
+                    // 再改变自己当前的操作状态为已处理
+                    Boolean result1 = this.getBaseMapper().updateOperationStatusById(iid, StatusCode.CZ_PROCESSED, opinion);
+                    if (result1) {
+                        // 最后改变该条贷款信息的业务状态为已否决
+                        Boolean result2 = this.getBaseMapper().updateBusinessStatusByBusinessId(
+                                this.getComplianceInvestigation(iid).getBusinessId(), StatusCode.YW_REJECTED);
+                        if (result2) {
+                            // 在业务流程表中插入一条拒绝数据(记得带上拒绝意见)
+                            return true;
+                        }
+                    }
+                }
+            }
+        }
+        // 已处理,表示业务进行到法规领导审核
+        if (Objects.equals(operationStatus, StatusCode.CZ_PROCESSED)) {
+            // 同意
+            if (status == 1) {
+                Boolean result = this.getBaseMapper().check(iid, opinion, new Date(), StatusCode.SP_REVIEWED,
+                        StatusCode.CZ_PROCESSED, Integer.parseInt(userId));
+                if (result) {
+                    // 在工作会表中插入一条数据;
+                    DgComplianceInvestigation complianceInvestigation = this.getComplianceInvestigation(iid);
+                    DgWorkConferenceConsider workConferenceConsider = new DgWorkConferenceConsider();
+                    workConferenceConsider.setCompanyId(complianceInvestigation.getCompanyId());
+                    workConferenceConsider.setBusinessId(complianceInvestigation.getBusinessId());
+                    workConferenceConsider.setRoleId(PromptSuccess.GZU_ID);
+                    workConferenceConsider.setAuditStatus(StatusCode.SP_IN_REVIEW);
+                    workConferenceConsider.setOperationStatus(StatusCode.CZ_ON_HAND);
+                    workConferenceConsider.setCreateTime(new Date());
+                    workConferenceConsider.setUpdateTime(new Date());
+                    Boolean result1 = this.getBaseMapper().insertWorkConferenceConsider(workConferenceConsider);
+                    if (result1) {
+                        // 在业务流程表中插入一条法规领导审核成功的数据
+                        return true;
+                    }
                 }
-            return false;
             }
             // 驳回
-        if (status == 3){
+            if (status == 2) {
-            if (surveyOpinion == null || surveyOpinion.length() == 0){
+
+            }
+            // 拒绝
+            if (status == 3) {
+                if (opinion == null || opinion.length() == 0) {
                     ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
                 }
-            Boolean result = this.getBaseMapper().survey(iid, null, surveyOpinion, new Date(), Integer.parseInt(userId), status);
+                // 先改变所有的审核状态为已拒绝
-            if (result){
+                Boolean result = this.getBaseMapper().updateAuditStatusByBusinessId(this.getComplianceInvestigation(iid).getBusinessId(),
-                // 在审核进程表中插入一条驳回数据;修改担保部调查表中AB角的数据状态为驳回
+                        StatusCode.SP_REFUSE);
+                if (result) {
+                    // 再改变自己当前的操作状态为已处理
+                    Boolean result1 = this.getBaseMapper().updateOperationStatusById(iid, StatusCode.CZ_PROCESSED, opinion);
+                    if (result1) {
+                        // 最后改变该条贷款信息的业务状态为已否决
+                        Boolean result2 = this.getBaseMapper().updateBusinessStatusByBusinessId(
+                                this.getComplianceInvestigation(iid).getBusinessId(), StatusCode.YW_REJECTED);
+                        if (result2) {
+                            // 在业务流程表中插入一条拒绝数据(记得带上拒绝意见)
+                            return true;
+                        }
+                    }
+                }
             }
-            return false;
         }
         return false;
     }
 
     /**
-     * 审核
+     * 查看
      */
     @Override
-    public Boolean check(Integer iid, String auditOpinion, Integer status) {
+    public DgComplianceInvestigation query(Integer iid) {
-        if (iid == null || status == null){
+        return this.getBaseMapper().queryDgComplianceInvestigation(iid);
-            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+    }
+
+    /**
+     * 导出
+     */
+    @Override
+    public Boolean excelExport(HttpServletResponse response, List<String> ids) {
+        if (ids == null || ids.size() == 0) {
+            ExceptionCast.cast(GuaranteeCode.EXCEL_ID_NOT_NULL);
         }
-        String userId = this.getUserId();
+        /*String userId = this.getUserId();
+        // 获取当前登录用户的角色id
         String roleIdString = RedisUtil.get("dq:userRole:" + userId);
-        if (roleIdString == null || roleIdString.length() == 0){
+        if (roleIdString == null || roleIdString.length() == 0) {
             ExceptionCast.cast(GuaranteeCode.ROLE_IS_NOT);
         }
-        String[] roleIds = roleIdString.split(",");
+        String[] roleIds = roleIdString.split(",");*/
+        String userId = "1";
+        String[] roleIds = {"70"};
+        List<Integer> roleList = new ArrayList<>();
         for (String roleId : roleIds) {
-            if (Integer.parseInt(roleId) == PromptSuccess.FG_JL_ID){
+            roleList.add(Integer.parseInt(roleId));
-                // 法规经理审核
-                if (status == 1){
-                    // 同意
-                    Boolean result = this.getBaseMapper().check(iid, auditOpinion, new Date(), status);
-                    if (result){
-
-                    }
         }
-            }else if (Integer.parseInt(roleId) == PromptSuccess.FG_LD_ID){
+        List<Integer> idList = new ArrayList<>();
-                // 法规领导审核
+        for (String id : ids) {
+            idList.add(Integer.parseInt(id));
         }
+        List<DgComplianceInvestigationResponse> list = this.getBaseMapper().listExcel(roleList, Integer.parseInt(userId), idList);
+        try {
+            ExcelUtil.writeExcelWithSheets(response, list, "合规调查数据一览表", "complianceInvestigation",
+                    new DgComplianceInvestigationResponse());
+        } catch (Exception e) {
+            ExceptionCast.cast(CrmsCode.CUSTOMER_EXPORT_EXSIT);
         }
-        return null;
+        return false;
     }
 
 
     /**
      * 获取当前登录用户信息
      */
-    private String getUserId(){
+    private String getUserId() {
         HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
         String token = request.getHeader("token");
-        return RedisUtil.get("dq:token:"+token);
+        String userId = RedisUtil.get("dq:token:" + token);
+        if (userId == null || userId.length() == 0) {
+            ExceptionCast.cast(CommonCode.GET_LOGIN_USER_FAIL);
+        }
+        return userId;
     }
 
     /**
      * 获取基本信息
      */
-    private DgComplianceInvestigation getComplianceInvestigation(Integer iid){
+    private DgComplianceInvestigation getComplianceInvestigation(Integer iid) {
 
         return this.getBaseMapper().getComplianceInvestigation(iid);
     }

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

@@ -1,10 +1,31 @@
 package com.daqing.financial.guarantee.service.impl;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.daqing.financial.guarantee.mapper.DgComplianceInvestigationMapper;
 import com.daqing.financial.guarantee.mapper.DgLoanCommitteeConsiderMapper;
+import com.daqing.financial.guarantee.model.request.DgLoanCommitteeConsiderRequest;
+import com.daqing.financial.guarantee.model.response.DgLoanCommitteeConsiderResponse;
 import com.daqing.financial.guarantee.service.IDgLoanCommitteeConsiderService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
+import com.daqing.framework.domain.guarantee.GuaranteeCode;
+import com.daqing.framework.exception.ExceptionCast;
+import com.daqing.framework.model.StatusCode;
+import com.daqing.framework.model.response.CommonCode;
+import com.daqing.framework.model.response.PromptSuccess;
+import com.daqing.framework.util.RedisUtil;
+import com.daqing.framework.utils.PageUtils;
+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.ArrayList;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
 
 /**
  * <p>
@@ -15,6 +36,135 @@ import org.springframework.stereotype.Service;
  * @since 2020-11-05
  */
 @Service
-public class DgLoanCommitteeConsiderServiceImpl extends ServiceImpl<DgLoanCommitteeConsiderMapper, DgLoanCommitteeConsider> implements IDgLoanCommitteeConsiderService {
+public class DgLoanCommitteeConsiderServiceImpl extends ServiceImpl<DgLoanCommitteeConsiderMapper, DgLoanCommitteeConsider>
+        implements IDgLoanCommitteeConsiderService {
+
+    @Autowired
+    private DgComplianceInvestigationMapper dgComplianceInvestigationMapper;
+
+    /**
+     * 列表
+     */
+    @Override
+    public PageUtils list(Integer page, Integer size, String codeOrName) {
+        if (page == null || size == null) {
+            page = 1;
+            size = 10;
+        }
+        /*String userId = this.getUserId();
+        // 获取当前登录用户的角色id
+        String roleIdString = RedisUtil.get("dq:userRole:" + userId);
+        if (roleIdString == null || roleIdString.length() == 0) {
+            ExceptionCast.cast(GuaranteeCode.ROLE_IS_NOT);
+        }
+        String[] roleIds = roleIdString.split(",");*/
+        String userId = "1";
+        String[] roleIds = {"72"};
+        List<Integer> roleList = new ArrayList<>();
+        for (String roleId : roleIds) {
+            roleList.add(Integer.parseInt(roleId));
+        }
+        IPage<DgLoanCommitteeConsiderResponse> list = this.getBaseMapper().list(new Page(page, size),
+                codeOrName, roleList, Integer.parseInt(userId));
+        return new PageUtils(list);
+    }
+
+    /**
+     * 审议
+     */
+    @Override
+    public Boolean check(DgLoanCommitteeConsiderRequest dgLoanCommitteeConsiderRequest) {
+        if (dgLoanCommitteeConsiderRequest == null || dgLoanCommitteeConsiderRequest.getId() == null
+                || dgLoanCommitteeConsiderRequest.getStatus() == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        String userId = this.getUserId();
+        // 同意
+        if (dgLoanCommitteeConsiderRequest.getStatus() == 1) {
+            if (dgLoanCommitteeConsiderRequest.getAdditionalItems() == null || dgLoanCommitteeConsiderRequest.getAdditionalItems().length() == 0
+                    || dgLoanCommitteeConsiderRequest.getAgreedItems() == null || dgLoanCommitteeConsiderRequest.getAgreedItems().length() == 0
+                    || dgLoanCommitteeConsiderRequest.getLoanMoney() == null || dgLoanCommitteeConsiderRequest.getLoanTern() == null
+                    || dgLoanCommitteeConsiderRequest.getLoanTern().length() == 0 || dgLoanCommitteeConsiderRequest.getFileUrl() == null
+                    || dgLoanCommitteeConsiderRequest.getFileUrl().length() == 0) {
+                ExceptionCast.cast(GuaranteeCode.LOAN_MESSAGE_NOT_NULL);
+            }
+            Boolean result = this.getBaseMapper().check(dgLoanCommitteeConsiderRequest, Integer.getInteger(userId), StatusCode.SP_REVIEWED, StatusCode.CZ_PROCESSED, new Date());
+            if (result) {
+                // 在业务流程表中插入一条审议成功的数据;在担保函表中插入条数据
+                return true;
+            }
+        }
+        // 拒绝
+        if (dgLoanCommitteeConsiderRequest.getStatus() == 2) {
+            if (dgLoanCommitteeConsiderRequest.getRefuseOpinion() == null
+                    || dgLoanCommitteeConsiderRequest.getRefuseOpinion().length() == 0 ) {
+                ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
+            }
+            // 先改变所有的审核状态为已拒绝
+            Boolean result = this.getBaseMapper().updateAuditStatusByBusinessId(
+                    this.getBaseMapper().getDgLoanCommitteeConsider(dgLoanCommitteeConsiderRequest.getId()).getBusinessId(),
+                    StatusCode.SP_REFUSE);
+            if (result) {
+                // 再改变自己当前的操作状态为已处理
+                Boolean result1 = this.getBaseMapper().updateOperationStatusById(dgLoanCommitteeConsiderRequest.getId(),
+                        StatusCode.CZ_PROCESSED, dgLoanCommitteeConsiderRequest.getRefuseOpinion());
+                if (result1) {
+                    // 最后改变该条贷款信息的业务状态为已否决
+                    Boolean result2 = dgComplianceInvestigationMapper.updateBusinessStatusByBusinessId(
+                            this.getBaseMapper().getDgLoanCommitteeConsider(dgLoanCommitteeConsiderRequest.getId()).getBusinessId(),
+                            StatusCode.YW_REJECTED);
+                    if (result2){
+                        // 在业务流程表中插入一条拒绝数据(记得带上拒绝意见)
+                        return true;
+                    }
+                }
+            }
+        }
+        // 驳回
+        if (dgLoanCommitteeConsiderRequest.getStatus() == 3) {
 
+        }
+        return false;
+    }
+
+    /**
+     * 获取工作会抽取的评委名单
+     */
+    @Override
+    public List<String> getJudges(Integer id) {
+        if (id == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        List<String> list = new ArrayList<>();
+        String judges = this.getBaseMapper().getJudges(id);
+        if (judges != null && judges.length() != 0) {
+            String[] judge = judges.split(",");
+            list.addAll(Arrays.asList(judge));
+        }
+        return list;
+    }
+
+    /**
+     * 查看
+     */
+    @Override
+    public DgLoanCommitteeConsider query(Integer id) {
+        if (id == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        return this.getBaseMapper().query(id);
+    }
+
+    /**
+     * 获取当前登录用户信息
+     */
+    private String getUserId() {
+        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        String token = request.getHeader("token");
+        String userId = RedisUtil.get("dq:token:" + token);
+        if (userId == null || userId.length() == 0) {
+            ExceptionCast.cast(CommonCode.GET_LOGIN_USER_FAIL);
+        }
+        return userId;
+    }
 }

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

@@ -46,41 +46,41 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
      */
     @Override
     public PageUtils list(Integer page, Integer size, DgStatisticsRequest dgStatisticsRequest) {
-        if (page == null || size == null){
+        if (page == null || size == null) {
             page = 1;
             size = 10;
         }
         // 时间筛选(固定时间)
-        if (dgStatisticsRequest.getCreateFixedTime() != null && dgStatisticsRequest.getCreateCustomTime() == null){
+        if (dgStatisticsRequest.getCreateFixedTime() != null && dgStatisticsRequest.getCreateCustomTime() == null) {
             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-            switch (dgStatisticsRequest.getCreateFixedTime()){
+            switch (dgStatisticsRequest.getCreateFixedTime()) {
-                case 0 :
+                case 0:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getDayBegin()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getDayEnd()));// 今天
                     break;
-                case 1 :
+                case 1:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfYesterday()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfYesterDay()));// 昨天
                     break;
-                case 2 :
+                case 2:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfWeek()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfWeek()));// 本周
                     break;
-                case 3 :
+                case 3:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfMonth()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfMonth()));// 本月
                     break;
-                case 4 :
+                case 4:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfYear()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfYear()));// 本年
                     break;
-                default :
+                default:
                     dgStatisticsRequest.setStartTime(null);
                     dgStatisticsRequest.setEndTime(null);
             }
         }
         // 时间筛选(自定义时间)
-        if (dgStatisticsRequest.getCreateCustomTime() != null){
+        if (dgStatisticsRequest.getCreateCustomTime() != null) {
             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getDayStartTime(dgStatisticsRequest.getCreateCustomTime())));
             dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getDayEndTime(dgStatisticsRequest.getCreateCustomTime())));
@@ -88,23 +88,23 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
         // 查询列表
         IPage<DgStatisticsPO> iPage = this.getBaseMapper().list(new Page(page, size), dgStatisticsRequest);
         List<DgStatisticsPO> dgStatisticsPOList = iPage.getRecords();
-        if (dgStatisticsPOList == null){
+        if (dgStatisticsPOList == null) {
             return null;
         }
         // 部门筛选
-        if (dgStatisticsRequest.getDeptId() != null && dgStatisticsRequest.getEmpId() == null){
+        if (dgStatisticsRequest.getDeptId() != null && dgStatisticsRequest.getEmpId() == null) {
             ResponseResult<List<EmployeeVO>> result = hrmsFeignService.listEmployeeByDeptId(dgStatisticsRequest.getDeptId().longValue());
-            if (result.getData() == null || result.getData().size() == 0){
+            if (result.getData() == null || result.getData().size() == 0) {
                 return null;
             }
-            for (int i = 0;i < dgStatisticsPOList.size();i++){
+            for (int i = 0; i < dgStatisticsPOList.size(); i++) {
                 boolean flag = false;
                 for (EmployeeVO employeeVO : result.getData()) {
-                    if (Objects.equals(dgStatisticsPOList.get(i).getPresenterId().longValue(),employeeVO.getId())){
+                    if (Objects.equals(dgStatisticsPOList.get(i).getPresenterId().longValue(), employeeVO.getId())) {
                         flag = true;
                     }
                 }
-                if (!flag){
+                if (!flag) {
                     dgStatisticsPOList.remove(i);
                     i--; // 索引要减一,不然会触发"快速失败"异常
                 }
@@ -113,9 +113,9 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
             iPage.setSize(iPage.getTotal() % size == 0 ? iPage.getTotal() / size : iPage.getTotal() / size + 1);
         }
         // 提单人筛选
-        if (dgStatisticsRequest.getEmpId() != null){
+        if (dgStatisticsRequest.getEmpId() != null) {
-            for (int i = 0;i < dgStatisticsPOList.size();i++){
+            for (int i = 0; i < dgStatisticsPOList.size(); i++) {
-                if (!Objects.equals(dgStatisticsPOList.get(i).getPresenterId(),dgStatisticsRequest.getEmpId())){
+                if (!Objects.equals(dgStatisticsPOList.get(i).getPresenterId(), dgStatisticsRequest.getEmpId())) {
                     dgStatisticsPOList.remove(i);
                     i--;// 索引要减一,不然会触发"快速失败"异常
                 }
@@ -125,23 +125,23 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
         }
         // 获取所有的提单人id
         Integer[] presenterIds = dgStatisticsPOList.stream().map(DgStatisticsPO::getPresenterId).toArray(Integer[]::new);
-        if (presenterIds.length != 0){
+        if (presenterIds.length != 0) {
             // 强制类型转换
             Long[] ids = new Long[presenterIds.length];
-            for (int i = 0;i < presenterIds.length;i++){
+            for (int i = 0; i < presenterIds.length; i++) {
                 ids[i] = presenterIds[i].longValue();
             }
             ResponseResult<List<EmployeeTO>> empAndDeptList = hrmsFeignService.getEmployeeAndDeptById(ids);
-            if (empAndDeptList.getData() != null){
+            if (empAndDeptList.getData() != null) {
                 List<DgStatisticsListResponse> listResponse = this.jointStatistics(dgStatisticsPOList, empAndDeptList.getData());
                 IPage<DgStatisticsListResponse> iPages = new Page<>();
-                BeanUtils.copyProperties(iPage,iPages);
+                BeanUtils.copyProperties(iPage, iPages);
                 iPages.setRecords(listResponse);
                 return new PageUtils(iPages);
-            }else {
+            } else {
                 return new PageUtils(iPage);
             }
-        }else {
+        } else {
             return new PageUtils(iPage);
         }
     }
@@ -154,7 +154,7 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
 
         IPage<DgStatisticsPO> list = this.getBaseMapper().list(new Page(), new DgStatisticsRequest());
         List<DgStatisticsPO> dgStatisticsPOList = list.getRecords();
-        if (dgStatisticsPOList == null){
+        if (dgStatisticsPOList == null) {
             return false;
         }
         Integer[] presenterIds = dgStatisticsPOList.stream().map(DgStatisticsPO::getPresenterId).toArray(Integer[]::new);
@@ -168,13 +168,13 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
             if (empAndDeptList.getData() != null) {
                 List<DgStatisticsListResponse> listResponse = this.jointStatistics(dgStatisticsPOList, empAndDeptList.getData());
                 try {
-                    ExcelUtil.writeExcelWithSheets(response,listResponse,"业务统计信息一览表","statistics",new DgStatisticsListResponse())
+                    ExcelUtil.writeExcelWithSheets(response, listResponse, "业务统计信息一览表", "statistics", new DgStatisticsListResponse())
                             .finish();
-                }catch (Exception e){
+                } catch (Exception e) {
                     ExceptionCast.cast(CrmsCode.CUSTOMER_EXPORT_EXSIT);
                 }
                 return true;
-            }else {
+            } else {
                 return false;
             }
         }
@@ -186,41 +186,41 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
      */
     @Override
     public PageUtils listRefuse(Integer page, Integer size, DgStatisticsRequest dgStatisticsRequest) {
-        if (page == null || size == null){
+        if (page == null || size == null) {
             page = 1;
             size = 10;
         }
         // 时间筛选(固定时间)
-        if (dgStatisticsRequest.getCreateFixedTime() != null && dgStatisticsRequest.getCreateCustomTime() == null){
+        if (dgStatisticsRequest.getCreateFixedTime() != null && dgStatisticsRequest.getCreateCustomTime() == null) {
             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-            switch (dgStatisticsRequest.getCreateFixedTime()){
+            switch (dgStatisticsRequest.getCreateFixedTime()) {
-                case 0 :
+                case 0:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getDayBegin()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getDayEnd()));// 今天
                     break;
-                case 1 :
+                case 1:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfYesterday()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfYesterDay()));// 昨天
                     break;
-                case 2 :
+                case 2:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfWeek()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfWeek()));// 本周
                     break;
-                case 3 :
+                case 3:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfMonth()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfMonth()));// 本月
                     break;
-                case 4 :
+                case 4:
                     dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getBeginDayOfYear()));
                     dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getEndDayOfYear()));// 本年
                     break;
-                default :
+                default:
                     dgStatisticsRequest.setStartTime(null);
                     dgStatisticsRequest.setEndTime(null);
             }
         }
         // 时间筛选(自定义时间)
-        if (dgStatisticsRequest.getCreateCustomTime() != null){
+        if (dgStatisticsRequest.getCreateCustomTime() != null) {
             SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
             dgStatisticsRequest.setStartTime(dateFormat.format(DateUtils.getDayStartTime(dgStatisticsRequest.getCreateCustomTime())));
             dgStatisticsRequest.setEndTime(dateFormat.format(DateUtils.getDayEndTime(dgStatisticsRequest.getCreateCustomTime())));
@@ -229,23 +229,23 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
         dgStatisticsRequest.setStatus(PromptSuccess.STATUS_REFUSE);
         IPage<DgStatisticsRefusePO> iPage = this.getBaseMapper().listRefuse(new Page(page, size), dgStatisticsRequest);
         List<DgStatisticsRefusePO> dgStatisticsRefusePOList = iPage.getRecords();
-        if (dgStatisticsRefusePOList == null){
+        if (dgStatisticsRefusePOList == null) {
             return null;
         }
         // 部门筛选
-        if (dgStatisticsRequest.getDeptId() != null && dgStatisticsRequest.getEmpId() == null){
+        if (dgStatisticsRequest.getDeptId() != null && dgStatisticsRequest.getEmpId() == null) {
             ResponseResult<List<EmployeeVO>> result = hrmsFeignService.listEmployeeByDeptId(dgStatisticsRequest.getDeptId().longValue());
-            if (result.getData() == null || result.getData().size() == 0){
+            if (result.getData() == null || result.getData().size() == 0) {
                 return null;
             }
-            for (int i = 0;i < dgStatisticsRefusePOList.size();i++){
+            for (int i = 0; i < dgStatisticsRefusePOList.size(); i++) {
                 boolean flag = false;
                 for (EmployeeVO employeeVO : result.getData()) {
-                    if (Objects.equals(dgStatisticsRefusePOList.get(i).getPresenterId().longValue(),employeeVO.getId())){
+                    if (Objects.equals(dgStatisticsRefusePOList.get(i).getPresenterId().longValue(), employeeVO.getId())) {
                         flag = true;
                     }
                 }
-                if (!flag){
+                if (!flag) {
                     dgStatisticsRefusePOList.remove(i);
                     i--; // 索引要减一,不然会触发"快速失败"异常
                 }
@@ -254,9 +254,9 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
             iPage.setSize(iPage.getTotal() % size == 0 ? iPage.getTotal() / size : iPage.getTotal() / size + 1);
         }
         // 提单人筛选
-        if (dgStatisticsRequest.getEmpId() != null){
+        if (dgStatisticsRequest.getEmpId() != null) {
-            for (int i = 0;i < dgStatisticsRefusePOList.size();i++){
+            for (int i = 0; i < dgStatisticsRefusePOList.size(); i++) {
-                if (!Objects.equals(dgStatisticsRefusePOList.get(i).getPresenterId(),dgStatisticsRequest.getEmpId())){
+                if (!Objects.equals(dgStatisticsRefusePOList.get(i).getPresenterId(), dgStatisticsRequest.getEmpId())) {
                     dgStatisticsRefusePOList.remove(i);
                     i--;// 索引要减一,不然会触发"快速失败"异常
                 }
@@ -266,23 +266,23 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
         }
         // 获取所有的提单人id
         Integer[] presenterIds = dgStatisticsRefusePOList.stream().map(DgStatisticsRefusePO::getPresenterId).toArray(Integer[]::new);
-        if (presenterIds.length != 0){
+        if (presenterIds.length != 0) {
             // 强制类型转换
             Long[] ids = new Long[presenterIds.length];
-            for (int i = 0;i < presenterIds.length;i++){
+            for (int i = 0; i < presenterIds.length; i++) {
                 ids[i] = presenterIds[i].longValue();
             }
             ResponseResult<List<EmployeeTO>> empAndDeptList = hrmsFeignService.getEmployeeAndDeptById(ids);
-            if (empAndDeptList.getData() != null){
+            if (empAndDeptList.getData() != null) {
                 List<DgStatisticsListRefuseResponse> listResponse = this.jointRefuseStatistics(dgStatisticsRefusePOList, empAndDeptList.getData());
                 IPage<DgStatisticsListRefuseResponse> iPages = new Page<>();
-                BeanUtils.copyProperties(iPage,iPages);
+                BeanUtils.copyProperties(iPage, iPages);
                 iPages.setRecords(listResponse);
                 return new PageUtils(iPages);
-            }else {
+            } else {
                 return new PageUtils(iPage);
             }
-        }else {
+        } else {
             return new PageUtils(iPage);
         }
     }
@@ -297,7 +297,7 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
         // 列表查询
         IPage<DgStatisticsRefusePO> listRefuse = this.getBaseMapper().listRefuse(new Page(), dgStatisticsRequest);
         List<DgStatisticsRefusePO> statisticsRefusePOList = listRefuse.getRecords();
-        if (statisticsRefusePOList == null){
+        if (statisticsRefusePOList == null) {
             return false;
         }
         Integer[] presenterIds = statisticsRefusePOList.stream().map(DgStatisticsRefusePO::getPresenterId).toArray(Integer[]::new);
@@ -312,20 +312,20 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
                 // 提单人姓名、部门拼装
                 List<DgStatisticsListRefuseResponse> listResponse = this.jointRefuseStatistics(statisticsRefusePOList, empAndDeptList.getData());
                 try {
-                    ExcelUtil.writeExcelWithSheets(response,listResponse,"业务统计拒绝信息一览表","statisticsRefuse",new DgStatisticsListRefuseResponse())
+                    ExcelUtil.writeExcelWithSheets(response, listResponse, "业务统计拒绝信息一览表", "statisticsRefuse", new DgStatisticsListRefuseResponse())
                             .finish();
-                }catch (Exception e){
+                } catch (Exception e) {
                     ExceptionCast.cast(CrmsCode.CUSTOMER_EXPORT_EXSIT);
                 }
                 return true;
-            }else {
+            } else {
                 return false;
             }
         }
         return false;
     }
 
-    private List<DgStatisticsListResponse> jointStatistics(List<DgStatisticsPO> dgStatisticsPOList,List<EmployeeTO> empAndDeptList){
+    private List<DgStatisticsListResponse> jointStatistics(List<DgStatisticsPO> dgStatisticsPOList, List<EmployeeTO> empAndDeptList) {
         // 用于拼装业务统计列表
         List<DgStatisticsListResponse> listResponse = new ArrayList<>();
         DgStatisticsListResponse dgStatisticsListResponse;
@@ -333,22 +333,22 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
             // 每一个客户对应一个不同的对象
             dgStatisticsListResponse = new DgStatisticsListResponse();
             for (EmployeeTO employeeTO : empAndDeptList) {
-                if (Objects.equals(dgStatisticsPO.getPresenterId().longValue(),employeeTO.getId())){
+                if (Objects.equals(dgStatisticsPO.getPresenterId().longValue(), employeeTO.getId())) {
-                    BeanUtils.copyProperties(dgStatisticsPO,dgStatisticsListResponse);
+                    BeanUtils.copyProperties(dgStatisticsPO, dgStatisticsListResponse);
                     dgStatisticsListResponse.setEmployeeName(employeeTO.getEmpName());
                     dgStatisticsListResponse.setDepartment(employeeTO.getDeptNames());
                     listResponse.add(dgStatisticsListResponse);
                 }
             }
-            if (dgStatisticsListResponse.getEmployeeName() == null || dgStatisticsListResponse.getEmployeeName().length() == 0){
+            if (dgStatisticsListResponse.getEmployeeName() == null || dgStatisticsListResponse.getEmployeeName().length() == 0) {
-                BeanUtils.copyProperties(dgStatisticsPO,dgStatisticsListResponse);
+                BeanUtils.copyProperties(dgStatisticsPO, dgStatisticsListResponse);
                 listResponse.add(dgStatisticsListResponse);
             }
         }
         return listResponse;
     }
 
-    private List<DgStatisticsListRefuseResponse> jointRefuseStatistics(List<DgStatisticsRefusePO> dgStatisticsRefusePOList, List<EmployeeTO> empAndDeptList){
+    private List<DgStatisticsListRefuseResponse> jointRefuseStatistics(List<DgStatisticsRefusePO> dgStatisticsRefusePOList, List<EmployeeTO> empAndDeptList) {
         // 用于拼装业务统计列表
         List<DgStatisticsListRefuseResponse> listResponse = new ArrayList<>();
         DgStatisticsListRefuseResponse dgStatisticsListRefuseResponse;
@@ -356,15 +356,15 @@ public class DgStatisticsServiceImpl extends ServiceImpl<DgStatisticsMapper, DgA
             // 每一个客户对应一个不同的对象
             dgStatisticsListRefuseResponse = new DgStatisticsListRefuseResponse();
             for (EmployeeTO employeeTO : empAndDeptList) {
-                if (Objects.equals(dgStatisticsRefusePO.getPresenterId().longValue(),employeeTO.getId())){
+                if (Objects.equals(dgStatisticsRefusePO.getPresenterId().longValue(), employeeTO.getId())) {
-                    BeanUtils.copyProperties(dgStatisticsRefusePO,dgStatisticsListRefuseResponse);
+                    BeanUtils.copyProperties(dgStatisticsRefusePO, dgStatisticsListRefuseResponse);
                     dgStatisticsListRefuseResponse.setEmployeeName(employeeTO.getEmpName());
                     dgStatisticsListRefuseResponse.setDepartment(employeeTO.getDeptNames());
                     listResponse.add(dgStatisticsListRefuseResponse);
                 }
             }
-            if (dgStatisticsListRefuseResponse.getEmployeeName() == null || dgStatisticsListRefuseResponse.getEmployeeName().length() == 0){
+            if (dgStatisticsListRefuseResponse.getEmployeeName() == null || dgStatisticsListRefuseResponse.getEmployeeName().length() == 0) {
-                BeanUtils.copyProperties(dgStatisticsRefusePO,dgStatisticsListRefuseResponse);
+                BeanUtils.copyProperties(dgStatisticsRefusePO, dgStatisticsListRefuseResponse);
                 listResponse.add(dgStatisticsListRefuseResponse);
             }
         }

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

@@ -1,10 +1,36 @@
 package com.daqing.financial.guarantee.service.impl;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.daqing.financial.guarantee.mapper.DgComplianceInvestigationMapper;
+import com.daqing.financial.guarantee.mapper.DgLoanCommitteeConsiderMapper;
 import com.daqing.financial.guarantee.mapper.DgWorkConferenceConsiderMapper;
+import com.daqing.financial.guarantee.model.response.AuditOpinionResponse;
 import com.daqing.financial.guarantee.service.IDgWorkConferenceConsiderService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.daqing.framework.domain.guarantee.DgComplianceInvestigation;
+import com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider;
 import com.daqing.framework.domain.guarantee.DgWorkConferenceConsider;
+import com.daqing.framework.domain.guarantee.GuaranteeCode;
+import com.daqing.framework.domain.guarantee.po.AuditOpinionPO;
+import com.daqing.framework.domain.guarantee.po.DgWorkConferencePO;
+import com.daqing.framework.exception.ExceptionCast;
+import com.daqing.framework.model.StatusCode;
+import com.daqing.framework.model.response.CommonCode;
+import com.daqing.framework.model.response.PromptSuccess;
+import com.daqing.framework.util.RedisUtil;
+import com.daqing.framework.utils.PageUtils;
+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 javax.servlet.http.HttpServletResponse;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
 
 /**
  * <p>
@@ -15,6 +41,192 @@ import org.springframework.stereotype.Service;
  * @since 2020-11-05
  */
 @Service
-public class DgWorkConferenceConsiderServiceImpl extends ServiceImpl<DgWorkConferenceConsiderMapper, DgWorkConferenceConsider> implements IDgWorkConferenceConsiderService {
+public class DgWorkConferenceConsiderServiceImpl extends ServiceImpl<DgWorkConferenceConsiderMapper, DgWorkConferenceConsider>
+        implements IDgWorkConferenceConsiderService {
+
+    @Autowired
+    private DgLoanCommitteeConsiderMapper dgLoanCommitteeConsiderMapper;
+
+    @Autowired
+    private DgComplianceInvestigationMapper dgComplianceInvestigationMapper;
+
+    /**
+     * 列表
+     */
+    @Override
+    public PageUtils list(Integer page, Integer size, String codeOrName) {
+        if (page == null || size == null) {
+            page = 1;
+            size = 10;
+        }
+        /*String userId = this.getUserId();
+        // 获取当前登录用户的角色id
+        String roleIdString = RedisUtil.get("dq:userRole:" + userId);
+        if (roleIdString == null || roleIdString.length() == 0) {
+            ExceptionCast.cast(GuaranteeCode.ROLE_IS_NOT);
+        }
+        String[] roleIds = roleIdString.split(",");*/
+        String userId = "1";
+        String[] roleIds = {"71"};
+        List<Integer> roleList = new ArrayList<>();
+        for (String roleId : roleIds) {
+            roleList.add(Integer.parseInt(roleId));
+        }
+        IPage<DgWorkConferencePO> list = this.getBaseMapper().list(new Page(page, size), codeOrName, roleList, Integer.parseInt(userId));
+        return new PageUtils(list);
+    }
+
+    /**
+     * 审议
+     */
+    @Transactional
+    @Override
+    public Boolean check(Integer id, String opinion, Integer status, List<String> empNames) {
+        if (id == null || status == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        // String userId = this.getUserId();
+        String userId = "1";
+        // 同意
+        if (status == 1) {
+            if (empNames == null || empNames.size() == 0) {
+                ExceptionCast.cast(GuaranteeCode.WORK_JUDGE_NOT_NULL);
+            }
+            // 拼接评委名字
+            StringBuilder names = new StringBuilder();
+            for (int i = 0; i < empNames.size(); i++) {
+                if (i == empNames.size() - 1) {
+                    names.append(empNames.get(i));
+                } else {
+                    names.append(empNames.get(i)).append(",");
+                }
+            }
+            Boolean result = this.getBaseMapper().check(id, Integer.parseInt(userId), opinion,
+                    StatusCode.SP_IN_REVIEW, StatusCode.CZ_ON_HAND, new Date(), names.toString());
+            if (result) {
+                // 在业务流程表中插入一条审议通过的数据
+                return true;
+            }
+        }
+        // 拒绝
+        if (status == 2) {
+            if (opinion == null || opinion.length() == 0) {
+                ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
+            }
+            // 先改变所有的审核状态为已拒绝
+            Boolean result = this.getBaseMapper().updateAuditStatusByBusinessId(
+                    this.getBaseMapper().getWorkConferenceConsider(id).getBusinessId(), StatusCode.SP_REFUSE);
+            if (result) {
+                // 再改变自己当前的操作状态为已处理
+                Boolean result1 = this.getBaseMapper().updateOperationStatusById(id, StatusCode.CZ_PROCESSED, opinion);
+                if (result1) {
+                    // 最后改变该条贷款信息的业务状态为已否决
+                    Boolean result2 = dgComplianceInvestigationMapper.updateBusinessStatusByBusinessId(
+                            this.getBaseMapper().getWorkConferenceConsider(id).getBusinessId(), StatusCode.YW_REJECTED);
+                    if (result2) {
+                        // 在业务流程表中插入一条拒绝数据(记得带上拒绝意见)
+                        return true;
+                    }
+                }
+            }
+        }
+        // 驳回
+        if (status == 3) {
+            if (opinion == null || opinion.length() == 0) {
+                ExceptionCast.cast(GuaranteeCode.COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL);
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 评委抽取
+     */
+    @Transactional
+    @Override
+    public Boolean theJudgesDrawn(Integer id, List<String> empNames) {
+        if (id == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        if (empNames == null || empNames.size() == 0) {
+            ExceptionCast.cast(GuaranteeCode.WORK_JUDGE_NOT_NULL);
+        }
+        // 拼接评委名字
+        StringBuilder names = new StringBuilder();
+        for (int i = 0; i < empNames.size(); i++) {
+            if (i == empNames.size() - 1) {
+                names.append(empNames.get(i));
+            } else {
+                names.append(empNames.get(i)).append(",");
+            }
+        }
+        DgWorkConferenceConsider workConferenceConsider = this.getBaseMapper().getWorkConferenceConsider(id);
+        // 新增一条贷审会数据
+        if (workConferenceConsider.getBusinessId() != null) {
+            DgLoanCommitteeConsider loanCommitteeConsider = new DgLoanCommitteeConsider();
+            loanCommitteeConsider.setBusinessId(workConferenceConsider.getBusinessId());
+            loanCommitteeConsider.setCompanyId(workConferenceConsider.getCompanyId());
+            loanCommitteeConsider.setRoleId(PromptSuccess.DSH_ID);
+            loanCommitteeConsider.setStatus(StatusCode.SP_IN_REVIEW);
+            loanCommitteeConsider.setOperatingStatus(StatusCode.CZ_ON_HAND);
+            loanCommitteeConsider.setCreateTime(new Date());
+            loanCommitteeConsider.setUpdateTime(new Date());
+            Boolean result = this.getBaseMapper().insertLoanCommitteeConsider(loanCommitteeConsider);
+            // 保存抽取的评委名单
+            if (result) {
+                Boolean result1 = dgLoanCommitteeConsiderMapper.TheJudgesDrawn(workConferenceConsider.getBusinessId(), names.toString());
+                if (result1) {
+                    // 在业务流程表中插入一条评委抽取成功的数据
+                    return true;
+                }
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 查询AB角、资产部调查、信息部调查、法规部调查的审核意见、审核人姓名及时间
+     */
+    @Override
+    public AuditOpinionResponse getAuditOpinion(Integer businessId) {
+        if (businessId == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        AuditOpinionPO auditOpinion = dgLoanCommitteeConsiderMapper.getAuditOpinion(businessId);
+        // 将对应的用户id转换成姓名返回回去
+        System.out.println(auditOpinion);
+        return null;
+    }
+
+    /**
+     * 查看
+     */
+    @Override
+    public DgWorkConferenceConsider query(Integer id) {
+        if (id == null) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+        }
+        return this.getBaseMapper().query(id);
+    }
+
+    /**
+     * 导出
+     */
+    @Override
+    public Boolean excelExport(HttpServletResponse response, List<String> ids) {
+        return null;
+    }
 
+    /**
+     * 获取当前登录用户信息
+     */
+    private String getUserId() {
+        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        String token = request.getHeader("token");
+        String userId = RedisUtil.get("dq:token:" + token);
+        if (userId == null || userId.length() == 0) {
+            ExceptionCast.cast(CommonCode.GET_LOGIN_USER_FAIL);
+        }
+        return userId;
+    }
 }

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

@@ -2,34 +2,25 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.daqing.financial.guarantee.mapper.DgComplianceInvestigationMapper">
 
-    <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.daqing.framework.domain.guarantee.DgComplianceInvestigation">
-        <id column="id" property="id" />
-        <result column="company_id" property="companyId" />
-        <result column="emp_id" property="empId" />
-        <result column="file" property="file" />
-        <result column="remark" property="remark" />
-        <result column="status" property="status" />
-        <result column="create_time" property="createTime" />
-        <result column="update_time" property="updateTime" />
-    </resultMap>
-
     <select id="list" resultType="com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse">
-        SELECT a.id AS id,a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
+        SELECT a.id AS business_id,a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
-               a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,i.status AS status,
+               a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,i.operation_status AS
-               i.id AS iid,i.role_id AS role_id
+               operation_status,i.audit_status AS audit_status,i.id AS iid,i.role_id AS role_id,b.business_status AS business_status
-        FROM dg_apply_amount_info AS a
+        FROM dg_compliance_investigation AS i
-        LEFT JOIN dg_audit_process AS p
+        LEFT JOIN dg_apply_amount_info AS a
-        ON a.id = p.apply_amount_info_id
+        ON a.id = i.business_id
         LEFT JOIN crms_customer AS c
         ON a.company_id = c.id
-        LEFT JOIN dg_compliance_investigation AS i
+        LEFT JOIN dg_business_process_status AS b
-        ON a.id = i.business_id
+        ON b.business_id = a.id
         WHERE c.del_or_not  = 0
-        AND i.role_id = #{roleId}
+        AND (i.user_id = #{userId} OR i.user_id IS NULL)
-        AND i.user_id = ''
+        AND i.role_id IN
-        <if test="cr.status != null and cr.status != ''">
+        <foreach collection="roleIds" open="(" separator="," close=")" item="roleId">
-            AND i.status = #{cr.status}
+            #{roleId}
+        </foreach>
+        <if test="cr.status != null">
+            AND i.audit_status = #{cr.status}
         </if>
         <if test="cr.codeOrName != null and cr.codeOrName != ''">
             AND (a.business_code LIKE CONCAT('%',#{cr.codeOrName},'%') OR c.name LIKE CONCAT('%',#{cr.codeOrName},'%'))
@@ -37,63 +28,110 @@
         ORDER BY a.create_time DESC
     </select>
 
-    <!-- 法规部经理和法规领导指派或者调查之后的数据 -->
+    <!-- 将要导出的excel数据列表 -->
-    <select id="listByUserId" resultType="com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse">
+    <select id="listExcel" resultType="com.daqing.financial.guarantee.model.response.DgComplianceInvestigationResponse">
-        SELECT a.id AS id,a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
+        SELECT a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
-        a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,i.status AS status,
+               a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,i.operation_status AS
-        i.id AS iid,i.role_id AS role_id
+               operation_status,i.audit_status AS audit_status,b.business_status AS business_status
-        FROM dg_apply_amount_info AS a
+        FROM dg_compliance_investigation AS i
-        LEFT JOIN dg_audit_process AS p
+        LEFT JOIN dg_apply_amount_info AS a
-        ON a.id = p.apply_amount_info_id
+        ON a.id = i.business_id
         LEFT JOIN crms_customer AS c
         ON a.company_id = c.id
-        LEFT JOIN dg_compliance_investigation AS i
+        LEFT JOIN dg_business_process_status AS b
-        ON a.id = i.business_id
+        ON b.business_id = a.id
         WHERE c.del_or_not  = 0
-        AND i.role_id = #{roleId}
+        AND i.role_id IN
-        AND i.user_id = #{userId}
+        <foreach collection="roleIds" open="(" separator="," close=")" item="roleId">
-        <if test="cr.status != null and cr.status != ''">
+            #{roleId}
-            AND i.status = #{cr.status}
+        </foreach>
-        </if>
+        AND (i.user_id = #{userId} OR i.user_id IS NULL)
-        <if test="cr.codeOrName != null and cr.codeOrName != ''">
+        WHERE i.id IN
-            AND (a.business_code LIKE CONCAT('%',#{cr.codeOrName},'%') OR c.name LIKE CONCAT('%',#{cr.codeOrName},'%'))
+        <foreach collection="ids" open="(" separator="," close=")" item="id">
-        </if>
+            #{id}
+        </foreach>
         ORDER BY a.create_time DESC
     </select>
 
     <!-- 调查 -->
     <update id="survey">
         UPDATE dg_compliance_investigation
-        SET user_id = #{userId},file = #{fileUrl},survey_opinion = #{surveyOpinion},status = #{status},update_time = #{date}
+        SET user_id = #{userId},file_url = #{fileUrl},opinion = #{opinion},operation_status = #{operationStatus},audit_status = #{auditStatus},update_time = #{date}
         WHERE id = #{iid}
     </update>
 
+    <!-- 插入数据的样板 -->
     <select id="getComplianceInvestigation" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgComplianceInvestigation">
-        SELECT company_id,business_id FROM dg_compliance_investigation
+        SELECT company_id,business_id FROM dg_compliance_investigation WHERE id = #{iid}
     </select>
 
     <!-- 指派之后将法规经理与该条数据绑定 -->
     <update id="updateAssign">
-        UPDATE dg_compliance_investigation SET user_id = #{userId} WHERE id = #{iid}
+        UPDATE dg_compliance_investigation
+        SET user_id = #{userId},operation_status = #{operationStatus},audit_status = #{auditStatus}
+        WHERE id = #{iid}
     </update>
 
     <!-- 新增一条指派数据 -->
     <insert id="assign" parameterType="com.daqing.framework.domain.guarantee.DgComplianceInvestigation">
-        INSERT INTO (company_id,user_id,status,create_time,update_time,business_id,role_id)
+        INSERT INTO dg_compliance_investigation (company_id,user_id,operation_status,audit_status,create_time,update_time,business_id,role_id)
-        VALUES (#{dci.companyId},#{dci.userId},#{dci.status},#{dci.createTime},#{dci.updateTime},#{dci.businessId},#{dci.roleId})
+        VALUES (#{dci.companyId},#{dci.userId},#{dci.operationStatus},#{dci.auditStatus},#{dci.createTime},#{dci.updateTime},#{dci.businessId},#{dci.roleId})
-    </insert>
-
-    <!-- 插入经理可以查询到的数据 -->
-    <insert id="insertManager" parameterType="com.daqing.framework.domain.guarantee.DgComplianceInvestigation">
-        INSERT INTO (company_id,file,status,create_time,update_time,business_id,role_id,survey_opinion)
-        VALUES (#{dci.companyId},#{dci.file},#{dci.status},#{dci.createTime},#{dci.updateTime},
-                #{dci.businessId},#{dci.roleId},#{dci.surveyOpinion})
     </insert>
 
     <!-- 审核 -->
     <update id="check">
         UPDATE dg_compliance_investigation
-        SET remark = #{auditOpinion},status = #{status},update_time = #{date}
+        SET opinion = #{opinion},audit_status = #{auditStatus},operation_status = #{operationStatus},
+            update_time = #{date},user_id = #{userId}
+        WHERE id = #{iid}
+    </update>
+
+    <!-- 上传附件 -->
+    <update id="uploadAccessory">
+        UPDATE dg_enclosure_info
+        SET other_file = #{fileUrl}
+        WHERE business_id = #{businessId}
+    </update>
+
+    <!-- 调查完之后将指派完的数据更新为待处理 -->
+    <update id="updateToAudit">
+        UPDATE dg_compliance_investigation
+        SET operation_status = #{operationStatus}
+        WHERE business_id = #{businessId}
+        AND role_id = #{roleId}
+    </update>
+
+    <!-- 根据业务id获取当前角色对应的数据的操作状态 -->
+    <select id="getOperationStatusByBusinessId" resultType="integer">
+        SELECT operation_status FROM dg_compliance_investigation WHERE business_id = #{businessId} AND role_id = #{roleId}
+    </select>
+
+    <!-- 根据id查询合规调查表详情 -->
+    <select id="queryDgComplianceInvestigation" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgComplianceInvestigation">
+        SELECT file_url,opinion
+        FROM dg_compliance_investigation
         WHERE id = #{iid}
+    </select>
+
+    <!-- 新增一条工作会记录 -->
+    <insert id="insertWorkConferenceConsider" parameterType="com.daqing.framework.domain.guarantee.DgWorkConferenceConsider">
+        INSERT INTO dg_work_conference_consider (company_id,business_id,role_id,audit_status,operation_status,create_time,update_time)
+        VALUES (#{wcc.companyId},#{wcc.businessId},#{wcc.roleId},#{wcc.auditStatus},#{wcc.operationStatus},#{wcc.createTime},#{wcc.updateTime})
+    </insert>
+
+    <!-- 改变所有业务id相同的审核状态,用于拒绝或者驳回 -->
+    <update id="updateAuditStatusByBusinessId">
+        UPDATE dg_compliance_investigation SET audit_status = #{auditStatus} WHERE business_id = #{businessId}
+    </update>
+
+    <!-- 根据id改变当前数据的操作状态 -->
+    <update id="updateOperationStatusById">
+        UPDATE dg_compliance_investigation SET operation_status = #{operationStatus},opinion = #{opinion} WHERE id = #{id}
+    </update>
+
+    <!-- 根据业务id改变当前数据的业务状态 -->
+    <update id="updateBusinessStatusByBusinessId">
+        UPDATE dg_business_process_status SET business_status = #{businessStatus} WHERE business_id = #{businessId}
     </update>
+
 </mapper>

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

@@ -4,19 +4,127 @@
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BaseResultMap" type="com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider">
-        <id column="id" property="id" />
+        <id column="id" property="id"/>
-        <result column="company_id" property="companyId" />
+        <result column="company_id" property="companyId"/>
-        <result column="consider_id" property="considerId" />
+        <result column="consider_id" property="considerId"/>
-        <result column="status" property="status" />
+        <result column="status" property="status"/>
-        <result column="agreed_items" property="agreedItems" />
+        <result column="agreed_items" property="agreedItems"/>
-        <result column="additional_items" property="additionalItems" />
+        <result column="additional_items" property="additionalItems"/>
-        <result column="loan_money" property="loanMoney" />
+        <result column="loan_money" property="loanMoney"/>
-        <result column="loan_tern" property="loanTern" />
+        <result column="loan_tern" property="loanTern"/>
-        <result column="agree_person" property="agreePerson" />
+        <result column="agree_person" property="agreePerson"/>
-        <result column="disagree_person" property="disagreePerson" />
+        <result column="disagree_person" property="disagreePerson"/>
-        <result column="file" property="file" />
+        <result column="file" property="file"/>
-        <result column="create_time" property="createTime" />
+        <result column="create_time" property="createTime"/>
-        <result column="update_time" property="updateTime" />
+        <result column="update_time" property="updateTime"/>
     </resultMap>
 
+    <select id="list" resultType="com.daqing.financial.guarantee.model.response.DgLoanCommitteeConsiderResponse">
+        SELECT a.id AS business_id,a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
+        a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,l.operating_status
+        AS operating_status,l.status AS status,l.id AS id,l.role_id AS role_id,b.business_status AS business_status
+        FROM dg_loan_committee_consider AS l
+        LEFT JOIN dg_apply_amount_info AS a
+        ON a.id = l.business_id
+        LEFT JOIN crms_customer AS c
+        ON a.company_id = c.id
+        LEFT JOIN dg_business_process_status AS b
+        ON b.business_id = a.id
+        WHERE c.del_or_not = 0
+        AND (l.consider = #{userId} OR l.consider_id IS NULL)
+        AND l.role_id IN
+        <foreach collection="roleIds" open="(" separator="," close=")" item="roleId">
+            #{roleId}
+        </foreach>
+        <if test="codeOrName != null and codeOrName != ''">
+            AND (a.business_code LIKE CONCAT('%',#{codeOrName},'%') OR c.name LIKE CONCAT('%',#{codeOrName},'%'))
+        </if>
+        ORDER BY a.create_time DESC
+    </select>
+
+    <select id="excelList" resultType="com.daqing.financial.guarantee.model.response.DgLoanCommitteeConsiderResponse">
+        SELECT a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
+        a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,l.operating_status
+        AS operating_status,l.status AS status,b.business_status AS business_status
+        FROM dg_loan_committee_consider AS l
+        LEFT JOIN dg_apply_amount_info AS a
+        ON a.id = l.business_id
+        LEFT JOIN crms_customer AS c
+        ON a.company_id = c.id
+        LEFT JOIN dg_business_process_status AS b
+        ON b.business_id = a.id
+        WHERE c.del_or_not = 0
+        AND (l.consider = #{userId} OR l.consider_id IS NULL)
+        AND l.role_id IN
+        <foreach collection="roleIds" open="(" separator="," close=")" item="roleId">
+            #{roleId}
+        </foreach>
+        ORDER BY a.create_time DESC
+    </select>
+
+    <update id="check">
+        UPDATE dg_loan_committee_consider
+        SET consider_id = #{userId},status = #{status},operating_status = #{operatingStatus},create_time = #{date},
+            agreed_items = #{lr.agreedItems},additional_items = #{lr.additionalItems},loan_money = #{lrloanMoney},
+            loan_tern = #{lr.loanTern},agree_person = #{lr.agreePerson},disagree_person = #{lr.disagreePerson},
+            file = #{lr.fileUrl},passing_time = #{lr.passingTime}
+        WHERE id = #{lr.id}
+    </update>
+
+    <!-- 保存评委名单-->
+    <update id="TheJudgesDrawn">
+        UPDATE dg_loan_committee_consider
+        SET agree_person = #{agreePerson}
+        WHERE business_id = #{businessId}
+    </update>
+
+    <!-- 获取评委名单-->
+    <select id="getJudges" parameterType="integer" resultType="string">
+        SELECT agree_person FROM dg_loan_committee_consider WHERE id = #{id}
+    </select>
+
+    <!-- 获取AB角、资产调查、信息调查、合规调查的审批意见、审批人和时间 -->
+    <select id="getAuditOpinion" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.po.AuditOpinionPO">
+        SELECT a.remark AS a_audit_opinion,a.emp_id AS a_emp_id,a.update_time AS a_time,
+               b.remark AS b_audit_opinion,b.emp_id AS b_emp_id,b.update_time AS b_time,
+               ass.apply_content AS asset_audit_opinion,ass.emp_id AS asset_emp_id,ass.update_time AS asset_time,
+               m.remark AS message_audit_opinion,m.emp_id AS message_emp_id,m.update_time AS message_time,
+               c.opinion AS regulation_audit_opinion,c.user_id AS regulation_emp_id,c.update_time AS regulation_time
+        FROM dg_assets_investigation AS ass
+        LEFT JOIN dg_message_investigation AS m
+        ON ass.business_id = m.business_id
+        LEFT JOIN dg_compliance_investigation AS c
+        ON c.business_id = ass.business_id
+        LEFT JOIN (SELECT business_id,emp_id,remark,update_time FROM dg_guarantee_assign_user
+                   WHERE business_id = #{businessId} AND role_id = 59) AS a
+        ON ass.business_id = a.business_id
+        LEFT JOIN (SELECT business_id,emp_id,remark,update_time FROM dg_guarantee_assign_user
+                   WHERE business_id = #{businessId} AND role_id = 60) AS b
+        ON ass.business_id = b.business_id
+        WHERE ass.business_id = #{businessId}
+        AND ass.role_id = 64
+        AND m.role_id = 67
+        AND c.role_id = 70
+    </select>
+
+    <select id="query" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider">
+        SELECT agreed_items,additional_items,loan_money,loan_tern,agree_person,disagree_person,file,passing_time,refuse_opinion
+        FROM dg_loan_committee_consider
+        WHERE id = #{id}
+    </select>
+
+    <select id="getDgLoanCommitteeConsider" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider">
+        SELECT business_id FROM dg_loan_committee_consider WHERE id = #{id}
+    </select>
+
+    <!-- 改变所有业务id相同的审核状态,用于拒绝或者驳回 -->
+    <update id="updateAuditStatusByBusinessId">
+        UPDATE dg_loan_committee_consider SET status = #{status} WHERE business_id = #{businessId}
+    </update>
+
+    <!-- 根据id改变当前数据的操作状态 -->
+    <update id="updateOperationStatusById">
+        UPDATE dg_loan_committee_consider SET operating_status = #{operatingStatus},refuse_opinion = #{refuseOpinion} WHERE id = #{id}
+    </update>
+
 </mapper>

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

@@ -13,4 +13,76 @@
         <result column="update_time" property="updateTime" />
     </resultMap>
 
+    <!-- 通过角色查询所有数据 -->
+    <select id="list" resultType="com.daqing.framework.domain.guarantee.po.DgWorkConferencePO">
+        SELECT a.id AS business_id,a.business_code AS business_code,a.business_type AS business_type,a.apply_amount AS apply_amount,
+        a.apply_time AS apply_time,a.create_time AS create_time,c.name AS name,c.phone AS phone,w.id AS id,
+        w.role_id AS role_id,w.audit_status AS audit_status,w.operation_status AS operation_status,
+        b.business_status AS business_status,i.user_id AS i_user_id,ass.emp_id AS ass_user_id,m.emp_id AS m_user_id,
+        ab.A AS a_user_id,ab.B AS b_user_id
+        FROM dg_work_conference_consider AS w
+        LEFT JOIN dg_apply_amount_info AS a
+        ON a.id = w.business_id
+        LEFT JOIN crms_customer AS c
+        ON a.company_id = c.id
+        LEFT JOIN dg_business_process_status AS b
+        ON b.business_id = a.id
+        LEFT JOIN (SELECT business_id,SUM(CASE role_id WHEN 59 THEN emp_id ELSE 0 END) AS A,
+                  SUM(CASE role_id WHEN 60 THEN emp_id ELSE 0 END) AS B
+                  FROM dg_guarantee_assign_user GROUP BY business_id) AS ab
+        ON a.id = ab.business_id
+        LEFT JOIN dg_compliance_investigation AS i
+        ON a.id = i.business_id
+        LEFT JOIN dg_assets_investigation AS ass
+        ON a.id = ass.business_id
+        LEFT JOIN dg_message_investigation AS m
+        ON a.id = m.business_id
+        WHERE c.del_or_not = 0
+        AND (w.user_id = #{userId} OR w.user_id IS NULL)
+        AND w.role_id IN
+        <foreach collection="roleIds" open="(" separator="," close=")" item="roleId">
+            #{roleId}
+        </foreach>
+        AND i.role_id = 70
+        AND ass.role_id = 64
+        AND m.role_id = 67
+        <if test="codeOrName != null and codeOrName != ''">
+            AND (a.business_code LIKE CONCAT('%',#{codeOrName},'%') OR c.name LIKE CONCAT('%',#{codeOrName},'%'))
+        </if>
+        ORDER BY a.create_time DESC
+    </select>
+
+    <!-- 审议 -->
+    <update id="check">
+        UPDATE dg_work_conference_consider
+        SET user_id = #{userId},opinion = #{opinion},audit_status = #{auditStatus},operation_status = #{operationStatus},
+            update_time = #{date},join_judge = #{joinJudge}
+        WHERE id = #{id}
+    </update>
+
+    <!-- 获取一个工作会对象 -->
+    <select id="getWorkConferenceConsider" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgWorkConferenceConsider">
+        SELECT company_id,business_id FROM dg_work_conference_consider WHERE id = #{id}
+    </select>
+
+    <!-- 新增一条贷审会数据 -->
+    <insert id="insertLoanCommitteeConsider" parameterType="com.daqing.framework.domain.guarantee.DgLoanCommitteeConsider">
+        INSERT INTO dg_loan_committee_consider (business_id,company_id,role_id,status,operating_status,create_time,update_time)
+        VALUES (#{lcc.businessId},#{lcc.companyId},#{lcc.roleId},#{lcc.status},#{lcc.operatingStatus},#{lcc.createTime},#{lcc.updateTime})
+    </insert>
+
+    <select id="query" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.DgWorkConferenceConsider">
+       SELECT opinion,join_judge FROM dg_work_conference_consider WHERE id = #{id}
+    </select>
+
+    <!-- 改变所有业务id相同的审核状态,用于拒绝或者驳回 -->
+    <update id="updateAuditStatusByBusinessId">
+        UPDATE dg_work_conference_consider SET audit_status = #{auditStatus} WHERE business_id = #{businessId}
+    </update>
+
+    <!-- 根据id改变当前数据的操作状态 -->
+    <update id="updateOperationStatusById">
+        UPDATE dg_work_conference_consider SET operation_status = #{operationStatus},opinion = #{opinion} WHERE id = #{id}
+    </update>
+
 </mapper>

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/controller/EmployeeController.java

@@ -149,7 +149,7 @@ public class EmployeeController implements EmployeeControllerApi {
      */
     @Override
     @GetMapping("/start")
-    public ResponseResult start(@RequestParam("id")Long id) {
+    public ResponseResult start(@RequestParam("id") Long id) {
 
         Boolean result = employeeService.start(id);
 
@@ -173,7 +173,7 @@ public class EmployeeController implements EmployeeControllerApi {
      */
     @GetMapping("/forbidInfo")
     @Override
-    public ResponseResult forbidInfo(@RequestParam("id")Long id) {
+    public ResponseResult forbidInfo(@RequestParam("id") Long id) {
 
         UserEntity user = employeeService.forbidInfo(id);
 
@@ -205,6 +205,7 @@ public class EmployeeController implements EmployeeControllerApi {
 
     /**
      * 根据id查询员工姓名
+     *
      * @param id
      * @return
      */
@@ -224,6 +225,7 @@ public class EmployeeController implements EmployeeControllerApi {
 
     /**
      * 根据userId查询员工头像
+     *
      * @param userId
      * @return
      */
@@ -234,6 +236,7 @@ public class EmployeeController implements EmployeeControllerApi {
 
     /**
      * 根据userId获取用户名以及部门名称
+     *
      * @param userId
      * @return
      */
@@ -244,16 +247,22 @@ public class EmployeeController implements EmployeeControllerApi {
 
     /**
      * 新增用户角色
+     *
      * @param userId
      * @return
      */
     @GetMapping("/insertUserRole")
-    public ResponseResult insertUserRole(@RequestParam("userId") Long userId,@RequestParam("roleId")Long roleId) {
+    public ResponseResult insertUserRole(@RequestParam("userId") Long userId, @RequestParam("roleId") Long roleId) {
-        return new ResponseResult<>().SUCCESS(employeeService.insertUserRole(userId,roleId));
+        return new ResponseResult<>().SUCCESS(employeeService.insertUserRole(userId, roleId));
     }
 
     @PostMapping("/insertUsrRole")
     public ResponseResult insertUsrRole(@RequestBody List<DgGuaranteePO> list) {
         return new ResponseResult<>().SUCCESS(employeeService.insertUsrRole(list));
     }
+
+    @GetMapping("/saveUserRole")
+    public ResponseResult saveUserRole(@RequestParam("userId") Long userId, @RequestParam("roleId") Long roleId) {
+        return ResponseResult.SUCCESS(employeeService.saveUserRole(userId,roleId));
+    }
 }

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/dao/EmployeeDao.java

@@ -34,6 +34,8 @@ public interface EmployeeDao extends BaseMapper<EmployeeEntity> {
 
     List<UserDeptVO> employeeListByDeptId(Long id);
 
+    List<EmployeeVO> listEmployeeByDeptIdAndEmpId(@Param("id") Long deptId, @Param("name") String name, @Param("empIds") List<Long> empIds);
+
     List<EmployeeVO> listEmployeeName();
 
     IPage<EmployeeVO> pageByCondition(Page page, @Param("employee") EmployeeEntity employee);
@@ -58,13 +60,13 @@ public interface EmployeeDao extends BaseMapper<EmployeeEntity> {
 
     Long getUserId(Long id);
 
-    Boolean updatePassword(@Param("id")Long id,@Param("password")String password);
+    Boolean updatePassword(@Param("id") Long id, @Param("password") String password);
 
     EmployeeInfoVO getInfo(Long id);
 
     Boolean updateEmployee(EmployeeEntity employeeEntity);
 
-    Boolean updateUser(@Param("id")Long id, @Param("account")String account, @Param("modifyTime")Date modifyTime);
+    Boolean updateUser(@Param("id") Long id, @Param("account") String account, @Param("modifyTime") Date modifyTime);
 
     Boolean deleteDepartment(Long id);
 
@@ -72,11 +74,11 @@ public interface EmployeeDao extends BaseMapper<EmployeeEntity> {
 
     Boolean deleteRole(Long id);
 
-    Boolean insertDepartment(@Param("id") Long id,@Param("deptIds") List<Long> ids);
+    Boolean insertDepartment(@Param("id") Long id, @Param("deptIds") List<Long> ids);
 
-    Boolean insertPosition(@Param("id") Long id,@Param("positionIds") List<Long> ids);
+    Boolean insertPosition(@Param("id") Long id, @Param("positionIds") List<Long> ids);
 
-    Boolean insertRole(@Param("id")Long id,@Param("roleIds") List<Long> roleIds);
+    Boolean insertRole(@Param("id") Long id, @Param("roleIds") List<Long> roleIds);
 
     Boolean insertUser(UserEntity user);
 
@@ -101,4 +103,6 @@ public interface EmployeeDao extends BaseMapper<EmployeeEntity> {
     boolean insertUserRole(Long userId, Long roleId);
 
     boolean insertUsrRole(@Param("list") List<DgGuaranteePO> list);
+
+    int saveUserRole(@Param("userId") Long userId, @Param("roleId") Long roleId);
 }

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/service/DeptService.java

@@ -28,6 +28,8 @@ public interface DeptService extends IService<DeptEntity> {
 
     List<DepartmentVO> listDepartmentAndEmployeeTree();
 
+    List<DepartmentVO> listDeptAndEmpTree(String name,List<Long> empIds);
+
     DepartmentVO getDepartmentAndEmployee(Long id);
 
     List<EmployeeVO> listEmployeeById(Long id);

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/service/EmployeeService.java

@@ -69,5 +69,7 @@ public interface EmployeeService extends IService<EmployeeEntity> {
     boolean insertUserRole(Long userId, Long roleId);
 
     boolean insertUsrRole(List<DgGuaranteePO> list);
+
+    Boolean saveUserRole(Long userId, Long roleId);
 }
 

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/service/impl/DeptServiceImpl.java

@@ -107,6 +107,7 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
 
     /**
      * 树形结构部门查询
+     *
      * @return
      */
     @Override
@@ -160,20 +161,23 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
 
     /**
      * 获取所有的部门及部门下的员工信息
+     *
      * @return
      */
     @Override
     public List<DepartmentVO> listDepartmentAndEmployeeTree() {
         return this.getListDepartmentAndEmployeeTree(deptDao.listDepartment(), 0L);
     }
-    private List<DepartmentVO> getListDepartmentAndEmployeeTree(List<DepartmentVO> list, Long parentId){
+
+
+    private List<DepartmentVO> getListDepartmentAndEmployeeTree(List<DepartmentVO> list, Long parentId) {
         return list.stream()
                 .filter(dept -> parentId.equals(dept.getParentId())) // 过滤出部门id为所选id的部门信息(也为递归的结果条件，找不到所对应的部门id)
                 .peek(dept -> {
                     dept.setChildren(getListDepartmentAndEmployeeTree(list, dept.getId())); // 设置该部门的子部门:递归调用
 
                     List<UserDeptVO> empList = employeeDao.employeeListByDeptId(dept.getId());
-                    System.out.println("empList========================"+empList);
+                    System.out.println("empList========================" + empList);
 
                     dept.setUserDept(employeeDao.employeeListByDeptId(dept.getId()));
 
@@ -183,7 +187,25 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
                 .collect(Collectors.toList());
     }
 
+    /**
+     * 根据条件获取所有部门及部门下的员工信息
+     */
+    @Override
+    public List<DepartmentVO> listDeptAndEmpTree(String name, List<Long> empIds) {
 
+        return this.getListDepartmentAndEmployeeTree(deptDao.listDepartment(), 0L, name, empIds);
+    }
+
+    private List<DepartmentVO> getListDepartmentAndEmployeeTree(List<DepartmentVO> list, Long parentId, String name, List<Long> empIds) {
+        return list.stream()
+                .filter(dept -> parentId.equals(dept.getParentId())) // 过滤出部门id为所选id的部门信息(也为递归的结果条件，找不到所对应的部门id)
+                .peek(dept -> {
+                    dept.setChildren(getListDepartmentAndEmployeeTree(list, dept.getId())); // 设置该部门的子部门:递归调用
+                    dept.setEmployee(employeeDao.listEmployeeByDeptIdAndEmpId(dept.getId(), name, empIds)); // 设置该部门下面的所有员工
+                })
+                .sorted(Comparator.comparingInt(menu -> (menu.getSort() == null ? 0 : menu.getSort()))) // 根据所选排序信息进行排序
+                .collect(Collectors.toList());
+    }
 
     /**
      * 获取该部门下子部门及部门下的员工
@@ -191,11 +213,11 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
     @Override
     public DepartmentVO getDepartmentAndEmployee(Long id) {
         DepartmentVO departmentVO = new DepartmentVO();
-        if (id == null){
+        if (id == null) {
             List<DepartmentVO> departments = deptDao.getDepartmentByParentId(0L);
             departmentVO.setChildren(departments);
             return departmentVO;
-        }else {
+        } else {
             List<DepartmentVO> departments = deptDao.getDepartmentByParentId(id);
             List<EmployeeVO> employeeS = employeeDao.listEmployeeByDeptId(id);
             departmentVO.setChildren(departments);
@@ -205,7 +227,6 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
     }
 
     /**
-     *
      * 根据员工id获取对应部门下所有的客户经理
      *
      * @param id 员工id
@@ -220,7 +241,7 @@ public class DeptServiceImpl extends ServiceImpl<DeptDao, DeptEntity> implements
     /**
      * 根据部门id获取该部门所有的员工id和姓名
      */
-    public List<EmployeeVO> listEmployeeByDeptId(Long deptId){
+    public List<EmployeeVO> listEmployeeByDeptId(Long deptId) {
 
         return this.getBaseMapper().listEmployeeByDeptId(deptId);
     }

dq-financial-hrms/src/main/java/com/daqing/financial/hrms/service/impl/EmployeeServiceImpl.java

@@ -601,8 +601,23 @@ public class EmployeeServiceImpl extends ServiceImpl<EmployeeDao, EmployeeEntity
         return this.getBaseMapper().insertUserRole(userId,roleId);
     }
 
+
+
     @Override
     public boolean insertUsrRole(List<DgGuaranteePO> list) {
         return this.getBaseMapper().insertUsrRole(list);
     }
+
+    /**
+     * 给用户赋予一个角色
+     */
+    @Override
+    public Boolean saveUserRole(Long userId, Long roleId) {
+        int i = this.getBaseMapper().saveUserRole(userId, roleId);
+        if (i > 0){
+
+            return true;
+        }
+        return false;
+    }
 }

dq-financial-hrms/src/main/resources/mapper/hrms/EmployeeDao.xml

@@ -137,7 +137,7 @@
     <resultMap type="com.daqing.framework.domain.hrms.ext.EmployeeTO" id="employeeTO">
         <id property="id" column="eid"/>
         <result property="empName" column="emp_name"/>
-        <collection property="deptNames" ofType="string" >
+        <collection property="deptNames" ofType="string">
             <result column="dept_name"/> <!-- 员工和部门是多对多,从单个员工的角度看为一对多 -->
         </collection>
     </resultMap>
@@ -184,6 +184,29 @@
         AND d.id = #{id}
     </select>
 
+    <!-- 根据部门id获取该部门下面所有的员工 -->
+    <select id="listEmployeeByDeptIdAndEmpId" resultType="com.daqing.framework.domain.hrms.ext.EmployeeVO">
+        SELECT e.id,e.name
+        FROM hrms_employee e
+        LEFT JOIN hrms_employee_dept ed
+        ON e.id = ed.employee_id
+        LEFT JOIN hrms_dept d
+        ON ed.dept_id = d.id
+        LEFT JOIN hrms_user u
+        ON e.user_id = u.id
+        WHERE u.del_or_not = 0
+        AND d.id = #{id}
+        <if test="name != null and name != ''">
+            AND e.name LIKE CONCAT('%',#{name},'%')
+        </if>
+        <if test="empIds != null and empIds != ''">
+            AND e.id NOT IN
+            <foreach collection="empIds" item="empId" open="(" separator="," close=")">
+                #{empId}
+            </foreach>
+        </if>
+    </select>
+
 
     <!-- 根据部门id获取该部门下面所有的员工 -->
     <select id="employeeListByDeptId" parameterType="long" resultType="com.daqing.framework.domain.hrms.ext.UserDeptVO">
@@ -229,7 +252,8 @@
         </where>
     </select>
 
-    <select id="pageList" parameterType="com.daqing.framework.domain.hrms.request.EmployeeRequest" resultMap="employeeList">
+    <select id="pageList" parameterType="com.daqing.framework.domain.hrms.request.EmployeeRequest"
+            resultMap="employeeList">
         SELECT e.id id,e.name name,u.account account,e.job_number job_number,
         u.create_time create_time,u.status status
         FROM hrms_employee e
@@ -237,7 +261,8 @@
         ON e.user_id = u.id
         WHERE u.del_or_not = 0
         <if test="employee.codeOrName != null and employee.codeOrName != ''">
-            AND (e.name LIKE CONCAT('%',#{employee.codeOrName},'%') OR u.account LIKE CONCAT('%',#{employee.codeOrName},'%')
+            AND (e.name LIKE CONCAT('%',#{employee.codeOrName},'%') OR u.account LIKE
+            CONCAT('%',#{employee.codeOrName},'%')
             OR e.job_number LIKE CONCAT('%',#{employee.codeOrName},'%'))
         </if>
     </select>
@@ -251,7 +276,8 @@
         WHERE u.del_or_not = 0
     </select>
 
-    <select id="pageListByDept" parameterType="com.daqing.framework.domain.hrms.request.EmployeeRequest" resultMap="employeeList">
+    <select id="pageListByDept" parameterType="com.daqing.framework.domain.hrms.request.EmployeeRequest"
+            resultMap="employeeList">
         SELECT e.id id,e.name name,u.account account,e.job_number job_number,
         u.create_time create_time,u.status status
         FROM hrms_employee e
@@ -266,7 +292,8 @@
             AND d.id = #{employee.id}
         </if>
         <if test="employee.codeOrName != null and employee.codeOrName != ''">
-            AND (e.name LIKE CONCAT('%',#{employee.codeOrName},'%') OR u.account LIKE CONCAT('%',#{employee.codeOrName},'%')
+            AND (e.name LIKE CONCAT('%',#{employee.codeOrName},'%') OR u.account LIKE
+            CONCAT('%',#{employee.codeOrName},'%')
             OR e.job_number LIKE CONCAT('%',#{employee.codeOrName},'%'))
         </if>
     </select>
@@ -448,12 +475,20 @@
         VALUES (#{userId},#{roleId})
     </insert>
 
-    <insert id="insertEmployee" keyProperty="id" useGeneratedKeys="true" parameterType="com.daqing.framework.domain.hrms.EmployeeEntity">
+    <insert id="saveUserRole">
+        INSERT INTO hrms_employee_role
+        (user_id,role_id)
+        VALUES (#{userId},#{roleId})
+    </insert>
+
+    <insert id="insertEmployee" keyProperty="id" useGeneratedKeys="true"
+            parameterType="com.daqing.framework.domain.hrms.EmployeeEntity">
         INSERT INTO hrms_employee (name,job_number,gender,birthday,phone,company_mail,user_id)
         VALUES (#{name},#{jobNumber},#{gender},#{birthday},#{phone},#{companyMail},#{userId})
     </insert>
 
-    <insert id="insertUser" keyProperty="id" useGeneratedKeys="true" parameterType="com.daqing.framework.domain.hrms.UserEntity">
+    <insert id="insertUser" keyProperty="id" useGeneratedKeys="true"
+            parameterType="com.daqing.framework.domain.hrms.UserEntity">
         INSERT INTO hrms_user (account,phone_account,create_time,motify_time) VALUES (#{account},#{phoneAccount},#{createTime},#{motifyTime})
     </insert>
 
@@ -494,7 +529,8 @@
     </update>
 
     <!-- 根据id查询员工头像 -->
-    <select id="getEmployeeEntityByUserId" parameterType="long" resultType="com.daqing.framework.domain.hrms.EmployeeEntity">
+    <select id="getEmployeeEntityByUserId" parameterType="long"
+            resultType="com.daqing.framework.domain.hrms.EmployeeEntity">
         SELECT head_portarit_url
         FROM hrms_employee
         WHERE user_id = #{userId}
@@ -523,7 +559,8 @@
         AND e.job_number = #{jobNumber}
     </select>
 
-    <select id="getEmployeeRepetitionByEmpId" parameterType="long" resultType="com.daqing.framework.domain.hrms.ext.EmployeeRepetition">
+    <select id="getEmployeeRepetitionByEmpId" parameterType="long"
+            resultType="com.daqing.framework.domain.hrms.ext.EmployeeRepetition">
         SELECT e.name name,e.job_number job_number,u.account account
         FROM hrms_employee e
         LEFT JOIN hrms_user u
@@ -532,7 +569,8 @@
         AND e.id = #{empId}
     </select>
 
-    <select id="getAccountAndDeptNameById" parameterType="long" resultType="com.daqing.framework.domain.guarantee.response.EmployeeMessageResponse">
+    <select id="getAccountAndDeptNameById" parameterType="long"
+            resultType="com.daqing.framework.domain.guarantee.response.EmployeeMessageResponse">
         select hu.id, hu.account, GROUP_CONCAT(hd.`name` SEPARATOR '/')deptName
         from hrms_employee_dept ed
         LEFT JOIN hrms_dept hd on hd.id=ed.dept_id

dq-framework-common/src/main/java/com/daqing/framework/model/response/CommonCode.java

@@ -32,7 +32,8 @@ public enum CommonCode implements ResultCode {
     POSITION_DEPT_NOT_NULL(false,10014,"职位名称或所属部门不能为空!"),
     PASSWORD_IS_ERROR(false, 10005, "密码错误！"),
     IMPORT_ERROR(false,10008,"导入数据失败!"),
-    SERVER_ERROR(false, 99999, "抱歉，系统繁忙，请稍后重试！");
+    SERVER_ERROR(false, 99999, "抱歉，系统繁忙，请稍后重试！"),
+    GET_LOGIN_USER_FAIL(false,10015,"获取当前登录用户失败,请稍后重试!");
 
     /**
      * 操作是否成功

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/DgComplianceInvestigation.java

@@ -35,38 +35,51 @@ public class DgComplianceInvestigation implements Serializable {
     /**
      * 用户id
      */
-    private Integer empId;
+    private Integer userId;
+
+    /**
+     * 贷款信息表id
+     */
+    private Integer businessId;
+
+    /**
+     * 角色id
+     */
+    private Integer roleId;
 
     /**
      * 附件
      */
+    @ApiModelProperty("附件")
     private String file;
 
     /**
-     * 审核意见
+     * 调查意见
      */
-    private String remark;
+    @ApiModelProperty("审核(调查)意见")
+    private String opinion;
 
     /**
      * 审核状态
      */
-    private Integer status;
+    private Integer auditStatus;
 
-    @ApiModelProperty(value = "创建时间")
+    /**
+     * 操作状态
+     */
+    private Integer operationStatus;
+
+    /**
+     * 创建时间
+     */
     @TableField(fill = FieldFill.INSERT)
     private Date createTime;
 
-    @ApiModelProperty(value = "更新时间")
+    /**
+     * 更新时间
+     */
     @TableField(fill = FieldFill.INSERT_UPDATE)
     private Date updateTime;
 
-    @ApiModelProperty("贷款信息表id")
-    private Integer businessId;
-
-    @ApiModelProperty("角色id")
-    private Integer roleId;
-
-    @ApiModelProperty("调查意见")
-    private String surveyOpinion;
 
 }

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/DgGuaranteeAssignUser.java

@@ -44,7 +44,7 @@ public class DgGuaranteeAssignUser implements Serializable {
     private Integer companyId;
 
     /**
-     * 员工id
+     * 用户id
      */
     private Integer empId;
 

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/DgLoanCommitteeConsider.java

@@ -32,11 +32,21 @@ public class DgLoanCommitteeConsider implements Serializable {
      */
     private Integer companyId;
 
+    /**
+     * 业务id
+     */
+    private Integer businessId;
+
     /**
      * 审议者id
      */
     private Integer considerId;
 
+    /**
+     * 角色id
+     */
+    private Integer roleId;
+
     @ApiModelProperty(value = "审核状态：（1审核中 、2已审核、4驳回）")
     private Integer status;
 

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/DgWorkConferenceConsider.java

@@ -33,19 +33,35 @@ public class DgWorkConferenceConsider implements Serializable {
     private Integer companyId;
 
     /**
-     * 审议者id
+     * 业务id
      */
-    private Integer considerId;
+    private Integer businessId;
+
+    /**
+     * 角色id
+     */
+    private Integer roleId;
 
     /**
-     * 工作会意见
+     * 审议者id
      */
+    private Integer considerId;
+
+    @ApiModelProperty("工作会意见")
     private String remark;
 
+    @ApiModelProperty("参会评委")
+    private String joinJudge;
+
     /**
      * 审核状态
      */
-    private Integer status;
+    private Integer auditStatus;
+
+    /**
+     * 操作状态
+     */
+    private Integer operationStatus;
 
     @ApiModelProperty(value = "创建时间")
     @TableField(fill = FieldFill.INSERT)

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/GuaranteeCode.java

@@ -18,9 +18,15 @@ public enum GuaranteeCode implements ResultCode {
 
     COMPLIANCE_INVESTIGATION_REMARK_NOT_NULL(false,80001,"意见不能为空,请输入拒绝/驳回意见!"),
     COMPLIANCE_UPLOAD_NOT_NULL(false,80002,"附件不能为空,请上传附件!"),
+    COMPLIANCE_USER_NOT_NULL(false,80003,"指派调查员不能为空,请选择指派员!"),
 
-    ROLE_IS_NOT(false,90001,"当前登录用户角色信息不存在,无法查询!");
+    ROLE_IS_NOT(false,90001,"当前登录用户角色信息不存在,无法查询!"),
 
+    LOAN_MESSAGE_NOT_NULL(false,100001,"议定事项、附加事项、贷款金额、贷款期限、附件等不能为空!"),
+
+    WORK_JUDGE_NOT_NULL(false,110001,"参会评委不能为空,请重新选择!"),
+
+    EXCEL_ID_NOT_NULL(false, 120001,"导出的数据不能为空,请选择要导出的数据!");
 
     /**
      * 操作是否成功

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/po/AuditOpinionPO.java

@@ -0,0 +1,64 @@
+package com.daqing.framework.domain.guarantee.po;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * AB角、合规调查、资产调查、信息调查、法规调查的审核意见、审核人id、时间
+ *
+ * @auther River
+ * @date 2020/11/25 16:43
+ */
+@Data
+@ToString
+public class AuditOpinionPO implements Serializable {
+
+    @ApiModelProperty("担保A角调查意见")
+    private String aAuditOpinion;
+
+    @ApiModelProperty("A角姓名")
+    private Integer aEmpId;
+
+    @ApiModelProperty("A角调查时间")
+    private Date aTime;
+
+    @ApiModelProperty("担保B角调查意见")
+    private String bAuditOpinion;
+
+    @ApiModelProperty("B角姓名")
+    private String bEmpId;
+
+    @ApiModelProperty("B角调查时间")
+    private Date bTime;
+
+    @ApiModelProperty("资产审核意见")
+    private String assetAuditOpinion;
+
+    @ApiModelProperty("资产姓名")
+    private String assetEmpId;
+
+    @ApiModelProperty("资产审核时间")
+    private Date assetTime;
+
+    @ApiModelProperty("信息审核意见")
+    private String messageAuditOpinion;
+
+    @ApiModelProperty("信息姓名")
+    private String messageEmpId;
+
+    @ApiModelProperty("信息审核时间")
+    private Date messageTime;
+
+    @ApiModelProperty("法规审核意见")
+    private String regulationAuditOpinion;
+
+    @ApiModelProperty("法规姓名")
+    private String regulationEmpId;
+
+    @ApiModelProperty("法规审核时间")
+    private Date regulationTime;
+}

dq-framework-model/src/main/java/com/daqing/framework/domain/guarantee/po/DgWorkConferencePO.java

@@ -0,0 +1,73 @@
+package com.daqing.framework.domain.guarantee.po;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.ToString;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @auther River
+ * @date 2020/11/23 16:17
+ */
+@Data
+@ToString
+public class DgWorkConferencePO implements Serializable {
+
+    @ApiModelProperty("工作会表id")
+    private Integer id;
+
+    @ApiModelProperty("业务编号")
+    private String businessCode;
+
+    @ApiModelProperty("客户名称")
+    private String name;
+
+    @ApiModelProperty("联系电话")
+    private String phone;
+
+    @ApiModelProperty("业务类别")
+    private String businessType;
+
+    @ApiModelProperty("金额")
+    private Double applyAmount;
+
+    @ApiModelProperty("期限")
+    private String applyTime;
+
+    @ApiModelProperty("申请日期")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
+    private Date createTime;
+
+    @ApiModelProperty("A角")
+    private Integer aUserId;
+
+    @ApiModelProperty("B角")
+    private Integer bUserId;
+
+    @ApiModelProperty("法规部领导")
+    private Integer iUserId;
+
+    @ApiModelProperty("资产部领导")
+    private Integer assUserId;
+
+    @ApiModelProperty("信息部领导")
+    private Integer mUserId;
+
+    @ApiModelProperty("操作状态,0:已发起,1:待处理,2:已处理")
+    private Integer operationStatus;
+
+    @ApiModelProperty("审核状态,0:待指派,1:审核中,2:已审核,3:已拒绝,4:已驳回,5:草稿,6:已撤销")
+    private Integer auditStatus;
+
+    @ApiModelProperty("业务状态,1->进行中;2->已完成;3->已否决")
+    private Integer businessStatus;
+
+    @ApiModelProperty("角色id")
+    private Integer roleId;
+
+    @ApiModelProperty("业务id")
+    private Integer businessId;
+}