hbwri/skjcmanager.git

			@@ -1,9 +1,14 @@
			package cn.gistack.sm.intelligentCall.service.impl;

			import cn.gistack.sm.intelligentCall.constant.CallConstant;
			import cn.gistack.sm.intelligentCall.mapper.CallTaskMapper;
			import cn.gistack.sm.intelligentCall.service.CallService;
			import cn.gistack.sm.intelligentCall.vo.CallTaskResultVO;
			import cn.gistack.sm.intelligentCall.vo.CallTaskStatistic;
			import com.alibaba.fastjson.JSONArray;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.dynamic.datasource.annotation.DS;
			import com.baomidou.mybatisplus.core.metadata.IPage;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.lang3.RandomUtils;
			import org.apache.commons.lang3.StringUtils;
			@@ -15,15 +20,18 @@
			import org.springframework.stereotype.Service;
			import org.springframework.util.DigestUtils;
			import org.springframework.web.client.RestTemplate;
			import javax.annotation.Resource;
			import java.time.LocalDateTime;
			import java.time.format.DateTimeFormatter;
			import java.util.ArrayList;
			import java.util.List;
			import java.util.Map;

			@Slf4j
			@Service
			public class CallServiceImpl implements CallService {

			@Autowired
			private CallTaskMapper callTaskMapper;

			@Autowired
			private RestTemplate restTemplate;
			@@ -55,18 +63,21 @@

			/**
			* 创建任务
			* @param params
			* @param map
			* @return
			*/
			@Override
			public Object createTask(List<Map<String, String>> params) {
			public Object createTask(Map<String,Object> map) {
			List<Map<String, String>> params = (List<Map<String, String>>) map.get("list");
			String requestUrl = url + CREATE_TASK_URL;
			LocalDateTime now = LocalDateTime.now();
			String timestamp = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss SSS"));
			String transId = generateTransId(now);
			String taskName = now.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm")) + "智能外呼";
			// String taskName = now.format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm")) + "智能外呼";
			String taskName = map.get("taskName").toString();
			String[] numbers = StringUtils.split(callingNumbers,",");
			String taskScheduleTime = LocalDateTime.now().plusHours(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
			// String taskScheduleTime = LocalDateTime.now().plusHours(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
			String taskScheduleTime = map.get("taskScheduleTime").toString();
			JSONArray arr = getCalleeInfo(params);
			HttpHeaders httpHeaders = new HttpHeaders();
			httpHeaders.add("Content-Type", CONTENT_TYPE);
			@@ -127,7 +138,7 @@
			JSONObject responseJson = (JSONObject) JSONObject.parse(response.getBody());
			assert responseJson != null;
			// return JSONObject.parseObject(responseJson.getString("data"), CallBackDetailVO.class);
			return responseJson.getString("data");
			return response.getBody();
			}
			return null;
			}
			@@ -180,4 +191,69 @@
			});
			return arr;
			}

			/**
			* 查詢任务列表数据
			* @param page
			* @param callTask
			* @return
			*/
			@Override
			public IPage<CallTaskStatistic> getCallListPage(IPage<CallTaskStatistic> page, CallTaskStatistic callTask) {
			return page.setRecords(callTaskMapper.getCallListPage(page,callTask));
			}

			/**
			* 查询呼叫详情列表信息
			* @param callTaskResult
			* @param page
			* @return
			*/
			@Override
			public IPage<CallTaskResultVO> getCallTaskResultListPage(IPage<CallTaskResultVO> page, CallTaskResultVO callTaskResult) {
			List<String> list = new ArrayList<>();
			if (null!= callTaskResult.getAreaName() && !callTaskResult.getAreaName().equals("")){
			// 查询所有下级区域code
			list = getWaterNameByAreaCode(callTaskResult.getAreaName());
			}
			List<CallTaskResultVO> resultListPage = callTaskMapper.getCallTaskResultListPage(page, callTaskResult,list);
			return page.setRecords(resultListPage);
			}

			/**
			* 导出呼叫详情列表信息
			* @param callTaskResult
			* @return
			*/
			@Override
			public Object getCallTaskResultList(CallTaskResultVO callTaskResult) {
			List<String> list = new ArrayList<>();
			if (null!= callTaskResult.getAreaName() && !callTaskResult.getAreaName().equals("")){
			// 查询所有下级区域code
			list = getWaterNameByAreaCode(callTaskResult.getAreaName());
			}
			List<CallTaskResultVO> resultListPage = callTaskMapper.getCallTaskResultListPage(null, callTaskResult,list);
			// 返回
			return resultListPage;
			}

			/**
			* 通过水库编码获取行政区名称
			* @param adCode
			* @return
			*/
			private String getAreaNameByAdCode(String adCode) {
			// 通过adCode查询区域名称
			return callTaskMapper.getAreaNameByAdCode(adCode);
			}

			/**
			* 通过行政区编号获取水库名称
			* @param areaCode
			* @return
			*/
			private List<String> getWaterNameByAreaCode(String areaCode) {
			// 通过行政区编号获取水库名称
			return callTaskMapper.getWaterNameByAreaCode(areaCode);
			}
			}