From d7ba79f26f4b032641013f81b7cf23d21c12a799 Mon Sep 17 00:00:00 2001 From: huangdeliang Date: Mon, 1 Feb 2021 15:38:07 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9B=BE=E7=89=87=E4=B8=8A=E4=BC=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../custom/SysWxSaleAccountController.java | 6 +- .../com/stdiet/custom/utils/WxTokenUtils.java | 100 ++++-------------- 2 files changed, 20 insertions(+), 86 deletions(-) diff --git a/stdiet-admin/src/main/java/com/stdiet/web/controller/custom/SysWxSaleAccountController.java b/stdiet-admin/src/main/java/com/stdiet/web/controller/custom/SysWxSaleAccountController.java index 881d748fe..f771961b1 100644 --- a/stdiet-admin/src/main/java/com/stdiet/web/controller/custom/SysWxSaleAccountController.java +++ b/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; diff --git a/stdiet-custom/src/main/java/com/stdiet/custom/utils/WxTokenUtils.java b/stdiet-custom/src/main/java/com/stdiet/custom/utils/WxTokenUtils.java index f6ad149c2..e668ffbb0 100644 --- a/stdiet-custom/src/main/java/com/stdiet/custom/utils/WxTokenUtils.java +++ b/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; } /**