|
|
|
@ -1,19 +1,13 @@ |
|
|
|
package com.yxt.anrui.riskcenter.biz.loanbuckleapply; |
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil; |
|
|
|
import cn.hutool.core.date.DateUtil; |
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.google.common.util.concurrent.ThreadFactoryBuilder; |
|
|
|
import com.yxt.anrui.base.api.basedistributorapply.BaseDistributorApplyFeign; |
|
|
|
import com.yxt.anrui.base.api.basedistributorapply.BaseSalesManger; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTemp; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempFeign; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempVo; |
|
|
|
import com.yxt.anrui.fin.api.fincompanyinvoicing.FinCompanyInvoicingDetailsVo; |
|
|
|
import com.yxt.anrui.fin.api.fincompanyinvoicing.FinCompanyInvoicingDto; |
|
|
|
import com.yxt.anrui.fin.api.fincompanyinvoicing.FinCompanyInvoicingFeign; |
|
|
|
import com.yxt.anrui.base.common.enums.BillTypeEnum; |
|
|
|
import com.yxt.anrui.base.common.utils.Rule; |
|
|
|
import com.yxt.anrui.base.common.utils.domain.BillNo; |
|
|
|
import com.yxt.anrui.flowable.api.flow.FlowableFeign; |
|
|
|
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; |
|
|
|
import com.yxt.anrui.flowable.api.flow2.FlowDelegateQuery; |
|
|
|
@ -24,25 +18,26 @@ import com.yxt.anrui.flowable.api.flowtask.LatestTaskVo; |
|
|
|
import com.yxt.anrui.flowable.api.utils.ProcDefEnum; |
|
|
|
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; |
|
|
|
import com.yxt.anrui.portal.api.sysorganization.*; |
|
|
|
import com.yxt.anrui.portal.api.sysparameter.SysParameterEnum; |
|
|
|
import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg; |
|
|
|
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.SysUserFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysuser.SysUserVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapply.LoanBuckleApply; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecord.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecord.app.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecord.flow.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecordstaff.AppStaffVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecordstaff.LoanCustomerRecordStaff; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecordstaff.LoanCustomerRecordStaffDto; |
|
|
|
import com.yxt.anrui.riskcenter.api.loancustomerrecordstaff.LoanCustomerRecordStaffVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapply.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapply.app.AppBuckleDetailsVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapply.app.AppRecordVo; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapply.flow.*; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanbuckleapplyrecord.LoanBuckleApplyRecord; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfile.LoanFile; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfile.LoanFileEnum; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loancustomerrecordstaff.LoanCustomerRecordStaffService; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfinotherPolicy.LoanFinOtherPolicy; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfinpolicy.LoanFinPolicy; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanfinpolicyrecordapply.LoanFinPolicyRecordApply; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrepaymenthistory.LoanRepaymentHistory; |
|
|
|
import com.yxt.anrui.riskcenter.api.loanrepaymenthistory.LoanRepaymentHistoryRecordVo; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanbuckleapplyrecord.LoanBuckleApplyRecordService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanfile.LoanFileService; |
|
|
|
import com.yxt.anrui.riskcenter.biz.loanrepaymenthistory.LoanRepaymentHistoryService; |
|
|
|
import com.yxt.common.base.config.component.DocPdfComponent; |
|
|
|
import com.yxt.common.base.config.component.FileUploadComponent; |
|
|
|
import com.yxt.common.base.service.MybatisBaseService; |
|
|
|
@ -71,5 +66,826 @@ import java.util.stream.Collectors; |
|
|
|
@Service |
|
|
|
public class LoanBuckleApplyService extends MybatisBaseService<LoanBuckleApplyMapper, LoanBuckleApply> { |
|
|
|
|
|
|
|
@Autowired |
|
|
|
private MessageFeign messageFeign; |
|
|
|
@Autowired |
|
|
|
private SysUserFeign sysUserFeign; |
|
|
|
@Autowired |
|
|
|
private LoanRepaymentHistoryService loanRepaymentHistoryService; |
|
|
|
@Autowired |
|
|
|
private SysStaffOrgFeign sysStaffOrgFeign; |
|
|
|
@Autowired |
|
|
|
private SysOrganizationFeign sysOrganizationFeign; |
|
|
|
@Autowired |
|
|
|
private LoanBuckleApplyRecordService loanBuckleApplyRecordService; |
|
|
|
@Autowired |
|
|
|
private LoanFileService loanFileService; |
|
|
|
@Autowired |
|
|
|
private FileUploadComponent fileUploadComponent; |
|
|
|
@Autowired |
|
|
|
private FlowFeign flowFeign; |
|
|
|
@Autowired |
|
|
|
private FlowTaskFeign flowTaskFeign; |
|
|
|
@Autowired |
|
|
|
private FlowableFeign flowableFeign; |
|
|
|
|
|
|
|
public PagerVo<LoanBuckleApplyVo> listPage(PagerQuery<LoanBuckleApplyQuery> pq) { |
|
|
|
IPage<LoanBuckleApply> page = PagerUtil.queryToPage(pq); |
|
|
|
LoanBuckleApplyQuery pagerQuery = pq.getParams(); |
|
|
|
QueryWrapper<LoanBuckleApply> qw = new QueryWrapper<>(); |
|
|
|
//=======================
|
|
|
|
PrivilegeQuery privilegeQuery = new PrivilegeQuery(); |
|
|
|
privilegeQuery.setOrgPath(pagerQuery.getOrgPath()); |
|
|
|
privilegeQuery.setMenuSid(pagerQuery.getMenuSid()); |
|
|
|
privilegeQuery.setMenuUrl(pagerQuery.getMenuUrl()); |
|
|
|
privilegeQuery.setUserSid(pagerQuery.getUserSid()); |
|
|
|
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery); |
|
|
|
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) { |
|
|
|
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
|
|
|
|
String orgSidPath = pagerQuery.getOrgPath(); |
|
|
|
orgSidPath = orgSidPath + "/"; |
|
|
|
int i1 = orgSidPath.indexOf("/"); |
|
|
|
int i2 = orgSidPath.indexOf("/", i1 + 1); |
|
|
|
int i3 = orgSidPath.indexOf("/", i2 + 1); |
|
|
|
int i4 = orgSidPath.indexOf("/", i3 + 1); |
|
|
|
String orgLevelKey = defaultIdReltBean.getData(); |
|
|
|
if ("1".equals(orgLevelKey)) { |
|
|
|
orgSidPath = orgSidPath.substring(0, i1); |
|
|
|
qw.like("orgSidPath", orgSidPath); |
|
|
|
} else if ("2".equals(orgLevelKey)) { |
|
|
|
orgSidPath = orgSidPath.substring(0, i2); |
|
|
|
qw.like("orgSidPath", orgSidPath); |
|
|
|
} else if ("3".equals(orgLevelKey)) { |
|
|
|
orgSidPath = orgSidPath.substring(0, i3); |
|
|
|
qw.like("orgSidPath", orgSidPath); |
|
|
|
} else if ("4".equals(orgLevelKey)) { |
|
|
|
orgSidPath = orgSidPath.substring(0, i4); |
|
|
|
qw.like("orgSidPath", orgSidPath); |
|
|
|
} else if ("5".equals(orgLevelKey)) { |
|
|
|
qw.eq("createBySid", pagerQuery.getUserSid()); |
|
|
|
} else { |
|
|
|
PagerVo<LoanBuckleApplyVo> p = new PagerVo<>(); |
|
|
|
return p; |
|
|
|
} |
|
|
|
} else { |
|
|
|
PagerVo<LoanBuckleApplyVo> p = new PagerVo<>(); |
|
|
|
return p; |
|
|
|
} |
|
|
|
//=======================
|
|
|
|
//分公司
|
|
|
|
if (StringUtils.isNotBlank(pagerQuery.getCompany())) { |
|
|
|
qw.like("useOrgName", pagerQuery.getCompany()); |
|
|
|
} |
|
|
|
//申请人
|
|
|
|
if (StringUtils.isNotBlank(pagerQuery.getApplyName())) { |
|
|
|
qw.like("applyName", pagerQuery.getApplyName()); |
|
|
|
} |
|
|
|
//申请编号
|
|
|
|
if (StringUtils.isNotBlank(pagerQuery.getBillNo())) { |
|
|
|
qw.like("billNo", pagerQuery.getBillNo()); |
|
|
|
} |
|
|
|
String applyStartTime = pagerQuery.getApplyStartDate(); |
|
|
|
String applyEndTime = pagerQuery.getApplyEndDate(); |
|
|
|
qw.apply(StringUtils.isNotEmpty(applyStartTime), "date_format (applyDate,'%Y-%m-%d') >= date_format('" + applyStartTime + "','%Y-%m-%d')"). |
|
|
|
apply(StringUtils.isNotEmpty(applyEndTime), "date_format (applyDate,'%Y-%m-%d') <= date_format('" + applyEndTime + "','%Y-%m-%d')" |
|
|
|
); |
|
|
|
qw.eq("isDelete", 0); |
|
|
|
qw.orderByDesc("createTime"); |
|
|
|
IPage<LoanBuckleApplyVo> pagging = baseMapper.listPage(page, qw); |
|
|
|
PagerVo<LoanBuckleApplyVo> p = PagerUtil.pageToVo(pagging, null); |
|
|
|
return p; |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<LoanBuckleApplyInit> buckleInit(String[] sids) { |
|
|
|
ResultBean<LoanBuckleApplyInit> rb = ResultBean.fireFail(); |
|
|
|
LoanBuckleApplyInit vo = new LoanBuckleApplyInit(); |
|
|
|
List<LoanBuckleHistoryRecord> historyRecords = new ArrayList<>(); |
|
|
|
for (String sid : sids) { |
|
|
|
LoanBuckleHistoryRecord record = new LoanBuckleHistoryRecord(); |
|
|
|
LoanRepaymentHistoryRecordVo recordVo = loanRepaymentHistoryService.buckleInfo(sid).getData(); |
|
|
|
if (null != recordVo) { |
|
|
|
BeanUtil.copyProperties(recordVo, record); |
|
|
|
} |
|
|
|
historyRecords.add(record); |
|
|
|
} |
|
|
|
vo.setRecords(historyRecords); |
|
|
|
return rb.success().setData(vo); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 生成交车资料确认单单据编号 |
|
|
|
* |
|
|
|
* @param orgSid |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
public String getApplyCode(String orgSid) { |
|
|
|
//获取分公司sid
|
|
|
|
ResultBean<SysOrganizationVo> resultBean1 = sysOrganizationFeign.fetchBySid(orgSid); |
|
|
|
String orgCode = resultBean1.getData().getOrgCode(); |
|
|
|
BillNo b = new BillNo(); |
|
|
|
b.setOrgCode(orgCode); |
|
|
|
b.setBillType(BillTypeEnum.HKSQ.getBillType()); |
|
|
|
String bill = Rule.getBill(b); |
|
|
|
int i = baseMapper.selectNum(bill); |
|
|
|
String billNo = Rule.getBillNo(bill, i); |
|
|
|
return billNo; |
|
|
|
} |
|
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
public ResultBean<String> saveBuckle(LoanBuckleApplyDto dto) { |
|
|
|
ResultBean<String> rb = ResultBean.fireFail(); |
|
|
|
String sid = ""; |
|
|
|
if (StringUtils.isNotBlank(dto.getSid())) { |
|
|
|
sid = dto.getSid(); |
|
|
|
LoanBuckleApply updateEntity = fetchBySid(sid); |
|
|
|
if (null != updateEntity) { |
|
|
|
BeanUtil.copyProperties(dto, updateEntity, "id", "sid"); |
|
|
|
baseMapper.updateById(updateEntity); |
|
|
|
loanBuckleApplyRecordService.deleteByMainSid(sid); |
|
|
|
//删除附件表中关于该linkSid的文件
|
|
|
|
loanFileService.deleteByLinkSid(sid); |
|
|
|
List<String> files = dto.getFiles(); |
|
|
|
if (!files.isEmpty()) { |
|
|
|
loanFileService.saveAll(sid, files, LoanFileEnum.BUCKLE_APPLY.getAttachType()); |
|
|
|
} |
|
|
|
List<LoanBuckleHistoryRecord> records = dto.getRecords(); |
|
|
|
if (!records.isEmpty()) { |
|
|
|
for (LoanBuckleHistoryRecord record : records) { |
|
|
|
LoanBuckleApplyRecord applyRecord = new LoanBuckleApplyRecord(); |
|
|
|
applyRecord.setMainSid(sid); |
|
|
|
applyRecord.setRepaymentHistorySid(record.getRecordSid()); |
|
|
|
loanBuckleApplyRecordService.insert(applyRecord); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} else { |
|
|
|
LoanBuckleApply loanBuckleApply = new LoanBuckleApply(); |
|
|
|
sid = loanBuckleApply.getSid(); |
|
|
|
BeanUtil.copyProperties(dto, loanBuckleApply, "id", "sid"); |
|
|
|
loanBuckleApply.setCreateBySid(dto.getUserSid()); |
|
|
|
loanBuckleApply.setOrgSidPath(dto.getOrgPath()); |
|
|
|
ResultBean<String> orgSidByPath = sysStaffOrgFeign.getOrgSidByPath(dto.getOrgPath()); |
|
|
|
if (orgSidByPath.getSuccess()) { |
|
|
|
String userOrgSid = orgSidByPath.getData(); |
|
|
|
loanBuckleApply.setUseOrgSid(userOrgSid); |
|
|
|
String billNo = getApplyCode(userOrgSid); |
|
|
|
loanBuckleApply.setBillNo(billNo); |
|
|
|
ResultBean<SysOrganizationVo> organizationVo = sysOrganizationFeign.fetchBySid(userOrgSid); |
|
|
|
if (organizationVo.getSuccess()) { |
|
|
|
SysOrganizationVo organizationVoData = organizationVo.getData(); |
|
|
|
if (null != organizationVoData) { |
|
|
|
loanBuckleApply.setUseOrgName(organizationVoData.getName()); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
loanBuckleApply.setNodeState("待提交"); |
|
|
|
baseMapper.insert(loanBuckleApply); |
|
|
|
List<LoanBuckleHistoryRecord> records = dto.getRecords(); |
|
|
|
if (!records.isEmpty()) { |
|
|
|
for (LoanBuckleHistoryRecord record : records) { |
|
|
|
LoanBuckleApplyRecord applyRecord = new LoanBuckleApplyRecord(); |
|
|
|
applyRecord.setMainSid(sid); |
|
|
|
applyRecord.setRepaymentHistorySid(record.getRecordSid()); |
|
|
|
loanBuckleApplyRecordService.insert(applyRecord); |
|
|
|
LoanRepaymentHistory repaymentHistory = loanRepaymentHistoryService.fetchBySid(record.getRecordSid()); |
|
|
|
if (null != repaymentHistory) { |
|
|
|
repaymentHistory.setBuckle("申请中"); |
|
|
|
repaymentHistory.setBuckleKey("002"); |
|
|
|
loanRepaymentHistoryService.updateById(repaymentHistory); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
List<String> files = dto.getFiles(); |
|
|
|
if (!files.isEmpty()) { |
|
|
|
loanFileService.saveAll(sid, files, LoanFileEnum.BUCKLE_APPLY.getAttachType()); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.success().setData(sid); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<LoanBuckleApplyInit> buckleDetails(String sid) { |
|
|
|
ResultBean<LoanBuckleApplyInit> rb = ResultBean.fireFail(); |
|
|
|
LoanBuckleApplyInit initVo = new LoanBuckleApplyInit(); |
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(sid); |
|
|
|
if (null != loanBuckleApply) { |
|
|
|
BeanUtil.copyProperties(loanBuckleApply, initVo); |
|
|
|
initVo.setUserSid(loanBuckleApply.getCreateBySid()); |
|
|
|
initVo.setOrgPath(loanBuckleApply.getOrgSidPath()); |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getProcInstId())) { |
|
|
|
initVo.setInstanceId(loanBuckleApply.getProcInstId()); |
|
|
|
} |
|
|
|
if (null != loanBuckleApply.getApplyDate()) { |
|
|
|
initVo.setApplyDate(sdf.format(loanBuckleApply.getApplyDate())); |
|
|
|
} |
|
|
|
List<LoanFile> fileList = loanFileService.selectByLinkSid(sid, LoanFileEnum.BUCKLE_APPLY.getAttachType()); |
|
|
|
fileList.removeAll(Collections.singleton(null)); |
|
|
|
if (!fileList.isEmpty()) { |
|
|
|
List<String> files = fileList.stream().map(c -> fileUploadComponent.getUrlPrefix() + c.getFilePath()). |
|
|
|
collect(Collectors.toList()); |
|
|
|
initVo.setFiles(files); |
|
|
|
} |
|
|
|
List<LoanBuckleApplyRecord> records = loanBuckleApplyRecordService.selByMainSid(sid); |
|
|
|
List<LoanBuckleHistoryRecord> recordList = new ArrayList<>(); |
|
|
|
if (!records.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord record : records) { |
|
|
|
String historySid = record.getRepaymentHistorySid(); |
|
|
|
LoanBuckleHistoryRecord historyRecord = new LoanBuckleHistoryRecord(); |
|
|
|
LoanRepaymentHistoryRecordVo recordVo = loanRepaymentHistoryService.buckleInfo(historySid).getData(); |
|
|
|
if (null != recordVo) { |
|
|
|
BeanUtil.copyProperties(recordVo, historyRecord); |
|
|
|
} |
|
|
|
recordList.add(historyRecord); |
|
|
|
} |
|
|
|
} |
|
|
|
initVo.setRecords(recordList); |
|
|
|
} |
|
|
|
return rb.success().setData(initVo); |
|
|
|
} |
|
|
|
|
|
|
|
//-------------------------------------流程------------------------------------------------/
|
|
|
|
|
|
|
|
/** |
|
|
|
* 判断提交的流程是否被允许 |
|
|
|
* |
|
|
|
* @param dto |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
private synchronized int submitBusinessData(SubmitBuckleDto dto, LoanBuckleApply loanBuckleApply) { |
|
|
|
int r = 0; |
|
|
|
if (StringUtils.isBlank(dto.getSid())) { |
|
|
|
r = 1; |
|
|
|
} else { |
|
|
|
if (loanBuckleApply != null) { |
|
|
|
String businessTaskId = loanBuckleApply.getTaskId(); |
|
|
|
if (StringUtils.isBlank(businessTaskId) && StringUtils.isBlank(dto.getTaskId())) { |
|
|
|
//新提交
|
|
|
|
r = 1; |
|
|
|
} else if (StringUtils.isNotBlank(businessTaskId) && businessTaskId.equals(dto.getTaskId())) { |
|
|
|
//二次提交//只有数据一致的时候才能进行下一步
|
|
|
|
r = 2; |
|
|
|
} |
|
|
|
} else { |
|
|
|
r = 3; |
|
|
|
} |
|
|
|
} |
|
|
|
return r; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 更新流程相关的状态 |
|
|
|
* |
|
|
|
* @param map |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
private int updateFlowFiled(Map<String, Object> map) { |
|
|
|
return baseMapper.updateFlowFiled(map); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean submitRecordApplication(SubmitBuckleDto dto) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(dto.getSid()); |
|
|
|
int r = submitBusinessData(dto, loanBuckleApply); |
|
|
|
if (r == 3) { |
|
|
|
return rb.setMsg("该申请不存在"); |
|
|
|
} |
|
|
|
if (r == 0) { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|
} |
|
|
|
String businessSid = ""; |
|
|
|
//新增修改保存
|
|
|
|
ResultBean<String> resultBean = saveBuckle(dto); |
|
|
|
if (resultBean.getSuccess()) { |
|
|
|
businessSid = resultBean.getData(); |
|
|
|
} |
|
|
|
LoanBuckleApply entity = fetchBySid(businessSid); |
|
|
|
String orgSidPath = ""; |
|
|
|
if (StringUtils.isNotBlank(entity.getOrgSidPath())) { |
|
|
|
orgSidPath = entity.getOrgSidPath(); |
|
|
|
} else { |
|
|
|
SysUserVo data = sysUserFeign.fetchBySid(entity.getCreateBySid()).getData(); |
|
|
|
if (null != data) { |
|
|
|
//根据staffSid获取用户的组织全路径
|
|
|
|
ResultBean<SysStaffOrg> staffOrgResultBean = sysStaffOrgFeign.getOrgByStaffSid(data.getStaffSid()); |
|
|
|
if (!staffOrgResultBean.getSuccess()) { |
|
|
|
return rb.setMsg(staffOrgResultBean.getMsg()); |
|
|
|
} |
|
|
|
//用户的组织全路径
|
|
|
|
orgSidPath = staffOrgResultBean.getData().getOrgSidPath(); |
|
|
|
} |
|
|
|
} |
|
|
|
List<String> orgPathList = Arrays.asList(orgSidPath.split("/")); |
|
|
|
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(orgPathList.get(orgPathList.size() - 1)).getData(); |
|
|
|
if (sysOrganization == null) { |
|
|
|
return rb.setMsg("当前所在的组织机构不存在"); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(sysOrganization.getManagerSid())) { |
|
|
|
// return rb.setMsg("当前所在的组织机构未设置主管人员");
|
|
|
|
sysOrganization.setManagerSid(ProcDefEnum.DEFAUL_TADMIN_SID.getProDefId()); |
|
|
|
} |
|
|
|
//创建BusinessVariables实体对象
|
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
//流程中的参数赋值
|
|
|
|
Map<String, Object> variables = BeanUtil.beanToMap(dto); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
//若有网关，则赋值网关中判断的字段。
|
|
|
|
// boolean isTure = true;
|
|
|
|
// //去查询是否同意
|
|
|
|
// if (StringUtils.isNotBlank(entity.getSalesUserSid())) {
|
|
|
|
// if (!entity.getCreateBySid().equals(entity.getSalesUserSid())) {
|
|
|
|
// isTure = false;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// variables.put("isTure", isTure);
|
|
|
|
variables.put("businessSid", businessSid); |
|
|
|
appMap.put("sid", businessSid); |
|
|
|
variables.put("app", appMap); |
|
|
|
// String orderNames = "<" + entity.getCustomer() + ">" + "欠款客户备案";
|
|
|
|
// variables.put("orderNames", orderNames);
|
|
|
|
LoanBuckleApply loanBuckleApply1 = fetchBySid(businessSid); |
|
|
|
String msgBusinessSid = loanBuckleApply1.getSid(); |
|
|
|
//用户的部门全路径sid
|
|
|
|
bv.setOrgSidPath(loanBuckleApply1.getOrgSidPath()); |
|
|
|
//业务sid
|
|
|
|
bv.setBusinessSid(businessSid); |
|
|
|
//用户sid
|
|
|
|
bv.setUserSid(dto.getUserSid()); |
|
|
|
bv.setFormVariables(variables); |
|
|
|
// String nextNodeUserSids_ = sysOrganization.getManagerSid();
|
|
|
|
// if (isTure) {
|
|
|
|
// bv.setNextNodeUserSids(nextNodeUserSids_);
|
|
|
|
// } else {
|
|
|
|
// bv.setNextNodeUserSids(entity.getSalesUserSid());
|
|
|
|
// }
|
|
|
|
//流程定义id
|
|
|
|
bv.setModelId(ProcDefEnum.LOANBUCKLEAPPLLY.getProDefId()); |
|
|
|
if (r == 1) { |
|
|
|
//流程定义id
|
|
|
|
bv.setModelId(ProcDefEnum.LOANBUCKLEAPPLLY.getProDefId()); |
|
|
|
ResultBean<UpdateFlowFieldVo> voResultBean = flowFeign.startProcess(bv); |
|
|
|
if (!voResultBean.getSuccess()) { |
|
|
|
return rb.setMsg(voResultBean.getMsg()); |
|
|
|
} |
|
|
|
UpdateFlowFieldVo ufVo = voResultBean.getData(); |
|
|
|
int i = updateFlowFiled(BeanUtil.beanToMap(ufVo)); |
|
|
|
//==================================添加线程
|
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|
ExecutorService pool = new ThreadPoolExecutor(2, 100, |
|
|
|
0L, TimeUnit.MILLISECONDS, |
|
|
|
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
//极光推送
|
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVo, messageFlowVo); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(msgBusinessSid); |
|
|
|
messageFlowableQuery.setModuleName("划扣申请"); |
|
|
|
SysUserVo userVo = sysUserFeign.fetchBySid(loanBuckleApply1.getCreateBySid()).getData(); |
|
|
|
if (userVo != null) { |
|
|
|
if (StringUtils.isNotBlank(userVo.getName())) { |
|
|
|
messageFlowableQuery.setMsgContent(userVo.getName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
} |
|
|
|
} |
|
|
|
messageFlowableQuery.setMsgTitle("划扣申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
//==================================添加线程
|
|
|
|
return voResultBean; |
|
|
|
} |
|
|
|
if (r == 2) { |
|
|
|
// ToDo:驳回到发起人后再次提交
|
|
|
|
if (StringUtils.isBlank(dto.getInstanceId())) { |
|
|
|
return rb.setMsg("参数错误：instanceId"); |
|
|
|
} |
|
|
|
LoanBuckleApply loanBuckleApply2 = fetchBySid(dto.getSid()); |
|
|
|
bv.setTaskId(dto.getTaskId()); |
|
|
|
bv.setTaskDefKey(loanBuckleApply2.getNodeSid()); |
|
|
|
bv.setComment("重新提交"); |
|
|
|
bv.setInstanceId(dto.getInstanceId()); |
|
|
|
return complete(bv); |
|
|
|
} |
|
|
|
return rb; |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean complete(BusinessVariables bv) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
String businessSid = bv.getBusinessSid(); |
|
|
|
LoanBuckleApply loanBuckleApply = this.fetchBySid(businessSid); |
|
|
|
if (bv.getTaskId().equals(loanBuckleApply.getTaskId())) { |
|
|
|
bv.setOrgSidPath(loanBuckleApply.getOrgSidPath()); |
|
|
|
//流程中的参数赋值
|
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
//若有网关，则赋值网关中判断的字段。
|
|
|
|
// boolean isTure = true;
|
|
|
|
// //去查询是否同意
|
|
|
|
// if (StringUtils.isNotBlank(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// if (!loanCustomerRecord.getCreateBySid().equals(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// isTure = false;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// variables.put("isTure", isTure);
|
|
|
|
// if (bv.getTaskDefKey().equals("Activity_1078xxs")) {
|
|
|
|
// if (StringUtils.isNotBlank(loanCustomerRecord.getManageSid())) {
|
|
|
|
// bv.setNextNodeUserSids(loanCustomerRecord.getManageSid());
|
|
|
|
// } else {
|
|
|
|
// bv.setNextNodeUserSids(ProcDefEnum.DEFAUL_TADMIN_SID.getProDefId());
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
variables.put("businessSid", businessSid); |
|
|
|
appMap.put("sid", businessSid); |
|
|
|
variables.put("app", appMap); |
|
|
|
bv.setFormVariables(variables); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowFeign.handleProsess(bv); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
int i = updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
|
if ("Event_end".equals(resultBean.getData().getTaskDefKey())) { |
|
|
|
List<LoanBuckleApplyRecord> applyRecords = loanBuckleApplyRecordService.selByMainSid(businessSid); |
|
|
|
if (!applyRecords.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord applyRecord : applyRecords) { |
|
|
|
LoanRepaymentHistory repaymentHistory = loanRepaymentHistoryService.fetchBySid(applyRecord.getRepaymentHistorySid()); |
|
|
|
if (null != repaymentHistory) { |
|
|
|
repaymentHistory.setBuckle("审核通过"); |
|
|
|
repaymentHistory.setBuckleKey("003"); |
|
|
|
loanRepaymentHistoryService.updateById(repaymentHistory); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} else { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public ResultBean revokeProcess(BuckleTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
if (StringUtils.isBlank(query.getUserSid())) { |
|
|
|
return rb.setMsg("参数错误：userSid"); |
|
|
|
} |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(query.getBusinessSid()); |
|
|
|
String businessTaskId = loanBuckleApply.getTaskId(); |
|
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
|
FlowTaskVo flowTaskVo = new FlowTaskVo(); |
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.revokeProcess(flowTaskVo); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.setMsg("操作失败，提交的数据不一致!"); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean taskReject(BuckleTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
String businessSid = query.getBusinessSid(); |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(businessSid); |
|
|
|
if (loanBuckleApply == null) { |
|
|
|
return rb.setMsg("该申请不存在"); |
|
|
|
} |
|
|
|
String businessTaskId = loanBuckleApply.getTaskId(); |
|
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
|
if (StringUtils.isBlank(query.getComment())) { |
|
|
|
return rb.setMsg("请填写意见"); |
|
|
|
} |
|
|
|
if (org.apache.commons.lang3.StringUtils.isBlank(query.getUserSid())) { |
|
|
|
return rb.setMsg("参数错误：userSid"); |
|
|
|
} |
|
|
|
FlowTaskVo flowTaskVo = new FlowTaskVo(); |
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("sid", businessSid); |
|
|
|
variables.put("app", appMap); |
|
|
|
//若有网关，则赋值网关中判断的字段。
|
|
|
|
// boolean isTure = true;
|
|
|
|
// //去查询是否同意
|
|
|
|
// if (StringUtils.isNotBlank(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// if (!loanCustomerRecord.getCreateBySid().equals(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// isTure = false;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// variables.put("isTure", isTure);
|
|
|
|
flowTaskVo.setValues(variables); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.taskReject(flowTaskVo); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
UpdateFlowFieldVo ufVo = resultBean.getData(); |
|
|
|
Map<String, Object> map = BeanUtil.beanToMap(ufVo); |
|
|
|
//更新业务中的流程相关的参数
|
|
|
|
updateFlowFiled(map); |
|
|
|
//极光推送
|
|
|
|
loanBuckleApply = fetchBySid(businessSid); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVo, messageFlowVo); |
|
|
|
String procId = loanBuckleApply.getProcInstId(); |
|
|
|
messageFlowVo.setProcInsId(procId); |
|
|
|
messageFlowVo.setProcDefId(loanBuckleApply.getProcDefId()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(businessSid); |
|
|
|
messageFlowableQuery.setModuleName("划扣申请"); |
|
|
|
ResultBean<List<LatestTaskVo>> listResultBean = flowTaskFeign.getLatestTasks(procId); |
|
|
|
String nextName = listResultBean.getData().get(0).getName_(); |
|
|
|
String nextNodeUserSids = listResultBean.getData().get(0).getASSIGNEE_(); |
|
|
|
List<String> receiveSidList = Arrays.asList(nextNodeUserSids.split(",")); |
|
|
|
// if (receiveSidList.size() == 1 && receiveSidList.get(0).equals(busVehicleApply.getCreateBySid())) {
|
|
|
|
if ("发起申请".equals(nextName)) { |
|
|
|
messageFlowableQuery.setMsgContent("您提交的" + messageFlowableQuery.getModuleName() + "已被驳回,请重新提交"); |
|
|
|
} else { |
|
|
|
SysUserVo userVo = sysUserFeign.fetchBySid(loanBuckleApply.getCreateBySid()).getData(); |
|
|
|
if (userVo != null) { |
|
|
|
if (org.apache.commons.lang3.StringUtils.isNotBlank(userVo.getName())) { |
|
|
|
messageFlowableQuery.setMsgContent(userVo.getName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
messageFlowableQuery.setMsgTitle("划扣申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
return rb.success(); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean breakProcess(BuckleTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
if (org.apache.commons.lang3.StringUtils.isBlank(query.getInstanceId())) { |
|
|
|
return rb.setMsg("参数错误：instanceId"); |
|
|
|
} |
|
|
|
if (org.apache.commons.lang3.StringUtils.isBlank(query.getUserSid())) { |
|
|
|
return rb.setMsg("参数错误：userSid"); |
|
|
|
} |
|
|
|
if (org.apache.commons.lang3.StringUtils.isBlank(query.getComment())) { |
|
|
|
return rb.setMsg("请填写意见"); |
|
|
|
} |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(query.getBusinessSid()); |
|
|
|
String businessTaskId = loanBuckleApply.getTaskId(); |
|
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
|
if (query.getUserSid().equals(loanBuckleApply.getCreateBySid())) { |
|
|
|
FlowTaskVo flowTaskVo = new FlowTaskVo(); |
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.breakProcess(flowTaskVo); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
Map<String, Object> map = BeanUtil.beanToMap(resultBean.getData()); |
|
|
|
updateFlowFiled(map); |
|
|
|
//终止任务后划扣状态改完未通过
|
|
|
|
LoanBuckleApply entity = fetchBySid(query.getBusinessSid()); |
|
|
|
if (entity.getNodeState().equals("终止")) { |
|
|
|
List<LoanBuckleApplyRecord> applyRecords = loanBuckleApplyRecordService.selByMainSid(query.getBusinessSid()); |
|
|
|
if (!applyRecords.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord applyRecord : applyRecords) { |
|
|
|
LoanRepaymentHistory repaymentHistory = loanRepaymentHistoryService.fetchBySid(applyRecord.getRepaymentHistorySid()); |
|
|
|
if (null != repaymentHistory) { |
|
|
|
repaymentHistory.setBuckle("审核未通过"); |
|
|
|
repaymentHistory.setBuckleKey("004"); |
|
|
|
loanRepaymentHistoryService.updateById(repaymentHistory); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} else { |
|
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
|
FlowTaskVo flowTaskVo = new FlowTaskVo(); |
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.breakProcess(flowTaskVo); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
Map<String, Object> map = BeanUtil.beanToMap(resultBean.getData()); |
|
|
|
updateFlowFiled(map); |
|
|
|
//终止任务后划扣状态改完未通过
|
|
|
|
LoanBuckleApply entity = fetchBySid(query.getBusinessSid()); |
|
|
|
if (entity.getNodeState().equals("终止")) { |
|
|
|
List<LoanBuckleApplyRecord> applyRecords = loanBuckleApplyRecordService.selByMainSid(query.getBusinessSid()); |
|
|
|
if (!applyRecords.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord applyRecord : applyRecords) { |
|
|
|
LoanRepaymentHistory repaymentHistory = loanRepaymentHistoryService.fetchBySid(applyRecord.getRepaymentHistorySid()); |
|
|
|
if (null != repaymentHistory) { |
|
|
|
repaymentHistory.setBuckle("审核未通过"); |
|
|
|
repaymentHistory.setBuckleKey("004"); |
|
|
|
loanRepaymentHistoryService.updateById(repaymentHistory); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean flowRecord(String procInsId) { |
|
|
|
return flowTaskFeign.businessFlowRecord(procInsId); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<List<BuckleGetNodeVo>> getNextNodesForSubmit(BuckleGetNodeQuery query) { |
|
|
|
ResultBean<List<BuckleGetNodeVo>> rb = ResultBean.fireFail(); |
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
BeanUtil.copyProperties(query, bv); |
|
|
|
//流程中的参数赋值、若有网关，则赋值网关中判断的字段。
|
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
|
|
|
|
//根据业务sid查询排产信息
|
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(query.getBusinessSid()); |
|
|
|
//若有网关，则赋值网关中判断的字段。
|
|
|
|
// boolean isTure = true;
|
|
|
|
// //去查询是否同意
|
|
|
|
// if (StringUtils.isNotBlank(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// if (!loanCustomerRecord.getCreateBySid().equals(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// isTure = false;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// variables.put("isTure", isTure);
|
|
|
|
bv.setFormVariables(variables); |
|
|
|
bv.setModelId(loanBuckleApply.getProcDefId()); |
|
|
|
ResultBean<List<Map<String, Object>>> resultBean = flowTaskFeign.getNextNodesForSubmit(bv); |
|
|
|
//判断数组是否为空，若为空则赋值，若不为空，则遍历循环将map中的数据赋值给getNodeVo
|
|
|
|
List<BuckleGetNodeVo> voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), BuckleGetNodeVo.class)).collect(Collectors.toList()); |
|
|
|
return rb.success().setData(voList); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<List<BuckleGetNodeVo>> getPreviousNodesForReject(BuckleGetNodeQuery query) { |
|
|
|
ResultBean<List<BuckleGetNodeVo>> rb = ResultBean.fireFail(); |
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
BeanUtil.copyProperties(query, bv); |
|
|
|
//流程中的参数赋值、若有网关，则赋值网关中判断的字段。
|
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
//根据业务sid查询排产信息
|
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(query.getBusinessSid()); |
|
|
|
// //若有网关，则赋值网关中判断的字段。
|
|
|
|
// boolean isTure = true;
|
|
|
|
// //去查询是否同意
|
|
|
|
// if (StringUtils.isNotBlank(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// if (!loanCustomerRecord.getCreateBySid().equals(loanCustomerRecord.getSalesUserSid())) {
|
|
|
|
// isTure = false;
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// variables.put("isTure", isTure);
|
|
|
|
bv.setFormVariables(variables); |
|
|
|
bv.setModelId(loanBuckleApply.getProcDefId()); |
|
|
|
ResultBean<List<Map<String, Object>>> resultBean = flowTaskFeign.getPreviousNodesForReject(bv); |
|
|
|
//判断数组是否为空，若为空则赋值，若不为空，则遍历循环将map中的数据赋值给getNodeVo
|
|
|
|
List<BuckleGetNodeVo> voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), BuckleGetNodeVo.class)).collect(Collectors.toList()); |
|
|
|
return rb.success().setData(voList); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean delegate(BuckleDelegateQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
FlowDelegateQuery delegateQuery = new FlowDelegateQuery(); |
|
|
|
BeanUtil.copyProperties(query, delegateQuery); |
|
|
|
flowFeign.delegate(delegateQuery); |
|
|
|
return rb.success(); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public ResultBean<AppBuckleDetailsVo> appDetail(String sid) { |
|
|
|
ResultBean<AppBuckleDetailsVo> rb = ResultBean.fireFail(); |
|
|
|
AppBuckleDetailsVo vo = new AppBuckleDetailsVo(); |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(sid); |
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
|
|
|
if (null != loanBuckleApply) { |
|
|
|
vo.setSid(sid); |
|
|
|
String dept = ""; |
|
|
|
String applyName = ""; |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getRemarks())) { |
|
|
|
vo.setRemarks(loanBuckleApply.getRemarks()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getProcInstId())) { |
|
|
|
vo.setProcInsId(loanBuckleApply.getProcInstId()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getTaskId())) { |
|
|
|
vo.setTaskId(loanBuckleApply.getTaskId()); |
|
|
|
} |
|
|
|
if (null != loanBuckleApply.getApplyDate()) { |
|
|
|
vo.setTime(sdf.format(loanBuckleApply.getApplyDate())); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getDept())) { |
|
|
|
dept = loanBuckleApply.getDept(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(loanBuckleApply.getApplyName())) { |
|
|
|
applyName = loanBuckleApply.getApplyName(); |
|
|
|
} |
|
|
|
vo.setPublishInfo(dept + "-" + applyName); |
|
|
|
List<LoanFile> fileList = loanFileService.selectByLinkSid(sid, LoanFileEnum.BUCKLE_APPLY.getAttachType()); |
|
|
|
fileList.removeAll(Collections.singleton(null)); |
|
|
|
if (!fileList.isEmpty()) { |
|
|
|
List<String> files = fileList.stream().map(c -> fileUploadComponent.getUrlPrefix() + c.getFilePath()). |
|
|
|
collect(Collectors.toList()); |
|
|
|
vo.setFiles(files); |
|
|
|
} |
|
|
|
List<LoanBuckleApplyRecord> applyRecords = loanBuckleApplyRecordService.selByMainSid(sid); |
|
|
|
List<AppRecordVo> records = new ArrayList<>(); |
|
|
|
if (!applyRecords.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord applyRecord : applyRecords) { |
|
|
|
String historySid = applyRecord.getRepaymentHistorySid(); |
|
|
|
LoanRepaymentHistoryRecordVo data = loanRepaymentHistoryService.buckleInfo(historySid).getData(); |
|
|
|
if (null != data) { |
|
|
|
AppRecordVo appRecordVo = new AppRecordVo(); |
|
|
|
if (StringUtils.isNotBlank(data.getLoanContractNo())) { |
|
|
|
appRecordVo.setContractId(data.getLoanContractNo()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getPeriod())) { |
|
|
|
appRecordVo.setInstalments("期数：" + data.getPeriod()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getVinNo())) { |
|
|
|
appRecordVo.setVin("车架号：" + data.getVinNo()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getReturnWay())) { |
|
|
|
appRecordVo.setType(data.getReturnWay()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getBankName())) { |
|
|
|
appRecordVo.setZf(data.getBankName()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getBankContractNo())) { |
|
|
|
appRecordVo.setZfNo(data.getBankContractNo()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getCustomer())) { |
|
|
|
appRecordVo.setCusName(data.getCustomer()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getBorrowerName())) { |
|
|
|
appRecordVo.setLoanName(data.getBorrowerName()); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getDueDate())) { |
|
|
|
appRecordVo.setRepaymentDate(data.getDueDate()); |
|
|
|
} |
|
|
|
String yinghuan = ""; |
|
|
|
String weihuan = ""; |
|
|
|
String shihuan = ""; |
|
|
|
String shihuandate = ""; |
|
|
|
if (StringUtils.isNotBlank(data.getDueMoney())) { |
|
|
|
yinghuan = data.getDueMoney(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getOutstandingMoney())) { |
|
|
|
weihuan = data.getOutstandingMoney(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getActualDate())) { |
|
|
|
shihuandate = data.getActualDate(); |
|
|
|
} |
|
|
|
if (StringUtils.isNotBlank(data.getActualMoney())) { |
|
|
|
shihuan = data.getActualMoney(); |
|
|
|
} |
|
|
|
appRecordVo.setInfo1("本期应还：" + yinghuan + "，本期未还：" + weihuan); |
|
|
|
appRecordVo.setInfo2("实还日期：" + shihuandate + "，实还金额：" + shihuan); |
|
|
|
records.add(appRecordVo); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
vo.setRecords(records); |
|
|
|
} |
|
|
|
return rb.success().setData(vo); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean deleteBySids(String[] sids) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
for (String sid : sids) { |
|
|
|
LoanBuckleApply loanBuckleApply = fetchBySid(sid); |
|
|
|
if (null != loanBuckleApply) { |
|
|
|
if (!loanBuckleApply.getNodeState().equals("待提交")) { |
|
|
|
return rb.setMsg("删除的数据中包含已经提交审批的数据，删除失败"); |
|
|
|
} |
|
|
|
} |
|
|
|
loanBuckleApply.setIsDelete(1); |
|
|
|
int i = baseMapper.updateById(loanBuckleApply); |
|
|
|
if (i == 0) { |
|
|
|
return rb.setMsg("删除失败"); |
|
|
|
} |
|
|
|
List<LoanBuckleApplyRecord> applyRecords = loanBuckleApplyRecordService.selByMainSid(sid); |
|
|
|
if (!applyRecords.isEmpty()) { |
|
|
|
for (LoanBuckleApplyRecord applyRecord : applyRecords) { |
|
|
|
LoanRepaymentHistory repaymentHistory = loanRepaymentHistoryService.fetchBySid(applyRecord.getRepaymentHistorySid()); |
|
|
|
if (null != repaymentHistory) { |
|
|
|
repaymentHistory.setBuckle("未申请"); |
|
|
|
repaymentHistory.setBuckleKey("001"); |
|
|
|
loanRepaymentHistoryService.updateById(repaymentHistory); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
return ResultBean.fireSuccess().setMsg("删除成功"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
fanzongzhe
1 year ago