Browse Source

Merge remote-tracking branch 'origin/master'

master
dimengzhe 2 years ago
parent
commit
30c2a8cb80
  1. 28
      anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributorapply/BaseDistributorApplyService.java
  2. 4
      anrui-buscenter/anrui-buscenter-api/src/main/java/com/yxt/anrui/buscenter/api/bussalesorderloancontract/BusSalesOrderLoancontractFeign.java
  3. 5
      anrui-buscenter/anrui-buscenter-api/src/main/java/com/yxt/anrui/buscenter/api/bussalesorderloancontract/BusSalesOrderLoancontractFeignFallback.java
  4. 3
      anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractMapper.java
  5. 5
      anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractRest.java
  6. 6
      anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractService.java
  7. 24
      anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/flow2/FlowDelegateQuery.java
  8. 7
      anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/flow2/FlowFeign.java
  9. 20
      anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow2/FlowRest.java
  10. 107
      anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow2/FlowService.java
  11. 14
      anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java
  12. 2
      anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitprep/LoanHomevisitPrepMapper.xml
  13. 4
      anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitprep/LoanHomevisitPrepService.java

28
anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributorapply/BaseDistributorApplyService.java

@ -45,6 +45,7 @@ import com.yxt.anrui.base.biz.basedistributorapplyappendix.BaseDistributorApplyA
import com.yxt.anrui.flowable.api.flow.FlowProcessMapQuery; import com.yxt.anrui.flowable.api.flow.FlowProcessMapQuery;
import com.yxt.anrui.flowable.api.flow.FlowableFeign; import com.yxt.anrui.flowable.api.flow.FlowableFeign;
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo;
import com.yxt.anrui.flowable.api.flow2.FlowDelegateQuery;
import com.yxt.anrui.flowable.api.flow2.FlowFeign; import com.yxt.anrui.flowable.api.flow2.FlowFeign;
import com.yxt.anrui.flowable.api.flowtask.DelegateQuery; import com.yxt.anrui.flowable.api.flowtask.DelegateQuery;
import com.yxt.anrui.flowable.api.flowtask.FlowTaskFeign; import com.yxt.anrui.flowable.api.flowtask.FlowTaskFeign;
@ -2031,32 +2032,9 @@ public class BaseDistributorApplyService extends MybatisBaseService<BaseDistribu
*/ */
public ResultBean delegate(DistributorDelegateQuery distributorDelegateQuery) { public ResultBean delegate(DistributorDelegateQuery distributorDelegateQuery) {
ResultBean rb = ResultBean.fireFail(); ResultBean rb = ResultBean.fireFail();
DelegateQuery delegateQuery = new DelegateQuery(); FlowDelegateQuery delegateQuery = new FlowDelegateQuery();
BeanUtil.copyProperties(distributorDelegateQuery, delegateQuery); BeanUtil.copyProperties(distributorDelegateQuery, delegateQuery);
ResultBean delegate = flowTaskFeign.delegate(delegateQuery); flowFeign.delegate(delegateQuery);
String userSid = distributorDelegateQuery.getUserSid();
String assignee = distributorDelegateQuery.getAssignee();
String instanceId = distributorDelegateQuery.getInstanceId();
String views = "";
if (StringUtils.isNotBlank(distributorDelegateQuery.getViews())) {
views = distributorDelegateQuery.getViews();
}
ResultBean<SysUserVo> userVoResultBean1 = sysUserFeign.fetchBySid(userSid);
String userName = "";
if (userVoResultBean1.getData() != null) {
userName = userVoResultBean1.getData().getName();
}
ResultBean<SysUserVo> userVoResultBean2 = sysUserFeign.fetchBySid(assignee);
ProcessCommentDto processCommentDto = new ProcessCommentDto();
processCommentDto.setReviewerSid(userSid);
if (userVoResultBean2.getData() != null) {
String changeName = userVoResultBean2.getData().getName();
processCommentDto.setReviewer(userName);
processCommentDto.setContent(userName + "加签给" + changeName + ":" + views);
}
processCommentDto.setTime(new Date());
processCommentDto.setProcessId(instanceId);
processCommentFeign.save(processCommentDto);
return rb.success(); return rb.success();
} }
} }

4
anrui-buscenter/anrui-buscenter-api/src/main/java/com/yxt/anrui/buscenter/api/bussalesorderloancontract/BusSalesOrderLoancontractFeign.java

