广州市综治平台后端
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
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);
    }
 
}