pdd-order-api/app/libs/const/class.QueueConst.php

<?php

class QueueConst {
	const orderCareRsyncQueue = 'order_care_rsync_queue';
	const orderFullRsyncQueue = 'order_full_rsync_queue';
	const orderQuickRsyncQueue = 'order_quick_rsync_queue';
	
	const wareQuickRsyncQueue = 'goods_quick_rsync_queue';
	const wareFullRsyncQueue = 'goods_full_rsync_queue';
	
	const crmMemberFullRsyncQueue = 'crm_member_full_rsync_queue';
	const crmMemberQuickRsyncQueue = 'crm_member_quick_rsync_queue';
	
	const titleKeywordRsyncQueue = 'title_keyword_rsync_queue';
	
	const statusProcessing = 'processing';
	const statusWait = 'wait';
	const statusFinish = 'finish';
	
	const rsyncTypeFixupRsync = 'fixup_rsync';

	const maxOpOrderRsyncRiskQueueCount = 500;
	const maxMoveImportTaskQueueCount = 500;
	const maxRsyncSingleOpOrderQueueCount = 500;

	public static function getQueueIdColumnName($queueName) {
		return $queueName . '_id';
	}
	
	public static function getRsyncLogTbl($queueName) {
		$rsyncLogMap = array (
				'goods_full_rsync_queue' => 'goods_rsync_log',
				'goods_quick_rsync_queue' => 'goods_rsync_log',
		);
		return $rsyncLogMap[$queueName];
	}
	
	public static function getRsyncInfoTbl($queueName) {
		$rsyncInfoMap = array (
				'goods_full_rsync_queue' => 'goods_rsync_info',
				'goods_quick_rsync_queue' => 'goods_rsync_info',
		);
		return $rsyncInfoMap[$queueName];
	}
	
	public static function getRsyncErrorMakeupTbl($queueName) {
		$rsyncErrorMakeupMap = array (
			'goods_full_rsync_queue' => 'goods_rsync_error_makeup',
			'goods_quick_rsync_queue' => 'goods_rsync_error_makeup',
		);
		return $rsyncErrorMakeupMap[$queueName];
	}
}