记得上下班打卡 | 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
ca458ce2
Commit
ca458ce2
authored
Mar 22, 2022
by
GaoHu
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
exit
parent
82d1f2bb
Changes
14
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
353 additions
and
55 deletions
+353
-55
SmileRedisConst.java
...om/liquidnet/service/goblin/constant/SmileRedisConst.java
+4
-0
SmileShowController.java
...in/web/controller/zhengzai/smile/SmileShowController.java
+5
-6
ShowAgentVo.java
...iquidnet/client/admin/zhengzai/smile/dto/ShowAgentVo.java
+2
-2
ShowTicketVo.java
...quidnet/client/admin/zhengzai/smile/dto/ShowTicketVo.java
+32
-2
ShowVo.java
...com/liquidnet/client/admin/zhengzai/smile/dto/ShowVo.java
+1
-1
ShowVoById.java
...liquidnet/client/admin/zhengzai/smile/dto/ShowVoById.java
+16
-4
ISmileShowService.java
...lient/admin/zhengzai/smile/service/ISmileShowService.java
+2
-3
SmileShowServiceImpl.java
...min/zhengzai/smile/service/impl/SmileShowServiceImpl.java
+127
-32
KylinOrderTicketAndAgentVo.java
...quidnet/service/kylin/dao/KylinOrderTicketAndAgentVo.java
+58
-0
TicketAndStatusDao.java
...a/com/liquidnet/service/kylin/dao/TicketAndStatusDao.java
+62
-0
KylinOrderTicketsMapper.java
...quidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
+1
-1
KylinTicketsMapper.java
...om/liquidnet/service/kylin/mapper/KylinTicketsMapper.java
+6
-1
KylinOrderTicketsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
+6
-3
KylinTicketsMapper.xml
...com.liquidnet.service.kylin.mapper/KylinTicketsMapper.xml
+31
-0
No files found.
liquidnet-bus-api/liquidnet-service-smile-api/src/main/java/com/liquidnet/service/goblin/constant/SmileRedisConst.java
View file @
ca458ce2
...
@@ -23,4 +23,8 @@ public class SmileRedisConst {
...
@@ -23,4 +23,8 @@ public class SmileRedisConst {
public
static
final
String
SELL_TEST
=
PREFIX
.
concat
(
"test"
);
//用户总营收 SELL_USER_REVENUE+uid
public
static
final
String
SELL_TEST
=
PREFIX
.
concat
(
"test"
);
//用户总营收 SELL_USER_REVENUE+uid
public
static
final
String
SELL_SHOW_POEN
=
PREFIX
.
concat
(
"show:poen:"
);
//代理总销售数量
public
static
final
String
SELL_SHOW_TOTAL_SALE_PRICE
=
PREFIX
.
concat
(
"show:total:sale:price:"
);
//代理总销售金额 TotalSalePrice
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/smile/SmileShowController.java
View file @
ca458ce2
package
com
.
liquidnet
.
client
.
admin
.
web
.
controller
.
zhengzai
.
smile
;
package
com
.
liquidnet
.
client
.
admin
.
web
.
controller
.
zhengzai
.
smile
;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.core.page.TableDataInfo
;
import
com.liquidnet.client.admin.common.core.page.TableDataInfo
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowSort
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowSort
;
...
@@ -12,8 +13,6 @@ import io.swagger.annotations.ApiOperation;
...
@@ -12,8 +13,6 @@ import io.swagger.annotations.ApiOperation;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.bind.annotation.*
;
import
java.util.List
;
/**
/**
* @author TT
* @author TT
*/
*/
...
@@ -29,11 +28,11 @@ public class SmileShowController {
...
@@ -29,11 +28,11 @@ public class SmileShowController {
@ApiOperation
(
"演出列表"
)
@ApiOperation
(
"演出列表"
)
@ResponseBody
@ResponseBody
public
TableDataInfo
schoolList
(
SmileShowParam
smileShowParam
)
{
public
TableDataInfo
schoolList
(
SmileShowParam
smileShowParam
)
{
List
<
ShowVo
>
list
=
smileShowService
.
listShow
(
smileShowParam
);
PageInfo
<
ShowVo
>
list
=
smileShowService
.
listShow
(
smileShowParam
);
TableDataInfo
rspData
=
new
TableDataInfo
();
TableDataInfo
rspData
=
new
TableDataInfo
();
//
rspData.setCode(0);
rspData
.
setCode
(
0
);
//
rspData.setRows(list.getList());
rspData
.
setRows
(
list
.
getList
());
//
rspData.setTotal(list.getTotal());
rspData
.
setTotal
(
list
.
getTotal
());
return
rspData
;
return
rspData
;
}
}
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/ShowAgentVo.java
View file @
ca458ce2
...
@@ -10,7 +10,7 @@ import java.math.BigDecimal;
...
@@ -10,7 +10,7 @@ import java.math.BigDecimal;
@Data
@Data
public
class
ShowAgentVo
{
public
class
ShowAgentVo
{
private
Long
id
;
private
Integer
id
;
/**
/**
* 演出id
* 演出id
...
@@ -25,7 +25,7 @@ public class ShowAgentVo {
...
@@ -25,7 +25,7 @@ public class ShowAgentVo {
/**
/**
* 票种名称
* 票种名称
*/
*/
private
String
ti
cketNam
e
;
private
String
ti
tl
e
;
/**
/**
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/ShowTicketVo.java
View file @
ca458ce2
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
dto
;
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
dto
;
import
lombok.Data
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.time.LocalDateTime
;
@Data
public
class
ShowTicketVo
{
public
class
ShowTicketVo
{
/**
/**
* 票种名
* 票种名
*/
*/
private
String
ti
cketNam
e
;
private
String
ti
tl
e
;
/**
/**
* 单价
* 单价
...
@@ -15,7 +19,33 @@ public class ShowTicketVo {
...
@@ -15,7 +19,33 @@ public class ShowTicketVo {
private
BigDecimal
price
;
private
BigDecimal
price
;
/**
/**
* 类型 票类型 1
单日票 2
通票
* 类型 票类型 1
.单日票 2.
通票
*/
*/
private
int
type
;
private
int
type
;
/**
* 适用开始时间
*/
private
LocalDateTime
useStart
;
/**
* 适用结束时间
*/
private
LocalDateTime
useEnd
;
/**
* 票总库存 正式库存
*/
private
Integer
totalGeneral
;
/**
* 代理销售数量 总代销售数量+普代销售数量
*/
private
Integer
agentSaleNum
;
/**
* 总销售金额 总代销售金额+普代销售金额
*/
private
BigDecimal
totalPrice
;
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/ShowVo.java
View file @
ca458ce2
...
@@ -34,7 +34,7 @@ public class ShowVo {
...
@@ -34,7 +34,7 @@ public class ShowVo {
/**
/**
* 总销售金额 totalSalePrice
* 总销售金额 totalSalePrice
*/
*/
private
BigDecimal
total
Amount
;
private
BigDecimal
total
SalePrice
;
/**
/**
* 总销售代理
* 总销售代理
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/dto/ShowVoById.java
View file @
ca458ce2
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
dto
;
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
dto
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
lombok.Data
;
import
java.util.List
;
import
java.util.List
;
...
@@ -13,62 +14,73 @@ public class ShowVoById {
...
@@ -13,62 +14,73 @@ public class ShowVoById {
/**
/**
* 演出id
* 演出id
*/
*/
@ApiModelProperty
(
value
=
"演出id"
)
private
String
performancesId
;
private
String
performancesId
;
/**
/**
* 演出图片
* 演出图片
*/
*/
@ApiModelProperty
(
value
=
"演出图片"
)
private
String
imgPoster
;
private
String
imgPoster
;
/**
/**
* 演出名
* 演出名
*/
*/
@ApiModelProperty
(
value
=
"演出名"
)
private
String
title
;
private
String
title
;
/**
/**
* 演出开始时间
* 演出开始时间
*/
*/
@ApiModelProperty
(
value
=
"演出开始时间"
)
private
String
timeStart
;
private
String
timeStart
;
/**
/**
* 演出结束时间
* 演出结束时间
*/
*/
@ApiModelProperty
(
value
=
"演出结束时间"
)
private
String
timeEnd
;
private
String
timeEnd
;
/**
/**
* 城市id
* 城市id
*/
*/
@ApiModelProperty
(
value
=
"城市id"
)
private
Integer
cityId
;
private
Integer
cityId
;
/**
/**
* 城市
* 城市
*/
*/
@ApiModelProperty
(
value
=
"城市"
)
private
String
cityName
;
private
String
cityName
;
/**
/**
* 场地id
* 场地id
*/
*/
@ApiModelProperty
(
value
=
"场地id"
)
private
String
fieldId
;
private
String
fieldId
;
/**
/**
* 场地名称
* 场地名称
*/
*/
@ApiModelProperty
(
value
=
"场地名称"
)
private
String
fieldName
;
private
String
fieldName
;
/**
/**
* 票提设置
* 票提设置
集合
*/
*/
@ApiModelProperty
(
value
=
"票提设置集合"
)
private
List
<
ShowAgentVo
>
showAgentVoList
;
private
List
<
ShowAgentVo
>
showAgentVoList
;
/**
/**
* 代理票种
* 代理票种
集合
*/
*/
@ApiModelProperty
(
value
=
"代理票种集合"
)
private
List
<
ShowTicketVo
>
showTicketVoList
;
/**
/**
* 演出详情
* 演出详情
*/
*/
@ApiModelProperty
(
value
=
"演出详情"
)
private
String
details
;
private
String
details
;
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/ISmileShowService.java
View file @
ca458ce2
...
@@ -2,14 +2,13 @@ package com.liquidnet.client.admin.zhengzai.smile.service;
...
@@ -2,14 +2,13 @@ package com.liquidnet.client.admin.zhengzai.smile.service;
import
com.baomidou.mybatisplus.extension.service.IService
;
import
com.baomidou.mybatisplus.extension.service.IService
;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowSort
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowSort
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowVo
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowVo
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.SmileShowParam
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.SmileShowParam
;
import
com.liquidnet.service.smile.entity.SmileSchool
;
import
com.liquidnet.service.smile.entity.SmileSchool
;
import
java.util.List
;
/**
/**
* <p>
* <p>
* 服务类
* 服务类
...
@@ -20,7 +19,7 @@ import java.util.List;
...
@@ -20,7 +19,7 @@ import java.util.List;
*/
*/
public
interface
ISmileShowService
extends
IService
<
SmileSchool
>
{
public
interface
ISmileShowService
extends
IService
<
SmileSchool
>
{
List
<
ShowVo
>
listShow
(
SmileShowParam
smileShowParam
);
PageInfo
<
ShowVo
>
listShow
(
SmileShowParam
smileShowParam
);
AjaxResult
sort
(
ShowSort
showSort
);
AjaxResult
sort
(
ShowSort
showSort
);
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/smile/service/impl/SmileShowServiceImpl.java
View file @
ca458ce2
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
service
.
impl
;
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
smile
.
service
.
impl
;
import
com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper
;
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.PageInfo
;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.utils.StringUtils
;
import
com.liquidnet.client.admin.common.utils.StringUtils
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowSort
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.*
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.ShowVo
;
import
com.liquidnet.client.admin.zhengzai.smile.dto.SmileShowParam
;
import
com.liquidnet.client.admin.zhengzai.smile.service.ISmileShowService
;
import
com.liquidnet.client.admin.zhengzai.smile.service.ISmileShowService
;
import
com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils
;
import
com.liquidnet.client.admin.zhengzai.smile.utils.SmileRedisUtils
;
import
com.liquidnet.service.goblin.constant.SmileRedisConst
;
import
com.liquidnet.service.goblin.constant.SmileRedisConst
;
import
com.liquidnet.service.goblin.dto.vo.SellDataVO
;
import
com.liquidnet.service.kylin.dao.KylinOrderTicketAndAgentVo
;
import
com.liquidnet.service.kylin.dao.TicketAndStatusDao
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo
;
import
com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo
;
import
com.liquidnet.service.kylin.entity.KylinOrderTickets
;
import
com.liquidnet.service.kylin.entity.KylinPerformances
;
import
com.liquidnet.service.kylin.entity.KylinPerformances
;
import
com.liquidnet.service.kylin.mapper.KylinOrderTicketRelationsMapper
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.mapper.KylinOrderTicketsMapper
;
import
com.liquidnet.service.kylin.mapper.KylinPerformancesMapper
;
import
com.liquidnet.service.kylin.mapper.KylinTicketStatusMapper
;
import
com.liquidnet.service.kylin.service.admin.IKylinPerformancesAdminService
;
import
com.liquidnet.service.kylin.service.admin.IKylinPerformancesAdminService
;
import
com.liquidnet.service.smile.entity.SmileAgent
;
import
com.liquidnet.service.smile.entity.SmileSchool
;
import
com.liquidnet.service.smile.entity.SmileSchool
;
import
com.liquidnet.service.smile.mapper.SmileAgentMapper
;
import
com.liquidnet.service.smile.mapper.SmileSchoolMapper
;
import
com.liquidnet.service.smile.mapper.SmileSchoolMapper
;
import
com.liquidnet.service.smile.mapper.SmileUserMapper
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
...
@@ -30,7 +30,10 @@ import org.springframework.data.mongodb.core.query.Query;
...
@@ -30,7 +30,10 @@ import org.springframework.data.mongodb.core.query.Query;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
/**
/**
...
@@ -69,13 +72,21 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
...
@@ -69,13 +72,21 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
@Autowired
@Autowired
KylinOrderTicketsMapper
kylinOrderTicketsMapper
;
KylinOrderTicketsMapper
kylinOrderTicketsMapper
;
@Autowired
SmileAgentMapper
smileAgentMapper
;
@Autowired
KylinTicketsMapper
kylinTicketsMapper
;
@Autowired
SmileUserMapper
smileUserMapper
;
@Override
@Override
public
List
<
ShowVo
>
listShow
(
SmileShowParam
smileShowParam
)
{
public
PageInfo
<
ShowVo
>
listShow
(
SmileShowParam
smileShowParam
)
{
PageInfo
<
KylinPerformances
>
pageInfo
;
PageInfo
<
ShowVo
>
pageInfo
;
//查询所有代理的演出id
//查询所有代理的演出id
List
<
KylinPerformances
>
kylinPerformancesList
=
kylinPerformancesMapper
.
selectPerIdByAgent
();
List
<
KylinPerformances
>
kylinPerformancesList
=
kylinPerformancesMapper
.
selectPerIdByAgent
();
List
<
ShowVo
>
showVoList
=
kylinPerformancesList
.
stream
().
map
(
kylinPerformances
->
{
return
kylinPerformancesList
.
stream
().
map
(
kylinPerformances
->
{
ShowVo
vo
=
new
ShowVo
();
ShowVo
vo
=
new
ShowVo
();
//演出id
//演出id
vo
.
setPerformancesId
(
kylinPerformances
.
getPerformancesId
());
vo
.
setPerformancesId
(
kylinPerformances
.
getPerformancesId
());
...
@@ -84,18 +95,26 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
...
@@ -84,18 +95,26 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//城市
//城市
vo
.
setCityName
(
kylinPerformances
.
getCityName
());
vo
.
setCityName
(
kylinPerformances
.
getCityName
());
//根据演出id 查询所有订单
//根据演出id 查询所有订单
List
<
KylinOrderTicket
s
>
kylinOrderTicketsList
=
kylinOrderTicketsMapper
.
selectListByPerformanceId
(
kylinPerformances
.
getPerformancesId
());
List
<
KylinOrderTicket
AndAgentVo
>
kylinOrderTicketsList
=
kylinOrderTicketsMapper
.
selectListByPerformanceId
(
kylinPerformances
.
getPerformancesId
());
int
open
=
0
;
int
open
=
0
;
BigDecimal
total
Amount
=
BigDecimal
.
valueOf
(
0
);
BigDecimal
total
SalePrice
=
BigDecimal
.
valueOf
(
0
);
for
(
KylinOrderTicket
s
kylinOrderTickets
:
kylinOrderTicketsList
)
{
for
(
KylinOrderTicket
AndAgentVo
kylinOrderTicketAndAgentVo
:
kylinOrderTicketsList
)
{
//演出张数
//演出张数
open
=
open
+
(
kylinOrderTickets
.
getNumber
()
-
kylinOrderTickets
.
getRefundNumber
());
int
num
=
kylinOrderTicketAndAgentVo
.
getNumber
()
-
kylinOrderTicketAndAgentVo
.
getRefundNumber
();
//总销售金额
if
(
num
>
0
){
totalAmount
=
totalAmount
.
add
(
kylinOrderTickets
.
getPriceActual
()).
subtract
(
kylinOrderTickets
.
getPriceRefund
());
open
+=
num
;
totalSalePrice
=
totalSalePrice
.
add
((
kylinOrderTicketAndAgentVo
.
getPriceActual
()).
subtract
(
kylinOrderTicketAndAgentVo
.
getPriceRefund
()).
multiply
(
BigDecimal
.
valueOf
(
num
)));
}
}
}
vo
.
setOpen
(
open
);
vo
.
setOpen
(
open
);
vo
.
setTotalAmount
(
totalAmount
);
//缓存redis
smileRedisUtils
.
set
(
SmileRedisConst
.
SELL_SHOW_POEN
.
concat
(
kylinPerformances
.
getPerformancesId
()),
open
);
vo
.
setTotalSalePrice
(
totalSalePrice
);
//缓存redis
smileRedisUtils
.
set
(
SmileRedisConst
.
SELL_SHOW_TOTAL_SALE_PRICE
.
concat
(
kylinPerformances
.
getPerformancesId
()),
totalSalePrice
);
//根据演出id查询销售代理
//根据演出id查询销售代理
vo
.
setTotalOutAgent
(
kylinOrderTicketRelationsMapper
.
concatByAgentDed
(
kylinPerformances
.
getPerformancesId
()));
vo
.
setTotalOutAgent
(
kylinOrderTicketRelationsMapper
.
concatByAgentDed
(
kylinPerformances
.
getPerformancesId
()));
...
@@ -104,6 +123,8 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
...
@@ -104,6 +123,8 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
return
vo
;
return
vo
;
}).
collect
(
Collectors
.
toList
());
}).
collect
(
Collectors
.
toList
());
pageInfo
=
new
PageInfo
<
ShowVo
>(
showVoList
);
return
pageInfo
;
}
}
@Override
@Override
...
@@ -132,27 +153,101 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
...
@@ -132,27 +153,101 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
@Override
@Override
public
AjaxResult
getShowById
(
String
performancesId
)
{
public
AjaxResult
getShowById
(
String
performancesId
)
{
if
(
StringUtils
.
isEmpty
(
performancesId
)){
if
(
StringUtils
.
isEmpty
(
performancesId
))
{
ShowVoById
showVoById
=
new
ShowVoById
();
//根据演出ID查询演出数据演出数据
//根据演出ID查询演出数据演出数据
KylinPerformanceVo
kylinPerformanceVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"performancesId"
).
is
(
performancesId
)),
KylinPerformanceVo
.
class
,
KylinPerformanceVo
.
class
.
getSimpleName
());
KylinPerformanceVo
kylinPerformanceVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"performancesId"
).
is
(
performancesId
)),
KylinPerformanceVo
.
class
,
KylinPerformanceVo
.
class
.
getSimpleName
());
try
{
assert
kylinPerformanceVo
!=
null
;
}
catch
(
Exception
e
)
{
return
null
;
}
showVoById
.
setPerformancesId
(
kylinPerformanceVo
.
getPerformancesId
());
showVoById
.
setImgPoster
(
kylinPerformanceVo
.
getImgPoster
());
showVoById
.
setTitle
(
kylinPerformanceVo
.
getTitle
());
showVoById
.
setTimeStart
(
kylinPerformanceVo
.
getTimeStart
());
showVoById
.
setTimeEnd
(
kylinPerformanceVo
.
getTimeEnd
());
showVoById
.
setCityId
(
kylinPerformanceVo
.
getCityId
());
showVoById
.
setCityName
(
kylinPerformanceVo
.
getCityName
());
showVoById
.
setFieldId
(
kylinPerformanceVo
.
getFieldId
());
showVoById
.
setFieldName
(
kylinPerformanceVo
.
getFieldName
());
//票提集合 根据演出id查询票提id
List
<
ShowAgentVo
>
showAgentVoList
=
new
ArrayList
<>();
List
<
ShowTicketVo
>
showTicketVoList
=
new
ArrayList
<>();
LambdaQueryWrapper
<
SmileAgent
>
queryWrapper
=
Wrappers
.
lambdaQuery
(
SmileAgent
.
class
);
queryWrapper
.
eq
(
SmileAgent:
:
getPerformanceId
,
performancesId
);
List
<
SmileAgent
>
smileAgents
=
smileAgentMapper
.
selectList
(
queryWrapper
);
Map
<
String
,
SmileAgent
>
map
=
new
HashMap
<>();
smileAgents
.
forEach
(
smileAgent
->
{
map
.
put
(
smileAgent
.
getTicketId
(),
smileAgent
);
});
List
<
String
>
ticketsIdList
=
smileAgents
.
stream
().
map
(
SmileAgent:
:
getTicketId
).
collect
(
Collectors
.
toList
());
//根据票提IDs查询票信息
List
<
TicketAndStatusDao
>
ticketAndStatusDaoList
=
kylinTicketsMapper
.
selectTicketsByIds
(
ticketsIdList
);
for
(
TicketAndStatusDao
ticketAndStatusDao
:
ticketAndStatusDaoList
)
{
SmileAgent
smileAgent
=
map
.
get
(
ticketAndStatusDao
.
getTicketsId
());
ShowAgentVo
showAgentVo
=
new
ShowAgentVo
();
showAgentVo
.
setId
(
ticketAndStatusDao
.
getMid
());
showAgentVo
.
setPerformanceId
(
performancesId
);
showAgentVo
.
setTicketId
(
ticketAndStatusDao
.
getTicketsId
());
showAgentVo
.
setTitle
(
ticketAndStatusDao
.
getTitle
());
//总代票提
showAgentVo
.
setTotalCarry
(
smileAgent
.
getTotalCarry
());
//普代票提
showAgentVo
.
setOrdCarry
(
smileAgent
.
getOrdCarry
());
ShowTicketVo
showTicketVo
=
new
ShowTicketVo
();
showTicketVo
.
setTitle
(
ticketAndStatusDao
.
getTitle
());
//单价
showTicketVo
.
setPrice
(
ticketAndStatusDao
.
getPrice
());
showTicketVo
.
setType
(
ticketAndStatusDao
.
getType
());
showTicketVo
.
setUseEnd
(
ticketAndStatusDao
.
getUseEnd
());
showTicketVo
.
setUseStart
(
ticketAndStatusDao
.
getUseStart
());
showTicketVo
.
setTotalGeneral
(
ticketAndStatusDao
.
getTotalGeneral
());
//根据演出id查询处所有订单
List
<
KylinOrderTicketAndAgentVo
>
kylinOrderTicketsList
=
kylinOrderTicketsMapper
.
selectListByPerformanceId
(
performancesId
);
//代理销售数量
int
agentSaleNum
=
0
;
//总销售金额
BigDecimal
totalPrice
=
BigDecimal
.
valueOf
(
0
);
//总代票提
for
(
KylinOrderTicketAndAgentVo
kylinOrderTicketAndAgentVo
:
kylinOrderTicketsList
)
{
int
num
=
kylinOrderTicketAndAgentVo
.
getNumber
()
-
kylinOrderTicketAndAgentVo
.
getRefundNumber
();
if
(
num
>
0
)
{
agentSaleNum
+=
num
;
totalPrice
=
totalPrice
.
add
(
(
ticketAndStatusDao
.
getPrice
().
multiply
(
kylinOrderTicketAndAgentVo
.
getAgentDistributions
()))
.
multiply
(
BigDecimal
.
valueOf
(
num
)));
}
}
showTicketVo
.
setAgentSaleNum
(
agentSaleNum
);
showAgentVo
.
setTotalCarry
(
totalPrice
);
showAgentVoList
.
add
(
showAgentVo
);
showTicketVoList
.
add
(
showTicketVo
);
}
ShowTicketVo
showTicketVo
=
new
ShowTicketVo
();
//代理销售总张数
showTicketVo
.
setTitle
(
"总计"
);
//总
showTicketVo
.
setAgentSaleNum
((
int
)
smileRedisUtils
.
get
(
SmileRedisConst
.
SELL_SHOW_POEN
.
concat
(
performancesId
)));
showTicketVo
.
setTotalPrice
((
BigDecimal
)
smileRedisUtils
.
get
(
SmileRedisConst
.
SELL_SHOW_TOTAL_SALE_PRICE
.
concat
(
performancesId
)));
showTicketVoList
.
add
(
showTicketVo
);
showVoById
.
setShowAgentVoList
(
showAgentVoList
);
showVoById
.
setShowTicketVoList
(
showTicketVoList
);
//根据演出id查询代理用户
return
AjaxResult
.
success
(
showVoById
);
List
<
String
>
agentIds
=
kylinOrderTicketsMapper
.
getAgentIdListByPerId
(
performancesId
);
for
(
String
agentId
:
agentIds
)
{
SellDataVO
sellDataVO
=
(
SellDataVO
)
smileRedisUtils
.
get
(
SmileRedisConst
.
SELL_DATA
.
concat
(
agentId
).
concat
(
performancesId
));
}
}
}
return
null
;
return
null
;
}
}
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/KylinOrderTicketAndAgentVo.java
0 → 100644
View file @
ca458ce2
package
com
.
liquidnet
.
service
.
kylin
.
dao
;
import
lombok.Data
;
import
java.math.BigDecimal
;
/**
* @author TT
*/
@Data
public
class
KylinOrderTicketAndAgentVo
{
/**
* order_tickets_id
*/
private
String
orderTicketsId
;
/**
* 用户id
*/
private
String
userId
;
/**
* 演出名称
*/
private
String
performanceTitle
;
/**
* 数量
*/
private
Integer
number
;
/**
* 退款张数
*/
private
Integer
refundNumber
;
/**
* 实付价格
*/
private
BigDecimal
priceActual
;
/**
* 退款价格
*/
private
BigDecimal
priceRefund
;
/**
* 代理id
*/
private
String
agentId
;
/**
* 代理分销比例
*/
private
BigDecimal
agentDistributions
;
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/TicketAndStatusDao.java
0 → 100644
View file @
ca458ce2
package
com
.
liquidnet
.
service
.
kylin
.
dao
;
import
lombok.Data
;
import
java.math.BigDecimal
;
import
java.time.LocalDateTime
;
/**
* @author TT
*/
@Data
public
class
TicketAndStatusDao
{
private
Integer
mid
;
/**
* 票id
*/
private
String
ticketsId
;
/**
* 票种名
*/
private
String
title
;
/**
* 单价
*/
private
BigDecimal
price
;
/**
* 类型 票类型 1.单日票 2.通票
*/
private
int
type
;
/**
* 适用开始时间
*/
private
LocalDateTime
useStart
;
/**
* 适用结束时间
*/
private
LocalDateTime
useEnd
;
/**
* 票总库存
*/
private
Integer
totalGeneral
;
/**
* 道理销售数量
*/
private
Integer
agentSaleNum
;
/**
* 总销售金额
*/
private
BigDecimal
totalPrice
;
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
View file @
ca458ce2
...
@@ -51,7 +51,7 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
...
@@ -51,7 +51,7 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
List
<
Map
>
getUserSellDetail
(
@Param
(
"agentId"
)
String
agentId
,
@Param
(
"ticketId"
)
String
ticketId
);
List
<
Map
>
getUserSellDetail
(
@Param
(
"agentId"
)
String
agentId
,
@Param
(
"ticketId"
)
String
ticketId
);
List
<
Map
>
getUserPerformance
(
@Param
(
"agentId"
)
String
userId
);
List
<
Map
>
getUserPerformance
(
@Param
(
"agentId"
)
String
userId
);
List
<
KylinOrderTicket
s
>
selectListByPerformanceId
(
@Param
(
"performancesId"
)
String
performancesId
);
List
<
KylinOrderTicket
AndAgentVo
>
selectListByPerformanceId
(
@Param
(
"performancesId"
)
String
performancesId
);
List
<
String
>
getAgentIdListByPerId
(
@Param
(
"performancesId"
)
String
performancesId
);
List
<
String
>
getAgentIdListByPerId
(
@Param
(
"performancesId"
)
String
performancesId
);
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinTicketsMapper.java
View file @
ca458ce2
package
com
.
liquidnet
.
service
.
kylin
.
mapper
;
package
com
.
liquidnet
.
service
.
kylin
.
mapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.liquidnet.service.kylin.dao.PerformancesTicketListDao
;
import
com.liquidnet.service.kylin.dao.PerformancesTicketListDao
;
import
com.liquidnet.service.kylin.dao.TicketAgentDao
;
import
com.liquidnet.service.kylin.dao.TicketAgentDao
;
import
com.liquidnet.service.kylin.dao.TicketAndStatusDao
;
import
com.liquidnet.service.kylin.dao.TicketDamaiDao
;
import
com.liquidnet.service.kylin.dao.TicketDamaiDao
;
import
com.liquidnet.service.kylin.entity.KylinTickets
;
import
com.liquidnet.service.kylin.entity.KylinTickets
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
java.util.List
;
import
java.util.List
;
...
@@ -23,4 +24,8 @@ public interface KylinTicketsMapper extends BaseMapper<KylinTickets> {
...
@@ -23,4 +24,8 @@ public interface KylinTicketsMapper extends BaseMapper<KylinTickets> {
List
<
TicketDamaiDao
>
ticketDamai
(
String
performanceIs
);
List
<
TicketDamaiDao
>
ticketDamai
(
String
performanceIs
);
List
<
PerformancesTicketListDao
>
getPerformancesTicketList
(
String
performanceId
);
List
<
PerformancesTicketListDao
>
getPerformancesTicketList
(
String
performanceId
);
List
<
TicketAndStatusDao
>
selectTicketsByIds
(
List
<
String
>
ticketsIdList
);
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
View file @
ca458ce2
...
@@ -459,7 +459,7 @@
...
@@ -459,7 +459,7 @@
where kots.status in (1) and kot.user_id = #{uid} ;
where kots.status in (1) and kot.user_id = #{uid} ;
</select>
</select>
<select
id=
"selectListByPerformanceId"
resultType=
"com.liquidnet.service.kylin.
entity.KylinOrderTickets
"
>
<select
id=
"selectListByPerformanceId"
resultType=
"com.liquidnet.service.kylin.
dao.KylinOrderTicketAndAgentVo
"
>
SELECT
SELECT
kot.order_tickets_id,
kot.order_tickets_id,
kot.user_id,
kot.user_id,
...
@@ -467,14 +467,17 @@
...
@@ -467,14 +467,17 @@
kot.number,
kot.number,
kot.refund_number,
kot.refund_number,
kot.price_actual,
kot.price_actual,
kot.price_refund
kot.price_refund,
kk.agent_id,
kk.agent_distributions
FROM
FROM
kylin_order_tickets AS kot
kylin_order_tickets AS kot
LEFT JOIN (
LEFT JOIN (
SELECT
SELECT
kotr.order_id,
kotr.order_id,
kotr.agent_id,
kotr.agent_id,
kotr.performance_id
kotr.performance_id,
kotr.agent_distributions
FROM
FROM
kylin_order_ticket_relations AS kotr
kylin_order_ticket_relations AS kotr
LEFT JOIN kylin_order_ticket_status AS kots ON kotr.order_id = kots.order_id
LEFT JOIN kylin_order_ticket_status AS kots ON kotr.order_id = kots.order_id
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinTicketsMapper.xml
View file @
ca458ce2
...
@@ -15,6 +15,8 @@
...
@@ -15,6 +15,8 @@
</resultMap>
</resultMap>
<!-- 票分销情况-->
<!-- 票分销情况-->
<select
id=
"ticketAgent"
parameterType=
"java.lang.String"
resultMap=
"ticketAgentResult"
>
<select
id=
"ticketAgent"
parameterType=
"java.lang.String"
resultMap=
"ticketAgentResult"
>
SELECT
SELECT
...
@@ -71,4 +73,33 @@
...
@@ -71,4 +73,33 @@
and b.is_express = 1
and b.is_express = 1
and b.status IN (2, 3, 6, 7, 8, 9, 10)*/
and b.status IN (2, 3, 6, 7, 8, 9, 10)*/
</select>
</select>
<resultMap
id=
"ticketAndStatusDao"
type=
"com.liquidnet.service.kylin.dao.TicketAndStatusDao"
>
<collection
column=
"mid"
property=
"mid"
/>
<collection
column=
"tickets_id"
property=
"ticketsId"
/>
<collection
column=
"title"
property=
"title"
/>
<collection
column=
"type"
property=
"type"
/>
<collection
column=
"price"
property=
"price"
/>
<collection
column=
"use_start"
property=
"useStart"
/>
<collection
column=
"use_end"
property=
"useEnd"
/>
<collection
column=
"total_general"
property=
"totalGeneral"
/>
</resultMap>
<select
id=
"selectTicketsByIds"
resultMap=
"ticketAndStatusDao"
>
select
kt.mid,
kt.tickets_id,
kt.title,
kt.`type`,
kt.price,
kt.use_start,
kt.use_end,
kts.total_general
from kylin_tickets as kt
LEFT JOIN kylin_ticket_status as kts ON kt.tickets_id = kts.ticket_id
where kt.tickets_id in
<foreach
collection=
"ticketsIdList"
item=
"ticketsId"
open=
"("
separator=
","
close=
")"
>
#{ticketsId}
</foreach>
</select>
</mapper>
</mapper>
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