完成初始化功能

java110-db/src/main/resources/mapper/community/InitializeBuildingUnitDaoImplMapper.xml

@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="initializeBuildingUnitDaoImpl">
+
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deleteBuildingUnit" parameterType="Map">
+        　delete from building_unit t where 1=1
+            and t.floor_id in
+            <foreach collection="floorIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+    </delete>
+
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deletefFloor" parameterType="Map">
+        　delete from f_floor t where 1=1
+            and t.community_id = #{communityId}
+    </delete>
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deleteBuildingRoom" parameterType="Map">
+        　delete from building_room t where 1=1
+            and t.community_id = #{communityId}
+    </delete>
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deleteParkingArea" parameterType="Map">
+        　delete from parking_area t where 1=1
+            and t.community_id = #{communityId}
+    </delete>
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deleteParkingSpace" parameterType="Map">
+        　delete from parking_space t where 1=1
+            and t.community_id = #{communityId}
+    </delete>
+</mapper>

java110-db/src/main/resources/mapper/fee/InitializePayFeeServiceDaoImplMapper.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="initializePayFeeServiceDaoImpl">
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deletePayFee" parameterType="Map">
+        　delete from pay_fee t where 1=1
+        and t.community_id = #{communityId}
+    </delete>
+
+</mapper>

java110-db/src/main/resources/mapper/user/InitializeOwnerServiceDaoImplMapper.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="initializeOwnerServiceDaoImpl">
+
+    <!-- 初始化数据 add by wuxw 2018-07-03 -->
+    <delete id="deleteBuildingOwner" parameterType="Map">
+        　delete from building_owner t where 1=1
+            and t.community_id = #{communityId}
+    </delete>
+</mapper>

java110-interface/src/main/java/com/java110/intf/community/IinitializeBuildingUnitSMO.java

@@ -0,0 +1,69 @@
+package com.java110.intf.community;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.CommunityMemberDto;
+import com.java110.dto.community.CommunityAttrDto;
+import com.java110.dto.community.CommunityDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName IFloorInnerServiceSMO
+ * @Description 小区楼接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "community-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/InitializeBuildingUnitApi")
+public interface IinitializeBuildingUnitSMO {
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param floorIds 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deleteBuildingUnit", method = RequestMethod.POST)
+    int deleteBuildingUnit(@RequestBody Map floorIds);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deletefFloor", method = RequestMethod.POST)
+    int deletefFloor(@RequestBody Map communityId);
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deleteBuildingRoom", method = RequestMethod.POST)
+    int deleteBuildingRoom(@RequestBody Map communityId);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deleteParkingArea", method = RequestMethod.POST)
+    int deleteParkingArea(@RequestBody Map communityId);
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deleteParkingSpace", method = RequestMethod.POST)
+    int deleteParkingSpace(@RequestBody Map communityId);
+}

java110-interface/src/main/java/com/java110/intf/fee/IInitializePayFeeInnerServiceSMO.java

@@ -0,0 +1,34 @@
+package com.java110.intf.fee;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.payFeeAudit.PayFeeAuditDto;
+import com.java110.po.payFeeAudit.PayFeeAuditPo;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName IPayFeeAuditInnerServiceSMO
+ * @Description 缴费审核接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "fee-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/IInitializePayFeeApi")
+public interface IInitializePayFeeInnerServiceSMO {
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deletePayFee", method = RequestMethod.POST)
+    int deletePayFee(@RequestBody Map communityId);
+}

java110-interface/src/main/java/com/java110/intf/user/IInitializeOwnerInnerServiceSMO.java

@@ -0,0 +1,34 @@
+package com.java110.intf.user;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.po.owner.OwnerPo;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName IOwnerInnerServiceSMO
+ * @Description 业主接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "user-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/initializeOwnerApi")
+public interface IInitializeOwnerInnerServiceSMO {
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param communityId 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/deleteBuildingOwner", method = RequestMethod.POST)
+    int deleteBuildingOwner(@RequestBody Map communityId);
+}

service-community/src/main/java/com/java110/community/api/InitializeBuildingUnitApi.java

