actitve-process/.svn/pristine/5a/5a7c259185d43763adf24713b8cbda93505f9084.svn-base

<?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:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:cache="http://www.springframework.org/schema/cache" xmlns:task="http://www.springframework.org/schema/task"
	xsi:schemaLocation="    
        http://www.springframework.org/schema/beans     
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd    
        http://www.springframework.org/schema/context     
        http://www.springframework.org/schema/context/spring-context-3.0.xsd 
        http://www.springframework.org/schema/cache    
        http://www.springframework.org/schema/cache/spring-cache-3.1.xsd    
        http://www.springframework.org/schema/task 
    	http://www.springframework.org/schema/task/spring-task-3.0.xsd ">

	<context:component-scan base-package="com.chinacreator"></context:component-scan>
	<cache:annotation-driven cache-manager="cacheManager" />

	<bean id="cacheManagerFactory"
		class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean"
		p:configLocation="classpath:ehcache.xml" p:shared="false" />

	<bean id="cacheManager" class="com.chinacreator.common.support.cache.EhCacheManager"
		p:cacheManager-ref="cacheManagerFactory" /> 
	<!-- 引用@Autowired必须定义这个bean --> 
    <bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/> 
    
	<bean id="activeMQConfig" class="org.springframework.beans.factory.config.PropertiesFactoryBean">
		<property name="locations">
			<value>classpath:activeMQ.properties</value>
		</property>
	</bean>
 
	<bean id="activeMQPropertyConfigurer" class="org.springframework.beans.factory.config.PreferencesPlaceholderConfigurer">
		<property name="properties" ref="activeMQConfig" />
	</bean>
	
	<bean id="redeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy">
		<!-- 失败重发次数， 超过此次数后， 消息会转化至ActiveMQ.DLQ -->
		<property name="maximumRedeliveries" value="10" />
	</bean>
	
	<bean id="prefetchPolicy" class="org.apache.activemq.ActiveMQPrefetchPolicy">
		<!-- 消息量限制 -->
		<property name="queuePrefetch" value="10" />
	</bean>

	<bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="${activemq.brokerURL}" />
		<property name="userName" value="${activemq.userName}" />
		<property name="password" value="${activemq.password}" />
		<property name="prefetchPolicy" ref="prefetchPolicy" />
		<property name="redeliveryPolicy" ref="redeliveryPolicy" />
		<property name="useAsyncSend" value="true" />
		<property name="optimizeAcknowledge" value="true" />
		<property name="optimizeAcknowledgeTimeOut" value="30000" />
	</bean>

	<bean id="connectionFactory"
		class="org.springframework.jms.connection.CachingConnectionFactory">
		<constructor-arg ref="amqConnectionFactory" />
		<property name="sessionCacheSize" value="${activemq.sessionsize}" />
	</bean>

	<!-- 消息转换 -->
	<bean id="messageConverter" class="com.chinacreator.video.queue.converter.SerializeMessageConverter" />

	<!-- 消息操作模板 -->
	<bean id="jmsTemplate" class="org.springframework.jms.core.BatchedJmsTemplate">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="messageConverter" ref="messageConverter" />
		<property name="pubSubDomain" value="false" />
		<property name="sessionTransacted" value="true" />
		<property name="receiveTimeout" value="1000" />
		<property name="batchSize" value="100" />
	</bean>

	<!-- 保存使用队列发送失败的消息 -->
	<bean id="queueDao" class="com.chinacreator.video.queue.dao.QueueDao" />

	<!-- 消息发送及同步接收 -->
	<bean id="messageService" class="com.chinacreator.video.queue.MessageService" />
	
	<!-- 采集活动数据 -->
	<bean id="reciveMQ" class="com.chinacreator.process.job.ReciveMQJob"></bean>
	
	<bean id="channelOrder" class="com.chinacreator.process.job.ChannelOrderJob"></bean>
	
	<!--<bean id="validateChage" class="com.chinacreator.process.job.ValidateJob">
	</bean>-->
	
	<bean id="channelUpdate" class="com.chinacreator.process.job.UpdateChannelJob"></bean>
	
	<bean id="cleanCahe" class="com.chinacreator.process.job.CleanCaheJob"></bean>
	
	<bean id="hnsms" class="com.chinacreator.process.job.HnSmsJob"></bean>
	
	<bean id="csorder" class="com.chinacreator.process.job.CSactivityJob"></bean>
	
	<bean id="kafka" class="com.chinacreator.process.job.KafkaMonitorJob"></bean>
	
	<!--
	<bean id="cssms" class="com.chinacreator.process.job.CShandleSmsJob">
	</bean>
	  -->
	  
	<bean id="cssms" class="com.chinacreator.process.job.CShandleSmsConfJob"></bean>
	
	<bean id="vacorder" class="com.chinacreator.process.job.VacMQJob"></bean>
	
	<bean id="continuevip" class="com.chinacreator.process.job.ContinueVIP"></bean>
	
	<bean id="tencentvacorder" class="com.chinacreator.process.job.TencentActivityJob"></bean>
	
	<bean id="tencent12notify" class="com.chinacreator.process.job.Tencent12NotifyJob"></bean>
	
	<bean id="kafkachange" class="com.chinacreator.process.job.KafkaTransJob"></bean>

	<bean id="oms" class="com.chinacreator.process.job.OrderSmsMonthJob"></bean>

    <bean id="oFhSms" class="com.chinacreator.process.job.OrderFhProSmsMonthJob"></bean>

    <bean id="vipLimitBlack" class="com.chinacreator.process.job.VipLimitBlackJob"></bean>
    
    <bean id="pointshop" class="com.chinacreator.process.job.PointShopMQJob"></bean>
    
    <bean id="vipretry" class="com.chinacreator.process.job.VipRetryMQJob"></bean>
    
    <bean id="youtuvip" class="com.chinacreator.process.job.YoutuVipMQJob"></bean>
    
    <bean id="kuaishoupush" class="com.chinacreator.process.job.KuaiShouPushMQJob"></bean>
    
    <bean id="Kuaishoupushmonth" class="com.chinacreator.process.job.KuaishouPushMonthJob"></bean>
    
    <bean id="KuaishouPushOrder" class="com.chinacreator.process.job.KuaishouPushOrderJob"></bean>
    
    <bean id="mangtvpush" class="com.chinacreator.process.job.MangtvPushMQJob"></bean>

    <bean id="douyinretry" class="com.chinacreator.process.job.DouyinRetryMQJob"></bean>  
    
    <bean id="backbusivipasyn" class="com.chinacreator.process.job.BackBusiVipAsynJob"></bean>     
