[microservice openfeign] use openfeign to remotely call the file upload interface

Service providers - File upload interface

@PostMapping("/saveFile")
@Transactional
@ApiOperation(value = " file save ", response = ResponseEntity.class)
@ApiImplicitParams(
        {
    
                @ApiImplicitParam(name = "fileUploadModel", value = " File upload information ",
                        required = true, dataType = "String", paramType = "query"),
                @ApiImplicitParam(name = "uploadFiles", value = " File stream ",
                        required = true, allowMultiple = true, dataType = "__file", paramType = "query")
        })
public ResponseEntity<Object> saveFile(@RequestParam(value = "fileUploadModel", required = false) String fileUploadModel,
                                       @RequestParam(value = "uploadFiles", required = false) List<MultipartFile> uploadFiles) {
    

    FileUploadModel model = JSON.parseObject(fileUploadModel, FileUploadModel.class);
// JSON.toJSONString()
    // The attachment 
    List<OfficeAttach> uploadFileList = new ArrayList<>();

    if (uploadFiles != null && uploadFiles.size() > 0) {
    
        uploadFileList = addFileInfoDto(uploadFiles, model);
// this.fileService.saveOfficeAttachList(uploadFileList);
        fileService.saveBatch(uploadFileList);
    }
    return ResponseEntity.ok(" File upload succeeded ");
}

FeignClient

@FeignClient(name = "${custom.feign.file.name}", url = "${custom.feign.file.url}", fallback = FileFeignClientFallBack.class, configuration = FileFeignClient.MultipartSupportConfig.class)
public interface FileFeignClient {
    

    @RequestMapping(value = "/upload/saveFile", method = RequestMethod.POST, consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
    public ResponseEntity<Object> fileUpload(@RequestParam(value = "fileUploadModel", required = false) String fileUploadModel,
                                             @RequestPart(value = "uploadFiles", required = false) List<MultipartFile> uploadFiles);

consumer - adopt FeignClient Call file upload interface

/** * @Description: 1、 Call the asset service to insert the application asset information  * 2、 Insert the request information to itsm_request_info surface , The status is directly written as IT Waiting list  * 3、 Call the file service to upload files  * @Param: * @return: * @Author:  Brest  * @Date: 2022/7/3 */
@PostMapping("/commitRequest")
@Idempotent
@GlobalTransactional
@ApiOperation(value = " Request Submission ", response = ResultModel.class)
@ApiImplicitParams(
        {
    
                @ApiImplicitParam(name = "requestInfo", value = " Demand application information ",
                        required = true, dataType = "String", paramType = "query"),
                @ApiImplicitParam(name = "assetModelList", value = " Asset application information ",
                        required = true, dataType = "String", paramType = "query"),
                @ApiImplicitParam(name = "uploadFiles", value = " Upload file information ",
                        required = true, allowMultiple = true, dataType = "__file", paramType = "query")
        })
public ResultModel commitRequest(@RequestParam(value = "requestInfo", required = false) String requestInfoModel,
                                 @RequestParam(value = "assetModelList", required = false) String assetRequestModel,
                                 @RequestParam(value = "uploadFiles", required = false) List<MultipartFile> uploadFiles,
                                 HttpServletRequest request) {
    

    RequestInfo requestInfo = JSON.parseObject(requestInfoModel, RequestInfo.class);
    List<AssetRequestModel> applyModelList = JSON.parseArray(assetRequestModel, AssetRequestModel.class);
    String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
    String userId = request.getHeader("userId");

    //issuId
    String issueId = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());

    //path
    // Call the asset service to insert the application asset information 
    FileUploadModel uploadModel = new FileUploadModel();
    uploadModel.setUploadPath("/request/");
    uploadModel.setAttachType(" Demand application ");
    uploadModel.setCreateId(request.getHeader("userId"));
    uploadModel.setIssueId(issueId);
    uploadModel.setRemark(requestInfo.getIssueContent());
    uploadModel.setObjectType("office End ");
    uploadModel.setRoleId("role-office");
    uploadModel.setRoleType("role-type");

    for (AssetRequestModel requestModel : applyModelList) {
    
        requestModel.setIssueId(issueId).setOperateType("2").setCreateId(request.getHeader("userId"));

    }
    assetFeignClient.saveApply(applyModelList);

    // Save the request information 
    requestInfo.setIssueId(issueId);
    requestInfo.setGuid(UUID.randomUUID().toString());
    requestInfo.setDelFlag("N");
    requestInfo.setStatus("IT Waiting list ");
    requestInfo.setCreateTime(time);
    requestInfo.setUpdateTime(time);
    requestInfo.setCreateId(userId);
    requestInfo.setUpdateId(userId);
    requestService.save(requestInfo);

    // Call the file service to upload files 

    String fileUploadModel = JSON.toJSONString(uploadModel);

    feignClient.fileUpload(fileUploadModel, uploadFiles);

    return ResultModel.ok(" Submit successfully ");
}