修复消息撤回失败的问题

master
toesbieya 6 years ago
parent 445e5b4b39
commit e2e2c1d21c
  1. 5
      java/cloud/web/web-modules/message/src/main/java/cn/toesbieya/jxc/message/controller/ManageController.java
  2. 4
      java/cloud/web/web-modules/message/src/main/java/cn/toesbieya/jxc/message/service/ManageService.java
  3. 1
      java/local/src/main/java/cn/toesbieya/jxc/controller/msg/ManageController.java
  4. 4
      java/local/src/main/java/cn/toesbieya/jxc/service/msg/MsgService.java

@ -3,6 +3,7 @@ package cn.toesbieya.jxc.message.controller;
import cn.toesbieya.jxc.common.model.entity.Msg; import cn.toesbieya.jxc.common.model.entity.Msg;
import cn.toesbieya.jxc.common.model.entity.SysUser; import cn.toesbieya.jxc.common.model.entity.SysUser;
import cn.toesbieya.jxc.common.model.vo.Result; import cn.toesbieya.jxc.common.model.vo.Result;
import cn.toesbieya.jxc.common.model.vo.UserVo;
import cn.toesbieya.jxc.message.constant.MsgConstant; import cn.toesbieya.jxc.message.constant.MsgConstant;
import cn.toesbieya.jxc.message.model.vo.MsgSearch; import cn.toesbieya.jxc.message.model.vo.MsgSearch;
import cn.toesbieya.jxc.message.service.ManageService; import cn.toesbieya.jxc.message.service.ManageService;
@ -69,11 +70,11 @@ public class ManageController {
public Result withdraw(@RequestBody Msg msg) { public Result withdraw(@RequestBody Msg msg) {
if (msg.getId() == null) return Result.fail("参数错误"); if (msg.getId() == null) return Result.fail("参数错误");
SysUser user = SessionUtil.get(); UserVo user = SessionUtil.get();
msg.setWid(user.getId()); msg.setWid(user.getId());
msg.setWname(user.getName()); msg.setWname(user.getName());
msg.setWtime(System.currentTimeMillis()); msg.setWtime(System.currentTimeMillis());
msg.setStatus(MsgConstant.STATUS_WITHDREW);
return service.withdraw(msg); return service.withdraw(msg);
} }

@ -111,12 +111,12 @@ public class ManageService {
int rows = mapper.update( int rows = mapper.update(
null, null,
Wrappers.lambdaUpdate(Msg.class) Wrappers.lambdaUpdate(Msg.class)
.set(Msg::getStatus, msg.getStatus()) .set(Msg::getStatus, MsgConstant.STATUS_WITHDREW)
.set(Msg::getWid, msg.getWid()) .set(Msg::getWid, msg.getWid())
.set(Msg::getWname, msg.getWname()) .set(Msg::getWname, msg.getWname())
.set(Msg::getWtime, msg.getWtime()) .set(Msg::getWtime, msg.getWtime())
.eq(Msg::getId, msg.getId()) .eq(Msg::getId, msg.getId())
.eq(Msg::getStatus, msg.getStatus()) .eq(Msg::getStatus, MsgConstant.STATUS_PUBLISHED)
); );
return rows > 0 ? Result.success("撤回成功", msg) : Result.fail("撤回失败,请刷新重试"); return rows > 0 ? Result.success("撤回成功", msg) : Result.fail("撤回失败,请刷新重试");
} }

@ -73,7 +73,6 @@ public class ManageController {
msg.setWid(user.getId()); msg.setWid(user.getId());
msg.setWname(user.getName()); msg.setWname(user.getName());
msg.setWtime(System.currentTimeMillis()); msg.setWtime(System.currentTimeMillis());
msg.setStatus(MsgConstant.STATUS_WITHDREW);
return service.withdraw(msg); return service.withdraw(msg);
} }

@ -113,12 +113,12 @@ public class MsgService {
int rows = mapper.update( int rows = mapper.update(
null, null,
Wrappers.lambdaUpdate(Msg.class) Wrappers.lambdaUpdate(Msg.class)
.set(Msg::getStatus, msg.getStatus()) .set(Msg::getStatus, MsgConstant.STATUS_WITHDREW)
.set(Msg::getWid, msg.getWid()) .set(Msg::getWid, msg.getWid())
.set(Msg::getWname, msg.getWname()) .set(Msg::getWname, msg.getWname())
.set(Msg::getWtime, msg.getWtime()) .set(Msg::getWtime, msg.getWtime())
.eq(Msg::getId, msg.getId()) .eq(Msg::getId, msg.getId())
.eq(Msg::getStatus, msg.getStatus()) .eq(Msg::getStatus, MsgConstant.STATUS_PUBLISHED)
); );
return rows > 0 ? Result.success("撤回成功", msg) : Result.fail("撤回失败,请刷新重试"); return rows > 0 ? Result.success("撤回成功", msg) : Result.fail("撤回失败,请刷新重试");
} }

Loading…
Cancel
Save