From 68cf0297f541f3891d33e173c3d5fee145aab169 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期二, 19 九月 2023 12:21:44 +0800
Subject: [PATCH] 基础字段

---
 server/company/src/main/java/com/doumee/api/business/GoodsController.java                  |   14 ++
 server/service/src/main/java/com/doumee/service/CateParamSelectService.java                |    3 
 server/service/src/main/java/com/doumee/service/business/impl/BaseCategoryServiceImpl.java |    3 
 server/company/src/main/java/com/doumee/api/business/CategoryController.java               |    5 +
 server/service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java    |    4 
 server/service/src/main/resources/mappers/CateParamSelectMapper.xml                        |   19 ++++
 server/service/src/main/java/com/doumee/biz/system/impl/SystemUserBizImpl.java             |   15 +++
 server/service/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java     |    8 +
 server/service/src/main/java/com/doumee/dao/business/CateParamSelectMapper.java            |    4 +
 server/service/src/main/java/com/doumee/service/impl/CateParamSelectServiceImpl.java       |   19 +++-
 server/service/src/main/java/com/doumee/service/business/impl/GoodsServiceImpl.java        |  115 ++++++++++++++--------------
 server/service/src/main/java/com/doumee/core/utils/Constants.java                          |    1 
 server/service/src/main/java/com/doumee/service/business/impl/BrandServiceImpl.java        |    5 +
 server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java                       |   19 ++++
 14 files changed, 160 insertions(+), 74 deletions(-)

diff --git a/server/company/src/main/java/com/doumee/api/business/CategoryController.java b/server/company/src/main/java/com/doumee/api/business/CategoryController.java
index 029e1d8..47bf101 100644
--- a/server/company/src/main/java/com/doumee/api/business/CategoryController.java
+++ b/server/company/src/main/java/com/doumee/api/business/CategoryController.java
@@ -13,6 +13,7 @@
 import com.doumee.dao.business.model.BaseCateParam;
 import com.doumee.dao.business.model.BaseCategory;
 import com.doumee.dao.business.model.Category;
+import com.doumee.service.CateParamSelectService;
 import com.doumee.service.business.BaseCateParamService;
 import com.doumee.service.business.BaseCategoryService;
 import com.doumee.service.business.CategoryService;
@@ -45,6 +46,8 @@
 
     @Autowired
     private BaseCateParamService baseCateParamService;
+    @Autowired
+    private CateParamSelectService cateParamSelectService;
 
     @PreventRepeat
     @ApiOperation("鏂板缓")
@@ -97,6 +100,7 @@
     @RequiresPermissions("business:category:update")
     public ApiResponse companyUpdateById(@RequestBody Category category) {
         categoryService.companyUpdateById(category);
+        cateParamSelectService.dealCateParamSelect();
         return ApiResponse.success(null);
     }
 
@@ -156,7 +160,6 @@
         BaseCategory baseCategory = new BaseCategory();
         baseCategory.setIsdeleted(Constants.ZERO);
         baseCategory.setStatus(Constants.ZERO);
-        baseCategoryService.findList(baseCategory);
         List list = baseCategoryService.findList(baseCategory);
         return ApiResponse.success(list);
     }
diff --git a/server/company/src/main/java/com/doumee/api/business/GoodsController.java b/server/company/src/main/java/com/doumee/api/business/GoodsController.java
index 0b62d52..835b91e 100644
--- a/server/company/src/main/java/com/doumee/api/business/GoodsController.java
+++ b/server/company/src/main/java/com/doumee/api/business/GoodsController.java
@@ -13,6 +13,7 @@
 import com.doumee.service.CateParamSelectService;
 import com.doumee.service.business.GoodsService;
 import io.swagger.annotations.*;
+import lombok.extern.java.Log;
 import org.apache.shiro.SecurityUtils;
 import org.apache.shiro.authz.annotation.RequiresPermissions;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -56,7 +57,7 @@
 //    @RequiresPermissions("business:goods:create")
     public ApiResponse companyCreate(@RequestBody Goods goods) {
         goodsService.companyCreate(goods);
-        cateParamSelectService.dealGroupVals(goods.getCompanyId());
+        cateParamSelectService.dealCateParamSelect();
         return ApiResponse.success("鎿嶄綔鎴愬姛");
     }
 
