仓库管理 相关代码

luqingyang

2023-10-26 ecf55bedecb4f35759ea6e97874bd414528177cb

仓库管理 相关代码

 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;


}

 consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java

New file
@@ -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();
    }

}


 consum-base/src/main/java/com/consum/base/controller/BaseWarehouseManagerController.java

New file
@@ -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("新增失败！");
    }
}


 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) {

 consum-base/src/main/java/com/consum/base/pojo/BaseWarehouseParam.java

New file
@@ -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;
    }
}

 consum-base/src/main/java/com/consum/base/service/BaseWarehouseManagerServiceImpl.java

New file
@@ -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);
    }
}

 consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java

New file
@@ -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();

        }


    }
}

 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());
    }
}

 consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager.java

New file
@@ -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;
    }
}

 consum-model-pojo/src/main/java/com/consum/model/po/BaseWarehouseManager_mapper.java

New file
@@ -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);
    }

    /**
     * 将resultset的一行转化为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;
    }
}