From 561aa63737f42136c69e87a8d907727da235b38c Mon Sep 17 00:00:00 2001
From: yxh <172933527@qq.com>
Date: 星期五, 16 八月 2024 18:51:41 +0800
Subject: [PATCH] Merge branch 'master' of http://116.62.18.175:6699/r/~yxh/opo
---
ruoyi-project/src/main/java/com/ruoyi/project/domain/VDonationworkflow.java | 9 +---
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java | 96 ++++++++++++++++++++++++++++++++++++-----------
ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceFundController.java | 4 +-
ruoyi-generator/src/main/resources/vm/java/mapper.java.vm | 4 +
4 files changed, 80 insertions(+), 33 deletions(-)
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceFundController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceFundController.java
index 94f0d70..9d02ba2 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceFundController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceFundController.java
@@ -78,7 +78,7 @@
private IServiceReimbursementService serviceReimbursementService;
@Autowired
- private IServiceSystemmessageService ServiceSystemmessage;
+ private IServiceSystemmessageService iServiceSystemmessageService;
@Autowired
private IServiceExternalpersonService externalpersonService;
@@ -470,7 +470,7 @@
serviceSystemmessage.setMessagecontent("鎮�" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(serviceFund.getCreateTime()) + "鎻愪氦鐨勭哗鏁堢敵璇峰凡椹冲洖锛屽師鍥�: " + checkFundVO.getFlowcontent() + "");
}
}
- ServiceSystemmessage.save(serviceSystemmessage);
+ iServiceSystemmessageService.save(serviceSystemmessage);
return AjaxResult.success();
} else {
return AjaxResult.error(HttpStatus.NO_CONTENT, "璐圭敤缂栧彿涓嶆纭�");
diff --git a/ruoyi-generator/src/main/resources/vm/java/mapper.java.vm b/ruoyi-generator/src/main/resources/vm/java/mapper.java.vm
index 6123f83..d2e5dc0 100644
--- a/ruoyi-generator/src/main/resources/vm/java/mapper.java.vm
+++ b/ruoyi-generator/src/main/resources/vm/java/mapper.java.vm
@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
import ${packageName}.domain.${ClassName};
#if($table.sub)
import ${packageName}.domain.${subClassName};
@@ -10,10 +11,11 @@
/**
* ${functionName}Mapper鎺ュ彛
- *
+ *
* @author ${author}
* @date ${datetime}
*/
+@Mapper
public interface ${ClassName}Mapper extends BaseMapper<${ClassName}>
{
/**
diff --git a/ruoyi-project/src/main/java/com/ruoyi/project/domain/VDonationworkflow.java b/ruoyi-project/src/main/java/com/ruoyi/project/domain/VDonationworkflow.java
index 9b6ab55..7e47de8 100644
--- a/ruoyi-project/src/main/java/com/ruoyi/project/domain/VDonationworkflow.java
+++ b/ruoyi-project/src/main/java/com/ruoyi/project/domain/VDonationworkflow.java
@@ -1,19 +1,14 @@
package com.ruoyi.project.domain;
-import java.util.Date;
-
-import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonFormat;
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
import com.ruoyi.common.annotation.Excel;
-import com.ruoyi.common.core.domain.BaseEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
-import jdk.nashorn.internal.ir.annotations.Ignore;
import lombok.Data;
+import java.util.Date;
+
/**
* VIEW瀵硅薄 v_donationworkflow
*
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
index c65944f..0f41336 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
@@ -17,6 +17,9 @@
import java.text.ParseException;
import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.format.DateTimeParseException;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.ReentrantLock;
@@ -53,12 +56,15 @@
@Autowired
private ISysUserService sysUserService;
+ @Autowired
+ private IServiceSystemmessageService iServiceSystemmessageService;
+
@Autowired
private IServiceFundflowService fundflowService;
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
- System.out.println(StringUtils.format("鎵ц澶氬弬鏂规硶锛� 瀛楃涓茬被鍨媨}锛屽竷灏旂被鍨媨}锛岄暱鏁村瀷{}锛屾诞鐐瑰瀷{}锛屾暣褰}", s, b, l, d, i));
+ System.out.println(StringUtils.format("鎵ц澶氬弬鏂规硶锛� 瀛楃涓茬被鍨媨}锛屽竷灏旂被鍨媨}锛岄暱鏁村瀷{}锛屾诞鐐瑰瀷{}锛屾暣褰}" , s, b, l, d, i));
}
public void ryParams(String params) {
@@ -81,9 +87,9 @@
}
String phone = serviceFundShared.getPhone();
//灏嗗垎浜噷鐨勮鏁版嵁鍒犻櫎
- log.info("checkReportInfo涓叆鍙侷D涓猴細{}", serviceFundShared.getId());
+ log.info("checkReportInfo涓叆鍙侷D涓猴細{}" , serviceFundShared.getId());
Boolean aBoolean = serviceFundSharedService.delfundsharedInfoById(serviceFundShared.getId(), null);
- log.info("fund鍒嗕韩琛ㄩ噷鐨勬暟鎹槸鍚﹀垹闄ゆ垚鍔燂細{}", aBoolean);
+ log.info("fund鍒嗕韩琛ㄩ噷鐨勬暟鎹槸鍚﹀垹闄ゆ垚鍔燂細{}" , aBoolean);
ServiceFund serviceFund = new ServiceFund();
serviceFund.setId(serviceFundShared.getSerfunid());
List<ServiceFund> serviceFunds = serviceFundService.queryInfoById(serviceFund);
@@ -96,6 +102,20 @@
SysUser sysUser = sysUserService.selectUserByUserName(serviceFund1.getUserno());
sendMeg(split, sysUser.getPhonenumber(), serviceFundShared.getApplytype(), 2, serviceFundShared.getSerfunid());
+ //鍙戦�佷俊鎭繚瀛�
+ ServiceSystemmessage serviceSystemmessage = new ServiceSystemmessage();
+ serviceSystemmessage.setFundtype(1);
+ serviceSystemmessage.setSenduserno(sysUser.getUserName());
+ serviceSystemmessage.setSendusername(sysUser.getNickName());
+ serviceSystemmessage.setReceiveuserno(serviceFund.getUserno());
+ serviceSystemmessage.setReceiveusername(serviceFund.getUsername());
+ serviceSystemmessage.setUpdateTime(new Date());
+ serviceSystemmessage.setUpdateBy(sysUser.getNickName());
+ serviceSystemmessage.setIsread(0);
+ serviceSystemmessage.setMessagetype(1);
+ serviceSystemmessage.setMessagetitle("璐㈠姟绯荤粺椹冲洖淇℃伅");
+ serviceSystemmessage.setMessagecontent(serviceFundShared.getCxrjyj());
+ iServiceSystemmessageService.save(serviceSystemmessage);
} else {
//涓嶆槸閫�鍥炵殑鎿嶄綔
if (StringUtils.isNotBlank(serviceFundShared.getZffs()) && serviceFundShared.getSpjg() == 0) {
@@ -125,7 +145,7 @@
}
serviceFund.setRiqi(serviceFundShared.getRiqi());
boolean b = serviceFundService.updateById(serviceFund);
- log.info("鏇存柊serviceFund閲岀殑zffs琛ㄦ槸鍚︽垚鍔�: {}", b);
+ log.info("鏇存柊serviceFund閲岀殑zffs琛ㄦ槸鍚︽垚鍔�: {}" , b);
ServiceFundflow serviceFundflow = new ServiceFundflow();
serviceFundflow.setCreateBy("admin");
serviceFundflow.setCreateTime(new Date());
@@ -303,14 +323,14 @@
if (StringUtils.isNotBlank(serviceReimbursementShared.getOabdzt()) && serviceReimbursementShared.getOabdzt().equals("宸叉挙閿�")) {
String phone = serviceReimbursementShared.getPhone();
String[] split = null;
- log.info("serviceReimbursementShared.getCxrjyj(): {}", serviceReimbursementShared.getCxrjyj());
+ log.info("serviceReimbursementShared.getCxrjyj(): {}" , serviceReimbursementShared.getCxrjyj());
if (StringUtils.isNotBlank(serviceReimbursementShared.getCxrjyj())) {
split = serviceReimbursementShared.getCxrjyj().split("&");
}
//灏嗗垎浜噷鐨勮鏁版嵁鍒犻櫎
Boolean aBoolean = serviceReimbursementSharedService.delResharedInfoById(serviceReimbursementShared.getId());
- log.info("灏嗗垎浜噷鐨勮鏁版嵁鍒犻櫎: {}", aBoolean);
+ log.info("灏嗗垎浜噷鐨勮鏁版嵁鍒犻櫎: {}" , aBoolean);
//灏咶lowlevel 璁剧疆涓�0;
ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
serviceReimbursement.setId(serviceReimbursementShared.getReimid());
@@ -324,7 +344,21 @@
serviceReimbursementService.updateById(serviceReimbursement1);
SysUser sysUser = sysUserService.selectUserByUserName(serviceReimbursement1.getUserno());
- sendMeg(split, sysUser.getPhonenumber(), "0", 1, serviceReimbursementShared.getReimid());
+ //鍙戦�佷俊鎭繚瀛�
+ sendMeg(split, sysUser.getPhonenumber(), "0" , 1, serviceReimbursementShared.getReimid());
+ ServiceSystemmessage serviceSystemmessage = new ServiceSystemmessage();
+ serviceSystemmessage.setFundtype(1);
+ serviceSystemmessage.setSenduserno(sysUser.getUserName());
+ serviceSystemmessage.setSendusername(sysUser.getNickName());
+ serviceSystemmessage.setReceiveuserno(serviceReimbursement1.getUserno());
+ serviceSystemmessage.setReceiveusername(serviceReimbursement1.getUsername());
+ serviceSystemmessage.setUpdateTime(new Date());
+ serviceSystemmessage.setUpdateBy(sysUser.getNickName());
+ serviceSystemmessage.setIsread(0);
+ serviceSystemmessage.setMessagetype(1);
+ serviceSystemmessage.setMessagetitle("璐㈠姟绯荤粺椹冲洖淇℃伅");
+ serviceSystemmessage.setMessagecontent(serviceReimbursementShared.getCxrjyj());
+ iServiceSystemmessageService.save(serviceSystemmessage);
} else {
//涓嶆槸閫�鍥炵殑鎿嶄綔
@@ -355,7 +389,7 @@
serviceReimbursement.setFinancechecher(serviceReimbursementShared.getFinancechecher());
}
boolean b = serviceReimbursementService.updateById(serviceReimbursement);
- log.info("鏇存柊serviceReimbursement閲岀殑zffs琛ㄦ槸鍚︽垚鍔�: {}", b);
+ log.info("鏇存柊serviceReimbursement閲岀殑zffs琛ㄦ槸鍚︽垚鍔�: {}" , b);
ServiceFundflow serviceFundflow = new ServiceFundflow();
serviceFundflow.setCreateBy("admin");
serviceFundflow.setCreateTime(new Date());
@@ -520,7 +554,6 @@
serviceFundflow.setCheckTime(parse);
fundflowService.save(serviceFundflow);
-
}
//濡傛灉宸茬粡鏇存柊鍒欎笉鍦ㄥ鐞�
}
@@ -563,15 +596,32 @@
ArrayList<ConcurrentHashMap<String, Object>> contentList = new ArrayList<>();
ConcurrentHashMap map = new ConcurrentHashMap();
- map.put("瀹℃壒浜猴細", people);
- map.put("瀹℃壒鏃堕棿锛�", time);
- map.put("鎰忚锛�", content);
+ map.put("瀹℃壒浜猴細" , people);
+ try {
+ boolean validDateTime = isValidDateTime(time);
+ if (validDateTime) map.put("瀹℃壒鏃堕棿锛�" , new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(time));
+ else map.put("瀹℃壒鏃堕棿锛�" , new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(time + ":00"));
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ map.put("鎰忚锛�" , content);
contentList.add(map);
DingTalkReqVo dingTalkReqVo = new DingTalkReqVo();
dingTalkReqVo.setTitle("璐㈠姟绯荤粺椹冲洖淇℃伅");
dingTalkReqVo.setNumber(phone);
dingTalkReqVo.setContents(contentList);
+ log.info("閽夐拤鍙戦�佹秷鎭�:{}" , dingTalkReqVo);
dingTalkService.sendNotification(dingTalkReqVo);
+ }
+
+ public boolean isValidDateTime(String dateTime) {
+ try {
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ LocalDateTime.parse(dateTime, formatter);
+ return true;
+ } catch (DateTimeParseException e) {
+ return false;
+ }
}
private ReentrantLock lock = new ReentrantLock();
@@ -610,7 +660,7 @@
}
}
} catch (Exception e) {
- log.error("鑾峰彇缂栧彿澶辫触浜唟}", e.getStackTrace());
+ log.error("鑾峰彇缂栧彿澶辫触浜唟}" , e.getStackTrace());
} finally {
lock.unlock();
}
@@ -626,7 +676,7 @@
//澶勭悊宸梾鎶ラ攢
serviceFundflowrule.setApplytype("0");
List<ServiceFundflowrule> serviceFundflowrules = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("宸梾鐨勬渶楂樼瓑绾�:{}", serviceFundflowrules.get(0).getTotallevel());
+ log.info("宸梾鐨勬渶楂樼瓑绾�:{}" , serviceFundflowrules.get(0).getTotallevel());
ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
serviceReimbursement.setFlowlevel(serviceFundflowrules.get(0).getTotallevel().longValue());
serviceReimbursement.setUploadStates(1);
@@ -634,14 +684,14 @@
List<ServiceReimbursement> serviceReimbursementList = serviceReimbursementService.queryList(serviceReimbursement);
for (ServiceReimbursement serviceReimbursement1 : serviceReimbursementList) {
try {
- log.info("鎻掑叆鍒嗕韩琛ㄧ殑ID涓猴細{}", serviceReimbursement1.getId());
+ log.info("鎻掑叆鍒嗕韩琛ㄧ殑ID涓猴細{}" , serviceReimbursement1.getId());
Boolean aBoolean = serviceReimbursementService.addSharedData(serviceReimbursement1.getId());
if (aBoolean) {
ServiceReimbursement serviceReimbursement3 = new ServiceReimbursement();
serviceReimbursement3.setId(serviceReimbursement1.getId());
serviceReimbursement3.setUploadStates(2);
boolean b = serviceReimbursementService.updateById(serviceReimbursement3);
- log.info("serviceReimbursement鏄惁鎻掑叆鎴愬姛{},{}", aBoolean, b);
+ log.info("serviceReimbursement鏄惁鎻掑叆鎴愬姛{},{}" , aBoolean, b);
}
} catch (Exception e) {
ServiceReimbursement serviceReimbursement2 = new ServiceReimbursement();
@@ -654,31 +704,31 @@
//涓撳鍔冲姟璐圭敵璇�
serviceFundflowrule.setApplytype("1");
List<ServiceFundflowrule> serviceFundflowrules2 = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("涓撳鍔冲姟鐨勬渶楂樼瓑绾�:{}", serviceFundflowrules2.get(0).getTotallevel());
+ log.info("涓撳鍔冲姟鐨勬渶楂樼瓑绾�:{}" , serviceFundflowrules2.get(0).getTotallevel());
addFundShared(serviceFundflowrules2.get(0).getTotallevel().longValue(), "1");
//浼︾悊涓撳鍔冲姟璐圭敵璇�
serviceFundflowrule.setApplytype("2");
List<ServiceFundflowrule> serviceFundflowrules3 = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("浼︾悊涓撳鍔冲姟璐圭敵璇�:{}", serviceFundflowrules3.get(0).getTotallevel());
+ log.info("浼︾悊涓撳鍔冲姟璐圭敵璇�:{}" , serviceFundflowrules3.get(0).getTotallevel());
addFundShared(serviceFundflowrules3.get(0).getTotallevel().longValue(), "2");
//鍖诲鎴愭湰鎶ラ攢
serviceFundflowrule.setApplytype("3");
List<ServiceFundflowrule> serviceFundflowrules4 = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("鍖诲鎴愭湰鎶ラ攢:{}", serviceFundflowrules4.get(0).getTotallevel());
+ log.info("鍖诲鎴愭湰鎶ラ攢:{}" , serviceFundflowrules4.get(0).getTotallevel());
addFundShared(serviceFundflowrules4.get(0).getTotallevel().longValue(), "3");
//鍔炲叕璐圭敤鎶ラ攢
serviceFundflowrule.setApplytype("4");
List<ServiceFundflowrule> serviceFundflowrules5 = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("鍔炲叕璐圭敤鎶ラ攢:{}", serviceFundflowrules5.get(0).getTotallevel());
+ log.info("鍔炲叕璐圭敤鎶ラ攢:{}" , serviceFundflowrules5.get(0).getTotallevel());
addFundShared(serviceFundflowrules5.get(0).getTotallevel().longValue(), "4");
//缁╂晥瀹℃壒鎶ラ攢
serviceFundflowrule.setApplytype("5");
List<ServiceFundflowrule> serviceFundflowrules6 = iServiceFundflowruleService.queryList(serviceFundflowrule);
- log.info("鍔炲叕璐圭敤鎶ラ攢:{}", serviceFundflowrules6.get(0).getTotallevel());
+ log.info("鍔炲叕璐圭敤鎶ラ攢:{}" , serviceFundflowrules6.get(0).getTotallevel());
addFundShared(serviceFundflowrules6.get(0).getTotallevel().longValue(), "5");
}
@@ -692,7 +742,7 @@
List<ServiceFund> serviceFundList = serviceFundService.queryList(serviceFund);
for (ServiceFund serviceFund1 : serviceFundList) {
try {
- log.info("鎻掑叆鍒嗕韩琛ㄧ殑FundID涓猴細{}", serviceFund1.getId());
+ log.info("鎻掑叆鍒嗕韩琛ㄧ殑FundID涓猴細{}" , serviceFund1.getId());
Boolean aBoolean = serviceFundService.addFundSharedInfo(serviceFund1.getId());
if (aBoolean) {
ServiceFund serviceFund2 = new ServiceFund();
@@ -700,7 +750,7 @@
serviceFund2.setUploadStates(2);
serviceFund2.setUpdateTime(new Date());
boolean b = serviceFundService.updateById(serviceFund2);
- log.info("serviceReimbursement鏄惁鎻掑叆鎴愬姛{},{}", aBoolean, b);
+ log.info("serviceReimbursement鏄惁鎻掑叆鎴愬姛{},{}" , aBoolean, b);
}
} catch (Exception e) {
e.printStackTrace();
--
Gitblit v1.9.3