init

.gitignore

@@ -0,0 +1,4 @@
/.settings/
/.classpath
/.project
/target/

pom.xml

@@ -0,0 +1,80 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.ekexiu.project</groupId>
	<artifactId>bridge</artifactId>
	<version>0.0.1</version>
	<packaging>war</packaging>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<maven.compiler.source>1.7</maven.compiler.source>
		<maven.compiler.target>1.7</maven.compiler.target>
		<maven.war.filteringDeploymentDescriptors>true</maven.war.filteringDeploymentDescriptors>
		<maven.tomcat.path>/</maven.tomcat.path>
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.postgresql</groupId>
			<artifactId>postgresql</artifactId>
			<version>9.4.1207.jre7</version>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwApt</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwAptOrm</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwAptWeb</artifactId>
			<version>0.0.2-SNAPSHOT</version>
			<optional>true</optional>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwUtil</artifactId>
			<version>0.0.2-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>org.jfw</groupId>
			<artifactId>jfwWebUtil</artifactId>
			<version>0.0.2-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<scope>provided</scope>
			<version>2.5</version>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
			<version>1.0.20</version>
		</dependency>
		<dependency>
			<groupId>javax.mail</groupId>
			<artifactId>mail</artifactId>
			<version>1.4</version>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.mortbay.jetty</groupId>
				<artifactId>jetty-maven-plugin</artifactId>
				<version>8.1.0.RC5</version>
				<configuration>
					<stopPort>9966</stopPort>
					<stopKey>foo</stopKey>
				</configuration>
			</plugin>
		</plugins>
		<finalName>bridge</finalName>
	</build>
</project>

src/main/java/com/ekexiu/project/bridge/base/po/BaseTable.java

@@ -0,0 +1,28 @@
package com.ekexiu.project.bridge.base.po;
import org.jfw.apt.annotation.JfwAptConfig;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.VirtualTable;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
@JfwAptConfig("DB:PostgreSQL")
@VirtualTable
public interface BaseTable {
	@Column(descp="创建时间（YYYYMMDDHH24MISS）不可修改", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = false)
	String getCreateTime();
	void setCreateTime(String createTime);
	@Column(descp="最后修改时间（YYYYMMDDHH24MISS）,初始值:20000101010101", handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "'20000101010101'", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = true)
	String getModifyTime();
	void setModifyTime(String modifyTime);
	@Column(descp="创建人ID",value= DE.id_32)
	String getCreator();
	void setCreator(String creator);
	
	@Column(descp="最后修改人ID",value=DE.refid_32)
	String getModifier();
	void setModifier(String modifier);
	
}

src/main/java/com/ekexiu/project/bridge/resource/po/Bridge.java

@@ -0,0 +1,161 @@
package com.ekexiu.project.bridge.resource.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.bridge.base.po.BaseTable;
@Table(descp="桥梁信息")
public class Bridge  implements BaseTable{
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	
	private String code;
	private String shortName;
	private String name;
	private String addrCode;
	private String serviceDay;
	private String location;
	private String descp;
	private String remark;
	private String img;
	private String org;
	private String phone;
	private String email;
	
	private boolean active;
	
	
	
	
	
	
	
	
	
	
	@Column(descp="是否可用",value=DE.boolean_de)	
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	@Column(descp="桥梁编号",value=DE.text_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	@Column(descp="桥梁简称",value=DE.text_de)
	public String getShortName() {
		return shortName;
	}
	public void setShortName(String shortName) {
		this.shortName = shortName;
	}
	@Column(descp="桥梁名称（全称）",value=DE.text_de)
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Column(descp="桥梁政区划编码",value=DE.text_de)
	public String getAddrCode() {
		return addrCode;
	}
	public void setAddrCode(String addrCode) {
		this.addrCode = addrCode;
	}
	@Column(descp="桥梁开通日期（YYYYMMDD）",value=DE.text_de)
	public String getServiceDay() {
		return serviceDay;
	}
	public void setServiceDay(String serviceDay) {
		this.serviceDay = serviceDay;
	}
	@Column(descp="桥梁定位",value=DE.text_de)
	public String getLocation() {
		return location;
	}
	
	public void setLocation(String location) {
		this.location = location;
	}
	@Column(descp="桥梁详细描述",value=DE.Text_de)
	public String getDescp() {
		return descp;
	}
	public void setDescp(String descp) {
		this.descp = descp;
	}
	@Column(descp="桥梁备注",value=DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	@Column(descp="",value=DE.text_de)
	public String getImg() {
		return img;
	}
	public void setImg(String img) {
		this.img = img;
	}
	@Column(descp="桥梁维护机构名称",value=DE.text_de)
	public String getOrg() {
		return org;
	}
	public void setOrg(String org) {
		this.org = org;
	}
	@Column(descp="桥梁维护机构电话",value=DE.text_de)
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}
	@Column(descp="桥梁维护机构电邮",value=DE.text_de)
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
	
}

src/main/java/com/ekexiu/project/bridge/resource/po/BridgeServer.java

@@ -0,0 +1,101 @@
package com.ekexiu.project.bridge.resource.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.bridge.base.po.BaseTable;
@Table(descp="采集服务器")
public class BridgeServer implements BaseTable {
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	private String code;
	private String bridgeCode;
	private String ip;
	private int devices;
	private String remark;
	private boolean active;
	
	
	
	
	
