package com.ruoyi.finance.service.impl; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.ruoyi.approvalFlow.domain.AuditItems; import com.ruoyi.approvalFlow.service.impl.AuditItemsAbout; import com.ruoyi.approvalFlow.service.impl.AuditItemsServiceImpl; import com.ruoyi.basicData.domain.TCorps; import com.ruoyi.basicData.domain.TFees; import com.ruoyi.basicData.mapper.TCorpsMapper; import com.ruoyi.basicData.mapper.TFeesMapper; import com.ruoyi.common.config.RuoYiConfig; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.domain.entity.SysDictData; import com.ruoyi.common.core.domain.model.LoginUser; import com.ruoyi.common.exception.WarehouseException; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.DictUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.poi.ExcelUtils; import com.ruoyi.finance.domain.TFee; import com.ruoyi.finance.domain.TFeeDo; import com.ruoyi.finance.domain.TWareHouseFees; import com.ruoyi.finance.domain.dto.FeeDTO; import com.ruoyi.finance.domain.excel.GeneralLedgerDetailExcel; import com.ruoyi.finance.domain.excel.GeneralLedgerDetailTotalExcel; import com.ruoyi.finance.domain.excel.GeneralLedgerExcel; import com.ruoyi.finance.domain.excel.ProfitGeneralLedgerExcel; import com.ruoyi.finance.domain.vo.FeeVO; import com.ruoyi.finance.excel.Charge; import com.ruoyi.finance.excel.Contrast; import com.ruoyi.finance.excel.Detailed; import com.ruoyi.finance.excel.Payment; import com.ruoyi.finance.mapper.TFeeDoMapper; import com.ruoyi.finance.mapper.TFeeMapper; import com.ruoyi.finance.service.ITFeeService; import com.ruoyi.finance.shipping.*; import com.ruoyi.reportManagement.dto.TWarehousebill; import com.ruoyi.reportManagement.excel.Profit; import com.ruoyi.reportManagement.excel.Receivable; import com.ruoyi.shipping.domain.TAccount; import com.ruoyi.shipping.domain.TFeeInvoice; import com.ruoyi.shipping.domain.TVessel; import com.ruoyi.shipping.domain.TVoyage; import com.ruoyi.shipping.excel.Account; import com.ruoyi.shipping.excel.ExportFinancial; import com.ruoyi.shipping.mapper.TFeeInvoiceMapper; import com.ruoyi.shipping.mapper.TVesselMapper; import com.ruoyi.shipping.mapper.TVoyageMapper; import com.ruoyi.system.domain.SysConfig; import com.ruoyi.system.mapper.SysConfigMapper; import com.ruoyi.system.mapper.SysDictDataMapper; import com.ruoyi.system.service.ISysDictDataService; import com.ruoyi.warehouseBusiness.domain.BillnoDel; import com.ruoyi.warehouseBusiness.domain.TWarehouseBills; import com.ruoyi.warehouseBusiness.domain.TWarehousebillsfees; import com.ruoyi.warehouseBusiness.domain.enums.FeesTypeEnum; import com.ruoyi.warehouseBusiness.domain.enums.WarehouseTypeEnum; import com.ruoyi.warehouseBusiness.excel.ListMapToBeanUtils; import com.ruoyi.warehouseBusiness.excel.TWareHouseExcelItem; import com.ruoyi.warehouseBusiness.mapper.BillnoDelMapper; import com.ruoyi.warehouseBusiness.mapper.TWarehouseBillsMapper; import com.ruoyi.warehouseBusiness.mapper.TWarehousebillsfeesMapper; import com.ruoyi.warehouseBusiness.service.impl.BillnoSerialServiceImpl; import org.apache.commons.compress.utils.Lists; import org.apache.poi.hssf.usermodel.*; import org.apache.poi.ss.util.CellRangeAddress; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import java.io.File; import java.io.FileOutputStream; import java.io.OutputStream; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; import static java.util.stream.Collectors.toList; /** * 财务数据主Service业务层处理 * * @author ruoyi * @date 2021-01-18 */ @Service public class TFeeServiceImpl implements ITFeeService { @Autowired private TFeeMapper tFeeMapper; @Autowired private TFeeDoMapper tFeeDoMapper; @Autowired private BillnoSerialServiceImpl billnoSerialServiceImpl; @Autowired private BillnoDelMapper billnoDelMapper; @Autowired private TCorpsMapper tCorpsMapper; @Autowired private TFeesMapper tFeesMapper; @Autowired private TWarehouseBillsMapper tWarehouseBillsMapper; @Autowired private TWarehousebillsfeesMapper tWarehousebillsfeesMapper; @Autowired private SysConfigMapper sysConfigMapper; @Autowired private AuditItemsServiceImpl auditItemsService; @Autowired private ISysDictDataService iSysDictDataService; @Autowired private SysDictDataMapper sysDictDataMapper; @Autowired private TFeeInvoiceMapper tFeeInvoiceMapper; @Autowired private TVesselMapper tVesselMapper; @Autowired private TVoyageMapper tVoyageMapper; private final String ST_IN_TYPE = "st_in_type"; private final String ST_OUT_TYPE = "st_out_type"; private final String ST_TRANS_TYPE = "st_trans_type"; /** * 查询财务数据主 * * @param fId 财务数据主ID * @return 财务数据主 */ @Override public Map selectTFeeById(Long fId) { Map map = new HashMap<>(); // 客户表 List corpsId = new ArrayList<>(); // 费用 List feesId = new ArrayList<>(); //费用名称 String feeName = null; TFee tFee = tFeeMapper.selectTFeeById(fId); if (StringUtils.isNotNull(tFee.getfCorpid())) { corpsId.add(tFee.getfCorpid()); } corpsId.add(tFee.getfCorpid()); // 查询从表数据 TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fId); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); List> feeDoList = new ArrayList<>(); if (StringUtils.isNotEmpty(tFeeDoList)) { for (TFeeDo fees : tFeeDoList) { Map map1 = new HashMap<>(); feesId.add(fees.getfFeeid()); // 查询主表 TWarehouseBills tWarehousebills = tWarehouseBillsMapper.selectTWarehousebillsById(fees.getfSrcpid()); if (Objects.isNull(tWarehousebills)) { throw new WarehouseException("未找到仓储信息"); } // 费用名称 TFees tFees = tFeesMapper.selectTFeesById(fees.getfFeeid()); if (tFees != null) { feeName = tFees.getfName(); } // 费用表数据 TWarehousebillsfees tWarehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesById(fees.getfSrcid()); if (tWarehousebillsfees == null) { return AjaxResult.error("费用数据为空，请确认"); } // 字典宝 SysDictData sysDictData = new SysDictData(); sysDictData.setDictType("data_unitfees"); sysDictData.setDictValue(String.valueOf(tWarehousebillsfees.getfFeeunitid())); sysDictData.setStatus("0"); List sysDictDataList = iSysDictDataService.selectDictDataList(sysDictData); List sysDictDataListIn = new ArrayList<>(); if (StringUtils.isNotEmpty(tWarehousebillsfees.getfBilltype()) && tWarehousebillsfees.getfBilltype().equals("SJRK")) { sysDictData.setDictType(ST_IN_TYPE); sysDictData.setDictValue(String.valueOf(tWarehousebillsfees.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (StringUtils.isNotEmpty(tWarehousebillsfees.getfBilltype()) && tWarehousebillsfees.getfBilltype().equals("SJCK")) { sysDictData.setDictType(ST_OUT_TYPE); sysDictData.setDictValue(String.valueOf(tWarehousebillsfees.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (StringUtils.isNotEmpty(tWarehousebillsfees.getfBilltype()) && tWarehousebillsfees.getfBilltype().equals("CKDB") | tWarehousebillsfees.getfBilltype().equals("HWTG")) { sysDictData.setDictType(ST_TRANS_TYPE); sysDictData.setDictValue(String.valueOf(tWarehousebillsfees.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } // 之前遗留汉字特别处理 FeesTypeEnum feesTypeEnum; if (fees.getfSrcdc().equals("收")) { feesTypeEnum = FeesTypeEnum.D; } else if (fees.getfSrcdc().equals("付")) { feesTypeEnum = FeesTypeEnum.C; } else { feesTypeEnum = FeesTypeEnum.fromType(fees.getfSrcdc()); } map1.put("fSrcdcName", feesTypeEnum.getName()); map1.put("fId", fees.getfId()); map1.put("fSrcid", fees.getfSrcid()); map1.put("fSrcpid", fees.getfSrcpid()); map1.put("fMblno", tWarehousebillsfees.getfMblno()); map1.put("fBscorpno", tWarehousebills.getfBscorpno()); map1.put("fProductName", tWarehousebillsfees.getfProductName()); map1.put("fBsdate", tWarehousebillsfees.getfBsdate()); map1.put("fFeeid", fees.getfFeeid()); map1.put("fFeeName", feeName); map1.put("fSrcdc", fees.getfSrcdc()); map1.put("fAmt", fees.getfAmt()); map1.put("fAmtdr", fees.getfAmtdr()); map1.put("fRemarks", fees.getfRemarks()); map1.put("srcBillNo", tWarehousebillsfees.getSrcId()); map1.put("fMarks", tWarehousebillsfees.getfMarks()); map1.put("fChargedate", tWarehousebillsfees.getfChargedate()); map1.put("fBillingDeadline", tWarehousebillsfees.getfBillingDeadline()); map1.put("fBillingDays", tWarehousebillsfees.getfBillingDays()); map1.put("fInventoryDays", tWarehousebillsfees.getfInventoryDays()); map1.put("fFeeunitid", sysDictDataList.get(0).getDictLabel()); map1.put("fQty", tWarehousebillsfees.getfQty()); map1.put("fUnitprice", tWarehousebillsfees.getfUnitprice()); map1.put("fBillno", fees.getfSrcBillno());// 业务编号（单据编号） map1.put("invoiceNo", fees.getfInvoiceNo());// 发票号 map1.put("fTaxrate", tWarehousebillsfees.getfTaxrateStr());// 税率--传递字符串数据 if (StringUtils.isNotEmpty(tWarehousebillsfees.getfBilltype()) && tWarehousebillsfees.getfBilltype().equals("KHDD")) { map1.put("fBusinessType", "船运订单"); } else if (CollectionUtils.isNotEmpty(sysDictDataListIn)) { map1.put("fBusinessType", sysDictDataListIn.get(0).getDictLabel()); } if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("SJRK")) { map1.put("fBilltype", "入库"); } else if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("SJCK")) { map1.put("fBilltype", "出库"); } else if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("CKDB")) { map1.put("fBilltype", "调拨"); } else if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("HWTG")) { map1.put("fBilltype", "货物通关"); } else if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("HQZY")) { map1.put("fBilltype", "货权转移"); } else if (StringUtils.isNotEmpty(tWarehousebills.getfBilltype()) && tWarehousebills.getfBilltype().equals("KHDD")) { map1.put("fBilltype", "船运订单"); } feeDoList.add(map1); } } List corpsList = new ArrayList<>(); List corpsIdList = StringUtils.integerDeduplication(corpsId); for (Long corpId : corpsIdList) { TCorps corps = tCorpsMapper.selectTCorpsById(corpId); if (StringUtils.isNotNull(corps)) { corpsList.add(corps); } } List feesList = new ArrayList<>(); List longList = StringUtils.integerDeduplication(feesId); for (Long fees : longList) { TFees tFees = tFeesMapper.selectTFeesById(fees); if (StringUtils.isNotNull(tFees)) { feesList.add(tFees); } } map.put("tFee", tFee); map.put("corps", corpsList); map.put("feesList", feesList); map.put("feeDoList", feeDoList); return map; } @Override public Map selectTFeeByIdNew(Long fId) { Map map = new HashMap<>(); TFee tFee = tFeeMapper.selectTFeeByIdNew(fId); List feeDoList = tFeeDoMapper.selectTFeeDoByfPid(fId); TFeeInvoice tFeeInvoice = new TFeeInvoice(); tFeeInvoice.setfPid(fId); List tFeeInvoiceList = tFeeInvoiceMapper.selectTFeeInvoiceList(tFeeInvoice); map.put("tFee", tFee); map.put("feeDoList", feeDoList); map.put("tFeeInvoiceList", tFeeInvoiceList); return map; } /** * 查询财务数据主列表 * * @param tFee 财务数据主 * @return 财务数据主 */ @Override public List selectTFeeList(TFee tFee) { List list = tFeeMapper.selectTFeeList(tFee); for (TFee tf : list) { List fd = tFeeDoMapper.selectTFeeDoByfPid(tf.getfId()); StringBuilder strb = new StringBuilder(); for (TFeeDo tFeeDo : fd) { if (StringUtils.isNotNull(tFeeDo.getfSrcBillno())) { strb.append(tFeeDo.getfSrcBillno()).append(","); } } tf.setfSrcBillno(StringUtils.objToStr(StringUtils.removeTheLastComma(strb))); } return list; } @Override public List> selectTFeeList1(TFee tFee) { List> list = tFeeMapper.selectTFeeList1(tFee); for (Map map : list) { List tfd = tFeeDoMapper.selectTFeeDoByfPid(Long.valueOf(map.get("fId").toString())); if (tfd.size() != 0) { StringBuilder stringBuilder = new StringBuilder(); for (TFeeDo tFeeDo : tfd) { if (StringUtils.isNotNull(tFeeDo.getfSrcBillno())) { stringBuilder.append(tFeeDo.getfSrcBillno()).append(","); } } map.put("fSrcBillno", StringUtils.removeTheLastComma(stringBuilder)); } } return list; } @Override public List> webVersionTFee(TFee tFee) { return tFeeMapper.webVersionTFee(tFee); } @Override public List> webVersionDetail(TAccount tAccount) { return tWarehousebillsfeesMapper.webVersionDetail(tAccount); } @Override public List> webVersionInvoice(TFee tFee) { return tFeeMapper.webVersionInvoice(tFee); } @Override public List> webVersionInvoiceDetail(TFee tFee) { List> list = tFeeMapper.webVersionInvoice(tFee); if (CollectionUtils.isNotEmpty(list)) { for (Map map : list) { Long fId = Long.valueOf(map.get("fId").toString()); List tFeeDos = tFeeDoMapper.selectTFeeDoByfPid(fId); map.put("tFeeDoList", tFeeDos); TFeeInvoice tFeeInvoice = new TFeeInvoice(); tFeeInvoice.setfPid(fId); List tFeeInvoiceList = tFeeInvoiceMapper.selectTFeeInvoiceList(tFeeInvoice); map.put("tFeeInvoiceList", tFeeInvoiceList); } } return list; } @Override public List> webVersionList(TAccount tAccount) { return tWarehousebillsfeesMapper.webVersionReconciliation(tAccount); } /** * 新增财务数据主 * * @param tFee 财务数据主 * @return 结果 */ @Override public int insertTFee(TFee tFee) { tFee.setCreateTime(DateUtils.getNowDate()); return tFeeMapper.insertTFee(tFee); } /** * 新增对账 、收费、 * * @param tfee * @param tfeeDo * @param loginUser * @param fBilltype * @return */ @Override @Transactional public AjaxResult insertTFeeTFeeDo(String tfee, String tfeeDo, LoginUser loginUser, String fBilltype) { Long fPid = null; Map map = new HashMap<>(); TFee tFee = JSONArray.parseObject(tfee, TFee.class); if (StringUtils.isNull(tFee.getfId())) { // 如果是新数据 tFee.setCreateBy(loginUser.getUser().getUserName()); tFee.setCreateTime(new Date()); tFee.setfDeptid(loginUser.getUser().getDeptId()); tFee.setfBilltype(fBilltype); // 业务编码 Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); tFee.setfBillno(billNo); tFee.setSrcBillNo(billNo); tFee.setfBillstatus("2"); tFeeMapper.insertTFee(tFee); fPid = tFee.getfId(); } else { fPid = tFee.getfId(); tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFeeMapper.updateTFee(tFee); tFee = tFeeMapper.selectTFeeById(fPid); tFee.setSrcBillNo(tFee.getfBillno()); // 删除从表 tFeeDoMapper.deleteByFPid(fPid); } // 财务从表 if (StringUtils.isNotNull(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { tFeeDo.setfPid(fPid); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDo.setfSrcBillno(tFeeDo.getfBillno()); tFeeDo.setfStatus("2"); tFeeDoMapper.insertTFeeDo(tFeeDo); } } List list = tFeeDoMapper.selectFinancialTFeeDo(fPid); map.put("tFee", tFee); map.put("tFeeDo", list); return AjaxResult.success("成功", map); } @Override public AjaxResult insertWebVersion(String tfee, String tfeeDo, LoginUser loginUser, String fBilltype) { Long fPid = null; Map map = new HashMap<>(); TFee tFee = JSONArray.parseObject(tfee, TFee.class); if (StringUtils.isNull(tFee.getfId())) { // 如果是新数据 tFee.setCreateBy(loginUser.getUser().getUserName()); tFee.setCreateTime(new Date()); tFee.setfDeptid(loginUser.getUser().getDeptId()); tFee.setfBilltype(fBilltype); // 业务编码 Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); tFee.setfBillno(billNo); tFee.setfBillstatus("2"); tFee.setfAccbilldate(new Date()); tFeeMapper.insertTFee(tFee); fPid = tFee.getfId(); } else { fPid = tFee.getfId(); tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFeeMapper.updateTFee(tFee); // 删除从表 tFeeDoMapper.deleteByFPid(fPid); } // 财务从表 if (StringUtils.isNotNull(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TAccount.class); for (TAccount tAccount : tFeeDoList) { TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfSrcid(tAccount.getfSrcid()); tFeeDo.setfSrcpid(tAccount.getfSrcpid()); tFeeDo.setfPid(fPid); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDo.setfStatus("2"); tFeeDo.setfSrcdc("D"); tFeeDo.setfAmtdr(tAccount.getfAmtdr()); tFeeDo.setfAmt(tAccount.getfAmt()); tFeeDo.setfFeeid(tAccount.getfFeeid()); tFeeDoMapper.insertTFeeDo(tFeeDo); } } map.put("tFee", tFee); return AjaxResult.success("成功", map); } /** * 新增对账 、收费、 * * @param tfee * @param tfeeDo * @param loginUser * @param fBilltype * @return */ @Override @Transactional public AjaxResult insertKHTFeeTFeeDo(String tfee, String tfeeDo, String tFeeInvoice, LoginUser loginUser, String fBilltype) { Long fPid = null; Map map = new HashMap<>(); String billStatus = "2"; if (fBilltype.equals("INV")) { billStatus = "6"; } TFee tFee = JSONArray.parseObject(tfee, TFee.class); if (StringUtils.isNull(tFee.getfId())) { // 如果是新数据 tFee.setCreateBy(loginUser.getUser().getUserName()); tFee.setCreateTime(new Date()); tFee.setfDeptid(loginUser.getUser().getDeptId()); tFee.setfBilltype(fBilltype); // 业务编码 Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); tFee.setfBillno(billNo); tFee.setfBillstatus(billStatus); tFeeMapper.insertTFee(tFee); fPid = tFee.getfId(); } else { fPid = tFee.getfId(); boolean change = this.change(fPid); if (!change && !"INV".equals(fBilltype)) { return AjaxResult.error("当前数据不支持修改"); } tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFeeMapper.updateTFee(tFee); // 删除从表 tFeeDoMapper.deleteByFPid(fPid); tFeeInvoiceMapper.deleteByFPid(fPid); } // 财务从表 if (StringUtils.isNotNull(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { tFeeDo.setfPid(fPid); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDo.setfStatus(billStatus); tFeeDoMapper.insertTFeeDo(tFeeDo); } } if (!"".equals(tFeeInvoice) && tFeeInvoice != null && !"null".equals(tFeeInvoice)) { JSONArray jsonDrArray = JSONArray.parseArray(tFeeInvoice); List tFeeInvoiceList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeInvoice.class); for (TFeeInvoice feeInvoice : tFeeInvoiceList) { feeInvoice.setfPid(fPid); feeInvoice.setCreateBy(loginUser.getUser().getUserName()); feeInvoice.setCreateTime(new Date()); feeInvoice.setfBillstatus(billStatus); tFeeInvoiceMapper.insertTFeeInvoice(feeInvoice); } } map.put("tFee", tFee); return AjaxResult.success("成功", map); } /** * 修改财务数据主 * * @param tFee 财务数据主 * @return 结果 */ @Override public int updateTFee(TFee tFee) { tFee.setUpdateTime(DateUtils.getNowDate()); return tFeeMapper.updateTFee(tFee); } /** * 批量删除财务数据主 * * @param fIds 需要删除的财务数据主ID * @return 结果 */ @Override @Transactional public AjaxResult deleteWebVersionByIds(Long[] fIds) { // 取出业务编号、 放入 billno_del for (Long id : fIds) { // 1、查询主表信息 TFee tFee = tFeeMapper.selectTFeeById(id); boolean change = this.change(id); if (change == false) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("数据正在审批或审批通过,不允许删除"); } // 2、业务编号、客存编号 放入 billno_del BillnoDel billnoDel = new BillnoDel(); billnoDel.setBillType(tFee.getfBilltype()); billnoDel.setBillNo(tFee.getfBillno()); billnoDelMapper.insertBillnoDel(billnoDel); if (tFee.getfAccountId() != null) { TFee fee = tFeeMapper.selectTFeeById(tFee.getfAccountId()); fee.setfMake(0); int updateTFee = tFeeMapper.updateTFee(fee); } } int i = tFeeMapper.deleteTFeeByIds(fIds); if (i <= 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("删除发票申请失败,请找管理员"); } return AjaxResult.success(); } @Override public int deleteTFeeByIds(Long[] fIds) { // 取出业务编号、 放入 billno_del for (Long id : fIds) { // 1、查询主表信息 TFee tFee = tFeeMapper.selectTFeeById(id); // 2、业务编号、客存编号 放入 billno_del BillnoDel billnoDel = new BillnoDel(); billnoDel.setBillType(tFee.getfBilltype()); billnoDel.setBillNo(tFee.getfBillno()); billnoDelMapper.insertBillnoDel(billnoDel); if (tFee.getfAccountId() != null) { TFee fee = tFeeMapper.selectTFeeById(tFee.getfAccountId()); fee.setfMake(0); tFeeMapper.updateTFee(fee); } } return tFeeMapper.deleteTFeeByIds(fIds); } /** * 删除财务数据主信息 * * @param fId 财务数据主ID * @return 结果 */ @Override public int deleteTFeeById(Long fId) { return tFeeMapper.deleteTFeeById(fId); } @Override public List> warehouseBillsFeesList(TWareHouseFees tWareHouseFees, String billsType) { Map map = new HashMap<>(); map.put("tWareHouseFees", tWareHouseFees); List> mapList; if (billsType.equals("DZ") || billsType.equals("KHDZ")) { mapList = tFeeMapper.warehouseBillsFeesListAccamount(map); updateBillTypeName(mapList, tWareHouseFees.getfBilltype()); return mapList; } else if (billsType.equals("invoiceFP")) { mapList = tFeeMapper.warehouseInvoiceFPFeesList(map); return mapList; } else if (billsType.equals("ApplyFP")) { mapList = tFeeMapper.warehouseApplyFPFeesList(map); return mapList; } else if (FeesTypeEnum.INVOICE.getType().equals(billsType)) { // 查询发票 mapList = tFeeMapper.queryApplyInvoiceFeesList(map); return mapList; } else { mapList = tFeeMapper.warehouseBillsFeesList(map); updateBillTypeName(mapList, tWareHouseFees.getfBilltype()); return mapList; } } /** * 根据传入业务类型判断传入对应值 * * @param mapList * @param type */ private void updateBillTypeName(List> mapList, String type) { if (CollectionUtils.isNotEmpty(mapList)) { List typeList = Lists.newArrayList(); typeList.add(ST_IN_TYPE); typeList.add(ST_OUT_TYPE); typeList.add(ST_TRANS_TYPE); List sysDictDataList = sysDictDataMapper.selectByTypes(typeList); // 遍历map for (Map map : mapList) { // 如果类型为入库 if (StringUtils.isEmpty(type) && Objects.nonNull(map.get("fBusinessType"))) { String fBusinessType = map.get("fBusinessType").toString(); String dictLabel = sysDictDataList.stream().filter(li -> Objects.equals(li.getDictValue(), fBusinessType)) .map(SysDictData::getDictLabel).findFirst().orElseThrow(() -> new WarehouseException("缺少字典表信息")); map.put("fBusinessType", dictLabel); } else if (StringUtils.isNotEmpty(type) && type.equals(WarehouseTypeEnum.SJRK.getType()) && Objects.nonNull(map.get("fBusinessType"))) { String dictLabel = DictUtils.getDictLabel(ST_IN_TYPE, map.get("fBusinessType").toString()); if (StringUtils.isNotEmpty(dictLabel)) { map.put("fBusinessType", dictLabel); } } else if (StringUtils.isNotEmpty(type) && type.equals(WarehouseTypeEnum.SJCK.getType()) && Objects.nonNull(map.get("fBusinessType"))) { String dictLabel = DictUtils.getDictLabel(ST_OUT_TYPE, map.get("fBusinessType").toString()); if (StringUtils.isNotEmpty(dictLabel)) { map.put("fBusinessType", dictLabel); } } else if (StringUtils.isNotEmpty(type) && type.equals(WarehouseTypeEnum.HQZY.getType()) && Objects.nonNull(map.get("fBusinessType"))) { String dictLabel = DictUtils.getDictLabel(ST_TRANS_TYPE, map.get("fBusinessType").toString()); if (StringUtils.isNotEmpty(dictLabel)) { map.put("fBusinessType", dictLabel); } } } } } @Override public List warehouseBillsFeesList(TWareHouseFees tWareHouseFees) { if (tWareHouseFees.getSwitchSection() == 1) { tWareHouseFees.setfBstimeExamine(tWareHouseFees.getTimeExamine()); tWareHouseFees.setTimeExamine(null); } else { tWareHouseFees.setTimeExamine(tWareHouseFees.getTimeExamine()); tWareHouseFees.setfBstimeExamine(null); } List list = tFeeMapper.selectFinancialLedgerList(tWareHouseFees); for (int i = 0; i < list.size(); i++) { if (tWareHouseFees.getSwitchSection() == 1) { list.get(i).setReviewDate(list.get(i).getBstime()); } FeeDTO feeDTO = new FeeDTO(); feeDTO.setFDc(tWareHouseFees.getfDc()); feeDTO.setFCorpId(list.get(i).getfCorpid()); BigDecimal amount = new BigDecimal("0.00"); BigDecimal stlamount = new BigDecimal("0.00"); if (ObjectUtils.isNotNull(list.get(i).getReviewDate())) { List list1 = new ArrayList<>(); list1.add(list.get(i).getReviewDate()); list1.add(list.get(i).getReviewDate()); if (tWareHouseFees.getSwitchSection() == 1) { feeDTO.setFAuditList(list1); } else { feeDTO.setFBstimeExamine(list1); } } else { feeDTO.setFAuditList(null); feeDTO.setFBstimeExamine(null); } List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); // 应收费用 amount = amount.add(feeVOList.stream().map(FeeVO::getFAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO)); // 已收费用 stlamount = stlamount.add(feeVOList.stream().map(FeeVO::getFStlamount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO)); list.get(i).setFAmount(amount); list.get(i).setNnfinished(amount.subtract(stlamount)); list.get(i).setFStlamount(stlamount); } return list; } @Override public List> warehouseBillsFeesProfitList(TWareHouseFees tWareHouseFees) { if (tWareHouseFees.getGroupBy() == 0) { return tFeeMapper.warehouseBillsFeesProfitList(tWareHouseFees); } if (tWareHouseFees.getSwitchSection() == 0) { tWareHouseFees.setTimeExamine(tWareHouseFees.getTimeExamine()); tWareHouseFees.setfBstimeExamine(null); } else { tWareHouseFees.setfBstimeExamine(tWareHouseFees.getTimeExamine()); tWareHouseFees.setTimeExamine(null); } List> mapList = tFeeMapper.warehouseBillsFeesCustomProfitList(tWareHouseFees); for (Map map : mapList) { FeeDTO feeDTO = new FeeDTO(); feeDTO.setFToCorpid(Long.parseLong(map.get("fCorpid").toString())); BigDecimal amount = new BigDecimal("0.00"); BigDecimal stlamount = new BigDecimal("0.00"); // if (tWareHouseFees.getSwitchSection() == 0) { if (ObjectUtils.isNotNull(map.get("f_bstime"))) { List list1 = new ArrayList<>(); list1.add(map.get("f_bstime").toString()); list1.add(map.get("f_bstime").toString()); feeDTO.setFAuditList(list1); } /* } else { if (ObjectUtils.isNotNull(map.get("f_bstime"))) { List list1 = new ArrayList<>(); list1.add(map.get("f_bstime").toString()); list1.add(map.get("f_bstime").toString()); feeDTO.setFBstimeExamine(list1); } }*/ List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); for (FeeVO feeVO : feeVOList) { if ("D".equals(feeVO.getfDc())) { amount = amount.add(feeVO.getFAmount()); } else { stlamount = stlamount.add(feeVO.getFAmount()); } } map.put("fAmount", amount); map.put("fStlamount", stlamount); map.put("nnfinished", amount.subtract(stlamount)); /*list.get(i).setFAmount(amount); list.get(i).setNnfinished(amount.subtract(stlamount)); list.get(i).setFStlamount(stlamount);*/ } return mapList; } public static BigDecimal calculation1(String fTotalgross, String fGrossweightblc) { BigDecimal num1 = new BigDecimal(fTotalgross); BigDecimal num2 = new BigDecimal(fGrossweightblc); BigDecimal result = num1.subtract(num2); return result.setScale(2, BigDecimal.ROUND_HALF_UP); } @Override @Transactional public AjaxResult confirm(String tfee, String tfeeDo, LoginUser loginUser, String fBilltype) { String key = ""; boolean isApprove = false; Map messageMap = new HashMap<>(); long actId = 0L; if (!fBilltype.equals(FeesTypeEnum.INVOICE.getType())) { if ("DZ".equals(fBilltype)) { actId = 210L; key = "warehouse.contrast.ApprovalFlow"; } else if ("SF".equals(fBilltype)) { actId = 220L; key = "warehouse.charge.ApprovalFlow"; } else if ("FF".equals(fBilltype)) { actId = 230L; key = "warehouse.payment.ApprovalFlow"; } else if ("KHDZ".equals(fBilltype)) { actId = 430L; key = "warehouse.kaiHeContrast.ApprovalFlow"; } else if ("KHSF".equals(fBilltype)) { actId = 440L; key = "warehouse.kaiHeCharge.ApprovalFlow"; } else if ("KHFF".equals(fBilltype)) { actId = 450L; key = "warehouse.kaiHePayment.ApprovalFlow"; } SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key); if (StringUtils.isNull(sysConfig)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("系统参数异常，未找到开启审批流参数"); } if ("0".equals(sysConfig.getConfigValue())) { isApprove = true; } } TFee tFee = JSONArray.parseObject(tfee, TFee.class); String billstatus = ""; if (isApprove) { billstatus = "4"; } else { billstatus = "6"; } if (StringUtils.isNull(tFee.getfId())) { // 如果是新数据 tFee.setCreateBy(loginUser.getUser().getUserName()); tFee.setfDeptid(loginUser.getUser().getDeptId()); tFee.setfBilltype(fBilltype); tFee.setfBillstatus(billstatus); // 业务编码 Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); tFee.setfBillno(billNo); tFee.setfApplyMoney(tFee.getfAmtcr()); tFeeMapper.insertTFee(tFee); } else { tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFee.setfBillstatus(billstatus); tFee.setfApplyMoney(tFee.getfAmtcr()); tFeeMapper.updateTFee(tFee); } // 删除从表 tFeeDoMapper.deleteByFPid(tFee.getfId()); messageMap.put("tFee", tFee); // 声明业务编号 list List fSrcBillnos = new ArrayList<>(); // 财务从表 if (StringUtils.isNotNull(tfeeDo) && !"[]".equals(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { Map map = this.judgeMoney(tFeeDo.getfSrcid(), tFeeDo.getfAmt(), fBilltype, tFeeDo.getfFeeid()); if (!(Boolean) map.get("flag")) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error(map.get("message").toString()); } tFeeDo.setfPid(tFee.getfId()); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDo.setfStatus(billstatus); tFeeDo.setfSrcBillno(tFeeDo.getfBillno()); if (StringUtils.isNotNull(tFeeDo.getfBillno())) { // 装载业务编号 fSrcBillnos.add(tFeeDo.getfBillno()); } tFeeDoMapper.insertTFeeDo(tFeeDo); } } if (isApprove) { // 点击对账、收费、付费提交审核时去掉费用 if (actId >= 210L && actId <= 230L) { AjaxResult ajaxResult = this.billsfeesFollow(tFee.getfId()); String code = ajaxResult.get("code").toString(); if ("500".equals(code)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return ajaxResult; } } } //凯和收费提交审核时去掉钱 if (actId >= 430 && actId <= 450) { //判断明细客户是否为同一个 List list = tFeeDoMapper.selectTFeeDoByfPid(tFee.getfId()); if (CollectionUtils.isNotEmpty(list)) { List collect = list.stream().filter(e -> e.getfSrcid() != null).map(TFeeDo::getfSrcid).collect(toList()); if (CollectionUtils.isNotEmpty(collect)) { List corpid = tWarehousebillsfeesMapper.getCorpid(collect); if (CollectionUtils.isNotEmpty(corpid)) { List longs = corpid.stream().distinct().collect(toList()); if (CollectionUtils.isNotEmpty(longs) && longs.size() > 1) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("费用明细的客户非同一个客户"); } } } } AjaxResult ajaxResult = this.billsfeesFollow(tFee.getfId()); String code = ajaxResult.get("code").toString(); if ("500".equals(code)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return ajaxResult; } } // 这里加个判断取系统参数来确定是否需要启用审批流 BigDecimal amount = BigDecimal.ZERO;//财务对账金额 //获取账单明细 List list = tFeeDoMapper.selectTFeeDoByfPid(tFee.getfId()); if (CollectionUtils.isNotEmpty(list)) { amount = list.stream().filter(e -> e.getfAmt() != null).map(TFeeDo::getfAmt).reduce(BigDecimal.ZERO, BigDecimal::add); } if (isApprove) { AuditItems auditItems = new AuditItems(); auditItems.setLevelId(0L); auditItems.setBillId(tFee.getfId()); auditItems.setActId(actId); auditItems.setIffinalItem("F"); auditItems.setBillNo(tFee.getfBillno()); // 业务编号 auditItems.setRefno1(String.valueOf(tFee.getfCorpid())); // 货权方 auditItems.setRefno2(fBilltype);// 财务类型 auditItems.setRefno3(tFee.gettMblno());// 提单号 auditItems.setSendUserId(loginUser.getUser().getUserId()); // 请核人 ID auditItems.setSendName(loginUser.getUsername()); // 请核人名称 auditItems.setSendTime(new Date()); // 请核时间 auditItems.setAuditUserId(loginUser.getUser().getUserId());// 审核人 ID auditItems.setAuditItem(new Date());// 审核通过时间 auditItems.setAuditOpTime(new Date());// 审核时间 auditItems.setFidStatus("f_billstatus");// 存储对应审批字段 auditItems.setTimes(1L);// 第几次提交审批 auditItems.setAuditMsg("提交"); auditItems.setAuditStatus("O");// 提交状态 auditItems.setfSrcBillnos(fSrcBillnos);// 装载业务编号数据（来源单据编号） auditItems.setAmount(amount);//对账金额 AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems);// 生成审批流 Long code = Long.valueOf(String.valueOf(approvalFlow.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("发票申请提交审核失败,请找管理员"); } } else { if (StringUtils.isNotNull(tfeeDo) && !"[]".equals(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { // 跟新费用明细 int m = updateBillsFees(tFee.getfId(), tFeeDo, fBilltype); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } } AjaxResult ajaxResult = tfeeFollow(tFee.getfId(), 6L); Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("发票申请提交审核失败,请找管理员"); } //凯和系统 修改订单的实收实付费用 if ("KHSF".equals(fBilltype) || "KHFF".equals(fBilltype)) { this.updateMessage(tFee.getfId()); } } return AjaxResult.success("成功", messageMap); } @Override @Transactional public AjaxResult webVersionConfirm(Long[] fIds, String billsType, LoginUser loginUser) { String key = ""; boolean isApprove = false; long actId = 0L; if ("DZ".equals(billsType)) { actId = 210L; key = "warehouse.contrast.ApprovalFlow"; } else if ("SF".equals(billsType)) { actId = 220L; key = "warehouse.charge.ApprovalFlow"; } else if ("FF".equals(billsType)) { actId = 230L; key = "warehouse.payment.ApprovalFlow"; } else if ("KHDZ".equals(billsType)) { actId = 430L; key = "warehouse.kaiHeContrast.ApprovalFlow"; } else if ("KHSF".equals(billsType)) { actId = 440L; key = "warehouse.kaiHeCharge.ApprovalFlow"; } else if ("KHFF".equals(billsType)) { actId = 450L; key = "warehouse.kaiHePayment.ApprovalFlow"; } SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key); if (StringUtils.isNull(sysConfig)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("系统参数异常，未找到开启审批流参数"); } if ("0".equals(sysConfig.getConfigValue())) { isApprove = true; } String billStatus = null; if (isApprove) { billStatus = "4"; } else { billStatus = "6"; } for (Long fId : fIds) { TFee tFee = tFeeMapper.selectTFeeById(fId); if (tFee == null) { return AjaxResult.error("对账数据有误请确认"); } boolean change = this.change(tFee.getfId()); if (change == false) { return AjaxResult.error("数据正在审批或审批通过,不允许提交审核"); } //更新主表数据状态 TFee fee = new TFee(); fee.setfId(fId); fee.setfBillstatus(billStatus); int i = tFeeMapper.updateTFee(fee); //更新从表数据状态 int update = tFeeDoMapper.tfeeDoFollowUpdate(fId, Long.valueOf(billStatus)); if (isApprove) { AuditItems auditItems = new AuditItems(); auditItems.setLevelId(0L); auditItems.setBillId(tFee.getfId()); auditItems.setActId(actId); auditItems.setIffinalItem("F"); auditItems.setBillNo(tFee.getfBillno()); // 业务编号 auditItems.setRefno1(String.valueOf(tFee.getfCorpid())); // 货权方 auditItems.setRefno2(billsType);// 财务类型 auditItems.setRefno3(tFee.gettMblno());// 提单号 auditItems.setSendUserId(loginUser.getUser().getUserId()); auditItems.setSendName(loginUser.getUsername()); auditItems.setSendTime(new Date()); auditItems.setAuditUserId(loginUser.getUser().getUserId()); auditItems.setAuditItem(new Date()); auditItems.setAuditOpTime(new Date()); auditItems.setFidStatus("f_billstatus"); auditItems.setTimes(1L); auditItems.setAuditMsg("提交"); auditItems.setAuditStatus("O"); AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems); Long code = Long.valueOf(String.valueOf(approvalFlow.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } return approvalFlow; } else { TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fId); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); for (TFeeDo feeDo : tFeeDoList) { // 跟新费用明细 int m = updateBillsFees(fId, feeDo, billsType); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } } AjaxResult ajaxResult = tfeeFollow(tFee.getfId(), 6L); Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue(); return ajaxResult; } return AjaxResult.success(); } @Override @Transactional public AjaxResult confirmKaiHe(String tfee, String tfeeDo, String tFeeInvoice, LoginUser loginUser, String fBilltype) { Long fPid = null; TFee tFee = JSONArray.parseObject(tfee, TFee.class); Map messageMap = new HashMap<>(); String key = ""; boolean isApprove = false; long actId = 0L; String billStatus = ""; if ("DZ".equals(fBilltype)) { actId = 210L; key = "warehouse.contrast.ApprovalFlow"; } else if ("SF".equals(fBilltype)) { actId = 220L; key = "warehouse.charge.ApprovalFlow"; } else if ("FF".equals(fBilltype)) { actId = 230L; key = "warehouse.payment.ApprovalFlow"; } else if ("KHDZ".equals(fBilltype)) { actId = 430L; key = "warehouse.kaiHeContrast.ApprovalFlow"; } else if ("KHSF".equals(fBilltype)) { actId = 440L; key = "warehouse.kaiHeCharge.ApprovalFlow"; } else if ("KHFF".equals(fBilltype)) { actId = 450L; key = "warehouse.kaiHePayment.ApprovalFlow"; } else if ("ApplyFP".equals(fBilltype)) { actId = 470L; key = "warehouse.kaiHeApplyFP.ApprovalFlow"; } SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key); if (StringUtils.isNull(sysConfig)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("系统参数异常，未找到开启审批流参数"); } if ("0".equals(sysConfig.getConfigValue())) { isApprove = true; } if (isApprove) { billStatus = "4"; } else { billStatus = "6"; } if (StringUtils.isNull(tFee.getfId())) { // 如果是新数据 tFee.setCreateBy(loginUser.getUser().getUserName()); tFee.setfDeptid(loginUser.getUser().getDeptId()); tFee.setfBilltype(fBilltype); // 业务编码 Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); tFee.setfBillno(billNo); tFee.setfBillstatus(billStatus); tFeeMapper.insertTFee(tFee); fPid = tFee.getfId(); } else { fPid = tFee.getfId(); boolean change = this.change(fPid); if (!change) { return AjaxResult.error("当前数据不支持修改"); } tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFee.setfBillstatus(billStatus); tFeeMapper.updateTFee(tFee); // 删除从表 tFeeDoMapper.deleteByFPid(tFee.getfId()); //删除开票从表 tFeeInvoiceMapper.deleteByFPid(tFee.getfId()); } messageMap.put("tFee", tFee); // 财务从表 if (StringUtils.isNotNull(tfeeDo) && !"[]".equals(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { Map map = this.judgeMoney(tFeeDo.getfSrcid(), tFeeDo.getfAmt(), fBilltype, tFeeDo.getfFeeid()); boolean b = (Boolean) map.get("flag"); if (b == false) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error(map.get("message").toString()); } tFeeDo.setfPid(tFee.getfId()); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDo.setfStatus(billStatus); tFeeDoMapper.insertTFeeDo(tFeeDo); } } if (!"".equals(tFeeInvoice) && tFeeInvoice != null && !"null".equals(tFeeInvoice)) { JSONArray jsonDrArray = JSONArray.parseArray(tFeeInvoice); List tFeeInvoiceList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeInvoice.class); for (TFeeInvoice feeInvoice : tFeeInvoiceList) { feeInvoice.setfPid(fPid); feeInvoice.setCreateBy(loginUser.getUser().getUserName()); feeInvoice.setCreateTime(new Date()); feeInvoice.setfBillstatus(billStatus); tFeeInvoiceMapper.insertTFeeInvoice(feeInvoice); } } // 这里加个判断取系统参数来确定是否需要启用审批流 if (isApprove) { AuditItems auditItems = new AuditItems(); auditItems.setLevelId(0L); auditItems.setBillId(tFee.getfId()); auditItems.setActId(actId); auditItems.setIffinalItem("F"); auditItems.setBillNo(tFee.getfBillno()); // 业务编号 auditItems.setRefno1(String.valueOf(tFee.getfCorpid())); // 货权方 auditItems.setRefno2(fBilltype);// 财务类型 auditItems.setRefno3(tFee.gettMblno());// 提单号 auditItems.setSendUserId(loginUser.getUser().getUserId()); auditItems.setSendName(loginUser.getUsername()); auditItems.setSendTime(new Date()); auditItems.setAuditUserId(loginUser.getUser().getUserId()); auditItems.setAuditItem(new Date()); auditItems.setAuditOpTime(new Date()); auditItems.setFidStatus("f_billstatus"); auditItems.setTimes(1L); auditItems.setAuditMsg("提交"); auditItems.setAuditStatus("O"); AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems); Long code = Long.valueOf(String.valueOf(approvalFlow.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("发票申请提交审核失败,请找管理员"); } } else { if (StringUtils.isNotNull(tfeeDo) && !"[]".equals(tfeeDo)) { JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { // 跟新费用明细 int m = updateBillsFees(tFee.getfId(), tFeeDo, fBilltype); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } } AjaxResult ajaxResult = tfeeFollow(tFee.getfId(), 6L); Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("发票申请提交审核失败,请找管理员"); } } return AjaxResult.success("成功", messageMap); } /** * 根据财务主表id 更新对应明细表状态 * * @param fPid 财务主表id * @return 结果 */ @Transactional public AjaxResult tfeeFollow(Long fPid, long fettle) { if (StringUtils.isNull(fPid)) { return AjaxResult.error("财务更新状态未找到主表信息，请与管理员联系"); } TFee tFee = new TFee(); tFee.setfId(fPid); tFee.setfBillstatus(String.valueOf(fettle)); int tFeeUpdateResult = tFeeMapper.updateTFee(tFee); if (tFeeUpdateResult <= 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新财务明细状态失败，请联系管理员"); } try { int itemUpdateResult = tFeeDoMapper.tfeeDoFollowUpdate(fPid, fettle); } catch (Exception exception) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新财务明细状态失败，请联系管理员"); } TFeeInvoice invoice = new TFeeInvoice(); invoice.setfPid(fPid); List tFeeInvoiceList = tFeeInvoiceMapper.selectTFeeInvoiceList(invoice); if (CollectionUtils.isNotEmpty(tFeeInvoiceList)) { try { int itemUpdateResult = tFeeInvoiceMapper.tFeeInvoiceUpdate(fPid, fettle); } catch (Exception exception) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新开票明细状态失败，请联系管理员"); } } return AjaxResult.success(); } @Transactional public synchronized AjaxResult billsfeesFollow(Long fPid) { if (StringUtils.isNull(fPid)) { return AjaxResult.error("费用明细更新状态未找到主表信息，请与管理员联系"); } TFee tFee = tFeeMapper.selectTFeeById(fPid); // 查询从表数据 TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fPid); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); for (TFeeDo tFeeDo1 : tFeeDoList) { // 跟新费用明细 Map map = this.judgeMoney(tFeeDo1.getfSrcid(), tFeeDo1.getfAmt(), tFee.getfBilltype(), tFeeDo1.getfFeeid()); if (!(Boolean) map.get("flag")) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error(map.get("message").toString()); } int m = updateBillsFees(fPid, tFeeDo1, tFee.getfBilltype()); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } return AjaxResult.success(); } /** * 账单管理撤销对账、收费、付费 * * @param fPid * @param fBillType * @return */ @Transactional public AjaxResult updateDSFMoney(Long fPid, String fBillType) { if (StringUtils.isNull(fPid)) { return AjaxResult.error("费用明细更新状态未找到主表信息，请与管理员联系"); } // 获取从表数据 TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fPid); List tFeeDos = tFeeDoMapper.selectTFeeDoList(tFeeDo); for (TFeeDo tFeeDo1 : tFeeDos) { int m = updateBillsFees(fPid, tFeeDo1, fBillType); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } return AjaxResult.success(); } /** * 凯和撤销收费 付费 对账 * * @param fPid * @param fBillType * @return */ @Transactional public AjaxResult updateMoney(Long fPid, String fBillType) { if (StringUtils.isNull(fPid)) { return AjaxResult.error("费用明细更新状态未找到主表信息，请与管理员联系"); } TFee tFee = tFeeMapper.selectTFeeById(fPid); // 查询从表数据 TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fPid); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); for (TFeeDo tFeeDo1 : tFeeDoList) { /* // 跟新费用明细 Map map = this.judgeMoney(tFeeDo1.getfSrcid(), tFeeDo1.getfAmt(), tFee.getfBilltype(), tFeeDo1.getfFeeid()); if (!(Boolean) map.get("flag")) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error(map.get("message").toString()); }*/ int m = updateBillsFees(fPid, tFeeDo1, fBillType); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } return AjaxResult.success(); } @Override @Transactional public AjaxResult revoke(String tfee, String tfeeDo, LoginUser loginUser, String fBilltype) { // 更新 主表、从表 TFee tFee = JSONArray.parseObject(tfee, TFee.class); if ("DZApplyFP".equals(fBilltype)) { TFee fee = tFeeMapper.selectTFeeById(tFee.getfId()); if (fee.getfMake() == 1) { return AjaxResult.error("该申请发票已开销项发票,不能撤销"); } } tFee.setUpdateBy(loginUser.getUser().getUserName()); tFee.setUpdateTime(new Date()); tFeeMapper.updateTFee(tFee); // 删除从表 // tFeeDoMapper.deleteByFPid(tFee.getfId()); // 财务从表 if (StringUtils.isNotNull(tfeeDo)) { Map map = new HashMap<>(); map.put("tFee", tFee); map.put("billType", fBilltype); JSONArray jsonDrArray = JSONArray.parseArray(tfeeDo); List tFeeDoList = JSONObject.parseArray(jsonDrArray.toJSONString(), TFeeDo.class); for (TFeeDo tFeeDo : tFeeDoList) { if (StringUtils.isNull(tFeeDo.getfId())) { // 需写入数据 tFeeDo.setfPid(tFee.getfId()); tFeeDo.setCreateBy(loginUser.getUser().getUserName()); tFeeDo.setCreateTime(new Date()); tFeeDoMapper.insertTFeeDo(tFeeDo); // 跟新费用明细 int m = updateBillsFees(tFee.getfId(), tFeeDo, fBilltype); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } else { // 需更改数据 TFeeDo tfdo = tFeeDoMapper.selectTFeeDoById(tFeeDo.getfId()); tfdo.setUpdateBy(loginUser.getUser().getUserName()); tfdo.setUpdateTime(new Date()); tFeeDoMapper.updateTFeeDo(tfdo); } map.put("tFeeDo", tFeeDo); tWarehousebillsfeesMapper.updateTWarehousebillsfee(map); } } //修改主订单费用信息 if (fBilltype.equals("DCRevoke")) { this.updateMessage(tFee.getfId()); } // 撤销对账时更改费用明细数据 /*if (fBilltype.equals("DZRevoke")) { this.updateDSFMoney(tFee.getfId(),fBilltype); }*/ // 根据业务财务数据 id 删除对应的审批流数据 AuditItemsAbout.deleteAuditItemsData(tFee.getfId()); return AjaxResult.success(); } public void updateMessage(Long fid) { List list = tFeeDoMapper.selectTFeeDoByfPid(fid); if (CollectionUtils.isNotEmpty(list)) { List collect = list.stream().map(TFeeDo::getfSrcpid).collect(toList()); collect.stream().forEach(item -> { TWarehouseBills warehouseBills = tWarehouseBillsMapper.selectTWarehousebillsById(item); //获取订舱单位 TCorps tCorps = tCorpsMapper.selectTCorpsById(warehouseBills.getfCorpid()); //实收费用 List warehousebillsfees = tWarehousebillsfeesMapper.selectFeesByPId(item, "D"); //实付费用 List tWarehousebillsfees = tWarehousebillsfeesMapper.selectFeesByPId(item, "C"); TWarehouseBills tWarehouseBills = new TWarehouseBills(); tWarehouseBills.setfId(item); tWarehouseBills.setfRecycle(warehousebillsfees.stream().filter(ei -> ei.getfStlamount() != null && ei.getfBillstatus().longValue() == 6L).map(TWarehousebillsfees::getfStlamount).reduce(BigDecimal.ZERO, BigDecimal::add)); tWarehouseBills.setfPay(tWarehousebillsfees.stream().filter(ei -> ei.getfStlamount() != null && ei.getfBillstatus().longValue() == 6L).map(TWarehousebillsfees::getfStlamount).reduce(BigDecimal.ZERO, BigDecimal::add)); //如果订舱单位是凯和 应收尾0 也是放货状态 //1: 未放货 应收>0 应收>实收 //2：放货 应收>0 应收=实收 if ((tCorps == null || tCorps.getfCname().equals("青岛凯和志诚物流有限公司")) && !warehouseBills.getfCaregoStatus().equals("3")) { tWarehouseBills.setfCaregoStatus("2"); } else if (warehouseBills.getfReceivable().compareTo(BigDecimal.ZERO) > 0 && warehouseBills.getfReceivable().compareTo(tWarehouseBills.getfRecycle()) > 0) { tWarehouseBills.setfCaregoStatus("1"); } else if (warehouseBills.getfReceivable().compareTo(BigDecimal.ZERO) > 0 && warehouseBills.getfReceivable().compareTo(tWarehouseBills.getfRecycle()) <= 0) { tWarehouseBills.setfCaregoStatus("2"); } tWarehouseBillsMapper.updateTWarehousebills(tWarehouseBills); }); } } @Override public AjaxResult queryRemove(Long fId) { TFee tFee = tFeeMapper.selectTFeeById(fId); TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(tFee.getfId()); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); if (StringUtils.isNull(tFee)) { return AjaxResult.success("0"); } else if (StringUtils.isNotNull(tFee) && StringUtils.isEmpty(tFeeDoList)) { return AjaxResult.success("1"); } else if (tFee.getfBilltype().equals("INV") && tFee.getfAccountId() != null) { return AjaxResult.success("3"); } else { return AjaxResult.success("2"); } } @Override @Transactional public AjaxResult remove(Long fId) { TFee tFee = tFeeMapper.selectTFeeById(fId); if ("4".equals(tFee.getfBillstatus())) { return AjaxResult.error("数据已提交审批,暂不能删除"); } else if ("5".equals(tFee.getfBillstatus())) { return AjaxResult.error("数据正在审批,暂不能删除"); } else if ("6".equals(tFee.getfBillstatus())) { return AjaxResult.error("数据审批完成,不能删除"); } else { try { tFeeMapper.deleteTFeeById(fId); tFeeDoMapper.deleteByFPid(fId); tFeeInvoiceMapper.deleteByFPid(fId); } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("删除失败,请找管理员"); } return AjaxResult.success(); } } @Override public List selectTWarehousebillsItemsList(Long fId) { List tWareHouseExcelItemList = tFeeMapper.selectTWarehousebillsItemsList(fId); List tWareHouseExcelItemList1 = new ArrayList<>(); for (TWareHouseExcelItem tWareHouseExcelItem : tWareHouseExcelItemList) { if (StringUtils.isNotNull(tWareHouseExcelItem.getfBusinessType())) { List sysDictDataListIn = new ArrayList<>(); SysDictData sysDictData = new SysDictData(); if (tWareHouseExcelItem.getfBilltype().equals("入库")) { sysDictData.setDictType(ST_IN_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (tWareHouseExcelItem.getfBilltype().equals("出库")) { sysDictData.setDictType(ST_OUT_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (tWareHouseExcelItem.getfBilltype().equals("调拨") | tWareHouseExcelItem.getfBilltype().equals("货物通关")) { sysDictData.setDictType(ST_TRANS_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } if (null != sysDictDataListIn && sysDictDataListIn.size() > 0) { tWareHouseExcelItem.setfBusinessType(sysDictDataListIn.get(0).getDictLabel()); } } tWareHouseExcelItemList1.add(tWareHouseExcelItem); } return tWareHouseExcelItemList1; } @Override public String findCtrlcorpid(Long fId) { TFee tFee = tFeeMapper.selectTFeeById(fId); //String exportName = tFee.getfCtrlcorpid() + "-" + tFee.getfBillno(); String exportName = tFee.getfCorpidName() + "-" + tFee.getfBillno(); return exportName; } @Override public List receivableExport(TWareHouseFees tWareHouseFees) throws Exception { List> list = tFeeMapper.warehouseBillsFeesList1(tWareHouseFees); List list1 = ListMapToBeanUtils.castMapToBean(list, Receivable.class); return list1; } @Override public List payableExport(TWareHouseFees tWareHouseFees) throws Exception { List ledgerExcelList = new ArrayList<>(); List feeVOList = tFeeMapper.selectFinancialLedgerList(tWareHouseFees); feeVOList.forEach(vo -> { GeneralLedgerExcel ledgerExcel = new GeneralLedgerExcel(); ledgerExcel.setFAmount(vo.getFAmount()); ledgerExcel.setReviewDate(vo.getReviewDate()); ledgerExcel.setFFeesName(vo.getFFeesName()); ledgerExcel.setNnfinished(vo.getNnfinished()); ledgerExcel.setFStlamount(vo.getFStlamount()); ledgerExcelList.add(ledgerExcel); }); return ledgerExcelList; } @Override public List profitExport(TWareHouseFees tWareHouseFees) throws Exception { List> list = tFeeMapper.warehouseBillsFeesProfitList(tWareHouseFees); return ListMapToBeanUtils.castMapToBean(list, Profit.class); } @Override public List profitCustomExport(TWareHouseFees tWareHouseFees) throws Exception { List> list = tFeeMapper.warehouseBillsFeesCustomProfitList(tWareHouseFees); return ListMapToBeanUtils.castMapToBean(list, ProfitGeneralLedgerExcel.class); } @Override public List contrastExport(TFee tFee) throws Exception { List> list = tFeeMapper.selectTFeeList1(tFee); for (Map map : list) { List tfd = tFeeDoMapper.selectTFeeDoByfPid(Long.valueOf(map.get("fId").toString())); if (tfd.size() != 0) { StringBuilder stringBuilder = new StringBuilder(); for (TFeeDo tFeeDo : tfd) { if (StringUtils.isNotNull(tFeeDo.getfSrcBillno())) { stringBuilder.append(tFeeDo.getfSrcBillno()).append(","); } } map.put("fSrcBillno", StringUtils.removeTheLastComma(stringBuilder)); } } return ListMapToBeanUtils.castMapToBean(list, Contrast.class); } @Override public List paymentExport(TFee tFee) throws Exception { List> list = tFeeMapper.selectFeeList(tFee); return ListMapToBeanUtils.castMapToBean(list, Payment.class); } @Override public List chargeExport(TFee tFee) throws Exception { List> list = tFeeMapper.selectFeeList(tFee); return ListMapToBeanUtils.castMapToBean(list, Charge.class); } @Override public List accountExport(TFee tFee) throws Exception { List> list = tFeeMapper.webVersionTFee(tFee); return ListMapToBeanUtils.castMapToBean(list, Account.class); } @Override public List selectDetailedList(Long fId) { List detailedList = tFeeMapper.selectDetailedList(fId); List detailedList1 = new ArrayList<>(); for (Detailed tWareHouseExcelItem : detailedList) { if (StringUtils.isNotNull(tWareHouseExcelItem.getfBusinessType())) { List sysDictDataListIn = new ArrayList<>(); SysDictData sysDictData = new SysDictData(); if (tWareHouseExcelItem.getfBilltype().equals("入库")) { sysDictData.setDictType(ST_IN_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (tWareHouseExcelItem.getfBilltype().equals("出库")) { sysDictData.setDictType(ST_OUT_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } else if (tWareHouseExcelItem.getfBilltype().equals("调拨") | tWareHouseExcelItem.getfBilltype().equals("货物通关")) { sysDictData.setDictType(ST_TRANS_TYPE); sysDictData.setDictValue(String.valueOf(tWareHouseExcelItem.getfBusinessType())); sysDictData.setStatus("0"); sysDictDataListIn = iSysDictDataService.selectDictDataList(sysDictData); } if (CollectionUtils.isNotEmpty(sysDictDataListIn)) { tWareHouseExcelItem.setfBusinessType(sysDictDataListIn.get(0).getDictLabel()); } } detailedList1.add(tWareHouseExcelItem); } return detailedList1; } @Override public List> selectdetailedList(TWarehousebill tWarehousebill) { return tFeeMapper.selectDetailedList1(tWarehousebill); } /** * 更新费用明细 * * @param fid * @param tFeeDo * @param billsType * @return */ @Transactional public int updateBillsFees(Long fid, TFeeDo tFeeDo, String billsType) { // 查询从表数据 TFee tFee = tFeeMapper.selectTFeeById(fid); if (billsType.equals("SF") || billsType.equals("FF") || billsType.equals("KHSF") || billsType.equals("KHFF")) { billsType = "DC"; } Map map = new HashMap<>(); map.put("tFee", tFee); map.put("billType", billsType); map.put("tFeeDo", tFeeDo); return tWarehousebillsfeesMapper.updateTWarehousebillsfee(map); } public boolean change(Long fId) { boolean flag = false; TFee tFee = tFeeMapper.selectTFeeById(fId); if ("4".equals(tFee.getfBillstatus()) || "5".equals(tFee.getfBillstatus()) || "6".equals(tFee.getfBillstatus())) { flag = false; } else { flag = true; } return flag; } @Override @Transactional public AjaxResult webVersionSubmitApplyFP(TFee tFee, LoginUser loginUser, String fBilltype) { String key = ""; boolean isApprove = false; long actId = 0L; String billStatus = ""; if ("ApplyFP".equals(fBilltype)) { actId = 470L; key = "warehouse.kaiHeApplyFP.ApprovalFlow"; } SysConfig sysConfig = sysConfigMapper.checkConfigKeyUnique(key); if (StringUtils.isNull(sysConfig)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("系统参数异常，未找到开启审批流参数"); } if ("0".equals(sysConfig.getConfigValue())) { isApprove = true; } if (isApprove) { billStatus = "4"; } else { billStatus = "6"; } /*for (Long getfId : tFee.getfIds()) {*/ TFee fee = tFeeMapper.selectTFeeById(tFee.getfId()); if (fee == null) { return AjaxResult.error("财务主表数据有误,请确认"); } boolean change = this.change(tFee.getfId()); if (change == false) { return AjaxResult.error("数据正在审批或审批通过,不允许提交审核"); } fee.setfId(tFee.getfId()); fee.setfBillstatus(billStatus); fee.setUpdateBy(loginUser.getUser().getUserName()); fee.setUpdateTime(new Date()); int updateTFee = tFeeMapper.updateTFee(fee); if (updateTFee <= 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新财务主表数据出错，请找管理员"); } TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(tFee.getfId()); List tFeeDos = tFeeDoMapper.selectTFeeDoList(tFeeDo); if (CollectionUtils.isEmpty(tFeeDos)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("财务从表数据有误,请确认"); } for (TFeeDo feeDo : tFeeDos) { feeDo.setfId(feeDo.getfId()); feeDo.setfStatus(billStatus); feeDo.setUpdateBy(loginUser.getUser().getUserName()); feeDo.setUpdateTime(new Date()); int i = tFeeDoMapper.updateTFeeDo(feeDo); if (i <= 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新财务主表数据出错，请找管理员"); } } TFeeInvoice tFeeInvoice = new TFeeInvoice(); tFeeInvoice.setfPid(tFee.getfId()); List tFeeInvoiceList = tFeeInvoiceMapper.selectTFeeInvoiceList(tFeeInvoice); if (CollectionUtils.isNotEmpty(tFeeInvoiceList)) { for (TFeeInvoice invoice : tFeeInvoiceList) { tFeeInvoice.setfBillstatus(billStatus); tFeeInvoice.setfId(invoice.getfId()); tFeeInvoice.setUpdateBy(loginUser.getUser().getUserName()); tFeeInvoice.setUpdateTime(new Date()); tFeeInvoiceMapper.updateTFeeInvoice(tFeeInvoice); } } //添加审批流 if (isApprove) { AuditItems auditItems = new AuditItems(); auditItems.setLevelId(0L); auditItems.setBillId(fee.getfId()); auditItems.setActId(actId); auditItems.setIffinalItem("F"); auditItems.setBillNo(fee.getfBillno()); // 业务编号 auditItems.setRefno1(String.valueOf(fee.getfCorpid())); // 货权方 auditItems.setRefno2(fee.getfBilltype());// 财务类型 auditItems.setRefno3(fee.gettMblno());// 提单号 auditItems.setSendUserId(loginUser.getUser().getUserId()); auditItems.setSendName(loginUser.getUsername()); auditItems.setSendTime(new Date()); auditItems.setAuditUserId(loginUser.getUser().getUserId()); auditItems.setAuditItem(new Date()); auditItems.setAuditOpTime(new Date()); auditItems.setFidStatus("f_billstatus"); auditItems.setTimes(1L); auditItems.setAuditMsg("提交"); auditItems.setAuditStatus("O"); AjaxResult approvalFlow = auditItemsService.createApprovalFlow(auditItems); Long code = Long.valueOf(String.valueOf(approvalFlow.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("提交审核失败,请找管理员"); } return approvalFlow; } else { for (TFeeDo t : tFeeDos) { // 跟新费用明细 int m = updateBillsFees(tFee.getfId(), t, fBilltype); if (m == 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("更新费用明细失败"); } } AjaxResult ajaxResult = tfeeFollow(tFee.getfId(), 6L); Long code = Long.valueOf(String.valueOf(ajaxResult.get("code"))).longValue(); if (code.equals(500L)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("提交审核失败,请找管理员"); } return ajaxResult; } /*}*/ //return AjaxResult.success(); } @Override public AjaxResult webVersionUpdateApplyFP(TFee tFee, LoginUser loginUser, String billType) { TFeeInvoice tFeeInvoice = tFee.gettFeeInvoice(); tFeeInvoice.setfPid(tFee.getfId()); int i = 0; if (tFeeInvoice.getfId() != null) { tFeeInvoice.setUpdateBy(loginUser.getUser().getUserName()); tFeeInvoice.setUpdateTime(new Date()); i = tFeeInvoiceMapper.updateTFeeInvoice(tFeeInvoice); } else { return AjaxResult.error("开票信息为空,请找管理员"); } if (i <= 0) { return AjaxResult.error("更新数据失败,请找管理员"); } else { return AjaxResult.success(); } } @Override public List selectFinancialTFeeList(TFee tFee) { return tFeeMapper.selectFinancialTFeeList(tFee); } @Override public List> FinancialFeesList(TWareHouseFees tWareHouseFees) { Map map = new HashMap<>(); map.put("tWareHouseFees", tWareHouseFees); return tFeeMapper.FinancialFeesList(map); } @Override public Map selectFinancialTFeeId(Long fId) { Map map = new HashMap<>(); FinancialTFee financialTFee = tFeeMapper.selectFinancialTFeeId(fId); List financialTFeeDoExcels = tFeeDoMapper.selectFinancialTFeeDo(fId); map.put("tFee", financialTFee); map.put("tFeeDo", financialTFeeDoExcels); return map; } @Override public List FinancialTFeeDoExcel(Long fId) { return tFeeDoMapper.selectFinancialTFeeDo(fId); } @Override @Transactional public AjaxResult webVersionApplyFP(TFee tFee, LoginUser loginUser, String fBilltype, TFeeInvoice tFeeInvoice) { Long fPid = null; String billStatus = "2"; try { /*for (Long getfId : tFee.getfIds()) {*/ TFee account = new TFee(); TFee fee = tFeeMapper.selectTFeeById(tFee.getfId()); if (fee == null) { return AjaxResult.error("财务主表数据有误,请确认"); } account.setfId(fee.getfId()); account.setfMake(1); fee.setfBilltype(fBilltype); fee.setfBillstatus(billStatus); fee.setCreateBy(loginUser.getUser().getUserName()); fee.setCreateTime(new Date()); fee.setfDeptid(loginUser.getUser().getDeptId()); fee.setUpdateBy(null); fee.setUpdateTime(null); fee.setfInvoiceRise(tFee.getfInvoiceRise()); fee.setfAccountId(fee.getfId()); Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); fee.setfBillno(billNo); fee.setfAccbilldate(null); fee.setfId(null); tFeeMapper.insertTFee(fee); tFeeMapper.updateTFee(account); //修改原来的数据的开票金额 fPid = fee.getfId(); TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(tFee.getfId()); List tFeeDos = tFeeDoMapper.selectTFeeDoList(tFeeDo); if (CollectionUtils.isEmpty(tFeeDos)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("财务从表数据有误,请确认"); } for (TFeeDo feeDo : tFeeDos) { feeDo.setfPid(fPid); feeDo.setfStatus(billStatus); feeDo.setCreateBy(loginUser.getUser().getUserName()); feeDo.setCreateTime(new Date()); feeDo.setUpdateBy(null); feeDo.setUpdateTime(null); int i = tFeeDoMapper.insertTFeeDo(feeDo); } tFeeInvoice.setfBillstatus(billStatus); tFeeInvoice.setfPid(fPid); tFeeInvoice.setCreateBy(loginUser.getUser().getUserName()); tFeeInvoice.setCreateTime(new Date()); tFeeInvoiceMapper.insertTFeeInvoice(tFeeInvoice); /*}*/ } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return AjaxResult.error("申请发票出错,请找管理员"); } return AjaxResult.success(); } /** * 判断金额是否超过可用金额 * * @param fid 费用明细表主键 * @param money 申请金额 * @param type DZ 对账 SF 收费 FF 付费 ApplyFP 开票申请 invoiceFP 开票 * @return */ public Map judgeMoney(long fid, BigDecimal money, String type, Long feeId) { Map map = new HashMap<>(); boolean flag = true; TWarehousebillsfees warehousebillsfees = tWarehousebillsfeesMapper.selectTWarehousebillsfeesById(fid); TWarehouseBills bills = tWarehouseBillsMapper.selectTWarehousebillsById(warehousebillsfees.getfPid()); TFees tFees = tFeesMapper.selectTFeesById(feeId); BigDecimal amount = warehousebillsfees.getfAmount();//金额 BigDecimal accamount = warehousebillsfees.getfAccamount();//对账金额 BigDecimal stlamount = warehousebillsfees.getfStlamount();//结算金额 BigDecimal invamount = warehousebillsfees.getfInvamount();//开票金额a BigDecimal askamount = warehousebillsfees.getfAskamount();//申请金额 if (bills == null) { flag = false; map.put("message", "费用明细数据有误,请找管理员"); } else if (warehousebillsfees == null) { flag = false; map.put("message", "费用明细数据有误,请找管理员"); } else if ("DZ".equals(type) || "KHDZ".equals(type)) { BigDecimal subtract = amount.subtract(accamount); if (subtract.compareTo(new BigDecimal(0)) == 0) { if (subtract.compareTo(money) <= 0) { flag = false; map.put("message", "提单号" + bills.getfMblno() + "的" + tFees.getfName() + "对账金额超过可对账金额,当前可对账金额为" + subtract + "元"); } } } else if ("SF".equals(type) || "KHSF".equals(type)) { BigDecimal subtract = amount.subtract(stlamount); if (subtract.compareTo(money) < 0) { flag = false; map.put("message", "提单号" + bills.getfMblno() + "的" + tFees.getfName() + "收费金额超过可收费金额,当前可对账金额为" + subtract + "元"); } } else if ("FF".equals(type) || "KHFF".equals(type)) { BigDecimal subtract = amount.subtract(stlamount); if (subtract.compareTo(money) < 0) { flag = false; map.put("message", "提单号" + bills.getfMblno() + "的" + tFees.getfName() + "付费金额超过可付费金额,当前可对账金额为" + subtract + "元"); } } else if ("ApplyFP".equals(type)) { BigDecimal subtract = amount.subtract(askamount); if (subtract.compareTo(money) < 0) { flag = false; map.put("message", "提单号" + bills.getfMblno() + "的" + tFees.getfName() + "开票金额超过可开票金额,当前可对账金额为" + subtract + "元"); } } else if ("invoiceFP".equals(type)) { BigDecimal subtract = amount.subtract(invamount); if (subtract.compareTo(money) < 0) { flag = false; map.put("message", "提单号" + bills.getfMblno() + "的" + tFees.getfName() + "开票金额超过可开票金额,当前可对账金额为" + subtract + "元"); } } map.put("flag", flag); return map; } /** * 申请发票审核成功复制数据到销项发票中 * * @param fId 主表id * @param fBilltype 类型 * @return */ @Transactional public AjaxResult copyInvoiceFp(Long fId, String fBilltype) { //查询费用主表信息复制主表信息 Integer insert = null; TFee fee = tFeeMapper.selectTFeeById(fId); TFee tFee = new TFee(); tFee.setfId(fee.getfId()); Date time = new Date(); String billNo = billnoSerialServiceImpl.getBillNo(fBilltype, time); //查询费用从表信息复制主表信息 fee.setfAccountId(fee.getfId()); fee.setfBillno(billNo); fee.setfBilltype(fBilltype); fee.setfId(null); insert = tFeeMapper.insertTFee(fee); tFee.setfMake(1); //修改原发票数据代表已开销项发票 insert = tFeeMapper.updateTFee(tFee); TFeeDo tFeeDo = new TFeeDo(); tFeeDo.setfPid(fId); List tFeeDoList = tFeeDoMapper.selectTFeeDoList(tFeeDo); if (CollectionUtils.isNotEmpty(tFeeDoList)) { for (TFeeDo feeDo : tFeeDoList) { feeDo.setfId(null); feeDo.setfPid(fee.getfId()); feeDo.setfBilltype(fBilltype); insert = tFeeDoMapper.insertTFeeDo(feeDo); } } //查询开票信息复制主表信息 TFeeInvoice tFeeInvoice = new TFeeInvoice(); tFeeInvoice.setfPid(fId); List tFeeInvoiceList = tFeeInvoiceMapper.selectTFeeInvoiceList(tFeeInvoice); if (CollectionUtils.isNotEmpty(tFeeInvoiceList)) { for (TFeeInvoice invoice : tFeeInvoiceList) { invoice.setfId(null); invoice.setfPid(fee.getfId()); insert = tFeeInvoiceMapper.insertTFeeInvoice(invoice); } } if (insert != null && insert > 0) { return AjaxResult.success(); } else { return AjaxResult.error("生成销项发票失败,请找管理员"); } } /** * 导出财务对账数据 * * @param fId * @return */ @Override public AjaxResult exportFinancial(Long fId) { //获取数据 String shipsName = "";//船名 String voyage = "";//航次 String corpName = "";//客户 String fFromDate = "";//离港日期开始 String fToDate = "";//离港日期结束 BigDecimal fAmount = new BigDecimal(0);//合计 //查询财务主数据 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); TFee fee = tFeeMapper.selectTFeeById(fId); if (fee != null) { corpName = fee.getfCtrlcorpid(); /* if (fee.getfFromDate() != null) { fFromDate = simpleDateFormat.format(fee.getfFromDate()); }*/ if (fee.getfToDate() != null) { fToDate = simpleDateFormat.format(fee.getfToDate()); } if (fee.getfVslid() != null) { TVessel vessel = tVesselMapper.selectTVesselById(fee.getfVslid()); if (vessel != null && StringUtils.isNotEmpty(vessel.getfName())) { shipsName = vessel.getfName(); } } if (fee.getfVoyid() != null) { TVoyage tVoyage = tVoyageMapper.selectTVoyageById(fee.getfVoyid()); if (tVoyage != null && StringUtils.isNotEmpty(tVoyage.getfNo())) { voyage = tVoyage.getfNo(); } } } //样式设置 //1.创建一个workbook,对应一个excel文件 HSSFWorkbook wb = new HSSFWorkbook(); //2.在workbook中添加一个sheet,对应Excel中的sheet HSSFSheet sheet = wb.createSheet("对账"); //设置每一列的列宽 sheet.setColumnWidth(0, 256 * 15); sheet.setColumnWidth(1, 256 * 20); sheet.setColumnWidth(2, 256 * 20); sheet.setColumnWidth(3, 256 * 20); sheet.setColumnWidth(4, 256 * 15); sheet.setColumnWidth(5, 256 * 15); sheet.setColumnWidth(6, 256 * 15); sheet.setColumnWidth(7, 100 * 35); sheet.setColumnWidth(8, 256 * 15); sheet.setColumnWidth(9, 256 * 15); //3.设置样式以及字体样式 HSSFCellStyle titleStyle = ExcelUtils.createTitleCellStyle(wb); HSSFCellStyle contentStyle = ExcelUtils.createContentCellStyle(wb); HSSFCellStyle subheadingStyle = ExcelUtils.createSubheadingStyle(wb); HSSFCellStyle endStyle = ExcelUtils.createEndStyle(wb); //4.创建标题，合并标题单元格 //行号 int rowNum = 0; //创建第一行，索引从0开始(标题行) HSSFRow row0 = sheet.createRow(rowNum++); row0.setHeight((short) 800);// 设置行高 for (int i = 0; i < 10; i++) { HSSFCell tempCell = row0.createCell(i); tempCell.setCellStyle(contentStyle); } String title = "青岛凯和志诚物流有限公司"; HSSFCell c00 = row0.createCell(0); c00.setCellValue(title); c00.setCellStyle(titleStyle); // 合并单元格，参数依次为起始行，结束行，起始列，结束列 （索引0开始） sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, 9));//标题合并单元格操作，总列数为9 //第2行 HSSFRow row1 = sheet.createRow(rowNum++); row1.setHeight((short) 500); String message1 = "客户确认单"; for (int i = 0; i < 10; i++) { HSSFCell tempCell = row1.createCell(i); tempCell.setCellStyle(contentStyle); } HSSFCell c01 = row1.createCell(0); c01.setCellValue(message1); c01.setCellStyle(subheadingStyle); sheet.addMergedRegion(new CellRangeAddress(1, 1, 0, 9));//标题合并单元格操作，总列数为9 //第3行 HSSFRow row2 = sheet.createRow(rowNum++); row2.setHeight((short) 500); String message2 = "尊敬的客户"; HSSFCell c02 = row2.createCell(0); c02.setCellValue(message2); c02.setCellStyle(contentStyle); //第3行 for (int i = 1; i < 10; i++) { HSSFCell tempCell = row2.createCell(i); tempCell.setCellStyle(contentStyle); } HSSFCell c03 = row2.createCell(1); c03.setCellValue(corpName); c03.setCellStyle(contentStyle); sheet.addMergedRegion(new CellRangeAddress(2, 2, 1, 9));//标题合并单元格操作，总列数为9 //合并单元格 sheet.addMergedRegion(new CellRangeAddress(3, 3, 1, 2)); sheet.addMergedRegion(new CellRangeAddress(3, 3, 3, 4)); sheet.addMergedRegion(new CellRangeAddress(3, 3, 5, 9)); //第4行 HSSFRow row3 = sheet.createRow(rowNum++); for (int i = 0; i < 1; i++) { HSSFCell tempCell = row3.createCell(i); tempCell.setCellStyle(contentStyle); } for (int i = 1; i < 3; i++) { HSSFCell tempCell = row3.createCell(i); tempCell.setCellStyle(contentStyle); } for (int i = 3; i < 5; i++) { HSSFCell tempCell = row3.createCell(i); tempCell.setCellStyle(contentStyle); } for (int i = 5; i < 10; i++) { HSSFCell tempCell = row3.createCell(i); tempCell.setCellStyle(contentStyle); } row3.setHeight((short) 500); HSSFCell c05 = row3.createCell(0); c05.setCellValue("船名航次:"); c05.setCellStyle(contentStyle); HSSFCell c051 = row3.createCell(1); c051.setCellValue(shipsName + voyage); c051.setCellStyle(contentStyle); HSSFCell c052 = row3.createCell(3); c052.setCellValue("离港日期:"); c052.setCellStyle(contentStyle); String message = ""; HSSFCell c053 = row3.createCell(5); /* if (StringUtils.isNotEmpty(fFromDate)) { if (StringUtils.isNotEmpty(fFromDate)) { message = fFromDate + "-" + fToDate; } else { message = fFromDate; } } else if (StringUtils.isNotEmpty(fToDate)) { message = fToDate; }*/ if (StringUtils.isNotEmpty(fToDate)) { message = fToDate; } else { message = "无"; } c053.setCellValue(message); c053.setCellStyle(contentStyle); //第5行 HSSFRow row4 = sheet.createRow(rowNum++); for (int i = 0; i < 10; i++) { HSSFCell tempCell = row4.createCell(i); tempCell.setCellStyle(contentStyle); } row4.setHeight((short) 500); String message4 = "费用明细"; HSSFCell c04 = row4.createCell(0); c04.setCellValue(message4); c04.setCellStyle(contentStyle); sheet.addMergedRegion(new CellRangeAddress(4, 4, 0, 9));//标题合并单元格操作，总列数为9 //第四行 HSSFRow row5 = sheet.createRow(rowNum++); row5.setHeight((short) 500); String[] row_third = {"序号", "提单号", "始发港", "目的港", "运输条款", "货名", "箱量", "规格", "单价", "合计"}; for (int i = 0; i < row_third.length; i++) { HSSFCell tempCell = row5.createCell(i); tempCell.setCellValue(row_third[i]); tempCell.setCellStyle(contentStyle); } //查询费用明细数据 List list = tFeeMapper.exportFinancial(fId); if (CollectionUtils.isNotEmpty(list)) { for (int i = 0; i < list.size(); i++) { HSSFRow tempRow = sheet.createRow(rowNum++); tempRow.setHeight((short) 500); //循环单元格填入数据 for (int j = 0; j < 10; j++) { HSSFCell tempCell = tempRow.createCell(j); tempCell.setCellStyle(contentStyle); String cellValue = ""; if (j == 0) { //序号 cellValue = list.get(i).getRankNo().toString(); } else if (j == 1) { //提单号 cellValue = list.get(i).getfMblNo(); } else if (j == 2) { //始发港 cellValue = list.get(i).getPortOfDeparture(); } else if (j == 3) { //目的港 cellValue = list.get(i).getDestinationPort(); } else if (j == 4) { //运输条款 cellValue = list.get(i).getfServiceitems() + "-" + list.get(i).getfServiceitemsNew(); } else if (j == 5) { //货名 cellValue = list.get(i).getGoodName(); } else if (j == 6) { //箱量 cellValue = list.get(i).getfCnTrCount().toString(); } else if (j == 7) { //规格 cellValue = list.get(i).getSpecification(); } else if (j == 8) { //单价 cellValue = list.get(i).getfUnitPrice().toString(); } else if (j == 9) { //合计 cellValue = list.get(i).getfAmount().toString(); } tempCell.setCellValue(cellValue); } } fAmount = list.stream().map(ExportFinancial::getfAmount).reduce(BigDecimal.ZERO, BigDecimal::add);//求所有和的合计 } //倒数第二行 HSSFRow row6 = sheet.createRow(rowNum++); for (int i = 0; i < 10; i++) { HSSFCell tempCell = row6.createCell(i); tempCell.setCellStyle(contentStyle); } row6.setHeight((short) 500); String message6 = "合计:"; HSSFCell c06 = row6.createCell(0); c06.setCellValue(message6); c06.setCellStyle(contentStyle); HSSFCell c061 = row6.createCell(9); c061.setCellValue(fAmount.toString()); c061.setCellStyle(contentStyle); //最后一行 HSSFRow row7 = sheet.createRow(rowNum++); for (int i = 0; i < 10; i++) { HSSFCell tempCell = row7.createCell(i); tempCell.setCellStyle(contentStyle); } row7.setHeight((short) 1500); String message7 = "纳税人识别号：91370202MA3UG1T04A\n" + "人民币账号:3803020309100171855\n" + "人民币开户行：工商银行青岛分行营业部"; HSSFCell c07 = row7.createCell(0); c07.setCellValue(message7); c07.setCellStyle(endStyle); sheet.addMergedRegion(new CellRangeAddress(rowNum - 1, rowNum - 1, 0, 9));//标题合并单元格操作，总列数为9 //导出excel String fileName = "客户对账单.xls"; try { OutputStream out = null; out = new FileOutputStream(getAbsoluteFile(fileName)); wb.write(out); if (null != wb && null != out) { wb.write(out); wb.close(); out.close(); } return AjaxResult.success(fileName); } catch (Exception e) { e.printStackTrace(); return AjaxResult.error("导出Excel失败"); } } /** * 根据结算单位、费用状态、审核日期查询应付总帐明细 * * @param feeDTO * @return */ @Override public AjaxResult financialLedgerDetails(FeeDTO feeDTO) { /*TFees ccf = tFeesMapper.seletFeesByCCF(); if (Objects.isNull(ccf)) { throw new WarehouseException("未找到仓储费费用信息"); } feeDTO.setFeesId(ccf.getfId());*/ List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); if (CollectionUtils.isNotEmpty(feeVOList)) { List voList = new ArrayList<>(); Map> map = feeVOList.stream().collect(Collectors.groupingBy(FeeVO::getFSrcpid)); map.forEach((key, value) -> { FeeVO vo = new FeeVO(); FeeVO feeVO = value.stream().findFirst().orElseThrow(() -> new WarehouseException("获取费用异常")); BeanUtils.copyProperties(feeVO, vo); // 仓储费 BigDecimal storageFee = value.stream().map(FeeVO::getStorageFee).reduce(BigDecimal::add).orElse(BigDecimal.ZERO); // 其他费用 BigDecimal otherFee = value.stream().map(FeeVO::getOtherFee).reduce(BigDecimal::add).orElse(BigDecimal.ZERO); // 应收费用 BigDecimal amount = value.stream().map(FeeVO::getFAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO); // 已收费用 BigDecimal stlamount = value.stream().map(FeeVO::getFStlamount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO); WarehouseTypeEnum storageType = WarehouseTypeEnum.fromTypeAndBusinessType(vo.getfBilltype(), "storageType"); vo.setfBilltype(storageType.getName()); vo.setStorageFee(storageFee); vo.setFStlamount(stlamount); vo.setOtherFee(otherFee); vo.setFAmount(amount); vo.setNnfinished(amount.subtract(stlamount)); voList.add(vo); }); return AjaxResult.success(voList); } return AjaxResult.success(feeVOList); } /** * 查询应付总帐明细 * * @param feeDTO * @return */ @Override public List financialLedgerDetailsExport(FeeDTO feeDTO) { List detailExcelList = new ArrayList<>(); List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); feeVOList.forEach(vo -> { GeneralLedgerDetailExcel detailExcel = new GeneralLedgerDetailExcel(); WarehouseTypeEnum storageType = WarehouseTypeEnum.fromTypeAndBusinessType(vo.getfBilltype(), "storageType"); detailExcel.setFMblno(vo.getFMblno()); detailExcel.setFMarks(vo.getFMarks()); detailExcel.setFAmount(vo.getFAmount()); detailExcel.setOtherFee(vo.getOtherFee()); detailExcel.setFFeesName(vo.getFFeesName()); detailExcel.setNnfinished(vo.getNnfinished()); detailExcel.setFStlamount(vo.getFStlamount()); detailExcel.setStorageFee(vo.getStorageFee()); detailExcel.setFBilltype(storageType.getName()); detailExcel.setFProductName(vo.getFProductName()); detailExcel.setFProductName(vo.getFProductName()); detailExcelList.add(detailExcel); }); return detailExcelList; } @Override public AjaxResult financialLedgerDetailsTotal(FeeDTO feeDTO) { feeDTO.setFToCorpid(feeDTO.getFCorpId()); feeDTO.setFCorpId(null); if (ObjectUtils.isNotNull(feeDTO.getFBstimeExamine())) { feeDTO.setFAuditList(feeDTO.getFBstimeExamine()); feeDTO.setFBstimeExamine(null); } List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); feeDTO.setFDc("D"); List feeVOListD = tFeeMapper.selectFinancialLedgerDetails(feeDTO); feeDTO.setFDc("C"); List feeVOListC = tFeeMapper.selectFinancialLedgerDetails(feeDTO); if (CollectionUtils.isNotEmpty(feeVOList)) { List voList = new ArrayList<>(); Map> map = feeVOList.stream().collect(Collectors.groupingBy(FeeVO::getFSrcpid)); map.forEach((key, value) -> { List feeVODList = feeVOListD.stream().filter(e -> e.getFSrcpid().equals(key)).collect(Collectors.toList()); FeeVO feeVOD = feeVOListD.stream().filter(e -> e.getFSrcpid().equals(key)).findFirst().orElse(null); List feeVOCList = feeVOListC.stream().filter(e -> e.getFSrcpid().equals(key)).collect(Collectors.toList()); FeeVO feeVOC = feeVOListC.stream().filter(e -> e.getFSrcpid().equals(key)).findFirst().orElse(null); FeeVO vo = new FeeVO(); FeeVO feeVO = value.stream().findFirst().orElseThrow(() -> new WarehouseException("获取费用异常")); BeanUtils.copyProperties(feeVO, vo); vo.setFFeesName(vo.getCorpName()); BigDecimal D = new BigDecimal("0.00"); BigDecimal C = new BigDecimal("0.00"); if (ObjectUtils.isNotNull(feeVOD)) { if (ObjectUtils.isNotNull(feeVODList)) { D = feeVODList.stream().map(FeeVO::getFAmount).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add); vo.setReceivableAmount(D); } else { vo.setReceivableAmount(D); } vo.setReceivableFQty(feeVOD.getFQty()); vo.setReceivablePrice(feeVOD.getPrice()); vo.setfBilltype(feeVOD.getFBillTypeName()); vo.setFBillingDays(feeVOD.getFBillingDays()); vo.setTfeesNameD(feeVOD.getName()); } if (ObjectUtils.isNotNull(feeVOC)) { if (ObjectUtils.isNotNull(feeVOCList)) { C = feeVOCList.stream().map(FeeVO::getFAmount).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add); vo.setCopeWithAmount(C); } else { vo.setCopeWithAmount(C); } vo.setFBilltypeC(feeVOC.getFBillTypeName()); vo.setCopeWithFQty(feeVOC.getFQty()); vo.setCopeWithPrice(feeVOC.getPrice()); vo.setTfeesNameC(feeVOC.getName()); } vo.setNnfinished(D.subtract(C)); voList.add(vo); }); return AjaxResult.success(voList); } return AjaxResult.success(feeVOList); } @Override public List financialLedgerDetailsTotalExport(FeeDTO feeDTO) { List list = new ArrayList<>(); feeDTO.setFToCorpid(feeDTO.getFCorpId()); feeDTO.setFCorpId(null); if (ObjectUtils.isNotNull(feeDTO.getFBstimeExamine())) { feeDTO.setFAuditList(feeDTO.getFBstimeExamine()); feeDTO.setFBstimeExamine(null); } List feeVOList = tFeeMapper.selectFinancialLedgerDetails(feeDTO); feeDTO.setFDc("D"); List feeVOListD = tFeeMapper.selectFinancialLedgerDetails(feeDTO); feeDTO.setFDc("C"); List feeVOListC = tFeeMapper.selectFinancialLedgerDetails(feeDTO); if (CollectionUtils.isNotEmpty(feeVOList)) { Map> map = feeVOList.stream().collect(Collectors.groupingBy(FeeVO::getFSrcpid)); map.forEach((key, value) -> { GeneralLedgerDetailTotalExcel generalLedgerDetailTotalExcel = new GeneralLedgerDetailTotalExcel(); List feeVODList = feeVOListD.stream().filter(e -> e.getFSrcpid().equals(key)).collect(Collectors.toList()); FeeVO feeVOD = feeVOListD.stream().filter(e -> e.getFSrcpid().equals(key)).findFirst().orElse(null); List feeVOCList = feeVOListC.stream().filter(e -> e.getFSrcpid().equals(key)).collect(Collectors.toList()); FeeVO feeVOC = feeVOListC.stream().filter(e -> e.getFSrcpid().equals(key)).findFirst().orElse(null); FeeVO feeVO = value.stream().findFirst().orElseThrow(() -> new WarehouseException("获取费用异常")); BeanUtils.copyProperties(feeVO, generalLedgerDetailTotalExcel); BigDecimal D = new BigDecimal("0.00"); BigDecimal C = new BigDecimal("0.00"); if (ObjectUtils.isNotNull(feeVOD)) { if (ObjectUtils.isNotNull(feeVOD)) { D = feeVODList.stream().map(FeeVO::getFAmount).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add); generalLedgerDetailTotalExcel.setReceivableAmount(D); } else { generalLedgerDetailTotalExcel.setReceivableAmount(D); } generalLedgerDetailTotalExcel.setReceivableFQty(feeVOD.getFQty()); generalLedgerDetailTotalExcel.setReceivablePrice(feeVOD.getPrice()); /*WarehouseTypeEnum storageType = WarehouseTypeEnum.fromTypeAndBusinessType(feeVOD.getfBilltype(), "storageType"); generalLedgerDetailTotalExcel.setFBilltype(storageType.getName());*/ generalLedgerDetailTotalExcel.setFBilltype(feeVOD.getFFeesName()); generalLedgerDetailTotalExcel.setFBillingDays(feeVOD.getFBillingDays().intValue()); } if (ObjectUtils.isNotNull(feeVOC)) { if (ObjectUtils.isNotNull(feeVOC.getFAmount())) { C = feeVOCList.stream().map(FeeVO::getFAmount).filter(Objects::nonNull).reduce(BigDecimal.ZERO, BigDecimal::add); generalLedgerDetailTotalExcel.setCopeWithAmount(C); } else { generalLedgerDetailTotalExcel.setCopeWithAmount(C); } /*WarehouseTypeEnum storageType = WarehouseTypeEnum.fromTypeAndBusinessType(feeVOC.getfBilltype(), "storageType"); generalLedgerDetailTotalExcel.setFBilltypeC(storageType.getName());*/ generalLedgerDetailTotalExcel.setFBilltypeC(feeVOC.getFFeesName()); generalLedgerDetailTotalExcel.setCopeWithFQty(feeVOC.getFQty()); generalLedgerDetailTotalExcel.setCopeWithPrice(feeVOC.getPrice()); } generalLedgerDetailTotalExcel.setNnfinished(D.subtract(C)); list.add(generalLedgerDetailTotalExcel); }); return list; } return list; } @Override public List receivable(TWareHouseFees tWareHouseFees) { return tFeeMapper.receivable(tWareHouseFees); } @Override public List profit(TWareHouseFees tWareHouseFees) { return tFeeMapper.profit(tWareHouseFees); } @Override public List handle(TWareHouseFees tWareHouseFees) { return tFeeMapper.handle(tWareHouseFees); } //下载路径 private String getAbsoluteFile(String fileName) { String downloadPath = RuoYiConfig.getDownloadPath() + fileName; File desc = new File(downloadPath); if (!desc.getParentFile().exists()) { desc.getParentFile().mkdirs(); } return downloadPath; } }