集成到定时任务
This commit is contained in:
parent
5f5e17f992
commit
a7f9b9c77f
|
@ -1,15 +1,10 @@
|
|||
package com.ruoyi.quartz.task;
|
||||
|
||||
import com.alibaba.fastjson2.JSON;
|
||||
import com.ruoyi.business.domain.BusFifteenInfo;
|
||||
import com.ruoyi.business.domain.BusOrderInfo;
|
||||
import com.ruoyi.business.domain.BusStoreInfo;
|
||||
import com.ruoyi.business.service.IAiService;
|
||||
import com.ruoyi.business.service.IBusOrderInfoService;
|
||||
import com.ruoyi.business.service.IBusStoreInfoService;
|
||||
import com.ruoyi.business.service.*;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
import com.ruoyi.common.utils.StringUtils;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
@ -26,31 +21,61 @@ public class RyTask
|
|||
private IBusOrderInfoService orderInfoService;
|
||||
@Autowired
|
||||
private IAiService aiService;
|
||||
@Autowired
|
||||
private IMeituanService iMeituanService;
|
||||
@Autowired
|
||||
private IBusFifteenInfoService fifteenInfoService;
|
||||
|
||||
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
|
||||
{
|
||||
System.out.println(StringUtils.format("执行多参方法: 字符串类型{},布尔类型{},长整型{},浮点型{},整形{}", s, b, l, d, i));
|
||||
// public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
|
||||
// {
|
||||
// System.out.println(StringUtils.format("执行多参方法: 字符串类型{},布尔类型{},长整型{},浮点型{},整形{}", s, b, l, d, i));
|
||||
// }
|
||||
//
|
||||
// public void ryParams(String params)
|
||||
// {
|
||||
// System.out.println("执行有参方法:" + params);
|
||||
// }
|
||||
//
|
||||
// public void ryNoParams()
|
||||
// {
|
||||
// System.out.println("执行无参方法");
|
||||
// }
|
||||
|
||||
/**
|
||||
* 获取订单并解析号码
|
||||
*/
|
||||
public void getOrders(){
|
||||
iMeituanService.orderInfoList();
|
||||
}
|
||||
|
||||
public void ryParams(String params)
|
||||
{
|
||||
System.out.println("执行有参方法:" + params);
|
||||
}
|
||||
|
||||
public void ryNoParams()
|
||||
{
|
||||
System.out.println("执行无参方法");
|
||||
}
|
||||
/**
|
||||
* 发送AI
|
||||
* @throws Exception
|
||||
*/
|
||||
public void sendToAi() throws Exception
|
||||
{
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
||||
BusOrderInfo orderInfo = new BusOrderInfo();
|
||||
List<BusOrderInfo> list = orderInfoService.selectBusOrderInfoList(orderInfo); //
|
||||
List<BusOrderInfo> list = orderInfoService.selectBusOrderInfoList(orderInfo);
|
||||
for (BusOrderInfo busOrderInfo : list) {
|
||||
if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+60000){
|
||||
// aiService.addAiTask(busOrderInfo.getPrivcyPhone(), busOrderInfo.getRecipientPhone());
|
||||
BusOrderInfo temp = new BusOrderInfo();
|
||||
temp.setPrivcyPhone(busOrderInfo.getPrivcyPhone());
|
||||
BusOrderInfo tempInfo = orderInfoService.selectBusOrderInfoList(temp).get(0);
|
||||
BusFifteenInfo fifteenInfo = new BusFifteenInfo();
|
||||
fifteenInfo.setCustomId(tempInfo.getCustomId());
|
||||
List<BusFifteenInfo> listInfo = fifteenInfoService.selectBusFifteenInfoList(fifteenInfo);
|
||||
if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+(10*60*1000)
|
||||
&& listInfo.size() == 0){
|
||||
aiService.addAiTask("外卖商户", "客户",busOrderInfo.getPrivcyPhone().split(",")[0], busOrderInfo.getPrivcyPhone().split(",")[1]);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取AI结果
|
||||
*/
|
||||
public void getAiResult() {
|
||||
aiService.queryAiTask();
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
@ -76,13 +76,13 @@ public class AiServiceImpl implements IAiService
|
|||
|
||||
System.out.println("建立任务返回: ============taskMainId,taskMainSn==========="+taskMainId+","+taskMainSn);
|
||||
|
||||
try {
|
||||
Thread.sleep(40000);
|
||||
} catch (InterruptedException e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
|
||||
appendAiTask(phoneNo,virtualPhone,apiKey,userSn,projectSn1,taskMainSn);
|
||||
// try {
|
||||
// Thread.sleep(30000);
|
||||
// } catch (InterruptedException e) {
|
||||
// throw new RuntimeException(e);
|
||||
// }
|
||||
//
|
||||
// appendAiTask(phoneNo,virtualPhone,apiKey,userSn,projectSn1,taskMainSn);
|
||||
|
||||
return R.ok();
|
||||
} else {
|
||||
|
|
Loading…
Reference in New Issue