From 47f0aa8aeda7a5a6984b04888c40b5cf86e33c8e Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 10 十月 2023 16:08:29 +0800
Subject: [PATCH] 骑行时长减免和强制还车
---
server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java | 133 +++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 129 insertions(+), 4 deletions(-)
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
index 25de87e..04d9dc4 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/MemberRidesServiceImpl.java
@@ -1,16 +1,18 @@
package com.doumee.service.business.impl;
+import com.alibaba.fastjson.JSONObject;
import com.doumee.core.constants.Constants;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
+import com.doumee.dao.business.ActionLogMapper;
import com.doumee.dao.business.MemberRidesMapper;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
-import com.doumee.dao.business.model.BaseParam;
-import com.doumee.dao.business.model.Goodsorder;
-import com.doumee.dao.business.model.Member;
-import com.doumee.dao.business.model.MemberRides;
+import com.doumee.dao.business.model.*;
import com.doumee.dao.business.web.request.MemberRidesQuery;
import com.doumee.dao.business.web.response.BikeLogDTO;
import com.doumee.dao.business.web.response.MemberRidesDTO;
@@ -22,12 +24,16 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.commons.lang3.StringUtils;
+import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
+import java.util.Date;
import java.util.List;
import java.util.Objects;
+import java.util.UUID;
/**
* 鐢ㄦ埛楠戣璁板綍琛⊿ervice瀹炵幇
@@ -39,6 +45,8 @@
@Autowired
private MemberRidesMapper memberRidesMapper;
+ @Autowired
+ private ActionLogMapper actionLogMapper;
@Autowired
@@ -132,6 +140,18 @@
@Override
+ public MemberRides findJoinById(String id) {
+
+ MPJLambdaWrapper<MemberRides> queryWrapper = new MPJLambdaWrapper<>();
+ queryWrapper.leftJoin(BaseParam.class,BaseParam::getId,MemberRides::getParamId);
+ queryWrapper.eq(MemberRides::getMemberId, id);
+ queryWrapper.selectAll(MemberRides.class);
+ queryWrapper.selectAs(BaseParam::getName,MemberRidesDTO::getBikeType) ;
+ queryWrapper.last("limit 1");
+
+ return memberRidesJoinMapper.selectJoinOne(MemberRides.class, queryWrapper);
+ }
+ @Override
public PageData<BikeLogDTO> findBikeLog(PageWrap<MemberRidesQuery> pageWrap) {
IPage<MemberRides> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
MPJLambdaWrapper<MemberRides> queryWrapper = initQueryParamByModel(pageWrap.getModel());
@@ -182,6 +202,111 @@
}
return memberRides.getBikeCode();
}
+ @Override
+ public void updateDuration(MemberRides memberRides){
+ LoginUserInfo user =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+ if(StringUtils.isBlank(memberRides.getMemberId())
+ || memberRides.getDuration() == null){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ MemberRides model = findJoinById(memberRides.getId());
+ if(model ==null){
+ throw new BusinessException( ResponseStatus.DATA_EMPTY );
+ }
+ if(Constants.formatIntegerNum(model.getStatus()) != Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey()||
+ Constants.formatIntegerNum(model.getCloseStatus()) != Constants.ONE){
+ throw new BusinessException( ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝鍙兘閽堝宸茶繕杞︿笖鏈粨绠楃殑鏁版嵁杩涜鎿嶄綔锛�" );
+ }
+ MemberRides update = new MemberRides();
+ update.setId(model.getId());
+ update.setDuration(memberRides.getDuration());
+ update.setEditDate(new Date());
+ update.setEditor(user.getId());
+ memberRidesMapper.updateById(update);
+ //淇敼鍓�
+ String beforeContent = JSONObject.toJSONString(model);
+ //淇敼鍚�
+ String after = JSONObject.toJSONString(update);
+
+ ActionLog log = new ActionLog();
+ log.setId(Constants.getUUID());
+ log.setIsdeleted(Constants.ZERO);
+ log.setCreateDate(update.getBackDate());
+ log.setCreator(user.getId());
+ log.setBeforeContent(beforeContent);
+ log.setAfterContent(after);
+ log.setUserId(user.getId());
+ log.setUserType(Constants.ONE);
+ log.setParam(JSONObject.toJSONString(memberRides ));
+ log.setType(Constants.ActionLogObjType.memberrides);
+ log.setResult(Constants.ZERO);
+ log.setObjId(model.getId());
+ log.setObjType(Constants.ACTIONLOG_TYPE.UPDATE_DURATION.getKey());
+ log.setContent(Constants.ACTIONLOG_TYPE.UPDATE_DURATION.getInfo());
+ log.setTitle(Constants.ACTIONLOG_TYPE.UPDATE_DURATION.getName());
+ //璁板綍鎿嶄綔鏃ュ織
+ actionLogMapper.insert(log);
+
+
+ }
+
+ /**
+ * 寮哄埗杩樿溅
+ * @param memberRides
+ */
+ @Override
+ @Transactional(rollbackFor = {BusinessException.class,Exception.class})
+ public void forceBack(MemberRides memberRides){
+ LoginUserInfo user =(LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+ if(StringUtils.isBlank(memberRides.getMemberId())
+ ||StringUtils.isBlank(memberRides.getBackReason())){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ MemberRides model = findJoinById(memberRides.getId());
+ if(model ==null){
+ throw new BusinessException( ResponseStatus.DATA_EMPTY );
+ }
+ if(Constants.formatIntegerNum(model.getStatus()) != Constants.MEMBER_RIDES_STATUS.RIDES_RUNNING.getKey() ){
+ throw new BusinessException( ResponseStatus.NOT_ALLOWED.getCode(),"瀵逛笉璧凤紝鍙兘閽堝鏈繕杞﹁締杩涜寮哄埗杩樿溅鎿嶄綔锛�" );
+ }
+ MemberRides update = new MemberRides();
+ update.setId(model.getId());
+ update.setEditDate(new Date());
+ update.setEditor(user.getId());
+ update.setBackInfo(memberRides.getBackInfo());
+ update.setBackDate(new Date());
+ update.setBackReason(memberRides.getBackReason());
+ update.setBackUserid(user.getId());
+ update.setBackType(Constants.ONE);
+ //璁＄畻楠戣璁¤垂鏃堕暱
+ update.setDuration(DateUtil.betweenMin(model.getRentDate(), update.getBackDate()));
+ memberRidesMapper.updateById(update);
+ //淇敼鍓�
+ String beforeContent = JSONObject.toJSONString(model);
+ //淇敼鍚�
+ String after = JSONObject.toJSONString(update);
+
+
+ ActionLog log = new ActionLog();
+ log.setId(Constants.getUUID());
+ log.setIsdeleted(Constants.ZERO);
+ log.setCreateDate(update.getBackDate());
+ log.setCreator(user.getId());
+ log.setBeforeContent(beforeContent);
+ log.setAfterContent(after);
+ log.setUserId(user.getId());
+ log.setUserType(Constants.ONE);
+ log.setParam(JSONObject.toJSONString(memberRides ));
+ log.setType(Constants.ActionLogObjType.memberrides);
+ log.setResult(Constants.ZERO);
+ log.setObjId(model.getId());
+ log.setObjType(Constants.ACTIONLOG_TYPE.FORCE_BACK.getKey());
+ log.setContent(Constants.ACTIONLOG_TYPE.FORCE_BACK.getInfo());
+ log.setTitle(Constants.ACTIONLOG_TYPE.FORCE_BACK.getName());
+ //璁板綍鎿嶄綔鏃ュ織
+ actionLogMapper.insert(log);
+
+ }
--
Gitblit v1.9.3