Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
Y
yl-transfer
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
图表
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
孙于凯
yl-transfer
Commits
76681b84
提交
76681b84
authored
7月 15, 2024
作者:
ljj
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix:fixbug
上级
a0c870a1
隐藏空白字符变更
内嵌
并排
正在显示
4 个修改的文件
包含
19 行增加
和
6 行删除
+19
-6
Biz088DcBranchTrainStatisticsImpl.java
...slave_service/impl/Biz088DcBranchTrainStatisticsImpl.java
+5
-1
Biz088DcNetworkStatisticsImpl.java
...fer/slave_service/impl/Biz088DcNetworkStatisticsImpl.java
+1
-1
Biz088DcTrainStatisticsImpl.java
...nsfer/slave_service/impl/Biz088DcTrainStatisticsImpl.java
+7
-2
Biz088DcVolunteerStatisticsImpl.java
...r/slave_service/impl/Biz088DcVolunteerStatisticsImpl.java
+6
-2
没有找到文件。
src/main/java/com/tykj/transfer/slave_service/impl/Biz088DcBranchTrainStatisticsImpl.java
浏览文件 @
76681b84
...
@@ -30,9 +30,12 @@ import javax.transaction.Transactional;
...
@@ -30,9 +30,12 @@ import javax.transaction.Transactional;
import
java.io.File
;
import
java.io.File
;
import
java.io.IOException
;
import
java.io.IOException
;
import
java.nio.charset.StandardCharsets
;
import
java.nio.charset.StandardCharsets
;
import
java.time.LocalDateTime
;
import
java.time.format.DateTimeFormatter
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.Date
;
import
java.util.Date
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Locale
;
import
java.util.regex.Matcher
;
import
java.util.regex.Matcher
;
import
java.util.regex.Pattern
;
import
java.util.regex.Pattern
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
...
@@ -68,12 +71,13 @@ public class Biz088DcBranchTrainStatisticsImpl implements Biz088DcBranchTrainSta
...
@@ -68,12 +71,13 @@ public class Biz088DcBranchTrainStatisticsImpl implements Biz088DcBranchTrainSta
List
<
Biz088DcBranchTrainStatistics
>
rs
=
new
ArrayList
<>();
List
<
Biz088DcBranchTrainStatistics
>
rs
=
new
ArrayList
<>();
List
<
YlBranchTrainStatistics
>
listVo
=
new
ArrayList
<>();
List
<
YlBranchTrainStatistics
>
listVo
=
new
ArrayList
<>();
Date
date
=
new
Date
();
Date
date
=
new
Date
();
String
yyyyMMdd
=
LocalDateTime
.
now
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyyMMdd"
));
for
(
BranchesVo
branchesVo
:
branchesList
)
{
for
(
BranchesVo
branchesVo
:
branchesList
)
{
Biz088DcBranchTrainStatistics
VO
=
new
Biz088DcBranchTrainStatistics
();
Biz088DcBranchTrainStatistics
VO
=
new
Biz088DcBranchTrainStatistics
();
YlBranchTrainStatistics
ylBranchTrainStatistics
=
new
YlBranchTrainStatistics
();
YlBranchTrainStatistics
ylBranchTrainStatistics
=
new
YlBranchTrainStatistics
();
VO
.
setBranchName
(
branchesVo
.
getName
());
VO
.
setBranchName
(
branchesVo
.
getName
());
Branches
allByName
=
branchesDao
.
findAllByName
(
branchesVo
.
getName
()).
get
(
0
);
Branches
allByName
=
branchesDao
.
findAllByName
(
branchesVo
.
getName
()).
get
(
0
);
VO
.
setId
(
allByName
.
getId
()
+
""
);
VO
.
setId
(
yyyyMMdd
+
allByName
.
getId
()
);
VO
.
setRegionCode
(
allByName
.
getArea
());
VO
.
setRegionCode
(
allByName
.
getArea
());
List
<
Activity
>
allByBranchId
=
activitiesDao
.
findAllByBranchId
(
allByName
.
getId
());
List
<
Activity
>
allByBranchId
=
activitiesDao
.
findAllByBranchId
(
allByName
.
getId
());
Long
activityApplyCount
=
0L
;
Long
activityApplyCount
=
0L
;
...
...
src/main/java/com/tykj/transfer/slave_service/impl/Biz088DcNetworkStatisticsImpl.java
浏览文件 @
76681b84
...
@@ -77,7 +77,7 @@ public class Biz088DcNetworkStatisticsImpl implements Biz088DcNetworkStatisticsS
...
@@ -77,7 +77,7 @@ public class Biz088DcNetworkStatisticsImpl implements Biz088DcNetworkStatisticsS
//计数
//计数
i
++;
i
++;
if
(
i
%
100
==
0
)
{
if
(
i
%
100
==
0
)
{
log
.
info
(
"{}/{}"
,
i
/
total
);
log
.
info
(
"{}/{}"
,
i
,
total
);
}
}
}
}
...
...
src/main/java/com/tykj/transfer/slave_service/impl/Biz088DcTrainStatisticsImpl.java
浏览文件 @
76681b84
...
@@ -17,6 +17,8 @@ import org.springframework.stereotype.Service;
...
@@ -17,6 +17,8 @@ import org.springframework.stereotype.Service;
import
javax.annotation.Resource
;
import
javax.annotation.Resource
;
import
javax.transaction.Transactional
;
import
javax.transaction.Transactional
;
import
java.time.LocalDateTime
;
import
java.time.format.DateTimeFormatter
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.Date
;
import
java.util.Date
;
import
java.util.List
;
import
java.util.List
;
...
@@ -45,6 +47,8 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
...
@@ -45,6 +47,8 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
List
<
Biz088DcTrainStatistics
>
rs
=
new
ArrayList
<>();
List
<
Biz088DcTrainStatistics
>
rs
=
new
ArrayList
<>();
List
<
YlTrainStatistics
>
localList
=
new
ArrayList
<>();
List
<
YlTrainStatistics
>
localList
=
new
ArrayList
<>();
Date
date
=
new
Date
();
Date
date
=
new
Date
();
String
yyyyMMdd
=
LocalDateTime
.
now
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyyMMdd"
));
String
s
=
stringRedisTemplate
.
opsForValue
().
get
(
"330000YlTotal"
);
String
s
=
stringRedisTemplate
.
opsForValue
().
get
(
"330000YlTotal"
);
PageVo
pageVo
=
JSON
.
parseObject
(
String
.
valueOf
(
s
),
PageVo
.
class
);
PageVo
pageVo
=
JSON
.
parseObject
(
String
.
valueOf
(
s
),
PageVo
.
class
);
Biz088DcTrainStatistics
provinceVo
=
new
Biz088DcTrainStatistics
();
Biz088DcTrainStatistics
provinceVo
=
new
Biz088DcTrainStatistics
();
...
@@ -65,6 +69,7 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
...
@@ -65,6 +69,7 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
provinceVo
.
setLoadTime
(
date
);
provinceVo
.
setLoadTime
(
date
);
provinceVo
.
setTongTime
(
date
);
provinceVo
.
setTongTime
(
date
);
provinceVo
.
setTongId
(
0L
);
provinceVo
.
setTongId
(
0L
);
YlTrainStatistics
localProvince
=
new
YlTrainStatistics
();
YlTrainStatistics
localProvince
=
new
YlTrainStatistics
();
BeanUtils
.
copyProperties
(
provinceVo
,
localProvince
);
BeanUtils
.
copyProperties
(
provinceVo
,
localProvince
);
List
<
RegionModelDo
>
regionVoList
=
regionModelRepository
.
getRegionVo
(
"330000"
);
List
<
RegionModelDo
>
regionVoList
=
regionModelRepository
.
getRegionVo
(
"330000"
);
...
@@ -125,10 +130,10 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
...
@@ -125,10 +130,10 @@ public class Biz088DcTrainStatisticsImpl implements Biz088DcTrainStatisticsServi
rs
.
add
(
provinceVo
);
rs
.
add
(
provinceVo
);
localList
.
add
(
localProvince
);
localList
.
add
(
localProvince
);
for
(
Biz088DcTrainStatistics
r
:
rs
)
{
for
(
Biz088DcTrainStatistics
r
:
rs
)
{
r
.
setId
(
r
.
getRegionCode
());
r
.
setId
(
yyyyMMdd
+
r
.
getRegionCode
());
}
}
for
(
YlTrainStatistics
ylTrainStatistics
:
localList
)
{
for
(
YlTrainStatistics
ylTrainStatistics
:
localList
)
{
ylTrainStatistics
.
setId
(
ylTrainStatistics
.
getRegionCode
());
ylTrainStatistics
.
setId
(
y
yyyMMdd
+
y
lTrainStatistics
.
getRegionCode
());
}
}
biz088DcTrainStatisticsDao
.
saveAll
(
rs
);
biz088DcTrainStatisticsDao
.
saveAll
(
rs
);
ylTrainStatisticsDao
.
saveAll
(
localList
);
ylTrainStatisticsDao
.
saveAll
(
localList
);
...
...
src/main/java/com/tykj/transfer/slave_service/impl/Biz088DcVolunteerStatisticsImpl.java
浏览文件 @
76681b84
...
@@ -17,6 +17,8 @@ import org.springframework.stereotype.Service;
...
@@ -17,6 +17,8 @@ import org.springframework.stereotype.Service;
import
javax.annotation.Resource
;
import
javax.annotation.Resource
;
import
javax.transaction.Transactional
;
import
javax.transaction.Transactional
;
import
java.time.LocalDateTime
;
import
java.time.format.DateTimeFormatter
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.Date
;
import
java.util.Date
;
import
java.util.List
;
import
java.util.List
;
...
@@ -41,6 +43,8 @@ public class Biz088DcVolunteerStatisticsImpl implements Biz088DcVolunteerStatist
...
@@ -41,6 +43,8 @@ public class Biz088DcVolunteerStatisticsImpl implements Biz088DcVolunteerStatist
@Override
@Override
// @Transactional
// @Transactional
public
void
transferVolunteer
()
{
public
void
transferVolunteer
()
{
String
yyyyMMdd
=
LocalDateTime
.
now
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyyMMdd"
));
String
s
=
stringRedisTemplate
.
opsForValue
().
get
(
"330000YlTotal"
);
String
s
=
stringRedisTemplate
.
opsForValue
().
get
(
"330000YlTotal"
);
List
<
Biz088DcVolunteerStatistics
>
rs
=
new
ArrayList
<>();
List
<
Biz088DcVolunteerStatistics
>
rs
=
new
ArrayList
<>();
List
<
YlVolunteerStatistics
>
localList
=
new
ArrayList
<>();
List
<
YlVolunteerStatistics
>
localList
=
new
ArrayList
<>();
...
@@ -111,10 +115,10 @@ public class Biz088DcVolunteerStatisticsImpl implements Biz088DcVolunteerStatist
...
@@ -111,10 +115,10 @@ public class Biz088DcVolunteerStatisticsImpl implements Biz088DcVolunteerStatist
}
}
}
}
for
(
Biz088DcVolunteerStatistics
r
:
rs
)
{
for
(
Biz088DcVolunteerStatistics
r
:
rs
)
{
r
.
setId
(
r
.
getRegionCode
());
r
.
setId
(
yyyyMMdd
+
r
.
getRegionCode
());
}
}
for
(
YlVolunteerStatistics
ylVolunteerStatistics
:
localList
)
{
for
(
YlVolunteerStatistics
ylVolunteerStatistics
:
localList
)
{
ylVolunteerStatistics
.
setId
(
ylVolunteerStatistics
.
getRegionCode
());
ylVolunteerStatistics
.
setId
(
y
yyyMMdd
+
y
lVolunteerStatistics
.
getRegionCode
());
}
}
biz088DcVolunteerStatisticsDao
.
saveAll
(
rs
);
biz088DcVolunteerStatisticsDao
.
saveAll
(
rs
);
ylVolunteerStatisticsDao
.
saveAll
(
localList
);
ylVolunteerStatisticsDao
.
saveAll
(
localList
);
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论