Commit 3767183d by huluobin

update

parent 0577f909
...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gogirl.application.xcx.CustomerMessageService; import com.gogirl.application.xcx.CustomerMessageService;
import com.gogirl.domain.user.customer.CustomerMessage; import com.gogirl.domain.user.customer.CustomerMessage;
import com.gogirl.infrastructure.common.exception.RRException;
import com.gogirl.infrastructure.mapper.user.customer.CustomerMessageMapper; import com.gogirl.infrastructure.mapper.user.customer.CustomerMessageMapper;
import com.gogirl.infrastructure.util.SessionUtils; import com.gogirl.infrastructure.util.SessionUtils;
import com.gogirl.shared.user.command.ReadMessageCommand; import com.gogirl.shared.user.command.ReadMessageCommand;
...@@ -28,6 +29,9 @@ public class CustomerMessageServiceImpl extends ServiceImpl<CustomerMessageMappe ...@@ -28,6 +29,9 @@ public class CustomerMessageServiceImpl extends ServiceImpl<CustomerMessageMappe
@Override @Override
public Page<CustomerMessage> queryPageMessage(CustomerMessagePageQuery qry) { public Page<CustomerMessage> queryPageMessage(CustomerMessagePageQuery qry) {
//线程变量当前当前用户id //线程变量当前当前用户id
if (SessionUtils.getCustomerToken() == null) {
throw new RRException(2001, "token失效");
}
qry.setCustomerId(SessionUtils.getCustomerToken().getCustomerId()); qry.setCustomerId(SessionUtils.getCustomerToken().getCustomerId());
LambdaQueryWrapper<CustomerMessage> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<CustomerMessage> wrapper = new LambdaQueryWrapper<>();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment