Files
OMS/app/taskmgr/lib/whitelist.php
2026-01-04 19:08:31 +08:00

502 lines
25 KiB
PHP
Raw Permalink Blame History

This file contains ambiguous Unicode characters
This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.
<?php
/**
* Copyright 2012-2026 ShopeX (https://www.shopex.cn)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
class taskmgr_whitelist
{
//进队列业务逻辑处理任务
public static function task_list()
{
return $_tasks = array(
'autochk' => array(
'method' => 'wms_autotask_task_check',
'threadNum' => 5,
'retry' => true,
'timeout' => 120,
),
'autodly' => array(
'method' => 'wms_autotask_task_consign',
'threadNum' => 5,
'retry' => true,
'timeout' => 360,
),
'autorder' => array(
'method' => 'ome_autotask_task_combine',
'threadNum' => 5,
'retry' => true,
'timeout' => 120,
'name' => '审单队列',
), //自动审单
'pre_select_branch' => array(
'method' => 'ome_autotask_task_preselectbranch',
'threadNum' => 5,
'retry' => true,
'timeout' => 120,
'name' => '提前选仓',
), //自动审单
'autoretryapi' => array(
'method' => 'erpapi_autotask_task_retryapi',
'threadNum' => 5,
'retry' => true,
'timeout' => 120,
),
'autowapdly' => array('method' => 'o2o_autotask_task_statistic', 'threadNum' => 1), //wap统计发货单数据
'ordertaking' => array(
'method' => 'ome_autotask_task_ordertaking',
'threadNum' => 5,
'retry' => true,
'timeout' => 120,
),
'confirmreship' => array(
'method' => 'ome_autotask_task_confirmreship',
'threadNum' => 5,
'retry' => true,
'timeout' => 180,
), //售后退货单
'confirminventory' => array(
'method' => 'ome_autotask_task_confirminventory',
'threadNum' => 1,
'retry' => true,
'timeout' => 180,
), //盘点确认
// 'stocksync' => array('method' => 'ome_autotask_task_stocksync', 'threadNum' => 5), // 库存检查
'dailyinventory' => array(
'method' => 'console_autotask_timer_dailyinventory',
'threadNum' => 1,
'timeout' => 180,
),
'syncaoxiang' => array(
'method' => 'dchain_autotask_syncproduct', //请求同步翱象商品
'threadNum' => 1,
'timeout' => 180,
),
'mappingaoxiang' => array(
'method' => 'dchain_autotask_mappingproduct', //请求同步翱象商品关系
'threadNum' => 1,
'timeout' => 180,
),
'aoxiangdelivery' => array(
'method' => 'dchain_autotask_syncdelivery', //请求同步翱象发货单
'threadNum' => 1,
'timeout' => 180,
),
'inventorydepthproduct' => array(
'method' => 'ome_autotask_task_inventorydepthproduct', //具体商品发起库存回写
'threadNum' => 5,
'timeout' => 180,
),
);
}
//定时任务,线程数不允许修改
public static function timer_list()
{
return $_tasks = array(
'misctask' => array('method' => 'ome_autotask_timer_misctask', 'threadNum' => 1), // 系统定时任务分、时、天、周、月任务
'inventorydepth' => array('method' => 'ome_autotask_timer_inventorydepth', 'threadNum' => 1), // 库存回写
// 'batchfill' => array('method' => 'ome_autotask_timer_batchfill', 'threadNum' => 1), // 订单补单任务
'cleandata' => array('method' => 'ome_autotask_timer_cleandata', 'threadNum' => 1), // 清理数据
'hour' => array('method' => 'ome_autotask_timer_hour', 'threadNum' => 1), // 按小时执行的任务,里面很杂
'cancelorder' => array('method' => 'ome_autotask_timer_cancelorder', 'threadNum' => 1), // 自动取消过期未支付且未确认的订单(除货到付款)
// 'ordersprice' => array('method' => 'ome_autotask_timer_ordersprice', 'threadNum' => 1), // 客单价分布情况
// 'orderstime' => array('method' => 'ome_autotask_timer_orderstime', 'threadNum' => 1), // 订单时间分布情况
// 'rmatype' => array('method' => 'ome_autotask_timer_rmatype', 'threadNum' => 1), // 售后类型分布统计
'sale' => array('method' => 'ome_autotask_timer_sale', 'threadNum' => 1), // 销售情况/退货率统计
// 'storestatus' => array('method' => 'ome_autotask_timer_storestatus', 'threadNum' => 1), // 仓库状态统计
'stockcost' => array('method' => 'tgstockcost_autotask_timer_stockcost', 'threadNum' => 1), // OMS库存快照
'wms_sync_inv' => array('method' => 'console_autotask_timer_invsnapshot', 'threadNum' => 1), // WMS库存快照
'logistestimate' => array('method' => 'ome_autotask_timer_logistestimate', 'threadNum' => 1), // 物流预估账单
'queue' => array('method' => 'ome_autotask_timer_queue', 'threadNum' => 1, 'name'=>'系统任务队列'), // 系统任务队列
// 'stocknsale' => array('method' => 'ome_autotask_timer_stocknsale', 'threadNum' => 1, 'retry' => false), // 呆滞库存统计
// 'productnsale' => array('method' => 'ome_autotask_timer_productnsale', 'threadNum' => 1, 'retry' => false), // 不动销商品统计
// 'storedaliy' => array('method' => 'o2o_autotask_timer_storedaliy', 'threadNum' => 1), // 门店订单统计
'vopurchase' => array('method' => 'ome_autotask_timer_vopurchase', 'threadNum' => 1), // VOP采购单下载
'vopick' => array('method' => 'ome_autotask_timer_vopick', 'threadNum' => 1), // VOP拣货单下载
'vopickinventory' => array('method' => 'ome_autotask_timer_vopickinventory', 'threadNum' => 1), // VOP销售单下载
// 'logisticsanalysts' => array('method' => 'ome_autotask_timer_logisticsanalysts', 'threadNum' => 1), // 仓储物流配送统计
// 'syncdlystatus' => array('method' => 'ome_autotask_timer_syncdlystatus', 'threadNum' => 1),
// 'syncwms' => array('method' => 'erpapi_autotask_task_sync', 'threadNum' => 1),
'financebasejob' => array('method' => 'financebase_autotask_timer_job', 'threadNum' => 1), // 财务基础数据定时任务
'sysordertaking' => array('method' => 'ome_autotask_timer_sysordertaking', 'threadNum' => 1), // 定时审单任务
'delaymisc' => array('method' => 'ome_autotask_timer_delaymisc', 'threadNum' => 1), // 延时定时审单任务
'batchchannelmaterial' => array('method' => 'material_autotask_timer_batchchannelmaterial', 'threadNum' => 1), // 定时同步物料至WMS
'orderdiscounts' => array('method'=>'omeanalysts_autotask_timer_orderdiscounts', 'threadNum'=>1), // 订单优惠明细统计
'vopbill' => array('method' => 'vop_autotask_timer_bill', 'threadNum' => 1), // 唯品会账单
'vopreturn' => array('method' => 'ome_autotask_timer_vopreturn', 'threadNum' => 1), // 唯品会退货单
'aoxiangsync' => array('method'=>'dchain_autotask_aoxiangsync', 'threadNum'=>1), // 翱象同步商品
'aoxiangmapping' => array('method'=>'dchain_autotask_aoxiangmapping', 'threadNum'=>1), // 翱象同步商品关系
'dailyinvmonitor' => array('method' => 'console_autotask_timer_dailyinvmonitor', 'threadNum' => 1), // 库存核对报警通知
'sendnotify' => array('method'=>'monitor_autotask_timer_sendnotify', 'threadNum'=>1), // 报警通知
'invoice_makeoutinvoice' => array('method' => 'invoice_autotask_timer_makeoutinvoice', 'threadNum' => 1), // 开具发票
'invoice_redapply_sync' => array('method' => 'invoice_autotask_timer_redapply_sync', 'threadNum' => 1), // 红冲申请同步
'jit_vreturn_diff' => array('method' => 'vop_autotask_timer_vreturndiff', 'threadNum' => 1), // 唯品会退供差异单
'sync_branch_freeze_decr' => array('method'=>'ome_autotask_timer_branchfreezedecr', 'threadNum' => 1), // 后置仓更新冻结
'sync_sku_freeze_decr' => array('method'=>'ome_autotask_timer_skufreezedecr', 'threadNum' => 1), // 后置商品更新冻结
'check_freeze_store' => array('method'=>'monitor_autotask_timer_checkfreezestore', 'threadNum' => 1), // 对比ome_branch_product和basic_material_stock_freeze
// 'clean_freeze_queue' => array('method'=>'monitor_autotask_timer_cleanfreezequeue', 'threadNum' => 1), // 清理冻结队列
'ediws_accountorders'=>array('method'=>'ediws_autotask_timer_accountorders', 'threadNum' => 1),// EDI实销实结明细
'ediws_accountsettlement'=>array('method'=>'ediws_autotask_timer_accountsettlement', 'threadNum' => 1),// EDI结算单
'ediws_shppackage'=>array('method'=>'ediws_task_shippackage', 'threadNum' => 1),// EID退供
'ediws_reship'=>array('method'=>'ediws_task_reship', 'threadNum' => 1),// EDI主库退货单
'o2o_syncproduct'=>array('method'=>'o2o_autotask_timer_syncproduct','threadNum' => 1), // 批量同步商品到O2O
'ediws_refundinfo'=>array('method'=>'ediws_task_refundinfo', 'threadNum' => 1),// EDI退货
'sync_shop_skus'=>array('method'=>'inventorydepth_autotask_timer_shopskus', 'threadNum' => 1, 'timeout' => 180),// 下载缓存商品
'check_order_is_delivery' => array('method'=>'monitor_autotask_timer_checkorderisdelivery', 'threadNum' => 1),
'o2oundelivery' => array('method'=>'monitor_autotask_timer_o2oundelivery', 'threadNum'=>1),
// 'retry_delivery_cancel_to_wms'=>array('method'=>'ome_autotask_timer_retrydeliverycancel', 'threadNum' => 1),// 重试推送wms发货单取消
'ediws_fixaccountorders'=>array('method'=>'ediws_autotask_timer_fixaccountorders', 'threadNum' => 1),// EDI实销实结明细补拉任务
'invoice_queryinvoicelist' => array('method' => 'invoice_autotask_timer_queryinvoicelist', 'threadNum' => 1),
);
}
//初始化域名进任务队列,这里的命名规范就是实际连的队列任务+domainqueue生成这个初始化任务的数组值线程数不允许修改
public static function init_list()
{
return $_tasks = array(
'misctaskdomainqueue' => array(
'threadNum' => 1,
'rule' => '*/30 * * * * *',
),
'inventorydepthdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */5 * * * *',
),
// 'batchfilldomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 */30 * * * *',
// ),
'cleandatadomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 1 * * *',
),
'hourdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
'cancelorderdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */10 * * * *',
),
// 'orderspricedomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 1 * * *',
// ),
// 'orderstimedomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 1 * * *',
// ),
// 'rmatypedomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 2 * * *',
// ),
'saledomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 2 * * *',
),
// 'catsalestatisdomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 3 * * *',
// ),
// 'productsalerankdomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 3 * * *',
// ),
// 'storestatusdomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 4 * * *',
// ),
'stockcostdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 1 * * *',//OMS库存快照生成时间要早于wms_sync_invdomainqueue获取WMS物料库存执行时间
),
'wms_sync_invdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 2 * * *',
),
'logistestimatedomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 5 * * *',
),
// 'stocknsaledomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 1 * * *',
// ),
// 'productnsaledomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 2 * * *',
// ),
// 'storedaliydomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 3 * * *',
// ),
'vopurchasedomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
'vopickdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */5 * * * *',
),
'vopickinventorydomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */2 * * * *',
),
// 'logisticsanalystsdomainqueue' => array(
// 'threadNum' => 1,
// 'rule' => '0 0 3 * * *',
// ),
'financebasejobdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 * * * * *',
),
'sysordertakingdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */1 * * * *',
),
'delaymiscdomainqueue' => array(
'threadNum' => 1,
'rule' => '*/10 * * * * *',
),
'batchchannelmaterialdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */10 * * * *',
),
'orderdiscountsdomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'vopbilldomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'vopreturndomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'aoxiangsyncdomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
'aoxiangmappingdomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
'dailyinvmonitordomainqueue' => array(
'threadNum' => 1,
'rule' => '0 0 8 * * *',
),
'sendnotifydomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */5 * * * *',
),
'invoice_makeoutinvoicedomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 */10 * * * *',
),
'invoice_redapply_sync' => array(
'threadNum' => 1,
'rule' => '0 */30 * * * * ',
),
'jitsaledomainqueue' => array(
'threadNum' => 1,
'rule' => '0 */5 * * * * ',
),
'jit_vreturn_diff' => array(
'threadNum' => 1,
'rule' => '0 0 * * * * ',
),
'sync_branch_freeze_decrdomainqueue'=>array(
'threadNum' => 1,
'rule' => '*/1 * * * * *',
),
'sync_sku_freeze_decrdomainqueue'=>array(
'threadNum' => 1,
'rule' => '*/1 * * * * *',
),
'check_freeze_storedomainqueue'=>array(
'threadNum' => 1,
'rule' => '*/60 * * * * *',
),
// 'clean_freeze_queuedomainqueue'=>array(
// 'threadNum' => 1,
// 'rule' => '0 6 0 * * *', // 00:06:00
// ),
'ediws_accountorders'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'ediws_accountsettlement'=>array(
'threadNum' => 1,
'rule' => '0 0 2 * * *',
),
'ediws_shppackage'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'ediws_reship'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'o2o_syncproductdomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * * ',
),
'ediws_refundinfo'=>array(
'threadNum' => 1,
'rule' => '0 */30 * * * *',
),
'sync_shop_skus'=>array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
'check_order_is_deliverydomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 */20 * * * *',
),
'o2oundeliverydomainqueue'=>array(
'threadNum' => 1,
'rule' => '0 0 * * * *',
),
// 'retry_delivery_cancel_to_wms'=>array(
// 'threadNum' => 1,
// 'rule' => '0 */5 * * * *',
// ),
'ediws_fixaccountorders'=>array(
'threadNum' => 1,
'rule' => '0 0 3 * * *',
),
// 'retry_reship_cancel_to_wms'=>array(
// 'threadNum' => 1,
// 'rule' => '0 */5 * * * *',
// ),
'invoice_queryinvoicelist'=>array(
'threadNum' => 1,
'rule' => '0 */15 * * * *',
),
);
}
//导出任务
public static function export_list()
{
return $_tasks = array(
'exportsplit' => array(
'method' => 'ome_autotask_export_exportsplit',
'threadNum' => 5,
'retry' => true,
'timeout' => 180,
'name' => '导出数据分片队列',
),
'dataquerybysheet' => array(
'method' => 'ome_autotask_export_dataquerybysheet',
'threadNum' => 5,
'retry' => true,
'timeout' => 600,
'name' => '分页导出队列',
),
'dataquerybyquicksheet' => array(
'method' => 'ome_autotask_export_dataquerybyquicksheet',
'threadNum' => 5,
'retry' => true,
'timeout' => 600,
'name' => '快速导出队列',
),
'dataquerybywhole' => array(
'method' => 'ome_autotask_export_dataquerybywhole',
'threadNum' => 5,
'retry' => true,
'timeout' => 3600,
'name' => '完整导出队列',
),
'createfile' => array(
'method' => 'ome_autotask_export_createfile',
'threadNum' => 5,
'retry' => true,
'timeout' => 3600,
'name' => '导出文件生成队列',
),
);
}
//rpc任务
public static function rpc_list()
{
return $_tasks = array(
'omecallback' => array('method' => 'ome_autotask_rpc_omecallback', 'threadNum' => 5),
'wmscallback' => array('method' => 'ome_autotask_rpc_wmscallback', 'threadNum' => 5),
'wmsrpc' => array(
'method' => 'ome_autotask_rpc_wmsrpc',
'threadNum' => 5,
'name' => 'WMS发货通知队列',
),
'orderrpc' => array(
'method' => 'ome_autotask_rpc_orderrpc',
'threadNum' => 5,
'name' => '收单队列',
),
);
}
public static function finance_list(){
return $_tasks = array(
'billapidownload' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //财务下载任务
'billassign' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //账单导入分派任务
'billjdwalletassign' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //京东钱包导入分派任务
'cainiaoassignorder' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //菜鸟导入分派任务
'cainiaoassignsku' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //菜鸟导入分派任务
'cainiaoassignsale' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //账单导入分派任务
'billimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //账单导入
'cainiaoorderimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //菜鸟根据订单导入
'cainiaoskuimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //菜鸟根据sku导入
'cainiaosaleimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //菜鸟根据销售周期导入
'syncaftersales' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //同步售后单
'syncsales' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //同步销售单
// 'verificationassign' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //分派流水单核销
// 'verificationprocess' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //账单核算自动对账任务
'initmonthlyreport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //生成新账期任务
'expensessplit' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //费用拆分
'cainiaoassignjzt' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //京准通导入分派任务
'cainiaojztimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //京准通导入保存数据任务
'cainiaoassignjdbill' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //京东钱包流水导入分派任务
'cainiaojdbillimport' => array('method'=>'financebase_autotask_task_process', 'threadNum'=>1), //京东钱包流水导入保存数据任务
'assign' => array('method'=>'omecsv_autotask_task_process', 'threadNum' => 1), //分片导入任务
'import' => array('method'=>'omecsv_autotask_task_process', 'threadNum' => 1), //分片导入
'jitsale' => array('method'=>'billcenter_autotask_timer_sales', 'threadNum' => 1), // JIT销售单
'jitaftersale' => array('method'=>'billcenter_autotask_timer_aftersales', 'threadNum' => 1), // JIT售后单
);
}
//全部任务
public static function get_all_task_list()
{
return array_merge(self::task_list(), self::timer_list(), self::export_list(), self::rpc_list(), self::finance_list());
}
public static function get_task_types()
{
return array('task', 'timer', 'init', 'export', 'rpc', 'finance');
}
}