场所数据处理调整

zhongrj

2024-05-13 fd370c8133638800f9b006b22e4d6abcf263ba89

场所数据处理调整

 src/main/java/org/springblade/modules/doorplateAddress/mapper/DoorplateAddressMapper.java

@@ -263,4 +263,11 @@
     * @return
     */
    DoorplateAddressVO getDoorplateAddressDetailByHouseId(@Param("houseId") Long houseId);

    /**
     * 查询未入库的场所
     * @param townName
     * @return
     */
    Integer getNotPlaceListCount(@Param("townName") String townName);
}

 src/main/java/org/springblade/modules/doorplateAddress/mapper/DoorplateAddressMapper.xml

@@ -572,6 +572,19 @@
        <if test="townName!=null and townName!=''">
            and jda.town_street_name like concat('%',#{townName},'%')
        </if>
        limit 0,1000
    </select>

    <!--查询未入库的场所-->
    <select id="getNotPlaceListCount" resultType="java.lang.Integer">
        select count(*) from jczz_doorplate_address jda
        left join jczz_place jp on jda.address_code=jp.house_code and jp.is_deleted = 0
        where 1=1
        and (doorplate_type = '小门牌' or (doorplate_type = '中门牌' and address_level = 1))
        and jp.id is null
        <if test="townName!=null and townName!=''">
            and jda.town_street_name like concat('%',#{townName},'%')
        </if>
    </select>

    <!--查询场所标准地址数据-->

 src/main/java/org/springblade/modules/doorplateAddress/service/impl/DoorplateAddressServiceImpl.java

@@ -909,15 +909,17 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Object placeDataHandle(String townName) {
        // 查询总数
        Integer count = baseMapper.getNotPlaceListCount(townName);
        if (count > 0) {
            int num = count / 1000;
            for (int i = 0; i <= num + 1; i++) {
        // 查询所有的地址表和场所表差集集合
        List<DoorplateAddressEntity> list = baseMapper.getNotInPlaceList(townName);
        // 创建场所集合对象
        List<PlaceEntity> placeList = new ArrayList<>();
        if (list.size() > 0) {
            // 将场所数据保存到场所表中
            for (DoorplateAddressEntity addressEntity : list) {
                // pio 名称不为空的进行插入操作
//                if (!Strings.isBlank(addressEntity.getPoi())) {
                PlaceEntity placeEntity = new PlaceEntity();
                placeEntity.setHouseCode(addressEntity.getAddressCode());
                placeEntity.setPlaceName(addressEntity.getPoi());
@@ -947,16 +949,13 @@
                    PoliceAffairsGridEntity policeAffairsGridEntity = policeAffairsGridEntityList.get(0);
                    placeEntity.setJwGridCode(policeAffairsGridEntity.getJwGridCode());
                }
                // 加入集合
//                    placeList.add(placeEntity);
                // 保存
                placeService.save(placeEntity);
                // 新增场所详情
                savePlaceExtAndTaskInfo(placeEntity);
//                }
            }
            // 批量插入
//            savePlaceExtAndTaskInfo(placeList);
                }
            }
        }
        // 返回
        return null;