From 5ab1a38d6fb2532b26311a4e2f9fd5120227a303 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 14 Jul 2025 21:03:13 +0800
Subject: [PATCH] 地址
---
src/main/java/project/project/web/admin/AdminContractOrderController.java | 200 +++++++++++++++++++++++++++++++------------------
1 files changed, 125 insertions(+), 75 deletions(-)
diff --git a/src/main/java/project/project/web/admin/AdminContractOrderController.java b/src/main/java/project/project/web/admin/AdminContractOrderController.java
index 9314af2..d2941aa 100644
--- a/src/main/java/project/project/web/admin/AdminContractOrderController.java
+++ b/src/main/java/project/project/web/admin/AdminContractOrderController.java
@@ -3,11 +3,12 @@
import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.text.MessageFormat;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
import javax.servlet.http.HttpServletRequest;
@@ -55,22 +56,22 @@
@Autowired
private LogService logService;
-
+
@Autowired
private ItemService itemService;
-
+
@Autowired
private DataService dataService;
-
+
@Autowired
private SecUserService secUserService;
-
+
@Autowired
private ContractOrderService contractOrderService;
-
+
@Autowired
private AdjustmentValueService adjustmentValueService;
-
+
@Autowired
private AdminContractOrderService adminContractOrderService;
@@ -78,7 +79,7 @@
private WalletService walletService;
private final String action = "normal/adminContractOrderAction!";
-
+
private static final Logger logger = LoggerFactory.getLogger(AdminContractOrderController.class);
/**
@@ -97,7 +98,7 @@
ModelAndView modelAndView = new ModelAndView();
modelAndView.setViewName("contract_order_list");
-
+
int pageNo=1;
Page page=null;
int pageSize=30;
@@ -106,17 +107,35 @@
String loginPartyId = this.getLoginPartyId();
page = this.adminContractOrderService.pagedQuery(pageNo, pageSize, ContractOrder.STATE_SUBMITTED,
rolename_para, loginPartyId, start_time, end_time, name_para, order_no_para);
-
+
List<Map> list = page.getElements();
for (int i = 0; i < list.size(); i++) {
- Map map = list.get(i);
+ Map map = list.get(i);
if (null == map.get("rolename")) {
map.put("roleNameDesc", "");
} else {
String roleName = map.get("rolename").toString();
map.put("roleNameDesc", Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
}
+ Object createTimeObj = map.get("createTime");
+ ZonedDateTime berlinTime;
+ if (createTimeObj instanceof String) {
+ // 处理字符串格式 "2025-07-14T16:13:29" (ISO格式)
+ berlinTime = LocalDateTime.parse((String) createTimeObj)
+ .atZone(ZoneId.systemDefault())
+ .withZoneSameInstant(ZoneId.of("Europe/Berlin"));
+ } else if (createTimeObj instanceof LocalDateTime) {
+ // 处理 LocalDateTime 对象
+ berlinTime = ((LocalDateTime) createTimeObj)
+ .atZone(ZoneId.systemDefault())
+ .withZoneSameInstant(ZoneId.of("Europe/Berlin"));
+ } else {
+ throw new IllegalArgumentException("不支持的日期类型");
+ }
+
+ String formatted = berlinTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+ map.put("createTime", formatted);
double depositOpen = Double.parseDouble(map.get("deposit_open").toString());
double leverRate = Double.parseDouble(map.get("lever_rate").toString());
double tradeAvgPrice = Double.parseDouble(map.get("trade_avg_price").toString());
@@ -134,7 +153,8 @@
profit = Arith.add(profit, Arith.add(close_line.getProfit(), close_line.getDeposit()));
}else{
profit = Arith.add(profit, close_line.getDeposit());
- } }
+ }
+ }
Wallet wallet = this.walletService.saveWalletByPartyId(map.get("party_id").toString());
double totleMoney = wallet.getMoney();
profit = Arith.add(profit,totleMoney);
@@ -143,40 +163,33 @@
if (map.get("direction") != null) {
String direction = map.get("direction").toString();
double liquidationPrice;
- double deposit = depositOpen + profit;
+ double deposit = profit;
+
if(leverRate == 1){
liquidationPrice = 0;
}else {
if ("sell".equals(direction)) {
- liquidationPrice = tradeAvgPrice + (deposit / div);
+ double lossPercentage = deposit / (Arith.mul(Double.parseDouble(map.get("volume").toString()), Double.parseDouble(map.get("unit_amount").toString())));
+ double priceIncrease = lossPercentage * tradeAvgPrice;
+ liquidationPrice = tradeAvgPrice + priceIncrease;
} else {
- liquidationPrice = (mul * tradeAvgPrice) / (deposit + mul);
+ double lossPercentage = deposit / (Arith.mul(Double.parseDouble(map.get("volume").toString()), Double.parseDouble(map.get("unit_amount").toString())));
+ double priceDrop = lossPercentage * tradeAvgPrice;
+ liquidationPrice = tradeAvgPrice - priceDrop;
}
}
DecimalFormat dfs = new DecimalFormat("#.#####");
String formattedPrice = dfs.format(liquidationPrice);
+ // 检查是否为负数
+ if (Double.parseDouble(formattedPrice) < 0) {
+ formattedPrice = "0";
+ }
map.put("qiangPing", formattedPrice);
}
-
-// double currentPrice = Double.parseDouble(map.get("trade_avg_price").toString());
-//
-// double leve = Double.parseDouble(map.get("lever_rate").toString());
-// //得到强平价格
-// if(null != map.get("direction")){
-// double liquidationPrice;
-// if(map.get("direction").equals("sell")){
-// liquidationPrice = currentPrice * (1 + (1 / leve));
-// }else{
-// liquidationPrice = currentPrice * (1 - 1 / leve);
-// }
-// DecimalFormat df = new DecimalFormat("#.#####");
-// String formattedPrice = df.format(liquidationPrice);
-// map.put("qiangPing",formattedPrice);
-// }
}
List<Item> items = this.itemService.cacheGetAll();
- SysparaService sysparaService =ApplicationUtil.getBean(SysparaService.class);
+ SysparaService sysparaService =ApplicationUtil.getBean(SysparaService.class);
Syspara syspara = sysparaService.find("symbol_sort");
if(ObjectUtils.isNotEmpty(syspara)) {
String[] symbolArr = syspara.getValue().split(",");
@@ -195,15 +208,15 @@
items.add(i, item_3);
continue;
}
- }
+ }
}
- }
+ }
Map<String, String> symbols = new LinkedHashMap<String, String>();
for (Item item : items) {
symbols.put(item.getSymbol(), item.getName());
}
-
+
modelAndView.addObject("symbols", symbols);
} catch (BusinessException e) {
@@ -244,20 +257,20 @@
ModelAndView modelAndView = new ModelAndView();
modelAndView.setViewName("contract_order_list_content");
-
+
int pageNo=1;
Page page=null;
int pageSize=30;
try {
pageNo=checkAndSetPageNo(pageNoStr);
-
+
String loginPartyId = getLoginPartyId();
page = this.adminContractOrderService.pagedQuery(pageNo, pageSize, ContractOrder.STATE_SUBMITTED,
rolename_para, loginPartyId, start_time, end_time, name_para, order_no_para);
List<Map> list = page.getElements();
for (int i = 0; i < list.size(); i++) {
- Map map = list.get(i);
+ Map map = list.get(i);
if (null == map.get("rolename")) {
map.put("roleNameDesc", "");
} else {
@@ -305,21 +318,30 @@
if (map.get("direction") != null) {
String direction = map.get("direction").toString();
double liquidationPrice;
- double deposit = depositOpen + profit;
+ double deposit = profit;
+
if(leverRate == 1){
liquidationPrice = 0;
}else {
if ("sell".equals(direction)) {
- liquidationPrice = tradeAvgPrice + (deposit / div);
+ double lossPercentage = deposit / (Arith.mul(Double.parseDouble(map.get("volume").toString()), Double.parseDouble(map.get("unit_amount").toString())));
+ double priceIncrease = lossPercentage * tradeAvgPrice;
+ liquidationPrice = tradeAvgPrice + priceIncrease;
} else {
- liquidationPrice = (mul * tradeAvgPrice) / (deposit + mul);
+ double lossPercentage = deposit / (Arith.mul(Double.parseDouble(map.get("volume").toString()), Double.parseDouble(map.get("unit_amount").toString())));
+ double priceDrop = lossPercentage * tradeAvgPrice;
+ liquidationPrice = tradeAvgPrice - priceDrop;
}
}
-
DecimalFormat dfs = new DecimalFormat("#.#####");
String formattedPrice = dfs.format(liquidationPrice);
+ // 检查是否为负数
+ if (Double.parseDouble(formattedPrice) < 0) {
+ formattedPrice = "0";
+ }
map.put("qiangPing", formattedPrice);
}
+
}
@@ -351,16 +373,16 @@
@RequestMapping(action + "showModal.action")
public String showModal(HttpServletRequest request) {
String symbol = request.getParameter("symbol");
-
+
Map<String, Object> resultMap = new HashMap<String, Object>();
-
+
try {
-
+
Realtime realtime = this.dataService.realtime(symbol).get(0);
Item item = this.itemService.cacheBySymbol(symbol, false);
-
+
Double currentValue = this.adjustmentValueService.getCurrentValue(symbol);
if (null == currentValue) {
resultMap.put("adjust_value", 0D);
@@ -392,7 +414,7 @@
/**
* 调整 页面计算
- *
+ *
* type 0增加一个pips；1减少一个pips；2直接修改调整值；
* value 调整值
*/
@@ -403,21 +425,21 @@
String value = request.getParameter("value");
Map<String, Object> resultMap = new HashMap<String, Object>();
-
+
try {
-
+
String error = this.verif(type, value);
if (!StringUtils.isNullOrEmpty(error)) {
throw new BusinessException(error);
}
-
+
int type_int = Integer.valueOf(request.getParameter("type")).intValue();
double value_double = Double.valueOf(request.getParameter("value")).doubleValue();
-
+
Realtime realtime = this.dataService.realtime(symbol).get(0);
Item item = this.itemService.cacheBySymbol(symbol, false);
-
+
Double currentValue = this.adjustmentValueService.getCurrentValue(symbol);
if (null == currentValue) {
resultMap.put("new_price", realtime.getClose());
@@ -426,7 +448,7 @@
}
double temp;
-
+
if (0 == type_int) {
temp = Arith.add(value_double, item.getPips());
// 调整量
@@ -448,7 +470,7 @@
} else {
resultMap.put("adjust_value", Arith.add(temp, currentValue));
}
-
+
AdjustmentValue delayValue = this.adjustmentValueService.getDelayValue(symbol);
if (delayValue != null) {
resultMap.put("delay_value", delayValue.getValue());
@@ -469,7 +491,7 @@
/**
* 调整
- *
+ *
* value 调整值
* second 延迟秒
*/
@@ -479,7 +501,7 @@
String value = request.getParameter("value");
String second = request.getParameter("second");
String username_login = request.getParameter("username_login");
-
+
String order_no_para = request.getParameter("order_no_para");
String name_para = request.getParameter("name_para");
String rolename_para = request.getParameter("rolename_para");
@@ -488,25 +510,25 @@
ModelAndView modelAndView = new ModelAndView();
modelAndView.setViewName("redirect:/" + action + "list.action");
-
+
try {
String error = this.verifAdjust(second, value);
if (!StringUtils.isNullOrEmpty(error)) {
throw new BusinessException(error);
}
-
+
double value_double = Double.valueOf(request.getParameter("value"));
double second_double = Double.valueOf(request.getParameter("second"));
-
+
Double currentValue = this.adjustmentValueService.getCurrentValue(symbol);
if (null == currentValue) {
Realtime realtime = this.dataService.realtime(symbol).get(0);
currentValue = realtime.getClose();
}
-
+
SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
-
+
String log = MessageFormat.format("ip:" + this.getIp() + ",管理员调整行情,币种:{0},原值:{1},调整值:{2},调整时间:{3}", symbol,
new BigDecimal(currentValue).toPlainString(), new BigDecimal(value_double).toPlainString(), second_double);
@@ -514,7 +536,7 @@
saveLog(sec, username_login, log);
ThreadUtils.sleep(1000);
-
+
modelAndView.addObject("order_no_para", order_no_para);
modelAndView.addObject("name_para", name_para);
modelAndView.addObject("rolename_para", rolename_para);
@@ -545,14 +567,42 @@
modelAndView.setViewName("redirect:/" + action + "list.action");
try {
-
+
ContractOrder order = this.contractOrderService.findByOrderNo(order_no);
if (order != null) {
CloseDelayThread lockDelayThread = new CloseDelayThread(order.getPartyId().toString(), order_no, this.contractOrderService);
Thread t = new Thread(lockDelayThread);
t.start();
}
-
+
+ } catch (BusinessException e) {
+ modelAndView.addObject("error", e.getMessage());
+ return modelAndView;
+ } catch (Throwable t) {
+ logger.error(" error ", t);
+ modelAndView.addObject("error", "[ERROR] " + t.getMessage());
+ return modelAndView;
+ }
+
+ modelAndView.addObject("message", "操作成功");
+ return modelAndView;
+ }
+
+ /**
+ * 平仓或撤单
+ */
+ @RequestMapping(action + "updateleve.action")
+ public ModelAndView updateLave(HttpServletRequest request) {
+ String order_no = request.getParameter("order_no");
+ String leve = request.getParameter("leve");
+
+ ModelAndView modelAndView = new ModelAndView();
+ modelAndView.setViewName("redirect:/" + action + "list.action");
+
+ try {
+ System.out.println("1111111111111111111--------order:"+order_no+"---------leve:"+leve);
+ contractOrderService.updateleve(order_no,leve);
+ System.out.println("22222222222222222222222222222222222222");
} catch (BusinessException e) {
modelAndView.addObject("error", e.getMessage());
return modelAndView;
@@ -578,7 +628,7 @@
}
protected String verif(String type, String value) {
-
+
if (StringUtils.isNullOrEmpty(type)) {
return "限制天数必填";
}
@@ -598,7 +648,7 @@
// if (Double.valueOf(value).doubleValue() < 0) {
// return "调整值不能小于0";
// }
-
+
return null;
}
@@ -620,7 +670,7 @@
// if (Double.valueOf(value).doubleValue() <= 0) {
// return "调整值不能小于等于0";
// }
-
+
return null;
}
@@ -633,11 +683,11 @@
private ContractOrderService contractOrderService;
public void run() {
-
+
try {
-
+
while (true) {
-
+
if (this.contractOrderService.lock(order_no)) {
this.contractOrderService.saveClose(partyId, order_no);
// 处理完退出
@@ -645,7 +695,7 @@
}
ThreadUtils.sleep(500);
}
-
+
} catch (Throwable t) {
logger.error("error:", t);
} finally {
--
Gitblit v1.9.3