记得上下班打卡 | 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
c08f2a62
Commit
c08f2a62
authored
Sep 01, 2021
by
Administrator
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'pre' into 'master'
Pre See merge request
!27
parents
580d3dd1
1aa32b0e
Changes
13
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
135 additions
and
44 deletions
+135
-44
OrderDetailsVo.java
...iquidnet/service/kylin/dto/vo/returns/OrderDetailsVo.java
+6
-1
details.html
...ources/templates/zhengzai/kylin/performances/details.html
+55
-6
PerformanceVoUtils.java
...client/admin/zhengzai/kylin/utils/PerformanceVoUtils.java
+1
-0
RedisUtil.java
...java/com.liquidnet.common.cache/redis/util/RedisUtil.java
+19
-1
KylinCheckUserMapper.xml
...m.liquidnet.service.kylin.mapper/KylinCheckUserMapper.xml
+1
-1
RedisRefundReceiver.java
...service/consumer/dragon/receiver/RedisRefundReceiver.java
+1
-1
KylinUtils.java
...om/liquidnet/service/consumer/kylin/Utils/KylinUtils.java
+3
-0
KylinOrderTicketsServiceImpl.java
...vice/kylin/service/impl/KylinOrderTicketsServiceImpl.java
+21
-15
DataUtils.java
...ain/java/com/liquidnet/service/kylin/utils/DataUtils.java
+6
-0
KylinOrderTicketsServiceImpl.java
...vice/order/service/impl/KylinOrderTicketsServiceImpl.java
+1
-1
KylinCheckUserPerformancesPartnerController.java
.../partner/KylinCheckUserPerformancesPartnerController.java
+3
-3
KylinCheckUserPartnerServiceImpl.java
...ervice/impl/partner/KylinCheckUserPartnerServiceImpl.java
+7
-4
KylinPerformancesPartnerServiceImpl.java
...ice/impl/partner/KylinPerformancesPartnerServiceImpl.java
+11
-11
No files found.
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/returns/OrderDetailsVo.java
View file @
c08f2a62
...
...
@@ -7,15 +7,20 @@ import lombok.Data;
import
java.util.List
;
@Data
public
class
OrderDetailsVo
implements
Cloneable
{
public
class
OrderDetailsVo
implements
Cloneable
{
private
KylinOrderTicketVo
orderTicketVo
;
private
String
enterDescribe
;
private
Integer
expressStatus
;
private
Long
restTime
;
private
Integer
isCanRefund
;
private
Integer
isShowQrCode
;
private
String
showQrCodeTime
;
private
List
<
KylinOrderRefundsOrderCodeVo
>
orderRefundsVoList
;
private
static
final
OrderDetailsVo
obj
=
new
OrderDetailsVo
();
public
static
OrderDetailsVo
getNew
()
{
try
{
return
(
OrderDetailsVo
)
obj
.
clone
();
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/performances/details.html
View file @
c08f2a62
...
...
@@ -9,9 +9,9 @@
<div
class=
"col-sm-12"
>
<div
class=
"tabs-container"
>
<ul
class=
"nav nav-tabs"
>
<li
class=
"active"
><a
data-toggle=
"tab"
href=
"#tab-2"
aria-expanded=
"false"
>
演出详情
</a>
<li
id=
"li-tab-2"
class=
"active"
><a
data-toggle=
"tab"
href=
"#tab-2"
aria-expanded=
"false"
>
演出详情
</a>
</li>
<li
class=
"
"
><a
data-toggle=
"tab"
href=
"#tab-1"
aria-expanded=
"true"
id=
"tab-nav-1"
>
演出数据
</a>
<li
id=
"li-tab-1
"
><a
data-toggle=
"tab"
href=
"#tab-1"
aria-expanded=
"true"
id=
"tab-nav-1"
>
演出数据
</a>
</li>
<!-- <li class=""><a data-toggle="tab" href="#tab-2" aria-expanded="false">校园分销</a>-->
<!-- </li>-->
...
...
@@ -19,13 +19,15 @@
<!-- </li>-->
<!-- <li class=""><a data-toggle="tab" href="#tab-2" aria-expanded="false">状态管理</a>-->
<!-- </li>-->
<li
class=
"
"
><a
data-toggle=
"tab"
href=
"#tab-6"
aria-expanded=
"false"
onclick=
"refundConfigInfo()"
>
退款管理
</a>
<li
id=
"li-tab-6
"
><a
data-toggle=
"tab"
href=
"#tab-6"
aria-expanded=
"false"
onclick=
"refundConfigInfo()"
>
退款管理
</a>
</li>
<li
class=
"
"
><a
data-toggle=
"tab"
href=
"#tab-3"
aria-expanded=
"false"
onclick=
"memberInfo()"
>
会员信息配置
</a>
<li
id=
"li-tab-3
"
><a
data-toggle=
"tab"
href=
"#tab-3"
aria-expanded=
"false"
onclick=
"memberInfo()"
>
会员信息配置
</a>
</li>
<li
class=
"
"
><a
data-toggle=
"tab"
href=
"#tab-4"
aria-expanded=
"false"
onclick=
"agentInfo()"
>
代理配置
</a>
<li
id=
"li-tab-4
"
><a
data-toggle=
"tab"
href=
"#tab-4"
aria-expanded=
"false"
onclick=
"agentInfo()"
>
代理配置
</a>
</li>
<li
class=
""
><a
data-toggle=
"tab"
href=
"#tab-5"
aria-expanded=
"false"
onclick=
"damaiInfo()"
>
大麦配置
</a>
<li
id=
"li-tab-5"
><a
data-toggle=
"tab"
href=
"#tab-5"
aria-expanded=
"false"
onclick=
"damaiInfo()"
>
大麦配置
</a>
</li>
<li
id=
"li-tab-7"
><a
data-toggle=
"tab"
href=
"#tab-7"
aria-expanded=
"false"
onclick=
"transferInfo()"
>
转赠配置
</a>
</li>
</ul>
<div
class=
"tab-content"
>
...
...
@@ -241,6 +243,12 @@
height=
800px
frameborder=
0
></iframe>
</div>
</div>
<div
id=
"tab-7"
class=
"tab-pane"
>
<div
class=
"panel-body"
>
<iframe
id=
"transfer_iframe"
name=
"transfer_iframe"
marginwidth=
0
marginheight=
0
width=
100%
height=
800px
frameborder=
0
></iframe>
</div>
</div>
</div>
...
...
@@ -254,6 +262,42 @@
const
isShow
=
'[[${kylinPerformanceMisVo.isShow}]]'
;
const
auditStatus
=
'[[${kylinPerformanceMisVo.auditStatus}]]'
;
var
agentFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:agent'
)}]];
if
(
agentFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-4"
).
style
.
display
=
"none"
;
}
var
otherFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:audit'
)}]];
if
(
otherFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-2"
).
style
.
display
=
"none"
;
document
.
getElementById
(
"tab-2"
).
style
.
display
=
"none"
;
}
var
refundFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:refund'
)}]];
if
(
refundFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-6"
).
style
.
display
=
"none"
;
}
var
memberFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:member'
)}]];
if
(
memberFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-3"
).
style
.
display
=
"none"
;
}
var
damaiFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:damai'
)}]];
if
(
damaiFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-5"
).
style
.
display
=
"none"
;
}
var
dataFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:data'
)}]];
if
(
dataFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-1"
).
style
.
display
=
"none"
;
}
var
transferFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performances:transfer'
)}]];
if
(
transferFlag
==
"hidden"
){
document
.
getElementById
(
"li-tab-7"
).
style
.
display
=
"none"
;
}
if
(
auditStatus
!=
0
)
{
document
.
getElementsByName
(
"auditBtn"
)[
0
].
style
.
display
=
"none"
;
}
...
...
@@ -322,6 +366,11 @@
document
.
getElementById
(
"refundConfig_iframe"
).
src
=
"../refundConfig/"
+
'[[${kylinPerformanceMisVo.performancesId}]]'
.
replaceAll
(
"
\"
"
,
""
);
}
//转正配置
function
transferInfo
(){
// document.getElementById("transfer_iframe").src = "../refundConfig/" + '[[${kylinPerformanceMisVo.performancesId}]]'.replaceAll("\"", "");
}
$
(
"#tab-nav-1"
).
bind
(
"click"
,
function
()
{
$
(
"#tab_iframe_1"
).
attr
(
"src"
,
prefix
+
"/performanceStatic/"
+
'[[${kylinPerformanceMisVo.performancesId}]]'
.
replaceAll
(
"
\"
"
,
""
));
});
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/PerformanceVoUtils.java
View file @
c08f2a62
...
...
@@ -269,6 +269,7 @@ public class PerformanceVoUtils {
performanceRelations
.
setPerformanceRelationsId
(
IDGenerator
.
nextSnowId
().
toString
());
performanceRelations
.
setCreatedAt
(
null
);
performanceRelations
.
setUpdatedAt
(
updatedAt
);
performanceRelations
.
setMerchantId
(
null
);
performancesMapper
.
update
(
performances
,
new
UpdateWrapper
<
KylinPerformances
>().
eq
(
"performances_id"
,
performances
.
getPerformancesId
()));
performanceStatusMapper
.
update
(
performanceStatus
,
new
UpdateWrapper
<
KylinPerformanceStatus
>().
eq
(
"performance_id"
,
performances
.
getPerformancesId
()));
...
...
liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisUtil.java
View file @
c08f2a62
...
...
@@ -149,7 +149,7 @@ public final class RedisUtil {
}
//删除Redis
for
(
Integer
redisDb:
hashMap
.
keySet
())
{
for
(
Integer
redisDb
:
hashMap
.
keySet
())
{
ArrayList
<
String
>
delRedisKeyList
=
hashMap
.
get
(
redisDb
);
redisConfig
.
getRedisTemplateByDb
(
redisDb
).
delete
(
delRedisKeyList
);
}
...
...
@@ -746,4 +746,22 @@ public final class RedisUtil {
public
Object
getDB15RedisGet
(
String
redisKey
)
{
return
redisConfig
.
getRedisTemplateByDb
(
15
).
opsForValue
().
get
(
redisKey
);
}
public
boolean
getDB15RedisHasKey
(
String
redisKey
,
String
item
)
{
return
redisConfig
.
getRedisTemplateByDb
(
15
).
opsForSet
().
isMember
(
redisKey
,
item
);
}
public
static
void
main
(
String
[]
args
)
{
String
[]
keys
=
{
"adam:identity:mobile:18518013286"
};
for
(
String
key
:
keys
)
{
long
value
=
key
.
hashCode
();
int
idx
=
((
int
)
(
value
^
(
value
>>>
32
))
%
250
);
System
.
out
.
printf
(
"\n[%s] - idx:%s"
,
key
,
idx
);
}
}
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinCheckUserMapper.xml
View file @
c08f2a62
...
...
@@ -22,7 +22,7 @@
mobile
FROM kylin_check_user
<where>
merchant_id=#{merchantId} AND
`status` = 1
`status` = 1
<if
test=
"mobile !=null and mobile !='' "
>
AND `mobile` LIKE concat('%', #{mobile}, '%')
</if>
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/receiver/RedisRefundReceiver.java
View file @
c08f2a62
...
...
@@ -32,7 +32,7 @@ public class RedisRefundReceiver implements StreamListener<String, MapRecord<Str
log
.
info
(
"body "
+
message
.
getValue
());
boolean
result
=
this
.
consumerSqlDaoHandler
(
message
.
getValue
().
get
(
"message"
));
// if(result){
log
.
error
(
"consumer success delete message messageId:{} "
,
message
.
getId
());
log
.
info
(
"consumer success delete message messageId:{} "
,
message
.
getId
());
try
{
// stringRedisTemplate.multi();
stringRedisTemplate
.
opsForStream
().
acknowledge
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
message
);
...
...
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/Utils/KylinUtils.java
View file @
c08f2a62
...
...
@@ -39,6 +39,9 @@ public class KylinUtils {
KylinOrderTicketVo
data
=
dataSingle
;
BeanUtils
.
copyProperties
(
data
,
voItem
);
List
<
KylinOrderListVo
>
redisData
=
(
List
<
KylinOrderListVo
>)
redisUtil
.
get
(
KylinRedisConst
.
ORDER_LIST
+
userId
);
if
(
redisData
==
null
){
return
false
;
}
if
(
type
==
1
)
{
redisVo
.
add
(
voItem
);
if
(
redisData
.
size
()
>
0
)
{
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java
View file @
c08f2a62
...
...
@@ -125,8 +125,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
// checkOrderTime(uid);
KylinOrderTicketVo
orderTicketVo
=
dataUtils
.
getOrderTicketVo
(
orderId
);
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(!
orderTicketVo
.
getUserId
().
equals
(
uid
))
{
return
null
;
}
...
...
@@ -162,11 +162,17 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
LocalDateTime
date
=
DateUtil
.
Formatter
.
yyyyMMddHHmmss
.
parse
(
ticketVo
.
getQrCodeShowTime
());
if
(
LocalDateTime
.
now
().
isAfter
(
date
))
{
orderTicketVo
.
setQrCode
(
orderTicketVo
.
getQrCode
());
vo
.
setIsShowQrCode
(
ticketVo
.
getIsShowCode
());
vo
.
setShowQrCodeTime
(
ticketVo
.
getQrCodeShowTime
()
==
null
?
""
:
ticketVo
.
getQrCodeShowTime
());
}
else
{
orderTicketVo
.
setQrCode
(
""
);
vo
.
setIsShowQrCode
(
ticketVo
.
getIsShowCode
());
vo
.
setShowQrCodeTime
(
ticketVo
.
getQrCodeShowTime
()
==
null
?
""
:
ticketVo
.
getQrCodeShowTime
());
}
}
else
{
orderTicketVo
.
setQrCode
(
""
);
vo
.
setIsShowQrCode
(
0
);
vo
.
setShowQrCodeTime
(
""
);
}
currentTime
=
System
.
currentTimeMillis
()
-
currentTime
;
...
...
@@ -205,7 +211,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
break
;
}
OrderRefundListVo
data
=
OrderRefundListVo
.
getNew
();
if
(
item
.
getOrderRefundCode
().
length
()>
20
)
{
if
(
item
.
getOrderRefundCode
().
length
()
>
20
)
{
data
.
setOrderRefundCode
(
item
.
getOrderRefundCode
().
substring
(
item
.
getOrderRefundCode
().
length
()
-
10
));
}
data
.
setOrderRefundsId
(
item
.
getOrderRefundsId
());
...
...
@@ -233,7 +239,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
}
orderTicketVo
.
setOrderRefundListVos
(
orderRefundListVos
);
if
(
orderTicketVo
.
getOrderCode
().
length
()>
20
)
{
if
(
orderTicketVo
.
getOrderCode
().
length
()
>
20
)
{
orderTicketVo
.
setOrderCode
(
orderTicketVo
.
getOrderCode
().
substring
(
orderTicketVo
.
getOrderCode
().
length
()
-
10
));
}
vo
.
setOrderTicketVo
(
orderTicketVo
);
...
...
@@ -242,7 +248,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
log
.
info
(
UserPathDto
.
setData
(
"订单详情"
,
orderId
,
vo
));
return
vo
;
}
catch
(
Exception
e
)
{
log
.
info
(
"订单详情异常:"
,
e
);
log
.
info
(
"订单详情异常:"
,
e
);
return
null
;
}
}
...
...
@@ -280,8 +286,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
KylinPerformanceVo
performanceVo
=
dataUtils
.
getPerformanceVo
(
orderTicketVo
.
getPerformanceId
());
List
<
KylinOrderRefundsVo
>
kylinOrderRefundsVoBaseList
=
dataUtils
.
getOrderRefundVoByOrderId
(
orderTicketVo
.
getOrderTicketsId
());
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(!
orderTicketVo
.
getUserId
().
equals
(
uid
))
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20003"
));
}
...
...
@@ -303,7 +309,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
kylinOrderTicketEntitiesPreRefundVos
.
add
(
refundVo
);
}
orderTicketVo
.
setFieldName
(
performanceVo
.
getFieldName
());
if
(
orderTicketVo
.
getOrderCode
().
length
()>
20
)
{
if
(
orderTicketVo
.
getOrderCode
().
length
()
>
20
)
{
orderTicketVo
.
setOrderCode
(
orderTicketVo
.
getOrderCode
().
substring
(
orderTicketVo
.
getOrderCode
().
length
()
-
10
));
}
BeanUtils
.
copyProperties
(
orderTicketVo
,
vo
);
...
...
@@ -324,18 +330,18 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
KylinOrderTicketVo
orderTicketVo
=
dataUtils
.
getOrderTicketVo
(
orderId
);
KylinPerformanceVo
performanceVo
=
dataUtils
.
getPerformanceVo
(
orderTicketVo
.
getPerformanceId
());
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(!
orderTicketVo
.
getUserId
().
equals
(
uid
))
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20003"
));
}
}
orderTicketVo
.
setFieldName
(
performanceVo
.
getFieldName
());
if
(
orderTicketVo
.
getOrderCode
().
length
()>
20
)
{
if
(
orderTicketVo
.
getOrderCode
().
length
()
>
20
)
{
orderTicketVo
.
setOrderCode
(
orderTicketVo
.
getOrderCode
().
substring
(
orderTicketVo
.
getOrderCode
().
length
()
-
10
));
}
KylinOrderRefundsVo
kylinOrderRefundsVoBase
=
dataUtils
.
getOrderRefundVo
(
orderRefundId
);
if
(
kylinOrderRefundsVoBase
.
getOrderRefundCode
().
length
()>
20
)
{
if
(
kylinOrderRefundsVoBase
.
getOrderRefundCode
().
length
()
>
20
)
{
kylinOrderRefundsVoBase
.
setOrderRefundCode
(
kylinOrderRefundsVoBase
.
getOrderRefundCode
().
substring
(
kylinOrderRefundsVoBase
.
getOrderRefundCode
().
length
()
-
10
));
}
vo
.
setKylinOrderRefundsVoBaseList
(
kylinOrderRefundsVoBase
);
...
...
@@ -354,8 +360,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
String
uid
=
CurrentUtil
.
getCurrentUid
();
KylinOrderTicketVo
orderTicketVo
=
dataUtils
.
getOrderTicketVo
(
orderId
);
List
<
KylinOrderRefundsVo
>
kylinOrderRefundsVoBaseList
=
dataUtils
.
getOrderRefundVoByOrderId
(
orderTicketVo
.
getOrderTicketsId
());
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(
uid
.
equals
(
"809406"
)
||
uid
.
equals
(
"773650"
))
{
}
else
{
if
(!
orderTicketVo
.
getUserId
().
equals
(
uid
))
{
return
"无权查看"
;
}
...
...
@@ -580,7 +586,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
entitiesTable
.
setIsPayment
(
newIsPayment
);
entitiesTable
.
setUpdatedAt
(
time
);
log
.
info
(
"sqlsDataB data = "
+
entitiesTable
.
getIsPayment
());
log
.
info
(
"sqlsDataB data = "
+
entitiesTable
.
getIsPayment
());
sqlsDataB
.
add
(
new
Object
[]{
entitiesTable
.
getIsPayment
(),
entitiesTable
.
getUpdatedAt
(),
item
.
getOrderTicketEntitiesId
(),
now
,
now
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java
View file @
c08f2a62
...
...
@@ -278,6 +278,9 @@ public class DataUtils {
if
(
obj
==
null
)
{
// 固定条件
Query
query
=
getCommonWhere
();
// 排序
Sort
sortName
=
Sort
.
by
(
Sort
.
Direction
.
ASC
,
"sellTime"
);
query
.
with
(
sortName
);
// 今天的
HashMap
toDayTime
=
DateUtil
.
oneDayStartEnd
();
...
...
@@ -292,6 +295,9 @@ public class DataUtils {
// 固定条件
Query
queryT
=
getCommonWhere
();
// 排序
Sort
sortNameT
=
Sort
.
by
(
Sort
.
Direction
.
ASC
,
"sellTime"
);
queryT
.
with
(
sortNameT
);
// 三天的
Calendar
cal
=
Calendar
.
getInstance
();
...
...
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java
View file @
c08f2a62
...
...
@@ -909,7 +909,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
public
boolean
checkAgent
(
String
agentId
,
KylinTicketVo
ticketData
)
{
boolean
isAgent
=
ticketData
.
getIsAgent
()
==
1
;
if
(
isAgent
)
{
return
redisUtil
.
sHasKey
(
KylinRedisConst
.
AGENT
,
agentId
);
return
redisUtil
.
getDB15Redi
sHasKey
(
KylinRedisConst
.
AGENT
,
agentId
);
}
else
{
return
true
;
}
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/partner/KylinCheckUserPerformancesPartnerController.java
View file @
c08f2a62
...
...
@@ -57,9 +57,9 @@ public class KylinCheckUserPerformancesPartnerController {
public
ResponseDto
<
PageInfo
<
ChildPerformanceDao
>>
childPerformanceList
(
@RequestParam
(
"merchantId"
)
@NotNull
(
message
=
"商户ID不能为空"
)
String
merchantId
,
@RequestParam
(
"checkUserId"
)
@NotNull
(
message
=
"验票用户ID不能为空"
)
String
checkUserId
,
@RequestParam
(
"page"
)
@NotNull
(
message
=
"页数不能为空"
)
@Min
(
1
)
int
page
,
@RequestParam
(
"size"
)
@NotNull
(
message
=
"数量不能为空"
)
@Min
(
1
)
int
size
,
@RequestParam
(
"size"
)
@NotNull
(
message
=
"数量不能为空"
)
@Min
(
1
)
int
size
,
@RequestParam
(
"name"
)
String
name
)
{
return
userPerformancesPartnerService
.
childPerformanceList
(
merchantId
,
checkUserId
,
page
,
size
,
name
);
return
userPerformancesPartnerService
.
childPerformanceList
(
merchantId
,
checkUserId
,
page
,
size
,
name
);
}
@GetMapping
(
value
=
"unRelation"
)
...
...
@@ -70,6 +70,6 @@ public class KylinCheckUserPerformancesPartnerController {
@RequestParam
(
"page"
)
@NotNull
(
message
=
"页数不能为空"
)
@Min
(
1
)
int
page
,
@RequestParam
(
"size"
)
@NotNull
(
message
=
"数量不能为空"
)
@Min
(
1
)
int
size
,
@RequestParam
(
"name"
)
String
name
)
{
return
userPerformancesPartnerService
.
unChildPerformanceList
(
merchantId
,
checkUserId
,
page
,
size
,
name
);
return
userPerformancesPartnerService
.
unChildPerformanceList
(
merchantId
,
checkUserId
,
page
,
size
,
name
);
}
}
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPartnerServiceImpl.java
View file @
c08f2a62
...
...
@@ -57,6 +57,9 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
try
{
PageHelper
.
startPage
(
page
,
size
);
List
<
ChildListDao
>
data
=
checkUserMapper
.
childSimpleList
(
merchantId
,
mobile
);
for
(
ChildListDao
item
:
data
)
{
item
.
setMobile
(
item
.
getMobile
().
substring
(
0
,
3
)
+
"****"
+
item
.
getMobile
().
substring
(
7
));
}
pageInfo
=
new
PageInfo
(
data
);
return
pageInfo
;
}
catch
(
Exception
e
)
{
...
...
@@ -86,8 +89,8 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
public
ResponseDto
<
String
>
create
(
String
merchantId
,
String
name
,
String
pwd
,
String
mobile
)
{
try
{
int
count
=
checkUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
KylinCheckUser
.
class
).
eq
(
KylinCheckUser:
:
getMobile
,
mobile
).
eq
(
KylinCheckUser:
:
getStatus
,
1
));
if
(
count
>
0
)
{
int
count
=
checkUserMapper
.
selectCount
(
Wrappers
.
lambdaQuery
(
KylinCheckUser
.
class
).
eq
(
KylinCheckUser:
:
getMobile
,
mobile
).
eq
(
KylinCheckUser:
:
getStatus
,
1
));
if
(
count
>
0
)
{
return
ResponseDto
.
failure
(
"手机号已存在"
);
}
...
...
@@ -114,8 +117,8 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
@Override
public
ResponseDto
<
String
>
change
(
String
merchantId
,
String
checkUserId
,
String
name
,
String
pwd
,
String
mobile
)
{
try
{
KylinCheckUser
kylinCheckUser
=
checkUserMapper
.
selectOne
(
Wrappers
.
lambdaQuery
(
KylinCheckUser
.
class
).
eq
(
KylinCheckUser:
:
getMobile
,
mobile
).
eq
(
KylinCheckUser:
:
getStatus
,
1
));
if
(
kylinCheckUser
!=
null
&&
!
kylinCheckUser
.
getCheckUserId
().
equals
(
checkUserId
))
{
KylinCheckUser
kylinCheckUser
=
checkUserMapper
.
selectOne
(
Wrappers
.
lambdaQuery
(
KylinCheckUser
.
class
).
eq
(
KylinCheckUser:
:
getMobile
,
mobile
).
eq
(
KylinCheckUser:
:
getStatus
,
1
));
if
(
kylinCheckUser
!=
null
&&
!
kylinCheckUser
.
getCheckUserId
().
equals
(
checkUserId
))
{
return
ResponseDto
.
failure
(
"手机号已存在"
);
}
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinPerformancesPartnerServiceImpl.java
View file @
c08f2a62
...
...
@@ -112,10 +112,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
PerformancePartnerVo
createParam
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"performancesId"
).
is
(
step1Param
.
getPerformancesId
())),
PerformancePartnerVo
.
class
,
PerformancePartnerVo
.
class
.
getSimpleName
());
if
(
createParam
==
null
)
{
result
=
createStep1
(
step1Param
);
log
.
info
(
UserPathDto
.
setPartnerData
(
step1Param
.
getMerchantId
(),
"createStep1"
,
step1Param
,
result
));
log
.
info
(
UserPathDto
.
setPartnerData
(
step1Param
.
getMerchantId
(),
"createStep1"
,
step1Param
,
result
));
}
else
{
// 修改
result
=
updateStep1
(
step1Param
);
log
.
info
(
UserPathDto
.
setPartnerData
(
step1Param
.
getMerchantId
(),
"updateStep1"
,
step1Param
,
result
));
log
.
info
(
UserPathDto
.
setPartnerData
(
step1Param
.
getMerchantId
(),
"updateStep1"
,
step1Param
,
result
));
}
}
return
result
;
...
...
@@ -219,7 +219,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
if
(
null
!=
performanceStatus
)
{
data
.
setStatus
(
performanceStatus
.
getStatus
());
}
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"getStep1"
,
"performancesId="
+
performancesId
,
data
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"getStep1"
,
"performancesId="
+
performancesId
,
data
));
return
ResponseDto
.
success
(
data
);
}
...
...
@@ -232,10 +232,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
KylinPerformanceStatus
performanceStatus
=
performanceStatusMapper
.
selectOne
(
Wrappers
.
lambdaQuery
(
KylinPerformanceStatus
.
class
).
eq
(
KylinPerformanceStatus:
:
getPerformanceId
,
step2Param
.
getPerformancesId
()));
if
(
performanceStatus
==
null
||
performanceStatus
.
getStatus
()
==
0
||
performanceStatus
.
getStatus
()
==
4
)
{
result
=
createStep2
(
step2Param
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"createStep2"
,
step2Param
,
result
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"createStep2"
,
step2Param
,
result
));
}
else
if
(
performanceStatus
.
getStatus
()
==
1
||
performanceStatus
.
getStatus
()
==
3
||
performanceStatus
.
getStatus
()
==
6
||
performanceStatus
.
getStatus
()
==
7
||
performanceStatus
.
getStatus
()
==
8
||
performanceStatus
.
getStatus
()
==
9
)
{
// 修改
result
=
updateStep2
(
step2Param
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"updateStep2(step2Param"
,
step2Param
,
result
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"updateStep2(step2Param"
,
step2Param
,
result
));
}
else
if
(
performanceStatus
.
getStatus
()
==
10
)
{
result
=
ResponseDto
.
failure
(
"演出已结束不可修改"
);
}
...
...
@@ -384,7 +384,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
performanceStatus
.
setLimitCount
(
step2Param
.
getLimitCount
());
performanceStatusMapper
.
update
(
performanceStatus
,
Wrappers
.
lambdaQuery
(
KylinPerformanceStatus
.
class
).
eq
(
KylinPerformanceStatus:
:
getPerformanceId
,
performanceId
));
dataUtils
.
setPerformanceIsTrueName
(
performanceId
,
step2Param
.
getIsTrueName
());
dataUtils
.
setPerformanceIsTrueName
(
performanceId
,
step2Param
.
getIsTrueName
());
//提示:票种价格、售票时间、票种购票限制 直接生效 (演出购票限制,购票须知 演出是否实名 票种缺货登记 票种是否电子票 票种是否快递票 票种最低购买张数 票种是否显示二维码)
List
<
TicketTimesTicketCreatePartnerVo
>
timeList
=
kylinPerformanceMisVo
.
getTicketTimes
();
...
...
@@ -477,7 +477,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
}
performanceStep2Param
.
setTicketTimes
(
ticketTimesTicketCreatePartnerVoList
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"getStep2"
,
"performancesId="
+
performancesId
,
performanceStep2Param
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"getStep2"
,
"performancesId="
+
performancesId
,
performanceStep2Param
));
return
ResponseDto
.
success
(
performanceStep2Param
);
}
...
...
@@ -524,7 +524,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
}
// 判断状态
performanceVoTask
.
performanceVoStatus
(
performancesId
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"onLinePerformance"
,
"performancesId="
+
performancesId
,
"上线成功"
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"onLinePerformance"
,
"performancesId="
+
performancesId
,
"上线成功"
));
return
ResponseDto
.
success
(
"上线成功"
);
}
catch
(
Exception
e
)
{
log
.
debug
(
"上线失败"
,
e
);
...
...
@@ -546,7 +546,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
,
Wrappers
.
lambdaQuery
(
KylinPerformanceStatus
.
class
).
eq
(
KylinPerformanceStatus:
:
getPerformanceId
,
performancesId
));
performanceVoTask
.
performanceVoStatus
(
performancesId
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"outLinePerformance"
,
"performancesId="
+
performancesId
,
"下线成功"
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"outLinePerformance"
,
"performancesId="
+
performancesId
,
"下线成功"
));
return
ResponseDto
.
success
(
"下线成功"
);
}
else
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
20111
));
...
...
@@ -585,7 +585,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
mongoTemplate
.
insert
(
ticketItem
,
KylinTicketPartnerVo
.
class
.
getSimpleName
());
}
}
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"copyPerformance"
,
"performancesId="
+
performancesId
,
performancePartnerVo
.
getPerformancesId
()));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"copyPerformance"
,
"performancesId="
+
performancesId
,
performancePartnerVo
.
getPerformancesId
()));
return
performancePartnerVo
.
getPerformancesId
();
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
...
...
@@ -673,7 +673,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
Query
.
query
(
Criteria
.
where
(
"performancesId"
).
is
(
performancesId
)).
getQueryObject
(),
object
);
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"withdraw"
,
"performancesId="
+
performancesId
,
"撤回成功"
));
log
.
info
(
UserPathDto
.
setPartnerData
(
"0"
,
"withdraw"
,
"performancesId="
+
performancesId
,
"撤回成功"
));
return
ResponseDto
.
success
(
"撤回成功"
);
}
else
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
20116
));
...
...
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