|
|
@@ -1,27 +1,17 @@
|
|
|
package com.jkcredit.invoice.hub.service.contract;
|
|
|
|
|
|
-import cn.com.taiji.common.manager.net.http.binclient.ApiRequestException;
|
|
|
-import cn.com.taiji.sdk.comm.ETCCommHelper;
|
|
|
-import cn.com.taiji.sdk.model.comm.protocol.eoms.company.B2bContractAddRequest;
|
|
|
-import cn.com.taiji.sdk.model.comm.protocol.eoms.company.B2bContractAddResponse;
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.jkcredit.invoice.hub.enums.ApiResponseCodeEnum;
|
|
|
import com.jkcredit.invoice.hub.mapper.ContractMapper;
|
|
|
import com.jkcredit.invoice.hub.model.dto.contract.ContractDto;
|
|
|
import com.jkcredit.invoice.hub.model.po.contract.ContractPo;
|
|
|
import com.jkcredit.invoice.hub.model.vo.contract.ContractVo;
|
|
|
import com.jkcredit.invoice.hub.service.base.BaseService;
|
|
|
-import com.jkcredit.invoice.hub.spi.lang.exception.ServiceException;
|
|
|
import com.jkcredit.invoice.hub.util.BeanUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
-import sun.misc.BASE64Encoder;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
-import java.io.IOException;
|
|
|
-import java.util.Date;
|
|
|
|
|
|
/**
|
|
|
* @description:
|
|
|
@@ -37,53 +27,53 @@ public class ContractServiceImpl extends BaseService implements ContractService
|
|
|
|
|
|
@Override
|
|
|
public void uploadContract(ContractDto contractDto) {
|
|
|
- String filename = contractDto.getContract().getOriginalFilename();
|
|
|
- String[] args = filename.split("\\.");
|
|
|
- if (!args[args.length - 1].equals("pdf")) {
|
|
|
- throw new ServiceException("协议转换失败");
|
|
|
- }
|
|
|
- // 参数设置
|
|
|
- validate(contractDto);
|
|
|
- B2bContractAddRequest request = new B2bContractAddRequest();
|
|
|
- request.setCompanyNum(contractDto.getCompanyNum());
|
|
|
- request.setServiceType(contractDto.getServiceType());
|
|
|
- request.setServiceStartTime(contractDto.getServiceStartTime());
|
|
|
- request.setServiceEndTime(contractDto.getServiceEndTime());
|
|
|
- request.setContractFileName(filename);
|
|
|
-
|
|
|
- BASE64Encoder base64Encoder = new BASE64Encoder();
|
|
|
- String base64Str;
|
|
|
- try {
|
|
|
- base64Str = base64Encoder.encode(contractDto.getContract().getBytes());
|
|
|
- } catch (IOException ioe) {
|
|
|
- log.error("上传协议转base64失败，失败原因：{}", ioe.getMessage());
|
|
|
- throw new ServiceException("协议转换失败");
|
|
|
- }
|
|
|
- String fileName = request.getFilename();
|
|
|
-
|
|
|
- // 接口调用
|
|
|
- B2bContractAddResponse response;
|
|
|
- try {
|
|
|
- // 调用upload 发送数据
|
|
|
- response = ETCCommHelper.upload(fileName, request, B2bContractAddResponse.class);
|
|
|
- } catch (IOException e) {
|
|
|
- log.error("[-uploadContract-] 网络错误：" + e.getMessage());
|
|
|
- throw new ServiceException("上传协议失败");
|
|
|
- } catch (ApiRequestException apie) {
|
|
|
- log.error("[-uploadContract-] 错误信息：" + apie.getMessage());
|
|
|
- throw new ServiceException("上传协议失败,失败原因：" + apie.getMessage());
|
|
|
- }
|
|
|
- try {
|
|
|
- ContractPo contractPo = new ContractPo();
|
|
|
- BeanUtil.copyProperties(contractPo, contractDto);
|
|
|
- contractPo.setBase64Str(base64Str);
|
|
|
- contractPo.setCreateTime(new Date());
|
|
|
- contractPo.setContractNum(response.getContrantNum());
|
|
|
- contractMapper.insert(contractPo);
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("上传协议失败，失败原因：{}", e.getMessage());
|
|
|
- throw new ServiceException("上传协议新增失败");
|
|
|
- }
|
|
|
+// String filename = contractDto.getContract().getOriginalFilename();
|
|
|
+// String[] args = filename.split("\\.");
|
|
|
+// if (!args[args.length - 1].equals("pdf")) {
|
|
|
+// throw new ServiceException("协议转换失败");
|
|
|
+// }
|
|
|
+// // 参数设置
|
|
|
+// validate(contractDto);
|
|
|
+// B2bContractAddRequest request = new B2bContractAddRequest();
|
|
|
+// request.setCompanyNum(contractDto.getCompanyNum());
|
|
|
+// request.setServiceType(contractDto.getServiceType());
|
|
|
+// request.setServiceStartTime(contractDto.getServiceStartTime());
|
|
|
+// request.setServiceEndTime(contractDto.getServiceEndTime());
|
|
|
+// request.setContractFileName(filename);
|
|
|
+//
|
|
|
+// BASE64Encoder base64Encoder = new BASE64Encoder();
|
|
|
+// String base64Str;
|
|
|
+// try {
|
|
|
+// base64Str = base64Encoder.encode(contractDto.getContract().getBytes());
|
|
|
+// } catch (IOException ioe) {
|
|
|
+// log.error("上传协议转base64失败，失败原因：{}", ioe.getMessage());
|
|
|
+// throw new ServiceException("协议转换失败");
|
|
|
+// }
|
|
|
+// String fileName = request.getFilename();
|
|
|
+//
|
|
|
+// // 接口调用
|
|
|
+// B2bContractAddResponse response;
|
|
|
+// try {
|
|
|
+// // 调用upload 发送数据
|
|
|
+// response = ETCCommHelper.upload(fileName, request, B2bContractAddResponse.class);
|
|
|
+// } catch (IOException e) {
|
|
|
+// log.error("[-uploadContract-] 网络错误：" + e.getMessage());
|
|
|
+// throw new ServiceException("上传协议失败");
|
|
|
+// } catch (ApiRequestException apie) {
|
|
|
+// log.error("[-uploadContract-] 错误信息：" + apie.getMessage());
|
|
|
+// throw new ServiceException("上传协议失败,失败原因：" + apie.getMessage());
|
|
|
+// }
|
|
|
+// try {
|
|
|
+// ContractPo contractPo = new ContractPo();
|
|
|
+// BeanUtil.copyProperties(contractPo, contractDto);
|
|
|
+// contractPo.setBase64Str(base64Str);
|
|
|
+// contractPo.setCreateTime(new Date());
|
|
|
+// contractPo.setContractNum(response.getContrantNum());
|
|
|
+// contractMapper.insert(contractPo);
|
|
|
+// } catch (Exception e) {
|
|
|
+// log.error("上传协议失败，失败原因：{}", e.getMessage());
|
|
|
+// throw new ServiceException("上传协议新增失败");
|
|
|
+// }
|
|
|
}
|
|
|
|
|
|
@Override
|
xusonglin