From 4fd01645f3c8591840a4ef0d2665da4f27a5a812 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 01 Aug 2023 16:02:49 +0800
Subject: [PATCH] 新增水位水位接近设计洪水位告警--电话告警

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/intelligentCall/feign/OutCallImplImplClient.java |   82 +++++++++++++++++++++++++++++++++++++++--
 1 files changed, 78 insertions(+), 4 deletions(-)

diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/intelligentCall/feign/OutCallImplImplClient.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/intelligentCall/feign/OutCallImplImplClient.java
index 053fbe3..1304931 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/intelligentCall/feign/OutCallImplImplClient.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/intelligentCall/feign/OutCallImplImplClient.java
@@ -1,10 +1,16 @@
 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.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 import springfox.documentation.annotations.ApiIgnore;
 import java.util.*;
@@ -23,16 +29,32 @@
 
 	private final CallService callService;
 
+	private final ICallNotFillRecordService callNotFillerService;
+
+	private final ICallSmsNoticeTaskService callSmsNoticeTaskService;
+
 	@Override
 	@GetMapping(CREATE_OUT_CALL_TASK_JOB_HANDLER)
-	public Object createOutCallTaskJobHandler(String isOver, String taskScheduleTime, String personNumber, String day) {
-		Map<String, Object> map = new HashMap<>();
+	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);
+	}
+
+	@Override
+	@GetMapping(CREATE_OUT_CALL_TASK_JOB_HANDLER_BY_NOT_CALL)
+	public List<String> createOutCallTaskJobHandlerByNotCall(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.createCallTaskByParamByNotCall(map);
 	}
 
 	/**
@@ -44,13 +66,65 @@
 	 * @return
 	 */
 	@Override
-	public Object testOutCall(String isOver, String taskScheduleTime, String personNumber, String day) {
-		Map<String, Object> map = new HashMap<>();
+	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);
+	}
+
+	/**
+	 * 创建告警外呼任务
+	 * @param map
+	 * @return
+	 */
+	@Override
+	@PostMapping(CREATE_OUT_CALL_TASK_BY_ALARM)
+	public List<String> createOutCallTaskByAlarm(@RequestBody Map<String, Object> map) {
+		//创建告警外呼任务并返回
+		return callService.createOutCallTaskByAlarm(map);
+	}
 }

--
Gitblit v1.9.3