package com.ruoyi.project.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.config.RuoYiConfig; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.exception.base.BaseException; import com.ruoyi.common.utils.HttpClientKit; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.bean.DtoConversionUtils; import com.ruoyi.common.utils.poi.ExcelUtil; import com.ruoyi.project.domain.*; import com.ruoyi.project.domain.vo.*; import com.ruoyi.project.mapper.*; import com.ruoyi.project.service.*; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.ObjectUtils; import org.apache.ibatis.annotations.Param; import org.apache.poi.ss.usermodel.*; import org.apache.poi.xssf.usermodel.XSSFColor; import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.InputStream; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; /** * 费用申请主Service业务层处理 * * @author ruoyi * @date 2022-01-24 */ @Slf4j @Service public class ServiceFundServiceImpl extends ServiceImpl implements IServiceFundService { @Autowired ServiceFundMapper serviceFundMapper; @Autowired ServiceFunddetailMapper serviceFunddetailMapper; @Autowired BaseExpertfeetypeMapper baseExpertfeetypeMapper; @Autowired ServiceReimbursementMapper serviceReimbursementMapper; @Autowired IServiceFundSharedService sharedService; @Autowired ServiceFundSharedMapper serviceFundSharedMapper; @Autowired ServiceFunddetailSharedMapper sharedMapper; @Autowired IServiceFunddetailSharedService detailSharedService; @Autowired private IServiceFunddetailService serviceFunddetailService; @Autowired private VExpertfeeExpertMapper vExpertfeeExpertMapper; @Autowired private VExpertfeeDonorMapper vExpertfeeDonorMapper; @Autowired private VExpertfeeTotalMapper vExpertfeeTotalMapper; /** * 查询费用申请主列表(包含删除的) * * @param serviceFund 费用申请主 * @return 费用申请主 */ @Override public List queryList(ServiceFund serviceFund) { LambdaQueryWrapper wrappers = Wrappers.lambdaQuery(); if (StringUtils.isNotBlank(serviceFund.getDonorno())) { wrappers.eq(ServiceFund::getDonorno, serviceFund.getDonorno()); } if (serviceFund.getId() != null) { wrappers.eq(ServiceFund::getId, serviceFund.getId()); } if (serviceFund.getFundTaxId() != null) { wrappers.eq(ServiceFund::getFundTaxId, serviceFund.getFundTaxId()); } if (StringUtils.isNotBlank(serviceFund.getUserno())) { wrappers.eq(ServiceFund::getUserno, serviceFund.getUserno()); } if (StringUtils.isNotBlank(serviceFund.getUsername())) { wrappers.like(ServiceFund::getUsername, serviceFund.getUsername()); } if (StringUtils.isNotBlank(serviceFund.getApplytype())) { wrappers.eq(ServiceFund::getApplytype, serviceFund.getApplytype()); } if (StringUtils.isNotBlank(serviceFund.getDeptmentname())) { wrappers.like(ServiceFund::getDeptmentname, serviceFund.getDeptmentname()); } if (serviceFund.getRecordstatus() != null) { wrappers.eq(ServiceFund::getRecordstatus, serviceFund.getRecordstatus()); } if (StringUtils.isNotBlank(serviceFund.getUploadflag())) { wrappers.eq(ServiceFund::getUploadflag, serviceFund.getUploadflag()); } if (serviceFund.getUploadtime() != null) { wrappers.eq(ServiceFund::getUploadtime, serviceFund.getUploadtime()); } if (serviceFund.getUploadStates() != null) { wrappers.eq(ServiceFund::getUploadStates, serviceFund.getUploadStates()); } if (serviceFund.getFlowlevel() != null) { wrappers.eq(ServiceFund::getFlowlevel, serviceFund.getFlowlevel()); } if (serviceFund.getJxrq() != null) { wrappers.eq(ServiceFund::getJxrq, serviceFund.getJxrq()); } return this.list(wrappers); } @Override public List queryInfoById(ServiceFund serviceFund) { LambdaQueryWrapper wrappers = Wrappers.lambdaQuery(); if (serviceFund.getId() != null) { wrappers.eq(ServiceFund::getId, serviceFund.getId()); } wrappers.eq(ServiceFund::getDel_flag, "0"); return this.list(wrappers); } @Override public List getInfoByInfoId(Long infoid) { return serviceFundMapper.getInfoByInfoId(infoid); } @Override public Long getFundId(Long infoid) { return serviceFundMapper.getFundId(infoid); } @Override @Transactional(rollbackFor = Exception.class) public Boolean addFundSharedInfo(Long id) { log.info("fund表的id:{}", id); //判断一下,share表是否已经存在了 Map map = new HashMap<>(); map.put("serfunid", id); map.put("del_flag", 0); List serviceFundSharedList = serviceFundSharedMapper.selectByMap(map); if (!CollectionUtils.isEmpty(serviceFundSharedList)) { return true; } ServiceFund serviceFund = serviceFundMapper.selectById(id); ServiceFundShared serviceFundShared = DtoConversionUtils.sourceToTarget(serviceFund, ServiceFundShared.class); serviceFundShared.setSerfunid(serviceFundShared.getId()); serviceFundShared.setId(null); log.info("数据都插进去了吗? {}", serviceFundShared); sharedService.save(serviceFundShared); //fundId为主表的ID Map columnMap = new HashMap<>(); columnMap.put("fundid", id); List serviceFunddetails = serviceFunddetailMapper.selectByMap(columnMap); //将查出的数据放到ServiceFunddetailShared中 List serviceFunddetailShareds = DtoConversionUtils.sourceToTarget(serviceFunddetails, ServiceFunddetailShared.class); for (int i = 0; i < serviceFunddetails.size(); i++) { serviceFunddetailShareds.get(i).setFdid(serviceFunddetailShareds.get(i).getId()); //fundID为service_fund_shared表的主键ID serviceFunddetailShareds.get(i).setFundid(serviceFundShared.getId()); serviceFunddetailShareds.get(i).setId(null); //数据发送给财务 try { uploadOAFileAndUpdateDb(serviceFunddetailShareds.get(i)); } catch (Exception e) { e.printStackTrace(); log.error("Exception中入参的ID为:{},异常信息为 : {}", id, e.getMessage()); if (id != null) { Boolean aBoolean = sharedService.delfundsharedInfoById(null, id); log.error("fund2分享表里的数据是否删除成功:{}", aBoolean); } return false; } } boolean result = false; for (ServiceFunddetailShared serviceFunddetailShared : serviceFunddetailShareds) { if (ObjectUtils.isNotEmpty(serviceFunddetailShared)) { result = detailSharedService.save(serviceFunddetailShared); } else { log.info("serviceFunddetailShared为空了!!!"); } } return result; } @Override public List selectServiceFundList(ServiceFund serviceFund) { return serviceFundMapper.selectServiceFundList(serviceFund); } @Override public List selectVOList(FundVO fundVO) { return serviceFundMapper.selectVOList(fundVO); } @Override public List showFundDetailOne(ServiceFund serviceFund) { List l = new ArrayList<>(); FundDetailOneVO f1 = new FundDetailOneVO(); f1.setNumber("1"); f1.setMessage("获取专家总费用: " + serviceFund.getProcurementcost() + "元; " + "专家费用总金额: " + serviceFund.getExpertcost() + "元; " + "伦理审查费用总金额: " + serviceFund.getEthicscost() + "元"); FundDetailOneVO f2 = new FundDetailOneVO(); f2.setNumber("2"); f2.setMessage("捐献者医学成本总金额: " + serviceFund.getMedicalcost() + "元; " + "捐献者善后成本总金额: " + serviceFund.getAftercarecost() + "元"); FundDetailOneVO f3 = new FundDetailOneVO(); f3.setNumber("3"); f3.setMessage("捐献者家属食宿费总金额: " + serviceFund.getFamilycost() + "元"); l.add(f1); l.add(f2); l.add(f3); return l; } @Override public FundDetailTwoVO showFundDetailTwo(Long infoid) { FundDetailTwoVO fdvo = new FundDetailTwoVO(); List serviceFunds = serviceFundMapper.getInfoByInfoId(infoid); List fd = new ArrayList<>(); for (ServiceFund s : serviceFunds) { List l = serviceFunddetailMapper.getAllDetailsByFDIDHZ(s.getId()); for (ServiceFunddetail df : l) { fd.add(df); } } List serviceReimbursements1 = serviceReimbursementMapper.getInfoByInfoId(infoid); List serviceReimbursements2 = serviceReimbursementMapper.getInfoByInfoIdRelatives(infoid); double f1 = 0; double f2 = 0; double f3 = 0; double f4 = 0; double f5 = 0; double f6 = 0; double f7 = 0; double f8 = 0; double f9 = 0; double f10 = 0; double f11 = 0; double f12 = 0; double f13 = 0; double f14 = 0; double f15 = 0; double f16 = 0; double f17 = 0; double f18 = 0; double f19 = 0; double f20 = 0; double f21 = 0; double f22 = 0; double f23 = 0; double f24 = 0; double f25 = 0; double f26 = 0; double f27 = 0; double f28 = 0; double f29 = 0; double f30 = 0; double f31 = 0; double f32 = 0; double f33 = 0; double f34 = 0; double f35 = 0; double f36 = 0; double f37 = 0; double f38 = 0; double f39 = 0; double f40 = 0; double f41 = 0; double f42 = 0; double f43 = 0; double f44 = 0; double f45 = 0; double f46 = 0; double f47 = 0; double f48 = 0; double f49 = 0; double f50 = 0; double f51 = 0; double f52 = 0; double hj = 0; double sh1 = 0; double sh2 = 0; double sh3 = 0; double sh4 = 0; double sh5 = 0; double sh6 = 0; double sh7 = 0; double sh8 = 0; double sh9 = 0; double sh10 = 0; double sh11 = 0; double sh12 = 0; double sh13 = 0; double sh14 = 0; double sh15 = 0; double sh16 = 0; double sh17 = 0; double sh18 = 0; double sh19 = 0; double sh20 = 0; double sh21 = 0; double sh22 = 0; double sh23 = 0; double sh24 = 0; double sh25 = 0; double sh26 = 0; double sh27 = 0; double sh28 = 0; double sh29 = 0; double sh30 = 0; double sh31 = 0; double sh32 = 0; double sh33 = 0; double sh34 = 0; double sh35 = 0; double sh36 = 0; double sh37 = 0; double sh38 = 0; double sh39 = 0; double sh40 = 0; double sh41 = 0; double sh42 = 0; double sh43 = 0; double sh44 = 0; double sh45 = 0; double sh46 = 0; double sh47 = 0; double sh48 = 0; double sh49 = 0; double sh50 = 0; double sh51 = 0; double sh52 = 0; double shhj = 0; for (ServiceReimbursement sr : serviceReimbursements1) { f28 += sr.getAmountrequested(); sh28 += sr.getAmountrequested(); } for (ServiceReimbursement sr : serviceReimbursements2) { f51 += sr.getAmountrequested(); sh51 += sr.getAmountrequested(); } for (ServiceFunddetail s : fd) { if (s.getItemid() == 1) { f1 += s.getAmount(); sh1 += s.getTaxedamount(); } if (s.getItemid() == 2) { f2 += s.getAmount(); sh2 += s.getTaxedamount(); } if (s.getItemid() == 3) { f3 += s.getAmount(); sh3 += s.getTaxedamount(); } if (s.getItemid() == 4) { f4 += s.getAmount(); sh4 += s.getTaxedamount(); } if (s.getItemid() == 5) { f5 += s.getAmount(); sh5 += s.getTaxedamount(); } if (s.getItemid() == 6) { f6 += s.getAmount(); sh6 += s.getTaxedamount(); } if (s.getItemid() == 7) { f7 += s.getAmount(); sh7 += s.getTaxedamount(); } if (s.getItemid() == 8) { f8 += s.getAmount(); sh8 += s.getTaxedamount(); } if (s.getItemid() == 9) { f9 += s.getAmount(); sh9 += s.getTaxedamount(); } if (s.getItemid() == 10) { f10 += s.getAmount(); sh10 += s.getTaxedamount(); } if (s.getItemid() == 11) { f11 += s.getAmount(); sh11 += s.getTaxedamount(); } if (s.getItemid() == 12) { f12 += s.getAmount(); sh12 += s.getTaxedamount(); } if (s.getItemid() == 13) { f13 += s.getAmount(); sh13 += s.getTaxedamount(); } if (s.getItemid() == 14) { f14 += s.getAmount(); sh14 += s.getTaxedamount(); } if (s.getItemid() == 15) { f15 += s.getAmount(); sh15 += s.getTaxedamount(); } if (s.getItemid() == 16) { f16 += s.getAmount(); sh16 += s.getTaxedamount(); } if (s.getItemid() == 17) { f17 += s.getAmount(); sh17 += s.getTaxedamount(); } if (s.getItemid() == 18) { f18 += s.getAmount(); sh18 += s.getTaxedamount(); } if (s.getItemid() == 19) { f19 += s.getAmount(); sh19 += s.getTaxedamount(); } if (s.getItemid() == 20) { f20 += s.getAmount(); sh20 += s.getTaxedamount(); } if (s.getItemid() == 21) { f21 += s.getAmount(); sh21 += s.getTaxedamount(); } if (s.getItemid() == 22) { f22 += s.getAmount(); sh22 += s.getTaxedamount(); } if (s.getItemid() == 23) { f23 += s.getAmount(); sh23 += s.getTaxedamount(); } if (s.getItemid() == 24) { f24 += s.getAmount(); sh24 += s.getTaxedamount(); } if (s.getItemid() == 25) { f25 += s.getAmount(); sh25 += s.getTaxedamount(); } if (s.getItemid() == 26) { f26 += s.getAmount(); sh26 += s.getTaxedamount(); } if (s.getItemid() == 27) { f27 += s.getAmount(); sh27 += s.getTaxedamount(); } if (s.getItemid() == 29) { f29 += s.getAmount(); sh29 += s.getTaxedamount(); } if (s.getItemid() == 30) { f30 += s.getAmount(); sh30 += s.getTaxedamount(); } if (s.getItemid() == 31) { f31 += s.getAmount(); sh31 += s.getTaxedamount(); } if (s.getItemid() == 32) { f32 += s.getAmount(); sh32 += s.getTaxedamount(); } if (s.getItemid() == 33) { f33 += s.getAmount(); sh33 += s.getTaxedamount(); } if (s.getItemid() == 34) { f34 += s.getAmount(); sh34 += s.getTaxedamount(); } if (s.getItemid() == 35) { f35 += s.getAmount(); sh35 += s.getTaxedamount(); } if (s.getItemid() == 36) { f36 += s.getAmount(); sh36 += s.getTaxedamount(); } if (s.getItemid() == 37) { f37 += s.getAmount(); sh37 += s.getTaxedamount(); } if (s.getItemid() == 38) { f38 += s.getAmount(); sh38 += s.getTaxedamount(); } if (s.getItemid() == 39) { f39 += s.getAmount(); sh39 += s.getTaxedamount(); } if (s.getItemid() == 40) { f40 += s.getAmount(); sh40 += s.getTaxedamount(); } if (s.getItemid() == 41) { f41 += s.getAmount(); sh41 += s.getTaxedamount(); } if (s.getItemid() == 42) { f42 += s.getAmount(); sh42 += s.getTaxedamount(); } if (s.getItemid() == 43) { f43 += s.getAmount(); sh43 += s.getTaxedamount(); } if (s.getItemid() == 44) { f44 += s.getAmount(); sh44 += s.getTaxedamount(); } if (s.getItemid() == 45) { f45 += s.getAmount(); sh45 += s.getTaxedamount(); } if (s.getItemid() == 46) { f46 += s.getAmount(); sh46 += s.getTaxedamount(); } if (s.getItemid() == 47) { f47 += s.getAmount(); sh47 += s.getTaxedamount(); } if (s.getItemid() == 48) { f48 += s.getAmount(); sh48 += s.getTaxedamount(); } if (s.getItemid() == 49) { f49 += s.getAmount(); sh49 += s.getTaxedamount(); } if (s.getItemid() == 50) { f50 += s.getAmount(); sh50 += s.getTaxedamount(); } if (s.getItemid() == 52) { f52 += s.getAmount(); sh52 += s.getTaxedamount(); } } hj = f1 + f2 + f3 + f4 + f5 + f6 + f7 + f8 + f9 + f10 + f11 + f12 + f13 + f14 + f15 + f16 + f17 + f18 + f19 + f20 + f21 + f22 + f23 + f24 + f25 + f26 + f27 + f28 + f29 + f30 + f31 + f32 + f33 + f34 + f35 + f36 + f37 + f38 + f39 + f40 + f41 + f42 + f43 + f44 + f45 + f46 + f47 + f48 + f49 + f50 + f51 + f52; shhj = sh1 + sh2 + sh3 + sh4 + sh5 + sh6 + sh7 + sh8 + sh9 + sh10 + sh11 + sh12 + sh13 + sh14 + sh15 + sh16 + sh17 + sh18 + sh19 + sh20 + sh21 + sh22 + sh23 + sh24 + sh25 + sh26 + sh27 + sh28 + sh29 + sh30 + sh31 + sh32 + sh33 + sh34 + sh35 + sh36 + sh37 + sh38 + sh39 + sh40 + sh41 + sh42 + sh43 + sh44 + sh45 + sh46 + sh47 + sh48 + sh49 + sh50 + sh51 + sh52; fdvo.setFy1(f1); fdvo.setFy2(f2); fdvo.setFy3(f3); fdvo.setFy4(f4); fdvo.setFy5(f5); fdvo.setFy6(f6); fdvo.setFy7(f7); fdvo.setFy8(f8); fdvo.setFy9(f9); fdvo.setFy10(f10); fdvo.setFy11(f11); fdvo.setFy12(f12); fdvo.setFy13(f13); fdvo.setFy14(f14); fdvo.setFy15(f15); fdvo.setFy16(f16); fdvo.setFy17(f17); fdvo.setFy18(f18); fdvo.setFy19(f19); fdvo.setFy20(f20); fdvo.setFy21(f21); fdvo.setFy22(f22); fdvo.setFy23(f23); fdvo.setFy24(f24); fdvo.setFy25(f25); fdvo.setFy26(f26); fdvo.setFy27(f27); fdvo.setFy28(f28); fdvo.setFy29(f29); fdvo.setFy30(f30); fdvo.setFy31(f31); fdvo.setFy32(f32); fdvo.setFy33(f33); fdvo.setFy34(f34); fdvo.setFy35(f35); fdvo.setFy36(f36); fdvo.setFy37(f37); fdvo.setFy38(f38); fdvo.setFy39(f39); fdvo.setFy40(f40); fdvo.setFy41(f41); fdvo.setFy42(f42); fdvo.setFy43(f43); fdvo.setFy44(f44); fdvo.setFy45(f45); fdvo.setFy46(f46); fdvo.setFy47(f47); fdvo.setFy48(f48); fdvo.setFy49(f49); fdvo.setFy50(f50); fdvo.setFy51(f51); fdvo.setFy52(f52); fdvo.setFyhj(hj); fdvo.setSh1(sh1); fdvo.setSh2(sh2); fdvo.setSh3(sh3); fdvo.setSh4(sh4); fdvo.setSh5(sh5); fdvo.setSh6(sh6); fdvo.setSh7(sh7); fdvo.setSh8(sh8); fdvo.setSh9(sh9); fdvo.setSh10(sh10); fdvo.setSh11(sh11); fdvo.setSh12(sh12); fdvo.setSh13(sh13); fdvo.setSh14(sh14); fdvo.setSh15(sh15); fdvo.setSh16(sh16); fdvo.setSh17(sh17); fdvo.setSh18(sh18); fdvo.setSh19(sh19); fdvo.setSh20(sh20); fdvo.setSh21(sh21); fdvo.setSh22(sh22); fdvo.setSh23(sh23); fdvo.setSh24(sh24); fdvo.setSh25(sh25); fdvo.setSh26(sh26); fdvo.setSh27(sh27); fdvo.setSh28(sh28); fdvo.setSh29(sh29); fdvo.setSh30(sh30); fdvo.setSh31(sh31); fdvo.setSh32(sh32); fdvo.setSh33(sh33); fdvo.setSh34(sh34); fdvo.setSh35(sh35); fdvo.setSh36(sh36); fdvo.setSh37(sh37); fdvo.setSh38(sh38); fdvo.setSh39(sh39); fdvo.setSh40(sh40); fdvo.setSh41(sh41); fdvo.setSh42(sh42); fdvo.setSh43(sh43); fdvo.setSh44(sh44); fdvo.setSh45(sh45); fdvo.setSh46(sh46); fdvo.setSh47(sh47); fdvo.setSh48(sh48); fdvo.setSh49(sh49); fdvo.setSh50(sh50); fdvo.setSh51(sh51); fdvo.setSh52(sh52); fdvo.setShhj(shhj); return fdvo; } @Override public String returnId(Long id) { return id.toString(); } @Override public List getListBypower(String PAUSERNO, Integer PAFUNDTYPE, String PAAPPLICANT, String PAAPPLICATIONBEGTIME, String PAAPPLICATIONENDTIME, String PADEPARTMENT, Integer CHECKFLAG, Integer APPLYTYPE, Integer CHECKSTATUS, String donorname) { return serviceFundMapper.getListBypower(PAUSERNO, PAFUNDTYPE, PAAPPLICANT, PAAPPLICATIONBEGTIME, PAAPPLICATIONENDTIME, PADEPARTMENT, CHECKFLAG, APPLYTYPE, CHECKSTATUS, donorname); } @Override public List getExpertfeeList(SpSelectExpertfee spSelectExpertfee) { log.info("spSelectExpertfee的入参为:{}", spSelectExpertfee); return serviceFundMapper.getExpertfeeList(spSelectExpertfee.getPaApplyType(), spSelectExpertfee.getPfundtaxid(), spSelectExpertfee.getDonorname(), spSelectExpertfee.getPadepartid(), spSelectExpertfee.getPausername()); } @Override public int countItem(Long infoid, Long itemid) { List serviceFunds = serviceFundMapper.getInfoByInfoId(infoid); int count = 0; for (ServiceFund s : serviceFunds) { long fundid = s.getId(); int l = serviceFunddetailMapper.countItem(fundid, itemid); count += l; } return count; } @Override @Transactional(rollbackFor = Exception.class) public Long addOrUpdateNew(ServiceFundVO serviceFundVO) { Long id = null; //将数据保存到fund表 serviceFundVO.setUploadStates(0); id = saveFund(serviceFundVO); List serviceFunddetails = serviceFundVO.getServiceFunddetails(); BigDecimal bigDecimal = new BigDecimal(0.0); if (!CollectionUtils.isEmpty(serviceFunddetails)) { // 保存详情数据 for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) { //去掉身份证的首尾空格 if (StringUtils.isNotEmpty(serviceFunddetailVO.getIdcardno())) { serviceFunddetailVO.setIdcardno(serviceFunddetailVO.getIdcardno().trim()); } log.info("身份证号为:{}", serviceFunddetailVO.getIdcardno()); if (StringUtils.isEmpty(serviceFunddetailVO.getBankcardno())) { throw new BaseException("请检查银行卡号是否为空,姓名:" + serviceFunddetailVO.getBeneficiaryname()); } serviceFunddetailVO.setFundid(id); //將附件转成json if (!CollectionUtils.isEmpty(serviceFunddetailVO.getAnnexfilesList())) { serviceFunddetailVO.setAnnexfiles(JSON.toJSONString(serviceFunddetailVO.getAnnexfilesList())); } else { serviceFunddetailVO.setAnnexfiles(null); } if (!CollectionUtils.isEmpty(serviceFunddetailVO.getInvoicefilesList())) { serviceFunddetailVO.setInvoicefiles(JSON.toJSONString(serviceFunddetailVO.getInvoicefilesList())); } else { serviceFunddetailVO.setInvoicefiles(null); } ServiceFunddetail serviceFunddetail = DtoConversionUtils.sourceToTarget(serviceFunddetailVO, ServiceFunddetail.class); if (serviceFunddetailVO.getId() == null) { serviceFunddetailService.save(serviceFunddetail); } else { serviceFunddetailService.updateById(serviceFunddetail); } bigDecimal = bigDecimal.add(BigDecimal.valueOf(serviceFunddetailVO.getAmount())); } } serviceFundVO.setPretaxcost(bigDecimal.doubleValue()); serviceFundMapper.updateById(serviceFundVO); return id; } @Override public Map performance(ServiceFundVO serviceFundVO) { Long id = null; //将数据保存到fund表 id = saveFund(serviceFundVO); List serviceFunddetails = serviceFundVO.getServiceFunddetails(); if (CollectionUtils.isEmpty(serviceFunddetails)) { System.out.println("serviceFunddetails为空喽"); return null; } //总税前 Double pretaxcosts = 0.00; //总税后 Double taxedcosts = 0.00; for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) { serviceFunddetailVO.setFundid(id); ServiceFunddetail serviceFunddetail = DtoConversionUtils.sourceToTarget(serviceFunddetailVO, ServiceFunddetail.class); Map performance = serviceFunddetailService.performance(serviceFunddetail); if (!performance.isEmpty()) { Double amount = performance.get("amount"); Double taxedamount = performance.get("taxedamount"); pretaxcosts = pretaxcosts + amount; taxedcosts = taxedcosts + taxedamount; } serviceFundVO.setPretaxcost(pretaxcosts); serviceFundVO.setTaxedcost(taxedcosts); updateById(serviceFundVO); } Map map = new HashMap(); map.put("fundId", id); return map; } @Override public Map> totaltax(TotalTaxVO totalTaxVO) { if (CollectionUtils.isEmpty(totalTaxVO.getFundids())) { throw new BaseException("请勾选之后,再进行合计个税"); } Map> map = new HashMap<>(); if (totalTaxVO.getIsTaxAfter() == null) { //如何为空,默认当没有算过税,进行合计 totalTaxVO.setIsTaxAfter(0); } List serviceFunddetails = serviceFunddetailMapper.totlaTax(totalTaxVO.getFundids()); if (CollectionUtils.isEmpty(serviceFunddetails)) { throw new BaseException("查询的详情数据为空"); } //用于返回excel List serviceFunddetailList = new ArrayList<>(); if (totalTaxVO.getIsTaxAfter() == 1) { //通过受益人名称,将税前、税后的值相加 Map sumAmount = serviceFunddetails.stream().collect(Collectors.groupingBy(ServiceFunddetail::getBeneficiaryname, Collectors.summingDouble(ServiceFunddetail::getAmount))); Map sumTaxdAmount = serviceFunddetails.stream().collect(Collectors.groupingBy(ServiceFunddetail::getBeneficiaryname, Collectors.summingDouble(ServiceFunddetail::getTaxedamount))); for (String key : sumAmount.keySet()) { ServiceFunddetailExcel serviceFunddetailExcel = new ServiceFunddetailExcel(); serviceFunddetailExcel.setAmount(sumAmount.getOrDefault(key, 0.0)); serviceFunddetailExcel.setTaxedamount(sumTaxdAmount.getOrDefault(key, 0.0)); for (ServiceFunddetail serviceFunddetail2 : serviceFunddetails) { if (serviceFunddetail2.getBeneficiaryname().equals(key)) { serviceFunddetailExcel.setIdcardno(serviceFunddetail2.getIdcardno()); serviceFunddetailExcel.setBankcardno(serviceFunddetail2.getBankcardno()); serviceFunddetailExcel.setBeneficiaryname(serviceFunddetail2.getBeneficiaryname()); serviceFunddetailExcel.setDepositbank(serviceFunddetail2.getDepositbank()); serviceFunddetailExcel.setBranchbankname(serviceFunddetail2.getBranchbankname()); serviceFunddetailExcel.setDonorname(serviceFunddetail2.getDonorname()); serviceFunddetailExcel.setPhone(serviceFunddetail2.getPhone()); break; } } serviceFunddetailList.add(serviceFunddetailExcel); } //返回算过税之后的,合计 map.put("合计个税(税后)", serviceFunddetailList); return map; } else { a: for (ServiceFunddetail serviceFunddetail : serviceFunddetails) { ServiceFunddetailExcel sfeBefore = new ServiceFunddetailExcel(); ServiceFunddetailExcel sfeAfter = new ServiceFunddetailExcel(); for (ServiceFunddetailExcel serviceFunddetailExcel : serviceFunddetailList) { //判断一下,该受益人是否已经计算过,已经计算过了,就不算了 if (serviceFunddetail.getBeneficiaryname().trim().equals(serviceFunddetailExcel.getBeneficiaryname().trim())) { continue a; } } for (ServiceFunddetail serviceFunddetail2 : serviceFunddetails) { if (StringUtils.isEmpty(serviceFunddetail2.getServicesscopename())) { ServiceFund serviceFund = null; if (serviceFunddetail2.getFundid() == null) { serviceFund = serviceFundMapper.selectById(serviceFunddetail2.getFundid()); } throw new BaseException("服务说明为空,请检查后再计算,捐献者为 :" + serviceFund.getDonorname()); } if (serviceFunddetail.getBeneficiaryname().equals(serviceFunddetail2.getBeneficiaryname()) && !(serviceFunddetail2.getServicesscopename().equals("税后"))) { //累计税前 sfeBefore.setIdcardno(serviceFunddetail2.getIdcardno()); sfeBefore.setBankcardno(serviceFunddetail2.getBankcardno()); sfeBefore.setBeneficiaryname(serviceFunddetail2.getBeneficiaryname()); sfeBefore.setDepositbank(serviceFunddetail2.getDepositbank()); sfeBefore.setBranchbankname(serviceFunddetail2.getBranchbankname()); sfeBefore.setDonorname(serviceFunddetail2.getDonorname()); sfeBefore.setPhone(serviceFunddetail2.getPhone()); if (sfeBefore.getAmount() == null) { sfeBefore.setAmount(serviceFunddetail2.getAmount()); } else { sfeBefore.setAmount(sfeBefore.getAmount() + serviceFunddetail2.getAmount()); } sfeBefore.setTaxedamount(null); } else if (serviceFunddetail.getBeneficiaryname().equals(serviceFunddetail2.getBeneficiaryname()) && serviceFunddetail2.getServicesscopename().equals("税后")) { //累计税后 sfeAfter.setIdcardno(serviceFunddetail2.getIdcardno()); sfeAfter.setBankcardno(serviceFunddetail2.getBankcardno()); sfeAfter.setBeneficiaryname(serviceFunddetail2.getBeneficiaryname()); sfeAfter.setDepositbank(serviceFunddetail2.getDepositbank()); sfeAfter.setBranchbankname(serviceFunddetail2.getBranchbankname()); sfeAfter.setDonorname(serviceFunddetail2.getDonorname()); sfeAfter.setPhone(serviceFunddetail2.getPhone()); sfeAfter.setAmount(null); if (sfeAfter.getTaxedamount() == null) { sfeAfter.setTaxedamount(serviceFunddetail2.getTaxedamount()); } else { sfeAfter.setTaxedamount(sfeAfter.getTaxedamount() + serviceFunddetail2.getTaxedamount()); } } } //将计算好的税前总值、税后总值,放到List中 if (ObjectUtils.isNotEmpty(sfeBefore.getBeneficiaryname())) serviceFunddetailList.add(sfeBefore); if (ObjectUtils.isNotEmpty(sfeAfter.getBeneficiaryname())) serviceFunddetailList.add(sfeAfter); } //返回算税之前的,合计 map.put("合计个税(税前)", serviceFunddetailList); return map; } } @Override public Map exportFeeSum(Integer faxId) { List list = vExpertfeeTotalMapper.selectVExpertfeeTotalListByTaxId(faxId); ExcelUtil util = new ExcelUtil(VExpertfeeTotal.class); AjaxResult ajaxResult = util.exportExcel(list, "vExpertfeeTotal"); String filePath = RuoYiConfig.getDownloadPath() + ajaxResult.get("msg"); List list2 = vExpertfeeDonorMapper.selectVExpertfeeDonorList2(faxId); ExcelUtil util2 = new ExcelUtil(VExpertfeeDonor.class); AjaxResult ajaxResult2 = util2.exportExcel(list2, "VExpertfeeDonor"); List list3 = vExpertfeeExpertMapper.selectVExpertfeeExpertListByFaxId(faxId); ExcelUtil util3 = new ExcelUtil(VExpertfeeExpert.class); AjaxResult ajaxResult3 = util3.exportExcel(list3, "vExpertfeeExpert"); List list1 = new ArrayList<>(); list1.add(ajaxResult.get("msg").toString()); list1.add(ajaxResult2.get("msg").toString()); list1.add(ajaxResult3.get("msg").toString()); String name = "专家费汇总单" + new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()) + ".xlsx"; mergeExcel(list1, RuoYiConfig.getDownloadPath() + name); for (String path : list1) { new File(RuoYiConfig.getDownloadPath() + path).delete(); } Map map = new HashMap<>(); map.put("downloadUrl", "/profile/download/" + name); map.put("downloadName", name); return map; } int uploadOAFileAndUpdateDb(ServiceFunddetailShared remShare) throws Exception { //上传OA文件 //String strUrl = "http://129.88.242.39:8899/seeyon/rest/token?userName=opo&password=127814f8-84e8-4304-84a5-a71573567efd&loginName=demo3"; String strUrl = "http://129.88.242.39:8899/seeyon/rest/token"; //String strUrl = "http://slb.hospitalstar.com:8899/seeyon/rest/token"; //上传文件成功后,去更新相关的数据库 Map map = new HashMap(); map.put("userName", "opo"); map.put("password", "4126407a-9821-4874-be41-6568abd6dbe5"); map.put("loginName", "demo3"); JSONObject jsonObj = new JSONObject(map); System.out.println("uploadOAFileAndUpdateDb + jsonObject" + jsonObj.toString() + "\r\n" + jsonObj.toJSONString()); String strRes = HttpClientKit.postOpr(strUrl, jsonObj.toString());// //String strRes = HttpClientKit.postMsg(strUrl,jsonObj);//得到返回的token? JSONObject json1 = JSONObject.parseObject(strRes); strRes = json1.get("id").toString(); String filePath = RuoYiConfig.getUploadPath(); String strFUrl = "http://129.88.242.39:8899/seeyon/rest/attachment?token=" + strRes; List parseArray2 = new ArrayList<>(); List invoicefilesList = new ArrayList<>(); //普通附件 List parseArray = JSON.parseArray(remShare.getAnnexfiles(), RbDetailFile.class); //发票附件 List invoicefilesArray = JSON.parseArray(remShare.getInvoicefiles(), RbDetailFile.class); log.info("parseArray的值 : {}, invoicefilesArray的值 : {},", parseArray, invoicefilesArray); //普通附件 uploadFile(filePath, strFUrl, parseArray2, parseArray, remShare, "1"); //发票附件 uploadFile(filePath, strFUrl, invoicefilesList, invoicefilesArray, remShare, "2"); return 0; } private Integer uploadFile(String filePath, String strFUrl, List parseArray2, List parseArray, ServiceFunddetailShared remShare, String flag) throws Exception { if (!CollectionUtils.isEmpty(parseArray)) { for (int i = 0; i < parseArray.size(); i++) { RbDetailFile rbDetailFile = parseArray.get(i); log.info("filePath的修改:{}", filePath); String url = rbDetailFile.getUrl(); //file用的是绝对位置 String substring = url.substring(url.indexOf("/profile/upload") + "/profile/upload".length()); // String strFile = rbDetailFile.getUrl().replace(filePath, "/profile/upload"); System.out.println("fund服务的filePath + substring: " + filePath + substring); File filetest = new File(filePath + substring); String struploadResult = HttpClientKit.sendPostWithFile(filetest, strFUrl); log.info("第三方传回的数据: {}", struploadResult); if (StringUtils.isEmpty(struploadResult)) { log.error("HttpClientKit.sendPostWithFile 请求为空了 filetest:{}, strFUrl:{} ", filetest, strFUrl); return 0; } //获取fileid JSONObject jsonR = JSONObject.parseObject(struploadResult); JSONArray jsonArr = jsonR.getJSONArray("atts"); log.info("第三方传回的数据获取的atts : {}", jsonArr); for (int j = 0; j < jsonArr.size(); j++) { JSONObject jsonRet = jsonArr.getJSONObject(j); if (StringUtils.isEmpty(jsonRet.get("fileUrl").toString())) { throw new BaseException("fileID为空,请联系第三方处理"); } rbDetailFile.setFileid(jsonRet.get("fileUrl").toString()); } parseArray2.add(rbDetailFile); } if (flag.equals("1")) { //如果flag为1,则是普通 remShare.setAnnexfiles(JSON.toJSONString(parseArray2)); } else if (flag.equals("2")) { //如果flag为2,则是发票 remShare.setInvoicefiles(JSON.toJSONString(parseArray2)); } log.info("ServiceReimbursementdetailShared 是否加上了fileid : {}", remShare); } return 0; } // int uploadOAFileAndUpdateDb(ServiceFundShared remShare) { // //上传OA文件 // //String strUrl = "http://129.88.242.39:8899/seeyon/rest/token?userName=opo&password=127814f8-84e8-4304-84a5-a71573567efd&loginName=demo3"; // String strUrl = "http://129.88.242.39:8899/seeyon/rest/token"; // //String strUrl = "http://slb.hospitalstar.com:8899/seeyon/rest/token"; // //上传文件成功后,去更新相关的数据库 // // // Map map = new HashMap(); // map.put("userName", "opo"); // map.put("password", "4126407a-9821-4874-be41-6568abd6dbe5"); // map.put("loginName", "demo3"); // // JSONObject jsonObj = new JSONObject(map); // // System.out.println("uploadOAFileAndUpdateDb + jsonObject" + jsonObj.toString() + "\r\n" + jsonObj.toJSONString()); // String strRes = HttpClientKit.postOpr(strUrl, jsonObj.toString());// // //String strRes = HttpClientKit.postMsg(strUrl,jsonObj);//得到返回的token? // // JSONObject json1 = JSONObject.parseObject(strRes); // strRes = json1.get("id").toString(); // // ///if(strRes.isEmpty() || "" == strRes) return -1;// 为空代表失败 // // //下面需求调用文件的接口,调用成功返回后,得到filename和fileid 用这二个值去更新数据 // // String filePath = RuoYiConfig.getUploadPath(); // String strMutfileUrl = remShare.getAnnexbankcard();//可能存在多个地址,以,分开 // // String strFUrl = "http://129.88.242.39:8899/seeyon/rest/attachment?token=" + strRes; // //String strFUrl = "http://slb.hospitalstar.com:8899/seeyon/rest/attachment?token="+strRes; // //strFUrl = String.format(strFUrl, strRes); // // /*File test = null; // File file = new File("E:\\YYJQ\\OPO\\WEB\\Upload\\upload\\2023\\02\\17"); // if (file.exists() && file.isDirectory()) { // // 获取所有盲盒文件夹 // File[] ones = file.listFiles(); // for (File one : ones) { // test = one; // } // }*/ // // String filename = ""; // String fileid = ""; // // String[] urlArray = strMutfileUrl.split(","); // for (int i = 0; i < urlArray.length; i++) { // String strOneFileName = urlArray[i]; // String strTemp = strOneFileName.substring(15); // String strFile = filePath + strTemp; // //FileUploadUtils.getAbsoluteFile(filePath,strOneFileName); // String struploadResult = ""; // File filetest = new File(strFile); // try { // struploadResult = HttpClientKit.sendPostWithFile(filetest, strFUrl); // } catch (Exception e) { // e.printStackTrace(); // } // // // //String strFRes = HttpClientKit.postMsg(strFUrl,jsonFObj); // if (struploadResult == null) return 0; // if (struploadResult.isEmpty()) return 0; // // JSONObject jsonR = JSONObject.parseObject(struploadResult); // // JSONArray jsonArr = jsonR.getJSONArray("atts"); // for (int j = 0; j < jsonArr.size(); j++) { // JSONObject jsonRet = jsonArr.getJSONObject(j); // String name1 = jsonRet.get("filename").toString(); // String id1 = jsonRet.get("fileUrl").toString(); // filename += name1; // fileid += id1; // if (i != urlArray.length - 1) { // filename += ","; // fileid += ","; // } // } // // } // // long nId = remShare.getId(); // remShare.setId(nId); // remShare.setFilename(filename); // remShare.setFileid(fileid); // boolean bRet = sharedService.updateById(remShare); // if (!bRet) return -1; // // return 0; // } public long saveFund(ServiceFundVO serviceFundVO) { Long id = null; //将数据保存到fund表 if (ObjectUtils.isNotEmpty(serviceFundVO) && serviceFundVO.getId() == null) { serviceFundVO.setCheckstatus(serviceFundVO.getCheckstatus() == null ? 1 : 2); save(serviceFundVO); id = serviceFundVO.getId(); } else { updateById(serviceFundVO); id = serviceFundVO.getId(); } return id; } public void mergeExcel(List files, String outputFile) { try { Workbook resultWorkbook = new XSSFWorkbook(); for (String file : files) { InputStream is1 = new FileInputStream(RuoYiConfig.getDownloadPath() + file); Workbook workbook1 = new XSSFWorkbook(is1); Sheet sheet1 = workbook1.getSheetAt(0); // 复制第一个文件的Sheet Sheet newSheet1 = resultWorkbook.createSheet(file.substring(0, file.indexOf("."))); for (Row row : sheet1) { Row newRow = newSheet1.createRow(row.getRowNum()); int columns = row.getLastCellNum(); for (int i = 0; i < columns; i++) { newSheet1.setColumnWidth(i, 5000); Cell cell = row.getCell(i); Cell newCell = newRow.createCell(cell.getColumnIndex()); newCell.setCellValue(cell.getStringCellValue()); // 创建单元格样式 CellStyle style = resultWorkbook.createCellStyle(); style.setAlignment(HorizontalAlignment.CENTER); // 水平居中 style.setVerticalAlignment(VerticalAlignment.CENTER); // 垂直居中 if (row.getRowNum() == 0) { // 设置第一行背景色 style.setFillForegroundColor(IndexedColors.GREY_50_PERCENT.getIndex()); style.setFillPattern(FillPatternType.SOLID_FOREGROUND); } newCell.setCellStyle(style); } } } FileOutputStream out = new FileOutputStream(outputFile); resultWorkbook.write(out); } catch (Exception e) { e.printStackTrace(); } } @Transactional(rollbackFor = Exception.class) public Boolean updateFundTaxIdById(Long id, Long fundTaxId) { //将fund里的算税时间,与详情里的版税时间全清空 Boolean aBoolean = serviceFundMapper.updateFundTaxIdById(id, fundTaxId); ServiceFunddetail serviceFunddetail = new ServiceFunddetail(); serviceFunddetail.setFundid(id); serviceFunddetail.setTaxTime(null); serviceFunddetail.setXh(null); boolean b = serviceFunddetailMapper.updateTaxTime(serviceFunddetail); return b; } }