111

src/main/java/com/ekexiu/push/service/PushService.java

@@ -57,7 +57,6 @@ public class PushService {
	private static Map<String, String> ERR_MAP = new HashMap<String, String>();
	final static char[] digits = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
	// UiIGJTfKNR8oXb8apYdGh3
	private String secret = "U96j677DHoA1Pv5X0mxMU9";
	private String appKey = "48nq7d7yHu8dgbzVHuisp6";
	private String appId = "TUdvbnxu1c97r6Fb6cUy57";
@@ -126,24 +125,22 @@ public class PushService {
		}
	}
	private void checkResult(Map<String, Object> ret) {
		Object obj = ret.get("result");
		if ("ok".equals(obj))
			return;
	private void raiseGeTuiError(Object obj){
		String errMsg = null;
		errMsg = ERR_MAP.get(obj);
		if (errMsg == null)
			errMsg = "其他错误";
		log.error("调用用个推restApi,返回结果错误：" + obj + ":" + errMsg);
		throw new RuntimeException("调用用个推restApi,返回结果错误：" + obj + ":" + errMsg);
	}
	private void checkResult(Map<String, Object> ret) {
		Object obj = ret.get("result");
		if (!"ok".equals(obj)){
			raiseGeTuiError(obj);
		}
	}
	
//	private void checkToken() {
//		if (this.token == null) {
//			log.error("token is null");
//			throw new RuntimeException("token is null");
//		}
//	}
	public String allocateRequesstId() {
		UUID uuid = UUID.randomUUID();
@@ -277,22 +274,6 @@ public class PushService {
			return false;
		}
	}
	@Path("/applyBadge")
	@Get
	public void applyBadge(int badge,String cid,String devtoken){
		String url = "https://restapi.getui.com/v1/" + this.appId + "/set_badge";
		StringBuilder sb = new StringBuilder();
		sb.append("{\"badge\":").append(badge).append(",\"cid_list\":[\"").append(cid).append("\"],\"devicetoken_list\":[\"").append(devtoken).append("\"]}");
		System.out.println(sb.toString());
		try {
			Map<String, Object> ret = post(url, TOKEN_MAP, sb.toString().getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (IOException e) {
			log.error("apply badge error[cid:" + cid + ",devtoken:" + devtoken + "]", e);
		}
		
	}
	
	private  Map<String,Object > createIosMessage(String title,String content,String payload){
		Map<String,Object> ret = new HashMap<String,Object>();
		Map<String,Object> message= new HashMap<String,Object>();
@@ -356,8 +337,6 @@ public class PushService {
		andriodMessage.put("requestid",this.allocateRequesstId());
		iosMessage.put("requestid",this.allocateRequesstId());		
		
//		System.out.println(JsonService.toJson(andriodMessage));
//		System.out.println(JsonService.toJson(iosMessage));
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(andriodMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
@@ -419,8 +398,6 @@ public class PushService {
		iosMessage.put("requestid",this.allocateRequesstId());		
		iosMessage.put("cid",cid);
		
//		System.out.println(JsonService.toJson(androidMessage));
//		System.out.println(JsonService.toJson(iosMessage));
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(androidMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
@@ -444,20 +421,35 @@ public class PushService {
		iosMessage.put("requestid",this.allocateRequesstId());		
		iosMessage.put("alias","I_"+alias);
		
//		System.out.println(JsonService.toJson(androidMessage));
//		System.out.println(JsonService.toJson(iosMessage));
		boolean  sended = false;
		Object result = null;
		Map<String,Object> ret = null;
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(androidMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
			ret = post(url, TOKEN_MAP,JsonService.toJson(androidMessage).getBytes(ConstData.UTF8));
		} catch (Exception e) {
			log.error("send app message error",e);
		}
		result = ret.get("result");
		if("ok".equals(result)){
			sended=true;
		}else if(!"alias_notbind".equals(result)){
			raiseGeTuiError(result);
		}
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
			 ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
		} catch (Exception e) {
			log.error("send app message error",e);
		}	
		}
		result = ret.get("result");
		if("ok".equals(result)){
			return;
		}else if("alias_notbind".equals(result)){
			raiseGeTuiError("alias_notbind");
		}else{
			if(!sended){				
				raiseGeTuiError(result);
			}
		}
	}
	
	
@@ -547,10 +539,21 @@ public class PushService {
		PushService s = new PushService();
//		 s.buildToken();
//		 s.checkToken();
		TOKEN_MAP.put("authtoken", "c3bbeb7aac006871f228d48e5da846933bfd2109e1d20fac3c8c0a3f3ccebd7d");
		
		
	
		
		String t="44f123977f387165a8c2b77f83ce30ccad8be50a922a21a96976700dad3a5f61";
		int idx = 51;
		int len = t.length();
		idx = len-idx;
		System.out.println();
		TOKEN_MAP.put("authtoken", t.substring(idx)+t.substring(0,idx));
	long l = System.currentTimeMillis();
		//s.toApp("title_" + l, "content_" + l, "payload_" + l);
	s.pushWithAlias("title_" + l, "content_" + l, "payload_" + l,"A21F6D7BD4C549A1A2ABC415DE7701BD");
	s.pushWithAlias("title_" + l, "content_" + l, "payload_" + l,"1A21F6D7BD4C549A1A2ABC415DE7701BD");
//	s.applyBadge(10, "f293af1f1cc043185ee9d921b63c4807", "9982595B6AAAE1EFABD0B40E215A76507E74D12477573491AF023B89807A01AA");
	System.out.println(l);
//	s.applyBadge(1, "f293af1f1cc043185ee9d921b63c4807", "D380AD6865B61F4D179DBB208EE3C7268A672AB9821385050596608A186F6023");