@ -105,4 +105,8 @@ public interface BusSalesOrderLoancontractFeign {
@ResponseBody @ResponseBody
ResultBean pushOtherReceivable(@RequestBody LoanOtherReceivablePush loanOtherReceivablePush); ResultBean pushOtherReceivable(@RequestBody LoanOtherReceivablePush loanOtherReceivablePush);
@ApiOperation("根据销售订单sid查询")
@GetMapping("/fetchAllByOrderSid/{orderSid}")
@ResponseBody
public ResultBean<List<BusSalesOrderLoancontract>> fetchAllByOrderSid(@PathVariable("orderSid") String sid);
} }

5
anrui-buscenter/anrui-buscenter-api/src/main/java/com/yxt/anrui/buscenter/api/bussalesorderloancontract/BusSalesOrderLoancontractFeignFallback.java

@ -99,4 +99,9 @@ public class BusSalesOrderLoancontractFeignFallback implements BusSalesOrderLoan
public ResultBean pushOtherReceivable(LoanOtherReceivablePush loanOtherReceivablePush) { public ResultBean pushOtherReceivable(LoanOtherReceivablePush loanOtherReceivablePush) {
return null; return null;
} }
@Override
public ResultBean<List<BusSalesOrderLoancontract>> fetchAllByOrderSid(String sid) {
return null;
}
} }

3
anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractMapper.java

@ -77,4 +77,7 @@ public interface BusSalesOrderLoancontractMapper extends BaseMapper<BusSalesOrde
@Update("update bus_sales_order_loancontract set bankContractNo=#{bankContractNo},busNo='305',busName='放款资料审核' where sid=#{loanContractSid}") @Update("update bus_sales_order_loancontract set bankContractNo=#{bankContractNo},busNo='305',busName='放款资料审核' where sid=#{loanContractSid}")
void updateBankConAndBusNo(@Param("loanContractSid") String loanContractSid,@Param("bankContractNo") String bankContractNo); void updateBankConAndBusNo(@Param("loanContractSid") String loanContractSid,@Param("bankContractNo") String bankContractNo);
@Select("select * from bus_sales_order_loancontract where salesOrderSid = #{sid}")
List<BusSalesOrderLoancontract> fetchAllByOrderSid(String sid);
} }

5
anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractRest.java

@ -128,4 +128,9 @@ public class BusSalesOrderLoancontractRest implements BusSalesOrderLoancontractF
public ResultBean pushOtherReceivable(LoanOtherReceivablePush loanOtherReceivablePush) { public ResultBean pushOtherReceivable(LoanOtherReceivablePush loanOtherReceivablePush) {
return busSalesOrderLoancontractService.pushOtherReceivable(loanOtherReceivablePush); return busSalesOrderLoancontractService.pushOtherReceivable(loanOtherReceivablePush);
} }
@Override
public ResultBean<List<BusSalesOrderLoancontract>> fetchAllByOrderSid(String sid) {
return busSalesOrderLoancontractService.fetchAllByOrderSid(sid);
}
} }

6
anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorderloancontract/BusSalesOrderLoancontractService.java

@ -479,4 +479,10 @@ public class BusSalesOrderLoancontractService extends MybatisBaseService<BusSale
} }
return rb.success(); return rb.success();
} }
public ResultBean<List<BusSalesOrderLoancontract>> fetchAllByOrderSid(String sid) {
ResultBean rb = ResultBean.fireFail();
List<BusSalesOrderLoancontract> busSalesOrderLoancontracts = baseMapper.fetchAllByOrderSid(sid);
return rb.success().setData(busSalesOrderLoancontracts);
}
} }

24
anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/flow2/FlowDelegateQuery.java

@ -0,0 +1,24 @@
package com.yxt.anrui.flowable.api.flow2;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author Administrator
* @description
* @date 2023/10/8 15:58
*/
@Data
public class FlowDelegateQuery {
@ApiModelProperty
private String userSid;
@ApiModelProperty("流程实例id")
// @JsonProperty("procInsId")
private String instanceId;
@ApiModelProperty("任务Id")
private String taskId;
@ApiModelProperty("审批人sid")
private String assignee;
@ApiModelProperty("填写意见")
private String views;
}

