1

zj

2025-08-12 f8c80b2848a6b2e3ef16db317147576f4a4e0714

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
90
91
92
93
94
95
96
97
98
package project.item.internal;
 
import java.util.ArrayList;
import java.util.List;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import kernel.exception.BusinessException;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.item.AdminItemService;
import project.item.ItemService;
import project.item.model.Item;
 
public class AdminItemServiceImpl implements AdminItemService {
    private Logger logger = LoggerFactory.getLogger(AdminItemServiceImpl.class);
    private ItemService itemService;
 
    public Page pagedQuery(int pageNo, int pageSize, String market, String symbol) {
        Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
        
        StringBuilder selectSqlBuilder=new StringBuilder("WHERE 1=1 ");
        ArrayList<Object> sqlParams=new ArrayList<Object>();
        if(null!=symbol && !(symbol=symbol.trim()).isEmpty()) {
            selectSqlBuilder.append("AND SYMBOL LIKE ? ");
            sqlParams.add("%"+symbol+"%");
        }
        
        selectSqlBuilder.append("LIMIT ?,?");
        sqlParams.add(page.getFirstElementNumber());
        sqlParams.add(pageSize);
        
        List<Item> list=ApplicationUtil.executeSelect(Item.class, selectSqlBuilder.toString(), sqlParams.toArray(new Object[sqlParams.size()]));
        page.setElements(list);
        return page;
    }
 
    @Override
    public Item get(String id) {
        List<Item> list=ApplicationUtil.executeSelect(Item.class, "WHERE UUID=?", new Object[] {id});
        return (null==list || list.isEmpty())?null:list.get(0);
    }
 
    @Override
    public void update(Item entity) {
        itemService.update(entity);
    }
 
    @Override
    public void save(Item entity) {
        Item item = itemService.cacheBySymbolData(entity.getSymbol_data());
        if (item != null) throw new BusinessException("交易品种已存在");
        itemService.add(entity);
    }
 
    public List<String> getSymbolsByMarket(String market) {
        return ApplicationUtil.executeDQL("SELECT SYMBOL FROM T_ITEM WHERE MARKET=?",new Object[] {market},String.class);
    }
 
    public Page pagedQuerySymbolsByMarket(int pageNo, int pageSize, String market) {
        Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
        
        StringBuilder selectSqlBuilder=new StringBuilder("SELECT SYMBOL FROM T_ITEM WHERE 1=1 ");
        ArrayList<Object> sqlParams=new ArrayList<Object>();
        if(null!=market && !(market=market.trim()).isEmpty()) {
            selectSqlBuilder.append("AND MARKET=? ");
            sqlParams.add(market);
        }
        
        selectSqlBuilder.append("LIMIT ?,?");
        sqlParams.add(page.getFirstElementNumber());
        sqlParams.add(pageSize);
        
        List<String> list=ApplicationUtil.executeDQL(selectSqlBuilder.toString(),sqlParams.toArray(new Object[sqlParams.size()]),String.class);
        page.setElements(list);
        return page;
    }
 
    public boolean checkSymbolExit(String symbol) {
        List<Item> list = ApplicationUtil.executeSelect(Item.class, "WHERE SYMBOL=?",new Object[] {symbol});
        return null!=list && !list.isEmpty() && null!=list.get(0);
    }
 
    public void setItemService(ItemService itemService) {
        this.itemService = itemService;
    }
 
    @Override
    public List<Item> getItems() {
        return ApplicationUtil.executeSelect(Item.class);
    }
    
    @Override
    public List<String> getSymbols() {
        return ApplicationUtil.executeDQL("SELECT SYMBOL FROM T_ITEM", String.class);
    }
}