tj_sfj/sfj/DA/util/DaHttpAction.java

package com.api.sfj.DA.util;

import com.alibaba.fastjson.JSONObject;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import weaver.general.BaseBean;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;


public class DaHttpAction {


    private static String FILENAME = "";
    private static String SESSION = "";
    private  static  File file = new File("");

    public static String getSESSION() {
        return SESSION;
    }

    public static void setSESSION(String SESSION) {
        DaHttpAction.SESSION = SESSION;
    }

    public String getFILENAME() {
        return FILENAME;
    }

    public void setFILENAME(String FILENAME) {
        this.FILENAME = FILENAME;
    }

    public File getFile() {
        return file;
    }

    public void setFile(File file) {
        this.file = file;
    }

    private static CloseableHttpClient httpClient = HttpClients.createDefault();

    private static final String ADDRESS_URL = "http://10.6.115.68:8082";

    private static String init() throws IOException {

        BaseBean bs = new BaseBean();
        bs.writeLog("进入归档初始化方法-->文件名称-->"+FILENAME);
        bs.writeLog("进入归档初始化方法-->文件名称长度-->"+String.valueOf(file.length()));
        String initpath = ADDRESS_URL + "/oa/InitUpload.do";
        bs.writeLog("进入归档初始化方法-->上传接口路径-->"+initpath);
        HttpPost httppost = new HttpPost(initpath);
        MultipartEntityBuilder mEntityBuilder = MultipartEntityBuilder.create();
        mEntityBuilder.addTextBody("fileName", FILENAME, ContentType.TEXT_PLAIN.withCharset("utf-8"));
        mEntityBuilder.addTextBody("fileSize", String.valueOf(file.length()));
        String reStr;
        JSONObject jsonObject;
        HttpResponse responce;
        httppost.setEntity(mEntityBuilder.build());
        try {
            bs.writeLog("进入初始化try/catch-->"+httppost);
            responce = httpClient.execute(httppost);
            bs.writeLog("进入归档初始化方法--执行接口返回结果-->"+responce);
            int resStatu = responce.getStatusLine().getStatusCode();
            bs.writeLog("第一个接口--resStatu--->"+resStatu);
            bs.writeLog("第一个接口--SC_OK--->"+HttpStatus.SC_OK);
            if (resStatu == HttpStatus.SC_OK) {
                HttpEntity entity = responce.getEntity();
                bs.writeLog(entity);
                reStr = EntityUtils.toString(entity);
                bs.writeLog("进入归档初始化方法响应-->"+reStr);
                jsonObject = JSONObject.parseObject(reStr);
                String session = jsonObject.getString("session");
                Integer code = jsonObject.getInteger("code");
                if (0==code){
                    return session;
                }
            }
        }catch (Exception e) {
            e.printStackTrace();
        }
        return "f";
    }

    private static boolean processData(String depId,String doctype) throws IOException {
        BaseBean bs = new BaseBean();
        bs.writeLog("进入上传校验方法-->");
        String upfile = ADDRESS_URL +"/oa/UploadFile.do";
        HttpPost httppost = new HttpPost(upfile);
        bs.writeLog("进入上传校验方法接口-->"+upfile);
        bs.writeLog("进入上传校验方法--打印FileName-->"+FILENAME);
        bs.writeLog("进入上传校验方法--打印Dept-->"+depId);
        bs.writeLog("进入上传校验方法--打印doctype-->"+doctype);
        MultipartEntityBuilder mEntityBuilder = MultipartEntityBuilder.create();
        mEntityBuilder.addTextBody("FileName", FILENAME, ContentType.TEXT_PLAIN.withCharset("utf-8"));
        mEntityBuilder.addTextBody("OffSoftName", "今易", ContentType.TEXT_PLAIN.withCharset("utf-8"));
        mEntityBuilder.addTextBody("OffSoftVer", "V1.0", ContentType.TEXT_PLAIN.withCharset("utf-8"));
        mEntityBuilder.addTextBody("Dept", depId, ContentType.TEXT_PLAIN.withCharset("utf-8"));//部门id
        mEntityBuilder.addTextBody("doctype", doctype, ContentType.TEXT_PLAIN.withCharset("utf-8"));//0收文，1发文
//        mEntityBuilder.addTextBody("Strategy", "sw", ContentType.TEXT_PLAIN.withCharset("utf-8"));
        String reStr;
        JSONObject jsonObject;
        HttpResponse responce;
        httppost.setEntity(mEntityBuilder.build());
        responce = httpClient.execute(httppost);
        int resStatu = responce.getStatusLine().getStatusCode();
        bs.writeLog("第三个接口--resStatu--->"+resStatu);
        bs.writeLog("第三个接口--SC_OK--->"+HttpStatus.SC_OK);
        if (resStatu == HttpStatus.SC_OK) {
            // get result data
            HttpEntity entity = responce.getEntity();
            reStr = EntityUtils.toString(entity);
            bs.writeLog("进入上传校验方法打印返回值-->"+reStr);
            jsonObject = JSONObject.parseObject(reStr);
            return 0 == jsonObject.getInteger("code");
        } else {
            return false;
        }

    }

