广州市综治平台后端
xusd
2025-06-07 36306491396230522fa20585c2621a7fc899849a
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
158
159
160
package cn.huge.module.judic.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.judic.dao.mapper.JudicAssistMapper;
import cn.huge.module.judic.domain.po.JudicAssist;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
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.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.Date;
import java.util.List;
import java.util.Map;
 
/**
 * @title: 司法确认参与人表业务逻辑处理
 * @Description JPA的单表数据查询以由BaseService完成
 * @company hugeinfo
 * @author liyj
 * @Time 2022-04-18 10:40:05
 * @version 1.0.0
 */
@Slf4j
@Service
@Transactional(rollbackFor = Exception.class)
public class JudicAssistService extends ServiceImpl<JudicAssistMapper, JudicAssist>{
 
    @Autowired
    private JudicAssistMapper mapper;
 
    @Autowired
    private UtilsClientImpl utilsClient;
 
    /**
    * 更新对象
    * @param entity 对象
    */
    public void updateJudicAssist(JudicAssist entity){
        try{
            mapper.updateJudicAssist(entity);
        }catch (Exception e){
            log.error("service方法[JudicAssistService.updateJudicAssist]调用异常:"+e, e);
            throw new ServiceException("JudicAssistService.updateJudicAssist", e);
        }
    }
 
    /**
    * 条件更新对象
    * @param entity 对象
    * @param terms 条件
    */
    public void updateJudicAssistTerms(JudicAssist entity, Map<String, Object> terms){
        try{
            mapper.updateJudicAssistTerms(entity, terms);
        }catch (Exception e){
            log.error("service方法[JudicAssistService.updateJudicAssistTerms]调用异常:"+e, e);
            throw new ServiceException("JudicAssistService.updateJudicAssistTerms", e);
        }
    }
 
    /**
    * 根据编号物理删除
    * @param id 查询条件集合
    */
    public void deleteJudicAssist(String id){
        try{
            mapper.deleteJudicAssist(id);
        }catch (Exception e){
            log.error("service方法[JudicAssistService.deleteJudicAssist]调用异常:"+e, e);
            throw new ServiceException("JudicAssistService.deleteJudicAssist", e);
        }
    }
 
    /**
    * 按条件查询
    * @param terms 条件
    * @return List
    */
    public List<JudicAssist> 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<JudicAssist> pageQuery(PageRequest page, Map<String, Object> terms){
        long total = mapper.countTerms(terms);
        List<JudicAssist> content = mapper.pageTerms(page, terms);
        return new PageImpl<JudicAssist>(content, page, total);
    }
 
    /**
    * 新增或更新对象
    * @param judicAssist 实体对象
    */
    public void saveJudicAssist(JudicAssist judicAssist){
        try{
            Date nowDate = DateUtils.getNowDate();
            // 判断是否新增
            if (IdUtils.checkNewId(judicAssist.getId())){
                judicAssist.setId(utilsClient.getNewTimeId());
                judicAssist.setCreateTime(nowDate);
            }
            judicAssist.setUpdateTime(nowDate);
            this.saveOrUpdate(judicAssist);
        }catch (Exception e){
            log.error("service方法[JudicAssistService.saveJudicAssist]调用异常:"+e, e);
            throw new ServiceException("JudicAssistService.saveJudicAssist", e);
        }
    }
 
    /**
     * 根据司法确认编号删除
     * @param judicId 司法确认编号
     */
    public void removeByJudicId(String judicId){
        try{
            QueryWrapper<JudicAssist> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("judic_id", judicId);
            mapper.delete(queryWrapper);
        }catch (Exception e){
            log.error("service方法[JudicTaskService.removeByJudicId]调用异常:"+e, e);
            throw new ServiceException("JudicTaskService.removeByJudicId", e);
        }
    }
 
 
    /**
     * 根据司法确认编号查询某一类型以外的数据
     * @param judicId 司法确认编号
     * @param assType 类型
     * @return
     */
    public List<JudicAssist> listByJudicIdNotType(String judicId, String assType){
        QueryWrapper<JudicAssist> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("judic_id", judicId).ne("ass_type", assType);
        return mapper.selectList(queryWrapper);
    }
 
}