package com.ruoyi.worker.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.constant.Constants;
|
import com.ruoyi.common.core.domain.Result;
|
import com.ruoyi.common.core.utils.GaoDeMapUtil;
|
import com.ruoyi.worker.entity.MasterWorker;
|
import com.ruoyi.worker.entity.Order;
|
import com.ruoyi.worker.entity.RecoveryServe;
|
import com.ruoyi.worker.mapper.MasterWorkerMapper;
|
import com.ruoyi.worker.service.MasterWorkerService;
|
import com.ruoyi.worker.service.OrderService;
|
import com.ruoyi.worker.service.RecoveryServeService;
|
import com.ruoyi.worker.vo.OrderCountVO;
|
import com.ruoyi.worker.vo.OrderListVO;
|
import com.ruoyi.worker.vo.OrderNotHandleVO;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 师傅信息表 服务实现类
|
* </p>
|
*
|
* @author hjl
|
* @since 2024-06-03
|
*/
|
@Service
|
public class MasterWorkerServiceImpl extends ServiceImpl<MasterWorkerMapper, MasterWorker> implements MasterWorkerService {
|
|
@Resource
|
private OrderService orderService;
|
@Resource
|
private RecoveryServeService recoveryServeService;
|
|
@Override
|
public OrderCountVO orderCount(Integer id) {
|
return baseMapper.orderCount(id);
|
}
|
|
@Override
|
public List<OrderListVO> orderNotHandle(Integer userid, String longitude, String latitude) {
|
QueryWrapper<Order> wrapper = new QueryWrapper<>();
|
wrapper.eq("server_id", userid)
|
.in("state", 1, 2)
|
.eq("is_delete", Constants.ZERO)
|
.orderByAsc("CASE WHEN topSort IS NULL THEN 1 ELSE 0 END")
|
.orderByAsc("topSort");
|
List<Order> orderList = orderService.list(wrapper);
|
// 根据经纬度距离封装
|
List<OrderNotHandleVO> list = new ArrayList<>();
|
boolean item = false;
|
for (Order order : orderList) {
|
if (null != order.getTopSort()) {
|
item = true;
|
break;
|
}
|
}
|
for (Order order : orderList) {
|
// 用户下单经纬度
|
Double orderLongitude = order.getLongitude();
|
Double orderLatitude = order.getLatitude();
|
Integer topSort = order.getTopSort();
|
String orderPosition = orderLongitude + "," + orderLatitude;
|
// 根据经纬度计算与师傅的距离
|
Result<Long> result = GaoDeMapUtil.getDistance(orderPosition, longitude + "," + latitude);
|
Long distance = result.getDatas();
|
// 回收服务信息
|
RecoveryServe recoveryServe = recoveryServeService.lambdaQuery()
|
.eq(RecoveryServe::getId, order.getServeId())
|
.eq(RecoveryServe::getIsDelete, 0).one();
|
// vo类信息封装
|
OrderListVO orderListVO = new OrderListVO(order.getServeId());
|
orderListVO.setOrderId(order.getId());
|
orderListVO.setOrderNumber(order.getOrderNumber());
|
orderListVO.setSiteId(order.getSiteId());
|
orderListVO.setSiteName(order.getSiteName());
|
orderListVO.setServeId(order.getServeId());
|
orderListVO.setServeName(order.getServeName());
|
if (null != recoveryServe) {
|
orderListVO.setServePicture(recoveryServe.getCover());
|
orderListVO.setServePrice(recoveryServe.getDefaultPrice());
|
}
|
orderListVO.setUserId(userid);
|
orderListVO.setReservationName(order.getReservationName());
|
orderListVO.setReservationPhone(order.getReservationPhone());
|
orderListVO.setReservationAddress(order.getReservationAddress());
|
orderListVO.setTime(order.getTime());
|
orderListVO.setServerId(order.getServerId());
|
orderListVO.setServerName(order.getServerName());
|
orderListVO.setServerPhone(order.getServerPhone());
|
orderListVO.setReservationRemark(order.getReservationRemark());
|
orderListVO.setOrderMoney(order.getOrderMoney());
|
orderListVO.setState(order.getState());
|
orderListVO.setAcceptTime(order.getAcceptTime());
|
orderListVO.setArriveTime(order.getArriveTime());
|
orderListVO.setType(order.getType());
|
orderListVO.setLongitude(order.getLongitude());
|
orderListVO.setLatitude(order.getLatitude());
|
orderListVO.setTopSort(topSort);
|
OrderNotHandleVO vo = new OrderNotHandleVO(distance, orderListVO);
|
list.add(vo);
|
}
|
if (item) {
|
return list.stream().map(OrderNotHandleVO::getOrderList).collect(Collectors.toList());
|
} else {
|
// 根据距离排序
|
list.sort(Comparator.comparing(OrderNotHandleVO::getDistance));
|
List<OrderListVO> resultList = list.stream().map(OrderNotHandleVO::getOrderList).collect(Collectors.toList());
|
for (OrderListVO orderListVO : resultList) {
|
Integer serveId = orderListVO.getServeId();
|
// 回收服务信息
|
RecoveryServe recoveryServe = recoveryServeService.lambdaQuery().eq(RecoveryServe::getId, serveId)
|
.eq(RecoveryServe::getIsDelete, 0).one();
|
if (null != recoveryServe) {
|
orderListVO.setServePicture(recoveryServe.getCover());
|
}
|
}
|
return resultList;
|
}
|
|
}
|
|
@Override
|
public Boolean orderTop(Integer orderId, Integer userid) {
|
// 订单代办列表
|
List<Order> orderList = orderService.lambdaQuery().eq(Order::getServerId, userid)
|
.in(Order::getState, Constants.ONE, Constants.TWO)
|
.eq(Order::getIsDelete, 0)
|
.orderByAsc(Order::getTopSort).list();
|
int itemSort = 2;
|
for (Order order : orderList) {
|
if (null != order.getTopSort()) {
|
order.setTopSort(itemSort);
|
itemSort++;
|
}
|
}
|
orderService.updateBatchById(orderList);
|
return orderService.lambdaUpdate().set(Order::getTopSort, Constants.ONE)
|
.eq(Order::getServerId, userid)
|
.eq(Order::getId, orderId)
|
.eq(Order::getIsDelete, 0).update();
|
}
|
|
}
|
