package com.nq.utils.task.stock; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.json.JSONArray; import com.alibaba.fastjson2.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.gson.Gson; import com.nq.common.ServerResponse; import com.nq.dao.StockMapper; import com.nq.dao.UserMapper; import com.nq.dao.UserPendingorderMapper; import com.nq.dao.UserPositionMapper; import com.nq.enums.EConfigKey; import com.nq.enums.EStockType; import com.nq.enums.EUserAssets; import com.nq.pojo.*; import com.nq.pojo.reponse.kResponse; import com.nq.service.*; import com.nq.service.impl.StockServiceImpl; import com.nq.service.impl.UserServiceImpl; import com.nq.utils.ConverterUtil; import com.nq.utils.KeyUtils; import com.nq.utils.UserPointUtil; import com.nq.utils.http.HttpClientRequest; import com.nq.utils.redis.RedisKeyConstant; import com.nq.utils.redis.RedisKeyUtil; import com.nq.utils.redis.RedisShardedPoolUtils; import com.nq.utils.stock.GeneratePosition; import com.nq.vo.position.PositionProfitVO; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.client.RestTemplate; import javax.servlet.http.HttpServletRequest; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.math.BigDecimal; import java.math.RoundingMode; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.text.DecimalFormat; import java.util.*; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; @Component public class StockTask { @Autowired IStockService stockService; @Autowired StockMapper stockMapper; @Autowired IUserPositionService userPositionService; @Autowired UserPositionMapper userPositionMapper; @Autowired private UserPendingorderService userPendingorderService; @Autowired IMandatoryLiquidationService mandatoryLiquidationService; @Autowired IUserAssetsServices iUserAssetsServices; @Autowired IStockConfigServices iStockConfigServices; @Autowired IPriceServices priceServices; @Autowired UserMapper userMapper; private static final Logger log = LoggerFactory.getLogger(StockTask.class); private final AtomicBoolean syncINStockData = new AtomicBoolean(false); private final Lock syncINStockDataLock = new ReentrantLock(); /** * 同步系统所需要的股票 */ @Scheduled(cron = "0 0/1 * * * ?") public void syncINStockData() { if (syncINStockData.get()) { // 判断任务是否在处理中 return; } if (syncINStockDataLock.tryLock()) { try { syncINStockData.set(true); // 设置处理中标识为true loadAllStock(EStockType.ST); } finally { syncINStockDataLock.unlock(); syncINStockData.set(false); // 设置处理中标识为false } } } /** * 挂单 */ @Scheduled(cron = "0/10 * * * * ?") public void pendingOrder() { ReentrantLock lock = new ReentrantLock(); if (lock.tryLock()) { // 尝试获取锁 try { pending(); }catch (Exception e){ e.printStackTrace(); log.error("买入挂单定时任务报错：",e.getMessage()); } finally { lock.unlock(); // 释放锁 } } else { // 如果锁不可用，可以选择不执行或打印日志等 System.out.println("买入挂单定时任务 任务正在执行，跳过本次执行。"); } } /** * 挂单平仓 */ @Scheduled(cron = "0/10 * * * * ?") public void closeOrder() { ReentrantLock lock = new ReentrantLock(); if (lock.tryLock()) { // 尝试获取锁 try { closeOutOrder(); }catch (Exception e){ e.printStackTrace(); log.error("平仓挂单定时任务报错：",e.getMessage()); } finally { lock.unlock(); // 释放锁 } } else { // 如果锁不可用，可以选择不执行或打印日志等 System.out.println("平仓挂单定时任务 任务正在执行，跳过本次执行。"); } } public void closeOutOrder() { List list = userPendingorderService.list(new LambdaQueryWrapper<>(UserPendingorder.class) .eq(UserPendingorder::getPositionType, 1) .eq(UserPendingorder::getHangingOrderType,2)); if(CollectionUtil.isNotEmpty(list)){ list.forEach(f->{ //获取当前价格 //股票类型 现价 数据源的处理 BigDecimal nowPrice = BigDecimal.ZERO; if(f.getStockType().equals("ST")){ nowPrice = priceServices.getNowPrice(f.getStockCode()); }else{ nowPrice = new BigDecimal(RedisShardedPoolUtils.get(RedisKeyConstant.getRedisKey(f.getStockName()))); } if((f.getOrderDirection().equals("买涨") && nowPrice.compareTo(f.getSellOrderPrice()) >= 0) || (f.getOrderDirection().equals("买跌") && nowPrice.compareTo(f.getSellOrderPrice()) <= 0)){ closeStockTransferPositions(f); } }); } } private void closeStockTransferPositions(UserPendingorder f) { UserPosition userPosition = userPositionMapper.selectOne(new LambdaQueryWrapper<>(UserPosition.class) .eq(UserPosition::getPositionSn, f.getPositionSn()) .eq(UserPosition::getUserId, f.getUserId()) ); BigDecimal siitteBuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.SELL_HANDLING_CHARGE.getCode()).getCValue()); //部分平仓 if(f.getOrderNum() < userPosition.getOrderNum()){ //拆分订单 UserPosition position = ConverterUtil.convert(userPosition,UserPosition.class); position.setId(null); position.setPositionSn(KeyUtils.getUniqueKey()); //得到均价 double buyOrderPrice = position.getOrderTotalPrice().doubleValue() / position.getOrderNum().doubleValue() * position.getOrderLever(); position.setOrderNum(userPosition.getOrderNum()-f.getOrderNum()); BigDecimal positionBuyAmt = new BigDecimal(buyOrderPrice).multiply(new BigDecimal(position.getOrderNum())).divide(new BigDecimal(position.getOrderLever())); position.setOrderTotalPrice(positionBuyAmt); position.setBuyOrderPrice(new BigDecimal(buyOrderPrice)); position.setBuyOrderId(GeneratePosition.getPositionId()); //修改拆分订单手续费 BigDecimal BuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue()); BigDecimal buyPrice = position.getBuyOrderPrice().multiply(new BigDecimal(position.getOrderNum())); BigDecimal xsPrice = buyPrice.multiply(BuyFee); position.setOrderFee(xsPrice); userPositionMapper.insert(position); //得到均价 double orderPrice = userPosition.getOrderTotalPrice().doubleValue() / userPosition.getOrderNum().doubleValue() * position.getOrderLever(); //修改原订单 userPosition.setOrderNum(f.getOrderNum()); BigDecimal buyAmt = new BigDecimal(orderPrice).multiply(new BigDecimal(userPosition.getOrderNum())).divide(new BigDecimal(userPosition.getOrderLever())); userPosition.setOrderTotalPrice(buyAmt); userPosition.setOrderFee(userPosition.getOrderFee().subtract(position.getOrderFee())); userPositionMapper.updateById(userPosition); } getObjectServerResponse(userPosition, f.getSellOrderPrice(), siitteBuyFee, f.getStockType()); f.setPositionType(2); userPendingorderService.updateById(f); } public void getObjectServerResponse( UserPosition userPosition, BigDecimal nowPrice, BigDecimal siitteBuyFee, String stockType) { userPosition.setSellOrderId(GeneratePosition.getPositionId()); userPosition.setSellOrderPrice(nowPrice); userPosition.setSellOrderTime(new Date()); BigDecimal sellOrderTotel = nowPrice.multiply(new BigDecimal(userPosition.getOrderNum())); BigDecimal xsPrice = sellOrderTotel.multiply(siitteBuyFee); userPosition.setOrderFee(userPosition.getOrderFee().add(xsPrice)); userPositionMapper.updateById(userPosition); iUserAssetsServices.availablebalanceChange(stockType, userPosition.getUserId(), EUserAssets.CLOSE_POSITION_RETURN_SECURITY_DEPOSIT, userPosition.getOrderTotalPrice(), "", ""); iUserAssetsServices.availablebalanceChange(stockType, userPosition.getUserId(), EUserAssets.HANDLING_CHARGE, xsPrice, "", ""); PositionProfitVO profitVO = UserPointUtil.getPositionProfitVO(userPosition, priceServices.getNowPrice(userPosition.getStockCode())); iUserAssetsServices.availablebalanceChange(stockType, userPosition.getUserId(), EUserAssets.CLOSE_POSITION, profitVO.getAllProfitAndLose(), "", ""); } public void pending(){ List list = userPendingorderService.list(new LambdaQueryWrapper<>(UserPendingorder.class) .eq(UserPendingorder::getPositionType, 1) .eq(UserPendingorder::getHangingOrderType,1)); if(CollectionUtil.isNotEmpty(list)){ list.forEach(f->{ if(f.getStockGid().equals("ST")){ //获取当前价格 //股票类型 现价 数据源的处理 BigDecimal nowPrice = priceServices.getNowPrice(f.getStockCode()); if((f.getOrderDirection().equals("买涨") && f.getBuyOrderPrice().compareTo(nowPrice) >= 0) || (f.getOrderDirection().equals("买跌") && f.getBuyOrderPrice().compareTo(nowPrice) <= 0)){ stockTransferPositions(f); } }else{ String price = RedisShardedPoolUtils.get(RedisKeyConstant.getRedisKey(f.getStockName())); if((f.getOrderDirection().equals("买涨") && f.getBuyOrderPrice().compareTo(new BigDecimal(price)) >= 0) || (f.getOrderDirection().equals("买跌") && f.getBuyOrderPrice().compareTo(new BigDecimal(price)) <= 0)){ hjTransferPositions(f); } } }); } } public void hjTransferPositions(UserPendingorder userPendingorder){ UserPosition position = userPositionMapper.selectOne(new LambdaQueryWrapper<>(UserPosition.class) .eq(UserPosition::getUserId, userPendingorder.getUserId()) .eq(UserPosition::getStockCode, userPendingorder.getStockCode()) .isNull(UserPosition::getSellOrderId) ); User user = userMapper.selectById(userPendingorder.getUserId()); BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue()) ; BigDecimal orderFree = siteSettingBuyFee.multiply(userPendingorder.getOrderTotalPrice()); UserPosition userPosition = ConverterUtil.convert(userPendingorder, UserPosition.class); if(ObjectUtil.isEmpty(position)){ userPosition.setPositionType(user.getAccountType()); userPosition.setId(null); userPendingorder.setPositionType(0); userPendingorderService.updateById(userPendingorder); userPositionMapper.insert(userPosition); iUserAssetsServices.availablebalanceChange("USD", user.getId(), EUserAssets.HANDLING_CHARGE, orderFree, "", ""); }else{ position.setOrderNum(position.getOrderNum()+userPosition.getOrderNum()); position.setOrderTotalPrice(position.getOrderTotalPrice().add(userPosition.getOrderTotalPrice())); position.setOrderFee(position.getOrderFee().add(orderFree)); position.setBuyOrderPrice(position.getBuyOrderPrice()); position.setAllProfitAndLose(position.getAllProfitAndLose().add(orderFree)); userPositionMapper.updateById(position); userPendingorder.setPositionType(0); userPendingorderService.updateById(userPendingorder); iUserAssetsServices.availablebalanceChange("USD", user.getId(), EUserAssets.HANDLING_CHARGE, orderFree, "", ""); } } public void stockTransferPositions(UserPendingorder userPendingorder){ UserPosition position = userPositionMapper.selectOne(new LambdaQueryWrapper<>(UserPosition.class) .eq(UserPosition::getUserId, userPendingorder.getUserId()) .eq(UserPosition::getStockCode, userPendingorder.getStockCode()) .isNull(UserPosition::getSellOrderId) ); // 手续费率 BigDecimal siteSettingBuyFee = new BigDecimal(iStockConfigServices.queryByKey(EConfigKey.BUY_HANDLING_CHARGE.getCode()).getCValue()) ; BigDecimal orderFree = siteSettingBuyFee.multiply(userPendingorder.getOrderTotalPrice()); User user = userMapper.selectById(userPendingorder.getUserId()); UserPosition userPosition = ConverterUtil.convert(userPendingorder, UserPosition.class); if(ObjectUtil.isEmpty(position)){ userPosition.setPositionType(user.getAccountType()); userPosition.setId(null); userPendingorder.setPositionType(0); userPendingorderService.updateById(userPendingorder); userPositionMapper.insert(userPosition); //挂单成功扣除手续费 iUserAssetsServices.availablebalanceChange("ST", user.getId(), EUserAssets.HANDLING_CHARGE, orderFree, "", ""); }else{ position.setOrderNum(position.getOrderNum()+userPosition.getOrderNum()); position.setOrderTotalPrice(position.getOrderTotalPrice().add(userPosition.getOrderTotalPrice())); position.setOrderFee(position.getOrderFee().add(orderFree)); double divide = position.getOrderTotalPrice().doubleValue() / position.getOrderNum(); position.setBuyOrderPrice(new BigDecimal(divide*position.getOrderLever())); position.setAllProfitAndLose(position.getAllProfitAndLose().add(orderFree)); userPositionMapper.updateById(position); userPendingorder.setPositionType(0); userPendingorderService.updateById(userPendingorder); //挂单成功扣除手续费 iUserAssetsServices.availablebalanceChange("ST", user.getId(), EUserAssets.HANDLING_CHARGE, orderFree, "", ""); } } //最新价格url private static final String PRICE_URL = "https://quote.alltick.io/quote-b-api/trade-tick?token=794ea65dc03c5af582cddec476fbb0d7-c-app&query="; //k线url private static final String K_URL = "https://quote.alltick.io/quote-b-api/kline?token=794ea65dc03c5af582cddec476fbb0d7-c-app&query="; public String getPriceData() { // 创建查询数据 JSONObject data = new JSONObject(); // 用于存储符号的列表 JSONArray symbolList = new JSONArray(); // 需要查询的符号列表（按你的要求，这里符号从 ["857.HK", "UNH.US"] 开始） String[] symbols = {"GOLD", "USOIL"}; // 遍历符号列表，构建 JSON 对象 for (String symbol : symbols) { JSONObject symbolObject = new JSONObject(); symbolObject.put("code", symbol); symbolList.put(symbolObject); } // 将 symbol_list 放入 data 对象中 data.put("symbol_list", symbolList); // 创建查询请求对象 JSONObject query = new JSONObject(); query.put("trace", generateTraceCode()); // 假设 generateTraceCode() 是生成唯一追踪代码的方法 query.put("data", data); // 返回构建的查询对象 return buildUrlWithQuery(query); } // 生成唯一追踪码 public static String generateTraceCode() { // 获取当前时间戳 long timestamp = System.currentTimeMillis(); // 生成唯一的 UUID String uuid = UUID.randomUUID().toString(); // 组合时间戳和 UUID，保证唯一性 return uuid + "-" + timestamp; } @Scheduled(cron = "0/2 * * * * ?") // 每6秒执行一次 public void sync() throws InterruptedException { ReentrantLock lock = new ReentrantLock(); if (lock.tryLock()) { // 尝试获取锁 try { gold(); Thread.sleep(2000); getKDate(); } finally { lock.unlock(); // 释放锁 } } else { // 如果锁不可用，可以选择不执行或打印日志等 System.out.println("任务正在执行，跳过本次执行。"); } } public void gold() { try { String url = PRICE_URL+getPriceData(); URL obj = new URL(url); HttpURLConnection con = (HttpURLConnection) obj.openConnection(); con.setRequestMethod("GET"); int responseCode = con.getResponseCode(); BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream())); String inputLine; StringBuffer response = new StringBuffer(); while ((inputLine = in.readLine()) != null) { response.append(inputLine); } in.close(); if(responseCode == 200){ // 创建 ObjectMapper 对象 ObjectMapper objectMapper = new ObjectMapper(); // 解析 JSON 字符串 JsonNode rootNode = objectMapper.readTree(response.toString()); // 获取 "data" 节点下的 "tick_list" 数组 JsonNode tickList = rootNode.path("data").path("tick_list"); // 遍历 tick_list 数组并提取 code 和 price for (JsonNode tick : tickList) { String code = tick.path("code").asText().equals("GOLD") ? "XAUUSD" : tick.path("code").asText(); String price = tick.path("price").asText(); RedisShardedPoolUtils.set(RedisKeyConstant.getRedisKey(code), price); } }else{ log.info("黄金原油获实时价格定时任务------没有接收到数据:"+response); } } catch (Exception e) { e.printStackTrace(); } } public static String buildUrlWithQuery(JSONObject jsonObject) { try { // 将 JSON 对象转换为字符串 String jsonString = jsonObject.toString(); // 使用 URLEncoder 编码 JSON 字符串 String encodedJson = URLEncoder.encode(jsonString, "UTF-8"); return encodedJson; } catch (UnsupportedEncodingException e) { e.printStackTrace(); return null; } } public void getKDate() throws InterruptedException { // 创建Map对象 Map map = new HashMap<>(); // 写死键值对 map.put("d", 8); map.put("w", 9); map.put("m", 10); map.put("1", 1); map.put("5", 2); map.put("30", 4); for (Map.Entry entry : map.entrySet()) { String gold = getResp(K_URL + getKQueryData(entry.getValue(), "XAUUSD")); if(StringUtils.isNotEmpty(gold)){ if(entry.getKey().equals("d")){ priceLimit(gold,"XAUUSD"); } RedisShardedPoolUtils.set("k_gold_"+entry.getKey(), gold); } Thread.sleep(2000); String c = getResp(K_URL+getKQueryData(entry.getValue(),"USOIL")); if(StringUtils.isNotEmpty(c)){ if(entry.getKey().equals("d")) { priceLimit(c, "USOIL"); } RedisShardedPoolUtils.set("k_crude_oil_"+entry.getKey(), c); } Thread.sleep(2000); } } @lombok.Data class kData { long t; String c; String o; String h; String l; String v; String vo; } public void priceLimit(String data,String key){ List kDataList = new ArrayList<>(); // 使用 Gson 解析 JSON 字符串 Gson gson = new Gson(); kResponse kResponse = gson.fromJson(data, kResponse.class); // 打印 kline_list 的内容 for (kResponse.KlineData item : kResponse.getData().getKlineList()) { kData kData = new kData(); kData.setT(item.getTimestamp()); kData.setC(item.getClose_price()); kData.setO(item.getOpen_price()); kData.setH(item.getHigh_price()); kData.setL(item.getLow_price()); kData.setV(item.getVolume()); kData.setVo(item.getTurnover()); kDataList.add(kData); } double oneC = Double.valueOf(kDataList.get(kDataList.size() - 1).getC()); double twoC = Double.valueOf(kDataList.get(kDataList.size() - 2).getC()); String h = String.valueOf(((oneC - twoC) / oneC * 100)); BigDecimal bd = new BigDecimal(h); bd = bd.setScale(2, RoundingMode.DOWN); // RoundingMode.DOWN 表示截断而非四舍五入 RedisShardedPoolUtils.set(key+"_H",bd.toString()); RedisShardedPoolUtils.set(key+"_H",bd.toString()); } public String getResp(String url){ try { URL obj = new URL(url); HttpURLConnection con = (HttpURLConnection) obj.openConnection(); con.setRequestMethod("GET"); int responseCode = con.getResponseCode(); BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream())); String inputLine; StringBuffer response = new StringBuffer(); while ((inputLine = in.readLine()) != null) { response.append(inputLine); } in.close(); if(responseCode == 200){ return response.toString(); } }catch (Exception e){ e.printStackTrace(); log.error("k线请求错误！", e.getMessage()); } return null; } //k线请求组装数据 public String getKQueryData(Integer k_data,String code){ JSONObject queryData = new JSONObject(); queryData.put("trace", generateTraceCode()); JSONObject data = new JSONObject(); data.put("code", code);//产品code /** * k线类型 * 1、1是1分钟K，2是5分钟K，3是15分钟K，4是30分钟K，5是小时K，6是2小时K(股票不支持2小时)，7是4小时K(股票不支持4小时)，8是日K，9是周K，10是月K （注：股票不支持2小时K、4小时K） * 2、最短的k线只支持1分钟 * 3、查询昨日收盘价，kline_type 传8 */ data.put("kline_type", k_data); /** * 从指定时间往前查询K线 * 1、传0表示从当前最新的交易日往前查k线 * 2、指定时间请传时间戳，传时间戳表示从该时间戳往前查k线 * 3、只有外汇贵金属加密货币支持传时间戳，股票类的code不支持 */ data.put("kline_timestamp_end", 0); /** * 1、表示查询多少根K线，每次最大请求1000根，可根据时间戳循环往前请求 * 2、通过该字段可查询昨日收盘价，kline_type 传8，query_kline_num传2，返回2根k线数据中，时间戳较小的数据是昨日收盘价 */ data.put("query_kline_num", 200); /* 复权类型,对于股票类的code才有效，例如：0:除权,1:前复权，目前仅支持0 */ data.put("adjust_type", 0); queryData.put("data", data); return buildUrlWithQuery(queryData); } /** * 加载所有股票数据 */ public void loadAllStock(EStockType eStockType) { log.info("同步股票 数据 {}", eStockType.getCode()); List list = new ArrayList<>(); int totleStock = 1; int page = 0; try { while (totleStock > list.size()) { try { String result = HttpClientRequest.doGet(eStockType.stockUrl + "list?country_id=" + eStockType.getContryId() + "&size=1000&page=" + page + "&key=" + eStockType.stockKey); ReponseBase reponseBase = new Gson().fromJson(result, ReponseBase.class); list.addAll(reponseBase.getData()); page++; totleStock = reponseBase.getTotal(); } catch (Exception e) { e.printStackTrace(); break; } } for (DataStockBean o : list) { Stock stock = stockMapper.findStockByCode(o.getId()); if (stock == null) { stock = new Stock(); stock.setStockCode(o.getId()); stock.setStockName(o.getName()); stock.setStockType(eStockType.getCode()); if (o.getType() == null) { stock.setStockGid(eStockType.getCode()); } else { stock.setStockGid(o.getType()); } stock.setStockSpell(o.getSymbol()); stock.setIsLock(0); stock.setIsShow(0); stock.setDataBase(0); stock.setAddTime(new Date()); stockMapper.insert1(stock); } else { stock.setStockCode(o.getId()); stock.setStockName(o.getName()); stock.setStockType(eStockType.getCode()); if (o.getType() == null) { stock.setStockGid(eStockType.getCode()); } else { stock.setStockGid(o.getType()); } stock.setStockSpell(o.getSymbol()); stock.setIsLock(0); stock.setIsShow(0); stock.setDataBase(0); stock.setAddTime(new Date()); stockMapper.updateById(stock); } RedisKeyUtil.setCaCheKeyBaseStock(eStockType, o); } log.info("同步股票 数据 成功 {} 总共同步数据 {}", eStockType.getCode(), list.size()); } catch ( Exception e) { log.error("同步出错", e); } } private final AtomicBoolean stockConstraint = new AtomicBoolean(false); /** * 强制平仓 */ // @Scheduled(cron = "0/1 * * * * ?") // public void stockConstraint() { // if (stockConstraint.get()) { // 判断任务是否在处理中 // return; // } // if (stockConstraintLock.tryLock()) { // try { // stockConstraint.set(true); // 设置处理中标识为true // List userPositions = userPositionMapper.selectList(new LambdaQueryWrapper().isNull(UserPosition::getSellOrderId)); // if (CollectionUtils.isNotEmpty(userPositions)) { // userPositionService.stockConstraint(userPositions); // } // } catch (Exception e) { // e.printStackTrace(); // log.error("强制平仓任务错误：" + e.getMessage()); // } finally { // stockConstraintLock.unlock(); // stockConstraint.set(false); // 设置处理中标识为false // } // } else { // log.info("强制平仓任务--------->上次任务还未执行完成，本次任务忽略"); // } // } }