Как вызвать Callback() с фрагмента для Retrofit?

Question

[newdancer]

Как вызвать Callback() с фрагмента для вызова интерфейса вызова Retrofit?
В фрагменте в onCreateView прописал:

// Создаем адаптер с базовым адресом
        RestAdapter restAdapter = new RestAdapter.Builder().setEndpoint(SOURCE).build();
        // Создаём сервис
        API api = restAdapter.create(API.class);
        api.getCinema(API_TOKEN, new Callback() {
            @Override
            public void success(KinoModel kinoModel, Response response) {
                // Получаем ввиде json и конвертируем
                cinemas.add(new Cinema(kinoModel.getTitleRU()));
            }
            @Override
            public void failure(RetrofitError error) {
                Log.d("myLogs", "Failed!!!");
            }
        });

сам интерфейс выглядит так:

public interface API
{
    @GET("/serial_updates.json")
    void getCinema(@Query("api_token") String api_token, Callback response);
}

выдает ошибку на Calback():

is not abstract and does not override abstract method success(Object,Response) in Callback

Answer 1

[Денис Загаевский]

Callback - это дженерик. Вы его не параметризовали
new Callback<KinoModel>(){ ... }

Comments

[newdancer]

А еще подскажите при вот таком виде json
{"current_page":1,"updates":[{"title_ru":"Американский герой","title_en":"American Hero","kinopoisk_id":915528,"token":"830c4e15d04edcd2","type":"movie","camrip":false,"iframe_url":"moonwalk.cc/video/830c4e15d04edcd2/iframe","translator":"datynet","translator_id":73,"added_at":"2016-02-24 18:01:01","category":null},

Если мне нужно значение поля title_ru, то необходимо сначала через модель получить массив updates? так?

[Денис Загаевский]

newdancer: да.

[newdancer]

Denis Zagayevskiy: в каком формате получает retrofit результат когда массив updates???
попробовал сделать так
@Expose
private List updates;
public List getUpdates()
{
return updates;
}
public class Upd {
@SerializedName("title_ru")
private String title_ru;
}
результат получается в виде кода типа: название пакета$Upd@85d2ea1

[Денис Загаевский]

newdancer: как вы его используете?

[newdancer]

Denis Zagayevskiy: а пока просто пытался вывести в лог
api.getCinema(API_TOKEN, new Callback() {
@Override
public void success(KinoModel kinoModel, Response response) {
// Получаем ввиде json и конвертируем
Log.d("myLogs", "s="+kinoModel.getUpdates().get(0));
}
@Override
public void failure(RetrofitError error) {
Log.d("myLogs", "Failed!!!");
}
});
результат получился такой s=net.kinomovies.onlinemovielibrary.KinoModel$Upd@85d2ea1

[Денис Загаевский]

newdancer: вот, я сегодня уже отвечал на такой вопрос: Как правильно вытаскивать класс из ArrayList?

[Денис Загаевский]

newdancer: в вашем случае достаточно создать метод getTitleRu() и вызывать его в цепочке kinoModel.getUpdates().get(0).getTitleRu(). И оформляйте код в тег <code> </code>, пожалуйста.

[newdancer]

Denis Zagayevskiy: спасибо! все получилось!

[newdancer]

Denis Zagayevskiy: Попытался добавить еще возможность парсить с другого файла json c другой структурой и все завершается методом failure.

RestAdapter restAdapter2 = new RestAdapter.Builder().setEndpoint(SOURCE_KP).build();
APIKp apiKp= restAdapter2.create(APIKp.class);

        apiKp.getKp(film_ID, new Callback<KinoModelKp>() {
            @Override
            public void success(KinoModelKp kinoModelKp, Response response) {

                Log.d("myLogs", "s=" + String.valueOf(kinoModelKp.getKPYear()));
            }

            @Override
            public void failure(RetrofitError error) { Log.d("myLogs", "KP! Failed!!!"); }
        });

Сама структура KinoModelKp выглядит так:

public class KinoModelKp
{
    @Expose
    private List<KpRatUpd> ratingData;

    @Expose
    private int year;

    public List<KpRatUpd> getRatUpdates() {return ratingData;}

    public int getKPYear() {
        return year;
    }

    public class KpRatUpd {
        @SerializedName("rating")
        private float rating;
        @SerializedName("ratingVoteCount")
        private int ratingVoteCount;
        @SerializedName("ratingIMDb")
        private float ratingIMDb;
        @SerializedName("ratingIMDbVoteCount")
        private int ratingIMDbVoteCount;

        public float getRatKP() {
            return rating;
        }

        public int getRatKPVote() {
            return ratingVoteCount;
        }

        public float getRatImdb() {
            return ratingIMDb;
        }

        public int getRatImdbVote() {
            return ratingIMDbVoteCount;
        }
    }
}

вот результат json
http://api.kinopoisk.cf/getFilm?filmID=840623
то не так сделал?

[Денис Загаевский]

Посмотрите, что в RetrofitError.

[newdancer]

Denis Zagayevskiy: при таком способе
error.getResponse().toString()
получил retrofit.client.Response@27668984
или не так надо смотреть?

[Денис Загаевский]

newdancer: а что, других методов, кроме toString(), там нет?

[newdancer]

Denis Zagayevskiy: error.getResponse().getReason() выдает OK
error.getResponse().getUrl() выдал http://api.kinopoisk.cf/getFilm?filmID=840623 т.е. сформировалось все нормально.
Вариантов там еще много. какой посмотреть?

[Денис Загаевский]

newdancer: ну вообще полезно дебаггер освоить и смотреть весь объект целиком, может что и наведёт на правильную мысль.
Но я открыл ваш JSON на компе с нормальным форматированием и, по-моему, ваша проблема сейчас довольно проста.
private List<KpRatUpd> ratingData;
и

"ratingData": {
"ratingVoteCount": 47,
"ratingAwait": "92%",
"ratingAwaitCount": "110",
"ratingIMDb": "6.9",
"ratingIMDbVoteCount": "816",
"ratingFilmCritics": "33%",
"ratingFilmCriticsVoteCount": "42"
}

ИМХО, как-то не сочетаются.

[newdancer]

Denis Zagayevskiy: эти данные я так понимаю нужно получать через массив, а не через List?
Вот блин. И из-за этого я и year получить не могу.

[newdancer]

Denis Zagayevskiy: спасибо! Все получилось. Только как использовать его в методах?
к примеру у меня метод

public String getKP (int film_ID)
    {
        apiKp.getKp(film_ID, new Callback<KinoModelKp>() {
            @Override
            public void success(KinoModelKp kinoModelKp, Response response) {
                rat = "KP=" + String.valueOf(kinoModelKp.ratingData.rating) + "(" + kinoModelKp.ratingData.ratingVoteCount + "); IMDB=" + String.valueOf(kinoModelKp.ratingData.ratingIMDb) + "(" + kinoModelKp.ratingData.ratingIMDbVoteCount + ")";
                Log.d("myLogs", "rat1=" + rat);
            }

            @Override
            public void failure(RetrofitError error) {
                Log.d("myLogs", "KP! Failed!!! = " + error.getResponse());
            }
        });

        Log.d("myLogs", "rat2=" + rat);
        return rat;
    }

изначально переменная String rat="";
Так вот при выполнении такого метода из переменная rat="". Как задержать выполнение return пока не отработает retrofit?

[Денис Загаевский]

newdancer: никак, это называется асинхронный вызов. Результат приходит в коллбек, который вы передаёте. Изучайте многопоточность.

[newdancer]

Denis Zagayevskiy: а если перевести на синхронный? и второй тогда делать синхронным?

[Денис Загаевский]

newdancer: тогда вам придётся всё это вместе оборачивать в асинхронный вызов, используя другие, не ретрофитовые абстракции. Дело в том, что в сеть вы можете ходить только не из главного потока, иначе получите NetworkOnMainThreadException.

[newdancer]

Denis Zagayevskiy: попробовал сделать через синхронный вызов

public void getCinemaFrag()
    {
        // Создаем адаптер с базовым адресом
        RestAdapter restAdapter = new RestAdapter.Builder().setEndpoint(SOURCE_MOON).build();
        RestAdapter restAdapter2 = new RestAdapter.Builder().setEndpoint(SOURCE_KP).build();
        // Создаём сервисы API
        apiMoon = restAdapter.create(APIMoon.class);
        apiKp= restAdapter2.create(APIKp.class);

        Thread t = new Thread(new Runnable(){
            @Override
            public void run(){
                mProgressBar.setVisibility(View.VISIBLE);
                KinoModel kinoModel = apiMoon.getCinema(API_TOKEN);
                // Получаем ввиде json и конвертируем
                cinemas.clear();
                for (int k = 0; k < kinoModel.getNumUpdates(); k++) {
                    film_ID = kinoModel.getUpdates().get(k).getKP();

                    if (film_ID != 0) {
                        KinoModelKp kinoModelKp = apiKp.getKp(film_ID);
                        cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "http://st.kp.yandex.net/images/film_big/"+String.valueOf(film_ID)+".jpg", kinoModelKp.getKPYear()));
                        //http://st.kp.yandex.net/images/film_big/"+film_ID+".jpg
                    } else {
                        cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "", 0));
                    }
                }

            }
        });
        t.start();

        try {
            t.join();
            mProgressBar.setVisibility(View.GONE);
            cinemaAdapter = new CinemaAdapter(getActivity(), cinemas);
            cinemaAdapter.notifyDataSetChanged();
            // настраиваем список
            lvMain.setAdapter(cinemaAdapter);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

метод getCinemaFrag() вызываю из onCreateView при этом пока грузятся данные висит интерфес. то не так сделал?

[Денис Загаевский]

newdancer: В андроиде методы жизненного цикла (к которым относится onCreateView) выполняются в MainThread (UiThread), ещё можно почитать здесь. Вызвав t.join(), вы явно сказали текущему потоку дождаться завершения операций с сетью, и, соответственно, главный поток "завис".

Вам надо адаптер хранить как поле класса и закидывать в него данные, когда они будут готовы, используя коллбеки ретрофита.

[newdancer]

Denis Zagayevskiy: с адаптером так и делаю. Я так понял что сам класс api должен выглядеть так. возвращать response

public interface APIKp
{
    @GET("/getFilm")
    Response getKp(@Query("filmID") int film_ID);
}

Только как сюда прилепить CallBack?

[Денис Загаевский]

newdancer: ну у вас же с самого начала был этот коллбек, ещё в вопросе. И вам советовали перейти на Retrofit 2. Там другой апи немного.

[newdancer]

Denis Zagayevskiy: переделал. как в Retrofit2 узнать когда данные со второго апи получены?

[Денис Загаевский]

newdancer: Здесь square.github.io/retrofit были? Какие методы есть у Call смотрели? (https://github.com/square/retrofit/blob/master/ret...

[newdancer]

Denis Zagayevskiy: нашел как но где то ошибка:

public void getCinemaFrag()
    {
        // Создаем адаптер с базовым адресом
        Retrofit.Builder builder = new Retrofit.Builder();
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(SOURCE_MOON)
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        Retrofit retrofit2 = new Retrofit.Builder()
                .baseUrl(SOURCE_KP)
                .addConverterFactory(GsonConverterFactory.create())
                .build();

        // Создаём сервисы API
        apiMoon = retrofit.create(APIMoon.class);
        apiKp= retrofit2.create(APIKp.class);

        Thread t = new Thread(new Runnable(){
            @Override
            public void run(){
                mProgressBar.setVisibility(View.VISIBLE);
                // Получаем данные
                cinemas.clear();
                Call<KinoModel> call = apiMoon.getCinema(API_TOKEN);
                call.enqueue(new Callback<KinoModel>() {
                    @Override
                    public void onResponse(Call<KinoModel> call, Response<KinoModel> response) {
                        try {
                                kinoModel = call.execute().body();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                        if(response.isSuccess())
                        {
                            for (int k = 0; k < kinoModel.getNumUpdates(); k++) {
                                film_ID = kinoModel.getUpdates().get(k).getKP();
                                if (film_ID != 0) {
                                    Call<KinoModelKp> call2 = apiKp.getKp(film_ID);
                                    try {
                                        kinoModelKp = call2.execute().body();
                                    } catch (IOException e) {
                                        e.printStackTrace();
                                    }
                                    if (film_ID != 0) {
                                        cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                                kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                                kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                                kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "http://st.kp.yandex.net/images/" + kinoModelKp.getPoster(), kinoModelKp.getKPYear(), kinoModelKp.getDescription()));
                                        //http://st.kp.yandex.net/images/film_big/"+film_ID+".jpg
                                    } else {
                                        cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                                kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                                kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                                kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "", 0, "описание отсутствует..."));
                                    }
                                    call2.enqueue(new Callback<KinoModelKp>() {
                                        @Override
                                        public void onResponse(Call<KinoModelKp> call2, Response<KinoModelKp> response) {
                                            if (response.isSuccess()) {
                                                Log.d("myLogs", "OK!");
                                                mProgressBar.setVisibility(View.GONE);
                                                cinemaAdapter = new CinemaAdapter(getActivity(), cinemas);
                                                cinemaAdapter.notifyDataSetChanged();
                                                // настраиваем список
                                                lvMain.setAdapter(cinemaAdapter);
                                            }
                                        }

                                        @Override
                                        public void onFailure(Call<KinoModelKp> call, Throwable t) {
                                            Log.d("myLogs", "NOT OK!");
                                        }
                                    });
                                }
                            }
                        }
                    }

                    @Override
                    public void onFailure(Call<KinoModel> call, Throwable t) {
                        Log.d("myLogs", "NOT OK!");
                    }
                });
            }
        });
        t.start();
    }
}

