切换导航条
此项目
正在载入...
登录
allied-creation
/
performance
·
提交
转到一个项目
GitLab
转到群组
项目
活动
文件
提交
管道
0
构建
0
图表
里程碑
问题
0
合并请求
0
成员
标记
维基
派生
网络
创建新的问题
下载为
邮件补丁
差异文件
浏览文件
作者
tangxvhui
2 years ago
提交
1592a6c38cd52eaf5b3d4b986680db4ac4f7e83d
1 个父辈
fc069413
日常保存
隐藏空白字符变更
内嵌
并排对比
正在显示
2 个修改的文件
包含
25 行增加
和
5 行删除
pkg/application/task/service/service2.go
pkg/constant/kafka.go
pkg/application/task/service/service2.go
查看文件 @
1592a6c
...
...
@@ -36,6 +36,9 @@ func (srv TaskService) listTaskAnomaly2(param *command.ListTaskAnomalyCommand) (
})
limit
:=
500
offset
:=
0
if
param
.
SubLevel
<
2
{
param
.
SubLevel
=
2
}
cnt
,
anomalyList
,
err
:=
taskAnomalyDao
.
List2
(
param
.
UserId
,
param
.
CompanyId
,
param
.
TaskName
,
param
.
Category
,
param
.
LeaderId
,
param
.
DayTime
,
param
.
SubLevel
,
limit
,
offset
)
if
err
!=
nil
{
return
0
,
nil
,
application
.
ThrowError
(
application
.
INTERNAL_SERVER_ERROR
,
err
.
Error
())
...
...
@@ -340,6 +343,7 @@ func (srv TaskService) listTaskAnomaly3(param *command.ListTaskAnomalyCommand) (
return
int64
(
cnt
),
listData
,
nil
}
// 与我有关的任务,异常列表
func
(
srv
TaskService
)
ListTaskAnomaly3
(
param
*
command
.
ListTaskAnomalyCommand
)
(
map
[
string
]
interface
{},
error
)
{
cnt
,
listData
,
err
:=
srv
.
listTaskAnomaly3
(
param
)
if
err
!=
nil
{
...
...
@@ -349,6 +353,7 @@ func (srv TaskService) ListTaskAnomaly3(param *command.ListTaskAnomalyCommand) (
return
result
,
nil
}
// 人员选择列表
func
(
srv
TaskService
)
UserSelect
(
param
*
command
.
UserSelectCommand
)
[]
adapter
.
UserItem
{
transactionContext
,
err
:=
factory
.
CreateTransactionContext
(
nil
)
if
err
!=
nil
{
...
...
@@ -403,7 +408,6 @@ func (srv TaskService) UserSelect(param *command.UserSelectCommand) []adapter.Us
}
// 我负责的任务,异常列表
func
(
srv
TaskService
)
ListTaskAnomaly1
(
param
*
command
.
ListTaskAnomalyCommand
)
(
map
[
string
]
interface
{},
error
)
{
transactionContext
,
err
:=
factory
.
CreateTransactionContext
(
nil
)
if
err
!=
nil
{
...
...
@@ -560,7 +564,7 @@ func (srv TaskService) ListTaskAnomaly1(param *command.ListTaskAnomalyCommand) (
return
result
,
nil
}
// 对异常记录的操作标记
//
在 异常中心
对异常记录的操作标记
func
(
srv
TaskService
)
MarkTaskAnomaly
(
param
*
command
.
MarkTaskAnomalyCommand
)
(
map
[
string
]
interface
{},
error
)
{
transactionContext
,
err
:=
factory
.
CreateTransactionContext
(
nil
)
if
err
!=
nil
{
...
...
@@ -945,3 +949,22 @@ func (srv TaskService) TaskAnomalyInfo(param *command.GetTaskAnomalyCommand) (*a
}
return
result
,
nil
}
// 任务列表中,对异常记录的操作标记
// 按照任务id 实则操作标记
func
(
srv
TaskService
)
MarkTaskAnomalyByTask
(
param
command
.
MarkTaskAnomalyCommand
)
(
map
[
string
]
interface
{},
error
)
{
transactionContext
,
err
:=
factory
.
CreateTransactionContext
(
nil
)
if
err
!=
nil
{
return
nil
,
application
.
ThrowError
(
application
.
INTERNAL_SERVER_ERROR
,
err
.
Error
())
}
if
err
:=
transactionContext
.
StartTransaction
();
err
!=
nil
{
return
map
[
string
]
interface
{}{},
application
.
ThrowError
(
application
.
INTERNAL_SERVER_ERROR
,
err
.
Error
())
}
defer
func
()
{
_
=
transactionContext
.
RollbackTransaction
()
}()
if
err
:=
transactionContext
.
CommitTransaction
();
err
!=
nil
{
return
map
[
string
]
interface
{}{},
application
.
ThrowError
(
application
.
INTERNAL_SERVER_ERROR
,
err
.
Error
())
}
return
nil
,
nil
}
...
...
pkg/constant/kafka.go
查看文件 @
1592a6c
//go:build !local
// +build !local
package
constant
import
"os"
...
...
请
注册
或
登录
后发表评论