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