88e030b7
王彪总
init project
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
package com.java110.community.dao.impl;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.DAOException;
import com.java110.utils.util.DateUtil;
import com.java110.community.dao.IRoomServiceDao;
import com.java110.core.base.dao.BaseServiceDao;
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
17
|
* 项目房屋服务 与数据库交互
|
88e030b7
王彪总
init project
|
18
19
20
21
22
23
24
25
26
|
* Created by wuxw on 2017/4/5.
*/
@Service("roomServiceDaoImpl")
//@Transactional
public class RoomServiceDaoImpl extends BaseServiceDao implements IRoomServiceDao {
private static Logger logger = LoggerFactory.getLogger(RoomServiceDaoImpl.class);
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
27
|
* 项目房屋信息封装
|
88e030b7
王彪总
init project
|
28
|
*
|
9750b443
王彪总
fix(config): 更新配置...
|
29
|
* @param businessRoomInfo 项目房屋信息 封装
|
88e030b7
王彪总
init project
|
30
31
32
33
34
35
|
* @throws DAOException
*/
@Override
public void saveBusinessRoomInfo(Map businessRoomInfo) throws DAOException {
businessRoomInfo.put("month", DateUtil.getCurrentMonth());
// 查询business_user 数据是否已经存在
|
9750b443
王彪总
fix(config): 更新配置...
|
36
|
logger.debug("保存项目房屋信息 入参 businessRoomInfo : {}", businessRoomInfo);
|
88e030b7
王彪总
init project
|
37
38
39
|
int saveFlag = sqlSessionTemplate.insert("roomServiceDaoImpl.saveBusinessRoomInfo", businessRoomInfo);
if (saveFlag < 1) {
|
9750b443
王彪总
fix(config): 更新配置...
|
40
|
throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存项目房屋数据失败:" + JSONObject.toJSONString(businessRoomInfo));
|
88e030b7
王彪总
init project
|
41
42
43
44
45
|
}
}
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
46
|
* 查询项目房屋信息
|
88e030b7
王彪总
init project
|
47
48
|
*
* @param info bId 信息
|
9750b443
王彪总
fix(config): 更新配置...
|
49
|
* @return 项目房屋信息
|
88e030b7
王彪总
init project
|
50
51
52
53
54
|
* @throws DAOException
*/
@Override
public List<Map> getBusinessRoomInfo(Map info) throws DAOException {
|
9750b443
王彪总
fix(config): 更新配置...
|
55
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
56
57
58
59
60
61
62
63
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getBusinessRoomInfo", info);
return infos;
}
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
64
|
* 保存项目房屋信息 到 instance
|
88e030b7
王彪总
init project
|
65
66
67
68
69
70
|
*
* @param info bId 信息
* @throws DAOException
*/
@Override
public void saveRoomInfoInstance(Map info) throws DAOException {
|
9750b443
王彪总
fix(config): 更新配置...
|
71
|
logger.debug("保存项目房屋信息Instance 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
72
73
74
75
|
int saveFlag = sqlSessionTemplate.insert("roomServiceDaoImpl.saveRoomInfoInstance", info);
if (saveFlag < 1) {
|
9750b443
王彪总
fix(config): 更新配置...
|
76
|
throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "保存项目房屋信息Instance数据失败:" + JSONObject.toJSONString(info));
|
88e030b7
王彪总
init project
|
77
78
79
80
81
|
}
}
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
82
|
* 查询项目房屋信息(instance)
|
88e030b7
王彪总
init project
|
83
84
85
86
87
88
89
|
*
* @param info bId 信息
* @return
* @throws DAOException
*/
@Override
public List<Map> getRoomInfo(Map info) throws DAOException {
|
9750b443
王彪总
fix(config): 更新配置...
|
90
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
91
92
93
94
95
96
97
98
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfo", info);
return infos;
}
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
99
|
* 修改项目房屋信息
|
88e030b7
王彪总
init project
|
100
101
102
103
104
105
|
*
* @param info 修改信息
* @throws DAOException
*/
@Override
public void updateRoomInfoInstance(Map info) throws DAOException {
|
9750b443
王彪总
fix(config): 更新配置...
|
106
|
logger.debug("修改项目房屋信息Instance 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
107
108
109
110
|
int saveFlag = sqlSessionTemplate.update("roomServiceDaoImpl.updateRoomInfoInstance", info);
if (saveFlag < 1) {
|
9750b443
王彪总
fix(config): 更新配置...
|
111
|
throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "修改项目房屋信息Instance数据失败:" + JSONObject.toJSONString(info));
|
88e030b7
王彪总
init project
|
112
113
114
115
|
}
}
/**
|
9750b443
王彪总
fix(config): 更新配置...
|
116
|
* 查询项目房屋数量
|
88e030b7
王彪总
init project
|
117
|
*
|
9750b443
王彪总
fix(config): 更新配置...
|
118
119
|
* @param info 项目房屋信息
* @return 项目房屋数量
|
88e030b7
王彪总
init project
|
120
121
122
|
*/
@Override
public int queryRoomsCount(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
123
|
logger.debug("查询项目房屋数据 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
124
125
126
127
128
129
130
131
132
133
134
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.queryRoomsCount", info);
if (infos.size() < 1) {
return 0;
}
return Integer.parseInt(infos.get(0).get("count").toString());
}
@Override
public int queryRoomsByCommunityIdCount(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
135
|
logger.debug("查询项目房屋数据 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
136
137
138
139
140
141
142
143
144
145
146
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.queryRoomsByCommunityIdCount", info);
if (infos.size() < 1) {
return 0;
}
return Integer.parseInt(infos.get(0).get("count").toString());
}
@Override
public int queryRoomsWithOutSellByCommunityIdCount(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
147
|
logger.debug("查询项目房屋数据 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
148
149
150
151
152
153
154
155
156
157
158
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.queryRoomsWithOutSellByCommunityIdCount", info);
if (infos.size() < 1) {
return 0;
}
return Integer.parseInt(infos.get(0).get("count").toString());
}
@Override
public int queryRoomsWithSellByCommunityIdCount(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
159
|
logger.debug("查询项目房屋数据 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
160
161
162
163
164
165
166
167
168
169
170
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.queryRoomsWithSellByCommunityIdCount", info);
if (infos.size() < 1) {
return 0;
}
return Integer.parseInt(infos.get(0).get("count").toString());
}
@Override
public List<Map> getRoomInfoByCommunityId(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
171
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
172
173
174
175
176
177
178
179
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfoByCommunityId", info);
return infos;
}
@Override
public List<Map> getRoomInfoByOwner(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
180
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
181
182
183
184
185
186
187
188
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfoByOwner", info);
return infos;
}
@Override
public List<Map> getRoomInfoWithOutSellByCommunityId(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
189
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
190
191
192
193
194
195
196
197
198
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfoWithOutSellByCommunityId", info);
return infos;
}
@Override
public List<Map> getRoomInfoWithSellByCommunityId(Map info) {
|
9750b443
王彪总
fix(config): 更新配置...
|
199
|
logger.debug("查询项目房屋信息 入参 info : {}", info);
|
88e030b7
王彪总
init project
|
200
201
202
203
204
205
206
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfoWithSellByCommunityId", info);
return infos;
}
public List<Map> getRoomInfos(Map info){
|
9750b443
王彪总
fix(config): 更新配置...
|
207
|
logger.debug("查询项目房屋信息 getRoomInfos入参 info : {}", info);
|
88e030b7
王彪总
init project
|
208
209
210
211
212
213
214
|
List<Map> infos = sqlSessionTemplate.selectList("roomServiceDaoImpl.getRoomInfos", info);
return infos;
}
}
|