From 20c30d26f8bab22a4cb6b6459962fa92d6da490f Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期一, 27 十一月 2023 14:20:29 +0800
Subject: [PATCH] feat: 漏洞修改
---
consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java | 65 +--
consum-base/src/main/java/com/consum/base/controller/LWhWarningConfigController.java | 24 +
deploy-jar-single/src/main/resources/application-dev.yml | 13
deploy-jar-single/src/main/java/com/consum/test/CodeGeneratorServiceTest.java | 82 ++--
consum-base/src/main/java/com/consum/base/controller/LWhWarningController.java | 6
consum-model-pojo/src/main/java/com/consum/model/po/FinSysTenantUser_mapper.java | 12
consum-base/src/main/java/com/consum/base/pojo/query/LWhLedgerQry.java | 2
consum-base/src/main/java/com/consum/base/pojo/LWhFormScrappedParam.java | 7
deploy-jar-single/src/main/resources/application-prod.yml | 13
deploy-jar-single/src/main/resources/import/depTaiZhangExpTemp.xlsx | 0
consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java | 40 -
consum-base/src/main/java/com/consum/base/controller/BaseGoodsTemplateController.java | 56 ++-
consum-base/src/main/java/com/consum/base/service/LWhWarningServiceImpl.java | 8
deploy-jar-single/src/main/resources/import/taiZhangExpTemp.xlsx | 0
consum-base/src/main/java/com/consum/base/pojo/query/WhWarningQry.java | 3
deploy-jar-single/src/main/java/com/consum/test/synchronizedCode.java | 94 ++--
consum-base/src/main/java/com/consum/base/controller/BaseCategoryController.java | 49 ++
consum-base/src/main/java/com/consum/base/controller/FinDepartLedgerController.java | 108 ++++++
consum-base/src/main/java/com/consum/base/controller/BaseGoodsModelsController.java | 22 +
consum-base/src/main/java/com/consum/base/core/utils/MapUtils.java | 11
deploy-jar-single/pom.xml | 7
consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java | 23
consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java | 47 ++
consum-base/src/main/java/com/consum/base/controller/LWarehouseFlowController.java | 22 +
consum-base/src/main/java/com/consum/base/controller/FinWarehouseLedgerController.java | 6
consum-base/src/main/java/com/consum/base/service/FinWarehouseLedgerServiceImpl.java | 54 +++
deploy-jar-single/src/main/java/com/consum/test/base/Base_Category.java | 74 ++--
consum-base/src/main/java/com/consum/base/controller/LWhFormProcureController.java | 103 ++---
consum-base/src/main/java/com/consum/base/service/LWhGoodsService.java | 13
consum-base/src/main/java/com/consum/base/controller/LWhHomeStatisticsController.java | 45 ++
30 files changed, 670 insertions(+), 339 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/controller/BaseCategoryController.java b/consum-base/src/main/java/com/consum/base/controller/BaseCategoryController.java
index 343c47b..4cea9f8 100644
--- a/consum-base/src/main/java/com/consum/base/controller/BaseCategoryController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseCategoryController.java
@@ -1,6 +1,7 @@
package com.consum.base.controller;
import com.consum.base.BaseController;
+import com.consum.base.core.utils.CommonUtil;
import com.consum.base.pojo.BaseCategoryParam;
import com.consum.base.pojo.ProjectTreeResult;
import com.consum.base.service.BaseCategoryServiceImpl;
@@ -11,17 +12,13 @@
import com.walker.infrastructure.tree.TreeNode;
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;
import java.util.Map;
import java.util.TreeMap;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.util.CollectionUtils;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
/**
* @Description 鐗╁搧鍒嗙被
@@ -50,7 +47,7 @@
* @Date 2023/10/30
*/
@GetMapping("/select/tree")
- public ResponseValue tree(String categoryName) {
+ public ResponseValue trees() {
List<ProjectTreeResult> tree = this.baseCategoryService.tree();
return ResponseValue.success(tree);
}
@@ -61,7 +58,11 @@
* @Date 2023/10/23
*/
@PostMapping("/add")
- public ResponseValue add(@RequestBody BaseCategoryParam param) {
+ public ResponseValue add() {
+ BaseCategoryParam param = CommonUtil.getObjFromReqBody(BaseCategoryParam.class);
+ BaseCategoryParam param2 = new BaseCategoryParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
if (StringUtils.isEmpty(param.getCategoryName())) {
return ResponseValue.error("鍒嗙被鍚嶇О涓虹┖");
}
@@ -87,7 +88,12 @@
* @Date 2023/10/23
*/
@GetMapping("/list")
- public ResponseValue queryBaseCategoryList(BaseCategoryParam param) {
+ public ResponseValue queryBaseCategoryList() {
+ BaseCategoryParam param = CommonUtil.getObjFromReq(BaseCategoryParam.class);
+ BaseCategoryParam param2 = new BaseCategoryParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -103,7 +109,12 @@
* @Date 2023/10/23
*/
@PostMapping("/edit")
- public ResponseValue edit(@RequestBody BaseCategory baseCategory) {
+ public ResponseValue edit() {
+ BaseCategory baseCategory = CommonUtil.getObjFromReqBody(BaseCategory.class);
+ BaseCategory param2 = new BaseCategory();
+ CommonUtil.copyProperties(baseCategory, param2);
+ baseCategory = param2;
+
Long id = baseCategory.getId();
if (id == null || id.longValue() <= 0) {
return ResponseValue.error("缂栬緫鐨勭墿鍝佸垎绫讳笉瀛樺湪");
@@ -131,7 +142,12 @@
*/
//鍒嗙被涓嬫湁姝e父鐘舵�佺殑鐗╁搧鏃讹紝涓嶅厑璁哥鐢�
@PostMapping("/updStatus")
- public ResponseValue updateStatus(@RequestBody BaseCategory baseCategory) {
+ public ResponseValue updateStatus() {
+ BaseCategory baseCategory = CommonUtil.getObjFromReqBody(BaseCategory.class);
+ BaseCategory param2 = new BaseCategory();
+ CommonUtil.copyProperties(baseCategory, param2);
+ baseCategory = param2;
+
if (baseCategory == null || baseCategory.getId() == null || baseCategory.getStates() == null) {
return ResponseValue.error("鍙傛暟閿欒");
}
@@ -151,7 +167,12 @@
* @Date 2023/10/23
*/
@DeleteMapping("/del")
- public ResponseValue updateById(@RequestBody BaseCategory baseCategory) {
+ public ResponseValue updateById() {
+ BaseCategory baseCategory = CommonUtil.getObjFromReqBody(BaseCategory.class);
+ BaseCategory param2 = new BaseCategory();
+ CommonUtil.copyProperties(baseCategory, param2);
+ baseCategory = param2;
+
if (baseCategory.getId() == null) {
return ResponseValue.error("鍒嗙被id涓虹┖");
}
diff --git a/consum-base/src/main/java/com/consum/base/controller/BaseGoodsModelsController.java b/consum-base/src/main/java/com/consum/base/controller/BaseGoodsModelsController.java
index b43e991..f074e93 100644
--- a/consum-base/src/main/java/com/consum/base/controller/BaseGoodsModelsController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseGoodsModelsController.java
@@ -1,6 +1,7 @@
package com.consum.base.controller;
import com.consum.base.BaseController;
+import com.consum.base.core.utils.CommonUtil;
import com.consum.base.service.BaseGoodsModelsServiceImpl;
import com.consum.model.po.BaseGoodsModels;
import com.iplatform.model.po.S_user_core;
@@ -48,7 +49,12 @@
* @Date 2023/10/23
*/
@PostMapping("/add")
- public ResponseValue add(@RequestBody BaseGoodsModels models) {
+ public ResponseValue add() {
+ BaseGoodsModels models = CommonUtil.getObjFromReqBody(BaseGoodsModels.class);
+ BaseGoodsModels param2 = new BaseGoodsModels();
+ CommonUtil.copyProperties(models, param2);
+ models = param2;
+
if (models.getGoodsTemplatesId() == null || StringUtils.isEmpty(models.getModelName()) || StringUtils.isEmpty(models.getUnit()) || models.getStates() == null) {
return ResponseValue.error("鍙傛暟閿欒");
}
@@ -69,7 +75,12 @@
* @date 2023/10/25
*/
@PostMapping("/updStatus")
- public ResponseValue updateStatus(@RequestBody BaseGoodsModels models) {
+ public ResponseValue updateStatus() {
+ BaseGoodsModels models = CommonUtil.getObjFromReqBody(BaseGoodsModels.class);
+ BaseGoodsModels param2 = new BaseGoodsModels();
+ CommonUtil.copyProperties(models, param2);
+ models = param2;
+
if (models == null || models.getId() == null || models.getStates() == null) {
return ResponseValue.error("鍙傛暟閿欒");
}
@@ -84,7 +95,12 @@
* @Date 2023/10/25
*/
@DeleteMapping("/del")
- public ResponseValue updateById(@RequestBody BaseGoodsModels models) {
+ public ResponseValue updateById() {
+ BaseGoodsModels models = CommonUtil.getObjFromReqBody(BaseGoodsModels.class);
+ BaseGoodsModels param2 = new BaseGoodsModels();
+ CommonUtil.copyProperties(models, param2);
+ models = param2;
+
if (models.getId() == null) {
return ResponseValue.error("瑙勬牸鍨嬪彿id涓虹┖");
}
diff --git a/consum-base/src/main/java/com/consum/base/controller/BaseGoodsTemplateController.java b/consum-base/src/main/java/com/consum/base/controller/BaseGoodsTemplateController.java
index c7c053a..f4ede5c 100644
--- a/consum-base/src/main/java/com/consum/base/controller/BaseGoodsTemplateController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseGoodsTemplateController.java
@@ -1,6 +1,7 @@
package com.consum.base.controller;
import com.consum.base.BaseController;
+import com.consum.base.core.utils.CommonUtil;
import com.consum.base.core.utils.MapUtils;
import com.consum.base.core.utils.MapperUtil;
import com.consum.base.pojo.BaseGoodsTemplateParam;
@@ -8,11 +9,7 @@
import com.consum.base.service.BaseGoodsTemplateServiceImpl;
import com.consum.base.service.BaseWarehouseServiceImpl;
import com.consum.base.service.LWhGoodsService;
-import com.consum.model.po.BaseGoodsModels;
-import com.consum.model.po.BaseGoodsTemplate;
-import com.consum.model.po.BaseWarehouse;
-import com.consum.model.po.FinSysTenantUser;
-import com.consum.model.po.SDictData;
+import com.consum.model.po.*;
import com.consum.model.vo.BaseGoodsTemplateVo;
import com.walker.db.page.GenericPager;
import com.walker.infrastructure.utils.StringUtils;
@@ -20,18 +17,14 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
/**
* @Description 鐗╁搧妯℃澘
@@ -57,7 +50,12 @@
* @Date 2023/10/24
*/
@PostMapping("/add")
- public ResponseValue add(@RequestBody BaseGoodsTemplateParam param) {
+ public ResponseValue add() {
+ BaseGoodsTemplateParam param = CommonUtil.getObjFromReqBody(BaseGoodsTemplateParam.class);
+ BaseGoodsTemplateParam param2 = new BaseGoodsTemplateParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
FinSysTenantUser sysInfo = this.getSysInfo();
if (param.getCategoryId() == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -87,7 +85,12 @@
* @Date 2023/10/24
*/
@GetMapping("/list")
- public ResponseValue queryList(BaseGoodsTemplateParam param) {
+ public ResponseValue queryList() {
+ BaseGoodsTemplateParam param = CommonUtil.getObjFromReq(BaseGoodsTemplateParam.class);
+ BaseGoodsTemplateParam param2 = new BaseGoodsTemplateParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
FinSysTenantUser sysInfo = this.getSysInfo();
if (sysInfo == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -121,7 +124,12 @@
* @Date 2023/10/24
*/
@PostMapping("/edit")
- public ResponseValue edit(@RequestBody BaseGoodsTemplateParam param) {
+ public ResponseValue edit() {
+ BaseGoodsTemplateParam param = CommonUtil.getObjFromReqBody(BaseGoodsTemplateParam.class);
+ BaseGoodsTemplateParam param2 = new BaseGoodsTemplateParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
if (StringUtils.isEmpty(param.getGoodsName())) {
return ResponseValue.error("鐗╁搧鍚嶇О涓虹┖");
}
@@ -142,7 +150,12 @@
*/
//TODO 鐗╁搧鐨勭鐢ㄦ垨鍒犻櫎锛屼笉褰卞搷宸茬粡閲囪喘鍏ヨ繃搴撶殑鐗╁搧淇℃伅銆�
@PostMapping("/updStatus")
- public ResponseValue updateStatus(@RequestBody BaseGoodsTemplate goodsTemplate) {
+ public ResponseValue updateStatus() {
+ BaseGoodsTemplate goodsTemplate = CommonUtil.getObjFromReqBody(BaseGoodsTemplate.class);
+ BaseGoodsTemplate param2 = new BaseGoodsTemplate();
+ CommonUtil.copyProperties(goodsTemplate, param2);
+ goodsTemplate = param2;
+
if (goodsTemplate == null || goodsTemplate.getId() == null || goodsTemplate.getStates() == null) {
return ResponseValue.error("鍙傛暟閿欒");
}
@@ -158,7 +171,12 @@
*/
//TODO 鐗╁搧鐨勭鐢ㄦ垨鍒犻櫎锛屼笉褰卞搷宸茬粡閲囪喘鍏ヨ繃搴撶殑鐗╁搧淇℃伅銆�
@DeleteMapping("/del")
- public ResponseValue updateById(@RequestBody BaseGoodsTemplate goodsTemplate) {
+ public ResponseValue updateById() {
+ BaseGoodsTemplate goodsTemplate = CommonUtil.getObjFromReqBody(BaseGoodsTemplate.class);
+ BaseGoodsTemplate param2 = new BaseGoodsTemplate();
+ CommonUtil.copyProperties(goodsTemplate, param2);
+ goodsTemplate = param2;
+
if (goodsTemplate.getId() == null) {
return ResponseValue.error("鐗╁搧id涓虹┖");
}
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
index b1dcd6a..9c1bb36 100644
--- a/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/BaseWarehouseController.java
@@ -1,6 +1,7 @@
package com.consum.base.controller;
import com.consum.base.BaseController;
+import com.consum.base.core.utils.CommonUtil;
import com.consum.base.pojo.BaseWarehouseParam;
import com.consum.base.pojo.query.WarehouseQry;
import com.consum.base.service.BaseWarehouseServiceImpl;
@@ -13,15 +14,10 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
/**
* @Description 浠撳簱绠$悊
@@ -44,7 +40,12 @@
* @Date 2023/10/26
*/
@PostMapping("/add")
- public ResponseValue add(@RequestBody BaseWarehouseParam param) {
+ public ResponseValue add() {
+ BaseWarehouseParam param = CommonUtil.getObjFromReqBody(BaseWarehouseParam.class);
+ BaseWarehouseParam param2 = new BaseWarehouseParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
if (StringUtils.isEmpty(param.getWarehouseName())) {
return ResponseValue.error("浠撳簱鍚嶇О涓虹┖");
}
@@ -63,7 +64,12 @@
* @Date 2023/10/26
*/
@GetMapping("/list")
- public ResponseValue queryList(BaseWarehouseParam param) {
+ public ResponseValue queryList() {
+ BaseWarehouseParam param = CommonUtil.getObjFromReq(BaseWarehouseParam.class);
+ BaseWarehouseParam param2 = new BaseWarehouseParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
FinSysTenantUser sysInfo = this.getSysInfo();
if (sysInfo == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -79,7 +85,12 @@
* @Date 2023/10/26
*/
@PostMapping("/edit")
- public ResponseValue edit(@RequestBody BaseWarehouse baseWarehouse) {
+ public ResponseValue edit() {
+ BaseWarehouse baseWarehouse = CommonUtil.getObjFromReqBody(BaseWarehouse.class);
+ BaseWarehouse param2 = new BaseWarehouse();
+ CommonUtil.copyProperties(baseWarehouse, param2);
+ baseWarehouse = param2;
+
Long id = baseWarehouse.getId();
if (id == null || id <= 0) {
return ResponseValue.error("缂栬緫鐨勪粨搴撲笉瀛樺湪");
@@ -116,7 +127,12 @@
* @Date 2023/10/26
*/
@DeleteMapping("/del")
- public ResponseValue updateById(@RequestBody BaseWarehouse baseWarehouse) {
+ public ResponseValue updateById() {
+ BaseWarehouse baseWarehouse = CommonUtil.getObjFromReqBody(BaseWarehouse.class);
+ BaseWarehouse param2 = new BaseWarehouse();
+ CommonUtil.copyProperties(baseWarehouse, param2);
+ baseWarehouse = param2;
+
if (baseWarehouse.getId() == null) {
return ResponseValue.error("浠撳簱id涓虹┖");
}
@@ -162,7 +178,12 @@
@ApiImplicitParam(name = "warehouseQry", value = "浠撳簱id鍜屽瀷鍙穒d", required = true, dataType = "WarehouseQry", paramType = "query")
})
@GetMapping("/select/number")
- public ResponseValue selectNumber(@Validated WarehouseQry warehouseQry) {
+ public ResponseValue selectNumber() {
+ WarehouseQry warehouseQry = CommonUtil.getObjFromReq(WarehouseQry.class);
+ WarehouseQry param2 = new WarehouseQry();
+ CommonUtil.copyProperties(warehouseQry, param2);
+ warehouseQry = param2;
+
Long warehouseId = warehouseQry.getWarehouseId();
if (warehouseId == null) {
Long agencyId = warehouseQry.getAgencyId();
diff --git a/consum-base/src/main/java/com/consum/base/controller/FinDepartLedgerController.java b/consum-base/src/main/java/com/consum/base/controller/FinDepartLedgerController.java
new file mode 100644
index 0000000..daec1ca
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/controller/FinDepartLedgerController.java
@@ -0,0 +1,108 @@
+package com.consum.base.controller;
+
+import cn.afterturn.easypoi.excel.ExcelExportUtil;
+import cn.afterturn.easypoi.excel.entity.TemplateExportParams;
+import com.consum.base.BaseController;
+import com.consum.base.core.utils.CommonUtil;
+import com.consum.base.pojo.query.LWhLedgerQry;
+import com.consum.base.service.FinWarehouseLedgerServiceImpl;
+import com.consum.model.po.FinSysTenantUser;
+import com.iplatform.model.po.S_user_core;
+import com.walker.db.page.GenericPager;
+import com.walker.web.ResponseValue;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.URLEncoder;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 閮ㄩ棬鍙拌处
+ */
+@RestController
+@RequestMapping("/pc/fin/warehouse/departLedger")
+public class FinDepartLedgerController extends BaseController {
+ @Resource
+ private FinWarehouseLedgerServiceImpl finWarehouseLedgerService;
+
+ /**
+ * @Description 鍒嗛〉鍒楄〃鏌ヨ
+ * @Author wh
+ * @Date 2023/7/11 13:59
+ */
+ @RequestMapping("/getList")
+ public ResponseValue getLedgerList() {
+ LWhLedgerQry param = CommonUtil.getObjFromReq(LWhLedgerQry.class);
+ LWhLedgerQry query = new LWhLedgerQry();
+ CommonUtil.copyProperties(param, query);
+ param = query;
+ S_user_core currentUser = this.getCurrentUser();
+ if (currentUser == null) {
+ return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
+ }
+ /*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
+ FinSysTenantUser sysInfo = this.getSysInfo();
+ String tenantId = sysInfo.getTenantId();
+ Long paramAgencyId = param.getAgencyId();
+ if (paramAgencyId == null || !paramAgencyId.toString().startsWith(tenantId)) {
+ param.setAgencyId(Long.valueOf(tenantId));
+ }
+ param.setStates((short) 1);
+ param.setWarehouseType((short) 1);
+ GenericPager pager = finWarehouseLedgerService.departLedgerList(param);
+ return ResponseValue.success(pager);
+ }
+
+ @RequestMapping("/getListExport")
+ public void getListExport(HttpServletResponse response) throws Exception {
+ LWhLedgerQry param = CommonUtil.getObjFromReq(LWhLedgerQry.class);
+ LWhLedgerQry query = new LWhLedgerQry();
+ CommonUtil.copyProperties(param, query);
+ param = query;
+ S_user_core currentUser = this.getCurrentUser();
+ if (currentUser == null) {
+ return;
+ }
+ /*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
+ FinSysTenantUser sysInfo = this.getSysInfo();
+ String tenantId = sysInfo.getTenantId();
+ Long paramAgencyId = param.getAgencyId();
+ if (paramAgencyId == null || !paramAgencyId.toString().startsWith(tenantId)) {
+ param.setAgencyId(Long.valueOf(tenantId));
+ }
+ param.setStates((short) 1);
+ param.setWarehouseType((short) 1);
+ param.setPageNum(1);
+ param.setPageSize(Integer.MAX_VALUE);
+ GenericPager<Map<String, Object>> pager = finWarehouseLedgerService.departLedgerList(param);
+ List<Map<String, Object>> datas = pager.getDatas();
+ org.springframework.core.io.Resource resource = new ClassPathResource("import/depTaiZhangExpTemp.xlsx");
+ // 鑾峰彇鏂囦欢杈撳叆娴�
+ InputStream inputStream = resource.getInputStream();
+ Workbook wb = new XSSFWorkbook(inputStream);
+ TemplateExportParams params = new TemplateExportParams();
+ params.setTemplateWb(wb);
+
+ Map<String, Object> map = new HashMap<String, Object>();
+ map.put("dataList", datas);
+
+ Workbook workbook = ExcelExportUtil.exportExcel(params, map);
+ // 璁剧疆鍝嶅簲澶�
+ response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet;charset=utf-8");
+ response.setHeader("Content-disposition", "attachment;filename=" + URLEncoder.encode("搴撳瓨鏌ヨ.xlsx", "utf-8"));
+ try (OutputStream outputStream = response.getOutputStream()) {
+ workbook.write(outputStream);
+ workbook.close();
+ }
+
+ }
+}
diff --git a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
index edae61d..f03df71 100644
--- a/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java
@@ -1,5 +1,6 @@
package com.consum.base.controller;
+import cn.hutool.core.util.ReflectUtil;
import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.context.AnalysisContext;
@@ -30,38 +31,22 @@
import com.iplatform.model.po.S_role;
import com.iplatform.model.po.S_user_core;
import com.walker.db.page.GenericPager;
-import com.walker.infrastructure.utils.CollectionUtils;
-import com.walker.infrastructure.utils.DateUtils;
-import com.walker.infrastructure.utils.NumberGenerator;
-import com.walker.infrastructure.utils.PhoneNumberUtils;
-import com.walker.infrastructure.utils.StringUtils;
+import com.walker.infrastructure.utils.*;
import com.walker.web.ResponseValue;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Optional;
-import java.util.Set;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.lang.reflect.Field;
+import java.util.*;
/**
* @Description 绯荤粺鐢ㄦ埛
@@ -174,8 +159,10 @@
try {
Field fieldDatas = GenericPager.class.getDeclaredField("datas");
- fieldDatas.setAccessible(true);
- fieldDatas.set(pager, resultList);
+// fieldDatas.setAccessible(true);
+// fieldDatas.set(pager, resultList);
+ ReflectUtil.setFieldValue(pager, fieldDatas, resultList);
+
} catch (Exception e) {
e.printStackTrace();
}
@@ -227,11 +214,11 @@
user.setSysUserId(NumberGenerator.getLongSequenceNumber());
// 鍔犲瘑鎵嬫満鍙�
String key = PlatformRSAUtils.AES_KEY;
- String pwdPhone = "";
+ String encPhone = "";
if (user.getUserPhone() != null) {
- pwdPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
+ encPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
}
- user.setUserPhone(pwdPhone);
+ user.setUserPhone(encPhone);
//鎬庝箞鑾峰彇宸︿晶鏈烘瀯鏍戞暟鎹�
user.setSysDeptId(3L); //瀵瑰簲骞冲彴鏈烘瀯id 榛樿涓哄钩鍙扮鐞�
this.finSysTenantUserService.insert(user);
@@ -245,7 +232,7 @@
userCore.setNick_name(user.getUserName());
//鐢ㄦ埛绫诲瀷 鍏堥粯璁よ缃负2
userCore.setUser_type(2);
- userCore.setPhonenumber(pwdPhone);
+ userCore.setPhonenumber(encPhone);
userCore.setSex(user.getSex().toString());
//鍒濆鍖栧瘑鐮� 123456
String pws = this.getArgumentVariable(ArgumentsConstants.KEY_SECURITY_PASSWORD_INIT).getStringValue();
@@ -427,8 +414,8 @@
user.setRemark("鎵归噺瀵煎叆");
// 鍔犲瘑鎵嬫満鍙�
String key = PlatformRSAUtils.AES_KEY;
- String pwdPhone = AESUtils.encryptStrAES(data.getUserPhone(), key);
- user.setUserPhone(pwdPhone);
+ String encPhone = AESUtils.encryptStrAES(data.getUserPhone(), key);
+ user.setUserPhone(encPhone);
user.setIsDelete(1);
//鎬庝箞鑾峰彇宸︿晶鏈烘瀯鏍戞暟鎹�
@@ -551,11 +538,11 @@
return ResponseValue.error("鍙傛暟涓虹┖");
}
String key = PlatformRSAUtils.AES_KEY;
- String pwdPhone = "";
+ String encPhone = "";
if (user.getUserPhone() != null) {
- pwdPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
+ encPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
}
- user.setUserPhone(pwdPhone);
+ user.setUserPhone(encPhone);
// 1.鏇存柊绯荤粺鐢ㄦ埛 FIN_SYS_TENANT_USER
finSysTenantUserService.update(user);
// 2.鏇存柊骞冲彴鐢ㄦ埛 S_USER_CORE
@@ -786,10 +773,10 @@
// 鍔犲瘑鎵嬫満鍙�
String key = PlatformRSAUtils.AES_KEY;
String userPhone = user.getUserPhone();
- String pwdPhone = "";
+ String encPhone = "";
if (userPhone != null) {
- pwdPhone = AESUtils.encryptStrAES(userPhone, key);
- user.setUserPhone(pwdPhone);
+ encPhone = AESUtils.encryptStrAES(userPhone, key);
+ user.setUserPhone(encPhone);
}
this.finSysTenantUserService.insert(user);
@@ -883,12 +870,12 @@
updUser.setEmail(user.getEmail());
updUser.setUserName(user.getUserName());
updUser.setSex(user.getSex());
- String pwdPhone = "";
+ String encPhone = "";
if (user.getUserPhone() != null) {
String key = PlatformRSAUtils.AES_KEY;
- pwdPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
+ encPhone = AESUtils.encryptStrAES(user.getUserPhone(), key);
}
- updUser.setUserPhone(pwdPhone);
+ updUser.setUserPhone(encPhone);
// 1.鏇存柊绯荤粺鐢ㄦ埛 FIN_SYS_TENANT_USER
finSysTenantUserService.update(updUser);
// 2.鏇存柊骞冲彴鐢ㄦ埛 S_USER_CORE
diff --git a/consum-base/src/main/java/com/consum/base/controller/FinWarehouseLedgerController.java b/consum-base/src/main/java/com/consum/base/controller/FinWarehouseLedgerController.java
index 2dd853c..2c0337d 100644
--- a/consum-base/src/main/java/com/consum/base/controller/FinWarehouseLedgerController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/FinWarehouseLedgerController.java
@@ -46,6 +46,9 @@
@RequestMapping("/getList")
public ResponseValue getLedgerList() {
LWhLedgerQry param = CommonUtil.getObjFromReq(LWhLedgerQry.class);
+ LWhLedgerQry query = new LWhLedgerQry();
+ CommonUtil.copyProperties(param, query);
+ param = query;
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -65,6 +68,9 @@
@RequestMapping("/getListExport")
public void getListExport(HttpServletResponse response) throws Exception {
LWhLedgerQry param = CommonUtil.getObjFromReq(LWhLedgerQry.class);
+ LWhLedgerQry query = new LWhLedgerQry();
+ CommonUtil.copyProperties(param, query);
+ param = query;
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return;
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWarehouseFlowController.java b/consum-base/src/main/java/com/consum/base/controller/LWarehouseFlowController.java
index 5177428..b55681b 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWarehouseFlowController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWarehouseFlowController.java
@@ -1,5 +1,6 @@
package com.consum.base.controller;
+import cn.hutool.core.util.ReflectUtil;
import com.consum.base.BaseController;
import com.consum.base.core.utils.CommonUtil;
import com.consum.base.core.utils.MapUtils;
@@ -34,7 +35,12 @@
private LWarehouseFlowService lWarehouseFlowService;
@GetMapping("/list")
- public ResponseValue queryFormProcureList(LWarehouseFlowParam param) {
+ public ResponseValue queryFormProcureList() {
+ LWarehouseFlowParam param = CommonUtil.getObjFromReq(LWarehouseFlowParam.class);
+ LWarehouseFlowParam param2 = new LWarehouseFlowParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -47,8 +53,9 @@
});
try {
Field fieldDatas = GenericPager.class.getDeclaredField("datas");
- fieldDatas.setAccessible(true);
- fieldDatas.set(genericPager, result);
+// fieldDatas.setAccessible(true);
+// fieldDatas.set(genericPager, result);
+ ReflectUtil.setFieldValue(genericPager, fieldDatas, result);
} catch (Exception e) {
logger.error(e.getMessage(), e);
}
@@ -58,7 +65,11 @@
@GetMapping("/detail/list")
- public ResponseValue queryFormProcureList1(LWarehouseFlowParam param) {
+ public ResponseValue queryFormProcureList1() {
+ LWarehouseFlowParam param = CommonUtil.getObjFromReq(LWarehouseFlowParam.class);
+ LWarehouseFlowParam param2 = new LWarehouseFlowParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -74,6 +85,9 @@
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
}
LWarehouseFlowParam param = CommonUtil.getObjFromReq(LWarehouseFlowParam.class);
+ LWarehouseFlowParam param2 = new LWarehouseFlowParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
/*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
FinSysTenantUser sysInfo = this.getSysInfo();
String tenantId = sysInfo.getTenantId();
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java b/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java
index fae394a..770b5b4 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java
@@ -1,16 +1,13 @@
package com.consum.base.controller;
+import cn.hutool.core.util.ReflectUtil;
import com.consum.base.BaseController;
import com.consum.base.core.utils.CommonUtil;
import com.consum.base.core.utils.MapUtils;
import com.consum.base.core.utils.MapperUtil;
import com.consum.base.pojo.LWhFormOutputParam;
import com.consum.base.pojo.query.LWhFormOutputQry;
-import com.consum.base.pojo.response.FormOutputGoodsVO;
-import com.consum.base.pojo.response.FormOutputTemplateInfoVO;
-import com.consum.base.pojo.response.FormOutputVO;
-import com.consum.base.pojo.response.GoodsModelVO;
-import com.consum.base.pojo.response.LWhFormOutputExtendVO;
+import com.consum.base.pojo.response.*;
import com.consum.base.service.LWarehouseFlowService;
import com.consum.base.service.LWhFormOutputServiceImpl;
import com.consum.base.service.LWhGoodsService;
@@ -25,11 +22,6 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.lang.reflect.Field;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import javax.annotation.Resource;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -37,6 +29,12 @@
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.lang.reflect.Field;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
/**
* @Description 鍑哄簱鍗�
@@ -129,8 +127,9 @@
}
try {
Field fieldDatas = GenericPager.class.getDeclaredField("datas");
- fieldDatas.setAccessible(true);
- fieldDatas.set(genericPager, resultList);
+// fieldDatas.setAccessible(true);
+// fieldDatas.set(genericPager, resultList);
+ ReflectUtil.setFieldValue(genericPager, fieldDatas, resultList);
} catch (Exception e) {
e.printStackTrace();
}
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhFormProcureController.java b/consum-base/src/main/java/com/consum/base/controller/LWhFormProcureController.java
index ed68075..79df3ac 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhFormProcureController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhFormProcureController.java
@@ -1,5 +1,6 @@
package com.consum.base.controller;
+import cn.hutool.core.util.ReflectUtil;
import com.consum.base.BaseController;
import com.consum.base.core.CodeGeneratorEnum;
import com.consum.base.core.CodeGeneratorService;
@@ -12,27 +13,9 @@
import com.consum.base.pojo.LWhFormProcureParam;
import com.consum.base.pojo.LWhProcureModelParam;
import com.consum.base.pojo.query.FormProcureQry;
-import com.consum.base.pojo.response.FormProcureVO;
-import com.consum.base.pojo.response.FromProcureTemplateInfoVO;
-import com.consum.base.pojo.response.GoodsModelVO;
-import com.consum.base.pojo.response.LWhFormProcureExtendVO;
-import com.consum.base.pojo.response.LWhFormProcureGoodsVO;
-import com.consum.base.service.BaseGoodsTemplateServiceImpl;
-import com.consum.base.service.BaseWarehouseServiceImpl;
-import com.consum.base.service.FinSysTenantServiceImpl;
-import com.consum.base.service.LOrgSupplierServiceImpl;
-import com.consum.base.service.LWhFormProcureCoreService;
-import com.consum.base.service.LWhFormProcureGoodsService;
-import com.consum.base.service.LWhFormProcureService;
-import com.consum.base.service.LWhGoodsService;
-import com.consum.base.service.LWhProcureModelService;
-import com.consum.model.po.BaseGoodsTemplate;
-import com.consum.model.po.BaseWarehouse;
-import com.consum.model.po.FinSysTenantUser;
-import com.consum.model.po.LOrgSupplier;
-import com.consum.model.po.LWhFormProcure;
-import com.consum.model.po.LWhFormProcureGoods;
-import com.consum.model.po.LWhProcureModel;
+import com.consum.base.pojo.response.*;
+import com.consum.base.service.*;
+import com.consum.model.po.*;
import com.iplatform.model.po.S_user_core;
import com.walker.db.page.GenericPager;
import com.walker.infrastructure.utils.CollectionUtils;
@@ -42,22 +25,13 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.lang.reflect.Field;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import javax.annotation.Resource;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.BeanUtils;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.lang.reflect.Field;
+import java.util.*;
/**
* @ClassName LWhFormProcureController
@@ -95,7 +69,15 @@
* @Description 鏂板
*/
@PostMapping("/add")
- public ResponseValue add(@RequestBody LWhFormProcureParam param) {
+ public ResponseValue add() {
+ LWhFormProcureParam param = CommonUtil.getObjFromReqBody(LWhFormProcureParam.class);
+ LWhFormProcureParam param2 = new LWhFormProcureParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+ return this.add(param);
+ }
+
+ private ResponseValue add(LWhFormProcureParam param) {
Long warehouseId = param.getWarehouseId();
if (param.getWarehouseId() == null) {
return ResponseValue.error("浠撳簱ID涓嶈兘涓虹┖");
@@ -222,10 +204,14 @@
*/
@ApiOperation(value = "閲囪喘鍗曞垪琛ㄦ煡璇�", notes = "閲囪喘鍗曞垪琛ㄦ煡璇�")
@ApiImplicitParams({
- @ApiImplicitParam(name = "param", value = "閲囪喘鏌ヨ鏉′欢", required = true, dataType = "FormProcureQryDto", paramType = "query")
+ @ApiImplicitParam(name = "param", value = "閲囪喘鏌ヨ鏉′欢", required = true, dataType = "FormProcureQryDto", paramType = "query")
})
@GetMapping("/list")
- public ResponseValue queryFormProcureList(FormProcureQry param) {
+ public ResponseValue queryFormProcureList() {
+ FormProcureQry param = CommonUtil.getObjFromReq(FormProcureQry.class);
+ FormProcureQry param2 = new FormProcureQry();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
@@ -248,8 +234,8 @@
// 鏌ヨ鍨嬪彿鏁伴噺
String sql = "select fpg.id,BASE_CATEGORY_ID ,BASE_GOODS_TEMPLATE_ID ,GOODS_TEMPLATE_NAME ,sum(counts) count "
- + "from L_WH_FORM_PROCURE_GOODS fpg left join L_WH_PROCURE_MODEL pm on fpg.id = pm.FROM_PROCURE_GOODS_ID "
- + "where fpg.WH_FORM_PROCURE_ID =:id group by pm.FROM_PROCURE_GOODS_ID";
+ + "from L_WH_FORM_PROCURE_GOODS fpg left join L_WH_PROCURE_MODEL pm on fpg.id = pm.FROM_PROCURE_GOODS_ID "
+ + "where fpg.WH_FORM_PROCURE_ID =:id group by pm.FROM_PROCURE_GOODS_ID";
Map<String, Object> paramMap = new HashMap<>();
paramMap.put("id", item.getId());
List<Map<String, Object>> procureModelList = lWhProcureModelService.select(sql, paramMap, new MapperUtil());
@@ -264,8 +250,9 @@
}
try {
Field fieldDatas = GenericPager.class.getDeclaredField("datas");
- fieldDatas.setAccessible(true);
- fieldDatas.set(genericPager, result);
+// fieldDatas.setAccessible(true);
+// fieldDatas.set(genericPager, result);
+ ReflectUtil.setFieldValue(genericPager, fieldDatas, result);
} catch (Exception e) {
e.printStackTrace();
}
@@ -277,7 +264,11 @@
* @Description 缂栬緫
*/
@PostMapping("/edit")
- public ResponseValue edit(@RequestBody LWhFormProcureParam param) {
+ public ResponseValue edit() {
+ LWhFormProcureParam param = CommonUtil.getObjFromReqBody(LWhFormProcureParam.class);
+ LWhFormProcureParam param2 = new LWhFormProcureParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
ResponseValue delFlag = delById(param.getId());
if (delFlag.getCode() == ResponseValue.CODE_SUCCESS) {
return this.add(param);
@@ -342,13 +333,13 @@
lWhFormProcureGoods.setWhFormProcureId(id);
List<LWhFormProcureGoods> formProcureGoods = lWhFormProcureGoodsService.select(lWhFormProcureGoods);
- Field fieldModels = null;
- try {
- fieldModels = LWhFormProcureGoodsVO.class.getDeclaredField("models");
- } catch (NoSuchFieldException e) {
- e.printStackTrace();
- }
- fieldModels.setAccessible(true);
+// Field fieldModels = null;
+// try {
+// fieldModels = LWhFormProcureGoodsVO.class.getDeclaredField("models");
+// } catch (NoSuchFieldException e) {
+// e.printStackTrace();
+// }
+// fieldModels.setAccessible(true);
ArrayList<LWhFormProcureGoodsVO> procureGoodsVOList = new ArrayList<>();
for (LWhFormProcureGoods formProcureGood : formProcureGoods) {
LWhFormProcureGoodsVO lWhFormProcureGoodsVO = new LWhFormProcureGoodsVO();
@@ -363,15 +354,17 @@
Map<String, Object> paramMap = new HashMap<>();
paramMap.put("formProcureGoodId", formProcureGood.getId());
String sql = "SELECT\n" + "pm.BASE_GOODS_MODELS_ID,pm.BASE_GOODS_MODELS_NAME,pm.PRICE,pm.COUNTS,pm.WOREHOUSE_COUNT,bgm.unit " + "FROM\n"
- + "\tl_wh_procure_model pm\n"
- + "\tLEFT JOIN base_goods_models bgm on pm.BASE_GOODS_MODELS_ID = bgm.id where pm.FROM_PROCURE_GOODS_ID =:formProcureGoodId";
+ + "\tl_wh_procure_model pm\n"
+ + "\tLEFT JOIN base_goods_models bgm on pm.BASE_GOODS_MODELS_ID = bgm.id where pm.FROM_PROCURE_GOODS_ID =:formProcureGoodId";
List<Map<String, Object>> procureModelList = lWhProcureModelService.select(sql, paramMap, new MapperUtil());
List<GoodsModelVO> goodsModelVOList = Lists.newArrayList();
procureModelList.forEach(item -> {
GoodsModelVO goodsModelVO = MapUtils.convertMapToObj(item, GoodsModelVO.class);
goodsModelVOList.add(goodsModelVO);
});
- fieldModels.set(lWhFormProcureGoodsVO, goodsModelVOList);
+// fieldModels.set(lWhFormProcureGoodsVO, goodsModelVOList);
+ ReflectUtil.setFieldValue(lWhFormProcureGoodsVO, "models", goodsModelVOList);
+
procureGoodsVOList.add(lWhFormProcureGoodsVO);
}
lWhFormProcureExtendVO.setProcureGoods(procureGoodsVOList);
@@ -384,6 +377,10 @@
@GetMapping("detail/list")
public ResponseValue queryFormProcureDetailList() {
FormProcureQry formProcureQry = CommonUtil.getObjFromReq(FormProcureQry.class);
+ FormProcureQry param2 = new FormProcureQry();
+ CommonUtil.copyProperties(formProcureQry, param2);
+ formProcureQry = param2;
+
S_user_core currentUser = this.getCurrentUser();
if (currentUser == null) {
return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java b/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
index a78ab43..7b482b3 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
@@ -1,33 +1,24 @@
package com.consum.base.controller;
+import cn.hutool.core.util.ReflectUtil;
import com.consum.base.BaseController;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.core.utils.MapUtils;
import com.consum.base.core.utils.MapperUtil;
import com.consum.base.pojo.GoodsUseRecordVO;
import com.consum.base.pojo.LWhFormTransferGoodsInfoParam;
-import com.consum.base.pojo.request.ProcureModelInfoParam;
import com.consum.base.pojo.RecordUserInfoVO;
import com.consum.base.pojo.UseRecordSkuVO;
import com.consum.base.pojo.dto.UseRecordDTO;
import com.consum.base.pojo.query.TransferQry;
import com.consum.base.pojo.request.LWhFormTransferParam;
+import com.consum.base.pojo.request.ProcureModelInfoParam;
import com.consum.base.pojo.response.FormTransferVO;
import com.consum.base.pojo.response.FromTransferTemplateInfoVO;
import com.consum.base.pojo.response.LWHFromTransferExtendVO;
import com.consum.base.pojo.response.TransferInfoVO;
-import com.consum.base.service.BaseGoodsModelsServiceImpl;
-import com.consum.base.service.BaseWarehouseServiceImpl;
-import com.consum.base.service.LWhFormTransferCoreService;
-import com.consum.base.service.LWhFormTransferServiceImpl;
-import com.consum.base.service.LWhProcureModelService;
-import com.consum.base.service.LWhProcureModelUserRecordServiceImpl;
-import com.consum.base.service.LWhProcureModelUserServiceImpl;
-import com.consum.model.po.BaseWarehouse;
-import com.consum.model.po.FinSysTenantUser;
-import com.consum.model.po.LWhFormTransfer;
-import com.consum.model.po.LWhProcureModelUser;
-import com.consum.model.po.LWhProcureModelUserRecord;
+import com.consum.base.service.*;
+import com.consum.model.po.*;
import com.consum.model.vo.LWhFormOutputVo;
import com.iplatform.model.po.S_user_core;
import com.walker.db.page.GenericPager;
@@ -38,21 +29,14 @@
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
-import java.lang.reflect.Field;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.stream.Collectors;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.lang.reflect.Field;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* @Description 璋冩嫧绠$悊
@@ -152,8 +136,10 @@
}
try {
Field fieldDatas = GenericPager.class.getDeclaredField("datas");
- fieldDatas.setAccessible(true);
- fieldDatas.set(genericPager, result);
+// fieldDatas.setAccessible(true);
+// fieldDatas.set(genericPager, result);
+ ReflectUtil.setFieldValue(genericPager, fieldDatas, result);
+
} catch (Exception e) {
e.printStackTrace();
}
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhHomeStatisticsController.java b/consum-base/src/main/java/com/consum/base/controller/LWhHomeStatisticsController.java
new file mode 100644
index 0000000..5ebf949
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhHomeStatisticsController.java
@@ -0,0 +1,45 @@
+package com.consum.base.controller;
+
+import cn.hutool.core.convert.Convert;
+import com.consum.base.BaseController;
+import com.consum.base.service.LWhGoodsService;
+import com.consum.model.po.FinSysTenantUser;
+import com.walker.web.ResponseValue;
+import io.swagger.annotations.Api;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName LWhHomeStatisticsController
+ * @Author cy
+ * @Date 2023/11/27
+ * @Description
+ * @Version 1.0
+ **/
+
+@RestController
+@RequestMapping("/pc/warehouse/homeStatistics")
+@Api(value = "棣栭〉缁熻", tags = "棣栭〉缁熻")
+public class LWhHomeStatisticsController extends BaseController {
+ @Resource
+ private LWhGoodsService lWhGoodsService;
+
+ /**
+ * 鐗╁搧鏁伴噺閲戦缁熻
+ *
+ * @return
+ */
+ @GetMapping("getGoodsNumPrice")
+ public ResponseValue goodsNumPrice() {
+ /*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
+ FinSysTenantUser sysInfo = this.getSysInfo();
+ String tenantId = sysInfo.getTenantId();
+ List<Map<String, Object>> goodsNumPrice = lWhGoodsService.getGoodsNumPrice(Convert.toLong(tenantId, 0l));
+ return ResponseValue.success(goodsNumPrice.get(0));
+ }
+}
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhWarningConfigController.java b/consum-base/src/main/java/com/consum/base/controller/LWhWarningConfigController.java
index 783f3de..e1610e4 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhWarningConfigController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhWarningConfigController.java
@@ -68,6 +68,10 @@
@PostMapping("/add")
public ResponseValue add() throws Exception {
WhWarningConfigParam param = CommonUtil.getObjFromReqBody(WhWarningConfigParam.class);
+ WhWarningConfigParam param2 = new WhWarningConfigParam();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
String modelConfigStr = param.getModelConfigStr();
Long baseWarehouseId = param.getBaseWarehouseId();
Long baseGoodsTemplateId = param.getBaseGoodsTemplateId();
@@ -144,6 +148,10 @@
@PostMapping("/upd")
public ResponseValue upd() {
WhWarningConfig param = CommonUtil.getObjFromReqBody(WhWarningConfig.class);
+ WhWarningConfig param2 = new WhWarningConfig();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
if (param.getId() == null || (param.getUpperLimit() == null && param.getLowerLimit() == null)) {
return ResponseValue.error("搴撳瓨涓婇檺銆佷笅闄愪笉鑳藉叏涓虹┖锛�");
}
@@ -160,6 +168,9 @@
@DeleteMapping("del")
public ResponseValue delById() {
WhWarningConfig param = CommonUtil.getObjFromReqBody(WhWarningConfig.class);
+ WhWarningConfig param2 = new WhWarningConfig();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
if (param.getId() == null) {
return ResponseValue.error("id涓虹┖");
}
@@ -170,6 +181,9 @@
@GetMapping("/getList")
public ResponseValue getConfigList() {
WhWarningConfigQry param = CommonUtil.getObjFromReq(WhWarningConfigQry.class);
+ WhWarningConfigQry param2 = new WhWarningConfigQry();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
/*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
FinSysTenantUser sysInfo = this.getSysInfo();
String tenantId = sysInfo.getTenantId();
@@ -184,12 +198,20 @@
@GetMapping("/getById")
public ResponseValue getById() {
WhWarningConfig param = CommonUtil.getObjFromReq(WhWarningConfig.class);
+ WhWarningConfig param2 = new WhWarningConfig();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
WhWarningConfig whWarningConfig = lWhWarningConfigService.get(param);
return ResponseValue.success(whWarningConfig);
}
@GetMapping("/getConfigList")
- public ResponseValue getConfigList(WhWarningConfig param) {
+ public ResponseValue getWarnConfigList() {
+ WhWarningConfig param = CommonUtil.getObjFromReq(WhWarningConfig.class);
+ WhWarningConfig param2 = new WhWarningConfig();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
+
if (param.getBaseWarehouseId() == null || param.getWarehouseType() == null || (param.getBaseGoodsModelsId() == null || param.getBaseGoodsTemplateId() == null)) {
return ResponseValue.error("缂哄皯蹇呰鍙傛暟");
}
diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhWarningController.java b/consum-base/src/main/java/com/consum/base/controller/LWhWarningController.java
index 585f3ea..bd64206 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhWarningController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhWarningController.java
@@ -35,6 +35,9 @@
@GetMapping("/getList")
public ResponseValue getList() {
WhWarningQry param = CommonUtil.getObjFromReq(WhWarningQry.class);
+ WhWarningQry param2 = new WhWarningQry();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
/*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/
FinSysTenantUser sysInfo = this.getSysInfo();
String tenantId = sysInfo.getTenantId();
@@ -60,6 +63,9 @@
@GetMapping("/handerChenKuCun")
public ResponseValue handerChenKuCun() {
WhWarningQry param = CommonUtil.getObjFromReq(WhWarningQry.class);
+ WhWarningQry param2 = new WhWarningQry();
+ CommonUtil.copyProperties(param, param2);
+ param = param2;
FinSysTenantUser sysInfo = this.getSysInfo();
long dealTime = DateUtils.getDateTimeNumber(System.currentTimeMillis());
diff --git a/consum-base/src/main/java/com/consum/base/core/utils/MapUtils.java b/consum-base/src/main/java/com/consum/base/core/utils/MapUtils.java
index b092d9c..a40697c 100644
--- a/consum-base/src/main/java/com/consum/base/core/utils/MapUtils.java
+++ b/consum-base/src/main/java/com/consum/base/core/utils/MapUtils.java
@@ -1,10 +1,12 @@
package com.consum.base.core.utils;
+import cn.hutool.core.util.ReflectUtil;
+import lombok.extern.slf4j.Slf4j;
+
import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
-import lombok.extern.slf4j.Slf4j;
@Slf4j
public class MapUtils {
@@ -24,8 +26,9 @@
T obj = clazz.newInstance();
for (Map.Entry<String, Object> entry : map.entrySet()) {
Field field = clazz.getDeclaredField(entry.getKey());
- field.setAccessible(true);
- field.set(obj, entry.getValue());
+// field.setAccessible(true);
+// field.set(obj, entry.getValue());
+ ReflectUtil.setFieldValue(obj, field, entry.getValue());
}
return obj;
} catch (InstantiationException | IllegalAccessException | NoSuchFieldException e) {
@@ -87,4 +90,4 @@
}
-}
\ No newline at end of file
+}
diff --git a/consum-base/src/main/java/com/consum/base/pojo/LWhFormScrappedParam.java b/consum-base/src/main/java/com/consum/base/pojo/LWhFormScrappedParam.java
index 574fd9e..42581d6 100644
--- a/consum-base/src/main/java/com/consum/base/pojo/LWhFormScrappedParam.java
+++ b/consum-base/src/main/java/com/consum/base/pojo/LWhFormScrappedParam.java
@@ -2,8 +2,9 @@
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
-import java.util.List;
import lombok.Data;
+
+import java.util.List;
@Data
@ApiModel(value = "鏂板鎶ュ簾鍗曚俊鎭�")
@@ -14,6 +15,10 @@
*/
@ApiModelProperty(value = "鏈烘瀯id")
private Long agencyId;
+
+ @ApiModelProperty(value = "閮ㄩ棬id")
+ private Long departmentId;
+
/**
* 浠撳簱缂栧彿
*/
diff --git a/consum-base/src/main/java/com/consum/base/pojo/query/LWhLedgerQry.java b/consum-base/src/main/java/com/consum/base/pojo/query/LWhLedgerQry.java
index 5e847d4..119d2ca 100644
--- a/consum-base/src/main/java/com/consum/base/pojo/query/LWhLedgerQry.java
+++ b/consum-base/src/main/java/com/consum/base/pojo/query/LWhLedgerQry.java
@@ -19,7 +19,7 @@
private Long agencyId;
@ApiModelProperty("浠撳簱绫诲瀷")
- private Long warehouseType;
+ private Short warehouseType;
@ApiModelProperty("浠撳簱id")
private Long warehouseId;
diff --git a/consum-base/src/main/java/com/consum/base/pojo/query/WhWarningQry.java b/consum-base/src/main/java/com/consum/base/pojo/query/WhWarningQry.java
index a52c402..4495408 100644
--- a/consum-base/src/main/java/com/consum/base/pojo/query/WhWarningQry.java
+++ b/consum-base/src/main/java/com/consum/base/pojo/query/WhWarningQry.java
@@ -40,6 +40,9 @@
@ApiModelProperty("鐘舵�侊紙1=鏈煡鐪嬶紱2=宸叉煡鐪嬶級")
private Integer states;
+ @ApiModelProperty("棰勮绫诲瀷锛�1=瓒呬笂闄愶紱2=瓒呬笅闄愶級")
+ private Short warningType;
+
@ApiModelProperty(value = "姣忛〉鏄剧ず鏉℃暟")
private Integer pageSize = 10;
diff --git a/consum-base/src/main/java/com/consum/base/service/FinWarehouseLedgerServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/FinWarehouseLedgerServiceImpl.java
index 664ffa8..12ed86d 100644
--- a/consum-base/src/main/java/com/consum/base/service/FinWarehouseLedgerServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/FinWarehouseLedgerServiceImpl.java
@@ -20,7 +20,8 @@
@Service
public class FinWarehouseLedgerServiceImpl extends BaseServiceImpl {
- private static String LEDGER_LIST_QUERY_PREFIX = "SELECT ware.AGENCY_NAME ,ware.WAREHOUSE_NAME ,goodsTemp.CATEGORY_NAME ,CASE goods.COST_TYPE WHEN 1 THEN 'A绫�' WHEN 2 THEN 'B绫�' WHEN 3 THEN 'C绫�' END AS cost_Type,goods.GOODS_TEMPLATE_NAME ,goods.BASE_GOODS_MODELS_NAME ,goods.UNIT unit,COUNt(goods.id) kucun FROM L_WH_GOODS goods LEFT JOIN BASE_GOODS_TEMPLATE goodsTemp ON goods.BASE_GOODS_TEMPLATE_ID=goodsTemp.id LEFT JOIN BASE_WAREHOUSE ware ON ware.id=goods.WAREHOUSE_ID where 1=1 ";
+ private String LEDGER_LIST_QUERY_PREFIX = "SELECT ware.AGENCY_NAME ,ware.WAREHOUSE_NAME ,goodsTemp.CATEGORY_NAME ,CASE goods.COST_TYPE WHEN 1 THEN 'A绫�' WHEN 2 THEN 'B绫�' WHEN 3 THEN 'C绫�' END AS cost_Type,goods.GOODS_TEMPLATE_NAME ,goods.BASE_GOODS_MODELS_NAME ,goods.UNIT unit,COUNt(goods.id) kucun FROM L_WH_GOODS goods LEFT JOIN BASE_GOODS_TEMPLATE goodsTemp ON goods.BASE_GOODS_TEMPLATE_ID=goodsTemp.id LEFT JOIN BASE_WAREHOUSE ware ON ware.id=goods.WAREHOUSE_ID where 1=1 ";
+ private String LEDGER_LIST_QUERY_GROUP = " GROUP BY ware.AGENCY_NAME,ware.WAREHOUSE_NAME,goodsTemp.CATEGORY_NAME,goods.COST_TYPE,goods.GOODS_TEMPLATE_NAME,goods.BASE_GOODS_MODELS_NAME,goods.UNIT";
public GenericPager<Map<String, Object>> ledgerList(LWhLedgerQry param) {
StringBuilder sql = new StringBuilder(LEDGER_LIST_QUERY_PREFIX);
@@ -64,7 +65,56 @@
sql.append(" AND goods.COST_TYPE=:costType");
paramts.put("costType", param.getCostType());
}
- sql.append(" GROUP BY ware.AGENCY_NAME,ware.WAREHOUSE_NAME,goodsTemp.CATEGORY_NAME,goods.COST_TYPE,goods.GOODS_TEMPLATE_NAME,goods.BASE_GOODS_MODELS_NAME,goods.UNIT");
+ sql.append(LEDGER_LIST_QUERY_GROUP);
+ return selectSplit(sql.toString(), paramts, param.getPageNum(), param.getPageSize(), new MapperUtil());
+ }
+
+ private String DEPART_LEDGER_LIST_QUERY_PREFIX = "SELECT tenant.id tenantId,tenant.NAME AS AGENCY_NAME,ware.NAME AS depart_name,goodsTemp.CATEGORY_NAME,CASE goods.COST_TYPE WHEN 1 THEN 'A绫�' WHEN 2 THEN 'B绫�' WHEN 3 THEN 'C绫�' END AS cost_Type,goods.GOODS_TEMPLATE_NAME,goods.BASE_GOODS_MODELS_NAME,goods.UNIT unit,COUNt(goods.id) kucun FROM L_WH_GOODS goods LEFT JOIN BASE_GOODS_TEMPLATE goodsTemp ON goods.BASE_GOODS_TEMPLATE_ID=goodsTemp.id LEFT JOIN fin_sys_tenant_department ware ON ware.id=goods.WAREHOUSE_ID AND goods.WAREHOUSE_TYPE=1 LEFT JOIN fin_sys_tenant tenant ON tenant.id=ware.TENANT_ID WHERE 1=1 ";
+ private String DEPART_LEDGER_LIST_QUERY_GROUP = " GROUP BY tenant.id,tenant.NAME,ware.NAME,goodsTemp.CATEGORY_NAME,goods.COST_TYPE,goods.GOODS_TEMPLATE_NAME,goods.BASE_GOODS_MODELS_NAME,goods.UNIT";
+
+ public GenericPager<Map<String, Object>> departLedgerList(LWhLedgerQry param) {
+ StringBuilder sql = new StringBuilder(DEPART_LEDGER_LIST_QUERY_PREFIX);
+ Map<String, Object> paramts = new HashMap<>();
+ //鐘舵�侊紙0=鍦ㄩ�旇皟鎷紱1=鍏ュ簱鏈垎鍙戯紱2=宸蹭笅鍙戯紱3=鎶ュ簾 4 闆舵槦鍑哄簱锛�
+ if (param.getStates() != null) {
+ sql.append(" and goods.states = :states");
+ paramts.put("states", param.getStates());
+ }
+ //鏈烘瀯
+ if (param.getAgencyId() != null) {
+ sql.append(" and left(ware.AGENCY_ID, length(:lengthAgencyId)) = :agencyId");
+ paramts.put("lengthAgencyId", param.getAgencyId());
+ paramts.put("agencyId", param.getAgencyId());
+ }
+ //浠撳簱绫诲瀷
+ if (param.getWarehouseType() != null) {
+ sql.append(" AND goods.WAREHOUSE_TYPE = :warehouseType");
+ paramts.put("warehouseType", param.getWarehouseType());
+ }
+ if (param.getWarehouseId() != null) {
+ sql.append(" AND goods.WAREHOUSE_ID = :warehouseId");
+ paramts.put("warehouseId", param.getWarehouseId());
+ }
+ //鐗╁搧鍚嶇О
+ if (StringUtils.isNotEmpty(param.getGoodsTemplateName())) {
+ sql.append(" AND goods.GOODS_TEMPLATE_NAME like :goodsTemplateName");
+ paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);
+ }
+ if (param.getGoodsTemplateId() != null) {
+ sql.append(" AND goods.BASE_GOODS_TEMPLATE_ID=:goodsTemplateId");
+ paramts.put("goodsTemplateId", param.getGoodsTemplateId());
+ }
+ //鍒嗙被
+ if (param.getCategoryId() != null) {
+ sql.append(" AND goodsTemp.CATEGORY_ID=:categoryId");
+ paramts.put("categoryId", param.getCategoryId());
+ }
+ //浠峰�肩被鍨�
+ if (param.getCostType() != null) {
+ sql.append(" AND goods.COST_TYPE=:costType");
+ paramts.put("costType", param.getCostType());
+ }
+ sql.append(DEPART_LEDGER_LIST_QUERY_GROUP);
return selectSplit(sql.toString(), paramts, param.getPageNum(), param.getPageSize(), new MapperUtil());
}
}
diff --git a/consum-base/src/main/java/com/consum/base/service/LWhGoodsService.java b/consum-base/src/main/java/com/consum/base/service/LWhGoodsService.java
index 32b6f70..cbfb40a 100644
--- a/consum-base/src/main/java/com/consum/base/service/LWhGoodsService.java
+++ b/consum-base/src/main/java/com/consum/base/service/LWhGoodsService.java
@@ -1,5 +1,6 @@
package com.consum.base.service;
+import com.consum.base.core.utils.MapperUtil;
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.apache.commons.lang3.StringUtils;
@@ -260,4 +261,16 @@
return update(sql.toString(), params.toArray());
}
+ private static String GOODS_NUM_PRICE = "SELECT t.tenantId,count(id) total_Num,count(CASE WHEN STATES=2 THEN 1 END) xia_fa_num,IFNULL(round(sum(PRICE)/1000000,2),0) total_price,IFNULL(ROUND(count(CASE WHEN STATES=2 THEN 1 END)/count(id),4),0)*100 AS zhan_you_percent,count(CASE COST_TYPE WHEN 1 THEN 1 END) a_total_Num,count(CASE COST_TYPE WHEN 2 THEN 1 END) b_total_Num,count(CASE COST_TYPE WHEN 3 THEN 1 END) c_total_Num FROM (SELECT tCangKu.tenantId,tKuCun.id,tKuCun.STATES,tKuCun.COST_TYPE,tKuCun.price FROM (SELECT tenant.id tenantId,tenant.NAME AS org_name,ware.*FROM fin_sys_tenant tenant RIGHT JOIN ( SELECT 0 WAREHOUSE_TYPE,id,AGENCY_ID,WAREHOUSE_NAME FROM BASE_WAREHOUSE UNION ALL SELECT 1 WAREHOUSE_TYPE,id,TENANT_ID AGENCY_ID,`NAME` WAREHOUSE_NAME FROM fin_sys_tenant_department) ware ON tenant.id=ware.AGENCY_ID WHERE 1=1 ";
+ private static String GOODS_NUM_PRICE_END = ") tCangKu LEFT JOIN L_WH_GOODS tKuCun ON tCangKu.WAREHOUSE_TYPE=tKuCun.WAREHOUSE_TYPE AND tCangKu.id=tKuCun.WAREHOUSE_ID AND tKuCun.STATES BETWEEN 1 AND 2) t GROUP BY t.tenantId";
+
+ //鏈烘瀯
+ public List<Map<String, Object>> getGoodsNumPrice(Long agencyId) {
+ StringBuilder sql = new StringBuilder(GOODS_NUM_PRICE);
+ Map<String, Object> paramts = new HashMap<>();
+ sql.append(" and tenant.id=:agencyId");
+ paramts.put("agencyId", agencyId);
+ return select(sql.append(GOODS_NUM_PRICE_END).toString(), paramts, new MapperUtil());
+ }
+
}
diff --git a/consum-base/src/main/java/com/consum/base/service/LWhWarningServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/LWhWarningServiceImpl.java
index a0a051d..e063677 100644
--- a/consum-base/src/main/java/com/consum/base/service/LWhWarningServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/LWhWarningServiceImpl.java
@@ -33,8 +33,8 @@
}
//鏈烘瀯
if (param.getAgencyId() != null) {
- sql.append(" and left(ware.AGENCY_ID, length(:lengthAgencyId)) = :agencyId");
- paramts.put("lengthAgencyId", param.getAgencyId());
+ sql.append(" and ware.AGENCY_ID=:agencyId");
+// paramts.put("lengthAgencyId", param.getAgencyId());
paramts.put("agencyId", param.getAgencyId());
}
//浠撳簱绫诲瀷
@@ -67,6 +67,10 @@
sql.append(" AND cate.CLASSIFICATION=':costType'");
paramts.put("costType", costType);
}
+ if (param.getWarningType() != null) {
+ sql.append(" AND wareWarn.WARNING_TYPE=:warningType");
+ paramts.put("warningType", param.getWarningType());
+ }
sql.append(" ORDER BY wareWarn.DEAL_TIME DESC ");
diff --git a/consum-model-pojo/src/main/java/com/consum/model/po/FinSysTenantUser_mapper.java b/consum-model-pojo/src/main/java/com/consum/model/po/FinSysTenantUser_mapper.java
index aaf437a..fbab27f 100644
--- a/consum-model-pojo/src/main/java/com/consum/model/po/FinSysTenantUser_mapper.java
+++ b/consum-model-pojo/src/main/java/com/consum/model/po/FinSysTenantUser_mapper.java
@@ -49,7 +49,7 @@
public static final String AgentJid = "agent_jid";
public static final String WorkgroupJid = "workgroup_jid";
public static final String ClientNumber = "client_number";
- public static final String ClientPwd = "client_pwd";
+ public static final String ClientPd = "client_pwd";
public static final String TenantName = "tenant_name";
public static final String Lv = "lv";
public static final String SupplierId = "supplier_Id";
@@ -225,7 +225,7 @@
ib.set(AgentJid, this.getAgentJid(), this.isset_agentJid);
ib.set(WorkgroupJid, this.getWorkgroupJid(), this.isset_workgroupJid);
ib.set(ClientNumber, this.getClientNumber(), this.isset_clientNumber);
- ib.set(ClientPwd, this.getClientPwd(), this.isset_clientPwd);
+ ib.set(ClientPd, this.getClientPwd(), this.isset_clientPwd);
return ib.genMapSql();
}
@@ -258,7 +258,7 @@
ub.set(AgentJid, this.getAgentJid(), this.isset_agentJid);
ub.set(WorkgroupJid, this.getWorkgroupJid(), this.isset_workgroupJid);
ub.set(ClientNumber, this.getClientNumber(), this.isset_clientNumber);
- ub.set(ClientPwd, this.getClientPwd(), this.isset_clientPwd);
+ ub.set(ClientPd, this.getClientPwd(), this.isset_clientPwd);
ub.where(this.getPkName_(), this.getPkValue_());
return ub.genMapSql();
}
@@ -292,7 +292,7 @@
ub.set(AgentJid, this.getAgentJid(), this.isset_agentJid);
ub.set(WorkgroupJid, this.getWorkgroupJid(), this.isset_workgroupJid);
ub.set(ClientNumber, this.getClientNumber(), this.isset_clientNumber);
- ub.set(ClientPwd, this.getClientPwd(), this.isset_clientPwd);
+ ub.set(ClientPd, this.getClientPwd(), this.isset_clientPwd);
return ub.genMapSql(where, parameters);
}
@@ -325,7 +325,7 @@
ub.set(AgentJid, this.getAgentJid(), this.isset_agentJid);
ub.set(WorkgroupJid, this.getWorkgroupJid(), this.isset_workgroupJid);
ub.set(ClientNumber, this.getClientNumber(), this.isset_clientNumber);
- ub.set(ClientPwd, this.getClientPwd(), this.isset_clientPwd);
+ ub.set(ClientPd, this.getClientPwd(), this.isset_clientPwd);
return ub.genArraySql(where, parameters);
}
@@ -573,7 +573,7 @@
if (columnIndex > 0) {
fin_sys_tenant_user.setClientNumber(rs.getString(columnIndex));
}
- columnIndex = resultSetUtils.findColumn(rs, FinSysTenantUser_mapper.ClientPwd);
+ columnIndex = resultSetUtils.findColumn(rs, FinSysTenantUser_mapper.ClientPd);
if (columnIndex > 0) {
fin_sys_tenant_user.setClientPwd(rs.getString(columnIndex));
}
diff --git a/deploy-jar-single/pom.xml b/deploy-jar-single/pom.xml
index f56e3cf..19e1ffe 100644
--- a/deploy-jar-single/pom.xml
+++ b/deploy-jar-single/pom.xml
@@ -95,7 +95,12 @@
<!-- <groupId>com.iplatform</groupId>-->
<!-- <artifactId>iplatform-report</artifactId>-->
<!-- </dependency>-->
-
+ <!-- 閰嶇疆鏂囦欢鍔犲瘑 -->
+ <dependency>
+ <groupId>com.github.ulisesbocchio</groupId>
+ <artifactId>jasypt-spring-boot-starter</artifactId>
+ <version>2.1.0</version>
+ </dependency>
</dependencies>
<build>
diff --git a/deploy-jar-single/src/main/java/com/consum/test/CodeGeneratorServiceTest.java b/deploy-jar-single/src/main/java/com/consum/test/CodeGeneratorServiceTest.java
index 7321ad7..9704716 100644
--- a/deploy-jar-single/src/main/java/com/consum/test/CodeGeneratorServiceTest.java
+++ b/deploy-jar-single/src/main/java/com/consum/test/CodeGeneratorServiceTest.java
@@ -1,46 +1,46 @@
-package com.consum.test;
-
-import com.consum.ConsumApplication;
-import com.consum.base.core.CodeGeneratorEnum;
-import com.consum.base.core.CodeGeneratorService;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-
-
-@RunWith(SpringRunner.class)
-@SpringBootTest(classes = {ConsumApplication.class})
-public class CodeGeneratorServiceTest {
-
- @Autowired
- private CodeGeneratorService service;
-
- @Test
- public void createWarehouseCode(){
- for (int i=0;i<5;i++){
- String code =service.createWarehouseCode();
- System.out.println(code);
- }
- }
-
+//package com.consum.test;
+//
+//import com.consum.ConsumApplication;
+//import com.consum.base.core.CodeGeneratorEnum;
+//import com.consum.base.core.CodeGeneratorService;
+//import org.junit.Test;
+//import org.junit.runner.RunWith;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.boot.test.context.SpringBootTest;
+//import org.springframework.test.context.junit4.SpringRunner;
+//
+//
+//@RunWith(SpringRunner.class)
+//@SpringBootTest(classes = {ConsumApplication.class})
+//public class CodeGeneratorServiceTest {
+//
+// @Autowired
+// private CodeGeneratorService service;
+//
// @Test
-// public void createGoodsTemplateCode(){
-// String[] prefixs = new String[] {"A","B","C","A","B"};
-// int[] leis = new int[]{1,2,2,1,2};
+// public void createWarehouseCode(){
+// for (int i=0;i<5;i++){
+// String code =service.createWarehouseCode();
+// System.out.println(code);
+// }
+// }
+//
+//// @Test
+//// public void createGoodsTemplateCode(){
+//// String[] prefixs = new String[] {"A","B","C","A","B"};
+//// int[] leis = new int[]{1,2,2,1,2};
+//// for (int i=0;i<5;i++){
+//// String code =service.createGoodsTemplateCode(prefixs[i],leis[i]);
+//// System.out.println(code);
+//// }
+//// }
+//
+// @Test
+// public void createBusinessFormCode(){
// for (int i=0;i<5;i++){
-// String code =service.createGoodsTemplateCode(prefixs[i],leis[i]);
+// String code =service.createBusinessFormCode(CodeGeneratorEnum.Transfer);
// System.out.println(code);
// }
// }
-
- @Test
- public void createBusinessFormCode(){
- for (int i=0;i<5;i++){
- String code =service.createBusinessFormCode(CodeGeneratorEnum.Transfer);
- System.out.println(code);
- }
- }
-
-}
+//
+//}
diff --git a/deploy-jar-single/src/main/java/com/consum/test/base/Base_Category.java b/deploy-jar-single/src/main/java/com/consum/test/base/Base_Category.java
index 772d042..653b689 100644
--- a/deploy-jar-single/src/main/java/com/consum/test/base/Base_Category.java
+++ b/deploy-jar-single/src/main/java/com/consum/test/base/Base_Category.java
@@ -1,37 +1,37 @@
-package com.consum.test.base;
-
-import com.consum.ConsumApplication;
-import com.consum.base.core.data.Base_CategoryService;
-import com.consum.model.po.BaseCategory;
-import com.walker.infrastructure.utils.NumberGenerator;
-import com.walker.jdbc.BaseDao;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-
-@RunWith(SpringRunner.class)
-@SpringBootTest(classes = {ConsumApplication.class})
-public class Base_Category {
- @Autowired
- private Base_CategoryService service;
-
- @Test
- public void addFirstCategory(){
- for (int ii =0;ii <10;ii++){
- Long id = NumberGenerator.getLongSequenceNumber();
- for (int i=0;i<1000;i++){
- service.addFirstCategory(id);
- }
- }
- }
- @Test
- public void addSecondCategory(){
- service.addSecondCategory(12624043866144l);
- }
- @Test
- public void addThirdCategory(){
- service.addThirdCategory(12838134761035l);
- }
-}
+//package com.consum.test.base;
+//
+//import com.consum.ConsumApplication;
+//import com.consum.base.core.data.Base_CategoryService;
+//import com.consum.model.po.BaseCategory;
+//import com.walker.infrastructure.utils.NumberGenerator;
+//import com.walker.jdbc.BaseDao;
+//import org.junit.Test;
+//import org.junit.runner.RunWith;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.boot.test.context.SpringBootTest;
+//import org.springframework.test.context.junit4.SpringRunner;
+//
+//@RunWith(SpringRunner.class)
+//@SpringBootTest(classes = {ConsumApplication.class})
+//public class Base_Category {
+// @Autowired
+// private Base_CategoryService service;
+//
+// @Test
+// public void addFirstCategory(){
+// for (int ii =0;ii <10;ii++){
+// Long id = NumberGenerator.getLongSequenceNumber();
+// for (int i=0;i<1000;i++){
+// service.addFirstCategory(id);
+// }
+// }
+// }
+// @Test
+// public void addSecondCategory(){
+// service.addSecondCategory(12624043866144l);
+// }
+// @Test
+// public void addThirdCategory(){
+// service.addThirdCategory(12838134761035l);
+// }
+//}
diff --git a/deploy-jar-single/src/main/java/com/consum/test/synchronizedCode.java b/deploy-jar-single/src/main/java/com/consum/test/synchronizedCode.java
index d27c5cd..d61d8e6 100644
--- a/deploy-jar-single/src/main/java/com/consum/test/synchronizedCode.java
+++ b/deploy-jar-single/src/main/java/com/consum/test/synchronizedCode.java
@@ -1,47 +1,47 @@
-package com.consum.test;
-
-/**
- * 娴嬭瘯澶氱嚎绋嬪苟鍙�
- */
-public class synchronizedCode implements Runnable {
-
- static synchronizedCode instance = new synchronizedCode();
- static int i = 0;
-
- static String key = "1";
-
- public static void main(String[] args) throws InterruptedException {
- for (int j=0;j<5;j++){
- Thread t1 = new Thread(instance);
- t1.start();
- }
-
- System.out.println("绾跨▼鎵ц缁撴潫");
- }
-
- @Override
- public void run() {
-
- String myKey;
- if (key == "1"){
- myKey = "def";
- key = "2";
- } else {
- myKey = "abc";
- key="1";
- }
-
- System.out.println(Thread.currentThread().getName() + ":" + myKey);
-
- synchronized (myKey){
- System.out.println(Thread.currentThread().getName() + "寮�濮嬭繍琛�");
- try {
- Thread.sleep(3000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- System.out.println("鎴戝彨"+ Thread.currentThread().getName()+"杩愯缁撴潫");
- }
- }
-}
\ No newline at end of file
+//package com.consum.test;
+//
+///**
+// * 娴嬭瘯澶氱嚎绋嬪苟鍙�
+// */
+//public class synchronizedCode implements Runnable {
+//
+// static synchronizedCode instance = new synchronizedCode();
+// static int i = 0;
+//
+// static String key = "1";
+//
+// public static void main(String[] args) throws InterruptedException {
+// for (int j=0;j<5;j++){
+// Thread t1 = new Thread(instance);
+// t1.start();
+// }
+//
+// System.out.println("绾跨▼鎵ц缁撴潫");
+// }
+//
+// @Override
+// public void run() {
+//
+// String myKey;
+// if (key == "1"){
+// myKey = "def";
+// key = "2";
+// } else {
+// myKey = "abc";
+// key="1";
+// }
+//
+// System.out.println(Thread.currentThread().getName() + ":" + myKey);
+//
+// synchronized (myKey){
+// System.out.println(Thread.currentThread().getName() + "寮�濮嬭繍琛�");
+// try {
+// Thread.sleep(3000);
+// } catch (InterruptedException e) {
+// // TODO Auto-generated catch block
+// e.printStackTrace();
+// }
+// System.out.println("鎴戝彨"+ Thread.currentThread().getName()+"杩愯缁撴潫");
+// }
+// }
+//}
diff --git a/deploy-jar-single/src/main/resources/application-dev.yml b/deploy-jar-single/src/main/resources/application-dev.yml
index 0a3dd1a..08d7122 100644
--- a/deploy-jar-single/src/main/resources/application-dev.yml
+++ b/deploy-jar-single/src/main/resources/application-dev.yml
@@ -7,7 +7,8 @@
# 鏁版嵁搴撻摼鎺�
dataBaseName: low_consum_manage_dev
username: root
- password: Bjjmy_2020
+# Bjjmy_2020
+ password: ENC(V7lFKlYcHfEzTbXsbBQhSUswgxLsbS5z)
url: jdbc:mysql://116.198.40.76:3306/${spring.datasource.dataBaseName}?useUnicode=true&characterEncoding=UTF-8&useSSL=false
# Druid杩炴帴姹�
type: com.walker.jdbc.ds.MyDruidDataSource
@@ -35,7 +36,7 @@
host: 116.198.40.76
port: 6379
database: 11
- password: Jmy2019.
+ password: ENC(C40h1dp9Q1oLqdU+JUGSBOWUfOmj/ZO4) #Jmy2019.
mvc:
pathmatch:
@@ -151,8 +152,8 @@
# - /api/**
# 瓒呯骇绠$悊鍛樺瘑鐮侊紝鍔犲瘑鍚庣殑绉樻枃
- supervisor-password: $2a$10$9lSwwUFMULR6/KhPsUbTj.0PTZfTnq0fB3OtS6PWoKAibpa8hL1cy
-
+ supervisor-password: ENC(cDkgI4dm/vDXFDsDm5KJW23i5zAAUxIUW448ReA27tmgQ83ZLgO3k/YMK5+wIiuGDKPDIXUH9/irgKTLMKl7n7mP6XRgBnOf)
+ # supervisor-password: $2a$10$9lSwwUFMULR6/KhPsUbTj.0PTZfTnq0fB3OtS6PWoKAibpa8hL1cy
# 鏄惁鍏佽閰嶇疆璺ㄥ煙鍝嶅簲澶�, true 鍚敤锛� false 涓嶅惎鐢ㄣ��2022-12-28
# 鍦℅ateway妯″紡涓紝闇�瑕佸叧闂法鍩熼厤缃紝鍥犱负缃戝叧涔熶細閰嶇疆銆�
cors-enabled: true
@@ -218,7 +219,7 @@
ip: 116.198.40.76
port: 22
user-name: mysftp
- password: Bjjmy_2020
+ password: ENC(kEQ43JzZv6yOOmbmKNLWmsU/wQKTwA9x)
private-key:
# ftp鏈嶅姟涓婇潰鐨勫瓨鍌ㄦ牴璺緞锛屽彧鑳芥槸linux璺緞
file-root: /progress/
@@ -248,4 +249,4 @@
# 閭欢閫氱煡鍙戦�佷俊鎭厤缃紝2023-04-26
mail-server: smtp.126.com
mail-from: hnzzzhsl@126.com
- mail-password: test
+ mail-password: ENC(hjRDRcQmmhpUICkAaJnXUQ==)
diff --git a/deploy-jar-single/src/main/resources/application-prod.yml b/deploy-jar-single/src/main/resources/application-prod.yml
index 28f88b7..bfbfa40 100644
--- a/deploy-jar-single/src/main/resources/application-prod.yml
+++ b/deploy-jar-single/src/main/resources/application-prod.yml
@@ -6,8 +6,8 @@
show-sql: true
# 鏁版嵁搴撻摼鎺�
username: root
- password: Bjjmy_2020
- dataBaseName: low_consum_manage_dev
+ password: ENC(Zw99rAYSpDE2VCWJjC+C8hFAOItlbiSZ)
+ dataBaseName: low_consum_manage
url: jdbc:mysql://192.200.0.49:3306/${spring.datasource.dataBaseName}?useUnicode=true&characterEncoding=UTF-8&useSSL=false
# Druid杩炴帴姹�
type: com.walker.jdbc.ds.MyDruidDataSource
@@ -35,7 +35,7 @@
host: 192.200.0.49
port: 6379
database: 11
- password: Jmy2019.
+ password: ENC(1IxlpqZ3ykMIWVknDjVydrCpK/6nccv/) #Jmy2019.
mvc:
pathmatch:
@@ -151,7 +151,8 @@
# - /api/**
# 瓒呯骇绠$悊鍛樺瘑鐮侊紝鍔犲瘑鍚庣殑绉樻枃
- supervisor-password: $2a$10$9lSwwUFMULR6/KhPsUbTj.0PTZfTnq0fB3OtS6PWoKAibpa8hL1cy
+ supervisor-password: ENC(cDkgI4dm/vDXFDsDm5KJW23i5zAAUxIUW448ReA27tmgQ83ZLgO3k/YMK5+wIiuGDKPDIXUH9/irgKTLMKl7n7mP6XRgBnOf)
+ # supervisor-password: $2a$10$9lSwwUFMULR6/KhPsUbTj.0PTZfTnq0fB3OtS6PWoKAibpa8hL1cy
# 鏄惁鍏佽閰嶇疆璺ㄥ煙鍝嶅簲澶�, true 鍚敤锛� false 涓嶅惎鐢ㄣ��2022-12-28
# 鍦℅ateway妯″紡涓紝闇�瑕佸叧闂法鍩熼厤缃紝鍥犱负缃戝叧涔熶細閰嶇疆銆�
@@ -218,7 +219,7 @@
ip: 192.200.0.28
port: 22
user-name: mysftp
- password: Jmy@2023
+ password: ENC(3o6p8lx7FWgH1Zi6gZ7ruZnt2geVGiC/)
private-key:
# ftp鏈嶅姟涓婇潰鐨勫瓨鍌ㄦ牴璺緞锛屽彧鑳芥槸linux璺緞
file-root: /lowconsum/
@@ -248,4 +249,4 @@
# 閭欢閫氱煡鍙戦�佷俊鎭厤缃紝2023-04-26
mail-server: smtp.126.com
mail-from: hnzzzhsl@126.com
- mail-password: test
+ mail-password: ENC(hjRDRcQmmhpUICkAaJnXUQ==)
diff --git a/deploy-jar-single/src/main/resources/import/depTaiZhangExpTemp.xlsx b/deploy-jar-single/src/main/resources/import/depTaiZhangExpTemp.xlsx
new file mode 100644
index 0000000..1bd3ffb
--- /dev/null
+++ b/deploy-jar-single/src/main/resources/import/depTaiZhangExpTemp.xlsx
Binary files differ
diff --git a/deploy-jar-single/src/main/resources/import/taiZhangExpTemp.xlsx b/deploy-jar-single/src/main/resources/import/taiZhangExpTemp.xlsx
index 5d99e2e..3631b7a 100644
--- a/deploy-jar-single/src/main/resources/import/taiZhangExpTemp.xlsx
+++ b/deploy-jar-single/src/main/resources/import/taiZhangExpTemp.xlsx
Binary files differ
--
Gitblit v1.9.1