@@ -65,7 +66,9 @@
     @PostMapping("/createPlat")
     @RequiresPermissions("business:goods:create")
     public ApiResponse createPlat(@RequestBody GoodCreatePlatRequest param) {
-        return ApiResponse.success(goodsService.createPlat(param));
+        goodsService.createPlat(param);
+        cateParamSelectService.dealCateParamSelect();
+        return ApiResponse.success("鎿嶄綔鎴愬姛");
     }
 
     @ApiOperation("鏍规嵁ID鍒犻櫎")
@@ -73,6 +76,7 @@
     @RequiresPermissions("business:goods:delete")
     public ApiResponse deleteById(@PathVariable Integer id) {
         goodsService.deleteById(id);
+        cateParamSelectService.dealCateParamSelect();
         return ApiResponse.success(null);
     }
 
@@ -86,6 +90,7 @@
             idList.add(Integer.valueOf(id));
         }
         goodsService.deleteByIdInBatch(idList);
+        cateParamSelectService.dealCateParamSelect();
         return ApiResponse.success(null);
     }
 
@@ -102,6 +107,7 @@
     @RequiresPermissions("business:goods:update")
     public ApiResponse companyUpdateById(@RequestBody Goods goods) {
         goodsService.companyUpdateById(goods);
+        cateParamSelectService.dealCateParamSelect();
         return ApiResponse.success(null);
     }
 
@@ -135,7 +141,9 @@
     })
 //    @RequiresPermissions("business:goods:create")
     public ApiResponse<Integer> importExcel (@ApiParam(value = "file") MultipartFile file) {
-        return ApiResponse.success(goodsService.importBatch(file));
+        Integer val = goodsService.importBatch(file);
+        cateParamSelectService.dealCateParamSelect();
+        return ApiResponse.success(val);
     }
 
 
diff --git a/server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java b/server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java
index e517d0d..c294ef4 100644
--- a/server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java
+++ b/server/company/src/main/java/com/doumee/config/shiro/ShiroRealm.java
@@ -4,9 +4,12 @@
 import com.doumee.core.exception.BusinessException;
 import com.doumee.core.model.LoginUserInfo;
 import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.dao.business.model.Company;
 import com.doumee.dao.system.model.SystemPermission;
 import com.doumee.dao.system.model.SystemRole;
 import com.doumee.dao.system.model.SystemUser;
+import com.doumee.service.business.CompanyService;
 import com.doumee.service.system.SystemDataPermissionService;
 import com.doumee.service.system.SystemPermissionService;
 import com.doumee.service.system.SystemRoleService;
@@ -23,6 +26,7 @@
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -48,6 +52,10 @@
     @Autowired
     private SystemPermissionService systemPermissionService;
 
+    @Lazy
+    @Autowired
+    private CompanyService companyService;
+
     /**
      * 鏉冮檺澶勭悊
      * @author Eva.Caesar Liu
@@ -69,7 +77,7 @@
      * @date 2022/03/15 09:54
      */
     @Override