<!--	<bean id="contsendvipcollect" class="com.chinacreator.process.job.ContSendVipCollectJob"></bean>-->
	
	<bean id="changshiPushMQJob" class="com.chinacreator.process.job.ChangshiPushMQJob"></bean>
	<bean id="unicomsmsorder" class="com.chinacreator.process.job.UnicomSmsOrderJob"></bean>
	<bean id="queryPrmDataJob" class="com.chinacreator.process.job.QueryPrmDataJob"></bean>
	
	<bean id="channelOrderAsynJob" class="com.chinacreator.process.job.ChannelOrderAsynJob"></bean>
	<bean id="taobSyncJob" class="com.chinacreator.process.job.TaobSyncJob"></bean>
	<bean id="everysmsJob" class="com.chinacreator.process.job.EverySmsJob"></bean>
	<!--博源数据推送-->
	<bean id="BoyuanPushData" class="com.chinacreator.process.job.BoYuanSyncJob"></bean>
	<!--违约金订购-->
	<bean id="WyjAsyncOrderJob" class="com.chinacreator.process.job.WyjAsyncOrderJob"></bean>

	<!-- 前端页面订购生成活动关系 -->
    <bean id="reciveOnlineMQ" class="com.chinacreator.process.job.ReciveOnlineMQJob"></bean>
    <!-- 反向通知订购生成活动关系 -->
	<bean id="reciveOfflineMQ" class="com.chinacreator.process.job.ReciveOfflineMQJob"></bean>
	<!-- 生成活动关系后实时送会员 -->
	<bean id="recivesendvipMQ" class="com.chinacreator.process.job.ReciveSendVipMQJob"></bean>
	<!-- 扫表生成活动关系后实时送会员 -->
	<bean id="recivewaitMQ" class="com.chinacreator.process.job.ReciveWaitMQJob"></bean>
	<bean id="orderPushJob" class="com.chinacreator.process.job.OrderPushJob"></bean>
	<!-- 快手月初推送处理 -->
    <bean id="kuaishouPushMonthNewJob" class="com.chinacreator.process.job.KuaishouPushMonthNewJob"></bean>	
    <!-- 快手订购推送处理 -->
    <bean id="KuaishouPushOrderNew" class="com.chinacreator.process.job.KuaishouPushOrderNewJob"></bean>
