diff --git a/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java b/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java index 5b43b0b5c3..0b995d4212 100644 --- a/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java +++ b/anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/utils/ProcDefEnum.java @@ -8,7 +8,7 @@ public enum ProcDefEnum { /***************************正式流程id***********************************/ - DEFAUL_TADMIN_SID("默认的管理员sid","427a2fb0-60c5-409f-bea4-4eb441041ae6"), + DEFAUL_TADMIN_SID("默认的管理员sid", "427a2fb0-60c5-409f-bea4-4eb441041ae6"), ORDERDEPOSITAPPROVE("简易订单-订金收取", "process_60lvxwuh:1:960004"), ORDERDEPOSITVEHICLEAPPROVE("简易订单-车辆预定", "process_pkyns85b:5:575008"), @@ -51,10 +51,10 @@ public enum ProcDefEnum { BUSSALESORDERRETURNVEHAPPLY("销售订单退车申请", "process_tzjjs03y:1:1012504"), BASETRAILEROUTAPPLY("挂车出库申请", "process_tkw6vhfw:1:1705004"), FINFUNDSAPPLY("款项结转申请", "process_ypafrrvg:1:2257504"), - BUSHANDOVER("交车确认", "process_e8feloik:5:1747508"), LOANFINPOLICYRECORDAPPLY("金融产品政策备案", "process_u45lo7qc:1:2272516"), LOANOTHERPOLICYRECORDAPPLY("其它融产品备案", "process_7pptyzfc:1:2272524"), + DEALERFILINGAPPLY("经销商备案", "process_jdu35cog:2:2472504"), /******************************测试流程id*********************************************/ diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApply.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApply.java index 94540b0970..1bf70013d6 100644 --- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApply.java +++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApply.java @@ -56,5 +56,7 @@ public class LoanFinOtherPolicyRecordApply extends BaseEntity { private String createOrgName; @ApiModelProperty("使用组织全路径") private String orgSidPath; + @ApiModelProperty("办结日期") + private Date closingDate; } diff --git a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicyrecordapply/LoanFinPolicyRecordApply.java b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicyrecordapply/LoanFinPolicyRecordApply.java index 01358652db..fdb056fbc6 100644 --- a/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicyrecordapply/LoanFinPolicyRecordApply.java +++ b/anrui-riskcenter/anrui-riskcenter-api/src/main/java/com/yxt/anrui/riskcenter/api/loanfinpolicyrecordapply/LoanFinPolicyRecordApply.java @@ -56,5 +56,7 @@ public class LoanFinPolicyRecordApply extends BaseEntity { private String createOrgName; @ApiModelProperty("使用组织全路径") private String orgSidPath; + @ApiModelProperty("办结日期") + private Date closingDate; } diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApplyService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApplyService.java index 86ae7a34dc..59ec31facc 100644 --- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApplyService.java +++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinotherpolicyrecordapply/LoanFinOtherPolicyRecordApplyService.java @@ -25,6 +25,8 @@ import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.GetNodeQu import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.GetNodeVo; import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.LoanOtherPolicyApplyTaskQuery; import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.SubmitLoanOtherPolicyApplyDto; +import com.yxt.anrui.riskcenter.api.loanfinpolicy.LoanFinPolicy; +import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.LoanFinPolicyApplyInitVo; import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.LoanFinPolicyRecordApply; import com.yxt.anrui.riskcenter.biz.loanfinotherPolicy.LoanFinOtherPolicyService; import com.yxt.anrui.riskcenter.biz.loanfinpolicy.LoanFinPolicyService; @@ -371,13 +373,18 @@ public class LoanFinOtherPolicyRecordApplyService extends MybatisBaseService policySids = entity.getPolicySids(); -// for (String policySid : policySids) { -// LoanFinPolicy loanFinPolicy = loanFinPolicyService.fetchBySid(policySid); -// loanFinPolicy.setFilingState(1); -// loanFinPolicyService.updateById(loanFinPolicy); -// } + //修改备案状态 + LoanFinOtherPolicyRecordApply entity = fetchBySid(businessSid); + String policySid = entity.getOtherPolicySid(); + String[] policySids = policySid.split(","); + for (String pSid : policySids) { + LoanFinOtherPolicy loanFinPolicy = loanFinOtherPolicyService.fetchBySid(pSid); + loanFinPolicy.setFilingState(1); + loanFinOtherPolicyService.updateById(loanFinPolicy); + } + entity.setClosingDate(new Date()); + //办结日期 + baseMapper.updateById(entity); } return rb.success().setData(resultBean.getData()); } else { @@ -450,14 +457,6 @@ public class LoanFinOtherPolicyRecordApplyService extends MybatisBaseService policySids = finOtherPolicyApplyInitVo.getPolicySids(); - for (String policySid : policySids) { - LoanFinOtherPolicy loanFinOtherPolicy = loanFinOtherPolicyService.fetchBySid(policySid); - loanFinOtherPolicy.setFilingState(1); - loanFinOtherPolicyService.updateById(loanFinOtherPolicy); - } return rb.success().setData(resultBean1.getData()); } else { return rb.setMsg("操作失败!提交的数据不一致"); diff --git a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicyrecordapply/LoanFinPolicyRecordApplyService.java b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicyrecordapply/LoanFinPolicyRecordApplyService.java index 6a9383b286..2fc896ad8d 100644 --- a/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicyrecordapply/LoanFinPolicyRecordApplyService.java +++ b/anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanfinpolicyrecordapply/LoanFinPolicyRecordApplyService.java @@ -419,6 +419,9 @@ public class LoanFinPolicyRecordApplyService extends MybatisBaseService policySids = new ArrayList<>(); + @ApiModelProperty("附件路径") + private List annexPaths = new ArrayList<>(); + @ApiModelProperty("使用组织全路径") + @JsonProperty("orgPath") + private String orgSidPath; + private List policyList = new ArrayList<>(); +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/AppOtherPolicyApplyInitListVo.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/AppOtherPolicyApplyInitListVo.java new file mode 100644 index 0000000000..c2e52bea05 --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/AppOtherPolicyApplyInitListVo.java @@ -0,0 +1,36 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.yxt.common.core.vo.Vo; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @author Administrator + * @description + * @date 2023/7/7 14:07 + */ +@Data +public class AppOtherPolicyApplyInitListVo implements Vo { + @ApiModelProperty("其他融政策sid") + @JsonProperty("policySid") + private String otherPolicySid; + @ApiModelProperty("政策名称") + @JsonProperty("policyName") + private String otherPolicyName; + @ApiModelProperty("业务类型") + private String busTypeValue; + @ApiModelProperty("车辆大类") + private String vehCategoryValue; + @ApiModelProperty("车辆功能") + private String vehTypeValue; + @ApiModelProperty("最高融资额") + private String maxLoanAmount; + @ApiModelProperty("期数") + private int period; + @ApiModelProperty("标准年利率（%）") + private String yearRatio; + @ApiModelProperty("有效期至") + private String validDateTo; + +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeign.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeign.java new file mode 100644 index 0000000000..17a75caf01 --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeign.java @@ -0,0 +1,70 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply; + + +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.CompleteOtherPolicyDto; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyTaskQuery; +import com.yxt.common.core.result.ResultBean; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.cloud.openfeign.SpringQueryMap; +import org.springframework.web.bind.annotation.*; + +import javax.validation.Valid; + +/** + * @Author + * @Date + * @Description + */ +@Api(tags = "其他融产品备案") +@FeignClient( + contextId = "terminal-OtherPolicyRecordApply", + name = "anrui-terminal", + path = "/risk/v1/otherpolicyrecordapply", + fallback = OtherPolicyRecordApplyFeignFallback.class) +public interface OtherPolicyRecordApplyFeign { + + /** + * 其他融产品报备初始化 + * @param sid + */ + @ApiOperation("其他融产品备案详情") + @GetMapping("/fetchDetailsBySid/{sid}") + @ResponseBody + public ResultBean fetchDetailsBySid(@PathVariable("sid") String sid); + + @ApiOperation("办理") + @PutMapping("/agreePolicyApplyInfo") + @ResponseBody + ResultBean agreePolicyApplyInfo(@Valid @RequestBody CompleteOtherPolicyDto dto); + + @ApiOperation("从分公司到风控中心办理") + @PutMapping("/agreeCompanyToDivisionOperate") + @ResponseBody + ResultBean agreeCompanyToDivisionOperate(@Valid @RequestBody CompleteOtherPolicyDto dto); + + + @ApiOperation("驳回") + @PutMapping("/rejectPolicyApplyInfo") + @ResponseBody + ResultBean rejectPolicyApplyInfo(@Valid @RequestBody OtherPolicyTaskQuery query); + + @ApiOperation("撤回") + @PutMapping("/recallPolicyApplyInfo") + @ResponseBody + ResultBean recallPolicyApplyInfo(@Valid @RequestBody OtherPolicyTaskQuery query); + + @ApiOperation("终止") + @PutMapping("/stopPolicyApplyInfo") + @ResponseBody + ResultBean stopPolicyApplyInfo(@Valid @RequestBody OtherPolicyTaskQuery query); + + @ApiOperation("获取流程操作标题") + @GetMapping("/getFlowOperateTitle") + @ResponseBody + ResultBean getFlowOperateTitle(@Valid @SpringQueryMap OtherPolicyFlowableQuery query); + + +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeignFallback.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeignFallback.java new file mode 100644 index 0000000000..2bd6e7aad9 --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/OtherPolicyRecordApplyFeignFallback.java @@ -0,0 +1,50 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply; + +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.CompleteOtherPolicyDto; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyTaskQuery; +import com.yxt.common.core.result.ResultBean; +import org.springframework.stereotype.Component; + +/** + * @Author dimengzhe + * @Date 2023/3/21 15:19 + * @Description + */ +@Component +public class OtherPolicyRecordApplyFeignFallback implements OtherPolicyRecordApplyFeign { + @Override + public ResultBean fetchDetailsBySid(String sid) { + return null; + } + + @Override + public ResultBean agreePolicyApplyInfo(CompleteOtherPolicyDto dto) { + return null; + } + + @Override + public ResultBean agreeCompanyToDivisionOperate(CompleteOtherPolicyDto dto) { + return null; + } + + @Override + public ResultBean rejectPolicyApplyInfo(OtherPolicyTaskQuery query) { + return null; + } + + @Override + public ResultBean recallPolicyApplyInfo(OtherPolicyTaskQuery query) { + return null; + } + + @Override + public ResultBean stopPolicyApplyInfo(OtherPolicyTaskQuery query) { + return null; + } + + @Override + public ResultBean getFlowOperateTitle(OtherPolicyFlowableQuery query) { + return null; + } +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/CompleteOtherPolicyDto.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/CompleteOtherPolicyDto.java new file mode 100644 index 0000000000..88afc95a9b --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/CompleteOtherPolicyDto.java @@ -0,0 +1,38 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.yxt.common.core.dto.Dto; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; + +/** + * @author Administrator + * @description + * @date 2023/7/7 14:35 + */ +@Data +public class CompleteOtherPolicyDto implements Dto { + private static final long serialVersionUID = -1634177638238174363L; + + @ApiModelProperty(value = "任务id") + @NotBlank(message = "参数错误：taskId") + private String taskId; + @ApiModelProperty(value = "流程id") + @NotBlank(message = "参数错误：procInsId") + @JsonProperty("procInsId") + private String instanceId; + @ApiModelProperty(value = "意见") + private String comment; + @ApiModelProperty(value = "业务sid") + @NotBlank(message = "参数错误：businessSid") + private String businessSid; + @ApiModelProperty(value = "用户sid") + @NotBlank(message = "参数错误：userSid") + private String userSid; + @ApiModelProperty(value = "节点id") + @NotBlank(message = "参数错误：taskDefKey") + private String taskDefKey; + +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyFlowableQuery.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyFlowableQuery.java new file mode 100644 index 0000000000..7d30c51d45 --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyFlowableQuery.java @@ -0,0 +1,21 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow; + +import com.yxt.common.core.query.Query; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotNull; + +@Data +public class OtherPolicyFlowableQuery implements Query { + private static final long serialVersionUID = -5879668616710833830L; + + @ApiModelProperty(value = "节点key") + private String taskDefKey; + @ApiModelProperty(value = "业务sid") + private String businessSid; + @ApiModelProperty(value = "0 上一环节 1下一环节") + @NotNull(message = "参数错误：next") + private Integer next; + +} diff --git a/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyTaskQuery.java b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyTaskQuery.java new file mode 100644 index 0000000000..4685ac6145 --- /dev/null +++ b/anrui-terminal/anrui-terminal-api/src/main/java/com/yxt/anrui/terminal/api/risk/otherpolicyrecordapply/flow/OtherPolicyTaskQuery.java @@ -0,0 +1,44 @@ +package com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.yxt.common.core.query.Query; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; + +@Data +public class OtherPolicyTaskQuery implements Query { + private static final long serialVersionUID = -6061453269533691015L; + + /** + * 终止、驳回、撤回 + */ + @ApiModelProperty("任务Id") + @NotBlank(message = "参数错误：taskId") + private String taskId; + /** + * 终止、驳回、撤回 + */ + @ApiModelProperty("业务sid") + @NotBlank(message = "参数错误：businessSid") + private String businessSid; + /** + * 终止、驳回 + */ + @ApiModelProperty("任务意见") + private String comment; + /** + * 终止、撤回、驳回 + */ + @ApiModelProperty("用户Sid") + private String userSid; + /** + * 终止 + */ + @ApiModelProperty("流程实例Id") + @JsonProperty("procInsId") + private String instanceId; + + +} diff --git a/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyRest.java b/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyRest.java new file mode 100644 index 0000000000..ae59ee33ae --- /dev/null +++ b/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyRest.java @@ -0,0 +1,67 @@ +package com.yxt.anrui.terminal.biz.risk.otherpolicyrecordapply; + +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.AppFinOtherPolicyApplyInitVo; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.OtherPolicyRecordApplyFeign; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.CompleteOtherPolicyDto; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyTaskQuery; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.AppFinPolicyApplyInitVo; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.PolicyRecordApplyFeign; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.CompletePolicyDto; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.PolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.PolicyTaskQuery; +import com.yxt.common.core.result.ResultBean; +import io.swagger.annotations.Api; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestMapping; + +/** + * @Author + * @Date 2023/3/25 9:39 + * @Description + */ +@Api(tags = "其他融方案") +@Controller +@RequestMapping("/risk/v1/otherpolicyrecordapply") +public class OtherPolicyRecordApplyRest implements OtherPolicyRecordApplyFeign { + + @Autowired + private OtherPolicyRecordApplyService otherPolicyRecordApplyService; + + + @Override + public ResultBean fetchDetailsBySid(String sid) { + return otherPolicyRecordApplyService.fetchDetailsBySid(sid); + } + + @Override + public ResultBean agreePolicyApplyInfo(CompleteOtherPolicyDto dto) { + return otherPolicyRecordApplyService.agreePolicyApplyInfo(dto); + } + + @Override + public ResultBean agreeCompanyToDivisionOperate(CompleteOtherPolicyDto dto) { + return otherPolicyRecordApplyService.agreeCompanyToDivisionOperate(dto); + } + + @Override + public ResultBean rejectPolicyApplyInfo(OtherPolicyTaskQuery query) { + return otherPolicyRecordApplyService.rejectPolicyApplyInfo(query); + } + + @Override + public ResultBean recallPolicyApplyInfo(OtherPolicyTaskQuery query) { + return otherPolicyRecordApplyService.recallPolicyApplyInfo(query); + } + + @Override + public ResultBean stopPolicyApplyInfo(OtherPolicyTaskQuery query) { + return otherPolicyRecordApplyService.stopPolicyApplyInfo(query); + } + + @Override + public ResultBean getFlowOperateTitle(OtherPolicyFlowableQuery query) { + return otherPolicyRecordApplyService.getFlowOperateTitle(query); + } +} diff --git a/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyService.java b/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyService.java new file mode 100644 index 0000000000..d8b7cac124 --- /dev/null +++ b/anrui-terminal/anrui-terminal-biz/src/main/java/com/yxt/anrui/terminal/biz/risk/otherpolicyrecordapply/OtherPolicyRecordApplyService.java @@ -0,0 +1,176 @@ +package com.yxt.anrui.terminal.biz.risk.otherpolicyrecordapply; + +import cn.hutool.core.bean.BeanUtil; +import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg; +import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign; +import com.yxt.anrui.portal.api.sysuser.SysUserFeign; +import com.yxt.anrui.portal.api.sysuser.SysUserVo; +import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.LoanFinOtherPolicyApplyInitVo; +import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.LoanFinOtherPolicyRecordApplyFeign; +import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.LoanOtherPolicyApplyCompleteDto; +import com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.LoanOtherPolicyApplyTaskQuery; +import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.LoanFinPolicyApplyInitVo; +import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.LoanFinPolicyRecordApplyFeign; +import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.flow.LoanFinPolicyApplyCompleteDto; +import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.flow.LoanFinPolicyApplyTaskQuery; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.AppFinOtherPolicyApplyInitVo; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.CompleteOtherPolicyDto; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.otherpolicyrecordapply.flow.OtherPolicyTaskQuery; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.AppFinPolicyApplyInitVo; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.CompletePolicyDto; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.PolicyFlowableQuery; +import com.yxt.anrui.terminal.api.risk.policyrecordapply.flow.PolicyTaskQuery; +import com.yxt.common.base.utils.StringUtils; +import com.yxt.common.core.result.ResultBean; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.Collections; +import java.util.List; + +/** + * @Author + * @Date 2023/3/25 9:40 + * @Description + */ +@Service +public class OtherPolicyRecordApplyService { + + @Autowired + private LoanFinOtherPolicyRecordApplyFeign loanFinOtherPolicyRecordApplyFeign; + + @Autowired + private SysUserFeign sysUserFeign; + + @Autowired + private SysStaffOrgFeign sysStaffOrgFeign; + + public ResultBean fetchDetailsBySid(String sid) { + ResultBean rb = ResultBean.fireFail(); + AppFinOtherPolicyApplyInitVo vo = new AppFinOtherPolicyApplyInitVo(); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.fetchDetailsBySid(sid); + if (resultBean.getSuccess()) { + LoanFinOtherPolicyApplyInitVo data = resultBean.getData(); + BeanUtil.copyProperties(data, vo); + if (StringUtils.isNotBlank(vo.getApplicant()) && StringUtils.isNotBlank(vo.getDepartment())) { + vo.setPublishInfo(vo.getDepartment() + "-" + vo.getApplicant()); + } + } + return rb.success().setData(vo); + } + + public ResultBean agreePolicyApplyInfo(CompleteOtherPolicyDto dto) { + ResultBean rb = ResultBean.fireFail(); + //根据用户sid获取staffSid + ResultBean userVoResultBean = sysUserFeign.fetchBySid(dto.getUserSid()); + if (!userVoResultBean.getSuccess()) { + return rb.setMsg(userVoResultBean.getMsg()); + } + //根据staffSid获取用户的组织全路径 + ResultBean staffOrgResultBean = sysStaffOrgFeign.getOrgByStaffSid(userVoResultBean.getData().getStaffSid()); + if (!staffOrgResultBean.getSuccess()) { + return rb.setMsg(staffOrgResultBean.getMsg()); + } + //用户的组织全路径 + String orgSidPath = staffOrgResultBean.getData().getOrgSidPath(); + LoanOtherPolicyApplyCompleteDto loanOtherPolicyApplyCompleteDto = new LoanOtherPolicyApplyCompleteDto(); + BeanUtil.copyProperties(dto, loanOtherPolicyApplyCompleteDto); + loanOtherPolicyApplyCompleteDto.setOrgSidPath(orgSidPath); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.complete(loanOtherPolicyApplyCompleteDto); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + return rb.success().setData(resultBean.getData()); + } + + public ResultBean agreeCompanyToDivisionOperate(CompleteOtherPolicyDto dto) { + ResultBean rb = ResultBean.fireFail(); + //根据用户sid获取staffSid + ResultBean userVoResultBean = sysUserFeign.fetchBySid(dto.getUserSid()); + if (!userVoResultBean.getSuccess()) { + return rb.setMsg(userVoResultBean.getMsg()); + } + //根据staffSid获取用户的组织全路径 + ResultBean staffOrgResultBean = sysStaffOrgFeign.getOrgByStaffSid(userVoResultBean.getData().getStaffSid()); + if (!staffOrgResultBean.getSuccess()) { + return rb.setMsg(staffOrgResultBean.getMsg()); + } + //用户的组织全路径 + String orgSidPath = staffOrgResultBean.getData().getOrgSidPath(); + + LoanOtherPolicyApplyCompleteDto loanOtherPolicyApplyCompleteDto = new LoanOtherPolicyApplyCompleteDto(); + BeanUtil.copyProperties(dto, loanOtherPolicyApplyCompleteDto); + loanOtherPolicyApplyCompleteDto.setOrgSidPath(orgSidPath); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.companyToDivisionOperate(loanOtherPolicyApplyCompleteDto); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + return rb.success().setData(resultBean.getData()); + } + + public ResultBean rejectPolicyApplyInfo(OtherPolicyTaskQuery query) { + ResultBean rb = ResultBean.fireFail(); + LoanOtherPolicyApplyTaskQuery taskQuery = new LoanOtherPolicyApplyTaskQuery(); + BeanUtil.copyProperties(query, taskQuery); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.taskReject(taskQuery); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + return rb.success().setData(resultBean.getData()); + } + + public ResultBean recallPolicyApplyInfo(OtherPolicyTaskQuery query) { + ResultBean rb = ResultBean.fireFail(); + LoanOtherPolicyApplyTaskQuery taskQuery = new LoanOtherPolicyApplyTaskQuery(); + BeanUtil.copyProperties(query, taskQuery); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.revokeProcess(taskQuery); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + return rb.success().setData(resultBean.getData()); + } + + public ResultBean stopPolicyApplyInfo(OtherPolicyTaskQuery query) { + ResultBean rb = ResultBean.fireFail(); + LoanOtherPolicyApplyTaskQuery taskQuery = new LoanOtherPolicyApplyTaskQuery(); + BeanUtil.copyProperties(query, taskQuery); + ResultBean resultBean = loanFinOtherPolicyRecordApplyFeign.breakProcess(taskQuery); + if (!resultBean.getSuccess()) { + return rb.setMsg(resultBean.getMsg()); + } + return rb.success().setData(resultBean.getData()); + } + + public ResultBean getFlowOperateTitle(OtherPolicyFlowableQuery query) { + ResultBean rb = ResultBean.fireFail(); + //0 上一环节 1下一环节 + int next = query.getNext(); + com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.GetNodeQuery getNodeQuery = new + com.yxt.anrui.riskcenter.api.loanfinotherpolicyrecordapply.flow.GetNodeQuery(); + BeanUtil.copyProperties(query, getNodeQuery); + String data = ""; + if (next == 0) { + ResultBean> getPreviousNodesForReject = loanFinOtherPolicyRecordApplyFeign.getPreviousNodesForReject(getNodeQuery); + if (getPreviousNodesForReject.getSuccess()) { + getPreviousNodesForReject.getData().removeAll(Collections.singleton(null)); + data = getPreviousNodesForReject.getData().get(0).getName(); + } else { + return rb.setMsg(getPreviousNodesForReject.getMsg()); + } + } else if (next == 1) { + ResultBean> getNextNodesForSubmit = loanFinOtherPolicyRecordApplyFeign.getNextNodesForSubmit(getNodeQuery); + if (getNextNodesForSubmit.getSuccess()) { + getNextNodesForSubmit.getData().removeAll(Collections.singleton(null)); + data = getNextNodesForSubmit.getData().get(0).getName(); + } else { + return rb.setMsg(getNextNodesForSubmit.getMsg()); + } + } else { + return rb.setMsg("参数错误：next"); + } + return rb.success().setData(data); + } + + +}