java微信平台，发源码

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
       ">
       
       
    <!-- 扫描注解Bean -->
    <context:component-scan base-package="com.cpic">
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>
    
    <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <list>
                <value>classpath:resources.properties</value>
            </list>
        </property>
    </bean>

 

      <bean id="dataSource" class="org.logicalcobwebs.proxool.ProxoolDataSource">
        <property name="alias" value="proxoolDataSource"/>
        <property name="driver" value="${connection.driver_class}" />
        <property name="driverUrl" value="${connection.url}" />
        <property name="user" value="${connection.username}" />
        <property name="password" value="${connection.password}" />
        <property name="maximumConnectionCount" value="${proxool.maximum.connection.count}"/>
        <property name="minimumConnectionCount" value="${proxool.minimum.connection.count}" />
        <property name="statistics" value="${proxool.statistics}" />
        <property name="simultaneousBuildThrottle" value="${proxool.simultaneous.build.throttle}"/>
    </bean>

      <bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean" >
        <property name="dataSource" ref="dataSource"/>
        <property name="packagesToScan">
            <list>
                <value>com.cpic</value>
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">${hibernate.dialect}</prop>
                <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
                <prop key="hibernate.format_sql">true</prop>
                <prop key="hibernate.query.substitutions">${hibernate.query.substitutions}</prop>
                <prop key="hibernate.default_batch_fetch_size">${hibernate.default_batch_fetch_size}</prop>
                <prop key="hibernate.max_fetch_depth">${hibernate.max_fetch_depth}</prop>
                <prop key="hibernate.generate_statistics">${hibernate.generate_statistics}</prop>
                <prop key="hibernate.bytecode.use_reflection_optimizer">${hibernate.bytecode.use_reflection_optimizer}</prop>
                
                
                <prop key="hibernate.cache.use_second_level_cache">${hibernate.cache.use_second_level_cache}</prop>
                <prop key="hibernate.cache.use_query_cache">${hibernate.cache.use_query_cache}</prop>
                <prop key="hibernate.cache.region.factory_class">${hibernate.cache.region.factory_class}</prop>
                <prop key="net.sf.ehcache.configurationResourceName">${net.sf.ehcache.configurationResourceName}</prop>
                <prop key="hibernate.cache.use_structured_entries">${hibernate.cache.use_structured_entries}</prop>
                <prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop>
                
                <!-- 
                <prop key="hibernate.connection.datasource">${hibernate.connection.datasource}</prop>
                <prop key="hibernate.connection.provider_class">${hibernate.connection.provider_class}</prop>
                <prop key="hibernate.jndi.class">${hibernate.jndi.class}</prop>
                -->
                
            </props>
        </property>
      </bean>


    <!-- 开启AOP监听 只对当前配置文件有效 -->
    <aop:aspectj-autoproxy expose-proxy="true"/>
    
    <!-- 开启注解事务 只对当前配置文件有效 -->
      <tx:annotation-driven transaction-manager="txManager"/>

    <bean id="txManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>

    <tx:advice id="txAdvice" transaction-manager="txManager">
        <tx:attributes>
            <tx:method name="save*" propagation="REQUIRED" />
            <tx:method name="add*" propagation="REQUIRED" />
            <tx:method name="create*" propagation="REQUIRED" />
            <tx:method name="insert*" propagation="REQUIRED" />
            <tx:method name="update*" propagation="REQUIRED" />
            <tx:method name="merge*" propagation="REQUIRED" />
            <tx:method name="del*" propagation="REQUIRED" />
            <tx:method name="remove*" propagation="REQUIRED" />
            <tx:method name="put*" propagation="REQUIRED" />
            <tx:method name="use*" propagation="REQUIRED"/>
            <tx:method name="send*" propagation="REQUIRED" />
            <!--hibernate4必须配置为开启事务 否则 getCurrentSession()获取不到-->
            <tx:method name="get*" propagation="REQUIRED" read-only="true" />
            <tx:method name="count*" propagation="REQUIRED" read-only="true" />
            <tx:method name="find*" propagation="REQUIRED" read-only="true" />
            <tx:method name="list*" propagation="REQUIRED" read-only="true" />
            <tx:method name="*"  read-only="true" />
        </tx:attributes>
    </tx:advice>
    <aop:config expose-proxy="true">
        <!-- 只对业务逻辑层实施事务 -->
        <aop:pointcut id="txPointcut" expression="execution(* com.cpic..service.*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut"/>
    </aop:config>
    
    
    <!-- spring启动时加载spring工具类  -->
    <bean id="springUtils" class="com.cpic.common.util.SpringContextUtil"></bean>
    
</beans>

