最近我在开发小程序备案这块功能涉及到上传备案材料，我可以将自己的实现分享出来 。使用的是响应式编程。

先看接口层：

@RequestMapping(value = {"/security_superadmin/mini/icp/media/upload"}, method = RequestMethod.POST)
public Mono image_upload(@RequestPart("file") Mono filePartMono,
                                     @RequestParam(value="component_appid",required = true) String component_appid,
                                     @RequestParam(value="authorizer_appid",required = true) String authorizer_appid,
                                     @RequestHeader(value="admintoken", required = true) String token,
                                     @RequestHeader("Content-Length") long contentLength,
                                     @RequestParam(value="type",required = true) String type,
                                     @RequestParam(value="certificate_type",required = true) String certificate_type,
                                     @RequestParam(value="icp_order_field",required = true) String icp_order_field
                                     ) throws Throwable
   {

         return wechatPlatformService.uploadMediaFile( filePartMono, component_appid, authorizer_appid, type, certificate_type, icp_order_field).map(res -> res);

   }

再看服务层：

 public  Mono  uploadMediaFile(Mono filePartMono , String component_appid, String authorizer_appid, String type, String certificate_type, String icp_order_field)
        throws Throwable {

     return filePartMono.doOnNext(fp -> log.info("Receiving File:{}" ,fp.filename())).flatMap(filePart -> {

         PlatformGrant grant = null;
         try {
             grant = super.getApiToken(component_appid, authorizer_appid);

         } catch (Exception e) {

             return Mono.just(Response.error(e));
         }
         String url = "https://api.weixin.qq.com/wxa/icp/upload_icp_media?access_token=" + grant.getAuthorizer_access_token();
         log.info("---> url {}", url);
         log.info("---->go here <----");

         File temFile = new File("/tmp");
         if (!temFile.exists()) {
             temFile.mkdirs();
         }
         File upFile = new File(temFile + "/" + UUID.randomUUID() + ".jpg");
         if (!upFile.exists()) {
             try {
                 upFile.createNewFile();
             } catch (Exception e) {
                 return Mono.just(Response.error("上传文件异常:" + e.getMessage()));
             }

         }
         filePart.transferTo(upFile);

         byte[] bytes = null;
         try {
             bytes = Files.readAllBytes(upFile.toPath());
         } catch (Exception e) {
             return Mono.just(Response.error("上传文件异常:" + e.getMessage()));
         }

         HttpHeaders headers = new HttpHeaders();
         headers.setContentType(MediaType.MULTIPART_FORM_DATA);
         HttpHeaders pictureHeader = new HttpHeaders();
         pictureHeader.setContentDispositionFormData("file",upFile.getName());
         pictureHeader.setContentType(MediaType.IMAGE_PNG);
         ByteArrayResource bar = new ByteArrayResource(bytes);
         HttpEntity picturePart = new HttpEntity<>(bar, pictureHeader);
         MultiValueMap multipartRequest = new LinkedMultiValueMap<>();
         multipartRequest.add("media", picturePart);
         multipartRequest.add("type", type);
         multipartRequest.add("certificate_type", certificate_type);
         multipartRequest.add("icp_order_field", icp_order_field);
         HttpEntity entity = new HttpEntity(multipartRequest, headers);
         JSONObject json =  restTemplate.postForObject(url, entity, JSONObject.class);

         log.info("--->上传备案媒体素材结果{}", json.toJSONString());
         if (upFile.exists()){

             upFile.delete();
             log.info("---->删除文件<----");
         }
         Integer errocode = json.getInteger("errcode");
         if (0 == errocode.intValue()) {

             MiniMediaRecord record = new MiniMediaRecord();
             record.setMedia_id(json.getString("media_id"));
             record.setType(type);
             record.setAuthorizer_appid(authorizer_appid);
             record.setComponent_appid(component_appid);
             record.setAuthorizer_appname(grant.getMuch_mini_name() != null ? grant.getMuch_mini_name() : "");
             record.setCert_type(certificate_type);
             record.setSubmit_time(new Date());
             record.setIcp_order_field(icp_order_field);
             miniMediaRecordRepository.save(record);
         }

         return Mono.just(Response.success("success"));

     }).then(Mono.just(Response.success("success")));


}

需要注意的是： 微信官方的这个接口不能以JSON格式提交参数，使用 restTemplate 需要

构造出一个 HttpEntity<ByteArrayResource> 对象。

HttpEntity picturePart = new HttpEntity<>(bar, pictureHeader);

UI 界面：

响应结果：

希望有帮助。 欢迎加我微信：comeon_betty 来交流学习。

这个参数该怎么传啊？例如我上传的是营业执照，certificate_type和icp_order_field对应传啥？没有看到微信有文档解释呢

我也不行，你解决了吗？

content-type不能是json，要是multipart/form-data

待上传的图片或视频的二进制内容