From 3d3ed4872b5038a8cc72abc72f95fc2c134e7bc4 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期四, 20 三月 2025 09:32:56 +0800
Subject: [PATCH] 111
---
server/services/src/main/java/com/doumee/service/business/impl/BikesServiceImpl.java | 57 ++++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 46 insertions(+), 11 deletions(-)
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/BikesServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/BikesServiceImpl.java
index 76469d4..cec7e7b 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/BikesServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/BikesServiceImpl.java
@@ -12,6 +12,7 @@
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.BaseParamMapper;
import com.doumee.dao.business.BikesMapper;
+import com.doumee.dao.business.MemberRidesMapper;
import com.doumee.dao.business.join.BikesJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.dao.business.vo.BikesImportVO;
@@ -39,6 +40,7 @@
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;
+import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
@@ -59,10 +61,10 @@
private BaseParamMapper baseParamMapper;
@Autowired
private BikesJoinMapper bikesJoinMapper;
-
-
@Autowired
- SystemDictDataMapper systemDictDataMapper;
+ private MemberRidesMapper memberRidesMapper;
+ @Autowired
+ private SystemDictDataMapper systemDictDataMapper;
@Override
public String create(Bikes bikes) {
@@ -208,7 +210,11 @@
.in(SystemDictData::getLabel, Arrays.asList(Constants.FORCE_BACK_SITE,Constants.FORCE_BACK_LOCK,Constants.LOW_BIKE_VOLTAGE));
List<SystemDictData> systemDictData = systemDictDataMapper.selectList(wrapper);
Map<String, SystemDictData> collect = systemDictData.stream().collect(Collectors.toMap(s -> s.getLabel(), s -> s));
-
+ double low = 0;
+ try {
+ low = Double.parseDouble(collect.get(Constants.LOW_BIKE_VOLTAGE).getCode());
+ }catch (Exception e){
+ }
IPage<Bikes> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
MPJLambdaWrapper<Bikes> queryWrapper = new MPJLambdaWrapper<>();
Utils.MP.blankToNull(pageWrap.getModel());
@@ -230,12 +236,7 @@
.isNotNull(Constants.formatIntegerNum(pageWrap.getModel().getType())==0,Bikes::getCode)
.and(Constants.formatIntegerNum(pageWrap.getModel().getType())==0,b->b.ne(Bikes::getCode,"")));
if(pageWrap.getModel().getLowVoltage()!=null){
- double low = 0;
- try {
- low = Double.parseDouble(collect.get(Constants.LOW_BIKE_VOLTAGE).getCode());
- }catch (Exception e){
- }
- if(pageWrap.getModel().getType() == Constants.ONE){
+ if(pageWrap.getModel().getLowVoltage() == Constants.ONE){
//浣庣數閲�
queryWrapper.lt(Bikes::getVoltage,low);
}else{
@@ -246,7 +247,15 @@
queryWrapper.selectAll(Bikes.class)
.selectAs(BaseParam::getName,Bikes::getParamName)
.selectAs(Sites::getName,Bikes::getSiteName) ;
- return PageData.from(bikesJoinMapper.selectJoinPage(page, Bikes.class, queryWrapper));
+ PageData<Bikes> pageData = PageData.from(bikesJoinMapper.selectJoinPage(page, Bikes.class, queryWrapper));
+ double finalLow = low;
+ pageData.getRecords().forEach(i->{
+ if(Constants.equalsInteger(i.getType(),Constants.ONE)){
+ i.setLowVoltage(i.getVoltage().compareTo(new BigDecimal(Double.toString(finalLow)))>=0?0:1);
+ }
+ });
+ return pageData;
+
}
@Override
public PageData<Bikes> findPage(PageWrap<Bikes> pageWrap) {
@@ -423,4 +432,30 @@
bike.setType(Constants.ONE);//鍙兘鏂板鐢佃溅鏁版嵁
return bike;
}
+
+
+ @Override
+ public List<Bikes> getEleBikes(String memberId) {
+ //鏌ヨ褰撳墠鏄惁澶勪簬楠戣涓�
+ MemberRides memberRides = memberRidesMapper.selectOne(new QueryWrapper<MemberRides>().lambda().eq(MemberRides::getMemberId,memberId)
+ .in(MemberRides::getStatus,Constants.MEMBER_RIDES_STATUS.RIDES_RUNNING.getKey()
+ ,Constants.MEMBER_RIDES_STATUS.RIDES_PAUSING.getKey())
+ .eq(MemberRides::getType,Constants.ONE)
+ .orderByDesc(MemberRides::getCreateDate)
+ .last(" limit 1 ")
+ );
+ QueryWrapper<Bikes> queryWrapper = new QueryWrapper<>();
+ queryWrapper.lambda().eq(Bikes::getIsdeleted,Constants.ZERO)
+ .eq(Bikes::getType,Constants.ONE)
+ .isNotNull(Bikes::getLatitude)
+ .isNotNull(Bikes::getLongitude);
+ if(Objects.nonNull(memberRides)&&StringUtils.isNotBlank(memberRides.getBikeCode())){
+ queryWrapper.lambda().eq(Bikes::getCode,memberRides.getBikeCode());
+ }else{
+ queryWrapper.lambda().eq(Bikes::getStatus,Constants.ZERO);
+ }
+ return bikesMapper.selectList(queryWrapper);
+ }
+
+
}
--
Gitblit v1.9.3