From 87f979fb201a82ebad5926735ed6dfa75ca004d3 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期一, 21 七月 2025 09:21:42 +0800
Subject: [PATCH] 修改bug
---
ruoyi-system/src/main/java/com/ruoyi/system/task/utils/TaskUtil.java | 77 ++++++++++++++++++++++++++++++++++++++
1 files changed, 77 insertions(+), 0 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/task/utils/TaskUtil.java b/ruoyi-system/src/main/java/com/ruoyi/system/task/utils/TaskUtil.java
index d29ca9f..14b9dfe 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/task/utils/TaskUtil.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/task/utils/TaskUtil.java
@@ -1,12 +1,89 @@
package com.ruoyi.system.task.utils;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.utils.AliSmsUtil;
+import com.ruoyi.system.model.TbAccountDetail;
+import com.ruoyi.system.model.TbCompany;
+import com.ruoyi.system.model.TbOrder;
+import com.ruoyi.system.model.TbUser;
+import com.ruoyi.system.service.TbAccountDetailService;
+import com.ruoyi.system.service.TbCompanyService;
+import com.ruoyi.system.service.TbOrderService;
+import com.ruoyi.system.service.TbUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Date;
+import java.util.List;
/**
* @author zhibing.pu
* @date 2023/7/11 8:39
*/
+@Component
public class TaskUtil {
+ @Autowired
+ private TbOrderService orderService;
+ @Autowired
+ private TbCompanyService companyService;
+ @Autowired
+ private TbAccountDetailService accountDetailService;
+ @Autowired
+ private TbUserService userService;
+
+
+
+ @Scheduled(cron ="0 0 10 * * ?")
+ public void sendSellerSms() {
+ List<TbOrder> list = orderService.list(new LambdaQueryWrapper<TbOrder>().lt(TbOrder::getStatus, 3).eq(TbOrder::getStatus, 2));
+ if(!list.isEmpty()){
+ for (TbOrder tbOrder : list) {
+ tbOrder.setSmsNum(tbOrder.getSmsNum() + 1);
+ tbOrder.updateById();
+ TbCompany company = companyService.getById(tbOrder.getCompanyId());
+ if(company!=null){
+ TbUser user = userService.getById(company.getUserId());
+ AliSmsUtil.sendSuccessMessageSeller(user.getPhone());
+ }
+ }
+ }
+ }
+
+ @Scheduled(fixedRate = 60000)
+ public void confirmOrder() {
+ String format = LocalDateTime.now().minusDays(5).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+ List<TbOrder> list = orderService.list(new LambdaQueryWrapper<TbOrder>().eq(TbOrder::getStatus, 5).le(TbOrder::getSellerFinishTime, format));
+ for (TbOrder tbOrder : list) {
+ successOrder(tbOrder.getId());
+ }
+ }
+
+ private void successOrder(String orderId){
+ TbOrder order = orderService.getById(orderId);
+ TbCompany company = companyService.getById(order.getCompanyId());
+ // 订单完成 商品已售卖
+ order.setStatus(6);
+ order.setFinishTime( new Date());
+ order.updateById();
+ company.setStatus(3);
+
+ // 分佣
+ orderService.commission(order, company.getUserId());
+
+ // 卖家账户明细记录更新
+ TbAccountDetail one = accountDetailService.getOne(new LambdaQueryWrapper<TbAccountDetail>().eq(TbAccountDetail::getOrderId, orderId).eq(TbAccountDetail::getCategory, 2));
+ if (one != null) {
+ one.setStatus(2);
+ one.updateById();
+ }
+
+ company.updateById();
+ }
}
--
Gitblit v1.7.1