wangshuai
/
youshi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

定时任务

This commit is contained in:
Lenovo 2024-07-07 16:43:19 +08:00
parent 72c6736306
commit b39a68be37
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java
View File

@ -3,6 +3,7 @@ package com.ruoyi.quartz.task;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.ruoyi.business.domain.BusOrderInfo; import com.ruoyi.business.domain.BusOrderInfo;
import com.ruoyi.business.domain.BusStoreInfo; import com.ruoyi.business.domain.BusStoreInfo;
import com.ruoyi.business.service.IAiService;
import com.ruoyi.business.service.IBusOrderInfoService; import com.ruoyi.business.service.IBusOrderInfoService;
import com.ruoyi.business.service.IBusStoreInfoService; import com.ruoyi.business.service.IBusStoreInfoService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -23,6 +24,8 @@ public class RyTask
{ {
@Autowired @Autowired
private IBusOrderInfoService orderInfoService; private IBusOrderInfoService orderInfoService;
@Autowired
private IAiService aiService;
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
{ {
@ -38,17 +41,16 @@ public class RyTask
{ {
System.out.println("执行无参方法"); System.out.println("执行无参方法");
} }
public void saveOrders() throws Exception public void sendToAi() throws Exception
{ {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
BusOrderInfo orderInfo = new BusOrderInfo(); BusOrderInfo orderInfo = new BusOrderInfo();
List<BusOrderInfo> list = orderInfoService.selectBusOrderInfoList(orderInfo); // List<BusOrderInfo> list = orderInfoService.selectBusOrderInfoList(orderInfo); //
for (BusOrderInfo busOrderInfo : list) { for (BusOrderInfo busOrderInfo : list) {
if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+60000){ if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+60000){
System.out.println("=============================================================================="); aiService.addAiTask(busOrderInfo.getPrivcyPhone(), busOrderInfo.getRecipientPhone());
} }
} }
System.out.println(JSON.toJSONString(list));
} }
} }