记得上下班打卡 | 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
32e0cd59
Commit
32e0cd59
authored
Jun 04, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/dev' into dev
parents
e14983ba
adc4d8d5
Changes
16
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
16 changed files
with
483 additions
and
316 deletions
+483
-316
RefundApplyParam.java
...m/liquidnet/service/kylin/dto/param/RefundApplyParam.java
+0
-3
RefundBatchApplyParam.java
...uidnet/service/kylin/dto/param/RefundBatchApplyParam.java
+34
-0
RefundBatchSearchParam.java
...idnet/service/kylin/dto/param/RefundBatchSearchParam.java
+36
-0
KylinOrderRefundBatchAdminController.java
.../zhengzai/kylin/KylinOrderRefundBatchAdminController.java
+77
-141
refund.html
...ain/resources/templates/zhengzai/kylin/refund/refund.html
+0
-1
details.html
...sources/templates/zhengzai/kylin/refundBatch/details.html
+23
-0
refundBatch.html
...ces/templates/zhengzai/kylin/refundBatch/refundBatch.html
+214
-0
KylinOrderRefundsServiceImpl.java
...gzai/kylin/service/impl/KylinOrderRefundsServiceImpl.java
+0
-1
KylinRefundExecuteServiceImpl.java
...zai/kylin/service/impl/KylinRefundExecuteServiceImpl.java
+55
-18
KylinRefundHttpSubmitServiceImpl.java
.../kylin/service/impl/KylinRefundHttpSubmitServiceImpl.java
+0
-101
KylinRefundPerformancesAdminServiceImpl.java
...service/impl/KylinRefundPerformancesAdminServiceImpl.java
+39
-28
KylinOrderRefundBatches.java
...quidnet/service/kylin/entity/KylinOrderRefundBatches.java
+0
-6
KylinOrderRefundsMapper.java
...quidnet/service/kylin/mapper/KylinOrderRefundsMapper.java
+0
-1
KylinOrderTicketsMapper.java
...quidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
+1
-1
KylinOrderRefundsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderRefundsMapper.xml
+3
-14
KylinOrderTicketsMapper.xml
...iquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
+1
-1
No files found.
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/RefundApplyParam.java
View file @
32e0cd59
package
com
.
liquidnet
.
service
.
kylin
.
dto
.
param
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
javax.validation.constraints.NotNull
;
import
java.io.Serializable
;
import
java.util.List
;
...
...
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/RefundBatchApplyParam.java
0 → 100644
View file @
32e0cd59
package
com
.
liquidnet
.
service
.
kylin
.
dto
.
param
;
import
lombok.Data
;
import
java.io.Serializable
;
/**
* <p>
* 退款申请参数
* </p>
*
* @author jiangxiulong
* @since 2021-06-02 11:19 上午
*/
@Data
public
class
RefundBatchApplyParam
implements
Serializable
{
private
String
targetId
;
private
String
refundBatchId
;
private
String
ids
;
private
String
reason
;
private
Integer
status
;
private
Integer
refundStatus
;
private
String
reject
;
private
String
refuse
;
}
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/RefundBatchSearchParam.java
0 → 100644
View file @
32e0cd59
package
com
.
liquidnet
.
service
.
kylin
.
dto
.
param
;
import
io.swagger.annotations.ApiModelProperty
;
import
lombok.Data
;
import
javax.validation.constraints.NotNull
;
import
java.io.Serializable
;
/**
* <p>
* 退款回掉参数
* </p>
*
* @author jiangxiulong
* @since 2021-05-31 11:19 上午
*/
@Data
public
class
RefundBatchSearchParam
implements
Serializable
{
private
String
refundBatchId
;
private
String
targetId
;
private
Integer
status
;
private
String
createdAt
;
@ApiModelProperty
(
value
=
"页数"
,
example
=
"0"
)
@NotNull
(
message
=
"不能为空"
)
private
Integer
pageSize
;
@ApiModelProperty
(
value
=
"数量"
,
example
=
"20"
)
@NotNull
(
message
=
"不能为空"
)
private
Integer
pageNum
;
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/KylinOrderRefundBatchAdminController.java
View file @
32e0cd59
This diff is collapsed.
Click to expand it.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/refund/refund.html
View file @
32e0cd59
...
...
@@ -109,7 +109,6 @@
</div>
</div>
<th:block
th:include=
"include :: footer"
/>
{include file="zhengzai/kylin/refund/reviewView.html" /}
<script
th:inline=
"javascript"
>
var
detailFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refund:detail'
)}]];
var
reviewFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refund:review'
)}]];
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/refundBatch/details.html
0 → 100644
View file @
32e0cd59
<!DOCTYPE html>
<html
lang=
"zh"
xmlns:th=
"http://www.thymeleaf.org"
>
<head>
<th:block
th:include=
"include :: header('演出退款详情')"
/>
</head>
<body
class=
"white-bg"
>
<div
class=
"wrapper wrapper-content animated fadeInRight ibox-content"
>
<form
class=
"form-horizontal m-t"
id=
"signupForm"
>
<div
class=
"form-group"
>
<label
class=
"col-sm-2 control-label"
>
批量退款id:
</label>
<div
class=
"form-control-static"
th:text=
"${KylinOrderRefundsBatchVo.refundBatchId}"
>
</div>
</div>
<div
class=
"form-group"
>
<label
class=
"col-sm-2 control-label"
>
批量提交时间:
</label>
<div
class=
"form-control-static"
th:text=
"${KylinOrderRefundsBatchVo.createdAt}"
>
</div>
</div>
</form>
</div>
<th:block
th:include=
"include :: footer"
/>
</body>
</html>
\ No newline at end of file
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/refundBatch/refundBatch.html
0 → 100644
View file @
32e0cd59
<!DOCTYPE html>
<html
lang=
"zh"
xmlns:th=
"http://www.thymeleaf.org"
xmlns:shiro=
"http://www.pollix.at/thymeleaf/shiro"
>
<head>
<th:block
th:include=
"include :: header('演出退款列表')"
/>
</head>
<body
class=
"gray-bg"
>
<div
class=
"container-div"
>
<div
class=
"row"
>
<div
class=
"col-sm-12 search-collapse"
>
<form
id=
"formId"
>
<div
class=
"select-list"
>
<ul>
<li>
<label>
退款Id:
</label>
<input
type=
"text"
name=
"refundBatchId"
/>
</li>
<li>
<label>
演出Id:
</label>
<input
type=
"text"
name=
"targetId"
/>
</li>
<li>
<label>
退款状态:
</label>
<select
name=
"status"
>
<option
value=
""
>
全部
</option>
<option
value=
"1"
>
申请退款
</option>
<option
value=
"2"
>
取消退款
</option>
<option
value=
"3"
>
运营驳回审核
</option>
<option
value=
"4"
>
运营通过审核
</option>
<option
value=
"5"
>
财务驳回审核
</option>
<option
value=
"6"
>
财务通过审核
</option>
</select>
</li>
<li>
<a
class=
"btn btn-primary btn-rounded btn-sm"
onclick=
"$.table.search()"
><i
class=
"fa fa-search"
></i>
搜索
</a>
<a
class=
"btn btn-warning btn-rounded btn-sm"
onclick=
"$.form.reset()"
><i
class=
"fa fa-refresh"
></i>
重置
</a>
</li>
</ul>
</div>
</form>
</div>
<div
class=
"btn-group-sm"
id=
"toolbar"
role=
"group"
>
<a
class=
"btn btn-success"
onclick=
"apply()"
shiro:hasPermission=
"kylin:refundBatch:apply"
>
添加
</a>
</div>
<div
class=
"col-sm-12 select-table table-bordered"
>
<table
id=
"bootstrap-table"
></table>
</div>
<form
id=
"appTest"
>
<div
class=
"select-list"
>
<ul>
<li>
<input
type=
"text"
name=
"targetId"
th:value=
"67689474263547904"
/>
<input
type=
"text"
name=
"reason"
th:value=
"222"
/>
</li>
</ul>
</div>
</form>
<div
class=
"wrapper wrapper-content animated fadeInRight ibox-content hidden"
id=
"form-refund-review"
>
<form
class=
"form-horizontal m"
>
<div
class=
"row"
>
<div
class=
"col-sm-12"
>
<div
class=
"form-group"
>
<label
class=
"col-xs-2 control-label layui-required"
>
备注:
</label>
<div
class=
"col-xs-10"
>
<textarea
name=
"remark"
maxlength=
"500"
class=
"form-control layui-required"
rows=
"3"
></textarea>
</div>
</div>
</div>
</div>
</form>
</div>
</div>
</div>
<th:block
th:include=
"include :: footer"
/>
<script
th:inline=
"javascript"
>
var
detailFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refundBatch:detail'
)}]];
var
reviewFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refundBatch:review'
)}]];
var
executeFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refundBatch:execute'
)}]];
var
cancelFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refundBatch:cancel'
)}]];
var
reapplyFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:refundBatch:reapply'
)}]];
var
prefix
=
ctx
+
"kylin/refundBatch"
;
function
apply
()
{
var
data
=
$
(
'#appTest'
).
serializeArray
();
$
.
operate
.
save
(
prefix
+
"/apply"
,
data
);
}
function
review
(
id
)
{
data
=
{
"refundBatchId"
:
id
};
layer
.
open
({
type
:
1
,
fixed
:
false
,
maxmin
:
true
,
title
:
'一审'
,
area
:
[
'500px'
,
'220px'
],
content
:
$
(
"#form-refund-review"
).
html
(),
btn
:
[
"通过"
,
'拒绝'
],
yes
:
function
(
index
,
layero
)
{
var
remark
=
$
(
layero
).
find
(
"[name='remark']"
).
val
();
if
(
!
remark
)
{
layer
.
msg
(
"请填写备注"
);
return
false
;
}
data
[
'reject'
]
=
remark
;
data
[
'status'
]
=
1
;
$
.
operate
.
save
(
prefix
+
"/review"
,
data
);
layer
.
close
(
index
)
},
btn2
:
function
(
index
,
layero
)
{
var
remark
=
$
(
layero
).
find
(
"[name='remark']"
).
val
();
if
(
!
remark
)
{
layer
.
msg
(
"请填写备注"
);
return
false
;
}
data
[
'reject'
]
=
remark
;
data
[
'status'
]
=
5
;
$
.
operate
.
save
(
prefix
+
"/review"
,
data
);
}
});
}
function
execute
(
id
)
{
data
=
{
"refundBatchId"
:
id
};
layer
.
open
({
type
:
1
,
fixed
:
false
,
maxmin
:
true
,
title
:
'二审'
,
area
:
[
'500px'
,
'220px'
],
content
:
$
(
"#form-refund-review"
).
html
(),
btn
:
[
"通过"
,
'拒绝'
],
yes
:
function
(
index
,
layero
)
{
var
remark
=
$
(
layero
).
find
(
"[name='remark']"
).
val
();
if
(
!
remark
)
{
layer
.
msg
(
"请填写备注"
);
return
false
;
}
data
[
'refuse'
]
=
remark
;
data
[
'status'
]
=
7
;
$
.
operate
.
save
(
prefix
+
"/execute"
,
data
);
layer
.
close
(
index
)
},
btn2
:
function
(
index
,
layero
)
{
var
remark
=
$
(
layero
).
find
(
"[name='remark']"
).
val
();
if
(
!
remark
)
{
layer
.
msg
(
"请填写备注"
);
return
false
;
}
data
[
'refuse'
]
=
remark
;
data
[
'status'
]
=
8
;
$
.
operate
.
save
(
prefix
+
"/execute"
,
data
);
// return false;
}
});
}
$
(
function
()
{
var
options
=
{
url
:
prefix
+
"/list"
,
detailUrl
:
prefix
+
"/details/{id}"
,
cancelUrl
:
prefix
+
"/cancel"
,
reapplyUrl
:
prefix
+
"/reapply"
,
columns
:
[{
checkbox
:
true
},
{
field
:
'refundBatchId'
,
title
:
'退款id'
},
{
field
:
'status'
,
title
:
'状态'
},
{
field
:
'targetId'
,
title
:
'演出id'
},
{
field
:
'createdAt'
,
title
:
'申请时间'
},
{
title
:
'操作'
,
align
:
'center'
,
formatter
:
function
(
value
,
row
,
index
)
{
var
actions
=
[];
actions
.
push
(
'<a class="btn btn-info btn-xs'
+
detailFlag
+
'" href="javascript:void(0)" onclick="$.operate.detailTab(
\'
'
+
row
.
refundBatchId
+
'
\'
)"></i>查看</a> '
);
actions
.
push
(
'<a class="btn btn-success btn-xs '
+
reviewFlag
+
'" href="javascript:void(0)" onclick="review(
\'
'
+
row
.
refundBatchId
+
'
\'
)"></i>一审</a> '
);
actions
.
push
(
'<a class="btn btn-primary btn-xs '
+
executeFlag
+
'" href="javascript:void(0)" onclick="execute(
\'
'
+
row
.
refundBatchId
+
'
\'
)"></i>二审</a> '
);
actions
.
push
(
'<a class="btn btn-danger btn-xs '
+
cancelFlag
+
'" href="javascript:void(0)" onclick="$.operate.remove(
\'
'
+
row
.
refundBatchId
+
'
\'
,
\'
确定取消退款申请吗?
\'
, table.options.cancelUrl)"></i>取消</a> '
);
actions
.
push
(
'<a class="btn btn-warning btn-xs '
+
reapplyFlag
+
'" href="javascript:void(0)" onclick="$.operate.remove(
\'
'
+
row
.
refundBatchId
+
'
\'
,
\'
确定重新提交退款审核吗?
\'
, table.options.reapplyUrl)"></i>重新提交</a> '
);
return
actions
.
join
(
''
);
}
}]
};
$
.
table
.
init
(
options
);
});
</script>
</body>
</html>
\ No newline at end of file
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinOrderRefundsServiceImpl.java
View file @
32e0cd59
...
...
@@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.github.pagehelper.PageHelper
;
import
com.github.pagehelper.PageInfo
;
import
com.liquidnet.client.admin.common.utils.ShiroUtils
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils
;
import
com.liquidnet.commons.lang.util.BeanUtil
;
import
com.liquidnet.service.kylin.constant.KylinTableStatusConst
;
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundExecuteServiceImpl.java
View file @
32e0cd59
...
...
@@ -3,6 +3,8 @@ package com.liquidnet.client.admin.zhengzai.kylin.service.impl;
import
com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper
;
import
com.liquidnet.common.cache.redis.util.RedisUtil
;
import
com.liquidnet.service.kylin.constant.KylinTableStatusConst
;
import
com.liquidnet.service.kylin.dto.param.RefundApplyParam
;
import
com.liquidnet.service.kylin.dto.param.RefundBatchApplyParam
;
import
com.liquidnet.service.kylin.entity.KylinOrderRefunds
;
import
com.liquidnet.service.kylin.entity.KylinOrderTicketEntities
;
import
com.liquidnet.service.kylin.entity.KylinOrderTickets
;
...
...
@@ -13,8 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.stereotype.Service
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.stream.Collectors
;
/**
* <p>
...
...
@@ -40,23 +42,30 @@ public class KylinRefundExecuteServiceImpl {
RedisUtil
redisUtil
;
@Autowired
private
Kylin
RefundHttpSubmitServiceImpl
kylinRefundHttpSubmit
ServiceImpl
;
private
Kylin
OrderRefundsServiceImpl
kylinOrderRefunds
ServiceImpl
;
@Async
public
void
refundBatchApply
(
String
targetId
,
String
refundBatchId
,
HashMap
<
String
,
Object
>
otherParam
)
throws
Exception
{
public
void
refundBatchApply
(
String
targetId
,
String
refundBatchId
,
String
reason
)
throws
Exception
{
RefundApplyParam
refundApplyParam
=
new
RefundApplyParam
();
int
count
;
int
limitNum
=
100
;
int
mid
=
0
;
do
{
List
<
KylinOrderTickets
>
orderList
=
kylinOrderTicketsMapper
.
getOrder
Entities
(
targetId
,
mid
,
limitNum
);
List
<
KylinOrderTickets
>
orderList
=
kylinOrderTicketsMapper
.
getOrder
List
(
targetId
,
mid
,
limitNum
);
for
(
KylinOrderTickets
v
:
orderList
)
{
for
(
KylinOrderTickets
order
:
orderList
)
{
List
<
KylinOrderTicketEntities
>
entitiesList
=
kylinOrderTicketEntitiesMapper
.
selectList
(
new
UpdateWrapper
<
KylinOrderTicketEntities
>().
eq
(
"order_id"
,
v
.
getOrderTicketsId
())
new
UpdateWrapper
<
KylinOrderTicketEntities
>().
eq
(
"order_id"
,
order
.
getOrderTicketsId
())
.
eq
(
"is_payment"
,
"yes"
)
);
List
<
String
>
ticketEntityIds
=
entitiesList
.
stream
().
map
(
KylinOrderTicketEntities
->
KylinOrderTicketEntities
.
getOrderTicketEntitiesId
()).
collect
(
Collectors
.
toList
());
// 请求php接口
kylinRefundHttpSubmitServiceImpl
.
httpApply
(
v
,
entitiesList
,
otherParam
,
refundBatchId
);
refundApplyParam
.
setOrderRefundBatchesId
(
refundBatchId
);
refundApplyParam
.
setReason
(
reason
);
refundApplyParam
.
setOrderTicketsId
(
order
.
getOrderTicketsId
());
refundApplyParam
.
setTicketEntityIds
(
ticketEntityIds
);
refundApplyParam
.
setRefundPriceExpress
(
order
.
getPriceExpress
().
doubleValue
());
Boolean
res
=
kylinOrderRefundsServiceImpl
.
refundApply
(
refundApplyParam
);
}
count
=
orderList
.
size
();
...
...
@@ -66,11 +75,13 @@ public class KylinRefundExecuteServiceImpl {
}
@Async
public
void
refundBatchStatus
(
String
refundBatchId
,
HashMap
<
String
,
Object
>
otherParam
)
throws
Exception
{
public
void
refundBatchStatus
(
RefundBatchApplyParam
refundBatchApplyParam
,
String
type
)
throws
Exception
{
String
refundBatchId
=
refundBatchApplyParam
.
getRefundBatchId
();
Integer
status
=
refundBatchApplyParam
.
getStatus
();
// 处理查询订单状态
Integer
[]
whereStatus
=
{};
Integer
whereType
=
KylinTableStatusConst
.
ORDER_REFUND_TYPE_APPLY
;
switch
(
(
String
)
otherParam
.
get
(
"type"
)
)
{
switch
(
type
)
{
case
"reapply"
:
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
};
break
;
...
...
@@ -78,18 +89,18 @@ public class KylinRefundExecuteServiceImpl {
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPLY
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
};
break
;
case
"review"
:
if
(
otherParam
.
get
(
"status"
)
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
)
{
// 通过申请
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
)
{
// 通过申请
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPLY
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
};
}
if
(
otherParam
.
get
(
"status"
)
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
)
{
// 驳回申请
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
)
{
// 驳回申请
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPLY
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
};
}
break
;
case
"execute"
:
if
(
otherParam
.
get
(
"status"
)
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_UNFILLED
)
{
// 执行退款
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_UNFILLED
)
{
// 执行退款
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_ERROR
};
}
if
(
otherParam
.
get
(
"status"
)
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
)
{
// 拒绝退款
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
)
{
// 拒绝退款
whereStatus
=
new
Integer
[]{
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
,
KylinTableStatusConst
.
ORDER_REFUND_STATUS_ERROR
};
}
break
;
...
...
@@ -105,12 +116,38 @@ public class KylinRefundExecuteServiceImpl {
List
<
String
>
refundIds
=
null
;
if
(!
refundList
.
isEmpty
())
{
for
(
KylinOrderRefunds
v
:
refundList
)
{
String
refundId
=
v
.
getRefundId
();
refundIds
.
add
(
refundId
);
refundIds
=
refundList
.
stream
().
map
(
KylinOrderRefunds
->
KylinOrderRefunds
.
getOrderRefundsId
()).
collect
(
Collectors
.
toList
());
RefundApplyParam
refundApplyParam
=
new
RefundApplyParam
();
refundApplyParam
.
setIds
(
refundIds
);
Boolean
res
=
null
;
switch
(
type
)
{
case
"reapply"
:
res
=
kylinOrderRefundsServiceImpl
.
refundReapply
(
refundApplyParam
);
break
;
case
"cancel"
:
res
=
kylinOrderRefundsServiceImpl
.
refundCancel
(
refundApplyParam
);
break
;
case
"review"
:
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_APPROVED
)
{
// 通过申请
res
=
kylinOrderRefundsServiceImpl
.
refundApproved
(
refundApplyParam
);
}
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REJECT
)
{
// 驳回申请
res
=
kylinOrderRefundsServiceImpl
.
refundReject
(
refundApplyParam
);
}
break
;
case
"execute"
:
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_UNFILLED
)
{
// 执行退款
res
=
kylinOrderRefundsServiceImpl
.
refundUnfilled
(
refundApplyParam
);
}
if
(
status
==
KylinTableStatusConst
.
ORDER_REFUND_STATUS_REFUSE
)
{
// 拒绝退款
res
=
kylinOrderRefundsServiceImpl
.
refundRefuse
(
refundApplyParam
);
}
break
;
default
:
throw
new
Exception
(
"type异常,无法操作"
);
}
// 请求php接口
kylinRefundHttpSubmitServiceImpl
.
httpStatus
(
refundIds
,
otherParam
);
}
count
=
refundList
.
size
();
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundHttpSubmitServiceImpl.java
deleted
100644 → 0
View file @
e14983ba
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
service
.
impl
;
import
com.fasterxml.jackson.databind.JsonNode
;
import
com.liquidnet.commons.lang.util.HttpUtil
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.kylin.entity.KylinOrderTicketEntities
;
import
com.liquidnet.service.kylin.entity.KylinOrderTickets
;
import
org.springframework.scheduling.annotation.Async
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.LinkedMultiValueMap
;
import
org.springframework.util.MultiValueMap
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
/**
* <p>
* 后台退款 服务实现类
* </p>
*
* @author jiangxiulong
* @since 2021-05-26 13:00 下午
*/
@Service
public
class
KylinRefundHttpSubmitServiceImpl
{
@Async
public
void
httpApply
(
KylinOrderTickets
orderInfo
,
List
<
KylinOrderTicketEntities
>
entitiesList
,
HashMap
<
String
,
Object
>
otherParam
,
String
refundBatchId
)
throws
Exception
{
String
postUrl
=
"apply"
;
// 构造退款数据
List
<
String
>
ticketEntityIds
=
null
;
if
(!
entitiesList
.
isEmpty
())
{
for
(
KylinOrderTicketEntities
v
:
entitiesList
)
{
String
orderTicketsId
=
v
.
getOrderTicketEntitiesId
();
ticketEntityIds
.
add
(
orderTicketsId
);
}
}
HashMap
<
String
,
Object
>
refundData
=
new
HashMap
();
refundData
.
put
(
"ticket_entity_ids"
,
ticketEntityIds
);
refundData
.
put
(
"matter_items"
,
new
ArrayList
());
//搭售不处理
if
(
ticketEntityIds
.
isEmpty
())
{
throw
new
Exception
(
"查询详情出错"
);
}
// 发起退款申请
MultiValueMap
<
String
,
String
>
headers
=
new
LinkedMultiValueMap
();
headers
.
add
(
"Authorization"
,
otherParam
.
get
(
"token"
).
toString
());
MultiValueMap
<
String
,
String
>
formParams
=
new
LinkedMultiValueMap
();
formParams
.
add
(
"order_type"
,
"order_ticket"
);
formParams
.
add
(
"order_id"
,
orderInfo
.
getOrderTicketsId
());
formParams
.
add
(
"batch_id"
,
refundBatchId
);
formParams
.
add
(
"reason"
,
otherParam
.
get
(
"reason"
).
toString
());
formParams
.
add
(
"refund_data"
,
JsonUtils
.
toJson
(
refundData
));
/*HashMap<String, Object> postParams = new HashMap();
postParams.put("headers", headers);
postParams.put("form_params", formParams);*/
// 请求提审接口参数
String
postResult
=
HttpUtil
.
post
(
postUrl
,
formParams
,
headers
);
JsonNode
postResultNew
=
JsonUtils
.
fromJson
(
postResult
,
JsonNode
.
class
);
// 请求提审接口结果
if
(
postResultNew
.
get
(
"message"
).
toString
()
!=
"OK"
)
{
throw
new
Exception
(
"申请退款出错"
);
}
}
@Async
public
void
httpStatus
(
List
<
String
>
refundIds
,
HashMap
<
String
,
Object
>
otherParam
)
throws
Exception
{
String
postUrl
=
"reapply"
;
// 发起退款申请
MultiValueMap
<
String
,
String
>
headers
=
new
LinkedMultiValueMap
();
headers
.
add
(
"Authorization"
,
otherParam
.
get
(
"token"
).
toString
());
MultiValueMap
<
String
,
String
>
formParams
=
new
LinkedMultiValueMap
();
formParams
.
put
(
"ids"
,
refundIds
);
String
reject
=
otherParam
.
get
(
"reject"
).
toString
();
if
(
reject
.
isEmpty
())
reject
=
""
;
String
refuse
=
otherParam
.
get
(
"refuse"
).
toString
();
if
(
refuse
.
isEmpty
())
refuse
=
""
;
String
status
=
(
String
)
otherParam
.
get
(
"status"
);
if
(
status
.
isEmpty
())
status
=
"0"
;
formParams
.
add
(
"reject"
,
reject
);
formParams
.
add
(
"status"
,
status
);
formParams
.
add
(
"refuse"
,
refuse
);
// 请求提审接口参数
String
postResult
=
HttpUtil
.
post
(
postUrl
,
formParams
,
headers
);
JsonNode
postResultNew
=
JsonUtils
.
fromJson
(
postResult
,
JsonNode
.
class
);
// 请求提审接口结果
if
(
postResultNew
.
get
(
"message"
).
toString
()
!=
"OK"
)
{
throw
new
Exception
(
"操作出错"
);
}
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinRefundPerformancesAdminServiceImpl.java
View file @
32e0cd59
This diff is collapsed.
Click to expand it.
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinOrderRefundBatches.java
View file @
32e0cd59
package
com
.
liquidnet
.
service
.
kylin
.
entity
;
import
java.math.BigDecimal
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
java.time.LocalDateTime
;
...
...
@@ -40,11 +39,6 @@ public class KylinOrderRefundBatches implements Serializable {
*/
private
Integer
status
;
/**
* 批量执行时间
*/
private
LocalDateTime
executorAt
;
private
LocalDateTime
createdAt
;
private
LocalDateTime
updatedAt
;
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderRefundsMapper.java
View file @
32e0cd59
...
...
@@ -16,7 +16,6 @@ import java.util.Map;
* @since 2021-05-26
*/
public
interface
KylinOrderRefundsMapper
extends
BaseMapper
<
KylinOrderRefunds
>
{
List
<
KylinOrderRefunds
>
getRefundList
(
Integer
whereType
,
String
refundBatchId
,
Integer
[]
whereStatus
,
int
mid
,
int
limitNum
);
double
refundedTotalPrice
(
String
orderTicketsId
);
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderTicketsMapper.java
View file @
32e0cd59
...
...
@@ -23,5 +23,5 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
Double
getTotalPrice
(
String
targetId
,
String
selectFields
,
String
[]
paymentType
);
// 获取订单和购票信息
List
getOrder
Entities
(
String
targetId
,
int
mid
,
int
limitNum
);
List
getOrder
List
(
String
targetId
,
int
mid
,
int
limitNum
);
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderRefundsMapper.xml
View file @
32e0cd59
...
...
@@ -2,20 +2,9 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper
namespace=
"com.liquidnet.service.kylin.mapper.KylinOrderRefundsMapper"
>
<select
id=
"getRefundList"
resultType=
"com.liquidnet.service.kylin.entity.KylinOrderRefunds"
>
SELECT refunds_id
FROM kylin_refunds
<where>
r.performance_id=#{targetId}
AND type=#{whereType}
AND batch_id=#{refundBatchId}
AND o.mid>#{mid}
AND status IN
<foreach
collection=
"whereStatus"
item=
"status"
index=
"index"
open=
"("
close=
")"
separator=
","
>
#{status}
</foreach>
</where>
LIMIT #{limitNum}
<select
id=
"getRefundList"
parameterType=
"java.lang.String"
resultType=
"com.liquidnet.service.kylin.entity.KylinOrderRefunds"
>
SELECT order_refunds_id
FROM kylin_order_refunds
</select>
<select
id=
"refundedTotalPrice"
resultType=
"java.lang.Double"
>
SELECT SUM('price')
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml
View file @
32e0cd59
...
...
@@ -30,7 +30,7 @@
</foreach>
</where>
</select>
<select
id=
"getOrder
Entities
"
resultType=
"java.util.List"
>
<select
id=
"getOrder
List
"
resultType=
"java.util.List"
>
SELECT o.mid, order_tickets_id, number, price_actual, performance_title
FROM kylin_order_tickets AS o
JOIN kylin_order_ticket_relations AS r ON r.order_id = o.order_tickets_id
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment