public class PDFUtils {
public static byte[] signPdf(String pdfUrl, String sealUrl) throws DocumentException, IOException {
        Document document = null;
        PdfStamper stamper = null;
        PdfReader reader = null;
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        byte[] data = null;
        try {
            // pdf文件路径
            URL url = new URL(pdfUrl);
            // 读取pdf文件
            reader = new PdfReader(url);
            // 获取页数
            int pageCount = reader.getNumberOfPages();
            // 生成副本
            stamper = new PdfStamper(reader, outputStream);
            // 生成document
            document = new Document(reader.getPageSize(1));
            // 获取页面宽度
            float width = document.getPageSize().getWidth();
            // 获取页面高度
            float height = document.getPageSize().getHeight();
            System.out.println("width = " + width + ", height = " + height);
            // 读取seal
            Image sealImage = Image.getInstance(sealUrl);
            // 根据域的大小缩放印章
            sealImage.scaleToFit(150, 150);
            // 设置印章位置
            sealImage.setAbsolutePosition(width - 150 - 50, 50);
            // 在最后一页盖章
            PdfContentByte sign = stamper.getOverContent(pageCount);
            sign.addImage(sealImage);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (document != null) {
                document.close();
            }
            if (stamper != null) {
                stamper.close();
            }
            if (reader != null) {
                data = outputStream.toByteArray();
                reader.close();
            }
            return data;
        }
    }

}

--- # Fabric 超级账本gateway连接配置项
fabric:
  # 网络配置文件路径
  networkConfigPath: mychannel_connection_for_javasdk.yaml
  # 用户证书路径
  certificatePath: crypto-config/peerOrganizations/bc1.henriport.com/users/Admin@bc1.henriport.com/msp/signcerts/Admin@bc1.henriport.com-cert.pem
  # 用户私钥路径
  privateKeyPath: crypto-config/peerOrganizations/bc1.henriport.com/users/Admin@bc1.henriport.com/msp/keystore/priv_sk
  # 链码名字
  contractName: contract
  # 通道名字
  channelName: mychannel
  # mspId
  mspId: bc1-henriport-com
  # 用户
  user: admin

@Data
@Component
@ConfigurationProperties(prefix = "fabric")
public class FabricProperties {

    /**
     * 网络配置文件路径
     */
    private String networkConfigPath;

    /**
     * 用户证书路径
     */
    private String certificatePath;

    /**
     * 用户私钥路径
     */
    private String privateKeyPath;

    /**
     * 链码名字
     */
    private String contractName;

    /**
     * 通道名字
     */
    private String channelName;

    /**
     * mspId
     */
    private String mspId;

    /**
     * 用户
     */
    private String user;

}

 @Component
public class FabricUtils {
    @Resource
    private FabricProperties fabricProperties;

    private Network network;

    public Network getNetwork() {
        return this.network;
    }

    private Contract contract;

    public Contract getContract() {
        return this.contract;
    }

    @PostConstruct
    private void FabricUtils() {
        try {
            // 获取当前文件类路径
            String resourcePath = this.getClass().getResource("/").toURI().toString();
            System.out.println(resourcePath);
            X509Certificate certificate = readX509Certificate(Paths.get(new URI(resourcePath+fabricProperties.getCertificatePath())));
            PrivateKey privateKey = getPrivateKey(Paths.get(new URI(resourcePath+fabricProperties.getPrivateKeyPath())));
            Wallet wallet = Wallets.newInMemoryWallet();
            wallet.put(fabricProperties.getUser(), Identities.newX509Identity(fabricProperties.getMspId(), certificate, privateKey));
            //根据配置文件 获取Fabric网络连接对象
            Gateway.Builder builder = Gateway.createBuilder()
                .identity(wallet, "admin")
                .networkConfig(Paths.get(new URI(resourcePath+fabricProperties.getNetworkConfigPath())));
            //连接网关
            Gateway gateway = builder.connect();
            //获取通道
            network = gateway.getNetwork(fabricProperties.getChannelName());
            //获取合约对象
            contract = network.getContract(fabricProperties.getContractName());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static X509Certificate readX509Certificate(final Path certificatePath) throws IOException, CertificateException {
        try (Reader certificateReader = Files.newBufferedReader(certificatePath, StandardCharsets.UTF_8)) {
            return Identities.readX509Certificate(certificateReader);
        }
    }

    private static PrivateKey getPrivateKey(final Path privateKeyPath) throws IOException, InvalidKeyException {
        try (Reader privateKeyReader = Files.newBufferedReader(privateKeyPath, StandardCharsets.UTF_8)) {
            return Identities.readPrivateKey(privateKeyReader);
        }
    }
}

/**
     * 修改审核状态
     *
     * @param id
     * @param type
     * @return
     */
    @ApiOperation("修改审核状态")
    @PreAuthorize("@ss.hasPermi('system:contract:edit')")
    @Log(title = "电子合同管理", businessType = BusinessType.UPDATE)
    @PutMapping("/state/{id}/{type}")
    public AjaxResult<Void> changeState(@NotNull(message = "主键不能为空")
                                        @PathVariable Long id,
                                        @NotNull(message = "type不能为空")
                                        @PathVariable Boolean type,
                                        String pdfUrl, String sealUrl) {
        return toAjax(iHeContractService.setStateById(id, type, pdfUrl, sealUrl) ? 1 : 0);
    }

   @Override
    public Boolean setStateById(Long id, Boolean type, String pdfUrl, String sealUrl) {
        String state = type ? "2" : "3";
        UpdateWrapper<HeContract> updateWrapper = new UpdateWrapper<>();
        // 如果审核通过
        try {
            if (type && pdfUrl != null && sealUrl != null) {
                // TODO 调用修改pdf方法,OSS文件重写
                byte[] data = PDFUtils.signPdf(pdfUrl, sealUrl);
                iSysOssService.updateFile(data, pdfUrl);
                // TODO 调用文件入ipfs方法
                String ipfsHash = IPFSUtils.upload(data);
                // 修改id对应的contract数据
                updateWrapper.eq("id", id)
                    .set("state", state)
                    .set("ipfs_hash", ipfsHash)
                    .set("is_link", 1);
                // TODO 调用数据入链方法，整体数据存入Fabric
                // 初始化
                Network network = fabricUtils.getNetwork();
                Contract contract = fabricUtils.getContract();
                // 获取contract
                HeContractVo heContractVo = queryById(id);
                byte[] addContractResult = contract.createTransaction("addContract")
                    .setEndorsingPeers(network.getChannel().getPeers(EnumSet.of(Peer.PeerRole.ENDORSING_PEER)))
                    .submit(
                        heContractVo.getId().toString(),
                        heContractVo.getTitle(),
                        heContractVo.getDescription(),
                        heContractVo.getType(),
                        ipfsHash,
                        heContractVo.getBelong().toString(),
                        heContractVo.getBelong().toString());
                log.info("addContract："+new String(addContractResult, StandardCharsets.UTF_8));
            }
        } catch (DocumentException documentException) {
            documentException.printStackTrace();
            return false;
        } catch (IOException ioException) {
            ioException.printStackTrace();
            return false;
        } catch (ContractException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }
        return update(updateWrapper);
    }

public class IPFSUtils {
    /**
     * ipfs的服务器地址和端口
     */
    private static IPFS ipfs = new IPFS("/ip4/127.0.0.1/tcp/5001");

    /**
     * 将文件url转换为InputStream
     * @param url
     * @return
     */
    public static InputStream getFileInputSteam(String url){
          try {
            URL httpUrl = new URL(url);
            HttpURLConnection conn = (HttpURLConnection)httpUrl.openConnection();
            conn.setRequestMethod("GET");
            conn.setConnectTimeout(5 * 1000);
            //通过输入流获取图片数据
            InputStream inStream = conn.getInputStream();
            return inStream;
        } catch (Exception e) {
           e.printStackTrace();
        }
        return null;
    }

    /**
     * 将文件url转换为byte[]
     * @param url
     * @return
     */
    public static byte[] getFileSteam(String url){
          try {
            URL httpUrl = new URL(url);
            HttpURLConnection conn = (HttpURLConnection)httpUrl.openConnection();
            conn.setRequestMethod("GET");
            conn.setConnectTimeout(5 * 1000);
            //通过输入流获取图片数据
            InputStream inStream = conn.getInputStream();
            //得到图片的二进制数据
            byte[] btImg = readInputStream(inStream);
            return btImg;
        } catch (Exception e) {
           e.printStackTrace();
        }
        return null;
    }

     /**
   * 从输入流中获取数据
   * @param inStream 输入流
   * @return
   * @throws Exception
   */
   public static byte[] readInputStream(InputStream inStream) throws Exception{
     ByteArrayOutputStream outStream = new ByteArrayOutputStream();
     byte[] buffer = new byte[1024];
     int len = 0;
     while( (len=inStream.read(buffer)) != -1 ){
         outStream.write(buffer, 0, len);
     }
     inStream.close();
     return outStream.toByteArray();
   }

    /**
     * 整合，根据URL地址上传文件
     * @param url
     * @return
     * @throws IOException
     */
   public static String uploadByUrl(String url) throws IOException {
       InputStream fileInputSteam = getFileInputSteam(url);
       return upload(fileInputSteam);
   }

    /**
     * 根据文件路径上传文件
     * src/image/hello.jpg
     *
     * @param fileName
     * @return
     * @throws IOException
     */
    public static String upload(String fileName) throws IOException {
        NamedStreamable.FileWrapper file = new NamedStreamable.FileWrapper(new File(fileName));
        MerkleNode addResult = ipfs.add(file).get(0);
        return addResult.hash.toString();
    }

    /**
     * 根据inputstream上传文件
     * @param inputStream
     * @return
     * @throws IOException
     */
    public static String upload(InputStream inputStream) throws IOException {
        NamedStreamable.InputStreamWrapper file = new NamedStreamable.InputStreamWrapper(inputStream);
        MerkleNode addResult = ipfs.add(file).get(0);
        return addResult.hash.toString();
    }

    /**
     * 根据文件二进制内容上传文件
     *
     * @param data
     * @return
     * @throws IOException
     */
    public static String upload(byte[] data) throws IOException {
        NamedStreamable.ByteArrayWrapper file = new NamedStreamable.ByteArrayWrapper(data);
        MerkleNode addResult = ipfs.add(file).get(0);
        return addResult.hash.toString();
    }

    /**
     * 根据hash值下载文件
     *
     * @param hash
     * @return
     */
    public static byte[] download(String hash) {
        byte[] data = null;
        try {
            data = ipfs.cat(Multihash.fromBase58(hash));
        } catch (IOException e) {
            e.printStackTrace();
        }
        return data;
    }

    /**
     * 替换文件？
     *
     * @param hash
     * @param destFile
     */
    public static void download(String hash, String destFile) {
        byte[] data = null;
        try {
            data = ipfs.cat(Multihash.fromBase58(hash));
        } catch (IOException e) {
            e.printStackTrace();
        }
        if (data != null && data.length > 0) {
            File file = new File(destFile);
            if (file.exists()) {
                file.delete();
            }
            FileOutputStream fos = null;
            try {
                fos = new FileOutputStream(file);
                fos.write(data);
                fos.flush();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    fos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }

            }
        }
    }
}

cd /mnt/d/minifabric-main/
vim spec.yaml

fabric:
  cas:
  - "ca.bc1.henriport.com"
  - "ca.bc2.henriport.com"
  peers:
  - "p1.bc1.henriport.com"
  - "p1.bc2.henriport.com"
  orderers:
  - "orderer1.henriport.com"
  settings:
    ca:
      FABRIC_LOGGING_SPEC: DEBUG
    peer:
      FABRIC_LOGGING_SPEC: DEBUG
    orderer:
      FABRIC_LOGGING_SPEC: DEBUG
  ### use go proxy when default go proxy is restricted in some of the regions.
  ### the default goproxy
  # goproxy: "https://proxy.golang.org,direct"
  ### the goproxy in China area
  goproxy: "https://goproxy.cn,direct"
  ### set the endpoint address to override the automatically detected IP address
  # endpoint_address: 104.196.45.144
  ### set the docker network name to override the automatically generated name.
  netname: "mysite"
  ### set the extra optins for docker run command
  # container_options: "--restart=always --log-opt max-size=10m --log-opt max-file=3"

./minifab up -n simple -l go -v 1.0 -r true -o bc1.henriport.com

./minifab restart

./minifab explorerup

./minifab explorerdown

./minifab down

./minifab cleanup

./minifab -h

# 添加用户
./minifab invoke -p '"addUser","1", "张三", "1208471280957102", "120847124"'
./minifab invoke -p '"addUser","2", "李四", "128754812074", "197264192"'
./minifab invoke -p '"addUser","3", "王五", "128712354812074", "197264141292"'
# 通过用户id查询用户
./minifab query -p '"getUserById","1"'
# 修改用户
./minifab invoke -p '"updateUserById","3", "赵六", "128712354812074", "197264141292"'
# 添加合同
./minifab invoke -p '"addContract","1","租房", "租房合同", "个人", "jqoiwdnqowhjgoqwj", "1", "2"'
# 通过合同id查询合同
./minifab query -p '"getContractById","1"'
# 修改合同
./minifab invoke -p '"updateContractById","1", "租房2", "租房合同2", "非个人", "jqoiwdnqowhjgoqwj", "1", "3"'
# 删除合同
./minifab invoke -p '"deleteContractById","1"'

// 到链码所在的目录下提前下载依赖包
cd fabric-samples/asset-transfer-basic/chaincode-go
//更改GO代理
go env -w GOPROXY=https://goproxy.io,direct
go env -w GO111MODULE=on
go mod vendor