1
zj
2024-08-02 a7bd76dfd00efc7b03999c4559cf8554e34c19cb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package project.futures;
 
import java.util.List;
import java.util.Map;
 
import kernel.web.Page;
import project.data.model.Realtime;
 
public interface FuturesOrderService {
    /**
     * 开仓
     */
    public FuturesOrder saveOpen(FuturesOrder futuresOrder, String para_id);
 
    public void saveClose(FuturesOrder order, Realtime realtime);
 
    public void refreshCache(FuturesOrder order, double close);
 
    /**
     * 
     * @return
     */
    public List<FuturesOrder> cacheSubmitted();
 
    public FuturesOrder findByOrderNo(String order_no);
 
    public FuturesOrder cacheByOrderNo(String order_no);
 
    public List<Map<String, Object>> bulidData(List<FuturesOrder> list);
 
    public Map<String, Object> bulidOne(FuturesOrder order);
 
    /**
     * APP查询订单列表
     * 
     * @return
     */
    public Page getPaged(int pageNo, int pageSize, String partyId, String symbol, String type);
 
    /**
     * 今日订单
     * 
     * @param partyId
     * @return
     */
    public List<FuturesOrder> findByPartyIdAndToday(String partyId);
 
    /**
     * 修改订单场控
     * 
     * @param orderNo
     * @param porfitOrLoss
     */
    public String saveOrderPorfitOrLoss(String orderNo, String porfitOrLoss, String operaName);
 
    /**
     * 业绩交易奖励
     * 
     * @param partyId
     * @param volume  交易金额
     */
    public void saveRecomProfit(String partyId, double volume);
 
    /**
     * 异步推送计算推荐奖励
     * 
     * @param futuresOrder
     */
    public void pushAsynRecom(FuturesOrder futuresOrder);
 
    /**
     * 根据日期获取到当日的购买订单
     * 
     * @param pageNo
     * @param pageSize
     * @param date
     * @return
     */
    public Page pagedQueryByDate(int pageNo, int pageSize, String date);
 
    /**
     * 根据用户批量赎回订单
     * 
     * @param partyId
     */
    public void saveCloseAllByPartyId(String partyId);
 
    void updateCache(String orderNo, FuturesOrder byOrderNo);
}