Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
amos-boot-biz
Project
Project
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
项目统一框架
amos-boot-biz
Commits
9439cba9
Commit
9439cba9
authored
Jun 08, 2023
by
lisong
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
更新
parent
4a054b34
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
245 additions
and
248 deletions
+245
-248
EnterpriseStatisticController.java
...tzs/flc/biz/controller/EnterpriseStatisticController.java
+6
-7
CylinderDateInfoServiceImpl.java
...tzs/flc/biz/service/impl/CylinderDateInfoServiceImpl.java
+239
-241
No files found.
amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/controller/EnterpriseStatisticController.java
View file @
9439cba9
...
...
@@ -25,12 +25,12 @@ import java.util.List;
public
class
EnterpriseStatisticController
extends
BaseController
{
@Autowired
CylinderDateInfoServiceImpl
cylinderDateInfoService
;
CylinderDateInfoServiceImpl
cylinderDateInfoService
;
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@ApiOperation
(
value
=
"根据搜索信息获取表格数据"
)
@GetMapping
(
value
=
"/getTableInfo"
)
public
ResponseModel
<
List
<
CylinderTableDto
>>
cylinderTableInfo
()
{
public
ResponseModel
<
List
<
CylinderTableDto
>>
cylinderTableInfo
()
{
List
<
CylinderTableDto
>
result
=
cylinderDateInfoService
.
selectTodayDate
();
return
ResponseHelper
.
buildResponse
(
result
);
}
...
...
@@ -39,8 +39,8 @@ public class EnterpriseStatisticController extends BaseController {
@ApiOperation
(
value
=
"根据搜索信息获取表格数据"
)
@GetMapping
(
value
=
"/getTableInfoPage"
)
public
ResponseModel
<
Page
<
CylinderTableDto
>>
cylinderTableInfoPage
(
String
pageNumber
,
String
pageSize
,
@RequestParam
(
value
=
"regionName"
,
required
=
false
)
String
regionName
,
@RequestParam
(
value
=
"unitName"
,
required
=
false
)
String
unitName
)
{
@RequestParam
(
value
=
"regionName"
,
required
=
false
)
String
regionName
,
@RequestParam
(
value
=
"unitName"
,
required
=
false
)
String
unitName
)
{
Page
<
CylinderTableDto
>
cylinderTableDtoPage
=
cylinderDateInfoService
.
selectTodayDatePage
(
pageNumber
,
pageSize
,
regionName
,
unitName
);
return
ResponseHelper
.
buildResponse
(
cylinderTableDtoPage
);
}
...
...
@@ -49,17 +49,16 @@ public class EnterpriseStatisticController extends BaseController {
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@ApiOperation
(
value
=
"创建表格数据"
)
@GetMapping
(
value
=
"/createTableInfoPage"
)
public
ResponseModel
createTableInfoPage
()
{
public
ResponseModel
createTableInfoPage
()
{
cylinderDateInfoService
.
fixedDelayJob
();
return
ResponseHelper
.
buildResponse
(
null
);
}
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
@ApiOperation
(
value
=
"初始化统计数据"
)
@GetMapping
(
value
=
"/initializeData"
)
public
ResponseModel
initializeData
()
{
public
ResponseModel
initializeData
()
{
cylinderDateInfoService
.
initializeData
();
return
ResponseHelper
.
buildResponse
(
null
);
}
...
...
amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/flc/biz/service/impl/CylinderDateInfoServiceImpl.java
View file @
9439cba9
...
...
@@ -18,6 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.scheduling.annotation.Scheduled
;
import
org.springframework.stereotype.Service
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
java.text.SimpleDateFormat
;
import
java.util.ArrayList
;
import
java.util.Calendar
;
...
...
@@ -26,268 +27,265 @@ import java.util.List;
@Service
public
class
CylinderDateInfoServiceImpl
extends
BaseService
<
CylinderDateInfoDto
,
CylinderDateInfo
,
CylinderDateInfoMapper
>
{
private
static
final
Logger
logger
=
LogManager
.
getLogger
(
CylinderDateInfoServiceImpl
.
class
);
@Autowired
private
CylinderUnitServiceImpl
cylinderUnitService
;
@Autowired
private
CylinderFillingCheckServiceImpl
cylinderFillingCheckService
;
@Autowired
private
CylinderFillingExamineServiceImpl
cylinderFillingExamineService
;
private
static
final
Logger
logger
=
LogManager
.
getLogger
(
CylinderDateInfoServiceImpl
.
class
);
@Autowired
private
CylinderFillingRecordServiceImpl
cylinderFillingRecord
Service
;
@Autowired
private
CylinderUnitServiceImpl
cylinderUnit
Service
;
@Autowired
private
CylinderFillingServiceImpl
cylinderFilling
Service
;
@Autowired
private
CylinderFillingCheckServiceImpl
cylinderFillingCheck
Service
;
@Autowired
private
CylinderInfoServiceImpl
cylinderInfo
Service
;
@Autowired
private
CylinderFillingExamineServiceImpl
cylinderFillingExamine
Service
;
@Autowired
private
CylinderInspectionServiceImpl
cylinderInspection
Service
;
@Autowired
private
CylinderFillingRecordServiceImpl
cylinderFillingRecord
Service
;
@Autowired
private
CylinderTagsServiceImpl
cylinderTags
Service
;
@Autowired
private
CylinderFillingServiceImpl
cylinderFilling
Service
;
@Autowired
private
CylinderUnitMapper
cylinderUnitMapper
;
@Autowired
private
CylinderInfoServiceImpl
cylinderInfoService
;
public
List
<
CylinderTableDto
>
selectTodayDate
()
{
List
<
CylinderTableDto
>
result
=
new
ArrayList
<>()
;
@Autowired
private
CylinderInspectionServiceImpl
cylinderInspectionService
;
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
null
);
@Autowired
private
CylinderTagsServiceImpl
cylinderTagsService
;
for
(
CylinderUnit
token
:
cylinderUnits
)
{
CylinderTableDto
temp
=
new
CylinderTableDto
();
temp
.
setUnitName
(
token
.
getUnitName
());
// 获取气瓶基本信息
Integer
cylinderUnit
=
0
;
Integer
cylinder
=
0
;
Integer
tags
=
0
;
Integer
inspection
=
0
;
Integer
flling
=
0
;
Integer
fllingRecord
=
0
;
Integer
fllingCheck
=
0
;
Integer
examine
=
0
;
Integer
total
=
0
;
@Autowired
private
CylinderUnitMapper
cylinderUnitMapper
;
// 获取气瓶基本信息
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
eq
(
CylinderDateInfo:
:
getAppId
,
token
.
getAppId
()));
for
(
CylinderDateInfo
info
:
list
)
{
cylinder
+=
info
.
getCylinderInfo
();
cylinderUnit
+=
info
.
getCylinderUnit
();
tags
+=
info
.
getCylinderTagInfo
();
inspection
+=
info
.
getCylinderInspectionInfo
();
flling
+=
info
.
getCylinderFillingInfo
();
fllingRecord
+=
info
.
getCylinderFillingRecordInfo
();
fllingCheck
+=
info
.
getCylinderFillingCheckInfo
();
examine
+=
info
.
getCylinderExamineInfo
();
total
+=
info
.
getCylinderTotal
();
}
public
List
<
CylinderTableDto
>
selectTodayDate
()
{
List
<
CylinderTableDto
>
result
=
new
ArrayList
<>();
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
null
);
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFllingCheckInfo
(
fllingCheck
);
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderFllingInfo
(
flling
);
temp
.
setCylinderFllingRecordInfo
(
fllingRecord
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderTotal
(
total
);
temp
.
setRegionName
(
token
.
getDeveloperAgency
());
result
.
add
(
temp
);
}
return
result
;
}
for
(
CylinderUnit
token
:
cylinderUnits
)
{
CylinderTableDto
temp
=
new
CylinderTableDto
();
temp
.
setUnitName
(
token
.
getUnitName
());
// 获取气瓶基本信息
Integer
cylinderUnit
=
0
;
Integer
cylinder
=
0
;
Integer
tags
=
0
;
Integer
inspection
=
0
;
Integer
flling
=
0
;
Integer
fllingRecord
=
0
;
Integer
fllingCheck
=
0
;
Integer
examine
=
0
;
Integer
total
=
0
;
// 获取气瓶基本信息
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
eq
(
CylinderDateInfo:
:
getAppId
,
token
.
getAppId
()));
for
(
CylinderDateInfo
info
:
list
)
{
cylinder
+=
info
.
getCylinderInfo
();
cylinderUnit
+=
info
.
getCylinderUnit
();
tags
+=
info
.
getCylinderTagInfo
();
inspection
+=
info
.
getCylinderInspectionInfo
();
flling
+=
info
.
getCylinderFillingInfo
();
fllingRecord
+=
info
.
getCylinderFillingRecordInfo
();
fllingCheck
+=
info
.
getCylinderFillingCheckInfo
();
examine
+=
info
.
getCylinderExamineInfo
();
total
+=
info
.
getCylinderTotal
();
}
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFllingCheckInfo
(
fllingCheck
);
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderFllingInfo
(
flling
);
temp
.
setCylinderFllingRecordInfo
(
fllingRecord
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderTotal
(
total
);
temp
.
setRegionName
(
token
.
getDeveloperAgency
());
result
.
add
(
temp
);
}
return
result
;
}
public
Page
<
CylinderTableDto
>
selectTodayDatePage
(
String
pageNumber
,
String
pageSize
,
String
regionName
,
String
unitName
)
{
Page
<
CylinderTableDto
>
page
=
new
Page
<>();
List
<
CylinderTableDto
>
result
=
new
ArrayList
<>();
Page
<
CylinderUnit
>
cylinderUnitPage
=
new
Page
<>(
Long
.
parseLong
(
pageNumber
),
Long
.
parseLong
(
pageSize
));
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
if
(!
ObjectUtils
.
isEmpty
(
regionName
)){
lambda
.
like
(
CylinderUnit:
:
getRegionCode
,
regionName
);
}
if
(!
ObjectUtils
.
isEmpty
(
unitName
)){
lambda
.
like
(
CylinderUnit:
:
getUnitName
,
unitName
);
}
IPage
<
CylinderUnit
>
cylinderUnitIPage
=
cylinderUnitMapper
.
selectPage
(
cylinderUnitPage
,
lambda
);
for
(
CylinderUnit
unit
:
cylinderUnitIPage
.
getRecords
())
{
CylinderTableDto
temp
=
new
CylinderTableDto
();
temp
.
setUnitName
(
unit
.
getUnitName
());
// 获取气瓶基本信息
Integer
cylinderUnit
=
0
;
Integer
cylinder
=
0
;
Integer
tags
=
0
;
Integer
inspection
=
0
;
Integer
flling
=
0
;
Integer
fllingRecord
=
0
;
Integer
fllingCheck
=
0
;
Integer
examine
=
0
;
Integer
total
=
0
;
// 获取气瓶基本信息
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
eq
(
CylinderDateInfo:
:
getAppId
,
unit
.
getAppId
()));
for
(
CylinderDateInfo
info
:
list
)
{
cylinder
+=
info
.
getCylinderInfo
();
cylinderUnit
+=
info
.
getCylinderUnit
();
tags
+=
info
.
getCylinderTagInfo
();
inspection
+=
info
.
getCylinderInspectionInfo
();
flling
+=
info
.
getCylinderFillingInfo
();
fllingRecord
+=
info
.
getCylinderFillingRecordInfo
();
fllingCheck
+=
info
.
getCylinderFillingCheckInfo
();
examine
+=
info
.
getCylinderExamineInfo
();
total
+=
info
.
getCylinderTotal
();
}
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFllingCheckInfo
(
fllingCheck
);
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderFllingInfo
(
flling
);
temp
.
setCylinderFllingRecordInfo
(
fllingRecord
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderTotal
(
total
);
temp
.
setRegionName
(
unit
.
getRegionName
());
result
.
add
(
temp
);
}
page
.
setRecords
(
result
);
page
.
setTotal
(
cylinderUnitIPage
.
getTotal
());
return
page
;
}
@Scheduled
(
cron
=
"0 0 2 * * ?"
)
//每天凌晨两点执行
public
void
fixedDelayJob
(){
// 每天更新或者添加昨天的数据
Date
date
=
new
Date
();
//取时间
Calendar
calendar
=
Calendar
.
getInstance
();
calendar
.
setTime
(
date
);
calendar
.
add
(
Calendar
.
DATE
,-
1
);
//这个时间就是日期往后推一天的结果
date
=
calendar
.
getTime
();
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
lambda
);
for
(
CylinderUnit
token
:
cylinderUnits
)
{
try
{
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd"
);
String
todayStr
=
sdf
.
format
(
date
);
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
between
(
CylinderDateInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
).
eq
(
CylinderDateInfo:
:
getAppId
,
token
.
getAppId
()));
if
(
ObjectUtils
.
isEmpty
(
list
))
{
CylinderDateInfoDto
temp
=
new
CylinderDateInfoDto
();
temp
.
setSyncDate
(
date
);
String
appid
=
token
.
getAppId
();
temp
.
setUnitName
(
token
.
getUnitName
());
temp
.
setAppId
(
appid
);
temp
.
setDeveloperAgency
(
token
.
getDeveloperAgency
());
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appid
).
between
(
CylinderInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appid
).
between
(
CylinderUnit:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appid
).
between
(
CylinderTags:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appid
).
between
(
CylinderInspection:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appid
).
between
(
CylinderFilling:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appid
).
between
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appid
).
between
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appid
).
between
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFillingCheckInfo
(
fillingCheck
);
temp
.
setCylinderFillingInfo
(
filling
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderFillingRecordInfo
(
fillingRecord
);
temp
.
setCylinderTotal
(
total
);
this
.
createWithModel
(
temp
);
}
else
{
list
.
forEach
(
info
->
{
String
appId
=
token
.
getAppId
();
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appId
).
between
(
CylinderInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appId
).
between
(
CylinderUnit:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appId
).
between
(
CylinderTags:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appId
).
between
(
CylinderInspection:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appId
).
between
(
CylinderFilling:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appId
).
between
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appId
).
between
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appId
).
between
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
info
.
setCylinderExamineInfo
(
examine
);
info
.
setCylinderUnit
(
cylinderUnit
);
info
.
setCylinderFillingCheckInfo
(
fillingCheck
);
info
.
setCylinderFillingInfo
(
filling
);
info
.
setCylinderInspectionInfo
(
inspection
);
info
.
setCylinderTagInfo
(
tags
);
info
.
setCylinderInfo
(
cylinder
);
info
.
setCylinderFillingRecordInfo
(
fillingRecord
);
info
.
setCylinderTotal
(
total
);
this
.
updateById
(
info
);
});
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
logger
.
info
(
"更新昨日数据成功"
);
}
public
Page
<
CylinderTableDto
>
selectTodayDatePage
(
String
pageNumber
,
String
pageSize
,
String
regionName
,
String
unitName
)
{
Page
<
CylinderTableDto
>
page
=
new
Page
<>();
List
<
CylinderTableDto
>
result
=
new
ArrayList
<>();
Page
<
CylinderUnit
>
cylinderUnitPage
=
new
Page
<>(
Long
.
parseLong
(
pageNumber
),
Long
.
parseLong
(
pageSize
));
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
if
(!
ObjectUtils
.
isEmpty
(
regionName
))
{
lambda
.
like
(
CylinderUnit:
:
getRegionCode
,
regionName
);
}
if
(!
ObjectUtils
.
isEmpty
(
unitName
))
{
lambda
.
like
(
CylinderUnit:
:
getUnitName
,
unitName
);
}
IPage
<
CylinderUnit
>
cylinderUnitIPage
=
cylinderUnitMapper
.
selectPage
(
cylinderUnitPage
,
lambda
);
for
(
CylinderUnit
unit
:
cylinderUnitIPage
.
getRecords
())
{
CylinderTableDto
temp
=
new
CylinderTableDto
();
temp
.
setUnitName
(
unit
.
getUnitName
());
// 获取气瓶基本信息
Integer
cylinderUnit
=
0
;
Integer
cylinder
=
0
;
Integer
tags
=
0
;
Integer
inspection
=
0
;
Integer
flling
=
0
;
Integer
fllingRecord
=
0
;
Integer
fllingCheck
=
0
;
Integer
examine
=
0
;
Integer
total
=
0
;
// 获取气瓶基本信息
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
eq
(
CylinderDateInfo:
:
getAppId
,
unit
.
getAppId
()));
for
(
CylinderDateInfo
info
:
list
)
{
cylinder
+=
info
.
getCylinderInfo
();
cylinderUnit
+=
info
.
getCylinderUnit
();
tags
+=
info
.
getCylinderTagInfo
();
inspection
+=
info
.
getCylinderInspectionInfo
();
flling
+=
info
.
getCylinderFillingInfo
();
fllingRecord
+=
info
.
getCylinderFillingRecordInfo
();
fllingCheck
+=
info
.
getCylinderFillingCheckInfo
();
examine
+=
info
.
getCylinderExamineInfo
();
total
+=
info
.
getCylinderTotal
();
}
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFllingCheckInfo
(
fllingCheck
);
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderFllingInfo
(
flling
);
temp
.
setCylinderFllingRecordInfo
(
fllingRecord
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderTotal
(
total
);
temp
.
setRegionName
(
unit
.
getRegionName
());
result
.
add
(
temp
);
}
page
.
setRecords
(
result
);
page
.
setTotal
(
cylinderUnitIPage
.
getTotal
());
return
page
;
}
@Scheduled
(
cron
=
"0 0 2 * * ?"
)
//每天凌晨两点执行
public
void
fixedDelayJob
()
{
// 每天更新或者添加昨天的数据
Date
date
=
new
Date
();
//取时间
Calendar
calendar
=
Calendar
.
getInstance
();
calendar
.
setTime
(
date
);
calendar
.
add
(
Calendar
.
DATE
,
-
1
);
//这个时间就是日期往后推一天的结果
date
=
calendar
.
getTime
();
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
lambda
);
for
(
CylinderUnit
token
:
cylinderUnits
)
{
try
{
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd"
);
String
todayStr
=
sdf
.
format
(
date
);
List
<
CylinderDateInfo
>
list
=
this
.
list
(
new
LambdaQueryWrapper
<
CylinderDateInfo
>().
between
(
CylinderDateInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
).
eq
(
CylinderDateInfo:
:
getAppId
,
token
.
getAppId
()));
if
(
ObjectUtils
.
isEmpty
(
list
))
{
CylinderDateInfoDto
temp
=
new
CylinderDateInfoDto
();
temp
.
setSyncDate
(
date
);
String
appid
=
token
.
getAppId
();
temp
.
setUnitName
(
token
.
getUnitName
());
temp
.
setAppId
(
appid
);
temp
.
setDeveloperAgency
(
token
.
getDeveloperAgency
());
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appid
).
between
(
CylinderInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appid
).
between
(
CylinderUnit:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appid
).
between
(
CylinderTags:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appid
).
between
(
CylinderInspection:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appid
).
between
(
CylinderFilling:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appid
).
between
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appid
).
between
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appid
).
between
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFillingCheckInfo
(
fillingCheck
);
temp
.
setCylinderFillingInfo
(
filling
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderFillingRecordInfo
(
fillingRecord
);
temp
.
setCylinderTotal
(
total
);
this
.
createWithModel
(
temp
);
}
else
{
list
.
forEach
(
info
->
{
String
appId
=
token
.
getAppId
();
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appId
).
between
(
CylinderInfo:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appId
).
between
(
CylinderUnit:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appId
).
between
(
CylinderTags:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appId
).
between
(
CylinderInspection:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appId
).
between
(
CylinderFilling:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appId
).
between
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appId
).
between
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appId
).
between
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
+
" 00:00:00"
,
todayStr
+
" 23:59:59"
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
info
.
setCylinderExamineInfo
(
examine
);
info
.
setCylinderUnit
(
cylinderUnit
);
info
.
setCylinderFillingCheckInfo
(
fillingCheck
);
info
.
setCylinderFillingInfo
(
filling
);
info
.
setCylinderInspectionInfo
(
inspection
);
info
.
setCylinderTagInfo
(
tags
);
info
.
setCylinderInfo
(
cylinder
);
info
.
setCylinderFillingRecordInfo
(
fillingRecord
);
info
.
setCylinderTotal
(
total
);
this
.
updateById
(
info
);
});
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
logger
.
info
(
"更新昨日数据成功"
);
}
public
void
initializeData
(){
// 每天更新或者添加昨天的数据
Date
date
=
new
Date
();
//取时间
Calendar
calendar
=
Calendar
.
getInstance
();
calendar
.
setTime
(
date
);
//这个时间就是日期往后推一天的结果
date
=
calendar
.
getTime
();
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
lambda
);
logger
.
info
(
"清除cylinder_date_info表已有数据"
);
this
.
baseMapper
.
delete
(
null
);
for
(
CylinderUnit
token
:
cylinderUnits
)
{
try
{
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd"
);
String
todayStr
=
sdf
.
format
(
date
);
CylinderDateInfoDto
temp
=
new
CylinderDateInfoDto
();
temp
.
setSyncDate
(
date
);
String
appid
=
token
.
getAppId
();
temp
.
setUnitName
(
token
.
getUnitName
());
temp
.
setAppId
(
appid
);
temp
.
setDeveloperAgency
(
token
.
getDeveloperAgency
());
logger
.
info
(
"初始化数据时间{}"
,
todayStr
);
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appid
).
notLike
(
CylinderInfo:
:
getSyncDate
,
todayStr
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appid
).
notLike
(
CylinderUnit:
:
getSyncDate
,
todayStr
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appid
).
notLike
(
CylinderTags:
:
getSyncDate
,
todayStr
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appid
).
notLike
(
CylinderInspection:
:
getSyncDate
,
todayStr
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appid
).
notLike
(
CylinderFilling:
:
getSyncDate
,
todayStr
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appid
).
notLike
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appid
).
notLike
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appid
).
notLike
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFillingCheckInfo
(
fillingCheck
);
temp
.
setCylinderFillingInfo
(
filling
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderFillingRecordInfo
(
fillingRecord
);
temp
.
setCylinderTotal
(
total
);
this
.
createWithModel
(
temp
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
logger
.
info
(
"更新昨日数据成功"
);
}
public
void
initializeData
()
{
// 每天更新或者添加昨天的数据
Date
date
=
new
Date
();
//取时间
Calendar
calendar
=
Calendar
.
getInstance
();
calendar
.
setTime
(
date
);
//这个时间就是日期往后推一天的结果
date
=
calendar
.
getTime
();
LambdaQueryWrapper
<
CylinderUnit
>
lambda
=
new
QueryWrapper
<
CylinderUnit
>().
lambda
();
List
<
CylinderUnit
>
cylinderUnits
=
cylinderUnitMapper
.
selectList
(
lambda
);
logger
.
info
(
"清除cylinder_date_info表已有数据"
);
this
.
baseMapper
.
delete
(
null
);
for
(
CylinderUnit
token
:
cylinderUnits
)
{
try
{
SimpleDateFormat
sdf
=
new
SimpleDateFormat
(
"yyyy-MM-dd"
);
String
todayStr
=
sdf
.
format
(
date
);
CylinderDateInfoDto
temp
=
new
CylinderDateInfoDto
();
temp
.
setSyncDate
(
date
);
String
appid
=
token
.
getAppId
();
temp
.
setUnitName
(
token
.
getUnitName
());
temp
.
setAppId
(
appid
);
temp
.
setDeveloperAgency
(
token
.
getDeveloperAgency
());
logger
.
info
(
"初始化数据时间{}"
,
todayStr
);
// 获取气瓶基本信息
Integer
cylinder
=
cylinderInfoService
.
count
(
new
LambdaQueryWrapper
<
CylinderInfo
>().
eq
(
CylinderInfo:
:
getAppId
,
appid
).
notLike
(
CylinderInfo:
:
getSyncDate
,
todayStr
));
Integer
cylinderUnit
=
cylinderUnitService
.
count
(
new
LambdaQueryWrapper
<
CylinderUnit
>().
eq
(
CylinderUnit:
:
getAppId
,
appid
).
notLike
(
CylinderUnit:
:
getSyncDate
,
todayStr
));
Integer
tags
=
cylinderTagsService
.
count
(
new
LambdaQueryWrapper
<
CylinderTags
>().
eq
(
CylinderTags:
:
getAppId
,
appid
).
notLike
(
CylinderTags:
:
getSyncDate
,
todayStr
));
Integer
inspection
=
cylinderInspectionService
.
count
(
new
LambdaQueryWrapper
<
CylinderInspection
>().
eq
(
CylinderInspection:
:
getAppId
,
appid
).
notLike
(
CylinderInspection:
:
getSyncDate
,
todayStr
));
Integer
filling
=
cylinderFillingService
.
count
(
new
LambdaQueryWrapper
<
CylinderFilling
>().
eq
(
CylinderFilling:
:
getAppId
,
appid
).
notLike
(
CylinderFilling:
:
getSyncDate
,
todayStr
));
Integer
fillingRecord
=
cylinderFillingRecordService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingRecord
>().
eq
(
CylinderFillingRecord:
:
getAppId
,
appid
).
notLike
(
CylinderFillingRecord:
:
getSyncDate
,
todayStr
));
Integer
fillingCheck
=
cylinderFillingCheckService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingCheck
>().
eq
(
CylinderFillingCheck:
:
getAppId
,
appid
).
notLike
(
CylinderFillingCheck:
:
getSyncDate
,
todayStr
));
Integer
examine
=
cylinderFillingExamineService
.
count
(
new
LambdaQueryWrapper
<
CylinderFillingExamine
>().
eq
(
CylinderFillingExamine:
:
getAppId
,
appid
).
notLike
(
CylinderFillingExamine:
:
getSyncDate
,
todayStr
));
Integer
total
=
cylinder
+
cylinderUnit
+
tags
+
inspection
+
filling
+
fillingRecord
+
fillingCheck
+
examine
;
temp
.
setCylinderExamineInfo
(
examine
);
temp
.
setCylinderUnit
(
cylinderUnit
);
temp
.
setCylinderFillingCheckInfo
(
fillingCheck
);
temp
.
setCylinderFillingInfo
(
filling
);
temp
.
setCylinderInspectionInfo
(
inspection
);
temp
.
setCylinderTagInfo
(
tags
);
temp
.
setCylinderInfo
(
cylinder
);
temp
.
setCylinderFillingRecordInfo
(
fillingRecord
);
temp
.
setCylinderTotal
(
total
);
this
.
createWithModel
(
temp
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
logger
.
info
(
"更新昨日数据成功"
);
}
}
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