分类开发

hx-service-api/victoriatourist-api/src/main/java/com/fjhx/enums/material/MaterialTypeEnum.java

@@ -0,0 +1,84 @@
+package com.fjhx.enums.material;
+
+import org.springblade.core.tool.utils.Func;
+import org.springblade.core.tool.utils.StringPool;
+
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 物料类型枚举
+ */
+public enum MaterialTypeEnum {
+    MATERIAL_TYPE_1(1, "原料"),
+    MATERIAL_TYPE_2(2, "辅料"),
+    MATERIAL_TYPE_3(3, "配件"),
+    MATERIAL_TYPE_99(99, "其他"),
+    ;
+
+    private int key;
+
+    private String value;
+
+    private static Map<Integer, String> map = new LinkedHashMap<>();
+
+    private static final HashMap<Integer, MaterialTypeEnum> classMap = new HashMap<>();
+
+    MaterialTypeEnum(int key, String value) {
+        this.key = key;
+        this.value = value;
+    }
+
+
+    static {
+        for (MaterialTypeEnum value : MaterialTypeEnum.values()) {
+            classMap.put(value.getKey(), value);
+        }
+    }
+
+    /**
+     * 根据type获取枚举
+     */
+    public static MaterialTypeEnum get(Integer type) {
+        return classMap.get(type);
+    }
+
+    /**
+     * 获取枚举map
+     *
+     * @return
+     */
+    public static Map<Integer, String> getMap() {
+        if (Func.isNotEmpty(map)) {
+            return map;
+        }
+        for (MaterialTypeEnum ms : values()) {
+            map.put(ms.key, ms.value);
+        }
+        return map;
+    }
+
+    /**
+     * 通过key获取名称
+     *
+     * @param key
+     * @return
+     */
+    public static String getNameByKey(Integer key) {
+        if (key == null || key < 0) {
+            return StringPool.EMPTY;
+        }
+        Map<Integer, String> map = getMap();
+        return map.getOrDefault(key, StringPool.EMPTY);
+    }
+
+    public int getKey() {
+        return key;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+}

hx-service/victoriatourist/src/main/java/com/fjhx/controller/material/MaterialController.java

@@ -52,5 +52,10 @@ public class MaterialController {
         return R.success();
     }
 
+    @PostMapping("/details")
+    public R details(@RequestBody MaterialVo materialVo){
+        return R.success(materialService.getById(materialVo.getId()));
+    }
+
 }
 

hx-service/victoriatourist/src/main/java/com/fjhx/service/material/impl/MaterialServiceImpl.java

@@ -1,15 +1,30 @@
 package com.fjhx.service.material.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fjhx.entity.classify.Classify;
 import com.fjhx.entity.material.Material;
-import com.fjhx.params.material.MaterialVo;
+import com.fjhx.entity.stock.Stock;
 import com.fjhx.mapper.material.MaterialMapper;
+import com.fjhx.params.material.MaterialVo;
+import com.fjhx.service.classify.ClassifyService;
 import com.fjhx.service.material.MaterialService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fjhx.service.stock.StockService;
+import com.fjhx.uitl.code.CodeEnum;
 import com.fjhx.utils.wrapperUtil.IWrapper;
+import org.springblade.core.log.exception.ServiceException;
+import org.springblade.core.redis.lock.RedisLockClient;
+import org.springblade.core.secure.utils.AuthUtil;
+import org.springblade.core.tool.utils.Func;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -22,17 +37,67 @@ import java.util.Map;
 @Service
 public class MaterialServiceImpl extends ServiceImpl<MaterialMapper, Material> implements MaterialService {
 
+    @Lazy
+    @Autowired
+    private ClassifyService classifyService;
+
+    @Autowired
+    private StockService stockService;
+
+    @Autowired
+    private RedisLockClient redisLockClient;
+
+    private final String REDIS_LOCK_CACHE_KEY = "seq:lock:" + AuthUtil.getTenantId() + ":material:";
+
     @Override
     public Page<Material> getPage(Map<String, Object> condition) {
 
         IWrapper<Material> wrapper = IWrapper.getWrapper(condition);
 
+        //处理分类
+        List<Long> classifyIds = new ArrayList<>();
+        if (Func.isNotEmpty(condition.get("classifyId"))) {
+            classifyIds.add(Convert.toLong(condition.get("classifyId")));
+            //查询所有子级
+            List<Classify> classifies = classifyService.lambdaQuery().apply("FIND_IN_SET(" + condition.get("classifyId") + ", parent_id_set)").list();
+            if (Func.isNotEmpty(classifies)) {
+                classifyIds.addAll(classifies.stream().map(Classify::getId).distinct().collect(Collectors.toList()));
+            }
+        }
+
+        wrapper.eq(Material::getType)
+                .in(Material::getClassifyId, classifyIds)
+                .apply(Func.isNotEmpty(condition.get("code")), "instr(`code`, '" + condition.get("code") + "') > 0")
+                .apply(Func.isNotEmpty(condition.get("name")), "instr(`name`, '" + condition.get("name") + "') > 0")
+                .and(Func.isNotEmpty(condition.get("keyword")), o -> o.apply("instr(`code`, '" + condition.get("keyword") + "') > 0").or().apply("instr(`name`, '" + condition.get("keyword") + "') > 0"));
+
         return page(condition, wrapper);
     }
 
     @Override
     public void add(MaterialVo materialVo) {
-        save(materialVo);
+        if (
+                !redisLockClient.lockFair(REDIS_LOCK_CACHE_KEY, () -> {
+                    //获取编码
+                    materialVo.setCode(CodeEnum.MATERIAL.getCode());
+                    //查询编码是否已存在
+                    if (!checkCodeIsExist(null, materialVo.getCode())) {
+                        throw new ServiceException("后台自增编码存在重复，请重试或联系管理员！编码：" + materialVo.getCode());
+                    }
+                    save(materialVo);
+                    return true;
+                })
+        ) {
+            throw new ServiceException("当前系统繁忙，请稍后重试！");
+        }
+    }
+
+    private Boolean checkCodeIsExist(Long id, String code) {
+        List<Material> list = lambdaQuery().ne(Func.isNotEmpty(id), Material::getId, id).eq(Material::getCode, code).list();
+        if (Func.isNotEmpty(list)) {
+            return false;
+        }
+        return true;
     }
 
     @Override
@@ -42,6 +107,11 @@ public class MaterialServiceImpl extends ServiceImpl<MaterialMapper, Material> i
 
     @Override
     public void delete(MaterialVo materialVo) {
+        //查询是否存在库存
+        List<Stock> stocks = stockService.lambdaQuery().eq(Stock::getGoodsId, materialVo.getId()).list();
+        if (Func.isNotEmpty(stocks)) {
+            throw new ServiceException("该物料还有库存，无法删除！");
+        }
         removeById(materialVo.getId());
     }