xntalk / xntalk-rnapp

/**
 * Created by tdzl2003 on 6/18/16.
 */

import {NativeModules} from 'react-native';
import config from './../config';
import MD5 from "md5"
import React from "react";
import {logCurrentTime} from "../utils/Common";


class ResponseError extends Error {
    constructor(message, code, origin) {
        super(message);
        this.code = code;
        this.origin = origin;
    }
}

export const isArray = (o) => {
    return Object.prototype.toString.call(o) === '[object Array]';
}

export function getPassportId() {
    return new Promise(function (resolve, reject) {
        NativeModules.security.getPassportId().then((result) => {
                resolve(result);
            }
        ).catch((error) => {
            console.log(error)
        });
    })
}

function identityId() {
    return new Promise(function (resolve, reject) {
        NativeModules.security.getIdentityId().then((result) => {
                resolve(result);
            }
        ).catch((error) => {
            console.log(error)
        });
    })
}

// appKey需要提供给商城使用，保持export
export const app_key = config.app_key; //dev
export const secret = config.secret; //dev

async function getPostParameter(request) {
    var post_data = '';
    var param_array = {};
    this.passportId = await getPassportId();
    this.identityId = await identityId();

    if (this.passportId != undefined && this.passportId != null && this.passportId > 0) {
        param_array.passportId = this.passportId;   //932843560934707200
        param_array.session = this.passportId;   //932843560934707200
    }
    if (this.identityId != undefined && this.identityId != null && this.identityId > 0) {
        param_array.identityId = this.identityId;
        param_array.session = this.identityId;
    }

    param_array.format = 'json';
    param_array.sign_method = 'md5';
    param_array.timestamp = Date.parse(new Date());
    param_array.app_key = app_key;
    if (!!!param_array.v) {
        param_array.v = '1.0';
    }

    for (var p in request) { // 方法
        if (request[p] != null && request[p] != undefined && typeof (request[p]) != "function") {
            param_array[p] = request[p];
        }
    }
    {
        var param_sign;
        var arrayKey = [];
        var strTemp;
        var arrayKeyTemp = [];
        for (var p in param_array) { // 方法
            if (typeof (param_array[p]) != "function") {
                arrayKeyTemp.push(p);
            }
        }
        // 最后显示所有的属性
        arrayKeyTemp.sort();
        var strTemp = secret;
        for (var i = 0; i < arrayKeyTemp.length; i++) {
            if (isArray(param_array[arrayKeyTemp[i]])) {
                strTemp = strTemp + arrayKeyTemp[i] + JSON.stringify(param_array[arrayKeyTemp[i]]);
            } else {
                strTemp = strTemp + arrayKeyTemp[i] + param_array[arrayKeyTemp[i]];
            }
        }
        strTemp = strTemp + secret;
        param_sign = MD5(strTemp).toString().toUpperCase();
        post_data = 'sign=' + param_sign.toUpperCase();
        for (var i = 0; i < arrayKeyTemp.length; i++) {
            if (isArray(param_array[arrayKeyTemp[i]])) {
                post_data = post_data + '&' + arrayKeyTemp[i] + '=' + encodeURI(JSON.stringify(param_array[arrayKeyTemp[i]]));
            } else {
                post_data = post_data + '&' + arrayKeyTemp[i] + '=' + encodeURI(param_array[arrayKeyTemp[i]]);
            }
        }
    }

    return post_data;
}

async function request(url, data, _options) {
    try {
        logCurrentTime('rps.js request开始' + data.method);
        const options = _options || {};
        options.method = options.method || 'GET';
        options.headers = options.headers || {};

        options.body = await getPostParameter(data)

        url = config.apiUrl.toString();
        if (!!data.useMoke) {
            url = data.mokeUrl.toString();
        }

        console.warn('options.body= ' + options.body);
        console.warn('config.apiUrl= ' + url);
        console.log('param:', data);
        console.log('options:', options);

        logCurrentTime('rps.js fetch开始' + data.method);
        let onError = false;
        const resp = await fetch(url.toString(), options);
        logCurrentTime('rps.js fetch结束' + data.method);
        logCurrentTime('rps.js json转换开始' + data.method);
        let json = await resp.json();
        // const json = eval("("+text+")");
        // console.log('json:', json);
        // const jsonText = JSON.parse(json);
        logCurrentTime('rps.js json转换结束' + data.method);
        logCurrentTime('rps.js request结束' + data.method);
        // console.log('jsonText:', jsonText);
        // 如果请求失败
        if (resp.status !== 200) {
            if (resp.status === 401) {
                console.log(resp.status);
            }
            onError = true;
        }
        // 服务不可用
        if (json.message) {
            onError = true;
        }
        // 如果数据格式最外面包了一层data，在这里解析掉
        if (!onError && !!json.data === true) {
            json = json.data;
        }
        console.log('数据返回:', json);
        return json;
    } catch (error) {
        console.log("rpc request 异常！" + error);
    }
}

//post
export function post(data, options) {
    return request(config.apiUrl, data, {
        method: 'POST',
        mode: "cors",
        headers: {
            'Accept': 'application/json',
            'Content-Type': 'application/x-www-form-urlencoded',
        },
        ...options,
    });
}

//上传
export async function upload(file) {
    const body = new FormData();
    body.append('File', file);
    body.append("Type", "PHOTO");
    const options = {
        method: 'POST',
        headers: {
            'Content-Type': 'multipart/form-data',
        },
        body,
    };
    let passportId = await getPassportId();
    const resp = await fetch(config.uploadUrl + "?passportId=" + passportId, options);
    const text = await resp.text();
    console.log('RESP:', text);
    const json = JSON.parse(text);
    // 如果请求失败
    if (resp.status !== 200) {
        throw new ResponseError(json.message, resp.status, json);
    }
    return json;
}