From 0bc118d74a03685d1b4685a0b7d38468f307b537 Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期三, 02 八月 2023 17:51:34 +0800 Subject: [PATCH] 修改代码 --- ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java | 190 +++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 188 insertions(+), 2 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 c5e299e..38adfd8 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 @@ -1,16 +1,25 @@ package com.ruoyi.project.service.impl; +import java.io.File; +import java.math.BigDecimal; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; +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.utils.HttpClientKit; import com.ruoyi.common.utils.bean.DtoConversionUtils; import com.ruoyi.project.domain.*; import com.ruoyi.project.domain.vo.*; import com.ruoyi.project.mapper.*; import com.ruoyi.project.service.IServiceFundSharedService; +import com.ruoyi.project.service.IServiceFunddetailService; import com.ruoyi.project.service.IServiceFunddetailSharedService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -26,6 +35,7 @@ * @author ruoyi * @date 2022-01-24 */ +@Slf4j @Service public class ServiceFundServiceImpl extends ServiceImpl<ServiceFundMapper, ServiceFund> implements IServiceFundService { @Autowired @@ -52,9 +62,12 @@ @Autowired IServiceFunddetailSharedService detailSharedService; + @Autowired + private IServiceFunddetailService serviceFunddetailService; + /** - * 鏌ヨ璐圭敤鐢宠涓诲垪琛� + * 鏌ヨ璐圭敤鐢宠涓诲垪琛�(鍖呭惈鍒犻櫎鐨�) * * @param serviceFund 璐圭敤鐢宠涓� * @return 璐圭敤鐢宠涓� @@ -64,6 +77,9 @@ LambdaQueryWrapper<ServiceFund> 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 (StringUtils.isNotBlank(serviceFund.getUserno())) { wrappers.eq(ServiceFund::getUserno, serviceFund.getUserno()); @@ -89,6 +105,18 @@ return this.list(wrappers); } + + @Override + public List<ServiceFund> queryInfoById(ServiceFund serviceFund) { + LambdaQueryWrapper<ServiceFund> 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<ServiceFund> getInfoByInfoId(Long infoid) { return serviceFundMapper.getInfoByInfoId(infoid); @@ -108,7 +136,8 @@ serviceFundShared.setSerfunid(serviceFundShared.getId()); serviceFundShared.setId(null); sharedService.save(serviceFundShared); - + //鏁版嵁鍙戦�佺粰璐㈠姟 + uploadOAFileAndUpdateDb(serviceFundShared); //fundId涓轰富琛ㄧ殑ID Map<String, Object> columnMap = new HashMap<>(); columnMap.put("fundid", id); @@ -638,5 +667,162 @@ return count; } + @Override + @Transactional + public Long addOrUpdateNew(ServiceFundVO serviceFundVO) { + Long id = null; + if (serviceFundVO.getId() == null) { + save(serviceFundVO); + id = serviceFundVO.getId(); + } else { + updateById(serviceFundVO); + id = serviceFundVO.getId(); + } + 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()); + } + } + + //鏍规嵁id鍒ゆ柇鏄柊澧炶繕鏄慨鏀� + if (serviceFunddetail.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) { + //涓婁紶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; + } } -- Gitblit v1.9.3