• 请求工具类和base64转成MultipartFile工具类

    请求工具类 hutool包HttpRequest带请求头和请求体发送post请求

    将MultipartFile文件保存到本地

    1. package org.jeecg.modules.quota.utils;
    2.  
    3. import cn.hutool.core.bean.BeanUtil;
    4. import cn.hutool.http.HttpRequest;
    5. import cn.hutool.json.JSONArray;
    6. import cn.hutool.json.JSONObject;
    7. import cn.hutool.json.JSONUtil;
    8. import org.jeecg.common.constant.CommonConstant;
    9. import org.jeecg.common.util.MinioUtil;
    10. import org.jeecg.common.util.ZOSUtil;
    11. import org.jeecg.modules.quota.controller.DataSynchronismController;
    12. import org.jeecg.modules.quota.entity.SysCertPdf;
    13. import org.jeecg.modules.quota.service.ISysCertPdfService;
    14. import org.springframework.beans.factory.annotation.Autowired;
    15. import org.springframework.web.client.RestTemplate;
    16. import org.springframework.web.multipart.MultipartFile;
    17.  
    18. import java.io.*;
    19. import java.util.*;
    20. import java.util.stream.Collectors;
    21. import java.util.stream.Stream;
    22.  
    23. /**
    24.  * @Author leitao
    25.  * @Date 2023/9/21 15:28
    26.  * @description: 请求工具类
    27.  * @Title: RequestYxeUtil
    28.  * @Package org.jeecg.modules.quota.utils
    29.  */
    30. public class RequestYxeUtil {
    31.     //    private static final String token_url = "http://23:89/xxxx/xxxx/token?clientId=2c9642bd21c0000&clientSecret=6abc4457bc60e0d2e0b08a8b9828c6e9d86250458b4de51bf82d9604abeb987d3";
    32.     //token（线上）
    33.     private static final String token_url = "http://23:89/xxxx/xxxx/token?clientId=2c9fb2d21c0000&clientSecret=6ab3e8291b9af828c6e9d86250458b4de51bf82d9604abeb987d3";
    34.     //获取渔船照片证据
    35.     private static final String XeblCertificate_url = "http://23:89/xxx/xxxx/xxxxx/XeblCertificate";
    36.  
    37.     //token（）
    38.     private static final String XeblCyzp_token_url = "http://28:87/xxx//xxxx/token";
    39.  
    40.     //获取船员照片
    41.     private static final String XeblCyzp_url = "http://28:87/xxx//xxxx/CyService/getCyPhoto";
    42.  
    43.     /**
    44.      * 限额xxxx证书
    45.      *
    46.      * @param cm
    47.      * @param ycid
    48.      * @throws IOException
    49.      */
    50.     public static ArrayList xeblCertificate(String cm, String ycid, String uploadType) throws Exception {
    51.         ArrayList sysCertPdfs = new ArrayList<>();
    52.         String requestResult = HttpRequest.post(token_url).execute().body();
    53.         JSONObject jsonResult = JSONUtil.parseObj(requestResult);
    54.         String code = jsonResult.getStr("code");
    55.         if ("0".equals(code)) {
    56.             String result = jsonResult.getStr("result");
    57.             JSONObject resultJson = JSONUtil.parseObj(result);
    58.             String accessToken = resultJson.getStr("accessToken");
    59.  
    60.             //json格式
    61.             HashMap paramMap = new HashMap<>();
    62.             paramMap.put("shipName", cm);
    63.             paramMap.put("shipInfoId", ycid);
    64.             String xeblCertificateResult = HttpRequest.post(XeblCertificate_url)
    65.                     .header("X-Access-Token", accessToken)
    66.                     .body(JSONUtil.toJsonPrettyStr(paramMap)).execute().body();
    67.             JSONObject jsonObject = JSONUtil.parseObj(xeblCertificateResult);
    68.             String code1 = jsonObject.getStr("code");
    69.             if ("200".equals(code1)) {
    70.                 //将result转成JSONObject
    71.                 JSONObject json_result = jsonObject.getJSONObject("result");
    72.                 Map map = JSONUtil.parseObj(json_result);
    73.  
    74.                 Map sysCertPdfMap = new HashMap<>();
    75.  
    76.                 Object pngCert = map.get("pngCert");
    77.                 if (pngCert instanceof JSONArray) {
    78.                     JSONArray jsonArray = (JSONArray) pngCert;
    79.                     for (Object o : jsonArray) {
    80.                         Map pngCertMap = (Map) o;
    81.                         for (String value : pngCertMap.keySet()) {
    82.                             SysCertPdf sysCertPdf = new SysCertPdf();
    83.                             String base64 = (String) pngCertMap.get(value);
    84.                             MultipartFile pngMultipartFile = Base64ToMultipartFileConverter.convert(base64, ycid + ".png");
    85.                             uploadFile(pngMultipartFile, value, "png", ycid, uploadType, sysCertPdf);
    86.                             sysCertPdfMap.put(value, sysCertPdf);
    87.                         }
    88.                     }
    89.                 }
    90.                 Object pdfCert = map.get("pdfCert");
    91.                 if (pdfCert instanceof JSONArray) {
    92.                     JSONArray jsonArray = (JSONArray) pdfCert;
    93.                     for (Object o : jsonArray) {
    94.                         Map pngCertMap = (Map) o;
    95.                         for (String value : pngCertMap.keySet()) {
    96.                             String base64 = (String) pngCertMap.get(value);
    97.                             MultipartFile pdfMultipartFile = Base64ToMultipartFileConverter.convert(base64, ycid + ".pdf");
    98.                             uploadFile(pdfMultipartFile, value, "pdf", ycid, uploadType, sysCertPdfMap.get(value));
    99.                         }
    100.                     }
    101.                 }
    102.                 for (String s : sysCertPdfMap.keySet()) {
    103.                     sysCertPdfs.add(sysCertPdfMap.get(s));
    104.                 }
    105.             }
    106.  
    107.         }
    108.         return sysCertPdfs;
    109.     }
    110.  
    111.     /**
    112.      * 将文件上传到服务器
    113.      *
    114.      * @param multipartFile
    115.      * @param value
    116.      * @param type
    117.      * @param ycid
    118.      * @param uploadType
    119.      * @param sysCertPdf
    120.      * @return
    121.      * @throws Exception
    122.      */
    123.     public static SysCertPdf uploadFile(MultipartFile multipartFile, String value, String type, String ycid, String uploadType, SysCertPdf sysCertPdf) throws Exception {
    124.         String bizPath = "pdfCert" + "/" + value;
    125.         String fileUrl = " ";
    126.         if ("png".equals(type)) {
    127.             if (CommonConstant.UPLOAD_TYPE_MINIO.equals(uploadType)) {
    128.                 fileUrl = MinioUtil.upload(multipartFile, bizPath);
    129.                 fileUrl = fileUrl.substring(1, fileUrl.length());
    130.                 //保存文件信息
    131.                 // 获取文件名
    132.                 sysCertPdf.setModelName(value);
    133.                 sysCertPdf.setPngPath(fileUrl);
    134.                 sysCertPdf.setCertId(ycid);
    135.                 sysCertPdf.setCertType(1);
    136.                 sysCertPdf.setDeleted(0);
    137.                 return sysCertPdf;
    138.             } else if (CommonConstant.UPLOAD_TYPE_ZOS.equals(uploadType)) {
    139.                 fileUrl = ZOSUtil.upload(multipartFile, bizPath);
    140.                 sysCertPdf.setModelName(value);
    141.                 sysCertPdf.setPngPath(fileUrl);
    142.                 sysCertPdf.setCertId(ycid);
    143.                 sysCertPdf.setCertType(1);
    144.                 sysCertPdf.setDeleted(0);
    145.                 return sysCertPdf;
    146.             }
    147.         } else if ("pdf".equals(type)) {
    148.             if (BeanUtil.isNotEmpty(sysCertPdf)) {
    149.                 if (CommonConstant.UPLOAD_TYPE_MINIO.equals(uploadType)) {
    150.                     fileUrl = MinioUtil.upload(multipartFile, bizPath);
    151.                     //保存文件信息
    152.                     // 获取文件名
    153.                     sysCertPdf.setPdfPath(fileUrl);
    154.                     return sysCertPdf;
    155.                 } else if (CommonConstant.UPLOAD_TYPE_ZOS.equals(uploadType)) {
    156.                     fileUrl = ZOSUtil.upload(multipartFile, bizPath);
    157.                     sysCertPdf.setPdfPath(fileUrl);
    158.                     return sysCertPdf;
    159.                 }
    160.             }
    161.         }
    162.  
    163.         return null;
    164.     }
    165.  
    166.     /**
    167.      * 将文件保存到本地
    168.      *
    169.      * @param file
    170.      * @param type
    171.      * @param value
    172.      * @param ycid
    173.      * @throws IOException
    174.      */
    175.     public static void saveFileToLocal(MultipartFile file, String type, String value, String ycid) throws IOException {
    176.         String fileName = file.getOriginalFilename();
    177.         String filePath = "E:\\workspace\\" + fileName + "." + type;
    178.         String filePath1 = "E:\\workspace\\" + "pdfCert" + "/" + value + "/" + ycid + "." + type;
    179.         File localFile = new File(filePath1);
    180.         // 文件名
    181.         if (!localFile.getParentFile().exists()) {
    182.             localFile.getParentFile().mkdirs();// 新建目录
    183.         }
    184.         file.transferTo(localFile);
    185.     }
    186.  
    187.     /**
    188.      * 根据船只身份证查询照片
    189.      *
    190.      * @param sfzhm
    191.      * @param uploadType
    192.      * @return
    193.      */
    194.     public static SysCertPdf xeblCyzp(String sfzhm, String uploadType) throws Exception {
    195.         //
    196.         HashMap paramMap = new HashMap<>();
    197.         paramMap.put("clientId", "402881f167e00001");
    198.         paramMap.put("clientSecret", "482978cf5bcb08bc51dcec5b680ccff5ff54ceef53cfde562");
    199.         //form-data
    200.         String requestResult = HttpRequest.post(XeblCyzp_token_url).form(paramMap)
    201.                 .execute().body();
    202.         JSONObject jsonResult = JSONUtil.parseObj(requestResult);
    203.  
    204.         String code = jsonResult.getStr("code");
    205.         if ("0".equals(code)) {
    206.             String result = jsonResult.getStr("result");
    207.             JSONObject resultJson = JSONUtil.parseObj(result);
    208.             String accessToken = resultJson.getStr("accessToken");
    209.             String[] str = new String[]{sfzhm};
    210.             String xeblCyzpUrlResult = HttpRequest.post(XeblCyzp_url)
    211.                     .header("X-Access-Token", accessToken)
    212.                     .body(Arrays.toString(str)).execute().body();
    213.             JSONObject jsonObject = JSONUtil.parseObj(xeblCyzpUrlResult);
    214.             String code1 = jsonObject.getStr("code");
    215.             if ("200".equals(code1)) {
    216.                 String str_result = jsonObject.getStr("result");
    217.                 Map collect = Arrays.stream(str_result.split(",")).collect(Collectors.toMap((e -> e.split(":")[0]), (e -> e.split(":")[1])));
    218.                 StringBuilder stringBuilder = new StringBuilder();
    219.                 StringBuilder append = stringBuilder.append("[{\"").append(sfzhm).append("\"");
    220.                 String sfzhmBase64 = collect.get(append.toString());
    221.                 String substring = sfzhmBase64.substring(1,sfzhmBase64.length()-3);
    222.                 MultipartFile jpgMultipartFile = Base64ToMultipartFileConverter.convert(substring, sfzhm + ".jpg");
    223.                 return uploadCyPhoto(jpgMultipartFile, sfzhm, uploadType);
    224.             }
    225.         }
    226.  
    227.         return null;
    228.     }
    229.  
    230.     /**
    231.      * 上传船员照片
    232.      * @param jpgMultipartFile
    233.      * @param sfzhm
    234.      * @param uploadType
    235.      * @return
    236.      * @throws Exception
    237.      */
    238.     private static SysCertPdf uploadCyPhoto(MultipartFile jpgMultipartFile, String sfzhm, String uploadType) throws Exception {
    239.         String bizPath = "cyPhoto";
    240.         String fileUrl = " ";
    241.         SysCertPdf sysCertPdf = new SysCertPdf();
    242.         if (CommonConstant.UPLOAD_TYPE_MINIO.equals(uploadType)) {
    243.             fileUrl = MinioUtil.upload(jpgMultipartFile, bizPath);
    244.             fileUrl = fileUrl.substring(1);
    245.             //保存文件信息
    246.             // 获取文件名
    247.             sysCertPdf.setModelName("cyPhoto");
    248.             sysCertPdf.setPngPath(fileUrl);
    249.             sysCertPdf.setCertId(sfzhm);
    250.             sysCertPdf.setCertType(2);
    251.             sysCertPdf.setDeleted(0);
    252.             return sysCertPdf;
    253.         }else if (CommonConstant.UPLOAD_TYPE_ZOS.equals(uploadType)) {
    254.             fileUrl = ZOSUtil.upload(jpgMultipartFile, bizPath);
    255.             sysCertPdf.setModelName("cyPhoto");
    256.             sysCertPdf.setPngPath(fileUrl);
    257.             sysCertPdf.setCertId(sfzhm);
    258.             sysCertPdf.setCertType(2);
    259.             sysCertPdf.setDeleted(0);
    260.             return sysCertPdf;
    261.         }
    262.         return null;
    263.     }
    264. }

    将 base64转成MultipartFile 

    1. package org.jeecg.modules.quota.utils;
    2.  
    3.  
    4. import org.apache.commons.fileupload.FileItem;
    5. import org.apache.commons.io.FileUtils;
    6. import org.springframework.mock.web.MockMultipartFile;
    7. import org.springframework.util.Base64Utils;  
    8. import org.springframework.core.io.ByteArrayResource;
    9. import org.springframework.web.multipart.MultipartFile;
    10. import org.springframework.web.multipart.commons.CommonsMultipartFile;
    11.  
    12. import java.io.ByteArrayInputStream;
    13. import java.io.File;
    14. import java.io.IOException;
    15. import java.nio.charset.StandardCharsets;
    16. import java.util.Base64;
    17.  
    18. public class Base64ToMultipartFileConverter {
    19.  
    20.     public static MultipartFile convert(String base64String, String fileName) {
    21.         // 解码Base64字符串为字节数组
    22.         byte[] bytes = Base64.getDecoder().decode(base64String);
    23.  
    24.         // 创建MockMultipartFile对象并设置文件内容和文件名
    25.         MockMultipartFile multipartFile = new MockMultipartFile("file", fileName, "application/octet-stream", bytes);
    26.  
    27.         return multipartFile;
    28.     }
    29.  
    30. }

    hutool发送＋参数get请求

    1. //地址
    2.         String checkur = downloa.getLoadConfigUrl();
    3.         //设备序列号
    4.         String deviceId = downloa.getDeviceId();
    5.  
    6.         HashMap paramMap = new HashMap();
    7.         paramMap.put("deviceId", deviceId);
    8.         //!!!!!!!!!!!!!!++++=
    9.         //发送post请求
    10.         String jsonResult = HttpRequest.post(checkur)
    11.                 .body(JSONUtil.toJsonPrettyStr(paramMap))
    12.                 .execute().body();
    13.         JSONObject jsonObject = JSONUtil.parseObj(jsonResult);
    14.  
    15.         String responseCode = jsonObject.getStr("responseCode");
    16.         if (Constants.SUCCESS.equals(responseCode)) {
    17.             BasicDownloadRes basicDownloadRes = new BasicDownloadRes();
    18.             basicDownloadRes.setResponseMessage(jsonObject.getStr("responseMessage"));
    19.             basicDownloadRes.setResponseCode(responseCode);
    20.             this.insertBasicDownloadRes(basicDownloadRes);
    21.             /**
    22.              * @Description: TODO
    23.              * @Author LeiTao
    24.              * @Date 2022/4/23
    25.              * @Version V1.0
    26.              **/
    27.             String data = jsonObject.getStr("data");
    28.  
    29.             Map map = JSONUtil.parseObj(data);
    30.             //行政区划代码
    31.             List> region = (List>) map.get("region");
    32.             this.basicDataDownloadRegionService.deleteRegionAll();
    33.  
    34.             for (Map regionMap : region) {
    35.                 BasicDataDownloadRegion basicDataDownloadRegionService = new BasicDataDownloadRegion();
    36.                 basicDataDownloadRegionService.setCode((String) regionMap.get("code"));
    37.                 basicDataDownloadRegionService.setFullName((String) regionMap.get("fullName"));
    38.                 basicDataDownloadRegionService.setName((String) regionMap.get("name"));
    39.                 basicDataDownloadRegionService.setType((Integer) regionMap.get("type"));
    40.                 this.basicDataDownloadRegionService.insertBasicDataDownloadRegion(basicDataDownloadRegionService);
    41.             }
    42.  
    43.             //行业代码
    44.             List> industry = (List>) map.get("industry");
    45.             basicDataDownloadIndustryService.deleteIndustryAll();
    46.  
    47.             for (Map industryMap : industry) {
    48.                 BasicDataDownloadIndustry basicDataDownloadIndustry = new BasicDataDownloadIndustry();
    49.                 basicDataDownloadIndustry.setCode((String) industryMap.get("code"));
    50.                 basicDataDownloadIndustry.setFullName((String) industryMap.get("fullName"));
    51.                 basicDataDownloadIndustry.setJgzh(Boolean.toString((Boolean) industryMap.get("jgzh")));
    52.                 basicDataDownloadIndustry.setName((String) industryMap.get("name"));
    53.                 basicDataDownloadIndustry.setPcode((String) industryMap.get("pcode"));
    54.                 basicDataDownloadIndustryService.insertBasicDataDownloadIndustry(basicDataDownloadIndustry);
    55.             }

  • 相关阅读:
    基于java的CRM客户关系管理系统的设计与实现
    QT实现TCP通信（服务器与客户端搭建）
    如何设计一条大型PLC生产线系统
    Nacos安装讲解教程
    面试题汇总
    2024级199管理类联考之写作
    【编译原理】词法分析
    JEECG BOOT 前端记录
    Kubernetes:kube-apiserver 之 scheme（二）
    Java开发 - Redis常见问题场景及解决办法一览
  • 原文地址：https://blog.csdn.net/weixin_60948956/article/details/133276941