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

ai接口改造

This commit is contained in:
Lenovo 2024-07-09 11:59:56 +08:00
parent a7f9b9c77f
commit 31e2249edd
4 changed files with 51 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ruoyi-admin/src/main/java/com/ruoyi/business/controller/AiController.java
View File

@ -47,7 +47,7 @@ public class AiController {
fifteenInfo.setCustomId(temp.getCustomId()); fifteenInfo.setCustomId(temp.getCustomId());
List<BusFifteenInfo> list = fifteenInfoService.selectBusFifteenInfoList(fifteenInfo); List<BusFifteenInfo> list = fifteenInfoService.selectBusFifteenInfoList(fifteenInfo);
if (list.size() == 0) { if (list.size() == 0) {
aiService.addAiTask("外卖商户", "客户", ss.split(",")[0], ss.split(",")[1]); aiService.addAiTask(ss.split(",")[0], ss.split(",")[1]);
} }
} }

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

@ -42,14 +42,14 @@ public class RyTask
// } // }
/** /**
* 获取订单并解析号码 * 获取订单并解析号码 5分钟
*/ */
public void getOrders(){ public void getOrders(){
iMeituanService.orderInfoList(); iMeituanService.orderInfoList();
} }
/** /**
* 发送AI * 发送AI 1分钟
* @throws Exception * @throws Exception
*/ */
public void sendToAi() throws Exception public void sendToAi() throws Exception
@ -66,13 +66,13 @@ public class RyTask
List<BusFifteenInfo> listInfo = fifteenInfoService.selectBusFifteenInfoList(fifteenInfo); List<BusFifteenInfo> listInfo = fifteenInfoService.selectBusFifteenInfoList(fifteenInfo);
if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+(10*60*1000) if (new Date().getTime() >= sdf.parse(busOrderInfo.getCompleteTime()).getTime()+(10*60*1000)
&& listInfo.size() == 0){ && listInfo.size() == 0){
aiService.addAiTask("外卖商户", "客户",busOrderInfo.getPrivcyPhone().split(",")[0], busOrderInfo.getPrivcyPhone().split(",")[1]); aiService.addAiTask(busOrderInfo.getPrivcyPhone().split(",")[0], busOrderInfo.getPrivcyPhone().split(",")[1]);
} }
} }
} }
/** /**
* 获取AI结果 * 获取AI结果 5分钟
*/ */
public void getAiResult() { public void getAiResult() {
aiService.queryAiTask(); aiService.queryAiTask();

2
ruoyi-system/src/main/java/com/ruoyi/business/service/IAiService.java
View File

@ -15,7 +15,7 @@ public interface IAiService
* @param phoneNo * @param phoneNo
* @param virtualPhone * @param virtualPhone
*/ */
R addAiTask(String storeName,String remark,String phoneNo,String virtualPhone); void addAiTask(String phoneNo,String virtualPhone);
void queryAiTask(); void queryAiTask();

61
ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java
View File

@ -10,13 +10,11 @@ import com.ruoyi.business.service.*;
import com.ruoyi.common.core.domain.R; import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.utils.HttpClientUtilT; import com.ruoyi.common.utils.HttpClientUtilT;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList; import java.util.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* 代理管理Service业务层处理 * 代理管理Service业务层处理
@ -37,9 +35,13 @@ public class AiServiceImpl implements IAiService
private IBusAgentInfoService agentInfoService; private IBusAgentInfoService agentInfoService;
@Autowired @Autowired
private IBusFifteenInfoService fifteenInfoService; private IBusFifteenInfoService fifteenInfoService;
@Autowired
private StringRedisTemplate redisTemplate;
@Override private String userSn = "SYSUSER|8398f13f3feccef770ee4d465fe22fbf";
public R addAiTask(String storeName,String remark,String phoneNo, String virtualPhone) { private String projectSn1 = "projects|00dd4cb88fc5f777d5c578c0fdb6b3a0";
private R login() {
String url = "https://ai002.ciopaas.com/api/login"; String url = "https://ai002.ciopaas.com/api/login";
String userName = "zw982210"; String userName = "zw982210";
Map<String, String> header = new HashMap<>(); Map<String, String> header = new HashMap<>();
@ -51,13 +53,31 @@ public class AiServiceImpl implements IAiService
if ("0".equals(jsonObject.getString("code"))){ if ("0".equals(jsonObject.getString("code"))){
JSONObject data = jsonObject.getJSONObject("data"); JSONObject data = jsonObject.getJSONObject("data");
String apiKey = data.getString("api_key"); String apiKey = data.getString("api_key");
long apiKeyExpire = Long.valueOf(data.getString("api_key_expire"));
String userSn = data.getString("user_sn"); String userSn = data.getString("user_sn");
String projectSn = data.getString("project_sn"); String projectSn = data.getString("project_sn");
System.out.println("login 返回：===========apikey,userSn,projectSn============="+apiKey+","+userSn+","+projectSn); System.out.println("login 返回：===========apikey,userSn,projectSn============="+apiKey+","+userSn+","+projectSn);
redisTemplate.opsForValue().set("apiKey",apiKey,apiKeyExpire);
} else {
System.out.println("login接口返回错误： " + jsonObject.toString());
}
return R.fail();
}
String projectSn1 = projectSn.split(",")[1]; public void addAiTask(String phoneNo,String virtualPhone){
String apiKey = Optional.ofNullable(redisTemplate.opsForValue().get("apiKey")).orElse(null);
String requestJson = "{\"api_key\": \""+apiKey+"\",\"user_sn\": \""+userSn+"\",\"source\": \""+storeName+"\",\"project_sn\": \""+projectSn1+"\",\"ai_user_sn\": \"SYSUSER|2665bcca63a2b5c724095fa01dce0470\",\"is_zidong\": \"on\",\"client_info_json\": {\"data\": [{\"姓名\": \""+storeName+"\",\"电话\": \""+phoneNo+"\",\"备注\": \"客户\",\"虚拟分机号\": \""+virtualPhone+"\"}]},\"is_open_second_dialing\": \"1\",\n" + if (apiKey == null){
login();
apiKey = redisTemplate.opsForValue().get("apiKey");
}
String dialTaskMainSn = Optional.ofNullable(redisTemplate.opsForValue().get("dialTaskMainSn")).orElse(null);
if (dialTaskMainSn != null){
appendAiTask(apiKey,phoneNo,virtualPhone,dialTaskMainSn);
} else {
Map<String, String> header = new HashMap<>();
header.put("Accept", "application/json");
header.put("Content-Type", "application/json;charset=utf-8");
String requestJson = "{\"api_key\": \"" + apiKey + "\",\"user_sn\": \"" + userSn + "\",\"source\": \"商户\",\"project_sn\": \"" + projectSn1 + "\",\"ai_user_sn\": \"SYSUSER|2665bcca63a2b5c724095fa01dce0470\",\"is_zidong\": \"on\",\"client_info_json\": {\"data\": [{\"姓名\": \"商户\",\"电话\": \"" + phoneNo + "\",\"备注\": \"客户\",\"虚拟分机号\": \"" + virtualPhone + "\"}]},\"is_open_second_dialing\": \"1\",\n" +
"\"is_open_remove_duplication\": \"0\",\"is_append\": \"0\"}"; "\"is_open_remove_duplication\": \"0\",\"is_append\": \"0\"}";
String requestUrl = "https://ai002.ciopaas.com/api/addJsonOfAsync"; String requestUrl = "https://ai002.ciopaas.com/api/addJsonOfAsync";
String requestResult = HttpClientUtilT.doPostJson(requestUrl, header, requestJson); String requestResult = HttpClientUtilT.doPostJson(requestUrl, header, requestJson);
@ -67,36 +87,19 @@ public class AiServiceImpl implements IAiService
String taskMainId = data1.getString("dial_task_main_id"); String taskMainId = data1.getString("dial_task_main_id");
String taskMainSn = data1.getString("dial_task_main_sn"); String taskMainSn = data1.getString("dial_task_main_sn");
// dialTaskMainSn = taskMainSn;
// JSONArray jsonArray = jsonObject.getJSONArray("list");
// JSONObject joo = jsonArray.getJSONObject(0);
// String taskMainSn1 = joo.getString("dial_task_main_sn");
// System.out.println(taskMainSn1);
System.out.println("建立任务返回： ============taskMainId,taskMainSn===========" + taskMainId + "," + taskMainSn); System.out.println("建立任务返回： ============taskMainId,taskMainSn===========" + taskMainId + "," + taskMainSn);
// try { redisTemplate.opsForValue().set("dialTaskMainSn", taskMainSn);
// Thread.sleep(30000);
// } catch (InterruptedException e) {
// throw new RuntimeException(e);
// }
//
// appendAiTask(phoneNo,virtualPhone,apiKey,userSn,projectSn1,taskMainSn);
return R.ok();
} else { } else {
System.out.println("建立任务接口返回错误： " + jo.toString()); System.out.println("建立任务接口返回错误： " + jo.toString());
} }
} else {
System.out.println("login接口返回错误： " + jsonObject.toString());
} }
return R.fail();
} }
private void appendAiTask(String phoneNo, String virtualPhone,String aKey, String uSn,String pSn,String dialTaskMainSn) { private void appendAiTask(String aKey, String phoneNo, String virtualPhone, String dialTaskMainSn) {
String requestJson = "{\"api_key\": \"" + aKey + "\",\"user_sn\": \"" + uSn + "\",\"source\": \"测试任务\",\"project_sn\": \"" + pSn + "\",\"ai_user_sn\": \"SYSUSER|2665bcca63a2b5c724095fa01dce0470\",\"is_zidong\": \"on\",\"client_info_json\": {\"data\": [{\"姓名\": \"ws测试\",\"电话\": \"" + phoneNo + "\",\"备注\": \"门店新客\",\"虚拟分机号\": \"" + virtualPhone + "\"}]},\"is_open_second_dialing\": \"1\",\n" + String requestJson = "{\"api_key\": \"" + aKey + "\",\"user_sn\": \"" + userSn + "\",\"source\": \"测试任务\",\"project_sn\": \"" + projectSn1 + "\",\"ai_user_sn\": \"SYSUSER|2665bcca63a2b5c724095fa01dce0470\",\"is_zidong\": \"on\",\"client_info_json\": {\"data\": [{\"姓名\": \"ws测试\",\"电话\": \"" + phoneNo + "\",\"备注\": \"门店新客\",\"虚拟分机号\": \"" + virtualPhone + "\"}]},\"is_open_second_dialing\": \"1\",\n" +
"\"is_open_remove_duplication\": \"0\",\"dial_task_main_sn\": \"" + dialTaskMainSn + "\",\"is_append\": \"1\"}"; "\"is_open_remove_duplication\": \"0\",\"dial_task_main_sn\": \"" + dialTaskMainSn + "\",\"is_append\": \"1\"}";
String requestUrl = "https://ai002.ciopaas.com/api/addJsonOfAsync"; String requestUrl = "https://ai002.ciopaas.com/api/addJsonOfAsync";
Map<String, String> header = new HashMap<>(); Map<String, String> header = new HashMap<>();