库房管理

sto/src/main/java/com/shinsoft/sto/controller/main/WareController.java

@@ -0,0 +1,94 @@
+package com.shinsoft.sto.controller.main;
+
+import com.shinsoft.tools.JSONTools;
+import com.shinsoft.tools.model.common.ResponseCodeMsg;
+import com.shinsoft.tools.model.common.ResultJSON;
+import com.shinsoft.sto.service.main.WareService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.Map;
+
+@RestController
+@RequestMapping("/Ware")
+public class WareController {
+
+    @Autowired
+    private WareService wareService;
+
+    ResultJSON resultJSON;
+
+    @RequestMapping(value = "/query")
+    public ResultJSON query(int page, int rows,
+                            @RequestParam(required = false) String wareNm,
+                            HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            Map<String, Object> map = new HashMap<>();
+            map.put("wareNm",wareNm);
+            resultJSON = wareService.query(page, rows, map);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/queryByPK")
+    public ResultJSON queryByPK(String id, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = wareService.queryByPK(id);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/save")
+    public ResultJSON save(String json, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = wareService.save(userId, json);
+        } catch (Exception ex) {
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+            ex.printStackTrace();
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/remove")
+    public ResultJSON remove(String id, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = wareService.remove(userId, id);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+
+    @RequestMapping(value = "/removeBatch")
+    public ResultJSON removeBatch(String ids, HttpServletRequest request) {
+        try {
+            String userId = (String) request.getHeader("userId");
+            resultJSON = wareService.removeBatch(userId, ids);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+            resultJSON = JSONTools.toResultJSON(ResponseCodeMsg.CODE_EX, ex);
+        } finally {
+            return resultJSON;
+        }
+    }
+}
+

sto/src/main/java/com/shinsoft/sto/mapper/main/WareMapper.java

@@ -0,0 +1,9 @@
+package com.shinsoft.sto.mapper.main;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.shinsoft.sto.model.main.Ware;
+
+public interface WareMapper extends BaseMapper<Ware> {
+
+}
+

sto/src/main/java/com/shinsoft/sto/model/main/Ware.java

@@ -0,0 +1,29 @@
+package com.shinsoft.sto.model.main;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.shinsoft.generator.model.BaseModel;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+
+@Getter
+@Setter
+@Accessors(chain = true)
+@TableName("T_MAIN_WARE")
+@ApiModel(value = "仓库", description = "仓库基本信息表")
+public class Ware extends BaseModel {
+
+    @ApiModelProperty("库房名称")
+    private String wareNm;
+    @ApiModelProperty("库房编码")
+    private String wareCode;
+    @ApiModelProperty("库房长度")
+    private String wareLength;
+    @ApiModelProperty("库房宽度")
+    private String wareWidth;
+
+}
+

sto/src/main/java/com/shinsoft/sto/service/impl/main/WareServiceImp.java

@@ -0,0 +1,117 @@
+package com.shinsoft.sto.service.impl.main;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.shinsoft.sto.mapper.main.WareMapper;
+import com.shinsoft.sto.model.main.Ware;
+import com.shinsoft.sto.service.main.WareService;
+import com.shinsoft.tools.JSONTools;
+import com.shinsoft.tools.model.common.ResultJSON;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ * 仓库 服务实现类
+ * </p>
+ *
+ * @author system
+ * @since 2024-10-15
+ */
+@Service
+public class WareServiceImp extends ServiceImpl<WareMapper, Ware> implements WareService {
+
+    ResultJSON resultJSON;
+
+    @Autowired
+    WareMapper wareMapper;
+
+    @Override
+    public ResultJSON query(int page, int rows,  Map<String, Object> map) {
+        Page<Ware> warePage = new Page<>(page, rows);
+        QueryWrapper<Ware> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("cancel_flag", "0");
+        queryWrapper.orderByDesc("add_time");
+        
+        // 解析查询参数
+        if (!ObjectUtils.isEmpty(map)) {
+            if (!ObjectUtils.isEmpty(map.get("wareNm"))) {
+                queryWrapper.like("ware_nm", map.get("wareNm"));
+            }
+            if (!ObjectUtils.isEmpty(map.get("wareCode"))) {
+                queryWrapper.like("ware_code", map.get("wareCode"));
+            }
+        }
+        
+        Page<Ware> list = wareMapper.selectPage(warePage, queryWrapper);
+        resultJSON = JSONTools.toResultJSON(list);
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON queryByPK(String id) {
+        Ware ware = wareMapper.selectById(id);
+        resultJSON = JSONTools.toResultJSON(ware);
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON save(String userId, String json) {
+        Date date = new Date();
+        Ware ware = JSON.parseObject(json, new TypeReference<Ware>() {
+        });
+        if (StringUtils.isEmpty(ware.getId())) {
+            ware.setCancelFlag("0");
+            ware.setAddId(userId);
+            ware.setAddTime(date);
+            wareMapper.insert(ware);
+        } else {
+            ware.setModifyId(userId);
+            ware.setModifyTime(date);
+            wareMapper.updateById(ware);
+        }
+
+        resultJSON = JSONTools.toResultJSON(ware);
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON remove(String userId, String id) {
+        Date date = new Date();
+        Ware ware = wareMapper.selectById(id);
+        ware.setCancelFlag("1");
+        ware.setModifyId(userId);
+        ware.setModifyTime(date);
+        wareMapper.updateById(ware);
+        resultJSON = JSONTools.toResultJSON("");
+        return resultJSON;
+    }
+
+    @Override
+    public ResultJSON removeBatch(String userId, String ids) {
+        Date date = new Date();
+        List<String> list = JSON.parseObject(ids, new TypeReference<List<String>>() {
+        });
+        Ware ware;
+        for (String id : list) {
+            ware = wareMapper.selectById(id);
+            ware.setCancelFlag("1");
+            ware.setModifyId(userId);
+            ware.setModifyTime(date);
+            wareMapper.updateById(ware);
+        }
+        resultJSON = JSONTools.toResultJSON("");
+        return resultJSON;
+    }
+}
+

sto/src/main/java/com/shinsoft/sto/service/main/WareService.java

@@ -0,0 +1,29 @@
+package com.shinsoft.sto.service.main;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.shinsoft.sto.model.main.Ware;
+import com.shinsoft.tools.model.common.ResultJSON;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 仓库 服务类
+ * </p>
+ *
+ * @author system
+ * @since 2024-10-15
+ */
+public interface WareService extends IService<Ware> {
+
+    ResultJSON query(int page, int rows, Map<String, Object> map);
+
+    ResultJSON queryByPK(String id);
+
+    ResultJSON save(String userId, String json);
+
+    ResultJSON remove(String userId, String id);
+
+    ResultJSON removeBatch(String userId, String ids);
+}
+