@@ -0,0 +1,42 @@
+package com.java110.community.api;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.community.bmo.initializeBuildingUnit.IinitializeBuildingUnit;
+import com.java110.utils.util.Assert;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @ClassName RoomApi
+ * @Description TODO
+ * @Author wuxw
+ * @Date 2020/8/6 23:27
+ * @Version 1.0
+ * add by wuxw 2020/8/6
+ **/
+
+@RestController
+@RequestMapping(value = "/InitializeBuildingUnit")
+public class InitializeBuildingUnitApi {
+
+    @Autowired
+    private IinitializeBuildingUnit IinitializeBuildingUnitImpl;
+    /**
+     * 初始化
+     *
+     * @param reqJson
+     * @return
+     * @Service /InitializeBuildingUnit/deleteBuildingUnit
+     * @path /app/InitializeBuildingUnit/deleteBuildingUnit
+     */
+    @RequestMapping(value = "/deleteBuildingUnit", method = RequestMethod.POST)
+    public ResponseEntity<String> deleteBuildingUnit(@RequestHeader(value = "user-id") String userId,
+                                                     @RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区ID");
+        String communityId = reqJson.getString("communityId");
+        String userPassword = reqJson.getString("devPassword");
+        IinitializeBuildingUnitImpl.deleteBuildingUnit(communityId,userId,userPassword);
+        return null;
+    }
+}

service-community/src/main/java/com/java110/community/bmo/initializeBuildingUnit/IinitializeBuildingUnit.java

@@ -0,0 +1,36 @@
+package com.java110.community.bmo.initializeBuildingUnit;/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import com.java110.dto.CommunityMemberDto;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * 查询 商户入驻成功的小区信息
+ * <p>
+ * add by 吴学文 2020-12-23
+ * <p>
+ * 文档参考：http://www.homecommunity.cn
+ */
+public interface IinitializeBuildingUnit {
+
+    /**
+     * 查询商户入驻 小区信息
+     *
+     * @param  communityId 小区成员信息
+     * @return
+     */
+    ResponseEntity<String> deleteBuildingUnit(String communityId,String userId,String userPassword);
+}

service-community/src/main/java/com/java110/community/bmo/initializeBuildingUnit/impl/IinitializeBuildingUnitImpl.java

