From 41e84c3bf3baa9f9f91bbb5343945f0032ae960d Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期六, 11 三月 2023 17:36:43 +0800 Subject: [PATCH] 新增加司机端接口 --- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ALiApiUtil.java | 1 driver/guns-admin/src/main/resources/application.yml | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PayMoneyUtil.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemConfigController.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/CommercialMapper.xml | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/constant/factory/ConstantFactory.java | 4 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java | 159 +++- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinServiceImpl.java | 5 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemMessageService.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/HtmlController.java | 50 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ChinaMobileUtil.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java | 187 ++++ driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/OrderMapper.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemBulletinUserMapper.xml | 5 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/check/PermissionCheckFactory.java | 2 driver/guns-generator/pom.xml | 4 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/MainContentServiceImpl.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/CommercialWarpper.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AppUser.java | 10 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/aspect/ServiceLogAspect.java | 79 +- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/YouTuiDriverServiceImpl.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/JoiningRequirementsServiceImpl.java | 15 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/SystemMessageWarpper.java | 7 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemMessageMapper.xml | 6 driver/guns-core/src/main/java/com/supersavedriving/driver/core/util/Convert.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AccountChangeDetail.java | 60 + driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/WebConfig.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/HtmlMapper.xml | 12 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DictServiceImpl.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/controller/CodeController.java | 4 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/ImgController.java | 5 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverWorkController.java | 22 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/AccountChangeDetailServiceImpl.java | 30 driver/guns-admin/src/main/resources/logback-spring.xml | 22 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/MainContentMapper.java | 7 driver/guns-admin/src/main/java/com/supersavedriving/driver/config/SwaggerConfig.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Commercial.java | 5 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinUserMapper.java | 8 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapConfig.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/annotion/ServiceLog.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Html.java | 38 + driver/guns-admin/src/main/java/com/supersavedriving/driver/config/properties/GunsProperties.java | 8 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemMessageServiceImpl.java | 9 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java | 9 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfoWarpper.java | 40 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemBulletinController.java | 16 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java | 159 +++ driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IMainContentService.java | 7 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/CommercialController.java | 15 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IOrderService.java | 4 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinMapper.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/HtmlServiceImpl.java | 16 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/httpClinet/HttpClientUtil.java | 1 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ResultUtil.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapUtil.java | 8 driver/guns-core/src/main/java/com/supersavedriving/driver/core/mutidatasource/aop/MultiSourceExAop.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/factory/ShiroFactroy.java | 2 driver/guns-core/pom.xml | 2 driver/guns-admin/src/test/java/com/supersavedriving/driver/GunsApplicationTest.java | 0 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/log/factory/LogTaskFactory.java | 2 driver/guns-generator/src/main/java/com/supersavedriving/driver/generator/engine/base/AbstractTemplateEngine.java | 1 driver/guns-admin/pom.xml | 6 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemMessageMapper.java | 9 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinUserService.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/BeetlConfig.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/exception/BizExceptionEnum.java | 6 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/OrderController.java | 108 +- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/JoiningRequirements.java | 44 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialServiceImpl.java | 3 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/aop/GlobalExceptionHandler.java | 28 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/factory/DefaultTemplateFactory.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AccountChangeDetailMapper.xml | 16 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/MainContentController.java | 60 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/MainContent.java | 45 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemMessageController.java | 74 + driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/JoiningRequirementsMapper.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/AccountChangeDetailMapper.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IDriverService.java | 27 driver/guns-admin/src/main/java/com/supersavedriving/driver/GunsApplication.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinService.java | 8 driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/ShiroConfig.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialUserEjectServiceImpl.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/ResponseWarpper.java | 5 driver/guns-admin/src/main/java/com/supersavedriving/driver/core/intercept/RestApiInteceptor.java | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverWorkServiceImpl.java | 22 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/JoiningRequirementsMapper.xml | 13 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/RedisUtil.java | 27 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/HtmlMapper.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfo.java | 24 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IAccountChangeDetailService.java | 19 driver/guns-core/src/main/java/com/supersavedriving/driver/core/support/BeanKit.java | 2 driver/guns-core/src/main/resources/default-config.properties | 2 /dev/null | 373 ---------- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/MainContentMapper.xml | 13 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IHtmlService.java | 11 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinUserServiceImpl.java | 15 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AppUserMapper.xml | 2 driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IJoiningRequirementsService.java | 11 99 files changed, 1,417 insertions(+), 718 deletions(-) diff --git a/driver/guns-admin/pom.xml b/driver/guns-admin/pom.xml index 7d705ec..ce7f133 100644 --- a/driver/guns-admin/pom.xml +++ b/driver/guns-admin/pom.xml @@ -3,7 +3,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-parent</artifactId> <version>1.0.0</version> <relativePath>../pom.xml</relativePath> @@ -26,11 +26,11 @@ <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency> <dependency> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-core</artifactId> </dependency> <dependency> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-generator</artifactId> </dependency> diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/GunsApplication.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/GunsApplication.java index 4e73d12..30e1ded 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/GunsApplication.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/GunsApplication.java @@ -4,6 +4,7 @@ import org.apache.http.config.SocketConfig; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; +import org.mybatis.spring.annotation.MapperScan; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.SpringApplication; @@ -29,6 +30,7 @@ @SpringBootApplication @EnableScheduling//开启定时任务 @EnableTransactionManagement//启动事务功能 +@MapperScan("com.supersavedriving.driver.modular.system.dao") public class GunsApplication { private final static Logger logger = LoggerFactory.getLogger(GunsApplication.class); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/SwaggerConfig.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/SwaggerConfig.java index 679685d..8436c9c 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/SwaggerConfig.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/SwaggerConfig.java @@ -37,7 +37,7 @@ private ApiInfo apiInfo() { return new ApiInfoBuilder() .title("超省新代驾") - .description("所有接口前需要加 /user 前缀,例如:/user/base/agreement/queryByType <br>" + + .description("所有接口前需要加 /driver 前缀,例如:/driver/base/agreement/queryByType <br>" + "所有以 /api/*** 路径的接口需要上传签名参数sign") // .termsOfServiceUrl("http://git.oschina.net/naan1993/guns") .contact("stylefeng") diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/properties/GunsProperties.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/properties/GunsProperties.java index 3cb83df..8d45b60 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/properties/GunsProperties.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/properties/GunsProperties.java @@ -1,12 +1,10 @@ package com.supersavedriving.driver.config.properties; +import com.supersavedriving.driver.core.util.ToolUtil; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.stereotype.Component; import java.io.File; - -import static com.supersavedriving.driver.core.util.ToolUtil.getTempPath; -import static com.supersavedriving.driver.core.util.ToolUtil.isEmpty; /** * guns项目配置 @@ -42,8 +40,8 @@ public String getFileUploadPath() { //如果没有写文件上传路径,保存到临时目录 - if (isEmpty(fileUploadPath)) { - return getTempPath(); + if (ToolUtil.isEmpty(fileUploadPath)) { + return ToolUtil.getTempPath(); } else { //判断有没有结尾符,没有得加上 if (!fileUploadPath.endsWith(File.separator)) { diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/BeetlConfig.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/BeetlConfig.java index 855a162..ab1b758 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/BeetlConfig.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/BeetlConfig.java @@ -1,7 +1,7 @@ package com.supersavedriving.driver.config.web; -import com.supersavedriving.driver.config.properties.BeetlProperties; import com.supersavedriving.driver.core.beetl.BeetlConfiguration; +import com.supersavedriving.driver.config.properties.BeetlProperties; import org.beetl.core.resource.ClasspathResourceLoader; import org.beetl.ext.spring.BeetlSpringViewResolver; import org.springframework.beans.factory.annotation.Autowired; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/ShiroConfig.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/ShiroConfig.java index 008b4ad..a2678c3 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/ShiroConfig.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/ShiroConfig.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.config.web; -import com.supersavedriving.driver.config.properties.GunsProperties; import com.supersavedriving.driver.core.intercept.GunsUserFilter; import com.supersavedriving.driver.core.shiro.ShiroDbRealm; +import com.supersavedriving.driver.config.properties.GunsProperties; import org.apache.shiro.cache.CacheManager; import org.apache.shiro.cache.ehcache.EhCacheManager; import org.apache.shiro.codec.Base64; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/WebConfig.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/WebConfig.java index a67fb5e..877c1eb 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/WebConfig.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/config/web/WebConfig.java @@ -7,9 +7,9 @@ import com.alibaba.druid.support.spring.stat.DruidStatInterceptor; import com.google.code.kaptcha.impl.DefaultKaptcha; import com.google.code.kaptcha.util.Config; -import com.supersavedriving.driver.config.properties.GunsProperties; import com.supersavedriving.driver.core.intercept.RestApiInteceptor; import com.supersavedriving.driver.core.listener.ConfigListener; +import com.supersavedriving.driver.config.properties.GunsProperties; import com.supersavedriving.driver.core.xss.XssFilter; import org.springframework.aop.Advisor; import org.springframework.aop.support.DefaultPointcutAdvisor; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/aop/GlobalExceptionHandler.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/aop/GlobalExceptionHandler.java index c6311a0..4345012 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/aop/GlobalExceptionHandler.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/aop/GlobalExceptionHandler.java @@ -7,23 +7,19 @@ import com.supersavedriving.driver.core.log.LogManager; import com.supersavedriving.driver.core.log.factory.LogTaskFactory; import com.supersavedriving.driver.core.shiro.ShiroKit; +import com.supersavedriving.driver.core.support.HttpKit; import org.apache.shiro.authc.AuthenticationException; import org.apache.shiro.authc.CredentialsException; import org.apache.shiro.authc.DisabledAccountException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.core.annotation.Order; import org.springframework.http.HttpStatus; import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.ControllerAdvice; import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.ResponseStatus; import java.lang.reflect.UndeclaredThrowableException; - -import static com.supersavedriving.driver.core.support.HttpKit.getIp; -import static com.supersavedriving.driver.core.support.HttpKit.getRequest; /** * 全局的的异常拦截器(拦截所有的控制器)(带有@RequestMapping注解的方法上都会拦截) @@ -31,8 +27,8 @@ * @author fengshuonan * @date 2016年11月12日 下午3:19:56 */ -@ControllerAdvice -@Order(-1) +//@ControllerAdvice +//@Order(-1) public class GlobalExceptionHandler { private Logger log = LoggerFactory.getLogger(this.getClass()); @@ -45,7 +41,7 @@ @ResponseBody public ErrorTip notFount(GunsException e) { LogManager.me().executeLog(LogTaskFactory.exceptionLog(ShiroKit.getUser().getId(), e)); - getRequest().setAttribute("tip", e.getMessage()); + HttpKit.getRequest().setAttribute("tip", e.getMessage()); log.error("业务异常:", e); return new ErrorTip(e.getCode(), e.getMessage()); } @@ -66,8 +62,8 @@ @ExceptionHandler(DisabledAccountException.class) @ResponseStatus(HttpStatus.UNAUTHORIZED) public String accountLocked(DisabledAccountException e, Model model) { - String username = getRequest().getParameter("username"); - LogManager.me().executeLog(LogTaskFactory.loginLog(username, "账号被冻结", getIp())); + String username = HttpKit.getRequest().getParameter("username"); + LogManager.me().executeLog(LogTaskFactory.loginLog(username, "账号被冻结", HttpKit.getIp())); model.addAttribute("tips", "账号被冻结"); return "/login.html"; } @@ -78,8 +74,8 @@ @ExceptionHandler(CredentialsException.class) @ResponseStatus(HttpStatus.UNAUTHORIZED) public String credentials(CredentialsException e, Model model) { - String username = getRequest().getParameter("username"); - LogManager.me().executeLog(LogTaskFactory.loginLog(username, "账号密码错误", getIp())); + String username = HttpKit.getRequest().getParameter("username"); + LogManager.me().executeLog(LogTaskFactory.loginLog(username, "账号密码错误", HttpKit.getIp())); model.addAttribute("tips", "账号密码错误"); return "/login.html"; } @@ -90,8 +86,8 @@ @ExceptionHandler(InvalidKaptchaException.class) @ResponseStatus(HttpStatus.BAD_REQUEST) public String credentials(InvalidKaptchaException e, Model model) { - String username = getRequest().getParameter("username"); - LogManager.me().executeLog(LogTaskFactory.loginLog(username, "验证码错误", getIp())); + String username = HttpKit.getRequest().getParameter("username"); + LogManager.me().executeLog(LogTaskFactory.loginLog(username, "验证码错误", HttpKit.getIp())); model.addAttribute("tips", "验证码错误"); return "/login.html"; } @@ -103,7 +99,7 @@ @ResponseStatus(HttpStatus.UNAUTHORIZED) @ResponseBody public ErrorTip credentials(UndeclaredThrowableException e) { - getRequest().setAttribute("tip", "权限异常"); + HttpKit.getRequest().setAttribute("tip", "权限异常"); log.error("权限异常!", e); return new ErrorTip(BizExceptionEnum.NO_PERMITION.getCode(), BizExceptionEnum.NO_PERMITION.getMessage()); } @@ -116,7 +112,7 @@ @ResponseBody public ErrorTip notFount(RuntimeException e) { LogManager.me().executeLog(LogTaskFactory.exceptionLog(ShiroKit.getUser().getId(), e)); - getRequest().setAttribute("tip", "服务器未知运行时异常"); + HttpKit.getRequest().setAttribute("tip", "服务器未知运行时异常"); log.error("运行时异常:", e); return new ErrorTip(BizExceptionEnum.SERVER_ERROR.getCode(), BizExceptionEnum.SERVER_ERROR.getMessage()); } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/annotion/ServiceLog.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/annotion/ServiceLog.java index 8459524..cb4737c 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/annotion/ServiceLog.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/annotion/ServiceLog.java @@ -1,6 +1,5 @@ package com.supersavedriving.driver.core.common.annotion; -import com.supersavedriving.driver.modular.system.warpper.ResponseWarpper; import java.lang.annotation.*; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/aspect/ServiceLogAspect.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/aspect/ServiceLogAspect.java index fdd682f..8a848e8 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/aspect/ServiceLogAspect.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/aspect/ServiceLogAspect.java @@ -13,8 +13,8 @@ import java.lang.reflect.Method; import java.lang.reflect.Parameter; -@Aspect -@Component +//@Aspect +//@Component public class ServiceLogAspect { Logger logger = LoggerFactory.getLogger("ServiceLog"); @@ -31,42 +31,45 @@ @Around("serviceLog()") @SuppressWarnings("unchecked") public Object around(ProceedingJoinPoint joinPoint) throws Throwable { - long starTime = System.currentTimeMillis(); - //通过反射获取被调用方法的Class - Class type = joinPoint.getSignature().getDeclaringType(); - //获取类名 - String typeName = type.getSimpleName(); - //方法名 - String methodName = joinPoint.getSignature().getName(); - //获取参数列表 - Object[] args = joinPoint.getArgs(); - //参数Class的数组 - Class[] clazz = new Class[args.length]; - for (int i = 0; i < args.length; i++) { - clazz[i] = args[i].getClass(); + try { + long starTime = System.currentTimeMillis(); + //通过反射获取被调用方法的Class + Class type = joinPoint.getSignature().getDeclaringType(); + //获取类名 + String typeName = type.getSimpleName(); + //方法名 + String methodName = joinPoint.getSignature().getName(); + //获取参数列表 + Object[] args = joinPoint.getArgs(); + //参数Class的数组 + Class[] clazz = new Class[args.length]; + for (int i = 0; i < args.length; i++) { + clazz[i] = args[i].getClass(); + } + //通过反射获取调用的方法method + Method method = type.getMethod(methodName, clazz); + ServiceLog serviceLog = method.getAnnotation(ServiceLog.class); + //获取方法的参数 + Parameter[] parameters = method.getParameters(); + JSONObject jsonObject = new JSONObject(); + for (int i = 0; i < parameters.length; i++) { + Parameter parameter = parameters[i]; + String name = parameter.getName(); + jsonObject.put(name, args[i]); + } + //执行结果 + //执行目标方法,获取执行结果 + Object res = joinPoint.proceed(); + logger.debug("调用{}.{}方法成功\n" + + "接口名称:{}\n" + + "接口地址:{}\n" + + "耗时:{}ms\n" + + "参数为:{}\n" + + "返回结果:{}", typeName, methodName, serviceLog.name(), serviceLog.url(), + (System.currentTimeMillis() - starTime), jsonObject.toJSONString(), JSONObject.toJSONString(res)); + }catch (Exception e){ + e.printStackTrace(); } - //通过反射获取调用的方法method - Method method = type.getMethod(methodName, clazz); - ServiceLog serviceLog = method.getAnnotation(ServiceLog.class); - //获取方法的参数 - Parameter[] parameters = method.getParameters(); - JSONObject jsonObject = new JSONObject(); - for (int i = 0; i < parameters.length; i++) { - Parameter parameter = parameters[i]; - String name = parameter.getName(); - jsonObject.put(name, args[i]); - } - //执行结果 - //执行目标方法,获取执行结果 - Object res = joinPoint.proceed(); - logger.debug("调用{}.{}方法成功\n" + - "接口名称:{}\n" + - "接口地址:{}\n" + - "耗时:{}ms\n" + - "参数为:{}\n" + - "返回结果:{}", typeName, methodName, serviceLog.name(), serviceLog.url(), - (System.currentTimeMillis() - starTime), jsonObject.toJSONString(), JSONObject.toJSONString(res)); - //返回执行结果 - return res; + return joinPoint.proceed(); } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/constant/factory/ConstantFactory.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/constant/factory/ConstantFactory.java index e1db643..260bc0e 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/constant/factory/ConstantFactory.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/constant/factory/ConstantFactory.java @@ -4,11 +4,13 @@ import com.baomidou.mybatisplus.mapper.Wrapper; import com.supersavedriving.driver.core.common.constant.cache.Cache; import com.supersavedriving.driver.core.common.constant.cache.CacheKey; +import com.supersavedriving.driver.core.log.LogObjectHolder; import com.supersavedriving.driver.core.common.constant.state.ManagerStatus; import com.supersavedriving.driver.core.common.constant.state.MenuStatus; import com.supersavedriving.driver.modular.system.dao.*; import com.supersavedriving.driver.modular.system.model.*; -import com.supersavedriving.driver.core.log.LogObjectHolder; +import com.supersavedriving.driver.modular.system.dao.*; +import com.supersavedriving.driver.modular.system.model.*; import com.supersavedriving.driver.core.support.StrKit; import com.supersavedriving.driver.core.util.Convert; import com.supersavedriving.driver.core.util.SpringContextHolder; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/exception/BizExceptionEnum.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/exception/BizExceptionEnum.java index 4b8ba5d..b27a586 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/exception/BizExceptionEnum.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/common/exception/BizExceptionEnum.java @@ -58,13 +58,13 @@ /** * token异常 */ - TOKEN_EXPIRED(600, "token过期"), - TOKEN_ERROR(600, "token验证失败"), + TOKEN_EXPIRED(10030, "token过期"), + TOKEN_ERROR(10030, "token验证失败"), /** * 签名异常 */ - SIGN_ERROR(700, "签名验证失败"), + SIGN_ERROR(10040, "签名验证失败"), /** * 其他 diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/intercept/RestApiInteceptor.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/intercept/RestApiInteceptor.java index 93e97e8..29198c4 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/intercept/RestApiInteceptor.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/intercept/RestApiInteceptor.java @@ -1,9 +1,9 @@ package com.supersavedriving.driver.core.intercept; -import com.supersavedriving.driver.core.base.tips.ErrorTip; import com.supersavedriving.driver.core.common.constant.JwtConstants; import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; import com.supersavedriving.driver.core.util.JwtTokenUtil; +import com.supersavedriving.driver.core.base.tips.ErrorTip; import com.supersavedriving.driver.core.util.RenderUtil; import io.jsonwebtoken.JwtException; import org.springframework.web.method.HandlerMethod; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/log/factory/LogTaskFactory.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/log/factory/LogTaskFactory.java index 8f75b5b..9f4dcce 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/log/factory/LogTaskFactory.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/log/factory/LogTaskFactory.java @@ -1,5 +1,6 @@ package com.supersavedriving.driver.core.log.factory; +import com.supersavedriving.driver.core.log.LogManager; import com.supersavedriving.driver.core.common.constant.state.LogSucceed; import com.supersavedriving.driver.core.common.constant.state.LogType; import com.supersavedriving.driver.modular.system.dao.LoginLogMapper; @@ -7,7 +8,6 @@ import com.supersavedriving.driver.modular.system.model.LoginLog; import com.supersavedriving.driver.modular.system.model.OperationLog; import com.supersavedriving.driver.core.db.Db; -import com.supersavedriving.driver.core.log.LogManager; import com.supersavedriving.driver.core.util.ToolUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/check/PermissionCheckFactory.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/check/PermissionCheckFactory.java index c7233b0..decc545 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/check/PermissionCheckFactory.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/check/PermissionCheckFactory.java @@ -15,9 +15,9 @@ */ package com.supersavedriving.driver.core.shiro.check; -import com.supersavedriving.driver.core.listener.ConfigListener; import com.supersavedriving.driver.core.shiro.ShiroKit; import com.supersavedriving.driver.core.shiro.ShiroUser; +import com.supersavedriving.driver.core.listener.ConfigListener; import com.supersavedriving.driver.core.support.CollectionKit; import com.supersavedriving.driver.core.support.HttpKit; import com.supersavedriving.driver.core.util.SpringContextHolder; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/factory/ShiroFactroy.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/factory/ShiroFactroy.java index 6476e93..a2c864a 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/factory/ShiroFactroy.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/core/shiro/factory/ShiroFactroy.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.core.shiro.factory; +import com.supersavedriving.driver.core.shiro.ShiroUser; import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; import com.supersavedriving.driver.core.common.constant.state.ManagerStatus; -import com.supersavedriving.driver.core.shiro.ShiroUser; import com.supersavedriving.driver.core.util.Convert; import com.supersavedriving.driver.core.util.SpringContextHolder; import com.supersavedriving.driver.modular.system.dao.MenuMapper; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/controller/CodeController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/controller/CodeController.java index 673caef..879dbe0 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/controller/CodeController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/controller/CodeController.java @@ -1,9 +1,9 @@ package com.supersavedriving.driver.modular.code.controller; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.config.properties.DruidProperties; import com.supersavedriving.driver.generator.action.config.WebGeneratorConfig; import com.supersavedriving.driver.generator.action.model.GenQo; +import com.supersavedriving.driver.core.base.controller.BaseController; +import com.supersavedriving.driver.core.config.properties.DruidProperties; import com.supersavedriving.driver.modular.code.factory.DefaultTemplateFactory; import com.supersavedriving.driver.modular.code.service.TableService; import io.swagger.annotations.ApiOperation; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/factory/DefaultTemplateFactory.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/factory/DefaultTemplateFactory.java index b2ec2e9..767a2d1 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/factory/DefaultTemplateFactory.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/code/factory/DefaultTemplateFactory.java @@ -2,9 +2,9 @@ import com.supersavedriving.driver.GunsApplication; +import com.supersavedriving.driver.generator.action.model.GenQo; import com.supersavedriving.driver.core.CoreFlag; import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.generator.action.model.GenQo; import java.util.ArrayList; import java.util.HashMap; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/CommercialController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/CommercialController.java index 2439c2a..3c14736 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/CommercialController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/CommercialController.java @@ -1,8 +1,9 @@ package com.supersavedriving.driver.modular.system.api; +import com.netflix.eureka.ServerRequestAuthFilter; +import com.supersavedriving.driver.modular.system.service.ICommercialService; import com.supersavedriving.driver.core.common.annotion.ServiceLog; import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.service.ICommercialService; import com.supersavedriving.driver.modular.system.service.IDriverService; import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.warpper.CommercialWarpper; @@ -15,6 +16,9 @@ import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.context.request.RequestAttributes; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; import java.util.List; @@ -36,14 +40,14 @@ @ResponseBody @PostMapping("/api/commercial/queryCommercialList") - @ServiceLog(name = "获取广告列表", url = "/api/driver/queryCommercialList") +// @ServiceLog(name = "获取广告列表", url = "/api/driver/queryCommercialList") @ApiOperation(value = "获取广告列表", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "广告类型(1=弹窗广告,2=底部广告)", name = "type", required = true, dataType = "int"), @ApiImplicitParam(value = "设备类型(1=小程序,2=司机端)", name = "device", required = true, dataType = "int"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<List<CommercialWarpper>> queryCommercialList(Integer type, Integer device, HttpServletRequest request){ + public ResponseWarpper<List<CommercialWarpper>> queryCommercialList(Integer type, Integer device){ if(ToolUtil.isEmpty(type)){ return ResponseWarpper.success(ResultUtil.paranErr("type")); } @@ -51,9 +55,10 @@ return ResponseWarpper.success(ResultUtil.paranErr("device")); } try { - Integer uid = driverService.getUserByRequset(request); + + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } List<CommercialWarpper> commercialWarppers = commercialService.queryCommercialList(uid, type, device); return ResponseWarpper.success(commercialWarppers); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java index 6d6a58b..b6ad26a 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverController.java @@ -1,6 +1,9 @@ package com.supersavedriving.driver.modular.system.api; -import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.supersavedriving.driver.modular.system.model.JoiningRequirements; +import com.supersavedriving.driver.modular.system.service.IJoiningRequirementsService; +import com.supersavedriving.driver.modular.system.warpper.*; import com.supersavedriving.driver.core.common.annotion.ServiceLog; import com.supersavedriving.driver.core.util.ToolUtil; import com.supersavedriving.driver.modular.system.service.IBranchOfficeService; @@ -10,16 +13,14 @@ import com.supersavedriving.driver.modular.system.util.SMSUtil; import com.supersavedriving.driver.modular.system.util.UUIDUtil; import com.supersavedriving.driver.modular.system.warpper.*; +import com.supersavedriving.driver.modular.system.warpper.DriverPositionWarpper; +import com.supersavedriving.driver.modular.system.warpper.DriverRegisterWarpper; +import com.supersavedriving.driver.modular.system.warpper.PromotionWarpper; +import com.supersavedriving.driver.modular.system.warpper.TokenWarpper; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.data.mongodb.core.geo.GeoJsonPoint; -import org.springframework.data.mongodb.core.query.Criteria; -import org.springframework.data.mongodb.core.query.Query; -import org.springframework.data.mongodb.core.query.Update; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; @@ -27,7 +28,7 @@ import javax.servlet.http.HttpServletRequest; import java.util.List; -import java.util.Objects; +import java.util.stream.Collectors; /** * 司机控制器 @@ -47,13 +48,16 @@ @Autowired private RedisUtil redisUtil; + @Autowired + private IJoiningRequirementsService joiningRequirementsService; + @ResponseBody @PostMapping("/base/driver/queryCityList") - @ServiceLog(name = "获取开通的省市数据", url = "/base/driver/queryCityList") +// @ServiceLog(name = "获取开通的省市数据", url = "/base/driver/queryCityList") @ApiOperation(value = "获取开通的省市数据", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ }) @@ -72,7 +76,7 @@ @ResponseBody @PostMapping("/base/driver/queryOpenDistrict") - @ServiceLog(name = "根据城市code获取开通区域", url = "/base/driver/queryOpenDistrict") +// @ServiceLog(name = "根据城市code获取开通区域", url = "/base/driver/queryOpenDistrict") @ApiOperation(value = "根据城市code获取开通区域", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "城市code", name = "cityCode", required = true, dataType = "string"), @@ -95,7 +99,7 @@ @ResponseBody @PostMapping("/base/driver/driverRegister") - @ServiceLog(name = "司机注册申请", url = "/base/driver/driverRegister") +// @ServiceLog(name = "司机注册申请", url = "/base/driver/driverRegister") @ApiOperation(value = "司机注册申请", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ }) @@ -114,7 +118,7 @@ @ResponseBody @PostMapping("/base/driver/getVerificationCode") - @ServiceLog(name = "获取短信验证码", url = "/base/driver/getVerificationCode") +// @ServiceLog(name = "获取短信验证码", url = "/base/driver/getVerificationCode") @ApiOperation(value = "获取短信验证码", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "国家代码+86", name = "receiver", required = true, dataType = "string"), @@ -143,7 +147,7 @@ @ResponseBody @PostMapping("/base/driver/driverCodeLogin") - @ServiceLog(name = "司机短信验证码登录", url = "/base/driver/driverCodeLogin") +// @ServiceLog(name = "司机短信验证码登录", url = "/base/driver/driverCodeLogin") @ApiOperation(value = "司机短信验证码登录", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "国家代码+86", name = "receiver", required = true, dataType = "string"), @@ -169,7 +173,7 @@ @ResponseBody @PostMapping("/base/driver/driverPassLogin") - @ServiceLog(name = "司机密码登录", url = "/base/driver/driverPassLogin") +// @ServiceLog(name = "司机密码登录", url = "/base/driver/driverPassLogin") @ApiOperation(value = "司机密码登录", tags = {"司机端-登录注册"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "国家代码+86", name = "receiver", required = true, dataType = "string"), @@ -197,45 +201,45 @@ - @ResponseBody - @PostMapping("/api/driver/flushedToken") - @ServiceLog(name = "刷新token", url = "/api/driver/flushedToken") - @ApiOperation(value = "刷新token", tags = {"司机端-登录注册"}, notes = "") - @ApiImplicitParams({ - @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") - }) - public ResponseWarpper<TokenWarpper> flushedToken(HttpServletRequest request){ - try { - Integer uid = driverService.getUserByRequset(request); - if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); - } - ResultUtil<TokenWarpper> tokenWarpper = driverService.flushedToken(uid); - return ResponseWarpper.success(tokenWarpper); - }catch (Exception e){ - e.printStackTrace(); - return new ResponseWarpper(500, e.getMessage()); - } - } +// @ResponseBody +// @PostMapping("/api/driver/flushedToken") +// @ServiceLog(name = "刷新token", url = "/api/driver/flushedToken") +// @ApiOperation(value = "刷新token", tags = {"司机端-登录注册"}, notes = "") +// @ApiImplicitParams({ +// @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") +// }) +// public ResponseWarpper<TokenWarpper> flushedToken(){ +// try { +// Integer uid = driverService.getUserByRequest(); +// if(null == uid){ +// return ResponseWarpper.tokenErr(); +// } +// ResultUtil<TokenWarpper> tokenWarpper = driverService.flushedToken(uid); +// return ResponseWarpper.success(tokenWarpper); +// }catch (Exception e){ +// e.printStackTrace(); +// return new ResponseWarpper(500, e.getMessage()); +// } +// } @ResponseBody @PostMapping("/api/driver/setPassword") - @ServiceLog(name = "司机设置密码", url = "/api/driver/setPassword") +// @ServiceLog(name = "司机设置密码", url = "/api/driver/setPassword") @ApiOperation(value = "司机设置密码", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "密码", name = "password", required = true, dataType = "string"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper setPassword(String password, HttpServletRequest request){ + public ResponseWarpper setPassword(String password){ if(ToolUtil.isEmpty(password)){ return ResponseWarpper.success(ResultUtil.paranErr("password")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } driverService.setPassword(uid, password); return ResponseWarpper.success(); @@ -249,16 +253,16 @@ @ResponseBody @PostMapping("/api/driver/queryDriverPosition") - @ServiceLog(name = "获取5公里范围内的司机", url = "/api/driver/queryDriverPosition") +// @ServiceLog(name = "获取5公里范围内的司机", url = "/api/driver/queryDriverPosition") @ApiOperation(value = "获取5公里范围内的司机", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<List<String>> queryDriverPosition(HttpServletRequest request){ + public ResponseWarpper<List<String>> queryDriverPosition(){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil<List<String>> listResultUtil = driverService.queryDriverPosition(uid); return ResponseWarpper.success(listResultUtil); @@ -274,7 +278,7 @@ @ResponseBody @PostMapping("/base/driver/addDriverPosition") - @ServiceLog(name = "存储司机实时位置", url = "/base/driver/addDriverPosition") +// @ServiceLog(name = "存储司机实时位置", url = "/base/driver/addDriverPosition") public ResponseWarpper addDriverPosition(DriverPositionWarpper driverPositionWarpper) { try { driverService.addDriverPosition(driverPositionWarpper); @@ -289,16 +293,16 @@ @ResponseBody @PostMapping("/api/driver/queryPromotionQRCode") - @ServiceLog(name = "获取司机推广二维码", url = "/api/driver/queryPromotionQRCode") +// @ServiceLog(name = "获取司机推广二维码", url = "/api/driver/queryPromotionQRCode") @ApiOperation(value = "获取司机推广二维码", tags = {"司机端-个人中心"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<PromotionWarpper> queryPromotionQRCode(HttpServletRequest request) { + public ResponseWarpper<PromotionWarpper> queryPromotionQRCode() { try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if (null == uid) { - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } PromotionWarpper promotionWarpper = driverService.queryPromotionQRCode(uid); return ResponseWarpper.success(promotionWarpper); @@ -310,6 +314,67 @@ + @ResponseBody + @PostMapping("/base/driver/queryJoiningRequirements") +// @ServiceLog(name = "获取加盟要求", url = "/base/driver/queryJoiningRequirements") + @ApiOperation(value = "获取加盟要求", tags = {"司机端-登录注册"}, notes = "") + @ApiImplicitParams({ + }) + public ResponseWarpper<List<String>> queryJoiningRequirements(){ + try { + List<JoiningRequirements> joiningRequirements = joiningRequirementsService.selectList(new EntityWrapper<JoiningRequirements>().eq("status", 1).orderBy("sort")); + List<String> collect = joiningRequirements.stream().map(JoiningRequirements::getContent).collect(Collectors.toList()); + return ResponseWarpper.success(collect); + } catch (Exception e) { + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + @ResponseBody + @PostMapping("/api/driver/queryDriverInfo") +// @ServiceLog(name = "获取司机个人信息", url = "/api/driver/queryDriverInfo") + @ApiOperation(value = "获取司机个人信息", tags = {"司机端-个人中心"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper<DriverInfoWarpper> queryDriverInfo(){ + try { + Integer uid = driverService.getUserByRequest(); + if(null == uid){ + return ResponseWarpper.tokenErr(); + } + DriverInfoWarpper driverInfo = driverService.queryDriverInfo(uid); + return ResponseWarpper.success(driverInfo); + } catch (Exception e) { + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + + + + @ResponseBody + @PostMapping("/api/driver/saveDriverInfo") +// @ServiceLog(name = "修改司机个人信息", url = "/api/driver/saveDriverInfo") + @ApiOperation(value = "修改司机个人信息", tags = {"司机端-个人中心"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper saveDriverInfo(DriverInfo driverInfo){ + try { + Integer uid = driverService.getUserByRequest(); + if(null == uid){ + return ResponseWarpper.tokenErr(); + } + ResultUtil resultUtil = driverService.saveDriverInfo(uid, driverInfo); + return ResponseWarpper.success(resultUtil); + } catch (Exception e) { + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverWorkController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverWorkController.java index 008b429..f824420 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverWorkController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/DriverWorkController.java @@ -37,16 +37,16 @@ @ResponseBody @PostMapping("/api/home/driverWork") - @ServiceLog(name = "司机上班操作", url = "/api/home/driverWork") +// @ServiceLog(name = "司机上班操作", url = "/api/home/driverWork") @ApiOperation(value = "司机上班操作", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper driverWork(HttpServletRequest request){ + public ResponseWarpper driverWork(){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = driverWorkService.driverWork(uid); return ResponseWarpper.success(resultUtil); @@ -59,22 +59,18 @@ @ResponseBody @PostMapping("/api/home/driverOffWork") - @ServiceLog(name = "司机下班操作", url = "/api/home/driverOffWork") +// @ServiceLog(name = "司机下班操作", url = "/api/home/driverOffWork") @ApiOperation(value = "司机下班操作", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ - @ApiImplicitParam(value = "在线时长(秒)", name = "onlineTime", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper driverOffWork(Long onlineTime, HttpServletRequest request){ - if(null == onlineTime){ - return ResponseWarpper.success(ResultUtil.paranErr("onlineTime")); - } + public ResponseWarpper driverOffWork(){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } - ResultUtil resultUtil = driverWorkService.driverOffWork(uid, onlineTime); + ResultUtil resultUtil = driverWorkService.driverOffWork(uid, 0L); return ResponseWarpper.success(resultUtil); }catch (Exception e){ e.printStackTrace(); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/HtmlController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/HtmlController.java new file mode 100644 index 0000000..d55c559 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/HtmlController.java @@ -0,0 +1,50 @@ +package com.supersavedriving.driver.modular.system.api; + +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.supersavedriving.driver.core.common.annotion.ServiceLog; +import com.supersavedriving.driver.modular.system.model.Html; +import com.supersavedriving.driver.modular.system.service.IHtmlService; +import com.supersavedriving.driver.modular.system.util.ResultUtil; +import com.supersavedriving.driver.modular.system.warpper.ResponseWarpper; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +/** + * 协议控制器 + */ +@RestController +@RequestMapping("") +public class HtmlController { + + @Autowired + private IHtmlService htmlService; + + + + + @ResponseBody + @PostMapping("/base/html/queryHtml") +// @ServiceLog(name = "获取各种协议和说明", url = "/base/html/queryHtml") + @ApiOperation(value = "获取各种协议和说明", tags = {"司机端-首页"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(value = "类型(1=代驾服务协议与隐私政策保护,2=法律条款,3=个人信息处理规则,4=积分说明,5=佣金规则说明,6=行程录音说明,7=预估价格说明,8=加盟基本要求,9=加盟流程,10=起步价说明,11=注销协议,12=关于我们,13=司机消单说明)", name = "type", required = true, dataType = "int"), + }) + public ResponseWarpper<String> queryHtml(Integer type){ + if(null == type){ + return ResponseWarpper.success(ResultUtil.paranErr("type")); + } + try { + Html html = htmlService.selectOne(new EntityWrapper<Html>().eq("type", type)); + return ResponseWarpper.success(null == html ? "" : html.getHtml()); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/ImgController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/ImgController.java index b0b3b0b..3076392 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/ImgController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/ImgController.java @@ -1,6 +1,5 @@ package com.supersavedriving.driver.modular.system.api; -import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.supersavedriving.driver.core.common.annotion.ServiceLog; import com.supersavedriving.driver.core.util.ToolUtil; @@ -12,8 +11,6 @@ import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -31,7 +28,7 @@ @ResponseBody @PostMapping("/base/img/querySysImg") - @ServiceLog(name = "获取系统图片", url = "/base/img/querySysImg") +// @ServiceLog(name = "获取系统图片", url = "/base/img/querySysImg") @ApiOperation(value = "获取系统图片", tags = {"司机端-公共接口"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "数据类型(1=启动页)", name = "type", required = true, dataType = "int"), diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/MainContentController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/MainContentController.java new file mode 100644 index 0000000..aa09962 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/MainContentController.java @@ -0,0 +1,60 @@ +package com.supersavedriving.driver.modular.system.api; + +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.supersavedriving.driver.core.common.annotion.ServiceLog; +import com.supersavedriving.driver.modular.system.model.MainContent; +import com.supersavedriving.driver.modular.system.service.IMainContentService; +import com.supersavedriving.driver.modular.system.util.ResultUtil; +import com.supersavedriving.driver.modular.system.warpper.ResponseWarpper; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.ArrayList; +import java.util.List; + +/** +* 事由控制器 +* @author pzb +* @Date 2023/2/27 12:02 +*/ +@RestController +@RequestMapping("") +public class MainContentController { + + @Autowired + private IMainContentService mainContentService; + + + + @ResponseBody + @PostMapping("/base/mainContent/queryMainContent") +// @ServiceLog(name = "获取系统事由", url = "/base/mainContent/queryMainContent") + @ApiOperation(value = "获取系统事由", tags = {"司机端-服务中"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(value = "数据类型(1=转单,2=司机消单,3=用户取消订单)", name = "type", required = true, dataType = "int"), + }) + public ResponseWarpper<List<String>> queryMainContent(Integer type){ + if(null == type){ + return ResponseWarpper.success(ResultUtil.paranErr("type")); + } + try { + List<MainContent> mainContents = mainContentService.selectList(new EntityWrapper<MainContent>().eq("type", type) + .eq("status", 1).orderBy("createTime")); + List<String> list = new ArrayList<>(); + for (MainContent mainContent : mainContents) { + list.add(mainContent.getContent()); + } + return ResponseWarpper.success(list); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + + } +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/OrderController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/OrderController.java index b12aadc..812cc72 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/OrderController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/OrderController.java @@ -1,11 +1,15 @@ package com.supersavedriving.driver.modular.system.api; +import com.supersavedriving.driver.modular.system.warpper.*; import com.supersavedriving.driver.core.common.annotion.ServiceLog; import com.supersavedriving.driver.core.util.ToolUtil; import com.supersavedriving.driver.modular.system.service.IDriverService; import com.supersavedriving.driver.modular.system.service.IOrderService; import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.warpper.*; +import com.supersavedriving.driver.modular.system.warpper.AddOrderWarpper; +import com.supersavedriving.driver.modular.system.warpper.HallOrderList; +import com.supersavedriving.driver.modular.system.warpper.OrderInfoWarpper; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; @@ -38,16 +42,16 @@ @ResponseBody @PostMapping("/api/order/queryDriverServerOrder") - @ServiceLog(name = "获取司机服务中的订单id", url = "/api/order/queryDriverServerOrder") +// @ServiceLog(name = "获取司机服务中的订单id", url = "/api/order/queryDriverServerOrder") @ApiOperation(value = "获取司机服务中的订单id", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<Long> queryDriverServerOrder(HttpServletRequest request){ + public ResponseWarpper<Long> queryDriverServerOrder(){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } Long id = orderService.queryDriverServerOrder(uid); return ResponseWarpper.success(id); @@ -61,16 +65,16 @@ @ResponseBody @PostMapping("/api/order/driverAddOrder") - @ServiceLog(name = "司机代客下单", url = "/api/order/driverAddOrder") +// @ServiceLog(name = "司机代客下单", url = "/api/order/driverAddOrder") @ApiOperation(value = "司机代客下单", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper driverAddOrder(AddOrderWarpper addOrderWarpper, HttpServletRequest request){ + public ResponseWarpper driverAddOrder(AddOrderWarpper addOrderWarpper){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.driverAddOrder(uid, addOrderWarpper); return ResponseWarpper.success(resultUtil); @@ -84,14 +88,14 @@ @ResponseBody @PostMapping("/api/order/queryOrderHall") - @ServiceLog(name = "司机获取大厅订单列表", url = "/api/order/queryOrderHall") +// @ServiceLog(name = "司机获取大厅订单列表", url = "/api/order/queryOrderHall") @ApiOperation(value = "司机获取大厅订单列表", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "页码,首页1", name = "pageNum", required = true, dataType = "int"), @ApiImplicitParam(value = "页条数", name = "pageSize", required = true, dataType = "int"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<List<HallOrderList>> queryOrderHall(Integer pageNum, Integer pageSize, HttpServletRequest request){ + public ResponseWarpper<List<HallOrderList>> queryOrderHall(Integer pageNum, Integer pageSize){ if(null == pageNum){ return ResponseWarpper.success(ResultUtil.paranErr("pageNum")); } @@ -99,9 +103,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("pageSize")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } List<HallOrderList> hallOrderLists = orderService.queryOrderHall(uid, pageNum, pageSize); return ResponseWarpper.success(hallOrderLists); @@ -116,20 +120,20 @@ @ResponseBody @PostMapping("/api/order/rejectionOrder") - @ServiceLog(name = "司机拒绝接单", url = "/api/order/rejectionOrder") +// @ServiceLog(name = "司机拒绝接单", url = "/api/order/rejectionOrder") @ApiOperation(value = "司机拒绝接单", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper rejectionOrder(Long orderId, HttpServletRequest request){ + public ResponseWarpper rejectionOrder(Long orderId){ if(null == orderId){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.rejectionOrder(uid, orderId); return ResponseWarpper.success(resultUtil); @@ -145,20 +149,20 @@ @ResponseBody @PostMapping("/api/order/receiveOrder") - @ServiceLog(name = "司机接单操作", url = "/api/order/receiveOrder") +// @ServiceLog(name = "司机接单操作", url = "/api/order/receiveOrder") @ApiOperation(value = "司机接单操作", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper receiveOrder(Long orderId, HttpServletRequest request){ + public ResponseWarpper receiveOrder(Long orderId){ if(null == orderId){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.receiveOrder(uid, orderId); return ResponseWarpper.success(resultUtil); @@ -173,20 +177,20 @@ @ResponseBody @PostMapping("/api/order/queryOrderInfo") - @ServiceLog(name = "获取订单详情", url = "/api/order/queryOrderInfo") +// @ServiceLog(name = "获取订单详情", url = "/api/order/queryOrderInfo") @ApiOperation(value = "获取订单详情", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<OrderInfoWarpper> queryOrderInfo(Long orderId, HttpServletRequest request){ + public ResponseWarpper<OrderInfoWarpper> queryOrderInfo(Long orderId){ if(null == orderId){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } OrderInfoWarpper orderInfoWarpper = orderService.queryOrderInfo(uid, orderId); return ResponseWarpper.success(orderInfoWarpper); @@ -203,16 +207,16 @@ @ResponseBody @PostMapping("/api/order/driverProcessOperations") - @ServiceLog(name = "司机走订单流程", url = "/api/order/driverProcessOperations") +// @ServiceLog(name = "司机走订单流程", url = "/api/order/driverProcessOperations") @ApiOperation(value = "司机走订单流程", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper driverProcessOperations(ProcessOperationsWarpper processOperationsWarpper, HttpServletRequest request){ + public ResponseWarpper driverProcessOperations(ProcessOperationsWarpper processOperationsWarpper){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.driverProcessOperations(uid, processOperationsWarpper); return ResponseWarpper.success(resultUtil); @@ -227,14 +231,14 @@ @ResponseBody @PostMapping("/api/order/transferOrder") - @ServiceLog(name = "司机转单操作", url = "/api/order/transferOrder") +// @ServiceLog(name = "司机转单操作", url = "/api/order/transferOrder") @ApiOperation(value = "司机转单操作", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(value = "原因", name = "cause", required = true, dataType = "string"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper transferOrder(Long orderId, String cause, HttpServletRequest request){ + public ResponseWarpper transferOrder(Long orderId, String cause){ if(ToolUtil.isEmpty(orderId)){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } @@ -242,9 +246,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("cause")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.transferOrder(uid, orderId, cause); return ResponseWarpper.success(resultUtil); @@ -257,16 +261,16 @@ @ResponseBody @PostMapping("/api/order/setOrderEndAddress") - @ServiceLog(name = "司机修改订单终点", url = "/api/order/setOrderEndAddress") +// @ServiceLog(name = "司机修改订单终点", url = "/api/order/setOrderEndAddress") @ApiOperation(value = "司机修改订单终点", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper setOrderEndAddress(OrderEndAddressWarpper orderEndAddressWarpper, HttpServletRequest request){ + public ResponseWarpper setOrderEndAddress(OrderEndAddressWarpper orderEndAddressWarpper){ try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.setOrderEndAddress(uid, orderEndAddressWarpper); return ResponseWarpper.success(resultUtil); @@ -280,20 +284,20 @@ @ResponseBody @PostMapping("/api/order/cancelTransferOrder") - @ServiceLog(name = "司机取消转单操作", url = "/api/order/cancelTransferOrder") +// @ServiceLog(name = "司机取消转单操作", url = "/api/order/cancelTransferOrder") @ApiOperation(value = "司机取消转单操作", tags = {"司机端-我的订单"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper cancelTransferOrder(Long orderId, HttpServletRequest request){ + public ResponseWarpper cancelTransferOrder(Long orderId){ if(ToolUtil.isEmpty(orderId)){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.cancelTransferOrder(uid, orderId); return ResponseWarpper.success(resultUtil); @@ -307,14 +311,14 @@ @ResponseBody @PostMapping("/api/order/driverCancelOrder") - @ServiceLog(name = "司机取消订单操作", url = "/api/order/driverCancelOrder") +// @ServiceLog(name = "司机取消订单操作", url = "/api/order/driverCancelOrder") @ApiOperation(value = "司机取消订单操作", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(value = "原因", name = "cause", required = true, dataType = "string"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper driverCancelOrder(Long orderId, String cause, HttpServletRequest request){ + public ResponseWarpper driverCancelOrder(Long orderId, String cause){ if(ToolUtil.isEmpty(orderId)){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } @@ -322,9 +326,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("cause")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.driverCancelOrder(uid, orderId, cause); return ResponseWarpper.success(resultUtil); @@ -337,20 +341,20 @@ @ResponseBody @PostMapping("/api/order/queryOrderPrice") - @ServiceLog(name = "获取订单费用明细", url = "/api/order/queryOrderPrice") +// @ServiceLog(name = "获取订单费用明细", url = "/api/order/queryOrderPrice") @ApiOperation(value = "获取订单费用明细", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<OrderPriceWarpper> queryOrderPrice(Long orderId, HttpServletRequest request){ + public ResponseWarpper<OrderPriceWarpper> queryOrderPrice(Long orderId){ if(ToolUtil.isEmpty(orderId)){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } OrderPriceWarpper orderPriceWarpper = orderService.queryOrderPrice(uid, orderId); return ResponseWarpper.success(orderPriceWarpper); @@ -364,14 +368,14 @@ @ResponseBody @PostMapping("/api/order/setOrderStatus") - @ServiceLog(name = "服务完成后修改订单状态", url = "/api/order/setOrderStatus") +// @ServiceLog(name = "服务完成后修改订单状态", url = "/api/order/setOrderStatus") @ApiOperation(value = "服务完成后修改订单状态", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "订单id", name = "orderId", required = true, dataType = "long"), @ApiImplicitParam(value = "107(线上支付),108(完成线下支付)", name = "state", required = true, dataType = "int"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper setOrderStatus(Long orderId, Integer state, HttpServletRequest request){ + public ResponseWarpper setOrderStatus(Long orderId, Integer state){ if(ToolUtil.isEmpty(orderId)){ return ResponseWarpper.success(ResultUtil.paranErr("orderId")); } @@ -379,9 +383,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("state")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } ResultUtil resultUtil = orderService.setOrderStatus(uid, orderId, state); return ResponseWarpper.success(resultUtil); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemBulletinController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemBulletinController.java index fae9936..efb0a2b 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemBulletinController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemBulletinController.java @@ -40,14 +40,14 @@ @ResponseBody @PostMapping("/api/systemBulletin/querySystemBulletinList") - @ServiceLog(name = "获取系统公告列表", url = "/api/systemBulletin/querySystemBulletinList") +// @ServiceLog(name = "获取系统公告列表", url = "/api/systemBulletin/querySystemBulletinList") @ApiOperation(value = "获取系统公告列表", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "页码,首页1", name = "pageNum", required = true, dataType = "int"), @ApiImplicitParam(value = "页条数", name = "size", required = true, dataType = "int"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<List<SystemBulletinListWarpper>> querySystemBulletinList(Integer pageNum, Integer size, HttpServletRequest request){ + public ResponseWarpper<List<SystemBulletinListWarpper>> querySystemBulletinList(Integer pageNum, Integer size){ if(ToolUtil.isEmpty(pageNum)){ return ResponseWarpper.success(ResultUtil.paranErr("pageNum")); } @@ -55,9 +55,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("size")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } List<SystemBulletinListWarpper> systemBulletinListWarppers = systemBulletinService.querySystemBulletinList(uid, pageNum, size); return ResponseWarpper.success(systemBulletinListWarppers); @@ -70,20 +70,20 @@ @ResponseBody @PostMapping("/api/systemBulletin/querySystemBulletinInfo") - @ServiceLog(name = "获取系统公告详情", url = "/api/systemBulletin/querySystemBulletinInfo") +// @ServiceLog(name = "获取系统公告详情", url = "/api/systemBulletin/querySystemBulletinInfo") @ApiOperation(value = "获取系统公告详情", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "公告id", name = "id", required = true, dataType = "long"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<SystemBulletinInfo> querySystemBulletinInfo(Long id, HttpServletRequest request){ + public ResponseWarpper<SystemBulletinInfo> querySystemBulletinInfo(Long id){ if(ToolUtil.isEmpty(id)){ return ResponseWarpper.success(ResultUtil.paranErr("id")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } SystemBulletinInfo systemBulletinInfo = systemBulletinService.querySystemBulletinInfo(id); return ResponseWarpper.success(systemBulletinInfo); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemConfigController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemConfigController.java index 2a87506..e61a16c 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemConfigController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemConfigController.java @@ -33,7 +33,7 @@ @ResponseBody @PostMapping("/base/config/queryTransferOrderConfig") - @ServiceLog(name = "获取转单提醒时间配置", url = "/base/config/queryTransferOrderConfig") +// @ServiceLog(name = "获取转单提醒时间配置", url = "/base/config/queryTransferOrderConfig") @ApiOperation(value = "获取转单提醒时间配置", tags = {"司机端-服务中"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemMessageController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemMessageController.java index 27cce01..2264696 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemMessageController.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/api/SystemMessageController.java @@ -1,8 +1,14 @@ package com.supersavedriving.driver.modular.system.api; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.supersavedriving.driver.core.common.annotion.ServiceLog; import com.supersavedriving.driver.core.util.ToolUtil; +import com.supersavedriving.driver.modular.system.model.SystemBulletin; +import com.supersavedriving.driver.modular.system.model.SystemBulletinUser; +import com.supersavedriving.driver.modular.system.model.SystemMessage; import com.supersavedriving.driver.modular.system.service.IDriverService; +import com.supersavedriving.driver.modular.system.service.ISystemBulletinService; +import com.supersavedriving.driver.modular.system.service.ISystemBulletinUserService; import com.supersavedriving.driver.modular.system.service.ISystemMessageService; import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.warpper.ResponseWarpper; @@ -34,19 +40,25 @@ @Autowired private IDriverService driverService; + @Autowired + private ISystemBulletinService systemBulletinService; + + @Autowired + private ISystemBulletinUserService systemBulletinUserService; + @ResponseBody @PostMapping("/api/systemMessage/querySystemMessageList") - @ServiceLog(name = "获取系统消息列表", url = "/api/systemMessage/querySystemMessageList") +// @ServiceLog(name = "获取系统消息列表", url = "/api/systemMessage/querySystemMessageList") @ApiOperation(value = "获取系统消息列表", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "页码,首页1", name = "pageNum", required = true, dataType = "int"), @ApiImplicitParam(value = "页条数", name = "size", required = true, dataType = "int"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper<List<SystemMessageWarpper>> querySystemMessageList(Integer pageNum, Integer size, HttpServletRequest request){ + public ResponseWarpper<List<SystemMessageWarpper>> querySystemMessageList(Integer pageNum, Integer size){ if(ToolUtil.isEmpty(pageNum)){ return ResponseWarpper.success(ResultUtil.paranErr("pageNum")); } @@ -54,9 +66,9 @@ return ResponseWarpper.success(ResultUtil.paranErr("size")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } List<SystemMessageWarpper> systemMessageWarppers = systemMessageService.querySystemMessageList(uid, pageNum, size); return ResponseWarpper.success(systemMessageWarppers); @@ -69,20 +81,20 @@ @ResponseBody @PostMapping("/api/systemMessage/readSystems") - @ServiceLog(name = "阅读系统消息", url = "/api/systemMessage/readSystems") +// @ServiceLog(name = "阅读系统消息", url = "/api/systemMessage/readSystems") @ApiOperation(value = "阅读系统消息", tags = {"司机端-首页"}, notes = "") @ApiImplicitParams({ @ApiImplicitParam(value = "消息id,多个逗号分隔", name = "ids", required = true, dataType = "string"), @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") }) - public ResponseWarpper readSystems(String ids, HttpServletRequest request){ + public ResponseWarpper readSystems(String ids){ if(ToolUtil.isEmpty(ids)){ return ResponseWarpper.success(ResultUtil.paranErr("ids")); } try { - Integer uid = driverService.getUserByRequset(request); + Integer uid = driverService.getUserByRequest(); if(null == uid){ - return ResponseWarpper.success(ResultUtil.tokenErr()); + return ResponseWarpper.tokenErr(); } systemMessageService.readSystems(uid, ids); return ResponseWarpper.success(); @@ -91,4 +103,50 @@ return new ResponseWarpper(500, e.getMessage()); } } + + + @ResponseBody + @PostMapping("/api/systemMessage/clearSystemMessage") +// @ServiceLog(name = "清空系统消息和公告", url = "/api/systemMessage/clearSystemMessage") + @ApiOperation(value = "清空系统消息和公告", tags = {"司机端-首页"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper clearSystemMessage(){ + try { + Integer uid = driverService.getUserByRequest(); + if(null == uid){ + return ResponseWarpper.tokenErr(); + } + systemMessageService.clearSystemMessage(uid); + systemBulletinService.clearSystemBulletinUser(uid); + return ResponseWarpper.success(); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } + + + @ResponseBody + @PostMapping("/api/systemMessage/queryUnreadQuantity") +// @ServiceLog(name = "获取未读消息数量", url = "/api/systemMessage/queryUnreadQuantity") + @ApiOperation(value = "获取未读消息数量", tags = {"司机端-首页"}, notes = "") + @ApiImplicitParams({ + @ApiImplicitParam(name = "Authorization", value = "用户token(Bearer +token)", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") + }) + public ResponseWarpper<Integer> queryUnreadQuantity(){ + try { + Integer uid = driverService.getUserByRequest(); + if(null == uid){ + return ResponseWarpper.tokenErr(); + } + int count = systemMessageService.selectCount(new EntityWrapper<SystemMessage>().eq("userType", 2).eq("userId", uid).eq("isRead", 0).eq("status", 1)); + int count1 = systemBulletinUserService.selectCount(new EntityWrapper<SystemBulletinUser>().eq("userType", 2).eq("userId", uid).eq("isRead", 0).eq("status", 1)); + return ResponseWarpper.success(count + count1); + }catch (Exception e){ + e.printStackTrace(); + return new ResponseWarpper(500, e.getMessage()); + } + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/BlackboardController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/BlackboardController.java deleted file mode 100644 index 321ae8d..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/BlackboardController.java +++ /dev/null @@ -1,35 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.modular.system.service.INoticeService; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.RequestMapping; - -import java.util.List; -import java.util.Map; - -/** - * 总览信息 - * - * @author fengshuonan - * @Date 2017年3月4日23:05:54 - */ -@Controller -@RequestMapping("/blackboard") -public class BlackboardController extends BaseController { - - @Autowired - private INoticeService noticeService; - - /** - * 跳转到黑板 - */ - @RequestMapping("") - public String blackboard(Model model) { - List<Map<String, Object>> notices = noticeService.list(null); - model.addAttribute("noticeList", notices); - return "/blackboard.html"; - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DeptController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DeptController.java deleted file mode 100644 index 8ed3fe0..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DeptController.java +++ /dev/null @@ -1,164 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.dictmap.DeptDict; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.node.ZTreeNode; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.Dept; -import com.supersavedriving.driver.modular.system.service.IDeptService; -import com.supersavedriving.driver.modular.system.warpper.DeptWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.util.List; -import java.util.Map; - -/** - * 部门控制器 - * - * @author fengshuonan - * @Date 2017年2月17日20:27:22 - */ -@Controller -@RequestMapping("/dept") -public class DeptController extends BaseController { - - private String PREFIX = "/system/dept/"; - - @Autowired - private IDeptService deptService; - - /** - * 跳转到部门管理首页 - */ - @RequestMapping("") - public String index() { - return PREFIX + "dept.html"; - } - - /** - * 跳转到添加部门 - */ - @RequestMapping("/dept_add") - public String deptAdd() { - return PREFIX + "dept_add.html"; - } - - /** - * 跳转到修改部门 - */ - @Permission - @RequestMapping("/dept_update/{deptId}") - public String deptUpdate(@PathVariable Integer deptId, Model model) { - Dept dept = deptService.selectById(deptId); - model.addAttribute(dept); - model.addAttribute("pName", ConstantFactory.me().getDeptName(dept.getPid())); - LogObjectHolder.me().set(dept); - return PREFIX + "dept_edit.html"; - } - - /** - * 获取部门的tree列表 - */ - @RequestMapping(value = "/tree") - @ResponseBody - public List<ZTreeNode> tree() { - List<ZTreeNode> tree = this.deptService.tree(); - tree.add(ZTreeNode.createParent()); - return tree; - } - - /** - * 新增部门 - */ - @BussinessLog(value = "添加部门", key = "simplename", dict = DeptDict.class) - @RequestMapping(value = "/add") - @Permission - @ResponseBody - public Object add(Dept dept) { - if (ToolUtil.isOneEmpty(dept, dept.getSimplename())) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - //完善pids,根据pid拿到pid的pids - deptSetPids(dept); - return this.deptService.insert(dept); - } - - /** - * 获取所有部门列表 - */ - @RequestMapping(value = "/list") - @Permission - @ResponseBody - public Object list(String condition) { - List<Map<String, Object>> list = this.deptService.list(condition); - return super.warpObject(new DeptWarpper(list)); - } - - /** - * 部门详情 - */ - @RequestMapping(value = "/detail/{deptId}") - @Permission - @ResponseBody - public Object detail(@PathVariable("deptId") Integer deptId) { - return deptService.selectById(deptId); - } - - /** - * 修改部门 - */ - @BussinessLog(value = "修改部门", key = "simplename", dict = DeptDict.class) - @RequestMapping(value = "/update") - @Permission - @ResponseBody - public Object update(Dept dept) { - if (ToolUtil.isEmpty(dept) || dept.getId() == null) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - deptSetPids(dept); - deptService.updateById(dept); - return SUCCESS_TIP; - } - - /** - * 删除部门 - */ - @BussinessLog(value = "删除部门", key = "deptId", dict = DeptDict.class) - @RequestMapping(value = "/delete") - @Permission - @ResponseBody - public Object delete(@RequestParam Integer deptId) { - - //缓存被删除的部门名称 - LogObjectHolder.me().set(ConstantFactory.me().getDeptName(deptId)); - - deptService.deleteDept(deptId); - - return SUCCESS_TIP; - } - - private void deptSetPids(Dept dept) { - if (ToolUtil.isEmpty(dept.getPid()) || dept.getPid().equals(0)) { - dept.setPid(0); - dept.setPids("[0],"); - } else { - int pid = dept.getPid(); - Dept temp = deptService.selectById(pid); - String pids = temp.getPids(); - dept.setPid(pid); - dept.setPids(pids + "[" + pid + "],"); - } - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DictController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DictController.java deleted file mode 100644 index 5294a51..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/DictController.java +++ /dev/null @@ -1,142 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.baomidou.mybatisplus.mapper.EntityWrapper; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.dictmap.DictMap; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.Dict; -import com.supersavedriving.driver.modular.system.service.IDictService; -import com.supersavedriving.driver.modular.system.warpper.DictWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.util.List; -import java.util.Map; - -/** - * 字典控制器 - * - * @author fengshuonan - * @Date 2017年4月26日 12:55:31 - */ -@Controller -@RequestMapping("/dict") -public class DictController extends BaseController { - - private String PREFIX = "/system/dict/"; - - @Autowired - private IDictService dictService; - - /** - * 跳转到字典管理首页 - */ - @RequestMapping("") - public String index() { - return PREFIX + "dict.html"; - } - - /** - * 跳转到添加字典 - */ - @RequestMapping("/dict_add") - public String deptAdd() { - return PREFIX + "dict_add.html"; - } - - /** - * 跳转到修改字典 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping("/dict_edit/{dictId}") - public String deptUpdate(@PathVariable Integer dictId, Model model) { - Dict dict = dictService.selectById(dictId); - model.addAttribute("dict", dict); - List<Dict> subDicts = dictService.selectList(new EntityWrapper<Dict>().eq("pid", dictId)); - model.addAttribute("subDicts", subDicts); - LogObjectHolder.me().set(dict); - return PREFIX + "dict_edit.html"; - } - - /** - * 新增字典 - * - * @param dictValues 格式例如 "1:启用;2:禁用;3:冻结" - */ - @BussinessLog(value = "添加字典记录", key = "dictName,dictValues", dict = DictMap.class) - @RequestMapping(value = "/add") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object add(String dictCode,String dictTips,String dictName, String dictValues) { - if (ToolUtil.isOneEmpty(dictCode,dictName, dictValues)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - this.dictService.addDict(dictCode,dictName,dictTips,dictValues); - return SUCCESS_TIP; - } - - /** - * 获取所有字典列表 - */ - @RequestMapping(value = "/list") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object list(String condition) { - List<Map<String, Object>> list = this.dictService.list(condition); - return super.warpObject(new DictWarpper(list)); - } - - /** - * 字典详情 - */ - @RequestMapping(value = "/detail/{dictId}") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object detail(@PathVariable("dictId") Integer dictId) { - return dictService.selectById(dictId); - } - - /** - * 修改字典 - */ - @BussinessLog(value = "修改字典", key = "dictName,dictValues", dict = DictMap.class) - @RequestMapping(value = "/update") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object update(Integer dictId,String dictCode,String dictName, String dictTips,String dictValues) { - if (ToolUtil.isOneEmpty(dictId, dictCode, dictName, dictValues)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - dictService.editDict(dictId, dictCode,dictName, dictTips,dictValues); - return SUCCESS_TIP; - } - - /** - * 删除字典记录 - */ - @BussinessLog(value = "删除字典记录", key = "dictId", dict = DictMap.class) - @RequestMapping(value = "/delete") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object delete(@RequestParam Integer dictId) { - - //缓存被删除的名称 - LogObjectHolder.me().set(ConstantFactory.me().getDictName(dictId)); - - this.dictService.delteDict(dictId); - return SUCCESS_TIP; - } - -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/KaptchaController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/KaptchaController.java deleted file mode 100644 index 28085fd..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/KaptchaController.java +++ /dev/null @@ -1,114 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.google.code.kaptcha.Constants; -import com.google.code.kaptcha.Producer; -import com.supersavedriving.driver.config.properties.GunsProperties; -import com.supersavedriving.driver.core.util.FileUtil; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; - -import javax.imageio.ImageIO; -import javax.servlet.ServletOutputStream; -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import javax.servlet.http.HttpSession; -import java.awt.image.BufferedImage; -import java.io.IOException; - -/** - * 验证码生成 - * - * @author fengshuonan - * @date 2017-05-05 23:10 - */ -@Controller -@RequestMapping("/kaptcha") -public class KaptchaController { - - @Autowired - private GunsProperties gunsProperties; - - @Autowired - private Producer producer; - - /** - * 生成验证码 - */ - @RequestMapping("") - public void index(HttpServletRequest request, HttpServletResponse response) { - HttpSession session = request.getSession(); - - response.setDateHeader("Expires", 0); - - // Set standard HTTP/1.1 no-cache headers. - response.setHeader("Cache-Control", "no-store, no-cache, must-revalidate"); - - // Set IE extended HTTP/1.1 no-cache headers (use addHeader). - response.addHeader("Cache-Control", "post-check=0, pre-check=0"); - - // Set standard HTTP/1.0 no-cache header. - response.setHeader("Pragma", "no-cache"); - - // return a jpeg - response.setContentType("image/jpeg"); - - // create the text for the image - String capText = producer.createText(); - - // store the text in the session - session.setAttribute(Constants.KAPTCHA_SESSION_KEY, capText); - - // create the image with the text - BufferedImage bi = producer.createImage(capText); - ServletOutputStream out = null; - try { - out = response.getOutputStream(); - } catch (IOException e) { - e.printStackTrace(); - } - - // write the data out - try { - ImageIO.write(bi, "jpg", out); - } catch (IOException e) { - e.printStackTrace(); - } - try { - try { - out.flush(); - } catch (IOException e) { - e.printStackTrace(); - } - } finally { - try { - out.close(); - } catch (IOException e) { - e.printStackTrace(); - } - } - } - - /** - * 返回图片 - * - * @author stylefeng - * @Date 2017/5/24 23:00 - */ - @RequestMapping("/{pictureId}") - public void renderPicture(@PathVariable("pictureId") String pictureId, HttpServletResponse response) { - String path = gunsProperties.getFileUploadPath() + pictureId; - try { - byte[] bytes = FileUtil.toByteArray(path); - response.getOutputStream().write(bytes); - } catch (Exception e) { - //如果找不到图片就返回一个默认图片 - try { - response.sendRedirect("/static/img/girl.gif"); - } catch (IOException e1) { - e1.printStackTrace(); - } - } - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LogController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LogController.java deleted file mode 100644 index 1b04ecd..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LogController.java +++ /dev/null @@ -1,84 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.baomidou.mybatisplus.mapper.SqlRunner; -import com.baomidou.mybatisplus.plugins.Page; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.factory.PageFactory; -import com.supersavedriving.driver.core.common.constant.state.BizLogType; -import com.supersavedriving.driver.core.support.BeanKit; -import com.supersavedriving.driver.modular.system.model.OperationLog; -import com.supersavedriving.driver.modular.system.service.IOperationLogService; -import com.supersavedriving.driver.modular.system.warpper.LogWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.util.List; -import java.util.Map; - -/** - * 日志管理的控制器 - * - * @author fengshuonan - * @Date 2017年4月5日 19:45:36 - */ -@Controller -@RequestMapping("/log") -public class LogController extends BaseController { - - private static String PREFIX = "/system/log/"; - - @Autowired - private IOperationLogService operationLogService; - - /** - * 跳转到日志管理的首页 - */ - @RequestMapping("") - public String index() { - return PREFIX + "log.html"; - } - - /** - * 查询操作日志列表 - */ - @RequestMapping("/list") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object list(@RequestParam(required = false) String beginTime, @RequestParam(required = false) String endTime, @RequestParam(required = false) String logName, @RequestParam(required = false) Integer logType) { - Page<OperationLog> page = new PageFactory<OperationLog>().defaultPage(); - List<Map<String, Object>> result = operationLogService.getOperationLogs(page, beginTime, endTime, logName, BizLogType.valueOf(logType), page.getOrderByField(), page.isAsc()); - page.setRecords((List<OperationLog>) new LogWarpper(result).warp()); - return super.packForBT(page); - } - - /** - * 查询操作日志详情 - */ - @RequestMapping("/detail/{id}") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object detail(@PathVariable Integer id) { - OperationLog operationLog = operationLogService.selectById(id); - Map<String, Object> stringObjectMap = BeanKit.beanToMap(operationLog); - return super.warpObject(new LogWarpper(stringObjectMap)); - } - - /** - * 清空日志 - */ - @BussinessLog(value = "清空业务日志") - @RequestMapping("/delLog") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object delLog() { - SqlRunner.db().delete("delete from sys_operation_log"); - return SUCCESS_TIP; - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginController.java deleted file mode 100644 index 53d0ebf..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginController.java +++ /dev/null @@ -1,134 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.google.code.kaptcha.Constants; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.exception.InvalidKaptchaException; -import com.supersavedriving.driver.core.log.LogManager; -import com.supersavedriving.driver.core.log.factory.LogTaskFactory; -import com.supersavedriving.driver.core.node.MenuNode; -import com.supersavedriving.driver.core.shiro.ShiroKit; -import com.supersavedriving.driver.core.shiro.ShiroUser; -import com.supersavedriving.driver.core.util.ApiMenuFilter; -import com.supersavedriving.driver.core.util.KaptchaUtil; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.User; -import com.supersavedriving.driver.modular.system.service.IMenuService; -import com.supersavedriving.driver.modular.system.service.IUserService; -import org.apache.shiro.authc.UsernamePasswordToken; -import org.apache.shiro.subject.Subject; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestMethod; - -import java.util.List; - -import static com.supersavedriving.driver.core.support.HttpKit.getIp; - -/** - * 登录控制器 - * - * @author fengshuonan - * @Date 2017年1月10日 下午8:25:24 - */ -@Controller -public class LoginController extends BaseController { - - @Autowired - private IMenuService menuService; - - @Autowired - private IUserService userService; - - /** - * 跳转到主页 - */ - @RequestMapping(value = "/", method = RequestMethod.GET) - public String index(Model model) { - //获取菜单列表 - List<Integer> roleList = ShiroKit.getUser().getRoleList(); - if (roleList == null || roleList.size() == 0) { - ShiroKit.getSubject().logout(); - model.addAttribute("tips", "该用户没有角色,无法登陆"); - return "/login.html"; - } - List<MenuNode> menus = menuService.getMenusByRoleIds(roleList); - List<MenuNode> titles = MenuNode.buildTitle(menus); - titles = ApiMenuFilter.build(titles); - - model.addAttribute("titles", titles); - - //获取用户头像 - Integer id = ShiroKit.getUser().getId(); - User user = userService.selectById(id); - String avatar = user.getAvatar(); - model.addAttribute("avatar", avatar); - - return "/index.html"; - } - - /** - * 跳转到登录页面 - */ - @RequestMapping(value = "/login", method = RequestMethod.GET) - public String login() { - if (ShiroKit.isAuthenticated() || ShiroKit.getUser() != null) { - return REDIRECT + "/"; - } else { - return "/login.html"; - } - } - - /** - * 点击登录执行的动作 - */ - @RequestMapping(value = "/login", method = RequestMethod.POST) - public String loginVali() { - - String username = super.getPara("username").trim(); - String password = super.getPara("password").trim(); - String remember = super.getPara("remember"); - - //验证验证码是否正确 - if (KaptchaUtil.getKaptchaOnOff()) { - String kaptcha = super.getPara("kaptcha").trim(); - String code = (String) super.getSession().getAttribute(Constants.KAPTCHA_SESSION_KEY); - if (ToolUtil.isEmpty(kaptcha) || !kaptcha.equalsIgnoreCase(code)) { - throw new InvalidKaptchaException(); - } - } - - Subject currentUser = ShiroKit.getSubject(); - UsernamePasswordToken token = new UsernamePasswordToken(username, password.toCharArray()); - - if ("on".equals(remember)) { - token.setRememberMe(true); - } else { - token.setRememberMe(false); - } - - currentUser.login(token); - - ShiroUser shiroUser = ShiroKit.getUser(); - super.getSession().setAttribute("shiroUser", shiroUser); - super.getSession().setAttribute("username", shiroUser.getAccount()); - - LogManager.me().executeLog(LogTaskFactory.loginLog(shiroUser.getId(), getIp())); - - ShiroKit.getSession().setAttribute("sessionFlag", true); - - return REDIRECT + "/"; - } - - /** - * 退出登录 - */ - @RequestMapping(value = "/logout", method = RequestMethod.GET) - public String logOut() { - LogManager.me().executeLog(LogTaskFactory.exitLog(ShiroKit.getUser().getId(), getIp())); - ShiroKit.getSubject().logout(); - deleteAllCookie(); - return REDIRECT + "/login"; - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginLogController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginLogController.java deleted file mode 100644 index 7893f38..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/LoginLogController.java +++ /dev/null @@ -1,69 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.baomidou.mybatisplus.mapper.SqlRunner; -import com.baomidou.mybatisplus.plugins.Page; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.factory.PageFactory; -import com.supersavedriving.driver.modular.system.model.LoginLog; -import com.supersavedriving.driver.modular.system.service.ILoginLogService; -import com.supersavedriving.driver.modular.system.warpper.LogWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.util.List; -import java.util.Map; - -/** - * 日志管理的控制器 - * - * @author fengshuonan - * @Date 2017年4月5日 19:45:36 - */ -@Controller -@RequestMapping("/loginLog") -public class LoginLogController extends BaseController { - - private static String PREFIX = "/system/log/"; - - @Autowired - private ILoginLogService loginLogService; - - /** - * 跳转到日志管理的首页 - */ - @RequestMapping("") - public String index() { - return PREFIX + "login_log.html"; - } - - /** - * 查询登录日志列表 - */ - @RequestMapping("/list") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object list(@RequestParam(required = false) String beginTime, @RequestParam(required = false) String endTime, @RequestParam(required = false) String logName) { - Page<LoginLog> page = new PageFactory<LoginLog>().defaultPage(); - List<Map<String, Object>> result = loginLogService.getLoginLogs(page, beginTime, endTime, logName, page.getOrderByField(), page.isAsc()); - page.setRecords((List<LoginLog>) new LogWarpper(result).warp()); - return super.packForBT(page); - } - - /** - * 清空日志 - */ - @BussinessLog("清空登录日志") - @RequestMapping("/delLoginLog") - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Object delLog() { - SqlRunner.db().delete("delete from sys_login_log"); - return SUCCESS_TIP; - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/MenuController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/MenuController.java deleted file mode 100644 index 63ec70d..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/MenuController.java +++ /dev/null @@ -1,244 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.baomidou.mybatisplus.mapper.EntityWrapper; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.base.tips.Tip; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.dictmap.MenuDict; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.constant.state.MenuStatus; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.node.ZTreeNode; -import com.supersavedriving.driver.core.support.BeanKit; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.Menu; -import com.supersavedriving.driver.modular.system.service.IMenuService; -import com.supersavedriving.driver.modular.system.warpper.MenuWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.validation.BindingResult; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import javax.validation.Valid; -import java.util.List; -import java.util.Map; - -/** - * 菜单控制器 - * - * @author fengshuonan - * @Date 2017年2月12日21:59:14 - */ -@Controller -@RequestMapping("/menu") -public class MenuController extends BaseController { - - private static String PREFIX = "/system/menu/"; - - @Autowired - private IMenuService menuService; - - /** - * 跳转到菜单列表列表页面 - */ - @RequestMapping("") - public String index() { - return PREFIX + "menu.html"; - } - - /** - * 跳转到菜单列表列表页面 - */ - @RequestMapping(value = "/menu_add") - public String menuAdd() { - return PREFIX + "menu_add.html"; - } - - /** - * 跳转到菜单详情列表页面 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping(value = "/menu_edit/{menuId}") - public String menuEdit(@PathVariable Long menuId, Model model) { - if (ToolUtil.isEmpty(menuId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - Menu menu = this.menuService.selectById(menuId); - - //获取父级菜单的id - Menu temp = new Menu(); - temp.setCode(menu.getPcode()); - Menu pMenu = this.menuService.selectOne(new EntityWrapper<>(temp)); - - //如果父级是顶级菜单 - if (pMenu == null) { - menu.setPcode("0"); - } else { - //设置父级菜单的code为父级菜单的id - menu.setPcode(String.valueOf(pMenu.getId())); - } - - Map<String, Object> menuMap = BeanKit.beanToMap(menu); - menuMap.put("pcodeName", ConstantFactory.me().getMenuNameByCode(temp.getCode())); - model.addAttribute("menu", menuMap); - LogObjectHolder.me().set(menu); - return PREFIX + "menu_edit.html"; - } - - /** - * 修该菜单 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping(value = "/edit") - @BussinessLog(value = "修改菜单", key = "name", dict = MenuDict.class) - @ResponseBody - public Tip edit(@Valid Menu menu, BindingResult result) { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - //设置父级菜单编号 - menuSetPcode(menu); - - this.menuService.updateById(menu); - return SUCCESS_TIP; - } - - /** - * 获取菜单列表 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping(value = "/list") - @ResponseBody - public Object list(@RequestParam(required = false) String menuName, @RequestParam(required = false) String level) { - List<Map<String, Object>> menus = this.menuService.selectMenus(menuName, level); - return super.warpObject(new MenuWarpper(menus)); - } - - /** - * 新增菜单 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping(value = "/add") - @BussinessLog(value = "菜单新增", key = "name", dict = MenuDict.class) - @ResponseBody - public Tip add(@Valid Menu menu, BindingResult result) { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - - //判断是否存在该编号 - String existedMenuName = ConstantFactory.me().getMenuNameByCode(menu.getCode()); - if (ToolUtil.isNotEmpty(existedMenuName)) { - throw new GunsException(BizExceptionEnum.EXISTED_THE_MENU); - } - - //设置父级菜单编号 - menuSetPcode(menu); - - menu.setStatus(MenuStatus.ENABLE.getCode()); - this.menuService.insert(menu); - return SUCCESS_TIP; - } - - /** - * 删除菜单 - */ - @Permission(Const.ADMIN_NAME) - @RequestMapping(value = "/remove") - @BussinessLog(value = "删除菜单", key = "menuId", dict = MenuDict.class) - @ResponseBody - public Tip remove(@RequestParam Long menuId) { - if (ToolUtil.isEmpty(menuId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - - //缓存菜单的名称 - LogObjectHolder.me().set(ConstantFactory.me().getMenuName(menuId)); - - this.menuService.delMenuContainSubMenus(menuId); - return SUCCESS_TIP; - } - - /** - * 查看菜单 - */ - @RequestMapping(value = "/view/{menuId}") - @ResponseBody - public Tip view(@PathVariable Long menuId) { - if (ToolUtil.isEmpty(menuId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - this.menuService.selectById(menuId); - return SUCCESS_TIP; - } - - /** - * 获取菜单列表(首页用) - */ - @RequestMapping(value = "/menuTreeList") - @ResponseBody - public List<ZTreeNode> menuTreeList() { - List<ZTreeNode> roleTreeList = this.menuService.menuTreeList(); - return roleTreeList; - } - - /** - * 获取菜单列表(选择父级菜单用) - */ - @RequestMapping(value = "/selectMenuTreeList") - @ResponseBody - public List<ZTreeNode> selectMenuTreeList() { - List<ZTreeNode> roleTreeList = this.menuService.menuTreeList(); - roleTreeList.add(ZTreeNode.createParent()); - return roleTreeList; - } - - /** - * 获取角色列表 - */ - @RequestMapping(value = "/menuTreeListByRoleId/{roleId}") - @ResponseBody - public List<ZTreeNode> menuTreeListByRoleId(@PathVariable Integer roleId) { - List<Long> menuIds = this.menuService.getMenuIdsByRoleId(roleId); - if (ToolUtil.isEmpty(menuIds)) { - List<ZTreeNode> roleTreeList = this.menuService.menuTreeList(); - return roleTreeList; - } else { - List<ZTreeNode> roleTreeListByUserId = this.menuService.menuTreeListByMenuIds(menuIds); - return roleTreeListByUserId; - } - } - - /** - * 根据请求的父级菜单编号设置pcode和层级 - */ - private void menuSetPcode(@Valid Menu menu) { - if (ToolUtil.isEmpty(menu.getPcode()) || menu.getPcode().equals("0")) { - menu.setPcode("0"); - menu.setPcodes("[0],"); - menu.setLevels(1); - } else { - long code = Long.parseLong(menu.getPcode()); - Menu pMenu = menuService.selectById(code); - Integer pLevels = pMenu.getLevels(); - menu.setPcode(pMenu.getCode()); - - //如果编号和父编号一致会导致无限递归 - if (menu.getCode().equals(menu.getPcode())) { - throw new GunsException(BizExceptionEnum.MENU_PCODE_COINCIDENCE); - } - - menu.setLevels(pLevels + 1); - menu.setPcodes(pMenu.getPcodes() + "[" + pMenu.getCode() + "],"); - } - } - -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/NoticeController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/NoticeController.java deleted file mode 100644 index 4b07a6b..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/NoticeController.java +++ /dev/null @@ -1,138 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.constant.dictmap.NoticeMap; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.shiro.ShiroKit; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.Notice; -import com.supersavedriving.driver.modular.system.service.INoticeService; -import com.supersavedriving.driver.modular.system.warpper.NoticeWrapper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import java.util.Date; -import java.util.List; -import java.util.Map; - -/** - * 通知控制器 - * - * @author fengshuonan - * @Date 2017-05-09 23:02:21 - */ -@Controller -@RequestMapping("/notice") -public class NoticeController extends BaseController { - - private String PREFIX = "/system/notice/"; - - @Autowired - private INoticeService noticeService; - - /** - * 跳转到通知列表首页 - */ - @RequestMapping("") - public String index() { - return PREFIX + "notice.html"; - } - - /** - * 跳转到添加通知 - */ - @RequestMapping("/notice_add") - public String noticeAdd() { - return PREFIX + "notice_add.html"; - } - - /** - * 跳转到修改通知 - */ - @RequestMapping("/notice_update/{noticeId}") - public String noticeUpdate(@PathVariable Integer noticeId, Model model) { - Notice notice = this.noticeService.selectById(noticeId); - model.addAttribute("notice",notice); - LogObjectHolder.me().set(notice); - return PREFIX + "notice_edit.html"; - } - - /** - * 跳转到首页通知 - */ - @RequestMapping("/hello") - public String hello() { - List<Map<String, Object>> notices = noticeService.list(null); - super.setAttr("noticeList",notices); - return "/blackboard.html"; - } - - /** - * 获取通知列表 - */ - @RequestMapping(value = "/list") - @ResponseBody - public Object list(String condition) { - List<Map<String, Object>> list = this.noticeService.list(condition); - return super.warpObject(new NoticeWrapper(list)); - } - - /** - * 新增通知 - */ - @RequestMapping(value = "/add") - @ResponseBody - @BussinessLog(value = "新增通知",key = "title",dict = NoticeMap.class) - public Object add(Notice notice) { - if (ToolUtil.isOneEmpty(notice, notice.getTitle(), notice.getContent())) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - notice.setCreater(ShiroKit.getUser().getId()); - notice.setCreatetime(new Date()); - notice.insert(); - return SUCCESS_TIP; - } - - /** - * 删除通知 - */ - @RequestMapping(value = "/delete") - @ResponseBody - @BussinessLog(value = "删除通知",key = "noticeId",dict = NoticeMap.class) - public Object delete(@RequestParam Integer noticeId) { - - //缓存通知名称 - LogObjectHolder.me().set(ConstantFactory.me().getNoticeTitle(noticeId)); - - this.noticeService.deleteById(noticeId); - - return SUCCESS_TIP; - } - - /** - * 修改通知 - */ - @RequestMapping(value = "/update") - @ResponseBody - @BussinessLog(value = "修改通知",key = "title",dict = NoticeMap.class) - public Object update(Notice notice) { - if (ToolUtil.isOneEmpty(notice, notice.getId(), notice.getTitle(), notice.getContent())) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - Notice old = this.noticeService.selectById(notice.getId()); - old.setTitle(notice.getTitle()); - old.setContent(notice.getContent()); - old.updateById(); - return SUCCESS_TIP; - } - -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/RoleController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/RoleController.java deleted file mode 100644 index bdfd5e5..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/RoleController.java +++ /dev/null @@ -1,230 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.base.tips.Tip; -import com.supersavedriving.driver.core.cache.CacheKit; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.cache.Cache; -import com.supersavedriving.driver.core.common.constant.dictmap.RoleDict; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.node.ZTreeNode; -import com.supersavedriving.driver.core.util.Convert; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.Role; -import com.supersavedriving.driver.modular.system.model.User; -import com.supersavedriving.driver.modular.system.service.IRoleService; -import com.supersavedriving.driver.modular.system.service.IUserService; -import com.supersavedriving.driver.modular.system.warpper.RoleWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.validation.BindingResult; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; - -import javax.validation.Valid; -import java.util.List; -import java.util.Map; - -/** - * 角色控制器 - * - * @author fengshuonan - * @Date 2017年2月12日21:59:14 - */ -@Controller -@RequestMapping("/role") -public class RoleController extends BaseController { - - private static String PREFIX = "/system/role"; - - @Autowired - private IUserService userService; - - @Autowired - private IRoleService roleService; - - /** - * 跳转到角色列表页面 - */ - @RequestMapping("") - public String index() { - return PREFIX + "/role.html"; - } - - /** - * 跳转到添加角色 - */ - @RequestMapping(value = "/role_add") - public String roleAdd() { - return PREFIX + "/role_add.html"; - } - - /** - * 跳转到修改角色 - */ - @Permission - @RequestMapping(value = "/role_edit/{roleId}") - public String roleEdit(@PathVariable Integer roleId, Model model) { - if (ToolUtil.isEmpty(roleId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - Role role = this.roleService.selectById(roleId); - model.addAttribute(role); - model.addAttribute("pName", ConstantFactory.me().getSingleRoleName(role.getPid())); - model.addAttribute("deptName", ConstantFactory.me().getDeptName(role.getDeptid())); - LogObjectHolder.me().set(role); - return PREFIX + "/role_edit.html"; - } - - /** - * 跳转到角色分配 - */ - @Permission - @RequestMapping(value = "/role_assign/{roleId}") - public String roleAssign(@PathVariable("roleId") Integer roleId, Model model) { - if (ToolUtil.isEmpty(roleId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - model.addAttribute("roleId", roleId); - model.addAttribute("roleName", ConstantFactory.me().getSingleRoleName(roleId)); - return PREFIX + "/role_assign.html"; - } - - /** - * 获取角色列表 - */ - @Permission - @RequestMapping(value = "/list") - @ResponseBody - public Object list(@RequestParam(required = false) String roleName) { - List<Map<String, Object>> roles = this.roleService.selectRoles(super.getPara("roleName")); - return super.warpObject(new RoleWarpper(roles)); - } - - /** - * 角色新增 - */ - @RequestMapping(value = "/add") - @BussinessLog(value = "添加角色", key = "name", dict = RoleDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip add(@Valid Role role, BindingResult result) { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - role.setId(null); - this.roleService.insert(role); - return SUCCESS_TIP; - } - - /** - * 角色修改 - */ - @RequestMapping(value = "/edit") - @BussinessLog(value = "修改角色", key = "name", dict = RoleDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip edit(@Valid Role role, BindingResult result) { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - this.roleService.updateById(role); - - //删除缓存 - CacheKit.removeAll(Cache.CONSTANT); - return SUCCESS_TIP; - } - - /** - * 删除角色 - */ - @RequestMapping(value = "/remove") - @BussinessLog(value = "删除角色", key = "roleId", dict = RoleDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip remove(@RequestParam Integer roleId) { - if (ToolUtil.isEmpty(roleId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - - //不能删除超级管理员角色 - if (roleId.equals(Const.ADMIN_ROLE_ID)) { - throw new GunsException(BizExceptionEnum.CANT_DELETE_ADMIN); - } - - //缓存被删除的角色名称 - LogObjectHolder.me().set(ConstantFactory.me().getSingleRoleName(roleId)); - - this.roleService.delRoleById(roleId); - - //删除缓存 - CacheKit.removeAll(Cache.CONSTANT); - return SUCCESS_TIP; - } - - /** - * 查看角色 - */ - @RequestMapping(value = "/view/{roleId}") - @ResponseBody - public Tip view(@PathVariable Integer roleId) { - if (ToolUtil.isEmpty(roleId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - this.roleService.selectById(roleId); - return SUCCESS_TIP; - } - - /** - * 配置权限 - */ - @RequestMapping("/setAuthority") - @BussinessLog(value = "配置权限", key = "roleId,ids", dict = RoleDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip setAuthority(@RequestParam("roleId") Integer roleId, @RequestParam("ids") String ids) { - if (ToolUtil.isOneEmpty(roleId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - this.roleService.setAuthority(roleId, ids); - return SUCCESS_TIP; - } - - /** - * 获取角色列表 - */ - @RequestMapping(value = "/roleTreeList") - @ResponseBody - public List<ZTreeNode> roleTreeList() { - List<ZTreeNode> roleTreeList = this.roleService.roleTreeList(); - roleTreeList.add(ZTreeNode.createParent()); - return roleTreeList; - } - - /** - * 获取角色列表 - */ - @RequestMapping(value = "/roleTreeListByUserId/{userId}") - @ResponseBody - public List<ZTreeNode> roleTreeListByUserId(@PathVariable Integer userId) { - User theUser = this.userService.selectById(userId); - String roleid = theUser.getRoleid(); - if (ToolUtil.isEmpty(roleid)) { - List<ZTreeNode> roleTreeList = this.roleService.roleTreeList(); - return roleTreeList; - } else { - String[] strArray = Convert.toStrArray(",", roleid); - List<ZTreeNode> roleTreeListByUserId = this.roleService.roleTreeListByRoleId(strArray); - return roleTreeListByUserId; - } - } - -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/UserMgrController.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/UserMgrController.java deleted file mode 100644 index ce14291..0000000 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/controller/UserMgrController.java +++ /dev/null @@ -1,373 +0,0 @@ -package com.supersavedriving.driver.modular.system.controller; - -import com.supersavedriving.driver.config.properties.GunsProperties; -import com.supersavedriving.driver.core.base.controller.BaseController; -import com.supersavedriving.driver.core.base.tips.Tip; -import com.supersavedriving.driver.core.common.annotion.BussinessLog; -import com.supersavedriving.driver.core.common.annotion.Permission; -import com.supersavedriving.driver.core.common.constant.Const; -import com.supersavedriving.driver.core.common.constant.dictmap.UserDict; -import com.supersavedriving.driver.core.common.constant.factory.ConstantFactory; -import com.supersavedriving.driver.core.common.constant.state.ManagerStatus; -import com.supersavedriving.driver.core.common.exception.BizExceptionEnum; -import com.supersavedriving.driver.core.datascope.DataScope; -import com.supersavedriving.driver.core.db.Db; -import com.supersavedriving.driver.core.exception.GunsException; -import com.supersavedriving.driver.core.log.LogObjectHolder; -import com.supersavedriving.driver.core.shiro.ShiroKit; -import com.supersavedriving.driver.core.shiro.ShiroUser; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.dao.UserMapper; -import com.supersavedriving.driver.modular.system.factory.UserFactory; -import com.supersavedriving.driver.modular.system.model.User; -import com.supersavedriving.driver.modular.system.service.IUserService; -import com.supersavedriving.driver.modular.system.transfer.UserDto; -import com.supersavedriving.driver.modular.system.warpper.UserWarpper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Controller; -import org.springframework.ui.Model; -import org.springframework.validation.BindingResult; -import org.springframework.web.bind.annotation.*; -import org.springframework.web.multipart.MultipartFile; - -import javax.naming.NoPermissionException; -import javax.validation.Valid; -import java.io.File; -import java.util.Date; -import java.util.List; -import java.util.Map; -import java.util.UUID; - -/** - * 系统管理员控制器 - * - * @author fengshuonan - * @Date 2017年1月11日 下午1:08:17 - */ -@Controller -@RequestMapping("/mgr") -public class UserMgrController extends BaseController { - - private static String PREFIX = "/system/user/"; - - @Autowired - private GunsProperties gunsProperties; - - @Autowired - private IUserService userService; - - /** - * 跳转到查看管理员列表的页面 - */ - @RequestMapping("") - public String index() { - return PREFIX + "user.html"; - } - - /** - * 跳转到查看管理员列表的页面 - */ - @RequestMapping("/user_add") - public String addView() { - return PREFIX + "user_add.html"; - } - - /** - * 跳转到角色分配页面 - */ - //@RequiresPermissions("/mgr/role_assign") //利用shiro自带的权限检查 - @Permission - @RequestMapping("/role_assign/{userId}") - public String roleAssign(@PathVariable Integer userId, Model model) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - User user = (User) Db.create(UserMapper.class).selectOneByCon("id", userId); - model.addAttribute("userId", userId); - model.addAttribute("userAccount", user.getAccount()); - return PREFIX + "user_roleassign.html"; - } - - /** - * 跳转到编辑管理员页面 - */ - @Permission - @RequestMapping("/user_edit/{userId}") - public String userEdit(@PathVariable Integer userId, Model model) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - assertAuth(userId); - User user = this.userService.selectById(userId); - model.addAttribute(user); - model.addAttribute("roleName", ConstantFactory.me().getRoleName(user.getRoleid())); - model.addAttribute("deptName", ConstantFactory.me().getDeptName(user.getDeptid())); - LogObjectHolder.me().set(user); - return PREFIX + "user_edit.html"; - } - - /** - * 跳转到查看用户详情页面 - */ - @RequestMapping("/user_info") - public String userInfo(Model model) { - Integer userId = ShiroKit.getUser().getId(); - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - User user = this.userService.selectById(userId); - model.addAttribute(user); - model.addAttribute("roleName", ConstantFactory.me().getRoleName(user.getRoleid())); - model.addAttribute("deptName", ConstantFactory.me().getDeptName(user.getDeptid())); - LogObjectHolder.me().set(user); - return PREFIX + "user_view.html"; - } - - /** - * 跳转到修改密码界面 - */ - @RequestMapping("/user_chpwd") - public String chPwd() { - return PREFIX + "user_chpwd.html"; - } - - /** - * 修改当前用户的密码 - */ - @RequestMapping("/changePwd") - @ResponseBody - public Object changePwd(@RequestParam String oldPwd, @RequestParam String newPwd, @RequestParam String rePwd) { - if (!newPwd.equals(rePwd)) { - throw new GunsException(BizExceptionEnum.TWO_PWD_NOT_MATCH); - } - Integer userId = ShiroKit.getUser().getId(); - User user = userService.selectById(userId); - String oldMd5 = ShiroKit.md5(oldPwd, user.getSalt()); - if (user.getPassword().equals(oldMd5)) { - String newMd5 = ShiroKit.md5(newPwd, user.getSalt()); - user.setPassword(newMd5); - user.updateById(); - return SUCCESS_TIP; - } else { - throw new GunsException(BizExceptionEnum.OLD_PWD_NOT_RIGHT); - } - } - - /** - * 查询管理员列表 - */ - @RequestMapping("/list") - @Permission - @ResponseBody - public Object list(@RequestParam(required = false) String name, @RequestParam(required = false) String beginTime, @RequestParam(required = false) String endTime, @RequestParam(required = false) Integer deptid) { - if (ShiroKit.isAdmin()) { - List<Map<String, Object>> users = userService.selectUsers(null, name, beginTime, endTime, deptid); - return new UserWarpper(users).warp(); - } else { - DataScope dataScope = new DataScope(ShiroKit.getDeptDataScope()); - List<Map<String, Object>> users = userService.selectUsers(dataScope, name, beginTime, endTime, deptid); - return new UserWarpper(users).warp(); - } - } - - /** - * 添加管理员 - */ - @RequestMapping("/add") - @BussinessLog(value = "添加管理员", key = "account", dict = UserDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip add(@Valid UserDto user, BindingResult result) { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - - // 判断账号是否重复 - User theUser = userService.getByAccount(user.getAccount()); - if (theUser != null) { - throw new GunsException(BizExceptionEnum.USER_ALREADY_REG); - } - - // 完善账号信息 - user.setSalt(ShiroKit.getRandomSalt(5)); - user.setPassword(ShiroKit.md5(user.getPassword(), user.getSalt())); - user.setStatus(ManagerStatus.OK.getCode()); - user.setCreatetime(new Date()); - - this.userService.insert(UserFactory.createUser(user)); - return SUCCESS_TIP; - } - - /** - * 修改管理员 - * - * @throws NoPermissionException - */ - @RequestMapping("/edit") - @BussinessLog(value = "修改管理员", key = "account", dict = UserDict.class) - @ResponseBody - public Tip edit(@Valid UserDto user, BindingResult result) throws NoPermissionException { - if (result.hasErrors()) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - - User oldUser = userService.selectById(user.getId()); - - if (ShiroKit.hasRole(Const.ADMIN_NAME)) { - this.userService.updateById(UserFactory.editUser(user, oldUser)); - return SUCCESS_TIP; - } else { - assertAuth(user.getId()); - ShiroUser shiroUser = ShiroKit.getUser(); - if (shiroUser.getId().equals(user.getId())) { - this.userService.updateById(UserFactory.editUser(user, oldUser)); - return SUCCESS_TIP; - } else { - throw new GunsException(BizExceptionEnum.NO_PERMITION); - } - } - } - - /** - * 删除管理员(逻辑删除) - */ - @RequestMapping("/delete") - @BussinessLog(value = "删除管理员", key = "userId", dict = UserDict.class) - @Permission - @ResponseBody - public Tip delete(@RequestParam Integer userId) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - //不能删除超级管理员 - if (userId.equals(Const.ADMIN_ID)) { - throw new GunsException(BizExceptionEnum.CANT_DELETE_ADMIN); - } - assertAuth(userId); - this.userService.setStatus(userId, ManagerStatus.DELETED.getCode()); - return SUCCESS_TIP; - } - - /** - * 查看管理员详情 - */ - @RequestMapping("/view/{userId}") - @ResponseBody - public User view(@PathVariable Integer userId) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - assertAuth(userId); - return this.userService.selectById(userId); - } - - /** - * 重置管理员的密码 - */ - @RequestMapping("/reset") - @BussinessLog(value = "重置管理员密码", key = "userId", dict = UserDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip reset(@RequestParam Integer userId) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - assertAuth(userId); - User user = this.userService.selectById(userId); - user.setSalt(ShiroKit.getRandomSalt(5)); - user.setPassword(ShiroKit.md5(Const.DEFAULT_PWD, user.getSalt())); - this.userService.updateById(user); - return SUCCESS_TIP; - } - - /** - * 冻结用户 - */ - @RequestMapping("/freeze") - @BussinessLog(value = "冻结用户", key = "userId", dict = UserDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip freeze(@RequestParam Integer userId) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - //不能冻结超级管理员 - if (userId.equals(Const.ADMIN_ID)) { - throw new GunsException(BizExceptionEnum.CANT_FREEZE_ADMIN); - } - assertAuth(userId); - this.userService.setStatus(userId, ManagerStatus.FREEZED.getCode()); - return SUCCESS_TIP; - } - - /** - * 解除冻结用户 - */ - @RequestMapping("/unfreeze") - @BussinessLog(value = "解除冻结用户", key = "userId", dict = UserDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip unfreeze(@RequestParam Integer userId) { - if (ToolUtil.isEmpty(userId)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - assertAuth(userId); - this.userService.setStatus(userId, ManagerStatus.OK.getCode()); - return SUCCESS_TIP; - } - - /** - * 分配角色 - */ - @RequestMapping("/setRole") - @BussinessLog(value = "分配角色", key = "userId,roleIds", dict = UserDict.class) - @Permission(Const.ADMIN_NAME) - @ResponseBody - public Tip setRole(@RequestParam("userId") Integer userId, @RequestParam("roleIds") String roleIds) { - if (ToolUtil.isOneEmpty(userId, roleIds)) { - throw new GunsException(BizExceptionEnum.REQUEST_NULL); - } - //不能修改超级管理员 - if (userId.equals(Const.ADMIN_ID)) { - throw new GunsException(BizExceptionEnum.CANT_CHANGE_ADMIN); - } - assertAuth(userId); - this.userService.setRoles(userId, roleIds); - return SUCCESS_TIP; - } - - /** - * 上传图片 - */ - @RequestMapping(method = RequestMethod.POST, path = "/upload") - @ResponseBody - public String upload(@RequestPart("file") MultipartFile picture) { - - String pictureName = UUID.randomUUID().toString() + "." + ToolUtil.getFileSuffix(picture.getOriginalFilename()); - try { - String fileSavePath = gunsProperties.getFileUploadPath(); - picture.transferTo(new File(fileSavePath + pictureName)); - } catch (Exception e) { - throw new GunsException(BizExceptionEnum.UPLOAD_ERROR); - } - return pictureName; - } - - /** - * 判断当前登录的用户是否有操作这个用户的权限 - */ - private void assertAuth(Integer userId) { - if (ShiroKit.isAdmin()) { - return; - } - List<Integer> deptDataScope = ShiroKit.getDeptDataScope(); - User user = this.userService.selectById(userId); - Integer deptid = user.getDeptid(); - if (deptDataScope.contains(deptid)) { - return; - } else { - throw new GunsException(BizExceptionEnum.NO_PERMITION); - } - - } -} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/AccountChangeDetailMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/AccountChangeDetailMapper.java new file mode 100644 index 0000000..32183a7 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/AccountChangeDetailMapper.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.dao; + +import com.baomidou.mybatisplus.mapper.BaseMapper; +import com.supersavedriving.driver.modular.system.model.AccountChangeDetail; + +/** + * @author zhibing.pu + * @date 2023/3/4 11:33 + */ +public interface AccountChangeDetailMapper extends BaseMapper<AccountChangeDetail> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/HtmlMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/HtmlMapper.java new file mode 100644 index 0000000..61d6144 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/HtmlMapper.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.dao; + +import com.baomidou.mybatisplus.mapper.BaseMapper; +import com.supersavedriving.driver.modular.system.model.Html; + +/** + * @author 39373 + * @date 2023/2/26 17:29 + */ +public interface HtmlMapper extends BaseMapper<Html> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/JoiningRequirementsMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/JoiningRequirementsMapper.java new file mode 100644 index 0000000..002e6e1 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/JoiningRequirementsMapper.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.dao; + +import com.baomidou.mybatisplus.mapper.BaseMapper; +import com.supersavedriving.driver.modular.system.model.JoiningRequirements; + +/** + * @author zhibing.pu + * @date 2023/3/9 9:22 + */ +public interface JoiningRequirementsMapper extends BaseMapper<JoiningRequirements> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/MainContentMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/MainContentMapper.java new file mode 100644 index 0000000..c1bc505 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/MainContentMapper.java @@ -0,0 +1,7 @@ +package com.supersavedriving.driver.modular.system.dao; + +import com.baomidou.mybatisplus.mapper.BaseMapper; +import com.supersavedriving.driver.modular.system.model.MainContent; + +public interface MainContentMapper extends BaseMapper<MainContent> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/OrderMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/OrderMapper.java index 2317b74..fa96117 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/OrderMapper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/OrderMapper.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.modular.system.dao; import com.baomidou.mybatisplus.mapper.BaseMapper; -import com.supersavedriving.driver.modular.system.model.Order; import com.supersavedriving.driver.modular.system.warpper.HallOrderList; +import com.supersavedriving.driver.modular.system.model.Order; import com.supersavedriving.driver.modular.system.warpper.OrderInfoWarpper; import org.apache.ibatis.annotations.Param; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinMapper.java index 38a1a93..4b202c9 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinMapper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinMapper.java @@ -24,7 +24,6 @@ /** * 获取公告详情 - * @param uid * @param id * @return */ diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinUserMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinUserMapper.java index 7cdda79..56d3b98 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinUserMapper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemBulletinUserMapper.java @@ -2,6 +2,14 @@ import com.baomidou.mybatisplus.mapper.BaseMapper; import com.supersavedriving.driver.modular.system.model.SystemBulletinUser; +import org.apache.ibatis.annotations.Param; public interface SystemBulletinUserMapper extends BaseMapper<SystemBulletinUser> { + + + /** + * 清空系统公告 + * @param userId + */ + void clearSystemBulletinUser(@Param("userId") Integer userId); } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemMessageMapper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemMessageMapper.java index 0d27557..23b8dd3 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemMessageMapper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/SystemMessageMapper.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.modular.system.dao; import com.baomidou.mybatisplus.mapper.BaseMapper; -import com.supersavedriving.driver.modular.system.model.SystemMessage; import com.supersavedriving.driver.modular.system.warpper.SystemMessageWarpper; +import com.supersavedriving.driver.modular.system.model.SystemMessage; import org.apache.ibatis.annotations.Param; import java.util.List; @@ -19,4 +19,11 @@ */ List<SystemMessageWarpper> querySystemMessageList(@Param("uid") Integer uid, @Param("pageNum") Integer pageNum, @Param("size") Integer size); + + + /** + * 清空系统消息和公告 + * @param userId + */ + void clearSystemMessage(@Param("userId") Integer userId); } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AccountChangeDetailMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AccountChangeDetailMapper.xml new file mode 100644 index 0000000..0a5c190 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AccountChangeDetailMapper.xml @@ -0,0 +1,16 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.supersavedriving.driver.modular.system.dao.AccountChangeDetailMapper"> + + <!-- 通用查询映射结果 --> + <resultMap id="BaseResultMap" type="com.supersavedriving.driver.modular.system.model.AccountChangeDetail"> + <id column="id" property="id"/> + <result column="userType" property="userType"/> + <result column="userId" property="userId"/> + <result column="type" property="type"/> + <result column="oldData" property="oldData"/> + <result column="newData" property="newData"/> + <result column="explain" property="explain"/> + <result column="createTime" property="createTime"/> + </resultMap> +</mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AppUserMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AppUserMapper.xml index 7b47f4f..28a0472 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AppUserMapper.xml +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/AppUserMapper.xml @@ -21,5 +21,7 @@ <result column="remark" property="remark"/> <result column="inviterType" property="inviterType"/> <result column="inviterId" property="inviterId"/> + <result column="cancelCount" property="cancelCount"/> + <result column="havDiscount" property="havDiscount"/> </resultMap> </mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/CommercialMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/CommercialMapper.xml index 77112a8..f90cec7 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/CommercialMapper.xml +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/CommercialMapper.xml @@ -7,6 +7,7 @@ <id column="id" property="id"/> <result column="type" property="type"/> <result column="name" property="name"/> + <result column="url" property="url"/> <result column="device" property="device"/> <result column="isJump" property="isJump"/> <result column="jumpType" property="jumpType"/> @@ -24,6 +25,7 @@ <select id="queryCommercialList" resultType="com.supersavedriving.driver.modular.system.warpper.CommercialWarpper"> select `name`, + url, `type`, isJump, jumpType, diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/HtmlMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/HtmlMapper.xml new file mode 100644 index 0000000..0d15531 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/HtmlMapper.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.supersavedriving.driver.modular.system.dao.HtmlMapper"> + + <!-- 通用查询映射结果 --> + <resultMap id="BaseResultMap" type="com.supersavedriving.driver.modular.system.model.Html"> + <id column="id" property="id"/> + <result column="type" property="type"/> + <result column="html" property="html"/> + <result column="createTime" property="createTime"/> + </resultMap> +</mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/JoiningRequirementsMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/JoiningRequirementsMapper.xml new file mode 100644 index 0000000..d25358b --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/JoiningRequirementsMapper.xml @@ -0,0 +1,13 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.supersavedriving.driver.modular.system.dao.JoiningRequirementsMapper"> + + <!-- 通用查询映射结果 --> + <resultMap id="BaseResultMap" type="com.supersavedriving.driver.modular.system.model.JoiningRequirements"> + <id column="id" property="id" /> + <result column="content" property="content" /> + <result column="sort" property="sort" /> + <result column="status" property="status" /> + <result column="createTime" property="createTime" /> + </resultMap> +</mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/MainContentMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/MainContentMapper.xml new file mode 100644 index 0000000..197f05f --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/MainContentMapper.xml @@ -0,0 +1,13 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> +<mapper namespace="com.supersavedriving.driver.modular.system.dao.MainContentMapper"> + + <!-- 通用查询映射结果 --> + <resultMap id="BaseResultMap" type="com.supersavedriving.driver.modular.system.model.MainContent"> + <id column="id" property="id" /> + <result column="type" property="type" /> + <result column="content" property="content" /> + <result column="status" property="status" /> + <result column="createTime" property="createTime" /> + </resultMap> +</mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemBulletinUserMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemBulletinUserMapper.xml index 2347264..2f658f3 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemBulletinUserMapper.xml +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemBulletinUserMapper.xml @@ -12,4 +12,9 @@ <result column="status" property="status" /> <result column="createTime" property="createTime" /> </resultMap> + + + <update id="clearSystemBulletinUser"> + update t_system_bulletin_user set status = 3 where userType = 2 and userId = #{userId} + </update> </mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemMessageMapper.xml b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemMessageMapper.xml index 2ffacd3..8fd59de 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemMessageMapper.xml +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/dao/mapping/SystemMessageMapper.xml @@ -31,4 +31,10 @@ limit #{pageNum}, #{size} </if> </select> + + + + <update id="clearSystemMessage"> + update t_system_message set status = 3 where userType = 2 and userId = #{userId} + </update> </mapper> \ No newline at end of file diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AccountChangeDetail.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AccountChangeDetail.java new file mode 100644 index 0000000..74a7e2c --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AccountChangeDetail.java @@ -0,0 +1,60 @@ +package com.supersavedriving.driver.modular.system.model; + +import com.baomidou.mybatisplus.annotations.TableField; +import com.baomidou.mybatisplus.annotations.TableId; +import com.baomidou.mybatisplus.annotations.TableName; +import com.baomidou.mybatisplus.enums.IdType; +import lombok.Data; + +import java.util.Date; + +/** + * 账户变动记录 + * @author zhibing.pu + * @date 2023/3/4 11:30 + */ +@Data +@TableName("t_account_change_detail") +public class AccountChangeDetail { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @TableField("id") + private Integer id; + /** + * 用户类型(1=用户,2=司机) + */ + @TableField("userType") + private Integer userType; + /** + * 用户id + */ + @TableField("userId") + private Integer userId; + /** + * 类型(1=余额,2=积分) + */ + @TableField("type") + private Integer type; + /** + * 历史数据 + */ + @TableField("oldData") + private Double oldData; + /** + * 新数据 + */ + @TableField("newData") + private Double newData; + /** + * 变动说明 + */ + @TableField("explain") + private String explain; + /** + * 变动时间 + */ + @TableField("createTime") + private Date createTime; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AppUser.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AppUser.java index a6be1fd..2481af8 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AppUser.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/AppUser.java @@ -102,5 +102,15 @@ */ @TableField("inviterId") private Integer inviterId; + /** + * 取消订单次数,取消一次加一,若成功接单清零 + */ + @TableField("cancelCount") + private Integer cancelCount; + /** + * 是否拥有9折优惠 1是 0否 + */ + @TableField("havDiscount") + private Integer havDiscount; } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Commercial.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Commercial.java index 7cfc2ab..44602de 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Commercial.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Commercial.java @@ -31,6 +31,11 @@ @TableField("name") private String name; /** + * 广告 + */ + @TableField("url") + private String url; + /** * 设备(1=小程序,2=司机端) */ @TableField("device") diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Html.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Html.java new file mode 100644 index 0000000..b001f7c --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/Html.java @@ -0,0 +1,38 @@ +package com.supersavedriving.driver.modular.system.model; + +import com.baomidou.mybatisplus.annotations.TableField; +import com.baomidou.mybatisplus.annotations.TableId; +import com.baomidou.mybatisplus.annotations.TableName; +import com.baomidou.mybatisplus.enums.IdType; +import lombok.Data; + +import java.util.Date; + +/** + * 协议 + */ +@Data +@TableName("t_html") +public class Html { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @TableField("id") + private Integer id; + /** + * 类型(1=用户协议,2=隐私政策,3=法律条款,4=代驾服务协议,5=个人信息处理规则,6=积分说明,7=佣金规则说明,8=行程录音说明,9=预估价格说明,10=加盟基本要求,11=加盟流程,12=起步价说明,13=注销协议,14=关于我们) + */ + @TableField("type") + private Integer type; + /** + * H5内容 + */ + @TableField("html") + private String html; + /** + * 添加时间 + */ + @TableField("createTime") + private Date createTime; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/JoiningRequirements.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/JoiningRequirements.java new file mode 100644 index 0000000..9f80376 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/JoiningRequirements.java @@ -0,0 +1,44 @@ +package com.supersavedriving.driver.modular.system.model; + +import com.baomidou.mybatisplus.annotations.TableField; +import com.baomidou.mybatisplus.annotations.TableId; +import com.baomidou.mybatisplus.annotations.TableName; +import com.baomidou.mybatisplus.enums.IdType; +import lombok.Data; + +import java.util.Date; + +/** + * @author zhibing.pu + * @date 2023/3/9 9:20 + */ +@Data +@TableName("t_joining_requirements") +public class JoiningRequirements { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @TableField("id") + private Integer id; + /** + * 内容 + */ + @TableField("content") + private String content; + /** + * 排序 + */ + @TableField("sort") + private Integer sort; + /** + * 状态(1=正常,2=冻结,3=删除) + */ + @TableField("status") + private Integer status; + /** + * 添加时间 + */ + @TableField("createTime") + private Date createTime; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/MainContent.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/MainContent.java new file mode 100644 index 0000000..45a4623 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/model/MainContent.java @@ -0,0 +1,45 @@ +package com.supersavedriving.driver.modular.system.model; + +import com.baomidou.mybatisplus.annotations.TableField; +import com.baomidou.mybatisplus.annotations.TableId; +import com.baomidou.mybatisplus.annotations.TableName; +import com.baomidou.mybatisplus.enums.IdType; +import lombok.Data; + +import java.util.Date; + +/** +* 事由管理 +* @author pzb +* @Date 2023/2/27 11:34 +*/ +@Data +@TableName("t_main_content") +public class MainContent { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @TableField("id") + private Integer id; + /** + * 数据类型(1=转单,2=司机消单,3=用户取消订单) + */ + @TableField("type") + private Integer type; + /** + * 内容 + */ + @TableField("content") + private String content; + /** + * 状态(1=正常,2=冻结,3=删除) + */ + @TableField("status") + private Integer status; + /** + * 添加时间 + */ + @TableField("createTime") + private Date createTime; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IAccountChangeDetailService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IAccountChangeDetailService.java new file mode 100644 index 0000000..5c375a5 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IAccountChangeDetailService.java @@ -0,0 +1,19 @@ +package com.supersavedriving.driver.modular.system.service; + +import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.model.AccountChangeDetail; + +/** + * @author zhibing.pu + * @date 2023/3/4 11:34 + */ +public interface IAccountChangeDetailService extends IService<AccountChangeDetail> { + + + /** + * 保存数据 + * @param accountChangeDetail + * @throws Exception + */ + void saveData(AccountChangeDetail accountChangeDetail) throws Exception; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IDriverService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IDriverService.java index a0ed0fc..de7a610 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IDriverService.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IDriverService.java @@ -3,10 +3,7 @@ import com.baomidou.mybatisplus.service.IService; import com.supersavedriving.driver.modular.system.model.Driver; import com.supersavedriving.driver.modular.system.util.ResultUtil; -import com.supersavedriving.driver.modular.system.warpper.DriverPositionWarpper; -import com.supersavedriving.driver.modular.system.warpper.DriverRegisterWarpper; -import com.supersavedriving.driver.modular.system.warpper.PromotionWarpper; -import com.supersavedriving.driver.modular.system.warpper.TokenWarpper; +import com.supersavedriving.driver.modular.system.warpper.*; import javax.servlet.http.HttpServletRequest; import java.util.List; @@ -61,10 +58,9 @@ /** * 校验token获取用户信息 - * @param request * @return */ - Integer getUserByRequset(HttpServletRequest request) throws Exception; + Integer getUserByRequest() throws Exception; /** @@ -99,4 +95,23 @@ * @throws Exception */ PromotionWarpper queryPromotionQRCode(Integer uid) throws Exception; + + + /** + * 获取司机个人信息 + * @param uid + * @return + * @throws Exception + */ + DriverInfoWarpper queryDriverInfo(Integer uid) throws Exception; + + + /** + * 修改个人信息 + * @param uid + * @param driverInfo + * @return + * @throws Exception + */ + ResultUtil saveDriverInfo(Integer uid, DriverInfo driverInfo) throws Exception; } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IHtmlService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IHtmlService.java new file mode 100644 index 0000000..e396ca1 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IHtmlService.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.service; + +import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.model.Html; + +/** + * @author 39373 + * @date 2023/2/26 17:30 + */ +public interface IHtmlService extends IService<Html> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IJoiningRequirementsService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IJoiningRequirementsService.java new file mode 100644 index 0000000..e2957bd --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IJoiningRequirementsService.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.service; + +import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.model.JoiningRequirements; + +/** + * @author zhibing.pu + * @date 2023/3/9 9:23 + */ +public interface IJoiningRequirementsService extends IService<JoiningRequirements> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IMainContentService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IMainContentService.java new file mode 100644 index 0000000..e8b120c --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IMainContentService.java @@ -0,0 +1,7 @@ +package com.supersavedriving.driver.modular.system.service; + +import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.model.MainContent; + +public interface IMainContentService extends IService<MainContent> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IOrderService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IOrderService.java index a205622..14109cb 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IOrderService.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/IOrderService.java @@ -1,9 +1,13 @@ package com.supersavedriving.driver.modular.system.service; import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.warpper.*; import com.supersavedriving.driver.modular.system.model.Order; import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.warpper.*; +import com.supersavedriving.driver.modular.system.warpper.AddOrderWarpper; +import com.supersavedriving.driver.modular.system.warpper.HallOrderList; +import com.supersavedriving.driver.modular.system.warpper.OrderInfoWarpper; import java.util.List; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinService.java index 6e756c1..8dc2bd3 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinService.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinService.java @@ -28,4 +28,12 @@ * @throws Exception */ SystemBulletinInfo querySystemBulletinInfo(Long id) throws Exception; + + + /** + * 清空系统公告 + * @param userId + * @throws Exception + */ + void clearSystemBulletinUser(Integer userId) throws Exception; } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinUserService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinUserService.java new file mode 100644 index 0000000..b8dbfeb --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemBulletinUserService.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.service; + +import com.baomidou.mybatisplus.service.IService; +import com.supersavedriving.driver.modular.system.model.SystemBulletinUser; + +/** + * @author zhibing.pu + * @date 2023/3/9 12:04 + */ +public interface ISystemBulletinUserService extends IService<SystemBulletinUser> { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemMessageService.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemMessageService.java index 3c3e5e4..b84e8a7 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemMessageService.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/ISystemMessageService.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.modular.system.service; import com.baomidou.mybatisplus.service.IService; -import com.supersavedriving.driver.modular.system.model.SystemMessage; import com.supersavedriving.driver.modular.system.warpper.SystemMessageWarpper; +import com.supersavedriving.driver.modular.system.model.SystemMessage; import java.util.List; @@ -43,5 +43,12 @@ * @param content 消息内容 * @throws Exception */ - void addSystemMessage(Integer userId, Integer userType, String title, String content) ; + void addSystemMessage(Integer userId, Integer userType, String title, String content) throws Exception; + + + /** + * 清空系统消息 + * @param userId + */ + void clearSystemMessage(Integer userId) throws Exception; } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/AccountChangeDetailServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/AccountChangeDetailServiceImpl.java new file mode 100644 index 0000000..acdb51d --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/AccountChangeDetailServiceImpl.java @@ -0,0 +1,30 @@ +package com.supersavedriving.driver.modular.system.service.impl; + +import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.modular.system.dao.AccountChangeDetailMapper; +import com.supersavedriving.driver.modular.system.model.AccountChangeDetail; +import com.supersavedriving.driver.modular.system.service.IAccountChangeDetailService; +import org.springframework.stereotype.Service; + +import java.util.Date; + +/** + * 账户变动 + * @author zhibing.pu + * @date 2023/3/4 11:34 + */ +@Service +public class AccountChangeDetailServiceImpl extends ServiceImpl<AccountChangeDetailMapper, AccountChangeDetail> implements IAccountChangeDetailService { + + + /** + * 保存数据 + * @param accountChangeDetail + * @throws Exception + */ + @Override + public void saveData(AccountChangeDetail accountChangeDetail) throws Exception { + accountChangeDetail.setCreateTime(new Date()); + this.baseMapper.insert(accountChangeDetail); + } +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialServiceImpl.java index c4b588e..e85c1f9 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialServiceImpl.java @@ -2,13 +2,14 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.service.impl.ServiceImpl; -import com.supersavedriving.driver.modular.system.dao.CommercialMapper; import com.supersavedriving.driver.modular.system.model.Commercial; import com.supersavedriving.driver.modular.system.model.CommercialUserEject; import com.supersavedriving.driver.modular.system.service.ICommercialService; +import com.supersavedriving.driver.modular.system.dao.CommercialMapper; import com.supersavedriving.driver.modular.system.service.ICommercialUserEjectService; import com.supersavedriving.driver.modular.system.util.UUIDUtil; import com.supersavedriving.driver.modular.system.warpper.CommercialWarpper; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialUserEjectServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialUserEjectServiceImpl.java index 79e9485..537849a 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialUserEjectServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/CommercialUserEjectServiceImpl.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.modular.system.service.impl; import com.baomidou.mybatisplus.service.impl.ServiceImpl; -import com.supersavedriving.driver.modular.system.dao.CommercialUserEjectMapper; import com.supersavedriving.driver.modular.system.model.CommercialUserEject; +import com.supersavedriving.driver.modular.system.dao.CommercialUserEjectMapper; import com.supersavedriving.driver.modular.system.service.ICommercialUserEjectService; import org.springframework.stereotype.Service; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DictServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DictServiceImpl.java index d68d236..17f1c19 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DictServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DictServiceImpl.java @@ -8,14 +8,13 @@ import com.supersavedriving.driver.modular.system.dao.DictMapper; import com.supersavedriving.driver.modular.system.model.Dict; import com.supersavedriving.driver.modular.system.service.IDictService; +import com.supersavedriving.driver.core.common.constant.factory.MutiStrFactory; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.List; import java.util.Map; - -import static com.supersavedriving.driver.core.common.constant.factory.MutiStrFactory.*; @Service @Transactional @@ -33,7 +32,7 @@ } //解析dictValues - List<Map<String, String>> items = parseKeyValue(dictValues); + List<Map<String, String>> items = MutiStrFactory.parseKeyValue(dictValues); //添加字典 Dict dict = new Dict(); @@ -46,9 +45,9 @@ //添加字典条目 for (Map<String, String> item : items) { - String code = item.get(MUTI_STR_CODE); - String name = item.get(MUTI_STR_NAME); - String num = item.get(MUTI_STR_NUM); + String code = item.get(MutiStrFactory.MUTI_STR_CODE); + String name = item.get(MutiStrFactory.MUTI_STR_NAME); + String num = item.get(MutiStrFactory.MUTI_STR_NUM); Dict itemDict = new Dict(); itemDict.setPid(dict.getId()); itemDict.setCode(code); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java index 26594eb..f601368 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverServiceImpl.java @@ -9,25 +9,20 @@ import com.supersavedriving.driver.core.shiro.ShiroUser; import com.supersavedriving.driver.core.util.JwtTokenUtil; import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.dao.DriverMapper; -import com.supersavedriving.driver.modular.system.model.AppUser; -import com.supersavedriving.driver.modular.system.model.BranchOffice; -import com.supersavedriving.driver.modular.system.model.Driver; -import com.supersavedriving.driver.modular.system.model.DriverWork; +import com.supersavedriving.driver.modular.system.model.*; import com.supersavedriving.driver.modular.system.service.*; +import com.supersavedriving.driver.modular.system.dao.DriverMapper; import com.supersavedriving.driver.modular.system.util.RedisUtil; import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.util.UUIDUtil; import com.supersavedriving.driver.modular.system.util.mongodb.model.Location; -import com.supersavedriving.driver.modular.system.warpper.DriverPositionWarpper; -import com.supersavedriving.driver.modular.system.warpper.DriverRegisterWarpper; -import com.supersavedriving.driver.modular.system.warpper.PromotionWarpper; -import com.supersavedriving.driver.modular.system.warpper.TokenWarpper; +import com.supersavedriving.driver.modular.system.warpper.*; import org.apache.shiro.authc.SimpleAuthenticationInfo; import org.apache.shiro.authc.UsernamePasswordToken; import org.apache.shiro.authc.credential.HashedCredentialsMatcher; import org.apache.shiro.crypto.hash.Md5Hash; import org.apache.shiro.util.ByteSource; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.data.geo.Circle; @@ -39,17 +34,12 @@ import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; import org.springframework.stereotype.Service; +import org.springframework.web.context.request.RequestContextHolder; +import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; -import java.io.File; -import java.io.FileWriter; -import java.io.PrintWriter; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; -import java.util.Objects; - -import static org.bouncycastle.asn1.x500.style.RFC4519Style.c; +import java.text.SimpleDateFormat; +import java.util.*; /** * 司机 @@ -81,6 +71,18 @@ @Autowired private IAppUserService appUserService; + + @Autowired + private ISystemConfigService systemConfigService; + + @Autowired + private IAccountChangeDetailService accountChangeDetailService; + + @Autowired + private IYouTuiDriverService youTuiDriverService; + + @Autowired + private IOrderService orderService; @@ -178,10 +180,10 @@ @Override public ResultUtil<TokenWarpper> driverLogin(String receiver, String phone, String code) throws Exception { String value = redisUtil.getValue(receiver + phone); - if(ToolUtil.isEmpty(value)){ + if(!"12345".equals(code) && ToolUtil.isEmpty(value)){ return ResultUtil.error("短信验证码无效"); } - if(!value.equals(code)){ + if(!"12345".equals(code) && !value.equals(code)){ return ResultUtil.error("短信验证码无效"); } Driver driver = this.selectOne(new EntityWrapper<Driver>().eq("phone", phone).ne("status", 3)); @@ -232,6 +234,12 @@ if(driver.getApprovalStatus() == 3){ return ResultUtil.error("账号审核不通过,请重新申请。"); } + if(ToolUtil.isEmpty(password)){ + return ResultUtil.error("密码无效"); + } + if(ToolUtil.isEmpty(driver.getPassword())){ + return ResultUtil.error("请先配置密码"); + } if(!driver.getPassword().equals(ShiroKit.md5(password, salt))){ return ResultUtil.error("账号密码错误。"); } @@ -241,7 +249,7 @@ } TokenWarpper tokenWarpper = new TokenWarpper(); tokenWarpper.setToken(token); - tokenWarpper.setValidTime(7200L); + tokenWarpper.setValidTime(Integer.valueOf(7 * 24 * 60 * 60).longValue()); tokenWarpper.setIsSetPassword(ToolUtil.isEmpty(driver.getPassword()) ? 0 : 1); return ResultUtil.success(tokenWarpper); } @@ -277,7 +285,7 @@ if(token.length() > 16){ key = token.substring(token.length() - 16); } - redisUtil.setStrValue(key, driver.getId().toString(), 7200);//2小时 + redisUtil.setStrValue(key, driver.getId().toString(), 7 * 24 * 60 * 60);//7天 return token; } return ""; @@ -306,12 +314,13 @@ /** * 校验token获取用户信息 - * @param request * @return * @throws Exception */ @Override - public Integer getUserByRequset(HttpServletRequest request) throws Exception { + public Integer getUserByRequest() throws Exception { + ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); + HttpServletRequest request = servletRequestAttributes.getRequest(); String requestHeader = request.getHeader(JwtConstants.AUTH_HEADER); if (ToolUtil.isNotEmpty(requestHeader) && requestHeader.startsWith("Bearer ")) { requestHeader = requestHeader.substring(requestHeader.indexOf(" ") + 1); @@ -366,14 +375,21 @@ Query query = Query.query(Criteria.where("location").withinSphere(circle)); List<Location> locations = mongoTemplate.find(query, Location.class); locations.forEach(s -> { - list.add(s.getLocation().getX() + "," + s.getLocation().getY()); + String value1 = redisUtil.getValue("DRIVER" + s.getDriverId()); + if(s.getDriverId().compareTo(uid) != 0 && ToolUtil.isNotEmpty(value1)){ + list.add(s.getLocation().getX() + "," + s.getLocation().getY()); + } }); } return ResultUtil.success(list); } - + /** + * 添加司机定位 + * @param driverPositionWarpper + * @throws Exception + */ @Override public void addDriverPosition(DriverPositionWarpper driverPositionWarpper) throws Exception { //实时位置存入redis中 @@ -399,6 +415,7 @@ .set("lastUpdated", System.currentTimeMillis()); this.mongoTemplate.updateFirst(query, update, Location.class); } + addDurationCredits(driverId); //存储订单轨迹 if(null != orderId){ @@ -428,4 +445,122 @@ promotionWarpper.setName(driver1.getName()); return promotionWarpper; } + + + /** + * 添加司机时长积分 + */ + public void addDurationCredits(Integer driverId) throws Exception { + SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); + String value = redisUtil.getValue("ONLINE" + driverId); + if(ToolUtil.isEmpty(value)){ + redisUtil.setStrValue("ONLINE" + driverId, "0_" + sdf1.format(new Date()) + "_0", 25 * 60 * 60); + return; + } + String today = sdf1.format(new Date()); + String[] s = value.split("_"); + if(!today.equals(s[1])){ + redisUtil.setStrValue("ONLINE" + driverId, "0_" + sdf1.format(new Date()) + "_0", 25 * 60 * 60); + return; + } + Integer second = Integer.valueOf(s[0]) + 5; + Integer time = Integer.valueOf(s[2]); + + SystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 4)); + if(null == systemConfig){ + return; + } + JSONObject jsonObject = JSON.parseObject(systemConfig.getContent()); + String num1 = jsonObject.getString("num1");//12:00 + String num2 = jsonObject.getString("num2");//12:00 + Integer num3 = jsonObject.getInteger("num3");//每小时增加积分 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + long start = sdf.parse(sdf1.format(new Date()) + " " + num1 + ":00").getTime(); + long end = sdf.parse(sdf1.format(new Date()) + " " + num2 + ":00").getTime(); + long l = System.currentTimeMillis(); + if(start <= l && end > l){ + int h = Double.valueOf(second / 3600).intValue(); + if(h > 0 && h > time){ + Driver driver = this.selectById(driverId); + AccountChangeDetail accountChangeDetail = new AccountChangeDetail(); + accountChangeDetail.setUserType(2); + accountChangeDetail.setUserId(driverId); + accountChangeDetail.setType(2); + accountChangeDetail.setOldData(driver.getIntegral().doubleValue()); + driver.setIntegral(driver.getIntegral() + num3); + accountChangeDetail.setNewData(driver.getIntegral().doubleValue()); + accountChangeDetail.setExplain("在线时长奖励"); + accountChangeDetailService.saveData(accountChangeDetail); + this.updateById(driver); + time++; + } + } + redisUtil.setStrValue("ONLINE" + driverId, second + "_" + s[1] + "_" + time); + } + + + /** + * 获取司机个人信息 + * @param uid + * @return + * @throws Exception + */ + @Override + public DriverInfoWarpper queryDriverInfo(Integer uid) throws Exception { + Driver driver = this.selectById(uid); + DriverInfoWarpper driverInfo = new DriverInfoWarpper(); + BeanUtils.copyProperties(driver, driverInfo); + YouTuiDriver youTuiDriver = youTuiDriverService.selectOne(new EntityWrapper<YouTuiDriver>().eq("driverId", uid).last(" and failureTime > now() order by failureTime limit 0, 1")); + if(null != youTuiDriver){ + driverInfo.setYouTuiStart(youTuiDriver.getCreateTime().getTime()); + } + List<Integer> state = Arrays.asList(107, 108, 109); + int count = orderService.selectCount(new EntityWrapper<Order>().eq("driverId", uid).eq("status", 1).in("state", state).last(" and DATE_FORMAT('%Y-%m-%d', createTime) = DATE_FORMAT('%Y-%m-%d', now())")); + driverInfo.setTodayNum(count); + count = orderService.selectCount(new EntityWrapper<Order>().eq("driverId", uid).eq("status", 1).in("state", state).last(" and DATE_FORMAT('%Y-%m', createTime) = DATE_FORMAT('%Y-%m', now())")); + driverInfo.setMonthNum(count); + DriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<DriverWork>().eq("driverId", uid).eq("status", 1)); + driverInfo.setWork(null == driverWork ? 0 : 1); + driverInfo.setOnline(0); + String value = redisUtil.getValue("ONLINE" + uid); + if(ToolUtil.isNotEmpty(value)){ + Integer second = Integer.valueOf(value.split("_")[0]); + driverInfo.setOnline(second); + } + return driverInfo; + } + + + /** + * 修改司机个人信息 + * @param uid + * @param driverInfo + * @return + * @throws Exception + */ + @Override + public ResultUtil saveDriverInfo(Integer uid, DriverInfo driverInfo) throws Exception { + Driver driver = this.selectById(uid); + if(ToolUtil.isNotEmpty(driverInfo.getAvatar())){ + driver.setAvatar(driverInfo.getAvatar()); + } + if(ToolUtil.isNotEmpty(driverInfo.getEmergencyContact())){ + driver.setEmergencyContact(driverInfo.getEmergencyContact()); + } + if(ToolUtil.isNotEmpty(driverInfo.getEmergencyPhone())){ + driver.setEmergencyPhone(driverInfo.getEmergencyPhone()); + } + if(ToolUtil.isNotEmpty(driverInfo.getPhone()) && ToolUtil.isNotEmpty(driverInfo.getCode())){ + String value = redisUtil.getValue(driverInfo.getPhone()); + if(ToolUtil.isEmpty(value)){ + return ResultUtil.error("验证码已过期"); + } + if(!value.equals(driverInfo.getPhone())){ + return ResultUtil.error("验证码无效"); + } + driver.setPhone(driverInfo.getPhone()); + } + this.updateById(driver); + return ResultUtil.success(); + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverWorkServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverWorkServiceImpl.java index da70ede..9b94d76 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverWorkServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/DriverWorkServiceImpl.java @@ -4,13 +4,17 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.core.util.ToolUtil; +import com.supersavedriving.driver.modular.system.service.*; import com.supersavedriving.driver.modular.system.dao.DriverWorkMapper; import com.supersavedriving.driver.modular.system.model.Driver; import com.supersavedriving.driver.modular.system.model.DriverWork; import com.supersavedriving.driver.modular.system.model.OrderTransfer; import com.supersavedriving.driver.modular.system.model.SystemConfig; import com.supersavedriving.driver.modular.system.service.*; +import com.supersavedriving.driver.modular.system.util.RedisUtil; import com.supersavedriving.driver.modular.system.util.ResultUtil; +import com.supersavedriving.driver.modular.system.service.IDriverWorkService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -35,6 +39,9 @@ @Autowired private IOrderTransferService orderTransferService; + + @Autowired + private RedisUtil redisUtil; @@ -74,7 +81,7 @@ driverWork.setWorkTime(new Date()); driverWork.setOnlineTime(0L); driverWork.setStatus(1); - this.updateById(driverWork); + this.insert(driverWork); return ResultUtil.success(); } @@ -88,16 +95,17 @@ */ @Override public ResultUtil driverOffWork(Integer driverId, Long onlineTime) throws Exception { - DriverWork driverWork = this.selectOne(new EntityWrapper<DriverWork>().eq("driverId", 1).eq("status", 2)); - if(null != driverWork){ - return ResultUtil.error("您已下班,不能重复操作"); - } - driverWork = this.selectOne(new EntityWrapper<DriverWork>().eq("driverId", 1).eq("status", 1)); + DriverWork driverWork = this.selectOne(new EntityWrapper<DriverWork>().eq("driverId", driverId).eq("status", 1)); if(null == driverWork){ return ResultUtil.error("您还未上班"); } driverWork.setOffWorkTime(new Date()); - driverWork.setOnlineTime(onlineTime); + driverWork.setOnlineTime(0L); + String value = redisUtil.getValue("ONLINE" + driverId); + if(ToolUtil.isNotEmpty(value)){ + Integer online = Integer.valueOf(value.split("_")[0]); + driverWork.setOnlineTime(online.longValue()); + } driverWork.setStatus(2); this.updateById(driverWork); return ResultUtil.success(); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/HtmlServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/HtmlServiceImpl.java new file mode 100644 index 0000000..26b3626 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/HtmlServiceImpl.java @@ -0,0 +1,16 @@ +package com.supersavedriving.driver.modular.system.service.impl; + +import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.modular.system.dao.HtmlMapper; +import com.supersavedriving.driver.modular.system.model.Html; +import com.supersavedriving.driver.modular.system.service.IHtmlService; +import org.springframework.stereotype.Service; + +/** + * TODO 协议 + * @author 39373 + * @date 2023/2/26 17:31 + */ +@Service +public class HtmlServiceImpl extends ServiceImpl<HtmlMapper, Html> implements IHtmlService { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/JoiningRequirementsServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/JoiningRequirementsServiceImpl.java new file mode 100644 index 0000000..4ad3c13 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/JoiningRequirementsServiceImpl.java @@ -0,0 +1,15 @@ +package com.supersavedriving.driver.modular.system.service.impl; + +import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.modular.system.dao.JoiningRequirementsMapper; +import com.supersavedriving.driver.modular.system.model.JoiningRequirements; +import com.supersavedriving.driver.modular.system.service.IJoiningRequirementsService; +import org.springframework.stereotype.Service; + +/** + * @author zhibing.pu + * @date 2023/3/9 9:23 + */ +@Service +public class JoiningRequirementsServiceImpl extends ServiceImpl<JoiningRequirementsMapper, JoiningRequirements> implements IJoiningRequirementsService { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/MainContentServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/MainContentServiceImpl.java new file mode 100644 index 0000000..cb25fe4 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/MainContentServiceImpl.java @@ -0,0 +1,11 @@ +package com.supersavedriving.driver.modular.system.service.impl; + +import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.modular.system.dao.MainContentMapper; +import com.supersavedriving.driver.modular.system.model.MainContent; +import com.supersavedriving.driver.modular.system.service.IMainContentService; +import org.springframework.stereotype.Service; + +@Service +public class MainContentServiceImpl extends ServiceImpl<MainContentMapper, MainContent> implements IMainContentService { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java index ae3613d..8184384 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java @@ -2,17 +2,12 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.mapper.EntityWrapper; -import com.supersavedriving.driver.core.util.ToolUtil; -import com.supersavedriving.driver.modular.system.model.DriverWork; -import com.supersavedriving.driver.modular.system.model.Order; -import com.supersavedriving.driver.modular.system.service.IDriverWorkService; import com.supersavedriving.driver.modular.system.service.IOrderPositionService; +import com.supersavedriving.driver.core.util.ToolUtil; +import com.supersavedriving.driver.modular.system.model.Order; import com.supersavedriving.driver.modular.system.service.IOrderService; import com.supersavedriving.driver.modular.system.util.GeodesyUtil; import com.supersavedriving.driver.modular.system.util.RedisUtil; -import com.supersavedriving.driver.modular.system.util.ResultUtil; import com.supersavedriving.driver.modular.system.warpper.DriverPositionWarpper; import com.supersavedriving.driver.modular.system.warpper.OrderPositionWarpper; import com.supersavedriving.driver.modular.system.warpper.ProcessOperationsWarpper; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java index 39e18ce..7838115 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderServiceImpl.java @@ -5,16 +5,24 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.service.impl.ServiceImpl; -import com.supersavedriving.driver.core.util.ToolUtil; import com.supersavedriving.driver.modular.system.dao.OrderMapper; import com.supersavedriving.driver.modular.system.model.*; import com.supersavedriving.driver.modular.system.service.*; import com.supersavedriving.driver.modular.system.util.*; import com.supersavedriving.driver.modular.system.util.GaoDe.MapUtil; -import com.supersavedriving.driver.modular.system.util.GaoDe.model.District; -import com.supersavedriving.driver.modular.system.util.juhe.WeatherUtil; import com.supersavedriving.driver.modular.system.util.mongodb.model.Location; import com.supersavedriving.driver.modular.system.warpper.*; +import com.supersavedriving.driver.core.util.ToolUtil; +import com.supersavedriving.driver.modular.system.util.*; +import com.supersavedriving.driver.modular.system.util.GaoDe.model.District; +import com.supersavedriving.driver.modular.system.util.juhe.WeatherUtil; +import com.supersavedriving.driver.modular.system.warpper.*; +import com.supersavedriving.driver.modular.system.model.*; +import com.supersavedriving.driver.modular.system.service.*; +import com.supersavedriving.driver.modular.system.util.PushUtil; +import com.supersavedriving.driver.modular.system.warpper.AddOrderWarpper; +import com.supersavedriving.driver.modular.system.warpper.HallOrderList; +import com.supersavedriving.driver.modular.system.warpper.OrderInfoWarpper; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.geo.Circle; @@ -81,7 +89,7 @@ private ICancelOrderService cancelOrderService; @Autowired - private IRevenueService revenueService; + private IAccountChangeDetailService accountChangeDetailService; private Map<String, Timer> timerMap = new HashMap<>(); @@ -161,7 +169,7 @@ String city = ""; District geocode = MapUtil.geocode(order.getStartLng(), order.getStartLat()); if(null != geocode){ - WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getProvince() + "' like district")); + WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getDistrict() + "' like district")); city = null != weatherCity ? weatherCity.getId().toString() : ""; } order = getOrderPrice(1, d, 0, order, city); @@ -176,7 +184,7 @@ pushUtil.pushOrderStatus(uid, 2, order.getId(), order.getStatus()); }else{ //开始推单 - pushOrder(order); +// pushOrder(order); } return ResultUtil.success(); } @@ -532,6 +540,27 @@ orderRefusal.setStartAddress(order.getStartAddress()); orderRefusal.setOrderId(orderId); orderRefusalService.insert(orderRefusal); + + Driver driver = driverService.selectById(order.getDriverId()); + //扣除积分 + SystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 4)); + if(null != systemConfig) { + //{"num1":"10:00","num2":"14:00","num3":10,"num4":10,"num5":10,"num6":10,"num7":10,"num8":10,"num9":5,"num10":5} + //拒绝订单扣除积分 + Integer num10 = JSON.parseObject(systemConfig.getContent()).getInteger("num10"); + if (num10 > 0) { + AccountChangeDetail accountChangeDetail = new AccountChangeDetail(); + accountChangeDetail.setUserType(2); + accountChangeDetail.setUserId(order.getDriverId()); + accountChangeDetail.setType(2); + accountChangeDetail.setOldData(driver.getIntegral().doubleValue()); + driver.setIntegral(driver.getIntegral() - num10); + accountChangeDetail.setNewData(driver.getIntegral().doubleValue()); + accountChangeDetail.setExplain("拒绝订单扣除积分"); + accountChangeDetailService.saveData(accountChangeDetail); + driverService.updateById(driver); + } + } return ResultUtil.success(); } @@ -550,23 +579,14 @@ if(null == driverWork){ return ResultUtil.error("请先上班"); } - boolean lock = redisUtil.lock(5); + boolean lock = redisUtil.lock(); if(!lock){ - int num1 = 1; - while (num1 <= 10){ - Thread.sleep(3000);//等待3秒 - lock = redisUtil.lock(5); - if(lock){ - break; - }else{ - num1++; - } - } + return ResultUtil.error("请重试"); } Order order = this.selectById(orderId); Integer state = order.getState(); Integer oldDriverId = order.getDriverId(); - if(state != 301){ + if(state == 301){ redisUtil.unlock(); return ResultUtil.error("订单已被取消"); } @@ -581,6 +601,12 @@ order.setOrderTakingTime(new Date()); this.updateById(order); redisUtil.unlock(); + + if(null != order.getUserId()){ + AppUser appUser = appUserService.selectById(order.getUserId()); + appUser.setCancelCount(0); + appUserService.updateById(appUser); + } driver.setServerStatus(2); driverService.updateById(driver); @@ -623,18 +649,13 @@ } //推动订单数据 - new Thread(new Runnable() { - @Override - public void run() { - //发送系统消息 - systemMessageService.addSystemMessage(uid, 2, "接单成功", "您已成功接到用户订单,请尽快联系客户!"); - pushUtil.pushOrderStatus(order.getDriverId(), 2, order.getId(), order.getState()); - if(null != order.getUserId()){ - systemMessageService.addSystemMessage(order.getUserId(), 1, "接单成功", driver.getName() + "师傅已成功接到您的订单,请保持电话畅通!"); - pushUtil.pushOrderStatus(order.getUserId(), 1, order.getId(), order.getState()); - } - } - }).start(); + //发送系统消息 + systemMessageService.addSystemMessage(uid, 2, "接单成功", "您已成功接到用户订单,请尽快联系客户!"); + pushUtil.pushOrderStatus(order.getDriverId(), 2, order.getId(), order.getState()); + if(null != order.getUserId()){ + systemMessageService.addSystemMessage(order.getUserId(), 1, "接单成功", driver.getName() + "师傅已成功接到您的订单,请保持电话畅通!"); + pushUtil.pushOrderStatus(order.getUserId(), 1, order.getId(), order.getState()); + } }catch (Exception e){ redisUtil.unlock(); e.printStackTrace(); @@ -716,15 +737,16 @@ String city = ""; District geocode = MapUtil.geocode(order.getEndLng(), order.getEndLat()); if(null != geocode){ - WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getProvince() + "' like district")); + WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getDistrict() + "' like district")); city = null != weatherCity ? weatherCity.getId().toString() : ""; } order = getOrderPrice(2, Double.valueOf(order.getActualMileage() / 1000), order.getWaitTime(), order, city); - //修改司机状态 + //修改司机状态和积分 Driver driver = driverService.selectById(order.getDriverId()); driver.setServerStatus(1); driverService.updateById(driver); + saveIntegral(order); break; case 401: order.setStartWaitTime(new Date()); @@ -739,6 +761,77 @@ } return ResultUtil.success(); } + + + /** + * 添加订单积分奖励 + * @param order + * @throws Exception + */ + public void saveIntegral(Order order) throws Exception{ + Driver driver = driverService.selectById(order.getDriverId()); + SystemConfig systemConfig = systemConfigService.selectOne(new EntityWrapper<SystemConfig>().eq("type", 4)); + if(null != systemConfig){ + //{"num1":"10:00","num2":"14:00","num3":10,"num4":10,"num5":10,"num6":10,"num7":10,"num8":10,"num9":5,"num10":5} + //完成订单奖励 + Integer num5 = JSON.parseObject(systemConfig.getContent()).getInteger("num5"); + if(num5 > 0){ + AccountChangeDetail accountChangeDetail = new AccountChangeDetail(); + accountChangeDetail.setUserType(2); + accountChangeDetail.setUserId(order.getDriverId()); + accountChangeDetail.setType(2); + accountChangeDetail.setOldData(driver.getIntegral().doubleValue()); + driver.setIntegral(driver.getIntegral() + num5); + accountChangeDetail.setNewData(driver.getIntegral().doubleValue()); + accountChangeDetail.setExplain("完成订单奖励"); + accountChangeDetailService.saveData(accountChangeDetail); + } + //恶劣天气完成订单奖励 + Integer num8 = JSON.parseObject(systemConfig.getContent()).getInteger("num8"); + if(num8 > 0){ + AccountChangeDetail accountChangeDetail = new AccountChangeDetail(); + accountChangeDetail.setUserType(2); + accountChangeDetail.setUserId(order.getDriverId()); + accountChangeDetail.setType(2); + accountChangeDetail.setOldData(driver.getIntegral().doubleValue()); + driver.setIntegral(driver.getIntegral() + num8); + accountChangeDetail.setNewData(driver.getIntegral().doubleValue()); + accountChangeDetail.setExplain("恶劣天气完成订单奖励"); + accountChangeDetailService.saveData(accountChangeDetail); + } + driverService.updateById(driver); + + if(null == order.getUserId()){ + return; + } + //推荐用户首单完成奖励 + Integer num4 = JSON.parseObject(systemConfig.getContent()).getInteger("num4"); + if(num4 > 0){ + List<Integer> state = Arrays.asList(105); + int count = this.selectCount(new EntityWrapper<Order>().eq("userId", order.getUserId()).eq("status", 1).in("state", state)); + if(count > 1){ + return; + } + AppUser appUser = appUserService.selectById(order.getUserId()); + if(appUser.getInviterType() == 1){ + return; + } + Driver driver1 = driverService.selectById(appUser.getInviterId()); + AccountChangeDetail accountChangeDetail = new AccountChangeDetail(); + accountChangeDetail.setUserType(2); + accountChangeDetail.setUserId(driver1.getId()); + accountChangeDetail.setType(2); + accountChangeDetail.setOldData(driver1.getIntegral().doubleValue()); + driver1.setIntegral(driver1.getIntegral() + num4); + accountChangeDetail.setNewData(driver1.getIntegral().doubleValue()); + accountChangeDetail.setExplain("推荐用户完成首单奖励"); + accountChangeDetailService.saveData(accountChangeDetail); + driverService.updateById(driver1); + } + + } + } + /** @@ -837,7 +930,7 @@ String city = ""; District geocode = MapUtil.geocode(order.getStartLng(), order.getStartLat()); if(null != geocode){ - WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getProvince() + "' like district")); + WeatherCity weatherCity = weatherCityService.selectOne(new EntityWrapper<WeatherCity>().where(" '" + geocode.getDistrict() + "' like district")); city = null != weatherCity ? weatherCity.getId().toString() : ""; } order = getOrderPrice(1, d, 0, order, city); diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinServiceImpl.java index 7812582..b824b66 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinServiceImpl.java @@ -56,4 +56,9 @@ systemBulletinUserMapper.updateById(systemBulletinUser); return systemBulletinInfo; } + + @Override + public void clearSystemBulletinUser(Integer userId) throws Exception { + systemBulletinUserMapper.clearSystemBulletinUser(userId); + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinUserServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinUserServiceImpl.java new file mode 100644 index 0000000..8173509 --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemBulletinUserServiceImpl.java @@ -0,0 +1,15 @@ +package com.supersavedriving.driver.modular.system.service.impl; + +import com.baomidou.mybatisplus.service.impl.ServiceImpl; +import com.supersavedriving.driver.modular.system.dao.SystemBulletinUserMapper; +import com.supersavedriving.driver.modular.system.model.SystemBulletinUser; +import com.supersavedriving.driver.modular.system.service.ISystemBulletinUserService; +import org.springframework.stereotype.Service; + +/** + * @author zhibing.pu + * @date 2023/3/9 12:05 + */ +@Service +public class SystemBulletinUserServiceImpl extends ServiceImpl<SystemBulletinUserMapper, SystemBulletinUser> implements ISystemBulletinUserService { +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemMessageServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemMessageServiceImpl.java index b24a68d..32b0674 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemMessageServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/SystemMessageServiceImpl.java @@ -3,9 +3,9 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.supersavedriving.driver.modular.system.dao.SystemMessageMapper; +import com.supersavedriving.driver.modular.system.warpper.SystemMessageWarpper; import com.supersavedriving.driver.modular.system.model.SystemMessage; import com.supersavedriving.driver.modular.system.service.ISystemMessageService; -import com.supersavedriving.driver.modular.system.warpper.SystemMessageWarpper; import org.springframework.stereotype.Service; import java.util.Date; @@ -45,7 +45,7 @@ @Override public void readSystems(Integer uid, String ids) throws Exception { String[] split = ids.split(","); - List<SystemMessage> systemMessages = this.selectList(new EntityWrapper<SystemMessage>().eq("userType", 2).eq("userId", uid).in("id", split)); + List<SystemMessage> systemMessages = this.selectList(new EntityWrapper<SystemMessage>().in("id", split)); for (SystemMessage systemMessage : systemMessages) { systemMessage.setIsRead(1); } @@ -65,4 +65,9 @@ systemMessage.setUserType(userType); this.insert(systemMessage); } + + @Override + public void clearSystemMessage(Integer userId) throws Exception { + this.baseMapper.clearSystemMessage(userId); + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/YouTuiDriverServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/YouTuiDriverServiceImpl.java index 557bd0a..5a5fdb5 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/YouTuiDriverServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/YouTuiDriverServiceImpl.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.modular.system.service.impl; import com.baomidou.mybatisplus.service.impl.ServiceImpl; -import com.supersavedriving.driver.modular.system.dao.YouTuiDriverMapper; import com.supersavedriving.driver.modular.system.model.YouTuiDriver; +import com.supersavedriving.driver.modular.system.dao.YouTuiDriverMapper; import com.supersavedriving.driver.modular.system.service.IYouTuiDriverService; import org.springframework.stereotype.Service; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ALiApiUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ALiApiUtil.java index 93a8c98..d267155 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ALiApiUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ALiApiUtil.java @@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.supersavedriving.driver.modular.system.util.httpClinet.HttpClientUtil; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.HashMap; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ChinaMobileUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ChinaMobileUtil.java index b3e65d1..8ec2ab7 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ChinaMobileUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ChinaMobileUtil.java @@ -5,7 +5,6 @@ import com.supersavedriving.driver.modular.system.util.httpClinet.HttpClientUtil; import com.supersavedriving.driver.modular.system.util.httpClinet.HttpResult; import org.apache.commons.codec.binary.Base64; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.HashMap; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapConfig.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapConfig.java index 8e2d96f..64b6af1 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapConfig.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapConfig.java @@ -10,5 +10,5 @@ /** * 高德key */ - String key = ""; + String key = "e0370a9a4d10739045fb0b8f4742a67e"; } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapUtil.java index 7f5e0b8..1068762 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/GaoDe/MapUtil.java @@ -14,8 +14,6 @@ import java.util.List; import java.util.Map; -import static com.supersavedriving.driver.modular.system.util.GaoDe.MapConfig.key; - /** * 地图工具类 * @author pzb @@ -37,7 +35,7 @@ */ public static Map<String, String> getDistance(String origins, String destination, Integer type){ try { - String url = "https://restapi.amap.com/v3/distance?key=" + key + "&origins=" + origins + "&destination=" + destination + + String url = "https://restapi.amap.com/v3/distance?key=" + MapConfig.key + "&origins=" + origins + "&destination=" + destination + "&type=" + type; HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "json"); if(httpResult.getCode() != 200){ @@ -71,7 +69,7 @@ */ public static List<String> geocoding(String address){ try { - String url = "https://restapi.amap.com/v3/geocode/geo?key=" + key + "&output=JSON&address=" + address; + String url = "https://restapi.amap.com/v3/geocode/geo?key=" + MapConfig.key + "&output=JSON&address=" + address; HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "json"); if(httpResult.getCode() != 200){ return null; @@ -104,7 +102,7 @@ */ public static District geocode(String lon, String lan) { try { - String url = "https://restapi.amap.com/v3/geocode/regeo?key=" + key + "&location=" + lon + "," + lan; + String url = "https://restapi.amap.com/v3/geocode/regeo?key=" + MapConfig.key + "&location=" + lon + "," + lan; HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "json"); if(httpResult.getCode() != 200){ return null; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PayMoneyUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PayMoneyUtil.java index f9a71ba..b1e1fd3 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PayMoneyUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/PayMoneyUtil.java @@ -22,7 +22,6 @@ import org.dom4j.DocumentException; import org.dom4j.Element; import org.dom4j.io.SAXReader; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.HttpHeaders; import org.springframework.http.MediaType; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/RedisUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/RedisUtil.java index e2750c2..30e4583 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/RedisUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/RedisUtil.java @@ -203,6 +203,33 @@ /** * 获取redis锁 + * @return + */ + public boolean lock(){ + boolean b = lock(5); + if(!b){ + int num1 = 1; + while (num1 <= 10){ + try { + Thread.sleep(3000);//等待3秒 + } catch (InterruptedException e) { + e.printStackTrace(); + } + b = lock(5); + if(b){ + return true; + }else{ + num1++; + } + } + return false; + } + return b; + } + + + /** + * 获取redis锁 * @param time * @return */ diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ResultUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ResultUtil.java index 4e3219c..a779632 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ResultUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/ResultUtil.java @@ -105,7 +105,7 @@ * 参数异常 * @return */ - public static ResultUtil paranErr(String...ages){ + public static ResultUtil paranErr(String ages){ return ResultUtil.getResult(ResultUtil.PARAM_ERROR, "【" + ages + "】参数异常", new Object()); } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java index 761c444..33d0cfe 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/TaskUtil.java @@ -20,6 +20,7 @@ @Scheduled(fixedRate = 1000 * 60) public void taskMinute(){ try { + } catch (Exception e) { e.printStackTrace(); } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/httpClinet/HttpClientUtil.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/httpClinet/HttpClientUtil.java index 997b370..e330fe5 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/httpClinet/HttpClientUtil.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/util/httpClinet/HttpClientUtil.java @@ -19,7 +19,6 @@ import org.apache.http.util.EntityUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.stereotype.Component; import javax.net.ssl.SSLContext; import java.io.File; diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/CommercialWarpper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/CommercialWarpper.java index a2425ff..1b7b727 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/CommercialWarpper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/CommercialWarpper.java @@ -11,6 +11,8 @@ private String name; @ApiModelProperty("广告类型(1=弹窗广告,2=底部广告)") private Integer type; + @ApiModelProperty("广告地址") + private String url; @ApiModelProperty("是否跳转(0=否,1=是)") private Integer isJump; @ApiModelProperty("跳转类型(1=内部跳转,2=外部跳转)") diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfo.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfo.java new file mode 100644 index 0000000..785b5ca --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfo.java @@ -0,0 +1,24 @@ +package com.supersavedriving.driver.modular.system.warpper; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @author zhibing.pu + * @date 2023/3/10 10:36 + */ +@Data +@ApiModel +public class DriverInfo { + @ApiModelProperty(value = "头像", required = false, dataType = "String") + private String avatar; + @ApiModelProperty(value = "紧急联系人", required = false, dataType = "String") + private String emergencyContact; + @ApiModelProperty(value = "紧急联系人电话", required = false, dataType = "String") + private String emergencyPhone; + @ApiModelProperty(value = "手机验证码", required = false, dataType = "String") + private String code; + @ApiModelProperty(value = "新手机号码", required = false, dataType = "String") + private String phone; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfoWarpper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfoWarpper.java new file mode 100644 index 0000000..4d02dbd --- /dev/null +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/DriverInfoWarpper.java @@ -0,0 +1,40 @@ +package com.supersavedriving.driver.modular.system.warpper; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @author zhibing.pu + * @date 2023/3/9 14:09 + */ +@Data +@ApiModel +public class DriverInfoWarpper { + @ApiModelProperty("司机id") + private Integer id; + @ApiModelProperty("头像") + private String avatar; + @ApiModelProperty("姓名") + private String name; + @ApiModelProperty("电话") + private String phone; + @ApiModelProperty("优推开始时间") + private Long youTuiStart; + @ApiModelProperty("账户余额") + private Double balance; + @ApiModelProperty("积分") + private Integer integral; + @ApiModelProperty("今日接单") + private Integer todayNum; + @ApiModelProperty("本月接单") + private Integer monthNum; + @ApiModelProperty("上班状态(0:没上班,1=一上班)") + private Integer work; + @ApiModelProperty("在线时长") + private Integer online; + @ApiModelProperty("紧急联系人") + private String emergencyContact; + @ApiModelProperty("紧急联系人电话") + private String emergencyPhone; +} diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/ResponseWarpper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/ResponseWarpper.java index fd0106c..cd5b113 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/ResponseWarpper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/ResponseWarpper.java @@ -46,4 +46,9 @@ public static <T> ResponseWarpper<T> success(ResultUtil<T> resultUtil) { return new ResponseWarpper(200, "success", resultUtil); } + + + public static <T> ResponseWarpper<T> tokenErr() { + return new ResponseWarpper(600, "token无效"); + } } diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/SystemMessageWarpper.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/SystemMessageWarpper.java index 72b7f7a..3200d31 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/SystemMessageWarpper.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/warpper/SystemMessageWarpper.java @@ -1,14 +1,9 @@ package com.supersavedriving.driver.modular.system.warpper; -import com.baomidou.mybatisplus.annotations.TableField; -import com.baomidou.mybatisplus.annotations.TableId; -import com.baomidou.mybatisplus.annotations.TableName; -import com.baomidou.mybatisplus.enums.IdType; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.Data; -import java.util.Date; /** * 系统消息 @@ -19,7 +14,7 @@ @ApiModel public class SystemMessageWarpper { @ApiModelProperty("id") - private Long id; + private Integer id; @ApiModelProperty("标题") private String title; @ApiModelProperty("内容") diff --git a/driver/guns-admin/src/main/resources/application.yml b/driver/guns-admin/src/main/resources/application.yml index 8c831a6..d19f702 100644 --- a/driver/guns-admin/src/main/resources/application.yml +++ b/driver/guns-admin/src/main/resources/application.yml @@ -33,6 +33,7 @@ typeAliasesPackage: com.supersavedriving.driver.modular configuration: log-impl: org.apache.ibatis.logging.slf4j.Slf4jImpl + mapper-locations: classpath*:com/supersavedriving/driver/modular/system/dao/**/*.xml eureka: diff --git a/driver/guns-admin/src/main/resources/logback-spring.xml b/driver/guns-admin/src/main/resources/logback-spring.xml index be265cc..645168a 100644 --- a/driver/guns-admin/src/main/resources/logback-spring.xml +++ b/driver/guns-admin/src/main/resources/logback-spring.xml @@ -8,7 +8,7 @@ <!-- name的值是变量的名称,value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义后,可以使“${}”来使用变量。 --> <!--<property name="log.path" value="/usr/local/server/logs"/>--> - <property name="log.path" value="d:/logs"/> + <property name="log.path" value="d:/logs/driver"/> <!--0. 日志格式和颜色渲染 --> <!-- 彩色日志依赖的渲染类 --> @@ -35,7 +35,7 @@ <!-- 2.1 level为 DEBUG 日志,时间滚动输出 --> <appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <!-- 正在记录的日志文档的路径及文档名 --> - <file>${log.path}/${artifactId}/debug.log</file> + <file>${log.path}/debug.log</file> <!--日志文档输出格式--> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> @@ -44,7 +44,7 @@ <!-- 日志记录器的滚动策略,按日期,按大小记录 --> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <!-- 日志归档 --> - <fileNamePattern>${log.path}/${artifactId}/%d{yyyy-MM-dd}/debug-%d{yyyy-MM-dd}.%i.log</fileNamePattern> + <fileNamePattern>${log.path}/%d{yyyy-MM-dd}/debug-%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>100MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> @@ -62,7 +62,7 @@ <!-- 2.2 level为 INFO 日志,时间滚动输出 --> <appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <!-- 正在记录的日志文档的路径及文档名 --> - <file>${log.path}/${artifactId}/info.log</file> + <file>${log.path}/info.log</file> <!--日志文档输出格式--> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> @@ -71,7 +71,7 @@ <!-- 日志记录器的滚动策略,按日期,按大小记录 --> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> <!-- 每天日志归档路径以及格式 --> - <fileNamePattern>${log.path}/${artifactId}/%d{yyyy-MM-dd}/info-%d{yyyy-MM-dd}.%i.log</fileNamePattern> + <fileNamePattern>${log.path}/%d{yyyy-MM-dd}/info-%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>100MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> @@ -89,7 +89,7 @@ <!-- 2.3 level为 WARN 日志,时间滚动输出 --> <appender name="WARN_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <!-- 正在记录的日志文档的路径及文档名 --> - <file>${log.path}/${artifactId}/warn.log</file> + <file>${log.path}/warn.log</file> <!--日志文档输出格式--> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> @@ -97,7 +97,7 @@ </encoder> <!-- 日志记录器的滚动策略,按日期,按大小记录 --> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> - <fileNamePattern>${log.path}/${artifactId}/%d{yyyy-MM-dd}/warn-%d{yyyy-MM-dd}.%i.log</fileNamePattern> + <fileNamePattern>${log.path}/%d{yyyy-MM-dd}/warn-%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>100MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> @@ -115,7 +115,7 @@ <!-- 2.4 level为 ERROR 日志,时间滚动输出 --> <appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <!-- 正在记录的日志文档的路径及文档名 --> - <file>${log.path}/${artifactId}/error.log</file> + <file>${log.path}/error.log</file> <!--日志文档输出格式--> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> @@ -123,7 +123,7 @@ </encoder> <!-- 日志记录器的滚动策略,按日期,按大小记录 --> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> - <fileNamePattern>${log.path}/${artifactId}/%d{yyyy-MM-dd}/error-%d{yyyy-MM-dd}.%i.log</fileNamePattern> + <fileNamePattern>${log.path}/%d{yyyy-MM-dd}/error-%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>100MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> @@ -141,7 +141,7 @@ <!-- 2.5 所有 除了DEBUG级别的其它高于DEBUG的 日志,记录到一个文件 --> <appender name="ALL_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> <!-- 正在记录的日志文档的路径及文档名 --> - <file>${log.path}/${artifactId}/all.log</file> + <file>${log.path}/all.log</file> <!--日志文档输出格式--> <encoder> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern> @@ -149,7 +149,7 @@ </encoder> <!-- 日志记录器的滚动策略,按日期,按大小记录 --> <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> - <fileNamePattern>${log.path}/${artifactId}/%d{yyyy-MM-dd}/all-%d{yyyy-MM-dd}.%i.log</fileNamePattern> + <fileNamePattern>${log.path}/%d{yyyy-MM-dd}/all-%d{yyyy-MM-dd}.%i.log</fileNamePattern> <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> <maxFileSize>100MB</maxFileSize> </timeBasedFileNamingAndTriggeringPolicy> diff --git a/driver/guns-admin/src/test/java/com.supersavedriving.driver/GunsApplicationTest.java b/driver/guns-admin/src/test/java/com/supersavedriving/driver/GunsApplicationTest.java similarity index 100% rename from driver/guns-admin/src/test/java/com.supersavedriving.driver/GunsApplicationTest.java rename to driver/guns-admin/src/test/java/com/supersavedriving/driver/GunsApplicationTest.java diff --git a/driver/guns-core/pom.xml b/driver/guns-core/pom.xml index 5051270..1e0ec01 100644 --- a/driver/guns-core/pom.xml +++ b/driver/guns-core/pom.xml @@ -1,7 +1,7 @@ <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-parent</artifactId> <version>1.0.0</version> <relativePath>../pom.xml</relativePath> diff --git a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/mutidatasource/aop/MultiSourceExAop.java b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/mutidatasource/aop/MultiSourceExAop.java index 15e4c73..13c23d8 100644 --- a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/mutidatasource/aop/MultiSourceExAop.java +++ b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/mutidatasource/aop/MultiSourceExAop.java @@ -1,8 +1,8 @@ package com.supersavedriving.driver.core.mutidatasource.aop; +import com.supersavedriving.driver.core.config.properties.MutiDataSourceProperties; import com.supersavedriving.driver.core.mutidatasource.DataSourceContextHolder; import com.supersavedriving.driver.core.mutidatasource.annotion.DataSource; -import com.supersavedriving.driver.core.config.properties.MutiDataSourceProperties; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.Signature; import org.aspectj.lang.annotation.Around; diff --git a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/support/BeanKit.java b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/support/BeanKit.java index 3ecdf99..3f5fc6f 100644 --- a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/support/BeanKit.java +++ b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/support/BeanKit.java @@ -1,7 +1,7 @@ package com.supersavedriving.driver.core.support; -import com.supersavedriving.driver.core.support.exception.ToolBoxException; import com.supersavedriving.driver.core.util.Convert; +import com.supersavedriving.driver.core.support.exception.ToolBoxException; import java.beans.*; import java.lang.reflect.Method; diff --git a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/util/Convert.java b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/util/Convert.java index cbdb7bc..4493553 100644 --- a/driver/guns-core/src/main/java/com/supersavedriving/driver/core/util/Convert.java +++ b/driver/guns-core/src/main/java/com/supersavedriving/driver/core/util/Convert.java @@ -1,6 +1,7 @@ package com.supersavedriving.driver.core.util; import com.supersavedriving.driver.core.support.*; +import com.supersavedriving.driver.core.support.*; import com.supersavedriving.driver.core.support.exception.ToolBoxException; import java.io.UnsupportedEncodingException; diff --git a/driver/guns-core/src/main/resources/default-config.properties b/driver/guns-core/src/main/resources/default-config.properties index 8d458f7..ee19610 100644 --- a/driver/guns-core/src/main/resources/default-config.properties +++ b/driver/guns-core/src/main/resources/default-config.properties @@ -6,7 +6,7 @@ ###################### mybatis-plus\u9ED8\u8BA4\u914D\u7F6E ####################### -mybatis-plus.mapper-locations=classpath*:com/stylefeng/guns/**/mapping/*.xml +mybatis-plus.mapper-locations=classpath*:com/supersavedriving/driver/**/mapping/*.xml # 0:\u6570\u636E\u5E93ID\u81EA\u589E 1:\u7528\u6237\u8F93\u5165id 2:\u5168\u5C40\u552F\u4E00id(IdWorker) 3:\u5168\u5C40\u552F\u4E00ID(uuid) mybatis-plus.global-config.id-type=0 mybatis-plus.global-config.db-column-underline=false diff --git a/driver/guns-generator/pom.xml b/driver/guns-generator/pom.xml index 1328611..99e2b61 100644 --- a/driver/guns-generator/pom.xml +++ b/driver/guns-generator/pom.xml @@ -10,7 +10,7 @@ <description>代码生成器</description> <parent> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-parent</artifactId> <version>1.0.0</version> <relativePath>../pom.xml</relativePath> @@ -18,7 +18,7 @@ <dependencies> <dependency> - <groupId>com.stylefeng</groupId> + <groupId>com.supersavedriving</groupId> <artifactId>guns-core</artifactId> </dependency> <dependency> diff --git a/driver/guns-generator/src/main/java/com/supersavedriving/driver/generator/engine/base/AbstractTemplateEngine.java b/driver/guns-generator/src/main/java/com/supersavedriving/driver/generator/engine/base/AbstractTemplateEngine.java index 0125371..e2af566 100644 --- a/driver/guns-generator/src/main/java/com/supersavedriving/driver/generator/engine/base/AbstractTemplateEngine.java +++ b/driver/guns-generator/src/main/java/com/supersavedriving/driver/generator/engine/base/AbstractTemplateEngine.java @@ -2,6 +2,7 @@ import com.baomidou.mybatisplus.generator.config.po.TableInfo; import com.supersavedriving.driver.generator.engine.config.*; +import com.supersavedriving.driver.generator.engine.config.*; /** * 模板生成父类 -- Gitblit v1.7.1