    public static boolean uploadFile(String filePath) throws  Exception{
        BaseBean bs = new BaseBean();
//        String url  = ADDRESS_URL +"/oa/UploadData.do";
//        System.out.println("进入归档上传方法---session---->"+session);
//        System.out.println("进入归档上传方法---服务端发布的接口地址---->"+url);
//        System.out.println("进入归档上传方法---文件名称---->"+FILENAME);
//        System.out.println("进入归档上传方法-->文件名称长度-->"+String.valueOf(file.length()));
//        System.out.println("进入归档上传方法----需要传递到服务器的文件路径---"+filePath);//需要传递到服务器的文件路径
//            File file = new File(filePath);
//            ZipInputStream zipInputStream = null;
//            InputStream inputStream = null;
//            try {
//                //InputStream in = new FileInputStream(file);
//                if(!file.exists())
//                {
//                    throw  new WebApplicationException(404);
//                }
//                zipInputStream = new ZipInputStream(new FileInputStream(file));
//                if (zipInputStream.getNextEntry() != null) {
//                    inputStream = new BufferedInputStream(zipInputStream);
//                }
//                MultipartEntityBuilder entityBuilder = MultipartEntityBuilder.create();
//                entityBuilder.addTextBody("fileName", FILENAME);
//                entityBuilder.addTextBody("fileSize", String.valueOf(file.length()));
//                entityBuilder.addBinaryBody("file", inputStream,
//                        ContentType.MULTIPART_FORM_DATA, FILENAME);
//                HttpPost httpPost = new HttpPost(url);
//                httpPost.setEntity(entityBuilder.build());
//                //执行post接口
//                HttpResponse response = httpClient.execute(httpPost);
//                String result="";
//                if (response!=null && response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
//                    HttpEntity resEntity = response.getEntity();
//                    if(resEntity != null){
//                        result = EntityUtils.toString(resEntity, Consts.UTF_8);
//                    }
//                }
//                System.out.println("进入上传校验方法打印返回值-->"+result);
//                JSONObject jsonObject = JSONObject.parseObject(result);
//                return 0 == jsonObject.getInteger("code");
//            } catch (FileNotFoundException e) {
//                e.printStackTrace();
//            } catch (ClientProtocolException e) {
//                e.printStackTrace();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
        try {
            String url  = ADDRESS_URL +"/oa/UploadData.do";
            HttpPost httppost = new HttpPost(url);
            FileInputStream fis = new FileInputStream(file);
            BufferedInputStream bis = new BufferedInputStream(fis);
            int count = 1000000;
            byte[] bytes = new byte[count];
            int len = -1;
            String reStr;
            JSONObject jsonObject;
            HttpResponse responce;
            HttpEntity entity;
            while ((len = bis.read(bytes, 0, count)) != -1) {
                MultipartEntityBuilder mEntityBuilder = MultipartEntityBuilder.create();
                mEntityBuilder.addTextBody("fileName", FILENAME, ContentType.TEXT_PLAIN.withCharset("utf-8"));
                mEntityBuilder.addTextBody("fileSize", String.valueOf(len), ContentType.TEXT_PLAIN.withCharset("utf-8"));
                mEntityBuilder.addBinaryBody("file", bytes, ContentType.DEFAULT_BINARY, FILENAME);
                //mEntityBuilder.addTextBody("Dept", "市委", ContentType.TEXT_PLAIN.withCharset("utf-8"));
                httppost.setEntity(mEntityBuilder.build());
                responce = httpClient.execute(httppost);
                int resStatu = responce.getStatusLine().getStatusCode();

                if (resStatu == HttpStatus.SC_OK) {
                    // get result data
                    entity = responce.getEntity();
                    reStr = EntityUtils.toString(entity);
                    jsonObject = JSONObject.parseObject(reStr);
                    bs.writeLog("reStr->"+reStr);
                    if (0 != jsonObject.getInteger("code")) {
                        bs.writeLog("上传出错");
                        return false;
                    }
                } else {
                    bs.writeLog("上传出错");
                    return false;
                }
            }
            bs.writeLog("上传完成");
            return true;
        } finally {
            bs.writeLog("上传完成");
        }
    }



    public static int doit(String filename,String  filepath ,String doctype,String depId) throws  Exception{
        BaseBean bs = new BaseBean();
        bs.writeLog("点击归档按钮-->filename-->"+filename);
        bs.writeLog("点击归档按钮-->filepath-->"+filepath);
        int success =9;
        DaHttpAction HttpAction = new DaHttpAction();
        HttpAction.setFILENAME(filename);
        HttpAction.setFile(new File(filepath));
        bs.writeLog("设置文件名称-->"+FILENAME);
        bs.writeLog("设置文件大小-->"+String.valueOf(file.length()));
        try {
            String session = init();
            if ("f".equals(session)) {
                bs.writeLog("初始化出错");
                return 2;
            }else {
                bs.writeLog("第一个接口执行成功-->文件初始化成功-->session-->"+session);
                if (!uploadFile(filepath)) {
                    bs.writeLog("文件上传出错");
                    return 4;
                }else {
                    bs.writeLog("第二个接口执行成功-->文件上传成功");
                    bs.writeLog("上传成功");
                    if (!processData(depId,doctype)) {
                        bs.writeLog("处理失败");
                        return 5;
                    } else {
                        success=0;
                        bs.writeLog("第三个接口执行成功-->文件验证成功");
                    }
                }
            }

        } finally {
            success=0;
//            httpClient.close();
        }
        return success;
    }



}