guoshilong
2024-02-27 0bdd1bda41e6fa8436d070b1f4e5b1f19f86d9d8
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
package cn.gistack.sm.sjztmd.service.impl;
 
import cn.gistack.sm.intelligentCall.mapper.CallTaskMapper;
import cn.gistack.sm.sjztmd.dto.AttResBaseUserDTO;
import cn.gistack.sm.sjztmd.entity.AttResBase;
import cn.gistack.sm.sjztmd.entity.RelResLabel;
import cn.gistack.sm.sjztmd.mapper.AttResBaseMapper;
import cn.gistack.sm.sjztmd.service.IAttResBaseService;
import cn.gistack.sm.sjztmd.service.IRelResLabelService;
import cn.gistack.sm.sjztmd.vo.AttResAdVO;
import cn.gistack.sm.sjztmd.vo.AttResBaseGeneralInvestigationVO;
import cn.gistack.sm.sjztmd.vo.AttResBaseVO;
import cn.gistack.sm.sjztmd.vo.ManagePersonVO;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.core.tool.utils.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestParam;
 
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
 
/**
 * @ClassName AttResBaseServiceImpl
 * @Description TODO
 * @Author aix
 * @Date 2023/4/21 20:01
 * @Version 1.0
 */
@Service
@DS("zt")
public class AttResBaseServiceImpl extends ServiceImpl<AttResBaseMapper, AttResBase> implements IAttResBaseService {
 
    @Autowired
    private CallTaskMapper callTaskMapper;
 
    @Autowired
    private IRelResLabelService relResLabelService;
 
 
    @Override
    public IPage<AttResBase> selectAttResBasePage(IPage<AttResBase> page, AttResBase attResBase) {
        return page.setRecords(baseMapper.selectAttResBasePage(page,attResBase));
    }
 
    @Override
    public IPage<AttResBaseGeneralInvestigationVO> selectAttResBaseGeneralInvestigation(IPage<AttResBaseGeneralInvestigationVO> page, AttResBaseGeneralInvestigationVO attResBase) {
        return page.setRecords(baseMapper.selectAttResBaseGeneralInvestigation(page,attResBase));
    }
 
    @Override
    public IPage<AttResBase> getListByRegion(IPage<AttResBase> page,Map<String, Object> obj) {
        return page.setRecords(baseMapper.getListByRegion(page,obj));
    }
 
    @Override
    public AttResBase getDetailByCode(String code) {
        return baseMapper.getDetailByCode(code);
    }
 
    /**
     * 获取水库对应责任人分页数据
     * @param params 条件查询参数对象
     * @param page 分页查询参数对象
     * @return
     */
    @Override
    public Object getAttResBaseUserPage(IPage<AttResBaseUserDTO> page,Map<String, Object> params) {
 
        Object isExport = params.get("isExport");
        // 判断是否导出,导出不分页
        if (null != isExport && !isExport.equals("")) {
            return baseMapper.getAttResBaseUserPage(null,params);
        }
        List<AttResBaseUserDTO> attResBaseUserDTOList = baseMapper.getAttResBaseUserPage(page,params);
        // 返回数据
        return page.setRecords(attResBaseUserDTOList);
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean updateResBaseByGuid(AttResBase attResBase) {
        attResBase.setUpdateTime(DateUtil.now());
 
 
        //向水库标签表中更新数据
        relResLabelService.updateEntity(attResBase.getGuid(),attResBase.getLabel());
 
 
        return baseMapper.updateResBaseByGuid(attResBase);
    }
 
    /**
     * 查询当前水库对应的市级编号和县区编号
     * @param res_cd
     * @return
     */
    @Override
    public AttResBaseVO getCityCountyCodeByResGuid(String res_cd) {
        return baseMapper.getCityCountyCodeByResGuid(res_cd);
    }
 
    /**
     * 根据水库编码获取行政区数据
     * @param guid
     * @return
     */
    @Override
    public AttResAdVO getWaterRegionInfoByResGuid(String guid) {
        return baseMapper.getWaterRegionInfoByResGuid(guid);
    }
 
    @Override
    public int getDimResInfoACount() {
        return baseMapper.getDimResInfoACount();
    }
 
    @Override
    public Boolean updateIsShowStatus(String ids, Integer status) {
        return baseMapper.updateIsShowStatus(ids,status);
    }
 
    /**
     * 根据水库名称、所在区域查询改水库的数量
     * @param resName 水库名称
     * @param countyCode 区县
     * @return
     */
    @Override
    public Integer getWaterCountByResNameAndCountyName(String resName, String countyCode) {
        return baseMapper.getWaterCountByResNameAndCountyName(resName,countyCode);
    }
}