Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
C
civil-bigdata
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
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
civil
civil-bigdata
Commits
d2d8ae22
Commit
d2d8ae22
authored
Nov 23, 2021
by
wqc
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
定时上报接口fdx88
parent
f1406ca2
Hide whitespace changes
Inline
Side-by-side
Showing
23 changed files
with
222 additions
and
529 deletions
+222
-529
config-server/src/main/resources/properties/config-dev.yml
+3
-0
config-server/src/main/resources/properties/config-product.yml
+3
-0
config-server/src/main/resources/properties/config-test.yml
+3
-0
open-server/src/main/java/com/zq/open/controller/api/DisabledApi.java
+0
-79
open-server/src/main/java/com/zq/open/service/DisabledService.java
+0
-48
open-server/src/main/java/com/zq/open/vo/DisableRequestVo.java
+0
-15
open-server/src/main/resources/bootstrap.yml
+2
-2
sync-server/pom.xml
+6
-23
sync-server/src/main/java/com/zq/sync/SyncApplication.java
+1
-25
sync-server/src/main/java/com/zq/sync/config/DataSource.java
+0
-12
sync-server/src/main/java/com/zq/sync/config/DataSourceAspect.java
+0
-49
sync-server/src/main/java/com/zq/sync/config/DataSourceNames.java
+0
-12
sync-server/src/main/java/com/zq/sync/config/DynamicDataSource.java
+0
-34
sync-server/src/main/java/com/zq/sync/config/DynamicDataSourceConfig.java
+0
-84
sync-server/src/main/java/com/zq/sync/config/ExecutorConfig.java
+0
-38
sync-server/src/main/java/com/zq/sync/config/SynKeys.java
+0
-43
sync-server/src/main/java/com/zq/sync/controller/ReportController.java
+25
-0
sync-server/src/main/java/com/zq/sync/dao/DisabledDao.java
+2
-3
sync-server/src/main/java/com/zq/sync/entity/Fdx88.java
+3
-3
sync-server/src/main/java/com/zq/sync/service/DisabledService.java
+85
-0
sync-server/src/main/java/com/zq/sync/task/ReportTask.java
+36
-0
sync-server/src/main/java/com/zq/sync/vo/Fdx88Vo.java
+7
-7
sync-server/src/main/resources/application.yml
+46
-52
No files found.
config-server/src/main/resources/properties/config-dev.yml
View file @
d2d8ae22
...
...
@@ -22,6 +22,9 @@ resource.name: RESOURCE-SERVER
open.port
:
9200
open.name
:
OPEN-SERVER
sync.port
:
9555
sync.name
:
SYNC-SERVER
gateway.port
:
9888
gateway.name
:
GATEWAY-SERVER
...
...
config-server/src/main/resources/properties/config-product.yml
View file @
d2d8ae22
...
...
@@ -22,6 +22,9 @@ resource.name: RESOURCE-SERVER
open.port
:
9200
open.name
:
OPEN-SERVER
sync.port
:
9555
sync.name
:
SYNC-SERVER
gateway.port
:
9888
gateway.name
:
GATEWAY-SERVER
...
...
config-server/src/main/resources/properties/config-test.yml
View file @
d2d8ae22
...
...
@@ -22,6 +22,9 @@ resource.name: RESOURCE-SERVER
open.port
:
9200
open.name
:
OPEN-SERVER
sync.port
:
9555
sync.name
:
SYNC-SERVER
gateway.port
:
9888
gateway.name
:
GATEWAY-SERVER
...
...
open-server/src/main/java/com/zq/open/controller/api/DisabledApi.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
open
.
controller
.
api
;
import
com.zq.open.service.DisabledService
;
import
com.zq.open.vo.Fdx88VO
;
import
io.swagger.annotations.Api
;
import
lombok.RequiredArgsConstructor
;
import
org.springframework.http.*
;
import
org.springframework.util.LinkedMultiValueMap
;
import
org.springframework.util.MultiValueMap
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.springframework.web.client.RestTemplate
;
import
java.util.Date
;
import
java.util.List
;
@Api
(
tags
=
"残疾人相关接口"
)
@RequiredArgsConstructor
@RestController
@RequestMapping
(
value
=
"/open/api/disabled"
)
public
class
DisabledApi
{
private
final
DisabledService
disabledService
;
//补贴对象类型FDX88上报
@PostMapping
(
"/btreport"
)
public
void
bttype
()
{
List
<
Fdx88VO
>
list
=
disabledService
.
search
();
for
(
Fdx88VO
vo
:
list
)
{
RestTemplate
client
=
new
RestTemplate
();
HttpHeaders
headers
=
new
HttpHeaders
();
// 请勿轻易改变此提交方式,大部分的情况下,提交方式都是表单提交
headers
.
setContentType
(
MediaType
.
APPLICATION_FORM_URLENCODED
);
// 封装参数,千万不要替换为Map与HashMap,否则参数无法传递
MultiValueMap
<
String
,
Object
>
params
=
new
LinkedMultiValueMap
<
String
,
Object
>();
params
.
add
(
"request_id"
,
""
);
params
.
add
(
"version"
,
"1.0"
);
params
.
add
(
"format"
,
"json"
);
params
.
add
(
"sign"
,
""
);
params
.
add
(
"timestamp"
,
String
.
valueOf
(
new
Date
().
getTime
()));
params
.
add
(
"access_key"
,
"mzb_gx_450000"
);
params
.
add
(
"biz_content"
,
vo
);
HttpEntity
<
MultiValueMap
<
String
,
Object
>>
requestEntity
=
new
HttpEntity
<
MultiValueMap
<
String
,
Object
>>(
params
,
headers
);
// 执行HTTP请求
ResponseEntity
<
String
>
response
=
client
.
exchange
(
"https://zwxt.mca.gov.cn/fwjc_engine_int/rest/cjrfl_report_btdxlxxx"
,
HttpMethod
.
POST
,
requestEntity
,
String
.
class
);
// 输出结果
System
.
out
.
println
(
response
.
getBody
());
}
}
// //在册人员FDX01上报
// @PostMapping("/zcreport")
// public void registered() {
// List<BizContent> list = disabledService.search();
// for (BizContent bizContent : list) {
// RestTemplate client = new RestTemplate();
// HttpHeaders headers = new HttpHeaders();
// // 请勿轻易改变此提交方式,大部分的情况下,提交方式都是表单提交
// headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
// // 封装参数,千万不要替换为Map与HashMap,否则参数无法传递
// MultiValueMap<String, Object> params= new LinkedMultiValueMap<String, Object>();
// params.add("request_id", "");
// params.add("version", "1.0");
// params.add("format", "json");
// params.add("sign", "");
// params.add("timestamp", String.valueOf(new Date().getTime()));
// params.add("access_key", "mzb_gx_450000");
// //@RequestBody BizContent bizContent
// params.add("biz_content", bizContent);
// HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<MultiValueMap<String, Object>>(params, headers);
// // 执行HTTP请求
// ResponseEntity<String> response = client.exchange("https://zwxt.mca.gov.cn/fwjc_engine_int/rest/cjrfl_report_btdxlxxx", HttpMethod.POST, requestEntity, String.class);
// // 输出结果
// System.out.println(response.getBody());
//// return response.getBody();
// }
// }
}
open-server/src/main/java/com/zq/open/service/DisabledService.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
open
.
service
;
import
com.baomidou.mybatisplus.core.toolkit.Wrappers
;
import
com.zq.open.dao.DisabledDao
;
import
com.zq.open.entity.Fdx88
;
import
com.zq.open.entity.Mrcase
;
import
com.zq.open.vo.Fdx88VO
;
import
com.zq.open.vo.MarriageVo
;
import
org.springframework.stereotype.Service
;
import
java.util.ArrayList
;
import
java.util.List
;
@Service
public
class
DisabledService
{
private
DisabledDao
disabledDao
;
public
List
<
Fdx88VO
>
search
()
{
List
<
Fdx88
>
list
=
disabledDao
.
selectList
(
Wrappers
.
lambdaQuery
(
Fdx88
.
class
));
List
<
Fdx88VO
>
returnList
=
new
ArrayList
<>();
for
(
Fdx88
fdx88
:
list
)
{
Fdx88VO
build
=
Fdx88VO
.
builder
()
.
afdx0801
(
fdx88
.
getAfdx0801
())
.
axcp0004
(
fdx88
.
getAxcp0004
())
.
afdx0803
(
fdx88
.
getAfdx0803
())
.
afdx0804
(
fdx88
.
getAfdx0804
())
.
afdx0805
(
fdx88
.
getAfdx0805
())
.
afdx0806
(
fdx88
.
getAfdx0806
())
.
afdx0807
(
fdx88
.
getAfdx0807
())
.
afdx0808
(
fdx88
.
getAfdx0808
())
.
afdx0809
(
fdx88
.
getAfdx0809
())
.
afdx0810
(
fdx88
.
getAfdx0810
())
.
afdx0811
(
fdx88
.
getAfdx0811
())
.
afdx0812
(
fdx88
.
getAfdx0812
())
.
afdx0814
(
fdx88
.
getAfdx0814
())
.
afdx0815
(
fdx88
.
getAfdx0815
())
.
afdx0816
(
fdx88
.
getAfdx0816
())
.
afdx0817
(
fdx88
.
getAfdx0817
())
.
afdx0818
(
fdx88
.
getAfdx0818
())
.
build
();
returnList
.
add
(
build
);
}
return
returnList
;
}
}
open-server/src/main/java/com/zq/open/vo/DisableRequestVo.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
open
.
vo
;
import
lombok.Data
;
@Data
public
class
DisableRequestVo
{
private
String
accessKey
;
private
String
format
;
private
String
requestId
;
private
String
sign
;
private
String
timestamp
;
private
String
version
;
private
Fdx88VO
vo
;
}
open-server/src/main/resources/bootstrap.yml
View file @
d2d8ae22
...
...
@@ -15,5 +15,5 @@ eureka:
instance-id
:
${spring.cloud.client.ip-address}:${server.port}
client
:
service-url
:
#
defaultZone: http://admin:123456@127.0.0.1:8800/eureka/
defaultZone
:
http://admin:123456@192.168.0.191:8800/eureka/
defaultZone
:
http://admin:123456@127.0.0.1:8800/eureka/
#
defaultZone: http://admin:123456@192.168.0.191:8800/eureka/
sync-server/pom.xml
View file @
d2d8ae22
...
...
@@ -53,6 +53,12 @@
<artifactId>
mybatis-plus-boot-starter
</artifactId>
<version>
${mybatis.plus.version}
</version>
</dependency>
<!--Mybatis plus多数据源-->
<dependency>
<groupId>
com.baomidou
</groupId>
<artifactId>
dynamic-datasource-spring-boot-starter
</artifactId>
<version>
3.4.0
</version>
</dependency>
<!-- druid数据源驱动 -->
<dependency>
<groupId>
com.alibaba
</groupId>
...
...
@@ -65,30 +71,7 @@
<artifactId>
mysql-connector-java
</artifactId>
<scope>
runtime
</scope>
</dependency>
<!-- sqlserver -->
<dependency>
<groupId>
com.microsoft.sqlserver
</groupId>
<artifactId>
sqljdbc4
</artifactId>
<version>
4.0
</version>
</dependency>
<dependency>
<groupId>
com.microsoft.sqlserver
</groupId>
<artifactId>
mssql-jdbc
</artifactId>
<version>
6.2.0.jre8
</version>
<scope>
runtime
</scope>
</dependency>
<!-- oracle8 -->
<dependency>
<groupId>
org.oracle
</groupId>
<artifactId>
ojdbc8
</artifactId>
<version>
12.1.0.2.0
</version>
</dependency>
<dependency>
<groupId>
cn.easyproject
</groupId>
<artifactId>
orai18n
</artifactId>
<version>
12.1.0.2.0
</version>
</dependency>
</dependencies>
<build>
...
...
sync-server/src/main/java/com/zq/sync/SyncApplication.java
View file @
d2d8ae22
package
com
.
zq
.
sync
;
import
com.zq.sync.config.DynamicDataSourceConfig
;
import
org.mybatis.spring.annotation.MapperScan
;
import
org.springframework.boot.SpringApplication
;
import
org.springframework.boot.autoconfigure.SpringBootApplication
;
...
...
@@ -13,34 +12,11 @@ import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import
org.springframework.web.filter.CorsFilter
;
@EnableScheduling
@SpringBootApplication
@Import
({
DynamicDataSourceConfig
.
class
})
@MapperScan
(
"com.zq.sync.dao"
)
@SpringBootApplication
public
class
SyncApplication
{
public
static
void
main
(
String
[]
args
)
{
SpringApplication
.
run
(
SyncApplication
.
class
,
args
);
}
@Bean
@ConditionalOnMissingBean
public
CorsFilter
corsFilter
()
{
final
UrlBasedCorsConfigurationSource
source
=
new
UrlBasedCorsConfigurationSource
();
final
CorsConfiguration
config
=
new
CorsConfiguration
();
config
.
addAllowedOrigin
(
"*"
);
config
.
addAllowedHeader
(
"Content-Type"
);
config
.
addAllowedHeader
(
"X-Requested-With"
);
config
.
addAllowedHeader
(
"Accept"
);
config
.
addAllowedHeader
(
"x-admin-token"
);
config
.
addAllowedHeader
(
"x-app-token"
);
config
.
addAllowedMethod
(
"OPTIONS"
);
config
.
addAllowedMethod
(
"GET"
);
config
.
addAllowedMethod
(
"POST"
);
source
.
registerCorsConfiguration
(
"/**"
,
config
);
return
new
CorsFilter
(
source
);
}
}
sync-server/src/main/java/com/zq/sync/config/DataSource.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
import
java.lang.annotation.*
;
@Target
(
ElementType
.
METHOD
)
@Retention
(
RetentionPolicy
.
RUNTIME
)
@Documented
public
@interface
DataSource
{
String
name
()
default
""
;
}
sync-server/src/main/java/com/zq/sync/config/DataSourceAspect.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
import
lombok.extern.slf4j.Slf4j
;
import
org.aspectj.lang.ProceedingJoinPoint
;
import
org.aspectj.lang.annotation.Around
;
import
org.aspectj.lang.annotation.Aspect
;
import
org.aspectj.lang.annotation.Pointcut
;
import
org.aspectj.lang.reflect.MethodSignature
;
import
org.springframework.core.Ordered
;
import
org.springframework.stereotype.Component
;
import
java.lang.reflect.Method
;
@Aspect
@Component
@Slf4j
public
class
DataSourceAspect
implements
Ordered
{
//等同于before
@Pointcut
(
"@annotation(com.zq.sync.config.DataSource)"
)
public
void
dataSourcePointCut
()
{
}
@Around
(
"dataSourcePointCut()"
)
public
Object
around
(
ProceedingJoinPoint
point
)
throws
Throwable
{
MethodSignature
signature
=
(
MethodSignature
)
point
.
getSignature
();
Method
method
=
signature
.
getMethod
();
DataSource
ds
=
method
.
getAnnotation
(
DataSource
.
class
);
if
(
ds
==
null
)
{
DynamicDataSource
.
setDataSource
(
DataSourceNames
.
GXMZ
);
log
.
debug
(
"set datasource is "
+
DataSourceNames
.
GXMZ
);
}
else
{
DynamicDataSource
.
setDataSource
(
ds
.
name
());
log
.
debug
(
"set datasource is "
+
ds
.
name
());
}
try
{
return
point
.
proceed
();
}
finally
{
DynamicDataSource
.
clearDataSource
();
log
.
debug
(
"clean datasource"
);
}
}
@Override
public
int
getOrder
()
{
return
1
;
}
}
sync-server/src/main/java/com/zq/sync/config/DataSourceNames.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
public
interface
DataSourceNames
{
String
GXMZDBOS
=
"gxmzdbos"
;
String
GXMZQZJ
=
"gxmzqzj"
;
String
GXMZQZJ_DB
=
"gxmzqzj-db"
;
String
GXMZQZJ_CJ
=
"gxmzqzj-cj"
;
String
GXMZ
=
"gxmz"
;
String
GXMZDBOS_DB
=
"gxmzdbos-db"
;
String
GXMZDB
=
"gxmzdb"
;
}
sync-server/src/main/java/com/zq/sync/config/DynamicDataSource.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
import
org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource
;
import
javax.sql.DataSource
;
import
java.util.Map
;
public
class
DynamicDataSource
extends
AbstractRoutingDataSource
{
private
static
final
ThreadLocal
<
String
>
contextHolder
=
new
ThreadLocal
<>();
public
DynamicDataSource
(
DataSource
defaultTargetDataSource
,
Map
<
Object
,
Object
>
targetDataSources
)
{
super
.
setDefaultTargetDataSource
(
defaultTargetDataSource
);
super
.
setTargetDataSources
(
targetDataSources
);
super
.
afterPropertiesSet
();
}
@Override
protected
Object
determineCurrentLookupKey
()
{
return
getDataSource
();
}
public
static
void
setDataSource
(
String
dataSource
)
{
contextHolder
.
set
(
dataSource
);
}
public
static
String
getDataSource
()
{
return
contextHolder
.
get
();
}
public
static
void
clearDataSource
()
{
contextHolder
.
remove
();
}
}
sync-server/src/main/java/com/zq/sync/config/DynamicDataSourceConfig.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
import
com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder
;
import
org.springframework.beans.factory.annotation.Qualifier
;
import
org.springframework.boot.context.properties.ConfigurationProperties
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.context.annotation.Primary
;
import
javax.sql.DataSource
;
import
java.util.HashMap
;
import
java.util.Map
;
@Configuration
public
class
DynamicDataSourceConfig
{
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzdbos"
)
public
DataSource
gxmzdbosDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzqzj"
)
public
DataSource
gxmzqzjDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzqzj-db"
)
public
DataSource
gxmzqzjDBDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzqzj-cj"
)
public
DataSource
gxmzqzjCJDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmz"
)
public
DataSource
gxmzDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzdb"
)
public
DataSource
gxmzDBSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.gxmzdbos-db"
)
public
DataSource
gxmzdbDataSource
()
{
return
DruidDataSourceBuilder
.
create
().
build
();
}
@Bean
@Primary
public
DynamicDataSource
dataSource
(
@Qualifier
(
"gxmzdbosDataSource"
)
DataSource
gxmzdbosDataSource
,
@Qualifier
(
"gxmzqzjDataSource"
)
DataSource
gxmzqzjDataSource
,
@Qualifier
(
"gxmzqzjDBDataSource"
)
DataSource
gxmzqzjDBDataSource
,
@Qualifier
(
"gxmzqzjCJDataSource"
)
DataSource
gxmzqzjCJDataSource
,
@Qualifier
(
"gxmzDataSource"
)
DataSource
gxmzDataSource
,
@Qualifier
(
"gxmzDBSource"
)
DataSource
gxmzDBSource
,
@Qualifier
(
"gxmzdbDataSource"
)
DataSource
gxmzdbDataSource
)
{
Map
<
Object
,
Object
>
targetDataSources
=
new
HashMap
<>();
targetDataSources
.
put
(
DataSourceNames
.
GXMZDBOS
,
gxmzdbosDataSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZQZJ
,
gxmzqzjDataSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZ
,
gxmzDataSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZDBOS_DB
,
gxmzdbDataSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZDB
,
gxmzDBSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZQZJ_DB
,
gxmzqzjDBDataSource
);
targetDataSources
.
put
(
DataSourceNames
.
GXMZQZJ_CJ
,
gxmzqzjCJDataSource
);
return
new
DynamicDataSource
(
gxmzDataSource
,
targetDataSources
);
}
}
sync-server/src/main/java/com/zq/sync/config/ExecutorConfig.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.scheduling.annotation.EnableAsync
;
import
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
;
import
java.util.concurrent.Executor
;
import
java.util.concurrent.ThreadPoolExecutor
;
/**
* 自定义线程池
* @author Lander
*/
@Slf4j
@Configuration
@EnableAsync
public
class
ExecutorConfig
{
@Bean
(
name
=
"MyThreadPool"
)
public
Executor
MyThreadPool
()
{
ThreadPoolTaskExecutor
executor
=
new
ThreadPoolTaskExecutor
();
executor
.
setCorePoolSize
(
30
);
//表示线程池核心线程,正常情况下开启的线程数量。
executor
.
setQueueCapacity
(
500
);
//配置队列大小
executor
.
setMaxPoolSize
(
50
);
//当核心线程都在跑任务,还有多余的任务会存到此处。
executor
.
setKeepAliveSeconds
(
60
);
//非核心线程的超时时长,超长后会被回收。
executor
.
setThreadNamePrefix
(
"MyThreadPool-"
);
//配置线程池前缀
//用来设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean
executor
.
setWaitForTasksToCompleteOnShutdown
(
true
);
executor
.
setRejectedExecutionHandler
((
Runnable
r
,
ThreadPoolExecutor
exe
)
->
{
log
.
warn
(
"MyThreadPool-当前任务线程池队列已满!"
);
});
//配置拒绝策略
executor
.
initialize
();
//初始化线程池。
return
executor
;
}
}
sync-server/src/main/java/com/zq/sync/config/SynKeys.java
deleted
100644 → 0
View file @
f1406ca2
package
com
.
zq
.
sync
.
config
;
public
class
SynKeys
{
/**
* 低保_标准 ENSYS_STANDARD 的同步配置标识
*/
public
static
final
String
STANDARD_SYN_KEY
=
"standard"
;
/**
* 低保_家庭 HOME_HIS 的同步配置标识
*/
public
static
final
String
HOME_HIS_SYN_KEY
=
"home_his"
;
/**
* 低保_申请_家庭 APPLY_HOME 的同步配置标识
*/
public
static
final
String
APPLY_HOME_SYN_KEY
=
"apply_home"
;
/**
* 低保_收入 INCOME_HIS 的同步配置标识
*/
public
static
final
String
INCOME_HIS_SYN_KEY
=
"income_his"
;
/**
* baf01 的同步配置标识
*/
public
static
final
String
BAF01_SYN_KEY
=
"baf01"
;
/**
* bap01 的同步配置标识
*/
public
static
final
String
BAP01_SYN_KEY
=
"bap01"
;
/**
* bap95 的同步配置标识
*/
public
static
final
String
BAP95_SYN_KEY
=
"bap"
;
}
sync-server/src/main/java/com/zq/sync/controller/ReportController.java
0 → 100644
View file @
d2d8ae22
package
com
.
zq
.
sync
.
controller
;
import
com.zq.common.vo.ResultVo
;
import
com.zq.sync.service.DisabledService
;
import
io.swagger.annotations.Api
;
import
lombok.RequiredArgsConstructor
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
@Api
(
tags
=
"残疾人相关接口"
)
@RequiredArgsConstructor
@RestController
@RequestMapping
(
value
=
"/sync/disabled"
)
public
class
ReportController
{
private
final
DisabledService
disabledService
;
@GetMapping
(
value
=
"/fdx88"
)
public
ResultVo
fdx88
()
{
disabledService
.
fdx88
();
return
ResultVo
.
success
(
"成功"
);
}
}
open-server/src/main/java/com/zq/open
/dao/DisabledDao.java
→
sync-server/src/main/java/com/zq/sync
/dao/DisabledDao.java
View file @
d2d8ae22
package
com
.
zq
.
open
.
dao
;
package
com
.
zq
.
sync
.
dao
;
import
com.baomidou.dynamic.datasource.annotation.DS
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.zq.common.constant.DBName
;
import
com.zq.open.entity.Fdx88
;
import
com.zq.open.vo.Fdx88VO
;
import
com.zq.sync.entity.Fdx88
;
import
org.springframework.stereotype.Repository
;
...
...
open-server/src/main/java/com/zq/open
/entity/Fdx88.java
→
sync-server/src/main/java/com/zq/sync
/entity/Fdx88.java
View file @
d2d8ae22
package
com
.
zq
.
open
.
entity
;
import
java.util.Date
;
package
com
.
zq
.
sync
.
entity
;
import
com.baomidou.mybatisplus.annotation.TableName
;
import
io.swagger.annotations.ApiModelProperty
;
...
...
@@ -9,6 +7,8 @@ import lombok.Builder;
import
lombok.Data
;
import
lombok.NoArgsConstructor
;
import
java.util.Date
;
/**
* 补贴对象类型信息表(Fdx88)实体类
*
...
...
sync-server/src/main/java/com/zq/sync/service/DisabledService.java
0 → 100644
View file @
d2d8ae22
package
com
.
zq
.
sync
.
service
;
import
cn.hutool.core.date.DatePattern
;
import
cn.hutool.core.date.DateUtil
;
import
cn.hutool.core.util.IdUtil
;
import
cn.hutool.http.HttpRequest
;
import
cn.hutool.http.HttpResponse
;
import
cn.hutool.json.JSONObject
;
import
cn.hutool.json.JSONUtil
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.zq.sync.dao.DisabledDao
;
import
com.zq.sync.entity.Fdx88
;
import
com.zq.sync.vo.Fdx88Vo
;
import
lombok.RequiredArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.stereotype.Service
;
import
java.math.BigDecimal
;
import
java.math.RoundingMode
;
import
java.util.List
;
@Slf4j
@Service
@RequiredArgsConstructor
public
class
DisabledService
{
private
final
DisabledDao
disabledDao
;
public
void
fdx88
(){
int
page
=
1
;
int
size
=
10000
;
while
(
true
){
Page
<
Fdx88
>
fdx88Page
=
disabledDao
.
selectPage
(
new
Page
<>(
page
,
size
),
null
);
List
<
Fdx88
>
records
=
fdx88Page
.
getRecords
();
for
(
Fdx88
fdx88
:
records
)
{
Fdx88Vo
build
=
Fdx88Vo
.
builder
()
.
afdx0801
(
fdx88
.
getAfdx0801
())
.
axcp0004
(
fdx88
.
getAxcp0004
())
.
afdx0803
(
fdx88
.
getAfdx0803
()!=
null
?
BigDecimal
.
valueOf
(
fdx88
.
getAfdx0803
()).
setScale
(
2
,
RoundingMode
.
HALF_UP
).
toString
():
""
)
.
afdx0804
(
fdx88
.
getAfdx0804
())
.
afdx0805
(
fdx88
.
getAfdx0805
())
.
afdx0806
(
fdx88
.
getAfdx0806
())
.
afdx0807
(
fdx88
.
getAfdx0807
())
.
afdx0808
(
fdx88
.
getAfdx0808
())
.
afdx0809
(
fdx88
.
getAfdx0809
())
.
afdx0810
(
fdx88
.
getAfdx0810
()!=
null
?
DateUtil
.
format
(
fdx88
.
getAfdx0810
(),
DatePattern
.
NORM_MONTH_PATTERN
):
""
)
.
afdx0811
(
fdx88
.
getAfdx0811
()!=
null
?
DateUtil
.
format
(
fdx88
.
getAfdx0811
(),
DatePattern
.
NORM_MONTH_PATTERN
):
""
)
.
afdx0812
(
fdx88
.
getAfdx0812
())
.
afdx0814
(
fdx88
.
getAfdx0814
())
.
afdx0815
(
fdx88
.
getAfdx0815
())
.
afdx0816
(
fdx88
.
getAfdx0816
())
.
afdx0817
(
fdx88
.
getAfdx0817
()!=
null
?
DateUtil
.
format
(
fdx88
.
getAfdx0817
(),
DatePattern
.
NORM_DATETIME_PATTERN
):
""
)
.
afdx0818
(
fdx88
.
getAfdx0818
()!=
null
?
DateUtil
.
format
(
fdx88
.
getAfdx0818
(),
DatePattern
.
NORM_DATETIME_PATTERN
):
""
)
.
build
();
HttpRequest
request
=
HttpRequest
.
post
(
""
)
.
form
(
"access_key"
,
"mzb_gx_450000"
)
.
form
(
"format"
,
"json"
)
.
form
(
"request_id"
,
IdUtil
.
simpleUUID
())
.
form
(
"sign"
,
""
)
.
form
(
"timestamp"
,
System
.
currentTimeMillis
())
.
form
(
"version"
,
"1.0"
)
.
form
(
"biz_content"
,
JSONUtil
.
toJsonStr
(
build
));
HttpResponse
response
=
request
.
execute
();
if
(
response
.
getStatus
()!=
200
){
log
.
error
(
"接口请求失败 => {}"
,
request
);
}
String
body
=
response
.
body
();
JSONObject
obj
=
JSONUtil
.
parseObj
(
body
);
Integer
code
=
obj
.
getInt
(
"code"
);
if
(
code
==
null
||
code
!=
1
){
log
.
warn
(
"上报错误 => {}"
,
body
);
}
}
if
(!
fdx88Page
.
hasNext
()){
break
;
}
page
++;
}
}
}
sync-server/src/main/java/com/zq/sync/task/ReportTask.java
0 → 100644
View file @
d2d8ae22
package
com
.
zq
.
sync
.
task
;
import
cn.hutool.core.date.DatePattern
;
import
cn.hutool.core.date.DateUtil
;
import
cn.hutool.core.date.format.DatePrinter
;
import
cn.hutool.core.util.IdUtil
;
import
cn.hutool.http.HttpRequest
;
import
cn.hutool.http.HttpResponse
;
import
cn.hutool.json.JSONObject
;
import
cn.hutool.json.JSONUtil
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.zq.sync.dao.DisabledDao
;
import
com.zq.sync.entity.Fdx88
;
import
com.zq.sync.service.DisabledService
;
import
com.zq.sync.vo.Fdx88Vo
;
import
lombok.RequiredArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.scheduling.annotation.Scheduled
;
import
org.springframework.stereotype.Component
;
@Slf4j
@Component
@RequiredArgsConstructor
public
class
ReportTask
{
private
final
DisabledService
disabledService
;
/**
* 每月16日执行上报
*/
@Scheduled
(
cron
=
"0 0 0 16 * ?"
)
public
void
fdx88
(){
disabledService
.
fdx88
();
}
}
open-server/src/main/java/com/zq/open/vo/Fdx88VO
.java
→
sync-server/src/main/java/com/zq/sync/vo/Fdx88Vo
.java
View file @
d2d8ae22
package
com
.
zq
.
open
.
vo
;
package
com
.
zq
.
sync
.
vo
;
import
com.fasterxml.jackson.annotation.JsonInclude
;
import
io.swagger.annotations.ApiModelProperty
;
...
...
@@ -14,7 +14,7 @@ import java.util.Date;
@NoArgsConstructor
@Builder
@JsonInclude
(
JsonInclude
.
Include
.
NON_NULL
)
public
class
Fdx88V
O
{
public
class
Fdx88V
o
{
/**
* 补贴对象类型名称
*/
...
...
@@ -31,7 +31,7 @@ public class Fdx88VO {
* 标准金额
*/
@ApiModelProperty
(
"标准金额"
)
private
Integer
afdx0803
;
private
String
afdx0803
;
/**
* 备注
...
...
@@ -73,13 +73,13 @@ public class Fdx88VO {
* 启用月份
*/
@ApiModelProperty
(
"启用月份"
)
private
Date
afdx0810
;
private
String
afdx0810
;
/**
* 停用月份
*/
@ApiModelProperty
(
"停用月份"
)
private
Date
afdx0811
;
private
String
afdx0811
;
/**
* 调标前的标准名称
...
...
@@ -109,11 +109,11 @@ public class Fdx88VO {
* 录入时间
*/
@ApiModelProperty
(
"录入时间"
)
private
Date
afdx0817
;
private
String
afdx0817
;
/**
* 修改时间
*/
@ApiModelProperty
(
"修改时间"
)
private
Date
afdx0818
;
private
String
afdx0818
;
}
sync-server/src/main/resources/application.yml
View file @
d2d8ae22
server
:
port
:
10230
port
:
12023
#配置数据源
spring
:
application
:
name
:
SYNC-SERVER
datasource
:
druid
:
gxmzdbos-db
:
url
:
jdbc:mysql://192.168.0.193:3306/gx-db?characterEncoding=utf8&useSSL=false
username
:
root
password
:
rooT123!321
driver-class-name
:
com.mysql.jdbc.Driver
gxmzdbos
:
url
:
jdbc:mysql://192.168.0.193:3306/gx-yl?characterEncoding=utf8&useSSL=false
username
:
root
password
:
rooT123!321
driver-class-name
:
com.mysql.jdbc.Driver
gxmzqzj
:
url
:
jdbc:mysql://192.168.0.197:10008/gx_yl?characterEncoding=utf8&useSSL=false
username
:
root
password
:
root
driver-class-name
:
com.mysql.jdbc.Driver
#前置机低保库
gxmzqzj-db
:
url
:
jdbc:mysql://192.168.0.197:10008/gx_db?characterEncoding=utf8&useSSL=false
username
:
root
password
:
root
driver-class-name
:
com.mysql.jdbc.Driver
#前置机残疾库
gxmzqzj-cj
:
url
:
jdbc:mysql://192.168.0.197:10008/gx_cj?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
username
:
root
password
:
root
driver-class-name
:
com.mysql.jdbc.Driver
gxmz
:
url
:
jdbc:mysql://192.168.201.28:3306/gx_unify?characterEncoding=utf8&useSSL=false
username
:
xieying
password
:
sharewin!#2020
driver-class-name
:
com.mysql.jdbc.Driver
#源数据库
gxmzdb
:
url
:
jdbc:oracle:thin:@//192.168.0.74:1521/GXDB
username
:
LiSZ
password
:
LSZ192125mcm
driver-class-name
:
oracle.jdbc.driver.OracleDriver
# gxmzqzj:
# driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
# username: sa
# password: gxmz@2017
# url: jdbc:sqlserver://192.168.0.220:1433;DatabaseName=gxqzdb
eureka
:
client
:
register-with-eureka
:
false
fetch-registry
:
false
mybatis-plus
:
mapper-locations
:
classpath:mapper/**/*.xml
dynamic
:
# mybatis plus多数据源插件
primary
:
master
#设置默认的数据源或者数据源组,默认值即为master
strict
:
true
#严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
datasource
:
gxcj
:
type
:
com.alibaba.druid.pool.DruidDataSource
driver-class-name
:
com.mysql.cj.jdbc.Driver
username
:
root
password
:
rooT123!321
url
:
jdbc:mysql://192.168.0.197:10008/gx_cj?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai
druid
:
# 初始连接数
initial-size
:
10
# 最小连接数
min-idle
:
20
# 最大连接数
max-active
:
50
# 获取连接超时时间
max-wait
:
5000
# 连接有效性检测时间
time-between-eviction-runs-millis
:
60000
# 连接在池中最小生存的时间
min-evictable-idle-time-millis
:
300000
# 连接在池中最大生存的时间
max-evictable-idle-time-millis
:
900000
test-while-idle
:
true
test-on-borrow
:
false
test-on-return
:
false
# 检测连接是否有效
validation-query
:
SELECT 1 FROM DUAL
filters
:
stat
stat
:
merge-sql
:
true
log-slow-sql
:
true
slow-sql-millis
:
2000
logging.lever.com.zq.syn.dao
:
debug
# mybatis plus 配置
mybatis-plus
:
global-config
:
db-config
:
select-strategy
:
not_empty
update-strategy
:
not_empty
\ No newline at end of file
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