From 0b597ea4500b3463ac9f0983dbabaca52417226c Mon Sep 17 00:00:00 2001 From: liyj <1003249715@qq.com> Date: Sat, 14 Sep 2024 12:21:37 +0800 Subject: [PATCH] 回退上报流程bug修复2 --- dyh-service/dyh-cust/src/main/java/cn/huge/module/ctuser/service/CtUsepostService.java | 20 +++++++++++++++++--- 1 files changed, 17 insertions(+), 3 deletions(-) diff --git a/dyh-service/dyh-cust/src/main/java/cn/huge/module/ctuser/service/CtUsepostService.java b/dyh-service/dyh-cust/src/main/java/cn/huge/module/ctuser/service/CtUsepostService.java index f43c4da..f3ef642 100644 --- a/dyh-service/dyh-cust/src/main/java/cn/huge/module/ctuser/service/CtUsepostService.java +++ b/dyh-service/dyh-cust/src/main/java/cn/huge/module/ctuser/service/CtUsepostService.java @@ -6,17 +6,16 @@ import cn.huge.module.client.api.impl.UtilsClientImpl; import cn.huge.module.ctuser.dao.mapper.CtUsepostMapper; import cn.huge.module.ctuser.domain.po.CtUsepost; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.PageRequest; import org.springframework.transaction.annotation.Transactional; -import javax.annotation.PostConstruct; import java.util.Date; import java.util.List; import java.util.Map; @@ -116,7 +115,7 @@ */ public void saveCtUsepost(CtUsepost ctUsepost){ try{ - Date nowDate = DateUtils.getMowDate(); + Date nowDate = DateUtils.getNowDate(); // 判断是否新增 if (IdUtils.checkNewId(ctUsepost.getId())){ ctUsepost.setId(utilsClient.getNewTimeId()); @@ -130,4 +129,19 @@ } } + /** + * 根据用户编号物理删除 + * @param userId 用户编号 + */ + public void deleteByUserId(String userId){ + try{ + QueryWrapper<CtUsepost> ctUseroleQueryWrapper = new QueryWrapper<>(); + ctUseroleQueryWrapper.eq("user_id", userId); + mapper.delete(ctUseroleQueryWrapper); + }catch (Exception e){ + log.error("[CtUsepostService.deleteByUserId]调用失败,异常信息:"+e, e); + throw new ServiceException("CtUsepostService.deleteByUserId", e); + } + } + } -- Gitblit v1.8.0