import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
protected DataSource(Parcel in) {
    super(in);
    platform = in.readParcelable(Platform.class.getClassLoader());
    platformApp = in.readParcelable(PlatformApp.class.getClassLoader());
    application = in.readParcelable(Application.class.getClassLoader());
    persistent = in.readByte() != 0;
    int size = in.readInt();
    if (size == -1) dataDescriptors = null;
    else {
        dataDescriptors = new ArrayList<>();
        for (int i = 0; i < size; i++) {
            HashMap<String, String> a;
            int size1 = in.readInt();
            if (size1 == -1)
                a = null;
            else {
                a = new HashMap<>();
                for (int j = 0; j < size1; j++) {
                    a.put(in.readString(), in.readString());
                }
            }
            dataDescriptors.add(a);
        }
    }
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
@Override
public void run() {
    try {
        Log.d(TAG, "runnableSubscribeResponse...run()");
        Application application = new ApplicationBuilder().setId("org.md2k.notificationmanager").build();
        DataSourceBuilder dataSourceBuilder = new DataSourceBuilder().setType(DataSourceType.NOTIFICATION_RESPONSE).setApplication(application);
        dataSourceClientResponses = DataKitAPI.getInstance(context).find(dataSourceBuilder);
        Log.d(TAG, "DataSourceClients...size=" + dataSourceClientResponses.size());
        if (dataSourceClientResponses.size() == 0) {
            handlerSubscribeResponse.postDelayed(this, 1000);
        } else {
            subscribeNotificationResponse();
            handlerSubscribeAck.post(runnableSubscribeAcknowledge);
        }
    } catch (DataKitException e) {
        LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(Constants.INTENT_RESTART));
    }
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
@Override
public void run() {
    Application application = new ApplicationBuilder().setId("org.md2k.notificationmanager").build();
    DataSourceBuilder dataSourceBuilder = new DataSourceBuilder().setType(DataSourceType.NOTIFICATION_REQUEST).setApplication(application);
    try {
        dataSourceClietNotificationRequests = DataKitAPI.getInstance(context).find(dataSourceBuilder);
        Log.d(TAG, "datasourceclient=" + dataSourceClietNotificationRequests.size());
        if (dataSourceClietNotificationRequests.size() == 0) {
            if (RERUN > 0) {
                RERUN--;
                handler.postDelayed(this, 1000);
            } else handler.postDelayed(this, 60000);
        } else {
            subscribe();
        }
    } catch (DataKitException e) {
        Intent intent = new Intent(Constants.INTENT_STOP);
        intent.putExtra("type", "NotificationManager.java...runnableSubscribe()");
        LocalBroadcastManager.getInstance(context).sendBroadcast(intent);
    }
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
public DataSourceBuilder createDataSourceBuilder() {
    Platform platform = new PlatformBuilder().setType(PlatformType.PHONE).build();
    ApplicationBuilder applicationBuilder=new ApplicationBuilder();
    applicationBuilder.setId(context.getApplicationInfo().packageName);
    applicationBuilder.setType(context.getApplicationInfo().name);
    Application application=applicationBuilder.build();
    return new DataSourceBuilder().setId(null).setType(dataSourceType).setPlatform(platform).setApplication(application);
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
public Application getApplication() {
    return application;
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
public DataSourceBuilder setApplication(Application application) {
    this.application = application;
    return this;
}
 

import org.md2k.datakitapi.source.application.Application; //导入依赖的package包/类
private DataSource createDataSourcePrivacy() {
    Platform platform = new PlatformBuilder().setType(PlatformType.PHONE).build();
    Application application = new ApplicationBuilder().setId(context.getPackageName()).build();
    return new DataSourceBuilder().setType(DataSourceType.PRIVACY).setPlatform(platform).setApplication(application).build();
}