7
anrui-flowable/anrui-flowable-api/src/main/java/com/yxt/anrui/flowable/api/flow2/FlowFeign.java

@ -3,7 +3,6 @@ package com.yxt.anrui.flowable.api.flow2;
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo;
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.result.ResultBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
@ -41,4 +40,10 @@ public interface FlowFeign {
@GetMapping(value = "/getMessageReminder") @GetMapping(value = "/getMessageReminder")
@ResponseBody @ResponseBody
ResultBean<FlowableMessageVo> getMessageReminder(@RequestParam("proDefId") String proDefId, @RequestParam("proInstId") String proInstId); ResultBean<FlowableMessageVo> getMessageReminder(@RequestParam("proDefId") String proDefId, @RequestParam("proInstId") String proInstId);
@ApiOperation(value = "加签")
@PostMapping(value = "/delegate")
public ResultBean delegate(@RequestBody FlowDelegateQuery flowDelegateQuery);
} }

20
anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow2/FlowRest.java

@ -1,34 +1,21 @@
package com.yxt.anrui.flowable.biz.flow2; package com.yxt.anrui.flowable.biz.flow2;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo;
import com.yxt.anrui.flowable.api.flow2.FlowDelegateQuery;
import com.yxt.anrui.flowable.api.flow2.FlowFeign; import com.yxt.anrui.flowable.api.flow2.FlowFeign;
import com.yxt.anrui.flowable.api.flow2.FlowableMessageVo; import com.yxt.anrui.flowable.api.flow2.FlowableMessageVo;
import com.yxt.anrui.flowable.api.flowtask.FlowTaskVo;
import com.yxt.anrui.flowable.biz.process.ProcessService;
import com.yxt.anrui.flowable.feign.MessageFeign;
import com.yxt.anrui.flowable.feign.form.MessageFlowVo;
import com.yxt.anrui.flowable.feign.form.MessageFlowableQuery;
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.anrui.portal.api.sysflowcc.SysFlowccFeign;
import com.yxt.anrui.portal.api.sysflowcc.SysFlowccVo;
import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
import com.yxt.anrui.portal.api.sysuser.SysUserVo;
import com.yxt.anrui.portal.api.sysuser.UserByRolesAndOrgQuery;
import com.yxt.common.base.utils.StringUtils; import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.result.ResultBean;
import org.apache.tomcat.util.threads.ThreadPoolExecutor; import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import org.flowable.engine.HistoryService;
import org.flowable.task.api.history.HistoricTaskInstance;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.util.Arrays;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -111,5 +98,10 @@ public class FlowRest implements FlowFeign {
return flowService.getMessageReminder(proDefId,proInstId); return flowService.getMessageReminder(proDefId,proInstId);
} }
@Override
public ResultBean delegate(FlowDelegateQuery flowDelegateQuery) {
return flowService.delegate(flowDelegateQuery);
}
} }

107
anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow2/FlowService.java

