diff --git a/data/bindata.go b/data/bindata.go index 5f210034..ca218563 100644 --- a/data/bindata.go +++ b/data/bindata.go @@ -1057,11 +1057,13 @@ var _bindata = map[string]func() (*asset, error){ // directory embedded in the file by go-bindata. // For example if you run go-bindata on data/... and data contains the // following hierarchy: -// data/ -// foo.txt -// img/ -// a.png -// b.png +// +// data/ +// foo.txt +// img/ +// a.png +// b.png +// // then AssetDir("data") would return []string{"foo.txt", "img"} // AssetDir("data/img") would return []string{"a.png", "b.png"} // AssetDir("foo.txt") and AssetDir("notexist") would return an error diff --git a/helper/array.go b/helper/array.go index c8bc2653..ebc29ef9 100644 --- a/helper/array.go +++ b/helper/array.go @@ -67,15 +67,19 @@ func ArraySplit(records []map[string]interface{}) ([]string, [][]interface{}) { } // ArrayPluck 将多个数据记录集合,合并为一个数据记录集合 -// columns: ["城市", "行业", "计费"] -// pluck: { -// "行业":{"key":"city", "value":"数量", "items":[{"city":"北京", "数量":32},{"city":"上海", "数量":20}]}, -// "计费":{"key":"city", "value":"计费种类", "items":[{"city":"北京", "计费种类":6},{"city":"西安", "计费种类":3}]}, -// } +// +// columns: ["城市", "行业", "计费"] +// pluck: { +// "行业":{"key":"city", "value":"数量", "items":[{"city":"北京", "数量":32},{"city":"上海", "数量":20}]}, +// "计费":{"key":"city", "value":"计费种类", "items":[{"city":"北京", "计费种类":6},{"city":"西安", "计费种类":3}]}, +// } +// // return: [ -// {"城市":"北京", "行业":32, "计费":6}, -// {"城市":"上海", "行业":20, "计费":null}, -// {"城市":"西安", "行业":null, "计费":6} +// +// {"城市":"北京", "行业":32, "计费":6}, +// {"城市":"上海", "行业":20, "计费":null}, +// {"城市":"西安", "行业":null, "计费":6} +// // ] func ArrayPluck(columns []string, pluck map[string]interface{}) []map[string]interface{} { if len(columns) < 2 { diff --git a/workflow/process.go b/workflow/process.go index 13420905..25db1c76 100644 --- a/workflow/process.go +++ b/workflow/process.go @@ -30,7 +30,9 @@ func init() { } // ProcessFind xiang.workflow.Find 读取工作流 -// args: [工作流名称*, 工作流ID*] +// +// args: [工作流名称*, 工作流ID*] +// // return: map[string]interface{} 工作流数据记录 func ProcessFind(process *gou.Process) interface{} { process.ValidateArgNums(2) @@ -39,7 +41,9 @@ func ProcessFind(process *gou.Process) interface{} { } // ProcessOpen xiang.workflow.Open 读取工作流 -// args: [工作流名称*, 当前用户ID*, 关联数据ID*] +// +// args: [工作流名称*, 当前用户ID*, 关联数据ID*] +// // return: map[string]interface{} 工作流数据记录 func ProcessOpen(process *gou.Process) interface{} { process.ValidateArgNums(3) @@ -48,7 +52,9 @@ func ProcessOpen(process *gou.Process) interface{} { } // ProcessSetting xiang.workflow.Setting 读取工作流配置 -// args: [工作流名称*, 当前用户ID*, 关联数据ID*] +// +// args: [工作流名称*, 当前用户ID*, 关联数据ID*] +// // return: map[string]interface{} 工作流配置 func ProcessSetting(process *gou.Process) interface{} { process.ValidateArgNums(3) @@ -57,7 +63,9 @@ func ProcessSetting(process *gou.Process) interface{} { } // ProcessSave xiang.workflow.Save 保存工作流节点信息 -// args: [工作流名称*, 当前用户ID*, 节点名称*, 关联数据ID*, 输入数据*, 输出数据] (输入数据: {"data":{}, "form":{}} data 关联数据记录信息, form 工作流body表单信息, 输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 节点名称*, 关联数据ID*, 输入数据*, 输出数据] (输入数据: {"data":{}, "form":{}} data 关联数据记录信息, form 工作流body表单信息, 输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessSave(process *gou.Process) interface{} { process.ValidateArgNums(5) @@ -71,7 +79,9 @@ func ProcessSave(process *gou.Process) interface{} { } // ProcessNext xiang.workflow.Next 进入下一个节点 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessNext(process *gou.Process) interface{} { process.ValidateArgNums(4) @@ -81,7 +91,9 @@ func ProcessNext(process *gou.Process) interface{} { } // ProcessGoto xiang.workflow.Goto 跳转到指定节点 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 节点名称*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 节点名称*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessGoto(process *gou.Process) interface{} { process.ValidateArgNums(5) @@ -91,7 +103,9 @@ func ProcessGoto(process *gou.Process) interface{} { } // ProcessStatus xiang.workflow.Status 更新工作流状态 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 状态名称*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 状态名称*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessStatus(process *gou.Process) interface{} { process.ValidateArgNums(5) @@ -101,7 +115,9 @@ func ProcessStatus(process *gou.Process) interface{} { } // ProcessDone xiang.workflow.Done 标记结束流程 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessDone(process *gou.Process) interface{} { process.ValidateArgNums(4) @@ -111,7 +127,9 @@ func ProcessDone(process *gou.Process) interface{} { } // ProcessClose xiang.workflow.Close 标记关闭流程 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessClose(process *gou.Process) interface{} { process.ValidateArgNums(4) @@ -121,7 +139,9 @@ func ProcessClose(process *gou.Process) interface{} { } // ProcessReset xiang.workflow.Reset 标记重置流程 -// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// +// args: [工作流名称*, 当前用户ID*, 工作流ID*, 输出数据*] (输出数据: {"foo":"bar"} ) +// // return: map[string]interface{} 工作流数据记录 func ProcessReset(process *gou.Process) interface{} { process.ValidateArgNums(4)