java110-bean/src/main/java/com/java110/dto/RoomDto.java
@@ -17,7 +17,7 @@ public class RoomDto extends PageDto implements Serializable { public static final String STATE_SELL = "2001"; // 已入住 public static final String STATE_FREE = "2002"; //未入住 public static final String STATE_FREE = "2002"; //未销售 public static final String STATE_DELIVERY = "2003";//已交房 public static final String STATE_RENOVATION = "2005";//已装修 public static final String STATE_SHOP_FIRE = "2006";//已经租 java110-bean/src/main/java/com/java110/dto/owner/OwnerDto.java
@@ -28,6 +28,9 @@ // 1000 表示待审核，2000 审核完成 3000 拒绝审核 public static final String STATE_FINISH = "2000"; public static final String IS_BIND_Y="Y"; public static final String IS_BIND_N="N"; private String communityId; private String communityName; @@ -74,6 +77,8 @@ private Date createTime; private String statusCd = "0"; private String isBind; public String getSex() { @@ -373,4 +378,12 @@ public void setsCommunityTel(String sCommunityTel) { this.sCommunityTel = sCommunityTel; } public String getIsBind() { return isBind; } public void setIsBind(String isBind) { this.isBind = isBind; } } java110-db/src/main/resources/mapper/user/OwnerV1ServiceDaoImplMapper.xml
@@ -163,4 +163,23 @@ </select> <select id="queryOwnersBindCount" parameterType="Map" resultType="Map"> select count(DISTINCT t.member_id) from building_owner t left join owner_app_user oau on t.community_id = oau.community_id and t.member_id = oau.member_id and oau.status_cd = '0' where t.status_cd = '0' <if test="isBind == 'N'"> and oau.member_id is null </if> <if test="isBind == 'Y'"> and oau.member_id is not null </if> <if test="communityId !=null and communityId != ''"> and t.community_id= #{communityId} </if> </select> </mapper> java110-interface/src/main/java/com/java110/intf/user/IOwnerV1InnerServiceSMO.java
@@ -65,4 +65,7 @@ */ @RequestMapping(value = "/queryOwnersCount", method = RequestMethod.POST) int queryOwnersCount(@RequestBody OwnerDto ownerDto); @RequestMapping(value = "/queryOwnersBindCount", method = RequestMethod.POST) int queryOwnersBindCount(@RequestBody OwnerDto ownerDto); } service-store/src/main/java/com/java110/store/cmd/propertyIndex/QueryOwnerRegisterIndexCmd.java
New file @@ -0,0 +1,68 @@ package com.java110.store.cmd.propertyIndex; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.dto.RoomDto; import com.java110.dto.complaint.ComplaintDto; import com.java110.dto.owner.OwnerDto; import com.java110.intf.community.IRoomV1InnerServiceSMO; import com.java110.intf.store.IComplaintInnerServiceSMO; import com.java110.intf.user.IOwnerV1InnerServiceSMO; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.vo.ResultVo; import org.springframework.beans.factory.annotation.Autowired; @Java110Cmd(serviceCode = "propertyIndex.queryOwnerRegisterIndex") public class QueryOwnerRegisterIndexCmd extends Cmd { @Autowired private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; @Autowired private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException { Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区信息"); } @Override public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException { JSONObject paramOut = new JSONObject(); // 未注册 住户 OwnerDto ownerDto = new OwnerDto(); ownerDto.setCommunityId(reqJson.getString("communityId")); ownerDto.setIsBind(OwnerDto.IS_BIND_N); int unbindCount = ownerV1InnerServiceSMOImpl.queryOwnersBindCount(ownerDto); paramOut.put("unbindCount", unbindCount); // 已注册 住户 ownerDto = new OwnerDto(); ownerDto.setCommunityId(reqJson.getString("communityId")); ownerDto.setIsBind(OwnerDto.IS_BIND_Y); int bindCount = ownerV1InnerServiceSMOImpl.queryOwnersBindCount(ownerDto); paramOut.put("bindCount", bindCount); RoomDto roomDto = new RoomDto(); roomDto.setCommunityId(reqJson.getString("communityId")); roomDto.setRoomType(RoomDto.ROOM_TYPE_ROOM); roomDto.setState(RoomDto.STATE_FREE); int unbindRoomCount = roomV1InnerServiceSMOImpl.queryRoomsCount(roomDto); paramOut.put("unbindRoomCount", unbindRoomCount); roomDto = new RoomDto(); roomDto.setCommunityId(reqJson.getString("communityId")); roomDto.setRoomType(RoomDto.ROOM_TYPE_ROOM); int allRoomCount = roomV1InnerServiceSMOImpl.queryRoomsCount(roomDto); paramOut.put("bindRoomCount", allRoomCount-unbindRoomCount); context.setResponseEntity(ResultVo.createResponseEntity(paramOut)); } } service-user/src/main/java/com/java110/user/dao/IOwnerV1ServiceDao.java
@@ -74,4 +74,5 @@ */ int queryOwnersCount(Map info); int queryOwnersBindCount(Map map); } service-user/src/main/java/com/java110/user/dao/impl/OwnerV1ServiceDaoImpl.java
@@ -104,5 +104,17 @@ return Integer.parseInt(businessOwnerInfos.get(0).get("count").toString()); } @Override public int queryOwnersBindCount(Map info) { logger.debug("查询 queryOwnersBindCount 入参 info : {}",info); List<Map> businessOwnerInfos = sqlSessionTemplate.selectList("ownerV1ServiceDaoImpl.queryOwnersBindCount", info); if (businessOwnerInfos.size() < 1) { return 0; } return Integer.parseInt(businessOwnerInfos.get(0).get("count").toString()); } } service-user/src/main/java/com/java110/user/smo/impl/OwnerV1InnerServiceSMOImpl.java
@@ -84,4 +84,9 @@ public int queryOwnersCount(@RequestBody OwnerDto ownerDto) { return ownerV1ServiceDaoImpl.queryOwnersCount(BeanConvertUtil.beanCovertMap(ownerDto)); } @Override public int queryOwnersBindCount(@RequestBody OwnerDto ownerDto) { return ownerV1ServiceDaoImpl.queryOwnersBindCount(BeanConvertUtil.beanCovertMap(ownerDto)); } }
