diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
index 25a05d5..cff72a3 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
@@ -7,6 +7,7 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.user.AppUserListDTO;
import com.casic.missiles.modular.app.dto.user.AppUserLoginDTO;
import com.casic.missiles.modular.app.dto.user.AppUserSaveDTO;
@@ -15,8 +16,8 @@
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -25,8 +26,8 @@
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@@ -49,8 +50,8 @@
});
AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
super.getSession().setAttribute("role", appUser.getRole());
- if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
- return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ if (appUserService.checkPassWord(appUserLoginDTO, appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO, appUser);
} else {
throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
}
@@ -121,12 +122,36 @@
*/
@RequestMapping(value = "/batchImport")
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("手机号", "phone");
+ mapper.put("密码", "password");
+ mapper.put("姓名", "name");
+ mapper.put("角色", "role");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(AppUser.class, file, null, null);
- List list = appUserService.batchImport(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, AppUser.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ AppUser appUser = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(appUser.getPhone(), appUser.getPassword())) {
+ results.add(appUser);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appUserService.batchImport(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
index 25a05d5..cff72a3 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
@@ -7,6 +7,7 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.user.AppUserListDTO;
import com.casic.missiles.modular.app.dto.user.AppUserLoginDTO;
import com.casic.missiles.modular.app.dto.user.AppUserSaveDTO;
@@ -15,8 +16,8 @@
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -25,8 +26,8 @@
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@@ -49,8 +50,8 @@
});
AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
super.getSession().setAttribute("role", appUser.getRole());
- if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
- return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ if (appUserService.checkPassWord(appUserLoginDTO, appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO, appUser);
} else {
throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
}
@@ -121,12 +122,36 @@
*/
@RequestMapping(value = "/batchImport")
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("手机号", "phone");
+ mapper.put("密码", "password");
+ mapper.put("姓名", "name");
+ mapper.put("角色", "role");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(AppUser.class, file, null, null);
- List list = appUserService.batchImport(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, AppUser.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ AppUser appUser = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(appUser.getPhone(), appUser.getPassword())) {
+ results.add(appUser);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appUserService.batchImport(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
index 32c676b..7932aaf 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
@@ -7,28 +7,30 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.WellPreDTO;
import com.casic.missiles.modular.app.enums.BusinessException;
import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.WellPreAdd;
import com.casic.missiles.modular.app.service.IAppWellPreService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends ExportController {
+public class AppWellPreController extends ExportController {
- private final IAppWellPreService appWellPreService;
+ private final IAppWellPreService appWellPreService;
+
/**
* 预录入点位信息列表
*/
@@ -38,7 +40,7 @@
throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
});
Page page = new PageFactory().defaultPage();
- return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page, wellPreDTO)));
}
/**
@@ -70,14 +72,37 @@
* 预录入点位信息批量导入
*/
@RequestMapping(value = "/batchImport")
- @ResponseBody
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("点位编号", "wellCode");
+ mapper.put("点位名称", "wellName");
+ mapper.put("点位类型", "wellTypeName");
+ mapper.put("位置信息", "position");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(WellPreAdd.class, file, null, null);
- List list = appWellPreService.addWellPreBatch(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, WellPreAdd.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ WellPreAdd wellPreAdd = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(wellPreAdd.getWellCode(), wellPreAdd.getWellTypeName())) {
+ results.add(wellPreAdd);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appWellPreService.addWellPreBatch(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
index 25a05d5..cff72a3 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
@@ -7,6 +7,7 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.user.AppUserListDTO;
import com.casic.missiles.modular.app.dto.user.AppUserLoginDTO;
import com.casic.missiles.modular.app.dto.user.AppUserSaveDTO;
@@ -15,8 +16,8 @@
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -25,8 +26,8 @@
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@@ -49,8 +50,8 @@
});
AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
super.getSession().setAttribute("role", appUser.getRole());
- if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
- return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ if (appUserService.checkPassWord(appUserLoginDTO, appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO, appUser);
} else {
throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
}
@@ -121,12 +122,36 @@
*/
@RequestMapping(value = "/batchImport")
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("手机号", "phone");
+ mapper.put("密码", "password");
+ mapper.put("姓名", "name");
+ mapper.put("角色", "role");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(AppUser.class, file, null, null);
- List list = appUserService.batchImport(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, AppUser.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ AppUser appUser = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(appUser.getPhone(), appUser.getPassword())) {
+ results.add(appUser);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appUserService.batchImport(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
index 32c676b..7932aaf 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
@@ -7,28 +7,30 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.WellPreDTO;
import com.casic.missiles.modular.app.enums.BusinessException;
import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.WellPreAdd;
import com.casic.missiles.modular.app.service.IAppWellPreService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends ExportController {
+public class AppWellPreController extends ExportController {
- private final IAppWellPreService appWellPreService;
+ private final IAppWellPreService appWellPreService;
+
/**
* 预录入点位信息列表
*/
@@ -38,7 +40,7 @@
throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
});
Page page = new PageFactory().defaultPage();
- return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page, wellPreDTO)));
}
/**
@@ -70,14 +72,37 @@
* 预录入点位信息批量导入
*/
@RequestMapping(value = "/batchImport")
- @ResponseBody
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("点位编号", "wellCode");
+ mapper.put("点位名称", "wellName");
+ mapper.put("点位类型", "wellTypeName");
+ mapper.put("位置信息", "position");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(WellPreAdd.class, file, null, null);
- List list = appWellPreService.addWellPreBatch(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, WellPreAdd.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ WellPreAdd wellPreAdd = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(wellPreAdd.getWellCode(), wellPreAdd.getWellTypeName())) {
+ results.add(wellPreAdd);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appWellPreService.addWellPreBatch(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
new file mode 100644
index 0000000..27e9adb
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
@@ -0,0 +1,11 @@
+package com.casic.missiles.modular.app.dao;
+
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import org.apache.ibatis.annotations.Param;
+
+public interface AppProductSafeMapper extends BaseMapper {
+
+ String getTodaySignStatus(@Param("openId") String openId);
+
+}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
index 25a05d5..cff72a3 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
@@ -7,6 +7,7 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.user.AppUserListDTO;
import com.casic.missiles.modular.app.dto.user.AppUserLoginDTO;
import com.casic.missiles.modular.app.dto.user.AppUserSaveDTO;
@@ -15,8 +16,8 @@
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -25,8 +26,8 @@
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@@ -49,8 +50,8 @@
});
AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
super.getSession().setAttribute("role", appUser.getRole());
- if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
- return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ if (appUserService.checkPassWord(appUserLoginDTO, appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO, appUser);
} else {
throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
}
@@ -121,12 +122,36 @@
*/
@RequestMapping(value = "/batchImport")
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("手机号", "phone");
+ mapper.put("密码", "password");
+ mapper.put("姓名", "name");
+ mapper.put("角色", "role");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(AppUser.class, file, null, null);
- List list = appUserService.batchImport(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, AppUser.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ AppUser appUser = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(appUser.getPhone(), appUser.getPassword())) {
+ results.add(appUser);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appUserService.batchImport(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
index 32c676b..7932aaf 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
@@ -7,28 +7,30 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.WellPreDTO;
import com.casic.missiles.modular.app.enums.BusinessException;
import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.WellPreAdd;
import com.casic.missiles.modular.app.service.IAppWellPreService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends ExportController {
+public class AppWellPreController extends ExportController {
- private final IAppWellPreService appWellPreService;
+ private final IAppWellPreService appWellPreService;
+
/**
* 预录入点位信息列表
*/
@@ -38,7 +40,7 @@
throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
});
Page page = new PageFactory().defaultPage();
- return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page, wellPreDTO)));
}
/**
@@ -70,14 +72,37 @@
* 预录入点位信息批量导入
*/
@RequestMapping(value = "/batchImport")
- @ResponseBody
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("点位编号", "wellCode");
+ mapper.put("点位名称", "wellName");
+ mapper.put("点位类型", "wellTypeName");
+ mapper.put("位置信息", "position");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(WellPreAdd.class, file, null, null);
- List list = appWellPreService.addWellPreBatch(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, WellPreAdd.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ WellPreAdd wellPreAdd = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(wellPreAdd.getWellCode(), wellPreAdd.getWellTypeName())) {
+ results.add(wellPreAdd);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appWellPreService.addWellPreBatch(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
new file mode 100644
index 0000000..27e9adb
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
@@ -0,0 +1,11 @@
+package com.casic.missiles.modular.app.dao;
+
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import org.apache.ibatis.annotations.Param;
+
+public interface AppProductSafeMapper extends BaseMapper {
+
+ String getTodaySignStatus(@Param("openId") String openId);
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java
deleted file mode 100644
index e50ba44..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java
+++ /dev/null
@@ -1,11 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import org.apache.ibatis.annotations.Param;
-
-public interface AppProducteSafeMapper extends BaseMapper {
-
- String getTodaySignStatus(@Param("openId") String openId);
-
-}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index a85d73b..ad85283 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -22,6 +22,7 @@
casic-core
${casic.version}
+
com.casic
casic-admin-support
@@ -45,11 +46,6 @@
org.springframework.boot
- spring-boot-starter-web
-
-
-
- org.springframework.boot
spring-boot-starter-validation
@@ -88,12 +84,6 @@
- cn.hutool
- hutool-core
- 5.7.2
-
-
-
com.casic
casic-admin-core
${casic.version}
@@ -105,6 +95,19 @@
3.0.0-beta3
+
+ org.springframework.boot
+ spring-boot-starter-web
+ 2.4.5
+ provided
+
+
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
new file mode 100644
index 0000000..d0c8d6e
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProductSafeController.java
@@ -0,0 +1,94 @@
+package com.casic.missiles.modular.app.controller;
+
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.casic.missiles.core.base.controller.BaseController;
+import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
+import com.casic.missiles.modular.app.enums.BusinessException;
+import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
+import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import com.casic.missiles.modular.app.service.IAppProductSafeService;
+import lombok.AllArgsConstructor;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import java.util.Objects;
+
+/**
+ * @author cz
+ */
+@AllArgsConstructor
+@RestController
+@RequestMapping("/product/safe")
+public class AppProductSafeController extends BaseController {
+
+ private final IAppProductSafeService proucteSafeService;
+
+ /**
+ * 安全生产分页列表
+ */
+ @RequestMapping(value = "/listPage")
+ public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ page= proucteSafeService.listPage(page,proucteSafeDTO);
+ return ResponseData.success(super.packForBT(page));
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/status")
+ public Object getTodaySignStatus(String openId) {
+ Assert.isFalse(StringUtils.isEmpty(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return proucteSafeService.getTodaySignStatus(openId);
+ }
+
+ /**
+ * 安全生产更新
+ */
+ @RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.update(appProductSafe);
+ }
+
+ /**
+ * 安全生产新增
+ */
+ @RequestMapping(value = "/add")
+ public Object add(@RequestBody @Valid AppProductSafe appProductSafe, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return proucteSafeService.add(appProductSafe);
+ }
+
+ /**
+ * 安全生产详情信息
+ */
+ @RequestMapping(value = "/detail")
+ public Object detail(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return proucteSafeService.detail(id);
+ }
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
deleted file mode 100644
index 4647839..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
+++ /dev/null
@@ -1,90 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import cn.hutool.core.lang.Assert;
-import com.baomidou.mybatisplus.plugins.Page;
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.common.constant.factory.PageFactory;
-import com.casic.missiles.modular.app.dto.ProucteSafeDTO;
-import com.casic.missiles.modular.app.enums.BusinessException;
-import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
-import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import com.casic.missiles.modular.app.service.IAppProucteSafeService;
-import lombok.AllArgsConstructor;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-import java.util.Objects;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProucteSafeController extends BaseController {
-
- private final IAppProucteSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- public Object listPage(@RequestBody @Valid ProucteSafeDTO proucteSafeDTO, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- Page page = new PageFactory().defaultPage();
- return proucteSafeService.listPage(page,proucteSafeDTO);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- public Object getTodaySignStatus(String openId) {
- Assert.isFalse(StringUtils.isEmpty(openId), () -> {
- throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
- });
- return proucteSafeService.getTodaySignStatus(openId);
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- public Object update(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(Objects.isNull(appProductSafe.getId()), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.update(appProductSafe);
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- public Object add(@RequestBody @Valid AppProducteSafe appProductSafe, BindingResult bindingResult) {
- Assert.isFalse(bindingResult.hasErrors(), () -> {
- throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
- });
- return proucteSafeService.add(appProductSafe);
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- public Object detail(Long id) {
- Assert.isFalse(Objects.isNull(id), () -> {
- throw new BusinessException(BusinessExceptionEnum.ID_NULL);
- });
- return proucteSafeService.detail(id);
- }
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
index 25a05d5..cff72a3 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppUserController.java
@@ -7,6 +7,7 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.user.AppUserListDTO;
import com.casic.missiles.modular.app.dto.user.AppUserLoginDTO;
import com.casic.missiles.modular.app.dto.user.AppUserSaveDTO;
@@ -15,8 +16,8 @@
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -25,8 +26,8 @@
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@@ -49,8 +50,8 @@
});
AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
super.getSession().setAttribute("role", appUser.getRole());
- if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
- return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ if (appUserService.checkPassWord(appUserLoginDTO, appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO, appUser);
} else {
throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
}
@@ -121,12 +122,36 @@
*/
@RequestMapping(value = "/batchImport")
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("手机号", "phone");
+ mapper.put("密码", "password");
+ mapper.put("姓名", "name");
+ mapper.put("角色", "role");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(AppUser.class, file, null, null);
- List list = appUserService.batchImport(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, AppUser.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ AppUser appUser = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(appUser.getPhone(), appUser.getPassword())) {
+ results.add(appUser);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appUserService.batchImport(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
index 32c676b..7932aaf 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppWellPreController.java
@@ -7,28 +7,30 @@
import com.casic.missiles.core.base.response.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
import com.casic.missiles.core.common.constant.factory.PageFactory;
+import com.casic.missiles.core.util.ToolUtil;
import com.casic.missiles.modular.app.dto.WellPreDTO;
import com.casic.missiles.modular.app.enums.BusinessException;
import com.casic.missiles.modular.app.enums.BusinessExceptionEnum;
import com.casic.missiles.modular.app.enums.CoreExceptionEnum;
import com.casic.missiles.modular.app.model.WellPreAdd;
import com.casic.missiles.modular.app.service.IAppWellPreService;
-import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+import org.hswebframework.expands.office.excel.ExcelIO;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
-import java.util.List;
-import java.util.Objects;
+import java.io.InputStream;
+import java.util.*;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends ExportController {
+public class AppWellPreController extends ExportController {
- private final IAppWellPreService appWellPreService;
+ private final IAppWellPreService appWellPreService;
+
/**
* 预录入点位信息列表
*/
@@ -38,7 +40,7 @@
throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
});
Page page = new PageFactory().defaultPage();
- return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page, wellPreDTO)));
}
/**
@@ -70,14 +72,37 @@
* 预录入点位信息批量导入
*/
@RequestMapping(value = "/batchImport")
- @ResponseBody
public Object batchImport(@RequestParam("file") MultipartFile file) {
+ List results = new ArrayList<>();
+ //设置表头与字段映射,可通过反射获取
+ Map mapper = new HashMap<>();
+ mapper.put("点位编号", "wellCode");
+ mapper.put("点位名称", "wellName");
+ mapper.put("点位类型", "wellTypeName");
+ mapper.put("位置信息", "position");
+ mapper.put("所属项目", "projectName");
try {
- List results = ImportExcelUtils.importExcel(WellPreAdd.class, file, null, null);
- List list = appWellPreService.addWellPreBatch(results);
- if (!CollectionUtil.isEmpty(list)) {
- //获取第校验报错信息
- return new ErrorResponseData(list.get(0));
+
+ try (InputStream in = file.getInputStream()) {
+ ExcelIO.read(in, mapper, WellPreAdd.class, (row) -> {
+ //仅读取第一个sheet
+ if (row.getSheet() == 0) {
+ if (row.getResult() != null) {
+ WellPreAdd wellPreAdd = row.getResult();
+ //过滤设备编号及设备名称都为空的数据 (判定为空行不导入该行)
+ if (!ToolUtil.isAllEmpty(wellPreAdd.getWellCode(), wellPreAdd.getWellTypeName())) {
+ results.add(wellPreAdd);
+ }
+ }
+ } else {
+ row.shutdown();
+ }
+ });
+ List list = appWellPreService.addWellPreBatch(results);
+ if (!CollectionUtil.isEmpty(list)) {
+ //获取第校验报错信息
+ return new ErrorResponseData(list.get(0));
+ }
}
} catch (Exception e) {
throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
new file mode 100644
index 0000000..27e9adb
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
@@ -0,0 +1,11 @@
+package com.casic.missiles.modular.app.dao;
+
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import com.casic.missiles.modular.app.model.AppProductSafe;
+import org.apache.ibatis.annotations.Param;
+
+public interface AppProductSafeMapper extends BaseMapper {
+
+ String getTodaySignStatus(@Param("openId") String openId);
+
+}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java
deleted file mode 100644
index e50ba44..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.java
+++ /dev/null
@@ -1,11 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProducteSafe;
-import org.apache.ibatis.annotations.Param;
-
-public interface AppProducteSafeMapper extends BaseMapper {
-
- String getTodaySignStatus(@Param("openId") String openId);
-
-}
diff --git a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/WellPreAddMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/WellPreAddMapper.java
index 5eb7275..75f7118 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/WellPreAddMapper.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/WellPreAddMapper.java
@@ -2,6 +2,7 @@
import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.casic.missiles.modular.app.model.WellPreAdd;
+import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.util.List;
@@ -9,11 +10,8 @@
public interface WellPreAddMapper extends BaseMapper {
- @Select(" SELECT ID as projectName,project_name AS projectName " +
- " FROM product_project ")
- List