Mrk 5213

src/main/aidl/ru/evotor/tspiot/ITsPioTService.aidl

@@ -0,0 +1,10 @@
+package ru.evotor.tspiot;
+
+import ru.evotor.tspiot.model.MarkingCode;
+import ru.evotor.tspiot.result.TsPioTResult;
+
+interface ITsPioTService {
+    TsPioTResult getKktInfo();
+
+    TsPioTResult getMarkedProductsInfo(in List<MarkingCode> codes, in String userUuid);
+}

src/main/aidl/ru/evotor/tspiot/model/MarkingCode.aidl

@@ -0,0 +1,3 @@
+package ru.evotor.tspiot.model;
+
+parcelable MarkingCode;

src/main/aidl/ru/evotor/tspiot/result/TsPioTResult.aidl

@@ -0,0 +1,3 @@
+package ru.evotor.tspiot.result;
+
+parcelable TsPioTResult;

src/main/java/ru/evotor/tspiot/TsPioTServiceConnector.java

@@ -0,0 +1,64 @@
+package ru.evotor.tspiot;
+
+import android.content.Context;
+import android.os.DeadObjectException;
+import java.util.concurrent.CopyOnWriteArrayList;
+import ru.evotor.tspiot.exceptions.ServiceNotConnectedException;
+import ru.evotor.tspiot.exceptions.TsPioTServiceOperationOnMainThreadException;
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+import ru.evotor.tspiot.exceptions.TsPioTServiceRuntimeException;
+import ru.evotor.tspiot.service.ITsPioTConnectionWrapper;
+import ru.evotor.tspiot.service.ITsPioTServiceWrapper;
+import ru.evotor.tspiot.service.TsPioTService;
+
+public class TsPioTServiceConnector {
+
+    protected static final String TAG = "TsPioTServiceConnector";
+
+    public static final String ACTION_TSPIOT_SERVICE = "evotor.intent.action.TSPIOT_SERVICE";
+    public static final String TARGET_PACKAGE = "ru.esp.umesm";
+    public static final String TARGET_CLASS_NAME = "ru.esp.worker.worker.IntegrationMarksCheckService";
+
+    protected final static TsPioTService tsPioTService = new TsPioTService();
+
+    protected final static CopyOnWriteArrayList<ITsPioTConnectionWrapper> connectionWrappers = new CopyOnWriteArrayList<>();
+
+    public static CopyOnWriteArrayList<ITsPioTConnectionWrapper> getConnectionWrappers() {
+        return connectionWrappers;
+    }
+
+    public static void addConnectionWrapper(ITsPioTConnectionWrapper connectionWrapper) {
+        connectionWrappers.add(connectionWrapper);
+    }
+
+    public static void removeConnectionWrapper(ITsPioTConnectionWrapper connectionWrapper) {
+        connectionWrappers.remove(connectionWrapper);
+    }
+
+    public static void clearConnectionWrappers() {
+        connectionWrappers.clear();
+    }
+
+    public static ITsPioTServiceWrapper connectTsPioTService(Context context) throws TsPioTServiceException {
+        TsPioTServiceOperationOnMainThreadException.throwIfMainThread();
+
+        tsPioTService.connectService(context, false);
+        return tsPioTService;
+    }
+
+    public static void disconnectTsPioTService() throws TsPioTServiceException {
+        TsPioTServiceOperationOnMainThreadException.throwIfMainThread();
+
+        tsPioTService.disconnectService();
+    }
+
+    public static void processException(Exception exc) throws TsPioTServiceException {
+        if (exc instanceof DeadObjectException) {
+            tsPioTService.reconnectService();
+            throw new ServiceNotConnectedException(exc);
+        } else if (exc instanceof RuntimeException) {
+            throw new TsPioTServiceRuntimeException(exc);
+        }
+        exc.printStackTrace();
+    }
+}

src/main/java/ru/evotor/tspiot/Utils.java

