java/Robotaxi.git

			@@ -2,6 +2,8 @@


			import cn.hutool.core.collection.CollUtil;
			import com.alibaba.fastjson2.JSONArray;
			import com.alibaba.fastjson2.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.xiaopeng.api.dto.operation.PointAddDto;
			@@ -23,6 +25,7 @@
			import com.xiaopeng.common.core.utils.StringUtils;
			import com.xiaopeng.common.core.web.page.PageInfo;
			import com.xiaopeng.common.redis.service.RedisService;
			import com.xiaopeng.evi.oss.service.AliOssService;
			import com.xiaopeng.map.constant.I18nKeyConstant;
			import com.xiaopeng.map.dto.NearestDto;
			import com.xiaopeng.map.mapper.XpPointMapper;
			@@ -49,6 +52,7 @@
			import org.springframework.transaction.annotation.Transactional;

			import javax.annotation.Resource;
			import java.io.UnsupportedEncodingException;
			import java.time.LocalTime;
			import java.util.*;
			import java.util.concurrent.TimeUnit;
			@@ -68,6 +72,7 @@
			public class XpPointServiceImpl extends ServiceImpl<XpPointMapper, XpPoint> implements XpPointService {

			private static final String POINT_BIZ_TYPE = "PUD";
			private static final int MAX_POINTS_PER_FENCE = 15;
			private static final int SERIAL_WIDTH = 6;
			private static final int LOCK_WAIT_SECONDS = 5;
			private static final int LOCK_LEASE_SECONDS = 30;
			@@ -90,6 +95,9 @@
			@Autowired
			private RedissonClient redissonClient;

			@Autowired
			private AliOssService aliOssService;

			@Override
			@Transactional
			@ShardingSphereTransactionType(TransactionType.BASE)
			@@ -100,6 +108,7 @@
			if (pointAddDto.getElectronicAreaId() == null) {
			throw new ServiceException("运营区域ID不能为空", I18nKeyConstant.POINT_ELECTRONIC_AREA_ID_EMPTY);
			}
			validatePointNameUnique(pointAddDto.getPointName(), null);

			String cityPrefix = buildCityPrefix(pointAddDto.getElectronicAreaId());
			String lockKey = buildPointNumberLockKey(cityPrefix, POINT_BIZ_TYPE);
			@@ -112,6 +121,7 @@
			if (!locked) {
			throw new ServiceException("点位编号生成繁忙，请稍后重试", I18nKeyConstant.POINT_NUMBER_LOCK_FAIL);
			}
			validateFencePointCountLimit(pointAddDto.getElectronicAreaId());
			String maxPointNumber = this.baseMapper.selectMaxPointNumber(cityPrefix, POINT_BIZ_TYPE);
			int nextSerial = 1;
			if (StringUtils.hasText(maxPointNumber)) {
			@@ -137,6 +147,20 @@
			xpPoint.setPointNumber(pointNumber);
			this.save(xpPoint);
			return xpPoint;
			}

			@Override
			public void validatePointNameUnique(String pointName, Long excludeId) {
			if (!StringUtils.hasText(pointName)) {
			return;
			}
			long count = this.lambdaQuery()
			.eq(XpPoint::getPointName, pointName)
			.ne(excludeId != null, XpPoint::getId, excludeId)
			.count();
			if (count > 0) {
			throw new ServiceException("点位名称已存在", I18nKeyConstant.POINT_NAME_EXISTS);
			}
			}

			@Override
			@@ -193,6 +217,10 @@
			}

			private String buildCityPrefix(Long electronicAreaId) {
			//所有围栏范围之外，测试点位
			if(0 == electronicAreaId){
			return "TEST";
			}
			XpElectronicFenceArea area = xpElectronicFenceAreaService.getById(electronicAreaId);
			if (area == null) {
			throw new ServiceException("运营区域不存在", I18nKeyConstant.POINT_ELECTRONIC_AREA_NOT_EXIST);
			@@ -210,6 +238,36 @@
			String name = region.getName();
			String prefix = name.length() <= 2 ? name : name.substring(0, 2);
			return getPinyinInitials(prefix).toUpperCase();
			}

			private void validateFencePointCountLimit(Long electronicAreaId) {
			if (electronicAreaId == null \|\| electronicAreaId == 0L) {
			return;
			}
			XpElectronicFenceArea currentArea = xpElectronicFenceAreaService.getById(electronicAreaId);
			if (currentArea == null) {
			throw new ServiceException("运营区域不存在", I18nKeyConstant.POINT_ELECTRONIC_AREA_NOT_EXIST);
			}
			Long fenceId = currentArea.getElectronicId();
			if (fenceId == null) {
			throw new ServiceException("运营区域不存在", I18nKeyConstant.POINT_ELECTRONIC_AREA_NOT_EXIST);
			}
			List<Long> areaIds = xpElectronicFenceAreaService.lambdaQuery()
			.eq(XpElectronicFenceArea::getElectronicId, fenceId)
			.list()
			.stream()
			.map(XpElectronicFenceArea::getId)
			.filter(Objects::nonNull)
			.collect(Collectors.toList());
			if (areaIds.isEmpty()) {
			return;
			}
			long pointCount = this.lambdaQuery()
			.in(XpPoint::getElectronicAreaId, areaIds)
			.count();
			if (pointCount >= MAX_POINTS_PER_FENCE) {
			throw new ServiceException("当前围栏最多只能添加15个点位", I18nKeyConstant.POINT_FENCE_POINT_LIMIT_EXCEEDED);
			}
			}

			private static String buildPointNumberLockKey(String cityPrefix, String bizType) {
			@@ -290,6 +348,34 @@
			@Override
			public List<XpPoint> listAll(PointListQuery query) {
			List<XpPoint> list = this.baseMapper.listAll(query);
			for (XpPoint xpPoint : list) {
			String pointPictures = xpPoint.getPointPictures();
			log.info("pointPictures:{}", pointPictures);
			if (StringUtils.isNotBlank(pointPictures)) {
			log.info("pointPictures进入处理:{}", pointPictures);

			JSONArray jsonArray = JSONArray.parseArray(pointPictures);
			for (int i = 0; i < jsonArray.size(); i++) {
			JSONObject jsonObject = jsonArray.getJSONObject(i);
			if (Objects.isNull(jsonObject)) {
			continue;
			}
			String downloadUrl ="";
			try {
			downloadUrl = aliOssService.getDownloadUrl(jsonObject.getString("id"), jsonObject.getString("name"), true);
			log.info("downloadUrl:{}", downloadUrl);
			} catch (UnsupportedEncodingException e) {
			log.error("获取图片下载地址失败", e);
			}
			jsonObject.put("url", downloadUrl);
			}
			log.info("jsonArray:{}", jsonArray);
			xpPoint.setPointPictures(JSONArray.toJSONString(jsonArray));
			log.info("xpPoint:{}", xpPoint.getPointPictures());
			}

			}

			return list;
			}