Форум программистов [Powered by Invision Power Board]

Код

    public void run() {
        try {

            while (true) {


                Thread.sleep(DELAY * 1000);

                    if ((chartList == null) || (chartList.size() == 0)) {
                        break;
                    }
                    final ChartBar bar = chartList.getLast();

                    final Date d = dateFormat.parse(bar.getDate() + " " + bar.getTime() + ":00");

                    final List<String[]> list = getData(MainFrame.getPair(), MainFrame.getInterval(), d.getTime());

                    if (list.size() > 0) {

                        boolean delete_at_end = false;

                        if(bar.getTime().equals(list.get(0)[1])) {
                            chartList.removeLast();
                            delete_at_end = true;
                            if(list.size() > 1) chartList.remove(0, list.size() - 1);
                        } else {
                            chartList.remove(0, list.size());
                        }
                        
                        chartList.add(list, 0);
                        
                        int fromIndex = chartList.size() - list.size();
                        
                        IndicatorsList.getInstance().refresh(IndicatorsList.ALL, (delete_at_end)?AbstractIndicator.AT_END:AbstractIndicator.AT_BEGIN, fromIndex);

                        if (MainFrame.getShiftLeft() == 0) {
                            MainFrame.getInstance().repaintAll();
                        } else {
                            int shiftLeft = MainFrame.getShiftLeft();
                            shiftLeft = MainFrame.setShiftLeft(shiftLeft + list.size());
                            if (shiftLeft > chartList.size() - MainFrame.timebarCount) {
                                shiftLeft = chartList.size() - MainFrame.timebarCount;
                                MainFrame.setShiftLeft(shiftLeft);
                                MainFrame.getInstance().repaintAll();
                            }
                        }
                    }
            }
        } catch (final InterruptedException ex) {
            DataManager.currentThread().interrupt();
            if(DEBUG_MESS) ex.printStackTrace();
        } catch (final ParseException ex) {
            if(DEBUG_MESS) ex.printStackTrace();
        } catch (final Exception ex) {
            if(DEBUG_MESS) ex.printStackTrace();
        }
    }

    private static List<String[]> doPost(final String pair,
            final int interval, final long time) {

        LinkedList<String[]> list = new LinkedList<String[]>();
        PrintWriter out = null;
        HttpURLConnection connection = null;

        try {

            final String urlAddr = MainFrame.dataHost + MainFrame.dataPath;

            final URL url = new URL(urlAddr);

            connection = (HttpURLConnection) url.openConnection();

            connection.setDoOutput(true);
            connection.setDoInput(true);
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            connection.setRequestMethod("GET");


            out = new PrintWriter(connection.getOutputStream());

            out.print("pair=");
            out.print(pair);
            out.print("&timeFrame=");
            out.print(interval);
            out.print("&time=");
            out.print(time);
            out.flush();

            Scanner in;
            try {
                in = new Scanner(connection.getInputStream());
            } catch (final IOException ex) {
                if (!(connection instanceof HttpURLConnection)) {
                    throw ex;
                }
                final InputStream err = ((HttpURLConnection) connection).getErrorStream();
                if (err == null) {
                    throw ex;
                }
                in = new Scanner(err);
                if (DEBUG_MESS) {
                    ex.printStackTrace();
                }
                MainFrame.showAlert(MainFrame.ALERT_CONN_ERR);
            }

            
            while (in.hasNextLine()) {
            
                final String s = in.nextLine();
                final String[] arr = s.split(delimiter);

                if (arr.length == 9) {
                    list.add(arr);
                }
            }

        } catch (final FileNotFoundException ex) {
            if(DEBUG_MESS) ex.printStackTrace();
        } catch (final IOException ex) {
            if(DEBUG_MESS) ex.printStackTrace();

        } catch (final java.security.AccessControlException ex) {
            if(DEBUG_MESS) ex.printStackTrace();
            MainFrame.showAlert(MainFrame.ALERT_ACCESS);
        } catch (final Exception ex) {
            if(DEBUG_MESS) ex.printStackTrace();
        } finally {
            if(out != null) out.close();
            if(connection != null) connection.disconnect();
        }

        if (list.size() != 0) {
            MainFrame.hideAlert();
        } else if(list.size() == 0) {
            MainFrame.showAlert(MainFrame.ALERT_SERVER_ERR);
        }

        return list;
    }

    public static synchronized List<String[]> getData(final String pair,
            final int interval, final long time) {

        return doPost(pair, interval, time);
    }