From ecf55bedecb4f35759ea6e97874bd414528177cb Mon Sep 17 00:00:00 2001
From: luqingyang <lqy5492@163.com>
Date: 星期四, 26 十月 2023 17:22:57 +0800
Subject: [PATCH] 仓库管理 相关代码

---
 consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager_mapper.java       |  253 ++++++++++++++++
 consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java |    2 
 consum-base/src/main/java/com/consum/base/service/BaseWarehouseManagerServiceImpl.java     |   25 +
 consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java            |  151 ++++++++++
 consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java   |   18 +
 consum-base/src/main/java/com/consum/base/controller/BaseWarehouseManagerController.java   |   45 +++
 consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager.java              |  150 ++++++++++
 consum-base/src/main/java/com/consum/base/Constants.java                                   |    8 
 consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java          |  124 ++++++++
 consum-base/src/main/java/com/consum/base/pojo/BaseWarehouseParam.java                     |   67 ++++
 10 files changed, 841 insertions(+), 2 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/Constants.java b/consum-base/src/main/java/com/consum/base/Constants.java
index 199f646..93fead0 100644
--- a/consum-base/src/main/java/com/consum/base/Constants.java
+++ b/consum-base/src/main/java/com/consum/base/Constants.java
@@ -57,5 +57,13 @@
     public static final Integer IS_DELETE_NO = 0;
     public static final Integer IS_DELETE_YES = 1;
 
+    //WAREHOUSE_TYPE  1鏈烘瀯浠撳簱2閮ㄩ棬浠撳簱
+    public static final Integer WAREHOUSE_TYPE_TENANT = 1;
+    public static final Integer WAREHOUSE_TYPE_DEPT = 2;
+
+    //IS_DEFAULT  1=鏄紱2=鍚�
+    public static final Integer IS_DEFAULT_YES = 1;
+    public static final Integer IS_DEFAULT_NO = 2;
+
 
 }
