1

src/main/java/com/ekexiu/operation/push/getui/Message.java

@@ -3,10 +3,12 @@ package com.ekexiu.operation.push.getui;
import com.google.gson.annotations.SerializedName;
public class Message {
	
	//注册应用时生成的appkey 
	@SerializedName("appkey")
	private String appKey;
	//是否离线推送 
	@SerializedName("is_offine")
	@SerializedName("is_offline")
	private boolean isOffline = true;
	//消息应用类型，可选项：notification、link、notypopload、transmission
	private String msgtype;

src/main/java/com/ekexiu/operation/push/getui/MsgCondition.java

@@ -0,0 +1,34 @@
package com.ekexiu.operation.push.getui;
import com.google.gson.annotations.SerializedName;
public class MsgCondition {
	private String key;
	private String[] values;
	@SerializedName("opt_type")
	private int optType;
	public String getKey() {
		return key;
	}
	public void setKey(String key) {
		this.key = key;
	}
	public String[] getValues() {
		return values;
	}
	public void setValues(String[] values) {
		this.values = values;
	}
	public int getOptType() {
		return optType;
	}
	public void setOptType(int optType) {
		this.optType = optType;
	}
	public MsgCondition(String key,String[] values,int optType){
		this.key = key;
		this.values = values;
		this.optType = optType;
	}
	
}

src/main/java/com/ekexiu/portal/dao/PpatentDao.java

@@ -7,6 +7,7 @@ import java.util.List;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.Or;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.operator.PageQuery;
@@ -63,6 +64,7 @@ public interface PpatentDao {
	
	@PageSelect
	@OrderBy(" ORDER BY SORT_NUM DESC,CREATE_TIME DESC,ID DESC")
	@Or
	PageQueryResult<Ppatent> query(Connection con,@Alias({"code","authors","name","keywords"}) @Like String cnt,int pageSize,int pageNo) throws SQLException;
	@SelectOne

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

@@ -22,19 +22,32 @@ import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.util.ConstData;
import org.jfw.util.StringUtil;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.operation.push.getui.Message;
import com.ekexiu.operation.push.getui.MsgCondition;
import com.ekexiu.operation.push.getui.MsgStyle;
import com.ekexiu.operation.push.getui.NotificationMessage;
@Path("/push")
public class PushService {
	private static final org.apache.log4j.Logger log = org.apache.log4j.Logger.getLogger(PushService.class);
	private static Type RES_TYPE = new TypeReference<Map<String, Object>>() {
	}.getType();
	
	
	private static final MsgCondition  android=new MsgCondition("phonetype",new String[]{"ANDROID"},1);
	private static final MsgCondition  ios=new MsgCondition("phonetype",new String[]{"IOS"},1);
	
	private static final MsgCondition[]  onlyAndroid = new MsgCondition[]{android};
	
	private static final MsgCondition[]  onlyIos = new MsgCondition[]{ios};
	private static Map<String, String> CONTENT_TYPE = new HashMap<String, String>();
	private static Map<String, String> TOKEN_MAP = new ConcurrentHashMap<String, String>();
@@ -218,17 +231,49 @@ public class PushService {
		}
	}
	
	@Path("/bindTags")
	@Post
	public boolean bindTags(String[] tags, String cid) {
		String url = "https://restapi.getui.com/v1/" + this.appId + "/set_tags";
		Map<String,Object> msg = new HashMap<String,Object>();
		msg.put("cid",cid);
		msg.put("tag_list",tags);
		try {
			Map<String, Object> ret = post(url, TOKEN_MAP, JsonService.toJson(msg).getBytes(ConstData.UTF8));
			this.checkResult(ret);
			return true;
		} catch (IOException e) {
			log.error("bind tags error:"+JsonService.toJson(msg), e);
			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>();
		ret.put("message", message);
		message.put("appkey",this.appKey);
		message.put("is_offline",false);
		message.put("is_offline",true);
		message.put("msgtype", "transmission");
		Map<String,Object> transmission = new HashMap<String,Object>();
		ret.put("transmission", transmission);
		transmission.put("transmission_type", false);
		transmission.put("transmission_content", "I"+payload);
		transmission.put("transmission_content", payload);
		Map<String,Object> pushInfo = new HashMap<String,Object>();
		ret.put("push_info", pushInfo);
		Map<String,Object> aps = new HashMap<String,Object>();
@@ -240,26 +285,34 @@ public class PushService {
		aps.put("autoBadge","+1");
		aps.put("content-available",1);
		aps.put("sound","default");
		pushInfo.put("payload","I"+payload);		
		pushInfo.put("payload",payload);		
		ret.put("condition", onlyIos);
		return ret;		
	}
	
	private  Map<String,Object > createAndriodMessage(String title,String content,String payload){
		Map<String,Object> ret = new HashMap<String,Object>();
		Map<String,Object> message= new HashMap<String,Object>();
		Message message = new Message();
		ret.put("message", message);
		message.put("appkey",this.appKey);
		message.put("is_offline",false);
		message.put("msgtype", "notification");
		Map<String,Object> notification = new HashMap<String,Object>();
		message.setAppKey(this.appKey);
		message.setMsgtype("notification");
		message.setOffline(true);
		message.setOfflineExpireTime(2*60*1000);
		message.setPushNetworkType(0);
		NotificationMessage notification = new NotificationMessage();
		ret.put("notification", notification);
		Map<String,Object> style = new HashMap<String,Object>();
		notification.put("style", style);
		style.put("type", 0);
		style.put("text", content);
		style.put("title",title);
		
		notification.put("transmission_type", false);
		notification.put("transmission_content", "A"+payload);
	    notification.setTransmissionType(true);
	    notification.setTransmissionContent(payload);
	    MsgStyle style = new MsgStyle();
	    notification.setStyle(style);		
		style.setType(0);
		style.setClearable(true);
		style.setRing(true);
		style.setText(content);
		style.setTitle(title);
		style.setVibrate(true);
		ret.put("condition", onlyAndroid);
		return ret;		
	}
	
@@ -268,19 +321,56 @@ public class PushService {
	public void toApp(String title,String content,Object payload){
		String url = "https://restapi.getui.com/v1/"+this.appId+"/push_app";
		String pl_str = JsonService.toJson(payload);
		//Map<String,Object> andriodMessage = this.createAndriodMessage(title, content, pl_str);
		Map<String,Object> andriodMessage = this.createAndriodMessage(title, content, pl_str);
		Map<String,Object> iosMessage = this.createIosMessage(title, content, pl_str);
		//andriodMessage.put("requestid",this.allocateRequesstId());
		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);
//		} catch (Exception e) {
//			log.error("send app message error",e);
//		}
//		System.out.println(JsonService.toJson(iosMessage));
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(andriodMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (Exception e) {
			log.error("send app message error",e);
		}
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (Exception e) {
			log.error("send app message error",e);
		}
	}
	private MsgCondition createTagCondition(String[] tags){
		return new MsgCondition("tag", tags, 0);
	}
	private void addTag(Map<String,Object> msg,MsgCondition  tagCondition){
		MsgCondition[] mcs = (MsgCondition[]) msg.get("condition");
		MsgCondition[] mcsn = new MsgCondition[mcs.length+1];
		System.arraycopy(mcs,0,mcsn, 0,mcs.length);
		mcsn[mcs.length] = tagCondition;
		msg.put("condition", mcsn);
		
	}
	
	public void pushWithTag(String title,String content,Object payload,String[] tags){
		String url = "https://restapi.getui.com/v1/"+this.appId+"/push_app";
		String pl_str = JsonService.toJson(payload);
		Map<String,Object> andriodMessage = this.createAndriodMessage(title, content, pl_str);
		Map<String,Object> iosMessage = this.createIosMessage(title, content, pl_str);
		andriodMessage.put("requestid",this.allocateRequesstId());
		iosMessage.put("requestid",this.allocateRequesstId());	
		
		MsgCondition tagC = this.createTagCondition(tags);
		addTag(andriodMessage, tagC);
		addTag(iosMessage, tagC);
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(andriodMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (Exception e) {
			log.error("send app message error",e);
		}
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
@@ -289,6 +379,59 @@ public class PushService {
		}
	}
	public void pushWithCid(String title,String content,Object payload,String cid){
		String url = "https://restapi.getui.com/v1/"+this.appId+"/push_single";
		String pl_str = JsonService.toJson(payload);
		Map<String,Object> androidMessage = this.createAndriodMessage(title, content, pl_str);
		Map<String,Object> iosMessage = this.createIosMessage(title, content, pl_str);
		androidMessage.put("requestid",this.allocateRequesstId());
		androidMessage.put("cid",cid);
		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);
		} catch (Exception e) {
			log.error("send app message error",e);
		}
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (Exception e) {
			log.error("send app message error",e);
		}	
	}
	public void pushWithAlias(String title,String content,Object payload,String alias){
		String url = "https://restapi.getui.com/v1/"+this.appId+"/push_single";
		String pl_str = JsonService.toJson(payload);
		Map<String,Object> androidMessage = this.createAndriodMessage(title, content, pl_str);
		Map<String,Object> iosMessage = this.createIosMessage(title, content, pl_str);
		androidMessage.put("requestid",this.allocateRequesstId());
		androidMessage.put("alias",alias);
		iosMessage.put("requestid",this.allocateRequesstId());		
		iosMessage.put("alias",alias);
		
//		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);
		} catch (Exception e) {
			log.error("send app message error",e);
		}
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,JsonService.toJson(iosMessage).getBytes(ConstData.UTF8));
			this.checkResult(ret);
		} catch (Exception e) {
			log.error("send app message error",e);
		}	
	}
	
	
	