-    protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException {
+    protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken authenticationToken) throws AuthenticationException{
         // 鑾峰彇鐢ㄦ埛鍚�
         String username = authenticationToken.getPrincipal().toString();
         // 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
@@ -86,6 +94,15 @@
         if(!Constants.equalsInteger(user.getStatus(),Constants.ZERO)){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝璐﹀彿淇℃伅宸茶绂佺敤锛屽鏈夌枒闂鑱旂郴绯荤粺绠$悊鍛橈紒");
         }
+        if(!user.getType().equals(Constants.UserType.SYSTEM)){
+            Company company = companyService.findById(user.getCompanyId());
+            if(company.getStatus().equals(Constants.ONE)){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝浼佷笟淇℃伅宸茶绂佺敤锛屽鏈夌枒闂鑱旂郴绯荤粺绠$悊鍛橈紒");
+            }
+            if(DateUtil.compareDate(new Date(),DateUtil.addDaysToDate(company.getOepnValidDate(),1))<=Constants.ZERO){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝浼佷笟淇℃伅宸茶繃鏈燂紝濡傛湁鐤戦棶璇疯仈绯荤郴缁熺鐞嗗憳锛�");
+            }
+        }
 
         // 鑾峰彇鐧诲綍鐢ㄦ埛淇℃伅
         List<SystemRole> roles = systemRoleService.findByUserId(user.getId());
diff --git a/server/service/src/main/java/com/doumee/biz/system/impl/SystemUserBizImpl.java b/server/service/src/main/java/com/doumee/biz/system/impl/SystemUserBizImpl.java
index 04ea0cb..dee67ff 100644
--- a/server/service/src/main/java/com/doumee/biz/system/impl/SystemUserBizImpl.java
+++ b/server/service/src/main/java/com/doumee/biz/system/impl/SystemUserBizImpl.java
@@ -7,11 +7,13 @@
 import com.doumee.core.model.LoginUserInfo;
 import com.doumee.core.utils.Constants;
 import com.doumee.core.utils.Utils;
+import com.doumee.dao.business.model.Company;
 import com.doumee.dao.system.dto.*;
 import com.doumee.dao.system.model.SystemDepartment;
 import com.doumee.dao.system.model.SystemDepartmentUser;
 import com.doumee.dao.system.model.SystemUser;
 import com.doumee.dao.system.model.SystemUserRole;
+import com.doumee.service.business.CompanyService;
 import com.doumee.service.system.*;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -32,6 +34,9 @@
 
     @Autowired
     private SystemUserService systemUserService;
+
+    @Autowired
+    private CompanyService companyService;
 
     @Autowired
     private SystemUserRoleService systemUserRoleService;
@@ -247,6 +252,16 @@
         if (user != null) {
             throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "鐢ㄦ埛鍚嶅凡瀛樺湪");
         }
+        if(createCompanyUserDTO.getType().equals(Constants.UserType.ZHUBO.getKey())){
+            Company company = companyService.findById(loginUserInfo.getCompanyId());
+            SystemUser zbUserNum = new SystemUser();
+            zbUserNum.setCompanyId(loginUserInfo.getCompanyId());
+            zbUserNum.setDeleted(Boolean.FALSE);
+            zbUserNum.setType(Constants.UserType.ZHUBO.getKey());
+            if(systemUserService.findList(zbUserNum).size()>=company.getUserNum()){
+                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝宸茶秴鍑轰紒涓氬彲鍒嗛厤涓绘挱鏁伴噺锛屽鏈夌枒闂鑱旂郴绯荤粺绠$悊鍛橈紒");
+            }
+        }
         SystemUser systemUser  = new SystemUser();
         BeanUtils.copyProperties(createCompanyUserDTO,systemUser);
         systemUser.setCompanyId(loginUserInfo.getCompanyId());
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 ed54c71..dbea4ac 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
@@ -29,6 +29,7 @@
     public static final String TOP_IMG = "TOP_IMG";
     public static final String PK_IMG = "PK_IMG";
     public static final String RANGE_SIZE = "RANGE_SIZE";
+    public static final String CATE_PARAM_OPEN = "_CATE_PARAM_OPEN";
 
 
     public static final String SYSTEM ="SYSTEM";
diff --git a/server/service/src/main/java/com/doumee/dao/business/CateParamSelectMapper.java b/server/service/src/main/java/com/doumee/dao/business/CateParamSelectMapper.java
index 1adabb6..85d8cac 100644
--- a/server/service/src/main/java/com/doumee/dao/business/CateParamSelectMapper.java
+++ b/server/service/src/main/java/com/doumee/dao/business/CateParamSelectMapper.java
@@ -3,10 +3,14 @@
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.doumee.dao.business.model.CateParamSelect;
 
+import java.util.List;
+
 /**
  * @author 姹熻箘韫�
  * @date 2023/09/11 14:45
  */
 public interface CateParamSelectMapper extends BaseMapper<CateParamSelect> {
 
+    void insertBatch(Integer companyId,Integer userId);
+
 }
diff --git a/server/service/src/main/java/com/doumee/service/CateParamSelectService.java b/server/service/src/main/java/com/doumee/service/CateParamSelectService.java
index 02aeeb4..ce0f2ff 100644
--- a/server/service/src/main/java/com/doumee/service/CateParamSelectService.java
+++ b/server/service/src/main/java/com/doumee/service/CateParamSelectService.java
@@ -1,5 +1,6 @@
 package com.doumee.service;
 
+import com.doumee.core.model.LoginUserInfo;
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
 import com.doumee.dao.business.model.CateParamSelect;
@@ -96,5 +97,5 @@
      */
     long count(CateParamSelect cateParamSelect);
 
