Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
O
order-group
Overview
Overview
Details
Activity
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
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
jenkins
order-group
Commits
34721912
Commit
34721912
authored
Mar 17, 2020
by
ping.wu
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
预约单接单接口增加预约任务,创建订单预约任务修改
parent
9a3b33f2
Hide whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
210 additions
and
47 deletions
+210
-47
assortment-ordercenter-sdk/pom.xml
+3
-3
assortment-ordercenter-sdk/readme.md
+3
-2
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/request/order/BaseQueryOrderRequest.java
+3
-0
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/service/order/OrderCenterSdkServiceImpl.java
+116
-20
order-application-service/pom.xml
+2
-2
order-application-service/src/main/java/cn/freemud/adapter/OrderAdapter.java
+70
-13
order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java
+4
-4
ordercenter-sdk/pom.xml
+1
-1
ordercenter-sdk/readme.md
+3
-2
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/request/POSOrderOperationBaseReq.java
+4
-0
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/request/create/OrderTaskReq.java
+1
-0
No files found.
assortment-ordercenter-sdk/pom.xml
View file @
34721912
...
...
@@ -10,7 +10,7 @@
<modelVersion>
4.0.0
</modelVersion>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<version>
1.1.
7
-SNAPSHOT
</version>
<version>
1.1.
8
-SNAPSHOT
</version>
<dependencies>
<dependency>
<groupId>
org.springframework.boot
</groupId>
...
...
@@ -38,7 +38,7 @@
<dependency>
<groupId>
cn.freemud
</groupId>
<artifactId>
ordercenter-sdk
</artifactId>
<version>
1.1.
7
-SNAPSHOT
</version>
<version>
1.1.
8
-SNAPSHOT
</version>
</dependency>
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
...
...
@@ -55,7 +55,7 @@
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
<artifactId>
storecenter-sdk
</artifactId>
<version>
2.
2.1.RELEASE
</version>
<version>
2.
3.3-SNAPSHOT
</version>
<scope>
provided
</scope>
</dependency>
<dependency>
...
...
assortment-ordercenter-sdk/readme.md
View file @
34721912
...
...
@@ -15,4 +15,5 @@
| 1.2.0.RELEASE| 开放平台创建订单 | 姜海波 | 2020-02-24 |
| 1.2.1.RELEASE| 基于1.2.0.RELEASE | 丁凯 | 2020-03-04 |
| 1.2.2.RELEASE| 升级RELEASE | wuping | 2020-03-04 |
| 1.1.7-SNAPSHOT| 预约单支付成功接口增加预约任务 | wuping | 2020-03-10 |
\ No newline at end of file
| 1.1.7-SNAPSHOT| 预约单支付成功接口增加预约任务 | wuping | 2020-03-10 |
| 1.1.8-SNAPSHOT| 预约单接单接口增加预约任务 | wuping | 2020-03-17 |
\ No newline at end of file
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/request/order/BaseQueryOrderRequest.java
View file @
34721912
...
...
@@ -56,4 +56,7 @@ public class BaseQueryOrderRequest extends BaseConfig {
//操作人
private
String
operator
;
//用户预约时间,仅为预约单时存放
private
String
expectTime
;
}
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/service/order/OrderCenterSdkServiceImpl.java
View file @
34721912
...
...
@@ -505,21 +505,7 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
request
.
setOrderCode
(
baseQueryOrderRequest
.
getOrderId
());
request
.
setOperator
(
baseQueryOrderRequest
.
getOperator
());
// 引入门店基础服务 查询自动制作完成配置时间
StoreResponse
.
Configuration
configuration
=
getStoreAutoConfiguration
(
baseQueryOrderRequest
.
getPartnerId
(),
baseQueryOrderRequest
.
getShopId
(),
baseQueryOrderRequest
.
getTrackingNo
());
//自配送外卖单
if
(
configuration
!=
null
)
{
if
(
OrderType
.
GENERAL_EXPRESS
.
equals
(
baseQueryOrderRequest
.
getOrderType
())
||
OrderType
.
RESERVED_EXPRESS
.
equals
(
baseQueryOrderRequest
.
getOrderType
()))
{
if
(
baseQueryOrderRequest
.
isHasSelfDelivery
()
&&
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
()))
{
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
())
);
}
}
else
{
if
(
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
()))
{
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
())
);
}
}
}
else
{
request
.
setTimeout
(
120
);
}
setTimeout
(
baseQueryOrderRequest
,
request
);
com
.
freemud
.
application
.
sdk
.
api
.
ordercenter
.
response
.
BaseResponse
response
=
orderSdkService
.
acceptOrder
(
request
,
baseQueryOrderRequest
.
getTrackingNo
());
return
orderSdkAdapter
.
convent2BaseOrderResponse
(
response
);
}
...
...
@@ -550,8 +536,14 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
request
.
setOperator
(
baseQueryOrderRequest
.
getOperator
());
// 调用门店服务查询外卖单自动完成时间
StoreResponse
.
Configuration
configuration
=
getStoreAutoConfiguration
(
baseQueryOrderRequest
.
getPartnerId
(),
baseQueryOrderRequest
.
getShopId
(),
baseQueryOrderRequest
.
getTrackingNo
());
if
(
configuration
!=
null
&&
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoDeliveryTakeOrderWorkflowFinishTime
()))
{
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoDeliveryTakeOrderWorkflowFinishTime
()));
if
(
configuration
!=
null
)
{
if
(
StringUtils
.
isNotEmpty
(
configuration
.
getAutoDeliveryTakeOrderWorkflowFinishTime
())){
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoDeliveryTakeOrderWorkflowFinishTime
()));
}
if
(
StringUtils
.
isNotEmpty
(
baseQueryOrderRequest
.
getExpectTime
())
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoDeliveryTakeOrderWorkflowFinishTime
())){
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoDeliveryTakeOrderWorkflowFinishTime
()));
}
}
else
{
request
.
setTimeout
(
120
);
}
...
...
@@ -631,9 +623,13 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
request
.
setOperator
(
baseQueryOrderRequest
.
getOperator
());
// 调用门店服务查询自动完成配置信息
StoreResponse
.
Configuration
configuration
=
getStoreAutoConfiguration
(
baseQueryOrderRequest
.
getPartnerId
(),
baseQueryOrderRequest
.
getShopId
(),
baseQueryOrderRequest
.
getTrackingNo
());
if
(
configuration
!=
null
&&
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoSelfmentionMakerWorkflowFinishTime
()))
{
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoSelfmentionMakerWorkflowFinishTime
()));
if
(
configuration
!=
null
)
{
if
(
StringUtils
.
isNotEmpty
(
configuration
.
getAutoSelfmentionMakerWorkflowFinishTime
())){
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoSelfmentionMakerWorkflowFinishTime
()));
}
if
(
StringUtils
.
isNotEmpty
(
baseQueryOrderRequest
.
getExpectTime
())
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoSelfmentionMakerWorkflowFinishTime
())){
request
.
setTimeout
(
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoSelfmentionMakerWorkflowFinishTime
()));
}
}
else
{
request
.
setTimeout
(
120
);
}
...
...
@@ -1317,4 +1313,104 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
=
orderSdkService
.
queryOrderWithCoupon
(
userId
,
trackingNo
);
return
orderSdkAdapter
.
convent2QueryOrdersResponse
(
response
);
}
private
void
setTimeout
(
BaseQueryOrderRequest
baseQueryOrderRequest
,
POSOrderOperationBaseReq
request
){
String
partnerId
=
baseQueryOrderRequest
.
getPartnerId
();
String
storeCode
=
baseQueryOrderRequest
.
getShopId
();
String
trackingNo
=
baseQueryOrderRequest
.
getTrackingNo
();
if
(
StringUtils
.
isEmpty
(
storeCode
))
{
return
;
}
StoreInfoRequest
storeInfoRequest
=
new
StoreInfoRequest
();
storeInfoRequest
.
setPartnerId
(
partnerId
);
storeInfoRequest
.
setStoreCode
(
storeCode
);
StoreResponse
storeResponse
=
storeCenterService
.
getStoreInfo
(
storeInfoRequest
,
trackingNo
);
if
(
storeResponse
==
null
||
storeResponse
.
getBizVO
()
==
null
)
{
return
;
}
StoreResponse
.
Configuration
configuration
=
storeResponse
.
getBizVO
().
getStoreConfig
();
String
orderWarnTime
=
storeResponse
.
getBizVO
().
getOrderWarnTime
();
Integer
timeout
=
0
;
//自配送外卖单
if
(
configuration
!=
null
)
{
//外卖单
if
(
OrderType
.
GENERAL_EXPRESS
.
equals
(
baseQueryOrderRequest
.
getOrderType
())
||
OrderType
.
RESERVED_EXPRESS
.
equals
(
baseQueryOrderRequest
.
getOrderType
()))
{
if
(
baseQueryOrderRequest
.
isHasSelfDelivery
()
&&
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
()))
{
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
());
}
//预约单
if
(
StringUtils
.
isNotEmpty
(
baseQueryOrderRequest
.
getExpectTime
())
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoTakeOutTakeOrderWorkflowFinishTime
())){
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoTakeOutTakeOrderWorkflowFinishTime
());
}
}
else
{
//自提单
if
(
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
()))
{
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
());
}
//预约单
if
(
StringUtils
.
isNotEmpty
(
baseQueryOrderRequest
.
getExpectTime
())
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoSelfmentionTakeOrderWorkflowFinishTime
())){
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoSelfmentionTakeOrderWorkflowFinishTime
());
}
}
//预约单提醒任务,触发放拉单队列
if
(
StringUtils
.
isNotEmpty
(
baseQueryOrderRequest
.
getExpectTime
())){
OrderTaskReq
orderTask
=
new
OrderTaskReq
();
orderTask
.
setTaskType
(
3
);
Date
processingDate
=
DateUtil
.
addMinutes
(
DateUtil
.
convert2Date
(
baseQueryOrderRequest
.
getExpectTime
(),
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
),
-
getMinTime
(
orderWarnTime
));
orderTask
.
setProcessingTime
(
DateUtil
.
convert2String
(
processingDate
,
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
));
orderTask
.
setTaskTime
(
baseQueryOrderRequest
.
getExpectTime
());
// orderTask.setTimeout(0);
request
.
setOrderTask
(
orderTask
);
//设置超时变制作完成或配送中时间为0
timeout
=
0
;
}
}
else
{
timeout
=
120
;
}
request
.
setTimeout
(
timeout
);
}
public
OrderTaskReq
saveOrderTaskReq
(
String
orderWarnTime
,
Long
gmtExpect
)
{
OrderTaskReq
orderTaskReq
=
new
OrderTaskReq
();
Date
date
=
new
Date
(
gmtExpect
);
long
timeStamp
=
getMinTime
(
orderWarnTime
)
*
60
*
1000
;
Date
warnDate
=
new
Date
(
gmtExpect
-
timeStamp
);
orderTaskReq
.
setTaskTime
(
DateUtil
.
convert2String
(
date
,
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
));
orderTaskReq
.
setProcessingTime
(
DateUtil
.
convert2String
(
warnDate
,
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
));
return
orderTaskReq
;
}
public
Integer
getMinTime
(
String
code
)
{
Integer
minTime
=
0
;
if
(
StringUtils
.
isBlank
(
code
)){
return
minTime
;
}
switch
(
code
)
{
case
"1"
:
minTime
=
15
;
break
;
case
"2"
:
minTime
=
30
;
break
;
case
"3"
:
minTime
=
45
;
break
;
case
"4"
:
minTime
=
60
;
break
;
case
"5"
:
minTime
=
5
;
break
;
case
"6"
:
minTime
=
10
;
break
;
default
:
minTime
=
0
;
}
return
minTime
;
}
}
order-application-service/pom.xml
View file @
34721912
...
...
@@ -40,7 +40,7 @@
<dependency>
<groupId>
cn.freemud
</groupId>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<version>
1.1.
7
-SNAPSHOT
</version>
<version>
1.1.
8
-SNAPSHOT
</version>
</dependency>
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
...
...
@@ -88,7 +88,7 @@
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
<artifactId>
storecenter-sdk
</artifactId>
<version>
2.
2.1.RELEASE
</version>
<version>
2.
3.3-SNAPSHOT
</version>
</dependency>
<dependency>
<groupId>
cn.freemud
</groupId>
...
...
order-application-service/src/main/java/cn/freemud/adapter/OrderAdapter.java
View file @
34721912
...
...
@@ -28,6 +28,7 @@ import cn.freemud.enums.ActivityTypeEnum;
import
cn.freemud.enums.*
;
import
cn.freemud.enums.OrderChannelType
;
import
cn.freemud.enums.OrderSourceType
;
import
cn.freemud.enums.OrderType
;
import
cn.freemud.enums.PayStatus
;
import
cn.freemud.enums.QueryOrderStatus
;
import
cn.freemud.enums.ResponseResult
;
...
...
@@ -42,10 +43,7 @@ import com.freemud.api.assortment.datamanager.entity.vo.AssortmentCustomerInfoVo
import
com.freemud.api.assortment.datamanager.enums.IappIdType
;
import
com.freemud.application.sdk.api.log.LogThreadLocal
;
import
com.freemud.api.assortment.datamanager.manager.cache.CacheOpenPlatformPartnerWxappConfigManager
;
import
com.freemud.application.sdk.api.ordercenter.enums.AfterSalesType
;
import
com.freemud.application.sdk.api.ordercenter.enums.OrderClientType
;
import
com.freemud.application.sdk.api.ordercenter.enums.OrderSettlementType
;
import
com.freemud.application.sdk.api.ordercenter.enums.ProductTypeEnum
;
import
com.freemud.application.sdk.api.ordercenter.enums.*
;
import
com.freemud.application.sdk.api.ordercenter.request.OrderExtendedReq
;
import
com.freemud.application.sdk.api.ordercenter.request.create.OrderTaskReq
;
import
com.freemud.application.sdk.api.promotioncenter.dto.promotion.GoodsStockDTO
;
...
...
@@ -118,18 +116,25 @@ public class OrderAdapter {
* @param shoppingCartGoodsDto
* @return
*/
public
BaseCreateOrderRequest
convent2CreateOrderDto
(
CreateOrderVo
createOrderVo
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
,
String
orderWarnTime
)
{
public
BaseCreateOrderRequest
convent2CreateOrderDto
(
CreateOrderVo
createOrderVo
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
,
StoreResponse
.
BizVO
storeResponseDto
)
{
UserDeliveryInfoDto
deliveryInfoDto
=
createOrderVo
.
getUserDeliveryInfoDto
();
BaseCreateOrderRequest
createOrderDto
=
getCreateOrderDto
(
createOrderVo
);
OrderTaskReq
orderTask
=
null
;
if
(
StringUtils
.
isNotEmpty
(
createOrderVo
.
getTakeMealTime
())){
Integer
orderType
=
0
;
if
(
Objects
.
equals
(
createOrderVo
.
getOrderType
(),
CreateOrderType
.
TAKE_OUT
.
getCode
()))
{
orderType
=
1
;
}
//预订单任务
orderTask
=
getOrderTaskReq
(
storeResponseDto
,
createOrderVo
.
getTakeMealTime
(),
orderType
);
}
if
(
orderTask
!=
null
){
createOrderDto
.
setOrderTask
(
orderTask
);
}
long
deliveryAmount
=
0
;
if
(
deliveryInfoDto
!=
null
)
{
deliveryAmount
=
getUserRealDeliveryAmount
(
deliveryInfoDto
.
getStoreDeliveryInfoDto
(),
deliveryInfoDto
.
getUserLongitude
(),
deliveryInfoDto
.
getUserLatitude
());
}
if
(
createOrderDto
.
getGmtExpect
()
!=
null
&&
createOrderDto
.
getGmtExpect
()
!=
0
){
//预订单任务
createOrderDto
.
setOrderTask
(
saveOrderTaskReq
(
orderWarnTime
,
createOrderDto
.
getGmtExpect
()));
}
Long
packageAmount
=
shoppingCartGoodsDto
.
getPackageAmount
()
==
null
?
0L
:
shoppingCartGoodsDto
.
getPackageAmount
();
createOrderDto
.
setAmount
(
shoppingCartGoodsDto
.
getTotalAmount
()
+
deliveryAmount
+
packageAmount
);
// 解析购物车信息
...
...
@@ -246,15 +251,28 @@ public class OrderAdapter {
return
createOrderDto
;
}
public
CreateFatherSonOrderRequest
convertFatherSonOrderRequest
(
CreateOrderVo
createOrderVo
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
,
OrderExtendedReq
orderExtendedReq
,
String
orderWarnTime
)
{
public
CreateFatherSonOrderRequest
convertFatherSonOrderRequest
(
CreateOrderVo
createOrderVo
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
,
OrderExtendedReq
orderExtendedReq
,
StoreResponse
.
BizVO
storeResponseDto
)
{
CreateFatherSonOrderRequest
createFatherSonOrderRequest
=
new
CreateFatherSonOrderRequest
();
createFatherSonOrderRequest
.
setPartnerId
(
createOrderVo
.
getPartnerId
());
createFatherSonOrderRequest
.
setTrackingNo
(
LogTreadLocal
.
getTrackingNo
());
createFatherSonOrderRequest
.
setMenuType
(
createOrderVo
.
getMenuType
());
UserDeliveryInfoDto
deliveryInfoDto
=
createOrderVo
.
getUserDeliveryInfoDto
();
List
<
CreateFatherSonOrderRequest
.
OrderInfo
>
orderInfoList
=
new
ArrayList
<>();
CreateFatherSonOrderRequest
.
OrderInfo
productOrderInfo
=
convertProductOrderInfo
(
createOrderVo
,
deliveryInfoDto
,
shoppingCartGoodsDto
,
orderWarnTime
);
CreateFatherSonOrderRequest
.
OrderInfo
productOrderInfo
=
convertProductOrderInfo
(
createOrderVo
,
deliveryInfoDto
,
shoppingCartGoodsDto
);
productOrderInfo
.
setOrderExtended
(
orderExtendedReq
);
OrderTaskReq
orderTask
=
null
;
if
(
StringUtils
.
isNotEmpty
(
createOrderVo
.
getTakeMealTime
())){
Integer
orderType
=
0
;
if
(
Objects
.
equals
(
createOrderVo
.
getOrderType
(),
CreateOrderType
.
TAKE_OUT
.
getCode
()))
{
orderType
=
1
;
}
//预订单任务
orderTask
=
getOrderTaskReq
(
storeResponseDto
,
createOrderVo
.
getTakeMealTime
(),
orderType
);
}
if
(
orderTask
!=
null
){
productOrderInfo
.
setOrderTask
(
orderTask
);
}
CreateFatherSonOrderRequest
.
OrderInfo
memberOrderInfo
=
convertMemberOrderInfo
(
createOrderVo
,
shoppingCartGoodsDto
,
productOrderInfo
.
getOrderType
());
CreateFatherSonOrderRequest
.
OrderInfo
fatherOrderInfo
=
convertFatherOrderInfo
(
createOrderVo
,
shoppingCartGoodsDto
,
deliveryInfoDto
,
productOrderInfo
.
getOrderType
());
...
...
@@ -507,7 +525,7 @@ public class OrderAdapter {
}
public
CreateFatherSonOrderRequest
.
OrderInfo
convertProductOrderInfo
(
CreateOrderVo
createOrderVo
,
UserDeliveryInfoDto
userDeliveryInfoDto
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
,
String
orderWarnTime
)
{
,
UserDeliveryInfoDto
userDeliveryInfoDto
,
ShoppingCartGoodsDto
shoppingCartGoodsDto
)
{
String
deliveryType
=
userDeliveryInfoDto
!=
null
&&
userDeliveryInfoDto
.
getStoreDeliveryInfoDto
()
!=
null
?
userDeliveryInfoDto
.
getStoreDeliveryInfoDto
().
getDeliveryType
()
:
""
;
QueryOrderType
orderType
;
...
...
@@ -2641,4 +2659,43 @@ public class OrderAdapter {
return
type
;
}
public
OrderTaskReq
getOrderTaskReq
(
StoreResponse
.
BizVO
storeResponse
,
String
expectTime
,
Integer
orderType
){
OrderTaskReq
orderTask
=
new
OrderTaskReq
();
StoreResponse
.
Configuration
configuration
=
storeResponse
.
getStoreConfig
();
Integer
timeout
=
0
;
if
(
configuration
!=
null
)
{
//外卖单
if
(
OldOrderType
.
TAKE_OUT
.
getCode
().
equals
(
orderType
))
{
if
(
StringUtils
.
isNotEmpty
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
()))
{
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoTakeOutTakeOrderWorkflowFinishTime
());
}
//预约单
if
(
StringUtils
.
isNotEmpty
(
expectTime
)
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoTakeOutTakeOrderWorkflowFinishTime
())){
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoTakeOutTakeOrderWorkflowFinishTime
());
}
}
else
{
//自提单
if
(
org
.
apache
.
commons
.
lang
.
StringUtils
.
isNotEmpty
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
()))
{
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAutoSelfmentionTakeOrderWorkflowFinishTime
());
}
//预约单
if
(
StringUtils
.
isNotEmpty
(
expectTime
)
&&
StringUtils
.
isNotEmpty
(
configuration
.
getAppointAutoSelfmentionTakeOrderWorkflowFinishTime
())){
timeout
=
AutoOrderConfigTime
.
getTime
(
configuration
.
getAppointAutoSelfmentionTakeOrderWorkflowFinishTime
());
}
}
}
else
{
timeout
=
120
;
}
//预约单提醒任务,触发放拉单队列
if
(
StringUtils
.
isNotEmpty
(
expectTime
)
&&
timeout
!=
null
&&
timeout
!=
0
){
orderTask
.
setTaskType
(
1
);
Date
processingDate
=
DateUtil
.
addMinutes
(
DateUtil
.
convert2Date
(
expectTime
,
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
),
timeout
);
orderTask
.
setProcessingTime
(
expectTime
);
orderTask
.
setTaskTime
(
DateUtil
.
convert2String
(
processingDate
,
DateUtil
.
FORMAT_YYYY_MM_DD_HHMMSS
));
orderTask
.
setTimeout
(
timeout
);
}
return
orderTask
;
}
}
order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java
View file @
34721912
...
...
@@ -1727,7 +1727,7 @@ public class OrderServiceImpl implements Orderservice {
//创建普通订单
OrderClientType
finalOrderClient
=
orderClient
;
Function
<
Object
,
CreateOrderResponse
>
createOrder
=
(
var
->
{
BaseCreateOrderRequest
baseCreateOrderRequest
=
orderAdapter
.
convent2CreateOrderDto
(
createOrderVo
,
shoppingCartGoodsDto
,
orderWarnTime
);
BaseCreateOrderRequest
baseCreateOrderRequest
=
orderAdapter
.
convent2CreateOrderDto
(
createOrderVo
,
shoppingCartGoodsDto
,
storeResponseDto
);
//查询第三方商品编号
baseCreateOrderRequest
=
getProductCustomerCode
(
baseCreateOrderRequest
);
//保存门店渠道信息
...
...
@@ -1745,7 +1745,7 @@ public class OrderServiceImpl implements Orderservice {
});
//创建父子订单
Function
<
Object
,
CreateFatherSonOrderResponse
>
createFatherSonOrder
=
(
var
->
{
CreateFatherSonOrderRequest
createFatherSonOrderRequest
=
orderAdapter
.
convertFatherSonOrderRequest
(
createOrderVo
,
shoppingCartGoodsDto
,
orderExtendedReq
,
orderWarnTime
);
CreateFatherSonOrderRequest
createFatherSonOrderRequest
=
orderAdapter
.
convertFatherSonOrderRequest
(
createOrderVo
,
shoppingCartGoodsDto
,
orderExtendedReq
,
storeResponseDto
);
//查询第三方商品编号
createFatherSonOrderRequest
=
getProductCustomerCodeNew
(
createFatherSonOrderRequest
);
MqMessageRequest
mqMessageRequest
=
new
MqMessageRequest
();
...
...
@@ -2239,7 +2239,7 @@ public class OrderServiceImpl implements Orderservice {
String
orderWarnTime
=
storeResponseDto
.
getOrderWarnTime
();
//创建普通订单
Function
<
Object
,
CreateOrderResponse
>
createOrder
=
(
var
->
{
BaseCreateOrderRequest
baseCreateOrderRequest
=
orderAdapter
.
convent2CreateOrderDto
(
createOrderVo
,
shoppingCartGoodsDto
,
orderWarnTime
);
BaseCreateOrderRequest
baseCreateOrderRequest
=
orderAdapter
.
convent2CreateOrderDto
(
createOrderVo
,
shoppingCartGoodsDto
,
storeResponseDto
);
//查询第三方商品编号
baseCreateOrderRequest
=
getProductCustomerCode
(
baseCreateOrderRequest
);
//保存门店渠道信息
...
...
@@ -2256,7 +2256,7 @@ public class OrderServiceImpl implements Orderservice {
});
//创建父子订单
Function
<
Object
,
CreateFatherSonOrderResponse
>
createFatherSonOrder
=
(
var
->
{
CreateFatherSonOrderRequest
createFatherSonOrderRequest
=
orderAdapter
.
convertFatherSonOrderRequest
(
createOrderVo
,
shoppingCartGoodsDto
,
orderExtendedReq
,
orderWarnTime
);
CreateFatherSonOrderRequest
createFatherSonOrderRequest
=
orderAdapter
.
convertFatherSonOrderRequest
(
createOrderVo
,
shoppingCartGoodsDto
,
orderExtendedReq
,
storeResponseDto
);
//查询第三方商品编号
createFatherSonOrderRequest
=
getProductCustomerCodeNew
(
createFatherSonOrderRequest
);
MqMessageRequest
mqMessageRequest
=
new
MqMessageRequest
();
...
...
ordercenter-sdk/pom.xml
View file @
34721912
...
...
@@ -8,7 +8,7 @@
<version>
1.0.0
</version>
</parent>
<modelVersion>
4.0.0
</modelVersion>
<version>
1.1.
7
-SNAPSHOT
</version>
<version>
1.1.
8
-SNAPSHOT
</version>
<artifactId>
ordercenter-sdk
</artifactId>
<dependencies>
...
...
ordercenter-sdk/readme.md
View file @
34721912
...
...
@@ -10,4 +10,5 @@
| 1.1.4-SNAPSHOT | 优化活动订单 | 胡超 | 2020-02-10 |
| 1.1.6-SNAPSHOT | OrderExtInfo新增formId | wuping | 2020-02-27 |
| 1.1.6.RELEASE | 升级RELEASE | wuping | 2020-03-04 |
| 1.1.7-SNAPSHOT | 预约单支付成功接口增加预约任务 | wuping | 2020-03-10 |
\ No newline at end of file
| 1.1.7-SNAPSHOT | 预约单支付成功接口增加预约任务 | wuping | 2020-03-10 |
| 1.1.8-SNAPSHOT | 预约单接单接口增加预约任务 | wuping | 2020-03-17 |
\ No newline at end of file
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/request/POSOrderOperationBaseReq.java
View file @
34721912
...
...
@@ -12,6 +12,7 @@
*/
package
com
.
freemud
.
application
.
sdk
.
api
.
ordercenter
.
request
;
import
com.freemud.application.sdk.api.ordercenter.request.create.OrderTaskReq
;
import
lombok.Data
;
@Data
...
...
@@ -24,4 +25,7 @@ public class POSOrderOperationBaseReq {
//从接单、制作完成、送出开始计时,超时的时间(单位:分钟)
private
Integer
timeout
;
//预约单任务(处理提醒时拉单的)接单接口时传
private
OrderTaskReq
orderTask
;
}
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/request/create/OrderTaskReq.java
View file @
34721912
...
...
@@ -25,6 +25,7 @@ public class OrderTaskReq {
//任务类型:1预约单 (OrderType设置为2预约堂食,4预约外送,6预约自取 默认为预约单)
//2 超时回调
//3 拉单队列
private
Integer
taskType
;
private
Integer
timeout
;
...
...
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