RF / xiangdianwms · Files

package com.lijinji.part.https;

import android.text.TextUtils;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.lijinji.part.bean.BarcodeDataBean;
import com.lijinji.part.bean.BarcodeOrderBean;
import com.lijinji.part.bean.BatchBean;
import com.lijinji.part.bean.BomOrderBean;
import com.lijinji.part.bean.FlowBean;
import com.lijinji.part.bean.LogOrderBean;
import com.lijinji.part.bean.MenuOperationBean;
import com.lijinji.part.bean.OrderBean;
import com.lijinji.part.bean.PackingBean;
import com.lijinji.part.bean.PartBean;
import com.lijinji.part.bean.PartOrderBean;
import com.lijinji.part.bean.ProductBean;
import com.lijinji.part.bean.ProductLineBean;
import com.lijinji.part.bean.ProductLinePartBean;
import com.lijinji.part.bean.RolesBean;
import com.lijinji.part.bean.TaskOrderBean;
import com.lijinji.part.bean.UpdateBarcodeDataBean;
import com.lijinji.part.product.ProductService;
import com.lijinji.part.WMSApplication;
import com.lijinji.part.bean.ActivityIslandBean;
import com.lijinji.part.bean.ChargingPileBean;
import com.lijinji.part.bean.EquipmentBean;
import com.lijinji.part.bean.LineBean;
import com.lijinji.part.bean.LocationBean;
import com.lijinji.part.bean.RGVUserBean;
import com.lijinji.part.bean.TaskBean;
import com.lijinji.part.bean.WorkProcessBean;
import com.lijinji.part.bean.WorkProcessDetailBean;
import com.lijinji.part.https.convert.ResponseConverterFactory;
import com.lijinji.part.util.Constant;
import com.lijinji.part.util.DataBaseHelpter;
import com.lijinji.part.util.WMSLog;
import com.lijinji.part.util.WMSUtils;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import java.io.IOException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.Date;

import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
import rx.Observable;
import rx.Subscriber;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Func1;
import rx.schedulers.Schedulers;

public class HttpInterface {

    public final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    private static HttpInterface insstance = null;
    private Retrofit retrofit;
    private Map<String, Object> paramMap;
    private OkHttpClient.Builder clientBuilder;
    private ProductService productService;

    public static HttpInterface getInsstance() {
        if (insstance == null) {
            insstance = new HttpInterface();
        }
        return insstance;
    }