-    void dealGroupVals(Integer companyId);
+    void dealCateParamSelect();
 }
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/BaseCategoryServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/BaseCategoryServiceImpl.java
index 59a522d..56cf831 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/BaseCategoryServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/BaseCategoryServiceImpl.java
@@ -257,8 +257,9 @@
 
     @Override
     public List<BaseCategory> findList(BaseCategory baseCategory) {
-        baseCategory.setIsdeleted(Constants.ZERO);
         QueryWrapper<BaseCategory> wrapper = new QueryWrapper<>(baseCategory);
+        wrapper.eq("ISDELETED",Constants.ZERO);
+        wrapper.eq("STATUS",Constants.ZERO);
         List<BaseCategory> list = baseCategoryMapper.selectList(wrapper);
         list.forEach(i->{
             if(StringUtils.isNotBlank(i.getImgurl())){
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/BrandServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/BrandServiceImpl.java
index 56ef6a8..2af9103 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/BrandServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/BrandServiceImpl.java
@@ -159,7 +159,7 @@
             wrapper.lambda().eq(Brand::getType,Constants.ONE);
         }else {
             wrapper.lambda().and(i->i.eq(Brand::getCompanyId,user.getCompanyId())
-                            .or().eq(Brand::getType,Constants.ZERO)
+                            .or().eq(Brand::getType,Constants.ONE)
             );
         }
         List<Brand> list = brandMapper.selectList(wrapper);
@@ -186,6 +186,9 @@
         if (pageWrap.getModel().getStatus() != null) {
             queryWrapper.lambda().eq(Brand::getStatus, pageWrap.getModel().getStatus());
         }
+        if (pageWrap.getModel().getType() != null) {
+            queryWrapper.lambda().eq(Brand::getType, pageWrap.getModel().getType());
+        }
         // 绫诲瀷 0浼佷笟 1骞冲彴
         if (Objects.isNull(user.getCompanyId())) {
             queryWrapper.lambda().eq(Brand::getType,Constants.ONE);
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java
index b076e7f..237ba6f 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/CategoryServiceImpl.java
@@ -279,7 +279,8 @@
     @Override
     public void companyUpdateById(Category category) {
         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
-        if(categoryMapper.selectCount(new QueryWrapper<Category>().eq("ISDELETED",Constants.ZERO).ne("id",category.getId()).eq("name",category.getName()))>0){
+        if(categoryMapper.selectCount(new QueryWrapper<Category>().eq("ISDELETED",Constants.ZERO).eq("COMPANY_ID",user.getCompanyId())
+                .ne("id",category.getId()).eq("name",category.getName()))>0){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"銆�"+category.getName()+"銆戝凡瀛樺湪");
         };
         category.setStatus(Constants.ZERO);
@@ -489,9 +490,11 @@
 
     @Override
     public List<Category> findListForGoods(Integer goodsId) {
+        LoginUserInfo loginUserInfo = (LoginUserInfo)SecurityUtils.getSubject().getPrincipal();
         QueryWrapper<Category> wrapper = new QueryWrapper<Category>()
                 .eq("STATUS",Constants.ZERO)
                 .eq("ISDELETED",Constants.ZERO)
+                .eq("COMPANY_ID",loginUserInfo.getCompanyId())
                 .orderByAsc(" SORTNUM ");
         List<Category> list = categoryMapper.selectList(wrapper);
         String prefixUrl = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
@@ -521,6 +524,9 @@
         if (pageWrap.getModel().getStatus() != null) {
             queryWrapper.lambda().eq(Category::getStatus, pageWrap.getModel().getStatus());
         }
+        if (pageWrap.getModel().getType() != null) {
+            queryWrapper.lambda().eq(Category::getType, pageWrap.getModel().getType());
+        }
         if (pageWrap.getModel().getCompanyId() != null) {
             queryWrapper.lambda().eq(Category::getCompanyId, pageWrap.getModel().getCompanyId());
         }
diff --git a/server/service/src/main/java/com/doumee/service/business/impl/GoodsServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/GoodsServiceImpl.java
index e5d6640..238da11 100644
--- a/server/service/src/main/java/com/doumee/service/business/impl/GoodsServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/business/impl/GoodsServiceImpl.java
@@ -223,19 +223,19 @@
                 goodsParamMapper.insert(goodsParam);
 
                 //瀛樺偍 cate_param_select 鏌ヨ鏄惁宸插瓨鍦�
-                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
-                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
-                    CateParamSelect cateParamSelect = new CateParamSelect();
-                    cateParamSelect.setCreator(user.getId());
-                    cateParamSelect.setCreateDate(new Date());
-                    cateParamSelect.setName(goodsParam.getVal());
-                    cateParamSelect.setIsdeleted(Constants.ZERO);
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelect.setParamId(goodsParam.getPramaId());
-                    cateParamSelect.setCategoryId(goods.getCategoryId());
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelectMapper.insert(cateParamSelect);
-                };
+//                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
+//                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
+//                    CateParamSelect cateParamSelect = new CateParamSelect();
+//                    cateParamSelect.setCreator(user.getId());
+//                    cateParamSelect.setCreateDate(new Date());
+//                    cateParamSelect.setName(goodsParam.getVal());
+//                    cateParamSelect.setIsdeleted(Constants.ZERO);
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelect.setParamId(goodsParam.getPramaId());
+//                    cateParamSelect.setCategoryId(goods.getCategoryId());
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelectMapper.insert(cateParamSelect);
+//                };
 
             }
         }
@@ -360,19 +360,19 @@
                 goodsParam.setGoodsId(goods.getId());
                 goodsParamMapper.insert(goodsParam);
                 //瀛樺偍 cate_param_select 鏌ヨ鏄惁宸插瓨鍦�
-                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
-                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
-                    CateParamSelect cateParamSelect = new CateParamSelect();
-                    cateParamSelect.setCreator(user.getId());
-                    cateParamSelect.setCreateDate(new Date());
-                    cateParamSelect.setName(goodsParam.getVal());
-                    cateParamSelect.setIsdeleted(Constants.ZERO);
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelect.setParamId(goodsParam.getPramaId());
-                    cateParamSelect.setCategoryId(goods.getCategoryId());
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelectMapper.insert(cateParamSelect);
-                };
+//                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
+//                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
+//                    CateParamSelect cateParamSelect = new CateParamSelect();
+//                    cateParamSelect.setCreator(user.getId());
+//                    cateParamSelect.setCreateDate(new Date());
+//                    cateParamSelect.setName(goodsParam.getVal());
+//                    cateParamSelect.setIsdeleted(Constants.ZERO);
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelect.setParamId(goodsParam.getPramaId());
+//                    cateParamSelect.setCategoryId(goods.getCategoryId());
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelectMapper.insert(cateParamSelect);
+//                };
             }
         }
         return goods.getId();
