From 0ad62ef3a9bcc2d8f0e3ae988f0a17cfd2384c26 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 19 九月 2023 14:58:54 +0800
Subject: [PATCH] 修改

---
 server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java  |    1 
 server/service/src/main/java/com/doumee/service/business/impl/BaseGoodsServiceImpl.java |   94 +++++++++++++++++++++++-----------------------
 server/service/src/main/java/com/doumee/core/utils/Constants.java                       |    6 +++
 server/service/src/main/java/com/doumee/dao/business/model/BaseGoods.java               |    3 +
 server/platform/src/main/resources/application.yml                                      |    2 
 5 files changed, 58 insertions(+), 48 deletions(-)

diff --git a/server/platform/src/main/resources/application.yml b/server/platform/src/main/resources/application.yml
index 687a24a..bf924e8 100644
--- a/server/platform/src/main/resources/application.yml
+++ b/server/platform/src/main/resources/application.yml
@@ -5,7 +5,7 @@
   env: development
 #  env: production
 server:
-  port: 10011
+  port: 10023
 
 spring:
 #  application:
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 dbea4ac..26b3869 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
@@ -306,6 +306,12 @@
             this.noteInfo = noteInfo;
         }
     }
+
+    public interface BasegoodsOrigin{
+         int userAdd = 0;
+         int imported = 1;
+         int basedata = 2;
+    }
     /**
      * 鍏宠仈瀵硅薄绫诲瀷 0浼佷笟钀ヤ笟鎵х収 1宸ュ晢鍙樻洿鐧昏  2椤圭洰鐢虫姤浼佷笟璧勬枡 3浼佷笟璇勫垎琛� 4璇婃柇鎶ュ憡 5璇婃柇鏈嶅姟璧勬枡 6涓撳璇勫垎鎶ュ憡 7鏈嶅姟鏈烘瀯涓婁紶鏈嶅姟璧勬枡 8浼佷笟璧勮川 9浼佷笟涓爣閫氱煡涔� 10椤圭洰鍥剧墖
      */
diff --git a/server/service/src/main/java/com/doumee/dao/business/model/BaseGoods.java b/server/service/src/main/java/com/doumee/dao/business/model/BaseGoods.java
index 97ab626..adbe230 100644
--- a/server/service/src/main/java/com/doumee/dao/business/model/BaseGoods.java
+++ b/server/service/src/main/java/com/doumee/dao/business/model/BaseGoods.java
@@ -93,6 +93,9 @@
     @ApiModelProperty(value = "鍏ユ墜浠锋牸锛堝厓锛�", example = "1")
     @ExcelColumn(name="鍏ユ墜浠锋牸锛堝厓锛�")
     private BigDecimal price;
+    @ApiModelProperty(value = "鏁版嵁鏉ユ簮 0鎵嬪姩褰曞叆 1鎵归噺瀵煎叆 2鏁版嵁婧愬悓姝�", example = "1")
+    @ExcelColumn(name="鏁版嵁鏉ユ簮 0鎵嬪姩褰曞叆 1鎵归噺瀵煎叆 2鏁版嵁婧愬悓姝�")
+    private Integer origin;
 
     @ApiModelProperty(value = "鍟嗗搧璇︽儏")
     @ExcelColumn(name="鍟嗗搧璇︽儏")
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java
index 7cb9362..78f36fe 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/BaseDataServiceImpl.java
@@ -373,6 +373,7 @@
         goods.setRemark(data.getTitle());
         goods.setContent(data.getTitle());
         goods.setStatus(Constants.ZERO);
+        goods.setOrigin(Constants.BasegoodsOrigin.basedata);
         goods.setShortPinyin(PinYinUtil.getFirstSpell(goods.getName()));
         goods.setPinyin(PinYinUtil.getFullSpell(goods.getName()));
         goods.setZdPrice(data.getPrice());
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 db4a088..a4f7709 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
@@ -434,32 +434,26 @@
             if(dataList == null || dataList.size() ==0){
                 throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝褰曞叆鏁版嵁涓虹┖锛�");
             }
-            List<String> comNameList = dataList.stream().map(s -> s.getName().trim()).distinct().collect(Collectors.toList());
-
-            if (!(dataList.size() == comNameList.size())){
-                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧鍚嶇О鏈夊凡瀛樺湪");
-            }
-
-//            List<String> collect1 = dataList.stream().filter(s->{
-//                if (StringUtils.isBlank(s.getBrandName())){
-//                    throw new BusinessException(ResponseStatus.BAD_REQUEST);
-//                }else {
-//                    return true;
-//                }
-//            }).map(s -> s.getCategoryName()).collect(Collectors.toList());
-//            QueryWrapper<BaseCategory> wrapper = new QueryWrapper<>();
-//            wrapper.lambda()
-//                    .in(BaseCategory::getName,collect1);
-//            List<BaseCategory> baseCategories = baseCategoryMapper.selectList(wrapper);
-
-            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()+"銆戝凡瀛樺湪");
+            //澶勭悊鎵归噺涓婁紶
+            String proDir =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.PLATFORM).getCode();
+            String basePath = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.GOODS_IMG_DIR).getCode()
+                    + proDir + File.separator ;
+            OssModel ossModel = baseDataService.initOssModel();
+            for (int index = 0; index < dataList.size(); index++) {
+                BaseGoodsImportDTO  s = dataList.get(index);
+                if(existedIdInList(s.getId(),index,dataList)){
+                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"绗��"+(1+index)+"琛屻�戝晢鍝佺紪鍙枫��"+s.getId()+"銆戝湪琛ㄦ牸涓噸澶�");
+                }
+                if(baseGoodsMapper.selectCount(new QueryWrapper<BaseGoods>().lambda().eq(BaseGoods::getIsdeleted, Constants.ZERO)
+                        .eq(BaseGoods::getBaseDataId,s.getId())
+                        .eq(BaseGoods::getOrigin,Constants.BasegoodsOrigin.imported))>0){
+                    throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"绗��"+(1+index)+"琛屻�戝晢鍝佺紪鍙枫��"+s.getId()+"銆戝凡瀵煎叆锛�");
                 }
 
                 BaseGoods baseGoods = new BaseGoods();
                 baseGoods.setCreator(user.getId());
