gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.0.0): 完成通知更新

Browse Source
This commit is contained in:
opensnail 2024-04-21 09:48:05 +08:00
parent 49daf08655
commit 535fe09741
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/NotifyRecipientServiceImpl.java
View File

@ -8,6 +8,7 @@ import com.aizuda.snailjob.server.web.model.response.CommonLabelValueResponseVO;
import com.aizuda.snailjob.server.web.model.response.NotifyRecipientResponseVO; import com.aizuda.snailjob.server.web.model.response.NotifyRecipientResponseVO;
import com.aizuda.snailjob.server.web.service.NotifyRecipientService; import com.aizuda.snailjob.server.web.service.NotifyRecipientService;
import com.aizuda.snailjob.server.web.service.convert.NotifyRecipientConverter; import com.aizuda.snailjob.server.web.service.convert.NotifyRecipientConverter;
import com.aizuda.snailjob.server.web.util.UserSessionUtils;
import com.aizuda.snailjob.template.datasource.persistence.mapper.NotifyRecipientMapper; import com.aizuda.snailjob.template.datasource.persistence.mapper.NotifyRecipientMapper;
import com.aizuda.snailjob.template.datasource.persistence.po.NotifyRecipient; import com.aizuda.snailjob.template.datasource.persistence.po.NotifyRecipient;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -48,12 +49,18 @@ public class NotifyRecipientServiceImpl implements NotifyRecipientService {
@Override @Override
public Boolean saveNotifyRecipient(NotifyRecipientRequestVO requestVO) { public Boolean saveNotifyRecipient(NotifyRecipientRequestVO requestVO) {
return 1 == notifyRecipientMapper.insert(NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO)); String namespaceId = UserSessionUtils.currentUserSession().getNamespaceId();
NotifyRecipient notifyRecipient = NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO);
notifyRecipient.setNamespaceId(namespaceId);
return 1 == notifyRecipientMapper.insert(notifyRecipient);
} }
@Override @Override
public Boolean updateNotifyRecipient(NotifyRecipientRequestVO requestVO) { public Boolean updateNotifyRecipient(NotifyRecipientRequestVO requestVO) {
return 1 == notifyRecipientMapper.updateById(NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO)); String namespaceId = UserSessionUtils.currentUserSession().getNamespaceId();
NotifyRecipient notifyRecipient = NotifyRecipientConverter.INSTANCE.toNotifyRecipient(requestVO);
notifyRecipient.setNamespaceId(namespaceId);
return 1 == notifyRecipientMapper.updateById(notifyRecipient);
} }
@Override @Override