From cb8db5f74edbbc4ae0f37aa089c761408cc017a5 Mon Sep 17 00:00:00 2001
From: jiaosong <jiaosong6760@dingtalk.com>
Date: 星期一, 18 九月 2023 18:37:29 +0800
Subject: [PATCH] #联调修改
---
server/platform/src/main/java/com/doumee/api/business/BaseGoodsController.java | 12 ++--
server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java | 117 +++++++++++++++++++++++++++++++++-----
server/service/src/main/java/com/doumee/core/utils/Constants.java | 1
server/platform/src/main/resources/application.yml | 2
server/service/src/main/java/com/doumee/dao/business/model/dto/BaseGoodsImportDTO.java | 4
5 files changed, 110 insertions(+), 26 deletions(-)
diff --git a/server/platform/src/main/java/com/doumee/api/business/BaseGoodsController.java b/server/platform/src/main/java/com/doumee/api/business/BaseGoodsController.java
index fcda94f..d11211e 100644
--- a/server/platform/src/main/java/com/doumee/api/business/BaseGoodsController.java
+++ b/server/platform/src/main/java/com/doumee/api/business/BaseGoodsController.java
@@ -37,7 +37,7 @@
@PreventRepeat
@ApiOperation("鏂板缓")
@PostMapping("/create")
-// @RequiresPermissions("business:basegoods:create")
+ @RequiresPermissions("business:basegoods:create")
public ApiResponse create(@RequestBody BaseGoodsCreateOrUpdateRequest baseGoods) {
return ApiResponse.success(baseGoodsService.create(baseGoods));
}
@@ -87,9 +87,9 @@
@ApiOperation("鏍规嵁ID鏌ヨ")
@GetMapping("/{id}")
-// @RequiresPermissions("business:basegoods:query")
- public ApiResponse findById(@PathVariable Integer id) {
- return ApiResponse.success(baseGoodsService.findById(id));
+ @RequiresPermissions("business:basegoods:query")
+ public ApiResponse<BaseGoodsDTO> findById(@PathVariable Integer id) {
+ return ApiResponse.success(baseGoodsService.findByIdBaseGoods(id));
}
/**
@@ -126,7 +126,7 @@
*/
@ApiOperation("鏍规嵁ID鏌ヨ骞冲彴鍟嗗搧璇︾粏淇℃伅")
@GetMapping("/findByIdBaseGoods")
-// @RequiresPermissions("business:basegoods:query")
+ @RequiresPermissions("business:basegoods:query")
public ApiResponse<BaseGoodsDTO> findByIdBaseGoods(@RequestParam Integer id){
BaseGoodsDTO byIdBaseGoods = baseGoodsService.findByIdBaseGoods(id);
return ApiResponse.success(byIdBaseGoods);
@@ -139,7 +139,7 @@
*/
@ApiOperation("鏍规嵁ID淇敼-缂栬緫淇敼")
@PostMapping("/update")
-// @RequiresPermissions("business:basegoods:update")
+ @RequiresPermissions("business:basegoods:update")
public ApiResponse update(@RequestBody BaseGoodsCreateOrUpdateRequest baseGoods){
baseGoodsService.update(baseGoods);
return ApiResponse.success(null);
diff --git a/server/platform/src/main/resources/application.yml b/server/platform/src/main/resources/application.yml
index 4059361..687a24a 100644
--- a/server/platform/src/main/resources/application.yml
+++ b/server/platform/src/main/resources/application.yml
@@ -62,4 +62,4 @@
basic:
enable: true
username: admin
- password: 111111
\ No newline at end of file
+ password: 111111
diff --git a/server/service/src/main/java/com/doumee/core/utils/Constants.java b/server/service/src/main/java/com/doumee/core/utils/Constants.java
index 7c7b36b..ed54c71 100644
--- a/server/service/src/main/java/com/doumee/core/utils/Constants.java
+++ b/server/service/src/main/java/com/doumee/core/utils/Constants.java
@@ -50,6 +50,7 @@
public static final String DEFAULT_MANAGE_ROLE = "DEFAULT_MANAGE_ROLE";
public static final String DEFAULT_PASSWORD = "DEFAULT_PASSWORD";
public static final String BRAND_IMG = "BRAND_IMG";
+ public static final String PLATFORM = "PLATFORM";
/**
* 浼佷笟鏁版嵁鏉ユ簮 0骞冲彴娉ㄥ唽 1鍚庡彴瀵煎叆
diff --git a/server/service/src/main/java/com/doumee/dao/business/model/dto/BaseGoodsImportDTO.java b/server/service/src/main/java/com/doumee/dao/business/model/dto/BaseGoodsImportDTO.java
index 001da90..2e0252e 100644
--- a/server/service/src/main/java/com/doumee/dao/business/model/dto/BaseGoodsImportDTO.java
+++ b/server/service/src/main/java/com/doumee/dao/business/model/dto/BaseGoodsImportDTO.java
@@ -32,11 +32,11 @@
@ApiModelProperty(value = "鎸囧浠�")
@ExcelColumn(name="鎸囧浠�")
- private BigDecimal zdPrice;
+ private String zdPrice;
@ApiModelProperty(value = "鍏ユ墜浠�")
@ExcelColumn(name="鍏ユ墜浠�")
- private BigDecimal price;
+ private String price;
@ApiModelProperty(value = "浜у搧鍙傛暟")
@ExcelColumn(name="浜у搧鍙傛暟")
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java
index 562835a..f0f4f19 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java
@@ -13,10 +13,8 @@
import com.doumee.dao.business.*;
import com.doumee.dao.business.join.BaseGoodsJoinMapper;
import com.doumee.dao.business.model.*;
-import com.doumee.dao.business.model.dto.BaseGoodsCreateOrUpdateRequest;
-import com.doumee.dao.business.model.dto.BaseGoodsDTO;
-import com.doumee.dao.business.model.dto.BaseGoodsImportDTO;
-import com.doumee.dao.business.model.dto.BaseGoodsParamCreatRequest;
+import com.doumee.dao.business.model.dto.*;
+import com.doumee.service.business.BaseDataService;
import com.doumee.service.business.BaseGoodsService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -33,10 +31,9 @@
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.io.File;
+import java.math.BigDecimal;
+import java.util.*;
import java.util.stream.Collectors;
/**
@@ -74,6 +71,11 @@
@Autowired
private BaseCategoryMapper baseCategoryMapper;
+
+
+ @Autowired
+ @Lazy
+ private BaseDataService baseDataService;
@Override
@@ -305,8 +307,8 @@
.eq(BaseGoods::getId,id);
BaseGoodsDTO baseGoodsDTO = baseGoodsJoinMapper.selectJoinOne(BaseGoodsDTO.class, queryWrapper);
- String prefixUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode()
- + systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.PROJECTS).getCode();
+ String prefixUrl = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
+ + systemDictDataBiz.queryByCode(Constants.OSS, Constants.GOODS_IMG).getCode();
baseGoodsDTO.setImgfullurl(prefixUrl+baseGoodsDTO.getImgurl());
List<Multifile> multifiles = multifileMapper.selectList(new QueryWrapper<Multifile>()
@@ -374,7 +376,7 @@
return baseGoodsMapper.selectCount(wrapper);
}
-
+ @Transactional(rollbackFor = {Exception.class,BusinessException.class})
@Override
public Integer importBaseGoodsBatch(MultipartFile file) {
@@ -406,6 +408,10 @@
dataList.forEach(s->{
+ if(baseGoodsMapper.selectCount(new QueryWrapper<BaseGoods>().eq("ISDELETED", Constants.ZERO).eq("name",s.getName()))>0){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"銆�"+s.getName()+"銆戝凡瀛樺湪");
+ }
+
BaseGoods baseGoods = new BaseGoods();
baseGoods.setCreator(user.getId());
baseGoods.setCreateDate(new Date());
@@ -414,7 +420,8 @@
baseGoods.setIsdeleted(Constants.ZERO);
baseGoods.setName(s.getName());
baseGoods.setStatus(Constants.ZERO);
-
+ baseGoods.setZdPrice(new BigDecimal(s.getZdPrice()));
+ baseGoods.setPrice(new BigDecimal(s.getPrice()));
if (StringUtils.isBlank(s.getCategoryName())){
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧绫诲埆涓嶅彲涓虹┖");
}
@@ -422,26 +429,87 @@
categoryQuery.lambda()
.eq(BaseCategory::getName,s.getCategoryName());
BaseCategory baseCategory = baseCategoryMapper.selectOne(categoryQuery);
-
+ if (Objects.isNull(baseCategory)){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧绫诲埆涓嶅瓨鍦�");
+ }
QueryWrapper<Brand> brandQuery = new QueryWrapper<>();
brandQuery.lambda()
.eq(Brand::getName,s.getBrandName());
Brand brand = brandMapper.selectOne(brandQuery);
+ if (Objects.isNull(brand)){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧鍝佺墝涓嶅瓨鍦�");
+ }
+ //澶勭悊鎵归噺涓婁紶
+ String proDir =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PLATFORM).getCode();
+
+ String path = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.GOODS_IMG_DIR).getCode()
+ + proDir + File.separator + s.getId();
+
+ List<String> mulFiles = new ArrayList<>();
+ if(StringUtils.isNotBlank(path)){
+ OssModel ossModel = baseDataService.initOssModel();
+ File dir =new File(path+File.separator);
+ if(dir!=null && dir.isDirectory()){
+ File[] files = dir.listFiles();
+ if(files!=null && files.length>0){
+ for(File f:files){
+ if(isImgFile(f)){
+ //鍙栫涓�寮犲浘鐗囦綔涓哄垪琛ㄥ浘
+ baseGoods.setImgurl(baseDataService.getOssImgurl(ossModel,ossModel.getGoodsFolder(),f));
+ }
+ if(f.isDirectory()){
+ //濡傛灉鏄枃浠跺す
+ File[] fs = f.listFiles();
+ if(fs != null && fs.length > 0){
+ for(File mf : fs){
+ if(isImgFile(mf)){
+ if(mulFiles==null){
+ mulFiles = new ArrayList<>();
+ }
+ mulFiles.add(baseDataService.getOssImgurl(ossModel,ossModel.getGoodsFolder(),mf));
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+
+
// baseGoods.setImgurl();
baseGoods.setCategoryId(baseCategory.getId());
baseGoods.setBrandId(brand.getId());
baseGoodsMapper.insert(baseGoods);
+ if(mulFiles !=null && mulFiles.size()>0){
+ for(int i=0;i<mulFiles.size();i++){
+ String str = mulFiles.get(i);
+ Multifile f = new Multifile();
+ f.setObjType(Constants.ZERO);
+ f.setName(str);
+ f.setType(Constants.ZERO);
+ f.setObjId(baseGoods.getId());
+ f.setCreateDate(new Date());
+ f.setCreator(user.getId());
+ f.setIsdeleted(Constants.ZERO);
+ f.setSortnum(i);
+ f.setCompanyId(user.getCompanyId());
+ f.setFileurl(str);
+ multifileMapper.insert(f);
+ }
+ }
+
String baseGoodsParamString = s.getBaseGoodsParamString();
List<List<String>> collect = Arrays.asList(baseGoodsParamString.split("\n"))
.stream().map(s1 -> Arrays.asList(s1.split("[锛�,:]")) ).collect(Collectors.toList());
if (!CollectionUtils.isEmpty(collect)){
- Integer i = 0;
- collect.forEach(s2->{
+// Integer i = 0;
+ for (int i = 0; i < collect.size(); i++){
if (!CollectionUtils.isEmpty(baseCategory.getBaseCateParamList())){
-
+ List<String> s2 = collect.get(i);
BaseCateParam baseCateParam = baseCategory.getBaseCateParamList()
.stream().filter(s3 -> s3.getName().equals(s2.get(0))).findFirst()
.orElseThrow(()->new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"閰嶇疆鍙傛暟涓嶅瓨鍦�"));
@@ -461,7 +529,7 @@
baseGoodsParamMapper.insert(baseGoodsParam);
}
- });
+ };
}
@@ -474,4 +542,19 @@
}
return null;
}
+
+ private boolean isImgFile(File f) {
+ if(f!=null && f.isFile() ){
+ String name = f.getName();
+ if(name.endsWith(".jpg")
+ ||name.endsWith(".JPG")
+ ||name.endsWith(".JPEG")
+ ||name.endsWith(".jpeg")
+ ||name.endsWith(".PNG")
+ ||name.endsWith(".png")){
+ return true;
+ }
+ }
+ return false;
+ }
}
--
Gitblit v1.9.3