From 08f0193d8bbd4dd9f68706ac1313f564b7219f95 Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期一, 16 十月 2023 16:05:09 +0800 Subject: [PATCH] 代码提交 --- ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java | 362 +++++++++++++++++++++++++++++++++----------------- 1 files changed, 237 insertions(+), 125 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 38adfd8..356e921 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 @@ -7,6 +7,7 @@ import java.util.List; import java.util.Map; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.ruoyi.common.config.RuoYiConfig; @@ -20,6 +21,7 @@ import com.ruoyi.project.service.IServiceFunddetailService; import com.ruoyi.project.service.IServiceFunddetailSharedService; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.ObjectUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -28,6 +30,7 @@ import com.ruoyi.common.utils.StringUtils; import com.ruoyi.project.service.IServiceFundService; import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.CollectionUtils; /** * 璐圭敤鐢宠涓籗ervice涓氬姟灞傚鐞� @@ -102,6 +105,9 @@ if (serviceFund.getUploadtime() != null) { wrappers.eq(ServiceFund::getUploadtime, serviceFund.getUploadtime()); } + if (serviceFund.getFlowlevel() != null) { + wrappers.eq(ServiceFund::getFlowlevel, serviceFund.getFlowlevel()); + } return this.list(wrappers); } @@ -135,9 +141,9 @@ ServiceFundShared serviceFundShared = DtoConversionUtils.sourceToTarget(serviceFund, ServiceFundShared.class); serviceFundShared.setSerfunid(serviceFundShared.getId()); serviceFundShared.setId(null); + log.info("鏁版嵁閮芥彃杩涘幓浜嗗悧锛� {}", serviceFundShared); sharedService.save(serviceFundShared); - //鏁版嵁鍙戦�佺粰璐㈠姟 - uploadOAFileAndUpdateDb(serviceFundShared); + //fundId涓轰富琛ㄧ殑ID Map<String, Object> columnMap = new HashMap<>(); columnMap.put("fundid", id); @@ -149,19 +155,23 @@ //fundID涓簊ervice_fund_shared琛ㄧ殑涓婚敭ID serviceFunddetailShareds.get(i).setFundid(serviceFundShared.getId()); serviceFunddetailShareds.get(i).setId(null); + //鏁版嵁鍙戦�佺粰璐㈠姟 + uploadOAFileAndUpdateDb(serviceFunddetailShareds.get(i)); } - boolean result = detailSharedService.saveBatch(serviceFunddetailShareds); + boolean result = false; + for (ServiceFunddetailShared serviceFunddetailShared : serviceFunddetailShareds) { + if (ObjectUtils.isNotEmpty(serviceFunddetailShared)) { + result = detailSharedService.save(serviceFunddetailShared); + } else { + log.info("serviceFunddetailShared涓虹┖浜嗭紒锛侊紒"); + } + } return result; } @Override public List<ServiceFund> selectServiceFundList(ServiceFund serviceFund) { return serviceFundMapper.selectServiceFundList(serviceFund); - } - - @Override - public List<ServiceFunddetail> getFundDetail(Long id) { - return serviceFunddetailMapper.selectFundDetailListById(id); } @Override @@ -649,8 +659,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) { + return serviceFundMapper.getListBypower(PAUSERNO, PAFUNDTYPE, PAAPPLICANT, PAAPPLICATIONBEGTIME, PAAPPLICATIONENDTIME, PADEPARTMENT, CHECKFLAG, APPLYTYPE, CHECKSTATUS); } @Override @@ -671,76 +681,78 @@ @Transactional public Long addOrUpdateNew(ServiceFundVO serviceFundVO) { Long id = null; - if (serviceFundVO.getId() == null) { - save(serviceFundVO); - id = serviceFundVO.getId(); - } else { - updateById(serviceFundVO); - id = serviceFundVO.getId(); + //灏嗘暟鎹繚瀛樺埌fund琛� + id = saveFund(serviceFundVO); + + List<ServiceFunddetailVO> serviceFunddetails = serviceFundVO.getServiceFunddetails(); + if (CollectionUtils.isEmpty(serviceFunddetails)) { + System.out.println("serviceFunddetails涓虹┖鍠�"); + return null; } - List<ServiceFunddetail> serviceFunddetails = serviceFundVO.getServiceFunddetails(); - - // 鐢ㄤ簬璁板綍绋庡墠銆佺◣鍚庣殑鎬诲拰 - double taxBefore = 0.0; - double taxAfter = 0.0; - - for (ServiceFunddetail serviceFunddetail : serviceFunddetails) { - serviceFunddetail.setFundid(id); - if (serviceFunddetail.getTaxedamount() != null && serviceFunddetail.getAmount() != null && serviceFunddetail.getTaxedamount() != 0.0 && serviceFunddetail.getAmount() != 0.0) { - // 绋庡墠绋庡悗閮戒笉涓虹┖ - if (serviceFunddetail.getId() == null) { - serviceFunddetailService.save(serviceFunddetail); - } else { - serviceFunddetailService.updateById(serviceFunddetail); - } - continue; - } else if (serviceFunddetail.getTaxedamount() != null && serviceFunddetail.getTaxedamount() != 0.0) { - // 绋庡悗姹傜◣鍓�,濡傛灉鏄笓瀹惰垂鐢宠 鎴� 浼︾悊涓撳璐圭敵璇� 鎵嶄細璁$畻绋庡墠绋庡悗 - if (StringUtils.isNotEmpty(serviceFundVO.getApplytype()) && serviceFundVO.getApplytype().equals("1") || serviceFundVO.getApplytype().equals("2")) { - Double taxationBefore = Double.valueOf(TaxtUtils.getTaxationBefore(BigDecimal.valueOf(serviceFunddetail.getTaxedamount()))); - // 绋庨噾 - String taxation = TaxtUtils.getTaxation(BigDecimal.valueOf(taxationBefore)); - serviceFunddetail.setAmount(Double.valueOf(taxationBefore)); - serviceFunddetail.setTaxamount(Double.parseDouble(taxation)); - } - } else if (serviceFunddetail.getAmount() != null && serviceFunddetail.getAmount() != 0.0) { - // 绋庡墠姹傜◣鍚�,濡傛灉鏄笓瀹惰垂鐢宠 鎴� 浼︾悊涓撳璐圭敵璇� 鎵嶄細璁$畻绋庡墠绋庡悗 - if (StringUtils.isNotEmpty(serviceFundVO.getApplytype()) && serviceFundVO.getApplytype().equals("1") || serviceFundVO.getApplytype().equals("2")) { - double tax = Double.parseDouble(TaxtUtils.getTaxation(BigDecimal.valueOf(serviceFunddetail.getAmount()))); - BigDecimal taxAfterMoney = BigDecimal.valueOf(serviceFunddetail.getAmount()).subtract(BigDecimal.valueOf(tax)); - serviceFunddetail.setTaxamount(tax); - serviceFunddetail.setTaxedamount(taxAfterMoney.doubleValue()); - } + // 淇濆瓨璇︽儏鏁版嵁 + for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) { + 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); - //鏍规嵁id鍒ゆ柇鏄柊澧炶繕鏄慨鏀� - if (serviceFunddetail.getId() == null) { + if (serviceFunddetailVO.getId() == null) { serviceFunddetailService.save(serviceFunddetail); } else { serviceFunddetailService.updateById(serviceFunddetail); } - if (serviceFundVO.getApplytype().equals("1") || serviceFundVO.getApplytype().equals("2")) { - //濡傛灉鏄笓瀹惰垂鐢宠 鎴� 浼︾悊涓撳璐圭敵璇� 鎵嶄細璁$畻绋庡墠绋庡悗 - taxBefore = taxBefore + serviceFunddetail.getAmount(); - taxAfter = taxAfter + serviceFunddetail.getTaxedamount(); - } } - //灏嗙◣鍓嶃�佺◣鍚庨噾棰濇洿鏂板埌fund琛ㄤ腑 - serviceFundVO.setPretaxcost(taxBefore); - serviceFundVO.setTaxedcost(taxAfter); - updateById(serviceFundVO); return id; } - int uploadOAFileAndUpdateDb(ServiceFundShared remShare) { + @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; + } + + int uploadOAFileAndUpdateDb(ServiceFunddetailShared 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<String, Object> map = new HashMap<String, Object>(); map.put("userName", "opo"); map.put("password", "4126407a-9821-4874-be41-6568abd6dbe5"); @@ -755,74 +767,174 @@ JSONObject json1 = JSONObject.parseObject(strRes); strRes = json1.get("id").toString(); - ///if(strRes.isEmpty() || "" == strRes) return -1;// 涓虹┖浠h〃澶辫触 - - //涓嬮潰闇�姹傝皟鐢ㄦ枃浠剁殑鎺ュ彛锛岃皟鐢ㄦ垚鍔熻繑鍥炲悗锛屽緱鍒癴ilename鍜宖ileid 鐢ㄨ繖浜屼釜鍊煎幓鏇存柊鏁版嵁 - 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); + List<RbDetailFile> parseArray2 = new ArrayList<>(); + List<RbDetailFile> invoicefilesList = new ArrayList<>(); - /*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; - } - }*/ + //鏅�氶檮浠� + List<RbDetailFile> parseArray = JSON.parseArray(remShare.getAnnexfiles(), RbDetailFile.class); + //鍙戠エ闄勪欢 + List<RbDetailFile> invoicefilesArray = JSON.parseArray(remShare.getInvoicefiles(), RbDetailFile.class); + log.info("parseArray鐨勫�� : {}, invoicefilesArray鐨勫�� : {},", parseArray, invoicefilesArray); - String filename = ""; - String fileid = ""; + //鏅�氶檮浠� + uploadFile(filePath, strFUrl, parseArray2, parseArray, remShare, "1"); - 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; - + //鍙戠エ闄勪欢 + 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); + 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鏈嶅姟鐨刦ilePath + substring: " + filePath + substring); + File filetest = new File(filePath + substring); + + try { + 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("绗笁鏂逛紶鍥炵殑鏁版嵁鑾峰彇鐨刟tts : {}", jsonArr); + for (int j = 0; j < jsonArr.size(); j++) { + JSONObject jsonRet = jsonArr.getJSONObject(j); + rbDetailFile.setFileid(jsonRet.get("fileUrl").toString()); + } + } catch (Exception e) { + e.printStackTrace(); + } + 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 鏄惁鍔犱笂浜唂ileid : {}", 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<String, Object> map = new HashMap<String, Object>(); +// 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);//寰楀埌杩斿洖鐨則oken? +// +// JSONObject json1 = JSONObject.parseObject(strRes); +// strRes = json1.get("id").toString(); +// +// ///if(strRes.isEmpty() || "" == strRes) return -1;// 涓虹┖浠h〃澶辫触 +// +// //涓嬮潰闇�姹傝皟鐢ㄦ枃浠剁殑鎺ュ彛锛岃皟鐢ㄦ垚鍔熻繑鍥炲悗锛屽緱鍒癴ilename鍜宖ileid 鐢ㄨ繖浜屼釜鍊煎幓鏇存柊鏁版嵁 +// +// 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; + } + } -- Gitblit v1.9.3