Compare commits
3 Commits
2ed121926b
...
98e427c65a
| Author | SHA1 | Date | |
|---|---|---|---|
| 98e427c65a | |||
| baf38df6c3 | |||
| eb4b615ed6 |
@@ -0,0 +1,44 @@
|
|||||||
|
package com.yolo.keyboard.api.tenantbalance;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantbalance.TenantBalanceDO;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantbalance.TenantBalanceMapper;
|
||||||
|
import com.yolo.keyboard.module.system.api.tenantbalance.TenantBalanceApi;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户余额 API 实现类
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
@Slf4j
|
||||||
|
public class TenantBalanceApiImpl implements TenantBalanceApi {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantBalanceMapper tenantBalanceMapper;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void initTenantBalance(Long tenantId) {
|
||||||
|
// 检查是否已存在
|
||||||
|
TenantBalanceDO existingBalance = tenantBalanceMapper.selectById(tenantId);
|
||||||
|
if (existingBalance != null) {
|
||||||
|
log.info("[initTenantBalance] 租户 {} 钱包已存在,跳过初始化", tenantId);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 初始化租户钱包
|
||||||
|
TenantBalanceDO balance = new TenantBalanceDO();
|
||||||
|
balance.setId(tenantId);
|
||||||
|
balance.setBalance(BigDecimal.ZERO);
|
||||||
|
balance.setWithdrawableBalance(BigDecimal.ZERO);
|
||||||
|
balance.setFrozenAmt(BigDecimal.ZERO);
|
||||||
|
balance.setVersion(0);
|
||||||
|
tenantBalanceMapper.insert(balance);
|
||||||
|
|
||||||
|
log.info("[initTenantBalance] 租户 {} 钱包初始化成功", tenantId);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,104 @@
|
|||||||
|
package com.yolo.keyboard.controller.admin.tenantcommission;
|
||||||
|
|
||||||
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
import org.springframework.security.access.prepost.PreAuthorize;
|
||||||
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
|
import io.swagger.v3.oas.annotations.Parameter;
|
||||||
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
|
|
||||||
|
import jakarta.validation.constraints.*;
|
||||||
|
import jakarta.validation.*;
|
||||||
|
import jakarta.servlet.http.*;
|
||||||
|
import java.util.*;
|
||||||
|
import java.io.IOException;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageParam;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageResult;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.CommonResult;
|
||||||
|
import com.yolo.keyboard.framework.common.util.object.BeanUtils;
|
||||||
|
import static com.yolo.keyboard.framework.common.pojo.CommonResult.success;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.framework.excel.core.util.ExcelUtils;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.framework.apilog.core.annotation.ApiAccessLog;
|
||||||
|
import static com.yolo.keyboard.framework.apilog.core.enums.OperateTypeEnum.*;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.controller.admin.tenantcommission.vo.*;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.service.tenantcommission.KeyboardTenantCommissionService;
|
||||||
|
|
||||||
|
@Tag(name = "管理后台 - 租户内购分成记录")
|
||||||
|
@RestController
|
||||||
|
@RequestMapping("/keyboard/tenant-commission")
|
||||||
|
@Validated
|
||||||
|
public class KeyboardTenantCommissionController {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardTenantCommissionService tenantCommissionService;
|
||||||
|
|
||||||
|
@PostMapping("/create")
|
||||||
|
@Operation(summary = "创建租户内购分成记录")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:create')")
|
||||||
|
public CommonResult<Long> createTenantCommission(@Valid @RequestBody KeyboardTenantCommissionSaveReqVO createReqVO) {
|
||||||
|
return success(tenantCommissionService.createTenantCommission(createReqVO));
|
||||||
|
}
|
||||||
|
|
||||||
|
@PutMapping("/update")
|
||||||
|
@Operation(summary = "更新租户内购分成记录")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:update')")
|
||||||
|
public CommonResult<Boolean> updateTenantCommission(@Valid @RequestBody KeyboardTenantCommissionSaveReqVO updateReqVO) {
|
||||||
|
tenantCommissionService.updateTenantCommission(updateReqVO);
|
||||||
|
return success(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
@DeleteMapping("/delete")
|
||||||
|
@Operation(summary = "删除租户内购分成记录")
|
||||||
|
@Parameter(name = "id", description = "编号", required = true)
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:delete')")
|
||||||
|
public CommonResult<Boolean> deleteTenantCommission(@RequestParam("id") Long id) {
|
||||||
|
tenantCommissionService.deleteTenantCommission(id);
|
||||||
|
return success(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
@DeleteMapping("/delete-list")
|
||||||
|
@Parameter(name = "ids", description = "编号", required = true)
|
||||||
|
@Operation(summary = "批量删除租户内购分成记录")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:delete')")
|
||||||
|
public CommonResult<Boolean> deleteTenantCommissionList(@RequestParam("ids") List<Long> ids) {
|
||||||
|
tenantCommissionService.deleteTenantCommissionListByIds(ids);
|
||||||
|
return success(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/get")
|
||||||
|
@Operation(summary = "获得租户内购分成记录")
|
||||||
|
@Parameter(name = "id", description = "编号", required = true, example = "1024")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:query')")
|
||||||
|
public CommonResult<KeyboardTenantCommissionRespVO> getTenantCommission(@RequestParam("id") Long id) {
|
||||||
|
KeyboardTenantCommissionDO tenantCommission = tenantCommissionService.getTenantCommission(id);
|
||||||
|
return success(BeanUtils.toBean(tenantCommission, KeyboardTenantCommissionRespVO.class));
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/page")
|
||||||
|
@Operation(summary = "获得租户内购分成记录分页")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:query')")
|
||||||
|
public CommonResult<PageResult<KeyboardTenantCommissionRespVO>> getTenantCommissionPage(@Valid KeyboardTenantCommissionPageReqVO pageReqVO) {
|
||||||
|
PageResult<KeyboardTenantCommissionDO> pageResult = tenantCommissionService.getTenantCommissionPage(pageReqVO);
|
||||||
|
return success(BeanUtils.toBean(pageResult, KeyboardTenantCommissionRespVO.class));
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/export-excel")
|
||||||
|
@Operation(summary = "导出租户内购分成记录 Excel")
|
||||||
|
@PreAuthorize("@ss.hasPermission('keyboard:tenant-commission:export')")
|
||||||
|
@ApiAccessLog(operateType = EXPORT)
|
||||||
|
public void exportTenantCommissionExcel(@Valid KeyboardTenantCommissionPageReqVO pageReqVO,
|
||||||
|
HttpServletResponse response) throws IOException {
|
||||||
|
pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
|
||||||
|
List<KeyboardTenantCommissionDO> list = tenantCommissionService.getTenantCommissionPage(pageReqVO).getList();
|
||||||
|
// 导出 Excel
|
||||||
|
ExcelUtils.write(response, "租户内购分成记录.xls", "数据", KeyboardTenantCommissionRespVO.class,
|
||||||
|
BeanUtils.toBean(list, KeyboardTenantCommissionRespVO.class));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,60 @@
|
|||||||
|
package com.yolo.keyboard.controller.admin.tenantcommission.vo;
|
||||||
|
|
||||||
|
import lombok.*;
|
||||||
|
import java.util.*;
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageParam;
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
import static com.yolo.keyboard.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
|
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 租户内购分成记录分页 Request VO")
|
||||||
|
@Data
|
||||||
|
public class KeyboardTenantCommissionPageReqVO extends PageParam {
|
||||||
|
|
||||||
|
@Schema(description = "内购记录ID", example = "20900")
|
||||||
|
private Integer purchaseRecordId;
|
||||||
|
|
||||||
|
@Schema(description = "内购交易ID", example = "30383")
|
||||||
|
private String transactionId;
|
||||||
|
|
||||||
|
@Schema(description = "被邀请用户ID(购买用户)", example = "2447")
|
||||||
|
private Integer inviteeUserId;
|
||||||
|
|
||||||
|
@Schema(description = "邀请人用户ID", example = "1012")
|
||||||
|
private Long inviterUserId;
|
||||||
|
|
||||||
|
@Schema(description = "内购金额")
|
||||||
|
private BigDecimal purchaseAmount;
|
||||||
|
|
||||||
|
@Schema(description = "分成比例")
|
||||||
|
private BigDecimal commissionRate;
|
||||||
|
|
||||||
|
@Schema(description = "分成金额")
|
||||||
|
private BigDecimal commissionAmount;
|
||||||
|
|
||||||
|
@Schema(description = "状态:PENDING-待结算,SETTLED-已结算,REFUNDED-已退款", example = "2")
|
||||||
|
private String status;
|
||||||
|
|
||||||
|
@Schema(description = "内购时间")
|
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
|
||||||
|
private LocalDateTime[] purchaseTime;
|
||||||
|
|
||||||
|
@Schema(description = "结算时间")
|
||||||
|
private LocalDateTime settledAt;
|
||||||
|
|
||||||
|
@Schema(description = "关联的余额交易记录ID", example = "29131")
|
||||||
|
private Long balanceTransactionId;
|
||||||
|
|
||||||
|
@Schema(description = "创建时间")
|
||||||
|
private LocalDateTime createdAt;
|
||||||
|
|
||||||
|
@Schema(description = "更新时间")
|
||||||
|
private LocalDateTime updatedAt;
|
||||||
|
|
||||||
|
@Schema(description = "备注", example = "随便")
|
||||||
|
private String remark;
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,76 @@
|
|||||||
|
package com.yolo.keyboard.controller.admin.tenantcommission.vo;
|
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import lombok.*;
|
||||||
|
import java.util.*;
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import cn.idev.excel.annotation.*;
|
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 租户内购分成记录 Response VO")
|
||||||
|
@Data
|
||||||
|
@ExcelIgnoreUnannotated
|
||||||
|
public class KeyboardTenantCommissionRespVO {
|
||||||
|
|
||||||
|
@Schema(description = "主键", requiredMode = Schema.RequiredMode.REQUIRED, example = "3144")
|
||||||
|
@ExcelProperty("主键")
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
@Schema(description = "内购记录ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "20900")
|
||||||
|
@ExcelProperty("内购记录ID")
|
||||||
|
private Integer purchaseRecordId;
|
||||||
|
|
||||||
|
@Schema(description = "内购交易ID", example = "30383")
|
||||||
|
@ExcelProperty("内购交易ID")
|
||||||
|
private String transactionId;
|
||||||
|
|
||||||
|
@Schema(description = "被邀请用户ID(购买用户)", example = "2447")
|
||||||
|
@ExcelProperty("被邀请用户ID(购买用户)")
|
||||||
|
private Integer inviteeUserId;
|
||||||
|
|
||||||
|
@Schema(description = "邀请人用户ID", example = "1012")
|
||||||
|
@ExcelProperty("邀请人用户ID")
|
||||||
|
private Long inviterUserId;
|
||||||
|
|
||||||
|
@Schema(description = "内购金额")
|
||||||
|
@ExcelProperty("内购金额")
|
||||||
|
private BigDecimal purchaseAmount;
|
||||||
|
|
||||||
|
@Schema(description = "分成比例")
|
||||||
|
@ExcelProperty("分成比例")
|
||||||
|
private BigDecimal commissionRate;
|
||||||
|
|
||||||
|
@Schema(description = "分成金额")
|
||||||
|
@ExcelProperty("分成金额")
|
||||||
|
private BigDecimal commissionAmount;
|
||||||
|
|
||||||
|
@Schema(description = "状态:PENDING-待结算,SETTLED-已结算,REFUNDED-已退款", example = "2")
|
||||||
|
@ExcelProperty("状态:PENDING-待结算,SETTLED-已结算,REFUNDED-已退款")
|
||||||
|
private String status;
|
||||||
|
|
||||||
|
@Schema(description = "内购时间")
|
||||||
|
@ExcelProperty("内购时间")
|
||||||
|
private LocalDateTime purchaseTime;
|
||||||
|
|
||||||
|
@Schema(description = "结算时间")
|
||||||
|
@ExcelProperty("结算时间")
|
||||||
|
private LocalDateTime settledAt;
|
||||||
|
|
||||||
|
@Schema(description = "关联的余额交易记录ID", example = "29131")
|
||||||
|
@ExcelProperty("关联的余额交易记录ID")
|
||||||
|
private Long balanceTransactionId;
|
||||||
|
|
||||||
|
@Schema(description = "创建时间")
|
||||||
|
@ExcelProperty("创建时间")
|
||||||
|
private LocalDateTime createdAt;
|
||||||
|
|
||||||
|
@Schema(description = "更新时间")
|
||||||
|
@ExcelProperty("更新时间")
|
||||||
|
private LocalDateTime updatedAt;
|
||||||
|
|
||||||
|
@Schema(description = "备注", example = "随便")
|
||||||
|
@ExcelProperty("备注")
|
||||||
|
private String remark;
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,61 @@
|
|||||||
|
package com.yolo.keyboard.controller.admin.tenantcommission.vo;
|
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
import lombok.*;
|
||||||
|
import java.util.*;
|
||||||
|
import jakarta.validation.constraints.*;
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Schema(description = "管理后台 - 租户内购分成记录新增/修改 Request VO")
|
||||||
|
@Data
|
||||||
|
public class KeyboardTenantCommissionSaveReqVO {
|
||||||
|
|
||||||
|
@Schema(description = "主键", requiredMode = Schema.RequiredMode.REQUIRED, example = "3144")
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
@Schema(description = "内购记录ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "20900")
|
||||||
|
@NotNull(message = "内购记录ID不能为空")
|
||||||
|
private Integer purchaseRecordId;
|
||||||
|
|
||||||
|
@Schema(description = "内购交易ID", example = "30383")
|
||||||
|
private String transactionId;
|
||||||
|
|
||||||
|
@Schema(description = "被邀请用户ID(购买用户)", example = "2447")
|
||||||
|
private Integer inviteeUserId;
|
||||||
|
|
||||||
|
@Schema(description = "邀请人用户ID", example = "1012")
|
||||||
|
private Long inviterUserId;
|
||||||
|
|
||||||
|
@Schema(description = "内购金额")
|
||||||
|
private BigDecimal purchaseAmount;
|
||||||
|
|
||||||
|
@Schema(description = "分成比例")
|
||||||
|
private BigDecimal commissionRate;
|
||||||
|
|
||||||
|
@Schema(description = "分成金额")
|
||||||
|
private BigDecimal commissionAmount;
|
||||||
|
|
||||||
|
@Schema(description = "状态:PENDING-待结算,SETTLED-已结算,REFUNDED-已退款", example = "2")
|
||||||
|
private String status;
|
||||||
|
|
||||||
|
@Schema(description = "内购时间")
|
||||||
|
private LocalDateTime purchaseTime;
|
||||||
|
|
||||||
|
@Schema(description = "结算时间")
|
||||||
|
private LocalDateTime settledAt;
|
||||||
|
|
||||||
|
@Schema(description = "关联的余额交易记录ID", example = "29131")
|
||||||
|
private Long balanceTransactionId;
|
||||||
|
|
||||||
|
@Schema(description = "创建时间")
|
||||||
|
private LocalDateTime createdAt;
|
||||||
|
|
||||||
|
@Schema(description = "更新时间")
|
||||||
|
private LocalDateTime updatedAt;
|
||||||
|
|
||||||
|
@Schema(description = "备注", example = "随便")
|
||||||
|
private String remark;
|
||||||
|
|
||||||
|
}
|
||||||
@@ -15,7 +15,7 @@ import com.yolo.keyboard.framework.mybatis.core.dataobject.BaseDO;
|
|||||||
* @author 芋道源码
|
* @author 芋道源码
|
||||||
*/
|
*/
|
||||||
@TableName("system_tenant_balance")
|
@TableName("system_tenant_balance")
|
||||||
@KeySequence("system_tenant_balance_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
|
//@KeySequence("system_tenant_balance_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库,可不写。
|
||||||
@Data
|
@Data
|
||||||
@EqualsAndHashCode(callSuper = true)
|
@EqualsAndHashCode(callSuper = true)
|
||||||
@ToString(callSuper = true)
|
@ToString(callSuper = true)
|
||||||
|
|||||||
@@ -0,0 +1,117 @@
|
|||||||
|
package com.yolo.keyboard.dal.dataobject.tenantcommission;
|
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.annotation.KeySequence;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableId;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableName;
|
||||||
|
import com.yolo.keyboard.framework.tenant.core.aop.TenantIgnore;
|
||||||
|
import lombok.*;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户分成记录 DO
|
||||||
|
* 记录每笔内购订单的分成计算结果
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@TableName("keyboard_tenant_commission")
|
||||||
|
@KeySequence("keyboard_tenant_commission_seq")
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@NoArgsConstructor
|
||||||
|
@AllArgsConstructor
|
||||||
|
@TenantIgnore
|
||||||
|
public class KeyboardTenantCommissionDO {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 主键
|
||||||
|
*/
|
||||||
|
@TableId
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 内购记录ID
|
||||||
|
*/
|
||||||
|
private Integer purchaseRecordId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 内购交易ID(唯一标识)
|
||||||
|
*/
|
||||||
|
private String transactionId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 被邀请用户ID(购买用户)
|
||||||
|
*/
|
||||||
|
private Integer inviteeUserId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 邀请人用户ID
|
||||||
|
*/
|
||||||
|
private Long inviterUserId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 收益归属租户ID
|
||||||
|
*/
|
||||||
|
private Long tenantId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 内购金额
|
||||||
|
*/
|
||||||
|
private BigDecimal purchaseAmount;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 分成比例
|
||||||
|
*/
|
||||||
|
private BigDecimal commissionRate;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 分成金额
|
||||||
|
*/
|
||||||
|
private BigDecimal commissionAmount;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 状态:PENDING-待结算,SETTLED-已结算,REFUNDED-已退款
|
||||||
|
*/
|
||||||
|
private String status;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 内购时间
|
||||||
|
*/
|
||||||
|
private LocalDateTime purchaseTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 结算时间
|
||||||
|
*/
|
||||||
|
private LocalDateTime settledAt;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 关联的余额交易记录ID
|
||||||
|
*/
|
||||||
|
private Long balanceTransactionId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建时间
|
||||||
|
*/
|
||||||
|
private LocalDateTime createdAt;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 更新时间
|
||||||
|
*/
|
||||||
|
private LocalDateTime updatedAt;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 可提现时间(结算时间 + 30天)
|
||||||
|
*/
|
||||||
|
private LocalDateTime withdrawableAt;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 是否已处理转可提现:false-未处理,true-已处理
|
||||||
|
*/
|
||||||
|
private Boolean withdrawableProcessed;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 备注
|
||||||
|
*/
|
||||||
|
private String remark;
|
||||||
|
}
|
||||||
@@ -0,0 +1,51 @@
|
|||||||
|
package com.yolo.keyboard.dal.mysql.tenantcommission;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.controller.admin.tenantcommission.vo.KeyboardTenantCommissionPageReqVO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageResult;
|
||||||
|
import com.yolo.keyboard.framework.mybatis.core.mapper.BaseMapperX;
|
||||||
|
import com.yolo.keyboard.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||||
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户分成记录 Mapper
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@Mapper
|
||||||
|
public interface KeyboardTenantCommissionMapper extends BaseMapperX<KeyboardTenantCommissionDO> {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据交易ID查询分成记录
|
||||||
|
*/
|
||||||
|
default KeyboardTenantCommissionDO selectByTransactionId(String transactionId) {
|
||||||
|
return selectOne(KeyboardTenantCommissionDO::getTransactionId, transactionId);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据内购记录ID查询分成记录
|
||||||
|
*/
|
||||||
|
default KeyboardTenantCommissionDO selectByPurchaseRecordId(Integer purchaseRecordId) {
|
||||||
|
return selectOne(KeyboardTenantCommissionDO::getPurchaseRecordId, purchaseRecordId);
|
||||||
|
}
|
||||||
|
|
||||||
|
default PageResult<KeyboardTenantCommissionDO> selectPage(KeyboardTenantCommissionPageReqVO reqVO) {
|
||||||
|
return selectPage(reqVO, new LambdaQueryWrapperX<KeyboardTenantCommissionDO>()
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getPurchaseRecordId, reqVO.getPurchaseRecordId())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getTransactionId, reqVO.getTransactionId())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getInviteeUserId, reqVO.getInviteeUserId())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getInviterUserId, reqVO.getInviterUserId())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getPurchaseAmount, reqVO.getPurchaseAmount())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getCommissionRate, reqVO.getCommissionRate())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getCommissionAmount, reqVO.getCommissionAmount())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getStatus, reqVO.getStatus())
|
||||||
|
.betweenIfPresent(KeyboardTenantCommissionDO::getPurchaseTime, reqVO.getPurchaseTime())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getSettledAt, reqVO.getSettledAt())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getBalanceTransactionId, reqVO.getBalanceTransactionId())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getCreatedAt, reqVO.getCreatedAt())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getUpdatedAt, reqVO.getUpdatedAt())
|
||||||
|
.eqIfPresent(KeyboardTenantCommissionDO::getRemark, reqVO.getRemark())
|
||||||
|
.orderByDesc(KeyboardTenantCommissionDO::getId));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,132 @@
|
|||||||
|
package com.yolo.keyboard.job;
|
||||||
|
|
||||||
|
import cn.hutool.core.collection.CollUtil;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantbalance.TenantBalanceDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantbalancetransaction.TenantBalanceTransactionDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantbalance.TenantBalanceMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantbalancetransaction.TenantBalanceTransactionMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantcommission.KeyboardTenantCommissionMapper;
|
||||||
|
import com.yolo.keyboard.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||||
|
import com.yolo.keyboard.framework.quartz.core.handler.JobHandler;
|
||||||
|
import com.yolo.keyboard.framework.tenant.core.aop.TenantIgnore;
|
||||||
|
import com.yolo.keyboard.utils.BizNoGenerator;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 分成可提现转换定时任务
|
||||||
|
* 每小时执行一次,将满30天的分成金额转为可提现余额
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Slf4j
|
||||||
|
public class CommissionWithdrawableJob implements JobHandler {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardTenantCommissionMapper commissionMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantBalanceMapper tenantBalanceMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantBalanceTransactionMapper balanceTransactionMapper;
|
||||||
|
|
||||||
|
private static final String WITHDRAWABLE_TYPE = "WITHDRAWABLE";
|
||||||
|
|
||||||
|
@Override
|
||||||
|
@TenantIgnore
|
||||||
|
@Transactional(rollbackFor = Exception.class)
|
||||||
|
public String execute(String param) {
|
||||||
|
log.info("[CommissionWithdrawableJob] 开始执行分成可提现转换任务");
|
||||||
|
|
||||||
|
LocalDateTime now = LocalDateTime.now();
|
||||||
|
|
||||||
|
// 1. 查询已到可提现时间且未处理的分成记录
|
||||||
|
List<KeyboardTenantCommissionDO> commissions = commissionMapper.selectList(
|
||||||
|
new LambdaQueryWrapperX<KeyboardTenantCommissionDO>()
|
||||||
|
.le(KeyboardTenantCommissionDO::getWithdrawableAt, now)
|
||||||
|
.eq(KeyboardTenantCommissionDO::getWithdrawableProcessed, false)
|
||||||
|
.eq(KeyboardTenantCommissionDO::getStatus, "SETTLED")
|
||||||
|
);
|
||||||
|
|
||||||
|
if (CollUtil.isEmpty(commissions)) {
|
||||||
|
log.info("[CommissionWithdrawableJob] 没有需要处理的分成记录");
|
||||||
|
return "没有需要处理的分成记录";
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. 按租户分组汇总金额
|
||||||
|
Map<Long, List<KeyboardTenantCommissionDO>> tenantCommissionsMap = commissions.stream()
|
||||||
|
.collect(Collectors.groupingBy(KeyboardTenantCommissionDO::getTenantId));
|
||||||
|
|
||||||
|
int tenantCount = 0;
|
||||||
|
int commissionCount = 0;
|
||||||
|
BigDecimal totalAmount = BigDecimal.ZERO;
|
||||||
|
|
||||||
|
// 3. 逐个租户处理
|
||||||
|
for (Map.Entry<Long, List<KeyboardTenantCommissionDO>> entry : tenantCommissionsMap.entrySet()) {
|
||||||
|
Long tenantId = entry.getKey();
|
||||||
|
List<KeyboardTenantCommissionDO> tenantCommissions = entry.getValue();
|
||||||
|
|
||||||
|
// 计算该租户的总可提现金额
|
||||||
|
BigDecimal tenantTotalAmount = tenantCommissions.stream()
|
||||||
|
.map(KeyboardTenantCommissionDO::getCommissionAmount)
|
||||||
|
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
||||||
|
|
||||||
|
// 更新租户可提现余额
|
||||||
|
TenantBalanceDO balance = tenantBalanceMapper.selectById(tenantId);
|
||||||
|
if (balance == null) {
|
||||||
|
log.warn("[CommissionWithdrawableJob] 租户 {} 余额记录不存在,跳过", tenantId);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
BigDecimal currentWithdrawable = balance.getWithdrawableBalance() != null
|
||||||
|
? balance.getWithdrawableBalance() : BigDecimal.ZERO;
|
||||||
|
BigDecimal newWithdrawable = currentWithdrawable.add(tenantTotalAmount);
|
||||||
|
balance.setWithdrawableBalance(newWithdrawable);
|
||||||
|
tenantBalanceMapper.updateById(balance);
|
||||||
|
|
||||||
|
// 创建余额交易记录
|
||||||
|
String bizNo = BizNoGenerator.generate("WDB");
|
||||||
|
TenantBalanceTransactionDO transaction = TenantBalanceTransactionDO.builder()
|
||||||
|
.bizNo(bizNo)
|
||||||
|
.points(tenantTotalAmount)
|
||||||
|
.balance(balance.getBalance())
|
||||||
|
.tenantId(tenantId)
|
||||||
|
.type(WITHDRAWABLE_TYPE)
|
||||||
|
.description("分成转可提现")
|
||||||
|
.createdAt(now)
|
||||||
|
.remark("共 " + tenantCommissions.size() + " 笔分成转为可提现")
|
||||||
|
.build();
|
||||||
|
balanceTransactionMapper.insert(transaction);
|
||||||
|
|
||||||
|
// 标记分成记录为已处理
|
||||||
|
for (KeyboardTenantCommissionDO commission : tenantCommissions) {
|
||||||
|
commission.setWithdrawableProcessed(true);
|
||||||
|
commission.setUpdatedAt(now);
|
||||||
|
commissionMapper.updateById(commission);
|
||||||
|
}
|
||||||
|
|
||||||
|
tenantCount++;
|
||||||
|
commissionCount += tenantCommissions.size();
|
||||||
|
totalAmount = totalAmount.add(tenantTotalAmount);
|
||||||
|
|
||||||
|
log.info("[CommissionWithdrawableJob] 处理租户 {},分成 {} 笔,金额 {}",
|
||||||
|
tenantId, tenantCommissions.size(), tenantTotalAmount);
|
||||||
|
}
|
||||||
|
|
||||||
|
String result = String.format("处理租户 %d 个,分成记录 %d 条,总金额 %s",
|
||||||
|
tenantCount, commissionCount, totalAmount.toPlainString());
|
||||||
|
log.info("[CommissionWithdrawableJob] 任务执行完成: {}", result);
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,215 @@
|
|||||||
|
package com.yolo.keyboard.job;
|
||||||
|
|
||||||
|
import cn.hutool.core.collection.CollUtil;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantbalance.TenantBalanceDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantbalancetransaction.TenantBalanceTransactionDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.userinvites.KeyboardUserInvitesDO;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.userpurchaserecords.KeyboardUserPurchaseRecordsDO;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantbalance.TenantBalanceMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantbalancetransaction.TenantBalanceTransactionMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantcommission.KeyboardTenantCommissionMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.userinvites.KeyboardUserInvitesMapper;
|
||||||
|
import com.yolo.keyboard.dal.mysql.userpurchaserecords.KeyboardUserPurchaseRecordsMapper;
|
||||||
|
import com.yolo.keyboard.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||||
|
import com.yolo.keyboard.framework.quartz.core.handler.JobHandler;
|
||||||
|
import com.yolo.keyboard.framework.tenant.core.aop.TenantIgnore;
|
||||||
|
import com.yolo.keyboard.module.system.dal.dataobject.tenant.TenantDO;
|
||||||
|
import com.yolo.keyboard.module.system.dal.mysql.tenant.TenantMapper;
|
||||||
|
import com.yolo.keyboard.utils.BizNoGenerator;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.math.RoundingMode;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户分成计算定时任务
|
||||||
|
* 每小时执行一次,计算邀请用户的内购分成
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Slf4j
|
||||||
|
public class TenantCommissionCalculateJob implements JobHandler {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardUserPurchaseRecordsMapper purchaseRecordsMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardUserInvitesMapper userInvitesMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardTenantCommissionMapper commissionMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantMapper tenantMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantBalanceMapper tenantBalanceMapper;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private TenantBalanceTransactionMapper balanceTransactionMapper;
|
||||||
|
|
||||||
|
private static final String COMMISSION_TYPE = "COMMISSION";
|
||||||
|
private static final String STATUS_PAID = "PAID";
|
||||||
|
private static final String INVITE_TYPE_AGENT = "AGENT";
|
||||||
|
|
||||||
|
@Override
|
||||||
|
@TenantIgnore
|
||||||
|
@Transactional(rollbackFor = Exception.class)
|
||||||
|
public String execute(String param) {
|
||||||
|
log.info("[TenantCommissionCalculateJob] 开始执行分成计算任务");
|
||||||
|
|
||||||
|
// 1. 查询最近一小时内已支付的内购记录
|
||||||
|
LocalDateTime endTime = LocalDateTime.now();
|
||||||
|
LocalDateTime startTime = endTime.minusHours(1);
|
||||||
|
|
||||||
|
List<KeyboardUserPurchaseRecordsDO> purchaseRecords = purchaseRecordsMapper.selectList(
|
||||||
|
new LambdaQueryWrapperX<KeyboardUserPurchaseRecordsDO>()
|
||||||
|
.eq(KeyboardUserPurchaseRecordsDO::getStatus, STATUS_PAID)
|
||||||
|
.between(KeyboardUserPurchaseRecordsDO::getPurchaseTime, startTime, endTime)
|
||||||
|
);
|
||||||
|
|
||||||
|
if (CollUtil.isEmpty(purchaseRecords)) {
|
||||||
|
log.info("[TenantCommissionCalculateJob] 最近一小时内没有已支付的内购记录");
|
||||||
|
return "没有需要处理的内购记录";
|
||||||
|
}
|
||||||
|
|
||||||
|
int processedCount = 0;
|
||||||
|
int commissionCount = 0;
|
||||||
|
BigDecimal totalCommission = BigDecimal.ZERO;
|
||||||
|
|
||||||
|
// 2. 遍历内购记录,检查是否有邀请关系
|
||||||
|
for (KeyboardUserPurchaseRecordsDO record : purchaseRecords) {
|
||||||
|
// 检查是否已经计算过分成
|
||||||
|
if (commissionMapper.selectByPurchaseRecordId(record.getId()) != null) {
|
||||||
|
log.debug("[TenantCommissionCalculateJob] 内购记录 {} 已计算过分成,跳过", record.getId());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
processedCount++;
|
||||||
|
|
||||||
|
// 查询该用户的邀请关系
|
||||||
|
KeyboardUserInvitesDO invite = userInvitesMapper.selectOne(
|
||||||
|
KeyboardUserInvitesDO::getInviteeUserId, record.getUserId().longValue()
|
||||||
|
);
|
||||||
|
|
||||||
|
if (invite == null) {
|
||||||
|
log.debug("[TenantCommissionCalculateJob] 用户 {} 没有邀请关系,跳过", record.getUserId());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 只处理代理邀请类型
|
||||||
|
if (!INVITE_TYPE_AGENT.equals(invite.getInviteType())) {
|
||||||
|
log.debug("[TenantCommissionCalculateJob] 用户 {} 的邀请类型不是代理,跳过", record.getUserId());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获取收益归属租户
|
||||||
|
Long tenantId = invite.getProfitTenantId();
|
||||||
|
if (tenantId == null) {
|
||||||
|
tenantId = invite.getInviterTenantId();
|
||||||
|
}
|
||||||
|
if (tenantId == null) {
|
||||||
|
log.warn("[TenantCommissionCalculateJob] 用户 {} 的邀请关系没有关联租户,跳过", record.getUserId());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获取租户信息和分成比例
|
||||||
|
TenantDO tenant = tenantMapper.selectById(tenantId);
|
||||||
|
if (tenant == null) {
|
||||||
|
log.warn("[TenantCommissionCalculateJob] 租户 {} 不存在,跳过", tenantId);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
BigDecimal commissionRate = tenant.getProfitShareRatio();
|
||||||
|
if (commissionRate == null || commissionRate.compareTo(BigDecimal.ZERO) <= 0) {
|
||||||
|
log.debug("[TenantCommissionCalculateJob] 租户 {} 没有设置分成比例,跳过", tenantId);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. 计算分成金额
|
||||||
|
BigDecimal purchaseAmount = record.getPrice();
|
||||||
|
if (purchaseAmount == null || purchaseAmount.compareTo(BigDecimal.ZERO) <= 0) {
|
||||||
|
log.debug("[TenantCommissionCalculateJob] 内购记录 {} 金额无效,跳过", record.getId());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
BigDecimal commissionAmount = purchaseAmount.multiply(commissionRate)
|
||||||
|
.setScale(2, RoundingMode.HALF_UP);
|
||||||
|
|
||||||
|
// 4. 创建分成记录
|
||||||
|
LocalDateTime now = LocalDateTime.now();
|
||||||
|
LocalDateTime withdrawableAt = now.plusDays(30); // 30天后可提现
|
||||||
|
KeyboardTenantCommissionDO commission = KeyboardTenantCommissionDO.builder()
|
||||||
|
.purchaseRecordId(record.getId())
|
||||||
|
.transactionId(record.getTransactionId())
|
||||||
|
.inviteeUserId(record.getUserId())
|
||||||
|
.inviterUserId(invite.getProfitEmployeeId())
|
||||||
|
.tenantId(tenantId)
|
||||||
|
.purchaseAmount(purchaseAmount)
|
||||||
|
.commissionRate(commissionRate)
|
||||||
|
.commissionAmount(commissionAmount)
|
||||||
|
.status("SETTLED")
|
||||||
|
.purchaseTime(record.getPurchaseTime())
|
||||||
|
.settledAt(now)
|
||||||
|
.withdrawableAt(withdrawableAt)
|
||||||
|
.withdrawableProcessed(false)
|
||||||
|
.createdAt(now)
|
||||||
|
.updatedAt(now)
|
||||||
|
.build();
|
||||||
|
|
||||||
|
// 5. 更新租户余额(分成金额先计入总余额,30天后才可提现)
|
||||||
|
TenantBalanceDO balance = tenantBalanceMapper.selectById(tenantId);
|
||||||
|
if (balance == null) {
|
||||||
|
// 如果租户余额记录不存在,创建一个
|
||||||
|
balance = new TenantBalanceDO();
|
||||||
|
balance.setId(tenantId);
|
||||||
|
balance.setBalance(commissionAmount);
|
||||||
|
balance.setWithdrawableBalance(BigDecimal.ZERO);
|
||||||
|
balance.setFrozenAmt(BigDecimal.ZERO);
|
||||||
|
balance.setVersion(0);
|
||||||
|
tenantBalanceMapper.insert(balance);
|
||||||
|
} else {
|
||||||
|
BigDecimal newBalance = balance.getBalance().add(commissionAmount);
|
||||||
|
balance.setBalance(newBalance);
|
||||||
|
tenantBalanceMapper.updateById(balance);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 6. 创建余额交易记录
|
||||||
|
String bizNo = BizNoGenerator.generate("COMM");
|
||||||
|
TenantBalanceTransactionDO transaction = TenantBalanceTransactionDO.builder()
|
||||||
|
.bizNo(bizNo)
|
||||||
|
.points(commissionAmount)
|
||||||
|
.balance(balance.getBalance())
|
||||||
|
.tenantId(tenantId)
|
||||||
|
.type(COMMISSION_TYPE)
|
||||||
|
.description("邀请用户内购分成")
|
||||||
|
.orderId(record.getTransactionId())
|
||||||
|
.createdAt(now)
|
||||||
|
.remark("内购记录ID: " + record.getId() + ", 被邀请用户: " + record.getUserId())
|
||||||
|
.build();
|
||||||
|
balanceTransactionMapper.insert(transaction);
|
||||||
|
|
||||||
|
// 更新分成记录的关联交易ID
|
||||||
|
commission.setBalanceTransactionId(transaction.getId());
|
||||||
|
commissionMapper.insert(commission);
|
||||||
|
|
||||||
|
commissionCount++;
|
||||||
|
totalCommission = totalCommission.add(commissionAmount);
|
||||||
|
|
||||||
|
log.info("[TenantCommissionCalculateJob] 处理内购记录 {}, 租户 {}, 分成金额 {}",
|
||||||
|
record.getId(), tenantId, commissionAmount);
|
||||||
|
}
|
||||||
|
|
||||||
|
String result = String.format("处理内购记录 %d 条,生成分成 %d 条,总分成金额 %s",
|
||||||
|
processedCount, commissionCount, totalCommission.toPlainString());
|
||||||
|
log.info("[TenantCommissionCalculateJob] 任务执行完成: {}", result);
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,62 @@
|
|||||||
|
package com.yolo.keyboard.service.tenantcommission;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
import jakarta.validation.*;
|
||||||
|
import com.yolo.keyboard.controller.admin.tenantcommission.vo.*;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageResult;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageParam;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户内购分成记录 Service 接口
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
public interface KeyboardTenantCommissionService {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建租户内购分成记录
|
||||||
|
*
|
||||||
|
* @param createReqVO 创建信息
|
||||||
|
* @return 编号
|
||||||
|
*/
|
||||||
|
Long createTenantCommission(@Valid KeyboardTenantCommissionSaveReqVO createReqVO);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 更新租户内购分成记录
|
||||||
|
*
|
||||||
|
* @param updateReqVO 更新信息
|
||||||
|
*/
|
||||||
|
void updateTenantCommission(@Valid KeyboardTenantCommissionSaveReqVO updateReqVO);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 删除租户内购分成记录
|
||||||
|
*
|
||||||
|
* @param id 编号
|
||||||
|
*/
|
||||||
|
void deleteTenantCommission(Long id);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 批量删除租户内购分成记录
|
||||||
|
*
|
||||||
|
* @param ids 编号
|
||||||
|
*/
|
||||||
|
void deleteTenantCommissionListByIds(List<Long> ids);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得租户内购分成记录
|
||||||
|
*
|
||||||
|
* @param id 编号
|
||||||
|
* @return 租户内购分成记录
|
||||||
|
*/
|
||||||
|
KeyboardTenantCommissionDO getTenantCommission(Long id);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得租户内购分成记录分页
|
||||||
|
*
|
||||||
|
* @param pageReqVO 分页查询
|
||||||
|
* @return 租户内购分成记录分页
|
||||||
|
*/
|
||||||
|
PageResult<KeyboardTenantCommissionDO> getTenantCommissionPage(KeyboardTenantCommissionPageReqVO pageReqVO);
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,84 @@
|
|||||||
|
package com.yolo.keyboard.service.tenantcommission;
|
||||||
|
|
||||||
|
import cn.hutool.core.collection.CollUtil;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
import com.yolo.keyboard.controller.admin.tenantcommission.vo.*;
|
||||||
|
import com.yolo.keyboard.dal.dataobject.tenantcommission.KeyboardTenantCommissionDO;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageResult;
|
||||||
|
import com.yolo.keyboard.framework.common.pojo.PageParam;
|
||||||
|
import com.yolo.keyboard.framework.common.util.object.BeanUtils;
|
||||||
|
|
||||||
|
import com.yolo.keyboard.dal.mysql.tenantcommission.KeyboardTenantCommissionMapper;
|
||||||
|
|
||||||
|
import static com.yolo.keyboard.framework.common.exception.util.ServiceExceptionUtil.exception;
|
||||||
|
import static com.yolo.keyboard.framework.common.util.collection.CollectionUtils.convertList;
|
||||||
|
import static com.yolo.keyboard.framework.common.util.collection.CollectionUtils.diffList;import static com.yolo.keyboard.module.infra.enums.ErrorCodeConstants.TENANT_COMMISSION_NOT_EXISTS;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户内购分成记录 Service 实现类
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
@Validated
|
||||||
|
public class KeyboardTenantCommissionServiceImpl implements KeyboardTenantCommissionService {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private KeyboardTenantCommissionMapper tenantCommissionMapper;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long createTenantCommission(KeyboardTenantCommissionSaveReqVO createReqVO) {
|
||||||
|
// 插入
|
||||||
|
KeyboardTenantCommissionDO tenantCommission = BeanUtils.toBean(createReqVO, KeyboardTenantCommissionDO.class);
|
||||||
|
tenantCommissionMapper.insert(tenantCommission);
|
||||||
|
|
||||||
|
// 返回
|
||||||
|
return tenantCommission.getId();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void updateTenantCommission(KeyboardTenantCommissionSaveReqVO updateReqVO) {
|
||||||
|
// 校验存在
|
||||||
|
validateTenantCommissionExists(updateReqVO.getId());
|
||||||
|
// 更新
|
||||||
|
KeyboardTenantCommissionDO updateObj = BeanUtils.toBean(updateReqVO, KeyboardTenantCommissionDO.class);
|
||||||
|
tenantCommissionMapper.updateById(updateObj);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void deleteTenantCommission(Long id) {
|
||||||
|
// 校验存在
|
||||||
|
validateTenantCommissionExists(id);
|
||||||
|
// 删除
|
||||||
|
tenantCommissionMapper.deleteById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void deleteTenantCommissionListByIds(List<Long> ids) {
|
||||||
|
// 删除
|
||||||
|
tenantCommissionMapper.deleteByIds(ids);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private void validateTenantCommissionExists(Long id) {
|
||||||
|
if (tenantCommissionMapper.selectById(id) == null) {
|
||||||
|
throw exception(TENANT_COMMISSION_NOT_EXISTS);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public KeyboardTenantCommissionDO getTenantCommission(Long id) {
|
||||||
|
return tenantCommissionMapper.selectById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public PageResult<KeyboardTenantCommissionDO> getTenantCommissionPage(KeyboardTenantCommissionPageReqVO pageReqVO) {
|
||||||
|
return tenantCommissionMapper.selectPage(pageReqVO);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -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.yolo.keyboard.module.keyboard.dal.mysql.tenantcommission.KeyboardTenantCommissionMapper">
|
||||||
|
|
||||||
|
<!--
|
||||||
|
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
|
||||||
|
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
|
||||||
|
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
|
||||||
|
文档可见:https://www.iocoder.cn/MyBatis/x-plugins/
|
||||||
|
-->
|
||||||
|
|
||||||
|
</mapper>
|
||||||
2
pom.xml
2
pom.xml
@@ -46,6 +46,8 @@
|
|||||||
<spring.boot.version>3.5.5</spring.boot.version>
|
<spring.boot.version>3.5.5</spring.boot.version>
|
||||||
<mapstruct.version>1.6.3</mapstruct.version>
|
<mapstruct.version>1.6.3</mapstruct.version>
|
||||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
|
<!-- 覆盖 Spring Boot 默认的 Quartz 版本 -->
|
||||||
|
<quartz.version>2.5.2</quartz.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<dependencyManagement>
|
<dependencyManagement>
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"local": {
|
"local": {
|
||||||
"baseUrl": "http://127.0.0.1:48080/admin-api",
|
"baseUrl": "http://127.0.0.1:48081/admin-api",
|
||||||
"token": "test1",
|
"token": "test1",
|
||||||
"adminTenantId": "1",
|
"adminTenantId": "1",
|
||||||
|
|
||||||
|
|||||||
@@ -18,6 +18,8 @@
|
|||||||
<flatten-maven-plugin.version>1.7.2</flatten-maven-plugin.version>
|
<flatten-maven-plugin.version>1.7.2</flatten-maven-plugin.version>
|
||||||
<!-- 统一依赖管理 -->
|
<!-- 统一依赖管理 -->
|
||||||
<spring.boot.version>3.5.8</spring.boot.version>
|
<spring.boot.version>3.5.8</spring.boot.version>
|
||||||
|
<!-- 覆盖 Spring Boot 默认的 Quartz 版本 -->
|
||||||
|
<quartz.version>2.5.2</quartz.version>
|
||||||
<!-- Web 相关 -->
|
<!-- Web 相关 -->
|
||||||
<springdoc.version>2.8.14</springdoc.version>
|
<springdoc.version>2.8.14</springdoc.version>
|
||||||
<knife4j.version>4.5.0</knife4j.version>
|
<knife4j.version>4.5.0</knife4j.version>
|
||||||
@@ -95,6 +97,13 @@
|
|||||||
<scope>import</scope>
|
<scope>import</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- 覆盖 Spring Boot 默认的 Quartz 版本 -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.quartz-scheduler</groupId>
|
||||||
|
<artifactId>quartz</artifactId>
|
||||||
|
<version>${quartz.version}</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
<!-- 业务组件 -->
|
<!-- 业务组件 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>io.github.mouzt</groupId>
|
<groupId>io.github.mouzt</groupId>
|
||||||
|
|||||||
@@ -28,8 +28,19 @@
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.springframework.boot</groupId>
|
<groupId>org.springframework.boot</groupId>
|
||||||
<artifactId>spring-boot-starter-quartz</artifactId>
|
<artifactId>spring-boot-starter-quartz</artifactId>
|
||||||
|
<exclusions>
|
||||||
|
<exclusion>
|
||||||
|
<artifactId>quartz</artifactId>
|
||||||
|
<groupId>org.quartz-scheduler</groupId>
|
||||||
|
</exclusion>
|
||||||
|
</exclusions>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.quartz-scheduler</groupId>
|
||||||
|
<artifactId>quartz</artifactId>
|
||||||
|
<version>2.5.2</version>
|
||||||
|
</dependency>
|
||||||
<!-- 工具类相关 -->
|
<!-- 工具类相关 -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>jakarta.validation</groupId>
|
<groupId>jakarta.validation</groupId>
|
||||||
|
|||||||
@@ -22,55 +22,8 @@ public class BannerApplicationRunner implements ApplicationRunner {
|
|||||||
ThreadUtil.sleep(1, TimeUnit.SECONDS); // 延迟 1 秒,保证输出到结尾
|
ThreadUtil.sleep(1, TimeUnit.SECONDS); // 延迟 1 秒,保证输出到结尾
|
||||||
log.info("\n----------------------------------------------------------\n\t" +
|
log.info("\n----------------------------------------------------------\n\t" +
|
||||||
"项目启动成功!\n\t" +
|
"项目启动成功!\n\t" +
|
||||||
"接口文档: \t{} \n\t" +
|
|
||||||
"开发文档: \t{} \n\t" +
|
|
||||||
"视频教程: \t{} \n" +
|
|
||||||
"----------------------------------------------------------",
|
|
||||||
"https://doc.iocoder.cn/api-doc/",
|
|
||||||
"https://doc.iocoder.cn",
|
|
||||||
"https://t.zsxq.com/02Yf6M7Qn");
|
|
||||||
|
|
||||||
// 数据报表
|
"----------------------------------------------------------");
|
||||||
if (isNotPresent("com.yolo.keyboard.module.report.framework.security.config.SecurityConfiguration")) {
|
|
||||||
System.out.println("[报表模块 yolo-module-report - 已禁用][参考 https://doc.iocoder.cn/report/ 开启]");
|
|
||||||
}
|
|
||||||
// 工作流
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.bpm.framework.flowable.config.BpmFlowableConfiguration")) {
|
|
||||||
System.out.println("[工作流模块 yolo-module-bpm - 已禁用][参考 https://doc.iocoder.cn/bpm/ 开启]");
|
|
||||||
}
|
|
||||||
// 商城系统
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.trade.framework.web.config.TradeWebConfiguration")) {
|
|
||||||
System.out.println("[商城系统 yolo-module-mall - 已禁用][参考 https://doc.iocoder.cn/mall/build/ 开启]");
|
|
||||||
}
|
|
||||||
// ERP 系统
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.erp.framework.web.config.ErpWebConfiguration")) {
|
|
||||||
System.out.println("[ERP 系统 yolo-module-erp - 已禁用][参考 https://doc.iocoder.cn/erp/build/ 开启]");
|
|
||||||
}
|
|
||||||
// CRM 系统
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.crm.framework.web.config.CrmWebConfiguration")) {
|
|
||||||
System.out.println("[CRM 系统 yolo-module-crm - 已禁用][参考 https://doc.iocoder.cn/crm/build/ 开启]");
|
|
||||||
}
|
|
||||||
// 微信公众号
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.mp.framework.mp.config.MpConfiguration")) {
|
|
||||||
System.out.println("[微信公众号 yolo-module-mp - 已禁用][参考 https://doc.iocoder.cn/mp/build/ 开启]");
|
|
||||||
}
|
|
||||||
// 支付平台
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.pay.framework.pay.config.PayConfiguration")) {
|
|
||||||
System.out.println("[支付系统 yolo-module-pay - 已禁用][参考 https://doc.iocoder.cn/pay/build/ 开启]");
|
|
||||||
}
|
|
||||||
// AI 大模型
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.ai.framework.web.config.AiWebConfiguration")) {
|
|
||||||
System.out.println("[AI 大模型 yolo-module-ai - 已禁用][参考 https://doc.iocoder.cn/ai/build/ 开启]");
|
|
||||||
}
|
|
||||||
// IoT 物联网
|
|
||||||
if (isNotPresent("com.yolo.keyboard.module.iot.framework.web.config.IotWebConfiguration")) {
|
|
||||||
System.out.println("[IoT 物联网 yolo-module-iot - 已禁用][参考 https://doc.iocoder.cn/iot/build/ 开启]");
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
private static boolean isNotPresent(String className) {
|
|
||||||
return !ClassUtils.isPresent(className, ClassUtils.getDefaultClassLoader());
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -93,5 +93,7 @@ public interface ErrorCodeConstants {
|
|||||||
ErrorCode TENANT_WITHDRAW_ORDER_NOT_EXISTS = new ErrorCode(1_001_202_019, "租户提现订单表(申请-审核-打款-完成/失败)不存在");
|
ErrorCode TENANT_WITHDRAW_ORDER_NOT_EXISTS = new ErrorCode(1_001_202_019, "租户提现订单表(申请-审核-打款-完成/失败)不存在");
|
||||||
ErrorCode USER_INVITE_CODES_NOT_EXISTS = new ErrorCode(1_001_202_020, "用户生成的邀请码表,用于邀请新用户注册/安装并建立邀请关系不存在");
|
ErrorCode USER_INVITE_CODES_NOT_EXISTS = new ErrorCode(1_001_202_020, "用户生成的邀请码表,用于邀请新用户注册/安装并建立邀请关系不存在");
|
||||||
ErrorCode USER_INVITES_NOT_EXISTS = new ErrorCode(1_001_202_021, "用户邀请关系绑定台账表,记录新用户最终归属的邀请人不存在");
|
ErrorCode USER_INVITES_NOT_EXISTS = new ErrorCode(1_001_202_021, "用户邀请关系绑定台账表,记录新用户最终归属的邀请人不存在");
|
||||||
|
ErrorCode TENANT_COMMISSION_NOT_EXISTS = new ErrorCode(1_001_202_022, "租户内购分成记录不存在");
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
package com.yolo.keyboard.module.system.api.tenantbalance;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 租户余额 API 接口
|
||||||
|
*
|
||||||
|
* @author ziin
|
||||||
|
*/
|
||||||
|
public interface TenantBalanceApi {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 初始化租户钱包
|
||||||
|
*
|
||||||
|
* @param tenantId 租户ID
|
||||||
|
*/
|
||||||
|
void initTenantBalance(Long tenantId);
|
||||||
|
|
||||||
|
}
|
||||||
@@ -22,6 +22,7 @@ import com.yolo.keyboard.module.system.dal.dataobject.tenant.TenantDO;
|
|||||||
import com.yolo.keyboard.module.system.dal.dataobject.tenant.TenantPackageDO;
|
import com.yolo.keyboard.module.system.dal.dataobject.tenant.TenantPackageDO;
|
||||||
import com.yolo.keyboard.module.system.dal.mysql.tenant.TenantMapper;
|
import com.yolo.keyboard.module.system.dal.mysql.tenant.TenantMapper;
|
||||||
import com.yolo.keyboard.module.system.api.invitecode.UserInviteCodeApi;
|
import com.yolo.keyboard.module.system.api.invitecode.UserInviteCodeApi;
|
||||||
|
import com.yolo.keyboard.module.system.api.tenantbalance.TenantBalanceApi;
|
||||||
import com.yolo.keyboard.module.system.enums.permission.RoleCodeEnum;
|
import com.yolo.keyboard.module.system.enums.permission.RoleCodeEnum;
|
||||||
import com.yolo.keyboard.module.system.enums.permission.RoleTypeEnum;
|
import com.yolo.keyboard.module.system.enums.permission.RoleTypeEnum;
|
||||||
import com.yolo.keyboard.module.system.service.permission.MenuService;
|
import com.yolo.keyboard.module.system.service.permission.MenuService;
|
||||||
@@ -79,6 +80,9 @@ public class TenantServiceImpl implements TenantService {
|
|||||||
@Autowired(required = false)
|
@Autowired(required = false)
|
||||||
private UserInviteCodeApi userInviteCodeApi;
|
private UserInviteCodeApi userInviteCodeApi;
|
||||||
|
|
||||||
|
@Autowired(required = false)
|
||||||
|
private TenantBalanceApi tenantBalanceApi;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<Long> getTenantIdList() {
|
public List<Long> getTenantIdList() {
|
||||||
List<TenantDO> tenants = tenantMapper.selectList();
|
List<TenantDO> tenants = tenantMapper.selectList();
|
||||||
@@ -143,6 +147,10 @@ public class TenantServiceImpl implements TenantService {
|
|||||||
if ("代理".equals(createReqVO.getTenantType()) && userInviteCodeApi != null) {
|
if ("代理".equals(createReqVO.getTenantType()) && userInviteCodeApi != null) {
|
||||||
userInviteCodeApi.createInviteCodeForAgent(userId, tenant.getId());
|
userInviteCodeApi.createInviteCodeForAgent(userId, tenant.getId());
|
||||||
}
|
}
|
||||||
|
// 为代理租户初始化钱包
|
||||||
|
if ("代理".equals(createReqVO.getTenantType()) && tenantBalanceApi != null) {
|
||||||
|
tenantBalanceApi.initTenantBalance(tenant.getId());
|
||||||
|
}
|
||||||
});
|
});
|
||||||
return tenant.getId();
|
return tenant.getId();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -87,6 +87,7 @@ spring:
|
|||||||
isClustered: true # 是集群模式
|
isClustered: true # 是集群模式
|
||||||
clusterCheckinInterval: 15000 # 集群检查频率,单位:毫秒。默认为 15000,即 15 秒
|
clusterCheckinInterval: 15000 # 集群检查频率,单位:毫秒。默认为 15000,即 15 秒
|
||||||
misfireThreshold: 60000 # misfire 阀值,单位:毫秒。
|
misfireThreshold: 60000 # misfire 阀值,单位:毫秒。
|
||||||
|
acquireTriggersWithinLock: true # 获取触发器时加锁,防止并发问题
|
||||||
# 线程池相关配置
|
# 线程池相关配置
|
||||||
threadPool:
|
threadPool:
|
||||||
threadCount: 25 # 线程池大小。默认为 10 。
|
threadCount: 25 # 线程池大小。默认为 10 。
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ spring:
|
|||||||
autoconfigure:
|
autoconfigure:
|
||||||
# noinspection SpringBootApplicationYaml
|
# noinspection SpringBootApplicationYaml
|
||||||
exclude:
|
exclude:
|
||||||
- org.springframework.boot.autoconfigure.quartz.QuartzAutoConfiguration # 默认 local 环境,不开启 Quartz 的自动配置
|
# - org.springframework.boot.autoconfigure.quartz.QuartzAutoConfiguration # 默认 local 环境,不开启 Quartz 的自动配置
|
||||||
- org.springframework.ai.vectorstore.qdrant.autoconfigure.QdrantVectorStoreAutoConfiguration # 禁用 AI 模块的 Qdrant,手动创建
|
- org.springframework.ai.vectorstore.qdrant.autoconfigure.QdrantVectorStoreAutoConfiguration # 禁用 AI 模块的 Qdrant,手动创建
|
||||||
- org.springframework.ai.vectorstore.milvus.autoconfigure.MilvusVectorStoreAutoConfiguration # 禁用 AI 模块的 Milvus,手动创建
|
- org.springframework.ai.vectorstore.milvus.autoconfigure.MilvusVectorStoreAutoConfiguration # 禁用 AI 模块的 Milvus,手动创建
|
||||||
# 数据源配置项
|
# 数据源配置项
|
||||||
@@ -97,9 +97,11 @@ spring:
|
|||||||
jobStore:
|
jobStore:
|
||||||
# JobStore 实现类。可见博客:https://blog.csdn.net/weixin_42458219/article/details/122247162
|
# JobStore 实现类。可见博客:https://blog.csdn.net/weixin_42458219/article/details/122247162
|
||||||
class: org.springframework.scheduling.quartz.LocalDataSourceJobStore
|
class: org.springframework.scheduling.quartz.LocalDataSourceJobStore
|
||||||
|
driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
|
||||||
isClustered: true # 是集群模式
|
isClustered: true # 是集群模式
|
||||||
clusterCheckinInterval: 15000 # 集群检查频率,单位:毫秒。默认为 15000,即 15 秒
|
clusterCheckinInterval: 15000 # 集群检查频率,单位:毫秒。默认为 15000,即 15 秒
|
||||||
misfireThreshold: 60000 # misfire 阀值,单位:毫秒。
|
misfireThreshold: 60000 # misfire 阀值,单位:毫秒。
|
||||||
|
acquireTriggersWithinLock: true # 获取触发器时加锁,防止并发问题
|
||||||
# 线程池相关配置
|
# 线程池相关配置
|
||||||
threadPool:
|
threadPool:
|
||||||
threadCount: 25 # 线程池大小。默认为 10 。
|
threadCount: 25 # 线程池大小。默认为 10 。
|
||||||
|
|||||||
Reference in New Issue
Block a user