11

src/main/java/com/ekexiu/portal/question/Service.java

package com.ekexiu.portal.question;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.util.SqlUtil;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
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.*;
import org.jfw.apt.web.annotation.param.AfterCommit;
import org.jfw.apt.web.annotation.param.FieldParam;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.RequestParam;
import org.jfw.apt.web.annotation.param.Upload;
import org.jfw.util.DateUtil;
import org.jfw.util.JpgUtil;
import org.jfw.util.ListUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.util.SqlUtil;
@Path("/question")
public class Service {
	private File imgPath;
	private int imgMaxWidth = 70;
	public int getImgMaxWidth() {
		return imgMaxWidth;
	}
	public void setImgMaxWidth(int imgMaxWidth) {
		this.imgMaxWidth = imgMaxWidth;
	}
	public NotifyService getNotifyService() {
		return notifyService;
	}
		}
	}
	private void saveSmallImg(String imgs) throws IOException {
		if (imgs != null) {
			List<String> list = ListUtil.splitTrimExcludeEmpty(imgs, ',');
			if (list.size() > 0) {
				String oname = list.get(0);
				if (oname != null) {
					if (oname.startsWith("/")) {
						oname = oname.substring(1);
						int idx = oname.indexOf('.');
						if (idx > 0) {
							String dname = oname.substring(0, idx) + "_s.jpg";
							File dest = new File(this.imgPath, dname);
							if (dest.exists())
								return;
							File src = new File(this.imgPath, oname);
							if (src.exists()) {
								byte[] obs = IoUtil.readStream(new FileInputStream(src), true);
								obs = JpgUtil.read(obs);
								FileOutputStream out = new FileOutputStream(dest);
								try {
									JpgUtil.scalingZoom(new ByteArrayInputStream(obs), out, this.imgMaxWidth);
									out.flush();
								} finally {
									IoUtil.close(out);
								}
							}
						}
					}
				}
			}
		}
	}
	/**
	 * 新增一提问
	 * 
	 *            title 标题 ，cnt 描述 img 图片 以英文逗号分隔， keys 关键字 以英文逗号分隔 ，uid 用户ID
	 * @return
	 * @throws SQLException
	 * @throws IOException 
	 */
	@Path()
	@Post
					@FieldParam(value = "cnt", valueClass = String.class, required = false),
					@FieldParam(value = "img", valueClass = String.class, required = false), @FieldParam(value = "keys", valueClass = String.class),
					@FieldParam(value = "uid", valueClass = String.class) }) Question q)
			throws SQLException {
			throws SQLException, IOException {
		String id = StringUtil.buildUUID();
		q.setId(id);
		q.setReplyCount(0);
		List<String> kws = ListUtil.splitTrimExcludeEmpty(q.getKeys(), ',');
		if (kws.isEmpty())
			throw new IllegalArgumentException("param keys invalid");
		this.saveSmallImg(q.getImg());
		questionDao.insert(con, q);
		questionDao.insert(con, build(id, kws));
		return id;
	@Get
	@Path("/answer")
	public Answer answer(@JdbcConn Connection con,@Nullable String id,@Nullable String uid, @Nullable String qid) throws SQLException {
		if(id!=null){
	public Answer answer(@JdbcConn Connection con, @Nullable String id, @Nullable String uid, @Nullable String qid) throws SQLException {
		if (id != null) {
			return questionDao.queryAnswer(con, id);
		}else if(qid!=null && uid !=null){
		} else if (qid != null && uid != null) {
			return questionDao.answer(con, uid, qid);
		}
		return null;
	@Get
	@Path("/answer/delete")
	public int logicDelete(@JdbcConn(true) Connection con, String id,String qid) throws SQLException {
		if (questionDao.logicDeleteAnswer(con, id,qid) > 0) {
	public int logicDelete(@JdbcConn(true) Connection con, String id, String qid) throws SQLException {
		if (questionDao.logicDeleteAnswer(con, id, qid) > 0) {
			questionDao.decQuestionReply(con, qid);
			return 1;
		}

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

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.RequestHeader;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.log.LogFactory;
		return null;
	}
	@Get
	@Path("/testCtrl")
	public void ctrl(@RequestHeader("EKEXIU-DEV") String dev, boolean enable) {
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		time = time.substring(7, 8);
		int i = Integer.parseInt(time) * 2;
		int j = i / 2 + 9;
		time = time + i + j;
		if (time.equals(dev)) {
			this.enable = enable;
			if (this.enable) {
				this.token = null;
				this.lastBuildTime = 0;
			}
			this.refresh();
		}
	}
	@Path("/bindTags")
	@Post
	public boolean bindTags(String[] tags, String cid) {