package com.ruoyi.system.service.impl;
|
|
import java.io.IOException;
|
import java.sql.Date;
|
import java.time.LocalDate;
|
import java.util.Arrays;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.google.gson.Gson;
|
import com.ruoyi.common.enums.MsgLSEnum;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.OkHttpExample;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.system.service.ISysConfigService;
|
import com.smartor.common.LSHospTokenUtil;
|
import com.smartor.domain.ServiceSubtask;
|
import com.smartor.mapper.ServiceSubtaskMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.system.mapper.SmsRecordsMapper;
|
import com.ruoyi.system.domain.SmsRecords;
|
import com.ruoyi.system.service.ISmsRecordsService;
|
|
/**
|
* 短信记录Service业务层处理
|
*
|
* @author smartor
|
* @date 2023-03-06
|
*/
|
@Slf4j
|
@Service
|
public class SmsRecordsServiceImpl implements ISmsRecordsService {
|
@Autowired
|
private SmsRecordsMapper smsRecordsMapper;
|
|
@Autowired
|
private ISysConfigService iSysConfigService;
|
|
@Autowired
|
private ServiceSubtaskMapper serviceSubtaskMapper;
|
|
/**
|
* 查询短信记录
|
*
|
* @param recordid 短信记录主键
|
* @return 短信记录
|
*/
|
@Override
|
public SmsRecords selectSmsRecordsByRecordid(Long recordid) {
|
return smsRecordsMapper.selectSmsRecordsByRecordid(recordid);
|
}
|
|
/**
|
* 查询短信记录列表
|
*
|
* @param smsRecords 短信记录
|
* @return 短信记录
|
*/
|
@Override
|
public List<SmsRecords> selectSmsRecordsList(SmsRecords smsRecords) {
|
return smsRecordsMapper.selectSmsRecordsList(smsRecords);
|
}
|
|
/**
|
* 新增短信记录
|
*
|
* @param smsRecords 短信记录
|
* @return 结果
|
*/
|
@Override
|
public int insertSmsRecords(SmsRecords smsRecords) {
|
smsRecords.setCreateTime(DateUtils.getNowDate());
|
return smsRecordsMapper.insertSmsRecords(smsRecords);
|
}
|
|
/**
|
* 新增短信记录
|
*
|
* @param smsRecords 短信记录
|
* @return 结果
|
*/
|
@Override
|
public Boolean sendSmsRecords(SmsRecords smsRecords) {
|
//获取通知短信提前"几天"发送
|
Integer days = 0;
|
String noticeSmsBeforeSend = iSysConfigService.selectConfigByKey("notice_sms_before_send");
|
//获取医院机构ID
|
String hospOrgid = iSysConfigService.selectConfigByKey("hosp_orgid");
|
if (StringUtils.isNotEmpty(noticeSmsBeforeSend)) days = Integer.valueOf(noticeSmsBeforeSend);
|
|
//通过当前日期，加上提前的天数，获取要
|
LocalDate newDate = LocalDate.now().plusDays(days);
|
Date date = Date.valueOf(newDate);
|
smsRecords.setVisitTime(date);
|
|
List<String> orgidList = null;
|
if (StringUtils.isNotEmpty(hospOrgid)) {
|
orgidList = Arrays.asList(hospOrgid.split(","));
|
smsRecords.setOrgidList(orgidList);
|
}
|
List<SmsRecords> selectSmsRecordsList = smsRecordsMapper.selectSmsRecordsList(smsRecords);
|
for (SmsRecords record : selectSmsRecordsList) {
|
Boolean aBoolean = sendSMS(record.getOrgid(), record.getPhone(), record.getMsg());
|
ServiceSubtask serviceSubtask = new ServiceSubtask();
|
serviceSubtask.setId(record.getSubId());
|
if (aBoolean) serviceSubtask.setVisitNotice(1);
|
serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
|
}
|
|
return true;
|
}
|
|
|
public Boolean sendSMS(String orgid, String phone, String content) {
|
//丽水的短信发送方式
|
Boolean isSuccess = false;
|
try {
|
Map<String, String> map = MsgLSEnum.getAddressByCode(orgid);
|
String token = LSHospTokenUtil.getToken(orgid);
|
log.info("【sfHandlle】丽水短信发送，地址：{}，参数：{}，机构ID：{}", map.get("address"), orgid);
|
String dxCode = getDXCode(map.get("address"), phone, content, map.get("sendPersonId"), map.get("sendPersonName"), MsgLSEnum.getHeaderByCode(orgid), token);
|
log.info("【sfHandlle】丽水短信发送结果：{}", dxCode);
|
ObjectMapper objectMapper = new ObjectMapper();
|
Map<String, Object> textParam = null;
|
textParam = objectMapper.readValue(dxCode, Map.class);
|
String code = textParam.get("Code").toString();
|
if (code.equals("0")) {
|
isSuccess = true;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return isSuccess;
|
}
|
|
/**
|
* 修改短信记录
|
*
|
* @param smsRecords 短信记录
|
* @return 结果
|
*/
|
@Override
|
public int updateSmsRecords(SmsRecords smsRecords) {
|
smsRecords.setUpdateTime(DateUtils.getNowDate());
|
return smsRecordsMapper.updateSmsRecords(smsRecords);
|
}
|
|
/**
|
* 批量删除短信记录
|
*
|
* @param recordids 需要删除的短信记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteSmsRecordsByRecordids(Long[] recordids) {
|
return smsRecordsMapper.deleteSmsRecordsByRecordids(recordids);
|
}
|
|
/**
|
* 删除短信记录信息
|
*
|
* @param recordid 短信记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteSmsRecordsByRecordid(Long recordid) {
|
return smsRecordsMapper.deleteSmsRecordsByRecordid(recordid);
|
}
|
|
|
private String getDXCode(String address, String ShouJiHM, String FaSongNR, String FaSongRID, String FaSongRXM, Map<String, Object> headerMap, String token) {
|
Map<String, Object> map = new LinkedHashMap<>();
|
|
Map<String, Object> YeWuXX = new LinkedHashMap<>();
|
Map<String, Object> DuanXinXX = new LinkedHashMap<>();
|
DuanXinXX.put("ShouJiHM", ShouJiHM);
|
DuanXinXX.put("FaSongNR", FaSongNR);
|
DuanXinXX.put("FaSongRID", FaSongRID);
|
DuanXinXX.put("FaSongRXM", FaSongRXM);
|
YeWuXX.put("DuanXinXX", DuanXinXX);
|
|
map.put("XiaoXiTou", headerMap);
|
map.put("YeWuXX", YeWuXX);
|
|
String body = new Gson().toJson(map);
|
|
// String result = HttpUtils.sendPost(address, body);
|
String result = null;
|
try {
|
result = OkHttpExample.sendPostRequest(address, body, token);
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
log.info("【getDXCode】短信发送结果：{}", result);
|
|
JSONObject jsonObject = JSONObject.parseObject(result);
|
String code = (String) jsonObject.toString();
|
return code;
|
}
|
}
|
