记得上下班打卡 | 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
52c57d1a
Commit
52c57d1a
authored
May 18, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
票 场次
parent
909efc52
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
279 additions
and
287 deletions
+279
-287
IKylinTicketTimesPartnerService.java
...ylin/service/partner/IKylinTicketTimesPartnerService.java
+6
-5
IKylinTicketsPartnerService.java
...ce/kylin/service/partner/IKylinTicketsPartnerService.java
+9
-10
KylinTicketTimesPartnerController.java
...controller/partner/KylinTicketTimesPartnerController.java
+3
-20
KylinTicketsPartnerController.java
...lin/controller/partner/KylinTicketsPartnerController.java
+6
-39
KylinTicketTimesPartnerServiceImpl.java
...vice/impl/partner/KylinTicketTimesPartnerServiceImpl.java
+73
-70
KylinTicketsPartnerServiceImpl.java
.../service/impl/partner/KylinTicketsPartnerServiceImpl.java
+156
-143
errors.properties
...t-service-kylin-impl/src/main/resources/errors.properties
+26
-0
No files found.
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/partner/IKylinTicketTimesPartnerService.java
View file @
52c57d1a
package
com
.
liquidnet
.
service
.
kylin
.
service
.
partner
;
import
com.baomidou.mybatisplus.extension.service.IService
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dto.param.CreateTicketTimesParam
;
import
com.liquidnet.service.kylin.dto.vo.partner.TicketTimesPartnerVo
;
import
com.liquidnet.service.kylin.entity.KylinTicketTimes
;
...
...
@@ -23,35 +24,35 @@ public interface IKylinTicketTimesPartnerService extends IService<KylinTicketTim
* @param createTicketTimesParam 相关参数
* @return vo
*/
TicketTimesPartnerVo
createTimesSummary
(
CreateTicketTimesParam
createTicketTimesParam
);
ResponseDto
<
TicketTimesPartnerVo
>
createTimesSummary
(
CreateTicketTimesParam
createTicketTimesParam
);
/**
* 未通过审核创建场次
* @param createTicketTimesParam 相关参数
* @return vo
*/
TicketTimesPartnerVo
createTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
ResponseDto
<
TicketTimesPartnerVo
>
createTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
/**
* 通过审核后创建场次
* @param createTicketTimesParam 相关参数
* @return 相关参数
*/
TicketTimesPartnerVo
addNewTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
ResponseDto
<
TicketTimesPartnerVo
>
addNewTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
/**
* 删除 场次(只有未审核通过可删除)
* @param ticketTimesId 场次id
* @return boolean
*/
Boolean
deleteTimes
(
String
ticketTimesId
);
ResponseDto
<
String
>
deleteTimes
(
String
ticketTimesId
);
/**
* 修改场次信息
* @param createTicketTimesParam 相关参数
* @return vo
*/
TicketTimesPartnerVo
changeTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
ResponseDto
<
TicketTimesPartnerVo
>
changeTimes
(
CreateTicketTimesParam
createTicketTimesParam
);
/**
* 根据演出id 获取全部场次数据
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/partner/IKylinTicketsPartnerService.java
View file @
52c57d1a
package
com
.
liquidnet
.
service
.
kylin
.
service
.
partner
;
import
com.baomidou.mybatisplus.extension.service.IService
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dto.param.TicketCreateParam
;
import
com.liquidnet.service.kylin.dto.vo.partner.TicketPartnerVo
;
import
com.liquidnet.service.kylin.entity.KylinTickets
;
...
...
@@ -22,42 +23,42 @@ public interface IKylinTicketsPartnerService extends IService<KylinTickets> {
* @param ticketCreateParam 相关参数
* @return vo
*/
TicketPartnerVo
createTicketSummary
(
TicketCreateParam
ticketCreateParam
);
ResponseDto
<
TicketPartnerVo
>
createTicketSummary
(
TicketCreateParam
ticketCreateParam
);
/**
* 未通过审核创建票
* @param ticketCreateParam 相关参数
* @return vo
*/
TicketPartnerVo
createTicket
(
TicketCreateParam
ticketCreateParam
);
ResponseDto
<
TicketPartnerVo
>
createTicket
(
TicketCreateParam
ticketCreateParam
);
/**
* 通过审核后创建票
* @param ticketCreateParam 相关参数
* @return vo
*/
TicketPartnerVo
addNewTicket
(
TicketCreateParam
ticketCreateParam
);
ResponseDto
<
TicketPartnerVo
>
addNewTicket
(
TicketCreateParam
ticketCreateParam
);
/**
* 修改票
* @param ticketCreateParam 相关参数
* @return vo
*/
TicketPartnerVo
updateTicket
(
TicketCreateParam
ticketCreateParam
);
ResponseDto
<
TicketPartnerVo
>
updateTicket
(
TicketCreateParam
ticketCreateParam
);
/**
* 删除 票(只有未审核通过可删除)
* @param ticketsId 票id
* @return boolean
*/
boolean
deleteTicket
(
String
ticketsId
);
ResponseDto
<
String
>
deleteTicket
(
String
ticketsId
);
/**
* 复制票
* @param ticketsId 票id
* @return vo
*/
TicketPartnerVo
copyTicket
(
String
ticketsId
);
ResponseDto
<
TicketPartnerVo
>
copyTicket
(
String
ticketsId
);
/**
* 整个场次票 提交 审核
...
...
@@ -85,14 +86,12 @@ public interface IKylinTicketsPartnerService extends IService<KylinTickets> {
* @param ticketsId 票id
* @return boolean
*/
boolean
onLine
(
String
ticketsId
);
ResponseDto
<
String
>
onLine
(
String
ticketsId
);
/**
* 票下线
* @param ticketsId 票id
* @return boolean
*/
boolean
outLine
(
String
ticketsId
);
//购票须知
ResponseDto
<
String
>
outLine
(
String
ticketsId
);
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/partner/KylinTicketTimesPartnerController.java
View file @
52c57d1a
...
...
@@ -31,38 +31,21 @@ public class KylinTicketTimesPartnerController {
@ApiOperation
(
value
=
"创建场次"
)
@ApiResponse
(
response
=
TicketTimesPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
TicketTimesPartnerVo
>
createTimesSummary
(
@RequestBody
CreateTicketTimesParam
createTicketTimesParam
)
{
TicketTimesPartnerVo
result
=
null
;
result
=
ticketTimesPartnerService
.
createTimesSummary
(
createTicketTimesParam
);
if
(
null
==
result
)
{
return
ResponseDto
.
failure
(
"创建失败"
);
}
else
{
return
ResponseDto
.
success
(
result
);
}
return
ticketTimesPartnerService
.
createTimesSummary
(
createTicketTimesParam
);
}
@DeleteMapping
(
value
=
""
)
@ApiOperation
(
value
=
"删除场次"
)
@ApiResponse
(
response
=
TicketTimesPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
String
>
deleteTimes
(
@RequestParam
(
"ticketTimesId"
)
String
ticketTimesId
)
{
boolean
result
=
ticketTimesPartnerService
.
deleteTimes
(
ticketTimesId
);
if
(
result
)
{
return
ResponseDto
.
success
(
"删除成功"
);
}
else
{
return
ResponseDto
.
failure
(
"删除失败"
);
}
return
ticketTimesPartnerService
.
deleteTimes
(
ticketTimesId
);
}
@PutMapping
(
value
=
""
)
@ApiOperation
(
value
=
"修改场次"
)
@ApiResponse
(
response
=
TicketTimesPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
TicketTimesPartnerVo
>
changeTimes
(
@RequestBody
CreateTicketTimesParam
createTicketTimesParam
)
{
TicketTimesPartnerVo
result
=
null
;
result
=
ticketTimesPartnerService
.
changeTimes
(
createTicketTimesParam
);
if
(
null
==
result
)
{
return
ResponseDto
.
failure
(
"修改失败"
);
}
else
{
return
ResponseDto
.
success
(
result
);
}
return
ticketTimesPartnerService
.
changeTimes
(
createTicketTimesParam
);
}
@GetMapping
(
value
=
"/details"
)
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/partner/KylinTicketsPartnerController.java
View file @
52c57d1a
...
...
@@ -31,51 +31,28 @@ public class KylinTicketsPartnerController {
@ApiOperation
(
value
=
"创建票务"
)
@ApiResponse
(
response
=
TicketPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
TicketPartnerVo
>
createTicketSummary
(
@RequestBody
TicketCreateParam
ticketCreateParam
)
{
TicketPartnerVo
result
=
null
;
result
=
ticketsPartnerService
.
createTicketSummary
(
ticketCreateParam
);
if
(
null
==
result
)
{
return
ResponseDto
.
failure
(
"创建票务失败"
);
}
else
{
return
ResponseDto
.
success
(
result
);
}
return
ticketsPartnerService
.
createTicketSummary
(
ticketCreateParam
);
}
@PutMapping
(
value
=
""
)
@ApiOperation
(
value
=
"修改票务"
)
@ApiResponse
(
response
=
TicketPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
TicketPartnerVo
>
updateTicket
(
@RequestBody
TicketCreateParam
ticketCreateParam
)
{
TicketPartnerVo
result
=
null
;
result
=
ticketsPartnerService
.
updateTicket
(
ticketCreateParam
);
if
(
null
==
result
)
{
return
ResponseDto
.
failure
(
"修改票务失败"
);
}
else
{
return
ResponseDto
.
success
(
result
);
}
return
ticketsPartnerService
.
updateTicket
(
ticketCreateParam
);
}
@DeleteMapping
(
value
=
""
)
@ApiOperation
(
value
=
"删除票务"
)
@ApiResponse
(
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
String
>
deleteTicket
(
@RequestParam
(
"ticketsId"
)
String
ticketsId
)
{
boolean
result
=
ticketsPartnerService
.
deleteTicket
(
ticketsId
);
if
(!
result
)
{
return
ResponseDto
.
failure
(
"删除票务失败"
);
}
else
{
return
ResponseDto
.
success
(
"删除成功"
);
}
return
ticketsPartnerService
.
deleteTicket
(
ticketsId
);
}
@PostMapping
(
value
=
"/copy"
)
@ApiOperation
(
value
=
"复制票务"
)
@ApiResponse
(
response
=
TicketPartnerVo
.
class
,
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
TicketPartnerVo
>
copyTicket
(
@RequestParam
(
"ticketsId"
)
String
ticketsId
)
{
TicketPartnerVo
result
=
null
;
result
=
ticketsPartnerService
.
copyTicket
(
ticketsId
);
if
(
null
==
result
)
{
return
ResponseDto
.
failure
(
"复制票务失败"
);
}
else
{
return
ResponseDto
.
success
(
result
);
}
return
ticketsPartnerService
.
copyTicket
(
ticketsId
);
}
@GetMapping
(
value
=
"/details"
)
...
...
@@ -95,23 +72,13 @@ public class KylinTicketsPartnerController {
@ApiOperation
(
value
=
"票上线"
)
@ApiResponse
(
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
String
>
onLine
(
@RequestParam
(
"ticketsId"
)
String
ticketsId
)
{
boolean
result
=
ticketsPartnerService
.
onLine
(
ticketsId
);
if
(!
result
)
{
return
ResponseDto
.
failure
(
"操作失败"
);
}
else
{
return
ResponseDto
.
success
(
"操作成功"
);
}
return
ticketsPartnerService
.
onLine
(
ticketsId
);
}
@PostMapping
(
value
=
"/outLine"
)
@ApiOperation
(
value
=
"票下线"
)
@ApiResponse
(
code
=
200
,
message
=
"接口返回对象参数"
)
public
ResponseDto
<
String
>
outLine
(
@RequestParam
(
"ticketsId"
)
String
ticketsId
)
{
boolean
result
=
ticketsPartnerService
.
outLine
(
ticketsId
);
if
(!
result
)
{
return
ResponseDto
.
failure
(
"操作失败"
);
}
else
{
return
ResponseDto
.
success
(
"操作成功"
);
}
return
ticketsPartnerService
.
outLine
(
ticketsId
);
}
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinTicketTimesPartnerServiceImpl.java
View file @
52c57d1a
...
...
@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.liquidnet.commons.lang.util.IDGenerator
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.base.ErrorMapping
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dto.param.CreateTicketTimesParam
;
import
com.liquidnet.service.kylin.dto.vo.partner.TicketTimesPartnerVo
;
import
com.liquidnet.service.kylin.entity.KylinPerformanceStatus
;
...
...
@@ -50,9 +52,6 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
@Autowired
private
MongoConverter
mongoConverter
;
@Autowired
private
KylinTicketTimesMapper
ticketTimesMapper
;
@Autowired
private
KylinTicketTimeRelationMapper
ticketTimeRelationMapper
;
...
...
@@ -60,8 +59,8 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
private
KylinPerformanceStatusMapper
performanceStatusMapper
;
@Override
public
TicketTimesPartnerVo
createTimesSummary
(
CreateTicketTimesParam
createTicketTimesParam
)
{
TicketTimesPartnerVo
ticketTimesPartnerVo
=
null
;
public
ResponseDto
<
TicketTimesPartnerVo
>
createTimesSummary
(
CreateTicketTimesParam
createTicketTimesParam
)
{
ResponseDto
<
TicketTimesPartnerVo
>
ticketTimesPartnerVo
=
null
;
//获取演出状态
KylinPerformanceStatus
performanceStatus
=
performanceStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinPerformanceStatus
>().
eq
(
"performance_id"
,
createTicketTimesParam
.
getPerformancesId
()));
...
...
@@ -79,75 +78,81 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
}
@Override
public
TicketTimesPartnerVo
createTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
// 获取 主键id
String
ticketTimesId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
// 标题
String
title
=
""
;
if
(
createTicketTimesParam
.
getType
()
==
1
)
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
else
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
))
+
"-"
+
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
// mongo 操作
TicketTimesPartnerVo
ticketTimesPartnerVo
=
new
TicketTimesPartnerVo
();
ticketTimesPartnerVo
.
setTicketTimesId
(
ticketTimesId
);
ticketTimesPartnerVo
.
setUseStart
(
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setUseEnd
(
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setStatus
(
1
);
ticketTimesPartnerVo
.
setTitle
(
title
);
ticketTimesPartnerVo
.
setPerformancesId
(
createTicketTimesParam
.
getPerformancesId
());
ticketTimesPartnerVo
.
setType
(
createTicketTimesParam
.
getType
());
ticketTimesPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketTimesPartnerVo
data
=
mongoTemplate
.
insert
(
ticketTimesPartnerVo
,
TicketTimesPartnerVo
.
class
.
getSimpleName
()
);
public
ResponseDto
<
TicketTimesPartnerVo
>
createTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
try
{
// 获取 主键id
String
ticketTimesId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
// 标题
String
title
=
""
;
if
(
createTicketTimesParam
.
getType
()
==
1
)
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
else
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
))
+
"-"
+
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
// mongo 操作
TicketTimesPartnerVo
ticketTimesPartnerVo
=
new
TicketTimesPartnerVo
();
ticketTimesPartnerVo
.
setTicketTimesId
(
ticketTimesId
);
ticketTimesPartnerVo
.
setUseStart
(
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setUseEnd
(
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setStatus
(
1
);
ticketTimesPartnerVo
.
setTitle
(
title
);
ticketTimesPartnerVo
.
setPerformancesId
(
createTicketTimesParam
.
getPerformancesId
());
ticketTimesPartnerVo
.
setType
(
createTicketTimesParam
.
getType
());
ticketTimesPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
mongoTemplate
.
insert
(
ticketTimesPartnerVo
,
TicketTimesPartnerVo
.
class
.
getSimpleName
()
);
return
ticketTimesPartnerVo
;
return
ResponseDto
.
success
(
ticketTimesPartnerVo
);
}
catch
(
Exception
e
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20105"
));
}
}
@Override
public
TicketTimesPartnerVo
addNewTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
// 获取 主键id
String
ticketTimesId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
// 标题
String
title
=
""
;
if
(
createTicketTimesParam
.
getType
()
==
1
)
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
else
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
))
+
"-"
+
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
public
ResponseDto
<
TicketTimesPartnerVo
>
addNewTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
try
{
// 获取 主键id
String
ticketTimesId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
// 标题
String
title
=
""
;
if
(
createTicketTimesParam
.
getType
()
==
1
)
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
else
{
title
=
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
))
+
"-"
+
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm"
));
}
// mongo 操作
TicketTimesPartnerVo
ticketTimesPartnerVo
=
new
TicketTimesPartnerVo
();
ticketTimesPartnerVo
.
setTicketTimesId
(
ticketTimesId
);
ticketTimesPartnerVo
.
setUseStart
(
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setUseEnd
(
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setStatus
(-
1
);
ticketTimesPartnerVo
.
setTitle
(
title
);
ticketTimesPartnerVo
.
setPerformancesId
(
createTicketTimesParam
.
getPerformancesId
());
ticketTimesPartnerVo
.
setType
(
createTicketTimesParam
.
getType
());
ticketTimesPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketTimesPartnerVo
data
=
mongoTemplate
.
insert
(
ticketTimesPartnerVo
,
TicketTimesPartnerVo
.
class
.
getSimpleName
()
);
return
ticketTimesPartnerVo
;
// mongo 操作
TicketTimesPartnerVo
ticketTimesPartnerVo
=
new
TicketTimesPartnerVo
();
ticketTimesPartnerVo
.
setTicketTimesId
(
ticketTimesId
);
ticketTimesPartnerVo
.
setUseStart
(
createTicketTimesParam
.
getUseStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setUseEnd
(
createTicketTimesParam
.
getUseEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketTimesPartnerVo
.
setStatus
(-
1
);
ticketTimesPartnerVo
.
setTitle
(
title
);
ticketTimesPartnerVo
.
setPerformancesId
(
createTicketTimesParam
.
getPerformancesId
());
ticketTimesPartnerVo
.
setType
(
createTicketTimesParam
.
getType
());
ticketTimesPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
mongoTemplate
.
insert
(
ticketTimesPartnerVo
,
TicketTimesPartnerVo
.
class
.
getSimpleName
()
);
return
ResponseDto
.
success
(
ticketTimesPartnerVo
);
}
catch
(
Exception
e
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20101"
));
}
}
@Override
public
Boolean
deleteTimes
(
String
ticketTimesId
)
{
public
ResponseDto
<
String
>
deleteTimes
(
String
ticketTimesId
)
{
try
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
TicketTimesPartnerVo
data
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketTimesId
)),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
if
(
data
.
getStatus
()
==
0
)
{
return
false
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20106"
))
;
}
KylinTicketTimeRelation
ticketTimeRelation
=
ticketTimeRelationMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketTimeRelation
>().
eq
(
"times_id"
,
ticketTimesId
));
...
...
@@ -165,21 +170,21 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
object
,
new
FindOneAndUpdateOptions
().
returnDocument
(
ReturnDocument
.
AFTER
)
);
return
true
;
return
ResponseDto
.
success
(
"删除成功"
)
;
}
else
{
return
false
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20106"
))
;
}
}
else
{
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketTimesId
)),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
return
true
;
return
ResponseDto
.
success
()
;
}
}
catch
(
Exception
e
)
{
return
false
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20102"
))
;
}
}
@Override
public
TicketTimesPartnerVo
changeTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
public
ResponseDto
<
TicketTimesPartnerVo
>
changeTimes
(
CreateTicketTimesParam
createTicketTimesParam
)
{
try
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
String
title
=
""
;
...
...
@@ -205,11 +210,9 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
object
,
new
FindOneAndUpdateOptions
().
returnDocument
(
ReturnDocument
.
AFTER
)
);
return
JsonUtils
.
fromJson
(
doc
.
toJson
(),
TicketTimesPartnerVo
.
class
);
return
ResponseDto
.
success
(
JsonUtils
.
fromJson
(
doc
.
toJson
(),
TicketTimesPartnerVo
.
class
));
}
catch
(
Exception
e
)
{
return
null
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20103"
))
;
}
}
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinTicketsPartnerServiceImpl.java
View file @
52c57d1a
...
...
@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.commons.lang.util.IDGenerator
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.base.ErrorMapping
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.constant.KylinRedisConst
;
import
com.liquidnet.service.kylin.dto.param.TicketCreateParam
;
import
com.liquidnet.service.kylin.dto.vo.TicketVo
;
...
...
@@ -51,9 +53,6 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
@Autowired
private
MongoConverter
mongoConverter
;
@Autowired
private
RedisUtil
redisUtil
;
@Autowired
private
KylinPerformanceStatusMapper
performanceStatusMapper
;
...
...
@@ -70,10 +69,10 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
private
KylinTicketRelationsMapper
ticketRelationsMapper
;
@Override
public
TicketPartnerVo
createTicketSummary
(
TicketCreateParam
ticketCreateParam
)
{
TicketPartnerVo
ticketPartnerVo
=
null
;
public
ResponseDto
<
TicketPartnerVo
>
createTicketSummary
(
TicketCreateParam
ticketCreateParam
)
{
ResponseDto
<
TicketPartnerVo
>
ticketPartnerVo
=
null
;
//获取演出状态
TicketTimesPartnerVo
timesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
TicketTimesPartnerVo
timesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
if
(
null
!=
timesPartnerVo
)
{
KylinPerformanceStatus
performanceStatus
=
performanceStatusMapper
.
selectOne
(
...
...
@@ -96,83 +95,91 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
}
@Override
public
TicketPartnerVo
createTicket
(
TicketCreateParam
ticketCreateParam
)
{
// 获取 主键id
String
ticketsId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
ticketCreateParam
.
setTicketsId
(
ticketsId
);
// mongo 操作
TicketPartnerVo
ticketPartnerVo
=
new
TicketPartnerVo
();
BeanUtils
.
copyProperties
(
ticketCreateParam
,
ticketPartnerVo
);
ticketPartnerVo
.
setTicketsId
(
ticketsId
);
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeStart
(
ticketCreateParam
.
getTimeStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeEnd
(
ticketCreateParam
.
getTimeEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketTimesPartnerVo
ticketTimesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setUseStart
(
ticketTimesPartnerVo
.
getUseStart
());
ticketPartnerVo
.
setUseEnd
(
ticketTimesPartnerVo
.
getUseEnd
());
ticketPartnerVo
.
setType
(
ticketTimesPartnerVo
.
getType
());
ticketPartnerVo
.
setStatus
(
0
);
ticketPartnerVo
.
setDefault
();
if
(
ticketCreateParam
.
getIsExpress
()
==
1
)
{
ticketPartnerVo
.
setTimeEndExpress
(
ticketCreateParam
.
getTimeEndExpress
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
public
ResponseDto
<
TicketPartnerVo
>
createTicket
(
TicketCreateParam
ticketCreateParam
)
{
try
{
// 获取 主键id
String
ticketsId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
ticketCreateParam
.
setTicketsId
(
ticketsId
);
if
(
ticketCreateParam
.
getIsShowCode
()
==
1
)
{
ticketPartnerVo
.
setQrCodeShowTime
(
ticketCreateParam
.
getQrCodeShowTime
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
// mongo 操作
TicketPartnerVo
ticketPartnerVo
=
new
TicketPartnerVo
();
BeanUtils
.
copyProperties
(
ticketCreateParam
,
ticketPartnerVo
);
ticketPartnerVo
.
setTicketsId
(
ticketsId
);
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeStart
(
ticketCreateParam
.
getTimeStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeEnd
(
ticketCreateParam
.
getTimeEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
TicketTimesPartnerVo
ticketTimesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setUseStart
(
ticketTimesPartnerVo
.
getUseStart
());
ticketPartnerVo
.
setUseEnd
(
ticketTimesPartnerVo
.
getUseEnd
());
ticketPartnerVo
.
setType
(
ticketTimesPartnerVo
.
getType
());
ticketPartnerVo
.
setStatus
(
0
);
ticketPartnerVo
.
setDefault
();
return
ticketPartnerVo
;
if
(
ticketCreateParam
.
getIsExpress
()
==
1
)
{
ticketPartnerVo
.
setTimeEndExpress
(
ticketCreateParam
.
getTimeEndExpress
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
if
(
ticketCreateParam
.
getIsShowCode
()
==
1
)
{
ticketPartnerVo
.
setQrCodeShowTime
(
ticketCreateParam
.
getQrCodeShowTime
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
return
ResponseDto
.
success
(
ticketPartnerVo
);
}
catch
(
Exception
e
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20105"
));
}
}
@Override
public
TicketPartnerVo
addNewTicket
(
TicketCreateParam
ticketCreateParam
)
{
// 获取 主键id
String
ticketsId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
ticketCreateParam
.
setTicketsId
(
ticketsId
);
// mongo 操作
TicketPartnerVo
ticketPartnerVo
=
new
TicketPartnerVo
();
BeanUtils
.
copyProperties
(
ticketCreateParam
,
ticketPartnerVo
);
ticketPartnerVo
.
setTicketsId
(
ticketsId
);
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeStart
(
ticketCreateParam
.
getTimeStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeEnd
(
ticketCreateParam
.
getTimeEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketTimesPartnerVo
ticketTimesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setUseStart
(
ticketTimesPartnerVo
.
getUseStart
());
ticketPartnerVo
.
setUseEnd
(
ticketTimesPartnerVo
.
getUseEnd
());
ticketPartnerVo
.
setType
(
ticketTimesPartnerVo
.
getType
());
ticketPartnerVo
.
setStatus
(-
2
);
ticketPartnerVo
.
setDefault
();
if
(
ticketCreateParam
.
getIsExpress
()
==
1
)
{
ticketPartnerVo
.
setTimeEndExpress
(
ticketCreateParam
.
getTimeEndExpress
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
public
ResponseDto
<
TicketPartnerVo
>
addNewTicket
(
TicketCreateParam
ticketCreateParam
)
{
try
{
// 获取 主键id
String
ticketsId
=
IDGenerator
.
nextSnowId
().
toString
();
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
ticketCreateParam
.
setTicketsId
(
ticketsId
);
if
(
ticketCreateParam
.
getIsShowCode
()
==
1
)
{
ticketPartnerVo
.
setQrCodeShowTime
(
ticketCreateParam
.
getQrCodeShowTime
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
// mongo 操作
TicketPartnerVo
ticketPartnerVo
=
new
TicketPartnerVo
();
BeanUtils
.
copyProperties
(
ticketCreateParam
,
ticketPartnerVo
);
ticketPartnerVo
.
setTicketsId
(
ticketsId
);
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeStart
(
ticketCreateParam
.
getTimeStart
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTimeEnd
(
ticketCreateParam
.
getTimeEnd
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
TicketTimesPartnerVo
ticketTimesPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketTimesId"
).
is
(
ticketCreateParam
.
getTimesId
())),
TicketTimesPartnerVo
.
class
,
TicketTimesPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setUseStart
(
ticketTimesPartnerVo
.
getUseStart
());
ticketPartnerVo
.
setUseEnd
(
ticketTimesPartnerVo
.
getUseEnd
());
ticketPartnerVo
.
setType
(
ticketTimesPartnerVo
.
getType
());
ticketPartnerVo
.
setStatus
(-
2
);
ticketPartnerVo
.
setDefault
();
return
ticketPartnerVo
;
if
(
ticketCreateParam
.
getIsExpress
()
==
1
)
{
ticketPartnerVo
.
setTimeEndExpress
(
ticketCreateParam
.
getTimeEndExpress
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
if
(
ticketCreateParam
.
getIsShowCode
()
==
1
)
{
ticketPartnerVo
.
setQrCodeShowTime
(
ticketCreateParam
.
getQrCodeShowTime
().
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
}
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
return
ResponseDto
.
success
(
ticketPartnerVo
);
}
catch
(
Exception
e
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20101"
));
}
}
@Override
public
TicketPartnerVo
updateTicket
(
TicketCreateParam
ticketCreateParam
)
{
public
ResponseDto
<
TicketPartnerVo
>
updateTicket
(
TicketCreateParam
ticketCreateParam
)
{
try
{
String
ticketId
=
ticketCreateParam
.
getTicketsId
();
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
...
...
@@ -200,14 +207,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
);
TicketPartnerVo
ticketPartnerVoData
=
JsonUtils
.
fromJson
(
doc
.
toJson
(),
TicketPartnerVo
.
class
);
return
ticketPartnerVoData
;
return
ResponseDto
.
success
(
ticketPartnerVoData
)
;
}
catch
(
Exception
e
)
{
return
null
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20103"
))
;
}
}
@Override
public
boolean
deleteTicket
(
String
ticketsId
)
{
public
ResponseDto
<
String
>
deleteTicket
(
String
ticketsId
)
{
try
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
...
...
@@ -216,7 +223,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
if
(
ticketRelations
==
null
)
{
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketsId
)),
TicketPartnerVo
.
class
,
TicketPartnerVo
.
class
.
getSimpleName
());
return
true
;
return
ResponseDto
.
success
(
"删除成功"
)
;
}
KylinTicketTimeRelation
ticketTimeRelation
=
ticketTimeRelationMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketTimeRelation
>().
eq
(
"times_id"
,
ticketRelations
.
getTimesId
()));
...
...
@@ -236,31 +243,32 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
object
,
new
FindOneAndUpdateOptions
().
returnDocument
(
ReturnDocument
.
AFTER
)
);
return
true
;
return
ResponseDto
.
success
(
"删除成功"
)
;
}
else
{
return
false
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20106"
))
;
}
}
catch
(
Exception
e
)
{
return
false
;
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20102"
))
;
}
}
@Override
public
TicketPartnerVo
copyTicket
(
String
ticketsId
)
{
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
public
ResponseDto
<
TicketPartnerVo
>
copyTicket
(
String
ticketsId
)
{
try
{
// 获取 当前时间 -> 创建时间
LocalDateTime
createdAt
=
LocalDateTime
.
now
();
TicketPartnerVo
ticketPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketsId
)),
TicketPartnerVo
.
class
,
TicketPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTicketsId
(
IDGenerator
.
nextSnowId
().
toString
());
TicketPartnerVo
ticketPartnerVo
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketsId
)),
TicketPartnerVo
.
class
,
TicketPartnerVo
.
class
.
getSimpleName
());
ticketPartnerVo
.
setCreatedAt
(
createdAt
.
format
(
DateTimeFormatter
.
ofPattern
(
"yyyy-MM-dd HH:mm:ss"
)));
ticketPartnerVo
.
setTicketsId
(
IDGenerator
.
nextSnowId
().
toString
());
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
redisUtil
.
hset
(
KylinRedisConst
.
TICKET
,
ticketsId
,
ticketPartnerVo
);
return
ticketPartnerVo
;
TicketPartnerVo
data
=
mongoTemplate
.
insert
(
ticketPartnerVo
,
TicketPartnerVo
.
class
.
getSimpleName
()
);
return
ResponseDto
.
success
(
ticketPartnerVo
);
}
catch
(
Exception
e
)
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20107"
));
}
}
@Override
...
...
@@ -289,65 +297,70 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
}
@Override
public
boolean
onLine
(
String
ticketsId
)
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
KylinTicketStatus
ticketStatus
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
if
(
ticketStatus
.
getStatus
()
>=
3
&&
ticketStatus
.
getStatus
()
!=
4
&&
ticketStatus
.
getStatus
()
!=
6
)
{
//未提审||被拒绝
//mysql
KylinTicketStatus
changeStatus
=
new
KylinTicketStatus
();
changeStatus
.
setUpdatedAt
(
updatedAt
);
changeStatus
.
setStatus
(
6
);
ticketStatusMapper
.
update
(
changeStatus
,
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
// mongo 操作
KylinTicketStatus
ticketStatusMongo
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
).
between
(
"status"
,
1
,
10
).
ne
(
"status"
,
7
));
KylinTicketRelations
ticketRelation
=
ticketRelationsMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketRelations
>().
eq
(
"ticket_id"
,
ticketsId
));
KylinTickets
tickets
=
ticketsMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTickets
>().
eq
(
"tickets_id"
,
ticketsId
)
);
TicketVo
ticketVo
=
new
TicketVo
();
ticketVo
.
setTimeId
(
ticketRelation
.
getTimesId
());
ticketVo
.
setTicket
(
tickets
);
ticketVo
.
setTicketStatus
(
ticketStatusMongo
);
public
ResponseDto
<
String
>
onLine
(
String
ticketsId
)
{
try
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
KylinTicketStatus
ticketStatus
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
if
(
ticketStatus
.
getStatus
()
>=
3
&&
ticketStatus
.
getStatus
()
!=
4
&&
ticketStatus
.
getStatus
()
!=
6
)
{
//未提审||被拒绝
//mysql
KylinTicketStatus
changeStatus
=
new
KylinTicketStatus
();
changeStatus
.
setUpdatedAt
(
updatedAt
);
changeStatus
.
setStatus
(
6
);
ticketStatusMapper
.
update
(
changeStatus
,
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
boolean
ticketExists
=
mongoTemplate
.
exists
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVo
.
getTicketsId
())),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
if
(!
ticketExists
)
{
mongoTemplate
.
insert
(
ticketVo
,
TicketVo
.
class
.
getSimpleName
()
// mongo 操作
KylinTicketStatus
ticketStatusMongo
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
).
between
(
"status"
,
1
,
10
).
ne
(
"status"
,
7
));
KylinTicketRelations
ticketRelation
=
ticketRelationsMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketRelations
>().
eq
(
"ticket_id"
,
ticketsId
));
KylinTickets
tickets
=
ticketsMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTickets
>().
eq
(
"tickets_id"
,
ticketsId
)
);
}
//TODO 修改misVo
return
true
;
}
else
{
return
false
;
TicketVo
ticketVo
=
new
TicketVo
();
ticketVo
.
setTimeId
(
ticketRelation
.
getTimesId
());
ticketVo
.
setTicket
(
tickets
);
ticketVo
.
setTicketStatus
(
ticketStatusMongo
);
boolean
ticketExists
=
mongoTemplate
.
exists
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVo
.
getTicketsId
())),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
if
(!
ticketExists
)
{
mongoTemplate
.
insert
(
ticketVo
,
TicketVo
.
class
.
getSimpleName
()
);
}
return
ResponseDto
.
success
(
"上线成功"
);
}
else
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20110"
));
}
}
catch
(
Exception
e
){
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20108"
));
}
}
@Override
public
boolean
outLine
(
String
ticketsId
)
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
KylinTicketStatus
ticketStatus
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
if
(
ticketStatus
.
getStatus
()
>=
3
&&
ticketStatus
.
getStatus
()
!=
4
&&
ticketStatus
.
getStatus
()
!=
7
)
{
//未提审||被拒绝
//mysql
KylinTicketStatus
changeStatus
=
new
KylinTicketStatus
();
changeStatus
.
setUpdatedAt
(
updatedAt
);
changeStatus
.
setStatus
(
7
);
ticketStatusMapper
.
update
(
changeStatus
,
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
// mongo 操作
TicketVo
ticketVoItem
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketsId
)),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
TicketIgnoreVo
ticketIgnoreVo
=
new
TicketIgnoreVo
();
BeanUtils
.
copyProperties
(
ticketVoItem
,
ticketIgnoreVo
);
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVoItem
.
getTicketsId
())),
TicketIgnoreVo
.
class
,
TicketIgnoreVo
.
class
.
getSimpleName
());
mongoTemplate
.
insert
(
ticketIgnoreVo
,
TicketIgnoreVo
.
class
.
getSimpleName
());
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVoItem
.
getTicketsId
())),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
//TODO 删除misVo
return
true
;
}
else
{
return
false
;
public
ResponseDto
<
String
>
outLine
(
String
ticketsId
)
{
try
{
LocalDateTime
updatedAt
=
LocalDateTime
.
now
();
KylinTicketStatus
ticketStatus
=
ticketStatusMapper
.
selectOne
(
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
if
(
ticketStatus
.
getStatus
()
>=
3
&&
ticketStatus
.
getStatus
()
!=
4
&&
ticketStatus
.
getStatus
()
!=
7
)
{
//未提审||被拒绝
//mysql
KylinTicketStatus
changeStatus
=
new
KylinTicketStatus
();
changeStatus
.
setUpdatedAt
(
updatedAt
);
changeStatus
.
setStatus
(
7
);
ticketStatusMapper
.
update
(
changeStatus
,
new
UpdateWrapper
<
KylinTicketStatus
>().
eq
(
"ticket_id"
,
ticketsId
));
// mongo 操作
TicketVo
ticketVoItem
=
mongoTemplate
.
findOne
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketsId
)),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
TicketIgnoreVo
ticketIgnoreVo
=
new
TicketIgnoreVo
();
BeanUtils
.
copyProperties
(
ticketVoItem
,
ticketIgnoreVo
);
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVoItem
.
getTicketsId
())),
TicketIgnoreVo
.
class
,
TicketIgnoreVo
.
class
.
getSimpleName
());
mongoTemplate
.
insert
(
ticketIgnoreVo
,
TicketIgnoreVo
.
class
.
getSimpleName
());
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"ticketsId"
).
is
(
ticketVoItem
.
getTicketsId
())),
TicketVo
.
class
,
TicketVo
.
class
.
getSimpleName
());
return
ResponseDto
.
success
(
"下线成功"
);
}
else
{
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20111"
));
}
}
catch
(
Exception
e
){
return
ResponseDto
.
failure
(
ErrorMapping
.
get
(
"20109"
));
}
}
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/resources/errors.properties
0 → 100644
View file @
52c57d1a
#APP ERROR
20001
=
验证码发送失败
20002
=
验证码无效
20003
=
20004
=
20005
=
手机号获取失败,请更换登录方式
20006
=
第三方账号未注册
20007
=
#APP PARTNER
20101
=
添加失败
20102
=
删除失败
20103
=
修改失败
20104
=
查询失败
20105
=
创建失败
20106
=
不可删除
20107
=
复制失败
20108
=
上线失败
20109
=
下线失败
20110
=
不可上线
20111
=
不可下线
#APP JDM
20201
=
\ No newline at end of file
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