в это строке kinoModel = call.execute().body();
выдает ошибку java.lang.IllegalStateException: Already executed.
В чем ошибся?

[Денис Загаевский]

newdancer: OMG.
Ответьте на три вопроса:
1. Зачем вам Thread;
2. Что делает метод enqueue;
3. Что делает метод execute.

[newdancer]

Denis Zagayevskiy:
1. Я так понимаю при использовании enqueue Thread не нужен
3. я так понимаю это и есть поток
переделал код без thread

public void getCinemaFrag()
    {
        // Создаем адаптер с базовым адресом
        Retrofit.Builder builder = new Retrofit.Builder();
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(SOURCE_MOON)
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        Retrofit retrofit2 = new Retrofit.Builder()
                .baseUrl(SOURCE_KP)
                .addConverterFactory(GsonConverterFactory.create())
                .build();

        // Создаём сервисы API
        apiMoon = retrofit.create(APIMoon.class);
        apiKp= retrofit2.create(APIKp.class);
        
        mProgressBar.setVisibility(View.VISIBLE);
        // Получаем данные
        cinemas.clear();
        Call<KinoModel> call = apiMoon.getCinema(API_TOKEN);
        call.enqueue(new Callback<KinoModel>() {
            @Override
            public void onResponse(Call<KinoModel> call, Response<KinoModel> response) {
                if (!call.isExecuted()) {
                    try {
                        kinoModel = call.execute().body();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    for (int k = 0; k < kinoModel.getNumUpdates(); k++) {
                        film_ID = kinoModel.getUpdates().get(k).getKP();
                        if (film_ID != 0) {
                            Call<KinoModelKp> call2 = apiKp.getKp(film_ID);
                            try {
                                if (!call2.isExecuted()) {
                                    kinoModelKp = call2.execute().body();
                                }
                            } catch (IOException e) {
                                e.printStackTrace();
                            }
                            if (film_ID != 0) {
                                cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                        kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                        kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                        kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "http://st.kp.yandex.net/images/" + kinoModelKp.getPoster(), kinoModelKp.getKPYear(), kinoModelKp.getDescription()));
                                //http://st.kp.yandex.net/images/film_big/"+film_ID+".jpg
                            } else {
                                cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                        kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                        kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                        kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "", 0, "описание отсутствует..."));
                            }
                            call2.enqueue(new Callback<KinoModelKp>() {
                                @Override
                                public void onResponse(Call<KinoModelKp> call2, Response<KinoModelKp> response2) {
                                        Log.d("myLogs", "OK!");
                                        mProgressBar.setVisibility(View.GONE);
                                        cinemaAdapter = new CinemaAdapter(getActivity(), cinemas);
                                        cinemaAdapter.notifyDataSetChanged();
                                        // настраиваем список
                                        lvMain.setAdapter(cinemaAdapter);

                                }

                                @Override
                                public void onFailure(Call<KinoModelKp> call, Throwable t) {
                                    Log.d("myLogs", "NOT OK!");
                                }
                            });
                        }
                    }
                }
            }

            @Override
            public void onFailure(Call<KinoModel> call, Throwable t) {
                Log.d("myLogs", "NOT OK!");
            }
        });
    }

