111

.gitignore

@@ -1,3 +1,6 @@
# Created by .ignore support plugin (hsz.mobi)
.idea
target
/.settings/
/.classpath
/.project

src/main/java/com/ekexiu/project/platform/organization/OrgDao.java

@@ -4,6 +4,8 @@ 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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
@@ -13,9 +15,6 @@ import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2018/11/22.
 */
@DAO
public interface OrgDao {
@@ -30,4 +29,11 @@ public interface OrgDao {
    @SelectOne
    @Nullable
    Organization queryOne(Connection con, String id) throws SQLException;
    
    @DeleteWith
    @From(Organization.class)
    int delete(Connection con,String id)throws SQLException;
    
    @Insert
    int insert(Connection con,Organization org)throws SQLException;
}

src/main/java/com/ekexiu/project/platform/organization/OrgService.java

@@ -6,10 +6,19 @@ 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.apt.web.annotation.param.JdbcConn;
import org.jfw.util.DateUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.project.platform.professor.Professor;
import com.ekexiu.project.util.HttpService;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
/**
 * Created by TT on 2018/11/22.
@@ -17,6 +26,8 @@ import java.util.List;
@Path("/org")
public class OrgService {
	private String syncUrl = "http://www.ekexiu.com/ajax/platform/ids/buttedOrgs?pid=";
	private String infoUrl = "http://www.ekexiu.com/ajax/org/";
    @Autowrie
    private OrgDao orgDao;
@@ -28,7 +39,23 @@ public class OrgService {
        this.orgDao = orgDao;
    }
    @Path("/setlevel")
    public String getSyncUrl() {
		return syncUrl;
	}
	public void setSyncUrl(String syncUrl) {
		this.syncUrl = syncUrl;
	}
	public String getInfoUrl() {
		return infoUrl;
	}
	public void setInfoUrl(String infoUrl) {
		this.infoUrl = infoUrl;
	}
	@Path("/setlevel")
    @Post
    public void setLevel(@JdbcConn(true) Connection con, String id, @Nullable Integer level) throws SQLException {
        orgDao.setlevel(con, id, level);
@@ -45,4 +72,55 @@ public class OrgService {
    public Organization queryOne(@JdbcConn Connection con, String id) throws SQLException {
        return orgDao.queryOne(con, id);
    }
    
	@Get
    @Path("/sync")
   synchronized public void sync(@JdbcConn(true) Connection con,String pid)throws SQLException, JfwBaseException, IOException{
    	 List<Organization> existsList = this.orgDao.queryList(con);
    	 List<Organization> insertList = new LinkedList<Organization>();
    	 
    	 List<Map<String,String>> buttedProfessores = HttpService.get(this.syncUrl+pid, new TypeReference<List<Map<String,String>>>() {
		} .getType());
    	 
    	 if(buttedProfessores.size()>0){
    		 for(Map<String,String> map:buttedProfessores){
    			 String uid = map.get("uid");
    			 if(uid!= null){
    				 Organization p = null;
    				for(Organization pe:existsList){
    					if(uid.equals(pe.getId())){
    						p = pe;
    					}
    				}
    				if(p == null){
	    				 p = new Organization();
	    				 p.setId(uid);
	    				 p.setAssTime(map.get("createTime"));
	    				 insertList.add(p);
    				}else{
    					existsList.remove(p);    					
    				}
    			 }
    		 }
    		 
    		 for(Organization p:insertList){
    			 Map<String,Object> map = HttpService.get(this.infoUrl+p.getId(), new TypeReference<Map<String,Object>>() {
    				} .getType());
    			 p.setShareId(-1);
    			 if(map!=null){
    				 Object tmp = map.get("shareId");
    				 if(tmp!= null && tmp instanceof Double){
    					 p.setShareId(((Double)tmp).longValue());
    					 if(p.getAssTime()==null){
    						 p.setAssTime(DateUtil.formatDateTime(System.currentTimeMillis()));
    					 }
    					 orgDao.insert(con, p);
    				 }
    			 }
    		 }
    	 }
    	 for(Organization p:existsList){
			 this.orgDao.delete(con, p.getId());
		 }
    }
}

src/main/java/com/ekexiu/project/platform/professor/ProfessorDao.java

@@ -4,6 +4,8 @@ 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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
@@ -30,5 +32,12 @@ public interface ProfessorDao {
    @SelectOne
    @Nullable
    Professor queryOne(Connection con, String id) throws SQLException;
    
    @DeleteWith
    @From(Professor.class)
    int delete(Connection con,String id)throws SQLException;
    
    @Insert
    int insert(Connection con,Professor p)throws SQLException;
}

src/main/java/com/ekexiu/project/platform/professor/ProfessorService.java

@@ -6,10 +6,18 @@ 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.apt.web.annotation.param.JdbcConn;
import org.jfw.util.DateUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.reflect.TypeReference;
import com.ekexiu.project.util.HttpService;
import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
/**
 * Created by TT on 2018/11/20.
@@ -17,33 +25,117 @@ import java.util.List;
@Path("/professor")
public class ProfessorService {
    @Autowrie
    private ProfessorDao professorDao;
	private String syncUrl = "http://www.ekexiu.com/ajax/platform/ids/buttedProfessors?pid=";
	private String infoUrl = "http://www.ekexiu.com/ajax/professor/baseInfo/";
    public ProfessorDao getProfessorDao() {
        return professorDao;
    }
	@Autowrie
	private ProfessorDao professorDao;
    public void setProfessorDao(ProfessorDao professorDao) {
        this.professorDao = professorDao;
    }
	public String getInfoUrl() {
		return infoUrl;
	}
    @Path("/setlevel")
    @Post
    public void setLevel(@JdbcConn(true) Connection con, String id, @Nullable Integer level) throws SQLException {
        professorDao.setlevel(con, id, level);
    }
	public void setInfoUrl(String infoUrl) {
		this.infoUrl = infoUrl;
	}
    @Path("/list")
    @Get
    public List<Professor> queryList(@JdbcConn Connection con) throws SQLException {
        return professorDao.queryList(con);
    }
	public String getSyncUrl() {
		return syncUrl;
	}
	public void setSyncUrl(String syncUrl) {
		this.syncUrl = syncUrl;
	}
	public ProfessorDao getProfessorDao() {
		return professorDao;
	}
	public void setProfessorDao(ProfessorDao professorDao) {
		this.professorDao = professorDao;
	}
	@Path("/setlevel")
	@Post
	public void setLevel(@JdbcConn(true) Connection con, String id, @Nullable Integer level) throws SQLException {
		professorDao.setlevel(con, id, level);
	}
	@Path("/list")
	@Get
	public List<Professor> queryList(@JdbcConn Connection con) throws SQLException {
		return professorDao.queryList(con);
	}
	@Path("/qo")
	@Get
	public Professor queryOne(@JdbcConn Connection con, String id) throws SQLException {
		return professorDao.queryOne(con, id);
	}
    @Path("/qo")
    @Get
    public Professor queryOne(@JdbcConn Connection con, String id) throws SQLException {
        return professorDao.queryOne(con, id);
	@Get
    @Path("/sync")
   synchronized public void sync(@JdbcConn(true) Connection con,String pid)throws SQLException, JfwBaseException, IOException{
    	 List<Professor> existsList = this.professorDao.queryList(con);
    	 List<Professor> insertList = new LinkedList<Professor>();
    	 
    	 List<Map<String,String>> buttedProfessores = HttpService.get(this.syncUrl+pid, new TypeReference<List<Map<String,String>>>() {
		} .getType());
    	 
    	 if(buttedProfessores.size()>0){
    		 for(Map<String,String> map:buttedProfessores){
    			 String uid = map.get("uid");
    			 if(uid!= null){
    				Professor p = null;
    				for(Professor pe:existsList){
    					if(uid.equals(pe.getId())){
    						p = pe;
    					}
    				}
    				if(p == null){
	    				 p = new Professor();
	    				 p.setId(uid);
	    				 p.setAssTime(map.get("createTime"));
	    				 insertList.add(p);
    				}else{
    					existsList.remove(p);    					
    				}
    			 }
    		 }
    		 
    		 for(Professor p:insertList){
    			 Map<String,Object> map = HttpService.get(this.infoUrl+p.getId(), new TypeReference<Map<String,Object>>() {
    				} .getType());
    			 p.setShareId(-1);
    			 if(map!=null){
    				 Object tmp = map.get("shareId");
    				 if(tmp!= null && tmp instanceof Double){
    					 p.setShareId(((Double)tmp).longValue());
    					 if(p.getAssTime()==null){
    						 p.setAssTime(DateUtil.formatDateTime(System.currentTimeMillis()));
    					 }
    					 professorDao.insert(con, p);
    				 }
    			 }
    		 }
    	 }
    	 for(Professor p:existsList){
			 this.professorDao.delete(con, p.getId());
		 }
    }
	
	
//	public static void main(String[] args) throws Exception{
//		 Map<String,Object> map = HttpService.get("http://www.ekexiu.com/ajax/professor/baseInfo/FA08E12933D64D76999512DDDF3958F9", new TypeReference<Map<String,Object>>() {
//			} .getType());
//
//		 if(map!=null){
//			 Object tmp = map.get("shareId");
//			 if(tmp!= null){
//				 System.out.println(((Double)tmp).longValue());
//			 }
//		 }
//		
//	}
}

src/main/java/com/ekexiu/project/util/HttpService.java

@@ -0,0 +1,216 @@
package com.ekexiu.project.util;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.StringWriter;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.URL;
import org.jfw.util.ConstData;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.reflect.TypeReference;
public class HttpService {
	private static final byte[] SIMPLE_POST_DATA = "1=1".getBytes(ConstData.UTF8);
	private static String charset = "UTF-8";
	public static Type buildResultType(final Type t) {
		return new ParameterizedType() {
			@Override
			public Type getRawType() {
				return Result.class;
			}
			@Override
			public Type getOwnerType() {
				return HttpService.class;
			}
			@Override
			public Type[] getActualTypeArguments() {
				return new Type[] { t };
			}
		};
	}
	private static  void raise(Result<?> ret) throws JfwBaseException {
		throw new JfwBaseException(ret.getCode().intValue(), "remote calll error:" + ret.getMsg() + ";\r\n" + ret.getDetailMsg());
	}
	private static <T> T handResponse(InputStream in, Type typeOfT) throws JfwBaseException {
		if (null != typeOfT) {
			Result<T> ret = JsonService.fromJson(new InputStreamReader(in, ConstData.UTF8), buildResultType(typeOfT));
			if (ret.isSuccess()) {
				return ret.getData();
			} else {
				raise(ret);
			}
		} else {
			Result<String> ret = JsonService.fromJson(new InputStreamReader(in, ConstData.UTF8), new TypeReference<Result<String>>() {
			}.getType());
			if (ret.isSuccess())
				return null;
			else {
				raise(ret);
			}
		}
		return null;
	}
	public static <T> T get(String url, Type typeOfT) throws JfwBaseException, IOException {
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	public static <T> T post(String url, String data, Type typeOfT) throws JfwBaseException, IOException {
		byte[] bs = SIMPLE_POST_DATA;
		if (data != null && data.length() > 0) {
			bs = data.getBytes(ConstData.UTF8);
		}
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setDoOutput(true);
		httpURLConnection.setRequestMethod("POST");
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		httpURLConnection.setRequestProperty("Content-Length", String.valueOf(bs.length));
		OutputStream outputStream = httpURLConnection.getOutputStream();
		try {
			outputStream.write(bs);
			outputStream.flush();
		} finally {
			IoUtil.close(outputStream);
		}
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	public static <T> T put(String url, Object data, Type typeOfT) throws JfwBaseException, IOException {
		StringWriter sw = new StringWriter();
		JsonService.toJson(data, sw);
		byte[] bs = sw.toString().getBytes(ConstData.UTF8);
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setDoOutput(true);
		httpURLConnection.setRequestMethod("PUT");
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestProperty("Content-Type", "application/json");
		httpURLConnection.setRequestProperty("Content-Length", String.valueOf(bs.length));
		OutputStream outputStream = httpURLConnection.getOutputStream();
		try {
			outputStream.write(bs);
			outputStream.flush();
		} finally {
			IoUtil.close(outputStream);
		}
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	public static <T> T delete(String url, Type typeOfT) throws JfwBaseException, IOException {
		URL u = new URL(url);
		HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
		httpURLConnection.setRequestProperty("Accept-Charset", charset);
		httpURLConnection.setRequestMethod("DELETE");
		httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		if (httpURLConnection.getResponseCode() != 200) {
			throw new IOException("HTTP Request is not success, Response code is " + httpURLConnection.getResponseCode());
		}
		InputStream in = httpURLConnection.getInputStream();
		try {
			return handResponse(in, typeOfT);
		} finally {
			IoUtil.close(in);
		}
	}
	public static class Result<T> {
		private boolean success;
		private Integer code;
		private String msg;
		private String detailMsg;
		private T data;
		public boolean isSuccess() {
			return success;
		}
		public void setSuccess(boolean success) {
			this.success = success;
		}
		public Integer getCode() {
			return code;
		}
		public void setCode(Integer code) {
			this.code = code;
		}
		public String getMsg() {
			return msg;
		}
		public void setMsg(String msg) {
			this.msg = msg;
		}
		public String getDetailMsg() {
			return detailMsg;
		}
		public void setDetailMsg(String detailMsg) {
			this.detailMsg = detailMsg;
		}
		public T getData() {
			return data;
		}
		public void setData(T data) {
			this.data = data;
		}
	}
}