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
c8b75de4
Commit
c8b75de4
authored
Mar 05, 2020
by
chenweisong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
更新
parent
ba069d91
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
19 changed files
with
225 additions
and
23 deletions
+225
-23
pom.xml
pom.xml
+0
-0
ActivitiApplication.java
src/main/java/com/keymobile/ActivitiApplication.java
+2
-2
IndexCtrl.java
src/main/java/com/keymobile/rest/ctrl/IndexCtrl.java
+28
-4
ExcelDao.java
src/main/java/com/keymobile/rest/dao/ExcelDao.java
+4
-0
RecordDataDao.java
src/main/java/com/keymobile/rest/dao/RecordDataDao.java
+8
-1
RecordInfoDao.java
src/main/java/com/keymobile/rest/dao/RecordInfoDao.java
+9
-0
TaskDao.java
src/main/java/com/keymobile/rest/dao/TaskDao.java
+0
-1
UserDao.java
src/main/java/com/keymobile/rest/dao/UserDao.java
+3
-0
Excel.java
src/main/java/com/keymobile/rest/model/Excel.java
+10
-0
RecordData.java
src/main/java/com/keymobile/rest/model/RecordData.java
+1
-1
RecordInfo.java
src/main/java/com/keymobile/rest/model/RecordInfo.java
+3
-0
Task.java
src/main/java/com/keymobile/rest/model/Task.java
+13
-0
ExcelService.java
src/main/java/com/keymobile/rest/service/ExcelService.java
+10
-5
RecordDataService.java
...in/java/com/keymobile/rest/service/RecordDataService.java
+28
-0
TaskService.java
src/main/java/com/keymobile/rest/service/TaskService.java
+72
-2
UserService.java
src/main/java/com/keymobile/rest/service/UserService.java
+1
-0
DataVo.java
src/main/java/com/keymobile/rest/vo/DataVo.java
+4
-0
ExcelVO.java
src/main/java/com/keymobile/rest/vo/ExcelVO.java
+19
-0
TaskVO.java
src/main/java/com/keymobile/rest/vo/TaskVO.java
+10
-7
No files found.
pom.xml
View file @
c8b75de4
This diff is collapsed.
Click to expand it.
src/main/java/com/keymobile/ActivitiApplication.java
View file @
c8b75de4
...
...
@@ -12,9 +12,9 @@ import springfox.documentation.swagger2.annotations.EnableSwagger2;
//@EnableFeignClients
@EnableAutoConfiguration
(
exclude
=
{
org
.
springframework
.
boot
.
autoconfigure
.
security
.
servlet
.
SecurityAutoConfiguration
.
class
,
org
.
activiti
.
spring
.
boot
.
SecurityAutoConfiguration
.
class
})
public
class
ActivitiApplication
extends
SpringBootServletInitializer
{
public
class
ActivitiApplication
extends
SpringBootServletInitializer
{
public
static
void
main
(
String
[]
args
)
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
ActivitiApplication
.
class
,
args
);
}
}
src/main/java/com/keymobile/rest/ctrl/IndexCtrl.java
View file @
c8b75de4
...
...
@@ -3,8 +3,12 @@ package com.keymobile.rest.ctrl;
import
com.google.common.collect.ImmutableMap
;
import
com.keymobile.rest.model.Task
;
import
com.keymobile.rest.model.User
;
import
com.keymobile.rest.service.ExcelService
;
import
com.keymobile.rest.service.RecordDataService
;
import
com.keymobile.rest.service.TaskService
;
import
com.keymobile.rest.service.UserService
;
import
com.keymobile.rest.vo.DataVo
;
import
com.keymobile.rest.vo.ExcelVO
;
import
com.keymobile.rest.vo.TaskVO
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
...
@@ -27,7 +31,10 @@ public class IndexCtrl {
@Autowired
private
TaskService
taskService
;
@Autowired
private
ExcelService
excelService
;
@Autowired
private
RecordDataService
recordDataService
;
@Autowired
private
UserService
userService
;
...
...
@@ -56,14 +63,15 @@ public class IndexCtrl {
@ApiOperation
(
value
=
"新建收数"
)
@PostMapping
(
value
=
"/task/create"
)
public
Map
createTask
(
TaskVO
task
)
{
return
ImmutableMap
.
of
(
"code"
,
200
);
public
Map
createTask
(
TaskVO
vo
)
{
long
id
=
taskService
.
create
(
vo
);
return
ImmutableMap
.
of
(
"code"
,
200
,
"data"
,
id
);
}
@ApiOperation
(
value
=
"手动发起收数"
)
@PostMapping
(
value
=
"/task/start"
)
public
Map
startTask
(
@RequestParam
int
id
)
{
taskService
.
start
(
id
);
return
ImmutableMap
.
of
(
"code"
,
200
);
}
...
...
@@ -71,6 +79,7 @@ public class IndexCtrl {
@ApiOperation
(
value
=
"审核通过收数"
)
@PostMapping
(
value
=
"/task/pass"
)
public
Map
passTask
(
@RequestParam
int
id
)
{
taskService
.
pass
(
id
);
return
ImmutableMap
.
of
(
"code"
,
200
);
}
...
...
@@ -78,6 +87,7 @@ public class IndexCtrl {
@ApiOperation
(
value
=
"审核驳回收数"
)
@PostMapping
(
value
=
"/task/reject"
)
public
Map
rejectTask
(
@RequestParam
int
id
)
{
taskService
.
reject
(
id
);
return
ImmutableMap
.
of
(
"code"
,
200
);
}
...
...
@@ -89,5 +99,19 @@ public class IndexCtrl {
return
ImmutableMap
.
of
(
"code"
,
200
,
"data"
,
userList
);
}
@ApiOperation
(
value
=
"新建模板"
)
@PostMapping
(
value
=
"/excel/create"
)
public
Map
saveExcel
(
ExcelVO
vo
)
{
int
id
=
excelService
.
create
(
vo
);
return
ImmutableMap
.
of
(
"code"
,
200
,
"data"
,
id
);
}
@ApiOperation
(
value
=
"填写补录数据"
)
@PostMapping
(
value
=
"/excel/saveData"
)
public
Map
saveRecordData
(
DataVo
vo
)
{
recordDataService
.
create
(
vo
);
return
ImmutableMap
.
of
(
"code"
,
200
);
}
}
src/main/java/com/keymobile/rest/dao/ExcelDao.java
View file @
c8b75de4
...
...
@@ -6,4 +6,8 @@ import org.springframework.data.jpa.repository.JpaRepository;
import
java.util.List
;
public
interface
ExcelDao
extends
JpaRepository
<
Excel
,
Long
>
{
List
<
Excel
>
findAllByIdIn
(
List
<
Long
>
ids
);
}
src/main/java/com/keymobile/rest/dao/
Excel
DataDao.java
→
src/main/java/com/keymobile/rest/dao/
Record
DataDao.java
View file @
c8b75de4
...
...
@@ -3,5 +3,12 @@ package com.keymobile.rest.dao;
import
com.keymobile.rest.model.RecordData
;
import
org.springframework.data.jpa.repository.JpaRepository
;
public
interface
ExcelDataDao
extends
JpaRepository
<
RecordData
,
Long
>
{
public
interface
RecordDataDao
extends
JpaRepository
<
RecordData
,
Long
>
{
}
src/main/java/com/keymobile/rest/dao/RecordInfoDao.java
0 → 100644
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
dao
;
import
com.keymobile.rest.model.RecordInfo
;
import
org.springframework.data.jpa.repository.JpaRepository
;
public
interface
RecordInfoDao
extends
JpaRepository
<
RecordInfo
,
Long
>
{
}
src/main/java/com/keymobile/rest/dao/TaskDao.java
View file @
c8b75de4
...
...
@@ -11,5 +11,4 @@ public interface TaskDao extends JpaRepository<Task, Long> {
Page
<
Task
>
findAllByNameLike
(
String
valueOf
,
Pageable
pageable
);
}
src/main/java/com/keymobile/rest/dao/UserDao.java
View file @
c8b75de4
...
...
@@ -8,4 +8,7 @@ import java.util.List;
public
interface
UserDao
extends
JpaRepository
<
User
,
Long
>
{
List
<
User
>
findAllByRole
(
int
role
);
List
<
User
>
findAllByIdIn
(
List
<
Long
>
ids
);
}
src/main/java/com/keymobile/rest/model/Excel.java
View file @
c8b75de4
...
...
@@ -9,6 +9,7 @@ import org.hibernate.annotations.CreationTimestamp;
import
javax.persistence.*
;
import
java.io.Serializable
;
import
java.sql.Timestamp
;
import
java.util.List
;
/**
* spreadJs 配置的报表
...
...
@@ -23,6 +24,11 @@ public class Excel implements Serializable {
@GeneratedValue
(
strategy
=
GenerationType
.
IDENTITY
)
private
long
id
;
@Column
(
columnDefinition
=
"VARCHAR(300) COMMENT 'SpreadJs表格配置'"
)
private
String
config
;
@Column
(
columnDefinition
=
"VARCHAR(50) COMMENT '备注'"
)
private
String
desc
;
@Column
(
columnDefinition
=
"DATETIME COMMENT '创建时间'"
)
@CreationTimestamp
...
...
@@ -31,4 +37,8 @@ public class Excel implements Serializable {
// 级别游离关联, 当加载的时候急加载这个对象
@ManyToOne
(
cascade
=
CascadeType
.
DETACH
,
fetch
=
FetchType
.
EAGER
)
private
Task
task
;
@OneToMany
@JsonIgnore
private
List
<
RecordInfo
>
recordInfoList
;
}
src/main/java/com/keymobile/rest/model/RecordData.java
View file @
c8b75de4
...
...
@@ -29,7 +29,7 @@ public class RecordData implements Serializable {
private
Timestamp
createAt
;
@ManyToOne
@JsonIgnore
private
RecordInfo
recordInfo
;
}
src/main/java/com/keymobile/rest/model/RecordInfo.java
View file @
c8b75de4
...
...
@@ -33,6 +33,9 @@ public class RecordInfo implements Serializable {
@JsonIgnore
List
<
RecordData
>
recordDataList
;
@ManyToOne
private
Excel
excel
;
@OneToOne
private
User
user
;
...
...
src/main/java/com/keymobile/rest/model/Task.java
View file @
c8b75de4
...
...
@@ -22,6 +22,16 @@ import java.util.List;
@Entity
public
class
Task
implements
Serializable
{
public
static
int
TYPE_AUTO
=
2
;
public
static
int
TYPE_MANUAL
=
1
;
public
static
int
STATUS_RELEASED
=
2
;
public
static
int
STATUS_UNRELEASED
=
1
;
public
static
int
JUDGE_NEED
=
2
;
public
static
int
JUDGE_NO_NEED
=
1
;
@Id
@GeneratedValue
(
strategy
=
GenerationType
.
IDENTITY
)
private
long
id
;
...
...
@@ -39,6 +49,9 @@ public class Task implements Serializable {
private
int
judge
=
2
;
@Column
private
long
processId
;
@Column
private
Timestamp
startAt
;
@Column
(
nullable
=
false
)
...
...
src/main/java/com/keymobile/rest/service/ExcelService.java
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
service
;
import
com.keymobile.rest.dao.
ExcelDao
;
import
com.keymobile.rest.
dao.ExcelDataDao
;
import
com.keymobile.rest.dao.
*
;
import
com.keymobile.rest.
vo.ExcelVO
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
java.util.List
;
@Service
public
class
ExcelService
{
@Autowired
private
TaskDao
taskDao
;
@Autowired
private
UserDao
userDao
;
@Autowired
private
ExcelDao
excelDao
;
@Autowired
private
ExcelDataDao
excelData
Dao
;
private
RecordInfoDao
recordInfo
Dao
;
public
int
create
(
ExcelVO
vo
)
{
return
0
;
}
}
src/main/java/com/keymobile/rest/service/RecordDataService.java
0 → 100644
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
service
;
import
com.keymobile.rest.dao.ExcelDao
;
import
com.keymobile.rest.dao.RecordInfoDao
;
import
com.keymobile.rest.dao.TaskDao
;
import
com.keymobile.rest.dao.UserDao
;
import
com.keymobile.rest.vo.DataVo
;
import
com.keymobile.rest.vo.ExcelVO
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
@Service
public
class
RecordDataService
{
@Autowired
private
TaskDao
taskDao
;
@Autowired
private
UserDao
userDao
;
@Autowired
private
ExcelDao
excelDao
;
@Autowired
private
RecordInfoDao
recordInfoDao
;
public
int
create
(
DataVo
vo
)
{
return
0
;
}
}
src/main/java/com/keymobile/rest/service/TaskService.java
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
service
;
import
com.keymobile.activiti.utils.DateUtil
;
import
com.keymobile.rest.dao.ExcelDao
;
import
com.keymobile.rest.dao.RecordInfoDao
;
import
com.keymobile.rest.dao.TaskDao
;
import
com.keymobile.rest.dao.UserDao
;
import
com.keymobile.rest.model.Excel
;
import
com.keymobile.rest.model.RecordInfo
;
import
com.keymobile.rest.model.Task
;
import
com.keymobile.rest.model.User
;
import
com.keymobile.rest.vo.TaskVO
;
import
javassist.compiler.ast.ASTList
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.domain.Page
;
import
org.springframework.data.domain.PageRequest
;
...
...
@@ -9,19 +18,66 @@ import org.springframework.data.domain.Pageable;
import
org.springframework.data.domain.Sort
;
import
org.springframework.stereotype.Service
;
import
java.sql.Array
;
import
java.sql.Timestamp
;
import
java.util.Arrays
;
import
java.util.List
;
import
java.util.stream.Collectors
;
@Service
public
class
TaskService
{
@Autowired
private
TaskDao
taskDao
;
@Autowired
private
UserDao
userDao
;
@Autowired
private
ExcelDao
excelDao
;
@Autowired
private
RecordInfoDao
recordInfoDao
;
public
Task
get
(
long
id
)
{
return
taskDao
.
getOne
(
id
);
}
public
void
save
()
{
public
long
create
(
TaskVO
vo
)
{
Timestamp
now
=
Timestamp
.
valueOf
(
DateUtil
.
getDateTime
());
Task
task
=
new
Task
();
task
.
setCreateAt
(
now
);
task
.
setStatus
(
Task
.
STATUS_UNRELEASED
);
task
.
setJudge
(
vo
.
getJudge
());
task
.
setName
(
vo
.
getName
());
task
.
setType
(
vo
.
getType
());
if
(
vo
.
getType
()
==
Task
.
TYPE_AUTO
)
{
task
.
setStartAt
(
vo
.
getStartAt
());
}
task
.
setUser
(
getLoginUser
());
taskDao
.
save
(
task
);
// 新建excel实例
if
(
vo
.
getExcelIds
()
!=
null
)
{
String
[]
excelIds
=
vo
.
getExcelIds
().
split
(
","
);
List
<
Long
>
ids
=
Arrays
.
asList
(
excelIds
).
stream
().
map
(
Long:
:
parseLong
).
collect
(
Collectors
.
toList
());
List
<
Excel
>
excelList
=
excelDao
.
findAllByIdIn
(
ids
);
excelList
.
forEach
(
excel
->
{
excel
.
setTask
(
task
);
// 新建补录人员任务关联
if
(
vo
.
getUserIds
()
!=
null
)
{
String
[]
userStrIds
=
vo
.
getUserIds
().
split
(
","
);
List
<
Long
>
userIds
=
Arrays
.
asList
(
userStrIds
).
stream
().
map
(
Long:
:
parseLong
).
collect
(
Collectors
.
toList
());
List
<
User
>
userList
=
userDao
.
findAllByIdIn
(
userIds
);
userList
.
forEach
(
user
->
{
RecordInfo
info
=
new
RecordInfo
();
info
.
setUser
(
user
);
info
.
setExcel
(
excel
);
info
.
setCreateAt
(
now
);
recordInfoDao
.
save
(
info
);
});
}
});
excelDao
.
saveAll
(
excelList
);
}
return
task
.
getId
();
}
...
...
@@ -29,6 +85,14 @@ public class TaskService {
}
public
void
pass
(
long
id
)
{
}
public
void
reject
(
long
id
)
{
}
public
Page
<
Task
>
findAll
(
int
pageNo
,
int
pageSize
,
String
orderBy
,
String
propBy
)
{
Pageable
pageable
=
convert
(
pageNo
,
pageSize
,
orderBy
,
propBy
);
return
taskDao
.
findAll
(
pageable
);
...
...
@@ -51,4 +115,10 @@ public class TaskService {
return
pageable
;
}
private
User
getLoginUser
()
{
User
user
=
new
User
();
user
.
setRole
(
User
.
ROLE_MANAGER
);
user
.
setUsername
(
"管理员"
);
return
user
;
}
}
src/main/java/com/keymobile/rest/service/UserService.java
View file @
c8b75de4
...
...
@@ -17,4 +17,5 @@ public class UserService {
return
userDao
.
findAllByRole
(
role
);
}
}
src/main/java/com/keymobile/rest/vo/DataVo.java
0 → 100644
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
vo
;
public
class
DataVo
{
}
src/main/java/com/keymobile/rest/vo/ExcelVO.java
0 → 100644
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
vo
;
import
lombok.Data
;
import
javax.persistence.Column
;
import
javax.persistence.GeneratedValue
;
import
javax.persistence.GenerationType
;
import
javax.persistence.Id
;
import
java.sql.Timestamp
;
@Data
public
class
ExcelVO
{
private
long
id
;
private
String
config
;
private
String
desc
;
}
src/main/java/com/keymobile/rest/vo/TaskVO.java
View file @
c8b75de4
package
com
.
keymobile
.
rest
.
vo
;
import
com.fasterxml.jackson.annotation.JsonIgnore
;
import
com.keymobile.rest.model.Excel
;
import
com.keymobile.rest.model.User
;
import
lombok.Data
;
import
org.hibernate.annotations.CreationTimestamp
;
import
javax.persistence.*
;
import
java.sql.Timestamp
;
@Data
public
class
TaskVO
{
@Id
private
long
id
;
private
String
name
;
...
...
@@ -26,4 +19,14 @@ public class TaskVO {
private
Timestamp
startAt
;
private
long
userId
;
/*
新建文件id, 逗号隔开
*/
private
String
excelIds
;
/*
补录人员id, 逗号隔开
*/
private
String
userIds
;
}
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