package cn.gistack.sm.intelligentCall.feign;
|
|
import cn.gistack.sm.intelligentCall.entity.CallNotFillRecord;
|
import cn.gistack.sm.intelligentCall.service.CallService;
|
import cn.gistack.sm.intelligentCall.service.ICallNotFillRecordService;
|
import cn.gistack.sm.intelligentCall.service.ICallSmsNoticeTaskService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springblade.core.tenant.annotation.NonDS;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import springfox.documentation.annotations.ApiIgnore;
|
import java.util.*;
|
|
/**
|
* Feign实现类
|
* @author zhongrj
|
* @date 2023-06-03
|
*/
|
@NonDS
|
@ApiIgnore
|
@RestController
|
@AllArgsConstructor
|
@Slf4j
|
public class OutCallImplImplClient implements OutCallClient {
|
|
private final CallService callService;
|
|
private final ICallNotFillRecordService callNotFillerService;
|
|
private final ICallSmsNoticeTaskService callSmsNoticeTaskService;
|
|
@Override
|
@GetMapping(CREATE_OUT_CALL_TASK_JOB_HANDLER)
|
public List<String> createOutCallTaskJobHandler(String isOver, String taskScheduleTime, String personNumber, String day) {
|
Map<String, Object> map = new HashMap<>(4);
|
map.put("isOver",isOver);
|
map.put("taskScheduleTime",taskScheduleTime);
|
map.put("personNumber",personNumber);
|
map.put("day",day);
|
// 创建定时任务并返回
|
return callService.createCallTaskByParam(map);
|
}
|
|
/**
|
* 测试
|
* @param isOver
|
* @param taskScheduleTime
|
* @param personNumber
|
* @param day
|
* @return
|
*/
|
@Override
|
public String testOutCall(String isOver, String taskScheduleTime, String personNumber, String day) {
|
Map<String, Object> map = new HashMap<>(4);
|
map.put("isOver",isOver);
|
map.put("taskScheduleTime",taskScheduleTime);
|
map.put("personNumber",personNumber);
|
map.put("day",day);
|
//外呼短信通知任务创建并返回
|
callSmsNoticeTaskService.createCallSmsNoticeTask("2216");
|
// 创建定时任务并返回
|
return "测试返回成功";
|
}
|
|
/**
|
* 智能外呼呼叫前一天未接通人员
|
* @param taskScheduleTime 调度时间
|
* @return
|
*/
|
@Override
|
@GetMapping(CREATE_OUT_CALL_TASK_BY_NOT_CONNECT_JOB_HANDLER)
|
public List<String> createOutCallTaskByNotConnectJobHandler(String taskScheduleTime) {
|
Map<String, Object> map = new HashMap<>(1);
|
map.put("taskScheduleTime",taskScheduleTime);
|
// 创建定时任务并返回
|
return callService.createOutCallTaskByNotConnectJobHandler(map);
|
}
|
|
/**
|
* 查询未接通填报信息
|
* @param callId 呼叫id
|
* @return
|
*/
|
@Override
|
@GetMapping(GET_CALL_NOT_FILL_RECORD_INFO)
|
public CallNotFillRecord getCallNotFillRecordInfo(String callId) {
|
// 创建定时任务并返回
|
return callNotFillerService.getOne(new QueryWrapper<CallNotFillRecord>().eq("call_id",callId));
|
}
|
|
/**
|
* 外呼短信通知任务创建
|
* @param taskId 外呼任务id
|
* @return
|
*/
|
@Override
|
@GetMapping(CREATE_CALL_SMS_NOTICE_TASK)
|
public Boolean createCallSmsNoticeTask(String taskId) {
|
//外呼短信通知任务创建并返回
|
return callSmsNoticeTaskService.createCallSmsNoticeTask(taskId);
|
}
|
}
|