@@ -469,7 +469,8 @@
         goods.setShortPinyin(PinYinUtil.getFirstSpell(goods.getName()));
         goodsMapper.updateById(goods);
 
-        multifileMapper.delete(new QueryWrapper<Multifile>().eq("OBJ_ID",goods.getId()));
+        multifileMapper.delete(new QueryWrapper<Multifile>().eq("OBJ_ID",goods.getId())
+                .eq("OBJ_TYPE",0).eq("COMPANY_ID",user.getCompanyId()));
         List<Multifile> multifileList = goods.getMultifileList();
         if(!Objects.isNull(multifileList)&&multifileList.size()>Constants.ZERO){
             for (int i = 0; i < multifileList.size(); i++) {
@@ -497,19 +498,19 @@
                 goodsParam.setGoodsId(goods.getId());
                 goodsParamMapper.insert(goodsParam);
                 //瀛樺偍 cate_param_select 鏌ヨ鏄惁宸插瓨鍦�
-                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
-                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
-                    CateParamSelect cateParamSelect = new CateParamSelect();
-                    cateParamSelect.setCreator(user.getId());
-                    cateParamSelect.setCreateDate(new Date());
-                    cateParamSelect.setName(goodsParam.getVal());
-                    cateParamSelect.setIsdeleted(Constants.ZERO);
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelect.setParamId(goodsParam.getPramaId());
-                    cateParamSelect.setCategoryId(goods.getCategoryId());
-                    cateParamSelect.setStatus(Constants.ZERO);
-                    cateParamSelectMapper.insert(cateParamSelect);
-                };
+//                if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
+//                        .eq("PARAM_ID",goodsParam.getPramaId()).eq("NAME",goodsParam.getName()))<=Constants.ZERO){
+//                    CateParamSelect cateParamSelect = new CateParamSelect();
+//                    cateParamSelect.setCreator(user.getId());
+//                    cateParamSelect.setCreateDate(new Date());
+//                    cateParamSelect.setName(goodsParam.getVal());
+//                    cateParamSelect.setIsdeleted(Constants.ZERO);
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelect.setParamId(goodsParam.getPramaId());
+//                    cateParamSelect.setCategoryId(goods.getCategoryId());
+//                    cateParamSelect.setStatus(Constants.ZERO);
+//                    cateParamSelectMapper.insert(cateParamSelect);
+//                };
             }
         }
     }
