From 68b49efb4da346edb42a5d8ebb39af47207402bd Mon Sep 17 00:00:00 2001
From: yxh <172933527@qq.com>
Date: 星期一, 12 十月 2026 11:14:13 +0800
Subject: [PATCH] 修改了报销校验
---
ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceFundServiceImpl.java | 1030 ++++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 911 insertions(+), 119 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 5cc56c4..296e3ec 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,24 +6,38 @@
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.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
import com.ruoyi.common.config.RuoYiConfig;
+import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.core.domain.model.LoginUser;
+import com.ruoyi.common.enums.ApplyTypeEnum;
+import com.ruoyi.common.exception.ServiceException;
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.common.FundNotifyMessageBuilder;
+import com.ruoyi.project.common.IdGeneratorUtils;
import com.ruoyi.project.domain.*;
import com.ruoyi.project.domain.vo.*;
import com.ruoyi.project.mapper.*;
import com.ruoyi.project.service.*;
+import com.ruoyi.system.mapper.SysUserMapper;
+import com.ruoyi.system.mapper.SysUserRoleMapper;
+import com.ruoyi.system.service.ISysConfigService;
+import com.ruoyi.system.service.ISysUserService;
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.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
@@ -35,6 +49,8 @@
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicLong;
import java.util.stream.Collectors;
/**
@@ -49,6 +65,25 @@
@Autowired
ServiceFundMapper serviceFundMapper;
+ /** 涓撳鍔冲姟璐� 9 鏉¤垂鐢ㄦ帶鍒惰鍒欐牎楠岋紙鍚屼竴妗堜緥绱锛� */
+ @Autowired
+ private ExpertFeeValidateService expertFeeValidateService;
+
+ @Autowired
+ private DingTalkService dingTalkService;
+
+ @Autowired
+ private IServiceFundflowruleService serviceFundflowruleService;
+
+ @Autowired
+ private IServiceFundflowService serviceFundflowService;
+
+ @Autowired
+ private SysUserRoleMapper sysUserRoleMapper;
+
+ @Autowired
+ SysUserMapper sysUserMapper;
+
@Autowired
ServiceFunddetailMapper serviceFunddetailMapper;
@@ -57,6 +92,21 @@
@Autowired
ServiceReimbursementMapper serviceReimbursementMapper;
+
+ @Autowired
+ ServiceReimbursementSharedMapper serviceReimbursementSharedMapper;
+
+ @Autowired
+ private IServiceFundflowService fundflowService;
+
+ @Autowired
+ private ISysUserService sysUserService;
+
+ @Autowired
+ private IServiceSystemmessageService iServiceSystemmessageService;
+
+ @Autowired
+ IServiceReimbursementService iServiceReimbursementService;
@Autowired
IServiceFundSharedService sharedService;
@@ -82,6 +132,236 @@
@Autowired
private VExpertfeeTotalMapper vExpertfeeTotalMapper;
+ @Value("${xyurl}")
+ private String xyurl;
+
+ @Value("${rexyurl}")
+ private String rexyurl;
+
+ @Value("${newSwitch}")
+ private Integer newSwitch;
+
+ @Value("${spring.profiles.active}")
+ private String active;
+
+ @Autowired
+ private ISysConfigService sysConfigService;
+
+ /**
+ * 瀹℃壒鍗曟槸鍚︿笂浼犲尰闄㈠崗鍙嬶紙鑷磋繙锛夌郴缁燂細0=涓嶄笂浼狅紙娴嬭瘯鐜锛夛紝1=涓婁紶锛堟寮忕幆澧冿級銆�
+ *
+ * <p>2026-10-09 鏂板锛氬師鏉ョ敤 {@code spring.profiles.active == druid} 鍒ゆ柇鏄惁鎺ㄩ�侊紝
+ * 娴嬭瘯鐜涓庢寮忕幆澧冩棤娉曢�氳繃鍙傛暟鍖哄垎銆傛敼涓虹郴缁熷弬鏁版帶鍒躲��
+ */
+ private static final String CFG_UPLOAD_OA = "sys.approval.upload.oa";
+
+ /** 鍙傛暟缂虹渷鍊硷細涓婁紶锛堜繚鎸佹寮忕幆澧冨師鏈夎涓猴級 */
+ private static final boolean DEFAULT_UPLOAD_OA = true;
+
+ /** 瀹℃壒鍗曟槸鍚﹂渶瑕佷笂浼犲尰闄㈠崗鍙嬶紙鑷磋繙锛夌郴缁� */
+ private boolean isUploadOaEnabled() {
+ String value = null;
+ try {
+ value = sysConfigService.selectConfigByKey(CFG_UPLOAD_OA);
+ } catch (Exception e) {
+ log.warn("璇诲彇鍙傛暟 {} 澶辫触锛屾寜榛樿鍊� {} 澶勭悊", CFG_UPLOAD_OA, DEFAULT_UPLOAD_OA, e);
+ }
+ if (value == null || value.trim().isEmpty()) {
+ return DEFAULT_UPLOAD_OA;
+ }
+ String v = value.trim();
+ return "1".equals(v) || "true".equalsIgnoreCase(v) || "y".equalsIgnoreCase(v) || "on".equalsIgnoreCase(v);
+ }
+
+ /**
+ * 鑷磋繙绯荤粺娴佺▼閫�鍥�
+ *
+ * @param serviceProcessVO
+ * @return
+ */
+ @Override
+ public Boolean backDocument(ServiceProcessDocVO serviceProcessVO) {
+ String applytype = serviceProcessVO.getApplytype();
+
+ if (applytype.equals("0")) {
+ //宸梾鎶ラ攢閫�鍥�
+ ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
+ serviceReimbursement.setId(serviceProcessVO.getBackCode());
+ List<ServiceReimbursement> serviceReimbursementList = iServiceReimbursementService.queryList(serviceReimbursement);
+ ServiceReimbursement serviceReimbursement1 = serviceReimbursementList.get(0);
+ serviceReimbursement1.setFlowlevel(100L);
+ serviceReimbursement1.setDelFlag(0);
+ serviceReimbursement1.setUploadStates(0);
+ serviceReimbursement1.setBackflowlevel(199L);
+ serviceReimbursement1.setRecordstatus(-1);
+ iServiceReimbursementService.updateById(serviceReimbursement1);
+
+ //鍒犻櫎share鏁版嵁
+ serviceReimbursementSharedMapper.delResharedInfoByReimid(serviceReimbursement1.getId());
+
+ } else {
+ //璐圭敤鐢宠閫�鍥�
+ ServiceFund serviceFund = new ServiceFund();
+ serviceFund.setId(serviceProcessVO.getBackCode());
+ List<ServiceFund> serviceFunds = queryInfoById(serviceFund);
+ ServiceFund serviceFund1 = serviceFunds.get(0);
+ serviceFund1.setFlowlevel(100L);
+ serviceFund1.setDel_flag(0);
+ serviceFund1.setRecordstatus(-1);
+ serviceFund1.setBackflowlevel(199);
+ updateById(serviceFund1);
+
+ //鍒犻櫎share鏁版嵁
+ serviceFundSharedMapper.delfundsharedInfoById(null, serviceFund1.getId());
+
+ //杩欎釜娑堟伅鍙戦�侊紝灏变笉鍦ㄨ繖鍋氫簡锛屽湪瀹℃壒璁板綍鐨勬帴鍙ｉ噷鍋氾紙鍗虫棩蹇楁帴鍙ｏ級
+// sendMeg(serviceFund1.getApplytype(), sysUser.getPhonenumber());
+ }
+
+ return true;
+ }
+
+ /**
+ * 娴佺▼瀹℃壒鏃ュ織
+ *
+ * @param serviceProcessVO
+ * @return
+ */
+ @Override
+ public Boolean processlog(ServiceProcessVO serviceProcessVO) {
+
+ String userNo = null;
+ String userName = null;
+ String phone = null;
+ String applytype = null;
+ Long flowlevel = null;
+ //閽夐拤閫氱煡鐢ㄧ殑鍗曟嵁淇℃伅
+ Double amount = null;
+ String donorName = null;
+ String billNo = null;
+ String travelers = null;
+ String reason = null;
+ if (serviceProcessVO.getApplytype().equals("0")) {
+ ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
+ serviceReimbursement.setId(StringUtils.isNotEmpty(serviceProcessVO.getBackCode()) ? Long.valueOf(serviceProcessVO.getBackCode()) : null);
+ List<ServiceReimbursement> serviceReimbursementList = iServiceReimbursementService.queryList(serviceReimbursement);
+ if (CollectionUtils.isEmpty(serviceReimbursementList)) {
+ log.error("serviceReimbursementList娌℃湁鏌ュ埌鏁版嵁锛歿}", serviceProcessVO.getBackCode());
+ return false;
+ }
+ //杩欏嚑涓�硷紝闇�瑕佺粰涓嬮潰鐢�; applytype锛屼笉鑳界敤浼犺繘鏉ョ殑锛屽彧鑳借嚜宸辨煡
+ userNo = serviceReimbursementList.get(0).getUserno();
+ userName = serviceReimbursementList.get(0).getUsername();
+ phone = serviceReimbursementList.get(0).getPhone();
+ flowlevel = serviceReimbursementList.get(0).getFlowlevel();
+ applytype = "0";
+ amount = serviceReimbursementList.get(0).getAmountrequested();
+ billNo = FundNotifyMessageBuilder.billNo(serviceReimbursementList.get(0).getBh(),
+ serviceReimbursementList.get(0).getId());
+ travelers = serviceReimbursementList.get(0).getTravelers();
+ reason = serviceReimbursementList.get(0).getReason();
+ } else {
+ ServiceFund serviceFund = new ServiceFund();
+ serviceFund.setId(StringUtils.isNotEmpty(serviceProcessVO.getBackCode()) ? Long.valueOf(serviceProcessVO.getBackCode()) : null);
+ List<ServiceFund> serviceFunds = queryInfoById(serviceFund);
+ if (CollectionUtils.isEmpty(serviceFunds)) {
+ log.error("serviceFunds娌℃湁鏌ュ埌鏁版嵁锛歿}", serviceProcessVO.getBackCode());
+ return false;
+ }
+ userNo = serviceFunds.get(0).getUserno();
+ userName = serviceFunds.get(0).getUsername();
+ phone = serviceFunds.get(0).getPhone();
+ flowlevel = serviceFunds.get(0).getFlowlevel();
+ applytype = serviceFunds.get(0).getApplytype();
+ amount = serviceFunds.get(0).getPretaxcost();
+ donorName = serviceFunds.get(0).getDonorname();
+ billNo = FundNotifyMessageBuilder.billNo(serviceFunds.get(0).getBh(),
+ serviceFunds.get(0).getId());
+ }
+
+// //灏嗘搷浣滀繚瀛樺埌fundflow琛ㄤ腑
+// ServiceFundflow serviceFundflow = new ServiceFundflow();
+// serviceFundflow.setCreateBy("admin");
+// serviceFundflow.setCreateTime(new Date());
+// serviceFundflow.setUpdateBy("admin");
+// serviceFundflow.setUpdateTime(new Date());
+// serviceFundflow.setCheckusername(serviceProcessVO.getCheckusername());
+// serviceFundflow.setFlowcontent(serviceProcessVO.getFlowcontent());
+// serviceFundflow.setFlowconclusion(1);
+// serviceFundflow.setFundtype(2);
+// serviceFundflow.setFlowlevel(flowlevel.intValue());
+// if (StringUtils.isNotEmpty(serviceProcessVO.getFlowconclusion()) && serviceProcessVO.getFlowconclusion().equals("3"))
+// serviceFundflow.setFlowlevel(999);
+// serviceFundflow.setApplytype(applytype);
+// serviceFundflow.setFundid(StringUtils.isNotEmpty(serviceProcessVO.getBackCode()) ? Long.valueOf(serviceProcessVO.getBackCode()) : null);
+// serviceFundflow.setCheckTime(serviceProcessVO.getCheckTime());
+// fundflowService.save(serviceFundflow);
+
+
+ SysUser sysUser = sysUserService.selectUserByUserName(userNo);
+
+ //閽夐拤閫氱煡鍐呭锛氬崟鎹俊鎭紙绫诲瀷/鎶ラ攢浜�/閲戦/妗堜緥/缂栧彿锛�+ 瀹℃壒浜�/瀹℃壒鏃堕棿/鎰忚
+ List<ConcurrentHashMap<String, Object>> notifyRows = FundNotifyMessageBuilder.newRows();
+ FundNotifyMessageBuilder.addBillInfo(notifyRows, applytype, userName, amount, donorName, billNo);
+ FundNotifyMessageBuilder.addTravelInfo(notifyRows, travelers, reason);
+ FundNotifyMessageBuilder.addAuditResult(notifyRows, serviceProcessVO.getCheckusername(),
+ serviceProcessVO.getCheckTime(),
+ FundNotifyMessageBuilder.opinion(serviceProcessVO.getFlowconclusion(),
+ serviceProcessVO.getFlowcontent()));
+ sendMeg(serviceProcessVO, phone, notifyRows);
+ //鍙戦�佷俊鎭繚瀛�
+ ServiceSystemmessage serviceSystemmessage = new ServiceSystemmessage();
+ serviceSystemmessage.setFundtype(1);
+ serviceSystemmessage.setSenduserno(sysUser.getUserName());
+ serviceSystemmessage.setSendusername(sysUser.getNickName());
+ serviceSystemmessage.setReceiveuserno(userNo);
+ serviceSystemmessage.setReceiveusername(userName);
+ serviceSystemmessage.setUpdateTime(new Date());
+ serviceSystemmessage.setUpdateBy(sysUser.getNickName());
+ serviceSystemmessage.setIsread(0);
+ serviceSystemmessage.setMessagetype(1);
+ serviceSystemmessage.setMessagetitle("OPO绯荤粺瀹℃壒");
+ serviceSystemmessage.setMessagecontent(serviceProcessVO.getFlowcontent());
+ iServiceSystemmessageService.save(serviceSystemmessage);
+
+ return true;
+ }
+
+ @Override
+ public Boolean updatecodepay(ServiceCodeAndPyaWay serviceCodeAndPyaWay) {
+ Integer i = null;
+ if (StringUtils.isNotEmpty(serviceCodeAndPyaWay.getApplytype()) && !serviceCodeAndPyaWay.getApplytype().equals("0")) {
+ ServiceFund serviceFund = new ServiceFund();
+ serviceFund.setId(serviceCodeAndPyaWay.getBackCode());
+ serviceFund.setBh(serviceCodeAndPyaWay.getBh());
+ serviceFund.setZffs(serviceCodeAndPyaWay.getZffs());
+ serviceFund.setRiqi(serviceCodeAndPyaWay.getRiqi());
+ i = serviceFundMapper.updateById(serviceFund);
+
+ ServiceFundShared serviceFundShared = new ServiceFundShared();
+ serviceFundShared.setSerfunid(serviceFund.getId());
+ serviceFundShared.setZffs(serviceFund.getZffs());
+ serviceFundShared.setRiqi(serviceFund.getRiqi());
+ serviceFundShared.setBh(serviceFund.getBh());
+ serviceFundSharedMapper.updateShareByfundid(serviceFundShared);
+ } else {
+ ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
+ serviceReimbursement.setId(serviceCodeAndPyaWay.getBackCode());
+ serviceReimbursement.setBh(serviceCodeAndPyaWay.getBh());
+ serviceReimbursement.setZffs(serviceCodeAndPyaWay.getZffs());
+ serviceReimbursement.setRiqi(serviceCodeAndPyaWay.getRiqi());
+ i = serviceReimbursementMapper.updateById(serviceReimbursement);
+
+ ServiceReimbursementShared serviceReimbursementShared = new ServiceReimbursementShared();
+ serviceReimbursementShared.setReimid(serviceReimbursement.getId());
+ serviceReimbursementShared.setBh(serviceReimbursement.getBh());
+ serviceReimbursementShared.setZffs(serviceReimbursement.getZffs());
+ serviceReimbursementShared.setRiqi(serviceReimbursement.getRiqi());
+ serviceReimbursementSharedMapper.updateReimShareByfundid(serviceReimbursementShared);
+ }
+ if (i == 0) return false;
+ return true;
+ }
/**
* 鏌ヨ璐圭敤鐢宠涓诲垪琛�(鍖呭惈鍒犻櫎鐨�)
@@ -131,6 +411,8 @@
if (serviceFund.getJxrq() != null) {
wrappers.eq(ServiceFund::getJxrq, serviceFund.getJxrq());
}
+ // 娣诲姞 group by donorname
+// wrappers.groupBy(ServiceFund::getDonorname);
return this.list(wrappers);
}
@@ -151,6 +433,543 @@
return serviceFundMapper.getInfoByInfoId(infoid);
}
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Map<String, String> checkFund(CheckFundVO checkFundVO, LoginUser loginUser) {
+ ServiceFund serviceFund = getById(checkFundVO.getFundid());
+ Map<String, String> map = new HashMap<>();
+
+ if (serviceFund == null) {
+ map.put(HttpStatus.NO_CONTENT + "", "璐圭敤缂栧彿涓嶆纭�");
+ return map;
+ }
+
+ // 涓撳鍔冲姟璐癸細瀹℃牳鈥滈�氳繃鈥濆墠鏍￠獙 9 鏉¤垂鐢ㄦ帶鍒惰鍒欙紙鍚屼竴妗堜緥绱锛夛紱涓嶉�氳繃鍒欎笉闃绘柇
+ if (checkFundVO.getFlowconclusion() != null && checkFundVO.getFlowconclusion() == 1) {
+ ExpertFeeCheckResult expertFeeResult = expertFeeValidateService.validateBeforeCheck(checkFundVO.getFundid());
+ if (expertFeeResult.hasError()) {
+ map.put(HttpStatus.ERROR + "", expertFeeResult.errorMessage());
+ return map;
+ }
+ if (expertFeeResult.hasWarning()) {
+ // 瑙勫垯 5銆�6 浠呮彁绀猴紝涓嶉樆鏂鏍�
+ log.warn("涓撳鍔冲姟璐瑰鏍告牎楠屾彁绀猴細fundId={}锛寋}", checkFundVO.getFundid(), expertFeeResult.warningMessage());
+ }
+ }
+
+ Integer TotalLevel = 0;
+ ServiceFundflowrule serviceFundflowrule = new ServiceFundflowrule();
+ serviceFundflowrule.setFundtype(2);
+ serviceFundflowrule.setApplytype(serviceFund.getApplytype());
+ serviceFundflowrule.setCheckuserno(loginUser.getUsername());
+ log.info("serviceFundController---checkFund---queryList鐨勫叆鍙傚�約erviceFundflowrule:{}", serviceFundflowrule);
+ List<ServiceFundflowrule> serviceFundflowrules = serviceFundflowruleService.queryList(serviceFundflowrule);
+
+ if (serviceFundflowrules == null || serviceFundflowrules.stream().count() == 0) {
+ map.put(HttpStatus.ERROR + "", "褰撳墠浜哄憳鏃犳璁板綍瀹℃牳鏉冮檺");
+ return map;
+ }
+
+ if (serviceFundflowrules.get(0).getFlowlevel() - 1 != serviceFund.getFlowlevel()) {
+ map.put(HttpStatus.ERROR + "", "褰撳墠浜哄憳涓庢璁板綍鐨勫鏍哥骇鍒笉绗�");
+ return map;
+ }
+
+ if (serviceFundflowrules != null && serviceFundflowrules.stream().count() > 0) {
+ TotalLevel = serviceFundflowrules.get(0).getTotallevel();
+ }
+
+ Integer CheckFlag = 0;
+ Integer RecordStatus = serviceFund.getRecordstatus();
+ Integer FlowLevel = serviceFund.getFlowlevel().intValue();
+ Integer OriginalFlowLevel = FlowLevel;
+ //瀹℃壒缁撹蹇呭～锛氬師瀹炵幇鐩存帴 == 1 鎷嗙锛屾帴鍙ｈ鐩磋皟浼� null 浼� NPE 500
+ if (checkFundVO.getFlowconclusion() == null) {
+ map.put(HttpStatus.ERROR + "", "瀹℃壒缁撹涓嶈兘涓虹┖");
+ return map;
+ }
+ if (checkFundVO.getFlowconclusion() == 1) {
+ CheckFlag = 1;
+ if (TotalLevel == 0) {
+ RecordStatus = 99;
+ } else {
+ if (TotalLevel == FlowLevel + 1) {
+ RecordStatus = 99;
+ } else {
+ RecordStatus = (FlowLevel + 1) * 2;
+ }
+ }
+ FlowLevel = FlowLevel + 1;
+ SysUser user = loginUser.getUser();
+ if (serviceFund.getFlowlevel() == Long.valueOf(serviceFundflowrules.get(0).getFlowlevel() - 1) && serviceFund.getBackflowlevel() == 100) {
+ log.info("璐㈠姟閫�鍥炲啀鎻愪氦锛屽嚭绾冲啀娆″鎵癸紝涔嬪悗鎻愪氦鍒拌储鍔�");
+// serviceFund.setFinancechecher("瀹℃壒浜猴細" + user.getNickName() + " & 瀹℃壒鏃堕棿" + new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()) + " & 瀹℃壒缁撴灉锛氶�氳繃");
+ serviceFund.setFinancechecher(user.getNickName());
+
+ serviceFund.setFlowlevel(serviceFundflowrules.get(0).getTotallevel().longValue());
+ serviceFund.setRecordstatus(99);
+ serviceFund.setUploadStates(1);
+ updateById(serviceFund);
+
+ //鏁版嵁鍙戦��
+ Boolean aBoolean1 = null;
+ if (newSwitch == 1) {
+ aBoolean1 = sendData(serviceFund);
+ if (!aBoolean1) {
+ // 鎺ㄩ�佸尰闄㈠崗鍙嬬郴缁熷け璐ワ細鏁翠釜瀹℃壒涓嶇敓鏁堬紙浜嬪姟鍥炴粴锛夛紝鍏佽涓嬫閲嶆柊瀹℃壒
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ紝瀹℃壒涓嶇敓鏁堬紝fundId={}锛岃閲嶆柊瀹℃壒", serviceFund.getId());
+ throw new ServiceException("鍖婚櫌鍗忓弸绯荤粺鎺ユ敹澶辫触锛屾湰娆″鎵规湭鐢熸晥锛岃绋嶅悗閲嶆柊瀹℃壒");
+ }
+ }
+ //淇濆瓨瀹℃壒娴佺▼琛�
+ ServiceFundflow serviceFundflow = new ServiceFundflow();
+ serviceFundflow.setFundid(serviceFund.getId());
+ serviceFundflow.setCheckuserno(user.getUserName());
+ serviceFundflow.setCheckusername(user.getNickName());
+ serviceFundflow.setFundtype(2);
+ serviceFundflow.setCheckTime(new Date());
+ serviceFundflow.setApplytype(serviceFund.getApplytype());
+ serviceFundflow.setFlowconclusion(CheckFlag);
+ serviceFundflow.setFlowcontent("閫氳繃");
+ Boolean aBoolean = serviceFundflowService.saveData(serviceFundflow);
+ map.put("200", "success");
+ return map;
+ }
+ //濡傛灉褰撳墠鐧婚檰鏄储鍔★紝鍒欒繘琛岃褰�
+ List<Integer> roleIds = sysUserRoleMapper.getUserRoleByUserId(user.getUserId());
+ if (roleIds != null && roleIds.contains(11)) {
+ //11涓鸿储鍔�
+// serviceFund.setFinancechecher("瀹℃壒浜猴細" + user.getNickName() + " & 瀹℃壒鏃堕棿" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " & 瀹℃壒缁撴灉锛氶�氳繃");
+ serviceFund.setFinancechecher(user.getNickName());
+ }
+
+ //璁板綍涓�涓嬶紝涓嬩竴绾х殑瀹℃壒锛屼互渚夸簬涓嬩竴绾ч��鍥炲悗锛屽彂璧疯�呮彁浜ゆ椂锛岃兘鍐嶆彁鍒板綋鍓嶅鎵瑰眰绾�
+ serviceFund.setBackflowlevel(FlowLevel);
+ } else {
+ CheckFlag = 2;
+ if (CheckFlag == 2) {
+ //搴斿尰闄㈣姹傚鏋滃嚭鐜伴��鍥烇紝鐩存帴閫�鍒板彂璧疯��
+ FlowLevel = 0;
+ RecordStatus = -1;
+ log.info("serviceFund杩涙潵浜嗗悧锛燂紵锛燂紵锛燂紵 :{},{}", RecordStatus, FlowLevel);
+ } else {
+ RecordStatus = (FlowLevel + 1) * 2 - 1;
+ FlowLevel = (FlowLevel - 1);
+ if (FlowLevel < 0) {
+ FlowLevel = 0;
+ }
+ }
+
+ SysUser sysUser = sysUserService.selectUserByUserName(serviceFund.getUserno());
+ //瀹℃壒鏈�氳繃锛氬崟鎹俊鎭� + 瀹℃壒浜�/瀹℃壒鏃堕棿/鎰忚锛堟剰瑙� = "瀹℃壒鏈�氳繃銆�" + 椹冲洖鎰忚锛�
+ List<ConcurrentHashMap<String, Object>> contentList = FundNotifyMessageBuilder.newRows();
+ FundNotifyMessageBuilder.addBillInfo(contentList, serviceFund.getApplytype(),
+ serviceFund.getUsername(), serviceFund.getPretaxcost(), serviceFund.getDonorname(),
+ FundNotifyMessageBuilder.billNo(serviceFund.getBh(), serviceFund.getId()));
+ FundNotifyMessageBuilder.addAuditResult(contentList, loginUser.getUser().getNickName(), new Date(),
+ FundNotifyMessageBuilder.opinion(FundNotifyMessageBuilder.CONCLUSION_REJECT,
+ checkFundVO.getFlowcontent()));
+ try {
+ DingTalkReqVo dingTalkReqVo = new DingTalkReqVo();
+ dingTalkReqVo.setTitle(FundNotifyMessageBuilder.TITLE);
+ dingTalkReqVo.setNumber(sysUser.getPhonenumber());
+ dingTalkReqVo.setContents(contentList);
+ dingTalkService.sendNotification(dingTalkReqVo);
+ } catch (Exception e) {
+ log.error("璐圭敤---瀹℃壒鏈�氳繃閽夐拤閫氱煡澶辫触锛宖undId={}", serviceFund.getId(), e);
+ }
+ }
+
+ serviceFund.setRecordstatus(RecordStatus);
+ serviceFund.setFlowlevel(FlowLevel.longValue());
+ // serviceFund.setBackflowlevel(serviceFund.getFlowlevel());
+
+ ServiceFundflow serviceFundflow = new ServiceFundflow();
+ SysUser user = loginUser.getUser();
+ serviceFundflow.setFundid(serviceFund.getId());
+ serviceFundflow.setCheckuserno(user.getUserName());
+ serviceFundflow.setCheckusername(user.getNickName());
+ serviceFundflow.setFundtype(2);
+ serviceFundflow.setApplytype(serviceFund.getApplytype());
+ serviceFundflow.setFlowconclusion(CheckFlag);
+ serviceFundflow.setCheckTime(new Date());
+ if (StringUtils.isNotBlank(checkFundVO.getFlowcontent())) {
+ serviceFundflow.setFlowcontent(checkFundVO.getFlowcontent());
+ } else {
+ serviceFundflow.setFlowcontent(checkFundVO.getFlowconclusion() == 1 ? "閫氳繃" : "涓嶉�氳繃");
+ }
+ serviceFundflow.setFlowlevel(OriginalFlowLevel + 1);
+
+ Boolean aBoolean = serviceFundflowService.saveData(serviceFundflow);
+ log.info("sserviceFund淇濆瓨鐨勭殑鍊兼槸-------- :{}", aBoolean);
+
+ //鍔炲叕瀹ゅ鎵归�氳繃涔嬪悗锛屽氨闇�瑕佹妸鈥滃姙鍏涓讳换鈥濈殑鍚嶅瓧濉笂
+ SysUser sysUsers = null;
+ if (StringUtils.isNotEmpty(user.getUserName())) {
+ sysUsers = sysUserMapper.selectUserByUserName(user.getUserName());
+ log.info("璐圭敤sysUsers杩斿洖鐨勫�间负:{}", sysUsers);
+ }
+ if (checkFundVO.getFlowconclusion() == 1 && sysUsers != null && sysUsers.getRoles() != null && sysUsers.getRoles().stream().anyMatch(role -> "officedirector".equals(role.getRoleKey()))) {
+ serviceFund.setOfficedirector(user.getNickName());
+ serviceFund.setUploadStates(1);
+ //鏁版嵁鍙戦��
+ Boolean aBoolean1 = null;
+ if (newSwitch == 1) {
+ log.info("璐圭敤newSwitch杩斿洖鐨勫�间负:{}", newSwitch);
+ //鎼炰竴涓紑鍏筹紝鍒奖鍝嶈�佹祦绋�
+ aBoolean1 = sendData(serviceFund);
+ if (!aBoolean1) {
+ // 鎺ㄩ�佸尰闄㈠崗鍙嬬郴缁熷け璐ワ細鏁翠釜瀹℃壒涓嶇敓鏁堬紙浜嬪姟鍥炴粴锛夛紝鍏佽涓嬫閲嶆柊瀹℃壒
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ紝瀹℃壒涓嶇敓鏁堬紝fundId={}锛岃閲嶆柊瀹℃壒", serviceFund.getId());
+ throw new ServiceException("鍖婚櫌鍗忓弸绯荤粺鎺ユ敹澶辫触锛屾湰娆″鎵规湭鐢熸晥锛岃绋嶅悗閲嶆柊瀹℃壒");
+ }
+ }
+ }
+ System.out.println("serviceFund鐨勫�兼槸--------:" + serviceFund);
+ Boolean aBoolean1 = updateById(serviceFund);
+ log.info("integer鏇存柊鐨勭殑鍊兼槸-------- :{}", aBoolean1);
+ ServiceSystemmessage serviceSystemmessage = new ServiceSystemmessage();
+ serviceSystemmessage.setFundtype(2);
+ serviceSystemmessage.setApplytype(serviceFund.getApplytype());
+ serviceSystemmessage.setSenduserno(user.getUserName());
+ serviceSystemmessage.setSendusername(user.getNickName());
+ serviceSystemmessage.setReceiveuserno(serviceFund.getUserno());
+ serviceSystemmessage.setReceiveusername(serviceFund.getUsername());
+ serviceSystemmessage.setUpdateTime(new Date());
+ serviceSystemmessage.setUpdateBy(user.getNickName());
+ serviceSystemmessage.setIsread(0);
+ serviceSystemmessage.setMessagetype(1);
+ serviceSystemmessage.setRelevantno(serviceFund.getId());
+
+ if (CheckFlag == 1) {
+ //閫氳繃
+ if (serviceFund.getApplytype().equals("1")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁�氳繃");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勪笓瀹跺姵鍔¤垂鎹愮尞妗堜緥銆�" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸查�氳繃");
+ } else if (serviceFund.getApplytype().equals("2")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁�氳繃");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勪鸡鐞嗕笓瀹跺姵鍔¤垂鎹愮尞妗堜緥銆�" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸查�氳繃");
+ } else if (serviceFund.getApplytype().equals("3")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁�氳繃");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勫尰瀛︽垚鏈崘鐚渚嬨��" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸查�氳繃");
+ } else if (serviceFund.getApplytype().equals("4")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁�氳繃");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勫姙鍏垂鐢ㄧ敵璇峰凡閫氳繃");
+ } else if (serviceFund.getApplytype().equals("5")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁�氳繃");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勭哗鏁堢敵璇峰凡閫氳繃");
+ }
+ } else {
+ //椹冲洖
+ if (serviceFund.getApplytype().equals("1")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁┏鍥�");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勪笓瀹跺姵鍔¤垂鎹愮尞妗堜緥銆�" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸茶椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
+ } else if (serviceFund.getApplytype().equals("2")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁┏鍥�");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勪鸡鐞嗕笓瀹跺姵鍔¤垂鎹愮尞妗堜緥銆�" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸茶椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
+ } else if (serviceFund.getApplytype().equals("3")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁┏鍥�");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勫尰瀛︽垚鏈崘鐚渚嬨��" + serviceFund.getDonorname() + "銆戠殑璐圭敤鐢宠宸茶椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
+ } else if (serviceFund.getApplytype().equals("4")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁┏鍥�");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勫姙鍏垂鐢ㄧ敵璇峰凡椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
+ } else if (serviceFund.getApplytype().equals("5")) {
+ serviceSystemmessage.setMessagetitle("" + (OriginalFlowLevel + 1) + "绾у鏍搁┏鍥�");
+ serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勭哗鏁堢敵璇峰凡椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
+ }
+ }
+ iServiceSystemmessageService.save(serviceSystemmessage);
+ map.put("200", "success");
+ return map;
+
+
+ }
+
+ /**
+ * 瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬶紙鑷磋繙锛夌郴缁熴��
+ *
+ * <p>2026-10-09锛氬灞傚寘涓�灞傚厹搴曪紝淇濊瘉**浠讳綍寮傚父閮戒笉浼氬悜澶栨姏**锛堝師鏉� strRes 涓� null 鏃�
+ * 浼氬湪 parseObject 鍚庡彇 code 瑙﹀彂 NPE锛屾妸鏁翠釜瀹℃壒璇锋眰鎵撴垚 500锛夈��
+ * 杩斿洖 false 琛ㄧず鎺ㄩ�佸け璐ワ紝璋冪敤鏂规寜"瀹℃壒涓嶇敓鏁堛�佸厑璁镐笅娆￠噸鏂板鎵�"澶勭悊銆�
+ */
+ public Boolean sendData(ServiceFund serviceFund) {
+ if (!isUploadOaEnabled()) {
+ // 涓婁紶寮�鍏冲叧闂紙濡傛祴璇曠幆澧冿級锛氳烦杩囦笂浼犲苟瑙嗕负鎴愬姛锛岀粷涓嶈兘鍥犳闃绘柇瀹℃壒
+ log.info("瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷凡鍏抽棴锛坰ys.approval.upload.oa != 1锛夛紝璺宠繃涓婁紶骞惰涓烘垚鍔燂紝fundId={}",
+ serviceFund == null ? null : serviceFund.getId());
+ return true;
+ }
+ try {
+ return doSendData(serviceFund);
+ } catch (Throwable t) {
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷紓甯革紝瀹℃壒涓嶇敓鏁堬紝fundId={}",
+ serviceFund == null ? null : serviceFund.getId(), t);
+ return false;
+ }
+ }
+
+ private Boolean doSendData(ServiceFund serviceFund) {
+ // fund鍜宖unddetail鐨勬暟鎹幏鍙�
+ addFundSharedInfo(serviceFund.getId());
+ List<ServiceFundShared> fundShareInfos = serviceFundSharedMapper.getFundShareInfoById(serviceFund.getId());
+ if (CollectionUtils.isEmpty(fundShareInfos)) return false;
+
+ log.info("fundShareInfos鐨勬暟鎹噺涓猴細{}", fundShareInfos.size());
+ ServiceFunddetailShared serviceFunddetailShared = new ServiceFunddetailShared();
+ serviceFunddetailShared.setFundid(fundShareInfos.get(0).getId());
+ List<ServiceFunddetailShared> serviceFunddetailShareds = detailSharedService.queryList(serviceFunddetailShared);
+
+ // 鏁版嵁鐨勫皝瑁�
+ Map<String, Object> map = new HashMap<>();
+ Map<String, Object> data = new HashMap<>();
+ //搴旂敤绫诲瀷 鍥哄畾鍊�
+ map.put("appName", "collaboration");
+
+ // 涓昏〃瀛楁鏁版嵁
+ Map<String, Object> data2 = new HashMap<>();
+ data2.put("formmain_0831", getformmain_0831(serviceFund));
+ // 鏄庣粏琛ㄥ瓧娈垫暟鎹紝涓庨檮浠剁殑澶勭悊
+ Map<String, List<Map<String, Object>>> map1 = formson_0832(serviceFunddetailShareds);
+ data2.put("formson_0832", map1.get("formson_0832"));
+ data2.put("thirdAttachments", map1.get("annexfilesList"));
+
+ data.put("data", data2);
+ //妯℃澘缂栧彿锛岀敱鑷磋繙鏂规彁渚涳紝璇ュ弬鏁板喅瀹氬彂璧峰崗鍚岀郴缁熶腑鍝釜娴佺▼
+ data.put("templateCode", "fybxd_rzhc_ceshi");
+ //鏄惁涓哄緟鍙戯細0:鏂板缓-鍙戦�侊紱1:鏂板缓-淇濆瓨寰呭彂
+ data.put("draft", "0");
+ //鍗忓悓鏍囬鍖洪檮浠讹紝Long鍨婰ist锛屽�间负闄勪欢鐨処d銆侷d鏄檮浠舵帴鍙ｅ搷搴旂粨鏋滀腑fileUrl瀛楁鐨勫��
+// data.put("attachments", null);
+ //鍗忓悓鍏枃鐨刬d
+// data.put("relateDoc", "col|123,456;doc|321,654");
+ //鏈缃彇妯℃澘璁剧疆鐨勬爣棰�
+ data.put("subject", "null");
+ ServiceFund serviceFund1 = serviceFundMapper.selectById(serviceFund.getId());
+ data.put("summaryId", serviceFund1.getSummaryId());
+
+ map.put("data", data);
+ String strRes = null;
+ if (isUploadOaEnabled()) {
+ //濡傛灉鏄湰鍦扮幆澧冿紝灏变笉璋冭繖涓簡
+ String token = getToken();
+ JSONObject json1 = JSONObject.parseObject(token);
+ token = json1.get("id").toString();
+ ObjectMapper objectMapper = new ObjectMapper();
+ String json = null;
+ if (serviceFund.getBackflowlevel() == 100L) {
+ //鍐嶆鍙戣捣
+ try {
+ json = objectMapper.writeValueAsString(map);
+ log.error("-----------------鍐嶆鍙戣捣鐨剈rl涓猴細{}, 鍏ュ弬涓猴細{}", rexyurl + "?token=" + token, json);
+ } catch (JsonProcessingException e) {
+ e.printStackTrace();
+ }
+ strRes = HttpClientKit.postOpr(rexyurl + "?token=" + token, json);
+ } else {
+ //棣栨鍙戣捣
+ try {
+ json = objectMapper.writeValueAsString(map);
+ log.error("-----------------棣栨鍙戣捣鐨剈rl涓猴細{}, 鍏ュ弬涓猴細{}", xyurl + "?token=" + token, json);
+ } catch (JsonProcessingException e) {
+ e.printStackTrace();
+ }
+
+ strRes = HttpClientKit.postOpr(xyurl + "?token=" + token, json);
+
+ // 灏唖ummaryId淇濆瓨璧锋潵,骞跺皢璇ュ�间繚瀛樺埌fund涓紝鐢ㄤ簬鍐嶆鍙戣捣鏃讹紝浣跨敤锛堝崗鍙嬭姹傦紝鍐嶆鍙戣捣鏃讹紝甯︿笂杩欎釜鍊硷級
+ JsonObject root = JsonParser.parseString(strRes).getAsJsonObject();
+ String code = root.get("code").getAsString();
+ if ("0".equals(code)) {
+ String appBusinessData = root.getAsJsonObject("data").get("app_bussiness_data").getAsString();
+ JsonObject appDataObj = JsonParser.parseString(appBusinessData).getAsJsonObject();
+ String summaryId = appDataObj.get("summaryId").getAsString();
+ serviceFund.setSummaryId(summaryId);
+ serviceFundMapper.updateById(serviceFund);
+ }
+ }
+ }
+ log.error("------------------strRes鐨勫�间负锛歿}", strRes);
+ if (strRes == null || strRes.trim().isEmpty()) {
+ // 鍖婚櫌鍗忓弸绯荤粺鏃犺繑鍥烇紙瓒呮椂/寮傚父/鏈厤缃級锛氭帹閫佸け璐ワ紝鐢辫皟鐢ㄦ柟鍥炴粴鏁翠釜瀹℃壒
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ細鎺ュ彛鏃犺繑鍥炲唴瀹癸紝fundId={}", serviceFund.getId());
+ return false;
+ }
+ JSONObject jsonObject = null;
+ try {
+ jsonObject = JSONObject.parseObject(strRes);
+ } catch (Exception e) {
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ細杩斿洖鍐呭鏃犳硶瑙ｆ瀽锛宖undId={}锛宻trRes={}",
+ serviceFund.getId(), strRes, e);
+ return false;
+ }
+ if (jsonObject == null) {
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ細杩斿洖鍐呭涓虹┖锛宖undId={}锛宻trRes={}",
+ serviceFund.getId(), strRes);
+ return false;
+ }
+ String code = jsonObject.getString("code");
+ if (code == null || !"0".equals(code)) {
+ log.error("璐圭敤瀹℃壒鍗曚笂浼犲尰闄㈠崗鍙嬬郴缁熷け璐ワ細code={}锛宖undId={}锛宻trRes={}",
+ code, serviceFund.getId(), strRes);
+ return false;
+ }
+
+ return true;
+ }
+
+ private Map<String, List<Map<String, Object>>> formson_0832(List<ServiceFunddetailShared> serviceFunddetailSharedList) {
+ Map<String, List<Map<String, Object>>> allMap = new HashMap<>();
+
+ List<Map<String, Object>> list = new ArrayList<>();
+ List<Map<String, Object>> annexfilesList = new ArrayList<>();
+ for (ServiceFunddetailShared serviceFunddetailShared : serviceFunddetailSharedList) {
+ //闄勪欢澶勭悊
+ String annexfiles = serviceFunddetailShared.getAnnexfiles();
+ String invoicefiles = serviceFunddetailShared.getInvoicefiles();
+
+ Map<String, Object> map = new HashMap<>();
+ map.put("搴忓彿1", serviceFunddetailShared.getOrderno());
+ map.put("璐圭敤椤圭洰", serviceFunddetailShared.getItemname());
+ map.put("绋庡墠閲戦", serviceFunddetailShared.getAmount());
+ map.put("寮�鎴烽摱琛�", serviceFunddetailShared.getDepositbank());
+ map.put("鍗″彿", serviceFunddetailShared.getBankcardno());
+ map.put("鏀剁泭浜哄灞炴垨涓撳", serviceFunddetailShared.getBeneficiaryname());
+ map.put("绋庡悗閲戦", serviceFunddetailShared.getTaxedamount());
+ map.put("浣滃簾鏈�缁堥噾棰�", null);
+ Long fpuuid = IdGeneratorUtils.nextId();
+ map.put("鍙戠エ闄勪欢", "");
+ if (StringUtils.isNotEmpty(invoicefiles)) {
+ map.put("鍙戠エ闄勪欢", fpuuid);
+ }
+ map.put("鍙戠エ璇嗗埆", null);
+ map.put("璇嗗埆浜�", null);
+ map.put("绋庨", serviceFunddetailShared.getTaxamount());
+ long qtuuid = IdGeneratorUtils.nextId();
+ map.put("鍏朵粬闄勪欢", "");
+ if (StringUtils.isNotEmpty(annexfiles)) {
+ map.put("鍏朵粬闄勪欢", qtuuid);
+ }
+ map.put("椤圭洰缂栫爜", serviceFunddetailShared.getItemcode());
+ map.put("棰勭畻椤圭洰", null);
+ map.put("璐锋柟绉戠洰", null);
+ map.put("鍊熸柟鎽樿", null);
+ map.put("璐锋柟鎽樿", null);
+ map.put("璇嗗埆澶囨敞", null);
+ map.put("璐圭敤璇存槑", null);
+ list.add(map);
+
+
+ int i = 0;
+ if (StringUtils.isNotEmpty(annexfiles)) {
+ List<RbDetailFile> parseArray = JSON.parseArray(annexfiles, RbDetailFile.class);
+ for (RbDetailFile rbDetailFile : parseArray) {
+ Map<String, Object> thirdAttachments = new HashMap<>();
+ thirdAttachments.put("subReference", qtuuid);
+ thirdAttachments.put("fileUrl", rbDetailFile.getFileid());
+ thirdAttachments.put("sort", i++);
+ annexfilesList.add(thirdAttachments);
+ }
+ }
+
+ if (StringUtils.isNotEmpty(invoicefiles)) {
+ List<RbDetailFile> parseArray = JSON.parseArray(invoicefiles, RbDetailFile.class);
+ for (RbDetailFile rbDetailFile : parseArray) {
+ Map<String, Object> thirdAttachments = new HashMap<>();
+ thirdAttachments.put("subReference", fpuuid);
+ thirdAttachments.put("fileUrl", rbDetailFile.getFileid());
+ thirdAttachments.put("sort", i++);
+ annexfilesList.add(thirdAttachments);
+ }
+ }
+
+ }
+ allMap.put("formson_0832", list);
+ allMap.put("annexfilesList", annexfilesList);
+ return allMap;
+ }
+
+
+ private Map<String, Object> getformmain_0831(ServiceFund serviceFund) {
+ ServiceFundflow serviceFundflow = new ServiceFundflow();
+ serviceFundflow.setFundid(serviceFund.getId());
+ serviceFundflow.setFundtype(2);
+ List<ServiceFundflow> serviceFundflows = serviceFundflowService.queryList(serviceFundflow);
+
+ Map<String, Object> formmain_0831 = new HashMap<>();
+ formmain_0831.put("鎹愮尞鑰呭鍚�", serviceFund.getDonorname());
+ formmain_0831.put("鎶ラ攢浜哄憳", serviceFund.getUsername());
+ formmain_0831.put("涓氬姟鍖哄煙", serviceFund.getDeptmentname());
+ formmain_0831.put("缁忔墜浜�", serviceFund.getUsername());
+ formmain_0831.put("濉〃鏃堕棿", new SimpleDateFormat("yyyy-MM-dd HH:mm").format(serviceFund.getApplyTime()));
+ formmain_0831.put("鎶ラ攢閲戦鍚堣", serviceFund.getPretaxcost());
+ formmain_0831.put("涓婁紶闄勪欢", null);
+ formmain_0831.put("澶囨敞", null);
+ formmain_0831.put("璐㈠姟瀹℃壒", null);
+ formmain_0831.put("璐㈠姟閮ㄨ礋璐ｄ汉瀹℃壒", getLastApprovalInfo(serviceFundflows, serviceFund.getFinancedirector()));
+
+// formmain_0831.put("鍔炲叕瀹や富浠诲鎵�", "鍔炲叕瀹や富浠诲鎵�", "瀹℃壒浜猴細鍚村織寮� & 瀹℃壒鏃堕棿锛�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " & 瀹℃壒缁撴灉锛氶�氳繃");
+ if (serviceFund.getBackflowlevel() == 3)
+ formmain_0831.put("鍔炲叕瀹や富浠诲鎵�", "瀹℃壒浜猴細鍚村織寮� & 瀹℃壒鏃堕棿锛�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " & 瀹℃壒缁撴灉锛氶�氳繃");
+ else formmain_0831.put("鍔炲叕瀹や富浠诲鎵�", getLastApprovalInfo(serviceFundflows, "鍚村織寮�"));
+
+ formmain_0831.put("涓氬姟鍓櫌闀垮鎵�", serviceFund.getBusvicepresident());
+ formmain_0831.put("璐㈠姟鍓櫌闀垮鎵�", serviceFund.getFinvicepresident());
+ formmain_0831.put("涓績璐熻矗浜哄鎵�", serviceFund.getOpochecker());
+ formmain_0831.put("鏀粯鏂瑰紡", serviceFund.getZffs());
+ String lastApprovalInfo = getLastApprovalInfo(serviceFundflows, serviceFund.getManagername());
+ formmain_0831.put("缁勯暱", lastApprovalInfo.contains("鍚村織寮�") ? null : lastApprovalInfo);
+ formmain_0831.put("瀹℃壒浜哄憳", StringUtils.isEmpty(getLastApprovalInfo(serviceFundflows, serviceFund.getFinancechecher())) ? "闄堟厱鍗�" : getLastApprovalInfo(serviceFundflows, serviceFund.getFinancechecher()));
+ formmain_0831.put("鏀粯鏃ユ湡", serviceFund.getRiqi());
+ formmain_0831.put("璇嗗埆浜�-浣滃簾", null);
+ formmain_0831.put("璐㈠姟瀹℃壒绛惧瓧", serviceFund.getFinancedirector());
+ formmain_0831.put("璐㈠姟閮ㄨ礋璐ｄ汉绛惧瓧", serviceFund.getFinancedirector());
+ formmain_0831.put("琛ㄨ揪绫诲瀷", StringUtils.isEmpty(serviceFund.getApplytype()) ? null : ApplyTypeEnum.getDescByCode(serviceFund.getApplytype()));
+ formmain_0831.put("绋庡墠閲戦鍚堣", serviceFund.getPretaxcost());
+ formmain_0831.put("绋庨鍚堣", serviceFund.getPretaxcost() - serviceFund.getTaxedcost());
+ formmain_0831.put("琛ㄥ崟缂栧彿1", null);
+ formmain_0831.put("缂栫爜", null);
+ formmain_0831.put("CIF璐﹀閰嶇疆1", null);
+ formmain_0831.put(" 闄㈠尯", null);
+ formmain_0831.put("鏄惁鏀粯", serviceFund.getIsdistribute());
+ formmain_0831.put("鍑瘉鍙�", null);
+ formmain_0831.put("閾惰鍥炲崟", null);
+ formmain_0831.put("OFD", null);
+ formmain_0831.put("琛ㄥ崟闄勪欢", null);
+ formmain_0831.put("鐜伴噾娴侀噺鍒嗘瀽", null);
+ formmain_0831.put("鍑瘉绫诲埆", null);
+ formmain_0831.put("绋庡悗閲戦鍚堣", serviceFund.getTaxedcost());
+ formmain_0831.put("鍘嗗彶瀹℃壒璁板綍", null);
+ formmain_0831.put("琛ㄥ崟缂栧彿", serviceFund.getId());
+ formmain_0831.put("鍘嗗彶瀹℃壒鍗曟煡璇�", null);
+ return formmain_0831;
+ }
+
+
+ public String getLastApprovalInfo(List<ServiceFundflow> serviceFundflows, String managerName) {
+ log.info("---------------serviceFundflows鐨勫叆鍙備负锛歿},managerName鐨勫�间负锛歿}", serviceFundflows, managerName);
+ if (StringUtils.isEmpty(managerName)) return "";
+ if (CollectionUtils.isEmpty(serviceFundflows)) {
+ //濡傛灉鏄渶鍚庝竴涓汉瀹℃壒锛岃繖涓椂鍊欏彲鑳絝low閲岃繕娌℃湁鐢熸垚杩涘幓
+ SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ return "瀹℃壒浜猴細" + managerName + " & 瀹℃壒鏃堕棿锛�" + sd.format(new Date()) + " & 瀹℃壒缁撴灉锛氶�氳繃";
+ }
+ //鍘讳竴涓嬬┖鏍�
+ String mn = managerName.trim();
+ Optional<ServiceFundflow> lastApproval = serviceFundflows.stream().filter(flow -> mn.trim().contains(flow.getCheckusername())).max(Comparator.comparing(ServiceFundflow::getCreateTime));
+
+ if (lastApproval.isPresent()) {
+ ServiceFundflow flow = lastApproval.get();
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ if (flow.getCheckTime() == null) {
+ flow.setCheckTime(new Date());
+ }
+ String formattedTime = sdf.format(flow.getCheckTime());
+
+ return "瀹℃壒浜猴細" + managerName + " & 瀹℃壒鏃堕棿锛�" + formattedTime + " & 瀹℃壒缁撴灉锛氶�氳繃";
+ }
+
+ return "";
+ }
@Override
public Long getFundId(Long infoid) {
@@ -190,7 +1009,7 @@
serviceFunddetailShareds.get(i).setId(null);
//鏁版嵁鍙戦�佺粰璐㈠姟
try {
- uploadOAFileAndUpdateDb(serviceFunddetailShareds.get(i));
+ if (isUploadOaEnabled()) uploadOAFileAndUpdateDb(serviceFunddetailShareds.get(i));
} catch (Exception e) {
e.printStackTrace();
log.error("Exception涓叆鍙傜殑ID涓猴細{},寮傚父淇℃伅涓� 锛� {}", id, e.getMessage());
@@ -726,8 +1545,23 @@
}
@Override
+ public ExpertFeeCheckResult validateExpertFee(ServiceFundVO serviceFundVO) {
+ return expertFeeValidateService.validateBeforeSave(serviceFundVO);
+ }
+
+ @Override
@Transactional(rollbackFor = Exception.class)
public Long addOrUpdateNew(ServiceFundVO serviceFundVO) {
+ // 涓撳鍔冲姟璐癸細淇濆瓨鍓嶆牎楠� 9 鏉¤垂鐢ㄦ帶鍒惰鍒欙紙鍚屼竴妗堜緥绱锛�
+ ExpertFeeCheckResult expertFeeResult = expertFeeValidateService.validateBeforeSave(serviceFundVO);
+ if (expertFeeResult.hasError()) {
+ throw new BaseException(expertFeeResult.errorMessage());
+ }
+ if (expertFeeResult.hasWarning()) {
+ // 瑙勫垯 5銆�6 浠呮彁绀猴紝涓嶉樆鏂繚瀛橈紱鍓嶇鍗曠嫭鍙栫敤鎻愮ず鏂囨
+ log.warn("涓撳鍔冲姟璐逛繚瀛樻牎楠屾彁绀猴細{}", expertFeeResult.warningMessage());
+ }
+
Long id = null;
//灏嗘暟鎹繚瀛樺埌fund琛�
serviceFundVO.setUploadStates(0);
@@ -744,7 +1578,7 @@
if (StringUtils.isNotEmpty(serviceFunddetailVO.getIdcardno())) {
serviceFunddetailVO.setIdcardno(serviceFunddetailVO.getIdcardno().trim());
}
-
+ log.info("韬唤璇佸彿涓猴細{}", serviceFunddetailVO.getIdcardno());
if (StringUtils.isEmpty(serviceFunddetailVO.getBankcardno())) {
throw new BaseException("璇锋鏌ラ摱琛屽崱鍙锋槸鍚︿负绌�,濮撳悕锛�" + serviceFunddetailVO.getBeneficiaryname());
}
@@ -789,10 +1623,9 @@
return null;
}
- //鎬荤◣鍓�
- Double pretaxcosts = 0.00;
- //鎬荤◣鍚�
- Double taxedcosts = 0.00;
+ //鎬荤◣鍓嶃�佹�荤◣鍚庯紙閲戦绱姞鐢� BigDecimal锛岄伩鍏嶆诞鐐瑰熬宸級
+ BigDecimal pretaxcosts = BigDecimal.ZERO;
+ BigDecimal taxedcosts = BigDecimal.ZERO;
for (ServiceFunddetailVO serviceFunddetailVO : serviceFunddetails) {
serviceFunddetailVO.setFundid(id);
@@ -801,13 +1634,18 @@
if (!performance.isEmpty()) {
Double amount = performance.get("amount");
Double taxedamount = performance.get("taxedamount");
- pretaxcosts = pretaxcosts + amount;
- taxedcosts = taxedcosts + taxedamount;
+ if (amount != null) {
+ pretaxcosts = pretaxcosts.add(BigDecimal.valueOf(amount));
+ }
+ if (taxedamount != null) {
+ taxedcosts = taxedcosts.add(BigDecimal.valueOf(taxedamount));
+ }
}
- serviceFundVO.setPretaxcost(pretaxcosts);
- serviceFundVO.setTaxedcost(taxedcosts);
- updateById(serviceFundVO);
}
+ // 鍚堣鍦ㄥ惊鐜粨鏉熷悗缁熶竴鍥炲啓锛屽師鏉ュ啓鍦ㄥ惊鐜唴浼氭瘡琛岄兘 UPDATE 涓�娆★紝涓斾腑闂村�艰鍙嶅瑕嗙洊
+ serviceFundVO.setPretaxcost(pretaxcosts.doubleValue());
+ serviceFundVO.setTaxedcost(taxedcosts.doubleValue());
+ updateById(serviceFundVO);
Map map = new HashMap();
map.put("fundId", id);
return map;
@@ -962,20 +1800,19 @@
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<String, Object> map = new HashMap<String, Object>();
- map.put("userName", "opo");
- map.put("password", "4126407a-9821-4874-be41-6568abd6dbe5");
- map.put("loginName", "demo3");
+// String strUrl = "http://129.88.242.39: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 = getToken();
- 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();
@@ -997,6 +1834,22 @@
//鍙戠エ闄勪欢
uploadFile(filePath, strFUrl, invoicefilesList, invoicefilesArray, remShare, "2");
return 0;
+ }
+
+ private String getToken() {
+ //涓婁紶OA鏂囦欢
+ String strUrl = "http://129.88.242.39: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", "OPO绯荤粺瀹℃壒");
+
+ JSONObject jsonObj = new JSONObject(map);
+
+ System.out.println("uploadOAFileAndUpdateDb + jsonObject" + jsonObj.toString() + "\r\n" + jsonObj.toJSONString());
+ String strRes = HttpClientKit.postOpr(strUrl, jsonObj.toString());
+ return strRes;
}
@@ -1043,98 +1896,6 @@
}
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;// 涓虹┖浠ｈ〃澶辫触
-//
-// //涓嬮潰闇�姹傝皟鐢ㄦ枃浠剁殑鎺ュ彛锛岃皟鐢ㄦ垚鍔熻繑鍥炲悗锛屽緱鍒癴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;
@@ -1197,7 +1958,38 @@
serviceFunddetail.setTaxTime(null);
serviceFunddetail.setXh(null);
boolean b = serviceFunddetailMapper.updateTaxTime(serviceFunddetail);
-
return b;
}
+
+
+ public void sendMeg(ServiceProcessVO serviceProcessVO, String phone,
+ List<ConcurrentHashMap<String, Object>> contentList) {
+ //璁板綍鎿嶄綔璁板綍
+ ServiceFundflow serviceFundflow = new ServiceFundflow();
+
+ serviceFundflow.setCreateBy(serviceProcessVO.getCheckusername());
+ serviceFundflow.setUpdateBy(serviceProcessVO.getCheckusername());
+ serviceFundflow.setCheckusername(serviceProcessVO.getCheckusername());
+ serviceFundflow.setCreateTime(new Date());
+ serviceFundflow.setCheckTime(new Date());
+ serviceFundflow.setUpdateTime(new Date());
+ serviceFundflow.setFlowcontent(serviceProcessVO.getFlowcontent());
+ serviceFundflow.setFlowconclusion(StringUtils.isNotEmpty(serviceProcessVO.getFlowconclusion()) ? Integer.valueOf(serviceProcessVO.getFlowconclusion()) : null);
+ if (serviceProcessVO.getApplytype().equals("0")) serviceFundflow.setFundtype(1);
+ if (serviceProcessVO.getApplytype().equals("1")) serviceFundflow.setFundtype(2);
+ serviceFundflow.setFlowlevel(100);
+ serviceFundflow.setApplytype(serviceProcessVO.getApplytype());
+ serviceFundflow.setFundid(StringUtils.isNotEmpty(serviceProcessVO.getBackCode()) ? Long.valueOf(serviceProcessVO.getBackCode()) : null);
+ fundflowService.save(serviceFundflow);
+ try {
+ DingTalkReqVo dingTalkReqVo = new DingTalkReqVo();
+ dingTalkReqVo.setTitle(FundNotifyMessageBuilder.TITLE);
+ dingTalkReqVo.setNumber(phone);
+ dingTalkReqVo.setContents(contentList);
+ log.info("閽夐拤鍙戦�佹秷鎭�:{}", dingTalkReqVo);
+ dingTalkService.sendNotification(dingTalkReqVo);
+ } catch (Exception e) {
+ log.error("鎶ラ攢瀹℃壒閽夐拤娑堟伅鍙戦�佸け璐ワ紝涓嶅奖鍝嶄富娴佺▼", e);
+ }
+ }
}
--
Gitblit v1.9.3