diff --git a/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java b/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java
new file mode 100644
index 0000000..f278db3
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java
@@ -0,0 +1,124 @@
+package com.consum.base.controller;
+
+import com.consum.base.BaseController;
+import com.consum.base.pojo.BaseWarehouseParam;
+import com.consum.base.pojo.FinSysTenantDepartmentParam;
+import com.consum.base.service.BaseWarehouseServiceImpl;
+import com.consum.model.po.BaseWarehouse;
+import com.consum.model.po.FinSysTenantDepartment;
+import com.consum.model.po.FinSysTenantUser;
+import com.walker.db.page.GenericPager;
+import com.walker.infrastructure.utils.StringUtils;
+import com.walker.web.ResponseValue;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Description 浠撳簱绠$悊
+ * @Author 鍗㈠簡闃�
+ * @Date 2023/10/26
+ */
+@RestController
+@RequestMapping("/pc/base/warehouse")
+public class BaseWarehouseController extends BaseController {
+
+    @Autowired
+    private BaseWarehouseServiceImpl baseWarehouseService;
+
+    /**
+     * @Description 鏂板
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @PostMapping("/add")
+    public ResponseValue add(@RequestBody BaseWarehouseParam param) {
+        if (StringUtils.isEmpty(param.getWarehouseName())) {
+            return ResponseValue.error("浠撳簱鍚嶇О涓虹┖");
+        }
+        //TODO 鍔犳潈闄� 鐪佺骇绠$悊鍛樺綍鍏ユ墍鏈変粨搴撲俊鎭�
+
+        int result = this.baseWarehouseService.add(param);
+        if (result > 0) return ResponseValue.success(1);
+        return ResponseValue.error("鏂板澶辫触锛�");
+    }
+
+    /**
+     * @Description 浠撳簱鍒楄〃鏌ヨ
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @GetMapping("/list")
+    public ResponseValue queryList(BaseWarehouseParam param) {
+        FinSysTenantUser sysInfo = this.getSysInfo();
+        if (sysInfo == null) {
+            return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
+        }
+        GenericPager<BaseWarehouse> pager = this.baseWarehouseService.queryList(param,sysInfo);
+        return ResponseValue.success(pager);
+    }
+
+    /**
+     * @Description 缂栬緫(淇敼鐘舵��)
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @PostMapping("/edit")
+    public ResponseValue edit(@RequestBody BaseWarehouse baseWarehouse) {
+        Long id = baseWarehouse.getId();
+        if (id == null || id <= 0) {
+            return ResponseValue.error("缂栬緫鐨勪粨搴撲笉瀛樺湪");
+        }
+        if (StringUtils.isEmpty(baseWarehouse.getWarehouseName())) {
+            return ResponseValue.error("浠撳簱鍚嶇О涓虹┖");
+        }
+
+        int num = this.baseWarehouseService.updateBaseWarehouse(baseWarehouse);
+        return num > 0 ? ResponseValue.success(1) : ResponseValue.error("缂栬緫澶辫触锛�");
+    }
+
+    /**
+     * 鏍规嵁id鏌ヨ浠撳簱璇︽儏
+     * @author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @GetMapping("/detail")
+    public ResponseValue getById(Long id) {
+        if (id == null) {
+            return ResponseValue.error("浠撳簱id涓虹┖");
+        }
+        BaseWarehouse baseWarehouse = this.baseWarehouseService.getById(id);
+        if (baseWarehouse == null) return ResponseValue.error("鏌ヨ澶辫触锛�");
+        return ResponseValue.success("鏌ヨ鎴愬姛!", baseWarehouse);
+    }
+
+    /**
+     * @Description 鏍规嵁id鍒犻櫎浠撳簱
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @DeleteMapping("/del")
+    public ResponseValue updateById(@RequestBody BaseWarehouse baseWarehouse) {
+        if (baseWarehouse.getId() == null) {
+            return ResponseValue.error("浠撳簱id涓虹┖");
+        }
+        int num = this.baseWarehouseService.updateById(baseWarehouse);
+
+        return num > 0 ? ResponseValue.success(1) : ResponseValue.error("鍒犻櫎澶辫触锛�");
+    }
+
+    /**
+     * @Description 鏍规嵁浠撳簱id鑾峰彇鏈烘瀯鐢ㄦ埛淇℃伅
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @GetMapping("/select/userList")
+    public ResponseValue queryList(Long baseWarehouseId) {
+        if (baseWarehouseId == null){
+            return ResponseValue.error("浠撳簱id涓虹┖");
+        }
+        this.baseWarehouseService.queryUserList(baseWarehouseId);
+        return ResponseValue.success();
+    }
+
+}
+
diff --git a/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseManagerController.java b/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseManagerController.java
new file mode 100644
index 0000000..e5021f9
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseManagerController.java
@@ -0,0 +1,45 @@
+package com.consum.base.controller;
+
+import com.consum.base.BaseController;
+import com.consum.base.pojo.BaseCategoryParam;
+import com.consum.base.pojo.BaseWarehouseParam;
+import com.consum.base.service.BaseCategoryServiceImpl;
+import com.consum.base.service.BaseGoodsTemplateServiceImpl;
+import com.consum.base.service.BaseWarehouseManagerServiceImpl;
+import com.consum.model.po.BaseCategory;
+import com.consum.model.po.BaseWarehouseManager;
+import com.iplatform.model.po.S_user_core;
+import com.walker.db.page.GenericPager;
+import com.walker.infrastructure.utils.StringUtils;
+import com.walker.web.ResponseValue;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.CollectionUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @Description 搴撶鍛�
+ * @Author 鍗㈠簡闃�
+ * @Date 2023/10/26
+ */
+@RestController
+@RequestMapping("/pc/base/warehouse/manager")
+public class BaseWarehouseManagerController extends BaseController {
+
+    @Autowired
+    private BaseWarehouseManagerServiceImpl baseWarehouseManagerService;
+
+    /**
+     * @Description 鏂板
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    @PostMapping("/add")
+    public ResponseValue add(@RequestBody BaseWarehouseManager baseWarehouseManager) {
+        int result = this.baseWarehouseManagerService.add(baseWarehouseManager);
+        if (result > 0) return ResponseValue.success(1);
+        return ResponseValue.error("鏂板澶辫触锛�");
+    }
+}
+
diff --git a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java
index 37eef96..76d3c26 100644
--- a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java
@@ -32,7 +32,7 @@
     /**
      * @Description 鏂板
      * @Author 鍗㈠簡闃�
-     * @Date 2023/10/25
+     * @Date 2023/10/26
      */
     @PostMapping("/add")
     public ResponseValue add(@RequestBody FinSysTenantDepartmentParam param) {
diff --git a/consum-base/src/main/java/com/consum/base/pojo/BaseWarehouseParam.java b/consum-base/src/main/java/com/consum/base/pojo/BaseWarehouseParam.java
new file mode 100644
index 0000000..669d74e
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/pojo/BaseWarehouseParam.java
@@ -0,0 +1,67 @@
+package com.consum.base.pojo;
+
+import com.walker.web.param.ParamRequest;
+
+public class BaseWarehouseParam extends ParamRequest {
+
+    /**
+     * 浠撳簱鍚嶇О
+     */
+    private String warehouseName;
+    /**
+     * 浠撳簱绫诲瀷Code
+     */
+    private String classificationCode;
+    /**
+     * 鏈烘瀯id
+     */
+    private Long agencyId;
+    /**
+     * 鍦板潃
+     */
+    private String adress;
+    /**
+     * 鐘舵��
+     */
+    private Integer states;
+
+    public String getWarehouseName() {
+        return warehouseName;
+    }
+
+    public void setWarehouseName(String warehouseName) {
+        this.warehouseName = warehouseName;
+    }
+
+    public String getClassificationCode() {
+        return classificationCode;
+    }
+
+    public void setClassificationCode(String classificationCode) {
+        this.classificationCode = classificationCode;
+    }
+
+    public Long getAgencyId() {
+        return agencyId;
+    }
+
+    public void setAgencyId(Long agencyId) {
+        this.agencyId = agencyId;
+    }
+
+    public String getAdress() {
+        return adress;
+    }
+
+    public void setAdress(String adress) {
+        this.adress = adress;
+    }
+
+    public Integer getStates() {
+        return states;
+    }
+
+    public void setStates(Integer states) {
+        this.states = states;
+    }
+}
diff --git a/consum-base/src/main/java/com/consum/base/service/BaseWarehouseManagerServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/BaseWarehouseManagerServiceImpl.java
new file mode 100644
index 0000000..5ef7473
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/service/BaseWarehouseManagerServiceImpl.java
@@ -0,0 +1,25 @@
+package com.consum.base.service;
+
+import com.consum.base.util.IdUtil;
+import com.consum.model.po.BaseWarehouseManager;
+import com.walker.jdbc.service.BaseServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Description 鐗╁搧鍒嗙被
+ * @Author 鍗㈠簡闃�
+ * @Date 2023/10/23
+ */
+@Service
+public class BaseWarehouseManagerServiceImpl extends BaseServiceImpl {
+
+    /**
+     * @Description 鏂板
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public int add(BaseWarehouseManager baseWarehouseManager) {
+        baseWarehouseManager.setId(IdUtil.generateId());
+        return this.insert(baseWarehouseManager);
+    }
+}
diff --git a/consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java
new file mode 100644
index 0000000..8201368
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java
@@ -0,0 +1,151 @@
+package com.consum.base.service;
+
+import com.consum.base.Constants;
+import com.consum.base.core.CodeGeneratorService;
+import com.consum.base.pojo.BaseWarehouseParam;
+import com.consum.base.util.IdUtil;
+import com.consum.model.po.BaseWarehouse;
+import com.consum.model.po.FinSysTenant;
+import com.consum.model.po.FinSysTenantDepartment;
+import com.consum.model.po.FinSysTenantUser;
+import com.walker.db.page.GenericPager;
+import com.walker.infrastructure.utils.DateUtils;
+import com.walker.infrastructure.utils.StringUtils;
+import com.walker.jdbc.service.BaseServiceImpl;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * @Description 浠撳簱绠$悊
+ * @Author 鍗㈠簡闃�
+ * @Date 2023/10/26
+ */
+@Service
+public class BaseWarehouseServiceImpl extends BaseServiceImpl {
+
+    @Autowired
+    private CodeGeneratorService codeGeneratorService;
+    @Autowired
+    private FinSysTenantServiceImpl finSysTenantService;
+    @Autowired
+    private FinSysTenantDepartmentServiceImpl departmentService;
+    @Autowired
+    private FinSysTenantUserServiceImpl userService;
+
+    /**
+     * @Description 鏂板
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public int add(BaseWarehouseParam param) {
+        BaseWarehouse baseWarehouse = new BaseWarehouse();
+        BeanUtils.copyProperties(param, baseWarehouse);
+        baseWarehouse.setId(IdUtil.generateId());
+        baseWarehouse.setWarehouseType(Constants.WAREHOUSE_TYPE_TENANT);
+        baseWarehouse.setWarehouseCode(codeGeneratorService.createWarehouseCode());
+        //鏍规嵁鏈烘瀯id鏌ヨ鏈烘瀯
+        FinSysTenant finSysTenant = finSysTenantService.get(new FinSysTenant(baseWarehouse.getAgencyId()));
+        if (finSysTenant != null) {
+            baseWarehouse.setParentAgencyId(finSysTenant.getParentId());
+            baseWarehouse.setAgencyName(finSysTenant.getName());
+        }
+        baseWarehouse.setIsDefault(Constants.IS_DEFAULT_YES);
+
+        return this.insert(baseWarehouse);
+    }
+
+    /**
+     * @Description 浠撳簱鍒楄〃鏌ヨ
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public GenericPager<BaseWarehouse> queryList(BaseWarehouseParam param, FinSysTenantUser sysInfo) {
+        StringBuilder sql = new StringBuilder("SELECT * FROM base_warehouse WHERE 1 = 1 ");
+        HashMap<String, Object> paramts = new HashMap<>();
+
+        //浠撳簱鍚嶇О
+        if (!StringUtils.isEmpty(param.getWarehouseName())) {
+            sql.append(" and WAREHOUSE_NAME like:WAREHOUSE_NAME ");
+            paramts.put("WAREHOUSE_NAME", StringUtils.CHAR_PERCENT + param.getWarehouseName() + StringUtils.CHAR_PERCENT);
+        }
+        //绫诲瀷
+        if (!StringUtils.isEmpty(param.getClassificationCode())) {
+            sql.append(" and CLASSIFICATION_CODE =:CLASSIFICATION_CODE ");
+            paramts.put("CLASSIFICATION_CODE", param.getClassificationCode());
+        }
+        //鏈烘瀯id
+        sql.append(" and AGENCY_ID =:AGENCY_ID ");
+        if (param.getAgencyId() != null) {
+            paramts.put("AGENCY_ID", param.getAgencyId());
+        } else {
+            paramts.put("AGENCY_ID", Long.valueOf(sysInfo.getTenantId()));
+        }
+        //鐘舵��
+        if (param.getStates() != null) {
+            sql.append(" and states =:states ");
+            paramts.put("states", param.getStates());
+        } else {
+            sql.append(" and states !=3 ");
+        }
+
+        sql.append(" ORDER BY states ");
+        return selectSplit(sql.toString(), paramts, new BaseWarehouse());
+    }
+
+    /**
+     * @Description 缂栬緫(淇敼鐘舵��)
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public int updateBaseWarehouse(BaseWarehouse baseWarehouse) {
+        return this.update(baseWarehouse);
+    }
+
+    /**
+     * 鏍规嵁id鏌ヨ浠撳簱璇︽儏
+     * @author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public BaseWarehouse getById(Long id) {
+        return this.get(new BaseWarehouse(id));
+    }
+
+    /**
+     * @Description 鏍规嵁id鍒犻櫎浠撳簱
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public int updateById(BaseWarehouse baseWarehouse) {
+        baseWarehouse.setStates(Constants.STATES_DELETED);
+        return this.update(baseWarehouse);
+    }
+
+    /**
+     * @Description 鏍规嵁浠撳簱id鑾峰彇鏈烘瀯鐢ㄦ埛淇℃伅
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/26
+     */
+    public void queryUserList(Long baseWarehouseId) {
+        //1.鏍规嵁浠撳簱id鏌ヨ浠撳簱
+        BaseWarehouse baseWarehouse = this.getById(baseWarehouseId);
+        if (baseWarehouse != null) {
+            Long agencyId = baseWarehouse.getAgencyId();
+            String agencyName = baseWarehouse.getAgencyName();
+            //2.鏍规嵁鏈烘瀯id鏌ヨ閮ㄩ棬
+            List<FinSysTenantDepartment> list = this.departmentService.getByTenantId(agencyId);
+            //鑾峰彇閮ㄩ棬id
+            Set<Long> deptIds = list.stream().map(dept -> dept.getId()).collect(Collectors.toSet());
+            //3.鏍规嵁閮ㄩ棬id鏌ヨ鐢ㄦ埛
+            //this.userService.getByDeptIds();
+
+        }
+
+
+    }
+}
diff --git a/consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java
index 95321c8..ef8975f 100644
--- a/consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java
@@ -47,7 +47,6 @@
             sql.append(" and TENANT_ID =:TENANT_ID ");
             paramts.put("TENANT_ID", tenantId);
         }
-
         return this.get(sql.toString(), paramts, new FinSysTenantDepartment());
     }
 
@@ -149,4 +148,21 @@
         department.setUpdateBy(currentUser.getUserName());
         return this.update(department);
     }
+
+    /**
+     * 鏍规嵁鏈烘瀯id鏌ヨ閮ㄩ棬
+     * @param agencyId
+     * @return
+     */
+    public List<FinSysTenantDepartment> getByTenantId(Long agencyId) {
+        StringBuilder sql = new StringBuilder("SELECT * FROM fin_sys_tenant_department WHERE 1 = 1 and is_delete = 0 ");
+        HashMap<String, Object> paramts = new HashMap<>();
+
+        //鏈烘瀯id
+        if (agencyId != null) {
+            sql.append(" and TENANT_ID =:TENANT_ID ");
+            paramts.put("TENANT_ID", agencyId);
+        }
+        return this.select(sql.toString(), paramts, new FinSysTenantDepartment());
+    }
 }
