package com.dingzhuo.energy.project.conglomeratepush.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.dingzhuo.energy.common.core.lang.UUID;
|
import com.dingzhuo.energy.project.conglomeratepush.HttpUtil;
|
import com.dingzhuo.energy.project.conglomeratepush.domain.ConglomeratePushLog;
|
import com.dingzhuo.energy.project.conglomeratepush.mapper.ConglomeratePushLogMapper;
|
import com.dingzhuo.energy.project.conglomeratepush.service.IConglomeratePushLogService;
|
import okhttp3.Response;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* @author zhw
|
*/
|
@Service
|
public class ConglomeratePushLogServiceImpl implements IConglomeratePushLogService {
|
|
@Autowired
|
private ConglomeratePushLogMapper conglomeratePushLogMapper;
|
|
@Override
|
public void test(){
|
ConglomeratePushLog conglomeratePushLog = new ConglomeratePushLog();
|
conglomeratePushLog.setId(UUID.fastUUID().toString());
|
conglomeratePushLog.setPushContent("abcd");
|
conglomeratePushLog.setPushResult("111");
|
conglomeratePushLog.setPushStatus("abssscd");
|
conglomeratePushLog.setPushCount(1L);
|
conglomeratePushLog.setPushTime(new Date());
|
//保存发送信息
|
conglomeratePushLogMapper.saveLog(conglomeratePushLog);
|
}
|
|
@Override
|
public void sendConglomerate(String jsonData,long pushCount){
|
ConglomeratePushLog conglomeratePushLog = new ConglomeratePushLog();
|
conglomeratePushLog.setId(UUID.fastUUID().toString());
|
//记录发送信息的对象
|
JSONObject sendResJson=null;
|
String exeRes="N";
|
try{
|
//要发送的数据对象
|
jsonData = "";
|
sendResJson = send(jsonData);
|
//不论成功、失败 都记录到推送 信息发送表中
|
String success = sendResJson.getString("success");
|
//成功
|
if(StringUtils.isNotBlank(success) && StringUtils.equals(success, "true")){
|
exeRes="Y";
|
}
|
}catch (Exception e){
|
//记录以下Log 捕获异常不要抛出
|
conglomeratePushLog.setErrorInfo(e.getMessage());
|
}finally {
|
//记录要发送的内容
|
conglomeratePushLog.setPushContent(jsonData);
|
conglomeratePushLog.setPushResult(ObjectUtils.isNotEmpty(sendResJson)?sendResJson.toJSONString():"");
|
conglomeratePushLog.setPushStatus(exeRes);
|
conglomeratePushLog.setPushCount(pushCount);
|
conglomeratePushLog.setPushTime(new Date());
|
//保存发送信息
|
conglomeratePushLogMapper.saveLog(conglomeratePushLog);
|
|
}
|
}
|
|
private JSONObject send(String jsonData){
|
try{
|
Map<String,String> params = new HashMap<String, String>();
|
params.put("appKey", "");
|
params.put("call", "");
|
params.put("timestamp", String.valueOf(System.currentTimeMillis()));
|
params.put("data", jsonData);//
|
Response response = HttpUtil.post(params,"url");
|
String res = response.body().string();
|
return JSONObject.parseObject(res);
|
}catch (Exception e)
|
{
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("success", false);
|
jsonObject.put("result", false);
|
jsonObject.put("error", e.getMessage());
|
return jsonObject;
|
}
|
}
|
}
|
