From 6f344e6360751574f7e03b21c00cfa3f4b2bc099 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期五, 10 十一月 2023 15:41:41 +0800
Subject: [PATCH] 代码提交

---
 ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java |  469 +++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 393 insertions(+), 76 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 07c8815..2e2f0b6 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
@@ -5,17 +5,25 @@
 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.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.*;
 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.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -24,6 +32,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涓氬姟灞傚鐞�
@@ -31,6 +40,7 @@
  * @author ruoyi
  * @date 2022-01-24
  */
+@Slf4j
 @Service
 public class ServiceFundServiceImpl extends ServiceImpl<ServiceFundMapper, ServiceFund> implements IServiceFundService {
     @Autowired
@@ -57,9 +67,12 @@
     @Autowired
     IServiceFunddetailSharedService detailSharedService;
 
+    @Autowired
+    private IServiceFunddetailService serviceFunddetailService;
+
 
     /**
-     * 鏌ヨ璐圭敤鐢宠涓诲垪琛�
+     * 鏌ヨ璐圭敤鐢宠涓诲垪琛�(鍖呭惈鍒犻櫎鐨�)
      *
      * @param serviceFund 璐圭敤鐢宠涓�
      * @return 璐圭敤鐢宠涓�
@@ -69,6 +82,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());
@@ -91,6 +107,21 @@
         if (serviceFund.getUploadtime() != null) {
             wrappers.eq(ServiceFund::getUploadtime, serviceFund.getUploadtime());
         }
+        if (serviceFund.getFlowlevel() != null) {
+            wrappers.eq(ServiceFund::getFlowlevel, serviceFund.getFlowlevel());
+        }
+        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);
     }
 
@@ -112,9 +143,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);
@@ -126,19 +157,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
@@ -626,8 +661,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
@@ -644,14 +679,196 @@
         return count;
     }
 
-    int uploadOAFileAndUpdateDb(ServiceFundShared remShare) {
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Long addOrUpdateNew(ServiceFundVO serviceFundVO) {
+        Long id = null;
+        //灏嗘暟鎹繚瀛樺埌fund琛�
+        id = saveFund(serviceFundVO);
+
+        List<ServiceFunddetailVO> serviceFunddetails = serviceFundVO.getServiceFunddetails();
+        if (CollectionUtils.isEmpty(serviceFunddetails)) {
+            throw new BaseException("serviceFunddetails涓虹┖鍠�");
+        }
+        // 淇濆瓨璇︽儏鏁版嵁
+        for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) {
+            if (StringUtils.isEmpty(serviceFunddetailVO.getIdcardno())) {
+                throw new BaseException("璇锋鏌ヨ韩浠借瘉鍙�,韬唤璇佸彿涓虹┖浜�,濮撳悕锛�" + serviceFunddetailVO.getBeneficiaryname());
+            }
+            if (StringUtils.isEmpty(serviceFunddetailVO.getTitle()) || ChineseUtils.isChinese(serviceFunddetailVO.getTitle())) {
+                throw new BaseException("璇锋鏌ヨ亴绉版槸鍚︿负绌猴紙鎴栦笉鏄腑鏂囷級,濮撳悕锛�" + serviceFunddetailVO.getBeneficiaryname() + "  鑱岀О:" + serviceFunddetailVO.getTitle());
+            }
+            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);
+
+            if (serviceFunddetailVO.getId() == null) {
+                serviceFunddetailService.save(serviceFunddetail);
+            } else {
+                serviceFunddetailService.updateById(serviceFunddetail);
+            }
+        }
+
+        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 Boolean totaltax(TotalTaxVO totalTaxVO) {
+        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<>();
+        //鎵撳嵃excel
+        ExcelUtil<ServiceFunddetailExcel> util = new ExcelUtil<ServiceFunddetailExcel>(ServiceFunddetailExcel.class);
+
+        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);
+            }
+            //鎵撳嵃绠楄繃绋庝箣鍚庣殑锛屽悎璁xcel
+            util.exportExcel(serviceFunddetailList, "鍚堣涓◣锛堢◣鍚庯級");
+        } 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())) {
+                        throw new BaseException("鏈嶅姟璇存槑涓虹┖,璇锋鏌ュ悗鍐嶈绠�");
+                    }
+                    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);
+
+            }
+            //鎵撳嵃绠楃◣涔嬪墠鐨勶紝鍚堣excel
+            util.exportExcel(serviceFunddetailList, "鍚堣涓◣锛堢◣鍓嶏級");
+        }
+        return true;
+    }
+
+
+    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");
@@ -666,74 +883,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