1

zj

2024-08-09 defbbc81145072e73cb51c6feb9d83936d9caa97

 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,9 +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;
@@ -28,6 +33,7 @@
import project.item.ItemService;
import project.item.model.Item;
import project.redis.RedisHandler;
import project.wallet.Wallet;

/**
 * 交割合约单
@@ -141,6 +147,39 @@
        return modelAndView;
    }

    @RequestMapping(action + "saveRemark.action")
    public ModelAndView saveRemark(HttpServletRequest request) {
        String orderNo = request.getParameter("orderNo");
        String remark = request.getParameter("remark");
        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("futures_order_list");

        try {
            FuturesOrder byOrderNo = futuresOrderService.findByOrderNo(orderNo);

            if(null != byOrderNo){
                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);
                }
            }
        } 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;
        }

        return modelAndView;
    }

    /**
     * 获取 交割合约单 列表
     * <p>