<!--    <bean id="testjob" class="com.chinacreator.process.job.TestJob"></bean>-->
	<bean id="QueryCapOrderJob" class="com.chinacreator.process.job.QueryCapOrderJob"></bean>
	<!-- 手动赠送会员数据发送短信 -->
	<bean id="VipSmsSpidSendJob" class="com.chinacreator.process.job.VipSmsSpidSendJob"></bean>
	<bean id="CShandleSmsTempJob" class="com.chinacreator.process.job.CShandleSmsTempJob"></bean>
   <bean id="KuaishouFlowMonthJob" class="com.chinacreator.process.job.KuaishouFlowMonthJob"></bean>
	<!-- 查询快手激活状态	-->
	<bean id="KuaiShouActivationStateMonthJob" class="com.chinacreator.process.job.KuaiShouActivationStateMonthJob"></bean>
	<bean id="KuaishouFlowMonthPart2Job" class="com.chinacreator.process.job.KuaishouFlowMonthPart2Job"></bean>
	<task:scheduler id="scheduler" pool-size="8" />
	<task:scheduled-tasks scheduler="scheduler" >

	<task:scheduled ref="KuaishouFlowMonthPart2Job" method="doProcess" cron="0 0/1 * * * ?" />
	<task:scheduled ref="KuaiShouActivationStateMonthJob" method="doProcess" cron="0/5 * * * * ?" />

	<!--
	<task:scheduled ref="KuaishouFlowMonthJob" method="doProcess" cron="0 0/2 * * * ?" />
	<task:scheduled ref="channelOrder" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="CShandleSmsTempJob" method="doProcess" cron="0/5 * * * * ?" />  

    <task:scheduled ref="VipSmsSpidSendJob" method="doProcess" cron="0 0/2 * * * ?" />
    <task:scheduled ref="QueryCapOrderJob" method="doProcess" cron="0/1 * * * * ?" />
    <task:scheduled ref="reciveOnlineMQ" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="reciveOfflineMQ" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="recivesendvipMQ" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="recivewaitMQ" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="backbusivipasyn" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="kafkachange" method="doProcess" cron="0/1 * * * * ?" />
    <task:scheduled ref="backbusivipasyn" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="channelOrderAsynJob" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="changshiPushMQJob" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="queryPrmDataJob" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="taobSyncJob" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="kafkachange" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="vacorder" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="tencent12notify" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="tencentvacorder" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="continuevip" method="doProcess" cron="0 30 5 1 * ?" /> 
	
	<task:scheduled ref="contsendvipcollect" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="unicomsmsorder" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="mangtvpush" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="continuevip" method="doProcess" cron="0 30 5 1 * ?" />
	<task:scheduled ref="channelOrder" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="mangtvpush" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="kuaishoupush" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="douyinretry" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="Kuaishoupushmonth" method="doProcess" cron="0 30 0 1 * ?" />
	<task:scheduled ref="KuaishouPushOrder" method="doProcess" cron="0 0/5 * * * ?" /> 
	<task:scheduled ref="Kuaishoupushmonth" method="doProcess" cron="0 30 0 1 * ?" />
	<task:scheduled ref="KuaishouPushOrderNew" method="doProcess" cron="0/5 * * * * ?" />
	<task:scheduled ref="testjob" method="doProcess" cron="0/5 * * * * ?" />
	<task:scheduled ref="KuaishouPushOrder" method="doProcess" cron="0 0/5 * * * ?" />
	<task:scheduled ref="csorder" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="reciveMQ" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="youtuvip" method="doProcess" cron="0 0/1 * * * ?" />
	<task:scheduled ref="kafka" method="doProcess" cron="0/30 * * * * ?" />
	<task:scheduled ref="channelUpdate" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="cleanCahe" method="doProcess" cron="0 0/30 * * * ?" />
	<task:scheduled ref="hnsms" method="doProcess" cron="0/10 * * * * ?" />
	<task:scheduled ref="cssms" method="doProcess" cron="0/1 * * * * ?" />
       
	<task:scheduled ref="oms" method="doProcess" cron="0 10 0 1 * ?" />
    <task:scheduled ref="oFhSms" method="doProcess" cron="0 10 0 1 * ?" />
	<task:scheduled ref="vipLimitBlack" method="doProcess" cron="0 0/30 * * * *" />
	<task:scheduled ref="pointshop" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="vipretry" method="doProcess" cron="0/1 * * * * ?" />
	<task:scheduled ref="orderPushJob" method="doProcess" cron="0 0/5 * * * ?"/>
	<task:scheduled ref="BoyuanPushData" method="doProcess" cron="0 */1 * * * ?" />
-->
</task:scheduled-tasks>
</beans>