记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
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
董敬伟
liquidnet-bus-v1
Commits
af3e1ec1
Commit
af3e1ec1
authored
Aug 11, 2025
by
姜秀龙
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/master' into container-prod
parents
3eea414f
b3ea589a
Changes
15
Show whitespace changes
Inline
Side-by-side
Showing
15 changed files
with
508 additions
and
54 deletions
+508
-54
KylinPerformancesController.java
...ontroller/zhengzai/kylin/KylinPerformancesController.java
+55
-15
performancesStatic.html
...lates/zhengzai/kylin/performances/performancesStatic.html
+37
-28
OpenDataBaseResponse.java
...client/admin/zhengzai/kylin/dto/OpenDataBaseResponse.java
+18
-0
OpenDataSalesResponse.java
...lient/admin/zhengzai/kylin/dto/OpenDataSalesResponse.java
+12
-0
OpenDataTicketSalesResponse.java
...admin/zhengzai/kylin/dto/OpenDataTicketSalesResponse.java
+12
-0
PerformanceSalesDto.java
.../client/admin/zhengzai/kylin/dto/PerformanceSalesDto.java
+34
-0
PerformanceTicketSalesDto.java
...t/admin/zhengzai/kylin/dto/PerformanceTicketSalesDto.java
+101
-0
IOpenDataService.java
...client/admin/zhengzai/kylin/service/IOpenDataService.java
+27
-0
KylinPerformancesAdminServiceImpl.java
...kylin/service/impl/KylinPerformancesAdminServiceImpl.java
+30
-3
OpenDataServiceImpl.java
...dmin/zhengzai/kylin/service/impl/OpenDataServiceImpl.java
+76
-0
liquidnet-client-admin-web-dev.yml
...onfig/liquidnet-config/liquidnet-client-admin-web-dev.yml
+3
-0
liquidnet-client-admin-web-test.yml
...nfig/liquidnet-config/liquidnet-client-admin-web-test.yml
+3
-0
PerformanceOrderStatisticalDao.java
...net/service/kylin/dao/PerformanceOrderStatisticalDao.java
+30
-8
KylinPerformancesMapper.java
...quidnet/service/kylin/mapper/KylinPerformancesMapper.java
+2
-0
KylinPerformancesMapper.xml
...iquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
+68
-0
No files found.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/KylinPerformancesController.java
View file @
af3e1ec1
...
@@ -10,6 +10,8 @@ import com.liquidnet.client.admin.common.enums.BusinessType;
...
@@ -10,6 +10,8 @@ import com.liquidnet.client.admin.common.enums.BusinessType;
import
com.liquidnet.client.admin.common.utils.poi.ExcelUtil
;
import
com.liquidnet.client.admin.common.utils.poi.ExcelUtil
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.KylinPerformanceSubscribeTicketStatisticalExportDao
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.KylinPerformanceSubscribeTicketStatisticalExportDao
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceOrderStatisCountResp
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceOrderStatisCountResp
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceTicketSalesDto
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.IOpenDataService
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dao.PerformanceAdminListDao
;
import
com.liquidnet.service.kylin.dao.PerformanceAdminListDao
;
...
@@ -52,6 +54,8 @@ public class KylinPerformancesController extends BaseController {
...
@@ -52,6 +54,8 @@ public class KylinPerformancesController extends BaseController {
@Autowired
@Autowired
private
DamaiService
damaiService
;
private
DamaiService
damaiService
;
@Autowired
private
IOpenDataService
openDataService
;
//@RequiresPermissions("kylin:performances:view")
//@RequiresPermissions("kylin:performances:view")
@GetMapping
()
@GetMapping
()
...
@@ -145,12 +149,47 @@ public class KylinPerformancesController extends BaseController {
...
@@ -145,12 +149,47 @@ public class KylinPerformancesController extends BaseController {
//@RequiresPermissions("kylin:performances:view")
//@RequiresPermissions("kylin:performances:view")
@GetMapping
(
value
=
"/performanceStatic/{performancesId}"
)
@GetMapping
(
value
=
"/performanceStatic/{performancesId}"
)
public
String
performanceStatic
(
@PathVariable
(
"performancesId"
)
String
performancesId
,
ModelMap
mmap
)
{
public
String
performanceStatic
(
@PathVariable
(
"performancesId"
)
String
performancesId
,
ModelMap
mmap
)
{
PerformanceOrderStatisCountResp
perCountResp
=
new
PerformanceOrderStatisCountResp
();
List
<
PerformanceOrderStatisticalDao
>
result
=
new
ArrayList
<>();
PerformanceTicketSalesDto
ticketSalesInfo
=
openDataService
.
getPerformanceTicketSalesInfo
(
performancesId
);
if
(
ticketSalesInfo
!=
null
)
{
perCountResp
.
setPerformanceTitle
(
ticketSalesInfo
.
getPerformanceTitle
());
perCountResp
.
setTotalSalePrice
(
new
BigDecimal
(
ticketSalesInfo
.
getFullSalesAmountTotal
()));
perCountResp
.
setSaleGeneral
(
new
BigDecimal
(
ticketSalesInfo
.
getFullAudienceTicketTotal
()));
perCountResp
.
setTotalGeneral
(
new
BigDecimal
(
ticketSalesInfo
.
getFullTotalGeneral
()));
perCountResp
.
setTotalRefundGeneral
(
new
BigDecimal
(
ticketSalesInfo
.
getFullRefundTicketTotal
()));
perCountResp
.
setTotalBuyUsers
(
new
BigDecimal
(
ticketSalesInfo
.
getFullBuyTotal
()));
List
<
PerformanceTicketSalesDto
.
TicketSales
>
fullTicketDataList
=
ticketSalesInfo
.
getFullTicketDataList
();
if
(!
fullTicketDataList
.
isEmpty
())
{
for
(
PerformanceTicketSalesDto
.
TicketSales
ticketSales
:
fullTicketDataList
)
{
PerformanceOrderStatisticalDao
statisticalDao
=
new
PerformanceOrderStatisticalDao
();
statisticalDao
.
setPerformancesId
(
ticketSalesInfo
.
getPerformanceId
());
statisticalDao
.
setTicketsId
(
ticketSales
.
getTicketId
());
statisticalDao
.
setTitle
(
ticketSales
.
getTicketTitle
());
statisticalDao
.
setPrice
(
new
BigDecimal
(
ticketSales
.
getTicketPrice
()));
statisticalDao
.
setType
(
ticketSales
.
getTicketType
());
statisticalDao
.
setTotalGeneral
(
new
BigDecimal
(
ticketSales
.
getTotalGeneral
()));
statisticalDao
.
setSaleGeneral
(
new
BigDecimal
(
ticketSales
.
getAudienceTicketTotal
()));
statisticalDao
.
setTotalRefundGeneral
(
new
BigDecimal
(
ticketSales
.
getRefundTicketTotal
()));
statisticalDao
.
setTotalPayingNumber
(
new
BigDecimal
(
ticketSales
.
getPayingTotal
()));
statisticalDao
.
setTimeId
(
ticketSales
.
getTimeId
());
statisticalDao
.
setTimeTitle
(
ticketSales
.
getTimeTitle
());
statisticalDao
.
setVipBuyTotal
(
ticketSales
.
getVipBuyTotal
());
statisticalDao
.
setFullRefundTicketTotal
(
ticketSales
.
getFullRefundTicketTotal
());
statisticalDao
.
setHandlingFeeRefundTicketTotal
(
ticketSales
.
getHandlingFeeRefundTicketTotal
());
statisticalDao
.
setRefundFeeRevenueTotal
(
new
BigDecimal
(
ticketSales
.
getRefundFeeRevenueTotal
()));
statisticalDao
.
setAudienceSalesAmountTotal
(
new
BigDecimal
(
ticketSales
.
getAudienceSalesAmountTotal
()));
result
.
add
(
statisticalDao
);
}
}
}
else
{
//获取演出详情
//获取演出详情
KylinPerformanceMisVo
performanceMisVo
=
kylinPerformancesService
.
performanceDetails
(
performancesId
);
KylinPerformanceMisVo
performanceMisVo
=
kylinPerformancesService
.
performanceDetails
(
performancesId
);
List
<
PerformanceOrderStatisticalDao
>
result
=
kylinPerformancesService
.
getPerformanceOrderStatisticalList
(
performancesId
);
result
=
kylinPerformancesService
.
getPerformanceOrderStatisticalList
(
performancesId
);
//构造top统计数据
PerformanceOrderStatisCountResp
perCountResp
=
new
PerformanceOrderStatisCountResp
();
perCountResp
.
setPerformanceTitle
(
performanceMisVo
.
getTitle
());
perCountResp
.
setPerformanceTitle
(
performanceMisVo
.
getTitle
());
if
(
result
.
size
()
>=
2
)
{
if
(
result
.
size
()
>=
2
)
{
PerformanceOrderStatisticalDao
resdao
=
result
.
get
(
result
.
size
()
-
1
);
PerformanceOrderStatisticalDao
resdao
=
result
.
get
(
result
.
size
()
-
1
);
...
@@ -163,6 +202,7 @@ public class KylinPerformancesController extends BaseController {
...
@@ -163,6 +202,7 @@ public class KylinPerformancesController extends BaseController {
perCountResp
.
setTotalDisPrice
(
BigDecimal
.
ONE
);
perCountResp
.
setTotalDisPrice
(
BigDecimal
.
ONE
);
perCountResp
.
setTotalRefundGeneral
(
resdao
.
getTotalRefundGeneral
());
perCountResp
.
setTotalRefundGeneral
(
resdao
.
getTotalRefundGeneral
());
}
}
}
mmap
.
put
(
"perCountResp"
,
perCountResp
);
mmap
.
put
(
"perCountResp"
,
perCountResp
);
mmap
.
put
(
"perOrderStaticList"
,
result
);
mmap
.
put
(
"perOrderStaticList"
,
result
);
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/performances/performancesStatic.html
View file @
af3e1ec1
...
@@ -53,12 +53,12 @@
...
@@ -53,12 +53,12 @@
<div
th:text=
"*{totalBuyUsers}"
>
39
</div>
<div
th:text=
"*{totalBuyUsers}"
>
39
</div>
</div>
</div>
</div>
</div>
<div
class=
"col-lg-1"
>
<!-- <div class="col-lg-1">--
>
<div
>
<!-- <div>--
>
<div>
小家伙分销(元)
</div
>
<!-- <div>小家伙分销(元)</div>--
>
<div
th:text=
"*{totalDisPrice}"
>
0
</div
>
<!-- <div th:text="*{totalDisPrice}">0</div>--
>
</div
>
<!-- </div>--
>
</div
>
<!-- </div>--
>
<div
class=
"col-lg-1"
>
<div
class=
"col-lg-1"
>
<div>
<div>
<div>
退票数量(张)
</div>
<div>
退票数量(张)
</div>
...
@@ -71,65 +71,68 @@
...
@@ -71,65 +71,68 @@
<thead>
<thead>
<tr>
<tr>
<th>
<th>
<div
class=
"cell"
>
票种名
</div>
<div
class=
"cell"
>
场次
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
单价
</div>
<div
class=
"cell"
>
票种类型
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
类型
</div>
<div
class=
"cell"
>
票种名称
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
适用时间
</div>
<div
class=
"cell"
>
票种价格
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
销售总
数量
</div>
<div
class=
"cell"
>
库存
数量
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
会员
销售数量
</div>
<div
class=
"cell"
>
销售数量
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
库存
数量
</div>
<div
class=
"cell"
>
登登登VIP购票
数量
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
正在支付数量
</div>
<div
class=
"cell"
>
正在支付数量
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
退票数量
</div>
<div
class=
"cell"
>
退票总数量
</div>
</th>
<th>
<div
class=
"cell"
>
全额退票数量
</div>
</th>
<th>
<div
class=
"cell"
>
手续费退票数量
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
羊毛券数量
</div>
<div
class=
"cell"
>
退票手续费收益
</div>
</th>
</th>
<th>
<th>
<div
class=
"cell"
>
销售额(元)
</div>
<div
class=
"cell"
>
票面销售金额
</div>
</th>
</th>
<!-- <th>-->
<!-- <div class="cell">兑换数量</div>-->
<!-- </th>-->
</tr>
</tr>
</thead>
</thead>
<tbody>
<tbody>
<tr
th:each=
"respBean,respBeanStat:${perOrderStaticList}"
>
<tr
th:each=
"respBean,respBeanStat:${perOrderStaticList}"
>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.title}"
>
180元区
</div>
<div
class=
"cell"
th:text=
"${respBean.ti
meTi
tle}"
>
180元区
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${
respBean.price}"
>
180.0
0
</div>
<div
class=
"cell"
th:text=
"${
@dict.getLabel('zhengzai_ticket_type',respBean.type)}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${
@dict.getLabel('zhengzai_ticket_type',respBean.type)
}"
>
0
</div>
<div
class=
"cell"
th:text=
"${
respBean.title
}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
>
[[${respBean.useStart}]] - [[${respBean.useEnd}]]
</div>
<div
class=
"cell"
th:text=
"${respBean.price}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.
sale
General}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.
total
General}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.
totalMemberNumber
}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.
saleGeneral
}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.
surplusGener
al}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.
vipBuyTot
al}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.totalPayingNumber}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.totalPayingNumber}"
>
0
</div>
...
@@ -138,10 +141,16 @@
...
@@ -138,10 +141,16 @@
<div
class=
"cell"
th:text=
"${respBean.totalRefundGeneral}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.totalRefundGeneral}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.totalVoucherCount}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.fullRefundTicketTotal}"
>
0
</div>
</td>
<td>
<div
class=
"cell"
th:text=
"${respBean.handlingFeeRefundTicketTotal}"
>
0
</div>
</td>
<td>
<div
class=
"cell"
th:text=
"${respBean.refundFeeRevenueTotal}"
>
0
</div>
</td>
</td>
<td>
<td>
<div
class=
"cell"
th:text=
"${respBean.
totalSalePrice
}"
>
0
</div>
<div
class=
"cell"
th:text=
"${respBean.
audienceSalesAmountTotal
}"
>
0
</div>
</td>
</td>
<!-- <td>-->
<!-- <td>-->
<!-- <div class="cell" th:text="${respBean.totalExchange}">0</div>-->
<!-- <div class="cell" th:text="${respBean.totalExchange}">0</div>-->
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/dto/OpenDataBaseResponse.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
dto
;
import
lombok.Data
;
@Data
public
class
OpenDataBaseResponse
<
T
>
{
private
Integer
code
;
private
String
msg
;
private
T
data
;
public
boolean
isSucc
(){
return
this
.
code
!=
null
&&
this
.
code
==
0
;
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/dto/OpenDataSalesResponse.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
dto
;
import
lombok.Data
;
import
lombok.EqualsAndHashCode
;
import
java.util.List
;
@EqualsAndHashCode
(
callSuper
=
true
)
@Data
public
class
OpenDataSalesResponse
extends
OpenDataBaseResponse
<
List
<
PerformanceSalesDto
>>{
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/dto/OpenDataTicketSalesResponse.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
dto
;
import
lombok.Data
;
import
lombok.EqualsAndHashCode
;
import
java.util.List
;
@EqualsAndHashCode
(
callSuper
=
true
)
@Data
public
class
OpenDataTicketSalesResponse
extends
OpenDataBaseResponse
<
PerformanceTicketSalesDto
>{
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/dto/PerformanceSalesDto.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
dto
;
import
lombok.Data
;
@Data
public
class
PerformanceSalesDto
{
/**
* 演出ID
*/
private
String
performanceId
;
/**
* 总库存
*/
private
Integer
totalGeneral
;
/**
* 观众购票数
*/
private
Integer
audienceTicketTotal
;
/**
* 剩余库存
*/
private
Integer
surplusGeneral
;
/**
* 总销售额
*/
private
String
salesAmountTotal
;
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/dto/PerformanceTicketSalesDto.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
dto
;
import
lombok.Data
;
import
java.util.List
;
@Data
public
class
PerformanceTicketSalesDto
{
/**
* 演出ID
*/
private
String
performanceId
;
/**
* 演出名称
*/
private
String
performanceTitle
;
/**
* 总销售票款(元)
*/
private
String
fullSalesAmountTotal
;
/**
* 观众购票数
*/
private
String
fullAudienceTicketTotal
;
/**
* 总库存
*/
private
String
fullTotalGeneral
;
/**
* 退票数量(张)
*/
private
String
fullRefundTicketTotal
;
/**
* 购买人数
*/
private
String
fullBuyTotal
;
/**
* 票种销售数据
*/
private
List
<
TicketSales
>
fullTicketDataList
;
@Data
public
static
class
TicketSales
{
// 票ID
private
String
ticketId
;
// 场次ID
private
String
timeId
;
// 场次名称
private
String
timeTitle
;
// 票种名称
private
String
ticketTitle
;
// 票种金额
private
String
ticketPrice
;
// 销售总金额
private
String
salesAmountTotal
;
// 退票手续费总收益
private
String
refundFeeRevenueTotal
;
// 观众购票总数[销售总票量-兑换码票总数] 销售数量
private
String
audienceTicketTotal
;
// 观众购票销售总金额[票种金额* 观众购票总数] 票面销售金额
private
String
audienceSalesAmountTotal
;
// 全额退票总数
private
Integer
fullRefundTicketTotal
;
// 手续费退票总数
private
Integer
handlingFeeRefundTicketTotal
;
// 退票总数量
private
String
refundTicketTotal
;
// 票种类型 1:单日票 2:通票
private
Integer
ticketType
;
// 库存数量
private
String
totalGeneral
;
// 登登登VIP购买数量
private
Integer
vipBuyTotal
;
// 正在支付数量
private
String
payingTotal
;
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/IOpenDataService.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
service
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceSalesDto
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceTicketSalesDto
;
import
java.util.List
;
/**
* 数据查询服务
*/
public
interface
IOpenDataService
{
/**
* 获取演出销售数据
* @param performanceIdList
* @return
*/
List
<
PerformanceSalesDto
>
getPerformanceSalesInfo
(
List
<
String
>
performanceIdList
);
/**
* 获取演出票销售数据
* @param performanceId
* @return
*/
PerformanceTicketSalesDto
getPerformanceTicketSalesInfo
(
String
performanceId
);
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java
View file @
af3e1ec1
...
@@ -7,14 +7,14 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
...
@@ -7,14 +7,14 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.github.pagehelper.PageHelper
;
import
com.github.pagehelper.PageHelper
;
import
com.github.pagehelper.PageInfo
;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.client.admin.common.utils.StringUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceSalesDto
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.IOpenDataService
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.InnerService
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.InnerService
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.PerformanceVoUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.PerformanceVoUtils
;
import
com.liquidnet.client.admin.zhengzai.slime.service.ISlimeAuthorizationRecordsAdminService
;
import
com.liquidnet.client.admin.zhengzai.slime.service.ISlimeAuthorizationRecordsAdminService
;
import
com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils
;
import
com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils
;
import
com.liquidnet.commons.lang.util.BeanUtil
;
import
com.liquidnet.commons.lang.util.BeanUtil
;
import
com.liquidnet.commons.lang.util.CollectionUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.service.goblin.dto.vo.SmileAgentVo
;
import
com.liquidnet.service.goblin.dto.vo.SmileAgentVo
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
...
@@ -104,6 +104,10 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
...
@@ -104,6 +104,10 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
@Autowired
@Autowired
KylinPerformancesMapper
kylinPerformancesMapper
;
KylinPerformancesMapper
kylinPerformancesMapper
;
@Autowired
private
IOpenDataService
openDataService
;
@Override
@Override
public
void
test
()
{
public
void
test
()
{
// //同步演出
// //同步演出
...
@@ -293,8 +297,31 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
...
@@ -293,8 +297,31 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
List
<
PerformanceAdminListDao
>
newList
=
new
ArrayList
();
List
<
PerformanceAdminListDao
>
newList
=
new
ArrayList
();
try
{
try
{
Map
<
String
,
Object
>
map
=
BeanUtil
.
convertBeanToMap
(
performanceAdminListParam
);
Map
<
String
,
Object
>
map
=
BeanUtil
.
convertBeanToMap
(
performanceAdminListParam
);
List
<
PerformanceAdminListDao
>
voList
=
performancesMapper
.
misPerformanceList
(
map
);
List
<
PerformanceAdminListDao
>
voList
=
performancesMapper
.
misPerformanceListV2
(
map
);
List
<
String
>
performanceIdList
=
voList
.
stream
().
map
(
PerformanceAdminListDao:
:
getPerformancesId
)
.
collect
(
Collectors
.
toList
());
Map
<
String
,
PerformanceSalesDto
>
salesDtoMap
=
new
HashMap
<>();
if
(!
performanceIdList
.
isEmpty
())
{
// 获取演出销售数据
List
<
PerformanceSalesDto
>
performanceSalesInfoList
=
openDataService
.
getPerformanceSalesInfo
(
performanceIdList
);
if
(!
performanceSalesInfoList
.
isEmpty
())
{
salesDtoMap
=
performanceSalesInfoList
.
stream
()
.
collect
(
Collectors
.
toMap
(
PerformanceSalesDto:
:
getPerformanceId
,
performanceSalesDto
->
performanceSalesDto
));
}
}
for
(
PerformanceAdminListDao
item
:
voList
)
{
for
(
PerformanceAdminListDao
item
:
voList
)
{
// 修改售卖数据
PerformanceSalesDto
performanceSalesDto
=
salesDtoMap
.
get
(
item
.
getPerformancesId
());
if
(
performanceSalesDto
!=
null
)
{
item
.
setTotalGeneral
(
performanceSalesDto
.
getTotalGeneral
());
item
.
setTotalSalePrice
(
new
BigDecimal
(
performanceSalesDto
.
getSalesAmountTotal
()));
item
.
setSaleGeneral
(
performanceSalesDto
.
getAudienceTicketTotal
());
item
.
setSurplusGeneral
(
performanceSalesDto
.
getSurplusGeneral
());
}
if
(
item
.
getTimeSell
()
==
null
||
item
.
getTimeStop
()
==
null
)
{
if
(
item
.
getTimeSell
()
==
null
||
item
.
getTimeStop
()
==
null
)
{
continue
;
continue
;
}
}
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/OpenDataServiceImpl.java
0 → 100644
View file @
af3e1ec1
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
service
.
impl
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.OpenDataSalesResponse
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.OpenDataTicketSalesResponse
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceSalesDto
;
import
com.liquidnet.client.admin.zhengzai.kylin.dto.PerformanceTicketSalesDto
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.IOpenDataService
;
import
com.liquidnet.commons.lang.util.HttpUtil
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.commons.lang.util.StringUtil
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.http.HttpHeaders
;
import
org.springframework.stereotype.Service
;
import
java.util.Collections
;
import
java.util.HashMap
;
import
java.util.List
;
@Slf4j
@Service
public
class
OpenDataServiceImpl
implements
IOpenDataService
{
@Value
(
"${liquidnet.openData.host}"
)
private
String
openDataHost
;
@Value
(
"${liquidnet.openData.auth}"
)
private
String
openDataAuth
;
@Override
public
List
<
PerformanceSalesDto
>
getPerformanceSalesInfo
(
List
<
String
>
performanceIdList
)
{
HashMap
<
String
,
List
<
String
>>
map
=
new
HashMap
<>();
map
.
put
(
"performanceIds"
,
performanceIdList
);
HttpHeaders
headers
=
new
HttpHeaders
();
headers
.
set
(
HttpHeaders
.
AUTHORIZATION
,
openDataAuth
);
try
{
String
postJson
=
HttpUtil
.
postJson
(
openDataHost
+
"/api/performance/sales"
,
JsonUtils
.
toJson
(
map
),
headers
);
log
.
info
(
"response: {}"
,
postJson
);
if
(
StringUtil
.
isBlank
(
postJson
))
{
return
Collections
.
emptyList
();
}
OpenDataSalesResponse
openDataSalesResponse
=
JsonUtils
.
fromJson
(
postJson
,
OpenDataSalesResponse
.
class
);
if
(!
openDataSalesResponse
.
isSucc
())
{
return
Collections
.
emptyList
();
}
return
openDataSalesResponse
.
getData
();
}
catch
(
Exception
e
)
{
log
.
error
(
"error"
,
e
);
}
return
Collections
.
emptyList
();
}
@Override
public
PerformanceTicketSalesDto
getPerformanceTicketSalesInfo
(
String
performanceId
)
{
HttpHeaders
headers
=
new
HttpHeaders
();
headers
.
set
(
HttpHeaders
.
AUTHORIZATION
,
openDataAuth
);
try
{
String
responseStr
=
HttpUtil
.
getByUri
(
openDataHost
+
"/api/performance/ticket/sales?performanceId="
+
performanceId
,
headers
);
log
.
info
(
"response: {}"
,
responseStr
);
if
(
StringUtil
.
isBlank
(
responseStr
))
{
return
null
;
}
OpenDataTicketSalesResponse
openDataSalesResponse
=
JsonUtils
.
fromJson
(
responseStr
,
OpenDataTicketSalesResponse
.
class
);
if
(!
openDataSalesResponse
.
isSucc
())
{
return
null
;
}
return
openDataSalesResponse
.
getData
();
}
catch
(
Exception
e
)
{
log
.
error
(
"error"
,
e
);
}
return
null
;
}
}
liquidnet-bus-config/liquidnet-config/liquidnet-client-admin-web-dev.yml
View file @
af3e1ec1
...
@@ -22,5 +22,8 @@ liquidnet:
...
@@ -22,5 +22,8 @@ liquidnet:
mongodb
:
mongodb
:
sslEnabled
:
false
sslEnabled
:
false
database
:
dev_ln_scene
database
:
dev_ln_scene
openData
:
host
:
http://localhost:8091
auth
:
t-gI1wT4kM4qF2bB4mJ4zQ1gM6cU6dC9uB
# end-dev-这里是配置信息基本值
# end-dev-这里是配置信息基本值
\ No newline at end of file
liquidnet-bus-config/liquidnet-config/liquidnet-client-admin-web-test.yml
View file @
af3e1ec1
...
@@ -22,5 +22,8 @@ liquidnet:
...
@@ -22,5 +22,8 @@ liquidnet:
mongodb
:
mongodb
:
sslEnabled
:
false
sslEnabled
:
false
database
:
test_ln_scene
database
:
test_ln_scene
openData
:
host
:
https://testopen.zhengzai.tv
auth
:
t-gI1wT4kM4qF2bB4mJ4zQ1gM6cU6dC9uB
# end-test-这里是配置信息基本值
# end-test-这里是配置信息基本值
\ No newline at end of file
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/PerformanceOrderStatisticalDao.java
View file @
af3e1ec1
...
@@ -3,7 +3,6 @@ package com.liquidnet.service.kylin.dao;
...
@@ -3,7 +3,6 @@ package com.liquidnet.service.kylin.dao;
import
lombok.Data
;
import
lombok.Data
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.time.LocalDateTime
;
/**
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @author AnJiabin <anjiabin@zhengzai.tv>
...
@@ -18,23 +17,46 @@ import java.time.LocalDateTime;
...
@@ -18,23 +17,46 @@ import java.time.LocalDateTime;
public
class
PerformanceOrderStatisticalDao
implements
Cloneable
{
public
class
PerformanceOrderStatisticalDao
implements
Cloneable
{
private
String
performancesId
;
private
String
performancesId
;
private
String
ticketsId
;
private
String
ticketsId
;
private
String
title
;
private
String
title
;
// 票种名称
private
BigDecimal
price
;
private
BigDecimal
price
;
// 票种价格
private
Integer
type
;
private
Integer
type
;
// 票种类型
private
String
useStart
;
private
String
useStart
;
private
String
useEnd
;
private
String
useEnd
;
private
BigDecimal
totalGeneral
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalGeneral
=
BigDecimal
.
ZERO
;
// 库存数量
private
BigDecimal
saleGeneral
=
BigDecimal
.
ZERO
;
private
BigDecimal
saleGeneral
=
BigDecimal
.
ZERO
;
// 销售数量
private
BigDecimal
surplusGeneral
=
BigDecimal
.
ZERO
;
private
BigDecimal
surplusGeneral
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalSalePrice
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalSalePrice
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalExchange
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalExchange
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalRefundGeneral
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalRefundGeneral
=
BigDecimal
.
ZERO
;
// 退票总数量
private
BigDecimal
totalRefundPrice
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalRefundPrice
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalMemberNumber
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalMemberNumber
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalPayingNumber
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalPayingNumber
=
BigDecimal
.
ZERO
;
// 正在支付数量
private
BigDecimal
totalBuyUsers
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalBuyUsers
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalVoucherCount
=
BigDecimal
.
ZERO
;
private
BigDecimal
totalVoucherCount
=
BigDecimal
.
ZERO
;
// 场次ID
private
String
timeId
;
// 场次名称
private
String
timeTitle
;
// vip购票数量
private
Integer
vipBuyTotal
=
0
;
// 全额退票总数
private
Integer
fullRefundTicketTotal
=
0
;
// 手续费退票总数
private
Integer
handlingFeeRefundTicketTotal
=
0
;
// 退票手续费总收益
private
BigDecimal
refundFeeRevenueTotal
=
BigDecimal
.
ZERO
;
// 票面销售金额
private
BigDecimal
audienceSalesAmountTotal
=
BigDecimal
.
ZERO
;
private
static
final
PerformanceOrderStatisticalDao
obj
=
new
PerformanceOrderStatisticalDao
();
private
static
final
PerformanceOrderStatisticalDao
obj
=
new
PerformanceOrderStatisticalDao
();
public
static
PerformanceOrderStatisticalDao
getNew
()
{
public
static
PerformanceOrderStatisticalDao
getNew
()
{
try
{
try
{
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformancesMapper.java
View file @
af3e1ec1
...
@@ -28,6 +28,8 @@ public interface KylinPerformancesMapper extends BaseMapper<KylinPerformances> {
...
@@ -28,6 +28,8 @@ public interface KylinPerformancesMapper extends BaseMapper<KylinPerformances> {
//列表
//列表
List
<
PerformanceAdminListDao
>
misPerformanceList
(
Map
<
String
,
Object
>
map
);
List
<
PerformanceAdminListDao
>
misPerformanceList
(
Map
<
String
,
Object
>
map
);
List
<
PerformanceAdminListDao
>
misPerformanceListV2
(
Map
<
String
,
Object
>
map
);
//根据巡演查询 通过审核演出列表
//根据巡演查询 通过审核演出列表
List
<
PerformanceTitleDao
>
misTitleByRoadShowIdList
(
String
roadShowId
);
List
<
PerformanceTitleDao
>
misTitleByRoadShowIdList
(
String
roadShowId
);
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
View file @
af3e1ec1
...
@@ -376,6 +376,74 @@
...
@@ -376,6 +376,74 @@
ORDER BY ${orderItem} ${orderSc}
ORDER BY ${orderItem} ${orderSc}
</if>
</if>
</select>
</select>
<select
id=
"misPerformanceListV2"
parameterType=
"java.util.Map"
resultMap=
"misPerformanceListResult"
>
SELECT
p.performances_id ,
p.sponsor,
p.audit_time,
p.sort,
p.title ,
p.type,
p.time_start ,
p.time_end ,
ps.sync_damai ,
t.time_sell,
t.time_stop,
ps.`status` ,
ps.audit_status ,
ps.field_audit_status,
p.reject_txt ,
p.created_at
FROM
kylin_performances AS p
LEFT JOIN kylin_performance_status AS ps ON p.performances_id = ps.performance_id
LEFT JOIN(
SELECT
ttr.performance_id ,
MIN(
DATE_SUB(
t.time_start ,
INTERVAL pay_countdown_minute MINUTE
)
) AS 'time_sell' ,
MAX(t.time_end) AS 'time_stop'
FROM
kylin_ticket_status AS ts
LEFT JOIN kylin_ticket_relations AS tr ON tr.ticket_id = ts.ticket_id
LEFT JOIN kylin_tickets AS t ON t.tickets_id = ts.ticket_id
LEFT JOIN kylin_ticket_time_relation AS ttr ON tr.times_id = ttr.times_id
GROUP BY
ttr.performance_id
) AS t ON p.performances_id = t.performance_id
<where>
<if
test=
"title!=''"
>
AND title LIKE concat('%', #{title}, '%')
</if>
<if
test=
"cityName!=''"
>
AND city_name LIKE concat('%', #{cityName}, '%')
</if>
<if
test=
"status!='-2'"
>
AND ps.STATUS = #{status}
</if>
<if
test=
"status=='-2'"
>
AND (ps.STATUS >= 3 or ps.STATUS = 1)
</if>
<if
test=
"auditStatus!='-2'"
>
AND ps.audit_status = #{auditStatus}
</if>
<!-- <if test="auditStatus=='-2'">-->
<!-- AND (ps.audit_status = 0 or ps.audit_status = 1 or ps.audit_status = 2)-->
<!-- </if>-->
<if
test=
"stopSellDay!=-2"
>
AND p.time_end BETWEEN #{stopSellTime} AND NOW()
</if>
</where>
<if
test=
"orderItem!=''"
>
ORDER BY ${orderItem} ${orderSc}
</if>
</select>
<!-- Mis 根据巡演查询演出列表 -->
<!-- Mis 根据巡演查询演出列表 -->
<select
id=
"misTitleByRoadShowIdList"
parameterType=
"java.lang.String"
resultMap=
"performanceTitleDaoResult"
>
<select
id=
"misTitleByRoadShowIdList"
parameterType=
"java.lang.String"
resultMap=
"performanceTitleDaoResult"
>
SELECT performances_id,
SELECT performances_id,
...
...
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