| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.ruoyi.common.core.constant.Constants; |
| | |
| | | import java.util.stream.Collectors; |
| | | import javax.annotation.Resource; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.util.CollectionUtils; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestBody; |
| | |
| | | order.setServerPhone(phone); |
| | | orderService.updateById(order); |
| | | } |
| | | List<ChangeDispatch> list = changeDispatchService.lambdaQuery().eq(ChangeDispatch::getOrderId, orderId).list(); |
| | | changeDispatchService.removeBatchByIds(list); |
| | | // List<ChangeDispatch> list = changeDispatchService.lambdaQuery().eq(ChangeDispatch::getOrderId, orderId).list(); |
| | | // changeDispatchService.removeBatchByIds(list); |
| | | return R.ok(order); |
| | | } |
| | | |
| | |
| | | ).set(Order::getArriveTime, null).update(); |
| | | |
| | | //删除改派管理的订单 |
| | | List<ChangeDispatch> list = changeDispatchService.lambdaQuery().eq(ChangeDispatch::getOrderId, order.getId()).list(); |
| | | changeDispatchService.removeBatchByIds(list); |
| | | // List<ChangeDispatch> list = changeDispatchService.lambdaQuery().eq(ChangeDispatch::getOrderId, order.getId()).list(); |
| | | // changeDispatchService.removeBatchByIds(list); |
| | | |
| | | } |
| | | // } |
| | |
| | | order.setProvinceCode(orderRequest.getProvinceCode()); |
| | | order.setAreaCode(orderRequest.getAreaCode()); |
| | | return R.ok(orderService.updateById(order)); |
| | | } |
| | | |
| | | /** |
| | | * 批量修改订单时间 |
| | | * @param ids 站点多条id拼接 |
| | | */ |
| | | @ApiOperation(value = "订单列表-批量修改订单时间", tags = {"后台-订单管理[2.0]"}) |
| | | @GetMapping(value = "/batchUpdateTime") |
| | | public R<Boolean> batchUpdateTime(@RequestParam("ids") String ids, @RequestParam("time") String time) { |
| | | List<String> idList = Arrays.stream(ids.split(",")).collect(Collectors.toList()); |
| | | List<Order> list = orderService.lambdaQuery().in(Order::getId, idList).list(); |
| | | if (!CollectionUtils.isEmpty(list)) { |
| | | list.forEach(data -> data.setTime(time)); |
| | | orderService.updateBatchById(list); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | |
| | | @GetMapping(value = "/updateArrivalTime") |
| | | public R<Boolean> updateArrivalTime(@RequestParam("orderId")String orderId,@RequestParam("arriveTime")Date arriveTime) { |
| | | public R<Boolean> updateArrivalTime(@RequestParam("orderId")String orderId,@RequestParam("arriveTime")String arriveTime) { |
| | | Order byId = orderService.getById(orderId); |
| | | byId.setArriveTime(arriveTime); |
| | | byId.setTime(arriveTime); |
| | | orderService.updateById(byId); |
| | | return R.ok(); |
| | | } |
| | | |
| | |
| | | @RequestParam("siteIds") List<String> siteIds |
| | | ) { |
| | | Page<Order> page = orderService.lambdaQuery().eq(Order::getUserId, userId) |
| | | .eq(Order::getIsDelete, 0).in(!siteIds.isEmpty(),Order::getSiteId, siteIds).in(!cityList.isEmpty(),Order::getCityCode, cityList).page(Page.of(pageNum, pageSize)); |
| | | .eq(Order::getIsDelete, 0) |
| | | .in(!cityList.isEmpty(),Order::getCityCode, cityList).page(Page.of(pageNum, pageSize)); |
| | | return R.ok(page); |
| | | } |
| | | |
| | |
| | | */ |
| | | @ApiOperation(value = "师傅端-订单列表", tags = {"师傅端"}) |
| | | @GetMapping(value = "/orderListWorker") |
| | | public R<Page<Order>> orderListWorker(@RequestParam("userId") Integer userId, @RequestParam("state") Integer state, |
| | | public R<Page<Order>> orderListWorker(@RequestParam("userId") Integer userId, @RequestParam("state") Integer state,@RequestParam("searchValues") String searchValues, |
| | | @RequestParam(name = "pageNum", defaultValue = "1") Integer pageNum, |
| | | @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) { |
| | | return R.ok(orderService.orderListWorker(userId, state, pageNum, pageSize)); |
| | | return R.ok(orderService.orderListWorker(userId, state, searchValues,pageNum, pageSize)); |
| | | } |
| | | |
| | | /** |
| | |
| | | order.setCompleteTime(new Date()); |
| | | order.setState(Constants.THREE); |
| | | order.setFake(orderSubmitRequest.getFake()); |
| | | order.setRemark(orderSubmitRequest.getRemark()); |
| | | boolean update = orderService.updateById(order); |
| | | // 服务记录 |
| | | ServeRecord serveRecord = new ServeRecord(); |
| | |
| | | |
| | | QueryWrapper<Order> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("server_id", workerId) |
| | | .in("state", 1, 2) |
| | | .in("state", 1, 2,7) |
| | | .eq("is_delete", Constants.ZERO) |
| | | .eq("DATE(time)", todayStr) // 添加这一行来筛选当天的订单 |
| | | .orderByAsc("CASE WHEN topSort IS NULL THEN 1 ELSE 0 END") |
| | |
| | | return R.ok(orderService.placeOrder(userOrderRequest)); |
| | | } |
| | | |
| | | /** |
| | | * 师傅端-打电话 |
| | | */ |
| | | @ApiOperation(value = "打电话", tags = {"师傅端-打电话[2.0]"}) |
| | | @GetMapping(value = "/call") |
| | | public R<String> call(@RequestParam("orderId") String orderId) { |
| | | Order order = orderService.getById(orderId); |
| | | if(Objects.isNull(order)){ |
| | | return R.fail("订单不存在"); |
| | | } |
| | | if(order.getState() == 7){ |
| | | order.setState(1); |
| | | orderService.updateById(order); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | /** |
| | | * 领取补贴金 |
| | | */ |
| | | @GetMapping(value = "/receiving") |
| | | public R<String> receiving(@RequestParam("orderId")String orderId, @RequestParam("recycleSubsidy")BigDecimal recycleSubsidy) { |
| | | Order order = orderService.getById(orderId); |
| | | if(Objects.isNull(order)){ |
| | | return R.fail("订单不存在"); |
| | | } |
| | | order.setSubsidy(recycleSubsidy); |
| | | order.setOrderMoney(order.getOrderMoney().add(recycleSubsidy)); |
| | | orderService.updateById(order); |
| | | return R.ok(); |
| | | } |
| | | |
| | | /** |
| | | * 领取补贴金 |
| | | */ |
| | | @GetMapping(value = "/getTodayOrderData") |
| | | public R<List<Order>> getTodayOrderData() { |
| | | List<Order> orders = orderService.list(Wrappers.lambdaQuery(Order.class) |
| | | .eq(Order::getTime, LocalDate.now()) |
| | | .eq(Order::getIsDelete, 0)); |
| | | return R.ok(orders); |
| | | } |
| | | |
| | | } |