QianQiao
/
2204A
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

2204-11-20 列表 添加

yingxiao
笨蛋 2024-11-22 23:12:18 +08:00
parent c40c0bc0cf
commit e083e409db
51 changed files with 381 additions and 159 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
doc/doc.json 100644
View File

@ -0,0 +1,25 @@
{
"商品id(projectId)": "Long",
"商品图片(projectImage)": "String",
"活动名称(activityName)": "String",
"活动介绍(activities)": "Test",
"商品单位(projectUnit)": "Long",
"轮播图(carouselImages)": [
"String",
"String"
],
"拼团策略id(strategyId)": "Long",
"拼团策略类型(strategyType)": "String",
"商品规格List(projectSkuList)": [
{
"商品sku(productSku)": "String",
"拼团价格(teamPrice)": "decimal",
"库存库存(teamStock)": "int"
}
],
"全重(weight)": "Long",
"商品详情（goodsDetails）": "String"
}

6
muyu-auth/src/main/java/com/muyu/auth/service/SysLoginService.java
View File

@ -69,7 +69,7 @@ public class SysLoginService {
if (StringUtils.isNull(userResult) || StringUtils.isNull(userResult.getData())) {
recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, "登录用户不存在");
throw new ServiceException("登录用户：" + username + " 不存在");
throw new ServiceException("登录用户:" + username + " 不存在");
}
if (Result.FAIL == userResult.getCode()) {
@ -80,11 +80,11 @@ public class SysLoginService {
SysUser user = userResult.getData().getSysUser();
if (UserStatus.DELETED.getCode().equals(user.getDelFlag())) {
recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, "对不起，您的账号已被删除");
throw new ServiceException("对不起，您的账号：" + username + " 已被删除");
throw new ServiceException("对不起，您的账号:" + username + " 已被删除");
}
if (UserStatus.DISABLE.getCode().equals(user.getStatus())) {
recordLogService.recordLogininfor(username, Constants.LOGIN_FAIL, "用户已停用，请联系管理员");
throw new ServiceException("对不起，您的账号：" + username + " 已停用");
throw new ServiceException("对不起，您的账号:" + username + " 已停用");
}
passwordService.validate(user, password);
recordLogService.recordLogininfor(username, Constants.LOGIN_SUCCESS, "登录成功");

12
muyu-auth/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

2
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/annotation/Excel.java
View File

@ -144,7 +144,7 @@ public @interface Excel {
public String[] args () default {};
/**
* 字段类型（0：导出导入；1：仅导出；2：仅导入）
* 字段类型（0:导出导入；1:仅导出；2:仅导入）
*/
Type type () default Type.ALL;

2
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/context/SecurityContextHolder.java
View File

@ -10,7 +10,7 @@ import java.util.concurrent.ConcurrentHashMap;
/**
* 获取当前线程变量中的 用户id、用户名称、Token等信息
* 注意： 必须在网关通过请求头的方法传入，同时在HeaderInterceptor拦截器设置值。 否则这里无法获取
* 注意: 必须在网关通过请求头的方法传入，同时在HeaderInterceptor拦截器设置值。 否则这里无法获取
*
* @author muyu
*/

2
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/text/Convert.java
View File

@ -480,7 +480,7 @@ public class Convert {
/**
* 转换为boolean<br>
* String支持的值为：true、false、yes、ok、no，1,0 如果给定的值为空，或者转换失败，返回默认值<br>
* String支持的值为:true、false、yes、ok、no，1,0 如果给定的值为空，或者转换失败，返回默认值<br>
* 转换失败不会报错
*
* @param value 被转换的值

8
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/text/StrFormatter.java
View File

@ -17,10 +17,10 @@ public class StrFormatter {
* 格式化字符串<br>
* 此方法只是简单将占位符 {} 按照顺序替换为参数<br>
* 如果想输出 {} 使用 \\转义 { 即可，如果想输出 {} 之前的 \ 使用双转义符 \\\\ 即可<br>
* 例：<br>
* 通常使用：format("this is {} for {}", "a", "b") -> this is a for b<br>
* 转义{}： format("this is \\{} for {}", "a", "b") -> this is \{} for a<br>
* 转义\： format("this is \\\\{} for {}", "a", "b") -> this is \a for b<br>
* 例:<br>
* 通常使用:format("this is {} for {}", "a", "b") -> this is a for b<br>
* 转义{}: format("this is \\{} for {}", "a", "b") -> this is \{} for a<br>
* 转义\: format("this is \\\\{} for {}", "a", "b") -> this is \a for b<br>
*
* @param strPattern 字符串模板
* @param argArray 参数列表

34
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/utils/StringUtils.java
View File

@ -40,7 +40,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param coll 要判断的Collection
*
* @return true：为空 false：非空
* @return true:为空 false:非空
*/
public static boolean isEmpty (Collection<?> coll) {
return isNull(coll) || coll.isEmpty();
@ -51,7 +51,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param coll 要判断的Collection
*
* @return true：非空 false：空
* @return true:非空 false:空
*/
public static boolean isNotEmpty (Collection<?> coll) {
return !isEmpty(coll);
@ -61,7 +61,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
* * 判断一个对象数组是否为空
*
* @param objects 要判断的对象数组
* * @return true：为空 false：非空
* * @return true:为空 false:非空
*/
public static boolean isEmpty (Object[] objects) {
return isNull(objects) || (objects.length == 0);
@ -72,7 +72,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param objects 要判断的对象数组
*
* @return true：非空 false：空
* @return true:非空 false:空
*/
public static boolean isNotEmpty (Object[] objects) {
return !isEmpty(objects);
@ -83,7 +83,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param map 要判断的Map
*
* @return true：为空 false：非空
* @return true:为空 false:非空
*/
public static boolean isEmpty (Map<?, ?> map) {
return isNull(map) || map.isEmpty();
@ -94,7 +94,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param map 要判断的Map
*
* @return true：非空 false：空
* @return true:非空 false:空
*/
public static boolean isNotEmpty (Map<?, ?> map) {
return !isEmpty(map);
@ -105,7 +105,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param str String
*
* @return true：为空 false：非空
* @return true:为空 false:非空
*/
public static boolean isEmpty (String str) {
return isNull(str) || NULLSTR.equals(str.trim());
@ -116,7 +116,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param str String
*
* @return true：非空串 false：空串
* @return true:非空串 false:空串
*/
public static boolean isNotEmpty (String str) {
return !isEmpty(str);
@ -127,7 +127,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param object Object
*
* @return true：为空 false：非空
* @return true:为空 false:非空
*/
public static boolean isNull (Object object) {
return object == null;
@ -138,7 +138,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param object Object
*
* @return true：非空 false：空
* @return true:非空 false:空
*/
public static boolean isNotNull (Object object) {
return !isNull(object);
@ -149,7 +149,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
*
* @param object 对象
*
* @return true：是数组 false：不是数组
* @return true:是数组 false:不是数组
*/
public static boolean isArray (Object object) {
return isNotNull(object) && object.getClass().isArray();
@ -253,10 +253,10 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
* 格式化文本, {} 表示占位符<br>
* 此方法只是简单将占位符 {} 按照顺序替换为参数<br>
* 如果想输出 {} 使用 \\转义 { 即可，如果想输出 {} 之前的 \ 使用双转义符 \\\\ 即可<br>
* 例：<br>
* 通常使用：format("this is {} for {}", "a", "b") -> this is a for b<br>
* 转义{}： format("this is \\{} for {}", "a", "b") -> this is \{} for a<br>
* 转义\： format("this is \\\\{} for {}", "a", "b") -> this is \a for b<br>
* 例:<br>
* 通常使用:format("this is {} for {}", "a", "b") -> this is a for b<br>
* 转义{}: format("this is \\{} for {}", "a", "b") -> this is \{} for a<br>
* 转义\: format("this is \\\\{} for {}", "a", "b") -> this is \a for b<br>
*
* @param template 文本模板，被替换的部分用 {} 表示
* @param params 参数值
@ -361,7 +361,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
}
/**
* 将下划线大写方式命名的字符串转换为驼峰式。如果转换前的下划线大写方式命名的字符串为空，则返回空字符串。 例如：HELLO_WORLD->HelloWorld
* 将下划线大写方式命名的字符串转换为驼峰式。如果转换前的下划线大写方式命名的字符串为空，则返回空字符串。 例如:HELLO_WORLD->HelloWorld
*
* @param name 转换前的下划线大写方式命名的字符串
*
@ -393,7 +393,7 @@ public class StringUtils extends org.apache.commons.lang3.StringUtils {
/**
* 驼峰式命名法
* 例如：user_name->userName
* 例如:user_name->userName
*/
public static String toCamelCase (String s) {
if (s == null) {

4
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/utils/file/FileUtils.java
View File

@ -16,12 +16,12 @@ import java.nio.charset.StandardCharsets;
*/
public class FileUtils {
/**
* 字符常量：斜杠 {@code '/'}
* 字符常量:斜杠 {@code '/'}
*/
public static final char SLASH = '/';
/**
* 字符常量：反斜杠 {@code '\\'}
* 字符常量:反斜杠 {@code '\\'}
*/
public static final char BACKSLASH = '\\';

6
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/utils/poi/ExcelUtil.java
View File

@ -67,7 +67,7 @@ public class ExcelUtil<T> {
*/
private String sheetName;
/**
* 导出类型（EXPORT:导出数据；IMPORT：导入模板）
* 导出类型（EXPORT:导出数据；IMPORT:导入模板）
*/
private Type type;
/**
@ -764,7 +764,7 @@ public class ExcelUtil<T> {
* 创建表格样式
*/
public void setDataValidation (Excel attr, Row row, int column) {
if (attr.name().indexOf("注：") >= 0) {
if (attr.name().indexOf("注:") >= 0) {
sheet.setColumnWidth(column, 6000);
} else {
// 设置列宽
@ -880,7 +880,7 @@ public class ExcelUtil<T> {
DataValidationHelper helper = sheet.getDataValidationHelper();
// 加载下拉列表内容
DataValidationConstraint constraint = helper.createFormulaListConstraint(hideSheetName + "_data");
// 设置数据有效性加载在哪个单元格上,四个参数分别是：起始行、终止行、起始列、终止列
// 设置数据有效性加载在哪个单元格上,四个参数分别是:起始行、终止行、起始列、终止列
CellRangeAddressList regions = new CellRangeAddressList(firstRow, endRow, firstCol, endCol);
// 数据有效性对象
DataValidation dataValidation = helper.createValidation(constraint, regions);

4
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/utils/reflect/ReflectUtils.java
View File

@ -28,7 +28,7 @@ public class ReflectUtils {
/**
* 调用Getter方法.
* 支持多级，如：对象名.对象名.方法
* 支持多级，如:对象名.对象名.方法
*/
@SuppressWarnings("unchecked")
public static <E> E invokeGetter (Object obj, String propertyName) {
@ -42,7 +42,7 @@ public class ReflectUtils {
/**
* 调用Setter方法, 仅匹配方法名。
* 支持多级，如：对象名.对象名.方法
* 支持多级，如:对象名.对象名.方法
*/
public static <E> void invokeSetter (Object obj, String propertyName, E value) {
Object object = obj;

6
muyu-common/muyu-common-core/src/main/java/com/muyu/common/core/utils/uuid/UUID.java
View File

@ -219,7 +219,7 @@ public final class UUID implements java.io.Serializable, Comparable<UUID> {
/**
* 与此 {@code UUID} 相关联的变体号。变体号描述 {@code UUID} 的布局。
* <p>
* 变体号具有以下含意：
* 变体号具有以下含意:
* <ul>
* <li>0 为 NCS 向后兼容保留
* <li>2 <a href="http://www.ietf.org/rfc/rfc4122.txt">IETF&nbsp;RFC&nbsp;4122</a>(Leach-Salz), 用于此类
@ -298,7 +298,7 @@ public final class UUID implements java.io.Serializable, Comparable<UUID> {
* 返回此{@code UUID} 的字符串表现形式。
*
* <p>
* UUID 的字符串表示形式由此 BNF 描述：
* UUID 的字符串表示形式由此 BNF 描述:
*
* <pre>
* {@code
@ -328,7 +328,7 @@ public final class UUID implements java.io.Serializable, Comparable<UUID> {
* 返回此{@code UUID} 的字符串表现形式。
*
* <p>
* UUID 的字符串表示形式由此 BNF 描述：
* UUID 的字符串表示形式由此 BNF 描述:
*
* <pre>
* {@code

2
muyu-common/muyu-common-security/src/main/java/com/muyu/common/security/annotation/RequiresLogin.java
View File

@ -6,7 +6,7 @@ import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 登录认证：只有登录之后才能进入该方法
* 登录认证:只有登录之后才能进入该方法
*
* @author muyu
*/

4
muyu-common/muyu-common-security/src/main/java/com/muyu/common/security/annotation/RequiresPermissions.java
View File

@ -6,7 +6,7 @@ import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 权限认证：必须具有指定权限才能进入该方法
* 权限认证:必须具有指定权限才能进入该方法
*
* @author muyu
*/
@ -19,7 +19,7 @@ public @interface RequiresPermissions {
String[] value () default {};
/**
* 验证模式：AND | OR，默认AND
* 验证模式:AND | OR，默认AND
*/
Logical logical () default Logical.AND;
}

4
muyu-common/muyu-common-security/src/main/java/com/muyu/common/security/annotation/RequiresRoles.java
View File

@ -6,7 +6,7 @@ import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
* 角色认证：必须具有指定角色标识才能进入该方法
* 角色认证:必须具有指定角色标识才能进入该方法
*
* @author muyu
*/
@ -19,7 +19,7 @@ public @interface RequiresRoles {
String[] value () default {};
/**
* 验证逻辑：AND | OR，默认AND
* 验证逻辑:AND | OR，默认AND
*/
Logical logical () default Logical.AND;
}

2
muyu-common/muyu-common-security/src/main/java/com/muyu/common/security/handler/GlobalExceptionHandler.java
View File

@ -86,7 +86,7 @@ public class GlobalExceptionHandler {
public Result handleMethodArgumentTypeMismatchException (MethodArgumentTypeMismatchException e, HttpServletRequest request) {
String requestURI = request.getRequestURI();
log.error("请求参数类型不匹配'{}',发生系统异常.", requestURI, e);
return Result.error(String.format("请求参数类型不匹配，参数[%s]要求类型为：'%s'，但输入值为：'%s'", e.getName(), e.getRequiredType().getName(), e.getValue()));
return Result.error(String.format("请求参数类型不匹配，参数[%s]要求类型为:'%s'，但输入值为:'%s'", e.getName(), e.getRequiredType().getName(), e.getValue()));
}
/**

2
muyu-common/muyu-common-security/src/main/java/com/muyu/common/security/interceptor/HeaderInterceptor.java
View File

@ -15,7 +15,7 @@ import javax.servlet.http.HttpServletResponse;
/**
* 自定义请求头拦截器，将Header数据封装到线程变量中方便获取
* 注意：此拦截器会同时验证当前用户有效期自动刷新有效期
* 注意:此拦截器会同时验证当前用户有效期自动刷新有效期
*
* @author muyu
*/

6
muyu-common/muyu-common-system/src/main/java/com/muyu/common/system/domain/SysRole.java
View File

@ -54,18 +54,18 @@ public class SysRole extends BaseEntity {
private Integer roleSort;
/**
* 数据范围（1：所有数据权限；2：自定义数据权限；3：本部门数据权限；4：本部门及以下数据权限；5：仅本人数据权限）
* 数据范围（1:所有数据权限；2:自定义数据权限；3:本部门数据权限；4:本部门及以下数据权限；5:仅本人数据权限）
*/
@Excel(name = "数据范围", readConverterExp = "1=所有数据权限,2=自定义数据权限,3=本部门数据权限,4=本部门及以下数据权限,5=仅本人数据权限")
private String dataScope;
/**
* 菜单树选择项是否关联显示（ 0：父子不互相关联显示 1：父子互相关联显示）
* 菜单树选择项是否关联显示（ 0:父子不互相关联显示 1:父子互相关联显示）
*/
private boolean menuCheckStrictly;
/**
* 部门树选择项是否关联显示（0：父子不互相关联显示 1：父子互相关联显示 ）
* 部门树选择项是否关联显示（0:父子不互相关联显示 1:父子互相关联显示 ）
*/
private boolean deptCheckStrictly;

12
muyu-gateway/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

12
muyu-modules/muyu-file/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

6
muyu-modules/muyu-gen/src/main/java/com/muyu/gen/service/GenTableServiceImpl.java
View File

@ -187,7 +187,7 @@ public class GenTableServiceImpl implements IGenTableService {
}
}
} catch (Exception e) {
throw new ServiceException("导入失败：" + e.getMessage());
throw new ServiceException("导入失败:" + e.getMessage());
}
}
@ -269,7 +269,7 @@ public class GenTableServiceImpl implements IGenTableService {
String path = getGenPath(table, template);
FileUtils.writeStringToFile(new File(path), sw.toString(), CharsetKit.UTF_8);
} catch (IOException e) {
throw new ServiceException("渲染模板失败，表名：" + table.getTableName());
throw new ServiceException("渲染模板失败，表名:" + table.getTableName());
}
}
}
@ -370,7 +370,7 @@ public class GenTableServiceImpl implements IGenTableService {
zip.flush();
zip.closeEntry();
} catch (IOException e) {
log.error("渲染模板失败，表名：" + table.getTableName(), e);
log.error("渲染模板失败，表名:" + table.getTableName(), e);
}
}
}

12
muyu-modules/muyu-gen/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

2
muyu-modules/muyu-job/src/main/java/com/muyu/job/service/SysJobServiceImpl.java
View File

@ -31,7 +31,7 @@ public class SysJobServiceImpl implements ISysJobService {
private SysJobMapper jobMapper;
/**
* 项目启动时，初始化定时器 主要是防止手动修改数据库导致未同步到定时任务处理（注：不能手动修改数据库ID和任务组名，否则会导致脏数据）
* 项目启动时，初始化定时器 主要是防止手动修改数据库导致未同步到定时任务处理（注:不能手动修改数据库ID和任务组名，否则会导致脏数据）
*/
@PostConstruct
public void init () throws SchedulerException, TaskException {

4
muyu-modules/muyu-job/src/main/java/com/muyu/job/task/MyTask.java
View File

@ -11,11 +11,11 @@ import org.springframework.stereotype.Component;
@Component("myTask")
public class MyTask {
public void ryMultipleParams (String s, Boolean b, Long l, Double d, Integer i) {
System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
System.out.println(StringUtils.format("执行多参方法: 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
}
public void ryParams (String params) {
System.out.println("执行有参方法：" + params);
System.out.println("执行有参方法:" + params);
}
public void ryNoParams () {

4
muyu-modules/muyu-job/src/main/java/com/muyu/job/util/AbstractQuartzJob.java
View File

@ -40,7 +40,7 @@ public abstract class AbstractQuartzJob implements Job {
}
after(context, sysJob, null);
} catch (Exception e) {
log.error("任务执行异常 - ：", e);
log.error("任务执行异常 - :", e);
after(context, sysJob, e);
}
}
@ -72,7 +72,7 @@ public abstract class AbstractQuartzJob implements Job {
sysJobLog.setStartTime(startTime);
sysJobLog.setStopTime(new Date());
long runMs = sysJobLog.getStopTime().getTime() - sysJobLog.getStartTime().getTime();
sysJobLog.setJobMessage(sysJobLog.getJobName() + " 总共耗时：" + runMs + "毫秒");
sysJobLog.setJobMessage(sysJobLog.getJobName() + " 总共耗时:" + runMs + "毫秒");
if (e != null) {
sysJobLog.setStatus("1");
String errorMsg = StringUtils.substring(ExceptionUtil.getExceptionMessage(e), 0, 2000);

12
muyu-modules/muyu-job/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

5
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/ActivityTeamInfo.java
View File

@ -11,9 +11,11 @@ import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.awt.*;
import java.sql.Timestamp;
import java.sql.Date;
import java.sql.Time;
import java.util.List;
/** 商品拼团*/
@Data
@ -51,7 +53,4 @@ public class ActivityTeamInfo extends BaseEntity {
private String strategyType;
/** 策略ID*/
private long strategyId;
}

11
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/ActivityTeamProductSkuInfo.java
View File

@ -11,6 +11,7 @@ import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.math.BigDecimal;
import java.sql.Timestamp;
import java.sql.Date;
import java.sql.Time;
@ -25,17 +26,17 @@ import java.sql.Time;
public class ActivityTeamProductSkuInfo extends BaseEntity {
@TableId(type = IdType.AUTO)
/** 主键*/
private long id;
private Long id;
/** 活动ID*/
private long teamId;
private Long teamId;
/** 商品ID*/
private String productId;
private Long productId;
/** 商品SKU*/
private String productSku;
/** 拼团库存*/
private String teamStock;
private Long teamStock;
/** 拼团价格*/
private String teamPrice;
private BigDecimal teamPrice;
}

17
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/model/TeamDiscountModel.java
View File

@ -1,17 +0,0 @@
package com.muyu.marketing.domain.model;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/** 团购活动 优惠模型*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class TeamDiscountModel {
}

38
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/model/TeamProductDiscountPriceModel.java 100644
View File

@ -0,0 +1,38 @@
package com.muyu.marketing.domain.model;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.math.RoundingMode;
/** 团购活动 优惠模型*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class TeamProductDiscountPriceModel {
/** 商品价格*/
private BigDecimal productPrice;
/** 团购优惠价*/
private BigDecimal teamPrice;
/** 优惠力度*/
private Double discount;
public static TeamProductDiscountPriceModel of (BigDecimal productPrice,BigDecimal teamPrice){
TeamProductDiscountPriceModel teamProductDiscountPriceModel = TeamProductDiscountPriceModel.builder()
.productPrice(productPrice)
.teamPrice(teamPrice)
.discount(
productPrice.subtract(teamPrice).divide(productPrice, 2, RoundingMode.HALF_DOWN).doubleValue()
)
.build();
return teamProductDiscountPriceModel;
}
}

7
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/resp/ActivityTeamInfoListResp.java → muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/req/ActivityTeamInfoListReq.java
View File

@ -1,9 +1,10 @@
package com.muyu.marketing.domain.resp;
package com.muyu.marketing.domain.req;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.annotations.ApiModel;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@ -14,11 +15,11 @@ import java.sql.Timestamp;
* 拼团resp
*/
@Data
@SuperBuilder
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(value = "ActivityTeamInfoListReq", description = "拼团")
public class ActivityTeamInfoListResp {
public class ActivityTeamInfoListReq {
@TableId(type = IdType.AUTO)
/** 主键*/

21
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/req/AddProjectSkuList.java 100644
View File

@ -0,0 +1,21 @@
package com.muyu.marketing.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.poi.hpsf.Decimal;
/** 添加拼团(商品规格List)Resp*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class AddProjectSkuList {
/** 商品sku*/
private String productSku;
/** 拼团价格*/
private Decimal teamPrice;
/** 库存库存*/
private Integer teamStock;
}

54
muyu-modules/muyu-marketing/marketing-common/src/main/java/com/muyu/marketing/domain/resp/ActivityTeamInfoAddResp.java 100644
View File

@ -0,0 +1,54 @@
package com.muyu.marketing.domain.resp;
import com.muyu.marketing.domain.req.AddProjectSkuList;
import io.swagger.annotations.ApiModel;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* 添加拼团Resp
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(value = "ActivityTeamInfoReq", description = "添加拼团")
public class ActivityTeamInfoAddResp {
/** 商品id*/
private Long projectId;
/** 商品图片*/
private String projectImage;
/** 活动名称*/
private String activityName;
/** 活动介绍*/
private String activities;
/** 商品单位*/
private String projectUnit;
/** 轮播图*/
private String carouselImages;
/** 拼团策略id*/
private Long strategyId;
/** 拼团策略类型*/
private String strategyType;
/** 商品规格List*/
private List<AddProjectSkuList> projectSkuList;
/** 全重*/
private Long weight;
/** 商品详情*/
private String goodsDetails;
}

8
muyu-modules/muyu-marketing/marketing-server/pom.xml
View File

@ -48,6 +48,14 @@
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>${dynamic-ds.version}</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-product-cache</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>muyu-common-security</artifactId>
</dependency>
</dependencies>

2
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/MuYuMarketIngApplication.java
View File

@ -2,6 +2,7 @@ package com.muyu.marketing;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.stereotype.Component;
/**
@ -11,6 +12,7 @@ import org.springframework.stereotype.Component;
*/
@SpringBootApplication
@Component
@EnableFeignClients
public class MuYuMarketIngApplication {
public static void main(String[] args) {
SpringApplication.run(MuYuMarketIngApplication.class,args);

12
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/controller/ActivityTeamInfoController.java
View File

@ -8,10 +8,12 @@ import com.muyu.marketing.domain.model.ActivityTeamInfoListModel;
import com.muyu.marketing.domain.model.ActivityTeamInfoListQueryModel;
import com.muyu.marketing.domain.req.TeamInfoListReq;
import com.muyu.marketing.domain.resp.ActivityTeamInfoAddResp;
import com.muyu.marketing.service.ActivityTeamInfoService;
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.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@ -40,6 +42,16 @@ public class ActivityTeamInfoController {
return Result.success(tableDataInfo);
}
/**
* 新增拼团活动
*/
@ApiOperation("添加拼团")
@PostMapping("add")
public Result<String> add(@RequestBody ActivityTeamInfoAddResp activityTeamInfoAddResp) {
activityTeamInfoService.addActivityTeamInfo(activityTeamInfoAddResp);
return Result.success("创建成功");
}

14
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/service/ActivityTeamInfoService.java
View File

@ -5,10 +5,24 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.marketing.domain.ActivityTeamInfo;
import com.muyu.marketing.domain.model.ActivityTeamInfoListModel;
import com.muyu.marketing.domain.model.ActivityTeamInfoListQueryModel;
import com.muyu.marketing.domain.resp.ActivityTeamInfoAddResp;
/** 拼团*/
public interface ActivityTeamInfoService extends IService<ActivityTeamInfo> {
/**
* 拼团活动列表
* @param activityTeamInfoListQueryModel
* @return
*/
TableDataInfo<ActivityTeamInfoListModel> tabDateInfo(ActivityTeamInfoListQueryModel activityTeamInfoListQueryModel);
/**
* 添加拼团活动
*/
void addActivityTeamInfo(ActivityTeamInfoAddResp activityTeamInfoAddResp);
}

3
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/service/ActivityTeamProductSkuInfoService.java
View File

@ -1,4 +1,7 @@
package com.muyu.marketing.service;
import com.muyu.marketing.domain.model.TeamProductDiscountPriceModel;
public interface ActivityTeamProductSkuInfoService {
public TeamProductDiscountPriceModel getDiscountPrice(Long teamId);
}

28
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/service/impl/ActivityTeamInfoServiceImpl.java
View File

@ -8,9 +8,11 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.marketing.domain.ActivityTeamInfo;
import com.muyu.marketing.domain.model.ActivityTeamInfoListModel;
import com.muyu.marketing.domain.model.ActivityTeamInfoListQueryModel;
import com.muyu.marketing.domain.resp.ActivityTeamInfoAddResp;
import com.muyu.marketing.mapper.ActivityTeamInfoMapper;
import com.muyu.marketing.service.ActivityTeamInfoService;
import com.muyu.marketing.service.ActivityTeamOpenInfoService;
import com.muyu.marketing.service.ActivityTeamProductSkuInfoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -30,6 +32,7 @@ implements ActivityTeamInfoService {
@Autowired
private ActivityTeamOpenInfoService activityTeamOpenInfoService;
/**
* 团购活动列表
*/
@ -71,5 +74,30 @@ implements ActivityTeamInfoService {
return tableDataInfo;
}
/**
* 添加 拼团 活动
*/
@Override
public void addActivityTeamInfo(ActivityTeamInfoAddResp addResp) {
//查询 商品
ActivityTeamInfo build = ActivityTeamInfo.builder()
.name(addResp.getActivityName())
.productId(addResp.getProjectId())
.productImage(addResp.getProjectImage())
.introduction(addResp.getCarouselImages())
.unit(addResp.getProjectUnit())
.imageList(addResp.getCarouselImages())
.strategyType(addResp.getStrategyType())
.strategyId(addResp.getStrategyId())
.build();
activityTeamInfoMapper.insert(build);
}
}

33
muyu-modules/muyu-marketing/marketing-server/src/main/java/com/muyu/marketing/service/impl/ActivityTeamProductSkuInfoServiceImpl.java
View File

@ -1,13 +1,46 @@
package com.muyu.marketing.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.marketing.domain.ActivityTeamProductSkuInfo;
import com.muyu.marketing.domain.model.TeamProductDiscountPriceModel;
import com.muyu.marketing.mapper.ActivityTeamProductSkuInfoMapper;
import com.muyu.marketing.service.ActivityTeamProductSkuInfoService;
import com.muyu.product.cache.ProjectSkuCache;
import com.muyu.product.domain.ProjectSkuInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Optional;
@Service
public class ActivityTeamProductSkuInfoServiceImpl extends ServiceImpl<ActivityTeamProductSkuInfoMapper, ActivityTeamProductSkuInfo>
implements ActivityTeamProductSkuInfoService {
@Autowired
private ProjectSkuCache projectSkuCache;
@Override //
public TeamProductDiscountPriceModel getDiscountPrice(Long teamId) {
LambdaQueryWrapper<ActivityTeamProductSkuInfo> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(ActivityTeamProductSkuInfo :: getTeamId , teamId);
List<ActivityTeamProductSkuInfo> teamProductSkuInfoList = this.list(queryWrapper);
//优惠模型集合
Optional<TeamProductDiscountPriceModel> discountPriceModelOptional = teamProductSkuInfoList.stream()
.map(activityTeamProductSkuInfo -> {
ProjectSkuInfo projectSkuInfo = projectSkuCache.get(activityTeamProductSkuInfo.getProductId(), activityTeamProductSkuInfo.getProductSku());
return TeamProductDiscountPriceModel.of(projectSkuInfo.getPrice(), activityTeamProductSkuInfo.getTeamPrice());
}).min((o1, o2) -> Double.valueOf(o1.getDiscount() *100 - o2.getDiscount() * 100). intValue());
if (discountPriceModelOptional.isEmpty()){
throw new RuntimeException("团队下没有绑定商品");
}
return discountPriceModelOptional.get();
}
}

12
muyu-modules/muyu-marketing/marketing-server/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

9
muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/datasource/impl/ProjectSkuDataRemoteImpl.java vendored
View File

@ -1,17 +1,18 @@
package com.muyu.product.cache.datasource.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.muyu.common.core.domain.Result;
import com.muyu.product.cache.datasource.ProjectSkuData;
import com.muyu.product.domain.ProjectSkuInfo;
import com.muyu.product.remote.RemoteProjectSkuService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
@ -22,7 +23,7 @@ import java.util.stream.Collectors;
@Service
public class ProjectSkuDataRemoteImpl implements ProjectSkuData {
@Autowired
@Resource
private RemoteProjectSkuService remoteProjectSkuService;
/**

1
muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/RemoteProjectSkuService.java
View File

@ -21,6 +21,7 @@ import java.util.List;
fallbackFactory = RemoteProjectSkuFactory.class,
path = "/sku"
)
public interface RemoteProjectSkuService {
/**

2
muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/factory/RemoteRuleFactory.java
View File

@ -1,9 +1,7 @@
package com.muyu.product.remote.factory;
import com.muyu.common.core.domain.Result;
import com.muyu.product.domain.ProjectSkuInfo;
import com.muyu.product.domain.RuleInfo;
import com.muyu.product.remote.RemoteProjectSkuService;
import com.muyu.product.remote.RemoteRuleService;
import org.springframework.cloud.openfeign.FallbackFactory;

12
muyu-modules/muyu-product/muyu-product-server/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

12
muyu-modules/muyu-shop-cart/muyu-shop-cart-server/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

2
muyu-modules/muyu-system/src/main/java/com/muyu/system/domain/vo/RouterVo.java
View File

@ -37,7 +37,7 @@ public class RouterVo {
private String component;
/**
* 路由参数：如 {"id": 1, "name": "ry"}
* 路由参数:如 {"id": 1, "name": "ry"}
*/
private String query;

6
muyu-modules/muyu-system/src/main/java/com/muyu/system/service/impl/SysUserServiceImpl.java
View File

@ -486,16 +486,16 @@ public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> impl
}
} catch (Exception e) {
failureNum++;
String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败：";
String msg = "<br/>" + failureNum + "、账号 " + user.getUserName() + " 导入失败:";
failureMsg.append(msg + e.getMessage());
log.error(msg, e);
}
}
if (failureNum > 0) {
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下:");
throw new ServiceException(failureMsg.toString());
} else {
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下:");
}
return successMsg.toString();
}

12
muyu-modules/muyu-system/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

12
muyu-visual/muyu-monitor/src/main/resources/logback.xml
View File

@ -15,7 +15,7 @@
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -28,16 +28,16 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<!-- 循环政策:基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
@ -50,9 +50,9 @@
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<!-- 匹配时的操作:接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<!-- 不匹配时的操作:拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>

12
sql/ry-cloud.sql
View File

@ -721,9 +721,9 @@ CREATE TABLE `sys_job_log` (
-- ----------------------------
-- Records of sys_job_log
-- ----------------------------
INSERT INTO `sys_job_log` VALUES (1, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时：2毫秒', '0', '', '2024-03-08 20:51:30');
INSERT INTO `sys_job_log` VALUES (2, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时：0毫秒', '0', '', '2024-03-08 20:51:38');
INSERT INTO `sys_job_log` VALUES (3, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时：0毫秒', '0', '', '2024-03-08 21:22:37');
INSERT INTO `sys_job_log` VALUES (1, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时:2毫秒', '0', '', '2024-03-08 20:51:30');
INSERT INTO `sys_job_log` VALUES (2, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时:0毫秒', '0', '', '2024-03-08 20:51:38');
INSERT INTO `sys_job_log` VALUES (3, '系统默认（无参）', 'DEFAULT', 'myTask.ryNoParams', '系统默认（无参） 总共耗时:0毫秒', '0', '', '2024-03-08 21:22:37');
-- ----------------------------
-- Table structure for sys_logininfor
@ -1388,8 +1388,8 @@ CREATE TABLE `sys_notice` (
-- ----------------------------
-- Records of sys_notice
-- ----------------------------
INSERT INTO `sys_notice` VALUES (1, '温馨提醒：2018-07-01 若依新版本发布啦', '1', 0xE696B0E78988E69CACE58685E5AEB9, '0', 'admin', '2023-11-12 15:57:50', 'admin', '2024-03-08 20:52:38', '管理员');
INSERT INTO `sys_notice` VALUES (2, '维护通知：2018-07-01 若依系统凌晨维护', '1', 0xE7BBB4E68AA4E58685E5AEB9, '0', 'admin', '2023-11-12 15:57:50', '', NULL, '管理员');
INSERT INTO `sys_notice` VALUES (1, '温馨提醒:2018-07-01 若依新版本发布啦', '1', 0xE696B0E78988E69CACE58685E5AEB9, '0', 'admin', '2023-11-12 15:57:50', 'admin', '2024-03-08 20:52:38', '管理员');
INSERT INTO `sys_notice` VALUES (2, '维护通知:2018-07-01 若依系统凌晨维护', '1', 0xE7BBB4E68AA4E58685E5AEB9, '0', 'admin', '2023-11-12 15:57:50', '', NULL, '管理员');
-- ----------------------------
-- Table structure for sys_oper_log
@ -1696,7 +1696,7 @@ CREATE TABLE `sys_role` (
`role_name` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '角色名称',
`role_key` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '角色权限字符串',
`role_sort` int(4) NOT NULL COMMENT '显示顺序',
`data_scope` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '1' COMMENT '数据范围（1：全部数据权限 2：自定数据权限 3：本部门数据权限 4：本部门及以下数据权限）',
`data_scope` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '1' COMMENT '数据范围（1:全部数据权限 2:自定数据权限 3:本部门数据权限 4:本部门及以下数据权限）',
`menu_check_strictly` tinyint(1) NULL DEFAULT 1 COMMENT '菜单树选择项是否关联显示',
`dept_check_strictly` tinyint(1) NULL DEFAULT 1 COMMENT '部门树选择项是否关联显示',
`status` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '角色状态（0正常 1停用）',