Управление элементами системы и событиями

Управление элементами и событиями системы подразумевает под собой отбор типов событий, которые нужно получать, получение событий и их дальнейшую обработку.

Внимание! Для запуска данного примера на Wialon Kit следует заменить http://hst-api.wialon.com на http://kit-api.wialon.com, а для входа в систему использовать логин и пароль своей учетной записи или логин и пароль демо-пользователя: kitdemo kitdemo.

package com.wialon.java.test;
 
import com.wialon.core.Errors;
import com.wialon.core.EventHandler;
import com.wialon.core.EventProvider;
import com.wialon.core.Session;
import com.wialon.extra.UpdateSpec;
import com.wialon.item.Item;
import com.wialon.item.Unit;
import com.wialon.remote.handlers.ResponseHandler;
 
import java.io.IOException;
import java.util.Collection;
 
public class EventsManagementExample implements Runnable {
    private Session session;
 
    // Login to server
    private void login(){
        // initialize Wialon session
        session.initSession("http://hst-api.wialon.com");
        // trying login
        session.login("wialon_test", "test", new ResponseHandler() {
            @Override
            public void onSuccess(String response) {
                super.onSuccess(response);
                // login succeed
                System.out.println(String.format("Logged successfully. User name is %s", session.getCurrUser().getName()));
                //call update data flags
                updateDataFlags();
            }
 
            @Override
            public void onFailure(int errorCode, Throwable throwableError) {
                super.onFailure(errorCode, throwableError);
                // login failed, print error
                System.out.println(Errors.getErrorText(errorCode));
            }
        });
    }
 
    private void updateDataFlags(){
        //Create new update specification
        UpdateSpec updateSpec=new UpdateSpec();
        //Set update mode to add specified flags
        updateSpec.setMode(1);
        //Set update type by type
        updateSpec.setType("type");
        //Set update data to units
        updateSpec.setData(Item.ItemType.avl_unit);
        //Set update data flags
        updateSpec.setFlags(Item.dataFlag.base.getValue()| Unit.dataFlag.lastMessage.getValue());
        //Send update by created update specification
        session.updateDataFlags(new UpdateSpec[]{updateSpec}, new ResponseHandler() {
            @Override
            public void onSuccess(String response) {
                super.onSuccess(response);
                // Update succeed
                System.out.println("Update data flags is successful");
                bindEventsHandler();
            }
            @Override
            public void onFailure(int errorCode, Throwable throwableError) {
                super.onFailure(errorCode, throwableError);
                // update data flags failed, print error
                System.out.println(Errors.getErrorText(errorCode));
                logout();
            }
        });
    }
 
    private void bindEventsHandler(){
        //Get items from session
        Collection<Item> sessionItems=session.getItems();
        //Create events handler
        EventsHandlerExample eventsHandlerExample=new EventsHandlerExample();
        //Add handler to session
        session.addListener(eventsHandlerExample, EventProvider.events.All);
        if (sessionItems!=null && sessionItems.size()>0) {
            System.out.println(String.format("%d items added to Session\r\nStart binding event listeners to items", sessionItems.size()));
            //Add handler to items
            for (Item item : sessionItems)
                item.addListener(eventsHandlerExample, EventProvider.events.All);
            System.out.println("Event listeners successfully bound to items\r\nPress enter to logout and exit");
        }
        //Wait for press enter key
        try {
            System.in.read();
            logout();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    // Logout
    private void logout(){
        session.logout(new ResponseHandler() {
            @Override
            public void onSuccess(String response) {
                super.onSuccess(response);
                // logout succeed
                System.out.println("Logout successfully");
                System.exit(0);
            }
            @Override
            public void onFailure(int errorCode, Throwable throwableError) {
                super.onFailure(errorCode, throwableError);
                // logout failed, print error
                System.out.println(Errors.getErrorText(errorCode));
                System.exit(0);
            }
        });
    }
    //EventHandler witch listen bound event types
    private class EventsHandlerExample implements EventHandler{
        @Override
        public void onEvent(Enum event, Object object, Object oldData, Object newData) {
            String objectValue= object==null ? "null" : object.toString();
            String oldDataValue= oldData==null ? "null" : oldData.toString();
            String newDataValue= newData==null ? "null" : newData.toString();
            System.out.println(String.format("Fired event with type %s, object is %s, oldData is %s, newData is %s", event, objectValue, oldDataValue, newDataValue));
        }
    }
 
    @Override
    public void run() {
        // get instance of current Session
        session=Session.getInstance();
        login();
    }
 
    public static void main(String[] args){
        new Thread(new EventsManagementExample()).start();
    }
}