@@ -677,7 +678,9 @@
         if (pageWrap.getModel().getStatus() != null) {
             queryWrapper.eq(Goods::getStatus, pageWrap.getModel().getStatus());
         }
-
+        if (pageWrap.getModel().getType() != null) {
+            queryWrapper.eq(Goods::getType, pageWrap.getModel().getType());
+        }
         if (pageWrap.getModel().getCategoryId() != null) {
             queryWrapper.eq(Goods::getCategoryId, pageWrap.getModel().getCategoryId());
         }
@@ -693,10 +696,6 @@
                 + systemDictDataBiz.queryByCode(Constants.OSS, Constants.GOODS_IMG).getCode();
         goodsIPage.getRecords().forEach(i->{
             i.setPrefixUrl(prefixUrl);
-            if(i.getType().equals(Constants.ONE)){
-                i.setBasePrice(i.getBasePrice().multiply(i.getBasePriceRate()));
-            }
-
         });
         return PageData.from(goodsIPage);
     }
@@ -875,19 +874,19 @@
                     //鎻掑叆浜у搧鍙傛暟鍏宠仈琛�
                     goodsParamMapper.insert(gp);
                     //瀛樺偍 cate_param_select 鏌ヨ鏄惁宸插瓨鍦�
-                    if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
-                            .eq("PARAM_ID",gp.getPramaId()).eq("NAME",gp.getName()))<=Constants.ZERO){
-                        CateParamSelect cateParamSelect = new CateParamSelect();
-                        cateParamSelect.setCreator(user.getId());
-                        cateParamSelect.setCreateDate(new Date());
-                        cateParamSelect.setName(gp.getVal());
-                        cateParamSelect.setIsdeleted(Constants.ZERO);
-                        cateParamSelect.setStatus(Constants.ZERO);
-                        cateParamSelect.setParamId(gp.getPramaId());
-                        cateParamSelect.setCategoryId(newModel.getCategoryId());
-                        cateParamSelect.setStatus(Constants.ZERO);
-                        cateParamSelectMapper.insert(cateParamSelect);
-                    };
+//                    if(cateParamSelectMapper.selectCount(new QueryWrapper<CateParamSelect>()
+//                            .eq("PARAM_ID",gp.getPramaId()).eq("NAME",gp.getName()))<=Constants.ZERO){
+//                        CateParamSelect cateParamSelect = new CateParamSelect();
+//                        cateParamSelect.setCreator(user.getId());
+//                        cateParamSelect.setCreateDate(new Date());
+//                        cateParamSelect.setName(gp.getVal());
+//                        cateParamSelect.setIsdeleted(Constants.ZERO);
+//                        cateParamSelect.setStatus(Constants.ZERO);
+//                        cateParamSelect.setParamId(gp.getPramaId());
+//                        cateParamSelect.setCategoryId(newModel.getCategoryId());
+//                        cateParamSelect.setStatus(Constants.ZERO);
+//                        cateParamSelectMapper.insert(cateParamSelect);
+//                    };
                 }
             }
             if(mulFiles !=null && mulFiles.size()>0){
diff --git a/server/service/src/main/java/com/doumee/service/impl/CateParamSelectServiceImpl.java b/server/service/src/main/java/com/doumee/service/impl/CateParamSelectServiceImpl.java
index fd8c3f6..0f3717a 100644
--- a/server/service/src/main/java/com/doumee/service/impl/CateParamSelectServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/impl/CateParamSelectServiceImpl.java
@@ -4,12 +4,15 @@
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.doumee.core.model.LoginUserInfo;
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
+import com.doumee.core.utils.Constants;
 import com.doumee.core.utils.Utils;
 import com.doumee.dao.business.CateParamSelectMapper;
 import com.doumee.dao.business.model.CateParamSelect;
 import com.doumee.service.CateParamSelectService;
+import org.apache.shiro.SecurityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.Async;
@@ -28,6 +31,7 @@
 
     @Autowired
     private RedisTemplate redisTemplate;
+
     @Autowired
     private CateParamSelectMapper cateParamSelectMapper;
 
@@ -149,19 +153,22 @@
 
     @Override
     @Async
-    public   void dealGroupVals(Integer companyId) {
-        Boolean  isGrouping = (Boolean)redisTemplate.opsForValue().get(companyId+"_isGrouping");
+    public   void dealCateParamSelect() {
+        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+        Boolean  isGrouping = (Boolean)redisTemplate.opsForValue().get(loginUserInfo.getCompanyId()+Constants.CATE_PARAM_OPEN);
         if(isGrouping!=null && isGrouping ){
             return;
         }
-        redisTemplate.opsForValue().set(companyId+"_isGrouping",true);
+        redisTemplate.opsForValue().set(loginUserInfo.getCompanyId()+Constants.CATE_PARAM_OPEN,true);
         try {
-            //---------TODO-------浠诲悍
-
+            //鍒犻櫎浼佷笟涓嬪巻鍙叉暟鎹�
+            cateParamSelectMapper.delete(new QueryWrapper<CateParamSelect>().exists(" select 1 from category c where c.id = cate_param_select.category_id and  c.company_id = "+loginUserInfo.getCompanyId()+"   "));
+            //鏂板褰撳墠浼佷笟鍙互浣跨敤鐨勬暟鎹�
+            cateParamSelectMapper.insertBatch(loginUserInfo.getCompanyId(),loginUserInfo.getId());
         }catch (Exception e){
 
         }finally {
-            redisTemplate.opsForValue().set(companyId+"_isGrouping",false);
+            redisTemplate.opsForValue().set(loginUserInfo.getCompanyId()+Constants.CATE_PARAM_OPEN,false);
         }
     }
 }
diff --git a/server/service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java b/server/service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
index 2f4ce06..b41579c 100644
--- a/server/service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
@@ -1,5 +1,6 @@
 package com.doumee.service.system.impl;
 
+import com.baomidou.mybatisplus.extension.api.R;
 import com.doumee.core.constants.ResponseStatus;
 import com.doumee.core.exception.BusinessException;
 import com.doumee.core.model.LoginUserInfo;
@@ -21,6 +22,7 @@
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.Date;
+import java.util.Objects;
 
 @Slf4j
 @Service
@@ -77,7 +79,7 @@
             loginLog.setReason(e.getMessage().length() > 200 ? (e.getMessage().substring(0, 190) + "...") : e.getMessage());
             loginLog.setSuccess(Boolean.FALSE);
             systemLoginLogService.create(loginLog);
-            throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
+            throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT.getCode(), Objects.isNull(e.getCause())?ResponseStatus.ACCOUNT_INCORRECT.getMessage():e.getCause().getMessage());
         }
     }
 }
diff --git a/server/service/src/main/resources/mappers/CateParamSelectMapper.xml b/server/service/src/main/resources/mappers/CateParamSelectMapper.xml
new file mode 100644
index 0000000..f11a72c
--- /dev/null
+++ b/server/service/src/main/resources/mappers/CateParamSelectMapper.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.doumee.dao.business.CateParamSelectMapper">
+
+
+    <insert id="insertBatch"  >
+        INSERT INTO `cate_param_select`
+            (`CREATOR`, `CREATE_DATE`, `EDITOR`, `EDIT_DATE`, `ISDELETED`, `REMARK`, `NAME`, `PARAM_ID`, `CATEGORY_ID`,
+             `STATUS`, `SORTNUM`)
+            select #{userId} , now(),null , null , 0 , null , a.VAL , a.PRAMA_ID , b.CATEGORY_ID , 0 , null  from goods_param a  inner join goods  b on a.GOODS_ID = b.ID
+                and a.PRAMA_ID is not null AND a.VAL is not null
+                and a.ISDELETED = 0
+                and a.`STATUS` = 0
+                and b.`STATUS` = 0
+                and b.ISDELETED = 0
+                AND b.company_id = #{companyId}
+    </insert>
+
+</mapper>

--
Gitblit v1.9.3