|
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
|
|
import cn.hutool.core.util.PageUtil;
|
|
import cn.hutool.core.util.PageUtil;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
+import com.obs.services.model.TemporarySignatureRequest;
|
|
import com.om.entity.dto.*;
|
|
import com.om.entity.dto.*;
|
|
import com.om.entity.po.*;
|
|
import com.om.entity.po.*;
|
|
import com.om.entity.vo.DiagnosisVersionVO;
|
|
import com.om.entity.vo.DiagnosisVersionVO;
|
|
@@ -20,8 +21,11 @@ import org.apache.commons.lang.StringUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
+import org.springframework.web.bind.annotation.PathVariable;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
|
|
+import java.time.ZoneOffset;
|
|
|
|
+import java.time.format.DateTimeFormatter;
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
@@ -50,21 +54,30 @@ public class DiagnosisVersionInfoServiceImpl extends ServiceImpl<DiagnosisVersio
|
|
|
|
|
|
@Resource
|
|
@Resource
|
|
private JwtUtils jwtUtils;
|
|
private JwtUtils jwtUtils;
|
|
- @Autowired
|
|
|
|
- private DiagnosisVersionDescribeMapper diagnosisVersionDescribeMapper;
|
|
|
|
|
|
+
|
|
|
|
+ @Resource
|
|
|
|
+ private HuaweiObsUtil obsUtil;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@Transactional
|
|
@Transactional
|
|
public Result add(DiagnosisVersionVO diagnosisVersionVO) {
|
|
public Result add(DiagnosisVersionVO diagnosisVersionVO) {
|
|
DiagnosisVersionInfo info = new DiagnosisVersionInfo();
|
|
DiagnosisVersionInfo info = new DiagnosisVersionInfo();
|
|
//客户端编号,需要取id,后面在进行设置
|
|
//客户端编号,需要取id,后面在进行设置
|
|
-
|
|
|
|
|
|
+ String[] clientNums = diagnosisVersionVO.getClientNums();
|
|
|
|
+ StringBuffer sb = new StringBuffer();
|
|
|
|
+ for (int i = 0; i < clientNums.length; i++) {
|
|
|
|
+ sb.append(clientNums[i]);
|
|
|
|
+ if (clientNums.length != 1 && i != clientNums.length - 1){
|
|
|
|
+ sb.append(",");
|
|
|
|
+ }
|
|
|
|
+ }
|
|
//文件地址
|
|
//文件地址
|
|
info.setFile(diagnosisVersionVO.getFileUrl());
|
|
info.setFile(diagnosisVersionVO.getFileUrl());
|
|
//文件大小
|
|
//文件大小
|
|
info.setDiagnosisFileSize(diagnosisVersionVO.getDiagnosisFileSize());
|
|
info.setDiagnosisFileSize(diagnosisVersionVO.getDiagnosisFileSize());
|
|
//品牌代码
|
|
//品牌代码
|
|
info.setBrandCode(diagnosisVersionVO.getBrandCode());
|
|
info.setBrandCode(diagnosisVersionVO.getBrandCode());
|
|
|
|
+ info.setClientNumber(sb.toString());
|
|
//诊断程序名称
|
|
//诊断程序名称
|
|
info.setDiagnosisName(diagnosisVersionVO.getDiagnosisName());
|
|
info.setDiagnosisName(diagnosisVersionVO.getDiagnosisName());
|
|
//程序状态
|
|
//程序状态
|
|
@@ -75,12 +88,14 @@ public class DiagnosisVersionInfoServiceImpl extends ServiceImpl<DiagnosisVersio
|
|
info.setVersion(diagnosisVersionVO.getVersion());
|
|
info.setVersion(diagnosisVersionVO.getVersion());
|
|
//保存地址
|
|
//保存地址
|
|
info.setSavePath(diagnosisVersionVO.getSavePath());
|
|
info.setSavePath(diagnosisVersionVO.getSavePath());
|
|
-
|
|
|
|
|
|
+ info.setFileName(diagnosisVersionVO.getFileName());
|
|
|
|
+ info.setLifecycle(0);
|
|
//保存
|
|
//保存
|
|
this.save(info);
|
|
this.save(info);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
+
|
|
LambdaQueryWrapper<DiagnosisVersionInfo> queryWrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<DiagnosisVersionInfo> queryWrapper = new LambdaQueryWrapper<>();
|
|
queryWrapper.eq(DiagnosisVersionInfo::getId, info.getId());
|
|
queryWrapper.eq(DiagnosisVersionInfo::getId, info.getId());
|
|
//保存后获取
|
|
//保存后获取
|
|
@@ -107,7 +122,12 @@ public class DiagnosisVersionInfoServiceImpl extends ServiceImpl<DiagnosisVersio
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public Result downloadFile(Integer id) {
|
|
public Result downloadFile(Integer id) {
|
|
- return null;
|
|
|
|
|
|
+ DiagnosisVersionInfo diagnosisVersionInfo = this.getById(id);
|
|
|
|
+ if (BeanUtil.isEmpty(diagnosisVersionInfo)) {
|
|
|
|
+ throw new BadReqException("该诊断程序不存在");
|
|
|
|
+ }
|
|
|
|
+ String uploadUrl = obsUtil.getUploadUrl(diagnosisVersionInfo.getFileName(), diagnosisVersionInfo.getSavePath());
|
|
|
|
+ return Result.ok(uploadUrl);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -177,8 +197,9 @@ public class DiagnosisVersionInfoServiceImpl extends ServiceImpl<DiagnosisVersio
|
|
return versionVO;
|
|
return versionVO;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
- public Result getByUserId(Integer id) {
|
|
|
|
|
|
+ public Result getByUserId( Integer id) {
|
|
DiagnosisVersionVO versionVO = this.getVO(id);
|
|
DiagnosisVersionVO versionVO = this.getVO(id);
|
|
|
|
|
|
|
|
|
|
@@ -325,14 +346,18 @@ public class DiagnosisVersionInfoServiceImpl extends ServiceImpl<DiagnosisVersio
|
|
if (BeanUtil.isEmpty(diagnosisVersionDescribe)) {
|
|
if (BeanUtil.isEmpty(diagnosisVersionDescribe)) {
|
|
throw new BadReqException("该描述不存在");
|
|
throw new BadReqException("该描述不存在");
|
|
}
|
|
}
|
|
|
|
+ //获取下载链接
|
|
|
|
+ String uploadUrl = obsUtil.getUploadUrl(diagnosisVersionInfo.getFileName(), "program");
|
|
VehicleDates vehicleDates1 = BeanUtil.copyProperties(diagnosisVersionInfo, VehicleDates.class);
|
|
VehicleDates vehicleDates1 = BeanUtil.copyProperties(diagnosisVersionInfo, VehicleDates.class);
|
|
- vehicleDates1.setUrl(diagnosisVersionInfo.getSavePath());
|
|
|
|
|
|
+ vehicleDates1.setUrl(uploadUrl);
|
|
vehicleDates1.setVersion(diagnosisVersionInfo.getVersion());
|
|
vehicleDates1.setVersion(diagnosisVersionInfo.getVersion());
|
|
vehicleDates1.setFileSize(diagnosisVersionInfo.getDiagnosisFileSize());
|
|
vehicleDates1.setFileSize(diagnosisVersionInfo.getDiagnosisFileSize());
|
|
vehicleDates1.setBrandCn(brand.getBrandCn());
|
|
vehicleDates1.setBrandCn(brand.getBrandCn());
|
|
vehicleDates1.setBrandEn(brand.getBrandEn());
|
|
vehicleDates1.setBrandEn(brand.getBrandEn());
|
|
vehicleDates1.setDescription(diagnosisVersionDescribe.getDescription());
|
|
vehicleDates1.setDescription(diagnosisVersionDescribe.getDescription());
|
|
-
|
|
|
|
|
|
+ vehicleDates1.setFileName(diagnosisVersionInfo.getFileName());
|
|
|
|
+ vehicleDates1.setPath(diagnosisVersionInfo.getSavePath());
|
|
|
|
+ vehicleDates1.setCreateTime(diagnosisVersionInfo.getCreateTime().toInstant(ZoneOffset.of("+8")).toEpochMilli());
|
|
voList.add(vehicleDates1);
|
|
voList.add(vehicleDates1);
|
|
}
|
|
}
|
|
|
|
|