diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
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 879f683..32c676b 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
@@ -1,53 +1,87 @@
package com.casic.missiles.modular.app.controller;
-import com.casic.missiles.core.base.controller.BaseController;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;;
+import com.casic.missiles.core.base.controller.ExportController;
+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.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.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+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;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends BaseController {
+public class AppWellPreController extends ExportController {
private final IAppWellPreService appWellPreService;
/**
* 预录入点位信息列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid WellPreDTO wellPreDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
}
/**
* 预录入点位信息新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
-
- /**
- * 预录入点位信息批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.add(wellPreAdd);
}
/**
* 预录入点位信息编辑
*/
@RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(wellPreAdd.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.update(wellPreAdd);
+ }
+
+ /**
+ * 预录入点位信息批量导入
+ */
+ @RequestMapping(value = "/batchImport")
@ResponseBody
- public Object update() {
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
@@ -56,8 +90,11 @@
*/
@RequestMapping(value = "/delete")
@ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appWellPreService.delete(id);
}
}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
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 879f683..32c676b 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
@@ -1,53 +1,87 @@
package com.casic.missiles.modular.app.controller;
-import com.casic.missiles.core.base.controller.BaseController;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;;
+import com.casic.missiles.core.base.controller.ExportController;
+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.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.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+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;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends BaseController {
+public class AppWellPreController extends ExportController {
private final IAppWellPreService appWellPreService;
/**
* 预录入点位信息列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid WellPreDTO wellPreDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
}
/**
* 预录入点位信息新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
-
- /**
- * 预录入点位信息批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.add(wellPreAdd);
}
/**
* 预录入点位信息编辑
*/
@RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(wellPreAdd.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.update(wellPreAdd);
+ }
+
+ /**
+ * 预录入点位信息批量导入
+ */
+ @RequestMapping(value = "/batchImport")
@ResponseBody
- public Object update() {
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
@@ -56,8 +90,11 @@
*/
@RequestMapping(value = "/delete")
@ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appWellPreService.delete(id);
}
}
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
deleted file mode 100644
index 6f7549b..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
+++ /dev/null
@@ -1,8 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProductSafe;
-
-public interface AppProductSafeMapper extends BaseMapper {
-
-}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
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 879f683..32c676b 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
@@ -1,53 +1,87 @@
package com.casic.missiles.modular.app.controller;
-import com.casic.missiles.core.base.controller.BaseController;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;;
+import com.casic.missiles.core.base.controller.ExportController;
+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.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.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+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;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends BaseController {
+public class AppWellPreController extends ExportController {
private final IAppWellPreService appWellPreService;
/**
* 预录入点位信息列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid WellPreDTO wellPreDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
}
/**
* 预录入点位信息新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
-
- /**
- * 预录入点位信息批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.add(wellPreAdd);
}
/**
* 预录入点位信息编辑
*/
@RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(wellPreAdd.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.update(wellPreAdd);
+ }
+
+ /**
+ * 预录入点位信息批量导入
+ */
+ @RequestMapping(value = "/batchImport")
@ResponseBody
- public Object update() {
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
@@ -56,8 +90,11 @@
*/
@RequestMapping(value = "/delete")
@ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appWellPreService.delete(id);
}
}
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
deleted file mode 100644
index 6f7549b..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
+++ /dev/null
@@ -1,8 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProductSafe;
-
-public interface AppProductSafeMapper extends BaseMapper {
-
-}
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
new file mode 100644
index 0000000..e50ba44
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.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.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 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
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 879f683..32c676b 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
@@ -1,53 +1,87 @@
package com.casic.missiles.modular.app.controller;
-import com.casic.missiles.core.base.controller.BaseController;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;;
+import com.casic.missiles.core.base.controller.ExportController;
+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.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.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+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;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends BaseController {
+public class AppWellPreController extends ExportController {
private final IAppWellPreService appWellPreService;
/**
* 预录入点位信息列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid WellPreDTO wellPreDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
}
/**
* 预录入点位信息新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
-
- /**
- * 预录入点位信息批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.add(wellPreAdd);
}
/**
* 预录入点位信息编辑
*/
@RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(wellPreAdd.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.update(wellPreAdd);
+ }
+
+ /**
+ * 预录入点位信息批量导入
+ */
+ @RequestMapping(value = "/batchImport")
@ResponseBody
- public Object update() {
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
@@ -56,8 +90,11 @@
*/
@RequestMapping(value = "/delete")
@ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appWellPreService.delete(id);
}
}
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
deleted file mode 100644
index 6f7549b..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
+++ /dev/null
@@ -1,8 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProductSafe;
-
-public interface AppProductSafeMapper extends BaseMapper {
-
-}
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
new file mode 100644
index 0000000..e50ba44
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.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.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/AppUserMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
index f29d19b..9a73ef8 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
@@ -2,6 +2,14 @@
import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.casic.missiles.modular.app.model.AppUser;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
public interface AppUserMapper extends BaseMapper {
+
+ @Select(" select phone " +
+ " from app_user " +
+ " where status!=3 ")
+ List getUserPhoneList();
}
diff --git a/casic-app/pom.xml b/casic-app/pom.xml
index 74d7eb2..a85d73b 100644
--- a/casic-app/pom.xml
+++ b/casic-app/pom.xml
@@ -87,6 +87,24 @@
4.3.0
+
+ cn.hutool
+ hutool-core
+ 5.7.2
+
+
+
+ com.casic
+ casic-admin-core
+ ${casic.version}
+
+
+
+ com.alibaba
+ easyexcel
+ 3.0.0-beta3
+
+
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
new file mode 100644
index 0000000..4647839
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProucteSafeController.java
@@ -0,0 +1,90 @@
+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/AppProuctionSafeController.java b/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
deleted file mode 100644
index 5b2ad70..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/controller/AppProuctionSafeController.java
+++ /dev/null
@@ -1,64 +0,0 @@
-package com.casic.missiles.modular.app.controller;
-
-
-import com.casic.missiles.core.base.controller.BaseController;
-import com.casic.missiles.core.base.response.ResponseData;
-import com.casic.missiles.modular.app.service.IAppProuctionSafeService;
-import lombok.AllArgsConstructor;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-@AllArgsConstructor
-@RestController
-@RequestMapping("/prouction/safe")
-public class AppProuctionSafeController extends BaseController {
-
- private final IAppProuctionSafeService proucteSafeService;
-
- /**
- * 安全生产分页列表
- */
- @RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/status")
- @ResponseBody
- public Object getTodaySignStatus() {
- return ResponseData.success();
- }
-
-
- /**
- * 安全生产更新
- */
- @RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产新增
- */
- @RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 安全生产详情信息
- */
- @RequestMapping(value = "/detail")
- @ResponseBody
- public Object detail() {
- return ResponseData.success();
- }
-}
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 a536e39..25a05d5 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
@@ -1,89 +1,149 @@
package com.casic.missiles.modular.app.controller;
+import cn.hutool.core.collection.CollectionUtil;
+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.ErrorResponseData;
import com.casic.missiles.core.base.response.ResponseData;
+import com.casic.missiles.core.common.constant.factory.PageFactory;
+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;
+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.AppUser;
import com.casic.missiles.modular.app.service.IAppUserService;
+import com.casic.missiles.modular.app.util.ImportExcelUtils;
import lombok.AllArgsConstructor;
+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.ResponseBody;
+import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.validation.Valid;;
+import java.util.List;
+import java.util.Objects;
@RestController
@AllArgsConstructor
@RequestMapping("/app/user")
-public class AppUserController extends BaseController {
+public class AppUserController extends BaseController {
private final IAppUserService appUserService;
/**
- * 登录之后进行绑定
+ * 账号的有效性、token暂时不加
+ * 1、获取用户信息
+ * 2、设置用户session
+ * 3、检验密码
+ * 4、正确进行相关的微信信息绑定
*/
@RequestMapping(value = "/login")
- public Object login() {
- return ResponseData.success();
+ public Object login(@RequestBody @Valid AppUserLoginDTO appUserLoginDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ AppUser appUser = appUserService.getAppUserByAccount(appUserLoginDTO.getPhone());
+ super.getSession().setAttribute("role", appUser.getRole());
+ if (appUserService.checkPassWord(appUserLoginDTO,appUser)) {
+ return appUserService.bindWechatUser(appUserLoginDTO,appUser);
+ } else {
+ throw new BusinessException(BusinessExceptionEnum.PASSWORD_ERROR);
+ }
}
/**
* 分页列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid AppUserListDTO appUserListDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appUserService.listPage(page, appUserListDTO)));
}
/**
* 新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
- /**
- * 由openId获取项目列表信息
- */
- @RequestMapping(value = "/project")
- @ResponseBody
- public Object project() {
- return ResponseData.success();
- }
-
- /**
- * 解除绑定
- */
- @RequestMapping(value = "/unbind")
- @ResponseBody
- public Object unbind() {
- return ResponseData.success();
- }
-
- /**
- * 批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.add(appUserDTO);
}
/**
* 编辑
*/
@RequestMapping(value = "/update")
- @ResponseBody
- public Object update() {
+ public Object update(@RequestBody @Valid AppUserSaveDTO appUserDTO, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(appUserDTO.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appUserService.update(appUserDTO);
+ }
+
+
+ /**
+ * 由openId获取项目列表信息
+ */
+ @RequestMapping(value = "/project")
+ public Object project(String openId) {
+ Assert.isFalse(Objects.isNull(openId), () -> {
+ throw new BusinessException(BusinessExceptionEnum.OPENID_NULL);
+ });
+ return appUserService.project(openId);
+ }
+
+ /**
+ * 解除绑定
+ */
+ @RequestMapping(value = "/unbind")
+ public Object unbind(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.unbind(id);
+ }
+
+ /**
+ * 批量导入
+ */
+ @RequestMapping(value = "/batchImport")
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
+
/**
* 删除
*/
@RequestMapping(value = "/delete")
- @ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appUserService.delete(id);
}
}
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 879f683..32c676b 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
@@ -1,53 +1,87 @@
package com.casic.missiles.modular.app.controller;
-import com.casic.missiles.core.base.controller.BaseController;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.lang.Assert;
+import com.baomidou.mybatisplus.plugins.Page;;
+import com.casic.missiles.core.base.controller.ExportController;
+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.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.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+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;
@RestController
@AllArgsConstructor
@RequestMapping("/well/pre")
-public class AppWellPreController extends BaseController {
+public class AppWellPreController extends ExportController {
private final IAppWellPreService appWellPreService;
/**
* 预录入点位信息列表
*/
@RequestMapping(value = "/listPage")
- @ResponseBody
- public Object listPage() {
- return ResponseData.success();
+ public Object listPage(@RequestBody @Valid WellPreDTO wellPreDTO, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ Page page = new PageFactory().defaultPage();
+ return ResponseData.success(super.packForBT(appWellPreService.listPage(page,wellPreDTO)));
}
/**
* 预录入点位信息新增
*/
@RequestMapping(value = "/add")
- @ResponseBody
- public Object add() {
- return ResponseData.success();
- }
-
-
- /**
- * 预录入点位信息批量导入
- */
- @RequestMapping(value = "/batchImport")
- @ResponseBody
- public Object batchImport() {
- return ResponseData.success();
+ public Object add(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.add(wellPreAdd);
}
/**
* 预录入点位信息编辑
*/
@RequestMapping(value = "/update")
+ public Object update(@RequestBody @Valid WellPreAdd wellPreAdd, BindingResult bindingResult) {
+ Assert.isFalse(Objects.isNull(wellPreAdd.getId()), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ Assert.isFalse(bindingResult.hasErrors(), () -> {
+ throw new BusinessException(CoreExceptionEnum.REQUEST_NULL.getCode(), bindingResult.getFieldError().getDefaultMessage());
+ });
+ return appWellPreService.update(wellPreAdd);
+ }
+
+ /**
+ * 预录入点位信息批量导入
+ */
+ @RequestMapping(value = "/batchImport")
@ResponseBody
- public Object update() {
+ public Object batchImport(@RequestParam("file") MultipartFile file) {
+ 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));
+ }
+ } catch (Exception e) {
+ throw new BusinessException(BusinessExceptionEnum.IMPORT_FILE_EMPTY);
+ }
return ResponseData.success();
}
@@ -56,8 +90,11 @@
*/
@RequestMapping(value = "/delete")
@ResponseBody
- public Object delete() {
- return ResponseData.success();
+ public Object delete(Long id) {
+ Assert.isFalse(Objects.isNull(id), () -> {
+ throw new BusinessException(BusinessExceptionEnum.ID_NULL);
+ });
+ return appWellPreService.delete(id);
}
}
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
deleted file mode 100644
index 6f7549b..0000000
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProductSafeMapper.java
+++ /dev/null
@@ -1,8 +0,0 @@
-package com.casic.missiles.modular.app.dao;
-
-import com.baomidou.mybatisplus.mapper.BaseMapper;
-import com.casic.missiles.modular.app.model.AppProductSafe;
-
-public interface AppProductSafeMapper extends BaseMapper {
-
-}
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
new file mode 100644
index 0000000..e50ba44
--- /dev/null
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppProducteSafeMapper.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.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/AppUserMapper.java b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
index f29d19b..9a73ef8 100644
--- a/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
+++ b/casic-app/src/main/java/com/casic/missiles/modular/app/dao/AppUserMapper.java
@@ -2,6 +2,14 @@
import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.casic.missiles.modular.app.model.AppUser;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
public interface AppUserMapper extends BaseMapper {
+
+ @Select(" select phone " +
+ " from app_user " +
+ " where status!=3 ")
+ List getUserPhoneList();
}
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 b3e0014..5eb7275 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,18 @@
import com.baomidou.mybatisplus.mapper.BaseMapper;
import com.casic.missiles.modular.app.model.WellPreAdd;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
public interface WellPreAddMapper extends BaseMapper {
+
+ @Select(" SELECT ID as projectName,project_name AS projectName " +
+ " FROM product_project ")
+ List