@Service
@Scope("singleton")
public class TestService {

	@Resource(name="jdbcTemplate")
	private JdbcTemplate jdbcTemplate;
	
	class Request{
		String orderCode;
		String serialNo;
		CompletableFuture<Map<String,TaskorderDomain>> future;
	}
	LinkedBlockingDeque<Request> queue = new LinkedBlockingDeque<TestService.Request>();
	
	public Map<String,TaskorderDomain> queryById(String id) throws InterruptedException, ExecutionException {
		String uuid = UUID.randomUUID().toString();
		CompletableFuture<Map<String,TaskorderDomain>> future = new CompletableFuture<>();
		
		Request request = new Request();
		request.orderCode = id;
		request.serialNo = uuid;
		request.future = future;
		
		queue.add(request);
		return future.get();
	}
	
	@PostConstruct
	public void init() {
		ScheduledExecutorService service = Executors.newScheduledThreadPool(1);
		
		service.scheduleAtFixedRate(new Runnable() {
			@Override
			public void run() {
				int size = queue.size();
				if(size == 0) {
					return;
				}
				
				List<Map<String,String>> params = new ArrayList<>();
				
				ArrayList<Request> requests = new ArrayList<>();
				for(int i = 0; i < size; i++) {
					Request request = queue.poll();
					
					Map<String,String> map = new HashMap<>();
					map.put("orderCode", request.orderCode);
					map.put("serialNo", request.serialNo);
					
					params.add(map);
					
					requests.add(request);
				}
				
				try {
					List<Map<String,TaskorderDomain>> responses = queryById1("1");
				
					for(Request request : requests) {
						String serialNo = request.serialNo;
						for(Map<String,TaskorderDomain> response : responses) {
							String resSerialNo = response.get("serialNo").toString();
							if(serialNo.equals(resSerialNo)) {
								request.future.complete(response);
								break;
							}
						}
					}
				
				} catch(Exception e) {
					e.printStackTrace();
				}
				
			}
		}, 0, 10, TimeUnit.MILLISECONDS);
	}
	public List<Map<String,TaskorderDomain>> queryById1(String id) throws InterruptedException, ExecutionException {
		
		TaskorderDomain taskorderdomain = new TaskorderDomain();
		taskorderdomain.setTaskorderid(id);
		
		String sql="SELECT taskorderid, optsn, taskname, tasktext, tasktype, operator, tasktime, zzywid, zzbm, fileid, filename, remark, taskstat, creator, createorg, createrole, createtime FROM tb_aiops_taskorder WHERE taskorderid=:taskorderid";
		List<TaskorderDomain> list = jdbcTemplate.query(sql, taskorderdomain, TaskorderDomain.class);
		
		Map<String, TaskorderDomain> map = new HashMap<>();
		map.put("1", list.get(0));
		
		List<Map<String,TaskorderDomain>> li = new ArrayList<>();
		li.add(map);
		
		return li;
	}
	
	
}