记得上下班打卡 | 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
0701f8de
Commit
0701f8de
authored
Jun 25, 2021
by
anjiabin
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'dev' into test
parents
9d1ef70d
5a3090e3
Changes
11
Hide whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
295 additions
and
88 deletions
+295
-88
PerformanceExpressSearchAdminParam.java
...e/kylin/dto/param/PerformanceExpressSearchAdminParam.java
+4
-0
IKylinOrderExpress.java
...m/liquidnet/service/kylin/service/IKylinOrderExpress.java
+16
-0
PerformancesExpressController.java
...troller/zhengzai/kylin/PerformancesExpressController.java
+13
-14
performanceOrderList.html
...ngzai/kylin/performancesExpress/performanceOrderList.html
+4
-2
PerformancesExpressServiceImpl.java
...ai/kylin/service/impl/PerformancesExpressServiceImpl.java
+78
-1
ShunfengSignUtils.java
.../client/admin/zhengzai/kylin/utils/ShunfengSignUtils.java
+10
-4
KylinOrderExpress.java
...com/liquidnet/service/kylin/entity/KylinOrderExpress.java
+50
-0
KylinOrderExpressMapper.java
...quidnet/service/kylin/mapper/KylinOrderExpressMapper.java
+16
-0
KylinPerformancesMapper.xml
...iquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
+78
-67
db_kylin_structure.sql
.../liquidnet-service-kylin-impl/docu/db_kylin_structure.sql
+23
-0
KylinPerformancesServiceImpl.java
...vice/kylin/service/impl/KylinPerformancesServiceImpl.java
+3
-0
No files found.
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/PerformanceExpressSearchAdminParam.java
View file @
0701f8de
...
@@ -2,6 +2,8 @@ package com.liquidnet.service.kylin.dto.param;
...
@@ -2,6 +2,8 @@ package com.liquidnet.service.kylin.dto.param;
import
lombok.Data
;
import
lombok.Data
;
import
java.util.List
;
@Data
@Data
public
class
PerformanceExpressSearchAdminParam
{
public
class
PerformanceExpressSearchAdminParam
{
...
@@ -24,4 +26,6 @@ public class PerformanceExpressSearchAdminParam {
...
@@ -24,4 +26,6 @@ public class PerformanceExpressSearchAdminParam {
private
String
expressContacts
;
private
String
expressContacts
;
private
String
expressPhone
;
private
String
expressPhone
;
private
List
<
String
>
ids
;
}
}
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinOrderExpress.java
0 → 100644
View file @
0701f8de
package
com
.
liquidnet
.
service
.
kylin
.
service
;
import
com.baomidou.mybatisplus.extension.service.IService
;
import
com.liquidnet.service.kylin.entity.KylinOrderExpress
;
/**
* <p>
* 订单快递 服务类
* </p>
*
* @author jiangxiulong
* @since 2021-05-02
*/
public
interface
IKylinOrderExpress
extends
IService
<
KylinOrderExpress
>
{
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/PerformancesExpressController.java
View file @
0701f8de
package
com
.
liquidnet
.
client
.
admin
.
web
.
controller
.
zhengzai
.
kylin
;
package
com
.
liquidnet
.
client
.
admin
.
web
.
controller
.
zhengzai
.
kylin
;
import
com.liquidnet.client.admin.common.core.controller.BaseController
;
import
com.liquidnet.client.admin.common.core.controller.BaseController
;
import
com.liquidnet.client.admin.common.core.domain.AjaxResult
;
import
com.liquidnet.client.admin.common.core.page.TableDataInfo
;
import
com.liquidnet.client.admin.common.core.page.TableDataInfo
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.impl.PerformancesExpressServiceImpl
;
import
com.liquidnet.client.admin.zhengzai.kylin.service.impl.PerformancesExpressServiceImpl
;
import
com.liquidnet.
client.admin.zhengzai.kylin.utils.ShunfengSignUtils
;
import
com.liquidnet.
service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dao.PerformanceExpressPerformanceListAdminDao
;
import
com.liquidnet.service.kylin.dao.PerformanceExpressPerformanceListAdminDao
;
import
com.liquidnet.service.kylin.dao.PerformanceExpressPerformanceOrderListAdminDao
;
import
com.liquidnet.service.kylin.dao.PerformanceExpressPerformanceOrderListAdminDao
;
import
com.liquidnet.service.kylin.dto.param.PerformanceExpressSearchAdminParam
;
import
com.liquidnet.service.kylin.dto.param.PerformanceExpressSearchAdminParam
;
...
@@ -40,8 +41,6 @@ public class PerformancesExpressController extends BaseController {
...
@@ -40,8 +41,6 @@ public class PerformancesExpressController extends BaseController {
@Autowired
@Autowired
private
PerformancesExpressServiceImpl
performancesExpressServiceImpl
;
private
PerformancesExpressServiceImpl
performancesExpressServiceImpl
;
private
ShunfengSignUtils
shunfengSignUtils
;
/**
/**
* 查询演出列表
* 查询演出列表
*/
*/
...
@@ -83,17 +82,17 @@ public class PerformancesExpressController extends BaseController {
...
@@ -83,17 +82,17 @@ public class PerformancesExpressController extends BaseController {
@RequiresPermissions
(
"kylin:performancesExpress:placeOrder"
)
@RequiresPermissions
(
"kylin:performancesExpress:placeOrder"
)
@PostMapping
(
"/placeOrder"
)
@PostMapping
(
"/placeOrder"
)
@ResponseBody
@ResponseBody
public
boolean
placeOrder
(
)
{
public
AjaxResult
placeOrder
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
// 请求body companyId参数值和APPID一致!!!
ResponseDto
res
=
performancesExpressServiceImpl
.
placeOrder
(
performanceExpressSearchAdminParam
);
String
body
=
"{\"dContact\":\"王昆\",\"companyId\":{{APP_ID}},\"jContact\":\"顺丰\",\"jTel\":\"111\",\"jMobile\":null,\"jAddress\":\"马甸\",\"dTel\":\"064756935\",\"dMobile\":null,\"dAddress\":\"北京市朝阳区花家地金兴路1号院5号楼1单元202\",\"custid\":\"7551234567\",\"payMethod\":\"0\",\"expressType\":\"1\",\"packagesNo\":\"1\",\"depositumInfo\":\"TCL空调\",\"depositumNo\":\"1\",\"remark\":null,\"isCollection\":\"1\",\"collectionMoney\":\"10.00\",\"isReceipt\":\"0\",\"receipt\":null}"
;
try
{
// 时间戳
if
(
res
.
isSuccess
())
{
long
currentTimeMillis
=
System
.
currentTimeMilli
s
();
return
succes
s
();
System
.
out
.
println
(
"时间戳:"
+
currentTimeMillis
);
}
else
{
return
error
(
res
.
getMessage
());
// 生成签名并请求
}
String
result
=
shunfengSignUtils
.
generateSignatureAndRequest
(
currentTimeMillis
+
""
,
body
,
"/order/v1/placeOrder"
);
}
catch
(
Exception
e
)
{
System
.
out
.
println
(
"响应:"
+
result
);
return
error
(
e
.
getMessage
()
);
return
true
;
}
}
}
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/performancesExpress/performanceOrderList.html
View file @
0701f8de
...
@@ -68,6 +68,8 @@
...
@@ -68,6 +68,8 @@
</div>
</div>
<th:block
th:include=
"include :: footer"
/>
<th:block
th:include=
"include :: footer"
/>
<script
th:inline=
"javascript"
>
<script
th:inline=
"javascript"
>
var
placeOrderFlag
=
[[
$
{@
permission
.
hasPermi
(
'kylin:performancesExpress:placeOrder'
)}]];
var
prefix
=
ctx
+
"kylin/performancesExpress"
;
var
prefix
=
ctx
+
"kylin/performancesExpress"
;
var
orderStatusDic
=
[[
$
{@
dict
.
getType
(
'zhengzai_order_status'
)}]];
var
orderStatusDic
=
[[
$
{@
dict
.
getType
(
'zhengzai_order_status'
)}]];
...
@@ -76,6 +78,7 @@
...
@@ -76,6 +78,7 @@
var
options
=
{
var
options
=
{
url
:
prefix
+
"/performanceOrderList"
,
url
:
prefix
+
"/performanceOrderList"
,
modalName
:
"演出订单"
,
modalName
:
"演出订单"
,
placeOrderUrl
:
prefix
+
"/placeOrder"
,
columns
:
[{
columns
:
[{
checkbox
:
true
checkbox
:
true
},
},
...
@@ -121,7 +124,6 @@
...
@@ -121,7 +124,6 @@
field
:
''
,
field
:
''
,
title
:
'收获用户'
,
title
:
'收获用户'
,
formatter
:
function
(
value
,
row
,
index
)
{
formatter
:
function
(
value
,
row
,
index
)
{
console
.
log
(
row
)
var
expressContacts
=
row
.
expressContacts
;
var
expressContacts
=
row
.
expressContacts
;
var
expressAddress
=
row
.
expressAddress
;
var
expressAddress
=
row
.
expressAddress
;
var
expressPhone
=
row
.
expressPhone
;
var
expressPhone
=
row
.
expressPhone
;
...
@@ -133,7 +135,7 @@
...
@@ -133,7 +135,7 @@
align
:
'center'
,
align
:
'center'
,
formatter
:
function
(
value
,
row
,
index
)
{
formatter
:
function
(
value
,
row
,
index
)
{
var
actions
=
[];
var
actions
=
[];
// actions.push('
<
a
class
=
"btn btn-warning btn-xs ' + detailFlag + '"
href
=
"javascript:void(0)"
onclick
=
"$.operate.detail(
\
'' + row.orderTicketsId + '
\
')"
><
i
class
=
"fa fa-search"
><
/i>详细</
a
>
');
actions
.
push
(
'<a class="btn btn-danger btn-xs '
+
placeOrderFlag
+
'" href="javascript:void(0)" onclick="$.operate.remove(
\'
'
+
row
.
orderTicketsId
+
'
\'
,
\'
确定下单吗?
\'
, table.options.placeOrderUrl)"></i>下单</a>
'
);
return
actions
.
join
(
''
);
return
actions
.
join
(
''
);
}
}
}]
}]
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/PerformancesExpressServiceImpl.java
View file @
0701f8de
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
service
.
impl
;
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
service
.
impl
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.liquidnet.client.admin.zhengzai.kylin.utils.ShunfengSignUtils
;
import
com.liquidnet.commons.lang.util.BeanUtil
;
import
com.liquidnet.commons.lang.util.BeanUtil
;
import
com.liquidnet.commons.lang.util.DateUtil
;
import
com.liquidnet.commons.lang.util.IDGenerator
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
com.liquidnet.service.base.ResponseDto
;
import
com.liquidnet.service.kylin.dao.*
;
import
com.liquidnet.service.kylin.dao.*
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.dto.param.*
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.entity.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.mapper.*
;
import
com.liquidnet.service.kylin.service.IKylinOrderExpress
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.time.LocalDateTime
;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Map
;
...
@@ -25,16 +34,23 @@ import java.util.Map;
...
@@ -25,16 +34,23 @@ import java.util.Map;
*/
*/
@Service
@Service
@Slf4j
@Slf4j
public
class
PerformancesExpressServiceImpl
extends
ServiceImpl
<
Kylin
PerformancesMapper
,
KylinPerformances
>
{
public
class
PerformancesExpressServiceImpl
extends
ServiceImpl
<
Kylin
OrderExpressMapper
,
KylinOrderExpress
>
implements
IKylinOrderExpress
{
@Autowired
@Autowired
MongoTemplate
mongoTemplate
;
MongoTemplate
mongoTemplate
;
@Autowired
private
ShunfengSignUtils
shunfengSignUtils
;
@Autowired
@Autowired
private
KylinPerformancesMapper
performancesMapper
;
private
KylinPerformancesMapper
performancesMapper
;
@Autowired
@Autowired
private
KylinOrderTicketsMapper
kylinOrderTicketsMapper
;
private
KylinOrderTicketsMapper
kylinOrderTicketsMapper
;
@Autowired
private
KylinOrderExpressMapper
kylinOrderExpressMapper
;
public
List
<
PerformanceExpressPerformanceListAdminDao
>
getPerformancesList
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
public
List
<
PerformanceExpressPerformanceListAdminDao
>
getPerformancesList
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
List
<
PerformanceExpressPerformanceListAdminDao
>
voList
=
new
ArrayList
();
List
<
PerformanceExpressPerformanceListAdminDao
>
voList
=
new
ArrayList
();
try
{
try
{
...
@@ -56,4 +72,65 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinPerformance
...
@@ -56,4 +72,65 @@ public class PerformancesExpressServiceImpl extends ServiceImpl<KylinPerformance
}
}
return
voList
;
return
voList
;
}
}
public
ResponseDto
placeOrder
(
PerformanceExpressSearchAdminParam
performanceExpressSearchAdminParam
)
{
List
<
String
>
ids
=
performanceExpressSearchAdminParam
.
getIds
();
for
(
String
orderTicketsId
:
ids
)
{
KylinOrderTickets
orderInfo
=
kylinOrderTicketsMapper
.
selectOne
(
new
QueryWrapper
<
KylinOrderTickets
>().
eq
(
"order_tickets_id"
,
orderTicketsId
)
);
HashMap
<
String
,
Object
>
hBody
=
new
HashMap
<>();
hBody
.
put
(
"orderId"
,
orderInfo
.
getOrderCode
());
hBody
.
put
(
"jCompany"
,
"摩登天空"
);
hBody
.
put
(
"jContact"
,
"姜秀龙"
);
// hBody.put("jTel", "010");
hBody
.
put
(
"jMobile"
,
"15811009011"
);
hBody
.
put
(
"jProvince"
,
"北京"
);
hBody
.
put
(
"jCity"
,
"北京市"
);
hBody
.
put
(
"jAddress"
,
"摩登天空"
);
hBody
.
put
(
"dContact"
,
"张红梅"
);
hBody
.
put
(
"dMobile"
,
"15010806631"
);
hBody
.
put
(
"dProvince"
,
"北京"
);
hBody
.
put
(
"dCity"
,
"北京市"
);
hBody
.
put
(
"dAddress"
,
"华通大厦"
);
hBody
.
put
(
"custid"
,
"7551234567"
);
hBody
.
put
(
"payMethod"
,
0
);
// 运费付款方式:0-寄付月结;1-寄付现结;2-收方付;3-第三方付;
hBody
.
put
(
"expressType"
,
1
);
// 顺丰特快
hBody
.
put
(
"depositumInfo"
,
"票"
);
hBody
.
put
(
"depositumNo"
,
1
);
// 时间戳
long
currentTimeMillis
=
System
.
currentTimeMillis
();
// 生成签名并请求
String
result
=
shunfengSignUtils
.
generateSignatureAndRequest
(
currentTimeMillis
+
""
,
hBody
,
"/public/order/v1/placeOrder"
);
HashMap
hashMap
=
JsonUtils
.
fromJson
(
result
,
HashMap
.
class
);
System
.
out
.
println
(
result
);
if
(
hashMap
.
get
(
"succ"
).
equals
(
"fail"
))
{
String
msg
=
(
String
)
hashMap
.
get
(
"msg"
);
return
ResponseDto
.
failure
(
msg
);
}
else
{
KylinOrderExpress
kylinOrderExpress
=
new
KylinOrderExpress
();
String
orderExpressId
=
IDGenerator
.
nextSnowId
();
kylinOrderExpress
.
setOrderExpressId
(
orderExpressId
);
kylinOrderExpress
.
setOrderTicketsId
(
orderTicketsId
);
kylinOrderExpress
.
setMailno
((
String
)
hashMap
.
get
(
"mailno"
));
kylinOrderExpress
.
setExpressType
(
1
);
kylinOrderExpress
.
setFilterResult
((
Integer
)
hashMap
.
get
(
"filter_result"
));
kylinOrderExpress
.
setRemark
((
String
)
hashMap
.
get
(
"remark"
));
kylinOrderExpress
.
setOrigincode
((
String
)
hashMap
.
get
(
"origincode"
));
kylinOrderExpress
.
setDestcode
((
String
)
hashMap
.
get
(
"destcode"
));
kylinOrderExpress
.
setPrintIcon
((
String
)
hashMap
.
get
(
"printIcon"
));
kylinOrderExpress
.
setPrintFlag
((
String
)
hashMap
.
get
(
"printFlag"
));
kylinOrderExpress
.
setTwoDimensionCode
((
String
)
hashMap
.
get
(
"twoDimensionCode"
));
kylinOrderExpress
.
setCreatedAt
(
DateUtil
.
getNowTime
());
kylinOrderExpressMapper
.
insert
(
kylinOrderExpress
);
}
}
return
ResponseDto
.
success
();
}
}
}
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/ShunfengSignUtils.java
View file @
0701f8de
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
utils
;
package
com
.
liquidnet
.
client
.
admin
.
zhengzai
.
kylin
.
utils
;
import
com.liquidnet.client.admin.common.json.JSONObject
;
import
com.liquidnet.commons.lang.util.JsonUtils
;
import
org.apache.commons.codec.binary.Base64
;
import
org.apache.commons.codec.binary.Base64
;
import
org.apache.commons.codec.digest.DigestUtils
;
import
org.apache.commons.codec.digest.DigestUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
...
@@ -11,9 +13,11 @@ import org.apache.http.impl.client.CloseableHttpClient;
...
@@ -11,9 +13,11 @@ import org.apache.http.impl.client.CloseableHttpClient;
import
org.apache.http.impl.client.HttpClients
;
import
org.apache.http.impl.client.HttpClients
;
import
org.apache.http.util.EntityUtils
;
import
org.apache.http.util.EntityUtils
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.stereotype.Component
;
import
javax.servlet.http.HttpServletRequest
;
import
javax.servlet.http.HttpServletRequest
;
import
java.io.IOException
;
import
java.io.IOException
;
import
java.util.HashMap
;
/**
/**
* <p>
* <p>
...
@@ -23,6 +27,7 @@ import java.io.IOException;
...
@@ -23,6 +27,7 @@ import java.io.IOException;
* @author jiangxiulong
* @author jiangxiulong
* @since 2021-06-24 8:00 下午
* @since 2021-06-24 8:00 下午
*/
*/
@Component
public
class
ShunfengSignUtils
{
public
class
ShunfengSignUtils
{
/**
/**
* appId
* appId
...
@@ -47,18 +52,18 @@ public class ShunfengSignUtils {
...
@@ -47,18 +52,18 @@ public class ShunfengSignUtils {
/**
/**
* 生成签名并请求
* 生成签名并请求
* @param timestamp 时间戳
* @param timestamp 时间戳
* @param body 请求body
* @param
h
body 请求body
* @return
* @return
*/
*/
public
String
generateSignatureAndRequest
(
String
timestamp
,
String
body
,
String
url
)
{
public
String
generateSignatureAndRequest
(
String
timestamp
,
HashMap
<
String
,
Object
>
hbody
,
String
url
)
{
hbody
.
put
(
"companyId"
,
APP_ID
);
String
body
=
JsonUtils
.
toJson
(
hbody
);
// 生成签名
// 生成签名
String
sign
=
genSign
(
timestamp
,
body
);
String
sign
=
genSign
(
timestamp
,
body
);
System
.
out
.
println
(
"签名:"
+
sign
);
CloseableHttpClient
client
=
HttpClients
.
createDefault
();
CloseableHttpClient
client
=
HttpClients
.
createDefault
();
// 请求下单地址
// 请求下单地址
HttpPost
httpPost
=
new
HttpPost
(
URL
+
url
);
HttpPost
httpPost
=
new
HttpPost
(
URL
+
url
);
System
.
out
.
println
(
"请求的url:"
+
URL
+
url
);
// sendAppId(sendAppId需赋值appId)
// sendAppId(sendAppId需赋值appId)
httpPost
.
addHeader
(
"sendAppId"
,
APP_ID
);
httpPost
.
addHeader
(
"sendAppId"
,
APP_ID
);
// 时间戳需和获取验签时一致!!!
// 时间戳需和获取验签时一致!!!
...
@@ -66,6 +71,7 @@ public class ShunfengSignUtils {
...
@@ -66,6 +71,7 @@ public class ShunfengSignUtils {
// 签名
// 签名
httpPost
.
addHeader
(
"sign"
,
sign
);
httpPost
.
addHeader
(
"sign"
,
sign
);
httpPost
.
addHeader
(
"Content-Type"
,
"application/json;charset=utf-8"
);
httpPost
.
addHeader
(
"Content-Type"
,
"application/json;charset=utf-8"
);
httpPost
.
addHeader
(
"Accept"
,
"application/json"
);
// 请求body体需和获取验签时一致且编码UTF8!!!
// 请求body体需和获取验签时一致且编码UTF8!!!
httpPost
.
setEntity
(
new
StringEntity
(
body
,
"utf-8"
));
httpPost
.
setEntity
(
new
StringEntity
(
body
,
"utf-8"
));
CloseableHttpResponse
response
=
null
;
CloseableHttpResponse
response
=
null
;
...
...
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinOrderExpress.java
0 → 100644
View file @
0701f8de
package
com
.
liquidnet
.
service
.
kylin
.
entity
;
import
com.baomidou.mybatisplus.annotation.IdType
;
import
com.baomidou.mybatisplus.annotation.TableId
;
import
lombok.Data
;
import
lombok.EqualsAndHashCode
;
import
java.io.Serializable
;
/**
* <p>
* 订单快递
* </p>
*
* @author jiangxiulong
* @since 2021-06-25
*/
@Data
@EqualsAndHashCode
(
callSuper
=
false
)
public
class
KylinOrderExpress
implements
Serializable
{
private
static
final
long
serialVersionUID
=
1L
;
@TableId
(
value
=
"mid"
,
type
=
IdType
.
AUTO
)
private
Integer
mid
;
private
String
orderExpressId
;
private
String
orderTicketsId
;
private
String
mailno
;
private
Integer
expressType
;
private
Integer
filterResult
;
private
String
remark
;
private
String
origincode
;
private
String
destcode
;
private
String
printIcon
;
private
String
twoDimensionCode
;
private
String
printFlag
;
/**
* 创建时间
*/
private
String
createdAt
;
/**
* 修改时间
*/
private
String
updatedAt
;
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderExpressMapper.java
0 → 100644
View file @
0701f8de
package
com
.
liquidnet
.
service
.
kylin
.
mapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.liquidnet.service.kylin.entity.KylinOrderExpress
;
/**
* <p>
* 订单快递 Mapper 接口 处理数据库
* </p>
*
* @author jiangxiulong
* @since 2021-05-01
*/
public
interface
KylinOrderExpressMapper
extends
BaseMapper
<
KylinOrderExpress
>
{
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformancesMapper.xml
View file @
0701f8de
...
@@ -387,73 +387,84 @@
...
@@ -387,73 +387,84 @@
<!-- 演出订单统计-->
<!-- 演出订单统计-->
<select
id=
"getPerformanceOrderStatisticalList"
parameterType=
"java.lang.String"
<select
id=
"getPerformanceOrderStatisticalList"
parameterType=
"java.lang.String"
resultMap=
"performanceOrderStatisticalDaoResult"
>
resultMap=
"performanceOrderStatisticalDaoResult"
>
SELECT kp.performances_id,
SET ${performancesId}:='247128260984832277986';
kt.tickets_id,
SELECT
kt.title,
kp.performances_id ,
kt.price,
kt.tickets_id,
kt.type,
kt.title,
kt.use_start,
kt.price,
IFNULL(kts.total_general, 0) AS 'total_general',
kt.type,
IFNULL(ot.total_sale_general, 0) AS 'sale_general',
kt.use_start,
IFNULL((kts.total_general - IFNULL(ot.total_sale_general,0) - IFNULL(otp.total_paying_number , 0)),0) AS 'surplus_general', AS 'surplus_general',
IFNULL(kts.total_general , 0) AS 'total_general' ,
IFNULL(ot.total_sale_price, 0) AS 'total_sale_price',
IFNULL(ot.total_sale_general , 0) AS 'sale_general' ,
IFNULL(kts.total_exchange, 0) AS 'total_exchange',
IFNULL((kts.total_general - IFNULL(ot.total_sale_general,0) - IFNULL(otp.total_paying_number , 0)),0) AS 'surplus_general',
IFNULL(ot.total_refund_general, 0) AS 'total_refund_general',
IFNULL(ot.total_sale_price , 0) AS 'total_sale_price' ,
IFNULL(ot.total_refund_price, 0) AS 'total_refund_price',
IFNULL(kts.total_exchange , 0) AS 'total_exchange',
IFNULL(ot.total_member_number, 0) AS 'total_member_number',
IFNULL(rd.total_refund_general , 0) AS 'total_refund_general',
IFNULL(otp.total_paying_number, 0) AS 'total_paying_number',
IFNULL(rd.total_refund_price , 0) AS 'total_refund_price',
IFNULL(ut.total_buy_users, 0) AS 'total_buy_users'
IFNULL(ot.total_member_number , 0) AS 'total_member_number',
FROM (select t.performances_id, ktr.ticket_id
IFNULL(otp.total_paying_number , 0) AS 'total_paying_number',
from kylin_performances t
IFNULL(ut.total_buy_users , 0) AS 'total_buy_users'
inner join kylin_ticket_time_relation kttr
FROM
on t.performances_id = kttr.performance_id
(select t.performances_id,ktr.ticket_id from kylin_performances t inner join kylin_ticket_time_relation kttr
inner join kylin_ticket_relations ktr on kttr.times_id = ktr.times_id
on t.performances_id = kttr.performance_id
where t.performances_id = ${performancesId}) AS kp
inner join kylin_ticket_relations ktr on kttr.times_id = ktr.times_id
left JOIN(
where t.performances_id = ${performancesId}) AS kp
SELECT kotr.performance_id AS 'performance_id',
left JOIN(
kotr.ticket_id,
SELECT
(sum(kot.number) - sum(kot.refund_number)) AS 'total_sale_general',
kotr.performance_id AS 'performance_id',
(sum(kot.price_actual) - sum(kot.price_refund)) AS 'total_sale_price',
kotr.ticket_id,
sum(kot.refund_number) as 'total_refund_general',
sum(kot.number) AS 'total_sale_general' ,
sum(kot.price_refund) as 'total_refund_price',
sum(kot.price_actual) AS 'total_sale_price',
sum(case when kotr.is_member = 1 then kot.number else 0 end) total_member_number
sum(case when kotr.is_member = 1 then kot.number else 0 end) total_member_number
FROM kylin_order_ticket_relations kotr
FROM
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
kylin_order_ticket_relations kotr
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
WHERE 1 > 0
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
and kotr.performance_id = ${performancesId}
WHERE 1>0 and kotr.performance_id = ${performancesId}
and kots.`status` in (1, 3, 4)
and kots.`status` in(1,3) and kot.coupon_type ='no'
and kot.coupon_type = 'no'
group by kotr.performance_id,kotr.ticket_id
group by kotr.performance_id, kotr.ticket_id
) AS ot ON (ot.performance_id = kp.performances_id and ot.ticket_id = kp.ticket_id)
) AS ot ON (ot.performance_id = kp.performances_id and ot.ticket_id = kp.ticket_id)
left JOIN(
left JOIN(
SELECT
SELECT kotr.performance_id,
kotr.performance_id,kotr.ticket_id,
kotr.ticket_id,
sum(ifnull(kot.number,0)) total_paying_number
sum(ifnull(kot.number, 0)) total_paying_number
FROM
FROM kylin_order_ticket_relations kotr
kylin_order_ticket_relations kotr
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
WHERE 1 > 0
WHERE 1>0 and kotr.performance_id = ${performancesId}
and kotr.performance_id = ${performancesId}
and kots.`status` = 0 and kot.coupon_type ='no'
and kots.`status` = 0
group by kotr.performance_id,kotr.ticket_id
and kot.coupon_type = 'no'
) AS otp ON (otp.performance_id = kp.performances_id and otp.ticket_id = kp.ticket_id)
group by kotr.performance_id, kotr.ticket_id
left JOIN(
) AS otp ON (otp.performance_id = kp.performances_id and otp.ticket_id = kp.ticket_id)
SELECT
left join kylin_tickets kt on kt.tickets_id = kp.ticket_id
kotr.performance_id,kotr.ticket_id,
left join kylin_ticket_status kts on kts.ticket_id = kp.ticket_id
sum(kot.refund_number) as 'total_refund_general',
inner JOIN(
sum(kot.price_refund) as 'total_refund_price'
select t.performance_id, count(t.user_id) as 'total_buy_users'
FROM
from (
kylin_order_ticket_relations kotr
SELECT kotr.performance_id,
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
kot.user_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
FROM kylin_order_ticket_relations kotr
WHERE 1>0 and kotr.performance_id = ${performancesId}
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
and kots.`status` = 4 and kot.coupon_type ='no'
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
group by kotr.performance_id,kotr.ticket_id
WHERE kotr.performance_id = ${performancesId}
) AS rd ON (rd.performance_id = kp.performances_id and rd.ticket_id = kp.ticket_id)
and (kots.`status` = 0 OR kots.`status` = 1)
left join kylin_tickets kt on kt.tickets_id = kp.ticket_id
group by kotr.performance_id, kot.user_id
left join kylin_ticket_status kts on kts.ticket_id = kp.ticket_id
) t
inner JOIN(
) AS ut ON ut.performance_id = kp.performances_id
select t.performance_id,count(t.user_id) as 'total_buy_users' from(
SELECT
kotr.performance_id,
kot.user_id
FROM
kylin_order_ticket_relations kotr
inner join kylin_order_tickets AS kot on kotr.order_id = kot.order_tickets_id
inner JOIN kylin_order_ticket_status AS kots ON kots.order_id = kot.order_tickets_id
WHERE kotr.performance_id = ${performancesId} and (kots.`status` = 0 OR kots.`status` = 1)
group by kotr.performance_id,kot.user_id
) t
) AS ut ON ut.performance_id = kp.performances_id
</select>
</select>
<select
id=
"getPerformanceSponsorList"
resultMap=
"performanceSponsorDaoResult"
>
<select
id=
"getPerformanceSponsorList"
resultMap=
"performanceSponsorDaoResult"
>
select distinct kp.sponsor_id, kp.sponsor, kp.sponsor_type
select distinct kp.sponsor_id, kp.sponsor, kp.sponsor_type
...
...
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/docu/db_kylin_structure.sql
View file @
0701f8de
...
@@ -744,3 +744,26 @@ CREATE TABLE `kylin_order_refund_entities`
...
@@ -744,3 +744,26 @@ CREATE TABLE `kylin_order_refund_entities`
)
ENGINE
=
InnoDB
)
ENGINE
=
InnoDB
DEFAULT
CHARSET
=
utf8mb4
DEFAULT
CHARSET
=
utf8mb4
COLLATE
=
utf8mb4_unicode_ci
COMMENT
'退款入场人表'
;
COLLATE
=
utf8mb4_unicode_ci
COMMENT
'退款入场人表'
;
drop
TABLE
if
exists
`kylin_order_express`
;
CREATE
TABLE
`kylin_order_express`
(
`mid`
int
unsigned
NOT
NULL
AUTO_INCREMENT
,
`order_express_id`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'order_express_id'
,
`order_tickets_id`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'订单id'
,
`mailno`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'顺丰运单号'
,
`express_type`
tinyint
NOT
NULL
DEFAULT
'0'
COMMENT
'快件产品类型 1顺丰特快...'
,
`filter_result`
tinyint
NOT
NULL
DEFAULT
'0'
COMMENT
'1-人工确认;2-可收派;3-不可以收派'
,
`remark`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'filter_result=3时返回不可以收派的原因代码'
,
`origincode`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'原寄地区域代码 可用于顺丰电子面单标签打印'
,
`destcode`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'目的地区域代码 可用于顺丰电子面单标签打印'
,
`print_icon`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'打印图标'
,
`print_flag`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'打印标志'
,
`two_dimension_code`
varchar
(
255
)
NOT
NULL
DEFAULT
''
COMMENT
'二维码'
,
`created_at`
timestamp
NULL
DEFAULT
NULL
,
`updated_at`
timestamp
NULL
DEFAULT
NULL
,
KEY
`kylin_order_express_order_express_id_index`
(
`order_express_id`
),
PRIMARY
KEY
(
`mid`
)
)
ENGINE
=
InnoDB
DEFAULT
CHARSET
=
utf8mb4
COLLATE
=
utf8mb4_unicode_ci
COMMENT
'订单快递表'
;
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinPerformancesServiceImpl.java
View file @
0701f8de
...
@@ -166,6 +166,9 @@ public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesM
...
@@ -166,6 +166,9 @@ public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesM
public
KylinPerformanceVo
detail
(
String
performancesId
,
double
latitudeFrom
,
double
longitudeFrom
,
String
agentId
)
{
public
KylinPerformanceVo
detail
(
String
performancesId
,
double
latitudeFrom
,
double
longitudeFrom
,
String
agentId
)
{
KylinPerformanceVo
performancesInfo
=
dataUtils
.
getPerformanceVo
(
performancesId
);
KylinPerformanceVo
performancesInfo
=
dataUtils
.
getPerformanceVo
(
performancesId
);
if
(
null
==
performancesInfo
)
{
return
performancesInfo
;
}
String
agentName
=
dataUtils
.
getAgentInfoName
(
agentId
);
String
agentName
=
dataUtils
.
getAgentInfoName
(
agentId
);
performancesInfo
.
setAgentName
(
agentName
);
performancesInfo
.
setAgentName
(
agentName
);
try
{
try
{
...
...
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