1

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

@@ -0,0 +1,63 @@
package com.ekexiu.operation.push.getui;
import com.google.gson.annotations.SerializedName;
public class Message {
	//注册应用时生成的appkey 
	private String appKey;
	//是否离线推送 
	@SerializedName("is_offine")
	private boolean isOffline = true;
	//消息应用类型，可选项：notification、link、notypopload、transmission
	private String msgtype;
	//消息离线存储有效期，单位：ms
	@SerializedName("offline_expire_time")
	private int offlineExpireTime = 1000*60*60*24;
	//选择推送消息使用网络类型，0：不限制，1：wifi
	
	@SerializedName("push_network_type")
	private int pushNetworkType = 0;
	public String getAppKey() {
		return appKey;
	}
	public void setAppKey(String appKey) {
		this.appKey = appKey;
	}
	public boolean isOffline() {
		return isOffline;
	}
	public void setOffline(boolean isOffline) {
		this.isOffline = isOffline;
	}
	public String getMsgtype() {
		return msgtype;
	}
	public void setMsgtype(String msgtype) {
		this.msgtype = msgtype;
	}
	public int getOfflineExpireTime() {
		return offlineExpireTime;
	}
	public void setOfflineExpireTime(int offlineExpireTime) {
		this.offlineExpireTime = offlineExpireTime;
	}
	public int getPushNetworkType() {
		return pushNetworkType;
	}
	public void setPushNetworkType(int pushNetworkType) {
		this.pushNetworkType = pushNetworkType==0?0:1;
	}
	
	
	
}

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

@@ -0,0 +1,73 @@
package com.ekexiu.operation.push.getui;
import com.google.gson.annotations.SerializedName;
public class MsgStyle {
	//type 	integer 	是 	固定为1
	private int type=1;
	//text 	String 	是 	通知内容
	private String text;
	//title 	String 	是 	通知标题
	private String title;
	//logo 	String 	是 	通知的图标名称，包含后缀名（需要在客户端开发时嵌入），如“push.png”
	private String logo;
	//logourl 	String 	否 	通知图标URL地址
	private String logourl;
	//is_ring 	boolean 	否 	收到通知是否响铃：true响铃，false不响铃。默认响铃
	@SerializedName("is_ring")
	private boolean ring=true;
	//is_vibrate 	boolean 	否 	收到通知是否振动：true振动，false不振动。默认振动
	@SerializedName("is_vibrate")
	private boolean vibrate = true;
	//is_clearable 	boolean 	否 	通知是否可清除： true可清除，false不可清除。默认可清除	
	@SerializedName("is_clearable")
	private boolean clearable;
	public int getType() {
		return type;
	}
	public void setType(int type) {
		this.type = type;
	}
	public String getText() {
		return text;
	}
	public void setText(String text) {
		this.text = text;
	}
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getLogo() {
		return logo;
	}
	public void setLogo(String logo) {
		this.logo = logo;
	}
	public String getLogourl() {
		return logourl;
	}
	public void setLogourl(String logourl) {
		this.logourl = logourl;
	}
	public boolean isRing() {
		return ring;
	}
	public void setRing(boolean ring) {
		this.ring = ring;
	}
	public boolean isVibrate() {
		return vibrate;
	}
	public void setVibrate(boolean vibrate) {
		this.vibrate = vibrate;
	}
	public boolean isClearable() {
		return clearable;
	}
	public void setClearable(boolean clearable) {
		this.clearable = clearable;
	}
}

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

@@ -0,0 +1,53 @@
package com.ekexiu.operation.push.getui;
import com.google.gson.annotations.SerializedName;
public class NotificationMessage {
	//transmission_type 	boolean 	否 	收到消息是否立即启动应用，true为立即启动，false则广播等待启动，默认是否
	@SerializedName("transmission_type")
	private boolean transmissionType=false;
	
	//transmission_content 	String 	否 	透传内容
	@SerializedName("transmission_content")
	private String transmissionContent;
	
	//duration_begin 	String 	否 	设定展示开始时间，格式为yyyy-MM-dd HH:mm:ss
	@SerializedName("duration_begin")
	private String durationBegin;
	
