门户

+<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>
+	<parent>
+		<groupId>cn.runsa</groupId>
+		<artifactId>crmapp</artifactId>
+		<version>1.0.1-SNAPSHOT</version>
+		<relativePath>../crmapp/pom.xml</relativePath>
+	</parent>
+	<artifactId>crm-base</artifactId>
+	<packaging>jar</packaging>
+	<name>crm-base</name>
+
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+
+	<dependencies>
+	
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-web</artifactId>
+			<version>${spring_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>javax.servlet</groupId>
+			<artifactId>javax.servlet-api</artifactId>
+			<version>3.0.1</version>
+			<scope>provided</scope>
+		</dependency>
+
+		<!-- mybatis -->
+		<dependency>
+			<groupId>org.mybatis</groupId>
+			<artifactId>mybatis</artifactId>
+			<version>${mybatis_version}</version>
+		</dependency>
+
+		<!-- aspect java -->
+		<dependency>
+			<groupId>org.aspectj</groupId>
+			<artifactId>aspectjrt</artifactId>
+			<version>${aspectj_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.aspectj</groupId>
+			<artifactId>aspectjweaver</artifactId>
+			<version>${aspectj_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-aspects</artifactId>
+			<version>${spring_version}</version>
+		</dependency>
+
+		<!-- java code generation -->
+		<dependency>
+			<groupId>cglib</groupId>
+			<artifactId>cglib-nodep</artifactId>
+			<version>3.1</version>
+		</dependency>
+		<dependency>
+			<groupId>org.ow2.asm</groupId>
+			<artifactId>asm</artifactId>
+			<version>5.0.2</version>
+		</dependency>
+
+
+		<!-- json -->
+		<dependency><!-- databind 编译依赖annotations,core -->
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>${jackson_xml_version}</version>
+			<exclusions>
+				<exclusion>
+					<groupId>com.fasterxml.jackson.core</groupId>
+					<artifactId>jackson-annotations</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
+		<dependency><!-- databind 编译依赖annotations,core -->
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-annotations</artifactId>
+			<version>${jackson_xml_version}</version>
+		</dependency>
+		<dependency><!-- mapper-asl 编译依赖 core-asl 不需要再次引用 -->
+			<groupId>org.codehaus.jackson</groupId>
+			<artifactId>jackson-mapper-asl</artifactId>
+			<version>${jackson_version}</version>
+		</dependency>
+
+		<!-- redis -->
+		<dependency>
+			<groupId>redis.clients</groupId>
+			<artifactId>jedis</artifactId>
+			<version>2.6.0</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.data</groupId>
+			<artifactId>spring-data-redis</artifactId>
+			<version>1.6.2.RELEASE</version>
+		</dependency>
+		
+		<!-- java excel -->
+		<dependency>
+			<groupId>org.apache.poi</groupId>
+			<artifactId>poi</artifactId>
+			<version>${poi_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.poi</groupId>
+			<artifactId>poi-ooxml</artifactId>
+			<version>${poi_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>xml-apis</groupId>
+			<artifactId>xml-apis</artifactId>
+			<version>1.4.01</version>
+		</dependency>
+		<dependency>
+			<groupId>xerces</groupId>
+			<artifactId>xercesImpl</artifactId>
+			<version>2.11.0</version>
+		</dependency>
+
+		<!-- httpClient -->
+		<dependency>
+			<groupId>org.apache.httpcomponents</groupId>
+			<artifactId>httpclient</artifactId>
+			<version>${httpClient_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.httpcomponents</groupId>
+			<artifactId>httpmime</artifactId>
+			<version>${httpClient_version}</version>
+		</dependency>
+
+		<dependency>
+			<groupId>commons-configuration</groupId>
+			<artifactId>commons-configuration</artifactId>
+			<version>${commons_configuration_version}</version>
+		</dependency>
+
+		<!-- http async -->
+		<dependency>
+			<groupId>org.apache.httpcomponents</groupId>
+			<artifactId>httpasyncclient</artifactId>
+			<version>4.1</version>
+		</dependency>
+
+		<!-- java mail -->
+		<dependency>
+			<groupId>com.sun.mail</groupId>
+			<artifactId>mailapi</artifactId>
+			<version>1.5.2</version>
+		</dependency>
+		<dependency>
+			<groupId>com.sun.mail</groupId>
+			<artifactId>smtp</artifactId>
+			<version>1.5.2</version>
+		</dependency>
+
+		<!-- java date time -->
+		<dependency>
+			<groupId>joda-time</groupId>
+			<artifactId>joda-time</artifactId>
+			<version>2.5</version>
+		</dependency>
+
+		<!-- commons -->
+		<dependency>
+			<groupId>commons-codec</groupId>
+			<artifactId>commons-codec</artifactId>
+			<version>1.9</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>2.4</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-fileupload</groupId>
+			<artifactId>commons-fileupload</artifactId>
+			<version>1.3.1</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>3.1</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-beanutils</groupId>
+			<artifactId>commons-beanutils</artifactId>
+			<version>1.9.2</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-pool2</artifactId>
+			<version>2.2</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-collections4</artifactId>
+			<version>4.0</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-collections</groupId>
+			<artifactId>commons-collections</artifactId>
+			<version>3.2.1</version>
+		</dependency>
+		<dependency>
+			<groupId>commons-net</groupId>
+			<artifactId>commons-net</artifactId>
+			<version>3.3</version>
+		</dependency>
+
+		<!-- google guava -->
+		<dependency>
+			<groupId>com.google.guava</groupId>
+			<artifactId>guava</artifactId>
+			<version>19.0</version>
+		</dependency>
+
+		<!-- quartz -->
+		<dependency>
+			<groupId>org.quartz-scheduler</groupId>
+			<artifactId>quartz</artifactId>
+			<version>${quartz_version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.quartz-scheduler</groupId>
+			<artifactId>quartz-jobs</artifactId>
+			<version>${quartz_version}</version>
+		</dependency>
+
+		<dependency>
+			<groupId>de.alpharogroup</groupId>
+			<artifactId>jgeohash</artifactId>
+			<version>1.4.7</version>
+		</dependency>
+
+		<!-- qiniu picture -->
+		<dependency>
+			<groupId>com.qiniu</groupId>
+			<artifactId>qiniu-java-sdk</artifactId>
+			<version>7.0.7</version>
+		</dependency>
+
+		<dependency>
+			<groupId>com.aliyun.mns</groupId>
+			<artifactId>aliyun-sdk-mns</artifactId>
+			<version>1.1.1</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.amqp</groupId>
+			<artifactId>spring-amqp</artifactId>
+			<version>1.5.4.RELEASE</version>
+		</dependency>
+		<dependency>
+			<groupId>org.codehaus.groovy</groupId>
+			<artifactId>groovy</artifactId>
+			<version>2.4.6</version>
+		</dependency>
+		<dependency>
+			<groupId>org.hibernate</groupId>
+			<artifactId>hibernate-validator</artifactId>
+			<version>5.2.4.Final</version>
+		</dependency>
+		<dependency>
+			<groupId>com.thoughtworks.xstream</groupId>
+			<artifactId>xstream</artifactId>
+			<version>1.4.9</version>
+		</dependency>
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>fastjson</artifactId>
+			<version>${fastjson_version}</version>
+		</dependency>
+
+		<dependency>
+			<groupId>net.sf.ehcache</groupId>
+			<artifactId>ehcache-core</artifactId>
+			<version>${ehcache_core_version}</version>
+		</dependency>
+	</dependencies>
+</project>

+package cn.runsa.crmapp.base;
+
+import java.util.Date;
+
+import org.joda.time.DateTime;
+import org.joda.time.DateTimeZone;
+
+/**
+ * 系统常量
+ * 
+ * @author Stephen
+ *
+ */
+public class Constants {
+	/**
+	 * rest webservice 提供的页面地址
+	 */
+	public static final String CONSTANTS_SERVER_WEB_URL = "SERVER_URL";
+	/**
+	 * rest webservice 提供页面的超时时间
+	 */
+	public static final int CONSTANTS_API_PAGE_REGISTER_TIMEOUT = 30*60;
+	/**
+	 * rest webservice 提供页面的业务：会员入会
+	 */
+	public static final String CONSTANTS_API_PAGE_SCOPE_REGISTER = "REGISTER";
+	
+	public static final String CONSTANTS_CLASS_IMPL_PROFILE = "class.impl.profile";
+	
+	public static final String CONSTANTS_CLASS_IMPL_SYSTEM = "system";
+	
+	public static final String CONSTANTS_SERVER_CONFIG_PATH = "server_config";
+	
+	
+	/**
+	 * 系统默认字符集
+	 */
+	public static final String CONSTANTS_DEFAULT_CHARSET = "UTF-8";
+	
+	public static final String CONSTANTS_DEFAULT_SQL_DELIMITER = "#@#!#";
+	
+	
+	/**
+	 * 内容服务的类型：url
+	 */
+	public static final Byte CONSTANTS_CONTENT_URL = 0;
+
+	
+	/**
+	 * 东八区：中国
+	 */
+	public static final int CONSTANTS_CHINA_OFFSET_UTC = 8;
+	/**
+	 * 一天的秒
+	 */
+	public static final int CONSTANTS_MILLS_OF_DAYS = 24 * 60 * 60 * 1000;
+
+	
+	/**
+	 * 操作失败(响应到前端)
+	 */
+	public static final String RES_EXEC_FAILURE = "cn.runsa.failure";
+
+	
+	/**
+	 * 阳历
+	 */
+	public static final int CALENDAR_GREGORIAN = 0;
+	/**
+	 * 阴历
+	 */
+	public static final int CALENDAR_LUNAR = 1;
+	
+	
+	/**
+	 * 未婚
+	 */
+	public static final int MARRIAGE_NO = 0;
+	/**
+	 * 已婚
+	 */
+	public static final int MARRIAGE_YES = 1;
+	/**
+	 * 婚姻保密
+	 */
+	public static final int MARRIAGE_UNKNOWN = 2;
+	
+	
+	/**
+	 * 女
+	 */
+	public static final int SEX_FEMALE = 0;
+	/**
+	 * 男
+	 */
+	public static final int SEX_MALE = 1;
+	/**
+	 * 性别保密
+	 */
+	public static final int SEX_UNKNOWN = 2;
+	
+	
+	/**
+	 * 永久
+	 */
+	public static Date DATE_FOR_EVER = new DateTime(2099, 12, 31, 23, 59, 59,DateTimeZone.forOffsetHours(CONSTANTS_CHINA_OFFSET_UTC)).toDate();
+	
+	
+	/**
+	 * 业务处理需要分页的默认值
+	 */
+	public static final int CONSTANTS_BUSINESS_DEFAULT_PAGE_SIZE = 100;
+	
+	
+	/**
+	 * 顾客未验证
+	 */
+	public static final byte CONSTANTS_CUSTOMER_VERIFY_NOT = 0;
+	
+
+	/**
+	 * 非会员
+	 */
+	public static final Byte CONSTANTS_CUSTOMER_NOT_MEMBER = (byte)0;
+	/**
+	 * 会员
+	 */
+	public static final Byte CONSTANTS_CUSTOMER_MEMBER = (byte)1;
+	
+	
+	/**
+	 * 顾客来源渠道：线下
+	 */
+	public static final String CONSTANTS_CUSTOMER_CHANNEL_OFFLINE = "OFFLINE";
+	/**
+	 * 顾客来源渠道：微信
+	 */
+	public static final String CONSTANTS_CUSTOMER_CHANNEL_WEIXIN = "WEIXIN";
+
+	
+	/**
+	 * 顾客来源：门店
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_SITE = "SIT";
+	/**
+	 * 顾客来源：推荐顾客
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_CUSTOMER = "CST";
+	/**
+	 * 顾客来源：推荐雇员
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_EMPLOYEE = "EMP";
+	/**
+	 * 顾客来源：优惠券
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_COUPON = "CPN";
+	/**
+	 * 顾客来源：搜索公众号
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_WEIXINGZH = "GZH";
+	/**
+	 * 顾客来源：物流单
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_EXPRESS = "EXP";
+	/**
+	 * 顾客来源：商品
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_GOODS = "GDS";
+	/**
+	 * 顾客来源：活动
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_ACTIVITY = "ACT";
+	/**
+	 * 顾客来源：订单
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_ORDER= "ODR";
+	/**
+	 * 顾客来源：APP
+	 */
+	public static final String CONSTANTS_CUSTOMER_SOURCE_APP = "APP";
+
+	
+	/**
+	 * 优惠券来源:内部券
+	 */
+	public static final int CONSTANTS_COUPONS_COME_FROM_INNER = 0;
+	/**
+	 * 优惠券来源:外部券
+	 */
+	public static final int CONSTANTS_COUPONS_COME_FROM_OUTER = 1;
+	
+	
+	/**
+	 * 优惠券类型:折扣券
+	 */
+	public static final int CONSTANTS_COUPONS_TYPE_DISCOUNT = 0;
+	/**
+	 * 优惠券类型:金额券
+	 */
+	public static final int CONSTANTS_COUPONS_TYPE_MONEY = 1;
+	/**
+	 * 优惠券类型:礼品券
+	 */
+	public static final int CONSTANTS_COUPONS_TYPE_GIFT = 2;
+	/**
+	 * 优惠券类型:定价券
+	 */
+	public static final int CONSTANTS_COUPONS_TYPE_PRICE = 3;
+	/**
+	 * 优惠券类型:包邮券
+	 */
+	public static final int CONSTANTS_COUPONS_TYPE_FREESHIPPING = 4;
+	
+	
+	/**
+	 * 优惠券的生成方式:自动
+	 */
+	public static final int CONSTANTS_COUPONS_GENERATE_AUTO = 0;
+	/**
+	 * 优惠券的生成方式:导入
+	 */
+	public static final int CONSTANTS_COUPONS_GENERATE_IMPORT = 1;
+	/**
+	 * 优惠券的生成方式:接口接入
+	 */
+	public static final int CONSTANTS_COUPONS_GENERATE_INTERFACE = 2;
+
+	
+	/**
+	 * 手机
+	 */
+	public static final String CONSTANTS_CHANNEL_PHONE = "phone";
+	/**
+	 * 邮箱
+	 */
+	public static final String CONSTANTS_CHANNEL_EMAIL = "email";
+
+	
+	/**
+	 * 联盟级
+	 */
+	public static final String CONSTANTS_CUSTOMER_RANK_DEFAULT = "LMJ";
+	
+	
+	/**
+	 * 等级改变：升级
+	 */
+	public static final boolean CONSTANTS_RANK_CHANGE_UPGRADE = true;
+	/**
+	 * 等级改变：降级
+	 */
+	public static final boolean CONSTANTS_RANK_CHANGE_DEGRADE = false;
+	
+	
+	/**
+	 * 订单回执业务：积分
+	 */
+	public static final String CONSTANTS_ORDER_SERVICE_POINTS = "POINTS";
+	/**
+	 * 订单回执业务：优惠券
+	 */
+	public static final String CONSTANTS_ORDER_SERVICE_COUPONS = "COUPON";
+	
+	
+	
+	public static final Byte CONSTANTS_ORDER_POINTS_INCREASE = 1;
+	
+	public static final Byte CONSTANTS_ORDER_POINTS_DECREASE = 2;
+	
+	
+	/**
+	 * API账户：公众号
+	 */
+	public static final String CONSTANTS_API_TYPE_WXGZH = "GZH";
+	/**
+	 * API账户：POS
+	 */
+	public static final String CONSTANTS_API_TYPE_POS = "POS";
+	/**
+	 * API账户：电商
+	 */
+	public static final String CONSTANTS_API_TYPE_E_COMMERCE = "EC";
+	/**
+	 * API账户：导购
+	 */
+	public static final String CONSTANTS_API_TYPE_SALES_ASSISTANT = "SALES";
+	
+	
+	/**
+	 * 缓存前缀：token
+	 */
+	public static final String CONSTANTS_PREFIX_TOKEN  = "TOKEN";
+	/**
+	 * 缓存前缀：顾客信息
+	 */
+	public static final String CONSTANTS_PREFIX_CUSTOMER_INFO = "CST_INF";
+	/**
+	 * 缓存前缀：顾客手机号
+	 */
+	public static final String CONSTANTS_PREFIX_CUSTOMER_ID_PHONE = "CST_TEL";
+	/**
+	 * 缓存前缀：顾客微信
+	 */
+	public static final String CONSTANTS_PREFIX_CUSTOMER_ID_WXGZH = "CST_GZH";
+	/**
+	 * 缓存前缀：顾客账套信息
+	 */
+	public static final String CONSTANTS_PREFIX_CUSTOMER_CRM_ACCOUNTS_ALL = "CST_ACTA";
+	/**
+	 * 缓存前缀：顾客部分账套信息
+	 */
+	public static final String CONSTANTS_PREFIX_CUSTOMER_CRM_ACCOUNTS_PART = "CST_ACTP";
+	
+	
+	
+	public static final String CONSTANTS_TEMPLATE_SCOPE_POINTS_EXPIRY = "POINTS_EXPIRY";
+	
+	public static final String CONSTANTS_POINTS_CHANGE_TYPE_ADJUST_MANUAL ="ADJ_MAN";
+	
+	public static final String CONSTANTS_POINTS_CHANGE_TYPE_EXPIRY ="EXPIRY";
+	
+	
+	/**
+	 * 新建时字段
+	 */
+	public static final String CONSTANTS_FIELD_MODE_NEW = "NEW";
+	/**
+	 * 更新时字段
+	 */
+	public static final String CONSTANTS_FIELD_MODE_MODIFY = "MOD";
+	/**
+	 * 审批通过
+	 */
+	public static final Byte CONSTANTS_APPROVAL_STAT_PASS = 2;
+	
+	public static final String CONSTANTS_EVENT_ENV_KEY_NAME_POINTS_CALCULATE = "CRM_CALCULATE";
+	
+	/**
+	 * QiNiu
+	 */
+	public static final String QN_ACCESS_KEY = "QN_ACCESS_KEY";
+	public static final String QN_SECRET_KEY = "QN_SECRET_KEY";
+	public static final String QN_BUCKET = "QN_BUCKET";
+}

+package cn.runsa.crmapp.base.cache;
+
+import java.util.Collection;
+
+import javax.annotation.Resource;
+
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.support.CompositeCacheManager;
+import org.springframework.stereotype.Component;
+
+import cn.runsa.crmapp.base.utils.SpringUtils;
+
+/**
+ * @author Stephen
+ */
+@Component
+public final class CacheAdmin {
+	
+	@Resource(type=CompositeCacheManager.class)
+	private CacheManager cacheManager;
+	
+	public void clearCache(CacheManager manager,String name){
+		if(manager==null)
+			manager = cacheManager;
+		Cache cache = manager.getCache(name);
+		if(cache!=null){
+			cache.clear();
+		}
+	}
+	
+	public void clearlocalCache(){
+		CacheManager local = SpringUtils.getBean("local", CacheManager.class);
+		for(String cache:local.getCacheNames()){
+			clearCache(local,cache);
+		}
+	}
+	
+	public void clearCenterCache(){
+		CacheManager center = SpringUtils.getBean("center", CacheManager.class);
+		for(String cache:center.getCacheNames()){
+			clearCache(center,cache);
+		}
+	}
+	
+	public void clearAllCache(){
+		Collection<String> caches = cacheManager.getCacheNames();
+		for(String cache:caches){
+			clearCache(null,cache);
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.conf;
+
+import java.io.IOException;
+import java.util.Properties;
+
+import org.slf4j.LoggerFactory;
+import org.springframework.core.io.FileSystemResource;
+import org.springframework.core.io.support.PropertiesLoaderUtils;
+
+import cn.runsa.crmapp.base.Constants;
+
+public class ServerConfigration {
+	
+	private final static Properties prop;
+	
+	static{
+		try {
+			prop = PropertiesLoaderUtils.loadProperties(new FileSystemResource(System.getProperty(Constants.CONSTANTS_SERVER_CONFIG_PATH)));
+		} catch (IOException e) {
+			LoggerFactory.getLogger(ServerConfigration.class).error("load resource-product configration file error",e);
+			throw new RuntimeException(e);
+		}
+	}
+	
+	public static Properties getServerConfig(){
+		return prop;
+	}
+
+}

+package cn.runsa.crmapp.base.email;
+
+import java.util.Calendar;
+import java.util.Properties;
+import javax.mail.Authenticator;
+import javax.mail.MessagingException;
+import javax.mail.PasswordAuthentication;
+import javax.mail.Session;
+import javax.mail.Transport;
+import javax.mail.Message.RecipientType;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SendMail {
+	
+	private final static Logger logger = LoggerFactory.getLogger(SendMail.class);
+	public static final String EN_CODE = "text/html;charset=gb2312";
+	
+	private Transport transport;
+	private Session mailSession;
+	private InternetAddress fromAddress;
+	
+	public SendMail(String smtpHost, String from, String fromUserPassword) throws MessagingException{
+		this.connect(smtpHost, from, fromUserPassword);
+	}
+
+	public void connect(String smtpHost, String from, String fromUserPassword) throws MessagingException {
+		// 第一步：配置javax.mail.Session对象
+		System.out.println("为" + smtpHost + "配置mail session对象");
+		fromAddress = new InternetAddress(from);
+		Properties props = new Properties();
+		props.put("mail.smtp.host", smtpHost);
+		props.put("mail.smtp.starttls.enable", "true");// 使用 STARTTLS安全连接
+		// props.put("mail.smtp.port", "25"); //google使用465或587端口
+		props.put("mail.smtp.auth", "true"); // 使用验证
+		// props.put("mail.debug", "true");
+		mailSession = Session.getInstance(props, new MyAuthenticator(from, fromUserPassword));
+		transport = mailSession.getTransport("smtp");
+		transport.connect(smtpHost, from, fromUserPassword);
+	}
+	
+	@SuppressWarnings("static-access")
+	public  void sendMessage(String to, String subject,
+			String messageText, String messageType) throws MessagingException {
+		
+		logger.info("开始发送mail.收件人:"+ to);
+		InternetAddress toAddress = new InternetAddress(to);
+		MimeMessage message = new MimeMessage(mailSession);
+		message.setFrom(fromAddress);
+		message.addRecipient(RecipientType.TO, toAddress);
+		message.setSentDate(Calendar.getInstance().getTime());
+		message.setSubject(subject);
+		if(messageType == null){
+			message.setContent(messageText, EN_CODE);
+		}else{
+			message.setContent(messageText, messageType);
+		}
+		// 第三步：发送消息
+		transport.send(message, message.getRecipients(RecipientType.TO));
+		System.out.println("message yes");
+	}
+	
+	public  void sendMessage(String to, String subject,
+			String messageText) throws MessagingException {
+		
+		sendMessage(to, subject, messageText,null);
+	}
+
+
+	@SuppressWarnings("static-access")
+	public static void sendMessage(String smtpHost, String from, String fromUserPassword, String to, String subject,
+			String messageText, String messageType) throws MessagingException {
+		Properties props = new Properties();
+		props.put("mail.smtp.host", smtpHost);
+		props.put("mail.smtp.starttls.enable", "true");// 使用 STARTTLS安全连接
+		// props.put("mail.smtp.port", "25"); //google使用465或587端口
+		props.put("mail.smtp.auth", "true"); // 使用验证
+		// props.put("mail.debug", "true");
+		Session mailSession = Session.getInstance(props, new MyAuthenticator(from, fromUserPassword));
+
+		// 第二步：编写消息
+		logger.info("开始发送mail.发送人:" + from + "收件人:" + to);
+		InternetAddress fromAddress = new InternetAddress(from);
+		InternetAddress toAddress = new InternetAddress(to);
+
+		MimeMessage message = new MimeMessage(mailSession);
+
+		message.setFrom(fromAddress);
+		message.addRecipient(RecipientType.TO, toAddress);
+
+		message.setSentDate(Calendar.getInstance().getTime());
+		message.setSubject(subject);
+		if(messageType == null){
+			message.setContent(messageText, EN_CODE);
+		}else{
+			message.setContent(messageText, messageType);
+		}
+
+		// 第三步：发送消息
+		Transport transport = mailSession.getTransport("smtp");
+		transport.connect(smtpHost, from, fromUserPassword);
+		transport.send(message, message.getRecipients(RecipientType.TO));
+		transport.close();
+		System.out.println("message yes");
+	}
+	
+	public void close(){
+		try {
+			transport.close();
+		} catch (MessagingException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+
+	public static void main(String[] args) {
+		try {
+			System.out.println("单发一人用法,自带关闭");
+			SendMail.sendMessage("smtp.runsa.cn", "support@runsa.cn", "Runsatest@123", "472109366@qq.com", "nihao","English123中文", EN_CODE);
+			
+			System.out.println("连续发多人用法,需要手动关闭连接");
+			SendMail send = new SendMail("smtp.runsa.cn", "support@runsa.cn", "Runsatest@123");
+			send.sendMessage("472109366@qq.com", "nihao","English123中文", EN_CODE);
+			send.sendMessage("472109366@qq.com", "nihao","English123中文", EN_CODE);
+			send.close();
+		} catch (MessagingException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+}
+
+class MyAuthenticator extends Authenticator {
+	String userName = "";
+	String password = "";
+
+	public MyAuthenticator() {
+
+	}
+
+	public MyAuthenticator(String userName, String password) {
+		this.userName = userName;
+		this.password = password;
+	}
+
+	protected PasswordAuthentication getPasswordAuthentication() {
+		return new PasswordAuthentication(userName, password);
+	}
+}

+package cn.runsa.crmapp.base.email;
+
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Properties;
+
+import javax.mail.Authenticator;
+import javax.mail.MessagingException;
+import javax.mail.NoSuchProviderException;
+import javax.mail.PasswordAuthentication;
+import javax.mail.Session;
+import javax.mail.Transport;
+import javax.mail.Message.RecipientType;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SendMail2 {
+	private final static Logger logger = LoggerFactory.getLogger(SendMail2.class);
+	
+	public static final String EN_CODE = "text/html;charset=gb2312";
+	private Transport transport;
+	private Session mailSession;
+	private InternetAddress fromAddress;
+	
+	public SendMail2(String smtpHost, String from, String fromUserPassword) throws MessagingException{
+		this.connect(smtpHost, from, fromUserPassword);
+	}
+
+	@SuppressWarnings("static-access")
+	public void connect(String smtpHost, String from, String fromUserPassword) throws MessagingException {
+		// 第一步：配置javax.mail.Session对象
+		System.out.println("为" + smtpHost + "配置mail session对象");
+		fromAddress = new InternetAddress(from);
+		Properties props = new Properties();
+		props.put("mail.smtp.host", smtpHost);
+		props.put("mail.smtp.starttls.enable", "true");// 使用 STARTTLS安全连接
+		// props.put("mail.smtp.port", "25"); //google使用465或587端口
+		props.put("mail.smtp.auth", "true"); // 使用验证
+		// props.put("mail.debug", "true");
+		mailSession = Session.getInstance(props, new MyAuthenticator(from, fromUserPassword));
+		transport = mailSession.getTransport("smtp");
+		transport.connect(smtpHost, from, fromUserPassword);
+	}
+	
+	public void sendMsg(String subject, String messageText){
+		
+	}
+
+	@SuppressWarnings("static-access")
+	public  void sendMessage(String to, String subject,
+			String messageText, String messageType) throws MessagingException {
+		
+		System.out.println("编写消息from——to:" + "——" + to);
+
+		InternetAddress toAddress = new InternetAddress(to);
+		MimeMessage message = new MimeMessage(mailSession);
+
+		message.setFrom(fromAddress);
+		message.addRecipient(RecipientType.TO, toAddress);
+		message.setSentDate(Calendar.getInstance().getTime());
+		message.setSubject(subject);
+		if(messageType == null){
+			message.setContent(messageText, EN_CODE);
+		}else{
+			message.setContent(messageText, messageType);
+		}
+
+		// 第三步：发送消息
+		transport.send(message, message.getRecipients(RecipientType.TO));
+		System.out.println("message yes");
+	}
+	public void close(){
+		try {
+			transport.close();
+		} catch (MessagingException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+
+	public static void main(String[] args) {
+		try {
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
+			System.out.println(sdf.format(new Date()));
+			SendMail2 send = new SendMail2("smtp.runsa.cn", "support@runsa.cn", "Runsatest@123");
+			send.sendMessage("472109366@qq.com", "nihao",
+					"---------------wrwe-----------中文", EN_CODE);
+			System.out.println(sdf.format(new Date()));
+			send.sendMessage("472109366@qq.com", "nihao",
+					"---------------wrwe-----------中文", EN_CODE);
+			System.out.println(sdf.format(new Date()));
+		} catch (MessagingException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+
+
+}

+package cn.runsa.crmapp.base.event;
+
+import cn.runsa.crmapp.base.event.exception.BusinessEventException;
+/**
+ * 抽象evnetHandler,定义流程
+ * @author Stephen
+ */
+public abstract class AbstractBusinessEventHandler implements BusinessEventHandler {
+
+	public abstract boolean preHandle(BusinessEvent event);
+
+	public abstract void handle(BusinessEvent event) throws BusinessEventException;
+
+	public abstract void postHandle(BusinessEvent event, BusinessEventException e);
+
+	@Override
+	public final void listen(BusinessEvent event) {
+		if (preHandle(event)) {
+			try {
+				handle(event);
+			} catch (BusinessEventException e) {
+				postHandle(event, e);
+			}
+		}
+	}
+}

+package cn.runsa.crmapp.base.event;
+
+import java.io.Serializable;
+import java.util.Map;
+/**
+ * 业务事件
+ * @author Stephen
+ *
+ */
+public class BusinessEvent implements Serializable{
+
+	private static final long serialVersionUID = 7738977611490794967L;
+	/**
+	 * 事件代号
+	 */
+	private String eventCode;
+	/**
+	 * 账套
+	 */
+	private Long [] acts;
+	
+	private Object target;
+	
+	private Map<String,Object> env;
+	
+	private long timestamp;
+	
+	
+	public BusinessEvent() {
+		super();
+	}
+
+	public BusinessEvent(Object target, long timestamp) {
+		super();
+		this.target = target;
+		this.timestamp = timestamp;
+	}
+
+	public Object getTarget() {
+		return target;
+	}
+
+	public void setTarget(Object target) {
+		this.target = target;
+	}
+
+	public Map<String, Object> getEnv() {
+		return env;
+	}
+	
+	public Object getEnval(String key){
+		if(this.env!=null){
+			return this.env.get(key);
+		}
+		return null;
+	}
+
+	public void setEnv(Map<String, Object> env) {
+		this.env = env;
+	}
+
+	public long getTimestamp() {
+		return timestamp;
+	}
+
+	public void setTimestamp(long timestamp) {
+		this.timestamp = timestamp;
+	}
+
+	public String getEventCode() {
+		return eventCode;
+	}
+
+	public void setEventCode(String eventCode) {
+		this.eventCode = eventCode;
+	}
+
+	public Long[] getActs() {
+		return acts;
+	}
+
+	public void setActs(Long[] acts) {
+		this.acts = acts;
+	}
+
+}

+package cn.runsa.crmapp.base.event;
+
+import com.google.common.eventbus.Subscribe;
+/**
+ * 业务事件监听接口
+ * @author Stephen
+ *
+ */
+public interface BusinessEventHandler {
+	@Subscribe
+	void listen(BusinessEvent event);
+
+}

+package cn.runsa.crmapp.base.event;
+
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+
+import com.google.common.eventbus.EventBus;
+
+/**
+ * @author Stephen
+ */
+@Aspect
+public class BusinessEventHelper {
+	@Before("execution(public * com.google.common.eventbus.EventBus.post(*)")
+	public void eventBefore(JoinPoint point){
+		Object[] args = point.getArgs();
+		if(args !=null&&args.length==1){
+			Object obj = args[0];
+			if(BusinessEvent.class.equals(obj.getClass())){
+				BusinessEvent event = (BusinessEvent) args[0];
+				EventBus bus = (EventBus) point.getTarget();
+				event.setEventCode(bus.identifier());
+			}
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.event;
+
+import java.util.HashMap;
+import java.util.Map;
+/**
+ * 业务事件builder
+ * @author Stephen
+ */
+public class EventBuilder {
+	
+	private BusinessEvent event;
+	
+	private EventBuilder(){
+		
+	}
+	
+	public static EventBuilder newEvent(Object target){
+		EventBuilder builder = new EventBuilder();
+		builder.event = new BusinessEvent(target,System.currentTimeMillis());
+		return builder;
+	}
+	
+	public static EventBuilder newEvent(Object target,String code){
+		EventBuilder builder = new EventBuilder();
+		builder.event = new BusinessEvent(target,System.currentTimeMillis());
+		builder.event.setEventCode(code);
+		return builder;
+	}
+	
+	public EventBuilder putEnv(String name,Object value){
+		this.getEnvMap().put(name, value);
+		return this;
+	}
+	
+	public EventBuilder putEnvs(Map<String,Object> envs){
+		this.getEnvMap().putAll(envs);
+		return this;
+	}
+	
+	public EventBuilder putActs(Long [] acts){
+		this.event.setActs(acts);
+		return this;
+	}
+	
+	public BusinessEvent build(){
+		return this.event;
+	}
+	
+	private Map<String,Object> getEnvMap(){
+		if(event.getEnv()==null){
+			synchronized (event) {
+				if(event.getEnv()==null){
+					event.setEnv(new HashMap<String,Object>());
+				}
+			}
+		}
+		return event.getEnv();
+	}
+}

+package cn.runsa.crmapp.base.event;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.dom4j.Document;
+import org.dom4j.Element;
+import org.dom4j.io.SAXReader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.io.ClassPathResource;
+
+import cn.runsa.crmapp.base.utils.SpringUtils;
+
+import com.google.common.eventbus.EventBus;
+
+/**
+ * Build EventBus<br>
+ * 一个id，对应唯 一 一 个EventBus
+ * 
+ * @author Stephen
+ *
+ */
+public class EventBusBuilder {
+	
+	private final static Logger log = LoggerFactory.getLogger(EventBusBuilder.class);
+
+	private static final Map<String, EventBus> list = new HashMap<String, EventBus>();
+
+	static {
+		init();
+	}
+
+	/**
+	 * 获取命名EventBus
+	 * 
+	 * @param identifier
+	 * @return
+	 */
+	public static EventBus named(String identifier) {
+		EventBus eventBus = null;
+		if (list.containsKey(identifier)) {
+			eventBus = list.get(identifier);
+			if (eventBus != null)
+				return eventBus;
+		}
+		eventBus = new EventBus(identifier);
+		list.put(identifier, eventBus);
+		return eventBus;
+	}
+
+	/**
+	 * 读取配置，初始化
+	 */
+	@SuppressWarnings("unchecked")
+	public static void init() {
+		SAXReader reader = new SAXReader();
+		InputStream in = null;
+		try {
+			in = new ClassPathResource("event/business_event.xml").getInputStream();
+			Document doc = reader.read(in);
+			Element root = doc.getRootElement();
+			//event element
+			List<Element> events = root.elements("event");
+			for (Element ele : events) {
+				//event id
+				String name = ele.attributeValue("id").trim();
+				EventBus bus = new EventBus(name);
+				Element ls = ele.element("listeners");
+				if (ls != null) {
+					List<Element> list = ls.elements("listener");
+					if (list != null && list.size() > 0) {
+						List<Listener> listeners = new ArrayList<Listener>();
+						for (Element lis : list) {
+							String clz = lis.attributeValue("class");
+							String priority = lis.attributeValue("priority");
+							String async = lis.attributeValue("async");
+							if (StringUtils.isNotBlank(clz)) {
+								Listener listner = new Listener();
+								listner.setClz(clz.trim());
+								if (StringUtils.isBlank(async)) {
+									listner.setAsync(false);
+								} else {
+									listner.setAsync("true".equalsIgnoreCase(async.trim()));
+								}
+								if (StringUtils.isNotBlank(priority)) {
+									listner.setPriority(Integer.parseInt(priority.trim()));
+								}
+								listeners.add(listner);
+							}
+						}
+						if (listeners.size() > 0) {
+							Collections.sort(listeners);
+							for (Listener l : listeners) {
+								try{
+									bus.register(SpringUtils.getBean(Class.forName(l.getClz())));
+								}catch(Exception e){
+									log.error("load class error", e);
+								}
+								
+							}
+						}
+					}
+				}
+				list.put(name, bus);
+			}
+
+		} catch (Exception e) {
+			log.error("init event bus builder throw an exception", e);
+		}finally{
+			IOUtils.closeQuietly(in);
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.event;
+/**
+ * @author Stephen
+ */
+public class Listener implements Comparable<Listener>{
+	
+	private String clz;
+	
+	private int priority;
+	
+	private boolean async;
+
+	public String getClz() {
+		return clz;
+	}
+
+	public void setClz(String clz) {
+		this.clz = clz;
+	}
+
+	public int getPriority() {
+		return priority;
+	}
+
+	public void setPriority(int priority) {
+		this.priority = priority;
+	}
+
+	public boolean isAsync() {
+		return async;
+	}
+
+	public void setAsync(boolean async) {
+		this.async = async;
+	}
+
+	@Override
+	public int compareTo(Listener o) {
+		if(o==null){
+			return -1;
+		}
+		if(this==o){
+			return 0;
+		}
+		if(this.priority>o.priority){
+			return -1;
+		}else if(this.priority<o.priority){
+			return 1;
+		}else{
+			return 0;
+		}
+	}
+	
+}

+package cn.runsa.crmapp.base.event;
+
+import cn.runsa.crmapp.base.event.exception.BusinessEventException;
+/**
+ * 简单实现的eventHandler,用户可以直接继承
+ * @author Stephen
+ *
+ */
+public abstract class SimpleBusinessEventHandler extends AbstractBusinessEventHandler{
+
+	@Override
+	public boolean preHandle(BusinessEvent event) {
+		return true;
+	}
+
+	/**
+	 * 只是把exception记录下来
+	 */
+	@Override
+	public void postHandle(BusinessEvent event, BusinessEventException e) {
+		if(e!=null){
+			e.printStackTrace();
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.event.exception;
+
+public class BusinessEventException extends Exception {
+
+	private static final long serialVersionUID = -97726556007905578L;
+
+	public BusinessEventException() {
+		super();
+	}
+
+	public BusinessEventException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public BusinessEventException(String message) {
+		super(message);
+	}
+
+	public BusinessEventException(Throwable cause) {
+		super(cause);
+	}
+}

+package cn.runsa.crmapp.base.excel.converter;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import cn.runsa.crmapp.base.excel.core.Converter;
+
+/**
+ * @author Stephen
+ */
+public class BooleanConverter implements Converter<Boolean>{
+
+	private static final Set<String> trueValues = new HashSet<String>(4);
+
+	private static final Set<String> falseValues = new HashSet<String>(4);
+
+	static {
+		trueValues.add("true");
+		trueValues.add("on");
+		trueValues.add("yes");
+		trueValues.add("1");
+		trueValues.add("是");
+
+		falseValues.add("false");
+		falseValues.add("off");
+		falseValues.add("no");
+		falseValues.add("0");
+		trueValues.add("否");
+	}
+
+	@Override
+	public Boolean convert(String source){
+		String value = source.trim();
+		if ("".equals(value)) {
+			return null;
+		}
+		value = value.toLowerCase();
+		if (trueValues.contains(value)) {
+			return Boolean.TRUE;
+		}
+		else if (falseValues.contains(value)) {
+			return Boolean.FALSE;
+		}
+		else {
+			throw new IllegalArgumentException(source+"无法判断是或否");
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.excel.converter;
+
+import java.text.ParseException;
+import java.util.Date;
+
+import org.apache.commons.lang3.time.DateUtils;
+import org.apache.poi.ss.usermodel.DateUtil;
+
+import cn.runsa.crmapp.base.excel.core.Converter;
+
+/**
+ * @author Stephen
+ */
+public class DateConverter implements Converter<Date> {
+
+	private String defaultPattern = "yyyy-MM-dd";
+
+	private String[] acceptPatterns = new String[] {"yyyy-MM-dd HH:mm:ss"};
+	
+	public DateConverter(){
+		super();
+	}
+	
+	public DateConverter(String pattern){
+		this(pattern,null);
+	}
+	
+	public DateConverter(String pattern,String [] accepts){
+		super();
+		if(pattern==null){
+			this.defaultPattern=pattern;
+		}
+		if(accepts!=null&&accepts.length>0){
+			this.acceptPatterns = accepts;
+		}
+	}
+
+	@Override
+	public Date convert(String source){
+		Date date=null;
+		String value = source.trim();
+		if ("".equals(value)) {
+			return null;
+		}
+		if(source.matches("^\\d+\\.\\d+$")){
+			double dt = Double.parseDouble(source);
+			date = DateUtil.getJavaDate(dt);
+			return date;
+		}
+		try{
+			date=DateUtils.parseDate(source,defaultPattern);
+			if(date==null){
+				date=DateUtils.parseDate(source,acceptPatterns);
+			}
+		}catch(ParseException e){
+			throw new IllegalArgumentException(source+"无法转换为日期");
+		}
+		
+		return date;
+	}
+
+}

+package cn.runsa.crmapp.base.excel.converter;
+
+import org.springframework.util.NumberUtils;
+
+import cn.runsa.crmapp.base.excel.core.Converter;
+
+/**
+ * @author Stephen
+ * 数字转换器
+ */
+public class NumberConverter<T extends Number> implements Converter<T>{
+	
+	private final Class<T> targetType;
+	
+	public NumberConverter(Class<T> targetType){
+		this.targetType = targetType;
+	}
+
+	@Override
+	public T convert(String source) {
+		if (source.length() == 0) {
+			return null;
+		}
+		try{
+			return NumberUtils.parseNumber(source, this.targetType);
+		}catch(Exception e){
+			e.printStackTrace();
+			throw new IllegalArgumentException(source+"无法转换为数字");
+		}
+		
+	}
+
+}

+package cn.runsa.crmapp.base.excel.core;
+/**
+ * @author Stephen
+ */
+public interface ConvertService {
+	
+	boolean canConvert(Class<?> targetType);
+	
+	<T> T convert(String source, Class<T> targetType);
+
+}

+package cn.runsa.crmapp.base.excel.core;
+/**
+ * 类型转换器
+ * @author Stephen
+ */
+public interface Converter<T> {
+	
+	T convert(String source);
+
+}

+package cn.runsa.crmapp.base.excel.core;
+
+/**
+ * 注册类型转换
+ * @author Stephen
+ */
+public interface ConverterRegistry {
+
+	<T> void addConverter(Class<T> type,Converter<T> converter);
+
+	void removeConvertible(Class<?> type);
+
+}

+package cn.runsa.crmapp.base.excel.core;
+/**
+ * @author Stephen
+ */
+public class DBExcelSchema {
+
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.util.Map;
+import java.util.regex.Pattern;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+/**
+ * excel的列
+ * @author Stephen
+ * @version 1.0
+ */
+public class ExcelCol implements Comparable<ExcelCol>{
+	
+	private Class<?> type;
+
+	private String code;//name;
+
+	private String name;//title;
+	/**
+	 * 排序
+	 */
+	private Integer sortCode = 0;
+	private boolean nullable = true;
+	private Integer maxLength = -1;
+	private Integer minLength = 0;
+	/**
+	 * 考虑到有可能做维护界面，预留字符串pattern
+	 */
+	private String pattern;
+	/**
+	 * 编译后的pattern
+	 */
+	private Pattern compiledPattern;
+
+	private Map<String, Object> items; //下拉后的选项值.数据来源于code_list 的值
+	
+	public Class<?> getType() {
+		return type;
+	}
+
+	public void setType(Class<?> type) {
+		this.type = type;
+	}
+
+
+
+	public String getCode() {
+		return code;
+	}
+
+	public void setCode(String code) {
+		this.code = code;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public Integer getSortCode() {
+		return sortCode;
+	}
+	public void setSortCode(Integer sortCode) {
+		this.sortCode = sortCode;
+	}
+
+	public boolean isNullable() {
+		return nullable;
+	}
+
+	public void setNullable(boolean nullable) {
+		this.nullable = nullable;
+	}
+
+	public Integer getMaxLength() {
+		return maxLength;
+	}
+
+	public void setMaxLength(Integer maxLength) {
+		this.maxLength = maxLength;
+	}
+
+	public Integer getMinLength() {
+		return minLength;
+	}
+
+	public void setMinLength(Integer minLength) {
+		this.minLength = minLength;
+	}
+
+	public String getPattern() {
+		return pattern;
+	}
+
+	public void setPattern(String pattern) {
+		this.pattern = pattern;
+	}
+
+	public Pattern getCompiledPattern() {
+		return compiledPattern;
+	}
+
+	public void setCompiledPattern(Pattern compiledPattern) {
+		this.compiledPattern = compiledPattern;
+	}
+
+	public Map<String, Object> getItems() {
+		return items;
+	}
+
+	public void setItems(Map<String, Object> items) {
+		this.items = items;
+	}
+
+	@Override
+	public int compareTo(ExcelCol o) {
+		if(o ==null){
+			return 1;
+		}else{
+			return this.sortCode-o.sortCode;
+		}
+	}
+
+	@Override
+	public String toString() {
+		return ToStringBuilder.reflectionToString(this);
+	}
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * excel数据获取后续的处理,如
+ * 每次读几行,读完之后存入临时表
+ * 调用存储过程等
+ * @author Stephen
+ */
+public abstract class ExcelDataHandler {
+	/**
+	 * 每次获取行数的默认数目
+	 */
+	private static final int DEFAULT_SIZE = 100;
+	
+	private static final int MAX_ERROR_SIZE = 100; //最大错误行数,超过此行数,不需要处理,返回错误结果
+	
+	private static final int MAX_SIZE = 10000;   //最大处理行数
+	/**
+	 * 每次获取的行数
+	 */
+	private int sizeOneTime;
+	private int maxErrRow;
+	/**
+	 * excel数据处理的上下文环境变量
+	 */
+	private Map<String,Object> excelDataContext = new HashMap<String,Object>();
+	
+	protected ExcelDataHandler(){
+		this(null);
+	}
+	
+	protected ExcelDataHandler(Map<String,Object> context){
+		super();
+		this.sizeOneTime = DEFAULT_SIZE;
+		this.maxErrRow = MAX_ERROR_SIZE;
+		if(context!=null){
+			this.excelDataContext = context;
+		}else{
+			this.excelDataContext = new HashMap<String,Object>();
+		}
+	}
+	
+	protected ExcelDataHandler(Map<String,Object> context, int maxRow, int maxErrRow){
+		super();
+		if(maxRow>0&&maxRow<=MAX_SIZE){
+			this.sizeOneTime = maxRow;
+		}else{
+			this.sizeOneTime = DEFAULT_SIZE;
+		}
+		if(maxErrRow>0&&maxErrRow<=MAX_ERROR_SIZE){
+			this.maxErrRow = maxErrRow;
+		}else{
+			this.maxErrRow = MAX_ERROR_SIZE;
+		}
+		if(context!=null){
+			this.excelDataContext = context;
+		}else{
+			this.excelDataContext = new HashMap<String,Object>();
+		}
+		
+	}
+	
+	protected void putData(String key,Object val){
+		excelDataContext.put(key, val);
+	}
+	
+	protected void putDatas(Map<String,Object> vals){
+		excelDataContext.putAll(vals);
+	}
+	
+	public int getSizeOneTime() {
+		return sizeOneTime;
+	}
+	
+	public Map<String, Object> getExcelDataContext() {
+		return excelDataContext;
+	}
+
+	/**
+	 * 处理获取的数据
+	 * @param schema 从db中获取的excel结构
+	 * @param groupId 组id,用于标记是这个用户操作的(用于多用户操作的区分)
+	 * @param datas 获取的数据集
+	 */
+	public abstract void dataFetched(ExcelSchema schema, String groupId, List<Map<String, Object>> datas);
+	
+	/**
+	 * excel数据读取完成
+	 * @param schema 从db中获取的excel结构
+	 * @param headSchema 从excel中获取的结构,和schema的区别在于: schema是预定义格式,headSchema是真实格式
+	 * @param groupId 组id,用于标记是这个用户操作的(用于多用户操作的区分)
+	 * @param 废弃 errorProcessor excel错误处理器 已放在DefaultSheetContentsHandler中处理
+	 * @return 返回失败的数据条数
+	 */
+	public abstract ExcelResult dataFinish(ExcelSchema schema, Map<String, ExcelCol> headSchema, String groupId);
+	
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.xssf.streaming.SXSSFWorkbook;
+import org.apache.poi.xssf.usermodel.XSSFClientAnchor;
+import org.apache.poi.xssf.usermodel.XSSFComment;
+import org.apache.poi.xssf.usermodel.XSSFDrawing;
+import org.apache.poi.xssf.usermodel.XSSFRichTextString;
+
+public class ExcelErrorProcessor{
+	
+	private final Map<String,Integer> headIndex;
+	private final SXSSFWorkbook workbook;
+	private final Sheet errorSheet;
+	// 创建绘图对象
+	XSSFDrawing p ;
+	private volatile int next = 0;
+	
+	public ExcelErrorProcessor(Map<String, ExcelCol> headSchema){
+		headIndex = new HashMap<String,Integer>(headSchema.size());
+		for(String str:headSchema.keySet()){
+			headIndex.put(headSchema.get(str).getCode(),HSSFSheetHandler.toNumber(str)); //存入的是code,待定 zwj,数据存的是位置
+		}
+		headIndex.put("RAWREF", headSchema.size());
+		headIndex.put("ERRMSG", headSchema.size()+1);
+		workbook = new SXSSFWorkbook(100);
+		workbook.setCompressTempFiles(true);
+		errorSheet = workbook.createSheet("错误信息");
+		p = (XSSFDrawing) errorSheet.createDrawingPatriarch();
+		Row row = errorSheet.createRow(next++);
+		Cell cell =null;
+		//因为现在不读取原数据,所以去掉
+//		for(ExcelCol col:headSchema.values()){
+//			Integer theIndex = headIndex.get(col.getCode());
+//			if(theIndex!=null){
+//				cell = row.createCell(theIndex);
+//				cell.setCellValue(col.getName());
+//				
+//			}
+//		}
+//		int start = headSchema.size();
+		int start = 0;
+		cell = row.createCell(start);
+		cell.setCellValue("原excel位置");
+		cell = row.createCell(start+1);
+		cell.setCellValue("报错信息");
+		
+	}
+	
+	//ExcelResult result
+	public void flushErrors(List<Map<String,Object>> errorRows){
+		if(errorRows!=null&&errorRows.size()>0){
+			for(Map<String,Object> rowVal:errorRows){
+				Row row = errorSheet.createRow(next++);
+				Cell cell =null;
+				for(String name:rowVal.keySet()){
+					Integer theIndex = headIndex.get(name);
+					if(theIndex!=null){
+						cell = row.createCell(theIndex);
+						Object val = rowVal.get(name);
+						if(val==null){
+							cell.setCellValue("");
+						}else{
+							cell.setCellValue(val.toString());
+						}
+					}
+				}
+			}
+		}
+	}
+	
+	public void flushErrors(ExcelResult result){
+		Map<String,String> errMsgMap =  result.getErrMsgMap();
+		List<Map<String, Object>> errRows = result.getErrRows();
+		Cell cell =null;
+
+		for(Map<String, Object> map: errRows){
+			Row row = errorSheet.createRow(next++);
+			for(Map.Entry<String, Object> entry : map.entrySet()){
+				Integer theIndex = headIndex.get(entry.getKey());
+				if(theIndex!=null){
+					cell = row.createCell(theIndex);
+					Object val = entry.getValue();
+					if(val==null){
+						cell.setCellValue("");
+					}else{
+						cell.setCellValue(val.toString());
+					}
+				}
+			}
+			
+		}
+		
+		for(Map.Entry<String, String> entry:errMsgMap.entrySet()){
+			Row row = errorSheet.createRow(next++);
+			cell = row.createCell(0);
+			cell.setCellValue(entry.getKey());
+			cell = row.createCell(1);
+			cell.setCellValue(entry.getValue());
+		}
+//		cell.setCellComment(comment);
+//		SXSSFComment
+		
+//		
+//		 // 前四个参数是坐标点,后四个参数是编辑和显示批注时的大小.
+//        XSSFComment comment = p.createCellComment(new XSSFClientAnchor(0, 0, 0,
+//                0, (short) 3, 3, (short) 5, 6));
+//        // 输入批注信息
+//        comment.setString(new XSSFRichTextString("这是批注内容!"));
+//        comment.setString(new XSSFRichTextString("这是批注内容!"));
+//        // 添加作者,选中B5单元格,看状态栏
+//        comment.setAuthor("toad");
+//        // 将批注添加到单元格对象中
+//        if(cell != null){
+//        	cell.setCellComment(comment);
+//        }
+		  
+	}
+	
+	public void flushErrors2Excel(ExcelResult result, String groupId){
+		flushErrors(result);
+		String filePath  =result.getFilePath();
+		String fileName  =result.getFileName();
+		File file = new File(filePath,fileName);
+		write(file);
+		
+	}
+	
+	/**
+	 * 请用OutputStream接收SXSSFWorkbook
+	 * eg: 
+	 * OutputStream ouputStream = response.getOutputStream(); 
+	 * workbook.write(stream);  
+	 * @param result
+	 * @param groupId
+	 * @return excel格式对象
+	 */
+	public SXSSFWorkbook flushErrors(ExcelResult result, String groupId){
+		flushErrors(result);
+		return workbook;
+	}
+	
+	
+	void write(File file){
+		FileOutputStream stream =null;
+		try {
+			stream = new FileOutputStream(file);
+			stream.flush();
+			workbook.write(stream);
+			stream.close();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}finally{
+			IOUtils.closeQuietly(stream);
+		}
+	}
+	
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.commons.lang3.builder.ToStringBuilder;
+
+/**
+ * excel导入结果
+ * @author Stephen
+ */
+public class ExcelResult {
+
+	private Integer total;  //总行数
+	
+	private Integer error;  //错误行数
+	
+	private String fileName; //错误的文件名称
+	private String filePath; //错误的文件名称
+	
+	private String uuid;   //不知道
+	
+	private Map<String,String> errMsgMap;  //错误消息,应该是需要写到文件中的
+	
+	//是不是需要存错误行数
+	private List<Map<String, Object>> errRows = new ArrayList<Map<String, Object>>();
+	
+
+	public Integer getTotal() {
+		return total;
+	}
+
+	public void setTotal(Integer total) {
+		this.total = total;
+	}
+
+	public Integer getError() {
+		return error;
+	}
+
+	public void setError(Integer error) {
+		this.error = error;
+	}
+
+	public String getUuid() {
+		return uuid;
+	}
+
+	public void setUuid(String uuid) {
+		this.uuid = uuid;
+	}
+
+	public Map<String, String> getErrMsgMap() {
+		return errMsgMap;
+	}
+
+	public void setErrMsgMap(Map<String, String> errMsgMap) {
+		this.errMsgMap = errMsgMap;
+	}
+
+	public List<Map<String, Object>> getErrRows() {
+		return errRows;
+	}
+
+	public void setErrRows(List<Map<String, Object>> errRows) {
+		this.errRows = errRows;
+	}
+	
+	public String getFileName() {
+		return fileName;
+	}
+
+	public void setFileName(String fileName) {
+		this.fileName = fileName;
+	}
+
+	public String getFilePath() {
+		return filePath;
+	}
+
+	public void setFilePath(String filePath) {
+		this.filePath = filePath;
+	}
+
+	@Override
+	public String toString() {
+		return ToStringBuilder.reflectionToString(this);
+	}
+
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.util.List;
+
+public class ExcelSchema {
+	
+	private String code;
+	
+	private String title;
+	
+	private String targetTableName;
+	
+	private List<ExcelCol> columns;
+	
+	public String getCode() {
+		return code;
+	}
+
+	public void setCode(String code) {
+		this.code = code;
+	}
+
+	public String getTitle() {
+		return title;
+	}
+
+	public void setTitle(String title) {
+		this.title = title;
+	}
+
+	public List<ExcelCol> getColumns() {
+		return columns;
+	}
+
+	public void setColumns(List<ExcelCol> columns) {
+		this.columns = columns;
+	}
+
+	public String getTargetTableName() {
+		return targetTableName;
+	}
+
+	public void setTargetTableName(String targetTableName) {
+		this.targetTableName = targetTableName;
+	}
+	
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang.StringUtils;
+import org.apache.poi.hssf.usermodel.HSSFSheet;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.openxml4j.opc.OPCPackage;
+import org.apache.poi.openxml4j.opc.PackageAccess;
+import org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable;
+import org.apache.poi.xssf.eventusermodel.XSSFReader;
+import org.apache.poi.xssf.model.StylesTable;
+import org.dom4j.Document;
+import org.dom4j.Element;
+import org.dom4j.io.SAXReader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.xml.sax.InputSource;
+import org.xml.sax.XMLReader;
+import org.xml.sax.helpers.XMLReaderFactory;
+
+import cn.runsa.crmapp.base.excel.exception.ExcelException;
+import cn.runsa.crmapp.base.excel.support.DefaultSheetContentsHandler;
+
+/**
+ * excel处理工具类
+ * @author Stephen
+ */
+public class ExcelUtils {
+	
+	private static final Logger log = LoggerFactory.getLogger(ExcelUtils.class);
+	
+	private static final SAXReader saxReader;
+
+	static {
+		saxReader = new SAXReader();
+		saxReader.setIncludeExternalDTDDeclarations(false);
+		saxReader.setIncludeInternalDTDDeclarations(false);
+		saxReader.setValidation(false);
+		saxReader.setIgnoreComments(true);
+		saxReader.setStripWhitespaceText(true);
+	}
+	//03 excel处理器
+	private static final HSSFSheetHandler handler = new HSSFSheetHandler();
+	
+	public static ExcelResult readExcel(File file, ExcelSchema schema,ExcelDataHandler dataHandler)throws ExcelException{
+		//检查文件
+		if (!file.exists()) {
+			throw new ExcelException("文件不存在");
+		}
+		if (!file.canRead()) {
+			throw new ExcelException("文件不可读");
+		}
+		//检查文件类型
+		String fileName = file.getName();
+		boolean isE2003 = false;
+		if (StringUtils.isBlank(fileName)) {
+			throw new ExcelException("无效的文件名，文件名不能为空");
+		} else if (fileName.endsWith("xlsx")) {
+			isE2003 = false;
+		} else if (fileName.endsWith("xls")) {
+			isE2003 = true;
+		} else {
+			throw new ExcelException("无效的文件类型");
+		}
+		//检查excel模型
+		if (schema == null) {
+			throw new ExcelException("缺少excel表头信息,请配置数据库");
+		}
+		if (dataHandler == null) {
+			throw new ExcelException("缺少excel处理方法");
+		}
+		SheetContentsHandler processor = new DefaultSheetContentsHandler(dataHandler, schema);
+		if (isE2003) {
+			FileInputStream stream = null;
+			try {
+				stream = new FileInputStream(file);
+				//poi 2003 HSSFWorkbook
+				HSSFWorkbook workbook = new HSSFWorkbook(stream);
+				//目前仅处理第一个sheet
+				HSSFSheet sheet = workbook.getSheetAt(0);
+				handler.parse(processor,sheet);
+				return processor.finish();
+			}catch(ExcelException ee) {
+				throw ee;
+			}catch (Exception e) {
+				log.error("excel处理失败", e);
+				throw new ExcelException("excel处理失败");
+			} finally {
+				IOUtils.closeQuietly(stream);
+			}
+		} else {
+			OPCPackage pkg = null;
+			InputStream sheet = null;
+			try {
+				pkg = OPCPackage.open(file, PackageAccess.READ);
+				XSSFReader reader = new XSSFReader(pkg);
+				StylesTable style = reader.getStylesTable();
+				XMLReader parser = XMLReaderFactory.createXMLReader("org.apache.xerces.parsers.SAXParser");
+				//字符串常量池
+				ReadOnlySharedStringsTable stringValueHandler = new ReadOnlySharedStringsTable(pkg);
+				XSSFSheetXMLHandler xmlHandler = new XSSFSheetXMLHandler(style,stringValueHandler, processor);
+				parser.setContentHandler(xmlHandler);
+				Document doc = saxReader.read(reader.getWorkbookData());
+				Element root = doc.getRootElement();
+				Element sheets = root.element("sheets");
+				Element thisSheet = sheets.element("sheet");
+				String id = thisSheet.attributeValue("id");
+				sheet = reader.getSheet(id);
+				InputSource sheetSource = new InputSource(sheet);
+				parser.parse(sheetSource);
+				return processor.finish();
+			}catch(ExcelException ee) {
+				throw ee;
+			} catch (Exception e) {
+				log.error("excel处理失败", e);
+				throw new ExcelException("excel处理失败");
+			} finally {
+				IOUtils.closeQuietly(sheet);
+				//todo
+				try {
+					pkg.close();
+				} catch (IOException e) {
+					// TODO Auto-generated catch block
+					e.printStackTrace();
+				}
+			}
+		}
+		
+	}
+	
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.math.BigDecimal;
+import java.util.Iterator;
+
+import org.apache.poi.hssf.usermodel.HSSFCell;
+import org.apache.poi.hssf.usermodel.HSSFRow;
+import org.apache.poi.hssf.usermodel.HSSFSheet;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.CellStyle;
+import org.apache.poi.ss.usermodel.DateUtil;
+
+import cn.runsa.crmapp.base.excel.exception.ExcelException;
+/**
+ * 处理excel97-03版本
+ * @author stephen
+ */
+public class HSSFSheetHandler {
+
+	private static final char[] digits = { 'A', 'B', 'C', 'D', 'E', 'F', 'G','H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T','U', 'V', 'W', 'X', 'Y', 'Z' };
+
+	/**
+	 * 解析excel文件
+	 * @throws ExcelException
+	 */
+	public void parse(SheetContentsHandler contentHandler, HSSFSheet sheet) throws ExcelException {
+		int first = sheet.getFirstRowNum();
+		int last = sheet.getLastRowNum();
+		if (last - first < 1)
+			throw new ExcelException("excel内容为空");
+		for (int i = first; i <= last; i++) {
+			HSSFRow row = sheet.getRow(i);
+			//开始行
+			contentHandler.startRow(i);
+			Iterator<Cell> cells = row.cellIterator();
+			while (cells.hasNext()) {
+				HSSFCell cell = (HSSFCell) cells.next();
+				String cellRef = getABCNumber(cell.getColumnIndex());
+				String cellVal = null;
+				int type = cell.getCellType();
+				//不处理公式，error类型
+				switch (type) {
+				case Cell.CELL_TYPE_BOOLEAN:
+					cellVal = String.valueOf(cell.getBooleanCellValue());
+					break;
+				case Cell.CELL_TYPE_NUMERIC:
+					//如果是时间
+					if (isDateFormat(cell)) {
+						cellVal = SheetContentsHandler.DATE_PREFIX+cell.getDateCellValue().getTime();
+					} else {
+						BigDecimal bd = new BigDecimal(cell.getNumericCellValue());
+						cellVal = bd.toPlainString();
+					}
+					break;
+				case Cell.CELL_TYPE_STRING:
+					cellVal = cell.getStringCellValue();
+					break;
+				default:
+					break;
+				}
+				contentHandler.cell(cellRef, cellVal);
+			}
+			contentHandler.endRow();
+		}
+	}
+	
+	/**
+	 * 将列号转换为excel统一格式，如A,B,AB等
+	 * @param number
+	 * @return
+	 */
+	public static String getABCNumber(int number) {
+		if (number < 26) {
+			return String.valueOf(digits[number]);
+		} else {
+			StringBuilder sb = new StringBuilder();
+			do {
+				int a = number % 26;
+				sb.append(digits[a]);
+				number /= 26;
+				number--;
+			} while (number > 25);
+			sb.append(digits[number]);
+			return sb.reverse().toString();
+		}
+	}
+	/**
+	 * 将excel统一列号转换为十进制数
+	 * @param excelNum
+	 * @return
+	 */
+	public static int toNumber(String excelNum) {
+		byte[] abcs = excelNum.getBytes();
+		int number = 0;
+		if(abcs.length == 1){
+			number = index(abcs[0]);
+		}else{
+			int total = abcs.length-1;
+			for(int i = 0;i<total;i++){
+				number=(int) (number+(index(abcs[i])+1)*Math.pow(26, total-i));
+			}
+			number+=index(abcs[total]);
+		}
+		return number;
+	}
+	
+	/**
+	 * 给定字符的序号
+	 * @param abc
+	 * @return
+	 */
+	private static int index(byte abc) {
+		return abc-65;
+	}
+	/**
+	 * 判断是否是时间
+	 * @param cell
+	 * @return
+	 */
+	private boolean isDateFormat(Cell cell) {
+		if (cell == null)
+			return false;
+		boolean bDate = false;
+		double d = cell.getNumericCellValue();
+		if (DateUtil.isValidExcelDate(d)) {
+			CellStyle style = cell.getCellStyle();
+			if (style == null)
+				return false;
+			int i = style.getDataFormat();
+			bDate = i >= 0x0e && i <= 0x24;
+		}
+		return bDate;
+	}
+	
+}

+package cn.runsa.crmapp.base.excel.core;
+/**
+ * 内部枚举，标识类
+ * @author Stephen
+ */
+public class InnerEnum {
+
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import cn.runsa.crmapp.base.excel.exception.ExcelException;
+
+
+/**
+ * @author stephen
+ * excel内容处理器,事件驱动
+ */
+public interface SheetContentsHandler {
+	
+	public static final String DATE_PREFIX = "@Date";
+	
+	/**
+	 * 开始一行
+	 * @param rowNum 行号，0开始
+	 */
+	void startRow(int rowNum);
+	/**
+	 * 行结束
+	 */
+	void endRow() throws ExcelException;
+	/**
+	 * 获取单元格
+	 * @param cellReference 单元格位置
+	 * @param formattedValue 格式化的字符串值
+	 */
+	String cell(String cellReference, String formattedValue);
+	/**
+	 * excel读取完成
+	 * @return
+	 */
+	ExcelResult finish();
+}

+package cn.runsa.crmapp.base.excel.core;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+import org.apache.poi.ss.usermodel.BuiltinFormats;
+import org.apache.poi.ss.usermodel.DateUtil;
+import org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable;
+import org.apache.poi.xssf.model.StylesTable;
+import org.apache.poi.xssf.usermodel.XSSFCellStyle;
+import org.apache.poi.xssf.usermodel.XSSFRichTextString;
+import org.xml.sax.Attributes;
+import org.xml.sax.SAXException;
+import org.xml.sax.helpers.DefaultHandler;
+
+import cn.runsa.crmapp.base.excel.exception.ExcelException;
+
+public class XSSFSheetXMLHandler extends DefaultHandler {
+	
+	enum xssfDataType {
+		BOOLEAN, ERROR, FORMULA, INLINE_STRING, SST_STRING, NUMBER;
+	}
+	//sheet样式表
+	private StylesTable stylesTable;
+	//字符串常量池
+	private ReadOnlySharedStringsTable sharedStringsTable;
+	//excel内容处理器
+	private final SheetContentsHandler output;
+
+	// V开始
+	private boolean vIsOpen;
+	// F开始
+	private boolean fIsOpen;
+	// Inline String 开始
+	private boolean isIsOpen;
+	
+	private xssfDataType nextDataType;
+
+	private short formatIndex;
+	private String formatString;
+	private String cellRef;
+
+	private StringBuffer value = new StringBuffer();
+	private StringBuffer formula = new StringBuffer();
+
+	/**
+	 * Accepts objects needed while parsing.
+	 *
+	 * @param styles
+	 *            Table of styles
+	 * @param strings
+	 *            Table of shared strings
+	 */
+	public XSSFSheetXMLHandler(StylesTable styles,ReadOnlySharedStringsTable strings,SheetContentsHandler sheetContentsHandler) {
+		this.stylesTable = styles;
+		this.sharedStringsTable = strings;
+		this.output = sheetContentsHandler;
+		this.nextDataType = xssfDataType.NUMBER;
+	}
+
+	private boolean isTextTag(String name) {
+		if ("v".equals(name)) {
+			return true;
+		}
+		if ("inlineStr".equals(name)) {
+			return true;
+		}
+		if ("t".equals(name) && isIsOpen) {
+			return true;
+		}
+		return false;
+	}
+
+	public void startElement(String uri, String localName, String name,Attributes attributes) throws SAXException {
+		if (isTextTag(name)) {
+			vIsOpen = true;
+			// Clear
+			value.setLength(0);
+		} else if ("is".equals(name)) {
+			isIsOpen = true;
+		} else if ("f".equals(name)) {
+			// Clear
+			formula.setLength(0);
+
+			//标记将要处理公式
+			if (nextDataType == xssfDataType.NUMBER) {
+				nextDataType = xssfDataType.FORMULA;
+			}
+			// 公式类型
+			String type = attributes.getValue("t");
+			if (type != null && type.equals("shared")) {
+				String ref = attributes.getValue("ref");
+				//如果有引用
+				if (ref != null) {
+					fIsOpen = true;
+				}
+			} else {
+				fIsOpen = true;
+			}
+		} else if ("row".equals(name)) {
+			//开始行
+			int rowNum = Integer.parseInt(attributes.getValue("r")) - 1;
+			output.startRow(rowNum);
+		}
+		//开始单元格
+		else if ("c".equals(name)) {
+			//默认number.
+			this.nextDataType = xssfDataType.NUMBER;
+			this.formatIndex = -1;
+			this.formatString = null;
+			cellRef = attributes.getValue("r");//.replaceAll("\\d", "");
+			String cellType = attributes.getValue("t");
+			String cellStyleStr = attributes.getValue("s");
+			if ("b".equals(cellType))
+				nextDataType = xssfDataType.BOOLEAN;
+			else if ("e".equals(cellType))
+				nextDataType = xssfDataType.ERROR;
+			else if ("inlineStr".equals(cellType))
+				nextDataType = xssfDataType.INLINE_STRING;
+			else if ("s".equals(cellType))
+				nextDataType = xssfDataType.SST_STRING;
+			else if ("str".equals(cellType))
+				nextDataType = xssfDataType.FORMULA;
+			else if (cellStyleStr != null) {
+				//带有样式的内容
+				int styleIndex = Integer.parseInt(cellStyleStr);
+				XSSFCellStyle style = stylesTable.getStyleAt(styleIndex);
+				this.formatIndex = style.getDataFormat();
+				this.formatString = style.getDataFormatString();
+				if (this.formatString == null)
+					this.formatString = BuiltinFormats.getBuiltinFormat(this.formatIndex);
+			}
+		}
+	}
+
+	public void endElement(String uri, String localName, String name)throws ExcelException,SAXException {
+		String thisStr = null;
+		//读取excel文本内容(excel以xml格式存储,会有字段标记此单元格的)
+		if (isTextTag(name)) {
+			vIsOpen = false;
+			switch (nextDataType) {
+			case BOOLEAN:
+				char first = value.charAt(0);
+				thisStr = first == '0' ? "false" : "true";
+				break;
+
+			case INLINE_STRING:
+				XSSFRichTextString rtsi = new XSSFRichTextString(value.toString());
+				thisStr = rtsi.toString();
+				break;
+
+			case SST_STRING:
+				String sstIndex = value.toString();
+				try {
+					int idx = Integer.parseInt(sstIndex);
+                    XSSFRichTextString rtss = new XSSFRichTextString(sharedStringsTable.getEntryAt(idx));
+                    thisStr = rtss.toString();
+				} catch (NumberFormatException ex) {
+					//undo
+				}
+				break;
+
+			case NUMBER:
+				String n = value.toString();
+				if (this.formatString != null) {
+					//若为日期
+					if (this.formatIndex >= 0x0e && this.formatIndex <= 0x24) {
+						Date date = DateUtil.getJavaDate(Double.parseDouble(n));
+						thisStr = SheetContentsHandler.DATE_PREFIX+date.getTime();
+					} else {
+						BigDecimal bd = new BigDecimal(n);
+						thisStr = bd.toPlainString();
+					}
+				} else
+					thisStr = n;
+				break;
+
+			default:
+				break;
+			}
+			output.cell(cellRef, thisStr);
+		} else if ("f".equals(name)) {
+			fIsOpen = false;
+		} else if ("is".equals(name)) {
+			isIsOpen = false;
+		} else if ("row".equals(name)) {
+			output.endRow();
+		}
+	}
+
+	public void characters(char[] ch, int start, int length) throws SAXException {
+		if (vIsOpen) {
+			value.append(ch, start, length);
+		}
+		if (fIsOpen) {
+			formula.append(ch, start, length);
+		}
+	}
+}

+package cn.runsa.crmapp.base.excel.exception;
+
+import org.xml.sax.SAXException;
+
+@SuppressWarnings("serial")
+/**
+ * excel处理异常
+ * @author stephen
+ */
+public class ExcelException extends SAXException {
+
+	public ExcelException() {
+		super();
+	}
+
+	public ExcelException(Exception e) {
+		super(e);
+	}
+
+	public ExcelException(String message, Exception e) {
+		super(message, e);
+	}
+
+	public ExcelException(String message) {
+		super(message);
+	}
+}

+package cn.runsa.crmapp.base.excel.support;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Random;
+import java.util.Set;
+import java.util.UUID;
+
+import org.apache.commons.lang3.StringUtils;
+
+import cn.runsa.crmapp.base.excel.core.Converter;
+import cn.runsa.crmapp.base.excel.core.ConverterRegistry;
+import cn.runsa.crmapp.base.excel.core.ExcelCol;
+import cn.runsa.crmapp.base.excel.core.ExcelDataHandler;
+import cn.runsa.crmapp.base.excel.core.ExcelErrorProcessor;
+import cn.runsa.crmapp.base.excel.core.ExcelResult;
+import cn.runsa.crmapp.base.excel.core.ExcelSchema;
+import cn.runsa.crmapp.base.excel.core.SheetContentsHandler;
+import cn.runsa.crmapp.base.excel.exception.ExcelException;
+
+/**
+ * @author Stephen
+ */
+public class DefaultSheetContentsHandler implements SheetContentsHandler,ConverterRegistry{
+	
+	//类型转换
+	private static GeneralConvertService convertService = new GeneralConvertService();
+	//处理获取的数据
+	private ExcelDataHandler dataHandler;
+	
+	private volatile boolean isHead = true;
+	
+	private volatile boolean isError = false;
+	private volatile boolean isRowError = false; //废弃,直接用current.keySet().containsAll(requiredCols)
+	
+	private volatile String errMsg;
+	private Map<String,String> errMsgMap = new HashMap<String,String>();
+	
+	private volatile int totalRow = 0; //总行数
+//	private volatile int errorRow = 0; //错误行数
+	//全部列 废弃,用schema.getColumns()获取 ,同时为了和headSchema做区别  2016-05-16
+	//	private volatile List<ExcelCol> thead;  //excel的表头,从db中获取
+	
+	//sheet页的code,以此code,就可以推算出需要插入的表和存储过程
+	//eg: code 为user,则插入的表为user_excel,存储过程为: pro_user_excel(写法待定,但是肯定可以推导出) 废弃
+	//private String sheetCode; //废弃 ,用schema.getCode() 代替 -- 2016-05-16
+	
+	//从db中获取的excel表结构.可能会和真实的excel不一致,因为有的列不是必填的
+	private ExcelSchema schema;
+	
+	private Map<String, ExcelCol> headSchema; //从excel中获取的表头,和db中获取的表头不一定对应
+	
+	private final Set<String> requiredCols = new HashSet<String>();
+	//当前行数据
+	private Map<String, Object> current;
+	//页中行数据
+	private final List<Map<String, Object>> rows ;
+	//页中行数据
+	private final List<Map<String, Object>> errRows= new ArrayList<Map<String, Object>>();
+	
+	ExcelErrorProcessor errorProcessor;
+	
+	//不知道原来id有什么用,准备作为group用,算了,自己定义一个吧
+//	private final String id = UUID.randomUUID().toString().replaceAll("-", "");
+	private final String groupId = (new SimpleDateFormat("yyyyMMddHHmmssSSS")).format(new Date())+ (new Random()).nextInt(9);
+	
+	
+	//zwj 引入了ExcelSchema
+//	public DefaultSheetContentsHandler(ExcelDataHandler dataHandler,List<ExcelCol> header,String sheetCode) {
+//		this.dataHandler = dataHandler;
+//		this.thead = header;
+//		this.sheetCode = sheetCode;
+//		rows = new ArrayList<Map<String, Object>>(dataHandler.getSizeOneTime());
+//	}
+	
+	public DefaultSheetContentsHandler(ExcelDataHandler dataHandler,ExcelSchema schema) {
+		this.dataHandler = dataHandler;
+//		this.thead = schema.getColumns(); 已废弃
+//		sheetCode = schema.getCode();     已废弃
+		this.schema = schema;
+		rows = new ArrayList<Map<String, Object>>(dataHandler.getSizeOneTime());
+	}
+
+	@Override
+	public void startRow(int rowNum) {
+		current = new HashMap<String, Object>();
+		isError = false;
+		isRowError = false;
+		errMsg = null;
+		if(!isHead){
+			totalRow++;
+			current.put("ROWNUM", ++rowNum);
+		}
+	}
+	/**
+	 * 表头处理
+	 * @throws ExcelException
+	 */
+	public void headRowHandle() throws ExcelException{
+
+		//列名
+		List<String> cols = new ArrayList<String>();
+		//必填列名
+		List<String> required = new ArrayList<String>();
+		for (ExcelCol col : schema.getColumns()){
+			cols.add(col.getName());
+			if (!col.isNullable()){
+				required.add(col.getName());
+				requiredCols.add(col.getCode());
+			}
+		}
+		Collection<Object> row = current.values();
+		//出现超出范围的列
+		if(!cols.containsAll(row)){
+			throw new ExcelException("表头超出范围");
+		}
+		//必填的列未出现
+		if(!row.containsAll(required)){
+			throw new ExcelException("缺少必填表头");
+		}
+		headSchema = new HashMap<String,ExcelCol>(current.size());
+		for(String ref:current.keySet()){
+			String title = current.get(ref).toString();
+			for(ExcelCol col :schema.getColumns()){
+				if(title.equals(col.getName())){
+					headSchema.put(ref, col);
+					break;
+				}
+			}
+		}
+		
+		errorProcessor = new ExcelErrorProcessor(headSchema);
+		
+		for (ExcelCol col : headSchema.values()){
+			Class<?> type = col.getType();
+			if(!List.class.equals(type)&&!String.class.equals(type)){
+				if(!convertService.canConvert(type)){
+					throw new ExcelException("缺少类型转换器");
+				}
+			}
+		}
+	}
+
+	@Override
+	public void endRow() throws ExcelException {
+		if(isHead){
+			headRowHandle();
+			isHead = false;
+		}else{
+			if(isRowError){
+				System.out.println("行格式错误");
+				errRows.add(current);
+			}else if(!current.keySet().containsAll(requiredCols)){
+				System.out.println("行缺少必填项");
+				errRows.add(current);
+			}else{
+				rows.add(current);
+				if(rows.size()==dataHandler.getSizeOneTime()){
+					dataHandler.dataFetched(schema, groupId, rows);
+					rows.clear();
+				}
+			}
+		}
+	}
+
+	@Override
+	public String cell(String cellReference, String formattedValue) {
+		String cellAbsoluteLocation = cellReference;
+		errMsg = "内容["+formattedValue+"]";
+		cellReference = cellReference.replaceAll("\\d", "");
+		if(isError){
+			return errMsg;
+		}
+		if(isHead){
+			//非空
+			if(StringUtils.isNotBlank(formattedValue)){
+				current.put(cellReference, formattedValue.trim());
+			}
+		}else{
+			ExcelCol col = headSchema.get(cellReference);
+			if(StringUtils.isNotBlank(formattedValue)){
+				
+				//没有表头，直接跳过
+				if(col == null){
+					return errMsg;
+				}
+				Class<?> type = col.getType();
+				String source = null;
+				//第一阶段 格式化验证 开始
+				//最大长度
+				if(col.getMaxLength() !=null && formattedValue.length()>col.getMaxLength()){
+					errMsg += "不符合最大长度"+col.getMinLength()+"的要求;";
+					isError = true;
+				} else 
+				//最小长度
+				if(col.getMinLength() !=null && formattedValue.length()<col.getMinLength()){
+					errMsg += "不符合最小长度"+col.getMinLength()+"的要求;";
+					isError = true;
+				}
+				//正则
+				if(col.getCompiledPattern()!=null){
+					if(!col.getCompiledPattern().matcher(formattedValue).matches()){
+						errMsg += "不符合格式规定;";
+						isError = true;
+					}
+				}
+				//第一阶段检测报告
+				if(isError){
+//					errMsgList.add(errMsg);
+					errMsgMap.put(cellAbsoluteLocation, errMsg);
+					isError = false;
+					isRowError = true;
+					return errMsg;
+				}
+				//第一阶段 格式化验证结束
+				
+				//第二阶段,数据类型转换开始
+				if(String.class.equals(type)){
+					current.put(col.getCode(), formattedValue);
+				}else if(List.class.equals(type)){
+					//如果是内部枚举
+					Object val = col.getItems().get(formattedValue.trim());
+					//参数错误
+					if(val == null){
+						errMsg += "不在可选择范围内;";
+						isError = true;
+					}else{
+						current.put(col.getCode(), val);
+					}
+				}else if(Date.class.equals(type)&&(source=formattedValue.trim()).startsWith(DATE_PREFIX)){
+					Date val = new Date(Long.parseLong(source.substring(DATE_PREFIX.length())));
+					current.put(col.getCode(), val);
+				}else{
+					try{
+						Object val = convertService.convert(formattedValue, type);
+						if(val == null){
+							isError = true;
+						}else{
+							current.put(col.getCode(),val);
+						}
+					}catch(Exception e){
+						e.printStackTrace();
+						isError = true;
+						errMsg += e.getMessage();
+					}
+				}
+			}
+//			else{
+//				if(!col.isNullable()){
+//					errMsg += "不能为空;";
+//				}
+//			}
+			
+			//第二阶段检测报告
+			if(isError){
+				errMsgMap.put(cellAbsoluteLocation, errMsg);
+				isError = false;
+				isRowError = true;
+				return errMsg;
+			}
+			//第二阶段,数据类型转换结束
+		}
+		
+		return null;
+	}
+
+	@Override
+	/**
+	 * zhangweijiang
+	 * 1. 处理最后几行数据(最后几行数据需要手动调用dataFetched,因为没有达到DEFAULT_SIZE大小)
+	 * 2. 把错误日志写入文件中
+	 * 3. 调用存储过程
+	 */
+	public ExcelResult finish() {
+		if(rows.size()>0){
+			dataHandler.dataFetched(schema, groupId, rows);
+			rows.clear();
+		}
+		 
+		ExcelResult result = dataHandler.dataFinish(schema, headSchema, groupId);
+		result.setTotal(totalRow);
+		//需要包含ErrorProcessor处理的错误信息,如果没有报错就算了
+		if(result.getErrMsgMap()!=null && !result.getErrMsgMap().isEmpty() ){
+			errMsgMap.putAll(result.getErrMsgMap()); 
+		}
+		result.setErrMsgMap(errMsgMap);
+		result.setFileName(groupId+".xlsx"); //组号即为文件名称
+		Set<String> errRefSet = new HashSet<String>();
+		if(!errMsgMap.isEmpty()){
+			for(String celRef:errMsgMap.keySet()){
+				String rowRef = celRef.replaceAll("[a-zA-Z]","");
+				errRefSet.add(rowRef);
+			}
+		}
+		result.setError(errRefSet.size());
+		result.setErrRows(errRows);
+		errorProcessor.flushErrors2Excel(result,groupId);
+		
+		
+		return result;
+	}
+
+	@Override
+	public <T> void addConverter(Class<T> type, Converter<T> converter) {
+		convertService.converts.put(type, converter);
+	}
+
+	@Override
+	public void removeConvertible(Class<?> type) {
+		convertService.converts.remove(type);
+	}
+
+	public String getErrMsg() {
+		return errMsg;
+	}
+	
+}

+package cn.runsa.crmapp.base.excel.support;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Date;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import cn.runsa.crmapp.base.excel.converter.BooleanConverter;
+import cn.runsa.crmapp.base.excel.converter.DateConverter;
+import cn.runsa.crmapp.base.excel.converter.NumberConverter;
+import cn.runsa.crmapp.base.excel.core.ConvertService;
+import cn.runsa.crmapp.base.excel.core.Converter;
+
+/**
+ * @author Stephen
+ */
+public class GeneralConvertService implements ConvertService{
+	
+	protected final Map<Class<?>,Converter<?>> converts;
+	
+	{
+		converts = new ConcurrentHashMap<Class<?>,Converter<?>>();
+		converts.put(Boolean.class, new BooleanConverter());
+		converts.put(Date.class, new DateConverter());
+		converts.put(Byte.class, new NumberConverter<Byte>(Byte.class));
+		converts.put(Short.class, new NumberConverter<Short>(Short.class));
+		converts.put(Integer.class, new NumberConverter<Integer>(Integer.class));
+		converts.put(Long.class, new NumberConverter<Long>(Long.class));
+		converts.put(Float.class, new NumberConverter<Float>(Float.class));
+		converts.put(Double.class, new NumberConverter<Double>(Double.class));
+		converts.put(BigDecimal.class, new NumberConverter<BigDecimal>(BigDecimal.class));
+		converts.put(BigInteger.class, new NumberConverter<BigInteger>(BigInteger.class));
+	}
+	
+	@Override
+	public boolean canConvert(Class<?> targetType) {
+		return converts.containsKey(targetType);
+	}
+
+	@Override
+	public <T> T convert(String source, Class<T> targetType) {
+		@SuppressWarnings("unchecked")
+		Converter<T> converter = (Converter<T>) converts.get(targetType);
+		return converter.convert(source);
+	}
+
+}

+package cn.runsa.crmapp.base.extendsion.spring;
+
+import org.springframework.beans.factory.support.DefaultListableBeanFactory;
+import org.springframework.web.context.support.XmlWebApplicationContext;
+
+/**
+ * @author Stephen
+ * 修改beanfactory的默认实现
+ */
+public class CustomXmlWebApplicationContext extends XmlWebApplicationContext{
+	
+	@Override
+	protected DefaultListableBeanFactory createBeanFactory() {
+		return new MultipleImplementsBeanFactory(getInternalParentBeanFactory());
+	}
+
+}

+package cn.runsa.crmapp.base.extendsion.spring;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.beans.factory.NoSuchBeanDefinitionException;
+import org.springframework.beans.factory.support.DefaultListableBeanFactory;
+
+import cn.runsa.crmapp.base.Constants;
+
+/**
+ * @author Stephen
+ * 多种实现选择注入的beanFactory
+ */
+public class MultipleImplementsBeanFactory extends DefaultListableBeanFactory{
+	
+	public MultipleImplementsBeanFactory() {
+		super();
+	}
+
+	public MultipleImplementsBeanFactory(BeanFactory parentBeanFactory) {
+		super(parentBeanFactory);
+	}
+	/**
+	 * 约定：系统外实现，包名包含open.***
+	 */
+	@Override
+	protected String determinePrimaryCandidate(Map<String, Object> candidateBeans, Class<?> requiredType) {
+		String prop = System.getProperty(Constants.CONSTANTS_CLASS_IMPL_PROFILE);
+		//允许多个profile
+		String [] profiles = null;
+		if(StringUtils.isBlank(prop)){
+			profiles = new String []{Constants.CONSTANTS_CLASS_IMPL_SYSTEM};
+		}else{
+			prop = prop.trim();
+			profiles = prop.split(",");
+		}
+		String beanName = null;
+		Map<String, Object> beans = new HashMap<String,Object>();
+		for (Map.Entry<String, Object> entry : candidateBeans.entrySet()) {
+			//取到包名
+			String pkgName = entry.getValue().getClass().getPackage().getName();
+			for(String profile : profiles){
+				//系统
+				if(Constants.CONSTANTS_CLASS_IMPL_SYSTEM.equals(profile)){
+					if(pkgName.indexOf(".open.") == -1){
+						beanName = entry.getKey();
+						beans.put(beanName, entry.getValue());
+					}
+				}else{
+					if(pkgName.indexOf(".open."+profile) != -1){
+						beanName = entry.getKey();
+						beans.put(beanName, entry.getValue());
+					}
+				}
+			}
+		}
+		if(beans.size() == 0){
+			throw new NoSuchBeanDefinitionException(requiredType);
+		}else if(beans.size() == 1){
+			return beanName;
+		}else{
+			return super.determinePrimaryCandidate(beans, requiredType); 
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.fs;
+/**
+ * 文件系统
+ * @author Stephen
+ *
+ */
+public interface FileSystem {
+
+	
+	
+}

+package cn.runsa.crmapp.base.http;
+/**
+ * Http post 数据格式
+ * @author Stephen
+ *
+ */
+public enum HttpDataType {
+
+	FORM,
+	
+	XML,
+	
+	JSON
+	
+}

+package cn.runsa.crmapp.base.http;
+
+/**
+ * Http post 数据格式
+ * 
+ * @author Stephen
+ *
+ */
+public enum HttpMethodType {
+	GET, POST, PUT
+}

+package cn.runsa.crmapp.base.http;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+
+import org.apache.commons.fileupload.util.Streams;
+import org.apache.commons.io.IOUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpStatus;
+import org.apache.http.StatusLine;
+import org.apache.http.client.methods.CloseableHttpResponse;
+
+import cn.runsa.crmapp.base.http.exception.HttpDataFormatException;
+import cn.runsa.crmapp.base.http.exception.HttpDataTypeNotSupportException;
+import cn.runsa.crmapp.base.http.exception.HttpResponseException;
+import cn.runsa.crmapp.base.utils.JsonUtils;
+import cn.runsa.crmapp.base.utils.XmlUtils;
+
+public class ResponseHandler {
+
+	@SuppressWarnings("unchecked")
+	public static <T> T handle(final CloseableHttpResponse response, Class<T> clz)
+			throws HttpResponseException, HttpDataFormatException {
+		final StatusLine statusLine = response.getStatusLine();
+		if (statusLine.getStatusCode() != HttpStatus.SC_OK) {
+			IOUtils.closeQuietly(response);
+			throw new HttpResponseException("http code :"
+					+ statusLine.getStatusCode());
+		} else {
+			HttpEntity entity = response.getEntity();
+			String type =null;
+			try{
+				type = entity.getContentType().getValue().toLowerCase();
+			}catch(Exception e){
+			}
+			InputStream in = null;
+			try {
+				in = entity.getContent();
+				String result = IOUtils.toString(in, "UTF-8");
+				if(clz.equals(String.class)){
+					return (T) result;
+				}
+				if (type.startsWith("application/json")) {
+					return JsonUtils.jsonToBean(result, clz);
+				} else if (type.startsWith("text/xml")||type.startsWith("application/xml")) {
+					return XmlUtils.xmlToBean(result, clz);
+				}else{
+					throw new HttpDataTypeNotSupportException(type+" not support");
+				}
+			} catch (Exception e) {
+				throw new HttpDataFormatException("", e);
+			}finally{
+				IOUtils.closeQuietly(in);
+//				IOUtils.closeQuietly(response);
+			}
+		}
+	}
+	
+	public static void downLoadFile(final CloseableHttpResponse response, File file) throws HttpResponseException{
+		StatusLine statusLine = response.getStatusLine();
+		if (statusLine.getStatusCode() != HttpStatus.SC_OK) {
+			IOUtils.closeQuietly(response);
+			throw new HttpResponseException("http code :"
+					+ statusLine.getStatusCode());
+		} else {
+			HttpEntity entity = response.getEntity();
+			InputStream in =null;
+			OutputStream out = null;
+			try {
+				in = entity.getContent();
+				out = new FileOutputStream(file);
+				Streams.copy(in, out, true);
+			} catch (IOException e) {
+				throw new HttpResponseException("File copy error.",e);
+			}finally{
+				IOUtils.closeQuietly(out);
+				IOUtils.closeQuietly(in);
+				IOUtils.closeQuietly(response);
+			}
+			
+			
+		}
+	}
+}

+package cn.runsa.crmapp.base.http;
+
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+
+import org.apache.http.conn.ssl.TrustStrategy;
+/**
+ * Https 安全策略：信任所有
+ * @author Stephen
+ *
+ */
+public class TrustAllStrategy implements TrustStrategy{
+
+	@Override
+	public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
+		return true;
+	}
+
+}

+package cn.runsa.crmapp.base.http.exception;
+/**
+ * http 请求数据格式化异常
+ * @author Stephen
+ *
+ */
+public class HttpDataFormatException extends HttpException {
+
+	private static final long serialVersionUID = -446888465201916329L;
+
+	public HttpDataFormatException() {
+		super();
+	}
+
+	public HttpDataFormatException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public HttpDataFormatException(String message) {
+		super(message);
+	}
+
+}

+package cn.runsa.crmapp.base.http.exception;
+/**
+ * http 处理响应数据异常
+ * @author Stephen
+ *
+ */
+public class HttpDataProcessException extends Exception {
+
+	private static final long serialVersionUID = -446888465233339L;
+
+	public HttpDataProcessException() {
+		super();
+	}
+
+	public HttpDataProcessException(final String message) {
+		super(message);
+	}
+
+	public HttpDataProcessException(final String message, final Throwable cause) {
+		super(message,cause);
+	}
+}

+package cn.runsa.crmapp.base.http.exception;
+/**
+ * http 请求数据格式不支持
+ * @author Stephen
+ *
+ */
+public class HttpDataTypeNotSupportException extends HttpException {
+
+	private static final long serialVersionUID = -4677744724999454091L;
+
+	public HttpDataTypeNotSupportException() {
+		super();
+	}
+
+	public HttpDataTypeNotSupportException(final String message) {
+		super(message);
+	}
+
+	public HttpDataTypeNotSupportException(final String message, final Throwable cause) {
+		super(message,cause);
+	}
+}

+package cn.runsa.crmapp.base.http.exception;
+
+/**
+ * Http 请求异常
+ * 
+ * @author Stephen
+ *
+ */
+public class HttpException extends Exception {
+
+	private static final long serialVersionUID = 2781235741466577292L;
+
+	public HttpException() {
+		super();
+	}
+
+	public HttpException(final String message) {
+		super(message);
+	}
+
+	public HttpException(final String message, final Throwable cause) {
+		super(message);
+		initCause(cause);
+	}
+}

+package cn.runsa.crmapp.base.http.exception;
+
+/**
+ * http 响应时异常
+ * 
+ * @author Stephen
+ *
+ */
+public class HttpResponseException extends HttpException {
+
+	private static final long serialVersionUID = -2960376536362148494L;
+
+	public HttpResponseException() {
+		super();
+	}
+
+	public HttpResponseException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public HttpResponseException(String message) {
+		super(message);
+	}
+
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.zip.GZIPInputStream;
+import java.util.zip.GZIPOutputStream;
+
+import com.alibaba.fastjson.JSON;
+import com.google.common.io.ByteStreams;
+
+public class BaseService {
+	
+	public final static <T> T getOject(String jsonString, Class<T> cls) {
+		T t = null;
+		try {
+			t = JSON.parseObject(jsonString, cls);
+		} catch (Exception e) {
+			// TODO: handle exception
+		}
+		return t;
+	}
+
+	public final static String unGZIP(byte[] body) {
+		ByteArrayOutputStream out = new ByteArrayOutputStream();
+		ByteArrayInputStream in = new ByteArrayInputStream(body);
+		try {
+			GZIPInputStream gunzip = new GZIPInputStream(in);
+			ByteStreams.copy(gunzip, out);
+			return out.toString();
+		} catch (IOException e1) {
+			e1.printStackTrace();
+		} finally {
+			try {
+				in.close();
+				out.close();
+			} catch (IOException e) {
+			}
+		}
+		return null;
+	}
+	
+	public final static byte[] GZIP(byte[] body) {
+		ByteArrayOutputStream out = new ByteArrayOutputStream();
+		try {
+			GZIPOutputStream  gunzip = new GZIPOutputStream(out);
+			gunzip.write(body);
+			gunzip.close();
+			return out.toByteArray();
+		} catch (IOException e1) {
+			e1.printStackTrace();
+		} finally {
+			try {
+				out.close();
+			} catch (IOException e) {
+			}
+		}
+		return null;
+	}
+}

+package cn.runsa.crmapp.base.mq;
+
+/**
+ * @author Stephen
+ * 延迟消息
+ */
+public class DelayMessage extends MqMessage{
+
+	private static final long serialVersionUID = -6406648480333023838L;
+	
+	private int delay ;
+	
+	public int getDelay() {
+		return delay;
+	}
+
+	public void setDelay(int delay) {
+		this.delay = delay;
+	}
+	
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.util.Properties;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.io.FileSystemResource;
+import org.springframework.core.io.support.PropertiesLoaderUtils;
+
+import cn.runsa.crmapp.base.Constants;
+
+import com.google.common.base.Throwables;
+
+/**
+ * 阿里云凭证
+ * @author Stephen
+ */
+public final class MNSCredential {
+	
+	private static Properties credential = null; 
+	
+	private static final Logger log = LoggerFactory.getLogger(MNSCredential.class);
+	
+	static{
+		try {
+			credential = PropertiesLoaderUtils.loadProperties(new FileSystemResource(System.getProperty(Constants.CONSTANTS_SERVER_CONFIG_PATH)));
+		} catch (Exception e) {
+			log.error("mns auth config error,with config file classpath:/mq/aliyun-mns.properties",e);
+			Throwables.propagate(e);
+		}
+	}
+	
+	public static String getMNSAccountEndpoint() {
+        return credential.getProperty("mns.accountendpoint");
+    }
+
+    public static String getMNSAccessKeyId() {
+        return credential.getProperty("mns.accesskeyid");
+    }
+
+    public static String getMNSAccessKeySecret() {
+        return credential.getProperty("mns.accesskeysecret");
+    }
+
+    public static String getMNSSecurityToken() {
+        return credential.getProperty("mns.securitytoken");
+    }
+
+}

+package cn.runsa.crmapp.base.mq;
+/**
+ * @author Stephen
+ * 
+ * 消息监听
+ */
+public interface MessageListener <T> {
+
+	void onMessage(T t) throws Exception;
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.core.io.ClassPathResource;
+
+import cn.runsa.crmapp.base.mq.entity.MqClient;
+import cn.runsa.crmapp.base.mq.entity.MqQueue;
+import cn.runsa.crmapp.base.utils.XmlUtils;
+
+import com.aliyun.mns.client.CloudAccount;
+import com.aliyun.mns.client.CloudQueue;
+import com.aliyun.mns.client.MNSClient;
+
+public class MessageReceiver implements InitializingBean, DisposableBean{
+	
+	private static MNSClient client = null;
+	
+	private static Map<String,CloudQueue> queues = new ConcurrentHashMap<String,CloudQueue>();
+	
+	private static final Logger log = LoggerFactory.getLogger(MessageReceiver.class);
+	
+	private static ExecutorService es ;
+	
+	private static CloudQueue getQueue(String name){
+		CloudQueue queue = queues.get(name);
+		if(queue==null){
+        	queue = client.getQueueRef(name);
+        	queues.put(name, queue);
+		}
+		return queue;
+	}
+	
+	@Override
+	public void destroy() throws Exception {
+		es.shutdown();
+		es.awaitTermination(60, TimeUnit.SECONDS);
+		if(client!=null)
+			client.close();
+		queues.clear();
+	}
+
+	@Override
+	public void afterPropertiesSet() throws Exception {
+		CloudAccount account = new CloudAccount(
+				MNSCredential.getMNSAccessKeyId(),
+				MNSCredential.getMNSAccessKeySecret(),
+				MNSCredential.getMNSAccountEndpoint());
+		client = account.getMNSClient();
+		es = Executors.newCachedThreadPool();
+		init();
+	}
+	
+	private void init(){
+		MqClient clt = null;
+		try {
+			clt = XmlUtils.xmlToBean(new ClassPathResource("mq/aliyun-mns.xml").getInputStream(), MqClient.class);
+		} catch (IOException e) {
+			log.error("mns init error", e);
+		}
+		List<MqQueue> list = clt.getQueues();
+		if(list != null && list.size() >0){
+			for(final MqQueue queue:list){
+				for(int i=1;i<=queue.getThread();i++){
+					final int index = i;
+					QueueReceiver reveiver = new QueueReceiver(index, getQueue(queue.getName()), queue.getListener());
+					es.execute(reveiver);
+				}
+			}
+		}
+	}
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.stereotype.Component;
+
+import cn.runsa.crmapp.base.mq.QueueNameAlias.InnerQueue;
+import cn.runsa.crmapp.base.mq.entity.MqClient;
+import cn.runsa.crmapp.base.utils.XmlUtils;
+
+import com.aliyun.mns.client.CloudAccount;
+import com.aliyun.mns.client.CloudQueue;
+import com.aliyun.mns.client.CloudTopic;
+import com.aliyun.mns.client.MNSClient;
+import com.aliyun.mns.model.Message;
+
+/**
+ * 发送mq消息
+ * @author Stephen
+ */
+public final class MessageSender implements InitializingBean, DisposableBean{
+	
+	private static final Logger log = LoggerFactory.getLogger(MessageSender.class);
+	
+	private static MNSClient client = null;
+	
+	private static Map<String,CloudQueue> queues = new ConcurrentHashMap<String,CloudQueue>();
+	
+	private static Map<String,CloudTopic> topics = new ConcurrentHashMap<String,CloudTopic>();
+	
+	private static Map<InnerQueue,String> queueAlias = new HashMap<InnerQueue,String>();
+
+	@Override
+	public void destroy() throws Exception {
+		if(client!=null)
+			client.close();
+		queues.clear();
+		topics.clear();
+	}
+
+	@Override
+	public void afterPropertiesSet() throws Exception {
+		MqClient clt = null;
+		try {
+			clt = XmlUtils.xmlToBean(new ClassPathResource("mq/aliyun-mns.xml").getInputStream(), MqClient.class);
+		} catch (IOException e) {
+			log.error("mns init error", e);
+			throw new RuntimeException(e);
+		}
+		if(clt.getQueueAlias()!=null&&clt.getQueueAlias().size()>0){
+			for(QueueNameAlias a : clt.getQueueAlias()){
+				queueAlias.put(a.getInner(), a.getQueueName());
+			}
+		}
+		CloudAccount account = new CloudAccount(
+				MNSCredential.getMNSAccessKeyId(),
+				MNSCredential.getMNSAccessKeySecret(),
+				MNSCredential.getMNSAccountEndpoint());
+		client = account.getMNSClient();
+	}
+	
+	private static CloudQueue getQueue(String name){
+		CloudQueue queue = queues.get(name);
+		if(queue==null){
+        	queue = client.getQueueRef(name);
+        	queues.put(name, queue);
+		}
+		return queue;
+	}
+	
+	/*private static CloudTopic getTopic(String name){
+		CloudTopic topic = topics.get(name);
+		if(topic==null){
+			synchronized (topic) {
+                if (topic == null){
+                	topic = client.getTopicRef(name);
+                	topics.put(name, topic);
+                }
+			}
+		}
+		return topic;
+	}*/
+	
+	public static void putMessage(String queueName,MqMessage message){
+		CloudQueue queue = getQueue(queueName);
+		Message msg = new Message();
+		msg.setMessageBody(BaseService.GZIP(message.getMessageBody()));
+		msg.setPriority(message.getPriority());
+		queue.putMessage(msg);
+	}
+	
+	public static void putMessage(InnerQueue alias,MqMessage message){
+		if(checkQueueAlias(alias)){
+			putMessage(queueAlias.get(alias), message);
+		}
+	}
+	
+	public static void putMessage(String queueName,List<MqMessage> messages){
+		CloudQueue queue = getQueue(queueName);
+		List<Message> list = new ArrayList<Message>(messages.size());
+		for(MqMessage message:messages){
+			Message msg = new Message();
+			msg.setMessageBody(BaseService.GZIP(message.getMessageBody()));
+			msg.setPriority(message.getPriority());
+			list.add(msg);
+		}
+		queue.batchPutMessage(list);
+	}
+	
+	public static void putMessage(InnerQueue alias,List<MqMessage> messages){
+		if(checkQueueAlias(alias)){
+			putMessage(queueAlias.get(alias), messages);
+		}
+	}
+	
+	public static void putDelayMessage(InnerQueue alias,DelayMessage message){
+		if(checkQueueAlias(alias)){
+			putDelayMessage(queueAlias.get(alias), message);
+		}
+	}
+	
+	public static void putDelayMessage(String queueName,DelayMessage message){
+		CloudQueue queue = getQueue(queueName);
+		Message msg = new Message();
+		msg.setMessageBody(BaseService.GZIP(message.getMessageBody()));
+		msg.setPriority(message.getPriority());
+		msg.setDelaySeconds(message.getDelay());
+		queue.putMessage(msg);
+	}
+	
+	public static void putDelayMessage(String queueName,List<DelayMessage> messages){
+		CloudQueue queue = getQueue(queueName);
+		List<Message> list = new ArrayList<Message>(messages.size());
+		for(DelayMessage message:messages){
+			Message msg = new Message();
+			msg.setMessageBody(BaseService.GZIP(message.getMessageBody()));
+			msg.setPriority(message.getPriority());
+			msg.setDelaySeconds(message.getDelay());
+			list.add(msg);
+		}
+		queue.batchPutMessage(list);
+	}
+	
+	public static void putDelayMessage(InnerQueue alias,List<DelayMessage> messages){
+		if(checkQueueAlias(alias)){
+			putDelayMessage(queueAlias.get(alias), messages);
+		}
+	}
+	
+	private static boolean checkQueueAlias(InnerQueue alias){
+		if(!queueAlias.containsKey(alias)){
+			if(log.isDebugEnabled()){
+				log.debug("alias with no queue name defined,queue alias :"+alias);
+			}
+			return false;
+		}
+		return true;
+	}
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.io.Serializable;
+import java.io.UnsupportedEncodingException;
+
+/**
+ * @author Stephen
+ * mq消息
+ */
+public class MqMessage implements Serializable{
+
+	private static final long serialVersionUID = -2913291790464662305L;
+	
+	private static final String ENCODING = "UTF-8";
+	
+	private static final int DEFAULT_PRIORITY = 8;
+	
+	private int priority ;
+	
+	private byte[] messageBody ;
+	
+	public MqMessage(){
+		super();
+	}
+	
+	public MqMessage(byte[] messageBody) {
+		this(DEFAULT_PRIORITY,messageBody);
+	}
+	
+	public MqMessage(int priority, byte[] messageBody) {
+		super();
+		this.priority = priority;
+		this.messageBody = messageBody;
+	}
+	
+	public MqMessage(String messageBody) {
+		this(DEFAULT_PRIORITY,messageBody);
+	}
+	
+	public MqMessage(int priority, String messageBody) {
+		super();
+		this.priority = priority;
+		setStringMessageBody(messageBody);
+	}
+	
+	public int getPriority() {
+		return priority;
+	}
+
+	public void setPriority(int priority) {
+		this.priority = priority;
+	}
+
+	public byte[] getMessageBody() {
+		return messageBody;
+	}
+
+	public void setMessageBody(byte[] messageBody) {
+		this.messageBody = messageBody;
+	}
+	
+	public void setStringMessageBody(String messageBody){
+		byte[] body = null;
+		try {
+			body = messageBody.getBytes(ENCODING);
+		} catch (UnsupportedEncodingException e) {
+			throw new RuntimeException("Not support encoding");
+		}
+		setMessageBody(body);
+	}
+}

+package cn.runsa.crmapp.base.mq;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
+
+/**
+ * @author Stephen
+ * queue 别名
+ */
+@XStreamAlias("alias")
+public class QueueNameAlias {
+
+	public static enum InnerQueue {
+		events
+	}
+	
+	@XStreamAsAttribute
+	private InnerQueue inner;
+	
+	@XStreamAlias("ref")
+	@XStreamAsAttribute
+	private String queueName;
+
+	public InnerQueue getInner() {
+		return inner;
+	}
+
+	public void setInner(InnerQueue inner) {
+		this.inner = inner;
+	}
+
+	public String getQueueName() {
+		return queueName;
+	}
+
+	public void setQueueName(String queueName) {
+		this.queueName = queueName;
+	}
+	
+}

+package cn.runsa.crmapp.base.mq;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import cn.runsa.crmapp.base.mq.entity.MqListener;
+import cn.runsa.crmapp.base.utils.SpringUtils;
+
+import com.alibaba.fastjson.JSON;
+import com.aliyun.mns.client.CloudQueue;
+import com.aliyun.mns.model.Message;
+
+/**
+ * @author Stephen
+ */
+public class QueueReceiver implements Runnable{
+	
+	public static final int WAIT_SECONDS = 30;
+	
+	public static final int BEAT_TEST_SECONDS = 10;
+	
+	public static final int MAX_MSG_RETRY_TIMES = 5;
+
+	private static final Map<String, Object> sLockObjMap = new HashMap<String, Object>();
+	private static Map<String, Integer> sPollingMap = new ConcurrentHashMap<String, Integer>();
+
+	private static final Logger log = LoggerFactory.getLogger(MessageReceiver.class);
+
+	private Object lockObj;
+	private String queueName;
+	private CloudQueue queue;
+	private int workerId;
+	@SuppressWarnings("rawtypes")
+	private MessageListener msgListener;
+	@SuppressWarnings("rawtypes")
+	private Class msgType;
+
+	public QueueReceiver(int worker, CloudQueue queue,MqListener listener) {
+		workerId = worker;
+		this.queue = queue;
+		queueName = queue.getAttributes().getQueueName();
+		try {
+			msgListener = (MessageListener<?>) SpringUtils.getBean(Class.forName(listener.getLisClass()));
+			msgType = Class.forName(listener.getMsgType());
+		} catch (ClassNotFoundException e) {
+			log.error("queue receiver init error",e);
+			throw new IllegalArgumentException(e);
+		}
+		// 初始化lock对象
+		synchronized (sLockObjMap) {
+			lockObj = sLockObjMap.get(queueName);
+			if (lockObj == null) {
+				lockObj = new Object();
+				sLockObjMap.put(queueName, lockObj);
+			}
+		}
+	}
+
+	public boolean setPolling() {
+		// 进入轮询状态
+		synchronized (lockObj) {
+			Integer ret = sPollingMap.get(queueName);
+			if (ret == null || ret == -1) {
+				sPollingMap.put(queueName, workerId);
+				System.out.println(workerId+"轮询");
+				return true;
+			} else if (ret == workerId) {
+				return true;
+			} else {
+				return false;
+			}
+		}
+	}
+
+	public void clearPolling() {
+		// 退出轮询状态
+		synchronized (lockObj) {
+			sPollingMap.put(queueName, -1);
+			lockObj.notifyAll();
+			System.out.println("唤醒");
+		}
+	}
+
+	public Message receiveMessage() {
+		// 轮询标志
+		boolean polling = false;
+		while (true) {
+			synchronized (lockObj) {
+				Integer p = sPollingMap.get(queueName);
+				// 轮询中，则等待
+				if (p != null && p >= 0) {
+					if (p != workerId) {
+						try {
+							polling = false;
+							System.out.println(workerId+"歇会儿");
+							lockObj.wait();
+						} catch (InterruptedException e) {
+							log.error("MessageReceiver Interrupted! QueueName is " + queueName, e);
+							return null;
+						}
+					} else {
+						//只有异常或者断网情况下进入这里
+						try {
+							Thread.sleep(WAIT_SECONDS * 1000);
+						} catch (InterruptedException e) {
+							// undo
+						}
+					}
+				}
+			}
+			Message message;
+			// 未处于轮询状态
+			if (!polling) {
+				try {
+					message = queue.popMessage();
+					if (message == null) {
+						polling = true;
+						continue;
+					}
+				} catch (Exception e) {
+					log.error("Exception Happened when popMessage: " + e);
+					polling = true;
+					continue;
+				}
+			} else {
+				// 尝试进入轮询状态
+				if (!setPolling()) {
+					continue;
+				}
+				try {
+					do {
+						message = queue.popMessage(WAIT_SECONDS);
+					} while (message == null);
+					clearPolling();
+				} catch (Exception e) {
+					log.error("Exception Happened when popMessage: " + e);
+					polling = false;
+					continue;
+				}
+			}
+			return message;
+		}
+	}
+
+	@SuppressWarnings("unchecked")
+	@Override
+	public void run() {
+		while (true) {
+			Message msg = receiveMessage();
+			if(msg != null){
+				String data = BaseService.unGZIP(msg.getMessageBodyAsBytes());
+				try{
+					if(String.class.equals(msgType)){
+						msgListener.onMessage(data);
+					}else{
+						msgListener.onMessage(JSON.parseObject(data, msgType));
+					}
+					queue.deleteMessage(msg.getReceiptHandle());
+				}catch(Exception e){
+					log.error("Exception Happened when process msg: " + e);
+					if(msg.getDequeueCount()>=MAX_MSG_RETRY_TIMES){
+						queue.deleteMessage(msg.getReceiptHandle());
+					}
+				}
+			}
+		}
+	}
+
+}

+package cn.runsa.crmapp.base.mq;
+
+import com.aliyun.mns.model.Message;
+
+import cn.runsa.crmapp.base.mq.exception.MqExcepiton;
+
+public interface ReceiverService {
+	public void execute(Message message) throws MqExcepiton;
+}

+package cn.runsa.crmapp.base.mq;
+/**
+ * @author Stephen
+ */
+public class TopicReceiver {
+
+}

+package cn.runsa.crmapp.base.mq.entity;
+
+import java.util.List;
+
+import javax.xml.bind.annotation.XmlRootElement;
+
+import cn.runsa.crmapp.base.mq.QueueNameAlias;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+
+/**
+ * @author Stephen
+ */
+@XmlRootElement
+@XStreamAlias("client")
+public class MqClient {
+	
+	private List<MqQueue> queues;
+	
+	private List<MqTopic> topics;
+	
+	private List<QueueNameAlias> queueAlias;
+
+	public List<MqQueue> getQueues() {
+		return queues;
+	}
+
+	public void setQueues(List<MqQueue> queues) {
+		this.queues = queues;
+	}
+
+	public List<MqTopic> getTopics() {
+		return topics;
+	}
+
+	public void setTopics(List<MqTopic> topics) {
+		this.topics = topics;
+	}
+
+	public List<QueueNameAlias> getQueueAlias() {
+		return queueAlias;
+	}
+
+	public void setQueueAlias(List<QueueNameAlias> queueAlias) {
+		this.queueAlias = queueAlias;
+	}
+	
+}

+package cn.runsa.crmapp.base.mq.entity;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
+
+/**
+ * @author Stephen
+ */
+@XStreamAlias("listener")
+public class MqListener {
+	
+	@XStreamAlias("class")
+	@XStreamAsAttribute
+	private String lisClass;
+	
+	@XStreamAsAttribute
+	private String msgType;
+
+	public String getLisClass() {
+		return lisClass;
+	}
+
+	public void setLisClass(String lisClass) {
+		this.lisClass = lisClass;
+	}
+
+	public String getMsgType() {
+		return msgType;
+	}
+
+	public void setMsgType(String msgType) {
+		this.msgType = msgType;
+	}
+	
+}

+package cn.runsa.crmapp.base.mq.entity;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+import com.thoughtworks.xstream.annotations.XStreamAsAttribute;
+
+/**
+ * @author Stephen
+ */
+@XStreamAlias("queue")
+public class MqQueue {
+	
+	@XStreamAsAttribute
+	private String name;
+	
+	@XStreamAsAttribute
+	private int thread = 1;
+	
+	@XStreamAsAttribute
+	private String compress = "gzip";
+	
+	private MqListener listener;
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public int getThread() {
+		return thread;
+	}
+
+	public void setThread(int thread) {
+		this.thread = thread;
+	}
+	
+	public String getCompress() {
+		return compress;
+	}
+
+	public void setCompress(String compress) {
+		this.compress = compress;
+	}
+
+	public MqListener getListener() {
+		return listener;
+	}
+
+	public void setListener(MqListener listener) {
+		this.listener = listener;
+	}
+
+}

+package cn.runsa.crmapp.base.mq.entity;
+
+import java.util.List;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+import com.thoughtworks.xstream.annotations.XStreamImplicit;
+
+/**
+ * @author Stephen
+ */
+@XStreamAlias("topic")
+public class MqTopic {
+
+	@XStreamImplicit
+	private List<MqListener> listeners;
+
+	public List<MqListener> getListeners() {
+		return listeners;
+	}
+
+	public void setListeners(List<MqListener> listeners) {
+		this.listeners = listeners;
+	}
+	
+}

+package cn.runsa.crmapp.base.mq.exception;
+
+public class MqExcepiton extends RuntimeException {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 220632093115334702L;
+
+	public MqExcepiton() {
+		super();
+	}
+
+	public MqExcepiton(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public MqExcepiton(String message) {
+		super(message);
+	}
+
+	public MqExcepiton(Throwable cause) {
+		super(cause);
+	}
+
+}

+package cn.runsa.crmapp.base.redis;
+
+import java.util.concurrent.TimeUnit;
+
+import org.apache.log4j.LogManager;
+import org.apache.log4j.Logger;
+import org.springframework.data.redis.core.RedisTemplate;
+
+import cn.runsa.crmapp.base.utils.JsonUtils;
+
+public class Redis {
+	
+	private static final Logger log = LogManager.getLogger(Redis.class);
+	
+	@SuppressWarnings("rawtypes")
+	private static RedisTemplate redis;
+	
+	@SuppressWarnings("rawtypes")
+	public RedisTemplate getRedis() {
+		return redis;
+	}
+
+	@SuppressWarnings("rawtypes")
+	public void setRedis(RedisTemplate redis) {
+		Redis.redis = redis;
+	}
+
+	public static String getString(String key) {
+		String str = null;
+		Object val = redis.opsForValue().get(key);
+		if(val!=null){
+			str = val.toString();
+		}
+		return str;
+	}
+
+	public static <T> T getObject(String key, Class<T> cls) {
+		T t = null;
+		try {
+			String str = getString(key);
+			if(str!=null)
+			t = JsonUtils.jsonToBean(str, cls);
+		} catch (Exception e) {
+			log.error("redis get object value error", e);
+		}
+		return t;
+	}
+
+	@SuppressWarnings("unchecked")
+	public static boolean setString(String key, String value) {
+		redis.opsForValue().set(key, value);
+		return true;
+	}
+
+	public static boolean setObject(String key, Object value) {
+		setString(key, JsonUtils.beanToJson(value));
+		return true;
+	}
+
+	@SuppressWarnings("unchecked")
+	public static boolean setString(String key, String value, int timeout) {
+		redis.opsForValue().set(key, value,timeout,TimeUnit.SECONDS);
+		return true;
+	}
+
+	public static boolean setObject(String key, Object value, int timeout) {
+		setString(key, JsonUtils.beanToJson(value), timeout);
+		return true;
+	}
+
+}

+package cn.runsa.crmapp.base.redis;
+
+public class RedisMQ {
+
+}

+package cn.runsa.crmapp.base.redis.exception;
+
+public class RedisException extends Exception{
+	
+	private static final long serialVersionUID = 6585013822092454600L;
+
+	public RedisException() {
+		super();
+		// TODO Auto-generated constructor stub
+	}
+
+	public RedisException(String message, Throwable cause) {
+		super(message, cause);
+		// TODO Auto-generated constructor stub
+	}
+
+	public RedisException(String message) {
+		super(message);
+		// TODO Auto-generated constructor stub
+	}
+	
+}

+package cn.runsa.crmapp.base.sms;
+
+import com.alibaba.fastjson.JSON;
+
+public abstract class AbstractHttpSmsSender implements SmsSender {
+
+	private Protocol protocol;
+
+	public AbstractHttpSmsSender() {
+		super();
+	}
+
+	@Override
+	public void setProtocol(Protocol protocol) {
+		this.protocol = protocol;
+	}
+
+	public Protocol getProtocol() {
+		return protocol;
+	}
+
+	public <T> T getOject(String jsonString, Class<T> cls) {
+		T t = null;
+		try {
+			t = JSON.parseObject(jsonString, cls);
+		} catch (Exception e) {
+			// TODO: handle exception
+		}
+		return t;
+	}
+
+	public String toJsonString(Object T) {
+		return JSON.toJSONString(T);
+	}
+
+}
\ No newline at end of file

+package cn.runsa.crmapp.base.sms;
+
+public interface Protocol {
+	String sendMsg(String url, String data);
+}

+package cn.runsa.crmapp.base.sms;
+
+import java.io.Serializable;
+/**
+ * 短信消息
+ * @author Stephen
+ *
+ */
+public class SmsMessage implements Serializable{
+
+	private static final long serialVersionUID = 8620596786869937729L;
+	/**
+	 * 手机号，可以为多个，中间以英文逗号分隔
+	 */
+	private String mobile;
+	/**
+	 * 内容编码为UTF8
+	 */
+	private String content;
+
+	public String getMobile() {
+		return mobile;
+	}
+
+	public void setMobile(String mobile) {
+		this.mobile = mobile;
+	}
+
+	public String getContent() {
+		return content;
+	}
+
+	public void setContent(String content) {
+		this.content = content;
+	}
+}

+package cn.runsa.crmapp.base.sms;
+
+public class SmsProvider {
+
+}

+package cn.runsa.crmapp.base.sms;
+
+import cn.runsa.crmapp.base.sms.exception.SmsException;
+
+/**
+ * 发短信
+ * 
+ * @author Stephen
+ *
+ */
+public interface SmsSender {
+
+	void sendSMS(SmsMessage msg) throws SmsException;
+
+	/**
+	 * 发送验证码，返回有效时间，单位为秒
+	 * 
+	 * @param mobile
+	 *            手机号
+	 * @param sequence
+	 *            序列号（可以为场景字符串或者任意字符）
+	 * @param code
+	 *            验证码
+	 * @return
+	 * @throws SmsException
+	 */
+	int sendCaptcha(String mobile, String sequence, String code) throws SmsException;
+
+	/**
+	 * 查询余额，返回剩余条数
+	 * 
+	 * @return
+	 * @throws SmsException
+	 */
+	long remainCheck() throws SmsException;
+
+	/**
+	 * 设置处理协议
+	 * 
+	 * @param protocol
+	 */
+	void setProtocol(Protocol protocol);
+
+}

+package cn.runsa.crmapp.base.sms.exception;
+/**
+ * 短信发送异常，不包括发送短信但没有接收到，意思就是 并不是端到端
+ * @author Stephen
+ *
+ */
+public class SmsException extends Exception{
+
+	private static final long serialVersionUID = 7587790473289942572L;
+
+	public SmsException() {
+		super();
+	}
+
+	public SmsException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public SmsException(String message) {
+		super(message);
+	}
+
+	public SmsException(Throwable cause) {
+		super(cause);
+	}
+
+}

+package cn.runsa.crmapp.base.utils;
+
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Method;
+import java.util.HashSet;
+import java.util.Set;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.Assert;
+
+import cn.runsa.crmapp.base.event.BusinessEvent;
+
+/**
+ * @author Stephen
+ */
+public class BeanUtils extends org.springframework.beans.BeanUtils{
+	
+	private static final Logger log = LoggerFactory.getLogger(BeanUtils.class);
+	
+	/**
+	 * 归并相同类型的两个对象
+	 * @param target
+	 * @param source
+	 * @param strategy
+	 * @param ignores
+	 */
+	public static void merge(Object target, Object source, MergeStrategy strategy,String [] ignores) {
+		Assert.notNull(source, "Source must not be null");
+		Assert.notNull(target, "Target must not be null");
+		if(!target.getClass().equals(source.getClass())){
+			throw new IllegalArgumentException("source and target must be same class type");
+		}
+		PropertyDescriptor[] targetPds = getPropertyDescriptors(target.getClass());
+		byte code = strategy.code;
+		Set<String> allIgnore = new HashSet<String>();
+		if(ignores!=null){
+			for(String ignore:ignores){
+				allIgnore.add(ignore);
+			}
+		}
+		for (PropertyDescriptor targetPd : targetPds) {
+			String name = targetPd.getName();
+			if("class".equals(name)){
+				continue;
+			}
+			Method read = targetPd.getReadMethod();
+			if(read==null){
+				allIgnore.add(name);
+			}else{
+				//target not null
+				if((code&0x01)!=0){
+					try{
+						if(read.invoke(target)!=null){
+							allIgnore.add(name);
+						}
+					}catch(Exception e){
+						log.error("get properties error with name "+name, e);
+						allIgnore.add(name);
+					}
+					
+				}
+				//source not null
+				if((code&0x10)!=0){
+					try{
+						if(read.invoke(source)==null){
+							allIgnore.add(name);
+						}
+					}catch(Exception e){
+						log.error("get properties error with name "+name, e);
+						allIgnore.add(name);
+					}
+				}
+			}
+			
+		}
+		ignores = new String [allIgnore.size()];
+		allIgnore.toArray(ignores);
+		copyProperties(source, target, ignores);
+	}
+	
+	public static enum MergeStrategy{
+		
+		targetEmpty((byte)1),sourceNotEmpty((byte)2),targetEmptyAndSourceNotEmpty((byte)3);
+		
+		private byte code;
+		
+		private MergeStrategy(byte code){
+			this.code = code;
+		}
+		
+		public byte getCode(){
+			return code;
+		}
+	}
+
+	public static void main(String[] args) {
+		merge(new BusinessEvent(), new BusinessEvent(),MergeStrategy.targetEmpty, null);
+	}
+}

+package cn.runsa.crmapp.base.utils;
+
+import java.io.ByteArrayInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+
+import org.apache.poi.poifs.filesystem.DirectoryEntry;
+import org.apache.poi.poifs.filesystem.POIFSFileSystem;
+
+
+public class ExportExcel {
+
+	public static int exportDoc(String destFile, String fileContent) {
+		try {
+			
+			StringBuffer sb = new StringBuffer();
+			sb.append("<html><head></head><body><div>sssssssssssss" + fileContent + "</div></body></html>");
+			ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(sb.toString().getBytes("UTF-8"));
+			POIFSFileSystem fileSystem = new POIFSFileSystem();
+			
+			DirectoryEntry directory = fileSystem.getRoot();
+			directory.createDocument("WordDocument", byteArrayInputStream);
+			
+			FileOutputStream fileOutputStream = new FileOutputStream(destFile);
+			fileSystem.writeFilesystem(fileOutputStream);
+			
+			byteArrayInputStream.close();
+			fileOutputStream.close();
+			return 1;
+		} catch (IOException e) {
+			return 0;
+		}
+	}
+	
+}

+package cn.runsa.crmapp.base.utils;
+
+import com.google.common.base.Strings;
+
+public class FourBytesCharEscapeUtils {
+	
+	public static String escape(String str){
+		if(Strings.isNullOrEmpty(str)){
+			return str;
+		}else{
+			byte[] conbyte = str.getBytes();
+	        for (int i = 0; i < conbyte.length; i++) {
+	        	//四字节,替换为? ? 
+	        	if ((conbyte[i] & 0xF8) == 0xF0) {
+	                for (int j = 0; j < 4; j+=2) {                          
+	                    conbyte[i+j]=0x3f;
+	                }
+	                for (int j = 1; j < 4; j+=2) {                          
+	                    conbyte[i+j]=0x20;
+	                }
+	                i += 3;
+	            }
+	        }
+	        str = new String(conbyte);
+	        return str;
+		}
+	}
+}

+package cn.runsa.crmapp.base.utils;
+
+import com.alibaba.fastjson.JSON;
+
+public class JsonUtils {
+
+	/**
+	 * 将java对象转换成json字符串
+	 * 
+	 * @param obj
+	 *            准备转换的对象
+	 * @return json字符串
+	 * @throws Exception
+	 */
+	public static String beanToJson(Object obj) {
+		return JSON.toJSONString(obj);
+		//.replaceAll("\\\\", "").replaceAll("\"", "\\\"")
+	}
+
+	/**
+	 * 将json字符串转换成java对象
+	 * 
+	 * @param json
+	 *            准备转换的json字符串
+	 * @param cls
+	 *            准备转换的类
+	 * @return
+	 * @throws Exception
+	 */
+	public static <T> T jsonToBean(String json, Class<T> cls) {
+		return JSON.parseObject(json, cls);
+	}
+
+}

+package cn.runsa.crmapp.base.utils;
+
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
+import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
+import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author Stephen
+ */
+@Component
+public final class SpringUtils implements BeanFactoryPostProcessor {
+
+	private static ConfigurableListableBeanFactory beanFactory;
+
+	@Override
+	public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
+		SpringUtils.beanFactory = beanFactory;
+	}
+
+	/**
+	 * 获取对象
+	 */
+	public static Object getBean(String name) {
+		return beanFactory.getBean(name);
+	}
+
+	/**
+	 * 获取对象
+	 */
+	@SuppressWarnings("unchecked")
+	public static <T> T getBean(String name, Class<T> clz) {
+		T result = (T) beanFactory.getBean(name);
+		return result;
+	}
+
+	/**
+	 * 获取对象
+	 */
+	public static <T> T getBean(Class<T> clz) {
+		T result = (T) beanFactory.getBean(clz);
+		return result;
+	}
+
+	/**
+	 * 判断是否包含对象
+	 */
+	public static boolean containsBean(String name) {
+		return beanFactory.containsBean(name);
+	}
+
+	/**
+	 * 创建对象到spring context
+	 */
+	@SuppressWarnings("unchecked")
+	public static <T> T createBean(Class<T> clz) {
+		T result = (T) beanFactory.createBean(clz, AutowireCapableBeanFactory.AUTOWIRE_BY_NAME, true);
+		return result;
+	}
+
+	/**
+	 * 删除对象
+	 */
+	public static void destroyBean(String beanName) {
+		beanFactory.destroyScopedBean(beanName);
+	}
+
+}