<bean id="textReceviService" class="com.cpic.basemsg.service.impl.TextReceviService"></bean>
    
    <bean id="eventReceviService" class="com.cpic.basemsg.service.impl.EventReceviService"></bean>
    
    <!-- 在线咨询 -->
    <bean id="onlineAskEventImpl" class="com.cpic.basemsg.service.event.impl.OnlineAskEventImpl"></bean>
    <!-- 卡单激活 -->
    <bean id="activeCareEventImpl" class="com.cpic.basemsg.service.event.impl.ActiveCareEventImpl"></bean>
    <!-- 客户回访 -->
    <bean id="custReVisEventImpl" class="com.cpic.basemsg.service.event.impl.CustReVisEventImpl"></bean>
    <!-- 道路救援 -->
    <bean id="roadHelpEventImpl" class="com.cpic.basemsg.service.event.impl.RoadHelpEventImpl"></bean>
    <!-- 自助报案 -->
    <bean id="selfPoliceEventImpl" class="com.cpic.basemsg.service.event.impl.SelfPoliceEventImpl"></bean>

    <bean id="wechatMng" class="com.cpic.basemsg.service.WeChatMng">
        <property name="map">
            <map>
                <entry key="text">
                    <ref local="textReceviService"/>
                </entry>
                <entry key="event">
                    <ref local="eventReceviService"/>
                </entry>
            </map>
        </property>
        
        <property name="baseMap">
            <map>
                <entry key="btn13">
                    <ref local="onlineAskEventImpl"/>
                </entry>
                <entry key="btn21">
                    <ref local="roadHelpEventImpl"/>
                </entry>
                <entry key="btn22">
                    <ref local="selfPoliceEventImpl"/>
                </entry>
                <entry key="btn23">
                    <ref local="custReVisEventImpl"/>
                </entry>
                <entry key="btn24">
                    <ref local="activeCareEventImpl"/>
                </entry>
            </map>
        </property>
    </bean>

package com.cpic.basemsg.service;

import java.util.Map;

/**
 * 设计这个类，主要是为了解耦，可实现对逻辑层的配置，将业务更细化
 * 将一些共同特性统一处理
 * @author wuxw
 *
 */
public class WeChatMng {
    
    static Logger logger = Logger.getLogger(WeChatMng.class);
    
    @SuppressWarnings("unchecked")
    public WeChatService weChatService;
    
    @SuppressWarnings("unchecked")
    private Map<String,WeChatService> map;
    
    private Map<String,BaseEventService> baseMap;
    
    /** 点击事件*/
    public BaseEventService baseEventService;
    

    public void setMap(Map<String, WeChatService> map) {
        this.map = map;
    }


    public void setBaseMap(Map<String, BaseEventService> baseMap) {
        this.baseMap = baseMap;
    }


    /**
     * 对不同消息类型的控制转发
     * @param msgType
     * @param wxMsgXml
     * @return
     */
    public String process(String msgType,String wxMsgXml) throws BaseMsgException{
        if(msgType == null || msgType == ""){
            logger.error("请求消息：" + msgType);
            throw new BaseMsgException("请求消息为空！");
        }
        weChatService = map.get(msgType);
        if(null == weChatService){
            throw new BaseMsgException("不支持的接口类型：" + msgType);
        }
        return weChatService.process(wxMsgXml);
    }
    
    
    /**
     * 对不同事件的控制转发 
     * @parama clickKey  按钮编号
     * @return
     * @throws BaseMsgException 业务异常
     */
    public String processEvent(String click,EventMsgModel model) throws BaseMsgException{
        if(click == null){
            throw new BaseMsgException("不存在的点击事件：" + click);
        }
        if(model == null){
            throw new BaseMsgException("传入的事件消息为null!" );
        }
        baseEventService = baseMap.get(click);
        if(baseEventService == null){
            throw new BaseMsgException("暂时不支持的点击参数:" + click);
        }
        return baseEventService.process(model);
    }
    
}

/**
 * 抽象出功能模块
 * 信息的处理流程分三步依次进行：
 *         1. 接收信息
 *         2. 处理信息
 *         3. 返回信息
 * 并且这个顺序不能变,强制使用处理信息的流程
 * 我们只需要关心业务处理的方式
 * @author wuxw
 *
 */
public abstract class WeChatServiceAbs<T extends BaseMsgModel> extends CommonHibernateDao implements WeChatService<BaseMsgModel> {
    
    /**
     * 处理消息，用模版的形式对各模块独立
     * @param xmlMsg    传入消息
     * @return            返回处理后的消息
     * @throws WeChatException
     */
    public String process(String xmlMsg) throws BaseMsgException{
        MsgModel msg = reviceMsg(xmlMsg);
        return processMsg(msg).toString();
    }
}