package com.doumee.service.business.third;
|
|
import cn.emay.sdk.client.SmsSDKClient;
|
import cn.emay.sdk.core.dto.sms.common.ResultModel;
|
import cn.emay.sdk.core.dto.sms.request.SmsSingleRequest;
|
import cn.emay.sdk.core.dto.sms.response.SmsResponse;
|
import com.alibaba.fastjson.JSONObject;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.haikang.model.HKConstants;
|
import com.doumee.core.haikang.model.param.BaseResponse;
|
import com.doumee.core.haikang.service.HKService;
|
import com.doumee.core.utils.Constants;
|
import com.doumee.dao.business.model.InterfaceLog;
|
import com.doumee.service.business.InterfaceLogService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service
|
public class EmayService {
|
private static SmsSDKClient client ;
|
|
public SmsSDKClient getClient() {
|
return client;
|
}
|
|
public void setClient(SmsSDKClient client) {
|
this.client = client;
|
}
|
@Autowired
|
@Lazy
|
private InterfaceLogService interfaceLogService ;
|
@Autowired
|
@Lazy
|
private SystemDictDataBiz systemDictDataBiz;
|
|
private void saveInterfaceLog(String path,String name,String req ,String res) {
|
if(interfaceLogService !=null){
|
InterfaceLog hkMonitoryLogDO=new InterfaceLog();
|
hkMonitoryLogDO.setType(0);
|
hkMonitoryLogDO.setCreateDate(new Date());
|
hkMonitoryLogDO.setIsdeleted(0);
|
hkMonitoryLogDO.setRequest(req);
|
hkMonitoryLogDO.setRepose(res);
|
hkMonitoryLogDO.setName(name);
|
hkMonitoryLogDO.setUrl(path);
|
interfaceLogService.create(hkMonitoryLogDO);
|
}
|
}
|
private static String ip;
|
private static int port;
|
private static String appSecret;
|
private static String appKey;
|
@PostConstruct//启动初始化
|
public int initClient(){
|
ip = systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_IP).getCode();
|
port = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_PORT).getCode());
|
appKey = systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_APPKEY).getCode();
|
appSecret = systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_APPSECRET).getCode();
|
return 0;
|
}
|
|
public boolean sendSingleSms(String mobile,String content) {
|
try {
|
client = new SmsSDKClient(ip,port,appKey,appSecret);
|
|
if(client == null){
|
return false;
|
}
|
String customSmsId = "1";
|
String extendedCode = "01";
|
|
SmsSingleRequest request = new SmsSingleRequest(mobile, content, customSmsId, extendedCode, "");
|
ResultModel<SmsResponse> result = client.sendSingleSms(request);
|
saveInterfaceLog(ip+"/"+port,"【短信】发送", JSONObject.toJSONString(result),JSONObject.toJSONString(result));
|
if (result.getCode().equals("SUCCESS")) {
|
System.out.println("请求成功");
|
SmsResponse response = result.getResult();
|
System.out.println("sendSingleSms:" + response.toString());
|
return true;
|
} else {
|
System.out.println("请求失败");
|
return false;
|
}
|
} catch (Exception e) {
|
|
}
|
return false;
|
}
|
|
|
public void sendSmsByHk(String phone,String content){
|
try {
|
String url = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_HTTPS).getCode() +
|
systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_HOST).getCode() +
|
HKConstants.ARTEMIS_PATH +
|
HKConstants.InterfacePath.sendSms[0];
|
Map<String,Object> map = new HashMap<>();
|
map.put("phoneNo",phone.split(","));
|
map.put("content",content);
|
BaseResponse result = HKService.sendSmsByHk(map,url);
|
if(result !=null){
|
if(!StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),result.getMsg());
|
}
|
}else{
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，短信发送失败，请稍后重试！");
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对不起，短信发送失败，请稍后重试！");
|
}
|
|
|
}
|
