wms / wms_guangzhouwanbao · Files

package com.huaheng.api.jindie;


import com.alibaba.fastjson.JSONObject;
import com.huaheng.api.jindie.domain.login.Login;
import com.huaheng.api.jindie.domain.purchase.PurchasePush;
import com.huaheng.api.jindie.domain.purchase.PurchasePushData;
import com.huaheng.api.jindie.domain.result.Results;
import com.huaheng.api.jindie.domain.uri.JinDieApiUri;
import org.springframework.stereotype.Service;


import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;

@Service
public class InvokeHelper {

    public static String POST_K3CloudURL = "http://219.137.250.36:8999/K3Cloud/";

    // Cookie 值
    private static String CookieVal = null;

    // HttpURLConnection
    private static HttpURLConnection initUrlConn(String url, JSONObject paras)
            throws Exception {
        URL postUrl = new URL(POST_K3CloudURL.concat(url));
        HttpURLConnection connection = (HttpURLConnection) postUrl
                .openConnection();
        if (CookieVal != null) {
            connection.setRequestProperty("Cookie", CookieVal);
        }
        if (!connection.getDoOutput()) {
            connection.setDoOutput(true);
        }
        connection.setRequestMethod("POST");
        connection.setUseCaches(false);
        connection.setInstanceFollowRedirects(true);
        connection.setRequestProperty("Content-Type", "application/json");
        System.out.println(" ============================= ");
        System.out.println(" JSON请求数据 ");
        System.out.println(paras.toString());
        System.out.println(" ============================= ");


        DataOutputStream out = new DataOutputStream(
                connection.getOutputStream());

//        UUID uuid = UUID.randomUUID();
//        int hashCode = uuid.toString().hashCode();
//        JSONObject jObj = new JSONObject();
//        jObj.put("format", 1);
//        jObj.put("useragent", "ApiClient");
//        jObj.put("rid", hashCode);
//        jObj.put("parameters", chinaToUnicode(paras.toString()));
//        jObj.put("timestamp", new Date().toString());
//        jObj.put("v", "1.0");

        out.writeBytes(paras.toString());
        out.flush();
        out.close();

        return connection;
    }

    // Login
    public static boolean Login(Login login)
            throws Exception {

        boolean bResult = false;

        String sUrl = JinDieApiUri.LOGIN.getApiUri();

//        JSONArray jParas = new JSONArray();
//        jParas.add(acctID);// 帐套Id
//        jParas.add(username);// 用户名
//        jParas.add(password);// 密码
//        jParas.add(Lcid);// 语言
        JSONObject jParas = (JSONObject)JSONObject.toJSON(login);
        HttpURLConnection connection = initUrlConn(sUrl, jParas);
        // 获取Cookie
        String key = null;
        for (int i = 1; (key = connection.getHeaderFieldKey(i)) != null; i++) {
            if (key.equalsIgnoreCase("Set-Cookie")) {
                String tempCookieVal = connection.getHeaderField(i);
                if (tempCookieVal.startsWith("kdservice-sessionid")) {
                    CookieVal = tempCookieVal;
                    break;
                }
            }
        }

        BufferedReader reader = new BufferedReader(new InputStreamReader(
                connection.getInputStream()));
        String line;
        while ((line = reader.readLine()) != null) {
            String sResult = new String(line.getBytes(), "utf-8");
            System.out.println(sResult);
            bResult = line.contains("LoginResultType");
        }
        reader.close();
        connection.disconnect();
        return bResult;
    }

    /**
     * 采购入库单操作
     * @throws Exception
     */

    // Push
    public static void Push(String billCode) throws Exception {
        PurchasePush purchasePush=new PurchasePush();
        PurchasePushData purchasePushData=new PurchasePushData();
        List<String> list=new ArrayList<>();
        list.add("bill123456");
        purchasePushData.setNumbers(list);
        purchasePushData.setTargetOrgId(0);
        purchasePushData.setTargetFormId("STK_InStock");
        purchasePushData.setIsEnableDefaultRule("true");
        purchasePush.setData(purchasePushData);
        purchasePush.setFormid("PUR_ReceiveBill");
        JSONObject jsonObject = (JSONObject) JSONObject.toJSON(purchasePush);
        Invoke(JinDieApiUri.PURCHASE_PUSH.getApiUri(), jsonObject);
    }

    // Select
    public static void Select(JSONObject jsonObject) throws Exception {
        Invoke("Select", jsonObject);
    }

    // Batch_Save
    public static void Batch_Save(JSONObject jsonObject) throws Exception {
        Invoke("Batch_Save", jsonObject);
    }

    // Submit
    public static void Submit(JSONObject jsonObject) throws Exception {
        Invoke("Submit", jsonObject);
    }

    // Audit
    public static void Audit(JSONObject jsonObject) throws Exception {
        Invoke("Audit", jsonObject);
    }


    private static void Invoke(String uri,JSONObject jParas)
            throws Exception {

//        JSONArray jParas = new JSONArray();
//        jParas.add(formId);
//        jParas.add(content);

        HttpURLConnection connectionInvoke = initUrlConn(uri, jParas);

        BufferedReader reader = new BufferedReader(new InputStreamReader(
                connectionInvoke.getInputStream()));

        String line;
        System.out.println(" ============================= ");
        System.out.println(" Contents of post request ");
        System.out.println(" ============================= ");
        String sResult=null;
        while ((line = reader.readLine()) != null) {
            sResult = new String(line.getBytes(), "utf-8");
            System.out.println(sResult);
        }
        Results results = JSONObject.parseObject(sResult, Results.class);
        System.out.println(results+"就是这样子");
        System.out.println(" ============================= ");
        System.out.println(" Contents of post request ends ");
        System.out.println(" ============================= ");
        reader.close();

        connectionInvoke.disconnect();
    }

    /**
     * 把中文转成Unicode码
     *
     * @param str
     * @return
     */
    public static String chinaToUnicode(String str) {
        String result = "";
        for (int i = 0; i < str.length(); i++) {
            int chr1 = (char) str.charAt(i);
            if (chr1 >= 19968 && chr1 <= 171941) {// 汉字范围 \u4e00-\u9fa5 (中文)
                result += "\\u" + Integer.toHexString(chr1);
            } else {
                result += str.charAt(i);
            }
        }
        return result;
    }
}