$taskName
$taskName : string
Class MongoDbTask
__initialization(integer $taskId, integer $workerPid, string $taskName, string $methodName, \PG\MSF\Helpers\Context $context, \PG\AOP\Wrapper|\PG\MSF\Base\Pool $objectPool)
Tasker进程中初始化任务
| integer | $taskId | Task ID |
| integer | $workerPid | worker pid |
| string | $taskName | 任务类名 |
| string | $methodName | 任务类方法 |
| \PG\MSF\Helpers\Context | $context | 请求上下文对象 |
| \PG\AOP\Wrapper|\PG\MSF\Base\Pool | $objectPool | 对象池对象 |
__call(string $name, array $arguments) : \PG\MSF\Coroutine\CTask
__call魔术方法
| string | $name | 任务方法名 |
| array | $arguments | 执行参数 |
getPack() : \PG\MSF\Pack\IPack
获取运行server实例打包对象
getRedisPool(string $poolName) : boolean|\PG\AOP\Wrapper|\PG\MSF\Pools\CoroutineRedisProxy|\Redis
获取Redis连接池
| string | $poolName | 配置的Redis连接池名称 |
getRedisProxy(string $proxyName) : boolean|\PG\AOP\Wrapper|\PG\MSF\Pools\CoroutineRedisProxy|\Redis
获取Redis代理
| string | $proxyName | 配置的Redis代理名称 |
setContext(\PG\MSF\Helpers\Context $context) : $this
设置上下文
| \PG\MSF\Helpers\Context | $context | 请求上下文对象 |
query(array $query = array(), array $fields = array(), array $sort = null, integer $limit = null, integer $skip = null, integer $timeout = 2000) : \PG\MSF\Tasks\array:
查询文档，返回二维数组的数据
| array | $query | 查询条件，如：['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
| array | $fields | 返回的字段列表，默认全部，如：['name' => true, 'age' => true] |
| array | $sort | 排序，如：['create_time' => 1, '_id' => -1] |
| integer | $limit | 限制返回的数据文档数 |
| integer | $skip | 开始返回的offset |
| integer | $timeout | 查询超时时间，default 2s, 0 wait forever. |
findOne(array $query = array(), array $fields = array(), integer $timeout = 2000) : array|null
查询返回一条数据
| array | $query | 查询条件，如：['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
| array | $fields | 返回的字段列表，默认全部，如：['name' => true, 'age' => true] |
| integer | $timeout | 查询超时时间，default 2s, 0 wait forever. |
count(array $query = array(), integer|null $limit = null, integer|null $skip = null, integer $timeout = 2000) : integer
返回符合条件的文档数
| array | $query | 查询条件，如：['_id' => new \MongoId('0f6821586b9887e3174e7c78')] |
| integer|null | $limit | 限制返回的数据文档数 |
| integer|null | $skip | 开始查询的offset |
| integer | $timeout | 查询超时时间，default 2s, 0 wait forever. |
batchAdd(array $docs, boolean $continueOnError = true, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
批量新建文档
| array | $docs | 新建文档的二维数组 |
| boolean | $continueOnError | 出现错误是否继续插入 |
| integer | $timeout | 查询超时时间，default 2s, 0 wait forever. |
| integer | $w | |
| boolean | $fsync | 是否立即写入磁盘 |
modify(array $criteria, array $doc, boolean $multiple = true, boolean $upsert = false, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
修改文档（包含set关键字）
| array | $criteria | 更新条件 |
| array | $doc | 要更新的字段和值 |
| boolean | $multiple | 是否更新所有符合条件的文档 |
| boolean | $upsert | 没有符合条件的文档时，是否插入新文档 |
| integer | $timeout | 超时时间，单位ms |
| integer | $w | 成功写入到多少个复制时返回 |
| boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |
updateDoc(array $criteria, array $doc, boolean $multiple = true, boolean $upsert = false, integer $timeout = 2000, integer $w = 1, boolean $fsync = false) : boolean
修改文档
| array | $criteria | 更新条件 |
| array | $doc | 要更新的字段和值 |
| boolean | $multiple | 是否更新所有符合条件的文档 |
| boolean | $upsert | 没有符合条件的文档时，是否插入新文档 |
| integer | $timeout | 超时时间，单位ms |
| integer | $w | 成功写入到多少个复制时返回 |
| boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |
delete(array $criteria, boolean $justOne = false, integer $timeout = 5000, integer $w = 1, boolean $fsync = false) : boolean
删除文档
| array | $criteria | 删除条件 |
| boolean | $justOne | 是否只删除符合条件的第一条 |
| integer | $timeout | 超时时间，单位ms |
| integer | $w | 成功写入到多少个复制时返回 |
| boolean | $fsync | 是否等待MongoDB将数据更新到磁盘 |