Merge branch 'zx_saas_goods' of http://git.dayaedu.com/yonge/mec into zx_saas_goods

mec-application/src/main/java/com/ym/mec/teacher/controller/GoodsController.java

@@ -1,5 +1,8 @@
 package com.ym.mec.teacher.controller;
 
+import com.ym.mec.biz.dal.entity.GoodsCategory;
+import com.ym.mec.biz.dal.wrapper.GoodsWrapper;
+import com.ym.mec.biz.service.GoodsCategoryService;
 import com.ym.mec.biz.service.GoodsService;
 import com.ym.mec.common.controller.BaseController;
 import io.swagger.annotations.Api;
@@ -11,6 +14,8 @@ import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Objects;
+
 @RequestMapping("${app-config.url.teacher:}/goods")
 @Api(tags = "商品(教材、辅件)服务")
 @RestController
@@ -18,11 +23,18 @@ public class GoodsController extends BaseController {
 
     @Autowired
     private GoodsService goodsService;
+    @Autowired
+    private GoodsCategoryService goodsCategoryService;
 
     @ApiOperation(value = "根据商品(教材、辅件)编号查询商品(教材、辅件)")
     @GetMapping("/get/{id}")
     public Object get(@ApiParam(value = "商品(教材、辅件)编号", required = true) @PathVariable("id") Integer id) {
-        return succeed(goodsService.getDetail(id));
+        GoodsWrapper.Goods goods = goodsService.getDetail(id);
+        GoodsCategory goodsCategory = goodsCategoryService.get(goods.getGoodsCategoryId());
+        if (Objects.nonNull(goodsCategory)) {
+            goods.setGoodsCategoryName(goodsCategory.getName());
+        }
+        return succeed(goods);
     }
 
 }

mec-application/src/main/java/com/ym/mec/web/controller/GoodsCategoryController.java