@@ -0,0 +1,153 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.community.bmo.initializeBuildingUnit.impl;
+
+import com.java110.community.bmo.initializeBuildingUnit.IinitializeBuildingUnit;
+import com.java110.core.factory.AuthenticationFactory;
+import com.java110.dto.FloorDto;
+import com.java110.dto.user.UserDto;
+import com.java110.intf.community.IFloorInnerServiceSMO;
+import com.java110.intf.community.IinitializeBuildingUnitSMO;
+import com.java110.intf.fee.IInitializePayFeeInnerServiceSMO;
+import com.java110.intf.user.IInitializeOwnerInnerServiceSMO;
+import com.java110.intf.user.IUserInnerServiceSMO;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 商户小区 查询实现类
+ * <p>
+ * add by 吴学文 2020-12-23
+ * <p>
+ * 文档参考：http://www.homecommunity.cn
+ */
+@Service
+public class IinitializeBuildingUnitImpl implements IinitializeBuildingUnit {
+
+    @Autowired
+    private IinitializeBuildingUnitSMO initializeBuildingUnitSMOImpl;
+    @Autowired
+    private IFloorInnerServiceSMO floorInnerServiceSMOImpl;
+    @Autowired
+    private IInitializeOwnerInnerServiceSMO initializeOwnerInnerServiceSMOImpl;
+    @Autowired
+    private IInitializePayFeeInnerServiceSMO initializePayFeeInnerServiceSMOImpl;
+    @Autowired
+    private IUserInnerServiceSMO UserInnerServiceSMOImpl;
+    @Override
+    public ResponseEntity<String> deleteBuildingUnit(String communityId,String userId,String userPassword) {
+        UserDto userDto = new UserDto();
+        userDto.setUserId(userId);
+        List<UserDto> userDtos = UserInnerServiceSMOImpl.getUserHasPwd(userDto);
+        if(null == userDtos || userDtos.size() < 1){
+            return ResultVo.createResponseEntity("没有查到用户信息，初始化失败！");
+        }
+        if(!AuthenticationFactory.passwdMd5(userPassword).equals(userDtos.get(0).getPassword())){
+            return ResultVo.createResponseEntity("初始化时输入的密码不正确，初始化失败！");
+        }
+        StringBuffer massage = new StringBuffer();
+        FloorDto floorDto = new FloorDto();
+        floorDto.setCommunityId(communityId);
+        List<FloorDto> floorDtos =  floorInnerServiceSMOImpl.queryFloors(floorDto);
+        List floors = new ArrayList();
+        if(null != floorDtos && floorDtos.size() > 0){
+            for (FloorDto floorDtotmp: floorDtos){
+                floors.add(floorDtotmp.getFloorId());
+            }
+        }
+        Map floorIds = new HashMap<String,String []>();
+        floorIds.put("floorIds",floors.toArray(new String[floors.size()]));
+        //单元
+        int communitys = initializeBuildingUnitSMOImpl.deleteBuildingUnit(floorIds);
+
+        if(communitys > 0){
+            massage.append("单元初始化成功【"+communitys+"】");
+            Map communityIds = new HashMap<String,String []>();
+            floorIds.put("communityId",communityId);
+            //楼栋
+            int deleteFlag = initializeBuildingUnitSMOImpl.deletefFloor(communityIds);
+            if(deleteFlag > 0){
+                massage.append("楼栋初始化成功【"+deleteFlag+"】");
+            }
+            //房屋
+            int deleteFlagRoot = initializeBuildingUnitSMOImpl.deleteBuildingRoom(communityIds);
+            if(deleteFlagRoot > 0){
+                massage.append("房屋初始化成功【"+deleteFlagRoot+"】");
+            }
+            //业主
+            int deleteFlagOwner = initializeOwnerInnerServiceSMOImpl.deleteBuildingOwner(communityIds);
+            if(deleteFlagOwner > 0){
+                massage.append("业主初始化成功【"+deleteFlagOwner+"】");
+            }
+            //费用
+            int deleteFlagFee = initializePayFeeInnerServiceSMOImpl.deletePayFee(communityIds);
+            if(deleteFlagFee > 0){
+                massage.append("费用初始化成功【"+deleteFlagFee+"】");
+            }
+
+            //停车场
+            int deleteFlagArea = initializeBuildingUnitSMOImpl.deleteParkingArea(communityIds);
+            if(deleteFlagArea > 0){
+                massage.append("停车场初始化成功【"+deleteFlagArea+"】");
+            }
+            //停车位
+            int deleteFlagSpace = initializeBuildingUnitSMOImpl.deleteParkingSpace(communityIds);
+            if(deleteFlagSpace > 0){
+                massage.append("停车位初始化成功【"+deleteFlagSpace+"】");
+            }
+        }
+        return ResultVo.createResponseEntity(massage);
+    }
+
+    public IinitializeBuildingUnitSMO getInitializeBuildingUnitSMOImpl() {
+        return initializeBuildingUnitSMOImpl;
+    }
+
+    public void setInitializeBuildingUnitSMOImpl(IinitializeBuildingUnitSMO initializeBuildingUnitSMOImpl) {
+        this.initializeBuildingUnitSMOImpl = initializeBuildingUnitSMOImpl;
+    }
+
+    public IFloorInnerServiceSMO getFloorInnerServiceSMOImpl() {
+        return floorInnerServiceSMOImpl;
+    }
+
+    public void setFloorInnerServiceSMOImpl(IFloorInnerServiceSMO floorInnerServiceSMOImpl) {
+        this.floorInnerServiceSMOImpl = floorInnerServiceSMOImpl;
+    }
+
+    public IInitializeOwnerInnerServiceSMO getInitializeOwnerInnerServiceSMOImpl() {
+        return initializeOwnerInnerServiceSMOImpl;
+    }
+
+    public void setInitializeOwnerInnerServiceSMOImpl(IInitializeOwnerInnerServiceSMO initializeOwnerInnerServiceSMOImpl) {
+        this.initializeOwnerInnerServiceSMOImpl = initializeOwnerInnerServiceSMOImpl;
+    }
+
+    public IInitializePayFeeInnerServiceSMO getInitializePayFeeInnerServiceSMOImpl() {
+        return initializePayFeeInnerServiceSMOImpl;
+    }
+
+    public void setInitializePayFeeInnerServiceSMOImpl(IInitializePayFeeInnerServiceSMO initializePayFeeInnerServiceSMOImpl) {
+        this.initializePayFeeInnerServiceSMOImpl = initializePayFeeInnerServiceSMOImpl;
+    }
+}

service-community/src/main/java/com/java110/community/dao/IInitializeBuildingUnitDao.java

