修改与优化

This commit is contained in:
Lenovo 2024-07-08 16:22:23 +08:00
parent ed005cfa29
commit 257cea70cc
3 changed files with 8 additions and 78 deletions

View File

@ -1,58 +0,0 @@
package com.ruoyi.business.domain;
public class AiAppendInfo {
private String phoneNo;
private String virtualPhone;
private String aKey;
private String uSn;
private String pSn;
private String dialTaskMainSn;
public String getPhoneNo() {
return phoneNo;
}
public void setPhoneNo(String phoneNo) {
this.phoneNo = phoneNo;
}
public String getVirtualPhone() {
return virtualPhone;
}
public void setVirtualPhone(String virtualPhone) {
this.virtualPhone = virtualPhone;
}
public String getaKey() {
return aKey;
}
public void setaKey(String aKey) {
this.aKey = aKey;
}
public String getuSn() {
return uSn;
}
public void setuSn(String uSn) {
this.uSn = uSn;
}
public String getpSn() {
return pSn;
}
public void setpSn(String pSn) {
this.pSn = pSn;
}
public String getDialTaskMainSn() {
return dialTaskMainSn;
}
public void setDialTaskMainSn(String dialTaskMainSn) {
this.dialTaskMainSn = dialTaskMainSn;
}
}

View File

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

View File

@ -10,6 +10,7 @@ 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.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList; import java.util.ArrayList;
@ -37,8 +38,6 @@ public class AiServiceImpl implements IAiService
@Autowired @Autowired
private IBusFifteenInfoService fifteenInfoService; private IBusFifteenInfoService fifteenInfoService;
private List<AiAppendInfo> list = new ArrayList<>();
@Override @Override
public R addAiTask(String storeName,String remark,String phoneNo, String virtualPhone) { public R addAiTask(String storeName,String remark,String phoneNo, String virtualPhone) {
String url = "https://ai002.ciopaas.com/api/login"; String url = "https://ai002.ciopaas.com/api/login";
@ -76,16 +75,9 @@ public class AiServiceImpl implements IAiService
System.out.println("建立任务返回: ============taskMainId,taskMainSn==========="+taskMainId+","+taskMainSn); System.out.println("建立任务返回: ============taskMainId,taskMainSn==========="+taskMainId+","+taskMainSn);
AiAppendInfo appendInfo = new AiAppendInfo();
appendInfo.setaKey(apiKey);
appendInfo.setpSn(projectSn1);
appendInfo.setuSn(userSn);
appendInfo.setPhoneNo(phoneNo);
appendInfo.setVirtualPhone(virtualPhone);
appendInfo.setDialTaskMainSn(taskMainSn);
list.add(appendInfo);
// appendAiTask(phoneNo,virtualPhone,apiKey,userSn,projectSn,taskMainSn); appendAiTask(phoneNo,virtualPhone,apiKey,userSn,projectSn,taskMainSn);
return R.ok(); return R.ok();
} else { } else {
System.out.println("建立任务接口返回错误: " + jo.toString()); System.out.println("建立任务接口返回错误: " + jo.toString());
@ -95,13 +87,10 @@ public class AiServiceImpl implements IAiService
} }
return R.fail(); return R.fail();
} }
@Async
public void appendAiTask() { public void appendAiTask(String phoneNo, String virtualPhone,String aKey, String uSn,String pSn,String dialTaskMainSn) {
for (AiAppendInfo appendInfo : list) { 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\": \"" + appendInfo.getaKey() + "\",\"user_sn\": \"" + appendInfo.getuSn() + "\",\"source\": \"测试任务\"" + "\"is_open_remove_duplication\": \"0\",\"dial_task_main_sn\": \"" + dialTaskMainSn + "\",\"is_append\": \"1\"}";
",\"project_sn\": \"" + appendInfo.getpSn() + "\",\"ai_user_sn\": \"SYSUSER|2665bcca63a2b5c724095fa01dce0470\",\"is_zidong\": \"on\"" +
",\"client_info_json\": {\"data\": [{\"姓名\": \"ws测试\",\"电话\": \"" + appendInfo.getPhoneNo() + "\",\"备注\": \"门店新客\",\"虚拟分机号\": \"" + appendInfo.getVirtualPhone() + "\"}]}" +
",\"is_open_second_dialing\": \"1\",\n" + "\"is_open_remove_duplication\": \"0\",\"dial_task_main_sn\": \"" + appendInfo.getDialTaskMainSn() + "\",\"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<>();
header.put("Accept", "application/json"); header.put("Accept", "application/json");
@ -122,7 +111,7 @@ public class AiServiceImpl implements IAiService
} else { } else {
System.out.println("追加任务接口返回错误: " + jo.toString()); System.out.println("追加任务接口返回错误: " + jo.toString());
} }
}
} }
@Override @Override