diff --git a/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager.java b/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager.java
new file mode 100644
index 0000000..cfd24af
--- /dev/null
+++ b/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager.java
@@ -0,0 +1,150 @@
+
+package com.consum.model.po;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.walker.jdbc.BasePo;
+
+/**
+ * 琛ㄥ悕:BASE_WAREHOUSE_MANAGER *
+ * @author genrator
+ */
+@JsonAutoDetect(fieldVisibility = JsonAutoDetect.Visibility.ANY)
+public class BaseWarehouseManager extends BasePo<BaseWarehouseManager> {
+    // 搴忓垪鍖栫増鏈彿
+    private static final long serialVersionUID = 1L;
+
+    // 涓婚敭
+    private Long id = null;
+    @JsonIgnore
+    protected boolean isset_id = false;
+
+    // 灞炴�у垪琛�
+    private Long managerId = null;
+    @JsonIgnore
+    protected boolean isset_managerId = false;
+
+    private String managerName = null;
+    @JsonIgnore
+    protected boolean isset_managerName = false;
+
+    private Long baseWarehouseId = null;
+    @JsonIgnore
+    protected boolean isset_baseWarehouseId = false;
+
+    /**
+     * 榛樿鏋勯�犲嚱鏁�
+     */
+    public BaseWarehouseManager() {
+    }
+
+    /**
+     * 鏍规嵁涓婚敭鏋勯�犲璞�
+     */
+    public BaseWarehouseManager(Long id) {
+        this.setId(id);
+    }
+
+    /**
+     * 璁剧疆涓婚敭鍊�
+     */
+    @Override
+    public void setPkValue(Object value) {
+        this.setId((Long) value);
+    }
+
+    public Long getId() {
+        return this.id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+        this.isset_id = true;
+    }
+
+    @JsonIgnore
+    public boolean isEmptyId() {
+        return this.id == null;
+    }
+
+    public Long getManagerId() {
+        return this.managerId;
+    }
+
+    public void setManagerId(Long managerId) {
+        this.managerId = managerId;
+        this.isset_managerId = true;
+    }
+
+    @JsonIgnore
+    public boolean isEmptyManagerId() {
+        return this.managerId == null;
+    }
+
+    public String getManagerName() {
+        return this.managerName;
+    }
+
+    public void setManagerName(String managerName) {
+        this.managerName = managerName;
+        this.isset_managerName = true;
+    }
+
+    @JsonIgnore
+    public boolean isEmptyManagerName() {
+        return this.managerName == null || this.managerName.length() == 0;
+    }
+
+    public Long getBaseWarehouseId() {
+        return this.baseWarehouseId;
+    }
+
+    public void setBaseWarehouseId(Long baseWarehouseId) {
+        this.baseWarehouseId = baseWarehouseId;
+        this.isset_baseWarehouseId = true;
+    }
+
+    @JsonIgnore
+    public boolean isEmptyBaseWarehouseId() {
+        return this.baseWarehouseId == null;
+    }
+
+    /**
+     * 閲嶅啓 toString() 鏂规硶
+     */
+    @Override
+    public String toString() {
+        return new StringBuilder()
+                .append("id=").append(this.id)
+                .append("managerId=").append(this.managerId)
+                .append("managerName=").append(this.managerName)
+                .append("baseWarehouseId=").append(this.baseWarehouseId)
+                .toString();
+    }
+
+    /**
+     * 鍏嬮殕
+     */
+    public BaseWarehouseManager $clone() {
+        BaseWarehouseManager base_warehouse_manager = new BaseWarehouseManager();
+
+        // 鏁版嵁搴撳悕绉�
+        //base_warehouse_manager.setDatabaseName_(this.getDatabaseName_());
+
+        // 涓婚敭
+        if (this.isset_id) {
+            base_warehouse_manager.setId(this.getId());
+        }
+        // 鏅�氬睘鎬�
+        if (this.isset_managerId) {
+            base_warehouse_manager.setManagerId(this.getManagerId());
+        }
+        if (this.isset_managerName) {
+            base_warehouse_manager.setManagerName(this.getManagerName());
+        }
+        if (this.isset_baseWarehouseId) {
+            base_warehouse_manager.setBaseWarehouseId(this.getBaseWarehouseId());
+        }
+        return base_warehouse_manager;
+    }
+}
diff --git a/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager_mapper.java b/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager_mapper.java
new file mode 100644
index 0000000..da106ba
--- /dev/null
+++ b/consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager_mapper.java
@@ -0,0 +1,253 @@
+package com.consum.model.po;
+
+import com.walker.jdbc.BaseMapper;
+import com.walker.jdbc.ResultSetUtils;
+import com.walker.jdbc.SqlAndParameters;
+import com.walker.jdbc.sqlgen.DeleteBuilder;
+import com.walker.jdbc.sqlgen.InsertBuilder;
+import com.walker.jdbc.sqlgen.SelectBuilder;
+import com.walker.jdbc.sqlgen.UpdateBuilder;
+import com.walker.jdbc.util.StringUtils;
+
+import org.springframework.jdbc.core.RowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.Map;
+
+/**
+ * 琛ㄥ悕:BASE_WAREHOUSE_MANAGER *
+ * @author genrator
+ */
+public class BaseWarehouseManager_mapper extends BaseWarehouseManager implements BaseMapper<BaseWarehouseManager> {
+    // 搴忓垪鍖栫増鏈彿
+    private static final long serialVersionUID = 1L;
+
+    public static final RowMapper<BaseWarehouseManager> ROW_MAPPER = new BaseWarehouseManagerRowMapper();
+
+    // 涓婚敭
+    public static final String Id = "id";
+    // 鏅�氬睘鎬�
+    public static final String ManagerId = "manager_id";
+    public static final String ManagerName = "manager_name";
+    public static final String BaseWarehouseId = "base_warehouse_id";
+
+    /**
+     * 榛樿鏋勯�犲嚱鏁�
+     */
+    public BaseWarehouseManager_mapper(BaseWarehouseManager baseWarehouseManager) {
+        if (baseWarehouseManager == null) {
+            throw new IllegalArgumentException("po鍙傛暟涓嶅厑璁镐负绌猴紒");
+        }
+        //涓婚敭
+        if (baseWarehouseManager.isset_id) {
+            this.setId(baseWarehouseManager.getId());
+        }
+        //鏅�氬睘鎬�
+        if (baseWarehouseManager.isset_managerId) {
+            this.setManagerId(baseWarehouseManager.getManagerId());
+        }
+        if (baseWarehouseManager.isset_managerName) {
+            this.setManagerName(baseWarehouseManager.getManagerName());
+        }
+        if (baseWarehouseManager.isset_baseWarehouseId) {
+            this.setBaseWarehouseId(baseWarehouseManager.getBaseWarehouseId());
+        }
+        // 鍘绘帀锛�2022-09-07
+        // this.setDatabaseName_(base_warehouse_manager.getDatabaseName_());
+    }
+
+    /**
+     * 鑾峰彇琛ㄥ悕
+     */
+    @Override
+    public String getTableName_() {
+        String tableName = "base_warehouse_manager";
+        /**
+        if (StringUtils.isNotEmpty(this.getDatabaseName_())) {
+            return this.getDatabaseName_() + "." + tableName;
+        } else {
+            return tableName;
+        }
+        */
+        return tableName;
+    }
+
+    /**
+     * 鑾峰彇涓婚敭鍚嶇О
+     */
+    @Override
+    public String getPkName_() {
+        return Id;
+    }
+
+    /**
+     * 鑾峰彇涓婚敭鍊�
+     */
+    @Override
+    public Object getPkValue_() {
+        return this.getId();
+    }
+
+    /**
+     * 鑾峰彇鎻掑叆璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getInsertSql_() {
+        InsertBuilder ib = new InsertBuilder(this.getTableName_());
+        ib.set(Id, this.getId());
+        ib.set(ManagerId, this.getManagerId(), this.isset_managerId);
+        ib.set(ManagerName, this.getManagerName(), this.isset_managerName);
+        ib.set(BaseWarehouseId, this.getBaseWarehouseId(), this.isset_baseWarehouseId);
+        return ib.genMapSql();
+    }
+
+    /**
+     * 鑾峰彇鏇存柊璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getUpdateSql_() {
+        UpdateBuilder ub = new UpdateBuilder(this.getTableName_());
+        ub.set(ManagerId, this.getManagerId(), this.isset_managerId);
+        ub.set(ManagerName, this.getManagerName(), this.isset_managerName);
+        ub.set(BaseWarehouseId, this.getBaseWarehouseId(), this.isset_baseWarehouseId);
+        ub.where(this.getPkName_(), this.getPkValue_());
+        return ub.genMapSql();
+    }
+
+    /**
+     * 鑾峰彇鏇存柊璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getUpdateSql_(String where, Map<String, Object> parameters) {
+        UpdateBuilder ub = new UpdateBuilder(this.getTableName_());
+        ub.set(ManagerId, this.getManagerId(), this.isset_managerId);
+        ub.set(ManagerName, this.getManagerName(), this.isset_managerName);
+        ub.set(BaseWarehouseId, this.getBaseWarehouseId(), this.isset_baseWarehouseId);
+        return ub.genMapSql(where, parameters);
+    }
+
+    /**
+     * 鑾峰彇鏇存柊璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Object[]> getUpdateSql_(String where, Object[] parameters) {
+        UpdateBuilder ub = new UpdateBuilder(this.getTableName_());
+        ub.set(ManagerId, this.getManagerId(), this.isset_managerId);
+        ub.set(ManagerName, this.getManagerName(), this.isset_managerName);
+        ub.set(BaseWarehouseId, this.getBaseWarehouseId(), this.isset_baseWarehouseId);
+        return ub.genArraySql(where, parameters);
+    }
+
+    /**
+     * 鑾峰彇鍒犻櫎璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getDeleteSql_() {
+        DeleteBuilder db = new DeleteBuilder(this.getTableName_());
+        db.where(this.getPkName_(), this.getPkValue_());
+        return db.genMapSql();
+    }
+
+    /**
+     * 鑾峰彇鍒犻櫎璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getDeleteSql_(String where, Map<String, Object> parameters) {
+        DeleteBuilder db = new DeleteBuilder(this.getTableName_());
+        return db.genMapSql(where, parameters);
+    }
+
+    /**
+     * 鑾峰彇鍒犻櫎璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Object[]> getDeleteSql_(String where, Object[] parameters) {
+        DeleteBuilder db = new DeleteBuilder(this.getTableName_());
+        return db.genArraySql(where, parameters);
+    }
+
+    /**
+     * 鑾峰彇鍗曡鏌ヨ璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getSingleSql_() {
+        SelectBuilder sb = new SelectBuilder(this.getTableName_());
+        sb.where(this.getPkName_(), this.getPkValue_());
+        return sb.genMapSql();
+    }
+
+
+    /**
+     * 鑾峰彇鏌ヨ璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Map<String, Object>> getSelectSql_(String where, Map<String, Object> parameters) {
+        return new SqlAndParameters<>("select id, manager_id, manager_name, base_warehouse_id from " + this.getTableName_() + " " + where, parameters);
+    }
+
+    /**
+     * 鑾峰彇鏌ヨ璇彞鍜屽弬鏁�
+     */
+    @Override
+    public SqlAndParameters<Object[]> getSelectSql_(String where, Object[] parameters) {
+        return new SqlAndParameters<>("select id, manager_id, manager_name, base_warehouse_id from " + this.getTableName_() + " " + where, parameters);
+    }
+
+    /**
+     * 灏唕esultset鐨勪竴琛岃浆鍖栦负po
+     */
+    @Override
+    public BaseWarehouseManager mapRow(ResultSet rs, int i) throws SQLException {
+        return ROW_MAPPER.mapRow(rs, i);
+    }
+
+    /**
+     * 鍏嬮殕
+     */
+    public BaseWarehouseManager toBaseWarehouseManager() {
+        return super.$clone();
+    }
+}
+
+/**
+ * base_warehouse_manager RowMapper
+ *
+ * @author genrator
+ */
+class BaseWarehouseManagerRowMapper implements RowMapper<BaseWarehouseManager> {
+
+    @Override
+    public BaseWarehouseManager mapRow(ResultSet rs, int i) throws SQLException {
+        ResultSetUtils resultSetUtils = new ResultSetUtils();
+        BaseWarehouseManager base_warehouse_manager = new BaseWarehouseManager();
+        Integer columnIndex;
+        //涓婚敭
+        columnIndex = resultSetUtils.findColumn(rs, BaseWarehouseManager_mapper.Id);
+        if (columnIndex > 0) {
+            base_warehouse_manager.setId(rs.getLong(columnIndex));
+        }
+        //鏅�氬睘鎬�
+        columnIndex = resultSetUtils.findColumn(rs, BaseWarehouseManager_mapper.ManagerId);
+        if (columnIndex > 0) {
+            if (rs.getBigDecimal(columnIndex) == null) {
+                base_warehouse_manager.setManagerId(null);
+            } else {
+                base_warehouse_manager.setManagerId(rs.getLong(columnIndex));
+            }
+        }
+        columnIndex = resultSetUtils.findColumn(rs, BaseWarehouseManager_mapper.ManagerName);
+        if (columnIndex > 0) {
+            base_warehouse_manager.setManagerName(rs.getString(columnIndex));
+        }
+        columnIndex = resultSetUtils.findColumn(rs, BaseWarehouseManager_mapper.BaseWarehouseId);
+        if (columnIndex > 0) {
+            if (rs.getBigDecimal(columnIndex) == null) {
+                base_warehouse_manager.setBaseWarehouseId(null);
+            } else {
+                base_warehouse_manager.setBaseWarehouseId(rs.getLong(columnIndex));
+            }
+        }
+        return base_warehouse_manager;
+    }
+}

--
Gitblit v1.9.1