• Collectors.groupingBy()

    List.stream().collect(Collectors.groupingBy(e -> e.getZshm() + e.getZszw() + e.getZszt()))

     

    1. package org.jeecg.modules.quota.xxljob;
    2.  
    3. import cn.hutool.core.bean.BeanUtil;
    4. import cn.hutool.http.HttpRequest;
    5. import cn.hutool.json.JSONObject;
    6. import cn.hutool.json.JSONUtil;
    7. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    8. import com.xxl.job.core.biz.model.ReturnT;
    9. import com.xxl.job.core.handler.annotation.XxlJob;
    10. import lombok.extern.slf4j.Slf4j;
    11. import org.jeecg.common.api.vo.Result;
    12. import org.jeecg.modules.quota.entity.ChuanYuan;
    13. import org.jeecg.modules.quota.entity.ChuanYuanZhengShu;
    14. import org.jeecg.modules.quota.entity.JcYc;
    15. import org.jeecg.modules.quota.entity.SysCertPdf;
    16. import org.jeecg.modules.quota.entity.cnfaidata.DsCyzsxx;
    17. import org.jeecg.modules.quota.entity.cnfaidata.DsYcjbxx;
    18. import org.jeecg.modules.quota.service.*;
    19. import org.jeecg.modules.quota.utils.RequestYxeUtil;
    20. import org.jeecg.modules.system.mapper.SysDictMapper;
    21. import org.springframework.beans.factory.annotation.Autowired;
    22. import org.springframework.beans.factory.annotation.Value;
    23. import org.springframework.data.redis.core.RedisTemplate;
    24. import org.springframework.stereotype.Component;
    25. import org.springframework.web.bind.annotation.GetMapping;
    26.  
    27. import java.text.ParseException;
    28. import java.text.SimpleDateFormat;
    29. import java.util.*;
    30. import java.util.stream.Collectors;
    31.  
    32. /**
    33.  * 渔船、证书、船员+证书，数据接口同步
    34.  */
    35. @Component
    36. @Slf4j
    37. public class JcYcJobHandler {
    38.     private static final String YC_MAX_TIME = "yc_max_time";
    39.     private static final String CYZSXX_MAX_TIME = "cyzsxx_max_time";
    40.     private static final String CYXX_MAX_TIME = "cyxx_max_time";
    41.     @Autowired
    42.     private IJcYcService jcYcService;
    43.     @Autowired
    44.     private IDsYcjbxxService dsYcjbxxService;
    45.     @Autowired
    46.     private IChuanYuanZhengShuService chuanYuanZhengShuService;
    47.     @Autowired
    48.     private IDsCyzsxxService dsCyzsxxService;
    49.     @Autowired
    50.     private SysDictMapper sysDictMapper;
    51.     @Autowired
    52.     private IChuanYuanService chuanYuanService;
    53.     @Autowired
    54.     private RedisTemplate redisTemplate;
    55.     @Autowired
    56.     private ISysCertPdfService sysCertPdfService;
    57.     @Value(value = "${jeecg.uploadType}")
    58.     private String uploadType;
    59.  
    60.     /**
    61.      * 基础渔船信息同步
    62.      * @return
    63.      * @throws ParseException
    64.      */
    65.     @XxlJob(value = "ycjbxx")
    66.     public ReturnT ycjbxx(String params) throws Exception {
    67.  
    68.         String ycMaxTime = dsYcjbxxService.queryMaxTime();
    69.         if (redisTemplate.hasKey(YC_MAX_TIME)) {
    70.             String redisYcTime = (String) redisTemplate.opsForValue().get(YC_MAX_TIME);
    71.             if (redisYcTime != null && !redisYcTime.equals(ycMaxTime)) {
    72.                 ArrayList updateList = new ArrayList<>();
    73.                 ArrayList insertList = new ArrayList<>();
    74.                 //需要同步的鱼小二 数据
    75.                 QueryWrapper queryWrapper = new QueryWrapper<>();
    76.                 queryWrapper.eq("YCSZDQMC", "苍南县");
    77.                 List dsYcjbxxList = dsYcjbxxService.list(queryWrapper);
    78.                 List jcYcList = jcYcService.list();
    79.                 Map> jcYcMap = jcYcList.stream().collect(Collectors.groupingBy(JcYc::getId));
    80.                 for (DsYcjbxx dsYcjbxx : dsYcjbxxList) {
    81.                     if (jcYcMap.get(dsYcjbxx.getId()) != null && !jcYcMap.get(dsYcjbxx.getId()).isEmpty()) {
    82.                         JcYc jcYc = jcYcMap.get(dsYcjbxx.getId()).get(0);
    83.                         if ("修改记录".equals(dsYcjbxx.getGxcz())) {
    84.                             // 数据已存在，执行更新操作
    85.                             jcYc.setYcssd(dsYcjbxx.getYcszdqdm());
    86.                             jcYc.setCjg(dsYcjbxx.getCjgcn());
    87.                             jcYc.setZycs(dsYcjbxx.getZycs());
    88.                             jcYc.setSyzxm(dsYcjbxx.getCbsyrmc());
    89.                             jcYc.setSyzdz(dsYcjbxx.getCbsyrdz());
    90.                             jcYc.setSyzdh(dsYcjbxx.getCbsyrdh());
    91.                             jcYc.setYzbm(dsYcjbxx.getYzbm());
    92.                             updateList.add(jcYc);
    93.                             System.out.println("基础渔船信息同步,数据已更新: cm=" + jcYc.getCm());
    94.                         } else if ("删除记录".equals(dsYcjbxx.getGxcz())) {
    95.                             jcYc.setDelFlag(1);
    96.                             updateList.add(jcYc);
    97.                             System.out.println("基础渔船信息同步,数据已删除: cm=" + jcYc.getCm());
    98.                         }
    99.                     } else {
    100.                         // 数据不存在，执行插入操作
    101.                         JcYc jcYcNew = new JcYc();
    102.                         jcYcNew.setSysOrgCode("A01");
    103.                         jcYcNew.setId(dsYcjbxx.getId());
    104.                         jcYcNew.setCm(dsYcjbxx.getCm());
    105.                         jcYcNew.setYcm(dsYcjbxx.getYcm());
    106.                         jcYcNew.setYcssd(dsYcjbxx.getYcszdqdm());
    107.                         jcYcNew.setCjg(dsYcjbxx.getCjgcn());
    108.                         jcYcNew.setZccmc(dsYcjbxx.getZccmc());
    109.                         jcYcNew.setZccyw(dsYcjbxx.getZccyw());
    110.                         jcYcNew.setZccdz(dsYcjbxx.getZccdz());
    111.                         jcYcNew.setZccdzyw(dsYcjbxx.getZccdzyw());
    112.                         jcYcNew.setCc(dsYcjbxx.getCc());
    113.                         jcYcNew.setXk(dsYcjbxx.getXk());
    114.                         jcYcNew.setXs(dsYcjbxx.getXs());
    115.                         jcYcNew.setZdw(dsYcjbxx.getZdw());
    116.                         jcYcNew.setJdw(dsYcjbxx.getJdw());
    117.                         jcYcNew.setZjzgl(dsYcjbxx.getZjzgl());
    118.                         String ctcz = dsYcjbxx.getCtcz();
    119.                         if (BeanUtil.isNotEmpty(ctcz)) {
    120.                             //限额捕捞_渔船管理_船体材质
    121.                             String valByText = sysDictMapper.getValByText("1682656333384515586", ctcz);
    122.                             jcYcNew.setCtcz(Integer.valueOf(valByText));
    123.                         }
    124.                         String jzwgrq = dsYcjbxx.getJzwgrq();
    125.                         if (BeanUtil.isNotEmpty(jzwgrq)) {
    126.                             //String转Date
    127.                             Date date = new SimpleDateFormat("yyyy-MM-dd").parse(jzwgrq);
    128.                             jcYcNew.setJzwgrq(date);
    129.                         }
    130.                         jcYcNew.setCbhh(dsYcjbxx.getCbhhsbm());
    131.                         String zylx = dsYcjbxx.getZylx();
    132.                         if (BeanUtil.isNotEmpty(zylx)) {
    133.                             //限额捕捞_渔船管理_作业类型
    134.                             String valByText = sysDictMapper.getValByText("1683404442990235649", zylx);
    135.                             jcYcNew.setZylx(Integer.valueOf(valByText));
    136.                         }
    137.                         jcYcNew.setZyfs(dsYcjbxx.getZyfs());
    138.                         jcYcNew.setZyfs2(dsYcjbxx.getZyfs2());
    139.                         jcYcNew.setZycs(dsYcjbxx.getZycs());
    140.                         jcYcNew.setSyzxm(dsYcjbxx.getCbsyrmc());
    141.                         jcYcNew.setSyzdz(dsYcjbxx.getCbsyrdz());
    142.                         jcYcNew.setSyzdh(dsYcjbxx.getCbsyrdh());
    143.                         jcYcNew.setYzbm(dsYcjbxx.getYzbm());
    144.                         jcYcNew.setBlxkzbh(dsYcjbxx.getBlxkzbh());
    145.                         jcYcNew.setCbjyzsbh(dsYcjbxx.getCbjyzsbh());
    146.                         jcYcNew.setGjdjzsbh(dsYcjbxx.getGjdjzsbh());
    147.                         jcYcNew.setSyqzsbh(dsYcjbxx.getSyqzsbh());
    148.                         jcYcNew.setZxdjbh(dsYcjbxx.getZxdjbh());
    149.                         jcYcNew.setCwpzsbh(dsYcjbxx.getCwgjzbpzsbh());
    150.                         String cbzl = dsYcjbxx.getCbzl();
    151.                         if (BeanUtil.isNotEmpty(cbzl)) {//字典
    152.                             //限额捕捞_渔船管理_渔船种类
    153.                             String valByText = sysDictMapper.getValByText("1683369911311855617", cbzl);
    154.                             jcYcNew.setYclx(Integer.valueOf(valByText));
    155.                         }
    156.                         jcYcNew.setHh(dsYcjbxx.getHh());
    157.                         jcYcNew.setJwm(dsYcjbxx.getCbsbm());
    158.                         jcYcNew.setCmhzsbh(dsYcjbxx.getCmhzsbh());
    159.                         jcYcNew.setYcbm(dsYcjbxx.getYcbm());
    160.                         jcYcNew.setDelFlag(0);
    161.                         jcYcNew.setSfzqybh(dsYcjbxx.getCbsyrsfzhmhqyzch());
    162.                         jcYcNew.setYcid(dsYcjbxx.getId());
    163.                         jcYcNew.setYyzzmc(dsYcjbxx.getYyzzmc());
    164.                         insertList.add(jcYcNew);
    165.                         System.out.println("基础渔船信息同步,数据已新增: cm=" + jcYcNew.getCm());
    166.                     }
    167.                 }
    168.                 jcYcService.updateBatchById(updateList);
    169.                 jcYcService.saveBatch(insertList);
    170.                 redisTemplate.opsForValue().set(YC_MAX_TIME, ycMaxTime);
    171.  
    172.                 //更新渔船照片
    173.                 List list = jcYcService.list();
    174.                 for (JcYc jcYc : list) {
    175.                     ArrayList sysCertPdfs = RequestYxeUtil.xeblCertificate(jcYc.getCm(), jcYc.getYcid(), uploadType);
    176.                     for (SysCertPdf sysCertPdf : sysCertPdfs) {
    177.                         SysCertPdf sysCertPdfOld = sysCertPdfService.getFileNameByValue(sysCertPdf.getModelName(), sysCertPdf.getCertId());
    178.                         if (BeanUtil.isNotEmpty(sysCertPdfOld)){
    179.                             BeanUtil.copyProperties(sysCertPdf,sysCertPdfOld,"id");
    180.                             sysCertPdfService.updateById(sysCertPdfOld);
    181.                         }else {
    182.                             sysCertPdfService.save(sysCertPdf);
    183.                         }
    184.                     }
    185.                 }
    186.             }
    187.         } else {
    188.             redisTemplate.opsForValue().set(YC_MAX_TIME, ycMaxTime);
    189.         }
    190.         return ReturnT.SUCCESS;
    191.     }
    192.  
    193.     /**
    194.      * 船员证书信息数据同步
    195.      * @return
    196.      */
    197.     @XxlJob(value = "cyzsxx")
    198.     public ReturnT cyzsxx(String params) {
    199.  
    200.         String cyszxxMaxTime = dsCyzsxxService.queryMaxTime();
    201.         if (redisTemplate.hasKey(CYZSXX_MAX_TIME)) {
    202.             String redisCyzsxxTime = (String) redisTemplate.opsForValue().get(CYZSXX_MAX_TIME);
    203.             if (redisCyzsxxTime != null && !redisCyzsxxTime.equals(cyszxxMaxTime)) {
    204.                 ArrayList updateList = new ArrayList<>();
    205.                 ArrayList insertList = new ArrayList<>();
    206.                 //鱼小二船员证书表
    207.                 List dsCyzsxxList = dsCyzsxxService.list();
    208.                 //本项目船员证书表
    209.                 List chuanYuanZhengShuList = chuanYuanZhengShuService.list();
    210.                 //将本项目船员证书表数据通过证书号码证书职务证书状态进行分组
    211.                 Map> chuanYuanZhengShuMap = chuanYuanZhengShuList.stream().collect(Collectors.groupingBy(e -> e.getZshm() + e.getZszw() + e.getZszt()));
    212.                 for (DsCyzsxx dsCyzsxx : dsCyzsxxList) {
    213.                     if (chuanYuanZhengShuMap.get(dsCyzsxx.getZshm() + dsCyzsxx.getZszw() + dsCyzsxx.getZszt()) != null && !chuanYuanZhengShuMap.get(dsCyzsxx.getZshm() + dsCyzsxx.getZszw() + dsCyzsxx.getZszt()).isEmpty()) {
    214.                         ChuanYuanZhengShu chuanYuanZhengShu = chuanYuanZhengShuMap.get(dsCyzsxx.getZshm() + dsCyzsxx.getZszw() + dsCyzsxx.getZszt()).get(0);
    215.                         // 更新操作
    216.                         updateList.add(chuanYuanZhengShu);
    217.                         System.out.println("船员证书信息数据同步,数据已更新: zshm=" + chuanYuanZhengShu.getZshm());
    218.                     } else {
    219.                         // 新增操作
    220.                         // 数据不存在，执行插入操作
    221.                         ChuanYuanZhengShu cyzsNew = new ChuanYuanZhengShu();
    222.                         cyzsNew.setSysOrgCode("A01");
    223.                         cyzsNew.setSfzhm(dsCyzsxx.getSfzhm());
    224.                         cyzsNew.setXm(dsCyzsxx.getXm());
    225.                         cyzsNew.setXmpy(dsCyzsxx.getXmpy());
    226.                         cyzsNew.setXb(dsCyzsxx.getXb());
    227.                         cyzsNew.setCsrq(dsCyzsxx.getCsrq());
    228.                         cyzsNew.setHjsf(dsCyzsxx.getHjsf());
    229.                         cyzsNew.setHjcs(dsCyzsxx.getHjcs());
    230.                         cyzsNew.setHjdz(dsCyzsxx.getHjdz());
    231.                         cyzsNew.setZslx(dsCyzsxx.getZslx());
    232.                         cyzsNew.setLbdm(dsCyzsxx.getLbdm());
    233.                         cyzsNew.setZszldm(dsCyzsxx.getZszldm());
    234.                         cyzsNew.setZsdj(dsCyzsxx.getZsdj());
    235.                         cyzsNew.setZszw(dsCyzsxx.getZszw());
    236.                         cyzsNew.setSycb(dsCyzsxx.getSycb());
    237.                         cyzsNew.setZshm(dsCyzsxx.getZshm());
    238.                         cyzsNew.setQfjg(dsCyzsxx.getQfjg());
    239.                         cyzsNew.setQfgyxm(dsCyzsxx.getQfgyxm());
    240.                         cyzsNew.setQfrq(dsCyzsxx.getQfrq());
    241.                         cyzsNew.setDyrq(dsCyzsxx.getQfrq());
    242.                         cyzsNew.setJzrq(dsCyzsxx.getJzrq());
    243.                         cyzsNew.setZszt(dsCyzsxx.getZszt());
    244.                         cyzsNew.setDahm(dsCyzsxx.getDahm());
    245.                         insertList.add(cyzsNew);
    246.                         System.out.println("船员证书信息数据同步,数据已新增: zshm=" + cyzsNew.getZshm());
    247.                     }
    248.                 }
    249.                 chuanYuanZhengShuService.updateBatchById(updateList);
    250.                 chuanYuanZhengShuService.saveOrUpdateBatch(insertList);
    251.                 redisTemplate.opsForValue().set(CYZSXX_MAX_TIME, cyszxxMaxTime);
    252.             }
    253.         } else {
    254.             redisTemplate.opsForValue().set(CYZSXX_MAX_TIME, cyszxxMaxTime);
    255.         }
    256.         return ReturnT.SUCCESS;
    257.     }
    258.  
    259.     /**
    260.      * 船员信息同步
    261.      * @return
    262.      */
    263.     @XxlJob(value = "cyxx")
    264.     public ReturnT cyxx(String params) throws Exception {
    265.  
    266.         String cyxxMaxTime = dsCyzsxxService.queryMaxTime();
    267.         if (redisTemplate.hasKey(CYXX_MAX_TIME)) {
    268.             String redisCyxxTime = (String) redisTemplate.opsForValue().get(CYXX_MAX_TIME);
    269.             if (redisCyxxTime != null && !redisCyxxTime.equals(cyxxMaxTime)) {
    270.                 ArrayList updateList = new ArrayList<>();
    271.                 ArrayList insertList = new ArrayList<>();
    272.                 QueryWrapper queryWrapperCy = new QueryWrapper<>();
    273.                 queryWrapperCy.groupBy("SFZHM");
    274.                 //鱼小二证书数据
    275.                 List dsYcjbxxesCy = dsCyzsxxService.list(queryWrapperCy);
    276.                 //船员数据
    277.                 List chuanYuanList = chuanYuanService.list();
    278.                 Map> ycMap = chuanYuanList.stream().collect(Collectors.groupingBy(ChuanYuan::getSfzhm));
    279.                 for (DsCyzsxx cyzsxx : dsYcjbxxesCy) {
    280.                     if (ycMap.get(cyzsxx.getSfzhm()) != null && !ycMap.get(cyzsxx.getSfzhm()).isEmpty()) {
    281.                         ChuanYuan chuanYuan = ycMap.get(cyzsxx.getSfzhm()).get(0);
    282.                         // 更新操作
    283.                         chuanYuan.setYxbz(cyzsxx.getZszt());
    284.                         updateList.add(chuanYuan);
    285.                         System.out.println("船员信息数据同步,数据已更新: sfzhm=" + chuanYuan.getSfzhm());
    286.                     } else {
    287.                         ChuanYuan cyNew = new ChuanYuan();
    288.                         cyNew.setSysOrgCode("A01");
    289.                         cyNew.setSfzhm(cyzsxx.getSfzhm());
    290.                         cyNew.setXm(cyzsxx.getXm());
    291.                         cyNew.setXmpy(cyzsxx.getXmpy());
    292.                         cyNew.setXb(cyzsxx.getXb());
    293.                         cyNew.setCsrq(cyzsxx.getCsrq());
    294.                         cyNew.setHjsf(cyzsxx.getHjsf());
    295.                         cyNew.setHjcs(cyzsxx.getHjcs());
    296.                         cyNew.setHjqx(cyzsxx.getHjxq());
    297.                         cyNew.setHjdz(cyzsxx.getHjdz());
    298.                         cyNew.setYxbz(cyzsxx.getZszt());
    299.                         insertList.add(cyNew);
    300.                         System.out.println("船员证书信息数据同步,数据已新增: zshm=" + cyNew.getSfzhm());
    301.                     }
    302.                 }
    303.                 chuanYuanService.updateBatchById(updateList);
    304.                 chuanYuanService.saveOrUpdateBatch(insertList);
    305.                 redisTemplate.opsForValue().set(CYXX_MAX_TIME, cyxxMaxTime);
    306.  
    307.                 //一网通办获取token同步船员照片等
    308.                 List list = chuanYuanService.list();
    309.                 for (ChuanYuan chuanYuan : list) {
    310.                     SysCertPdf sysCertPdf = RequestYxeUtil.xeblCyzp(chuanYuan.getSfzhm(), uploadType);
    311.                     if (BeanUtil.isNotEmpty(sysCertPdf)) {
    312.                         SysCertPdf sysCertPdfOld = sysCertPdfService.getFileNameByValue(sysCertPdf.getModelName(), sysCertPdf.getCertId());
    313.                         if (BeanUtil.isNotEmpty(sysCertPdfOld)){
    314.                             BeanUtil.copyProperties(sysCertPdf,sysCertPdfOld,"id");
    315.                             sysCertPdfService.updateById(sysCertPdfOld);
    316.                         }else {
    317.                             sysCertPdfService.save(sysCertPdf);
    318.                         }
    319.                     }
    320.                 }
    321.             }
    322.         } else {
    323.             redisTemplate.opsForValue().set(CYXX_MAX_TIME, cyxxMaxTime);
    324.         }
    325.         return ReturnT.SUCCESS;
    326.     }
    327. }
    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://2xx.x.xx.xx3:xx99/cnfai/oauth/token?clientId=2c9fb2a67c642bd2017c642bd21c0000&clientSecret=6ab3e8291b9af57c7ac4457bc60e0d2e0b08a8b9828c6e9d86250458b4de51bf82d9604abeb987d3";
    32.     //token（线上）鱼小二
    33.     private static final String token_url = "http://2xx.x.xx.xx3:xx99/cnfai/oauth/token?clientId=2c9fb2a67c642bd2017c642bd21c0000&clientSecret=6ab3e8291b9af57c7ac4457bc60e0d2e0b08a8b9828c6e9d86250458b4de51bf82d9604abeb987d3";
    34.     //鱼小二获取渔船照片证据
    35.     private static final String XeblCertificate_url = "http://2xx.x.xx.xx3:xx99/cnfai/services/certificateApi/XeblCertificate";
    36.  
    37.     //token（一网通办）
    38.     private static final String XeblCyzp_token_url = "http://2xx.x.xx.xx3:xx99/cnfai//oauth/token";
    39.  
    40.     //获取船员照片
    41.     private static final String XeblCyzp_url = "http://2xx.x.xx.xx3:xx99/cnfai//services/CyService/getCyPhoto";
    42.  
    43.     /**
    44.      * 限额捕捞获取渔船证书
    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.             //限额捕捞获取渔船证书
    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", "402881fXXXXXXXXXXc27e00001");
    198.         paramMap.put("clientSecret", "482978cf5bcb08bc51dcec5b680ccXXXXXXXXXXXXXXXXXXXfc894ccff5ff54ceef53cfde562");
    199.  
    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. }

  • 相关阅读:
    Python之文件处理-JSON文件
    linux 文本处理工具 cut 和 awk
    B-tree（PostgreSQL 14 Internals翻译版）
    PLSQL 存储函数SQL编程
    centos升级cmake之相关问题解决
    某城市道路桥梁设计计算书+cad图纸
    高数 |【23数一 李林六套卷】卷一 自用思路 及 知识点 整理
    Pyglet综合应用｜推箱子游戏地图编辑器之图片跟随鼠标
    微型微控制器托管双直流/直流升压转换器
    VMware虚拟机中ubuntu网络连接不上
  • 原文地址：https://blog.csdn.net/weixin_60948956/article/details/133982832