九小数据导入

linwei

2024-02-06 743a4bccc0487b9e3fc268792ba88f571dfe3a2e

九小数据导入

 src/main/java/org/springblade/modules/taskPlaceRectification/excel/PlaceRectificationsExcel.java

@@ -1,16 +1,13 @@
package org.springblade.modules.taskPlaceRectification.excel;

import com.alibaba.excel.annotation.ExcelIgnore;
import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.alibaba.excel.annotation.write.style.ContentRowHeight;
import com.alibaba.excel.annotation.write.style.HeadRowHeight;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springblade.modules.patrol.vo.PatrolRecordVO;
import org.springblade.modules.place.vo.PlacePoiLabelVO;

import java.util.List;
import org.springblade.common.excel.ExcelDictConverter;
import org.springblade.common.excel.ExcelDictItem;
import org.springblade.common.excel.ExcelDictItemLabel;

@Data
@ColumnWidth(25)
@@ -18,8 +15,9 @@
@ContentRowHeight(18)
public class PlaceRectificationsExcel {
    private static final long serialVersionUID = 1L;

    @ExcelProperty( value = "场所类别")
    @ExcelProperty( value = "场所类别",converter = ExcelDictConverter.class)
    @ExcelDictItem(type = "nineType")
    @ExcelDictItemLabel(type = "nineType")
    private String nineType;

    @ExcelProperty(value = "场所名称")

 src/main/java/org/springblade/modules/taskPlaceRectification/service/impl/TaskPlaceRectificationServiceImpl.java

@@ -36,6 +36,7 @@
import org.springblade.modules.place.excel.NinePlaceExcel;
import org.springblade.modules.place.service.IPlaceCheckService;
import org.springblade.modules.place.service.IPlaceService;
import org.springblade.modules.place.vo.PlaceVO;
import org.springblade.modules.system.entity.DictBiz;
import org.springblade.modules.system.entity.Region;
import org.springblade.modules.system.entity.User;
@@ -217,8 +218,16 @@
        IUserService bean1 = SpringUtils.getBean(IUserService.class);
        IPlaceCheckService bean2 = SpringUtils.getBean(IPlaceCheckService.class);
        IDoorplateAddressService bean3 = SpringUtils.getBean(IDoorplateAddressService.class);
        IPlaceService bean4 = SpringUtils.getBean(IPlaceService.class);