теперь данные вообще не грузятся

[Денис Загаевский]

newdancer: я вам скопирую отсюда: https://github.com/square/retrofit/blob/master/ret... , ок?

/**
   * Synchronously send the request and return its response.
   *
   * @throws IOException if a problem occurred talking to the server.
   * @throws RuntimeException (and subclasses) if an unexpected error occurs creating the request
   * or decoding the response.
   */
  Response<T> execute() throws IOException;

  /**
   * Asynchronously send the request and notify {@code callback} of its response or if an error
   * occurred talking to the server, creating the request, or processing the response.
   */
  void enqueue(Callback<T> callback);

Дословно, что вы написали:
Эй, ретрофит, иди загрузи асинхронно данные, результат кинь мне в коллбек, в котором я спрошу у тебя, выполнил ли ты этот запрос, и если не выполнил, попрошу ещё раз СИНХРОННО сходить за этими же данными, а если выполнил, то ничего делать не буду.

[newdancer]

Denis Zagayevskiy: судя из краткого описания сделал)))

public void getCinemaFrag()
    {
        // Создаем адаптер с базовым адресом
        Retrofit.Builder builder = new Retrofit.Builder();
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(SOURCE_MOON)
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        Retrofit retrofit2 = new Retrofit.Builder()
                .baseUrl(SOURCE_KP)
                .addConverterFactory(GsonConverterFactory.create())
                .build();

        // Создаём сервисы API
        apiMoon = retrofit.create(APIMoon.class);
        apiKp= retrofit2.create(APIKp.class);

        Thread t = new Thread(new Runnable(){
            @Override
            public void run(){
                mProgressBar.setVisibility(View.VISIBLE);
                // Получаем данные
                cinemas.clear();
                Call<KinoModel> call = apiMoon.getCinema(API_TOKEN);
                try {
                    kinoModel = call.execute().body();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                if (call.isExecuted()) {
                    for (int k = 0; k < kinoModel.getNumUpdates(); k++) {
                        film_ID = kinoModel.getUpdates().get(k).getKP();
                        if (film_ID != 0) {
                            Call<KinoModelKp> call2 = apiKp.getKp(film_ID);
                            try {
                                kinoModelKp = call2.execute().body();
                            } catch (IOException e) {
                                e.printStackTrace();
                            }
                            cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                    kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                    kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                    kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "http://st.kp.yandex.net/images/" + kinoModelKp.getPoster(), kinoModelKp.getKPYear(), kinoModelKp.getDescription()));
                        }
                        else
                        {
                            cinemas.add(new Cinema(kinoModel.getUpdates().get(k).getTitleRU(), kinoModel.getUpdates().get(k).getTitleEN(),
                                    kinoModel.getUpdates().get(k).getKP(), kinoModel.getUpdates().get(k).getToken(), kinoModel.getUpdates().get(k).getType(),
                                    kinoModel.getUpdates().get(k).getCAM(), kinoModel.getUpdates().get(k).getIframe(), kinoModel.getUpdates().get(k).getTranslate(),
                                    kinoModel.getUpdates().get(k).getTranslateID(), kinoModel.getUpdates().get(k).getAdded(), "", 0, "описание отсутствует..."));
                        }
                    }
                }
            }
        });
        t.start();

        try {
            t.join();
             mProgressBar.setVisibility(View.GONE);
        cinemaAdapter = new CinemaAdapter(getActivity(), cinemas);
        cinemaAdapter.notifyDataSetChanged();
        // настраиваем список
        lvMain.setAdapter(cinemaAdapter);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

только так до конца и не понятно в как узнать когда retrofit законит чтобы обновить список. Пришлось вернуть Thread т.к. в главном активити не грузит инет

[Денис Загаевский]

newdancer: блин, я не знаю уже, как вам ещё это сказать.
Вам нужен не execute - он СИНХРОННЫЙ. Используйте enqueue- он АСИНХРОННЫЙ. В методе onResponse вам доступен Response - из него доставайте данные. execute дополнительно вызывать не нужно. Thread - НЕ НУЖЕН.
Это ещё очень странно, что вы до сих пор не огребли ошибок за манипуляциями c UI из не-UiThread. Прочитайте, пожалуйста, ВНИМАТЕЛЬНО все ссылки, которые я вам скинул. Там всё есть.

[newdancer]

Denis Zagayevskiy: так то в обоих случаях нужно использовать асинхронный?

[newdancer]

Denis Zagayevskiy: вот так заработало

public void getCinemaFrag()
    {
        // Создаем адаптер с базовым адресом
        Retrofit.Builder builder = new Retrofit.Builder();
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(SOURCE_MOON)
                .addConverterFactory(GsonConverterFactory.create())
                .build();
        Retrofit retrofit2 = new Retrofit.Builder()
                .baseUrl(SOURCE_KP)
                .addConverterFactory(GsonConverterFactory.create())
                .build();

        // Создаём сервисы API
        apiMoon = retrofit.create(APIMoon.class);
        apiKp= retrofit2.create(APIKp.class);

        mProgressBar.setVisibility(View.VISIBLE);
        // Получаем данные
        cinemas.clear();
        Call<KinoModel> call = apiMoon.getCinema(API_TOKEN);
        call.enqueue(new Callback<KinoModel>() {
            @Override
            public void onResponse(Call<KinoModel> call, Response<KinoModel> response)
            {
                for (int k = 0; k < response.body().getNumUpdates(); k++) {
                    film_ID = response.body().getUpdates().get(k).getKP();
                    if (film_ID != 0) {
                        Call<KinoModelKp> call2 = apiKp.getKp(film_ID);
                        models[0]=response.body().getUpdates().get(k).getTitleRU();
                        models[1]=response.body().getUpdates().get(k).getTitleEN();
                        models[2]=String.valueOf(response.body().getUpdates().get(k).getKP());
                        models[3]=response.body().getUpdates().get(k).getToken();
                        models[4]=response.body().getUpdates().get(k).getType();
                        models[5]=String.valueOf(response.body().getUpdates().get(k).getCAM());
                        models[6]=response.body().getUpdates().get(k).getIframe();
                        models[7]=response.body().getUpdates().get(k).getTranslate();
                        models[8]=response.body().getUpdates().get(k).getTranslateID();
                        models[9]=response.body().getUpdates().get(k).getAdded();
                        call2.enqueue(new Callback<KinoModelKp>() {
                            @Override
                            public void onResponse(Call<KinoModelKp> call2, Response<KinoModelKp> response2) {
                                    cinemas.add(new Cinema(models[0], models[1],
                                            models[2], models[3], models[4],
                                            models[5], models[6], models[7],
                                            models[8], models[9], "http://kinopoisk.ru/images/" + response2.body().getPoster(), String.valueOf(response2.body().getKPYear()), response2.body().getDescription()));
                            }

                            @Override
                            public void onFailure(Call<KinoModelKp> call2, Throwable t) {
                                Log.d("myLogs", "Failed!!! KP ");
                            }
                        });
                    }
                    else
                    {
                        cinemas.add(new Cinema(response.body().getUpdates().get(k).getTitleRU(), response.body().getUpdates().get(k).getTitleEN(),
                                String.valueOf(response.body().getUpdates().get(k).getKP()), response.body().getUpdates().get(k).getToken(), response.body().getUpdates().get(k).getType(),
                                String.valueOf(response.body().getUpdates().get(k).getCAM()), response.body().getUpdates().get(k).getIframe(), response.body().getUpdates().get(k).getTranslate(),
                                response.body().getUpdates().get(k).getTranslateID(), response.body().getUpdates().get(k).getAdded(), "", "0", "описание отсутствует..."));
                    }
                    if(k==response.body().getNumUpdates()-1)
                    {
                        mProgressBar.setVisibility(View.GONE);
                        cinemaAdapter = new CinemaAdapter(getActivity(), cinemas);
                        cinemaAdapter.notifyDataSetChanged();
                        // настраиваем список
                        lvMain.setAdapter(cinemaAdapter);
                    }
                }
            }

            @Override
            public void onFailure(Call<KinoModel> call, Throwable t) {
                Log.d("myLogs", "Failed!!!");
            }
        });
    }

только тако способ придумал определять когда список весь догрузился

[Денис Загаевский]

newdancer: выглядит примерно похоже на правду. Но у вас есть логические ошибки. Например, смотрите.
Вы выполнили call, дождались, когда запрос закончится и в нём стартовали ещё несколько асинхронных запросов call2.enqueue(). Затем, не дожидаясь выполнения всех call2, вы скрываете прогресс, настраиваете список и показываете его. Всё это время запросы call2 могут выполняться. Вам либо надо в call2 вызывать notifyDataSetChanged(), либо ждать каким-то образом, пока все запросы выполнятся. Ждать можно просто - перед вызовом call2.enqueue() counter++; при заходе в onResponse/onFailure counter--; когда counter ==0 - все запросы выполнены.

Также непонятно, что за массив models, такое ощущение, что вокруг него пляски избыточны.

P.S. я бы стал решать эту задачу, используя RxJava, благо ретрофит её поддерживает. Но вам этого не советую - сейчас не потянете.

[newdancer]

Denis Zagayevskiy: с массивом models пришлось связаться так как responce первого call не доступен когда вызываю call2. Что посоветуете?

[Денис Загаевский]

newdancer: final Response response. final int currentIndex = k; Тогда они будут видны в коллбеке

Answer 2

[Илья Павловский]

Настоятельно рекомендую заранее переходить уже на Retrofit2.

Comments

[newdancer]

Вопрос встречный зачем? В чем преимущество 2 версии от первой?

[Илья Павловский]

newdancer: Решены проблемы с передачей файлов, Rx + не нужно дублировать интерфейсы, для использования синхронных/асинхронных вызовов. Лично для меня, это существенные новшества.

[Денис Загаевский]

Плюсую.

Answer 3

[newdancer]

в каком формате получает retrofit результат когда массив updates???
попробовал сделать так

@Expose
private List<Upd> updates;
public List<Upd> getUpdates()
{
return updates;
}
public class Upd {
@SerializedName("title_ru")
private String title_ru;
}

результат получается в виде кода типа: название пакета$Upd@85d2ea1