	public static HttpURLConnection getConnection(String urlString) throws IOException {
		URL url = new URL(urlString);
		HttpURLConnection conn = null;
@@ -345,6 +488,7 @@ public class PushService {
	static {
		CONTENT_TYPE.put("Content-Type", "application/json");
		TOKEN_MAP.putAll(CONTENT_TYPE);
		TOKEN_MAP.put("authtoken", "ef60d2aa2bc3193fc99a99ef43906cee70658156dfb41156acc35f7e7b7fb3dd");
		ERR_MAP.put("no_msg", "没有消息体");
		ERR_MAP.put("alias_error", "找不到别名");
@@ -373,10 +517,11 @@ public class PushService {
		PushService s = new PushService();
//		 s.buildToken();
//		 s.checkToken();
		TOKEN_MAP.put("authtoken", "4119677018b45c49d6ff6350e7bea33e81ead059061c50455dda2237938f5bf5");
		long l = System.currentTimeMillis();
//		TOKEN_MAP.put("authtoken", "ef60d2aa2bc3193fc99a99ef43906cee70658156dfb41156acc35f7e7b7fb3dd");
	long l = System.currentTimeMillis();
		s.toApp("title_" + l, "content_" + l, "payload_" + l);
//	s.applyBadge(1, "f293af1f1cc043185ee9d921b63c4807", "D380AD6865B61F4D179DBB208EE3C7268A672AB9821385050596608A186F6023");
		// for(int i = 0 ;i < 100;++i){
		// UUID uuid= UUID.randomUUID();
		// System.out.println( "A"+Long.toString(