|
|
@ -7,6 +7,7 @@ import cc.yunxi.common.exception.BizIllegalException;
|
|
|
|
import cc.yunxi.common.utils.BeanUtils;
|
|
|
|
import cc.yunxi.common.utils.BeanUtils;
|
|
|
|
import cc.yunxi.common.utils.CollUtils;
|
|
|
|
import cc.yunxi.common.utils.CollUtils;
|
|
|
|
import cc.yunxi.common.utils.CommonUtil;
|
|
|
|
import cc.yunxi.common.utils.CommonUtil;
|
|
|
|
|
|
|
|
import cc.yunxi.domain.vo.socket.NoticeVo;
|
|
|
|
import cc.yunxi.domain.dto.LocationDTO;
|
|
|
|
import cc.yunxi.domain.dto.LocationDTO;
|
|
|
|
import cc.yunxi.domain.dto.UserDTO;
|
|
|
|
import cc.yunxi.domain.dto.UserDTO;
|
|
|
|
import cc.yunxi.domain.po.*;
|
|
|
|
import cc.yunxi.domain.po.*;
|
|
|
@ -31,9 +32,9 @@ import cc.yunxi.enums.OrderTypeEnum;
|
|
|
|
import cc.yunxi.enums.UserTypeEnum;
|
|
|
|
import cc.yunxi.enums.UserTypeEnum;
|
|
|
|
import cc.yunxi.service.*;
|
|
|
|
import cc.yunxi.service.*;
|
|
|
|
import cc.yunxi.utils.UserContext;
|
|
|
|
import cc.yunxi.utils.UserContext;
|
|
|
|
|
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
import cn.hutool.log.Log;
|
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
import io.swagger.annotations.Api;
|
|
|
|
import io.swagger.annotations.Api;
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
@ -112,9 +113,10 @@ public class RecycleOrderController {
|
|
|
|
orderCreateVO.setClientId(userDTO.getId());
|
|
|
|
orderCreateVO.setClientId(userDTO.getId());
|
|
|
|
String orderId = recycleOrderService.createOrder(orderCreateVO);
|
|
|
|
String orderId = recycleOrderService.createOrder(orderCreateVO);
|
|
|
|
|
|
|
|
|
|
|
|
Enterprise enterprise = enterpriseService.getById(orderCreateVO.getRecycleStationId());
|
|
|
|
RecycleStation station = recycleStationService.getStationById(orderCreateVO.getRecycleStationId());
|
|
|
|
|
|
|
|
Enterprise enterprise = enterpriseService.getById(station.getEnterpriseId());
|
|
|
|
String mode = enterprise.getOrderTakingMode();
|
|
|
|
String mode = enterprise.getOrderTakingMode();
|
|
|
|
if ("1".equals(mode)) {//派单模式 不发送通知
|
|
|
|
if ("2".equals(mode)) {//派单模式 不发送通知
|
|
|
|
return CommonResult.success(orderId);
|
|
|
|
return CommonResult.success(orderId);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -225,7 +227,7 @@ public class RecycleOrderController {
|
|
|
|
|
|
|
|
|
|
|
|
cancel.setOrderNo(order.getOrderNumber());
|
|
|
|
cancel.setOrderNo(order.getOrderNumber());
|
|
|
|
cancel.setOrderStatus(order.getOrderStatus());
|
|
|
|
cancel.setOrderStatus(order.getOrderStatus());
|
|
|
|
cancel.setCancelOrderTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
|
|
|
cancel.setCancelOrderTime(DateUtil.now());
|
|
|
|
cancel.setClientPhone(order.getClientMobile());
|
|
|
|
cancel.setClientPhone(order.getClientMobile());
|
|
|
|
if (OrderTypeEnum.SH_ORDER.equals(order.getOrderType())) {
|
|
|
|
if (OrderTypeEnum.SH_ORDER.equals(order.getOrderType())) {
|
|
|
|
ClientAddress addressInfo = clientAddressService.getAddressInfo(order.getClientAddressId());
|
|
|
|
ClientAddress addressInfo = clientAddressService.getAddressInfo(order.getClientAddressId());
|
|
|
@ -272,7 +274,7 @@ public class RecycleOrderController {
|
|
|
|
taken.setOrderStatus(order.getOrderStatus());
|
|
|
|
taken.setOrderStatus(order.getOrderStatus());
|
|
|
|
taken.setTakeOrderUser(recycler.getStaffsName());
|
|
|
|
taken.setTakeOrderUser(recycler.getStaffsName());
|
|
|
|
taken.setTakeUserPhone(recycler.getMobilePhone());
|
|
|
|
taken.setTakeUserPhone(recycler.getMobilePhone());
|
|
|
|
taken.setTakeOrderTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
|
|
|
taken.setTakeOrderTime(DateUtil.now());
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
wsService.sendMsgToUser(taken);
|
|
|
|
wsService.sendMsgToUser(taken);
|
|
|
|
} catch (IOException e) {
|
|
|
|
} catch (IOException e) {
|
|
|
@ -520,4 +522,28 @@ public class RecycleOrderController {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//派单通知
|
|
|
|
|
|
|
|
@PostMapping("/notice")
|
|
|
|
|
|
|
|
public CommonResult notice(@RequestBody List<String> ids) {
|
|
|
|
|
|
|
|
List<RecycleOrder> orders = recycleOrderService.listByIds(ids);
|
|
|
|
|
|
|
|
for (RecycleOrder order : orders) {
|
|
|
|
|
|
|
|
Recycler recycler = recyclerService.getRecyclerById(order.getAssignStaffsId());
|
|
|
|
|
|
|
|
OrderTaken taken = new OrderTaken();
|
|
|
|
|
|
|
|
taken.setAppType(AppTypeEnum.client);
|
|
|
|
|
|
|
|
taken.setReceiveUserId(order.getClientId());
|
|
|
|
|
|
|
|
taken.setMessageType(MessageTypeEnum.TAKEN);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
taken.setOrderStatus(order.getOrderStatus());
|
|
|
|
|
|
|
|
taken.setOrderNo(order.getOrderNumber());
|
|
|
|
|
|
|
|
taken.setTakeOrderUser(recycler.getStaffsName());
|
|
|
|
|
|
|
|
taken.setTakeUserPhone(recycler.getMobilePhone());
|
|
|
|
|
|
|
|
taken.setTakeOrderTime(DateUtil.now());
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
wsService.sendMsgToUser(taken);
|
|
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return CommonResult.success("通知成功!");
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|