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
9df7b7c4
Commit
9df7b7c4
authored
Jan 08, 2020
by
ping.wu
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
代码冲突修改
parent
cdce86b5
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
196 additions
and
196 deletions
+196
-196
order-application-service/src/main/java/cn/freemud/adapter/UserAdapter.java
+42
-42
order-application-service/src/main/java/cn/freemud/entities/dto/UserLoginInfoDto.java
+44
-44
order-application-service/src/main/java/cn/freemud/service/UserService.java
+25
-25
order-application-service/src/main/java/cn/freemud/service/impl/CheckMallOrder.java
+1
-1
order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java
+3
-3
order-application-service/src/main/java/cn/freemud/service/impl/UserServiceImpl.java
+81
-81
No files found.
order-application-service/src/main/java/cn/freemud/adapter/UserAdapter.java
View file @
9df7b7c4
//
package cn.freemud.adapter;
package
cn
.
freemud
.
adapter
;
//
//
import cn.freemud.entities.dto.*;
import
cn.freemud.entities.dto.*
;
//
import cn.freemud.entities.vo.AddDeliveryAddressVo;
import
cn.freemud.entities.vo.AddDeliveryAddressVo
;
//
import cn.freemud.entities.vo.CreateOrderVo;
import
cn.freemud.entities.vo.CreateOrderVo
;
//
import cn.freemud.entities.vo.QueryReceiveAddressResponseVo;
import
cn.freemud.entities.vo.QueryReceiveAddressResponseVo
;
//
import cn.freemud.entities.vo.UserLoginVo;
import
cn.freemud.entities.vo.UserLoginVo
;
//
import cn.freemud.enums.ReceiveAddressLabelType;
import
cn.freemud.enums.ReceiveAddressLabelType
;
//
import cn.freemud.enums.SexType;
import
cn.freemud.enums.SexType
;
//
import cn.freemud.manager.OpenPlatformPartnerStoreDeliveryConfigManager;
import
cn.freemud.manager.OpenPlatformPartnerStoreDeliveryConfigManager
;
//
import cn.freemud.service.impl.StoreServiceImpl;
import
cn.freemud.service.impl.StoreServiceImpl
;
//
import cn.freemud.utils.UnicodeUtil;
import
cn.freemud.utils.UnicodeUtil
;
//
import com.alibaba.fastjson.JSONObject;
import
com.alibaba.fastjson.JSONObject
;
//
import com.google.common.collect.Lists;
import
com.google.common.collect.Lists
;
//
import com.google.common.collect.Maps;
import
com.google.common.collect.Maps
;
//
import com.google.gson.Gson;
import
com.google.gson.Gson
;
//
import org.apache.commons.collections4.CollectionUtils;
import
org.apache.commons.collections4.CollectionUtils
;
//
import org.apache.commons.lang.StringUtils;
import
org.apache.commons.lang.StringUtils
;
//
import org.springframework.beans.factory.annotation.Autowired;
import
org.springframework.beans.factory.annotation.Autowired
;
//
import org.springframework.stereotype.Component;
import
org.springframework.stereotype.Component
;
//
//
import java.util.*;
import
java.util.*
;
//
import java.util.stream.Collectors;
import
java.util.stream.Collectors
;
//
//
@Component
@Component
//
public class UserAdapter {
public
class
UserAdapter
{
//
//
public UserLoginInfoDto getUserLoginInfoDto(Map<String, Object> map) {
public
UserLoginInfoDto
getUserLoginInfoDto
(
Map
<
String
,
Object
>
map
)
{
//
UserLoginInfoDto userLoginInfoDto = new UserLoginInfoDto();
UserLoginInfoDto
userLoginInfoDto
=
new
UserLoginInfoDto
();
//
userLoginInfoDto.setOpenId(String.valueOf(map.get("openid")));
userLoginInfoDto
.
setOpenId
(
String
.
valueOf
(
map
.
get
(
"openid"
)));
//
userLoginInfoDto.setWxAppId(String.valueOf(map.get("wxAppId")));
userLoginInfoDto
.
setWxAppId
(
String
.
valueOf
(
map
.
get
(
"wxAppId"
)));
//
userLoginInfoDto.setSessionKey(String.valueOf(map.get("session_key")));
userLoginInfoDto
.
setSessionKey
(
String
.
valueOf
(
map
.
get
(
"session_key"
)));
//
userLoginInfoDto.setMobile(String.valueOf(map.get("mobile")));
userLoginInfoDto
.
setMobile
(
String
.
valueOf
(
map
.
get
(
"mobile"
)));
//
userLoginInfoDto.setAppSecret(String.valueOf(map.get("appsecret")));
userLoginInfoDto
.
setAppSecret
(
String
.
valueOf
(
map
.
get
(
"appsecret"
)));
//
userLoginInfoDto.setMemberId(String.valueOf(map.get("memberId")));
userLoginInfoDto
.
setMemberId
(
String
.
valueOf
(
map
.
get
(
"memberId"
)));
//
userLoginInfoDto.setPartnerId(String.valueOf(map.get("partnerId")));
userLoginInfoDto
.
setPartnerId
(
String
.
valueOf
(
map
.
get
(
"partnerId"
)));
//
userLoginInfoDto.setUnionId(String.valueOf(map.get("unionId")));
userLoginInfoDto
.
setUnionId
(
String
.
valueOf
(
map
.
get
(
"unionId"
)));
//
userLoginInfoDto.setNewMember(Boolean.valueOf(map.get("newMember").toString()));
userLoginInfoDto
.
setNewMember
(
Boolean
.
valueOf
(
map
.
get
(
"newMember"
).
toString
()));
//
userLoginInfoDto.setNickName(String.valueOf(map.get("nickName")));
userLoginInfoDto
.
setNickName
(
String
.
valueOf
(
map
.
get
(
"nickName"
)));
//
return userLoginInfoDto;
return
userLoginInfoDto
;
//
}
}
//
}
}
order-application-service/src/main/java/cn/freemud/entities/dto/UserLoginInfoDto.java
View file @
9df7b7c4
//package cn.freemud.entities.dto;
package
cn
.
freemud
.
entities
.
dto
;
//
//import lombok.Data;
import
lombok.Data
;
//
//@Data
@Data
//public class UserLoginInfoDto {
public
class
UserLoginInfoDto
{
//
//// private String openId;
// private String openId;
////
//// private String wxAppid;
////
//// private String sessionKey;
////
//// private String mobile;
////
//// private String appsecret;
////
//// private String memberId;
////
//// private String partnerId;
////
//// private boolean newMemeber;
////
//// private String unionId;
////
//// private String nickName;
//
//
// private String wxAppid;
//
//
// private String openId;
// private String unionId;
// private String wxAppId;
// private String sessionKey;
// private String sessionKey;
//
// private String mobile;
// private String mobile;
// private String appSecret;
//
// private String appsecret;
//
// private String memberId;
// private String memberId;
//
// private String partnerId;
// private String partnerId;
// private Boolean newMember;
//
// private String devBrand;
// private boolean newMemeber;
// private String devModel;
//
// private String channel;
// private String unionId;
//
// private String nickName;
// private String nickName;
// private String photoUrl;
// private String sessionId;
// private String tableNumber;
private
String
openId
;
// private String iappId;
private
String
unionId
;
// private String storeId;
private
String
wxAppId
;
// private String userId;
private
String
sessionKey
;
// private String accessToken;
private
String
mobile
;
// private String alipayUserId;
private
String
appSecret
;
// private String alipayAppId;
private
String
memberId
;
//}
private
String
partnerId
;
private
Boolean
newMember
;
private
String
devBrand
;
private
String
devModel
;
private
String
channel
;
private
String
nickName
;
private
String
photoUrl
;
private
String
sessionId
;
private
String
tableNumber
;
private
String
iappId
;
private
String
storeId
;
private
String
userId
;
private
String
accessToken
;
private
String
alipayUserId
;
private
String
alipayAppId
;
}
order-application-service/src/main/java/cn/freemud/service/UserService.java
View file @
9df7b7c4
//
package cn.freemud.service;
package
cn
.
freemud
.
service
;
//
//
import cn.freemud.entities.dto.UserLoginInfoDto;
import
cn.freemud.entities.dto.UserLoginInfoDto
;
//
//
import java.util.Map;
import
java.util.Map
;
//
/
//
**
/**
//
* 用户服务
* 用户服务
//
*
*
//
* @author liming.guo
* @author liming.guo
//
* @date 2018/05/08
* @date 2018/05/08
//
*/
*/
//
public interface UserService {
public
interface
UserService
{
//
//
Map<String, Object> getUserInfoMapBySessionId(String sessionId);
Map
<
String
,
Object
>
getUserInfoMapBySessionId
(
String
sessionId
);
//
//
/**
/**
//
* 获取缓存用户信息
* 获取缓存用户信息
//
*
*
//
* @param sessionId
* @param sessionId
//
* @return
* @return
//
*/
*/
//
UserLoginInfoDto getUserLoginInfoBySessionId(String sessionId);
UserLoginInfoDto
getUserLoginInfoBySessionId
(
String
sessionId
);
//
//
}
}
order-application-service/src/main/java/cn/freemud/service/impl/CheckMallOrder.java
View file @
9df7b7c4
...
@@ -70,7 +70,7 @@ public class CheckMallOrder {
...
@@ -70,7 +70,7 @@ public class CheckMallOrder {
*/
*/
public
void
checkOrderByDelivery
(
CreateOrderVo
createOrderVo
,
UserLoginInfoDto
userLoginInfoDto
,
public
void
checkOrderByDelivery
(
CreateOrderVo
createOrderVo
,
UserLoginInfoDto
userLoginInfoDto
,
StoreResponse
.
BizVO
storeResponseDto
,
Long
totalAmount
,
String
trackingNo
)
{
StoreResponse
.
BizVO
storeResponseDto
,
Long
totalAmount
,
String
trackingNo
)
{
StoreDeliveryInfoDto
storeDeliveryInfoDto
=
this
.
getStoreDeliveryInfo
(
storeResponseDto
,
userLoginInfoDto
.
getWxApp
i
d
());
StoreDeliveryInfoDto
storeDeliveryInfoDto
=
this
.
getStoreDeliveryInfo
(
storeResponseDto
,
userLoginInfoDto
.
getWxApp
I
d
());
//订单金额小于起送费提示
//订单金额小于起送费提示
if
(
storeDeliveryInfoDto
.
getDeliveryLimitAmount
()
>
totalAmount
)
{
if
(
storeDeliveryInfoDto
.
getDeliveryLimitAmount
()
>
totalAmount
)
{
throw
new
ServiceException
(
ResponseResult
.
STORE_DISCONTENT_DELIVERY_FEE
);
throw
new
ServiceException
(
ResponseResult
.
STORE_DISCONTENT_DELIVERY_FEE
);
...
...
order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java
View file @
9df7b7c4
...
@@ -128,7 +128,7 @@ public class MallOrderServiceImpl implements MallOrderService {
...
@@ -128,7 +128,7 @@ public class MallOrderServiceImpl implements MallOrderService {
// 查询用户信息、校验svc卡,余额购物车校验
// 查询用户信息、校验svc卡,余额购物车校验
UserLoginInfoDto
userLoginInfoDto
=
checkMallOrder
.
checkOrderByMember
(
createOrderVo
,
trackingNo
);
UserLoginInfoDto
userLoginInfoDto
=
checkMallOrder
.
checkOrderByMember
(
createOrderVo
,
trackingNo
);
// 设置门店id为商城的虚拟门店id
// 设置门店id为商城的虚拟门店id
this
.
change2BindMallShopId
(
createOrderVo
,
userLoginInfoDto
.
getWxApp
i
d
());
this
.
change2BindMallShopId
(
createOrderVo
,
userLoginInfoDto
.
getWxApp
I
d
());
// 查询门店信息 营业时间、营业状态,服务器当前时间在营业时间内 点餐桌号
// 查询门店信息 营业时间、营业状态,服务器当前时间在营业时间内 点餐桌号
StoreResponse
.
BizVO
storeResponseDto
=
checkMallOrder
.
checkOrderByStore
(
createOrderVo
,
trackingNo
);
StoreResponse
.
BizVO
storeResponseDto
=
checkMallOrder
.
checkOrderByStore
(
createOrderVo
,
trackingNo
);
// 查询购物车(内部校验券点餐方式,券是否可用) 校验当前订单类型的下单参数
// 查询购物车(内部校验券点餐方式,券是否可用) 校验当前订单类型的下单参数
...
@@ -220,7 +220,7 @@ public class MallOrderServiceImpl implements MallOrderService {
...
@@ -220,7 +220,7 @@ public class MallOrderServiceImpl implements MallOrderService {
OrderExtInfoDTO
orderExtInfoDto
=
new
OrderExtInfoDTO
();
OrderExtInfoDTO
orderExtInfoDto
=
new
OrderExtInfoDTO
();
orderExtInfoDto
.
setOpenid
(
userLoginInfoDto
.
getOpenId
());
orderExtInfoDto
.
setOpenid
(
userLoginInfoDto
.
getOpenId
());
orderExtInfoDto
.
setAppid
(
userLoginInfoDto
.
getWxApp
i
d
());
orderExtInfoDto
.
setAppid
(
userLoginInfoDto
.
getWxApp
I
d
());
orderExtInfoDto
.
setSessionId
(
sessionId
);
orderExtInfoDto
.
setSessionId
(
sessionId
);
orderExtInfoDto
.
setVersion
(
version
);
orderExtInfoDto
.
setVersion
(
version
);
return
orderExtInfoDto
;
return
orderExtInfoDto
;
...
@@ -293,7 +293,7 @@ public class MallOrderServiceImpl implements MallOrderService {
...
@@ -293,7 +293,7 @@ public class MallOrderServiceImpl implements MallOrderService {
}
}
private
PaymentRequest
orderBodyConvertToPaymentBody
(
UserLoginInfoDto
userLoginInfoDto
,
String
partnerId
)
{
private
PaymentRequest
orderBodyConvertToPaymentBody
(
UserLoginInfoDto
userLoginInfoDto
,
String
partnerId
)
{
String
wxAppId
=
userLoginInfoDto
.
getWxApp
i
d
();
String
wxAppId
=
userLoginInfoDto
.
getWxApp
I
d
();
//设置支付信息
//设置支付信息
PaymentRequest
paymentRequest
=
new
PaymentRequest
();
PaymentRequest
paymentRequest
=
new
PaymentRequest
();
paymentRequest
.
setOpenId
(
userLoginInfoDto
.
getOpenId
());
paymentRequest
.
setOpenId
(
userLoginInfoDto
.
getOpenId
());
...
...
order-application-service/src/main/java/cn/freemud/service/impl/UserServiceImpl.java
View file @
9df7b7c4
//
package cn.freemud.service.impl;
package
cn
.
freemud
.
service
.
impl
;
//
//
import cn.freemud.adapter.UserAdapter;
import
cn.freemud.adapter.UserAdapter
;
//
import cn.freemud.constant.RedisKeyConstant;
import
cn.freemud.constant.RedisKeyConstant
;
//
import cn.freemud.constant.UserInfoKeyConstant;
import
cn.freemud.constant.UserInfoKeyConstant
;
//
import cn.freemud.entities.dto.UserLoginInfoDto;
import
cn.freemud.entities.dto.UserLoginInfoDto
;
//
import cn.freemud.enums.ResponseResult;
import
cn.freemud.enums.ResponseResult
;
//
import cn.freemud.interceptor.ServiceException;
import
cn.freemud.interceptor.ServiceException
;
//
import cn.freemud.redis.RedisCache;
import
cn.freemud.redis.RedisCache
;
//
import cn.freemud.service.UserService;
import
cn.freemud.service.UserService
;
//
import com.google.gson.Gson;
import
com.google.gson.Gson
;
//
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.stereotype.Service;
import
org.springframework.stereotype.Service
;
//
//
import java.util.Map;
import
java.util.Map
;
//
/
//
**
/**
//
* @author liming.guo
* @author liming.guo
//
* @date 2018/05/11
* @date 2018/05/11
//
*/
*/
//
@Service
@Service
//
@Slf4j
@Slf4j
//
public class UserServiceImpl implements UserService {
public
class
UserServiceImpl
implements
UserService
{
//
private static Gson gson = new Gson();
private
static
Gson
gson
=
new
Gson
();
//
@Autowired
@Autowired
//
private UserAdapter userAdapter;
private
UserAdapter
userAdapter
;
//
@Autowired
@Autowired
//
private RedisCache redisCache;
private
RedisCache
redisCache
;
//
//
/**
/**
//
* 校验用户是否登录
* 校验用户是否登录
//
*/
*/
//
public void checkUserLogin(String sessionId) {
public
void
checkUserLogin
(
String
sessionId
)
{
//
Map<String, Object> userInfoMap = this.getUserInfoMapBySessionId(sessionId);
Map
<
String
,
Object
>
userInfoMap
=
this
.
getUserInfoMapBySessionId
(
sessionId
);
//
if (userInfoMap == null || userInfoMap.size() <= 0 || userInfoMap.get(UserInfoKeyConstant.MEMBER_ID) == null) {
if
(
userInfoMap
==
null
||
userInfoMap
.
size
()
<=
0
||
userInfoMap
.
get
(
UserInfoKeyConstant
.
MEMBER_ID
)
==
null
)
{
//
throw new ServiceException(ResponseResult.NOT_LOGIN);
throw
new
ServiceException
(
ResponseResult
.
NOT_LOGIN
);
//
}
}
//
}
}
//
/**
/**
//
* 校验用户是否登录
* 校验用户是否登录
//
*/
*/
//
public boolean checkUserLoginFlag(String sessionId) {
public
boolean
checkUserLoginFlag
(
String
sessionId
)
{
//
Map<String, Object> userInfoMap = this.getUserInfoMapBySessionId(sessionId);
Map
<
String
,
Object
>
userInfoMap
=
this
.
getUserInfoMapBySessionId
(
sessionId
);
//
log.info("submit userInfoMap:{}", gson.toJson(userInfoMap));
log
.
info
(
"submit userInfoMap:{}"
,
gson
.
toJson
(
userInfoMap
));
//
if (userInfoMap == null || userInfoMap.size() <= 0 || userInfoMap.get(UserInfoKeyConstant.MEMBER_ID) == null) {
if
(
userInfoMap
==
null
||
userInfoMap
.
size
()
<=
0
||
userInfoMap
.
get
(
UserInfoKeyConstant
.
MEMBER_ID
)
==
null
)
{
//
return false;
return
false
;
//
}
}
//
return true;
return
true
;
//
}
}
//
//
/**
/**
//
* 获取缓存用户信息
* 获取缓存用户信息
//
*/
*/
//
@Override
@Override
//
public Map<String, Object> getUserInfoMapBySessionId(String sessionId) {
public
Map
<
String
,
Object
>
getUserInfoMapBySessionId
(
String
sessionId
)
{
//
String redisKey = RedisKeyConstant.SAAS_USER_INFO_SESSIONID_KEY_PREFIX + sessionId;
String
redisKey
=
RedisKeyConstant
.
SAAS_USER_INFO_SESSIONID_KEY_PREFIX
+
sessionId
;
//
Map<String, Object> map;
Map
<
String
,
Object
>
map
;
//
try {
try
{
//
map = redisCache.getValue(redisKey);
map
=
redisCache
.
getValue
(
redisKey
);
//
}catch (Exception e){
}
catch
(
Exception
e
){
//
map = redisCache.getValue(redisKey);
map
=
redisCache
.
getValue
(
redisKey
);
//
}
}
//
return map;
return
map
;
//
}
}
//
//
/**
/**
//
* 获取缓存用户信息
* 获取缓存用户信息
//
*
*
//
* @param sessionId
* @param sessionId
//
* @return
* @return
//
*/
*/
//
@Override
@Override
//
public UserLoginInfoDto getUserLoginInfoBySessionId(String sessionId) {
public
UserLoginInfoDto
getUserLoginInfoBySessionId
(
String
sessionId
)
{
//
checkUserLogin(sessionId);
checkUserLogin
(
sessionId
);
//
//
String redisKey = RedisKeyConstant.SAAS_USER_INFO_SESSIONID_KEY_PREFIX + sessionId;
String
redisKey
=
RedisKeyConstant
.
SAAS_USER_INFO_SESSIONID_KEY_PREFIX
+
sessionId
;
//
Map<String, Object> map = redisCache.getValue(redisKey);
Map
<
String
,
Object
>
map
=
redisCache
.
getValue
(
redisKey
);
//
return userAdapter.getUserLoginInfoDto(map);
return
userAdapter
.
getUserLoginInfoDto
(
map
);
//
}
}
//
}
}
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