diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java index 80f00b6..3889288 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java @@ -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 list = orderInfoService.selectBusOrderInfoList(orderInfo); // + List 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 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(); + } + } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java index 81c5cd0..cfafc40 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java @@ -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 {