modify_定时任务

common/src/main/java/com/behosoft/lis/common/subscriber/BsCarriertrackingStatusFeedbackSubscriber.java

@@ -50,7 +50,7 @@ import com.wondersgroup.saas.util.JSONUtil;
  * @author (lastest modification by  )
  * @since 1.0
  */
-public class BsCarriertrackingStatusFeedbackSubscriber extends AbstractDataSubscriber<WrappedMessage>{
+public class BsCarriertrackingStatusFeedbackSubscriber{
 	private final Log logger = LogFactory.getLog(this.getClass());
 	@Autowired
 	private AccountConfigService accountConfigService;
@@ -64,10 +64,7 @@ public class BsCarriertrackingStatusFeedbackSubscriber extends AbstractDataSubsc
 	@Autowired
 	private DeliverDocumentService deliverDocumentService;
 	
-	@Override
-	public void receive(WrappedMessage param) {
-		List<Serializable> serializables = ((SerializableMessage) param).getFilteredObjects();
-		Date date = (Date) serializables.get(0);
+	public void receive() {
 //		logger.info("enter BsCarriertrackingStatusFeedbackSubscriber get date is:" + date);
 		
 		List<AccountConfig> accountConfigList = accountConfigService.getValueByKey("BS_CUSTOMER_CODE");

common/src/main/java/com/behosoft/lis/common/subscriber/DailyCleanLocationContainerSubscriber.java

@@ -38,18 +38,18 @@ import com.wondersgroup.saas.message.subscribe.AbstractDataSubscriber;
  * @author (lastest modification by )
  * @since 1.0
  */
-public class DailyCleanLocationContainerSubscriber extends AbstractDataSubscriber<WrappedMessage> {
+public class DailyCleanLocationContainerSubscriber{
 
 	private final Log logger = LogFactory.getLog(this.getClass());
 
 	@Autowired
 	private LocationContainerService locationContainerService;
 
-	@Override
-	public void receive(WrappedMessage param) {
-		List<Serializable> serializables = ((SerializableMessage) param).getFilteredObjects();
-		Date date = (Date) serializables.get(0);
-		logger.info("DailyInventorySubscriber get date is:" + date);
+//	@Override
+	public void receive() {
+//		List<Serializable> serializables = ((SerializableMessage) param).getFilteredObjects();
+//		Date date = (Date) serializables.get(0);
+//		logger.info("DailyInventorySubscriber get date is:" + date);
 		// 调用service执行每日库存清理
 		int row = this.locationContainerService.dailyCleanLocationContainer();
 		logger.info("DailyCleanLocationContainerSubscriber完成删除" + row + "行记录！");

web-clis/src/main/resources/config/lis/applicationContext.xml

@@ -32,16 +32,26 @@
 
 
 	<!--<context:component-scan base-package="com.behosoft.lis.common.subscriber" />-->
-	<!--采购入库反馈-->
+	<!--百胜采购入库反馈-->
 	<task:scheduled-tasks>
-		<task:scheduled ref="BsOmsPickInboundFeedbackSubscriberBean" method="receive" cron="0 0/10 * * * ?" />
+		<task:scheduled ref="BsOmsPickInboundFeedbackSubscriberBean" method="receive" cron="0 0/10 8-20 * * ?" />
 	</task:scheduled-tasks>
 	<bean id="BsOmsPickInboundFeedbackSubscriberBean" class="com.behosoft.lis.common.subscriber.BsOmsPickInboundFeedbackSubscriber"/>
-	<!--销售出库反馈-->
+	<!--百胜销售出库反馈-->
 	<task:scheduled-tasks>
-		<task:scheduled ref="BsOmsDeliveryOutboundFeedbackSubscriberBean" method="receive" cron="0 0/5 * * * ?" />
+		<task:scheduled ref="BsOmsDeliveryOutboundFeedbackSubscriberBean" method="receive" cron="0 0/5 8-20 * * ?" />
 	</task:scheduled-tasks>
 	<bean id="BsOmsDeliveryOutboundFeedbackSubscriberBean" class="com.behosoft.lis.common.subscriber.BsOmsDeliveryOutboundFeedbackSubscriber"/>
+	<!--百胜快递状态反馈-->
+	<task:scheduled-tasks>
+		<task:scheduled ref="BsCarriertrackingStatusFeedbackSubscriberBean" method="receive" cron="0 0/10 8-20 * * ?" />
+	</task:scheduled-tasks>
+	<bean id="BsCarriertrackingStatusFeedbackSubscriberBean" class="com.behosoft.lis.common.subscriber.BsCarriertrackingStatusFeedbackSubscriber"/>
+
+	<task:scheduled-tasks>
+		<task:scheduled ref="DailyCleanLocationContainerSubscriberBean" method="receive" cron="0 0 2 * * ?" />
+	</task:scheduled-tasks>
+	<bean id="DailyCleanLocationContainerSubscriberBean" class="com.behosoft.lis.common.subscriber.DailyCleanLocationContainerSubscriber"/>