@ -1,31 +1,27 @@
package com.yxt.anrui.flowable.biz.flow2; package com.yxt.anrui.flowable.biz.flow2;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.map.MapUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.yxt.anrui.flowable.api.flow.Flowable; import com.yxt.anrui.flowable.api.flow.Flowable;
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo;
import com.yxt.anrui.flowable.api.flow2.FlowDelegateQuery;
import com.yxt.anrui.flowable.api.flow2.FlowableMessageVo; import com.yxt.anrui.flowable.api.flow2.FlowableMessageVo;
import com.yxt.anrui.flowable.api.flowcomment.FlowComment; import com.yxt.anrui.flowable.api.flowcomment.FlowComment;
import com.yxt.anrui.flowable.api.flowtask.FlowTask; import com.yxt.anrui.flowable.api.flowtask.DelegateQuery;
import com.yxt.anrui.flowable.api.flowtask.FlowTaskVo;
import com.yxt.anrui.flowable.api.flowtask.LatestTaskVo; import com.yxt.anrui.flowable.api.flowtask.LatestTaskVo;
import com.yxt.anrui.flowable.api.processcomment.ProcessCommentDto; import com.yxt.anrui.flowable.api.processcomment.ProcessCommentDto;
import com.yxt.anrui.flowable.api.utils.ProcDefEnum; import com.yxt.anrui.flowable.api.utils.ProcDefEnum;
import com.yxt.anrui.flowable.biz.flowtask.FlowTaskMapper;
import com.yxt.anrui.flowable.biz.flowtask.FlowTaskService; import com.yxt.anrui.flowable.biz.flowtask.FlowTaskService;
import com.yxt.anrui.flowable.biz.process.ExpressionCmd; import com.yxt.anrui.flowable.biz.process.ExpressionCmd;
import com.yxt.anrui.flowable.biz.process.ProcessService; import com.yxt.anrui.flowable.biz.process.ProcessService;
import com.yxt.anrui.flowable.biz.processcomment.ProcessCommentService; import com.yxt.anrui.flowable.biz.processcomment.ProcessCommentService;
import com.yxt.anrui.flowable.common.ProcessConstants; import com.yxt.anrui.flowable.common.ProcessConstants;
import com.yxt.anrui.flowable.exception.CustomException;
import com.yxt.anrui.flowable.feign.MessageFeign; import com.yxt.anrui.flowable.feign.MessageFeign;
import com.yxt.anrui.flowable.feign.form.MessageFlowVo; import com.yxt.anrui.flowable.feign.form.MessageFlowVo;
import com.yxt.anrui.flowable.feign.form.MessageFlowableQuery; import com.yxt.anrui.flowable.feign.form.MessageFlowableQuery;
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.anrui.flowable.utils.FlowableUtils;
import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigFeign; import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigFeign;
import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigQuery; import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigQuery;
import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigVvo; import com.yxt.anrui.portal.api.sysflowableconfig.SysFlowableConfigVvo;
@ -37,16 +33,10 @@ import com.yxt.common.base.utils.StringUtils;
import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.result.ResultBean;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.flowable.bpmn.model.*; import org.flowable.bpmn.model.*;
import org.flowable.bpmn.model.Process;
import org.flowable.common.engine.api.FlowableException;
import org.flowable.common.engine.api.FlowableObjectNotFoundException;
import org.flowable.common.engine.impl.identity.Authentication; import org.flowable.common.engine.impl.identity.Authentication;
import org.flowable.engine.*; import org.flowable.engine.*;
import org.flowable.engine.delegate.DelegateExecution;
import org.flowable.engine.history.HistoricActivityInstance;
import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl; import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl;
import org.flowable.engine.repository.ProcessDefinition; import org.flowable.engine.repository.ProcessDefinition;
import org.flowable.engine.runtime.Execution;
import org.flowable.engine.runtime.ProcessInstance; import org.flowable.engine.runtime.ProcessInstance;
import org.flowable.task.api.DelegationState; import org.flowable.task.api.DelegationState;
import org.flowable.task.api.Task; import org.flowable.task.api.Task;
@ -711,8 +701,8 @@ public class FlowService extends MybatisBaseService<FlowMapper, Flowable> {
String assignee = (String) processVariables.get("assignee"); String assignee = (String) processVariables.get("assignee");
ResultBean<SysUserVo> stringResultBean = sysUserFeign.fetchBySid(assignee); ResultBean<SysUserVo> stringResultBean = sysUserFeign.fetchBySid(assignee);
String assigneeName = ""; String assigneeName = "";
if(stringResultBean.getData() != null){ if (stringResultBean.getData() != null) {
assigneeName= stringResultBean.getData().getName(); assigneeName = stringResultBean.getData().getName();
} }
Map<String, Object> app = new HashMap<>(); Map<String, Object> app = new HashMap<>();
@ -722,7 +712,7 @@ public class FlowService extends MybatisBaseService<FlowMapper, Flowable> {
log.info("抄送方法-historicTaskInstance:{}", JSONObject.toJSONString(historicTaskInstance)); log.info("抄送方法-historicTaskInstance:{}", JSONObject.toJSONString(historicTaskInstance));
mfq.setAppMap(app); mfq.setAppMap(app);
mfq.setBusinessSid(bv.getBusinessSid()); mfq.setBusinessSid(bv.getBusinessSid());
mfq.setMsgContent(assigneeName+"抄送的流程审批,请查看"); mfq.setMsgContent(assigneeName + "抄送的流程审批,请查看");
// act_re_procdef // act_re_procdef
Map<String, String> process = processService.getProcessDefByDefId(historicTaskInstance.getProcessDefinitionId()); Map<String, String> process = processService.getProcessDefByDefId(historicTaskInstance.getProcessDefinitionId());
log.info("抄送成功-process:{}", process); log.info("抄送成功-process:{}", process);
@ -770,7 +760,92 @@ public class FlowService extends MybatisBaseService<FlowMapper, Flowable> {
public ResultBean<FlowableMessageVo> getMessageReminder(String proDefId, String proInstId) { public ResultBean<FlowableMessageVo> getMessageReminder(String proDefId, String proInstId) {
ResultBean<FlowableMessageVo> rb = ResultBean.fireFail(); ResultBean<FlowableMessageVo> rb = ResultBean.fireFail();
FlowableMessageVo flowableMessageVo = baseMapper.getMessageReminder(proDefId,proInstId); FlowableMessageVo flowableMessageVo = baseMapper.getMessageReminder(proDefId, proInstId);
return rb.success().setData(flowableMessageVo); return rb.success().setData(flowableMessageVo);
} }
public ResultBean delegate(FlowDelegateQuery flowDelegateQuery) {
ResultBean rb = ResultBean.fireFail();
DelegateQuery delegateQuery = new DelegateQuery();
BeanUtil.copyProperties(flowDelegateQuery, delegateQuery);
ResultBean delegate = flowTaskService.delegate(delegateQuery);
String userSid = flowDelegateQuery.getUserSid();
String assigneeSid = flowDelegateQuery.getAssignee();
String instanceId = flowDelegateQuery.getInstanceId();
String views = "";
if (StringUtils.isNotBlank(flowDelegateQuery.getViews())) {
views = flowDelegateQuery.getViews();
}
ResultBean<SysUserVo> userVoResultBean1 = sysUserFeign.fetchBySid(userSid);
String userName = "";
if (userVoResultBean1.getData() != null) {
userName = userVoResultBean1.getData().getName();
}
ResultBean<SysUserVo> userVoResultBean2 = sysUserFeign.fetchBySid(assigneeSid);
ProcessCommentDto processCommentDto = new ProcessCommentDto();
processCommentDto.setReviewerSid(userSid);
if (userVoResultBean2.getData() != null) {
String changeName = userVoResultBean2.getData().getName();
processCommentDto.setReviewer(userName);
processCommentDto.setContent(userName + "加签给" + changeName + ":" + views);
}
processCommentDto.setTime(new Date());
processCommentDto.setProcessId(instanceId);
processCommentService.saveOrUpdateDto(processCommentDto);
//加签内容推送至待阅
HistoricTaskInstance historicTaskInstance = historyService.createHistoricTaskInstanceQuery()
.includeProcessVariables().taskId(delegateQuery.getTaskId()).singleResult();
if (historicTaskInstance == null) {
return rb.setMsg("分享失败!");
}
MessageFlowVo messageFlowVo = new MessageFlowVo();
String procDefId = historicTaskInstance.getProcessDefinitionId();
String procInsId = historicTaskInstance.getProcessInstanceId();
String nodeState = historicTaskInstance.getName();
String taskDefKey = historicTaskInstance.getTaskDefinitionKey();
messageFlowVo.setProcDefId(procDefId);
messageFlowVo.setTaskId(delegateQuery.getTaskId());
messageFlowVo.setNodeState(nodeState);
messageFlowVo.setProcInsId(procInsId);
messageFlowVo.setTaskDefKey(taskDefKey);
Map<String, Object> processVariables = historicTaskInstance.getProcessVariables();
MessageFlowableQuery mfq = new MessageFlowableQuery();
mfq.setUfVo(messageFlowVo);
String createrOrgPath = (String) processVariables.get("createrOrgPath");
if (historicTaskInstance == null) {
return rb.setMsg("分享失败!");
}
//
String assignee = (String) processVariables.get("assignee");
ResultBean<SysUserVo> stringResultBean = sysUserFeign.fetchBySid(assignee);
String assigneeName = "";
if (stringResultBean.getData() != null) {
assigneeName = stringResultBean.getData().getName();
}
Map<String, Object> app = new HashMap<>();
if (processVariables.get("app") != null) {
app = (Map<String, Object>) processVariables.get("app");
}
mfq.setAppMap(app);
String businessSid = (String) processVariables.get("businessSid");
mfq.setBusinessSid(businessSid);
mfq.setMsgContent(userName + "分享的流程审批,请查看");
// act_re_procdef
Map<String, String> process = processService.getProcessDefByDefId(historicTaskInstance.getProcessDefinitionId());
mfq.setModuleName(process.get("NAME_"));
if (processVariables.containsKey("orderNames")) {
mfq.setMsgTitle(processVariables.get("orderNames").toString());
} else {
mfq.setMsgTitle(process.get("NAME_"));
}
mfq.setUserSids(assigneeSid);
mfq.setOrgPath(createrOrgPath);
mfq.setUserSid(assignee);
mfq.setApplicationName(assigneeName);
ResultBean<String> resultBean = messageFeign.pushMessageShare(mfq);
return rb.success();
}
} }

14
anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitfileexamine/LoanHomevisitFileexamineService.java

@ -30,10 +30,12 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerDetailsVo; import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerDetailsVo;
import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerFeign; import com.yxt.anrui.buscenter.api.bussalesorderborrower.BusSalesOrderBorrowerFeign;
import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontract;
import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontractDetailsVo; import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontractDetailsVo;
import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontractFeign; import com.yxt.anrui.buscenter.api.bussalesorderloancontract.BusSalesOrderLoancontractFeign;
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery; import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery;
import com.yxt.anrui.portal.api.sysuser.SysUserFeign; import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
import com.yxt.anrui.riskcenter.api.loancapitalcreditresult.LoanCapitalCreditResultDto;
import com.yxt.anrui.riskcenter.api.loanhomevisitfileexamine.*; import com.yxt.anrui.riskcenter.api.loanhomevisitfileexamine.*;
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvestigate; import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvestigate;
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvestigateDetailsVo; import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvestigateDetailsVo;
@ -42,6 +44,7 @@ import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigate.LoanHomevisitInvest
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanAttachTypeEnum; import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanAttachTypeEnum;
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDetailsVo; import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDetailsVo;
import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDto; import com.yxt.anrui.riskcenter.api.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileDto;
import com.yxt.anrui.riskcenter.biz.loancapitalcreditresult.LoanCapitalCreditResultService;
import com.yxt.anrui.riskcenter.biz.loanhomevisitinvestigate.LoanHomevisitInvestigateService; import com.yxt.anrui.riskcenter.biz.loanhomevisitinvestigate.LoanHomevisitInvestigateService;
import com.yxt.anrui.riskcenter.biz.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileService; import com.yxt.anrui.riskcenter.biz.loanhomevisitinvestigatefile.LoanHomevisitInvestigateFileService;
import com.yxt.common.base.config.component.FileUploadComponent; import com.yxt.common.base.config.component.FileUploadComponent;
@ -81,6 +84,8 @@ public class LoanHomevisitFileexamineService extends MybatisBaseService<LoanHome
@Autowired @Autowired
private LoanHomevisitInvestigateFileService loanHomevisitInvestigateFileService; private LoanHomevisitInvestigateFileService loanHomevisitInvestigateFileService;
@Autowired @Autowired
private LoanCapitalCreditResultService loanCapitalCreditResultService;
@Autowired
private LoanHomevisitInvestigateService loanHomevisitInvestigateService; private LoanHomevisitInvestigateService loanHomevisitInvestigateService;
@Autowired @Autowired
private BusSalesOrderLoancontractFeign busSalesOrderLoancontractFeign; private BusSalesOrderLoancontractFeign busSalesOrderLoancontractFeign;
@ -399,6 +404,15 @@ public class LoanHomevisitFileexamineService extends MybatisBaseService<LoanHome
} }
} }
this.updateByDto(dto); this.updateByDto(dto);
List<BusSalesOrderLoancontract> busSalesOrderLoancontracts = busSalesOrderLoancontractFeign.fetchAllByOrderSid(dto.getSaleOrderSid()).getData();
if (busSalesOrderLoancontracts != null){
for (BusSalesOrderLoancontract busSalesOrderLoancontract : busSalesOrderLoancontracts) {
LoanCapitalCreditResultDto loanCapitalCreditResultDto = new LoanCapitalCreditResultDto();
loanCapitalCreditResultDto.setSaleOrderSid(dto.getSaleOrderSid());
loanCapitalCreditResultDto.setLoanContractSid(busSalesOrderLoancontract.getSid());
loanCapitalCreditResultService.saveOrUpdateDto(loanCapitalCreditResultDto);
}
}
} }
public void insertByDto(LoanHomevisitFileexamineDto dto) { public void insertByDto(LoanHomevisitFileexamineDto dto) {

2
anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitprep/LoanHomevisitPrepMapper.xml

@ -54,7 +54,7 @@
bo.`staffName`, bo.`staffName`,
bo.`contractNo`, bo.`contractNo`,
bb.`vehCount`, bb.`vehCount`,
bb.borrowerSid, lp.saleOrderBorrowerSid AS borrowerSid,
bb.`borrowerName`, bb.`borrowerName`,
bb.`mobile`, bb.`mobile`,
bb.`bankName`, bb.`bankName`,

4
anrui-riskcenter/anrui-riskcenter-biz/src/main/java/com/yxt/anrui/riskcenter/biz/loanhomevisitprep/LoanHomevisitPrepService.java

@ -238,7 +238,7 @@ public class LoanHomevisitPrepService extends MybatisBaseService<LoanHomevisitPr
for (BusSalesOrderVehicle busSalesOrderVehicle : busSalesOrderVehicles) { for (BusSalesOrderVehicle busSalesOrderVehicle : busSalesOrderVehicles) {
BusSalesOrderLoancontractDto busSalesOrderLoancontractDto = new BusSalesOrderLoancontractDto(); BusSalesOrderLoancontractDto busSalesOrderLoancontractDto = new BusSalesOrderLoancontractDto();
busSalesOrderLoancontractDto.setSalesOrderSid(loanHomevisitPrepVo.getSaleOrderSid()); busSalesOrderLoancontractDto.setSalesOrderSid(loanHomevisitPrepVo.getSaleOrderSid());
busSalesOrderLoancontractDto.setBorrowerSid(loanHomevisitPrepVo.getSid()); busSalesOrderLoancontractDto.setBorrowerSid(loanHomevisitPrepVo.getBorrowerSid());
busSalesOrderLoancontractDto.setBorrowerName(loanHomevisitPrepVo.getBorrowerName()); busSalesOrderLoancontractDto.setBorrowerName(loanHomevisitPrepVo.getBorrowerName());
busSalesOrderLoancontractDto.setVehCount(loanHomevisitPrepVo.getVehCount()); busSalesOrderLoancontractDto.setVehCount(loanHomevisitPrepVo.getVehCount());
BusSalesOrder busSalesOrder = busSalesOrderFeign.fetchBySid(loanHomevisitPrepVo.getSaleOrderSid()).getData(); BusSalesOrder busSalesOrder = busSalesOrderFeign.fetchBySid(loanHomevisitPrepVo.getSaleOrderSid()).getData();
@ -255,7 +255,7 @@ public class LoanHomevisitPrepService extends MybatisBaseService<LoanHomevisitPr
} else if (conSetUpKey.equals("002")) {//一人一合同 } else if (conSetUpKey.equals("002")) {//一人一合同
BusSalesOrderLoancontractDto busSalesOrderLoancontractDto = new BusSalesOrderLoancontractDto(); BusSalesOrderLoancontractDto busSalesOrderLoancontractDto = new BusSalesOrderLoancontractDto();
busSalesOrderLoancontractDto.setSalesOrderSid(loanHomevisitPrepVo.getSaleOrderSid()); busSalesOrderLoancontractDto.setSalesOrderSid(loanHomevisitPrepVo.getSaleOrderSid());
busSalesOrderLoancontractDto.setBorrowerSid(loanHomevisitPrepVo.getSid()); busSalesOrderLoancontractDto.setBorrowerSid(loanHomevisitPrepVo.getBorrowerSid());
busSalesOrderLoancontractDto.setBorrowerName(loanHomevisitPrepVo.getBorrowerName()); busSalesOrderLoancontractDto.setBorrowerName(loanHomevisitPrepVo.getBorrowerName());
busSalesOrderLoancontractDto.setVehCount(loanHomevisitPrepVo.getVehCount()); busSalesOrderLoancontractDto.setVehCount(loanHomevisitPrepVo.getVehCount());
BusSalesOrder busSalesOrder = busSalesOrderFeign.fetchBySid(loanHomevisitPrepVo.getSaleOrderSid()).getData(); BusSalesOrder busSalesOrder = busSalesOrderFeign.fetchBySid(loanHomevisitPrepVo.getSaleOrderSid()).getData();

Loading…
Cancel
Save