Commit 3be01361 by 周晓航

修改 生态调用 传参

parent 74233d28
package cn.freemud.entities.vo;
import com.freemud.application.sdk.api.ordercenter.response.OrderCountResp;
import lombok.Builder;
import lombok.Data;
import java.util.List;
/**
* @author : xh.Z
* @email : fisherman0510@163.com
* @Date : 2021/4/28 下午5:59
* @description :
*/
@Data
@Builder
public class SendOrderCountsMsg {
private List<OrderCountResp> orders;
}
...@@ -2,6 +2,7 @@ package cn.freemud.service.thirdparty; ...@@ -2,6 +2,7 @@ package cn.freemud.service.thirdparty;
import cn.freemud.entities.dto.delivery.GetFilterPartnerResponse; import cn.freemud.entities.dto.delivery.GetFilterPartnerResponse;
import cn.freemud.base.entity.BaseResponse; import cn.freemud.base.entity.BaseResponse;
import cn.freemud.entities.vo.SendOrderCountsMsg;
import com.freemud.application.sdk.api.ordercenter.response.OrderCountResp; import com.freemud.application.sdk.api.ordercenter.response.OrderCountResp;
import com.freemud.application.sdk.api.ordercenter.response.OrderGetPartnerRequest; import com.freemud.application.sdk.api.ordercenter.response.OrderGetPartnerRequest;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
...@@ -29,7 +30,7 @@ public interface MicroOpenplatformClient { ...@@ -29,7 +30,7 @@ public interface MicroOpenplatformClient {
* @return * @return
*/ */
@PostMapping("/thirdApp/order/addOrderSum") @PostMapping("/thirdApp/order/addOrderSum")
BaseResponse addOrderSum(@RequestBody List<OrderCountResp> orderCounts); BaseResponse addOrderSum(@RequestBody SendOrderCountsMsg orderCounts);
/** /**
......
...@@ -4,6 +4,7 @@ import cn.freemud.base.entity.BaseResponse; ...@@ -4,6 +4,7 @@ import cn.freemud.base.entity.BaseResponse;
import cn.freemud.entities.dto.delivery.GetFilterPartnerResponse; import cn.freemud.entities.dto.delivery.GetFilterPartnerResponse;
import cn.freemud.entities.dto.delivery.PartnerFilterResponse; import cn.freemud.entities.dto.delivery.PartnerFilterResponse;
import cn.freemud.entities.vo.OrderCountRequestVo; import cn.freemud.entities.vo.OrderCountRequestVo;
import cn.freemud.entities.vo.SendOrderCountsMsg;
import cn.freemud.service.Orderservice; import cn.freemud.service.Orderservice;
import cn.freemud.service.thirdparty.MicroOpenplatformClient; import cn.freemud.service.thirdparty.MicroOpenplatformClient;
import cn.freemud.utils.LogUtil; import cn.freemud.utils.LogUtil;
...@@ -76,7 +77,8 @@ public class OrderCountJobHandler extends IJobHandler { ...@@ -76,7 +77,8 @@ public class OrderCountJobHandler extends IJobHandler {
} }
// 每次推送 只能 50条 让生态端处理 // 每次推送 只能 50条 让生态端处理
List<OrderCountResp> orderCounts = result.getResult(); List<OrderCountResp> orderCounts = result.getResult();
BaseResponse baseResponse = microOpenplatformClient.addOrderSum(orderCounts); SendOrderCountsMsg build = SendOrderCountsMsg.builder().orders(orderCounts).build();
BaseResponse baseResponse = microOpenplatformClient.addOrderSum(build);
LogUtil.info("orderCountJobHandler send report order end ", null, baseResponse); LogUtil.info("orderCountJobHandler send report order end ", null, baseResponse);
log.info("end xxl-job by send report msg -------- trackingNo:{}", trackingNo); log.info("end xxl-job by send report msg -------- trackingNo:{}", trackingNo);
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment