Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
J
jz-dmp-service
Project
Project
Details
Activity
Releases
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
姚本章
jz-dmp-service
Commits
93909528
Commit
93909528
authored
Dec 21, 2020
by
mcb
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
no message
parent
35851557
Changes
6
Show whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
211 additions
and
0 deletions
+211
-0
DataSourceController.java
...ules/controller/DataIntegration/DataSourceController.java
+35
-0
OfflineSynchController.java
...es/controller/DataIntegration/OfflineSynchController.java
+36
-0
TaskListPageReq.java
...ules/controller/DataIntegration/bean/TaskListPageReq.java
+95
-0
OfflineSynchDao.java
src/main/java/com/jz/dmp/modules/dao/OfflineSynchDao.java
+11
-0
OfflineSynchService.java
.../java/com/jz/dmp/modules/service/OfflineSynchService.java
+11
-0
DataGoodsApiParamsServiceImpl.java
...p/modules/service/impl/DataGoodsApiParamsServiceImpl.java
+23
-0
No files found.
src/main/java/com/jz/dmp/modules/controller/DataIntegration/DataSourceController.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
controller
.
DataIntegration
;
import
com.jz.common.constant.JsonResult
;
import
com.jz.dmp.modules.service.OfflineSynchService
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
/**
* @Description:数据源
* @ClassName: DataSourceController
* @Author Bellamy
* @Date 2020/12/20
*/
@RestController
@RequestMapping
(
"/dataSource"
)
@Api
(
tags
=
"数据集成--数据源"
)
public
class
DataSourceController
{
@Autowired
private
OfflineSynchService
offlineSynchService
;
/**
* 数据源列表分页查询
* @return
*/
@ApiOperation
(
value
=
"数据源列表分页查询"
,
notes
=
"数据源列表分页查询"
)
@PostMapping
(
value
=
"/delRedisKeys"
)
public
JsonResult
delRedisKeys
(
String
key
)
{
return
new
JsonResult
();
}
}
src/main/java/com/jz/dmp/modules/controller/DataIntegration/OfflineSynchController.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
controller
.
DataIntegration
;
import
com.jz.common.constant.JsonResult
;
import
com.jz.dmp.modules.controller.DataIntegration.bean.TaskListPageReq
;
import
com.jz.dmp.modules.service.AtomBaseCacheService
;
import
com.jz.dmp.modules.service.OfflineSynchService
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.*
;
/**
* @Description:离线同步
* @ClassName: OfflineSynchController
* @Author Bellamy
* @Date 2020/12/20
*/
@RestController
@RequestMapping
(
"/offlineSynch"
)
@Api
(
tags
=
"数据集成--离线同步"
)
public
class
OfflineSynchController
{
@Autowired
private
OfflineSynchService
offlineSynchService
;
/**
* 任务列表分页查询
* @return
*/
@ApiOperation
(
value
=
"任务列表分页查询"
,
notes
=
"任务列表分页查询"
)
@PostMapping
(
value
=
"/taskListPage"
)
public
JsonResult
delRedisKeys
(
@RequestBody
@Validated
TaskListPageReq
taskListPageReq
)
{
return
new
JsonResult
();
}
}
src/main/java/com/jz/dmp/modules/controller/DataIntegration/bean/TaskListPageReq.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
controller
.
DataIntegration
.
bean
;
/**
* @ClassName: TaskListPageReq
* @Description: 离线任务列表参数对象
* @Author
* @Date 2020/12/21
* @Version 1.0
*/
public
class
TaskListPageReq
{
// @NotNull(message = "父类ID不能空")
private
String
projectId
;
//@NotNull(message = "父类ID不能空")
private
String
parentId
;
private
String
sourceDb
;
private
String
targetDb
;
private
String
sourceTable
;
private
String
targetTable
;
private
Integer
pageNum
=
1
;
private
Integer
pageSize
=
30
;
public
String
getProjectId
()
{
return
projectId
;
}
public
void
setProjectId
(
String
projectId
)
{
this
.
projectId
=
projectId
;
}
public
String
getParentId
()
{
return
parentId
;
}
public
void
setParentId
(
String
parentId
)
{
this
.
parentId
=
parentId
;
}
public
String
getSourceDb
()
{
return
sourceDb
;
}
public
void
setSourceDb
(
String
sourceDb
)
{
this
.
sourceDb
=
sourceDb
;
}
public
String
getTargetDb
()
{
return
targetDb
;
}
public
void
setTargetDb
(
String
targetDb
)
{
this
.
targetDb
=
targetDb
;
}
public
String
getSourceTable
()
{
return
sourceTable
;
}
public
void
setSourceTable
(
String
sourceTable
)
{
this
.
sourceTable
=
sourceTable
;
}
public
String
getTargetTable
()
{
return
targetTable
;
}
public
void
setTargetTable
(
String
targetTable
)
{
this
.
targetTable
=
targetTable
;
}
public
Integer
getPageNum
()
{
return
pageNum
;
}
public
void
setPageNum
(
Integer
pageNum
)
{
this
.
pageNum
=
pageNum
;
}
public
Integer
getPageSize
()
{
return
pageSize
;
}
public
void
setPageSize
(
Integer
pageSize
)
{
this
.
pageSize
=
pageSize
;
}
}
src/main/java/com/jz/dmp/modules/dao/OfflineSynchDao.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
dao
;
/**
* @author Bellamy
* @since 2020-12-020
*/
public
interface
OfflineSynchDao
{
}
\ No newline at end of file
src/main/java/com/jz/dmp/modules/service/OfflineSynchService.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
service
;
/**
* @ClassName: OfflineSynchService
* @Description:
* @Author:Bellamy
* @Date 2020/12/19
* @Version 1.0
*/
public
interface
OfflineSynchService
{
}
src/main/java/com/jz/dmp/modules/service/impl/DataGoodsApiParamsServiceImpl.java
0 → 100644
View file @
93909528
package
com
.
jz
.
dmp
.
modules
.
service
.
impl
;
import
com.jz.dmp.modules.dao.OfflineSynchDao
;
import
com.jz.dmp.modules.service.OfflineSynchService
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
/**
* @Description:离线同步服务层
* @ClassName: DataGoodsApiParamsServiceImpl
* @Author Bellamy
* @Date 2020/12/20
*/
@Service
(
"offlineSynchService"
)
@Transactional
public
class
DataGoodsApiParamsServiceImpl
implements
OfflineSynchService
{
@Autowired
private
OfflineSynchDao
offlineSynchDao
;
}
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