From defbbc81145072e73cb51c6feb9d83936d9caa97 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 09 Aug 2024 13:50:56 +0800
Subject: [PATCH] 1
---
src/main/java/project/futures/FuturesOrderService.java | 3 +++
src/main/java/project/admin/AdminFuturesOrderController.java | 19 +++++++++++++++----
src/main/java/project/futures/internal/FuturesOrderServiceImpl.java | 6 ++++++
3 files changed, 24 insertions(+), 4 deletions(-)
diff --git a/src/main/java/project/admin/AdminFuturesOrderController.java b/src/main/java/project/admin/AdminFuturesOrderController.java
index 65d6e54..3fe21b0 100644
--- a/src/main/java/project/admin/AdminFuturesOrderController.java
+++ b/src/main/java/project/admin/AdminFuturesOrderController.java
@@ -1,5 +1,6 @@
package project.web.admin;
+import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -7,10 +8,13 @@
import javax.servlet.http.HttpServletRequest;
+import kernel.bo.RecordObjectMapper;
import kernel.web.ApplicationUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@@ -29,6 +33,7 @@
import project.item.ItemService;
import project.item.model.Item;
import project.redis.RedisHandler;
+import project.wallet.Wallet;
/**
* 交割合约单
@@ -151,12 +156,18 @@
try {
FuturesOrder byOrderNo = futuresOrderService.findByOrderNo(orderNo);
+
if(null != byOrderNo){
- byOrderNo.setRemark(remark);
+ List<FuturesOrder> query = futuresOrderService.findByPartyId(byOrderNo.getPartyId().toString());
+ for (FuturesOrder f : query) {
+ System.out.println("修改之前==="+f);
+ f.setRemark(remark);
+ ApplicationUtil.executeUpdate(f);
+ System.out.println("修改之后==="+f);
+ futuresOrderService.updateCache(f.getOrder_no(), f);
+ redisHandler.setSync(FuturesRedisKeys.FUTURES_SUBMITTED_ORDERNO + f.getOrder_no(),f);
+ }
}
- ApplicationUtil.executeUpdate(byOrderNo);
- futuresOrderService.updateCache(byOrderNo.getOrder_no(), byOrderNo);
- redisHandler.remove(FuturesRedisKeys.FUTURES_SUBMITTED_ORDERNO + byOrderNo.getOrder_no());
} catch (BusinessException e) {
modelAndView.addObject("error", e.getMessage());
return modelAndView;
diff --git a/src/main/java/project/futures/FuturesOrderService.java b/src/main/java/project/futures/FuturesOrderService.java
index fc69db4..5ec8e95 100644
--- a/src/main/java/project/futures/FuturesOrderService.java
+++ b/src/main/java/project/futures/FuturesOrderService.java
@@ -45,6 +45,9 @@
*/
public List<FuturesOrder> findByPartyIdAndToday(String partyId);
+
+ public List<FuturesOrder> findByPartyId(String partyId);
+
/**
* 修改订单场控
*
diff --git a/src/main/java/project/futures/internal/FuturesOrderServiceImpl.java b/src/main/java/project/futures/internal/FuturesOrderServiceImpl.java
index e623c1a..ca64670 100644
--- a/src/main/java/project/futures/internal/FuturesOrderServiceImpl.java
+++ b/src/main/java/project/futures/internal/FuturesOrderServiceImpl.java
@@ -709,6 +709,12 @@
public List<FuturesOrder> findByPartyIdAndToday(String partyId) {
return ApplicationUtil.executeSelect(FuturesOrder.class,"WHERE PARTY_ID=? AND DATEDIFF(CREATE_TIME,NOW())=0",new Object[] {partyId});
}
+
+ public List<FuturesOrder> findByPartyId(String partyId) {
+ String querySql="SELECT * FROM T_FUTURES_ORDER WHERE PARTY_ID=? ";
+ List<FuturesOrder> list = ApplicationUtil.executeSelect(FuturesOrder.class,"WHERE PARTY_ID=?",new Object[] {partyId});
+ return list;
+ }
public List<FuturesOrder> findByHourAndSate(String state, String rolename) {
String querySql="SELECT * FROM T_FUTURES_ORDER order,PAT_PARTY par WHERE TIMESTAMPDIFF(MINUTE,order.SETTLEMENT_TIME,NOW())<24*60 AND order.STATE=? AND par.UUID=order.PARTY_ID AND par.ROLENAME=?";
--
Gitblit v1.9.3