|
|
|
@ -26,24 +26,42 @@ |
|
|
|
package com.yxt.anrui.buscenter.biz.busadvanceginvoiceapply; |
|
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil; |
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.baomidou.mybatisplus.extension.api.R; |
|
|
|
import com.yxt.anrui.base.api.basevehicle.*; |
|
|
|
import com.yxt.anrui.base.api.commonappendix.CommonAppendixFeign; |
|
|
|
import com.yxt.anrui.base.api.commonappendix.CommonAppendixVo; |
|
|
|
import com.yxt.anrui.base.api.commonappendix.CommonAttachTypeEnum; |
|
|
|
import com.yxt.anrui.base.api.commoncontract.CommonContractFeign; |
|
|
|
import com.yxt.anrui.base.api.commoncontract.CommonContractVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busadvanceginvoiceapply.*; |
|
|
|
import com.yxt.anrui.buscenter.api.busdeliveredapply.AppDeliveredApplyPageQuery; |
|
|
|
import com.yxt.anrui.buscenter.api.busdeliveredapply.AppDeliveredApplyPageVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busadvanceginvoiceapply.flowable.AppAdvanceInvoiceTaskQuery; |
|
|
|
import com.yxt.anrui.buscenter.api.busadvanceginvoiceapply.flowable.AppSubmitAdvanceInvoiceDto; |
|
|
|
import com.yxt.anrui.buscenter.api.busadvanceginvoiceapply.flowable.GetNodeQuery; |
|
|
|
import com.yxt.anrui.buscenter.api.busadvanceginvoiceapply.flowable.GetNodeVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busginvoiceapplyvehicle.BusGinvoiceapplyVehicle; |
|
|
|
import com.yxt.anrui.buscenter.api.busginvoiceapplyvehicle.BusGinvoiceapplyVehicleDetailsVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busginvoiceapplyvehicle.BusGinvoiceapplyVehicleDto; |
|
|
|
import com.yxt.anrui.buscenter.api.bussalesorder.contract.AppRovalContractPageVo; |
|
|
|
import com.yxt.anrui.buscenter.biz.busginvoiceapplyvehicle.BusGinvoiceapplyVehicleService; |
|
|
|
import com.yxt.anrui.buscenter.biz.bussalesorder.BusSalesOrderService; |
|
|
|
import com.yxt.anrui.buscenter.biz.flow.FlowableService; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempFeign; |
|
|
|
import com.yxt.anrui.crm.api.crmcustomertemp.CrmCustomerTempVo; |
|
|
|
import com.yxt.anrui.flowable.api.flow.FlowableFeign; |
|
|
|
import com.yxt.anrui.flowable.api.flow.UpdateFlowFieldVo; |
|
|
|
import com.yxt.anrui.flowable.api.flowtask.FlowTaskFeign; |
|
|
|
import com.yxt.anrui.flowable.api.flowtask.FlowTaskVo; |
|
|
|
import com.yxt.anrui.flowable.api.flowtask.LatestTaskVo; |
|
|
|
import com.yxt.anrui.flowable.api.sysformlink.SysFormLinkDto; |
|
|
|
import com.yxt.anrui.flowable.api.sysformlink.SysFormLinkFeign; |
|
|
|
import com.yxt.anrui.flowable.api.sysformlink.SysFormLinkTypeEnum; |
|
|
|
import com.yxt.anrui.flowable.api.utils.ProcDefEnum; |
|
|
|
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables; |
|
|
|
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationFeign; |
|
|
|
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationVo; |
|
|
|
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; |
|
|
|
@ -53,15 +71,16 @@ import com.yxt.common.base.utils.PagerUtil; |
|
|
|
import com.yxt.common.core.query.PagerQuery; |
|
|
|
import com.yxt.common.core.result.ResultBean; |
|
|
|
import com.yxt.common.core.vo.PagerVo; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFeign; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFlowVo; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFlowableQuery; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.apache.http.nio.pool.NIOConnFactory; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
import java.text.SimpleDateFormat; |
|
|
|
import java.util.*; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
/** |
|
|
|
* Project: anrui_buscenter(销售业务) <br/> |
|
|
|
@ -93,6 +112,22 @@ public class BusAdvanceGinvoiceapplyService extends MybatisBaseService<BusAdvanc |
|
|
|
private SysUserFeign sysUserFeign; |
|
|
|
@Autowired |
|
|
|
private SysStaffOrgFeign sysStaffOrgFeign; |
|
|
|
@Autowired |
|
|
|
private SysOrganizationFeign sysOrganizationFeign; |
|
|
|
@Autowired |
|
|
|
private MessageFeign messageFeign; |
|
|
|
@Autowired |
|
|
|
private FlowableFeign flowableFeign; |
|
|
|
@Autowired |
|
|
|
private FlowTaskFeign flowTaskFeign; |
|
|
|
@Autowired |
|
|
|
private BaseVehicleFeign baseVehicleFeign; |
|
|
|
@Autowired |
|
|
|
private BusSalesOrderService busSalesOrderService; |
|
|
|
@Autowired |
|
|
|
private CommonContractFeign commonContractFeign; |
|
|
|
@Autowired |
|
|
|
private CrmCustomerTempFeign crmCustomerTempFeign; |
|
|
|
|
|
|
|
public PagerVo<BusAdvanceGinvoiceapply> listPage(PagerQuery<BusAdvanceGinvoiceapplyQuery> pq) { |
|
|
|
BusAdvanceGinvoiceapplyQuery query = pq.getParams(); |
|
|
|
@ -339,14 +374,22 @@ public class BusAdvanceGinvoiceapplyService extends MybatisBaseService<BusAdvanc |
|
|
|
sysFormLinkFeign.save(sysFormLinkDto); |
|
|
|
} |
|
|
|
|
|
|
|
public IPage<AppAdvanceInvoicePageVo> getAdvanceInvoiceList(PagerQuery<AppAdvanceInvoiceQuery> pagerQuery) { |
|
|
|
AppAdvanceInvoiceQuery params = pagerQuery.getParams(); |
|
|
|
QueryWrapper<AppAdvanceInvoiceQuery> qw = new QueryWrapper<>(); |
|
|
|
public IPage<AppAdvanceInvoicePageVo> getAdvanceInvoiceList(PagerQuery<AppAdvanceInvoicePageQuery> pagerQuery) { |
|
|
|
AppAdvanceInvoicePageQuery params = pagerQuery.getParams(); |
|
|
|
QueryWrapper<AppAdvanceInvoicePageQuery> qw = new QueryWrapper<>(); |
|
|
|
if (StringUtils.isNotBlank(params.getUserSid())) { |
|
|
|
qw.eq("createBySid", params.getUserSid()); |
|
|
|
} |
|
|
|
IPage<AppAdvanceInvoiceQuery> page = PagerUtil.queryToPage(pagerQuery); |
|
|
|
IPage<AppAdvanceInvoicePageQuery> page = PagerUtil.queryToPage(pagerQuery); |
|
|
|
IPage<AppAdvanceInvoicePageVo> iPage = baseMapper.getAdvanceInvoiceList(page, qw, params.getName()); |
|
|
|
for (AppAdvanceInvoicePageVo record : iPage.getRecords()) { |
|
|
|
if ("1".equals(record.getAdvGinReasonType())) { |
|
|
|
record.setReason(record.getAdvGinReasonValue()); |
|
|
|
} |
|
|
|
if ("0".equals(record.getAdvGinReasonType())) { |
|
|
|
record.setReason(record.getOtherReasons()); |
|
|
|
} |
|
|
|
} |
|
|
|
return iPage; |
|
|
|
} |
|
|
|
|
|
|
|
@ -355,15 +398,35 @@ public class BusAdvanceGinvoiceapplyService extends MybatisBaseService<BusAdvanc |
|
|
|
AppAdvanceInvoiceInfoVo vo = new AppAdvanceInvoiceInfoVo(); |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(contractSid); |
|
|
|
BeanUtil.copyProperties(busAdvanceGinvoiceapply, vo, "sid"); |
|
|
|
vo.setUserSid(busAdvanceGinvoiceapply.getCreateBySid()); |
|
|
|
vo.setContractSid(contractSid); |
|
|
|
List<AdCarListVo> carList = new ArrayList<>(); |
|
|
|
List<BusGinvoiceapplyVehicleDetailsVo> vinList = busGinvoiceapplyVehicleService.fetchByAdvGinSid(contractSid); |
|
|
|
for (BusGinvoiceapplyVehicleDetailsVo vehicleDetailsVo : vinList) { |
|
|
|
List<AdCarListVo> vinList = new ArrayList<>(); |
|
|
|
int arrearsMoney = 0; |
|
|
|
List<BusGinvoiceapplyVehicleDetailsVo> carLists = busGinvoiceapplyVehicleService.fetchByAdvGinSid(contractSid); |
|
|
|
for (BusGinvoiceapplyVehicleDetailsVo vehicleDetailsVo : carLists) { |
|
|
|
AdCarListVo adCarListVo = new AdCarListVo(); |
|
|
|
adCarListVo.setPrice(vehicleDetailsVo.getDealMoney()); |
|
|
|
adCarListVo.setVin(vehicleDetailsVo.getVinNo()); |
|
|
|
carList.add(adCarListVo); |
|
|
|
int dealMoney = Integer.parseInt(vehicleDetailsVo.getDealMoney()); |
|
|
|
arrearsMoney = dealMoney + arrearsMoney; |
|
|
|
} |
|
|
|
vo.setCarList(carList); |
|
|
|
vo.setArrearsMoney(String.valueOf(arrearsMoney)); |
|
|
|
List<AppRovalContractPageVo> vinLists = busSalesOrderService.selectByContractNo(busAdvanceGinvoiceapply.getContractNo()); |
|
|
|
if (vinLists.size() > 0) { |
|
|
|
for (AppRovalContractPageVo appRovalContractPageVo : vinLists) { |
|
|
|
AdCarListVo adCarListVo = new AdCarListVo(); |
|
|
|
adCarListVo.setVin(appRovalContractPageVo.getVin()); |
|
|
|
CommonContractVo commonContractVo = commonContractFeign.getContractBySalesOrderSid(appRovalContractPageVo.getBusSid()).getData(); |
|
|
|
if (commonContractVo != null) { |
|
|
|
adCarListVo.setPrice(commonContractVo.getPrice()); |
|
|
|
} |
|
|
|
vinList.add(adCarListVo); |
|
|
|
} |
|
|
|
} |
|
|
|
vo.setVinList(vinList); |
|
|
|
String urlPrefix = fileUploadComponent.getUrlPrefix(); |
|
|
|
List<String> confirmFile = new ArrayList<>(); |
|
|
|
List<CommonAppendixVo> confirmFiles = commonAppendixFeign.getAppAppendixList(contractSid, CommonAttachTypeEnum.ADVANCE_KPXXQRS.getAttachType()).getData(); |
|
|
|
@ -386,39 +449,76 @@ public class BusAdvanceGinvoiceapplyService extends MybatisBaseService<BusAdvanc |
|
|
|
return rb.success().setData(vo); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean saveAdvanceInvoice(AppAdvanceInvoiceDto dto) { |
|
|
|
public ResultBean addAdvanceInvoice(AppAdvanceInvoiceVinDto dto) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
String useOrgSid = sysStaffOrgFeign.getPathSidByUserSid(dto.getUserSid()).getData(); |
|
|
|
SysOrganizationVo sysOrganizationVo = sysOrganizationFeign.fetchBySid(useOrgSid).getData(); |
|
|
|
SysUserVo sysUserVo = sysUserFeign.fetchBySid(dto.getUserSid()).getData(); |
|
|
|
if (StringUtils.isBlank(dto.getContractSid())) { |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = new BusAdvanceGinvoiceapply(); |
|
|
|
BeanUtil.copyProperties(dto, busAdvanceGinvoiceapply); |
|
|
|
save(busAdvanceGinvoiceapply); |
|
|
|
List<AdCarListVo> carList = dto.getCarList(); |
|
|
|
for (AdCarListVo adCarListVo : carList) { |
|
|
|
BusGinvoiceapplyVehicle busGinvoiceapplyVehicle = new BusGinvoiceapplyVehicle(); |
|
|
|
busGinvoiceapplyVehicle.setAdvGinSid(busAdvanceGinvoiceapply.getSid()); |
|
|
|
busGinvoiceapplyVehicle.setVinNo(adCarListVo.getVin()); |
|
|
|
busGinvoiceapplyVehicle.setDealMoney(adCarListVo.getPrice()); |
|
|
|
busGinvoiceapplyVehicleService.save(busGinvoiceapplyVehicle); |
|
|
|
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd"); |
|
|
|
String price = ""; |
|
|
|
String modelName = ""; |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = new BusAdvanceGinvoiceapply(); |
|
|
|
busAdvanceGinvoiceapply.setAdvGinReasonType("0"); |
|
|
|
if (StringUtils.isNotBlank(dto.getContractSid())) { |
|
|
|
CommonContractVo commonContractVo = commonContractFeign.fetchBySid(dto.getContractSid()).getData(); |
|
|
|
if (commonContractVo != null) { |
|
|
|
CrmCustomerTempVo crmCustomerTempVo = crmCustomerTempFeign.fetchSid(commonContractVo.getCustomerSid()).getData(); |
|
|
|
if (crmCustomerTempVo != null) { |
|
|
|
busAdvanceGinvoiceapply.setCustomerName(crmCustomerTempVo.getName()); |
|
|
|
} |
|
|
|
busAdvanceGinvoiceapply.setContractNo(commonContractVo.getContractNo()); |
|
|
|
price = commonContractVo.getPrice(); |
|
|
|
modelName = commonContractVo.getModelName(); |
|
|
|
} |
|
|
|
saveFile(dto.getConfirmFile(), dto.getApplyFile(), dto.getRegisterFile(), busAdvanceGinvoiceapply.getSid(), sysUserVo.getStaffSid()); |
|
|
|
} else { |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(dto.getContractSid()); |
|
|
|
BeanUtil.copyProperties(dto, busAdvanceGinvoiceapply); |
|
|
|
updateById(busAdvanceGinvoiceapply); |
|
|
|
busGinvoiceapplyVehicleService.delByAdvGinSid(dto.getContractSid()); |
|
|
|
List<AdCarListVo> carList = dto.getCarList(); |
|
|
|
for (AdCarListVo adCarListVo : carList) { |
|
|
|
} |
|
|
|
busAdvanceGinvoiceapply.setCreateBySid(dto.getUserSid()); |
|
|
|
busAdvanceGinvoiceapply.setUseOrgSid(useOrgSid); |
|
|
|
busAdvanceGinvoiceapply.setApplyName(sysUserVo.getName()); |
|
|
|
busAdvanceGinvoiceapply.setApplyDate(sf.format(new Date())); |
|
|
|
busAdvanceGinvoiceapply.setUseOrgName(sysOrganizationVo.getName()); |
|
|
|
if (dto.getVinList().size() > 0) { |
|
|
|
for (String vin : dto.getVinList()) { |
|
|
|
BusGinvoiceapplyVehicle busGinvoiceapplyVehicle = new BusGinvoiceapplyVehicle(); |
|
|
|
busGinvoiceapplyVehicle.setAdvGinSid(busAdvanceGinvoiceapply.getSid()); |
|
|
|
busGinvoiceapplyVehicle.setVinNo(adCarListVo.getVin()); |
|
|
|
busGinvoiceapplyVehicle.setDealMoney(adCarListVo.getPrice()); |
|
|
|
busGinvoiceapplyVehicle.setVinNo(vin); |
|
|
|
BaseVehicle baseVehicle = baseVehicleFeign.selectByVinNoAndOrgSid(vin, useOrgSid).getData(); |
|
|
|
if (baseVehicle != null) { |
|
|
|
busGinvoiceapplyVehicle.setVehicleSid(baseVehicle.getSid()); |
|
|
|
} |
|
|
|
busGinvoiceapplyVehicle.setDealMoney(price); |
|
|
|
busGinvoiceapplyVehicleService.save(busGinvoiceapplyVehicle); |
|
|
|
} |
|
|
|
commonAppendixFeign.deleteFiles(dto.getContractSid()); |
|
|
|
saveFile(dto.getConfirmFile(), dto.getApplyFile(), dto.getRegisterFile(), busAdvanceGinvoiceapply.getSid(), sysUserVo.getStaffSid()); |
|
|
|
} |
|
|
|
return rb.success(); |
|
|
|
busAdvanceGinvoiceapply.setNum(dto.getVinList().size()); |
|
|
|
busAdvanceGinvoiceapply.setCarModel(modelName); |
|
|
|
save(busAdvanceGinvoiceapply); |
|
|
|
return rb.success().setData(busAdvanceGinvoiceapply.getSid()); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean saveAdvanceInvoice(AppAdvanceInvoiceDto dto) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
String useOrgSid = sysStaffOrgFeign.getPathSidByUserSid(dto.getUserSid()).getData(); |
|
|
|
SysUserVo sysUserVo = sysUserFeign.fetchBySid(dto.getUserSid()).getData(); |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(dto.getContractSid()); |
|
|
|
BeanUtil.copyProperties(dto, busAdvanceGinvoiceapply); |
|
|
|
updateById(busAdvanceGinvoiceapply); |
|
|
|
String sid = dto.getContractSid(); |
|
|
|
busGinvoiceapplyVehicleService.delByAdvGinSid(sid); |
|
|
|
List<AdCarListDto> carList = dto.getCarList(); |
|
|
|
for (AdCarListDto adCarListDto : carList) { |
|
|
|
BusGinvoiceapplyVehicle busGinvoiceapplyVehicle = new BusGinvoiceapplyVehicle(); |
|
|
|
busGinvoiceapplyVehicle.setAdvGinSid(busAdvanceGinvoiceapply.getSid()); |
|
|
|
busGinvoiceapplyVehicle.setVinNo(adCarListDto.getVin()); |
|
|
|
BaseVehicle baseVehicle = baseVehicleFeign.selectByVinNoAndOrgSid(adCarListDto.getVin(), useOrgSid).getData(); |
|
|
|
if (baseVehicle != null) { |
|
|
|
busGinvoiceapplyVehicle.setVehicleSid(baseVehicle.getSid()); |
|
|
|
} |
|
|
|
busGinvoiceapplyVehicle.setDealMoney(adCarListDto.getPrice()); |
|
|
|
busGinvoiceapplyVehicleService.save(busGinvoiceapplyVehicle); |
|
|
|
} |
|
|
|
commonAppendixFeign.deleteFiles(dto.getContractSid()); |
|
|
|
saveFile(dto.getConfirmFile(), dto.getApplyFile(), dto.getRegisterFile(), busAdvanceGinvoiceapply.getSid(), sysUserVo.getStaffSid()); |
|
|
|
return rb.success().setData(busAdvanceGinvoiceapply.getSid()); |
|
|
|
} |
|
|
|
|
|
|
|
public void saveFile(List<String> confirmFile, List<String> applyFile, List<String> registerFile, String sid, String staffSid) { |
|
|
|
@ -461,4 +561,294 @@ public class BusAdvanceGinvoiceapplyService extends MybatisBaseService<BusAdvanc |
|
|
|
busGinvoiceapplyVehicleService.delByAdvGinSid(contractSid); |
|
|
|
return rb.success(); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean submitCarTransfer(AppSubmitAdvanceInvoiceDto dto) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
//根据用户sid获取staffSid
|
|
|
|
ResultBean<SysUserVo> userVoResultBean = sysUserFeign.fetchBySid(dto.getUserSid()); |
|
|
|
if (!userVoResultBean.getSuccess()) { |
|
|
|
return rb.setMsg(userVoResultBean.getMsg()); |
|
|
|
} |
|
|
|
//根据staffSid获取用户的组织全路径
|
|
|
|
ResultBean<SysStaffOrg> staffOrgResultBean = sysStaffOrgFeign.getOrgByStaffSid(userVoResultBean.getData().getStaffSid()); |
|
|
|
if (!staffOrgResultBean.getSuccess()) { |
|
|
|
return rb.setMsg(staffOrgResultBean.getMsg()); |
|
|
|
} |
|
|
|
//用户的组织全路径
|
|
|
|
String orgSidPath = staffOrgResultBean.getData().getOrgSidPath(); |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(dto.getContractSid()); |
|
|
|
int r = submitBusinessData(dto, busAdvanceGinvoiceapply); |
|
|
|
if (r == 3) { |
|
|
|
return rb.setMsg("该申请不存在"); |
|
|
|
} |
|
|
|
if (r == 0) { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|
} |
|
|
|
//新增修改保存
|
|
|
|
ResultBean<String> resultBean = saveAdvanceInvoice(dto); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
String businessSid = resultBean.getData(); |
|
|
|
//创建BusinessVariables实体对象
|
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
//流程中的参数赋值、若有网关，则赋值网关中判断的字段。
|
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
//用户的部门全路径sid
|
|
|
|
bv.setOrgSidPath(orgSidPath); |
|
|
|
//业务sid
|
|
|
|
bv.setBusinessSid(businessSid); |
|
|
|
//用户sid
|
|
|
|
bv.setUserSid(dto.getUserSid()); |
|
|
|
bv.setFormVariables(variables); |
|
|
|
//若app移动端有此功能，则传递appMap参数
|
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
//需和移动端沟通业务sid保存的属性具体值：appMap中sid不是固定的。移动端提供具体字段。
|
|
|
|
appMap.put("contractSid", businessSid); |
|
|
|
variables.put("app", appMap); |
|
|
|
//流程定义id
|
|
|
|
bv.setModelId(ProcDefEnum.BUSCENTERADVANCEGINVOICEAPPLY.getProDefId()); |
|
|
|
if (r == 1) { |
|
|
|
ResultBean<UpdateFlowFieldVo> voResultBean = flowableFeign.startProcess(bv); |
|
|
|
UpdateFlowFieldVo ufVo = voResultBean.getData(); |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(ufVo)); |
|
|
|
//极光推送
|
|
|
|
busAdvanceGinvoiceapply = fetchBySid(businessSid); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVo, messageFlowVo); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(businessSid); |
|
|
|
messageFlowableQuery.setModuleName("提前开票申请"); |
|
|
|
messageFlowableQuery.setMsgContent(busAdvanceGinvoiceapply.getApplyName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("提前开票申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
return voResultBean; |
|
|
|
} |
|
|
|
if (r == 2) { |
|
|
|
// ToDo:驳回到发起人后再次提交
|
|
|
|
if (StringUtils.isBlank(dto.getInstanceId())) { |
|
|
|
return rb.setMsg("参数错误：instanceId"); |
|
|
|
} |
|
|
|
bv.setTaskId(busAdvanceGinvoiceapply.getTaskId()); |
|
|
|
bv.setTaskDefKey(busAdvanceGinvoiceapply.getNodeId()); |
|
|
|
bv.setComment(StringUtils.isNotBlank(dto.getComment()) ? dto.getComment() : "重新提交"); |
|
|
|
bv.setInstanceId(dto.getInstanceId()); |
|
|
|
return complete(bv); |
|
|
|
} |
|
|
|
return rb; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 判断提交的流程是否被允许 |
|
|
|
* |
|
|
|
* @param dto |
|
|
|
* @return |
|
|
|
*/ |
|
|
|
private synchronized int submitBusinessData(AppSubmitAdvanceInvoiceDto dto, BusAdvanceGinvoiceapply busAdvanceGinvoiceapply) { |
|
|
|
int r = 0; |
|
|
|
if (StringUtils.isBlank(dto.getContractSid())) { |
|
|
|
r = 1; |
|
|
|
} else { |
|
|
|
if (busAdvanceGinvoiceapply != null) { |
|
|
|
String businessTaskId = busAdvanceGinvoiceapply.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 complete(BusinessVariables bv) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(bv.getBusinessSid()); |
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("contractSid", bv.getBusinessSid()); |
|
|
|
variables.put("app", appMap); |
|
|
|
bv.setFormVariables(variables); |
|
|
|
if (bv.getTaskId().equals(busAdvanceGinvoiceapply.getTaskId())) { |
|
|
|
ResultBean<UpdateFlowFieldVo> resultBean = flowableFeign.handleProsess(bv); |
|
|
|
if (!resultBean.getSuccess()) { |
|
|
|
return rb.setMsg(resultBean.getMsg()); |
|
|
|
} |
|
|
|
UpdateFlowFieldVo ufVo = resultBean.getData(); |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
|
if (!"Event_end".equals(ufVo.getTaskDefKey())) { |
|
|
|
//极光推送
|
|
|
|
busAdvanceGinvoiceapply = fetchBySid(bv.getBusinessSid()); |
|
|
|
ufVo.setProcInsId(busAdvanceGinvoiceapply.getProcInstId()); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVo, messageFlowVo); |
|
|
|
ufVo.setProcInsId(busAdvanceGinvoiceapply.getProcInstId()); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(bv.getBusinessSid()); |
|
|
|
messageFlowableQuery.setModuleName("提前开票申请"); |
|
|
|
messageFlowableQuery.setMsgContent(busAdvanceGinvoiceapply.getApplyName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
messageFlowableQuery.setMsgTitle("提前开票申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
} |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} else { |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<List<GetNodeVo>> getPreviousNodesForReject(GetNodeQuery query) { |
|
|
|
ResultBean<List<GetNodeVo>> rb = new ResultBean<>(); |
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
BeanUtil.copyProperties(query, bv); |
|
|
|
// Map<String, Object> formVariables = query.getFormVariables();
|
|
|
|
//判断流程分支
|
|
|
|
// Map<String, Object> map = IsTrue(formVariables.get("businessSid"));
|
|
|
|
// bv.setFormVariables(map);
|
|
|
|
bv.setModelId(ProcDefEnum.BUSCENTERADVANCEGINVOICEAPPLY.getProDefId()); |
|
|
|
ResultBean<List<Map<String, Object>>> resultBean = flowTaskFeign.getPreviousNodesForReject(bv); |
|
|
|
//判断数组是否为空，若为空则赋值，若不为空，则遍历循环将map中的数据赋值给getNodeVo
|
|
|
|
List<GetNodeVo> voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); |
|
|
|
return rb.success().setData(voList); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean<List<GetNodeVo>> getNextNodesForSubmit(GetNodeQuery query) { |
|
|
|
ResultBean<List<GetNodeVo>> rb = ResultBean.fireFail(); |
|
|
|
BusinessVariables bv = new BusinessVariables(); |
|
|
|
BeanUtil.copyProperties(query, bv); |
|
|
|
// Map<String, Object> formVariables = query.getFormVariables();
|
|
|
|
//判断流程分支
|
|
|
|
// Map<String, Object> map = IsTrue(formVariables.get("businessSid"));
|
|
|
|
// bv.setFormVariables(map);
|
|
|
|
bv.setModelId(ProcDefEnum.BUSCENTERADVANCEGINVOICEAPPLY.getProDefId()); |
|
|
|
ResultBean<List<Map<String, Object>>> resultBean = flowTaskFeign.getNextNodesForSubmit(bv); |
|
|
|
//判断数组是否为空，若为空则赋值，若不为空，则遍历循环将map中的数据赋值给getNodeVo
|
|
|
|
List<GetNodeVo> voList = Optional.ofNullable(resultBean.getData()).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), GetNodeVo.class)).collect(Collectors.toList()); |
|
|
|
return rb.success().setData(voList); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean taskReject(AppAdvanceInvoiceTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
if (StringUtils.isBlank(query.getComment())) { |
|
|
|
return rb.setMsg("意见不能为空"); |
|
|
|
} |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(query.getBusinessSid()); |
|
|
|
if (busAdvanceGinvoiceapply == null) { |
|
|
|
return rb.setMsg("该申请不存在"); |
|
|
|
} |
|
|
|
String businessTaskId = busAdvanceGinvoiceapply.getTaskId(); |
|
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
|
if (businessTaskId.equals(query.getTaskId())) { |
|
|
|
FlowTaskVo flowTaskVo = new FlowTaskVo(); |
|
|
|
BeanUtil.copyProperties(query, flowTaskVo); |
|
|
|
Map<String, Object> variables = new HashMap<>(); |
|
|
|
Map<String, Object> appMap = new HashMap<>(); |
|
|
|
appMap.put("contractSid", query.getBusinessSid()); |
|
|
|
variables.put("app", appMap); |
|
|
|
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(resultBean.getData()); |
|
|
|
//更新业务中的流程相关的参数
|
|
|
|
updateFlowFiled(map); |
|
|
|
busAdvanceGinvoiceapply = fetchBySid(query.getBusinessSid()); |
|
|
|
MessageFlowableQuery messageFlowableQuery = new MessageFlowableQuery(); |
|
|
|
MessageFlowVo messageFlowVo = new MessageFlowVo(); |
|
|
|
BeanUtil.copyProperties(ufVo, messageFlowVo); |
|
|
|
String procId = busAdvanceGinvoiceapply.getProcInstId(); |
|
|
|
ufVo.setProcInsId(procId); |
|
|
|
messageFlowableQuery.setUfVo(messageFlowVo); |
|
|
|
messageFlowableQuery.setAppMap(appMap); |
|
|
|
messageFlowableQuery.setBusinessSid(query.getBusinessSid()); |
|
|
|
messageFlowableQuery.setModuleName("提前开票申请"); |
|
|
|
ResultBean<List<LatestTaskVo>> listResultBean = flowTaskFeign.getLatestTasks(procId); |
|
|
|
String nextNodeUserSids = listResultBean.getData().get(0).getASSIGNEE_(); |
|
|
|
List<String> receiveSidList = Arrays.asList(nextNodeUserSids.split(",")); |
|
|
|
if (receiveSidList.size() == 1 && receiveSidList.get(0).equals(busAdvanceGinvoiceapply.getCreateBySid())) { |
|
|
|
messageFlowableQuery.setMsgContent("您提交的" + messageFlowableQuery.getModuleName() + "已被驳回,请重新提交"); |
|
|
|
} else { |
|
|
|
messageFlowableQuery.setMsgContent(busAdvanceGinvoiceapply.getApplyName() + "提交的" + messageFlowableQuery.getModuleName() + ",请审批"); |
|
|
|
} |
|
|
|
messageFlowableQuery.setMsgTitle("提前开票申请"); |
|
|
|
ResultBean<String> stringResultBean = messageFeign.pushMessage(messageFlowableQuery); |
|
|
|
return rb.success(); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean revokeProcess(AppAdvanceInvoiceTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
if (StringUtils.isBlank(query.getUserSid())) { |
|
|
|
return rb.setMsg("参数错误：userSid"); |
|
|
|
} |
|
|
|
//根据业务sid查询移库申请
|
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(query.getBusinessSid()); |
|
|
|
String businessTaskId = busAdvanceGinvoiceapply.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("操作失败!"); |
|
|
|
} |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.setMsg("操作失败，提交的数据不一致!"); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
public ResultBean breakProcess(AppAdvanceInvoiceTaskQuery query) { |
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
if (StringUtils.isBlank(query.getInstanceId())) { |
|
|
|
return rb.setMsg("参数错误：instanceId"); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(query.getUserSid())) { |
|
|
|
return rb.setMsg("参数错误：userSid"); |
|
|
|
} |
|
|
|
if (StringUtils.isBlank(query.getComment())) { |
|
|
|
return rb.setMsg("意见不能为空"); |
|
|
|
} |
|
|
|
BusAdvanceGinvoiceapply busAdvanceGinvoiceapply = fetchBySid(query.getBusinessSid()); |
|
|
|
String businessTaskId = busAdvanceGinvoiceapply.getTaskId(); |
|
|
|
if (StringUtils.isNotBlank(businessTaskId)) { |
|
|
|
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()); |
|
|
|
} |
|
|
|
updateFlowFiled(BeanUtil.beanToMap(resultBean.getData())); |
|
|
|
return rb.success().setData(resultBean.getData()); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.setMsg("操作失败!提交的数据不一致!"); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