    public HttpInterface() {
        WMSLog.d("HttpInterface");
        TrustManager[] trustManager = new TrustManager[]{
                new X509TrustManager() {
                    @Override
                    public void checkClientTrusted(X509Certificate[] chain, String authType) throws
                            CertificateException {
                    }

                    @Override
                    public void checkServerTrusted(X509Certificate[] chain, String authType) throws
                            CertificateException {
                    }

                    @Override
                    public X509Certificate[] getAcceptedIssuers() {
                        return null;    // 返回null
                    }
                }
        };

        clientBuilder = new OkHttpClient.Builder();
        try {
            clientBuilder
                    .connectTimeout(HttpConstant.CONNECT_TIMEOUT, TimeUnit.SECONDS)
                    .readTimeout(HttpConstant.READ_TIMEOUT, TimeUnit.SECONDS)
                    .writeTimeout(HttpConstant.WRITE_TIMEOUT, TimeUnit.SECONDS)
//                    .addInterceptor(new UserEntityInterceptor())
//                    .addInterceptor(new LoggerInterceptor("", true))
                    .sslSocketFactory(getSSLSocketFactory())
                    .hostnameVerifier(new HostnameVerifier() {
                        @Override
                        public boolean verify(String hostname, SSLSession session) {

                            return true;
                        }
                    });
            clientBuilder.interceptors().add(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    // 获取 Cookie
                    Response resp = chain.proceed(chain.request());
                    List<String> cookies = resp.headers("Set-Cookie");
                    String cookieStr = "";
                    if (cookies != null && cookies.size() > 0) {
                        for (int i = 0; i < cookies.size(); i++) {
                            cookieStr += cookies.get(i);
                        }
                        WMSApplication.setOkhttpCookie(cookieStr);
                    }
                    return resp;
                }
            });
            clientBuilder.interceptors().add(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    // 设置 Cookie
                    String cookieStr = WMSApplication.getOkhttpCookie();
                    if (!TextUtils.isEmpty(cookieStr)) {
                        return chain.proceed(chain.request().newBuilder().header("Cookie", cookieStr).build());
                    }
                    return chain.proceed(chain.request());
                }
            });
            clientBuilder.interceptors().add(new Interceptor() {
                @Override
                public Response intercept(Chain chain) throws IOException {
                    Request request = chain.request().newBuilder()
                            .addHeader("Content-Type", "application/json")
                            .addHeader("accept", "application/json").build();
                    return chain.proceed(request);
                }
            });
        } catch (Exception e) {
            e.printStackTrace();
        }

        String url = WMSUtils.getData(Constant.NETWORK);
        if(url != null) {
            retrofit = new Retrofit.Builder()
                    .client(clientBuilder.build())
                    .addConverterFactory(ResponseConverterFactory.create())
                    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                    .baseUrl(url)
                    .build();
        } else {
            retrofit = new Retrofit.Builder()
                    .client(clientBuilder.build())
                    .addConverterFactory(ResponseConverterFactory.create())
                    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                    .baseUrl(HttpConstant.AGV_URL)
                    .build();
        }

        paramMap = new HashMap<>();
        WMSLog.d("initService");
        initService(retrofit);
    }

    public void  reset() {
        insstance = null;
    }

    private static SSLSocketFactory getSSLSocketFactory() throws Exception {
        //创建一个不验证证书链的证书信任管理器。
        final TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {
            @Override
            public void checkClientTrusted(
                    X509Certificate[] chain,
                    String authType) throws CertificateException {
            }

            @Override
            public void checkServerTrusted(
                    X509Certificate[] chain,
                    String authType) throws CertificateException {
            }

            @Override
            public X509Certificate[] getAcceptedIssuers() {
                return new X509Certificate[0];
            }
        }};

        // Install the all-trusting trust manager
        final SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, trustAllCerts, new java.security.SecureRandom());
        // Create an ssl socket factory with our all-trusting manager
        return sslContext.getSocketFactory();
    }

    public void setBaseUrl(String url) {
        retrofit = new Retrofit.Builder()
                .client(clientBuilder.build())
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .baseUrl(url)
                .build();
        initService(retrofit);
    }

    private void initService(Retrofit retrofit) {
        productService = retrofit.create(ProductService.class);
    }

    public String getBaseUrl() {
        return retrofit.baseUrl().toString();
    }


    public void login(Subscriber<RGVUserBean> subscriber, String userCode, String password) {
        JSONObject json = new JSONObject();
        try {
            json.put("userCode", userCode);
            json.put("password", password);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.login(formBody)
                .map(new ApiResponseFunc<RGVUserBean>());

        toSubscribe(observable, subscriber);
    }

    public void getAllLine(Subscriber<ArrayList<LineBean>> subscriber) {
        JSONObject json = new JSONObject();
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getAllLine(formBody)
                .map(new ApiResponseFunc<ArrayList<LineBean>>());

        toSubscribe(observable, subscriber);
    }

    public void getOrderByCondition(Subscriber<OrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition, String Condition2) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Condition2", Condition2);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getOrderByCondition :" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getOrderByCondition(formBody)
                .map(new ApiResponseFunc<OrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void excuteOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("excuteOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.excuteOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void pauseOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("pauseOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.pauseOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void finishOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("finishOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.finishOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void openFinishOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("openFinishOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.openFinishOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void createOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("createOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.createOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void updateOrder(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("updateOrder:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.updateOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void updateOrderBatch(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("updateOrderBatch:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.updateOrderBatch(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }


    public void deleteOrder(Subscriber<String> subscriber, ProductBean productBean) {
        JSONObject json = new JSONObject();
        try {
            json.put("order", new Gson().toJson(productBean));
        } catch (JSONException e) {
            e.printStackTrace();
        }
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.deleteOrder(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getPartTasksByCondition(Subscriber<TaskOrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition, String Condition2) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Condition2", Condition2);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getPartTasksByConditio:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getPartTasksByConditio(formBody)
                .map(new ApiResponseFunc<TaskOrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void completeTask(Subscriber<String> subscriber, TaskBean taskBean) {
        String post = new Gson().toJson(taskBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("completeTask:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.completeTask(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void cancelTask(Subscriber<String> subscriber, TaskBean taskBean) {
        String post = new Gson().toJson(taskBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("cancelTask:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.cancelTask(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void flagTask(Subscriber<String> subscriber, TaskBean taskBean) {
        String post = new Gson().toJson(taskBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("flagTask:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.flagTask(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getPartsByCondition(Subscriber<PartOrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getPartsByCondition:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getPartsByCondition(formBody)
                .map(new ApiResponseFunc<PartOrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void updatePart(Subscriber<String> subscriber, PartBean partBean) {
        String post = new Gson().toJson(partBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("updatePart:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.updatePart(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void addPart(Subscriber<String> subscriber, PartBean partBean) {
        String post = new Gson().toJson(partBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("addPart:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.addPart(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void excutePausePart(Subscriber<String> subscriber, PartBean partBean) {
        String post = new Gson().toJson(partBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("excutePausePart:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.excutePausePart(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void excuteFinishedPart(Subscriber<String> subscriber, PartBean partBean) {
        String post = new Gson().toJson(partBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("excuteFinishedPart:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.excuteFinishedPart(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void partOfflinePost(Subscriber<String> subscriber, String qrcode, String lineCode, String qty, String userCode) {
        JSONObject json = new JSONObject();
        try {
            json.put("Qrcode", qrcode);
            json.put("LineCode", lineCode);
            json.put("Qty", qty);
            json.put("UserCode", userCode);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("partOfflinePost:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.partOfflinePost(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getProductLineByCondition(Subscriber<ProductLinePartBean> subscriber, int pageNumber, int pageSize, String orderBy, String condition) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", pageNumber);
            json.put("PageSize", pageSize);
            json.put("OrderBy", orderBy);
            json.put("Condition", condition);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getPartsByCondition:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getProductLineByCondition(formBody)
                .map(new ApiResponseFunc<ProductLinePartBean>());

        toSubscribe(observable, subscriber);
    }

    public void changePartWCSPalletQty(Subscriber<String> subscriber, int id, int synPalletQty) {
        JSONObject json = new JSONObject();
        try {
            json.put("Id", id);
            json.put("SynPalletQty", synPalletQty);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("changePartWCSPalletQty:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.changePartWCSPalletQty(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void changePartPriority(Subscriber<String> subscriber, int id, int priority) {
        JSONObject json = new JSONObject();
        List<Integer> ids = new ArrayList<>();
        ids.add(id);
        try {
            json.put("Ids", ids);
            json.put("Priority", priority);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        String post = json.toString();
        post = post.replace("\"[", "[");
        post = post.replace("]\"", "]");
        WMSLog.d("changePartPriority:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.changePartPriority(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getBatch(Subscriber<BatchBean> subscriber, String line, String plant, String dateTime) {
        JSONObject json = new JSONObject();
        String post = null;
        try {
            json.put("UserId", "admin");
            json.put("UserPW", "B1!#@!#234wwwx");
            json.put("Line", line);
            json.put("Plant", plant);
            json.put("Date", dateTime);
            json.put("Batch", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        post = json.toString();
        post = post.replace("\\/", "/");
        WMSLog.d("getBatch:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.getBatch(formBody)
                .map(new ApiResponseFunc<BatchBean>());

        toSubscribe(observable, subscriber);
    }

    public void getOrderRemainCalculate(Subscriber<String> subscriber, String lineCode, String qty, String userCode) {
        JSONObject json = new JSONObject();
        try {
            json.put("LineCode", lineCode);
            json.put("Qty", qty);
            json.put("UserCode", userCode);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getOrderRemainCalculate:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getOrderRemainCalculate(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getPartQtyConvertByCodes(Subscriber<List<PackingBean>> subscriber, String code) {
        String post = "[\"" + code + "\"]";
        WMSLog.d("getPartQtyConvertByCodes:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.getPartQtyConvertByCodes(formBody)
                .map(new ApiResponseFunc<List<PackingBean>>());

        toSubscribe(observable, subscriber);
    }

    public void getLogSynByCondition(Subscriber<LogOrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition, String Condition2) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Condition2", Condition2);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getLogSynByCondition:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getLogSynByCondition(formBody)
                .map(new ApiResponseFunc<LogOrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void partToWMS(Subscriber<String> subscriber) {
        JSONObject json = new JSONObject();
        WMSLog.d("partToWMS:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.partToWMS(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getMenuOperation(Subscriber<List<MenuOperationBean>> subscriber, List<RolesBean> rolesBeans) {
        String post = null;
        try {
            WMSLog.d("getMenuOperation:" + rolesBeans);
            post = new Gson().toJson(rolesBeans);
        } catch (Exception e) {
            e.printStackTrace();
        }
        WMSLog.d("getMenuOperation:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.getMenuOperation(formBody)
                .map(new ApiResponseFunc<List<MenuOperationBean>>());

        toSubscribe(observable, subscriber);
    }


    public void getFlow(Subscriber<List<FlowBean>> subscriber) {
        JSONObject json = new JSONObject();
        WMSLog.d("getFlow:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getFlow(formBody)
                .map(new ApiResponseFunc<List<FlowBean>>());

        toSubscribe(observable, subscriber);
    }

    public void getBOMViewByCondition(Subscriber<BomOrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition, String Condition2) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Condition2", Condition2);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getBOMViewByCondition:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getBOMViewByCondition(formBody)
                .map(new ApiResponseFunc<BomOrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void getExcutedOrderByLineCode(Subscriber<ProductBean> subscriber, String lineCode) {
        lineCode = "'" + lineCode + "'";
        WMSLog.d("getExcutedOrderByLineCode:" + lineCode);
        RequestBody formBody = RequestBody.create(JSON, lineCode);
        Observable observable = productService.getExcutedOrderByLineCode(formBody)
                .map(new ApiResponseFunc<ProductBean>());

        toSubscribe(observable, subscriber);
    }

    public void setOrderPriority(Subscriber<String> subscriber, String orderCode,
                                 String nORMTPriority, String specificationPriority, String mRPCTRLPriority, String qtyPriority) {
        JSONObject json = new JSONObject();
        try {
            json.put("OrderCode", orderCode);
            json.put("NORMTPriority", nORMTPriority);
            json.put("SpecificationPriority", specificationPriority);
            json.put("MRPCTRLPriority", mRPCTRLPriority);
            json.put("QtyPriority", qtyPriority);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("setOrderPriority:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.setOrderPriority(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void rSTOrderAlarm(Subscriber<String> subscriber, String lineCode, String lineName, String lineType) {
        JSONObject json = new JSONObject();
        try {
            json.put("Code", lineCode);
            json.put("Name", lineName);
            json.put("Type", lineType);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("rSTOrderAlarm:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.rSTOrderAlarm(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void getOrderInfoTime(Subscriber<String> subscriber, ProductBean productBean) {
        String post = new Gson().toJson(productBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("getOrderInfoTime:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.getOrderInfoTime(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void updateTaskOrderCode(Subscriber<String> subscriber, List<Integer> taskIds, String orderCode, String userCode) {
        JSONObject json = new JSONObject();
        try {
            json.put("TaskIds", taskIds);
            json.put("OrderCode", orderCode);
            json.put("UserCode", userCode);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        String post = json.toString();
        post = post.replace("\"[", "[");
        post = post.replace("]\"", "]");
        WMSLog.d("updateTaskOrderCode:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.updateTaskOrderCode(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }

    public void updateReplace(Subscriber<String> subscriber, List<Integer> taskIds) {
        JSONObject json = new JSONObject();
        try {
            json.put("Tasks", taskIds);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        String post = json.toString();
        post = post.replace("\"[", "[");
        post = post.replace("]\"", "]");
        WMSLog.d("updateReplace:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.updateReplace(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }
    public void getBarcodeData(Subscriber<BarcodeDataBean> subscriber, String userCode, String barcode) {
        JSONObject json = new JSONObject();
        try {
            json.put("UserCode", userCode);
            json.put("Barcode", barcode);
            json.put("Flag", 1);
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getBarcodeData:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getBarcodeData(formBody)
                .map(new ApiResponseFunc<BarcodeDataBean>());

        toSubscribe(observable, subscriber);
    }

    public void verifyBarcodeData(Subscriber<String> subscriber, BarcodeDataBean barcodeDataBean) {
        Gson gson = new GsonBuilder().disableHtmlEscaping().create();
        String post = gson.toJson(barcodeDataBean);
        post = post.replace("\\", "");
        post = post.replace("}\"}", "}}");
        post = post.replace("\"{", "{");
        post = post.replace("\"}\"", "\"}");
        WMSLog.d("verifyBarcodeData:" + post);
        RequestBody formBody = RequestBody.create(JSON, post);
        Observable observable = productService.verifyBarcodeData(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }


    public void getBarcodeDataByCondition(Subscriber<BarcodeOrderBean> subscriber, int PageNumber, int PageSize, String OrderBy, String Condition, String Condition2) {
        JSONObject json = new JSONObject();
        try {
            json.put("PageNumber", PageNumber);
            json.put("PageSize", PageSize);
            json.put("OrderBy", OrderBy);
            json.put("Condition", Condition);
            json.put("Condition2", Condition2);
            json.put("Count", 0);
            json.put("Datas", "");
        } catch (JSONException e) {
            e.printStackTrace();
        }
        WMSLog.d("getBarcodeDataByCondition:" + json.toString());
        RequestBody formBody = RequestBody.create(JSON, json.toString());
        Observable observable = productService.getBarcodeDataByCondition(formBody)
                .map(new ApiResponseFunc<BarcodeOrderBean>());

        toSubscribe(observable, subscriber);
    }

    public void updateBarcodeData(Subscriber<String> subscriber, List<UpdateBarcodeDataBean> barcodeDataBeans) {
        JSONArray array = new JSONArray();
        for(UpdateBarcodeDataBean updateBarcodeDataBean : barcodeDataBeans) {
            JSONObject json = new JSONObject();
            try {
                json.put("Id", updateBarcodeDataBean.getId());
                json.put("UserCode", updateBarcodeDataBean.getUserCode());
                json.put("RemainQty", updateBarcodeDataBean.getRemainQty());
                json.put("CurrentQty", updateBarcodeDataBean.getCurrentQty());
            } catch (JSONException e) {
                e.printStackTrace();
            }
            array.put(json);
        }
        WMSLog.d("updateBarcodeData:" + array.toString());
        RequestBody formBody = RequestBody.create(JSON, array.toString());
        Observable observable = productService.updateBarcodeData(formBody)
                .map(new ApiResponseFunc<String>());

        toSubscribe(observable, subscriber);
    }



    /**
     * 用来统一处理Http的resultCode,并将HttpResult的Data部分剥离出来返回给subscriber
     *
     * @param <T> Subscriber真正需要的数据类型，也就是Data部分的数据类型
     */
    private class ApiResponseFunc<T> implements Func1<ApiResponse<T>, T> {

        @Override
        public T call(ApiResponse<T> apiResponse) {
            WMSLog.d("apiResponse.getCode()：" + apiResponse.getCode());
            if (!apiResponse.getCode().equals("200")) {
                throw new ApiException(apiResponse.getMsg());
            }

            if (apiResponse.getData() != null) {
                return apiResponse.getData();
            } else if (apiResponse.getSession() != null) {
                return apiResponse.getSession();
            }

            return null;
        }
    }

    private void toSubscribe(Observable observable, Subscriber subscriber) {
        observable
                .subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(subscriber);
    }


}