@@ -0,0 +1,104 @@
+package ru.evotor.tspiot;
+
+import android.os.Parcel;
+import android.os.Parcelable;
+import androidx.annotation.Nullable;
+import java.io.Serializable;
+
+public final class Utils {
+
+    @Nullable
+    public static Integer readInteger(Parcel parcel) {
+        try {
+            return (Integer) parcel.readValue(Integer.class.getClassLoader());
+        } catch (Exception ex) {
+            return null;
+        }
+    }
+
+    @Nullable
+    public static Boolean readBoolean(Parcel parcel) {
+        try {
+            return (Boolean) parcel.readValue(Boolean.class.getClassLoader());
+        } catch (Exception ex) {
+            return null;
+        }
+    }
+
+    @SuppressWarnings("unchecked")
+    @Nullable
+    public static <T> Class<T> readClass(Parcel parcel) {
+        Serializable serializable = parcel.readSerializable();
+
+        if (serializable == null) {
+            return null;
+        }
+
+        try {
+            return (Class<T>) serializable;
+        } catch (Exception exception) {
+            return null;
+        }
+    }
+
+    @Nullable
+    public static <T extends Parcelable> T readData(Class<? extends T> classType, Parcel parcel) {
+        try {
+            if (classType == null) {
+                return parcel.readParcelable(null);
+            }
+
+            return parcel.readParcelable(classType.getClassLoader());
+        } catch (Exception exception) {
+            return null;
+        }
+    }
+
+    public static String toString(@Nullable Object object) {
+        return object == null ? "null" : object.toString();
+    }
+
+    public static String toString(@Nullable int[] ints) {
+        if (ints == null) {
+            return "null";
+        } else if (ints.length == 0) {
+            return "[]";
+        } else {
+            StringBuilder sb = new StringBuilder();
+
+            sb.append("[");
+            for (int i = 0; i < ints.length; i++) {
+                sb.append(ints[i]);
+
+                if (i != ints.length - 1) {
+                    sb.append(", ");
+                }
+            }
+            sb.append("]");
+
+            return sb.toString();
+        }
+    }
+
+    public static String toString(@Nullable Object[] objects) {
+        if (objects == null) {
+            return "null";
+        } else if (objects.length == 0) {
+            return "[]";
+        } else {
+            StringBuilder sb = new StringBuilder();
+
+            sb.append("[");
+            for (int i = 0; i < objects.length; i++) {
+                sb.append(objects[i]);
+
+                if (i != objects.length - 1) {
+                    sb.append(", ");
+                }
+            }
+            sb.append("]");
+
+            return sb.toString();
+        }
+    }
+}

src/main/java/ru/evotor/tspiot/exceptions/NullContextException.java

@@ -0,0 +1,5 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class NullContextException extends TsPioTServiceException { }

src/main/java/ru/evotor/tspiot/exceptions/ServiceAlreadyConnectedException.java

@@ -0,0 +1,5 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class ServiceAlreadyConnectedException extends TsPioTServiceException { }

src/main/java/ru/evotor/tspiot/exceptions/ServiceNotConnectedException.java

@@ -0,0 +1,8 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class ServiceNotConnectedException extends TsPioTServiceException {
+
+    public ServiceNotConnectedException(Exception ex) { super(ex); }
+}

src/main/java/ru/evotor/tspiot/exceptions/TsPioTErrorHolderException.java

@@ -0,0 +1,16 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+import ru.evotor.tspiot.result.model.base.ErrorDescription;
+import ru.evotor.tspiot.result.model.errors.TsPioTErrorsDescriptionWrapper;
+
+/** Исключение обёртка для передачи ошибок от драйвера ТС ПИоТ */
+public class TsPioTErrorHolderException extends TsPioTServiceException {
+
+    public final TsPioTErrorsDescriptionWrapper<? extends ErrorDescription> errorDescriptionWrapper;
+
+    public TsPioTErrorHolderException(TsPioTErrorsDescriptionWrapper<? extends ErrorDescription> errorDescriptionWrapper) {
+        super();
+        this.errorDescriptionWrapper = errorDescriptionWrapper;
+    }
+}

src/main/java/ru/evotor/tspiot/exceptions/TsPioTServiceOperationOnMainThreadException.java

@@ -0,0 +1,16 @@
+package ru.evotor.tspiot.exceptions;
+
+import android.os.Looper;
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class TsPioTServiceOperationOnMainThreadException extends TsPioTServiceException {
+    public TsPioTServiceOperationOnMainThreadException() {
+        super("It is forbidden to perform operations with TS PIoT service in the main thread, it can be time-consuming");
+    }
+
+    public static void throwIfMainThread() throws TsPioTServiceOperationOnMainThreadException {
+        if (Looper.getMainLooper() == Looper.myLooper()) {
+            throw new TsPioTServiceOperationOnMainThreadException();
+        }
+    }
+}

src/main/java/ru/evotor/tspiot/exceptions/TsPioTServiceRuntimeException.java

@@ -0,0 +1,8 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class TsPioTServiceRuntimeException extends TsPioTServiceException {
+
+    public TsPioTServiceRuntimeException(Exception ex) { super(ex); }
+}

src/main/java/ru/evotor/tspiot/exceptions/UnknownException.java

