This commit is contained in:
2023-04-06 15:30:55 +08:00
parent d3cf6c42b2
commit 64a8ea3379
5 changed files with 37 additions and 11 deletions

View File

@@ -107,6 +107,8 @@ public class PileRemoteService {
*/ */
public void issueQRCode(String pileSn) { public void issueQRCode(String pileSn) {
IssueQRCodeCommand command = IssueQRCodeCommand.builder().pileSn(pileSn).build(); IssueQRCodeCommand command = IssueQRCodeCommand.builder().pileSn(pileSn).build();
// 查询充电站info
ykcPushCommandService.pushIssueQRCodeCommand(command); ykcPushCommandService.pushIssueQRCodeCommand(command);
} }

View File

@@ -15,7 +15,6 @@ import com.jsowell.common.util.DateUtils;
import com.jsowell.common.util.SecurityUtils; import com.jsowell.common.util.SecurityUtils;
import com.jsowell.common.util.StringUtils; import com.jsowell.common.util.StringUtils;
import com.jsowell.common.util.id.SnUtils; import com.jsowell.common.util.id.SnUtils;
import com.jsowell.netty.command.ykc.IssueQRCodeCommand;
import com.jsowell.netty.service.yunkuaichong.YKCPushCommandService; import com.jsowell.netty.service.yunkuaichong.YKCPushCommandService;
import com.jsowell.pile.domain.MemberBasicInfo; import com.jsowell.pile.domain.MemberBasicInfo;
import com.jsowell.pile.domain.OrderBasicInfo; import com.jsowell.pile.domain.OrderBasicInfo;
@@ -106,6 +105,9 @@ public class PileService {
@Autowired @Autowired
private YKCPushCommandService ykcPushCommandService; private YKCPushCommandService ykcPushCommandService;
@Autowired
private PileRemoteService pileRemoteService;
/** /**
* 查询设备信息 * 查询设备信息
* *
@@ -519,13 +521,15 @@ public class PileService {
List<String> pileSnList = pileDetailVOS.stream() List<String> pileSnList = pileDetailVOS.stream()
.map(PileDetailVO::getPileSn) .map(PileDetailVO::getPileSn)
.collect(Collectors.toList()); .collect(Collectors.toList());
IssueQRCodeCommand command; // IssueQRCodeCommand command;
for (String pileSn : pileSnList) { for (String pileSn : pileSnList) {
// 给桩下发二维码 // 给桩下发二维码
command = new IssueQRCodeCommand(); // command = new IssueQRCodeCommand();
command.setPileSn(pileSn); // command.setPileSn(pileSn);
command.setQrcodePrefix(dto.getQrcodePrefix()); // command.setQrcodePrefix(dto.getQrcodePrefix());
ykcPushCommandService.pushIssueQRCodeCommand(command); // ykcPushCommandService.pushIssueQRCodeCommand(command);
pileRemoteService.issueQRCode(pileSn);
} }
return 1; return 1;
} }

View File

@@ -4,7 +4,6 @@ import com.jsowell.common.core.page.PageResponse;
import com.jsowell.pile.domain.PileStationInfo; import com.jsowell.pile.domain.PileStationInfo;
import com.jsowell.pile.dto.FastCreateStationDTO; import com.jsowell.pile.dto.FastCreateStationDTO;
import com.jsowell.pile.dto.QueryStationDTO; import com.jsowell.pile.dto.QueryStationDTO;
import com.jsowell.pile.vo.base.StationInfoVO;
import com.jsowell.pile.vo.web.PileStationVO; import com.jsowell.pile.vo.web.PileStationVO;
import java.util.List; import java.util.List;
@@ -89,4 +88,6 @@ public interface IPileStationInfoService {
PageResponse uniAppQueryStationInfoList(QueryStationDTO queryStationDTO); PageResponse uniAppQueryStationInfoList(QueryStationDTO queryStationDTO);
PileStationVO getStationInfo(String stationId); PileStationVO getStationInfo(String stationId);
PileStationVO getStationInfoByPileSn(String pileSn);
} }

View File

@@ -95,6 +95,7 @@ public class PileBasicInfoServiceImpl implements IPileBasicInfoService {
@Override @Override
public PileBasicInfo selectPileBasicInfoBySN(String pileSn) { public PileBasicInfo selectPileBasicInfoBySN(String pileSn) {
// 加缓存
return pileBasicInfoMapper.selectPileBasicInfoBySn(pileSn); return pileBasicInfoMapper.selectPileBasicInfoBySn(pileSn);
} }

View File

@@ -1,31 +1,33 @@
package com.jsowell.pile.service.impl; package com.jsowell.pile.service.impl;
import cn.hutool.core.util.PageUtil; import cn.hutool.core.util.PageUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.jsowell.common.constant.Constants; import com.jsowell.common.constant.Constants;
import com.jsowell.common.core.domain.entity.SysDept; import com.jsowell.common.core.domain.entity.SysDept;
import com.jsowell.common.core.domain.vo.AuthorizedDeptVO; import com.jsowell.common.core.domain.vo.AuthorizedDeptVO;
import com.jsowell.common.core.page.PageResponse; import com.jsowell.common.core.page.PageResponse;
import com.jsowell.common.util.*; import com.jsowell.common.util.DateUtils;
import com.jsowell.common.util.DistanceUtils;
import com.jsowell.common.util.SecurityUtils;
import com.jsowell.common.util.StringUtils;
import com.jsowell.common.util.ip.AddressUtils; import com.jsowell.common.util.ip.AddressUtils;
import com.jsowell.pile.domain.PileStationInfo; import com.jsowell.pile.domain.PileStationInfo;
import com.jsowell.pile.dto.FastCreateStationDTO; import com.jsowell.pile.dto.FastCreateStationDTO;
import com.jsowell.pile.dto.QueryStationDTO; import com.jsowell.pile.dto.QueryStationDTO;
import com.jsowell.pile.mapper.PileStationInfoMapper; import com.jsowell.pile.mapper.PileStationInfoMapper;
import com.jsowell.pile.service.IPileBasicInfoService;
import com.jsowell.pile.service.IPileBillingTemplateService; import com.jsowell.pile.service.IPileBillingTemplateService;
import com.jsowell.pile.service.IPileConnectorInfoService; import com.jsowell.pile.service.IPileConnectorInfoService;
import com.jsowell.pile.service.IPileMerchantInfoService; import com.jsowell.pile.service.IPileMerchantInfoService;
import com.jsowell.pile.service.IPileStationInfoService; import com.jsowell.pile.service.IPileStationInfoService;
import com.jsowell.pile.vo.base.ConnectorInfoVO; import com.jsowell.pile.vo.base.ConnectorInfoVO;
import com.jsowell.pile.vo.base.MerchantInfoVO; import com.jsowell.pile.vo.base.MerchantInfoVO;
import com.jsowell.pile.vo.base.PileInfoVO;
import com.jsowell.pile.vo.base.StationInfoVO; import com.jsowell.pile.vo.base.StationInfoVO;
import com.jsowell.pile.vo.uniapp.CurrentTimePriceDetails; import com.jsowell.pile.vo.uniapp.CurrentTimePriceDetails;
import com.jsowell.pile.vo.web.PileStationVO; import com.jsowell.pile.vo.web.PileStationVO;
import com.jsowell.system.service.SysDeptService; import com.jsowell.system.service.SysDeptService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -58,6 +60,9 @@ public class PileStationInfoServiceImpl implements IPileStationInfoService {
@Autowired @Autowired
private SysDeptService sysDeptService; private SysDeptService sysDeptService;
@Autowired
private IPileBasicInfoService pileBasicInfoService;
/** /**
* 查询充电站信息 * 查询充电站信息
* *
@@ -71,6 +76,7 @@ public class PileStationInfoServiceImpl implements IPileStationInfoService {
/** /**
* 查询站点基本资料 * 查询站点基本资料
* 加缓存
* @param stationId * @param stationId
* @return * @return
*/ */
@@ -116,6 +122,18 @@ public class PileStationInfoServiceImpl implements IPileStationInfoService {
return vo; return vo;
} }
@Override
public PileStationVO getStationInfoByPileSn(String pileSn) {
// 通过pileSn查询充电桩缓存方法
PileInfoVO pileInfoVO = pileBasicInfoService.selectPileInfoBySn(pileSn);
if (pileInfoVO == null) {
return null;
}
// 通过stationId查询充电站信息缓存方法
PileStationVO stationInfo = getStationInfo(pileInfoVO.getStationId());
return stationInfo;
}
/** /**
* 查询充电站信息列表 * 查询充电站信息列表
* *