作者 Your Name

修复一些问题

1 package main 1 package main
2 2
3 import ( 3 import (
  4 + "time"
  5 +
4 "github.com/beego/beego/v2/server/web" 6 "github.com/beego/beego/v2/server/web"
5 serviceTask "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/node_task" 7 serviceTask "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/node_task"
6 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log" 8 "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
7 _ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego" 9 _ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego"
8 - "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/consumer"  
9 - "time"  
10 ) 10 )
11 11
12 func main() { 12 func main() {
@@ -17,7 +17,7 @@ func main() { @@ -17,7 +17,7 @@ func main() {
17 // for k, v := range methods { 17 // for k, v := range methods {
18 // fmt.Printf("%s => %v \n", k, v) 18 // fmt.Printf("%s => %v \n", k, v)
19 // } 19 // }
20 - go consumer.Run() 20 + // go consumer.Run()
21 web.Run() 21 web.Run()
22 } 22 }
23 23
@@ -40,7 +40,7 @@ func (d *StaffAssessDao) CountInviteAssessByTargetUser(userIds []int, assessTask @@ -40,7 +40,7 @@ func (d *StaffAssessDao) CountInviteAssessByTargetUser(userIds []int, assessTask
40 WHERE staff_assess.target_user->>'userId' IN(?) 40 WHERE staff_assess.target_user->>'userId' IN(?)
41 AND staff_assess.types IN ('invite_same_super','invite_diff_super') 41 AND staff_assess.types IN ('invite_same_super','invite_diff_super')
42 AND staff_assess.staff_assess_task_id = ? 42 AND staff_assess.staff_assess_task_id = ?
43 - GROUP BY userId` 43 + GROUP BY target_user_id`
44 44
45 userIdList := []string{} 45 userIdList := []string{}
46 for _, v := range userIds { 46 for _, v := range userIds {