|
@@ -122,10 +122,10 @@ func SaveChange(ctx context.Context, argsChange, argsTask, argsFollowRecord []in
|
|
|
// TaskExecutePlanAdd 任务执行计划存储
|
|
|
func TaskExecutePlanAdd(tx *sql.Tx, tplId, taskId int64) int64 {
|
|
|
args := []interface{}{}
|
|
|
- data := cm.CrmMysql.SelectBySqlByTx(tx, `SELECT b.name,c.name,c.id FROM task a
|
|
|
- INNER JOIN config_tpl_stage b ON (a.tpl_id=b.tpl_id and b.tpl_id=?)
|
|
|
- INNER JOIN config_stage_matter c ON (c.stage_id=b.id)
|
|
|
- order by b.id,c.id `, tplId)
|
|
|
+ data := cm.CrmMysql.SelectBySqlByTx(tx, `SELECT a.name,b.name,b.id FROM config_tpl_stage a
|
|
|
+ INNER JOIN config_stage_matter b ON (b.stage_id=a.id)
|
|
|
+ where a.tpl_id=2
|
|
|
+ order by a.id,b.id `, tplId)
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
for _, v := range *data {
|
|
|
matterId := gconv.Int(v["id"])
|