bug--解决七牛云重复上传问题

This commit is contained in:
taochengbo
2020-05-24 13:56:02 +08:00
parent 200b48dc4e
commit 908f1f8ede
2 changed files with 16 additions and 11 deletions

View File

@ -172,7 +172,7 @@ public class PictureServiceImpl extends BaseServiceImpl<PictureMapper, Picture>
if(this.getOne(new QueryWrapper<Picture>().eq("url",picture.getUrl()))==null){ if(this.getOne(new QueryWrapper<Picture>().eq("url",picture.getUrl()))==null){
picture.setSize(FileUtil.getSize(Integer.parseInt(picture.getSize()))); picture.setSize(FileUtil.getSize(Integer.parseInt(picture.getSize())));
picture.setUsername("System Sync"); picture.setUsername("System Sync");
picture.setMd5code(""); picture.setMd5code(null);
this.save(picture); this.save(picture);
} }
} }

View File

@ -112,16 +112,21 @@ public class QiNiuServiceImpl implements QiNiuService {
//解析上传成功的结果 //解析上传成功的结果
DefaultPutRet putRet = JSON.parseObject(response.bodyString(), DefaultPutRet.class); DefaultPutRet putRet = JSON.parseObject(response.bodyString(), DefaultPutRet.class);
//存入数据库
QiniuContent qiniuContent = new QiniuContent(); QiniuContent content = qiniuContentService.getOne(new QueryWrapper<QiniuContent>().eq("name",FileUtil.getFileNameNoEx(putRet.key)));
qiniuContent.setSuffix(FileUtil.getExtensionName(putRet.key)); if (content == null) {
qiniuContent.setBucket(qiniuConfig.getBucket()); //存入数据库
qiniuContent.setType(qiniuConfig.getType()); QiniuContent qiniuContent = new QiniuContent();
qiniuContent.setName(FileUtil.getFileNameNoEx(putRet.key)); qiniuContent.setSuffix(FileUtil.getExtensionName(putRet.key));
qiniuContent.setUrl(qiniuConfig.getHost()+"/"+putRet.key); qiniuContent.setBucket(qiniuConfig.getBucket());
qiniuContent.setSize(FileUtil.getSize(Integer.parseInt(file.getSize()+""))); qiniuContent.setType(qiniuConfig.getType());
qiniuContentService.save(qiniuContent); qiniuContent.setName(FileUtil.getFileNameNoEx(putRet.key));
return qiniuContent; qiniuContent.setUrl(qiniuConfig.getHost()+"/"+putRet.key);
qiniuContent.setSize(FileUtil.getSize(Integer.parseInt(file.getSize()+"")));
qiniuContentService.save(qiniuContent);
return qiniuContent;
}
return content;
} catch (Exception e) { } catch (Exception e) {
throw new BadRequestException(e.getMessage()); throw new BadRequestException(e.getMessage());
} }