图片上传

stdiet-admin/src/main/java/com/stdiet/web/controller/custom/SysWxSaleAccountController.java

@@ -137,14 +137,12 @@ public class SysWxSaleAccountController extends BaseController {
                 accessToken = wxAccessToken.getAccessToken();
             }
 
-            File uploadFile = new File(oriFilePath);
-
-            WxFileUploadResult result = WxTokenUtils.uploadImage(uploadFile, oriFileName, accessToken);
+            WxFileUploadResult result = WxTokenUtils.uploadImage(oriFilePath, oriFileName, accessToken);
 
             AjaxResult ajax = AjaxResult.success();
             ajax.put("fileName", fileName);
             ajax.put("wxInfo", result);
-            ajax.put("file", uploadFile);
+            ajax.put("file", oriFilePath);
             ajax.put("accessToken", accessToken);
             ajax.put("url", url);
             return ajax;

stdiet-custom/src/main/java/com/stdiet/custom/utils/WxTokenUtils.java

@@ -9,9 +9,10 @@ import com.stdiet.custom.domain.wechat.WxFileUploadResult;
 import com.thoughtworks.xstream.XStream;
 import org.apache.commons.io.IOUtils;
 
-import java.io.*;
-import java.net.HttpURLConnection;
-import java.net.URL;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
 import java.nio.charset.StandardCharsets;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
@@ -54,88 +55,23 @@ public class WxTokenUtils {
      * @return String url的响应信息返回值
      * @throws IOException
      */
-    public static WxFileUploadResult uploadImage(File file, String fileName, String accessToken) throws Exception {
-        String url = uploadMaterialUrl.replaceAll("ACCESS_TOKEN", accessToken);;//微信上传图片的url
-        String result = null;
-        if (!file.exists() || !file.isFile()) {
-            throw new IOException("文件不存在");
+    public static WxFileUploadResult uploadImage(String filePath, String fileName, String accessToken) throws Exception {
+        String[] cmds = {"curl", uploadMaterialUrl.replaceAll("ACCESS_TOKEN", accessToken), "-F"
+                , "media='@" + filePath + ";filename=" + fileName + "'"};//必须分开写，不能有空格
+
+        ProcessBuilder process = new ProcessBuilder(cmds);
+        Process p = process.start();
+        BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()));
+        StringBuilder builder = new StringBuilder();
+        String line = null;
+        while ((line = reader.readLine()) != null) {
+            builder.append(line);
+            builder.append(System.getProperty("line.separator"));
         }
-        // 第一部分
-        URL urlObj = new URL(url);
-        HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();
+        JSONObject obj = JSONObject.parseObject(builder.toString());
 
-        // 设置关键值
-        con.setRequestMethod("POST"); // 以Post方式提交表单，默认get方式
-        con.setDoInput(true);
-        con.setDoOutput(true);
-        con.setUseCaches(false); // post方式不能使用缓存
+        return JSONObject.toJavaObject(obj, WxFileUploadResult.class);
 
-        // 设置请求头信息
-        con.setRequestProperty("Connection", "Keep-Alive");
-        con.setRequestProperty("Charset", "UTF-8");
-
-        // 设置边界
-        String BOUNDARY = "----------" + System.currentTimeMillis();
-        con.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);
-
-        // 请求正文信息
-        // 第一部分：
-        StringBuilder sb = new StringBuilder();
-        sb.append("--"); // 必须多两道线
-        sb.append(BOUNDARY);
-        sb.append("\r\n");
-        sb.append("Content-Disposition: form-data;name=\"file\";filename=\"" + file.getName() + "\"\r\n");
-        sb.append("Content-Type:application/octet-stream\r\n\r\n");
-
-        byte[] head = sb.toString().getBytes("utf-8");
-        // 获得输出流
-        OutputStream out = new DataOutputStream(con.getOutputStream());
-        // 输出表头
-        out.write(head);
-
-        // 文件正文部分
-        // 把文件已流文件的方式 推入到url中
-        DataInputStream in = new DataInputStream(new FileInputStream(file));
-        int bytes = 0;
-        byte[] bufferOut = new byte[1024];
-        while ((bytes = in.read(bufferOut)) != -1) {
-            out.write(bufferOut, 0, bytes);
-        }
-        in.close();
-
-        // 结尾部分
-        byte[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线
-        out.write(foot);
-        out.flush();
-        out.close();
-
-        StringBuffer buffer = new StringBuffer();
-        BufferedReader reader = null;
-        try {
-            // 定义BufferedReader输入流来读取URL的响应
-            reader = new BufferedReader(new InputStreamReader(con.getInputStream()));
-            String line = null;
-            while ((line = reader.readLine()) != null) {
-                // System.out.println(line);
-                buffer.append(line);
-            }
-            if (result == null) {
-                result = buffer.toString();
-            }
-        } catch (IOException e) {
-            System.out.println("发送POST请求出现异常！" + e);
-            e.printStackTrace();
-            throw new IOException("数据读取异常");
-        } finally {
-            if (reader != null) {
-                reader.close();
-            }
-        }
-        JSONObject jsonObject = JSONObject.parseObject(result);
-        WxFileUploadResult result1 = JSONObject.toJavaObject(jsonObject, WxFileUploadResult.class);
-        result1.setMediaId(result);
-        result1.setUrl(fileName);
-        return result1;
     }
 
     /**