@@ -0,0 +1,8 @@
+package ru.evotor.tspiot.exceptions;
+
+import ru.evotor.tspiot.exceptions.base.TsPioTServiceException;
+
+public class UnknownException extends TsPioTServiceException {
+
+    public UnknownException(String message) { super(message); }
+}

src/main/java/ru/evotor/tspiot/exceptions/base/TsPioTServiceException.java

@@ -0,0 +1,17 @@
+package ru.evotor.tspiot.exceptions.base;
+
+/** Базовый класс для исключений, которые могу возникнуть на стороне клиента ТС ПИоТ*/
+public class TsPioTServiceException extends Exception {
+
+    public TsPioTServiceException() {
+        super();
+    }
+
+    public TsPioTServiceException(String message) {
+        super(message);
+    }
+
+    public TsPioTServiceException(Exception e) {
+        super(e);
+    }
+}

src/main/java/ru/evotor/tspiot/model/MarkingCode.java

@@ -0,0 +1,59 @@
+package ru.evotor.tspiot.model;
+
+import android.os.Parcel;
+import android.os.Parcelable;
+import androidx.annotation.Nullable;
+import org.jetbrains.annotations.NotNull;
+import java.util.Objects;
+import ru.evotor.tspiot.Utils;
+
+public class MarkingCode implements Parcelable {
+
+    /** Версия MarkingCode */
+    private static final int VERSION = 1;
+
+    /** Код маркировки */
+    @NotNull private final String cis;
+
+    /** Опциональный параметр идентификатора товарной группы */
+    @Nullable private final Integer productType;
+
+    public MarkingCode(@NotNull String cis, @Nullable Integer productType) {
+        this.cis = cis;
+        this.productType = productType;
+    }
+
+    private MarkingCode(Parcel parcel) {
+        int version = parcel.readInt();
+        this.cis = Objects.requireNonNull(parcel.readString());
+        this.productType = Utils.readInteger(parcel);
+    }
+
+    @NotNull
+    public String getCis() { return cis; }
+
+    @Nullable
+    public Integer getProductType() { return productType; }
+
+    @Override
+    public int describeContents() { return 0; }
+
+    @Override
+    public void writeToParcel(Parcel parcel, int i) {
+        parcel.writeInt(VERSION);
+        parcel.writeString(cis);
+        parcel.writeValue(productType);
+    }
+
+    public static Creator<MarkingCode> CREATOR = new Creator<>() {
+        @Override
+        public MarkingCode createFromParcel(Parcel parcel) {
+            return new MarkingCode(parcel);
+        }
+
+        @Override
+        public MarkingCode[] newArray(int i) {
+            return new MarkingCode[i];
+        }
+    };
+}

src/main/java/ru/evotor/tspiot/result/TsPioTError.java

@@ -0,0 +1,54 @@
+package ru.evotor.tspiot.result;
+
+import android.os.Parcel;
+import android.os.Parcelable;
+import ru.evotor.tspiot.Utils;
+import ru.evotor.tspiot.result.model.base.ErrorDescription;
+import ru.evotor.tspiot.result.model.errors.TsPioTErrorsDescriptionWrapper;
+
+public class TsPioTError implements Parcelable {
+
+    /** Версия TsPioTError */
+    private final static int VERSION = 1;
+
+    /** Описание ошибки */
+    private final TsPioTErrorsDescriptionWrapper<? extends ErrorDescription> error;
+
+    private final Class<? extends TsPioTErrorsDescriptionWrapper<? extends ErrorDescription>> errorType;
+
+    private TsPioTError(Parcel parcel) {
+        int version = parcel.readInt();
+        errorType = Utils.readClass(parcel);
+        error = Utils.readData(errorType, parcel);
+    }
+
+    @SuppressWarnings("unchecked")
+    public TsPioTError(TsPioTErrorsDescriptionWrapper<? extends ErrorDescription> error) {
+        this.error = error;
+        this.errorType = (Class<? extends TsPioTErrorsDescriptionWrapper<? extends ErrorDescription>>) error.getClass();
+    }
+
+    public TsPioTErrorsDescriptionWrapper<? extends ErrorDescription> getError() { return error; }
+
+    @Override
+    public int describeContents() { return 0; }
+
+    @Override
+    public void writeToParcel(Parcel parcel, int flags) {
+        parcel.writeInt(VERSION);
+        parcel.writeSerializable(errorType);
+        parcel.writeParcelable(error, flags);
+    }
+
+    public static final Creator<TsPioTError> CREATOR = new Creator<>() {
+        @Override
+        public TsPioTError createFromParcel(Parcel parcel) {
+            return new TsPioTError(parcel);
+        }
+
+        @Override
+        public TsPioTError[] newArray(int size) {
+            return new TsPioTError[size];
+        }
+    };
+}