@@ -22,7 +22,7 @@ public class GoodsCategoryController extends BaseController {
     @PostMapping("/del")
     @PreAuthorize("@pcs.hasPermissions('category/del')")
     public Object del(Integer id) {
-        return succeed(goodsCategoryService.get(id));
+        return succeed(goodsCategoryService.delete(id));
     }
 
     @ApiOperation(value = "新增、修改商品类型")

mec-application/src/main/java/com/ym/mec/web/controller/GoodsController.java

@@ -3,11 +3,13 @@ package com.ym.mec.web.controller;
 import com.ym.mec.biz.dal.dao.EmployeeDao;
 import com.ym.mec.biz.dal.entity.Employee;
 import com.ym.mec.biz.dal.entity.Goods;
+import com.ym.mec.biz.dal.entity.GoodsCategory;
 import com.ym.mec.biz.dal.entity.GoodsProcurement;
 import com.ym.mec.biz.dal.enums.YesOrNoEnum;
 import com.ym.mec.biz.dal.page.GoodsQuery;
 import com.ym.mec.biz.dal.page.GoodsQueryInfo;
 import com.ym.mec.biz.dal.wrapper.GoodsWrapper;
+import com.ym.mec.biz.service.GoodsCategoryService;
 import com.ym.mec.biz.service.GoodsService;
 import com.ym.mec.biz.service.SysUserService;
 import com.ym.mec.common.controller.BaseController;
@@ -25,6 +27,10 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
 
 @RequestMapping("${app-config.url.web:}/goods")
 @Api(tags = "商品(教材、辅件)服务")
@@ -34,6 +40,8 @@ public class GoodsController extends BaseController {
     @Autowired
     private GoodsService goodsService;
     @Autowired
+    private GoodsCategoryService goodsCategoryService;
+    @Autowired
     private SysUserService sysUserService;
     @Autowired
     private EmployeeDao employeeDao;
@@ -89,7 +97,12 @@ public class GoodsController extends BaseController {
     @ApiOperation(value = "根据商品(教材、辅件)编号查询商品(教材、辅件)")
     @GetMapping("/get/{id}")
     public Object get(@ApiParam(value = "商品(教材、辅件)编号", required = true) @PathVariable("id") Integer id){
-        return succeed(goodsService.getDetail(id));
+        GoodsWrapper.Goods goods = goodsService.getDetail(id);
+        GoodsCategory goodsCategory = goodsCategoryService.get(goods.getGoodsCategoryId());
+        if(Objects.nonNull(goodsCategory)){
+            goods.setGoodsCategoryName(goodsCategory.getName());
+        }
+        return succeed(goods);
     }
 
     @ApiOperation(value = "分页查询商品(教材、辅件)列表")

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/Goods.java

@@ -179,6 +179,9 @@ public class Goods {
 	@ApiModelProperty(value = "库存预警")
 	private YesOrNoEnum stockWarning;
 
+	@ApiModelProperty(value = "是否是组合商品，1：是，0：不是")
+	private Boolean groupGoods;
+
 	private Integer tenantId = TenantContextHolder.getTenantId();
 
 	private String childId;

mec-biz/src/main/java/com/ym/mec/biz/dal/page/GoodsQueryInfo.java

@@ -57,8 +57,6 @@ public class GoodsQueryInfo extends QueryInfo {
 
     private Integer subjectId;
 
-    private String goodsCategoryIds;
-
     public Integer getNoOrganSearch() {
         return noOrganSearch;
     }
@@ -186,12 +184,4 @@ public class GoodsQueryInfo extends QueryInfo {
     public void setBrandId(String brandId) {
         this.brandId = brandId;
     }
-
-    public String getGoodsCategoryIds() {
-        return goodsCategoryIds;
-    }
-
-    public void setGoodsCategoryIds(String goodsCategoryIds) {
-        this.goodsCategoryIds = goodsCategoryIds;
-    }
 }

mec-biz/src/main/java/com/ym/mec/biz/dal/wrapper/GoodsWrapper.java

@@ -154,6 +154,9 @@ public class GoodsWrapper {
         @ApiModelProperty(value = "库存预警")
         private YesOrNoEnum stockWarning;
 
+        @ApiModelProperty(value = "是否是组合商品，1：是，0：不是")
+        private Boolean groupGoods;
+
         private Integer tenantId = TenantContextHolder.getTenantId();
 
         private String childId;
@@ -189,9 +192,12 @@ public class GoodsWrapper {
         @ApiModelProperty("商城商品名称")
         private String mallGoodsName;
 
-        @ApiModelProperty("sku编号")
+        @ApiModelProperty("skuID")
         private Integer sku;
 
+        @ApiModelProperty("sku编号")
+        private String skuCode;
+
         @ApiModelProperty("销售价格")
         private BigDecimal price;
 

mec-biz/src/main/java/com/ym/mec/biz/service/GoodsCategoryService.java

@@ -8,10 +8,8 @@ import com.ym.mec.common.page.PageInfo;
 import com.ym.mec.common.service.BaseService;
 
 import java.util.List;
-import java.util.Map;
 
-//public interface GoodsCategoryService extends BaseService<Integer, GoodsCategory> {
-public interface GoodsCategoryService{
+public interface GoodsCategoryService extends BaseService<Integer, GoodsCategory> {
     /**
      * 新增、修改商品类型
      * @param goodsCategory
@@ -31,10 +29,4 @@ public interface GoodsCategoryService{
      * @param goodsIds
      */
     void updateSubjectGoods(Long subjectGoodsMapperId, String goodsIds);
-
-    GoodsCategory get(Integer goodsCategoryId);
-
-    List<GoodsCategory> queryPage(GoodsCategoryQueryInfo queryInfo);
-
-    Map<Integer,String> getNameMap();
 }

mec-biz/src/main/java/com/ym/mec/biz/service/GoodsService.java

@@ -69,8 +69,6 @@ public interface GoodsService extends BaseService<Integer, Goods> {
      */
     List<Goods> findTypeGoods(String type, Integer tenantId);
 
-    PageInfo<Goods> queryPage(GoodsQueryInfo queryInfo);
-
     /**
      * @describe 商品导入
      * @apiNote 时光荏苒，认真工作的时间总是过得很快，而我、享受这一刻！

mec-biz/src/main/java/com/ym/mec/biz/service/impl/GoodsCategoryServiceImpl.java

@@ -1,64 +1,53 @@
 package com.ym.mec.biz.service.impl;
 
-import com.alibaba.fastjson.JSON;
-import com.ym.mec.biz.dal.dao.SubjectDao;
+import com.ym.mec.biz.dal.dao.GoodsCategoryDao;
 import com.ym.mec.biz.dal.dao.SubjectGoodsMapperDao;
 import com.ym.mec.biz.dal.dto.SubjectGoodsDto;
+import com.ym.mec.biz.dal.entity.Goods;
 import com.ym.mec.biz.dal.entity.GoodsCategory;
-import com.ym.mec.biz.dal.entity.Subject;
 import com.ym.mec.biz.dal.entity.SubjectGoodsMapper;
+import com.ym.mec.biz.dal.enums.AccountType;
 import com.ym.mec.biz.dal.enums.GoodsType;
 import com.ym.mec.biz.dal.page.GoodsCategoryQueryInfo;
 import com.ym.mec.biz.service.GoodsCategoryService;
-import com.ym.mec.common.dto.ProductCategoryDto;
+import com.ym.mec.biz.service.GoodsService;
+import com.ym.mec.common.dal.BaseDAO;
 import com.ym.mec.common.page.PageInfo;
-import com.ym.mec.mall.MallFeignService;
+import com.ym.mec.common.service.impl.BaseServiceImpl;
 import com.ym.mec.util.collection.MapUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.util.CollectionUtils;
-import org.springframework.util.StringUtils;
 
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.function.Function;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Service
-//public class GoodsCategoryServiceImpl extends BaseServiceImpl<Integer, GoodsCategory>  implements GoodsCategoryService {
-public class GoodsCategoryServiceImpl implements GoodsCategoryService {
-
-//	@Autowired
-//	private GoodsCategoryDao goodsCategoryDao;
+public class GoodsCategoryServiceImpl extends BaseServiceImpl<Integer, GoodsCategory>  implements GoodsCategoryService {
+	
 	@Autowired
-	private SubjectGoodsMapperDao subjectGoodsMapperDao;
-
+	private GoodsCategoryDao goodsCategoryDao;
 	@Autowired
-	private MallFeignService mallFeignService;
-
-	@Autowired
-	private SubjectDao subjectDao;
+	private SubjectGoodsMapperDao subjectGoodsMapperDao;
 
+	@Override
+	public BaseDAO<Integer, GoodsCategory> getDAO() {
+		return goodsCategoryDao;
+	}
 
 	@Override
 	@Transactional(rollbackFor = Exception.class)
 	public void upsetGoodsCategory(GoodsCategory goodsCategory) {
-//		goodsCategory.setParentId(0);
+		goodsCategory.setParentId(0);
 		if(goodsCategory.getId() != null){
-//			goodsCategory.setUpdateTime(new Date());
-//			goodsCategoryDao.update(goodsCategory);
+			goodsCategory.setUpdateTime(new Date());
+			goodsCategoryDao.update(goodsCategory);
 			//删除关联
 			subjectGoodsMapperDao.delByGoodsCategoryId(goodsCategory.getId());
+		}else {
+			goodsCategoryDao.insert(goodsCategory);
 		}
-//		else {
-//			goodsCategoryDao.insert(goodsCategory);
-//		}
 		List<Integer> subjectIds = goodsCategory.getSubjectIds();
 		subjectGoodsMapperDao.batchAdd(goodsCategory.getId(),subjectIds, goodsCategory.getTenantId());
 	}
@@ -75,9 +64,7 @@ public class GoodsCategoryServiceImpl implements GoodsCategoryService {
 			pageInfo.setTotal(count);
 			params.put("offset", pageInfo.getOffset());
 			dataList = subjectGoodsMapperDao.querySubjectGoods(params);
-			Map<Integer, String> nameMap = getNameMap();
 			dataList.forEach(e->{
-				e.setGoodsCategoryName(nameMap.getOrDefault(e.getGoodsCategoryId(),""));
 				e.setInstrument(e.getGoodsList().stream().filter(goods -> goods.getType() == GoodsType.INSTRUMENT).collect(Collectors.toList()));
 				e.setAccessories(e.getGoodsList().stream().filter(goods -> goods.getType() == GoodsType.ACCESSORIES).collect(Collectors.toList()));
 				e.setGoodsList(null);
@@ -98,70 +85,4 @@ public class GoodsCategoryServiceImpl implements GoodsCategoryService {
 		subjectGoodsMapper.setUpdateTime(new Date());
 		subjectGoodsMapperDao.update(subjectGoodsMapper);
 	}
-
-	@Override
-	public GoodsCategory get(Integer goodsCategoryId) {
-		mallFeignService.listWithChildren();
-		List<ProductCategoryDto> productCategoryDtos = treeToList(mallFeignService.listWithChildren());
-		Optional<ProductCategoryDto> first = productCategoryDtos.stream().filter(next -> next.getId().equals(Long.valueOf(goodsCategoryId))).findFirst();
-		if(first.isPresent()){
-			ProductCategoryDto productCategoryDto = first.get();
-			GoodsCategory goodsCategory = new GoodsCategory();
-			goodsCategory.setId(goodsCategoryId);
-			goodsCategory.setName(productCategoryDto.getName());
-			return goodsCategory;
-		}
-		return null;
-	}
-
-	@Override
-	public List<GoodsCategory> queryPage(GoodsCategoryQueryInfo queryInfo) {
-		List<ProductCategoryDto> productCategoryDtos = treeToList(mallFeignService.listWithChildren());
-		List<ProductCategoryDto> childrens = productCategoryDtos.stream().map(ProductCategoryDto::getChildren).flatMap(Collection::stream).collect(Collectors.toList());
-		List<GoodsCategory> goodsCategories = JSON.parseArray(JSON.toJSONString(childrens), GoodsCategory.class);
-
-		List<Integer> categoryIdList = goodsCategories.stream().map(GoodsCategory::getId).distinct().collect(Collectors.toList());
-		if (!categoryIdList.isEmpty()) {
-			List<SubjectGoodsMapper> mappers = subjectGoodsMapperDao.queryByCategoryIds(categoryIdList);
-
-			List<Integer> subjectIdList = mappers.stream().filter(next -> !StringUtils.isEmpty(next.getSubjectId()))
-					.map(next -> Integer.valueOf(next.getSubjectId())).distinct().collect(Collectors.toList());
-			Map<Integer, Subject> subjectIfdNameMap = subjectDao.findBySubjectIds(subjectIdList).stream().collect(Collectors.toMap(Subject::getId, Function.identity()));
-
-			Map<Integer, List<SubjectGoodsMapper>> groupByCategoryId = mappers.stream().collect(Collectors.groupingBy(SubjectGoodsMapper::getGoodsCategoryId));
-
-			goodsCategories.forEach(next -> {
-				List<SubjectGoodsMapper> goodsMappers = groupByCategoryId.getOrDefault(next.getId(), new ArrayList<>());
-				if (!goodsMappers.isEmpty()) {
-					List<Subject> subjectList =
-							goodsMappers.stream().filter(o -> subjectIfdNameMap.containsKey(Integer.valueOf(o.getSubjectId()))).map(o -> subjectIfdNameMap.get(Integer.valueOf(o.getSubjectId()))).collect(Collectors.toList());
-					next.setSubjects(subjectList);
-				}
-			});
-		}
-		return goodsCategories;
-	}
-
-	@Override
-	public Map<Integer, String> getNameMap() {
-		return treeToList(mallFeignService.listWithChildren()).stream()
-				.collect(Collectors.toMap(next->next.getId().intValue(), ProductCategoryDto::getName));
-	}
-
-	public List<ProductCategoryDto> treeToList(List<ProductCategoryDto> categoryList) {
-		if (categoryList.isEmpty()) {
-			return new ArrayList<>();
-		}
-		List<ProductCategoryDto> result = new ArrayList<>();
-		categoryList.forEach(next -> {
-			result.add(next);
-			String name = next.getName();
-			List<ProductCategoryDto> children = next.getChildren();
-			if (!CollectionUtils.isEmpty(children)) {
-				children.forEach(c -> c.setName(name + "/" + c.getName()));
-				result.addAll(children);
-			}
-		});
-		return result;
-	}
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/GoodsServiceImpl.java

@@ -14,6 +14,7 @@ import com.ym.mec.biz.dal.dao.TeacherDao;
 import com.ym.mec.biz.dal.dto.BasicUserDto;
 import com.ym.mec.biz.dal.dto.GoodsSellDto;
 import com.ym.mec.biz.dal.entity.Goods;
+import com.ym.mec.biz.dal.entity.GoodsCategory;
 import com.ym.mec.biz.dal.entity.GoodsProcurement;
 import com.ym.mec.biz.dal.entity.GoodsSub;
 import com.ym.mec.biz.dal.entity.Organization;
@@ -47,6 +48,7 @@ import com.ym.mec.common.entity.GoodsSubStockModel;
 import com.ym.mec.common.entity.UploadReturnBean;
 import com.ym.mec.common.exception.BizException;
 import com.ym.mec.common.page.PageInfo;
+import com.ym.mec.common.page.QueryInfo;
 import com.ym.mec.common.service.IdGeneratorService;
 import com.ym.mec.common.service.impl.BaseServiceImpl;
 import com.ym.mec.common.tenant.TenantContextHolder;
@@ -128,13 +130,9 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 		if (CollectionUtils.isEmpty(rows)) {
 			throw new BizException("没有查询到商品信息");
 		}
-		List<ProductCategoryDto> productCategoryDtos = treeToList(queryGoodsCategoryList());
-		Map<Long, String> IdNamemap = productCategoryDtos.stream().collect(Collectors.toMap(ProductCategoryDto::getId, ProductCategoryDto::getName));
-
 		List<Organization> all = organizationDao.findAll(params);
 		Map<Integer, String> organizationMap = all.stream().collect(Collectors.toMap(Organization::getId, Organization::getName));
 		for (Goods goods : rows) {
-			goods.setGoodsCategoryName(IdNamemap.getOrDefault(Long.valueOf(goods.getGoodsCategoryId()),""));
 			if(StringUtils.isNotEmpty(goods.getStudentShowOrganId())){
 				String[] split = goods.getStudentShowOrganId().split(",");
 				StringBuffer sb = new StringBuffer();
@@ -349,6 +347,7 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 			PmsProductDto dto = map.get(next.getSku());
 			if (dto != null) {
 				next.setPrice(dto.getPrice());
+				next.setSkuCode(dto.getSkuCode());
 				if (1 == dto.getDeleteStatus()) {
 					next.setGoodsStatus(false);
 				} else {
@@ -384,29 +383,14 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 	}
 
 	@Override
-	public PageInfo<Goods> queryPage(GoodsQueryInfo queryInfo) {
-		Integer goodsCategoryId = queryInfo.getGoodsCategoryId();
-		if (goodsCategoryId != null) {
-			Map<Long, ProductCategoryDto> idCategoryMap = mallFeignService.listWithChildren().stream().collect(Collectors.toMap(ProductCategoryDto::getId, Function.identity()));
-			if (idCategoryMap.containsKey(Long.valueOf(goodsCategoryId))) {
-				ProductCategoryDto productCategoryDto = idCategoryMap.get(Long.valueOf(goodsCategoryId));
-				List<String> categoryIdList = productCategoryDto.getChildren().stream().map(ProductCategoryDto::getId).map(String::valueOf).distinct().collect(Collectors.toList());
-				categoryIdList.add(goodsCategoryId.toString());
-				queryInfo.setGoodsCategoryIds(String.join(",", categoryIdList));
-				queryInfo.setGoodsCategoryId(null);
-			}
-		}
+	public PageInfo<Goods> queryPage(QueryInfo queryInfo) {
 		PageInfo<Goods> page = super.queryPage(queryInfo);
 
 		List<Goods> rows = page.getRows();
 		if (!rows.isEmpty()) {
 			Map<String, String> brandIdNameMap = this.queryGoodsBrandList().stream().collect(Collectors.toMap(next -> next.getId().toString(), BrandDto::getName));
-			List<ProductCategoryDto> productCategoryDtos = treeToList(this.queryGoodsCategoryList());
-			Map<Integer, String> categoryIdNameMap = productCategoryDtos.stream().collect(Collectors.toMap(next -> next.getId().intValue(), ProductCategoryDto::getName));
-
 			for (Goods row : rows) {
 				row.setBrandName(brandIdNameMap.getOrDefault(row.getBrand(), row.getBrand()));
-				row.setGoodsCategoryName(categoryIdNameMap.getOrDefault(row.getGoodsCategoryId(), ""));
 			}
 		}
 		return page;
@@ -629,10 +613,10 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 		goodsCategoryQueryInfo.setPage(1);
 		goodsCategoryQueryInfo.setRows(9999);
 
-		List<ProductCategoryDto> categoryList = mallFeignService.listWithChildren();
-		List<ProductCategoryDto> allCategoryList = categoryList.stream().map(ProductCategoryDto::getChildren).filter(next->!next.isEmpty()).flatMap(Collection::stream).collect(Collectors.toList());
-		Map<String, Long> categoryIdNameMap = allCategoryList
-				.stream().collect(Collectors.toMap(ProductCategoryDto::getName, ProductCategoryDto::getId));
+
+		List<GoodsCategory> categoryList = goodsCategoryService.findAll(new HashMap<>()).stream().filter(next -> YesOrNoEnum.NO.equals(next.getDelFlag())).collect(Collectors.toList());
+		Map<String, Integer> categoryIdNameMap = categoryList
+				.stream().collect(Collectors.toMap(GoodsCategory::getName, GoodsCategory::getId));
 		Set<String> categoryNames = categoryIdNameMap.keySet();
 
 		// 查询员工机构
@@ -668,8 +652,13 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 			}
 		});
 
-		List<String> snSet = firstSheet.stream().map(next -> next.get("组合商品货号").toString()).filter(StringUtils::isNotEmpty).distinct().collect(Collectors.toList());
-		List<String> existSnList = goodsDao.findBySns(snSet).stream().map(Goods::getSn).distinct().collect(Collectors.toList());
+		// excel中所有的sn
+		List<String> snSet = firstSheet.stream().map(next -> next.get("组合商品货号").toString()).filter(StringUtils::isNotEmpty).collect(Collectors.toList());
+		// 获取重复的货号
+		List<String> repeatSnList = snSet.stream().collect(Collectors.groupingBy(e -> e, Collectors.counting()))
+				.entrySet().stream().filter(e -> e.getValue() > 1)
+				.map(Map.Entry::getKey).collect(Collectors.toList());
+		List<String> existSnList = goodsDao.findBySns(snSet.stream().distinct().collect(Collectors.toList())).stream().map(Goods::getSn).distinct().collect(Collectors.toList());
 
 		Map<String, Long> brandNameIdMap = mallFeignService.getList().stream().collect(Collectors.toMap(BrandDto::getName, BrandDto::getId));
 
@@ -690,8 +679,7 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 
 			String lineErrMsg = "错误行号:第%s行,%s";
 			Map<String, String> beforeGoods = new HashMap<>();
-
-			Map<String, String> snNameMap = new HashMap<>();
+			Map<String, Set<String>> snSubGoodsMap = new HashMap<>();
 			for (int i = 0; i < rows.size(); i++) {
 				JSONObject objectMap = new JSONObject();
 				int rowNum = i + 2;
@@ -699,6 +687,11 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 				if (row.size() == 0) {
 					continue;
 				}
+				// 新商品标志
+				String sn = row.get("组合商品货号").toString();
+				if (StringUtils.isNotEmpty(sn)) {
+					beforeGoods.clear();
+				}
 				String subGoodsName = null;
 				String subGoodsSku = null;
 				List<String> lineErrList = new ArrayList<>();
@@ -731,21 +724,16 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 					} else {
 						beforeGoods.put(fieldCode, value);
 					}
-					if("sn".equals(fieldCode)){
+					if ("sn".equals(fieldCode)) {
 						if (existSnList.contains(value)) {
 							lineErrList.add("货号[" + value + "]已存在");
 						} else {
-							String goodsName = row.get("组合商品名称").toString();
-							if (snNameMap.containsKey(value) && !snNameMap.get(value).equals(goodsName)) {
+							if (repeatSnList.contains(value)) {
 								lineErrList.add("货号[" + value + "]重复");
-							} else {
-								snNameMap.put(value, goodsName);
 							}
-							objectMap.put(fieldCode, value);
 						}
-					}
-					else
-					if ("marketPrice".equals(fieldCode)
+						objectMap.put(fieldCode, value);
+					} else if ("marketPrice".equals(fieldCode)
 							|| "discountPrice".equals(fieldCode)
 							|| "groupPurchasePrice".equals(fieldCode)) {
 						if (NumberUtils.isNumber(value)) {
@@ -842,8 +830,21 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 						!objectMap.containsKey("memberFeeShowOrganId") &&
 						!objectMap.containsKey("freeFeeShowOrganId") &&
 						!objectMap.containsKey("replacementShowOrganId")) {
-					lineErrList.add("可售分部至少需要选择一个");
+					lineErrList.add("可售分部至少需要填写一个");
 				}
+				// 校验子商品sku是否重复
+				String tempSn = objectMap.get("sn").toString();
+				String tempSku = objectMap.get("sku").toString();
+				if (StringUtils.isNotEmpty(tempSn) && StringUtils.isNotEmpty(tempSku)) {
+					Set<String> set = snSubGoodsMap.getOrDefault(tempSn, new HashSet<>());
+					if (set.contains(tempSku)) {
+						lineErrList.add("子商品SKU重复");
+					} else {
+						set.add(tempSku);
+						snSubGoodsMap.put(tempSn, set);
+					}
+				}
+
 				if (!lineErrList.isEmpty()) {
 					errList.add(String.format(lineErrMsg, rowNum, String.join(",", lineErrList)));
 				}
@@ -863,6 +864,7 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 		List<GoodsWrapper.Goods> goodsList = jsonObjectList.stream().map(next -> {
 			String jsonString = next.toJSONString();
 			GoodsWrapper.Goods goods = JSON.parseObject(jsonString, GoodsWrapper.Goods.class);
+			goods.setSellCount(0);
 			GoodsWrapper.GoodsSub goodsSub = JSON.parseObject(jsonString, GoodsWrapper.GoodsSub.class);
 			ArrayList<GoodsWrapper.GoodsSub> arrayList = new ArrayList<>();
 			arrayList.add(goodsSub);
@@ -1173,10 +1175,6 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 		}
 		GoodsWrapper.Goods detail = JSON.parseObject(JSON.toJSONString(goods), GoodsWrapper.Goods.class);
 		detail.setGoodsSubList(queryGoodsSubByGoodId(goodsId));
-
-		List<ProductCategoryDto> productCategoryDtos = treeToList(queryGoodsCategoryList());
-		Map<Long, String> IdNamemap = productCategoryDtos.stream().collect(Collectors.toMap(ProductCategoryDto::getId, ProductCategoryDto::getName));
-		detail.setGoodsCategoryName(IdNamemap.getOrDefault(Long.valueOf(detail.getGoodsCategoryId()), ""));
 		return detail;
 	}
 
@@ -1404,21 +1402,4 @@ public class GoodsServiceImpl extends BaseServiceImpl<Integer, Goods>  implement
 		}
 		return "";
 	}
-
-	public List<ProductCategoryDto> treeToList(List<ProductCategoryDto> categoryList) {
-		if (categoryList.isEmpty()) {
-			return new ArrayList<>();
-		}
-		List<ProductCategoryDto> result = new ArrayList<>();
-		categoryList.forEach(next -> {
-			result.add(next);
-			String name = next.getName();
-			List<ProductCategoryDto> children = next.getChildren();
-			if (!CollectionUtils.isEmpty(children)) {
-				children.forEach(c -> c.setName(name + "/" + c.getName()));
-				result.addAll(children);
-			}
-		});
-		return result;
-	}
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/StudentGoodsSellServiceImpl.java

@@ -14,11 +14,9 @@ import com.ym.mec.biz.service.SysConfigService;
 import com.ym.mec.biz.service.SysTenantConfigService;
 import com.ym.mec.biz.service.TenantInfoService;
 import com.ym.mec.common.dal.BaseDAO;
-import com.ym.mec.common.dto.ProductCategoryDto;
 import com.ym.mec.common.page.PageInfo;
 import com.ym.mec.common.service.impl.BaseServiceImpl;
 import com.ym.mec.common.tenant.TenantContextHolder;
-import com.ym.mec.mall.MallFeignService;
 import com.ym.mec.util.collection.MapUtil;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -46,8 +44,6 @@ public class StudentGoodsSellServiceImpl extends BaseServiceImpl<Integer, Studen
     private StudentInstrumentDao studentInstrumentDao;
     @Autowired
     private SysCouponCodeDao sysCouponCodeDao;
-    @Autowired
-    private MallFeignService mallFeignService;
 
     @Override
     public BaseDAO<Integer, StudentGoodsSell> getDAO() {
@@ -150,8 +146,6 @@ public class StudentGoodsSellServiceImpl extends BaseServiceImpl<Integer, Studen
             return null;
         }
         List<Goods> goodies = goodsDao.getGoodiesAndCate(goodsIds);
-        List<ProductCategoryDto> productCategoryDtos = treeToList(mallFeignService.listWithChildren());
-        Map<Long, String> categoryIdNameMap = productCategoryDtos.stream().collect(Collectors.toMap(next -> next.getId(), next -> next.getName()));
         List<StudentInstrument> studentInstruments = new ArrayList<>();
         for (Goods goods : goodies) {
             StudentInstrument studentInstrument = new StudentInstrument();
@@ -159,7 +153,7 @@ public class StudentGoodsSellServiceImpl extends BaseServiceImpl<Integer, Studen
             studentInstrument.setOrganId(studentGoodsSell.getOrganId());
             studentInstrument.setGoodsId(goods.getId());
             studentInstrument.setGoodsCategoryId(goods.getGoodsCategoryId());
-            studentInstrument.setGoodsCategoryName(categoryIdNameMap.getOrDefault(Long.valueOf(goods.getGoodsCategoryId()),""));
+            studentInstrument.setGoodsCategoryName(goods.getGoodsCategoryName());
             studentInstrument.setGoodsName(goods.getName());
             studentInstrument.setGoodsBrand(goods.getBrand());
             studentInstrument.setSpecification(goods.getSpecification());
@@ -184,21 +178,4 @@ public class StudentGoodsSellServiceImpl extends BaseServiceImpl<Integer, Studen
         }
         return studentGoodsSell;
     }
-
-    public List<ProductCategoryDto> treeToList(List<ProductCategoryDto> categoryList) {
-        if (categoryList.isEmpty()) {
-            return new ArrayList<>();
-        }
-        List<ProductCategoryDto> result = new ArrayList<>();
-        categoryList.forEach(next -> {
-            result.add(next);
-            String name = next.getName();
-            List<ProductCategoryDto> children = next.getChildren();
-            if (!org.springframework.util.CollectionUtils.isEmpty(children)) {
-                children.forEach(c -> c.setName(name + "/" + c.getName()));
-                result.addAll(children);
-            }
-        });
-        return result;
-    }
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/StudentInstrumentServiceImpl.java

@@ -5,11 +5,9 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 import java.util.Optional;
 import java.util.stream.Collectors;
 
-import com.ym.mec.mall.MallFeignService;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -449,9 +447,7 @@ public class StudentInstrumentServiceImpl extends BaseServiceImpl<Long, StudentI
         List<Goods> goodies = goodsDao.getGoodsByBaseGoodsId(76);
         List<Integer> goodsIds = goodies.stream().map(Goods::getId).collect(Collectors.toList());
         List<StudentInstrument> oldStudentInstruments = studentInstrumentDao.getOldStudentInstrument(startTime, goodsIds);
-        Map<Integer, String> nameMap = goodsCategoryService.getNameMap();
         for (StudentInstrument oldStudentInstrument : oldStudentInstruments) {
-            oldStudentInstrument.setGoodsCategoryName(nameMap.getOrDefault(oldStudentInstrument.getGoodsCategoryId(),""));
             oldStudentInstrument.setChangeOrderId(oldStudentInstrument.getOrderId());
             if (oldStudentInstrument.getEndTime().compareTo(nowDate) > 0) {
                 oldStudentInstrument.setStatus(1);

mec-biz/src/main/resources/config/mybatis/GoodsCategoryMapper.xml

@@ -24,7 +24,7 @@
 
     <!-- 根据主键查询一条记录 -->
     <select id="get" resultMap="GoodsCategory">
-		SELECT * FROM goods_category WHERE id_ = #{id}
+		SELECT * FROM goods_category WHERE id_ = #{id} 
 	</select>
 
     <!-- 全查询 -->

mec-biz/src/main/resources/config/mybatis/GoodsMapper.xml

@@ -54,6 +54,7 @@
         <result column="child_name_" property="childName"/>
         <result column="child_sn_" property="childSn"/>
         <result column="child_organ_cost_price_" property="childOrganCostPrice"/>
+        <result column="group_goods_" property="groupGoods"/>
     </resultMap>
 
     <!-- 根据主键查询一条记录 -->
@@ -79,14 +80,14 @@
          discount_price_,group_purchase_price_,brief_,desc_,is_new_,is_top_,status_,memo_,publish_time_,
          complement_goods_id_list_,update_time_,create_time_,type_,agree_cost_price_,stock_warning_,stock_type_
             ,student_show_organ_id_,education_show_organ_id_,replacement_show_organ_id_,course_fee_show_organ_id_,
-         member_fee_show_organ_id_,free_fee_show_organ_id_,tenant_id_,organ_cost_price_)
+         member_fee_show_organ_id_,free_fee_show_organ_id_,tenant_id_,organ_cost_price_,group_goods_)
         VALUES(#{goodsCategoryId},#{sn},#{name},#{brand},#{specification},#{image},#{stockCount},#{taxStockCount},#{sellCount},#{marketPrice},
                #{discountPrice},#{groupPurchasePrice},#{brief},#{desc},
                #{isNew,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},#{isTop,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},#{status,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},
                #{memo},#{publishTime},#{complementGoodsIdList},now(),now(),#{type,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},#{agreeCostPrice},
                #{stockWarning,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler}, #{stockType,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},
                #{studentShowOrganId},#{educationShowOrganId},#{replacementShowOrganId},#{courseFeeShowOrganId},
-               #{memberFeeShowOrganId},#{freeFeeShowOrganId},#{tenantId},#{organCostPrice})
+               #{memberFeeShowOrganId},#{freeFeeShowOrganId},#{tenantId},#{organCostPrice},#{groupGoods})
     </insert>
     <insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
         INSERT INTO goods
@@ -94,7 +95,7 @@
         discount_price_,group_purchase_price_,brief_,desc_,update_time_,create_time_,type_,agree_cost_price_,sn_,
         stock_count_,tax_stock_count_,stock_warning_,stock_type_
         ,student_show_organ_id_,education_show_organ_id_,replacement_show_organ_id_,course_fee_show_organ_id_,
-        member_fee_show_organ_id_,free_fee_show_organ_id_,tenant_id_,organ_cost_price_)
+        member_fee_show_organ_id_,free_fee_show_organ_id_,tenant_id_,organ_cost_price_,group_goods_)
         VALUES
         <foreach collection="list" separator="," item="goods">
             (#{goods.goodsCategoryId},#{goods.name},#{goods.brand},#{goods.specification},#{goods.image},#{goods.marketPrice},
@@ -104,7 +105,7 @@
             #{goods.stockWarning,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},
             #{goods.stockType,typeHandler=com.ym.mec.common.dal.CustomEnumTypeHandler},
             #{goods.studentShowOrganId},#{goods.educationShowOrganId},#{goods.replacementShowOrganId},
-            #{goods.courseFeeShowOrganId},#{goods.memberFeeShowOrganId},#{goods.freeFeeShowOrganId},#{goods.tenantId},#{goods.organCostPrice}
+            #{goods.courseFeeShowOrganId},#{goods.memberFeeShowOrganId},#{goods.freeFeeShowOrganId},#{goods.tenantId},#{goods.organCostPrice},#{goods.groupGoods}
             )
         </foreach>
     </insert>
@@ -308,9 +309,8 @@
 
     <!-- 分页查询 -->
     <select id="queryPage" resultMap="Goods" parameterType="map">
-        SELECT g.* FROM goods g
-<!--        SELECT g.*,gc.name_ goods_category_name_ FROM goods g-->
-<!--        LEFT JOIN goods_category gc ON g.goods_category_id_ = gc.id_-->
+        SELECT g.*,gc.name_ goods_category_name_ FROM goods g
+        LEFT JOIN goods_category gc ON g.goods_category_id_ = gc.id_
         <include refid="queryGoodsPageSql"/>
         GROUP BY g.id_
         ORDER BY g.id_ DESC
@@ -384,6 +384,9 @@
             <if test="search!=null and search!=''">
                 AND (g.sn_=#{search} OR g.id_=#{search} OR g.name_ LIKE CONCAT('%', #{search}, '%'))
             </if>
+            <if test="groupGoods != null">
+                AND t.group_goods_ = #{groupGoods}
+            </if>
         </where>
     </sql>
 
@@ -521,14 +524,14 @@
     </select>
 
     <select id="getGoodsInfo" resultMap="Goods">
-        SELECT g.* FROM goods g
-<!----><!--                                                          LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_-->
+        SELECT g.*,gc.name_ goods_category_name_ FROM goods g
+                                                          LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_
         WHERE g.id_=#{id}
     </select>
 
     <select id="getGoodiesAndCate" resultMap="Goods">
-        SELECT g.* FROM goods g
-<!--        LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_-->
+        SELECT g.*,gc.name_ goods_category_name_ FROM goods g
+        LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_
         WHERE g.id_ IN
         <foreach collection="goodsIds" item="goodsId" open="(" close=")" separator=",">
             #{goodsId}
@@ -545,7 +548,7 @@
         SELECT g.id_,g.brand_,g.specification_,g.brief_ param_,g.market_price_,g.discount_price_,g.group_purchase_price_ sale_price_,
         (g.discount_price_-g.group_purchase_price_) depreciation_price_
         FROM subject_goods_mapper sgm
-<!--        LEFT JOIN goods_category gc ON gc.id_=sgm.goods_category_id_-->
+        LEFT JOIN goods_category gc ON gc.id_=sgm.goods_category_id_
         LEFT JOIN goods g ON sgm.goods_category_id_ = g.goods_category_id_
         <include refid="replacementQuerySql"/>
         <include refid="global.limit"/>
@@ -554,7 +557,7 @@
     <select id="getReplacementInstrumentCount" resultType="int">
         SELECT COUNT(*)
         FROM subject_goods_mapper sgm
-<!--        LEFT JOIN goods_category gc ON gc.id_=sgm.goods_category_id_-->
+        LEFT JOIN goods_category gc ON gc.id_=sgm.goods_category_id_
         LEFT JOIN goods g ON sgm.goods_category_id_ = g.goods_category_id_
         <include refid="replacementQuerySql"/>
         <include refid="global.limit"/>
@@ -563,10 +566,10 @@
         select SUM(organ_cost_price_) from goods where FIND_IN_SET(id_,#{complementGoodsIdList});
     </select>
     <select id="exportGoods" resultMap="Goods">
-        SELECT g.*,
+        SELECT g.*,gc.name_ goods_category_name_,
         GROUP_CONCAT(gs.name_) child_name_,GROUP_CONCAT(gs.sn_) child_sn_,
         GROUP_CONCAT(gs.id_) child_id_,GROUP_CONCAT(gs.organ_cost_price_) child_organ_cost_price_ FROM goods g
-<!--        LEFT JOIN goods_category gc ON g.goods_category_id_ = gc.id_-->
+        LEFT JOIN goods_category gc ON g.goods_category_id_ = gc.id_
         left join goods gs ON FIND_IN_SET(gs.id_,g.complement_goods_id_list_)
         <include refid="queryGoodsPageSql"/>
         GROUP BY g.id_
@@ -577,7 +580,7 @@
         <where>
             g.status_ != 0
             AND g.type_ = 'INSTRUMENT'
-<!--            AND gc.del_flag_ = 0 and g.tenant_id_ = #{tenantId}-->
+            AND gc.del_flag_ = 0 and g.tenant_id_ = #{tenantId}
             <if test="organId != null">
                 AND FIND_IN_SET(#{organId},g.replacement_show_organ_id_)
             </if>

mec-biz/src/main/resources/config/mybatis/StudentInstrumentMapper.xml

@@ -266,7 +266,7 @@
         spo.organ_id_,
         g.id_ goods_id_,
         g.goods_category_id_,
-<!--        gc.name_ goods_category_name_,-->
+        gc.name_ goods_category_name_,
         g.name_ goods_name_,
         g.brand_ goods_brand_,
         g.specification_,
@@ -278,7 +278,7 @@
         LEFT JOIN student_payment_order spo ON spo.id_ = spod.payment_order_id_
         LEFT JOIN student_payment_order_detail spod2 ON spod2.payment_order_id_ = spo.id_
         LEFT JOIN goods g ON g.id_ = spod2.goods_id_list_
-<!--        LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_-->
+        LEFT JOIN goods_category gc on g.goods_category_id_ = gc.id_
         WHERE spo.status_ = 'SUCCESS'
         AND spod2.type_ = 'MUSICAL'
         AND (

mec-biz/src/main/resources/config/mybatis/SubjectGoodsMapperMapper.xml

@@ -89,12 +89,11 @@
     </select>
     <select id="querySubjectGoods" resultMap="querySubjectGoodsMap">
         SELECT sgc.*,g.type_ goods_type_,g.name_ goods_name_,g.id_ goods_id_ FROM
-        (SELECT s.name_ subject_name_,s.id_ subject_id_,sgm.goods_category_id_ goods_category_id_,
+        (SELECT s.name_ subject_name_,s.id_ subject_id_,gc.id_ goods_category_id_,gc.name_ goods_category_name_,
         sgm.goods_id_list_,sgm.id_ subject_goods_mapper_id_
         FROM subject_goods_mapper sgm
         LEFT JOIN `subject` s ON s.id_ = sgm.subject_id_
-<!--        LEFT JOIN goods_category gc ON gc.id_ = sgm.goods_category_id_ -->
-        <include refid="global.limit"/>) sgc
+        LEFT JOIN goods_category gc ON gc.id_ = sgm.goods_category_id_ <include refid="global.limit"/>) sgc
         LEFT JOIN goods g ON FIND_IN_SET(g.id_,sgc.goods_id_list_)
         where g.tenant_id_ = #{tenantId}
     </select>
@@ -110,12 +109,4 @@
             <result property="type" column="goods_type_"/>
         </collection>
     </resultMap>
-
-    <select id="queryByCategoryIds" resultMap="SubjectGoodsMapper">
-        select t.* from subject_goods_mapper t
-        where t.goods_category_id_ in
-        <foreach collection="categoryIdList" item="item" separator="," open="(" close=")">
-            #{item}
-        </foreach>
-    </select>
 </mapper>