提交 15812889 authored 作者: huyufan's avatar huyufan

逆向

上级 31fbbf30
package com.clx.performance.feign; package com.clx.performance.feign;
import com.clx.performance.param.pc.OrderCancelParam; import com.clx.performance.param.pc.OrderCancelFeignParam;
import com.clx.performance.vo.feign.OrderGoodsFeignVO; import com.clx.performance.vo.feign.OrderGoodsFeignVO;
import com.msl.common.result.Result; import com.msl.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
...@@ -54,7 +54,7 @@ public interface PerformanceFeign { ...@@ -54,7 +54,7 @@ public interface PerformanceFeign {
@PostMapping(value = {"clx-performance/feign/order/orderCancel"}) @PostMapping(value = {"clx-performance/feign/order/orderCancel"})
Result<Object> orderCancel(@RequestBody OrderCancelParam param); Result<Object> orderCancel(@RequestBody OrderCancelFeignParam param);
/** /**
......
package com.clx.performance.param.pc;
import io.swagger.annotations.ApiModelProperty;
import lombok.Getter;
import lombok.Setter;
import javax.validation.constraints.NotNull;
@Getter
@Setter
public class OrderCancelFeignParam {
@NotNull(message = "订单编号不能为空")
@ApiModelProperty("订单编号")
private String orderNo;
}
package com.clx.performance.param.pc; package com.clx.performance.param.pc;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Getter; import lombok.Data;
import lombok.Setter;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
@Data
@Getter
@Setter
public class OrderCancelParam { public class OrderCancelParam {
@NotNull(message = "订单编号不能为空") @NotNull(message = "订单编号不能为空")
@ApiModelProperty("订单编号") @ApiModelProperty("订单编号")
private String orderNo; private String orderNo;
@ApiModelProperty("1:弹窗1 2:弹窗取消未拉运吨数 3:取消未拉运+已到达货源地之前的吨数")
private Integer cancelType;
@ApiModelProperty("1:平台 2:货主")
private Integer createByType;
} }
package com.clx.performance.controller.feign; package com.clx.performance.controller.feign;
import com.clx.performance.param.pc.OrderCancelParam; import com.clx.performance.param.pc.OrderCancelFeignParam;
import com.clx.performance.service.OrderCancelService; import com.clx.performance.service.OrderCancelService;
import com.msl.common.result.Result; import com.msl.common.result.Result;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -27,8 +27,8 @@ public class OrderCancelFeignController { ...@@ -27,8 +27,8 @@ public class OrderCancelFeignController {
@ApiOperation(value = "货主端订单取消", notes = "<br>By:胡宇帆") @ApiOperation(value = "货主端订单取消", notes = "<br>By:胡宇帆")
@PostMapping("/orderCancel") @PostMapping("/orderCancel")
public Result<Object> orderCancel(@RequestBody OrderCancelParam param) { public Result<Object> orderCancel(@RequestBody OrderCancelFeignParam param) {
orderCancelService.ownerCancelOrderPre(param.getOrderNo()); //orderCancelService.platformCancelOrderPrePC(param.getOrderNo());
return Result.ok(); return Result.ok();
} }
} }
package com.clx.performance.controller.pc; package com.clx.performance.controller.pc;
import com.clx.performance.param.pc.OrderCancelParam;
import com.clx.performance.service.OrderCancelService; import com.clx.performance.service.OrderCancelService;
import com.clx.performance.vo.pc.OrderGoodsVO;
import com.msl.common.convertor.aspect.UnitCovert;
import com.msl.common.result.Result; import com.msl.common.result.Result;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
...@@ -19,23 +18,23 @@ import org.springframework.web.bind.annotation.RestController; ...@@ -19,23 +18,23 @@ import org.springframework.web.bind.annotation.RestController;
@RestController @RestController
@RequestMapping(value="/pc/order/") @RequestMapping(value="/pc/order/")
@Validated @Validated
@Api(tags = "PC-订单取消取消") @Api(tags = "PC-订单取消")
@AllArgsConstructor @AllArgsConstructor
public class OrderCancelController { public class OrderCancelController {
private final OrderCancelService orderCancelService; private final OrderCancelService orderCancelService;
@ApiOperation(value = "承运端取消订单", notes = "<br>By:胡宇帆") @ApiOperation(value = "承运端取消订单", notes = "<br>By:胡宇帆")
@GetMapping("/platformCancelOrderPre") @PostMapping("/platformCancelOrderPre")
public Result<Object> platformCancelOrderPre(@RequestParam String orderNo) { public Result<Object> platformCancelOrderPre(@RequestParam OrderCancelParam param) {
orderCancelService.platformCancelOrderPre(orderNo); orderCancelService.platformCancelOrderPrePC(param);
return Result.ok(); return Result.ok();
} }
@ApiOperation(value = "货主端取消订单", notes = "<br>By:胡宇帆") @ApiOperation(value = "货主端取消订单", notes = "<br>By:胡宇帆")
@GetMapping("/ownCancelOrderPre") @PostMapping("/ownCancelOrderPre")
public Result<Object> ownCancelOrderPre(@RequestParam String orderNo) { public Result<Object> ownCancelOrderPre(@RequestParam OrderCancelParam param) {
orderCancelService.ownerCancelOrderPre(orderNo); orderCancelService.ownerCancelOrderPrePC(param);
return Result.ok(); return Result.ok();
} }
} }
package com.clx.performance.listener; package com.clx.performance.listener;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.clx.performance.constant.RabbitKeyConstants; import com.clx.performance.constant.RabbitKeyConstants;
import com.clx.performance.dao.OrderGoodsDao; import com.clx.performance.param.pc.OrderCancelParam;
import com.clx.performance.enums.OrderGoodsStatusEnum;
import com.clx.performance.model.OrderGoods;
import com.clx.performance.param.mq.OrderCancelMqParam;
import com.clx.performance.service.IntegralMqService;
import com.clx.performance.service.OrderCancelService; import com.clx.performance.service.OrderCancelService;
import com.msl.common.base.Optional;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -28,16 +23,12 @@ public class OrderCancelHandler { ...@@ -28,16 +23,12 @@ public class OrderCancelHandler {
@RabbitListener(queues = RabbitKeyConstants.ORDER_CANCEL_QUEUE) @RabbitListener(queues = RabbitKeyConstants.ORDER_CANCEL_QUEUE)
public void onMessage(String message) { public void onMessage(String message) {
log.info("处理订单取消监听器执行,订单No为{}", message); log.info("处理订单取消监听器执行,订单No为{}", message);
OrderCancelMqParam param = JSONUtil.toBean(message, OrderCancelMqParam.class); OrderCancelParam param = JSONUtil.toBean(message, OrderCancelParam.class);
if (StringUtils.equals(param.getType(), "1")) { if (ObjectUtil.equals(param.getCancelType(), 1)) {
orderCancelService.platformCancelOrder(param.getOrderNo()); orderCancelService.ownerCancelOrderPrePCMQ(param);
} else { } else {
orderCancelService.ownerCancelOrder(param.getOrderNo()); orderCancelService.ownerCancelOrderPrePCMQ(param);
} }
return;
// if (StringUtils.isBlank(message)) {
// return;
// }
// orderCancelService.ownerCancelOrder(message);
} }
} }
package com.clx.performance.service; package com.clx.performance.service;
import com.clx.performance.param.pc.OrderCancelParam;
public interface OrderCancelService { public interface OrderCancelService {
void platformCancelOrderPre(String orderNo); // void platformCancelOrderPre(String orderNo);
//
// void platformCancelOrder(String orderNo);
//
// void ownerCancelOrderPre(String orderNo);
//
// void ownerCancelOrder(String orderNo);
void platformCancelOrder(String orderNo); void ownerCancelOrderPrePC(OrderCancelParam param);
void ownerCancelOrderPre(String orderNo); void platformCancelOrderPrePC(OrderCancelParam param);
void ownerCancelOrder(String orderNo); void ownerCancelOrderPrePCMQ(OrderCancelParam param);
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论