訊息推送，定時任務
阿新 • • 發佈：2018-12-31
package com.idorabox.manage.task;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Controller GetNewStockByIdEntity的實體類，可以通過工具生成：
package com.idorabox.manage.entity.jd;
import java.util.List;
/**
* 查詢庫存
* @author Administrator
*
*/
public class GetNewStockByIdEntity {
public static String jd_url = "https://bizapi.jd.com/api/stock/getNewStockById";
private boolean success;
private String resultMessage;
private String resultCode;
private List<ResultBeanX> result;
public boolean isSuccess() {
return success;
}
public void setSuccess(boolean success) {
this.success = success;
}
public String getResultMessage() {
return resultMessage;
}
public void setResultMessage(String resultMessage) {
this.resultMessage = resultMessage;
}
public String getResultCode() {
return resultCode;
}
public List<ResultBeanX> getResult() {
return result;
}
public void setResult(List<ResultBeanX> result) {
this.result = result;
}
public void setResultCode(String resultCode) {
this.resultCode = resultCode;
}
public static class ResultBeanX {
/**
* id : 1785319316
* result : {"price":"","skuId":723749,"jdPrice":""}
* time : 2017-06-30 01:02:20
* type : 2
*/
private Long skuId;
private String areaId;
private String stockStateId;
private String stockStateDesc;
private String remainNum;
public Long getSkuId() {
return skuId;
}
public void setSkuId(Long skuId) {
this.skuId = skuId;
}
public String getAreaId() {
return areaId;
}
public void setAreaId(String areaId) {
this.areaId = areaId;
}
public String getStockStateId() {
return stockStateId;
}
public void setStockStateId(String stockStateId) {
this.stockStateId = stockStateId;
}
public String getStockStateDesc() {
return stockStateDesc;
}
public void setStockStateDesc(String stockStateDesc) {
this.stockStateDesc = stockStateDesc;
}
public String getRemainNum() {
return remainNum;
}
public void setRemainNum(String remainNum) {
this.remainNum = remainNum;
}
}
}JPushConstantUtil 實體類，作為推送的標誌
package com.idorabox.manage.jpush;
/**
*
* @ClassName: JPushConstantUtil
* @Description: 極光推送常量類
* @author qinzz
* @date 2016年9月23日
* @time 下午1:29:57
*/
public class JPushConstantUtil {
/**
* 朵拉購APP_KEY
*/
public static final String APP_KEY_BUSINESS="77857a3190fca8f9af0f735b";
/**
* 朵拉購 master_key
*/
public static final String MASTER_SECRET_BUSINESS="ebfa8ca1913e2f3ca7eefc7a";
/**
* 訂單訊息推送
*/
public static final String ORDER_MSG="1";
/**
* 回購訊息推送
*/
public static final String BACK_MSG="2";
/**
* 一般訊息推送
*/
public static final String MSG="3";
/**
* 產品詳情 推送 (推送此型別的訊息，附帶productId)
*/
public static final String PRODUCT_MSG="4";
/**
* 商品url詳情 推送
*/
public static final String URL_MSG="5";
/**
* 紅包快過期推送
*/
public static final String REDPACKET_MSG="6";
/**
* 到貨提醒推送
*/
public static final String DH_MSG="7";
}
推送類：
package com.idorabox.manage.jpush;
import java.util.Map;
import cn.jpush.api.JPushClient;
import cn.jpush.api.common.resp.APIConnectionException;
import cn.jpush.api.common.resp.APIRequestException;
import cn.jpush.api.push.PushResult;
import cn.jpush.api.push.model.Options;
import cn.jpush.api.push.model.Platform;
import cn.jpush.api.push.model.PushPayload;
import cn.jpush.api.push.model.audience.Audience;
import cn.jpush.api.push.model.notification.AndroidNotification;
import cn.jpush.api.push.model.notification.IosNotification;
import cn.jpush.api.push.model.notification.Notification;
public class DolaGouJPushUtil {
/**
*
* @Title: SendPush_To_One
* @Description: 朵拉購推送給單個使用者
* @param masterKey
* @param appKey
* @param registrationId 使用者的reg_id
* @param content 推送內容
* @param title 推送的標題
* @param alert 顯示的內容
* void 返回型別
* @throws
*/
public static void SendPush_To_One(String registrationId,String alert, String title,Map map){
// JPushClient jpushClient = new JPushClient(JPushConstantUtil.MASTER_SECRET_BUSINESS,
// JPushConstantUtil.APP_KEY_BUSINESS);
//使用單例模式創建極光推送客戶端
JPushClient jpushClient=SingletonJPushClient.getJpushClient();
try {
PushPayload paylosd=PushPayload.newBuilder()
.setPlatform(Platform.android_ios())//設定接受的平臺
.setAudience(Audience.registrationId(registrationId))//推送給單個使用者
.setNotification(Notification.newBuilder()
.setAlert(alert)
.addPlatformNotification(AndroidNotification.newBuilder()
.setTitle(title)//推送給安卓端的標題
.addExtras(map).build())
.addPlatformNotification(IosNotification.newBuilder()
.incrBadge(1)
.setBadge(0)
.addExtras(map).build())
.build())
.setOptions(Options.newBuilder()
.setApnsProduction(true)
.build())
.build();//ApnsProduction：true:正式環境，false:測試環境
PushResult result = jpushClient.sendPush(paylosd);
if(result!=null){
System.out.println("result......"+result);
System.out.println("推送成功！！！！！！");
}
else{
System.out.println("result is null..........");
}
} catch (APIConnectionException e) {
System.out.println("Connection error. Should retry later");
e.printStackTrace();
} catch (APIRequestException e) {
System.out.println("Error response from JPush server. Should review and fix it.");
e.printStackTrace();
} finally {
System.out.println("推送已經推出");
}
}
}