Commit 00200579 authored by shiyu's avatar shiyu

创建商品,图片url加上尺寸

parent 3bf121b6
......@@ -5,6 +5,7 @@ import java.util.stream.Collectors;
import com.wwdz.ch.admin.entity.vo.ItemVo;
import com.wwdz.ch.admin.service.AdminGoodsService;
import com.wwdz.ch.core.consts.CommonEnum;
import com.wwdz.ch.core.consts.ItemStateEnum;
import com.wwdz.ch.db.dao.CategoryDao;
import com.wwdz.ch.db.dao.ItemDao;
......@@ -137,6 +138,7 @@ public class AdminGoodsServiceImpl implements AdminGoodsService {
item.setCreateTime(now);
item.setUpdateTime(now);
item.setIsDeleted(false);
item.setSourceType(CommonEnum.SourceTypeEnum.SYSTEM_UPLOAD.getCode());
item.setState(ItemStateEnum.PENDING.getCode());
itemDao.add(item);
......
......@@ -38,6 +38,7 @@ public class CommonEnum {
public enum SourceTypeEnum {
SYSTEM_GET(1, "系统获取"),
USER_UPLOAD(2, "用户上传"),
SYSTEM_UPLOAD(3, "后台上传"),
;
private int code;
......
......@@ -51,4 +51,16 @@ public enum MediaTypeEnum {
}
return null;
}
public static MediaTypeEnum getByMime(String mime) {
if (StringUtils.isEmpty(mime)) {
return null;
}
for (MediaTypeEnum mediaTypeEnum : MediaTypeEnum.values()) {
if (mediaTypeEnum.getMime().equals(mime)) {
return mediaTypeEnum;
}
}
return null;
}
}
......@@ -27,6 +27,8 @@ import java.nio.file.Path;
import java.util.Base64;
import java.util.stream.Stream;
import static com.wwdz.ch.core.util.MediaUtil.bufferedImageToInputStream;
public class QiniuStorage implements Storage {
private final Log logger = LogFactory.getLog(QiniuStorage.class);
......@@ -84,19 +86,22 @@ public class QiniuStorage implements Storage {
}
uploadManager = new UploadManager(new Configuration());
}
try {
BufferedImage bufferedImage = ImageIO.read(inputStream);
keyName = CommConsts.UPLOAD_PRE_DIRECTORY + CommonUtils.getUUID() + "_" + bufferedImage.getWidth() + "x" + bufferedImage.getHeight();
InputStream imageStream = bufferedImageToInputStream(bufferedImage, MediaTypeEnum.getByMime(contentType) == null ? MediaTypeEnum.IMAGE_JPG.getExt() : MediaTypeEnum.getByMime(contentType).getExt());
String upToken = auth.uploadToken(bucketName);
Response response = uploadManager.put(inputStream, keyName, upToken, null, contentType);
Response response = uploadManager.put(imageStream, keyName, upToken, null, contentType);
logger.info("七牛存储结果 response:{}" + response);
logger.info("七牛存储结果:" + response.statusCode);
} catch (QiniuException ex) {
} catch (Exception ex) {
ex.printStackTrace();
}
}
public void store(byte[] data, String keyName) {
if (uploadManager == null) {
if (auth == null) {
......@@ -230,7 +235,7 @@ public class QiniuStorage implements Storage {
InputStream inputStream = url.openStream();
BufferedImage bufferedImage = ImageIO.read(inputStream);
String keyName = CommConsts.UPLOAD_PRE_DIRECTORY + CommonUtils.getUUID() + "_" + bufferedImage.getWidth() + "x" + bufferedImage.getHeight() + "." + MediaTypeEnum.IMAGE_JPG.getExt();
InputStream imageStream = MediaUtil.bufferedImageToInputStream(bufferedImage, MediaTypeEnum.IMAGE_JPG.getExt());
InputStream imageStream = bufferedImageToInputStream(bufferedImage, MediaTypeEnum.IMAGE_JPG.getExt());
store(imageStream, 1, MediaTypeEnum.IMAGE_JPG.getMime(), keyName);
return keyName;
}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment