From b938c9c1824cc57d9b487ed607bbf65bf63f4a81 Mon Sep 17 00:00:00 2001
From: 彭雪彬 <1724387007@qq.com>
Date: Wed, 16 Jul 2025 16:49:54 +0800
Subject: [PATCH] 骑手完成订单接口修改
---
oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java | 43 ++++++++++++++++++++-
oying-system/src/main/resources/mapper/rider/RiderOrderRecordMapper.xml | 45 +++++++++++++++++++---
oying-system/src/main/java/com/oying/modules/rider/mapper/RiderOrderRecordMapper.java | 2 +
oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java | 16 ++++++++
oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java | 2
oying-system/src/main/java/com/oying/modules/rider/domain/RiderOrderRecord.java | 3 +
6 files changed, 100 insertions(+), 11 deletions(-)
diff --git a/oying-system/src/main/java/com/oying/modules/rider/domain/RiderOrderRecord.java b/oying-system/src/main/java/com/oying/modules/rider/domain/RiderOrderRecord.java
index 51998f3..9fc34c6 100644
--- a/oying-system/src/main/java/com/oying/modules/rider/domain/RiderOrderRecord.java
+++ b/oying-system/src/main/java/com/oying/modules/rider/domain/RiderOrderRecord.java
@@ -96,6 +96,9 @@
@ApiModelProperty(value = "配送费详情Id")
private String deliveryFeeId;
+ @ApiModelProperty(value = "预计送达时间")
+ private String orderTime;
+
public void copy(RiderOrderRecord source){
BeanUtil.copyProperties(source,this, CopyOptions.create().setIgnoreNullValue(true));
}
diff --git a/oying-system/src/main/java/com/oying/modules/rider/mapper/RiderOrderRecordMapper.java b/oying-system/src/main/java/com/oying/modules/rider/mapper/RiderOrderRecordMapper.java
index c24ed5f..7ca744f 100644
--- a/oying-system/src/main/java/com/oying/modules/rider/mapper/RiderOrderRecordMapper.java
+++ b/oying-system/src/main/java/com/oying/modules/rider/mapper/RiderOrderRecordMapper.java
@@ -19,4 +19,6 @@
IPage<RiderOrderRecord> findAll(@Param("criteria") RiderOrderRecordQueryCriteria criteria, Page<Object> page);
List<RiderOrderRecord> findAll(@Param("criteria") RiderOrderRecordQueryCriteria criteria);
+
+ RiderOrderRecord selectRiderInfo(@Param("orderNum") String orderNum);
}
diff --git a/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java b/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java
index 67c9d43..aac7c8a 100644
--- a/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java
+++ b/oying-system/src/main/java/com/oying/modules/rider/service/RiderOrderRecordService.java
@@ -2,6 +2,8 @@
import com.oying.modules.rider.domain.RiderOrderRecord;
import com.oying.modules.rider.domain.dto.RiderOrderRecordQueryCriteria;
+
+import java.text.ParseException;
import java.util.List;
import java.io.IOException;
import javax.servlet.http.HttpServletResponse;
@@ -60,6 +62,7 @@
*/
void download(List<RiderOrderRecord> all, HttpServletResponse response) throws IOException;
+
/**
* 骑手接单
* @param orderNum
@@ -88,5 +91,18 @@
*/
R riderOperationOrder(OrderRiderOperationVo orderRiderOperation);
+ /**
+ * 骑手完成订单状态
+ * @param orderNum
+ * @throws IOException /
+ */
R riderCompleteOrder(String orderNum);
+
+ /**
+ * 骑手完成订单修改接口
+ * @param orderNum
+ * @param
+ * @throws IOException /
+ */
+ void updateRiderOrderInfo(String orderNum) ;
}
diff --git a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java b/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java
index bfc28be..716c517 100644
--- a/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java
+++ b/oying-system/src/main/java/com/oying/modules/rider/service/impl/RiderOrderRecordServiceImpl.java
@@ -3,7 +3,6 @@
import cn.hutool.core.lang.UUID;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.oying.exception.BadRequestException;
-import com.oying.modules.pc.store.domain.Store;
import com.oying.modules.pc.store.service.StoreService;
import com.oying.modules.rider.domain.RiderIncomeDetail;
import com.oying.modules.rider.domain.RiderInfo;
@@ -29,6 +28,8 @@
import org.springframework.transaction.annotation.Transactional;
import java.sql.Timestamp;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.Map;
import java.io.IOException;
@@ -126,6 +127,41 @@
@Override
@Transactional(rollbackFor = Exception.class)
+ public void updateRiderOrderInfo(String orderNum) {
+ // 查询骑手订单信息
+ RiderOrderRecord riderOrderRecord = riderOrderRecordMapper.selectRiderInfo(orderNum);
+ // 当前为接单 设置为待取货状态 1-待取货 2-配送中 3-已完成 4-商家取消 5-骑手取消 6-客户取消 7-系统取消
+ RiderOrderRecord riderOrderRecordUpdate = new RiderOrderRecord();
+ riderOrderRecordUpdate.setRecordId(riderOrderRecord.getRecordId());
+ riderOrderRecordUpdate.setOrderNum(orderNum);
+ riderOrderRecordUpdate.setOrderStatus(Constants.ORDER_STATUS_FINISH);
+ // 判断是否超时 当前时间和预计送达时间做比较// 获取当前时间
+ Timestamp now = new Timestamp(System.currentTimeMillis());
+ // 获取订单的预计送达时间（假设 orderResponse.getOrder().getOrderTime() 返回的是 Timestamp 类型）
+ DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+ LocalDateTime orderLocalTime = LocalDateTime.parse(riderOrderRecord.getOrderTime(), formatter);
+ Timestamp orderTime = Timestamp.valueOf(orderLocalTime);
+ // 判断是否超时
+ String isOvertime = Constants.IS_OVERTIME_YES;
+ if (now.after(orderTime)) {
+ isOvertime = Constants.IS_OVERTIME_YES;
+ }
+ // 设置到订单记录中
+ riderOrderRecordUpdate.setIsOvertime(isOvertime);
+ // 完成时间
+ Timestamp finishTime = new Timestamp(System.currentTimeMillis());
+ riderOrderRecordUpdate.setFinishTime(finishTime);
+ // 接单时间-完成时间 计算出相隔秒数
+ Timestamp acceptTime = riderOrderRecord.getAcceptTime();
+ // 计算两个时间之间的秒数差
+ long durationInSeconds = (finishTime.getTime() - acceptTime.getTime()) / 1000;
+ riderOrderRecordUpdate.setDeliveryDuration(durationInSeconds);
+ // 更新订单状态
+ riderOrderRecordMapper.updateById(riderOrderRecordUpdate);
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
public R riderGrabOrder(String orderNum) {
Long riderId = SecurityUtils.getCurrentUserId();
// 查询骑手信息
@@ -216,6 +252,7 @@
// 配送费详情Id
// riderOrderRecord.setDeliveryFeeId(orderResponse.getOrder().getDeliveryFeeId());
riderOrderRecord.setOrderIncome(orderResponse.getOrder().getSendPrice());
+ riderOrderRecord.setOrderTime(orderResponse.getOrder().getOrderTime());
create(riderOrderRecord);
}
@@ -257,8 +294,8 @@
Order order = orderResponse.getOrder();
// 添加订单操作记录 订单完成
orderService.operationLog(orderResponse, OrderStatusEnum.SEVEN, orderResponse.getOrder().getRiderName());
- // 修改骑手端的订单状态
- updateRiderOrderStatus(orderNum, Constants.ORDER_STATUS_FINISH);
+ // 修改骑手端的订单状态 // 修改完成时间
+ updateRiderOrderInfo(orderNum);
// 返回参数
orderResponse.getOrder().setOrderStatus(OrderStatusEnum.SEVEN.getKey());
// 查询骑手钱包信息
diff --git a/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java b/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java
index af9f5c5..ecbb6cc 100644
--- a/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java
+++ b/oying-system/src/main/java/com/oying/modules/rider/utils/Constants.java
@@ -42,7 +42,7 @@
* 超时状态 1-是 0-否
*/
String IS_OVERTIME_NO = "0";
- String IS_OVERTIME = "1";
+ String IS_OVERTIME_YES = "1";
/**
* 订单来源： 1-平台派单 2-骑手抢单 3-商家直派 4-其他
diff --git a/oying-system/src/main/resources/mapper/rider/RiderOrderRecordMapper.xml b/oying-system/src/main/resources/mapper/rider/RiderOrderRecordMapper.xml
index b7d5b39..9442c58 100644
--- a/oying-system/src/main/resources/mapper/rider/RiderOrderRecordMapper.xml
+++ b/oying-system/src/main/resources/mapper/rider/RiderOrderRecordMapper.xml
@@ -30,13 +30,39 @@
<result column="merchant_latitude" property="merchantLatitude"/>
<result column="user_id" property="userId"/>
<result column="delivery_fee_id" property="deliveryFeeId"/>
+ <result column="order_time" property="orderTime"/>
</resultMap>
<sql id="Base_Column_List">
- record_id, order_id, order_num, merchant_id, merchant_name, merchant_address,
- receiver_address, order_status, accept_time, accept_num, finish_time, delivery_duration,
- is_overtime, order_source, order_income, create_by, create_time, update_by, update_time,
- rider_id, phone, rider_name, user_id, user_longitude, user_latitude, merchant_longitude, merchant_latitude,delivery_fee_id
+ record_id,
+ order_id,
+ order_num,
+ merchant_id,
+ merchant_name,
+ merchant_address,
+ receiver_address,
+ order_status,
+ accept_time,
+ accept_num,
+ finish_time,
+ delivery_duration,
+ is_overtime,
+ order_source,
+ order_income,
+ create_by,
+ create_time,
+ update_by,
+ update_time,
+ rider_id,
+ phone,
+ rider_name,
+ user_id,
+ user_longitude,
+ user_latitude,
+ merchant_longitude,
+ merchant_latitude,
+ delivery_fee_id,
+ order_time
</sql>
<select id="findAll" resultMap="BaseResultMap">
select
@@ -59,13 +85,13 @@
and merchant_id = #{criteria.merchantId}
</if>
<if test="criteria.merchantName != null">
- and merchant_name like concat('%',#{criteria.merchantName},'%')
+ and merchant_name like concat('%', #{criteria.merchantName}, '%')
</if>
<if test="criteria.merchantAddress != null">
- and merchant_address like concat('%',#{criteria.merchantAddress},'%')
+ and merchant_address like concat('%', #{criteria.merchantAddress}, '%')
</if>
<if test="criteria.receiverAddress != null">
- and receiver_address like concat('%',#{criteria.receiverAddress},'%')
+ and receiver_address like concat('%', #{criteria.receiverAddress}, '%')
</if>
<if test="criteria.orderStatus != null">
and order_status = #{criteria.orderStatus}
@@ -85,4 +111,9 @@
</where>
order by create_time desc
</select>
+
+ <select id="selectRiderInfo" resultMap="BaseResultMap">
+ select record_id recordId ,accept_time as acceptTime, order_time as orderTime
+ from qs_rider_order_record where order_num = #{orderNum}
+ </select>
</mapper>
\ No newline at end of file
--
Gitblit v1.9.3