diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxActivityJoinServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxActivityJoinServiceImpl.java index 7247a8eb2..95959d4ba 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxActivityJoinServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxActivityJoinServiceImpl.java @@ -109,13 +109,18 @@ public class WxActivityJoinServiceImpl implements WxActivityJoinService { @Override public ResultData sendMsg(WxActivityJoin wxActivityJoin) { + wxActivityJoin.setSendMsg(EnumSendMsg.NO.getCode()); + wxActivityJoin.setStatus(EnumActivityJoinStatus.CONFIRMED.getCode()); + List joinList = wxActivityJoinMapper.select(wxActivityJoin); + if (joinList.size() == 0) { + return new ResultData(); + } + //更改状态 WxActivity activity = wxActivityMapper.selectByPrimaryKey(wxActivityJoin.getActivityId()); activity.setSendMsg(EnumSendMsg.YES.getCode()); activity.setUpdateTime(new Date()); wxActivityMapper.updateByPrimaryKeySelective(activity); - wxActivityJoin.setSendMsg(EnumSendMsg.NO.getCode()); - wxActivityJoin.setStatus(EnumActivityJoinStatus.CONFIRMED.getCode()); - List joinList = wxActivityJoinMapper.select(wxActivityJoin); + //发短信 for (WxActivityJoin join : joinList) { sendMessage(join, activity); } @@ -123,6 +128,8 @@ public class WxActivityJoinServiceImpl implements WxActivityJoinService { param.put("sendMsg", EnumSendMsg.YES.getCode()); param.put("joinList", joinList); wxActivityJoinMapper.updateSendMsg(param); + + return new ResultData(); }