	@Column(descp="是否可用",value=DE.boolean_de)	
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	@Column(descp="采集服务器编号",value=DE.text_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	@Column(descp="采集服务器所属桥梁编号",value=DE.text_de)
	public String getBridgeCode() {
		return bridgeCode;
	}
	public void setBridgeCode(String bridgeCode) {
		this.bridgeCode = bridgeCode;
	}
	@Column(descp="采集服务器IP",value=DE.text_de)
	public String getIp() {
		return ip;
	}
	public void setIp(String ip) {
		this.ip = ip;
	}
	@Column(descp="采集盒数量",value=DE.int_de)
	public int getDevices() {
		return devices;
	}
	public void setDevices(int devices) {
		this.devices = devices;
	}
	@Column(descp="备注",value=DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
	
	
	
	
	
	
}

src/main/java/com/ekexiu/project/bridge/resource/po/CollectDevice.java

@@ -0,0 +1,93 @@
package com.ekexiu.project.bridge.resource.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.bridge.base.po.BaseTable;
@Table(descp="采集盒")
public class CollectDevice implements BaseTable {
	private String code;
	private String serverCode;
	private int	channels;
	private String remark;
	private boolean active;
	
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	
	
	
	
	
	
	@Column(descp="采集盒编号",value=DE.text_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	@Column(descp="采集盒所属服务器编号",value=DE.text_de)
	public String getServerCode() {
		return serverCode;
	}
	public void setServerCode(String serverCode) {
		this.serverCode = serverCode;
	}
	@Column(descp="采集盒信道数量",value=DE.int_de)
	public int getChannels() {
		return channels;
	}
	public void setChannels(int channels) {
		this.channels = channels;
	}
	@Column(descp="备注",value=DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	@Column(descp="是否可用",value=DE.boolean_de)	
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
	
	
}

src/main/java/com/ekexiu/project/bridge/resource/po/Transducer.java

@@ -0,0 +1,91 @@
package com.ekexiu.project.bridge.resource.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table(descp="传感器")
public class Transducer {
	private String code;
	private String deviceCode;
	private String cableType;
	private String locType;
	private String remark;
	private boolean active;
	
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	@Column(descp="采集盒编号",value=DE.text_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	@Column(descp="传感器编号",value=DE.text_de)
	public String getDeviceCode() {
		return deviceCode;
	}
	public void setDeviceCode(String deviceCode) {
		this.deviceCode = deviceCode;
	}
	@Column(descp="传感器所在主缆(dict)",value=DE.text_de)
	public String getCableType() {
		return cableType;
	}
	public void setCableType(String cableType) {
		this.cableType = cableType;
	}
	@Column(descp="传感器所在位置(dict)",value=DE.text_de)
	public String getLocType() {
		return locType;
	}
	public void setLocType(String locType) {
		this.locType = locType;
	}
	@Column(descp="备注",value=DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	@Column(descp="是否可用",value=DE.boolean_de)	
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
	
	
}

src/main/java/com/ekexiu/project/bridge/right/po/UserBridge.java

@@ -0,0 +1,30 @@
package com.ekexiu.project.bridge.right.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table(descp="用户桥梁")
public class UserBridge {
	private String uid;
	private String bcode;
	
	@Column(descp="用户ID",value= DE.rtext_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(descp="桥梁编号",value= DE.rtext_de)
	public String getBcode() {
		return bcode;
	}
	public void setBcode(String bcode) {
		this.bcode = bcode;
	}
	
	
}

src/main/java/com/ekexiu/project/bridge/servlet/VerifyCodeServlet.java

@@ -0,0 +1,237 @@
package com.ekexiu.project.bridge.servlet;
import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics;
import java.awt.Graphics2D;
import java.awt.RenderingHints;
import java.awt.geom.AffineTransform;
import java.awt.image.BufferedImage;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Arrays;
import java.util.Random;
import javax.imageio.ImageIO;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
public class VerifyCodeServlet extends HttpServlet {
	/**
	 * 
	 */
	private static final long serialVersionUID = -384069991394456296L;
	private static final String DEFAULT_VERIFY_FLAG = "PIC_COMM";
	private static final long DEFAULT_TIMEOUT = 1000 * 60;
	private static final int DEFAULT_VERIFY_LEN = 4;
	private static final int DEFAULT_IMG_WIDTH = 100;
	private static final int DEFAULT_IMG_HEIGHT = 40;
	// 使用到Algerian字体，系统里没有的话需要安装字体，字体只显示大写，去掉了1,0,i,o几个容易混淆的字符
	public static final String VERIFY_CODES = "23456789ABCDEFGHJKLMNPQRSTUVWXYZ";
	private static Random random = new Random();
	public static String generateVerifyCode(int verifySize, String sources) {
		if (sources == null || sources.length() == 0) {
			sources = VERIFY_CODES;
		}
		int codesLen = sources.length();
		Random rand = new Random(System.currentTimeMillis());
		StringBuilder verifyCode = new StringBuilder(verifySize);
		for (int i = 0; i < verifySize; i++) {
			verifyCode.append(sources.charAt(rand.nextInt(codesLen - 1)));
		}
		return verifyCode.toString();
	}
	public static void outputImage(int w, int h, OutputStream os, String code) throws IOException {
		int verifySize = code.length();
		BufferedImage image = new BufferedImage(w, h, BufferedImage.TYPE_INT_RGB);
		Random rand = new Random();
		Graphics2D g2 = image.createGraphics();
		g2.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
		Color[] colors = new Color[5];
		Color[] colorSpaces = new Color[] { Color.WHITE, Color.CYAN, Color.GRAY, Color.LIGHT_GRAY, Color.MAGENTA, Color.ORANGE, Color.PINK, Color.YELLOW };
		float[] fractions = new float[colors.length];
		for (int i = 0; i < colors.length; i++) {
			colors[i] = colorSpaces[rand.nextInt(colorSpaces.length)];
			fractions[i] = rand.nextFloat();
		}
		Arrays.sort(fractions);
		g2.setColor(Color.GRAY);// 设置边框色
		g2.fillRect(0, 0, w, h);
		Color c = getRandColor(200, 250);
		g2.setColor(c);// 设置背景色
		g2.fillRect(0, 2, w, h - 4);
		// 绘制干扰线
		Random random = new Random();
		g2.setColor(getRandColor(160, 200));// 设置线条的颜色
		for (int i = 0; i < 20; i++) {
			int x = random.nextInt(w - 1);
			int y = random.nextInt(h - 1);
			int xl = random.nextInt(6) + 1;
			int yl = random.nextInt(12) + 1;
			g2.drawLine(x, y, x + xl + 40, y + yl + 20);
		}
		// 添加噪点
		float yawpRate = 0.05f;// 噪声率
		int area = (int) (yawpRate * w * h);
		for (int i = 0; i < area; i++) {
			int x = random.nextInt(w);
			int y = random.nextInt(h);
			int rgb = getRandomIntColor();
			image.setRGB(x, y, rgb);
		}
		shear(g2, w, h, c);// 使图片扭曲
		g2.setColor(getRandColor(100, 160));
		int fontSize = h - 4;
		Font font = new Font("Algerian", Font.ITALIC, fontSize);
		g2.setFont(font);
		char[] chars = code.toCharArray();
		for (int i = 0; i < verifySize; i++) {
			AffineTransform affine = new AffineTransform();
			affine.setToRotation(Math.PI / 4 * rand.nextDouble() * (rand.nextBoolean() ? 1 : -1), (w / verifySize) * i + fontSize / 2, h / 2);
			g2.setTransform(affine);
			g2.drawChars(chars, i, 1, ((w - 10) / verifySize) * i + 5, h / 2 + fontSize / 2 - 10);
		}
		g2.dispose();
		ImageIO.write(image, "jpg", os);
	}
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		response.setHeader("Pragma", "No-cache");
		response.setHeader("Cache-Control", "no-cache");
		response.setDateHeader("Expires", 0);
		response.setContentType("image/jpeg");
		int width = 0, height = 0, len = 0;
		try {
			width = Integer.parseInt(request.getParameter("w"));
		} catch (Exception e) {
		}
		if (width < 30 || width > 500) {
			width = DEFAULT_IMG_WIDTH;
		}
		try {
			height = Integer.parseInt(request.getParameter("h"));
		} catch (Exception e) {
		}
		if (height < 10 || height > 300) {
			height = DEFAULT_IMG_HEIGHT;
		}
		try {
			len = Integer.parseInt(request.getParameter("l"));
		} catch (Exception e) {
		}
		if (width < 4 || width > 10) {
			width = DEFAULT_VERIFY_LEN;
		}
		String flag = request.getParameter("flag");
		if (flag == null || flag.length() == 0) {
			flag = DEFAULT_VERIFY_FLAG;
		}
		String vc = generateVerifyCode(len, VERIFY_CODES);
		outputImage(width, height, response.getOutputStream(), vc);
		HttpSession session = request.getSession();
		session.setAttribute(flag, vc);
		long timeout = 0;
		try {
			timeout = Long.parseLong(request.getParameter("__timeout"));
		} catch (Exception e) {
		}
		if (timeout < 10000 || (timeout > (60000 * 30))) {
			timeout = DEFAULT_TIMEOUT;
		}
		timeout += (5000 + System.currentTimeMillis());
		session.setAttribute("TIMEOUT_" + flag, timeout);
	}
	protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		response.sendError(400);
	}
	private static Color getRandColor(int fc, int bc) {
		if (fc > 255)
			fc = 255;
		if (bc > 255)
			bc = 255;
		int r = fc + random.nextInt(bc - fc);
		int g = fc + random.nextInt(bc - fc);
		int b = fc + random.nextInt(bc - fc);
		return new Color(r, g, b);
	}
	private static int getRandomIntColor() {
		int[] rgb = getRandomRgb();
		int color = 0;
		for (int c : rgb) {
			color = color << 8;
			color = color | c;
		}
		return color;
	}
	private static int[] getRandomRgb() {
		int[] rgb = new int[3];
		for (int i = 0; i < 3; i++) {
			rgb[i] = random.nextInt(255);
		}
		return rgb;
	}
	private static void shear(Graphics g, int w1, int h1, Color color) {
		shearX(g, w1, h1, color);
		shearY(g, w1, h1, color);
	}
	private static void shearX(Graphics g, int w1, int h1, Color color) {
		int period = random.nextInt(2);
		boolean borderGap = true;
		int frames = 1;
		int phase = random.nextInt(2);
		for (int i = 0; i < h1; i++) {
			double d = (double) (period >> 1) * Math.sin((double) i / (double) period + (6.2831853071795862D * (double) phase) / (double) frames);
			g.copyArea(0, i, w1, 1, (int) d, 0);
			if (borderGap) {
				g.setColor(color);
				g.drawLine((int) d, i, 0, i);
				g.drawLine((int) d + w1, i, w1, i);
			}
		}
	}
	private static void shearY(Graphics g, int w1, int h1, Color color) {
		int period = random.nextInt(40) + 10; // 50;
		boolean borderGap = true;
		int frames = 20;
		int phase = 7;
		for (int i = 0; i < w1; i++) {
			double d = (double) (period >> 1) * Math.sin((double) i / (double) period + (6.2831853071795862D * (double) phase) / (double) frames);
			g.copyArea(i, 0, 1, h1, 0, (int) d);
			if (borderGap) {
				g.setColor(color);
				g.drawLine(i, (int) d, i, 0);
				g.drawLine(i, (int) d + h1, i, h1);
			}
		}
	}
}

src/main/java/com/ekexiu/project/bridge/system/dao/DictDao.java

@@ -0,0 +1,43 @@
package com.ekexiu.project.bridge.system.dao;
import java.sql.Connection;
import java.sql.SQLException;
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.IncludeFixSet;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
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.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import com.ekexiu.project.bridge.system.po.DictItem;
@DAO
public interface DictDao {
	@SelectList
	List<DictItem> query(Connection con) throws SQLException;
	@Insert
	int insert(Connection con, DictItem dict) throws SQLException;
	@UpdateWith
	@From(DictItem.class)
	@Where("ACTIVE = '1' AND READONLY <> '1'")
	@SetSentence("ACTIVE='0'")
	@IncludeFixSet
	int disable(Connection con, String dictCode, String code) throws SQLException;
	
	@UpdateWith
	@From(DictItem.class)
	@Where("ACTIVE = '1' AND READONLY <> '1'")
	int update(Connection con, @Nullable @Set String bcode, @Set String caption, @Nullable @Set String fullCaption, @Set @Nullable String shortCut,
			@Nullable @Set String remark, String code, String dictCode) throws SQLException;
}

src/main/java/com/ekexiu/project/bridge/system/po/DictItem.java

@@ -0,0 +1,88 @@
package com.ekexiu.project.bridge.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey({"dictCode","code"})
@Table(descp="数据字典表",value="SYS_DICT")
public class DictItem {
	private String code;
	private String dictCode;
	private String bcode;
	private String caption;
	private String fullCaption;
	private String shortCut;
	private String remark;
	private boolean readonly;
	private boolean active;
	
	@Column(descp="字典项编码",value= DE.rtext_de)
	public String getCode() {
		return code;
	}
	public void setCode(String code) {
		this.code = code;
	}
	
	@Column(descp="字典项编码(业务编码)",value= DE.Text_de)
	public String getBcode() {
		return bcode;
	}
	public void setBcode(String bcode) {
		this.bcode = bcode;
	}
	@Column(descp="字典编码",value= DE.rtext_de)
	public String getDictCode() {
		return dictCode;
	}
	public void setDictCode(String dictCode) {
		this.dictCode = dictCode;
	}
	@Column(descp="字典项显示",value= DE.text_de)
	public String getCaption() {
		return caption;
	}
	public void setCaption(String caption) {
		this.caption = caption;
	}
	@Column(descp="字典项显示(全)",value= DE.Text_de)
	public String getFullCaption() {
		return fullCaption;
	}
	public void setFullCaption(String fullCaption) {
		this.fullCaption = fullCaption;
	}
	@Column(descp="助记码",value= DE.Text_de)
	public String getShortCut() {
		return shortCut;
	}
	public void setShortCut(String shortCut) {
		this.shortCut = shortCut;
	}
	@Column(descp="备注",value= DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	@Column(descp="是否只读",value= DE.boolean_de)
	public boolean isReadonly() {
		return readonly;
	}
	public void setReadonly(boolean readonly) {
		this.readonly = readonly;
	}
	@Column(descp="是否有效",value= DE.boolean_de)
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	
	
	
}

src/main/java/com/ekexiu/project/bridge/system/po/User.java

@@ -0,0 +1,131 @@
package com.ekexiu.project.bridge.system.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.bridge.base.po.BaseTable;
@PrimaryKey("id")
@Uniques({@Unique(clolumns="account",name="UC_LUSER_ACCOUNT")})
@Table(descp="用户表",value="LUSER")
public class User implements BaseTable {
	private String createTime;
	private String modifyTime;
	private String creator;
	private String modifier;
	
	private String id;
	private String name;
	private String account;
	private String comp;
	private String job;
	private String phone;
	private String email;
	private String remark;
	private String passwd;
	
	private boolean active;
	
	
	@Column(descp="是否可用",value=DE.boolean_de)
	public boolean isActive() {
		return active;
	}
	public void setActive(boolean active) {
		this.active = active;
	}
	@Column(descp="密码（MD5）",value=DE.id_32)
	public String getPasswd() {
		return passwd;
	}
	public void setPasswd(String passwd) {
		this.passwd = passwd;
	}
	@Column(descp="用户ID",value =DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(descp="用户姓名",value =DE.text_de)
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Column(descp="用户帐号",value=DE.text_de)
	public String getAccount() {
		return account;
	}
	public void setAccount(String account) {
		this.account = account;
	}
	@Column(descp="用户所属单位",value=DE.text_de)
	public String getComp() {
		return comp;
	}
	public void setComp(String comp) {
		this.comp = comp;
	}
	@Column(value=DE.text_de,descp="用户职位")
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	@Column(descp="联系电话",value=DE.Text_de)
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}
	@Column(descp="联系邮件",value=DE.Text_de)
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	@Column(descp="备注",value=DE.Text_de)
	public String getRemark() {
		return remark;
	}
	public void setRemark(String remark) {
		this.remark = remark;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	public String getCreator() {
		return creator;
	}
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getModifier() {
		return modifier;
	}
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	
	
	
}

src/main/java/com/ekexiu/project/bridge/system/service/DictService.java

@@ -0,0 +1,149 @@
package com.ekexiu.project.bridge.system.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import com.ekexiu.project.bridge.system.dao.DictDao;
import com.ekexiu.project.bridge.system.po.DictItem;
@Path("/dict")
public class DictService {
	private static final HashMap<String, List<DictItem>> dictCache = new HashMap<String, List<DictItem>>();
	private static final List<DictItem> Empty_DICT = Collections.emptyList();
	@Autowrie
	private DictDao dictDao;
	public void load(Connection con) throws SQLException {
		List<DictItem> items = this.dictDao.query(con);
		for (DictItem item : items) {
			List<DictItem> list = dictCache.get(item.getDictCode());
			if (list == null) {
				list = new LinkedList<DictItem>();
				dictCache.put(item.getDictCode(), list);
			}
			list.add(item);
		}
	}
	@Path("/items")
	@Get
	public List<DictItem> query(String dict) {
		List<DictItem> ret = null;
		synchronized (dictCache) {
			ret = dictCache.get(dict);
		}
		return ret == null ? Empty_DICT : ret;
	}
	@Path("/delete")
	@Post
	public int delete(@JdbcConn(true) Connection con, final String dict, final String code, @AfterCommit List<Runnable> runs) throws SQLException {
		int num = this.dictDao.disable(con, dict, code);
		if (num > 0) {
			runs.add(new Runnable() {
				@Override
				public void run() {
					synchronized (dictCache) {
						List<DictItem> list = dictCache.get(dict);
						if (list != null) {
							List<DictItem> newlist = new LinkedList<DictItem>();
							for (DictItem item : list) {
								if (!item.getCode().equals(code)) {
									newlist.add(item);
								}
							}
							dictCache.put(dict, newlist);
						}
					}
				}
			});
		}
		return num;
	}
	@Post
	@Path("/add")
	public void insert(@JdbcConn(true) Connection con, String code, String dict, @Nullable String bcode, String caption, @Nullable String fullCaption,
			@Nullable String shortCut, @Nullable String remark, boolean readonly, @AfterCommit List<Runnable> runs) throws SQLException {
		final DictItem item = new DictItem();
		item.setActive(true);
		item.setBcode(bcode);
		item.setCaption(caption);
		item.setCode(code);
		item.setDictCode(dict);
		item.setFullCaption(fullCaption);
		item.setReadonly(readonly);
		item.setRemark(remark);
		item.setShortCut(shortCut);
		this.dictDao.insert(con, item);
		runs.add(new Runnable() {
			@Override
			public void run() {
				synchronized (dictCache) {
					List<DictItem> newlist = new LinkedList<DictItem>();
					List<DictItem> list = dictCache.get(item.getDictCode());
					if (list != null) {
						newlist.addAll(list);
					}
					newlist.add(item);
					dictCache.put(item.getDictCode(), newlist);
				}
			}
		});
	}
	@Post
	@Path("/modify")
	public int update(@JdbcConn(true) Connection con, String code, String dict, @Nullable String bcode, String caption, @Nullable String fullCaption,
			@Nullable String shortCut, @Nullable String remark, boolean readonly, @AfterCommit List<Runnable> runs) throws SQLException {
		int num = this.dictDao.update(con, bcode, caption, fullCaption, shortCut, remark, code, dict);
		if (num > 0) {
			final DictItem item = new DictItem();
			item.setActive(true);
			item.setBcode(bcode);
			item.setCaption(caption);
			item.setCode(code);
			item.setDictCode(dict);
			item.setFullCaption(fullCaption);
			item.setReadonly(false);
			item.setRemark(remark);
			item.setShortCut(shortCut);
			runs.add(new Runnable() {
				@Override
				public void run() {
					synchronized (dictCache) {
						List<DictItem> newlist = new LinkedList<DictItem>();
						List<DictItem> list = dictCache.get(item.getDictCode());
						if (list != null) {
							for (DictItem nitem : list) {
								if (!nitem.getCode().equals(item.getCode())) {
									newlist.add(nitem);
								}
							}
						}
						newlist.add(item);
						dictCache.put(item.getDictCode(), newlist);
					}
				}
			});
		}
		return num;
	}
}

src/main/java/com/ekexiu/project/job/TaskJob.java

@@ -0,0 +1,43 @@
package com.ekexiu.project.job;
import java.sql.Connection;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import javax.sql.DataSource;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.project.bridge.system.service.DictService;
public class TaskJob implements AfterBeanFactory {
	private ScheduledExecutorService service;
	private DataSource dataSource;
	@Override
	public void handle(BeanFactory bf) throws Throwable {
		this.service = JfwAppContext.getScheduledExecutorService();
		this.dataSource =(DataSource) bf.getBean("dataSource");
		Connection con  = this.dataSource.getConnection();
		try{
		
		DictService ds = (DictService) bf.getBean("com_ekexiu_project_bridge_system_service_DictService");
		ds.load(con);
		
		}finally{
			JdbcUtil.close(con);
		}
	}
}

src/main/resources/project.properties

@@ -0,0 +1,31 @@
dataSource=com.alibaba.druid.pool.DruidDataSource
#数据库连接地址、名称、密码
dataSource.url=jdbc:postgresql://192.168.3.233:5432/bridge
dataSource.username=postgres
dataSource.password=postgres
#连接池启动时的初始值（初始化连接）
dataSource.initialSize::int=1
#最小空闲连接值
dataSource.minIdle::int=1 
#连接池的最大值（最大连接数量）
dataSource.maxActive::int=1
#超时等待时间（maxWait代表当Connection用尽了，多久之后进行回收丢失连接）
dataSource.maxWait::long=60000
#连接超时任务的时间间隔
dataSource.timeBetweenEvictionRunsMillis::long=60000
#连接的超时时间
dataSource.minEvictableIdleTimeMillis::long=300000  
#用来验证从连接池取出的连接
dataSource.validationQuery=SELECT 1  
#指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败则连接将被从池中去除
dataSource.testWhileIdle::boolean=true
#在从池中取出连接前进行检验,如果检验失败则从池中去除连接并尝试取出另一个
dataSource.testOnBorrow::boolean=true
#指明是否在归还到池中前进行检验
dataSource.testOnReturn::boolean=true   
#开启池的prepared statement 池功能
dataSource.poolPreparedStatements::boolean=true 
#statement池能够同时分配的打开的statements的最大数量
dataSource.maxPoolPreparedStatementPerConnectionSize::int=20
#默认的SQL语句自动提交状态(开启或关闭)设置由连接池本身设置(false由连接池定)
dataSource.defaultAutoCommit::boolean=false

src/main/webapp/WEB-INF/web.xml

@@ -0,0 +1,40 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
                      http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
	version="3.0" metadata-complete="true">
	<servlet>
		<servlet-name>ajax</servlet-name>
		<servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
		<init-param>
			<param-name>prefixLen</param-name>
			<param-value>7</param-value>
		</init-param>
		<init-param>
			<param-name>viewType</param-name>
			<param-value>1</param-value>
		</init-param>
		<init-param>
			<param-name>configFileName</param-name>
			<param-value>beanConfig.properties,project.properties</param-value>
		</init-param>
		<init-param>
			<param-name>afterBeanFactory</param-name>
			<param-value>com.ekexiu.project.job.TaskJob</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>PictureVC</servlet-name>
		<servlet-class>com.ekexiu.project.bridge.servlet.VerifyCodeServlet</servlet-class>
		<load-on-startup>5</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>ajax</servlet-name>
		<url-pattern>/ajax/*</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>PictureVC</servlet-name>
		<url-pattern>/ajax/PictureVC</url-pattern>
	</servlet-mapping>
</web-app>