Merge pull request 'v1.0.39' (#51) from dev into master

Reviewed-on: #51

pom.xml

@@ -11,7 +11,7 @@
 
 	<groupId>com.imyeyu.timiserverapi</groupId>
 	<artifactId>TimiServerAPI</artifactId>
-	<version>1.0.38</version>
+	<version>1.0.39</version>
 	<packaging>jar</packaging>
 	<name>TimiServerAPI</name>
 	<description>imyeyu.com API</description>

src/main/java/com/imyeyu/api/modules/common/controller/SettingController.java

@@ -15,8 +15,12 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  *
  *
@@ -26,11 +30,30 @@ import org.springframework.web.bind.annotation.RestController;
 @Slf4j
 @RestController
 @RequiredArgsConstructor
-@RequestMapping("/system/setting")
+@RequestMapping("/setting")
 public class SettingController {
 
 	private final SettingService service;
 
+	/**
+	 * 查询公开配置映射
+	 *
+	 * @param bizType 业务类型
+	 * @param bizId 业务 ID，可为空
+	 * @param code 配置代码列表，可为空
+	 * @return 公开配置映射
+	 */
+	@JsonView(ResponseView.Public.class)
+	@RequestRateLimit
+	@RequestMapping("/map")
+	public Map<String, Setting> map(
+			@RequestParam String bizType,
+			@RequestParam(required = false) String bizId,
+			@RequestParam(required = false) List<String> code
+	) {
+		return service.mapPublic(bizType, bizId, code);
+	}
+
 	/**
 	 * 查询配置列表
 	 *

src/main/java/com/imyeyu/api/modules/common/entity/Notify.java

@@ -20,11 +20,11 @@ public class Notify extends UUIDEntity {
 	/** 业务类型 */
 	private String bizType;
 
-	/** 提醒业务类型 */
+	/** 业务提醒类型 */
 	private String bizRemindedType;
 
-	/** 提醒业务 ID */
-	private String bizRemindedId;
+	/** 业务提醒查重键 */
+	private String bizRemindedKey;
 
 	/** 参数 */
 	private String args;

src/main/java/com/imyeyu/api/modules/common/mapper/NotifyMapper.java

@@ -2,9 +2,8 @@ package com.imyeyu.api.modules.common.mapper;
 
 import com.imyeyu.api.modules.common.entity.Notify;
 import com.imyeyu.api.modules.common.vo.NotifyManagementItem;
-import org.apache.ibatis.annotations.Param;
-import org.apache.ibatis.annotations.Select;
 import com.imyeyu.spring.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -16,9 +15,8 @@ import java.util.List;
  */
 public interface NotifyMapper extends BaseMapper<Notify, String> {
 
-	/// 查询业务提醒是否已创建
-	@Select("SELECT EXISTS (SELECT 1 FROM `notify` WHERE `biz_type` = #{bizType} AND `biz_reminded_type` = #{bizRemindedType} AND `biz_reminded_id` = #{bizRemindedId} AND `deleted_at` IS NULL)")
-	boolean existsByBizReminded(@Param("bizType") String bizType, @Param("bizRemindedType") String bizRemindedType, @Param("bizRemindedId") String bizRemindedId);
+	/// 原子创建业务提醒
+	int insertIfAbsent(Notify notify);
 
 	/// 分页查询管理端通知
 	///

src/main/java/com/imyeyu/api/modules/common/mapper/SettingMapper.java

@@ -3,6 +3,8 @@ package com.imyeyu.api.modules.common.mapper;
 import com.imyeyu.api.modules.common.entity.Setting;
 import com.imyeyu.spring.mapper.BaseMapper;
 
+import java.util.List;
+
 /**
  * 系统配置
  *
@@ -10,4 +12,6 @@ import com.imyeyu.spring.mapper.BaseMapper;
  * @since 2021-07-20 22:26
  */
 public interface SettingMapper extends BaseMapper<Setting, String> {
+
+	List<Setting> selectPublicByQuery(String bizType, String bizId, List<String> codeList);
 }

src/main/java/com/imyeyu/api/modules/common/service/NotifyService.java

@@ -14,13 +14,10 @@ import com.imyeyu.spring.service.BaseService;
  */
 public interface NotifyService extends BaseService<Notify, String> {
 
-	/// 查询业务提醒是否已创建
+	/// 原子创建业务提醒，重复查重键不会创建通知详情
 	///
-	/// @param bizType 业务类型
-	/// @param bizRemindedType 被提醒业务类型
-	/// @param bizRemindedId 被提醒业务 ID
-	/// @return true 为已创建
-	boolean existsByBizReminded(String bizType, String bizRemindedType, String bizRemindedId);
+	/// @param notify 通知
+	void createIfAbsent(Notify notify);
 
 	/// 分页查询当前用户创建的通知
 	///

src/main/java/com/imyeyu/api/modules/common/service/SettingService.java

@@ -7,6 +7,7 @@ import com.imyeyu.java.TimiJava;
 import com.imyeyu.spring.service.BaseService;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 配置服务
@@ -24,6 +25,16 @@ public interface SettingService extends BaseService<Setting, String> {
 
 	List<Setting> listByBizId(String bizType, String bizId);
 
+	/**
+	 * 查询公开配置映射
+	 *
+	 * @param bizType 业务类型
+	 * @param bizId 业务 ID，可为空
+	 * @param code 配置代码列表，可为空
+	 * @return 公开配置映射
+	 */
+	Map<String, Setting> mapPublic(String bizType, String bizId, List<String> code);
+
 	default List<Setting> listBySettingSupport(SettingSupport settingSupport) {
 		String bizType = settingSupport.getClass().getSimpleName().toUpperCase();
 		return listByBizId(bizType, settingSupport.getId());

src/main/java/com/imyeyu/api/modules/common/service/implement/NotifyServiceImplement.java

@@ -7,9 +7,8 @@ import com.imyeyu.api.modules.common.mapper.NotifyMapper;
 import com.imyeyu.api.modules.common.service.NotifyDetailService;
 import com.imyeyu.api.modules.common.service.NotifyService;
 import com.imyeyu.api.modules.common.vo.NotifyManagementItem;
-import com.imyeyu.api.modules.system.entity.Logger;
-import com.imyeyu.api.modules.system.service.LoggerService;
-import com.imyeyu.api.modules.user.service.UserLoginService;
+import com.imyeyu.api.modules.system.audit.AuditOperation;
+import com.imyeyu.api.modules.system.audit.OperationAudit;
 import com.imyeyu.java.TimiJava;
 import com.imyeyu.java.bean.timi.TimiCode;
 import com.imyeyu.java.bean.timi.TimiException;
@@ -17,12 +16,13 @@ import com.imyeyu.spring.bean.Page;
 import com.imyeyu.spring.bean.PageResult;
 import com.imyeyu.spring.mapper.BaseMapper;
 import com.imyeyu.spring.service.AbstractEntityService;
+import com.imyeyu.utils.Time;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
+import java.util.UUID;
 
 /**
  * 通知服务实现
@@ -30,13 +30,10 @@ import java.util.List;
  * @author 夜雨
  * @since 2026-05-13 14:46
  */
-@Slf4j
 @Service
 @RequiredArgsConstructor
 public class NotifyServiceImplement extends AbstractEntityService<Notify, String> implements NotifyService {
 
-	private final LoggerService loggerService;
-	private final UserLoginService userLoginService;
 	private final NotifyDetailService detailService;
 
 	private final NotifyMapper mapper;
@@ -46,44 +43,54 @@ public class NotifyServiceImplement extends AbstractEntityService<Notify, String
 		return mapper;
 	}
 
-	@Override
-	public boolean existsByBizReminded(String bizType, String bizRemindedType, String bizRemindedId) {
-		return mapper.existsByBizReminded(bizType, bizRemindedType, bizRemindedId);
-	}
-
 	/// 创建通知并级联创建通知详情
 	///
 	/// @param notify 通知
+	@OperationAudit(AuditOperation.COMMON_NOTIFY_CREATE)
 	@Transactional(TimiServerDBConfig.ROLLBACKER)
 	@Override
 	public void create(Notify notify) {
-		Logger logger = new Logger(Logger.Module.COMMON, "COMMON_NOTIFY_CREATE");
-		try {
+		prepareCreate(notify);
+		super.create(notify);
+		createDetails(notify);
+	}
+
+	/// 原子创建业务提醒并级联创建通知详情
+	///
+	/// @param notify 通知
+	@OperationAudit(AuditOperation.COMMON_NOTIFY_CREATE)
+	@Transactional(TimiServerDBConfig.ROLLBACKER)
+	@Override
+	public void createIfAbsent(Notify notify) {
+		prepareCreate(notify);
+		if (mapper.insertIfAbsent(notify) == 0) {
+			return;
+		}
+		createDetails(notify);
+	}
+
+	/// 校验并补全通知创建字段
+	///
+	/// @param notify 通知
+	private void prepareCreate(Notify notify) {
 		TimiException.required(notify, "未找到通知");
 		TimiException.required(notify.getDetailList(), "未找到通知详情列表");
-
+		notify.setId(TimiJava.defaultIfEmpty(notify.getId(), UUID.randomUUID().toString()));
 		notify.setCreatedBy(TimiJava.defaultIfEmpty(notify.getCreatedBy(), TimiJava.ZERO_UUID));
-			super.create(notify);
+		notify.setCreatedAt(TimiJava.defaultIfNull(notify.getCreatedAt(), Time.now()));
+		notify.setUpdatedAt(null);
+		notify.setDeletedAt(null);
+	}
 
+	/// 创建通知详情
+	///
+	/// @param notify 通知
+	private void createDetails(Notify notify) {
 		for (NotifyDetail detail : notify.getDetailList()) {
 			detail.setNotifyId(notify.getId());
 			detail.setSendFrom(TimiJava.defaultIfEmpty(detail.getSendFrom(), TimiJava.ZERO_UUID));
 			detailService.create(detail);
 		}
-			logger.setLevel(Logger.Level.INFO);
-			logger.setResult(notify.getId());
-		} catch (TimiException e) {
-			logger.setLevel(Logger.Level.WARN);
-			logger.setException(e.getMessage());
-			throw e;
-		} catch (Exception e) {
-			logger.setLevel(Logger.Level.ERROR);
-			logger.setException(TimiJava.serializeThrowable(e));
-			log.error("创建通知失败", e);
-			throw new TimiException(TimiCode.ERROR, "创建通知失败", e);
-		} finally {
-			loggerService.create(logger);
-		}
 	}
 
 	/// 分页查询当前用户创建的通知
@@ -120,6 +127,8 @@ public class NotifyServiceImplement extends AbstractEntityService<Notify, String
 	/// @param notifyId 通知 ID
 	/// @param userId 用户 ID
 	@Override
+	@Transactional(TimiServerDBConfig.ROLLBACKER)
+	@OperationAudit(AuditOperation.COMMON_NOTIFY_DELETE)
 	public void deleteManagement(String notifyId, String userId) {
 		getManagement(notifyId, userId);
 		delete(notifyId);
@@ -130,6 +139,7 @@ public class NotifyServiceImplement extends AbstractEntityService<Notify, String
 	/// @param notifyId 通知 ID
 	/// @param userId 用户 ID
 	@Override
+	@Transactional(TimiServerDBConfig.ROLLBACKER)
 	public void cancelManagement(String notifyId, String userId) {
 		getManagement(notifyId, userId);
 		cancel(notifyId);
@@ -138,11 +148,10 @@ public class NotifyServiceImplement extends AbstractEntityService<Notify, String
 	/// 删除通知并级联软删除通知详情
 	///
 	/// @param notifyId 通知 ID
+	@OperationAudit(AuditOperation.COMMON_NOTIFY_DELETE)
 	@Transactional(TimiServerDBConfig.ROLLBACKER)
 	@Override
 	public void delete(String notifyId) {
-		Logger logger = new Logger(Logger.Module.COMMON, "COMMON_NOTIFY_DELETE");
-		try {
 		TimiException.required(notifyId, "未找到通知 ID");
 		TimiException.required(get(notifyId), "未找到通知");
 		List<NotifyDetail> detailList = detailService.listByNotifyId(notifyId);
@@ -150,20 +159,6 @@ public class NotifyServiceImplement extends AbstractEntityService<Notify, String
 			detailService.delete(detail.getId());
 		}
 		super.delete(notifyId);
-			logger.setLevel(Logger.Level.INFO);
-			logger.setResult(notifyId);
-		} catch (TimiException e) {
-			logger.setLevel(Logger.Level.WARN);
-			logger.setException(e.getMessage());
-			throw e;
-		} catch (Exception e) {
-			logger.setLevel(Logger.Level.ERROR);
-			logger.setException(TimiJava.serializeThrowable(e));
-			log.error("删除通知失败", e);
-			throw new TimiException(TimiCode.ERROR, "删除通知失败", e);
-		} finally {
-			loggerService.create(logger);
-		}
 	}
 
 	/// 取消通知中尚未成功发送的通知详情

src/main/java/com/imyeyu/api/modules/common/service/implement/SettingServiceImplement.java

@@ -17,6 +17,8 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 /**
  * 系统配置服务实现
@@ -53,6 +55,12 @@ public class SettingServiceImplement extends AbstractEntityService<Setting, Stri
 		return mapper.selectAllByExample(example);
 	}
 
+	@Override
+	public Map<String, Setting> mapPublic(String bizType, String bizId, List<String> code) {
+		TimiException.required(bizType, "not found bizType");
+		return mapper.selectPublicByQuery(bizType, bizId, code).stream().collect(Collectors.toMap(Setting::getCode, Function.identity()));
+	}
+
 	@Transactional(TimiServerDBConfig.ROLLBACKER)
 	@Override
 	public void updateByBizId(String bizType, String bizId, List<Setting> list) {

src/main/java/com/imyeyu/api/modules/gao/mapper/GaoCustomerMapper.java

@@ -55,5 +55,5 @@ public interface GaoCustomerMapper extends BaseMapper<GaoCustomer, String> {
 	/// @param customerId 客户 ID
 	/// @param delta 变化量
 	@Update("UPDATE `gao_customer` SET `invited_count` = GREATEST(IFNULL(`invited_count`, 0) + #{delta}, 0), `updated_at` = " + UNIX_TIME + " WHERE `id` = #{customerId}" + NOT_DELETE)
-	void updateInvitedCountDelta(@Param("customerId") String customerId, @Param("delta") Long delta);
+	void updateInvitedCountDelta(String customerId, Long delta);
 }

src/main/java/com/imyeyu/api/modules/gao/service/implement/GaoOrderReminderServiceImplement.java

@@ -103,20 +103,17 @@ public class GaoOrderReminderServiceImplement implements GaoOrderReminderService
 					log.warn("GAO 订单提醒跳过不存在的店长用户: storeId[{}], userId[{}]", storeId, manager.getUserId());
 					continue;
 				}
-				String remindedId = "%s:%s:%s:%s".formatted(LocalDate.now(ZoneId.of(ZONE_ID)), storeId, manager.getUserId(), reminderType);
-				if (notifyService.existsByBizReminded(NOTIFY_BIZ_TYPE, reminderType, remindedId)) {
-					continue;
-				}
+				String remindedKey = "%s:%s:%s:%s".formatted(LocalDate.now(ZoneId.of(ZONE_ID)), storeId, manager.getUserId(), reminderType);
 				long sendAt = Time.now();
 				Notify notify = new Notify();
 				notify.setBizType(NOTIFY_BIZ_TYPE);
 				notify.setBizRemindedType(reminderType);
-				notify.setBizRemindedId(remindedId);
+				notify.setBizRemindedKey(remindedKey);
 				notify.setDetailList(List.of(
 					createInternalDetail(manager.getUserId(), content, sendAt),
 					createSmsDetail(user.getPhoneNo(), customerNames, action, content, sendAt)
 				));
-				notifyService.create(notify);
+				notifyService.createIfAbsent(notify);
 			} catch (Exception e) {
 				log.error("GAO 订单提醒发送失败: storeId[{}], userId[{}], reminderType[{}]", storeId, manager.getUserId(), reminderType, e);
 			}

src/main/java/com/imyeyu/api/modules/gao/vo/GaoCustomerPage.java

@@ -1,6 +1,7 @@
 package com.imyeyu.api.modules.gao.vo;
 
-import com.imyeyu.java.bean.BasePage;
+import com.imyeyu.api.modules.gao.entity.GaoCustomer;
+import com.imyeyu.spring.bean.Page;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
@@ -12,7 +13,7 @@ import java.util.List;
 /// @since 2026-08-13
 @Data
 @EqualsAndHashCode(callSuper = true)
-public class GaoCustomerPage extends BasePage {
+public class GaoCustomerPage extends Page<GaoCustomer> {
 
 	/// 门店 ID
 	private String storeId;

src/main/java/com/imyeyu/api/modules/system/audit/AuditOperation.java

@@ -1,66 +1,51 @@
 package com.imyeyu.api.modules.system.audit;
 
 import com.imyeyu.api.modules.system.entity.Logger;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
 
 /// 操作审计编码
 ///
 /// @author Codex
 /// @since 2026-09-09
+@Getter
+@AllArgsConstructor
 public enum AuditOperation {
 
-	GAO_CUSTOMER_PACKAGE_PURCHASE(Logger.Module.GAO, "GAO_CUSTOMER_PACKAGE_PURCHASE"),
-	GAO_CUSTOMER_PACKAGE_CANCEL(Logger.Module.GAO, "GAO_CUSTOMER_PACKAGE_CANCEL"),
-	GAO_SALES_ORDER_PAYMENT_RECEIVE(Logger.Module.GAO, "GAO_SALES_ORDER_PAYMENT_RECEIVE"),
-	GAO_SALES_ORDER_PAYMENT_VERIFY(Logger.Module.GAO, "GAO_SALES_ORDER_PAYMENT_VERIFY"),
-	GAO_SALES_ORDER_REFUND(Logger.Module.GAO, "GAO_SALES_ORDER_REFUND"),
-	GAO_SALES_ORDER_CONFIRM_NO_REFUND(Logger.Module.GAO, "GAO_SALES_ORDER_CONFIRM_NO_REFUND"),
-	GAO_SALES_ORDER_FUND_REVOKE(Logger.Module.GAO, "GAO_SALES_ORDER_FUND_REVOKE"),
-	GAO_ORDER_FULFILLMENT_CREATE(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_CREATE"),
-	GAO_ORDER_FULFILLMENT_PREPARE_STOCK(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_PREPARE_STOCK"),
-	GAO_ORDER_FULFILLMENT_VERIFY(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_VERIFY"),
-	GAO_ORDER_FULFILLMENT_REJECT(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_REJECT"),
-	GAO_ORDER_FULFILLMENT_CANCEL(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_CANCEL"),
-	GAO_ORDER_FULFILLMENT_REVOKE(Logger.Module.GAO, "GAO_ORDER_FULFILLMENT_REVOKE"),
-	GAO_PACKAGE_CONFIG_CREATE(Logger.Module.GAO, "GAO_PACKAGE_CONFIG_CREATE"),
-	GAO_PACKAGE_CONFIG_UPDATE(Logger.Module.GAO, "GAO_PACKAGE_CONFIG_UPDATE"),
-	GAO_PACKAGE_CONFIG_DELETE(Logger.Module.GAO, "GAO_PACKAGE_CONFIG_DELETE"),
-	GAO_PRODUCT_CATEGORY_SORT(Logger.Module.GAO, "GAO_PRODUCT_CATEGORY_SORT"),
-	GAO_PRODUCT_CATEGORY_CREATE(Logger.Module.GAO, "GAO_PRODUCT_CATEGORY_CREATE"),
-	GAO_PRODUCT_CATEGORY_UPDATE(Logger.Module.GAO, "GAO_PRODUCT_CATEGORY_UPDATE"),
-	GAO_PRODUCT_CATEGORY_DISABLE(Logger.Module.GAO, "GAO_PRODUCT_CATEGORY_DISABLE"),
-	GAO_PRODUCT_CREATE(Logger.Module.GAO, "GAO_PRODUCT_CREATE"),
-	GAO_PRODUCT_UPDATE(Logger.Module.GAO, "GAO_PRODUCT_UPDATE"),
-	GAO_PRODUCT_DISABLE(Logger.Module.GAO, "GAO_PRODUCT_DISABLE"),
-	GAO_PRODUCT_STOCK_INITIAL_IN(Logger.Module.GAO, "GAO_PRODUCT_STOCK_INITIAL_IN"),
-	GAO_PRODUCT_STOCK_MANUAL_IN(Logger.Module.GAO, "GAO_PRODUCT_STOCK_MANUAL_IN"),
-	GAO_PRODUCT_STOCK_MANUAL_OUT(Logger.Module.GAO, "GAO_PRODUCT_STOCK_MANUAL_OUT"),
-	GAO_PRODUCT_STOCK_MANUAL_REVOKE(Logger.Module.GAO, "GAO_PRODUCT_STOCK_MANUAL_REVOKE"),
-	GAO_PRODUCT_STOCK_STOCKTAKE_GAIN(Logger.Module.GAO, "GAO_PRODUCT_STOCK_STOCKTAKE_GAIN"),
-	GAO_PRODUCT_STOCK_STOCKTAKE_LOSS(Logger.Module.GAO, "GAO_PRODUCT_STOCK_STOCKTAKE_LOSS"),
-	GAO_SALES_ORDER_DIRECT_PRODUCT_CREATE(Logger.Module.GAO, "GAO_SALES_ORDER_DIRECT_PRODUCT_CREATE"),
-	GAO_SALES_ORDER_UPDATE(Logger.Module.GAO, "GAO_SALES_ORDER_UPDATE"),
-	GAO_SALES_ORDER_CANCEL(Logger.Module.GAO, "GAO_SALES_ORDER_CANCEL");
+	COMMON_NOTIFY_CREATE(Logger.Module.COMMON),
+	COMMON_NOTIFY_DELETE(Logger.Module.COMMON),
+	GAO_CUSTOMER_PACKAGE_PURCHASE(Logger.Module.GAO),
+	GAO_CUSTOMER_PACKAGE_CANCEL(Logger.Module.GAO),
+	GAO_SALES_ORDER_PAYMENT_RECEIVE(Logger.Module.GAO),
+	GAO_SALES_ORDER_PAYMENT_VERIFY(Logger.Module.GAO),
+	GAO_SALES_ORDER_REFUND(Logger.Module.GAO),
+	GAO_SALES_ORDER_CONFIRM_NO_REFUND(Logger.Module.GAO),
+	GAO_SALES_ORDER_FUND_REVOKE(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_CREATE(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_PREPARE_STOCK(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_VERIFY(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_REJECT(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_CANCEL(Logger.Module.GAO),
+	GAO_ORDER_FULFILLMENT_REVOKE(Logger.Module.GAO),
+	GAO_PACKAGE_CONFIG_CREATE(Logger.Module.GAO),
+	GAO_PACKAGE_CONFIG_UPDATE(Logger.Module.GAO),
+	GAO_PACKAGE_CONFIG_DELETE(Logger.Module.GAO),
+	GAO_PRODUCT_CATEGORY_SORT(Logger.Module.GAO),
+	GAO_PRODUCT_CATEGORY_CREATE(Logger.Module.GAO),
+	GAO_PRODUCT_CATEGORY_UPDATE(Logger.Module.GAO),
+	GAO_PRODUCT_CATEGORY_DISABLE(Logger.Module.GAO),
+	GAO_PRODUCT_CREATE(Logger.Module.GAO),
+	GAO_PRODUCT_UPDATE(Logger.Module.GAO),
+	GAO_PRODUCT_DISABLE(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_INITIAL_IN(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_MANUAL_IN(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_MANUAL_OUT(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_MANUAL_REVOKE(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_STOCKTAKE_GAIN(Logger.Module.GAO),
+	GAO_PRODUCT_STOCK_STOCKTAKE_LOSS(Logger.Module.GAO),
+	GAO_SALES_ORDER_DIRECT_PRODUCT_CREATE(Logger.Module.GAO),
+	GAO_SALES_ORDER_UPDATE(Logger.Module.GAO),
+	GAO_SALES_ORDER_CANCEL(Logger.Module.GAO);
 
-	private final Logger.Module module;
-
-	private final String code;
-
-	AuditOperation(Logger.Module module, String code) {
-		this.module = module;
-		this.code = code;
-	}
-
-	/// 获取日志模块
-	///
-	/// @return 日志模块
-	public Logger.Module getModule() {
-		return module;
-	}
-
-	/// 获取操作编码
-	///
-	/// @return 操作编码
-	public String getCode() {
-		return code;
-	}
+	final Logger.Module module;
 }

src/main/java/com/imyeyu/api/modules/system/audit/OperationAuditAspect.java

@@ -1,6 +1,7 @@
 package com.imyeyu.api.modules.system.audit;
 
 import com.imyeyu.api.modules.system.entity.Logger;
+import com.imyeyu.java.TimiJava;
 import com.imyeyu.java.bean.timi.TimiException;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -38,7 +39,7 @@ public class OperationAuditAspect {
 	public Object around(ProceedingJoinPoint joinPoint, OperationAudit operationAudit) throws Throwable {
 		AuditOperation operation = operationAudit.value();
 		Object[] arguments = joinPoint.getArgs();
-		Logger logger = new Logger(operation.getModule(), operation.getCode());
+		Logger logger = new Logger(operation.getModule(), operation.name());
 		logger.setContent(payloadSerializer.serializeArguments(arguments));
 		long startNanos = System.nanoTime();
 		try {
@@ -56,9 +57,9 @@ public class OperationAuditAspect {
 			throw e;
 		} catch (Throwable e) {
 			logger.setLevel(Logger.Level.ERROR);
-			logger.setException(serializeThrowable(e));
+			logger.setException(TimiJava.serializeThrowable(e));
 			logger.setDuration(duration(startNanos));
-			log.error("业务操作失败: {}", operation.getCode(), e);
+			log.error("业务操作失败: {}", operation.name(), e);
 			record(logger);
 			throw e;
 		}
@@ -79,12 +80,4 @@ public class OperationAuditAspect {
 		}
 		return (int) Math.max(0L, millis);
 	}
-
-	private String serializeThrowable(Throwable throwable) {
-		java.io.StringWriter stringWriter = new java.io.StringWriter();
-		try (java.io.PrintWriter printWriter = new java.io.PrintWriter(stringWriter)) {
-			throwable.printStackTrace(printWriter);
-		}
-		return stringWriter.toString();
-	}
 }

src/main/resources/db/migration/timiserver/V76__extend_notify_biz_reminded_id.sql

@@ -0,0 +1,25 @@
+ALTER TABLE `notify`
+	CHANGE COLUMN `biz_reminded_id` `biz_reminded_key` VARCHAR(191) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci COMMENT '业务提醒查重键',
+	ADD COLUMN `biz_reminded_active_key` TINYINT(1) GENERATED ALWAYS AS (IF(`deleted_at` IS NULL, 1, NULL)) STORED COMMENT '未删除查重键' INVISIBLE AFTER `deleted_at`,
+	DROP INDEX `idx_biz_reminded_created`,
+	ADD INDEX `idx_biz_reminded_key_created`(`biz_type` ASC, `biz_reminded_type` ASC, `biz_reminded_key` ASC, `created_at` ASC) USING BTREE;
+
+UPDATE `notify` target
+INNER JOIN (
+	SELECT
+		id,
+		ROW_NUMBER() OVER (
+			PARTITION BY biz_type, biz_reminded_type, biz_reminded_key
+			ORDER BY created_at DESC, id DESC
+		) AS rn
+	FROM `notify`
+	WHERE deleted_at IS NULL
+		AND biz_type IS NOT NULL
+		AND biz_reminded_type IS NOT NULL
+		AND biz_reminded_key IS NOT NULL
+) duplicate ON duplicate.id = target.id
+SET target.deleted_at = UNIX_TIMESTAMP() * 1000
+WHERE duplicate.rn > 1;
+
+ALTER TABLE `notify`
+	ADD UNIQUE INDEX `uk_biz_reminded_key_active`(`biz_type` ASC, `biz_reminded_type` ASC, `biz_reminded_key` ASC, `biz_reminded_active_key` ASC) USING BTREE;

src/main/resources/mapper/timi-server/common/NotifyMapper.xml

@@ -1,6 +1,31 @@
 <?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.imyeyu.api.modules.common.mapper.NotifyMapper">
+	<insert id="insertIfAbsent">
+		INSERT INTO `notify` (
+			`id`,
+			`biz_type`,
+			`biz_reminded_type`,
+			`biz_reminded_key`,
+			`args`,
+			`created_by`,
+			`created_at`,
+			`updated_at`,
+			`deleted_at`
+		) VALUES (
+			#{id},
+			#{bizType},
+			#{bizRemindedType},
+			#{bizRemindedKey},
+			#{args},
+			#{createdBy},
+			#{createdAt},
+			#{updatedAt},
+			#{deletedAt}
+		)
+		ON DUPLICATE KEY UPDATE `id` = `id`
+	</insert>
+
 	<select id="selectManagementPage" resultType="com.imyeyu.api.modules.common.vo.NotifyManagementItem">
 		SELECT
 			n.`id`,

src/main/resources/mapper/timi-server/common/SettingMapper.xml

@@ -0,0 +1,20 @@
+<?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.imyeyu.api.modules.common.mapper.SettingMapper">
+	<select id="selectPublicByQuery" resultType="com.imyeyu.api.modules.common.entity.Setting">
+		SELECT *
+		FROM `setting`
+		WHERE `biz_type` = #{bizType}
+			AND `is_private` = 0
+			<if test="bizId != null and bizId != ''">
+				AND `biz_id` = #{bizId}
+			</if>
+			<if test="codeList != null and !codeList.isEmpty()">
+				AND `code` IN
+				<foreach collection="codeList" item="code" separator="," open="(" close=")">
+					#{code}
+				</foreach>
+			</if>
+			AND (`deleted_at` IS NULL OR FLOOR(UNIX_TIMESTAMP(NOW(3)) * 1000) &lt; `deleted_at`)
+	</select>
+</mapper>

src/main/resources/mapper/timi-server/gao/GaoCustomerMapper.xml

@@ -18,7 +18,6 @@
 			</if>
 			AND `deleted_at` IS NULL
 	</select>
-
 	<sql id="queryWhere">
 		`c`.`deleted_at` IS NULL
 		<if test="storeId != null and storeId != ''">
@@ -64,7 +63,18 @@
 		FROM `gao_customer` `c`
 		WHERE
 			<include refid="queryWhere"/>
+		<choose>
+			<when test="orderMap != null and !orderMap.isEmpty()">
+				ORDER BY
+				<foreach collection="orderMap" index="key" item="value" separator=",">
+					<bind name="underscoreKey" value="@com.imyeyu.utils.Text@camelCase2underscore(key)"/>
+					${underscoreKey} ${value}
+				</foreach>
+			</when>
+			<otherwise>
 				ORDER BY `c`.`created_at` DESC, `c`.`id` DESC
+			</otherwise>
+		</choose>
 		LIMIT #{offset}, #{limit}
 	</select>