        List<String> objects = new ArrayList<>();
        List<String> objects2 = new ArrayList<>();
        List<String> objects3 = new ArrayList<>();
        List<String> objects4 = new ArrayList<>();
        int a = 0;
        for (PlaceRectificationsExcel datum : data) {
            a++;
            System.out.println(a + "第几个：" + datum.getHouseCode());
            String phone1 = getPhone(datum.getPrincipals());
            String name = getName(datum.getPrincipals());
            datum.setPrincipalPhone(phone1);
@@ -229,47 +238,36 @@
                .eq(PlaceEntity::getIsDeleted, 0));
            if (one == null) {
                // 新增场所
                DoorplateAddressEntity one1 = bean3.getOne(Wrappers.<DoorplateAddressEntity>lambdaQuery()
                DoorplateAddressEntity doorplateAddressEntity = bean3.getOne(Wrappers.<DoorplateAddressEntity>lambdaQuery()
                    .eq(DoorplateAddressEntity::getAddressCode, datum.getHouseCode()));
                if (one1 == null) {
                if (doorplateAddressEntity == null) {
                    objects.add(datum.getHouseCode());
                }
                PlaceCheckEntity placeCheckEntity = new PlaceCheckEntity();
                String police = datum.getPolice();
                String phone = getPhone(police);
                if (StringUtils.isNotBlank(phone)) {
                    User one3 = bean1.getOne(Wrappers.<User>lambdaQuery()
                        .eq(User::getPhone, phone)
                        .eq(User::getIsDeleted, 0));
                    if (one3 != null) {
                        placeCheckEntity.setCreateUser(one3.getId());
                    continue;
                } else {
                    PlaceVO placeVO = new PlaceVO();
                    placeVO.setHouseCode(datum.getHouseCode());
                    placeVO.setIsNine(1);
                    placeVO.setPrincipal(StringUtils.isBlank(datum.getPrincipal().trim()) ? "demo" : datum.getPrincipal().trim());
                    placeVO.setPrincipalPhone(datum.getPrincipalPhone());
                    placeVO.setRoleName("民警");
                    placeVO.setBuildingCode(doorplateAddressEntity.getBuildingCode());
                    placeVO.setLat(doorplateAddressEntity.getY());
                    placeVO.setLng(doorplateAddressEntity.getX());
                    placeVO.setLocation(datum.getAddressName());
                    placeVO.setSource(1);
                    placeVO.setIsScene(1);
                    placeVO.setIsNine(1);
                    if (StringUtils.isNotBlank(datum.getNineType())) {
                        placeVO.setNineType(Integer.valueOf(datum.getNineType()));
                    }
                    Boolean aBoolean = bean4.addOrUpdate(placeVO);

                    objects2.add(datum.getHouseCode());
                }
                // 4.保存检查表
                placeCheckEntity.setHouseCode(datum.getHouseCode());
                bean2.save(placeCheckEntity);
                continue;
            }
            // 2.判断负责人电话是否存在
            if (StringUtils.isBlank(datum.getPrincipalPhone())) {
                one.setLocation(datum.getAddressName());
                one.setPlaceName(datum.getPlaceName());
                bean.updateById(one);

                PlaceCheckEntity placeCheckEntity = new PlaceCheckEntity();
                String police = datum.getPolice();
                String phone = getPhone(police);
                if (StringUtils.isNotBlank(phone)) {
                    User one3 = bean1.getOne(Wrappers.<User>lambdaQuery()
                        .eq(User::getPhone, phone)
                        .eq(User::getIsDeleted, 0));
                    if (one3 != null) {
                        placeCheckEntity.setCreateUser(one3.getId());
                    }
                }
                // 4.保存检查表
                placeCheckEntity.setHouseCode(datum.getHouseCode());
                bean2.save(placeCheckEntity);
                objects4.add(datum.getHouseCode());
                continue;
            }
            // 2.判断负责人是否存在
@@ -282,27 +280,38 @@
                //如果用户不存在，则新增一个用户
                newUser.setAccount(datum.getPrincipalPhone().trim());
                newUser.setPhone(datum.getPrincipalPhone().trim());
                newUser.setName(datum.getPrincipal().trim());
                newUser.setRealName(datum.getPrincipal().trim());
                newUser.setName(StringUtils.isBlank(datum.getPrincipal().trim()) ? "demo" : datum.getPrincipal().trim());
                newUser.setRealName(StringUtils.isBlank(datum.getPrincipal().trim()) ? "demo" : datum.getPrincipal().trim());
                // 社区群众部门
                newUser.setDeptId("1727979636479037441");
                // 目前暂定居民角色，
                newUser.setRoleId("1717429059648606209");
                //默认密码为 123456
                newUser.setPassword("123456");
                // 设置机构
                // 用户新增
                boolean submit = bean1.submit(newUser);

                // 3.更新场所负责人
                one.setPrincipal(newUser.getRealName());
                one.setPrincipalUserId(newUser.getId());
                one.setPrincipalPhone(newUser.getPhone());
                one.setLocation(datum.getAddressName());
                one.setPlaceName(datum.getPlaceName());
                one.setIsNine(1);
                if (StringUtils.isNotBlank(datum.getNineType())) {
                    one.setNineType(Integer.valueOf(datum.getNineType()));
                }
                bean.updateById(one);
            } else {
                if (one == null) {
                    one = bean.getOne(Wrappers.<PlaceEntity>lambdaQuery()
                        .eq(PlaceEntity::getHouseCode, datum.getHouseCode())
                        .eq(PlaceEntity::getIsDeleted, 0));
                }
                // 3.更新场所负责人
                one.setIsNine(1);
                if (StringUtils.isNotBlank(datum.getNineType())) {
                    one.setNineType(Integer.valueOf(datum.getNineType()));
                }
                one.setPrincipal(one1.getRealName());
                one.setPrincipalUserId(one1.getId());
                one.setPrincipalPhone(one1.getPhone());
@@ -310,22 +319,11 @@
                one.setPlaceName(datum.getPlaceName());
                bean.updateById(one);
            }
            PlaceCheckEntity placeCheckEntity = new PlaceCheckEntity();
            String police = datum.getPolice();
            String phone = getPhone(police);
            if (StringUtils.isNotBlank(phone)) {
                User one3 = bean1.getOne(Wrappers.<User>lambdaQuery()
                    .eq(User::getPhone, phone)
                    .eq(User::getIsDeleted, 0));
                if (one3 != null) {
                    placeCheckEntity.setCreateUser(one3.getId());
                }
            }
            // 4.保存检查表
            placeCheckEntity.setHouseCode(datum.getHouseCode());
            bean2.save(placeCheckEntity);
        }
        System.out.println("没有数据:" + JSON.toJSONString(objects));
        System.out.println("没有数据2:" + JSON.toJSONString(objects2));
        System.out.println("没有数据3:" + JSON.toJSONString(objects3));
        System.out.println("没有数据4:" + JSON.toJSONString(objects4));
    }