package com.nq.config;
|
|
import com.nq.dao.RealTimeMapper;
|
import com.nq.dao.StockFuturesMapper;
|
import com.nq.dao.StockIndexMapper;
|
import com.nq.dao.StockMapper;
|
import com.nq.pojo.Stock;
|
import com.nq.pojo.StockFutures;
|
import com.nq.pojo.StockIndex;
|
import com.nq.utils.stock.BuyAndSellUtils;
|
import com.nq.utils.stock.sina.SinaStockApi;
|
|
import java.math.BigDecimal;
|
import java.util.List;
|
import java.util.concurrent.ArrayBlockingQueue;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class StockPoll {
|
@Resource
|
StockMapper stockMapper;
|
|
@Resource
|
RealTimeMapper realTimeMapper;
|
|
@Resource
|
StockFuturesMapper stockFuturesMapper;
|
|
@Resource
|
StockIndexMapper stockIndexMapper;
|
|
private ThreadPoolExecutor pool;
|
|
@PostConstruct
|
public void initPool() {
|
this.pool = new ThreadPoolExecutor(50, 70, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(240));
|
this.pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
|
}
|
|
public void test(String stockType, Integer stock_num, Integer stock_nums) {
|
List<Stock> stockCodes = this.stockMapper.findStockCode(stockType, stock_num, stock_nums);
|
System.out.println("stockCodes" + stockCodes.size() + "--stockCodes");
|
for (Stock stock : stockCodes) {
|
String stockGid = stock.getStockGid();
|
String sinaStock = SinaStockApi.getInStockDetail( stockGid);
|
String[] arrayOfString = sinaStock.split(",");
|
StockTask stockTask = new StockTask();
|
stockTask.splits((Object[])arrayOfString);
|
stockTask.stockGid(stockGid);
|
stockTask.averagePrice(Double.parseDouble("0"));
|
stockTask.StockPoll(this);
|
stockTask.RealTimeMapper(this.realTimeMapper);
|
|
this.pool.submit(stockTask);
|
}
|
}
|
|
//0-540
|
// public void z1() {
|
// test("sz", Integer.valueOf(0), Integer.valueOf(300));
|
// }
|
// public void z11() {
|
// test("sz", Integer.valueOf(300), Integer.valueOf(300));
|
// }
|
// public void z12() {
|
// test("sz", Integer.valueOf(600), Integer.valueOf(200));
|
// }
|
//
|
// //540-540
|
// public void z2() {
|
// test("sz", Integer.valueOf(800), Integer.valueOf(300));
|
// }
|
// public void z21() {
|
// test("sz", Integer.valueOf(1100), Integer.valueOf(300));
|
// }
|
// public void z22() {
|
// test("sz", Integer.valueOf(1400), Integer.valueOf(200));
|
// }
|
//
|
// //1080 - 540
|
// public void z3() {
|
// test("sz", Integer.valueOf(1600), Integer.valueOf(300));
|
// }
|
// public void z31() {
|
// test("sz", Integer.valueOf(1900), Integer.valueOf(300));
|
// }
|
// public void z32() {
|
// test("sz", Integer.valueOf(2200), Integer.valueOf(200));
|
// }
|
//
|
// //1620 - 539
|
// public void z4() {
|
// // test("sz", Integer.valueOf(2400), Integer.valueOf(200));
|
// }
|
// public void z41() {
|
// test("sz", Integer.valueOf(2600), Integer.valueOf(100));
|
// }
|
// public void z42() {
|
// test("sz", Integer.valueOf(2700), Integer.valueOf(100));
|
// }
|
//
|
// //0-484
|
// public void h1() {
|
// test("sh", Integer.valueOf(0), Integer.valueOf(300));
|
// }
|
// public void h11() {
|
// test("sh", Integer.valueOf(300), Integer.valueOf(300));
|
// }
|
// public void h12() {
|
// test("sh", Integer.valueOf(600), Integer.valueOf(100));
|
// }
|
//
|
// //484-484
|
// public void h2() {
|
// test("sh", Integer.valueOf(700), Integer.valueOf(300));
|
// }
|
// public void h21() {
|
// test("sh", Integer.valueOf(1000), Integer.valueOf(300));
|
// }
|
// public void h22() {
|
// test("sh", Integer.valueOf(1300), Integer.valueOf(100));
|
// }
|
//
|
// //968-485
|
// public void h3() {
|
// test("sh", Integer.valueOf(1400), Integer.valueOf(300));
|
// }
|
// public void h31() {
|
// test("sh", Integer.valueOf(1700), Integer.valueOf(300));
|
// }
|
// public void h32() {
|
// test("sh", Integer.valueOf(2000), Integer.valueOf(200));
|
// }
|
//
|
// //bj 0-121
|
// public void bj1() {
|
// test("bj", Integer.valueOf(0), Integer.valueOf(200));
|
// }
|
|
// public void qh1() {
|
// qhDataGrab("qh", Integer.valueOf(0), Integer.valueOf(540));
|
// }
|
|
|
}
|
