From c06b2f5b2aa6d8910664b30ab4f74ff3895ebbeb Mon Sep 17 00:00:00 2001 From: liyj <15602261488@163.com> Date: Fri, 20 Sep 2024 10:27:45 +0800 Subject: [PATCH] Merge branch 'master' into gzdyh_test --- dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseAssistInfoService.java | 157 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 157 insertions(+), 0 deletions(-) diff --git a/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseAssistInfoService.java b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseAssistInfoService.java new file mode 100644 index 0000000..26844d0 --- /dev/null +++ b/dyh-service/dyh-mediate/src/main/java/cn/huge/module/cases/service/CaseAssistInfoService.java @@ -0,0 +1,157 @@ +package cn.huge.module.cases.service; + +import cn.huge.base.common.exception.ServiceException; +import cn.huge.base.common.utils.DateUtils; +import cn.huge.base.common.utils.IdUtils; +import cn.huge.module.client.api.impl.UtilsClientImpl; +import cn.huge.module.cases.dao.mapper.CaseAssistInfoMapper; +import cn.huge.module.cases.domain.po.CaseAssistInfo; +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; + +/** + * @title: 联合处置信息表业务逻辑处理 + * @Description 联合处置信息表业务逻辑处理 + * @company hugeinfo + * @author liyj + * @Time 2024-09-18 09:36:59 + * @version 1.0.0 + */ +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class CaseAssistInfoService extends ServiceImpl<CaseAssistInfoMapper, CaseAssistInfo>{ + + @Autowired + private CaseAssistInfoMapper mapper; + + @Autowired + private UtilsClientImpl utilsClient; + + /** + * 更新对象 + * @param entity 对象 + */ + public void updateCaseAssistInfo(CaseAssistInfo entity){ + try{ + mapper.updateCaseAssistInfo(entity); + }catch (Exception e){ + log.error("[CaseAssistInfoService.updateCaseAssistInfo]调用失败,异常信息:"+e, e); + throw new ServiceException("CaseAssistInfoService.updateCaseAssistInfo", e); + } + } + + /** + * 条件更新对象 + * @param entity 对象 + * @param terms 条件 + */ + public void updateCaseAssistInfoTerms(CaseAssistInfo entity, Map<String, Object> terms){ + try{ + mapper.updateCaseAssistInfoTerms(entity, terms); + }catch (Exception e){ + log.error("[CaseAssistInfoService.updateCaseAssistInfoTerms]调用失败,异常信息:"+e, e); + throw new ServiceException("CaseAssistInfoService.updateCaseAssistInfoTerms", e); + } + } + + /** + * 根据编号物理删除 + * @param id 查询条件集合 + */ + public void deleteCaseAssistInfo(String id){ + try{ + mapper.deleteCaseAssistInfo(id); + }catch (Exception e){ + log.error("[CaseAssistInfoService.deleteCaseAssistInfo]调用失败,异常信息:"+e, e); + throw new ServiceException("CaseAssistInfoService.deleteCaseAssistInfo", e); + } + } + + /** + * 按条件查询 + * @param terms 条件 + * @return List + */ + public List<CaseAssistInfo> listTerms(Map<String, Object> terms){ + return mapper.listTerms(terms); + } + + /** + * 按条件统计 + * @param terms 条件 + * @return long + */ + public long countTerms(Map<String, Object> terms){ + return mapper.countTerms(terms); + } + + /** + * 按条件分页查询 + * @param page 分页对象 + * @param terms 条件 + * @return Page + */ + public Page<CaseAssistInfo> pageQuery(PageRequest page, Map<String, Object> terms){ + long total = mapper.countTerms(terms); + List<CaseAssistInfo> content = mapper.pageTerms(page, terms); + return new PageImpl<CaseAssistInfo>(content, page, total); + } + + /** + * 新增或更新对象 + * @param caseAssistInfo 实体对象 + */ + public void saveCaseAssistInfo(CaseAssistInfo caseAssistInfo){ + try{ + Date nowDate = DateUtils.getNowDate(); + // 判断是否新增 + if (IdUtils.checkNewId(caseAssistInfo.getId())){ + caseAssistInfo.setId(utilsClient.getNewTimeId()); + caseAssistInfo.setCreateTime(nowDate); + } + caseAssistInfo.setUpdateTime(nowDate); + this.saveOrUpdate(caseAssistInfo); + }catch (Exception e){ + log.error("[CaseAssistInfoService.saveCaseAssistInfo]调用失败,异常信息:"+e, e); + throw new ServiceException("CaseAssistInfoService.saveCaseAssistInfo", e); + } + } + + /** + * 根据纠纷处理任务编号查询 + * @param caseTaskId + * @return + */ + public CaseAssistInfo getByCaseTaskId(String caseTaskId){ + QueryWrapper<CaseAssistInfo> caseAssistInfoQueryWrapper = new QueryWrapper<>(); + caseAssistInfoQueryWrapper.eq("case_task_id", caseTaskId); + CaseAssistInfo caseAssistInfo = mapper.selectOne(caseAssistInfoQueryWrapper); + return caseAssistInfo; + } + + /** + * 根据案件编号查询 + * @param caseId + * @return + */ + public List<CaseAssistInfo> listByCaseId(String caseId){ + QueryWrapper<CaseAssistInfo> caseAssistInfoQueryWrapper = new QueryWrapper<>(); + caseAssistInfoQueryWrapper.eq("case_id", caseId); + return mapper.selectList(caseAssistInfoQueryWrapper); + } + +} -- Gitblit v1.8.0