完成初始化功能

1098226878

2021-08-05 baa71aef0d0e7a8aa2416a55a03596c7722d797a

完成初始化功能

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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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

New file
@@ -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;
    }
}