Blame view

service-community/src/main/java/com/java110/community/dao/impl/RoomServiceDaoImpl.java 6.61 KB
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;
      }
  
  
  
  }