+                baseGoods.setOrigin(Constants.BasegoodsOrigin.imported);
+                baseGoods.setBaseDataId(s.getId());
                 baseGoods.setCreateDate(new Date());
                 baseGoods.setEditor(user.getId());
                 baseGoods.setEditDate(new Date());
@@ -469,39 +463,39 @@
                 baseGoods.setZdPrice(new BigDecimal(s.getZdPrice()));
                 baseGoods.setPrice(new BigDecimal(s.getPrice()));
                 if (StringUtils.isBlank(s.getCategoryName())){
-                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧绫诲埆涓嶅彲涓虹┖");
+                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"绗��"+(1+index)+"琛屻�戝晢鍝佺被鍒笉鍙负绌�");
                 }
                 QueryWrapper<BaseCategory> categoryQuery = new QueryWrapper<>();
                 categoryQuery.lambda()
                     .eq(BaseCategory::getName,s.getCategoryName());
-                BaseCategory baseCategory = baseCategoryMapper.selectOne(categoryQuery);
+                categoryQuery.lambda()
+                    .eq(BaseCategory::getIsdeleted,Constants.ZERO);
+                BaseCategory baseCategory = baseCategoryMapper.selectOne(categoryQuery.last(" limit 1"));
                 if (Objects.isNull(baseCategory)){
-                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧绫诲埆涓嶅瓨鍦�");
+                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"绗��"+(1+index)+"琛屻�戝晢鍝佺被鍒��"+s.getCategoryName()+"銆戜笉瀛樺湪");
                 }
 
                 QueryWrapper<Brand> brandQuery = new QueryWrapper<>();
                 brandQuery.lambda()
                         .eq(Brand::getName,s.getBrandName());
-                Brand brand = brandMapper.selectOne(brandQuery);
+                brandQuery.lambda()
+                        .eq(Brand::getIsdeleted,Constants.ZERO);
+                brandQuery.lambda()
+                        .eq(Brand::getType,Constants.ZERO);
+                Brand brand = brandMapper.selectOne(brandQuery.last("limit 1"));
 
                 if (Objects.isNull(brand)){
-                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鍟嗗搧鍝佺墝涓嶅瓨鍦�");
+                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"绗��"+(1+index)+"琛屻�戝晢鍝佸搧鐗屻��"+s.getBrandName()+"銆戜笉瀛樺湪");
                 }
-                //澶勭悊鎵归噺涓婁紶
-                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();
-
+                String path =basePath+ 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)){
+                                if(StringUtils.isBlank(baseCategory.getImgurl()) && isImgFile(f)){
                                     //鍙栫涓�寮犲浘鐗囦綔涓哄垪琛ㄥ浘
                                     baseGoods.setImgurl(baseDataService.getOssImgurl(ossModel,ossModel.getGoodsFolder(),f));
                                 }
@@ -523,8 +517,6 @@
                         }
                     }
                 }
-
-
 //                baseGoods.setImgurl();
                 baseGoods.setCategoryId(baseCategory.getId());
                 baseGoods.setBrandId(brand.getId());
@@ -551,14 +543,13 @@
                 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;
-                    for (int i = 0; i < collect.size(); i++){
-                        if (!CollectionUtils.isEmpty(baseCategory.getBaseCateParamList())){
+                if (!CollectionUtils.isEmpty(collect)) {
+                    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(),"閰嶇疆鍙傛暟涓嶅瓨鍦�"));
+                                    .orElseThrow(() -> new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "閰嶇疆鍙傛暟銆愩�戜笉瀛樺湪"));
                             BaseGoodsParam baseGoodsParam = new BaseGoodsParam();
                             baseGoodsParam.setCreator(user.getId());
                             baseGoodsParam.setCreateDate(new Date());
@@ -568,18 +559,18 @@
                             baseGoodsParam.setName(baseCateParam.getName());
                             baseGoodsParam.setRemark(baseCateParam.getRemark());
                             baseGoodsParam.setStatus(Constants.ZERO);
-                            baseGoodsParam.setSortnum(i+Constants.ONE);
+                            baseGoodsParam.setSortnum(i + Constants.ONE);
                             baseGoodsParam.setPramaId(baseCateParam.getId());
-                            baseGoodsParam.setVal(s2.size() > 1 ? s2.get(1) : null );
+                            baseGoodsParam.setVal(s2.size() > 1 ? s2.get(1) : null);
                             baseGoodsParam.setGoodsId(baseGoods.getId());
                             baseGoodsParamMapper.insert(baseGoodsParam);
 
                         }
-                    };
-
+                    }
+                    ;
                 }
 
-            });
+            }
         }catch (Exception e) {
             log.error(String.format("鎵归噺鎻掑叆寮傚父%s ",e.getMessage()));
             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),e.getMessage());
@@ -589,6 +580,15 @@
         return null;
     }
 
+    private boolean existedIdInList(String id,int index, List<BaseGoodsImportDTO> dataList) {
+        for (int j = 0; j <dataList.size(); j++) {
+            if(index!=j && StringUtils.equals(id,dataList.get(j).getId())){
+                return true;
+            }
+        }
+        return false;
+    }
+
     private boolean isImgFile(File f) {
         if(f!=null && f.isFile() ){
             String name = f.getName();

--
Gitblit v1.9.3