Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
D
datacollector
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
chenweisong
datacollector
Commits
73768388
Commit
73768388
authored
Mar 13, 2020
by
chenweisong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
更新
parent
10c676d3
Show whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
49 additions
and
9 deletions
+49
-9
IndexCtrl.java
src/main/java/com/keymobile/rest/ctrl/IndexCtrl.java
+11
-7
JobInfoDao.java
src/main/java/com/keymobile/rest/dao/JobInfoDao.java
+1
-0
Job.java
src/main/java/com/keymobile/rest/model/Job.java
+8
-0
RecordData.java
src/main/java/com/keymobile/rest/model/RecordData.java
+3
-0
JobInfoService.java
src/main/java/com/keymobile/rest/service/JobInfoService.java
+4
-0
JobService.java
src/main/java/com/keymobile/rest/service/JobService.java
+9
-1
RecordDataService.java
...in/java/com/keymobile/rest/service/RecordDataService.java
+2
-0
RecordDataForm.java
src/main/java/com/keymobile/rest/vo/RecordDataForm.java
+11
-1
No files found.
src/main/java/com/keymobile/rest/ctrl/IndexCtrl.java
View file @
73768388
...
@@ -85,26 +85,27 @@ public class IndexCtrl {
...
@@ -85,26 +85,27 @@ public class IndexCtrl {
public
ApiResponse
getMyTasks
()
{
public
ApiResponse
getMyTasks
()
{
User
user
=
userService
.
getNormalUser
();
User
user
=
userService
.
getNormalUser
();
User
audit
=
userService
.
getAudit
();
User
audit
=
userService
.
getAudit
();
List
<
Job
>
recordList
=
new
ArrayList
<>();
List
<
Job
>
jobList
=
new
ArrayList
<>();
List
<
Job
>
auditList
=
new
ArrayList
<>();
// 获取任务
// 获取任务
List
<
Task
>
tasks
=
taskService
.
createNativeTaskQuery
()
List
<
Task
>
tasks
=
taskService
.
createNativeTaskQuery
()
.
sql
(
"SELECT * FROM "
+
managementService
.
getTableName
(
Task
.
class
)
+
" T WHERE T.ASSIGNEE_ = #{assignee1} OR T.ASSIGNEE_ = #{assignee2}"
)
.
sql
(
"SELECT * FROM "
+
managementService
.
getTableName
(
Task
.
class
)
+
" T WHERE T.ASSIGNEE_ = #{assignee1} OR T.ASSIGNEE_ = #{assignee2}"
)
.
parameter
(
"assignee1"
,
user
.
getUsername
()).
parameter
(
"assignee2"
,
audit
.
getUsername
())
.
parameter
(
"assignee1"
,
user
.
getUsername
()).
parameter
(
"assignee2"
,
audit
.
getUsername
())
.
list
();
.
list
();
for
(
Task
task
:
tasks
)
{
for
(
Task
task
:
tasks
)
{
String
processId
=
task
.
getProcessInstanceId
();
String
processId
=
task
.
getProcessInstanceId
();
Job
job
=
jobService
.
findByProcessId
(
processId
);
Job
job
=
jobService
.
findByProcessId
(
processId
);
if
(
job
!=
null
&&
job
.
getStatus
()
!=
Job
.
STATUS_COMPLETED
)
{
if
(
job
!=
null
&&
job
.
getStatus
()
!=
Job
.
STATUS_COMPLETED
)
{
if
(
task
.
getTaskDefinitionKey
().
equals
(
"addData"
))
{
if
(
task
.
getTaskDefinitionKey
().
equals
(
"addData"
))
{
recordList
.
add
(
job
);
job
.
setKind
(
Job
.
KIND_RECORD
);
}
else
{
}
else
{
auditList
.
add
(
job
);
job
.
setKind
(
Job
.
KIND_AUDIT
);
}
}
jobList
.
add
(
job
);
}
}
}
}
return
ApiResponse
.
ok
(
ImmutableMap
.
of
(
"recordList"
,
recordList
,
"auditList"
,
auditList
)
);
return
ApiResponse
.
ok
(
jobList
);
}
}
...
@@ -192,6 +193,7 @@ public class IndexCtrl {
...
@@ -192,6 +193,7 @@ public class IndexCtrl {
// 根据活动查找需要填写的人 目前只支持一人
// 根据活动查找需要填写的人 目前只支持一人
List
<
Excel
>
excelList
=
job
.
getExcelList
();
List
<
Excel
>
excelList
=
job
.
getExcelList
();
TwinkleValidator
.
notLessThan
(
excelList
.
size
(),
1
,
"补录模板不存在"
);
TwinkleValidator
.
notLessThan
(
excelList
.
size
(),
1
,
"补录模板不存在"
);
Excel
excel
=
excelList
.
get
(
0
);
Excel
excel
=
excelList
.
get
(
0
);
List
<
JobInfo
>
jobInfoList
=
jobInfoService
.
findAllByExcelId
(
excel
.
getId
());
List
<
JobInfo
>
jobInfoList
=
jobInfoService
.
findAllByExcelId
(
excel
.
getId
());
TwinkleValidator
.
notLessThan
(
jobInfoList
.
size
(),
1
,
"补录人员不存在"
);
TwinkleValidator
.
notLessThan
(
jobInfoList
.
size
(),
1
,
"补录人员不存在"
);
...
@@ -245,14 +247,16 @@ public class IndexCtrl {
...
@@ -245,14 +247,16 @@ public class IndexCtrl {
@ApiOperation
(
value
=
"填写补录数据"
)
@ApiOperation
(
value
=
"填写补录数据"
)
@PostMapping
(
value
=
"/excel/saveData"
)
@PostMapping
(
value
=
"/excel/saveData"
)
public
ApiResponse
saveRecordData
(
@RequestBody
RecordDataForm
form
)
{
public
ApiResponse
saveRecordData
(
@RequestBody
RecordDataForm
form
)
{
User
curUser
=
userService
.
getNormalUser
();
Excel
excel
=
excelService
.
get
(
form
.
getExcelId
());
JobInfo
jobInfo
=
jobInfoService
.
findByExcelIdAndUserId
(
form
.
getExcelId
(),
curUser
.
getId
());
RecordData
recordData
;
RecordData
recordData
;
if
(
form
.
getDataId
()
!=
null
)
{
if
(
form
.
getDataId
()
!=
null
)
{
recordData
=
recordDataService
.
update
(
form
);
recordData
=
recordDataService
.
update
(
form
);
}
else
{
}
else
{
form
.
setJobInfo
(
jobInfo
);
recordData
=
recordDataService
.
save
(
form
);
recordData
=
recordDataService
.
save
(
form
);
}
}
User
curUser
=
userService
.
getNormalUser
();
Excel
excel
=
excelService
.
get
(
form
.
getExcelId
());
Job
job
=
excel
.
getJob
();
Job
job
=
excel
.
getJob
();
String
processId
=
job
.
getProcessId
();
String
processId
=
job
.
getProcessId
();
// 发起人把流程发送到下一个人
// 发起人把流程发送到下一个人
...
...
src/main/java/com/keymobile/rest/dao/JobInfoDao.java
View file @
73768388
...
@@ -13,4 +13,5 @@ public interface JobInfoDao extends JpaRepository<JobInfo, Long> {
...
@@ -13,4 +13,5 @@ public interface JobInfoDao extends JpaRepository<JobInfo, Long> {
void
deleteAllByExcelId
(
long
eid
);
void
deleteAllByExcelId
(
long
eid
);
JobInfo
findByExcelIdAndUserId
(
long
eid
,
long
uid
);
}
}
src/main/java/com/keymobile/rest/model/Job.java
View file @
73768388
...
@@ -23,6 +23,9 @@ import java.util.List;
...
@@ -23,6 +23,9 @@ import java.util.List;
@Entity
@Entity
public
class
Job
implements
Serializable
{
public
class
Job
implements
Serializable
{
public
static
int
KIND_RECORD
=
1
;
public
static
int
KIND_AUDIT
=
2
;
public
static
int
TYPE_AUTO
=
2
;
public
static
int
TYPE_AUTO
=
2
;
public
static
int
TYPE_MANUAL
=
1
;
public
static
int
TYPE_MANUAL
=
1
;
...
@@ -59,6 +62,7 @@ public class Job implements Serializable {
...
@@ -59,6 +62,7 @@ public class Job implements Serializable {
@Column
(
name
=
"start_at"
)
@Column
(
name
=
"start_at"
)
private
Timestamp
startAt
;
private
Timestamp
startAt
;
@Column
(
nullable
=
false
,
name
=
"create_at"
)
@Column
(
nullable
=
false
,
name
=
"create_at"
)
@CreationTimestamp
@CreationTimestamp
private
Timestamp
createAt
;
private
Timestamp
createAt
;
...
@@ -69,4 +73,8 @@ public class Job implements Serializable {
...
@@ -69,4 +73,8 @@ public class Job implements Serializable {
@ManyToOne
@ManyToOne
private
User
user
;
private
User
user
;
@Transient
private
int
kind
;
}
}
src/main/java/com/keymobile/rest/model/RecordData.java
View file @
73768388
...
@@ -25,6 +25,9 @@ public class RecordData implements Serializable {
...
@@ -25,6 +25,9 @@ public class RecordData implements Serializable {
@GeneratedValue
(
strategy
=
GenerationType
.
IDENTITY
)
@GeneratedValue
(
strategy
=
GenerationType
.
IDENTITY
)
private
long
id
;
private
long
id
;
@Column
(
nullable
=
false
)
private
String
datas
;
@Column
(
name
=
"create_at"
,
nullable
=
false
)
@Column
(
name
=
"create_at"
,
nullable
=
false
)
@CreationTimestamp
@CreationTimestamp
private
Timestamp
createAt
;
private
Timestamp
createAt
;
...
...
src/main/java/com/keymobile/rest/service/JobInfoService.java
View file @
73768388
...
@@ -31,6 +31,10 @@ public class JobInfoService {
...
@@ -31,6 +31,10 @@ public class JobInfoService {
return
jobInfoDao
.
findAllByExcelId
(
eid
);
return
jobInfoDao
.
findAllByExcelId
(
eid
);
}
}
public
JobInfo
findByExcelIdAndUserId
(
long
eid
,
long
uid
)
{
return
jobInfoDao
.
findByExcelIdAndUserId
(
eid
,
uid
);
}
public
List
<
JobInfo
>
findByUserId
(
long
uid
)
{
public
List
<
JobInfo
>
findByUserId
(
long
uid
)
{
return
jobInfoDao
.
findAllByUserId
(
uid
);
return
jobInfoDao
.
findAllByUserId
(
uid
);
}
}
...
...
src/main/java/com/keymobile/rest/service/JobService.java
View file @
73768388
...
@@ -12,6 +12,8 @@ import org.springframework.data.domain.Sort;
...
@@ -12,6 +12,8 @@ import org.springframework.data.domain.Sort;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.sql.Timestamp
;
import
java.sql.Timestamp
;
import
java.time.LocalDateTime
;
import
java.util.Date
;
@Service
@Service
public
class
JobService
{
public
class
JobService
{
...
@@ -36,7 +38,13 @@ public class JobService {
...
@@ -36,7 +38,13 @@ public class JobService {
job
.
setName
(
form
.
getName
());
job
.
setName
(
form
.
getName
());
job
.
setType
(
form
.
getType
());
job
.
setType
(
form
.
getType
());
if
(
form
.
getType
()
==
Job
.
TYPE_AUTO
)
{
if
(
form
.
getType
()
==
Job
.
TYPE_AUTO
)
{
job
.
setStartAt
(
Timestamp
.
valueOf
(
form
.
getStartAt
()));
Timestamp
startAt
;
try
{
startAt
=
Timestamp
.
valueOf
(
form
.
getStartAt
());
}
catch
(
Exception
e
)
{
startAt
=
Timestamp
.
valueOf
(
LocalDateTime
.
now
());
}
job
.
setStartAt
(
startAt
);
}
}
job
.
setUser
(
form
.
getUser
());
job
.
setUser
(
form
.
getUser
());
job
=
jobDao
.
save
(
job
);
job
=
jobDao
.
save
(
job
);
...
...
src/main/java/com/keymobile/rest/service/RecordDataService.java
View file @
73768388
...
@@ -21,6 +21,8 @@ public class RecordDataService {
...
@@ -21,6 +21,8 @@ public class RecordDataService {
public
RecordData
save
(
RecordDataForm
form
)
{
public
RecordData
save
(
RecordDataForm
form
)
{
RecordData
data
=
new
RecordData
();
RecordData
data
=
new
RecordData
();
data
.
setDatas
(
form
.
getDataStr
());
data
.
setJobInfo
(
form
.
getJobInfo
());
Timestamp
now
=
Timestamp
.
valueOf
(
DateUtil
.
getDateTime
());
Timestamp
now
=
Timestamp
.
valueOf
(
DateUtil
.
getDateTime
());
data
.
setCreateAt
(
now
);
data
.
setCreateAt
(
now
);
data
=
recordDataDao
.
save
(
data
);
data
=
recordDataDao
.
save
(
data
);
...
...
src/main/java/com/keymobile/rest/vo/RecordDataForm.java
View file @
73768388
package
com
.
keymobile
.
rest
.
vo
;
package
com
.
keymobile
.
rest
.
vo
;
import
com.fasterxml.jackson.annotation.JsonIgnore
;
import
com.keymobile.rest.model.JobInfo
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModel
;
import
io.swagger.annotations.ApiModelProperty
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
lombok.Data
;
...
@@ -16,8 +18,16 @@ public class RecordDataForm {
...
@@ -16,8 +18,16 @@ public class RecordDataForm {
@ApiModelProperty
(
required
=
true
,
name
=
"excelId"
,
value
=
"当前模板id"
)
@ApiModelProperty
(
required
=
true
,
name
=
"excelId"
,
value
=
"当前模板id"
)
private
long
excelId
;
private
long
excelId
;
@ApiModelProperty
(
required
=
true
,
name
=
"dataList"
,
value
=
"当前数据数组"
)
@ApiModelProperty
(
required
=
true
,
name
=
"dataStr"
,
value
=
"当前数据字符"
)
private
String
dataStr
;
@ApiModelProperty
(
required
=
true
,
name
=
"dataList"
,
value
=
"当前数据数组"
,
hidden
=
true
)
private
List
<
Object
>
dataList
;
private
List
<
Object
>
dataList
;
@JsonIgnore
private
JobInfo
jobInfo
;
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment