提交 4df90b39 authored 作者: aiqingguo's avatar aiqingguo

Merge branch 'v1.0_init_contract_20240306' into test

package com.clx.performance.feign; package com.clx.performance.feign;
import com.clx.open.sdk.request.action.GetOrderBreakContractOwnerRuleFileAction;
import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO; import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO;
import com.clx.performance.param.pc.OrderCancelParam; import com.clx.performance.param.pc.OrderCancelParam;
import com.clx.performance.vo.pc.OwnerAccountAllVO; import com.clx.performance.vo.pc.OwnerAccountAllVO;
import com.clx.performance.vo.pc.breakcontract.carrier.BreakContractOwnerRuleFileVO;
import com.msl.common.result.Result; import com.msl.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
...@@ -25,4 +27,10 @@ public interface PerformanceSDKFeign { ...@@ -25,4 +27,10 @@ public interface PerformanceSDKFeign {
@GetMapping(value = {"clx-performance/feign/sdk/accountAllInfo"}) @GetMapping(value = {"clx-performance/feign/sdk/accountAllInfo"})
Result<OwnerAccountAllVO> accountAllInfo(@RequestParam Long userNo); Result<OwnerAccountAllVO> accountAllInfo(@RequestParam Long userNo);
/**
* 查询规则文档信息
*/
@PostMapping("clx-performance/feign/sdk/getOwnerRuleFile")
Result<BreakContractOwnerRuleFileVO> getOwnerRuleFile(@RequestBody GetOrderBreakContractOwnerRuleFileAction action);
} }
package com.clx.performance.config;
import lombok.Getter;
import lombok.Setter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
@Configuration
@Getter
@Setter
public class MslAppConfig {
@Value("${msl.supervise.trade.appid}")
private String appId;
@Value("${msl.supervise.trade.url}")
private String url;
@Value("${msl.supervise.trade.secret}")
private String secret;
}
package com.clx.performance.controller.feign; package com.clx.performance.controller.feign;
import com.clx.open.sdk.request.action.GetOrderBreakContractOwnerRuleFileAction;
import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO; import com.clx.open.sdk.request.dto.OwnerCancelResidueWeightDTO;
import com.clx.performance.param.pc.OrderCancelParam; import com.clx.performance.param.pc.OrderCancelParam;
import com.clx.performance.service.OrderCancelService; import com.clx.performance.service.OrderCancelService;
import com.clx.performance.service.OrderGoodsService; import com.clx.performance.service.OrderGoodsService;
import com.clx.performance.service.OwnerAccountService; import com.clx.performance.service.OwnerAccountService;
import com.clx.performance.service.breakcontract.BreakContractOwnerRuleService;
import com.clx.performance.vo.pc.OwnerAccountAllVO; import com.clx.performance.vo.pc.OwnerAccountAllVO;
import com.clx.performance.vo.pc.breakcontract.carrier.BreakContractOwnerRuleFileVO;
import com.msl.common.result.Result; import com.msl.common.result.Result;
import com.msl.user.utils.TokenUtil; import com.msl.user.utils.TokenUtil;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -32,6 +35,8 @@ public class PerformanceSdkFeignController { ...@@ -32,6 +35,8 @@ public class PerformanceSdkFeignController {
private final OwnerAccountService ownerAccountService; private final OwnerAccountService ownerAccountService;
private final BreakContractOwnerRuleService breakContractOwnerRuleService;
@ApiOperation(value = "货主端取消订单", notes = "<br>By:胡宇帆") @ApiOperation(value = "货主端取消订单", notes = "<br>By:胡宇帆")
@PostMapping("/ownCancelOrderPre") @PostMapping("/ownCancelOrderPre")
...@@ -55,4 +60,12 @@ public class PerformanceSdkFeignController { ...@@ -55,4 +60,12 @@ public class PerformanceSdkFeignController {
public Result<OwnerAccountAllVO> accountAllInfo(@RequestParam Long userNo) { public Result<OwnerAccountAllVO> accountAllInfo(@RequestParam Long userNo) {
return Result.ok(ownerAccountService.accountAllInfo(userNo)); return Result.ok(ownerAccountService.accountAllInfo(userNo));
} }
@ApiOperation(value = "查询规则文档信息", notes = "<br>By:艾庆国")
@PostMapping("/getOwnerRuleFile")
Result<BreakContractOwnerRuleFileVO> getOwnerRuleFile(@RequestBody GetOrderBreakContractOwnerRuleFileAction action){
return Result.ok(breakContractOwnerRuleService.getRuleFile(action.getId()));
}
} }
...@@ -9,7 +9,6 @@ import com.clx.order.enums.OrderEnum; ...@@ -9,7 +9,6 @@ import com.clx.order.enums.OrderEnum;
import com.clx.order.enums.SyncPlatformEnum; import com.clx.order.enums.SyncPlatformEnum;
import com.clx.order.feign.OrderFeign; import com.clx.order.feign.OrderFeign;
import com.clx.order.vo.feign.FeignOrderVO; import com.clx.order.vo.feign.FeignOrderVO;
import com.clx.performance.config.MslAppConfig;
import com.clx.performance.config.ThirdAppConfig; import com.clx.performance.config.ThirdAppConfig;
import com.clx.performance.constant.RabbitKeyConstants; import com.clx.performance.constant.RabbitKeyConstants;
import com.clx.performance.dto.dts.DataTransportDTO; import com.clx.performance.dto.dts.DataTransportDTO;
...@@ -38,7 +37,6 @@ import java.util.Optional; ...@@ -38,7 +37,6 @@ import java.util.Optional;
@Component @Component
@AllArgsConstructor @AllArgsConstructor
public class OrderChildDtsListener { public class OrderChildDtsListener {
private final MslAppConfig mslAppConfig;
private final OrderFeign orderFeign; private final OrderFeign orderFeign;
private final LastTruckService lastTruckService; private final LastTruckService lastTruckService;
private final DriverService driverService; private final DriverService driverService;
...@@ -113,10 +111,10 @@ public class OrderChildDtsListener { ...@@ -113,10 +111,10 @@ public class OrderChildDtsListener {
after.setStatus(com.clx.open.sdk.enums.OrderChildEnum.Status.COMMON_CANCEL.getCode()); after.setStatus(com.clx.open.sdk.enums.OrderChildEnum.Status.COMMON_CANCEL.getCode());
} }
after.setLastFlag(ResultStatusEnum.NO.getCode()); after.setLastFlag(ResultStatusEnum.NO.getCode());
OpenCallBackClient client = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret()); String data = JSON.toJSONString(after);
Result<?> result = client.encryptPost(JSON.toJSONString(after),after.topic()); OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(orderInfoFeign.getOrderSource().toString());
Result<?> result = openCallBackClient.encryptPost(data,after.topic());
log.info("运单信息同步,运单编号:{},响应结果:{}",after.getChildNo(),JSON.toJSONString(result)); log.info("运单信息同步,运单编号:{},响应结果:{}",after.getChildNo(),JSON.toJSONString(result));
syncLastTruck(orderInfoFeign,after); syncLastTruck(orderInfoFeign,after);
} }
......
...@@ -6,7 +6,7 @@ import com.clx.open.sdk.callback.message.OrderChildMessage; ...@@ -6,7 +6,7 @@ import com.clx.open.sdk.callback.message.OrderChildMessage;
import com.clx.open.sdk.enums.ResultStatusEnum; import com.clx.open.sdk.enums.ResultStatusEnum;
import com.clx.order.feign.OrderFeign; import com.clx.order.feign.OrderFeign;
import com.clx.order.vo.feign.FeignOrderVO; import com.clx.order.vo.feign.FeignOrderVO;
import com.clx.performance.config.MslAppConfig; import com.clx.performance.config.ThirdAppConfig;
import com.clx.performance.dao.OrderChildDao; import com.clx.performance.dao.OrderChildDao;
import com.clx.performance.model.OrderChild; import com.clx.performance.model.OrderChild;
import com.clx.performance.service.LastTruckService; import com.clx.performance.service.LastTruckService;
...@@ -34,7 +34,7 @@ public class LastTruckServiceImpl implements LastTruckService { ...@@ -34,7 +34,7 @@ public class LastTruckServiceImpl implements LastTruckService {
private final OrderFeign orderFeign; private final OrderFeign orderFeign;
private final OrderChildDao orderChildDao; private final OrderChildDao orderChildDao;
private final OrderChildStruct orderChildStruct; private final OrderChildStruct orderChildStruct;
private final MslAppConfig mslAppConfig; private final ThirdAppConfig thirdAppConfig;
/** /**
* @Author kavin * @Author kavin
* @Description 判断最后一车的逻辑 * @Description 判断最后一车的逻辑
...@@ -68,13 +68,15 @@ public class LastTruckServiceImpl implements LastTruckService { ...@@ -68,13 +68,15 @@ public class LastTruckServiceImpl implements LastTruckService {
**/ **/
@Override @Override
public Result<?> syncLastTruckChild(OrderChild child) { public Result<?> syncLastTruckChild(OrderChild child) {
FeignOrderVO orderInfo = orderFeign.getOrderInfoFeign(child.getOrderNo());
OrderChildMessage message = orderChildStruct.convertMessage(child); OrderChildMessage message = orderChildStruct.convertMessage(child);
message.setLastFlag(ResultStatusEnum.YES.getCode()); message.setLastFlag(ResultStatusEnum.YES.getCode());
log.info("开始同步最后一车的运单,运单编号:{},运单信息:{}",child.getChildNo(), JSON.toJSONString(message)); String data = JSON.toJSONString(message);
OpenCallBackClient client2 = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret()); log.info("开始同步最后一车的运单,运单编号:{},运单信息:{}",child.getChildNo(), data);
Result<?> result2 = client2.encryptPost(JSON.toJSONString(message),message.topic()); OpenCallBackClient openCallBackClient = thirdAppConfig.getOpenCallBackClient(orderInfo.getOrderSource().toString());
log.info("结束同步最后一车的运单,运单编号:{},响应结果:{}",child.getChildNo(),JSON.toJSONString(result2)); Result<?> result = openCallBackClient.encryptPost(data,message.topic());
return result2; log.info("结束同步最后一车的运单,运单编号:{},响应结果:{}",child.getChildNo(),JSON.toJSONString(result));
return result;
} }
@Override @Override
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论