提交代码

master
胡锐 1 month ago
parent 1c6585b060
commit bd64c3a16f
  1. 4
      cweb/src/main/java/com/hfkj/controller/MessageController.java
  2. 23
      cweb/src/main/java/com/hfkj/controller/TestController.java
  3. 2
      service/src/main/java/com/hfkj/service/message/impl/BsMessageReadServiceImpl.java

@ -63,7 +63,7 @@ public class MessageController {
Map<String,Object> param = new HashMap<>();
param.put("userId", userSession.getUser().getId());
param.put("status", MessageStatusEnum.status2.getStatus());
param.put("msgStatus", MessageStatusEnum.status2.getStatus());
param.put("type", type);
PageHelper.startPage(pageNum,pageSize);
@ -85,7 +85,7 @@ public class MessageController {
for (MessageTypeEnum type : MessageTypeEnum.values()) {
Map<String,Object> param = new HashMap<>();
param.put("userId", userSession.getUser().getId());
param.put("status", MessageStatusEnum.status2.getStatus());
param.put("msgStatus", MessageStatusEnum.status2.getStatus());
param.put("type", type.getType());
param.put("readStatus", 0);
List<Map<String, Object>> list = messageService.getUserMsgList(param);

@ -51,12 +51,13 @@ public class TestController {
@Resource
private BsUserService bsUserService;
@Resource
private BsUserContributeService userContributeService;
@RequestMapping(value="/getPublisherInfo",method = RequestMethod.GET)
@ResponseBody
@ApiOperation(value = "淘宝客-公用-私域用户备案")
public ResponseData getPublisherInfo(@RequestParam(value = "code" , required = false) String code
) {
public ResponseData getPublisherInfo(@RequestParam(value = "code" , required = false) String code) {
try {
// 用户session
UserSessionObject userSession = userCenter.getSessionModel(UserSessionObject.class);
@ -78,7 +79,25 @@ public class TestController {
}
}
@RequestMapping(value="/purchase",method = RequestMethod.GET)
@ResponseBody
@ApiOperation(value = "会员贡献测试")
public ResponseData purchase(@RequestParam(value = "rebate" , required = true) BigDecimal rebate,
@RequestParam(value = "userId" , required = true) Long userId) {
try {
Map<String,Object> otherParam = new HashMap<>();
otherParam.put("sourceId", System.currentTimeMillis());
otherParam.put("sourceOrderNo", System.currentTimeMillis());
userContributeService.purchase(rebate, userId, otherParam);
return ResponseMsgUtil.success("操作成功");
} catch (Exception e) {
log.error("error!",e);
return ResponseMsgUtil.exception(e);
}
}
}

@ -54,7 +54,7 @@ public class BsMessageReadServiceImpl implements BsMessageReadService {
Map<String,Object> param = new HashMap<>();
param.put("userId", userId);
param.put("type", messageType.getType());
param.put("status", MessageStatusEnum.status2.getStatus());
param.put("msgStatus", MessageStatusEnum.status2.getStatus());
// 未读
param.put("readStatus", 0);

Loading…
Cancel
Save