From 318ff5bea1f2e41f6496da525ae7f9a3833d081d Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期一, 13 十一月 2023 12:27:12 +0800 Subject: [PATCH] 代码提交 --- ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java | 233 +++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 215 insertions(+), 18 deletions(-) diff --git a/ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java b/ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java index 3edc1f1..76c4855 100644 --- a/ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java +++ b/ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java @@ -6,14 +6,17 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.ruoyi.common.config.RuoYiConfig; -import com.ruoyi.common.tax.TaxtUtils; +import com.ruoyi.common.exception.base.BaseException; +import com.ruoyi.common.utils.ChineseUtils; import com.ruoyi.common.utils.HttpClientKit; 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.*; @@ -659,8 +662,8 @@ } @Override - public List<SpFinancialExpensesFundOut> getListBypower(String PAUSERNO, Integer PAFUNDTYPE, String PAAPPLICANT, String PAAPPLICATIONBEGTIME, String PAAPPLICATIONENDTIME, String PADEPARTMENT, Integer CHECKFLAG, Integer APPLYTYPE) { - return serviceFundMapper.getListBypower(PAUSERNO, PAFUNDTYPE, PAAPPLICANT, PAAPPLICATIONBEGTIME, PAAPPLICATIONENDTIME, PADEPARTMENT, CHECKFLAG, APPLYTYPE); + public List<SpFinancialExpensesFundOut> 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 @@ -678,28 +681,31 @@ } @Override - @Transactional + @Transactional(rollbackFor = Exception.class) public Long addOrUpdateNew(ServiceFundVO serviceFundVO) { Long id = null; //灏嗘暟鎹繚瀛樺埌fund琛� - if (serviceFundVO.getId() == null) { - save(serviceFundVO); - id = serviceFundVO.getId(); - } else { - updateById(serviceFundVO); - id = serviceFundVO.getId(); - } + id = saveFund(serviceFundVO); + List<ServiceFunddetailVO> serviceFunddetails = serviceFundVO.getServiceFunddetails(); if (CollectionUtils.isEmpty(serviceFunddetails)) { - System.out.println("serviceFunddetails涓虹┖鍠�"); - return null; + throw new BaseException("serviceFunddetails涓虹┖鍠�"); } + + BigDecimal bigDecimal = new BigDecimal(0.0); // 淇濆瓨璇︽儏鏁版嵁 for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) { + + if (StringUtils.isEmpty(serviceFunddetailVO.getBankcardno())) { + throw new BaseException("璇锋鏌ラ摱琛屽崱鍙锋槸鍚︿负绌�,濮撳悕锛�" + serviceFunddetailVO.getBeneficiaryname()); + } serviceFunddetailVO.setFundid(id); //灏囬檮浠惰浆鎴恓son if (!CollectionUtils.isEmpty(serviceFunddetailVO.getAnnexfilesList())) { serviceFunddetailVO.setAnnexfiles(JSON.toJSONString(serviceFunddetailVO.getAnnexfilesList())); + } + if (!CollectionUtils.isEmpty(serviceFunddetailVO.getInvoicefilesList())) { + serviceFunddetailVO.setInvoicefiles(JSON.toJSONString(serviceFunddetailVO.getInvoicefilesList())); } ServiceFunddetail serviceFunddetail = DtoConversionUtils.sourceToTarget(serviceFunddetailVO, ServiceFunddetail.class); @@ -708,10 +714,166 @@ } else { serviceFunddetailService.updateById(serviceFunddetail); } - } + bigDecimal = bigDecimal.add(BigDecimal.valueOf(serviceFunddetailVO.getAmount())); + + + } + serviceFundVO.setPretaxcost(bigDecimal.doubleValue()); + serviceFundMapper.updateById(serviceFundVO); return id; } + + @Override + public Map<String, Long> performance(ServiceFundVO serviceFundVO) { + Long id = null; + //灏嗘暟鎹繚瀛樺埌fund琛� + id = saveFund(serviceFundVO); + + List<ServiceFunddetailVO> 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<String, Double> 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<String, List<ServiceFunddetailExcel>> totaltax(TotalTaxVO totalTaxVO) { + if (CollectionUtils.isEmpty(totalTaxVO.getFundids())) { + throw new BaseException("璇峰嬀閫変箣鍚庯紝鍐嶈繘琛屽悎璁′釜绋�"); + } + Map<String, List<ServiceFunddetailExcel>> map = new HashMap<>(); + + if (totalTaxVO.getIsTaxAfter() == null) { + //濡備綍涓虹┖锛岄粯璁ゅ綋娌℃湁绠楄繃绋庯紝杩涜鍚堣 + totalTaxVO.setIsTaxAfter(0); + } + List<ServiceFunddetail> serviceFunddetails = serviceFunddetailMapper.totlaTax(totalTaxVO.getFundids()); + if (CollectionUtils.isEmpty(serviceFunddetails)) { + throw new BaseException("鏌ヨ鐨勮鎯呮暟鎹负绌�"); + } + + //鐢ㄤ簬杩斿洖excel + List<ServiceFunddetailExcel> serviceFunddetailList = new ArrayList<>(); + + if (totalTaxVO.getIsTaxAfter() == 1) { + //閫氳繃鍙楃泭浜哄悕绉帮紝灏嗙◣鍓嶃�佺◣鍚庣殑鍊肩浉鍔� + Map<String, Double> sumAmount = serviceFunddetails.stream().collect(Collectors.groupingBy(ServiceFunddetail::getBeneficiaryname, Collectors.summingDouble(ServiceFunddetail::getAmount))); + Map<String, Double> 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; + } + } + int uploadOAFileAndUpdateDb(ServiceFunddetailShared remShare) { //涓婁紶OA鏂囦欢 @@ -736,8 +898,24 @@ String filePath = RuoYiConfig.getUploadPath(); String strFUrl = "http://129.88.242.39:8899/seeyon/rest/attachment?token=" + strRes; List<RbDetailFile> parseArray2 = new ArrayList<>(); + List<RbDetailFile> invoicefilesList = new ArrayList<>(); + + //鏅�氶檮浠� List<RbDetailFile> parseArray = JSON.parseArray(remShare.getAnnexfiles(), RbDetailFile.class); - log.info("parseArray鐨勫�� : {}", parseArray); + //鍙戠エ闄勪欢 + List<RbDetailFile> 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<RbDetailFile> parseArray2, List<RbDetailFile> parseArray, ServiceFunddetailShared remShare, String flag) { if (!CollectionUtils.isEmpty(parseArray)) { for (int i = 0; i < parseArray.size(); i++) { RbDetailFile rbDetailFile = parseArray.get(i); @@ -753,7 +931,7 @@ String struploadResult = HttpClientKit.sendPostWithFile(filetest, strFUrl); log.info("绗笁鏂逛紶鍥炵殑鏁版嵁: {}", struploadResult); if (StringUtils.isEmpty(struploadResult)) { - log.info("HttpClientKit.sendPostWithFile 璇锋眰涓虹┖浜� filetest:{}, strFUrl:{} ", filetest, strFUrl); + log.error("HttpClientKit.sendPostWithFile 璇锋眰涓虹┖浜� filetest:{}, strFUrl:{} ", filetest, strFUrl); return 0; } //鑾峰彇fileid @@ -769,12 +947,17 @@ } parseArray2.add(rbDetailFile); } - remShare.setAnnexfiles(JSON.toJSONString(parseArray2)); + 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 鏄惁鍔犱笂浜唂ileid : {}", remShare); } return 0; } - // int uploadOAFileAndUpdateDb(ServiceFundShared remShare) { // //涓婁紶OA鏂囦欢 @@ -868,4 +1051,18 @@ // 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; + } + } -- Gitblit v1.9.3