	//duration_end 	String 	否 	设定展示结束时间，格式为yyyy-MM-dd HH:mm:ss
	@SerializedName("duration_end")
	private String durationEnd;
	//style 	Style 	是 	通知栏消息布局样式，见底下Style说明
	private MsgStyle style;
	public boolean isTransmissionType() {
		return transmissionType;
	}
	public void setTransmissionType(boolean transmissionType) {
		this.transmissionType = transmissionType;
	}
	public String getTransmissionContent() {
		return transmissionContent;
	}
	public void setTransmissionContent(String transmissionContent) {
		this.transmissionContent = transmissionContent;
	}
	public String getDurationBegin() {
		return durationBegin;
	}
	public void setDurationBegin(String durationBegin) {
		this.durationBegin = durationBegin;
	}
	public String getDurationEnd() {
		return durationEnd;
	}
	public void setDurationEnd(String durationEnd) {
		this.durationEnd = durationEnd;
	}
	public MsgStyle getStyle() {
		return style;
	}
	public void setStyle(MsgStyle style) {
		this.style = style;
	}
}

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

@@ -0,0 +1,16 @@
package com.ekexiu.operation.push.getui;
public class PushMessage {
	private final Message message;
	
	private NotificationMessage notification;
	private TransmissionMessage transmission;
	
	private String requestid;
	private String alias;
	
	public PushMessage(){
		this.message = new Message();
	}
	
}

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

@@ -0,0 +1,57 @@
package com.ekexiu.operation.push.getui;
import java.util.Map;
import com.google.gson.annotations.SerializedName;
public class TransmissionMessage {
	//transmission_type 	boolean 	否 	收到消息是否立即启动应用，true为立即启动，false则广播等待启动，默认是否
	@SerializedName("transmission_type")
	private boolean transmissionType=false;
	
	//transmission_content 	String 	否 	透传内容
	@SerializedName("transmission_content")
	private String transmissionContent;
	
	//duration_begin 	String 	否 	设定展示开始时间，格式为yyyy-MM-dd HH:mm:ss
	@SerializedName("duration_begin")
	private String durationBegin;
	
	//duration_end 	String 	否 	设定展示结束时间，格式为yyyy-MM-dd HH:mm:ss
	@SerializedName("duration_end")
	private String durationEnd;
	//push_info 	Map 	否 	APNs消息内容
	@SerializedName("push_info")
	private Map<String,Object> pushInfo;
	public boolean isTransmissionType() {
		return transmissionType;
	}
	public void setTransmissionType(boolean transmissionType) {
		this.transmissionType = transmissionType;
	}
	public String getTransmissionContent() {
		return transmissionContent;
	}
	public void setTransmissionContent(String transmissionContent) {
		this.transmissionContent = transmissionContent;
	}
	public String getDurationBegin() {
		return durationBegin;
	}
	public void setDurationBegin(String durationBegin) {
		this.durationBegin = durationBegin;
	}
	public String getDurationEnd() {
		return durationEnd;
	}
	public void setDurationEnd(String durationEnd) {
		this.durationEnd = durationEnd;
	}
	public Map<String, Object> getPushInfo() {
		return pushInfo;
	}
	public void setPushInfo(Map<String, Object> pushInfo) {
		this.pushInfo = pushInfo;
	}
	
}

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

@@ -280,7 +280,7 @@ public abstract class ProfessorDao {
	public EditProfessor queryBaseInfo(Connection con, String id) throws SQLException {
		int index = 1;
        String sql = "SELECT P.OFFICE,P.DEPARTMENT,P.TITLE,AUTHENTICATION,AUTH_TYPE,P.AUTH_STATUS,"
        		+ " P.ID,P.NAME,P.ADDRESS,P.ORG_AUTH,ORGANIZATION.NAME,P.ORG_ID,P.SCORE_PERCENT,P.SHARE_ID "
        		+ " P.ID,P.NAME,P.ADDRESS,P.ORG_AUTH,ORGANIZATION.NAME,P.ORG_ID,P.SCORE_PERCENT,P.SHARE_ID,P.PHONE,P.EMAIL"
        		+ " FROM PROFESSOR P LEFT JOIN ORGANIZATION ON P.ORG_ID = ORGANIZATION.ID WHERE P.ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
@@ -335,6 +335,17 @@ public abstract class ProfessorDao {
                    }
                    professor.setScorePercent(scorePercent);
                    professor.setShareId(rs.getLong(14));
                    String phone = rs.getString(15);
                    if(rs.wasNull()){
                    	phone = null;
                    }
                    professor.setPhone(phone);
                    String email = rs.getString(16);
                    if(rs.wasNull()){
                    	email = null;
                    }
                    professor.setEmail(email);
                    
                    return professor;
                }else{
                    return null;

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

@@ -11,6 +11,7 @@ import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import javax.net.ssl.HostnameVerifier;
@@ -23,6 +24,7 @@ import javax.net.ssl.X509TrustManager;
import org.jfw.apt.web.annotation.Path;
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;
@@ -35,14 +37,14 @@ public class PushService {
	}.getType();
	private static Map<String, String> CONTENT_TYPE = new HashMap<String, String>();
	private static Map<String,String>  TOKEN_MAP = new ConcurrentHashMap<String,String>();
	private static Map<String, String> TOKEN_MAP = new ConcurrentHashMap<String, String>();
	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 = "UiIGJTfKNR8oXb8apYdGh3";
	private String appKey = "FnwUFkK2nt9BLgQ0XjtOl4";
	private String appId = "G3L3npt6LU92DZHkdNxuL4";
	private String secret = "U96j677DHoA1Pv5X0mxMU9";
	private String appKey = "48nq7d7yHu8dgbzVHuisp6";
	private String appId = "TUdvbnxu1c97r6Fb6cUy57";
	private int timeout = 0;
	private String token = null;
@@ -108,16 +110,21 @@ public class PushService {
		log.error("调用用个推restApi,返回结果错误：" + obj + ":" + errMsg);
		throw new RuntimeException("调用用个推restApi,返回结果错误：" + obj + ":" + errMsg);
	}
	
	private void checkToken()
	{
		if(this.token==null){
	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();
		return "A" + Long.toString(uuid.getLeastSignificantBits(), 36) + "_" + Long.toString(uuid.getMostSignificantBits(), 36);
	}
	private void buildToken() {
		if(true) return;
		long time = System.currentTimeMillis();
		String sign = this.buildSign(time);
		StringBuilder sb = new StringBuilder();
@@ -138,13 +145,13 @@ public class PushService {
		}
	}
	public void refresh(){
		if((this.token!=null)  && ((System.currentTimeMillis() -  this.lastBuildTime) < (24*60 *60*1000-5000))){
			return ;
	public void refresh() {
		if ((this.token != null) && ((System.currentTimeMillis() - this.lastBuildTime) < (24 * 60 * 60 * 1000 - 5000))) {
			return;
		}
		this.buildToken();
	}
	
	public Map<String, Object> post(String url, Map<String, String> header, byte[] data) throws IOException {
		HttpURLConnection connection = getConnection(url);
		try {
@@ -195,26 +202,93 @@ public class PushService {
		}
	}
	
	
	@Path("/bindAlias")
	@Post
	public boolean bindAlias(String alias,String cid){
		String url = "https://restapi.getui.com/v1/"+this.appId+"/bind_alias";
	public boolean bindAlias(String alias, String cid) {
		String url = "https://restapi.getui.com/v1/" + this.appId + "/bind_alias";
		StringBuilder sb = new StringBuilder();
		sb.append("{\"alias_list\" : [{\"cid\":\"").append(cid).append("\",\"alias\":\"").append(alias).append("\" }]}");
		try {
			Map<String,Object> ret = post(url, TOKEN_MAP,sb.toString().getBytes(ConstData.UTF8));
			Map<String, Object> ret = post(url, TOKEN_MAP, sb.toString().getBytes(ConstData.UTF8));
			this.checkResult(ret);
			return true;
		} catch (IOException e) {
			log.error("bind alias error[cid:"+cid+",alias:"+alias+"]",e);
			log.error("bind alias error[cid:" + cid + ",alias:" + alias + "]", e);
			return false;
		}
	}
	
	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("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);
		Map<String,Object> pushInfo = new HashMap<String,Object>();
		ret.put("push_info", pushInfo);
		Map<String,Object> aps = new HashMap<String,Object>();
		pushInfo.put("aps",aps);
		Map<String,Object> alert = new HashMap<String,Object>();
		aps.put("alert", alert);
		alert.put("title", title);
		alert.put("body",content);
		aps.put("autoBadge","+1");
		aps.put("content-available",1);
		aps.put("sound","default");
		pushInfo.put("payload","I"+payload);		
		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>();
		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>();
		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);
		return ret;		
	}
	
	
	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> iosMessage = this.createIosMessage(title, content, pl_str);
		//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);
//		}
		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;
@@ -297,7 +371,18 @@ public class PushService {
	public static void main(String[] args) throws Exception {
		PushService s = new PushService();
		s.buildToken();
		s.checkToken();
//		 s.buildToken();
//		 s.checkToken();
		TOKEN_MAP.put("authtoken", "4119677018b45c49d6ff6350e7bea33e81ead059061c50455dda2237938f5bf5");
		long l = System.currentTimeMillis();
		s.toApp("title_" + l, "content_" + l, "payload_" + l);
		// for(int i = 0 ;i < 100;++i){
		// UUID uuid= UUID.randomUUID();
		// System.out.println( "A"+Long.toString(
		// uuid.getLeastSignificantBits(),36)+"_"+Long.toString(uuid.getMostSignificantBits(),
		// 36));
		// }
	}
}