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
order-group-application
order-group
Commits
8857fdbc
Commit
8857fdbc
authored
Dec 04, 2020
by
孙昱
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'qa' of gitlab.freemud.com:order-group-application/order-group into qa
parents
b9ef4d48
32453178
Show whitespace changes
Inline
Side-by-side
Showing
19 changed files
with
275 additions
and
31 deletions
+275
-31
assortment-ordercenter-sdk/pom.xml
+2
-2
assortment-ordercenter-sdk/readme.md
+1
-0
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/response/order/QueryOrdersResponse.java
+1
-0
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/response/payment/OrderPayResponse.java
+10
-0
order-application-service/pom.xml
+2
-2
order-application-service/src/main/java/cn/freemud/adapter/OrderAdapter.java
+2
-0
order-application-service/src/main/java/cn/freemud/controller/CallerController.java
+8
-2
order-application-service/src/main/java/cn/freemud/entities/dto/ecology/SubscribeMessageRequest.java
+40
-5
order-application-service/src/main/java/cn/freemud/entities/vo/CreateOrderResponseVo.java
+10
-0
order-application-service/src/main/java/cn/freemud/entities/vo/TakeMealNoticesVO.java
+3
-1
order-application-service/src/main/java/cn/freemud/enums/MessageEventTypeEnum.java
+30
-0
order-application-service/src/main/java/cn/freemud/enums/OrderChannelType.java
+3
-1
order-application-service/src/main/java/cn/freemud/service/CallerService.java
+130
-6
order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java
+27
-10
order-application-service/src/main/java/cn/freemud/service/thirdparty/EcologyAdminApplicationClient.java
+1
-1
ordercenter-sdk/pom.xml
+1
-1
ordercenter-sdk/readme.md
+1
-0
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/enums/OrderClientType.java
+1
-0
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/response/orderInfo/OrderInfoReqs.java
+2
-0
No files found.
assortment-ordercenter-sdk/pom.xml
View file @
8857fdbc
...
@@ -10,7 +10,7 @@
...
@@ -10,7 +10,7 @@
<modelVersion>
4.0.0
</modelVersion>
<modelVersion>
4.0.0
</modelVersion>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<version>
2.2.1
6
-SNAPSHOT
</version>
<version>
2.2.1
8
-SNAPSHOT
</version>
<dependencies>
<dependencies>
<dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<groupId>
org.springframework.boot
</groupId>
...
@@ -38,7 +38,7 @@
...
@@ -38,7 +38,7 @@
<dependency>
<dependency>
<groupId>
cn.freemud
</groupId>
<groupId>
cn.freemud
</groupId>
<artifactId>
ordercenter-sdk
</artifactId>
<artifactId>
ordercenter-sdk
</artifactId>
<version>
1.7.
1
-SNAPSHOT
</version>
<version>
1.7.
3
-SNAPSHOT
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
<groupId>
com.freemud.application.service.sdk
</groupId>
...
...
assortment-ordercenter-sdk/readme.md
View file @
8857fdbc
...
@@ -147,3 +147,4 @@
...
@@ -147,3 +147,4 @@
| 2.1.4-RELEASE | 退款增加自动退款配置的null判断 | 刘鹏飞 | 2020-11-12 |
| 2.1.4-RELEASE | 退款增加自动退款配置的null判断 | 刘鹏飞 | 2020-11-12 |
| 2.1.5-RELEASE | 麦咖啡权益卡金额入机 | 徐康 | 2020-11-23 |
| 2.1.5-RELEASE | 麦咖啡权益卡金额入机 | 徐康 | 2020-11-23 |
| 2.1.6-RELEASE | hun | 徐康 | 2020-11-23 |
| 2.1.6-RELEASE | hun | 徐康 | 2020-11-23 |
| 2.2.18-SNAPSHOT| 抖音支付新增抖音单号和openId | 张志恒 | 2020-12-4 |
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/response/order/QueryOrdersResponse.java
View file @
8857fdbc
...
@@ -195,6 +195,7 @@ public class QueryOrdersResponse {
...
@@ -195,6 +195,7 @@ public class QueryOrdersResponse {
* 支付凭证 非码流水ID
* 支付凭证 非码流水ID
*/
*/
private
String
payVoucher
;
private
String
payVoucher
;
/**
/**
* 手机号
* 手机号
*/
*/
...
...
assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/response/payment/OrderPayResponse.java
View file @
8857fdbc
...
@@ -66,6 +66,16 @@ public class OrderPayResponse {
...
@@ -66,6 +66,16 @@ public class OrderPayResponse {
private
String
payMode
;
private
String
payMode
;
private
List
<
PayItem
>
payItem
=
new
ArrayList
<>();
private
List
<
PayItem
>
payItem
=
new
ArrayList
<>();
/**
* 抖音支付的返回的为orderId 映射为我们thirdOrderId
*/
private
String
thirdOrderId
;
/**
* 抖音支付的orderToken 映射为我们thirdOrderToken
*/
private
String
thirdOrderToken
;
@NoArgsConstructor
@NoArgsConstructor
@Data
@Data
public
static
class
PayOrderBean
{
public
static
class
PayOrderBean
{
...
...
order-application-service/pom.xml
View file @
8857fdbc
...
@@ -40,7 +40,7 @@
...
@@ -40,7 +40,7 @@
<dependency>
<dependency>
<groupId>
cn.freemud
</groupId>
<groupId>
cn.freemud
</groupId>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<artifactId>
assortment-ordercenter-sdk
</artifactId>
<version>
2.2.1
7
-SNAPSHOT
</version>
<version>
2.2.1
8
-SNAPSHOT
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
com.freemud.application.service.sdk
</groupId>
<groupId>
com.freemud.application.service.sdk
</groupId>
...
@@ -320,7 +320,7 @@
...
@@ -320,7 +320,7 @@
<dependency>
<dependency>
<groupId>
com.freemud.sdk.api.assortment
</groupId>
<groupId>
com.freemud.sdk.api.assortment
</groupId>
<artifactId>
assortment-payment-sdk
</artifactId>
<artifactId>
assortment-payment-sdk
</artifactId>
<version>
2.6.
3
.RELEASE
</version>
<version>
2.6.
4
.RELEASE
</version>
</dependency>
</dependency>
<dependency>
<dependency>
<groupId>
org.apache.rocketmq
</groupId>
<groupId>
org.apache.rocketmq
</groupId>
...
...
order-application-service/src/main/java/cn/freemud/adapter/OrderAdapter.java
View file @
8857fdbc
...
@@ -2927,6 +2927,8 @@ public class OrderAdapter {
...
@@ -2927,6 +2927,8 @@ public class OrderAdapter {
}
}
responseDto
.
setStatusCode
(
unifiedOrderResponse
.
getStatusCode
());
responseDto
.
setStatusCode
(
unifiedOrderResponse
.
getStatusCode
());
responseDto
.
setPayTransId
(
unifiedOrderResponse
.
getPayTransId
());
responseDto
.
setPayTransId
(
unifiedOrderResponse
.
getPayTransId
());
responseDto
.
setThirdOrderToken
(
unifiedOrderResponse
.
getOrderToken
());
responseDto
.
setThirdOrderId
(
unifiedOrderResponse
.
getOrderId
());
return
responseDto
;
return
responseDto
;
}
}
...
...
order-application-service/src/main/java/cn/freemud/controller/CallerController.java
View file @
8857fdbc
...
@@ -5,8 +5,12 @@ import cn.freemud.base.entity.BaseResponse;
...
@@ -5,8 +5,12 @@ import cn.freemud.base.entity.BaseResponse;
import
cn.freemud.entities.vo.TakeMealNoticesVO
;
import
cn.freemud.entities.vo.TakeMealNoticesVO
;
import
cn.freemud.service.CallerService
;
import
cn.freemud.service.CallerService
;
import
cn.freemud.utils.ResponseUtil
;
import
cn.freemud.utils.ResponseUtil
;
import
com.freemud.application.sdk.api.log.ApiAnnotation
;
import
com.freemud.application.sdk.api.log.LogParams
;
import
lombok.extern.slf4j.Slf4j
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.validation.annotation.Validated
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.springframework.web.bind.annotation.RestController
;
...
@@ -14,7 +18,7 @@ import org.springframework.web.bind.annotation.RestController;
...
@@ -14,7 +18,7 @@ import org.springframework.web.bind.annotation.RestController;
* 叫号器
* 叫号器
*/
*/
@Slf4j
@Slf4j
@RequestMapping
(
"/caller"
)
@RequestMapping
(
"
order
/caller"
)
@RestController
@RestController
@Validated
@Validated
public
class
CallerController
{
public
class
CallerController
{
...
@@ -29,7 +33,9 @@ private CallerService callerService;
...
@@ -29,7 +33,9 @@ private CallerService callerService;
* 取餐通知
* 取餐通知
* @return
* @return
*/
*/
public
BaseResponse
takeMealNotices
(
TakeMealNoticesVO
vo
){
@PostMapping
(
"/takeMealNotices"
)
@ApiAnnotation
(
logMessage
=
"takeMealNotices"
)
public
BaseResponse
takeMealNotices
(
@Validated
@LogParams
@RequestBody
TakeMealNoticesVO
vo
){
return
callerService
.
takeMealNotices
(
vo
);
return
callerService
.
takeMealNotices
(
vo
);
}
}
...
...
order-application-service/src/main/java/cn/freemud/entities/dto/ecology/SubscribeMessageRequest.java
View file @
8857fdbc
...
@@ -10,27 +10,49 @@ import java.util.List;
...
@@ -10,27 +10,49 @@ import java.util.List;
public
class
SubscribeMessageRequest
{
public
class
SubscribeMessageRequest
{
/**
* 预约单下单成功通知
*/
private
BookingOrderPayedScene
bookingOrderPayedScene
;
private
BookingOrderPayedScene
bookingOrderPayedScene
;
/**
* 预约单取单提醒
*/
private
BookingOrderPayedScene
bookingOrderTakeReminderScene
;
private
BookingOrderPayedScene
bookingOrderTakeReminderScene
;
/**
/**
* 渠道
* 渠道
* 1 微信小程序
* 2 支付宝小程序
* 3 手机app
* 4 线下应用
* 5 字节小程序
* 6 h5
*/
*/
private
Integer
channel
;
private
Integer
channel
;
/**
/**
*
*
配送异常提醒
*/
*/
private
String
scene
;
private
DeliveryErrorReminder
deliveryErrorReminder
;
private
DeliveryErrorReminder
deliveryErrorReminder
;
/**拼单提醒
*
*/
private
GroupBuyingStatusReminder
groupBuyingStatusReminder
;
private
GroupBuyingStatusReminder
groupBuyingStatusReminder
;
/**
* 即时单下单成功通知
*/
private
InstantOrderPayedScene
instantOrderPayedScene
;
private
InstantOrderPayedScene
instantOrderPayedScene
;
/**
* 即时单取餐通知
*/
private
InstantOrderPayedScene
instantOrderTakeReminderScene
;
private
InstantOrderPayedScene
instantOrderTakeReminderScene
;
/**
*
*/
private
String
messageEventType
;
private
String
messageEventType
;
/**
/**
...
@@ -43,10 +65,23 @@ public class SubscribeMessageRequest {
...
@@ -43,10 +65,23 @@ public class SubscribeMessageRequest {
*/
*/
private
List
<
String
>
openIdList
;
private
List
<
String
>
openIdList
;
/**
*自配送配送通知
*/
private
OrderDeliveryScene
orderDeliveryScene
;
private
OrderDeliveryScene
orderDeliveryScene
;
/**
*
*/
private
SceneCouponRequest
sceneCouponExpiredRequest
;
private
SceneCouponRequest
sceneCouponExpiredRequest
;
/**
* //即时单scene_instant
* //预约单:scene_appoint
* //自配送单:scene_self_delivery
* //拼单提醒:scene_group_buying
*/
private
String
scene
;
private
SceneCouponRequest
sceneCouponReceiveRequest
;
private
SceneCouponRequest
sceneCouponReceiveRequest
;
private
SceneInviteGiftRequest
sceneInviteGiftRequest
;
private
SceneInviteGiftRequest
sceneInviteGiftRequest
;
...
...
order-application-service/src/main/java/cn/freemud/entities/vo/CreateOrderResponseVo.java
View file @
8857fdbc
...
@@ -62,4 +62,14 @@ public class CreateOrderResponseVo {
...
@@ -62,4 +62,14 @@ public class CreateOrderResponseVo {
@ApiModelProperty
(
value
=
"支付宝参数 唤起支付宝支付使用"
)
@ApiModelProperty
(
value
=
"支付宝参数 唤起支付宝支付使用"
)
private
String
orderStr
;
private
String
orderStr
;
/**
* 抖音支付的返回的为orderId 映射为我们thirdOrderId
*/
private
String
thirdOrderId
;
/**
* 抖音支付的orderToken 映射为我们thirdOrderToken
*/
private
String
thirdOrderToken
;
}
}
order-application-service/src/main/java/cn/freemud/entities/vo/TakeMealNoticesVO.java
View file @
8857fdbc
...
@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModelProperty;
...
@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModelProperty;
import
lombok.Getter
;
import
lombok.Getter
;
import
lombok.Setter
;
import
lombok.Setter
;
import
java.util.List
;
/**
/**
* @author freemud
* @author freemud
*/
*/
...
@@ -25,5 +27,5 @@ public class TakeMealNoticesVO {
...
@@ -25,5 +27,5 @@ public class TakeMealNoticesVO {
private
Integer
cupTotalNum
;
private
Integer
cupTotalNum
;
@ApiModelProperty
(
value
=
"订单"
)
@ApiModelProperty
(
value
=
"订单"
)
private
String
[]
orders
;
private
List
<
String
>
orderList
;
}
}
order-application-service/src/main/java/cn/freemud/enums/MessageEventTypeEnum.java
0 → 100644
View file @
8857fdbc
package
cn
.
freemud
.
enums
;
import
lombok.Getter
;
@Getter
public
enum
MessageEventTypeEnum
{
INSTANT_ORDER_PAYED
(
30
,
"INSTANT_ORDER_PAYED"
,
"即时单下单成功通知"
),
BOOKING_ORDER_PAYED
(
31
,
"BOOKING_ORDER_PAYED"
,
"预约单下单成功通知"
),
SELF_DELIVERY_ORDER_PAYED
(
32
,
"SELF_DELIVERY_ORDER_PAYED"
,
"自配送下单成功通知"
),
ORDER_DELIVERY
(
33
,
"ORDER_DELIVERY"
,
"订单配送通知"
),
BOOKING_ORDER_TAKE_REMINDER
(
34
,
"BOOKING_ORDER_TAKE_REMINDER"
,
"预约单取单通知"
),
INSTANT_ORDER_TAKE_REMINDER
(
35
,
"INSTANT_ORDER_TAKE_REMINDER"
,
"即时单取单通知"
),
GROUP_BUYING_STATUS_REMINDER
(
36
,
"GROUP_BUYING_STATUS_REMINDER"
,
"拼单提醒"
),
DELIVERY_ERROR_REMINDER
(
37
,
"DELIVERY_ERROR_REMINDER"
,
"配送异常提醒"
),
;
private
int
code
;
private
String
type
;
private
String
name
;
MessageEventTypeEnum
(
int
code
,
String
type
,
String
name
)
{
this
.
code
=
code
;
this
.
type
=
type
;
this
.
name
=
name
;
}
}
order-application-service/src/main/java/cn/freemud/enums/OrderChannelType.java
View file @
8857fdbc
...
@@ -22,7 +22,9 @@ public enum OrderChannelType {
...
@@ -22,7 +22,9 @@ public enum OrderChannelType {
SAASMALL
(
"saasmall"
,
"微商城"
),
SAASMALL
(
"saasmall"
,
"微商城"
),
APP
(
"app"
,
"APP"
);
APP
(
"app"
,
"APP"
),
TOUTIAO
(
"toutiao"
,
"抖音小程序"
);;
private
String
code
;
private
String
code
;
...
...
order-application-service/src/main/java/cn/freemud/service/CallerService.java
View file @
8857fdbc
package
cn
.
freemud
.
service
;
package
cn
.
freemud
.
service
;
import
cn.freemud.amp.body.OrderBody
;
import
cn.freemud.base.entity.BaseResponse
;
import
cn.freemud.base.entity.BaseResponse
;
import
cn.freemud.base.log.LogTreadLocal
;
import
cn.freemud.base.util.DateUtil
;
import
cn.freemud.constant.RedisKeyConstant
;
import
cn.freemud.constant.RedisKeyConstant
;
import
cn.freemud.constant.ResponseCodeConstant
;
import
cn.freemud.entities.dto.GetMemberInfoByIdRequestDto
;
import
cn.freemud.entities.dto.GetMemberInfoByIdResponseDto
;
import
cn.freemud.entities.dto.ecology.BookingOrderPayedScene
;
import
cn.freemud.entities.dto.ecology.InstantOrderPayedScene
;
import
cn.freemud.entities.dto.ecology.SubscribeMessageRequest
;
import
cn.freemud.entities.dto.ecology.SubscribeMessageResponse
;
import
cn.freemud.entities.vo.TakeMealNoticesVO
;
import
cn.freemud.entities.vo.TakeMealNoticesVO
;
import
cn.freemud.enums.MessageEventTypeEnum
;
import
cn.freemud.service.impl.CheckOrder
;
import
cn.freemud.service.thirdparty.CustomerClient
;
import
cn.freemud.service.thirdparty.EcologyAdminApplicationClient
;
import
cn.freemud.utils.DateTimeUtil
;
import
cn.freemud.utils.ResponseUtil
;
import
cn.freemud.utils.ResponseUtil
;
import
com.alibaba.fastjson.JSON
;
import
com.alibaba.fastjson.JSONObject
;
import
com.alibaba.fastjson.TypeReference
;
import
com.freemud.application.sdk.api.ordercenter.request.OrderExtInfoDto
;
import
com.freemud.application.sdk.api.storecenter.response.StoreResponse
;
import
com.freemud.sdk.api.assortment.order.enums.NewOrderType
;
import
com.freemud.sdk.api.assortment.order.request.order.BaseQueryOrderRequest
;
import
com.freemud.sdk.api.assortment.order.response.order.QueryOrderByIdResponse
;
import
com.freemud.sdk.api.assortment.order.response.order.QueryOrdersResponse
;
import
com.freemud.sdk.api.assortment.order.service.OrderCenterSdkService
;
import
com.google.common.collect.Lists
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.slf4j.Slf4j
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.util.List
;
import
java.util.Objects
;
import
java.util.concurrent.TimeUnit
;
import
java.util.concurrent.TimeUnit
;
@AllArgsConstructor
@Service
@Service
@Slf4j
public
class
CallerService
{
public
class
CallerService
{
@Autowired
private
final
RedisTemplate
redisTemplate
;
private
RedisTemplate
redisTemplate
;
private
final
EcologyAdminApplicationClient
ecologyAdminApplicationClient
;
private
final
OrderCenterSdkService
orderCenterSdkService
;
private
final
CheckOrder
checkOrder
;
/**
/**
* 缓存 待制作杯数量
* 缓存 待制作杯数量
*
* @param vo
* @param vo
*/
*/
private
void
cacheTakeMealNotices
(
TakeMealNoticesVO
vo
)
{
private
void
cacheTakeMealNotices
(
TakeMealNoticesVO
vo
)
{
String
redisKey
=
RedisKeyConstant
.
notMadeGoodsNumber
(
vo
.
getPartnerId
(),
vo
.
getStoreCode
());
String
redisKey
=
RedisKeyConstant
.
notMadeGoodsNumber
(
vo
.
getPartnerId
(),
vo
.
getStoreCode
());
redisTemplate
.
boundValueOps
(
redisKey
).
set
(
vo
.
getCupTotalNum
(),
1
,
TimeUnit
.
DAYS
);
redisTemplate
.
boundValueOps
(
redisKey
).
set
(
vo
.
getCupTotalNum
(),
1
,
TimeUnit
.
DAYS
);
}
}
public
BaseResponse
takeMealNotices
(
TakeMealNoticesVO
vo
){
/**
* pos -> 推送模板消息
* 即时单
* 预约单
*
* @param vo
* @return
*/
public
BaseResponse
takeMealNotices
(
TakeMealNoticesVO
vo
)
{
cacheTakeMealNotices
(
vo
);
cacheTakeMealNotices
(
vo
);
//发送取餐通知消息 cc 生态
if
(
Objects
.
isNull
(
vo
.
getOrderList
()))
{
return
ResponseUtil
.
success
();
return
ResponseUtil
.
success
();
}
}
vo
.
getOrderList
().
stream
().
forEach
(
orderId
->
{
BaseQueryOrderRequest
baseQueryOrderRequest
=
new
BaseQueryOrderRequest
();
baseQueryOrderRequest
.
setOrderId
(
orderId
);
baseQueryOrderRequest
.
setTrackingNo
(
LogTreadLocal
.
getTrackingNo
());
QueryOrderByIdResponse
queryOrderByIdResponse
=
orderCenterSdkService
.
queryOrderById
(
baseQueryOrderRequest
);
QueryOrdersResponse
.
DataBean
.
OrderBean
orderBean
=
queryOrderByIdResponse
.
getData
();
if
(
Objects
.
isNull
(
orderBean
))
{
return
;
}
OrderExtInfoDto
extInfoDto
=
JSONObject
.
parseObject
(
orderBean
.
getExtInfo
(),
new
TypeReference
<
OrderExtInfoDto
>()
{
});
if
(
Objects
.
isNull
(
extInfoDto
.
getOpenid
()))
{
log
.
error
(
"订单号:{},没有openId"
,
orderId
);
return
;
}
StoreResponse
storeResponse
=
checkOrder
.
getStoreInfo
(
orderBean
.
getCompanyId
(),
orderBean
.
getShopId
(),
LogTreadLocal
.
getTrackingNo
());
if
(
storeResponse
.
getBizVO
()
==
null
)
{
log
.
error
(
"订单号:{},商户号:{},没有门店信息"
,
orderId
,
orderBean
.
getShopId
());
return
;
}
List
<
Integer
>
takeawayOrderType
=
Lists
.
newArrayList
(
NewOrderType
.
RESERVED_EXPRESS
.
getCode
(),
NewOrderType
.
GENERAL_EXPRESS
.
getCode
());
if
(
takeawayOrderType
.
contains
(
orderBean
.
getNewOrderType
()))
{
// 外卖单不发模板消息
return
;
}
orderBean
.
setShopAddress
(
storeResponse
.
getBizVO
().
getAddress
());
SubscribeMessageRequest
subscribeMessageRequest
=
new
SubscribeMessageRequest
();
subscribeMessageRequest
.
setMiniAppId
(
extInfoDto
.
getAppid
());
subscribeMessageRequest
.
setOpenIdList
(
Lists
.
newArrayList
(
extInfoDto
.
getOpenid
()));
// coco order_client 2微信小程序 3支付宝小程序 需要转换生态的
subscribeMessageRequest
.
setChannel
(
orderBean
.
getOrderClient
().
equals
(
"2"
)
?
1
:
2
);
boolean
reservationOrder
=
isReservationOrder
(
orderBean
);
if
(
reservationOrder
)
{
//预约单
BookingOrderPayedScene
scene
=
new
BookingOrderPayedScene
();
scene
.
setMerchantAddress
(
orderBean
.
getShopAddress
());
scene
.
setMerchantName
(
orderBean
.
getShopName
());
scene
.
setOrderNo
(
orderId
);
scene
.
setOrderType
(
orderBean
.
getNewOrderType
().
toString
());
scene
.
setTakeOrderTime
(
DateTimeUtil
.
getCurrentTimeStr
());
subscribeMessageRequest
.
setBookingOrderTakeReminderScene
(
scene
);
subscribeMessageRequest
.
setScene
(
"scene_appoint"
);
subscribeMessageRequest
.
setMessageEventType
(
MessageEventTypeEnum
.
BOOKING_ORDER_TAKE_REMINDER
.
getType
());
}
else
{
InstantOrderPayedScene
scene
=
new
InstantOrderPayedScene
();
scene
.
setFriendlyTips
(
"饮品已制作完成,请凭取单号及时到店取单哟!"
);
scene
.
setOrderType
(
orderBean
.
getNewOrderType
().
toString
());
scene
.
setMerchantAddress
(
orderBean
.
getShopAddress
());
scene
.
setMerchantName
(
orderBean
.
getShopName
());
scene
.
setOrderNo
(
orderId
);
subscribeMessageRequest
.
setInstantOrderTakeReminderScene
(
scene
);
subscribeMessageRequest
.
setScene
(
"scene_instant"
);
subscribeMessageRequest
.
setMessageEventType
(
MessageEventTypeEnum
.
INSTANT_ORDER_TAKE_REMINDER
.
getType
());
}
//发送模板消息
SubscribeMessageResponse
subscribeMessageResponse
=
ecologyAdminApplicationClient
.
subscribeMessage
(
subscribeMessageRequest
);
if
(!
ResponseCodeConstant
.
RESPONSE_SUCCESS
.
equals
(
subscribeMessageResponse
.
getCode
()))
{
log
.
error
(
"ecologyAdminApplicationClient.subscribeMessage调用失败 ,request:{},body:{}"
,
JSON
.
toJSONString
(
subscribeMessageResponse
),
JSON
.
toJSONString
(
subscribeMessageRequest
));
}
});
return
ResponseUtil
.
success
();
}
/**
* 是否预约单
* true 预约单
*
* @return
*/
private
boolean
isReservationOrder
(
QueryOrdersResponse
.
DataBean
.
OrderBean
orderBean
)
{
if
(
Objects
.
nonNull
(
orderBean
.
getGmtExpect
()))
{
return
Boolean
.
TRUE
;
}
return
Boolean
.
FALSE
;
}
}
}
order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java
View file @
8857fdbc
...
@@ -30,6 +30,14 @@ import cn.freemud.entities.dto.PayAccessResponse;
...
@@ -30,6 +30,14 @@ import cn.freemud.entities.dto.PayAccessResponse;
import
cn.freemud.entities.dto.QueryOrdersResponseDto.DataBean.OrderBean
;
import
cn.freemud.entities.dto.QueryOrdersResponseDto.DataBean.OrderBean
;
import
cn.freemud.entities.dto.activity.PayGiftCheckAndJoinResponseDto
;
import
cn.freemud.entities.dto.activity.PayGiftCheckAndJoinResponseDto
;
import
cn.freemud.entities.dto.activity.PayGitCheckAndJoinRequestDto
;
import
cn.freemud.entities.dto.activity.PayGitCheckAndJoinRequestDto
;
import
cn.freemud.entities.dto.delivery.OrderRemindRequestDto
;
import
cn.freemud.entities.dto.delivery.QueryDeliveryAmountResponseDto
;
import
cn.freemud.entities.dto.delivery.QueryLocusRiderTrackDto
;
import
cn.freemud.entities.dto.delivery.ResRiderTrackDto
;
import
cn.freemud.entities.dto.ecology.BookingOrderPayedScene
;
import
cn.freemud.entities.dto.ecology.InstantOrderPayedScene
;
import
cn.freemud.entities.dto.ecology.SubscribeMessageRequest
;
import
cn.freemud.entities.dto.ecology.SubscribeMessageResponse
;
import
cn.freemud.entities.dto.delivery.*
;
import
cn.freemud.entities.dto.delivery.*
;
import
cn.freemud.entities.dto.order.CreateOrderOperateDto
;
import
cn.freemud.entities.dto.order.CreateOrderOperateDto
;
import
cn.freemud.entities.dto.order.CreatePrepayRequestDto
;
import
cn.freemud.entities.dto.order.CreatePrepayRequestDto
;
...
@@ -56,6 +64,7 @@ import cn.freemud.utils.*;
...
@@ -56,6 +64,7 @@ import cn.freemud.utils.*;
import
com.alibaba.fastjson.JSON
;
import
com.alibaba.fastjson.JSON
;
import
com.alibaba.fastjson.JSONArray
;
import
com.alibaba.fastjson.JSONArray
;
import
com.alibaba.fastjson.JSONObject
;
import
com.alibaba.fastjson.JSONObject
;
import
com.alibaba.fastjson.TypeReference
;
import
com.freemud.api.assortment.datamanager.entity.db.*
;
import
com.freemud.api.assortment.datamanager.entity.db.*
;
import
com.freemud.api.assortment.datamanager.entity.vo.AssortmentCustomerInfoVo
;
import
com.freemud.api.assortment.datamanager.entity.vo.AssortmentCustomerInfoVo
;
import
com.freemud.api.assortment.datamanager.manager.*
;
import
com.freemud.api.assortment.datamanager.manager.*
;
...
@@ -286,6 +295,8 @@ public class OrderServiceImpl implements Orderservice {
...
@@ -286,6 +295,8 @@ public class OrderServiceImpl implements Orderservice {
private
ComPayClient
comPayClient
;
private
ComPayClient
comPayClient
;
@Autowired
@Autowired
private
AssortmentOpenPlatformIappWxappStoreManager
assortmentOpenPlatformIappWxappStoreManager
;
private
AssortmentOpenPlatformIappWxappStoreManager
assortmentOpenPlatformIappWxappStoreManager
;
@Autowired
private
EcologyAdminApplicationClient
ecologyAdminApplicationClient
;
@Autowired
@Autowired
private
SvcComPayClient
svcComPayClient
;
private
SvcComPayClient
svcComPayClient
;
...
@@ -1775,6 +1786,18 @@ public class OrderServiceImpl implements Orderservice {
...
@@ -1775,6 +1786,18 @@ public class OrderServiceImpl implements Orderservice {
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER_QUERYORDER_ERROR
.
getCode
(),
"不能操作非本人的订单"
);
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER_QUERYORDER_ERROR
.
getCode
(),
"不能操作非本人的订单"
);
}
}
OrderBean
orderBean
=
orderByIdResponseDto
.
getData
();
OrderBean
orderBean
=
orderByIdResponseDto
.
getData
();
if
(
PayStatus
.
NOT_PAY
.
getCode
().
equals
(
orderByIdResponseDto
.
getData
().
getPayStatus
())
||
OrderStatus
.
WAIT_PAY
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单未支付,无法退款"
);
}
if
(
OrderStatus
.
CALCEL
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单已取消,无法退款"
);
}
if
(
OrderStatus
.
DISTRIBUTION
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单配送中,退款请联系售后!"
);
}
// todo coco 商户校验
// todo coco 商户校验
if
(
partnerId
.
equals
(
orderByIdResponseDto
.
getData
().
getCompanyId
()))
{
if
(
partnerId
.
equals
(
orderByIdResponseDto
.
getData
().
getCompanyId
()))
{
// COCO 即时单不可取消
// COCO 即时单不可取消
...
@@ -1802,16 +1825,6 @@ public class OrderServiceImpl implements Orderservice {
...
@@ -1802,16 +1825,6 @@ public class OrderServiceImpl implements Orderservice {
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER_CANCEL_ERROR_ESTIMATE_TIME
);
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER_CANCEL_ERROR_ESTIMATE_TIME
);
}
}
}
}
if
(
PayStatus
.
NOT_PAY
.
getCode
().
equals
(
orderByIdResponseDto
.
getData
().
getPayStatus
())
||
OrderStatus
.
WAIT_PAY
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单未支付,无法退款"
);
}
if
(
OrderStatus
.
CALCEL
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单已取消,无法退款"
);
}
if
(
OrderStatus
.
DISTRIBUTION
.
getCode
().
equals
(
orderBean
.
getStatus
()))
{
return
ResponseUtil
.
error
(
ResponseResult
.
ORDER__ERRORREFUND
.
getCode
(),
"订单配送中,退款请联系售后!"
);
}
/**
/**
* 已接单,制作完成,配送中,未接单,用户可申请退款
* 已接单,制作完成,配送中,未接单,用户可申请退款
...
@@ -2426,6 +2439,10 @@ public class OrderServiceImpl implements Orderservice {
...
@@ -2426,6 +2439,10 @@ public class OrderServiceImpl implements Orderservice {
}
else
if
(
UserLoginChannelEnum
.
APP
.
getCode
().
equals
(
userLoginInfoDto
.
getChannel
()))
{
}
else
if
(
UserLoginChannelEnum
.
APP
.
getCode
().
equals
(
userLoginInfoDto
.
getChannel
()))
{
orderClient
=
OrderClientType
.
APP
;
orderClient
=
OrderClientType
.
APP
;
}
}
//抖音小程序
if
(
OrderChannelType
.
TOUTIAO
.
getCode
().
equals
(
createOrderVo
.
getChannelType
()))
{
orderClient
=
OrderClientType
.
TOUTIAO
;
}
long
totalAmount
=
0
;
long
totalAmount
=
0
;
int
cardAmount
=
0
;
int
cardAmount
=
0
;
QueryOrdersResponse
.
DataBean
.
OrderBean
fatherBeanListOne
=
new
QueryOrdersResponse
.
DataBean
.
OrderBean
();
QueryOrdersResponse
.
DataBean
.
OrderBean
fatherBeanListOne
=
new
QueryOrdersResponse
.
DataBean
.
OrderBean
();
...
...
order-application-service/src/main/java/cn/freemud/service/thirdparty/EcologyAdminApplicationClient.java
View file @
8857fdbc
...
@@ -30,7 +30,7 @@ public interface EcologyAdminApplicationClient {
...
@@ -30,7 +30,7 @@ public interface EcologyAdminApplicationClient {
@PostMapping
(
value
=
"/ecology/api/getAuthorizerAccessToken"
)
@PostMapping
(
value
=
"/ecology/api/getAuthorizerAccessToken"
)
GetTokenResponseDto
getAuthorizerAccessToken
(
@RequestBody
GetAuthorizerRequestDto
request
);
GetTokenResponseDto
getAuthorizerAccessToken
(
@RequestBody
GetAuthorizerRequestDto
request
);
@PostMapping
(
value
=
"/ecology/api/subscribeMessage/send"
)
@PostMapping
(
value
=
"/ecology/api/subscribeMessage/send"
)
SubscribeMessageResponse
subscribeMessage
(
SubscribeMessageRequest
request
);
SubscribeMessageResponse
subscribeMessage
(
SubscribeMessageRequest
request
);
}
}
ordercenter-sdk/pom.xml
View file @
8857fdbc
...
@@ -8,7 +8,7 @@
...
@@ -8,7 +8,7 @@
<version>
1.0.0
</version>
<version>
1.0.0
</version>
</parent>
</parent>
<modelVersion>
4.0.0
</modelVersion>
<modelVersion>
4.0.0
</modelVersion>
<version>
1.7.
2
-SNAPSHOT
</version>
<version>
1.7.
3
-SNAPSHOT
</version>
<artifactId>
ordercenter-sdk
</artifactId>
<artifactId>
ordercenter-sdk
</artifactId>
<dependencies>
<dependencies>
...
...
ordercenter-sdk/readme.md
View file @
8857fdbc
...
@@ -88,4 +88,5 @@
...
@@ -88,4 +88,5 @@
| 1.3.18.RELEASE | 麦咖啡加料 | 徐康 | 2020-10-30 |
| 1.3.18.RELEASE | 麦咖啡加料 | 徐康 | 2020-10-30 |
| 1.3.20.RELEASE | 麦咖啡权益卡金额入机 | 徐康 | 2020-11-23 |
| 1.3.20.RELEASE | 麦咖啡权益卡金额入机 | 徐康 | 2020-11-23 |
| 1.3.21.RELEASE | 混支付 | 徐康 | 2020-11-26 |
| 1.3.21.RELEASE | 混支付 | 徐康 | 2020-11-26 |
| 1.7.3-SNAPSHOT| 抖音支付新增抖音单号和openId | 张志恒 | 2020-12-4 |
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/enums/OrderClientType.java
View file @
8857fdbc
...
@@ -36,6 +36,7 @@ public enum OrderClientType {
...
@@ -36,6 +36,7 @@ public enum OrderClientType {
SAASMALL
(
23
,
"微商城"
),
SAASMALL
(
23
,
"微商城"
),
DPZHCT
(
24
,
"美团点评智慧餐厅"
),
DPZHCT
(
24
,
"美团点评智慧餐厅"
),
FMWD
(
25
,
"非码微店"
),
FMWD
(
25
,
"非码微店"
),
TOUTIAO
(
27
,
"抖音小程序"
),
PARKING
(
99
,
"农工商停车"
),
PARKING
(
99
,
"农工商停车"
),
FU_YOU
(
100
,
"富有"
),
FU_YOU
(
100
,
"富有"
),
;
;
...
...
ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/response/orderInfo/OrderInfoReqs.java
View file @
8857fdbc
...
@@ -277,6 +277,8 @@ public class OrderInfoReqs {
...
@@ -277,6 +277,8 @@ public class OrderInfoReqs {
*/
*/
private
List
<
OrderPayItemReqs
>
orderPayItemCreateReqList
;
private
List
<
OrderPayItemReqs
>
orderPayItemCreateReqList
;
private
String
appId
;
List
<
OrderSendCouponResp
>
orderSendCouponRespList
;
List
<
OrderSendCouponResp
>
orderSendCouponRespList
;
}
}
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