@@ -0,0 +1,52 @@
+package com.java110.community.dao;
+
+
+import com.java110.utils.exception.DAOException;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 小区组件内部之间使用，没有给外围系统提供服务能力
+ * 小区服务接口类，要求全部以字符串传输，方便微服务化
+ * 新建客户，修改客户，删除客户，查询客户等功能
+ * <p>
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IInitializeBuildingUnitDao {
+
+    /**
+     * 修改服务信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int deleteBuildingUnit(Map info) throws DAOException;
+
+    /**
+     * 修改服务信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int deletefFloor(Map info) throws DAOException;
+    /**
+     * 修改服务信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int deleteBuildingRoom(Map info) throws DAOException;
+
+
+    /**
+     * 修改服务信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int deleteParkingArea(Map info) throws DAOException;
+    /**
+     * 修改服务信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int deleteParkingSpace(Map info) throws DAOException;
+
+}

service-community/src/main/java/com/java110/community/dao/impl/InitializeBuildingUnitDaoImpl.java

@@ -0,0 +1,104 @@
+package com.java110.community.dao.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.community.dao.ICommunityServiceDao;
+import com.java110.community.dao.IInitializeBuildingUnitDao;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.DAOException;
+import com.java110.utils.util.DateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 小区服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("initializeBuildingUnitDaoImpl")
+//@Transactional
+public class InitializeBuildingUnitDaoImpl extends BaseServiceDao implements IInitializeBuildingUnitDao {
+
+    private static Logger logger = LoggerFactory.getLogger(InitializeBuildingUnitDaoImpl.class);
+
+    /**
+     * 修改小区成员加入信息
+     *
+     * @param info 修改信息
+     * @throws DAOException
+     */
+    public int deleteBuildingUnit(Map info) throws DAOException {
+        logger.debug("初始化单元Instance 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeBuildingUnitDaoImpl.deleteBuildingUnit", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "building_unit初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+    /**
+     * 修改小区成员加入信息
+     *
+     * @param info 修改信息
+     * @throws DAOException
+     */
+    public int deletefFloor(Map info) throws DAOException {
+        logger.debug("初始化楼栋Instance 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeBuildingUnitDaoImpl.deletefFloor", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "f_floor初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+    /**
+     * 修改小区成员加入信息
+     *
+     * @param info 修改信息
+     * @throws DAOException
+     */
+    public int deleteBuildingRoom(Map info) throws DAOException {
+        logger.debug("初始化房屋Instance 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeBuildingUnitDaoImpl.deleteBuildingRoom", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "f_floor初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+
+    public int deleteParkingArea(Map info) throws DAOException {
+        logger.debug("停车场Instance 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeBuildingUnitDaoImpl.deleteParkingArea", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "f_floor初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+    /**
+     * 修改小区成员加入信息
+     *
+     * @param info 修改信息
+     * @throws DAOException
+     */
+    public int deleteParkingSpace(Map info) throws DAOException {
+        logger.debug("停车位Instance 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeBuildingUnitDaoImpl.deleteParkingSpace", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "f_floor初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+
+
+}

service-community/src/main/java/com/java110/community/smo/impl/InitializeBuildingUnitSMOImpl.java

@@ -0,0 +1,89 @@
+package com.java110.community.smo.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.community.dao.IInitializeBuildingUnitDao;
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.core.context.BusinessServiceDataFlow;
+import com.java110.core.event.service.BusinessServiceDataFlowEventPublishing;
+import com.java110.core.factory.DataFlowFactory;
+import com.java110.entity.center.DataFlowLinksCost;
+import com.java110.entity.center.DataFlowLog;
+import com.java110.intf.community.IinitializeBuildingUnitSMO;
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.constant.KafkaConstant;
+import com.java110.utils.constant.MappingConstant;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.SMOException;
+import com.java110.utils.kafka.KafkaFactory;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.DateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+
+import java.util.Map;
+
+/**
+ * 用户服务信息管理业务信息实现
+ * Created by wuxw on 2017/4/5.
+ */
+@Transactional
+public class InitializeBuildingUnitSMOImpl extends BaseServiceSMO implements IinitializeBuildingUnitSMO {
+
+    private static Logger logger = LoggerFactory.getLogger(InitializeBuildingUnitSMOImpl.class);
+
+    @Autowired
+    private IInitializeBuildingUnitDao initializeBuildingUnitDaoImpl;
+
+    @Override
+    public int deleteBuildingUnit(Map floorIds) {
+        int deleteFlag = initializeBuildingUnitDaoImpl.deleteBuildingUnit(floorIds);
+        return deleteFlag;
+    }
+
+    @Override
+    public int deletefFloor(Map communityId) {
+        int deleteFlag = initializeBuildingUnitDaoImpl.deletefFloor(communityId);
+        return deleteFlag;
+    }
+
+    @Override
+    public int deleteBuildingRoom(Map communityId) {
+        int deleteFlag = initializeBuildingUnitDaoImpl.deleteBuildingRoom(communityId);
+        return deleteFlag;
+    }
+
+    @Override
+    public int deleteParkingArea(Map communityId) {
+        int deleteFlag = initializeBuildingUnitDaoImpl.deleteParkingArea(communityId);
+        return deleteFlag;
+    }
+    @Override
+    public int deleteParkingSpace(Map communityId) {
+        int deleteFlag = initializeBuildingUnitDaoImpl.deleteParkingSpace(communityId);
+        return deleteFlag;
+    }
+
+    public static Logger getLogger() {
+        return logger;
+    }
+
+    public static void setLogger(Logger logger) {
+        InitializeBuildingUnitSMOImpl.logger = logger;
+    }
+
+    public IInitializeBuildingUnitDao getInitializeBuildingUnitDaoImpl() {
+        return initializeBuildingUnitDaoImpl;
+    }
+
+    public void setInitializeBuildingUnitDaoImpl(IInitializeBuildingUnitDao initializeBuildingUnitDaoImpl) {
+        this.initializeBuildingUnitDaoImpl = initializeBuildingUnitDaoImpl;
+    }
+}

service-fee/src/main/java/com/java110/fee/dao/IInitializePayFeeServiceDao.java

@@ -0,0 +1,24 @@
+package com.java110.fee.dao;
+
+
+import java.util.Map;
+
+/**
+ * 缴费审核组件内部之间使用，没有给外围系统提供服务能力
+ * 缴费审核服务接口类，要求全部以字符串传输，方便微服务化
+ * 新建客户，修改客户，删除客户，查询客户等功能
+ *
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IInitializePayFeeServiceDao {
+
+
+    /**
+     * 修改关系
+     *
+     * @param communityId
+     * @return
+     */
+    int deletePayFee(Map communityId);
+
+}

service-fee/src/main/java/com/java110/fee/dao/impl/InitializePayFeeServiceDaoImpl.java

@@ -0,0 +1,39 @@
+package com.java110.fee.dao.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.fee.dao.IInitializePayFeeServiceDao;
+import com.java110.fee.dao.IPayFeeAuditServiceDao;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.DAOException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 缴费审核服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("initializePayFeeServiceDaoImpl")
+//@Transactional
+public class InitializePayFeeServiceDaoImpl extends BaseServiceDao implements IInitializePayFeeServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(InitializePayFeeServiceDaoImpl.class);
+
+
+
+    public int deletePayFee(Map info) throws DAOException {
+        logger.debug("删除费用信息 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializePayFeeServiceDaoImpl.deletePayFee", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "building_owner初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+
+}

service-fee/src/main/java/com/java110/fee/smo/impl/InitializePayFeeInnerServiceSMOImpl.java

@@ -0,0 +1,48 @@
+package com.java110.fee.smo.impl;
+
+
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.dto.PageDto;
+import com.java110.dto.payFeeAudit.PayFeeAuditDto;
+import com.java110.fee.dao.IInitializePayFeeServiceDao;
+import com.java110.fee.dao.IPayFeeAuditServiceDao;
+import com.java110.intf.fee.IInitializePayFeeInnerServiceSMO;
+import com.java110.intf.fee.IPayFeeAuditInnerServiceSMO;
+import com.java110.po.payFeeAudit.PayFeeAuditPo;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName FloorInnerServiceSMOImpl
+ * @Description 缴费审核内部服务实现类
+ * @Author wuxw
+ * @Date 2019/4/24 9:20
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@RestController
+public class InitializePayFeeInnerServiceSMOImpl extends BaseServiceSMO implements IInitializePayFeeInnerServiceSMO {
+
+    @Autowired
+    private IInitializePayFeeServiceDao initializePayFeeServiceDaoImpl;
+
+
+    @Override
+    public int deletePayFee(Map communityId) {
+        int deleteFee = initializePayFeeServiceDaoImpl.deletePayFee(communityId);
+        return deleteFee;
+    }
+
+    public IInitializePayFeeServiceDao getInitializePayFeeServiceDaoImpl() {
+        return initializePayFeeServiceDaoImpl;
+    }
+
+    public void setInitializePayFeeServiceDaoImpl(IInitializePayFeeServiceDao initializePayFeeServiceDaoImpl) {
+        this.initializePayFeeServiceDaoImpl = initializePayFeeServiceDaoImpl;
+    }
+}

service-user/src/main/java/com/java110/user/dao/IInitializeOwneServiceDao.java

@@ -0,0 +1,22 @@
+package com.java110.user.dao;
+
+
+import java.util.Map;
+
+/**
+ * 业主房屋组件内部之间使用，没有给外围系统提供服务能力
+ * 业主房屋服务接口类，要求全部以字符串传输，方便微服务化
+ * 新建客户，修改客户，删除客户，查询客户等功能
+ * <p>
+ * Created by wuxw on 2016/12/27.
+ */
+public interface IInitializeOwneServiceDao {
+
+    /**
+     * 修改关系
+     *
+     * @param communityId
+     * @return
+     */
+    int deleteBuildingOwner(Map communityId);
+}

service-user/src/main/java/com/java110/user/dao/impl/InitializeOwnerServiceDaoImpl.java

@@ -0,0 +1,39 @@
+package com.java110.user.dao.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.user.dao.IInitializeOwneServiceDao;
+import com.java110.user.dao.IOwnerServiceDao;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.DAOException;
+import com.java110.utils.util.DateUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 业主服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("initializeOwnerServiceDaoImpl")
+//@Transactional
+public class InitializeOwnerServiceDaoImpl extends BaseServiceDao implements IInitializeOwneServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(InitializeOwnerServiceDaoImpl.class);
+
+
+
+    public int deleteBuildingOwner(Map info) throws DAOException {
+        logger.debug("删除业主信息 入参 info : {}", info);
+
+        int deleteFlag = sqlSessionTemplate.delete("initializeOwnerServiceDaoImpl.deleteBuildingOwner", info);
+
+        if (deleteFlag < 1) {
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR, "building_owner初始化失败：" + JSONObject.toJSONString(info));
+        }
+        return deleteFlag;
+    }
+}

service-user/src/main/java/com/java110/user/smo/impl/InitializeOwnerInnerServiceSMOImpl.java

@@ -0,0 +1,55 @@
+package com.java110.user.smo.impl;
+
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.dto.CommunityMemberDto;
+import com.java110.dto.PageDto;
+import com.java110.dto.owner.OwnerAttrDto;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.user.UserDto;
+import com.java110.intf.community.ICommunityInnerServiceSMO;
+import com.java110.intf.user.IInitializeOwnerInnerServiceSMO;
+import com.java110.intf.user.IOwnerAttrInnerServiceSMO;
+import com.java110.intf.user.IOwnerInnerServiceSMO;
+import com.java110.intf.user.IUserInnerServiceSMO;
+import com.java110.po.owner.OwnerPo;
+import com.java110.user.dao.IInitializeOwneServiceDao;
+import com.java110.user.dao.IOwnerServiceDao;
+import com.java110.utils.constant.OwnerTypeConstant;
+import com.java110.utils.constant.StatusConstant;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @ClassName FloorInnerServiceSMOImpl
+ * @Description 业主内部服务实现类
+ * @Author wuxw
+ * @Date 2019/4/24 9:20
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@RestController
+public class InitializeOwnerInnerServiceSMOImpl extends BaseServiceSMO implements IInitializeOwnerInnerServiceSMO {
+
+    @Autowired
+    private IInitializeOwneServiceDao initializeOwnerServiceDaoImpl;
+    @Override
+    public int deleteBuildingOwner(Map communityId) {
+        int deleteFast = initializeOwnerServiceDaoImpl.deleteBuildingOwner(communityId);
+        return deleteFast;
+    }
+
+    public IInitializeOwneServiceDao getInitializeOwnerServiceDaoImpl() {
+        return initializeOwnerServiceDaoImpl;
+    }
+
+    public void setInitializeOwnerServiceDaoImpl(IInitializeOwneServiceDao initializeOwnerServiceDaoImpl) {
+        this.initializeOwnerServiceDaoImpl = initializeOwnerServiceDaoImpl;
+    }
+}