|
@ -3,7 +3,6 @@ package com.digiwin.athena.app.service.order; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.alibaba.fastjson.TypeReference; |
|
|
import com.alibaba.fastjson.TypeReference; |
|
|
import com.digiwin.app.service.DWEAIResult; |
|
|
import com.digiwin.app.service.DWEAIResult; |
|
|
import com.digiwin.athena.app.infra.dto.order.SalesOrderDetailDTO; |
|
|
|
|
|
import com.digiwin.athena.app.infra.entity.SalesOrderDetailEntity; |
|
|
import com.digiwin.athena.app.infra.entity.SalesOrderDetailEntity; |
|
|
import com.digiwin.athena.app.infra.service.SalesOrderDetailService; |
|
|
import com.digiwin.athena.app.infra.service.SalesOrderDetailService; |
|
|
import com.digiwin.athena.opt.common.eai.EAIRequest; |
|
|
import com.digiwin.athena.opt.common.eai.EAIRequest; |
|
@ -41,7 +40,7 @@ public class SalesOrderDetailCreateEAIService extends AbsEAIService { |
|
|
public DWEAIResult execute(Map<String, String> headers, String messageBody) throws Exception { |
|
|
public DWEAIResult execute(Map<String, String> headers, String messageBody) throws Exception { |
|
|
// 入参反序列化 |
|
|
// 入参反序列化 |
|
|
EAIRequest request = new EAIRequest(messageBody); |
|
|
EAIRequest request = new EAIRequest(messageBody); |
|
|
List<SalesOrderDetailDTO> salesOrderDetailDTOList = request.getObject("sales_order_detail", new TypeReference<List<SalesOrderDetailDTO>>(){}); |
|
|
|
|
|
|
|
|
List<SalesOrderDetailEntity> salesOrderDetailDTOList = request.getObject("sales_order_detail", new TypeReference<List<SalesOrderDetailEntity>>(){}); |
|
|
|
|
|
|
|
|
List<SalesOrderDetailEntity> salesOrderDetailEntityList = salesOrderDetailDTOList.stream().map(assemble->{ |
|
|
List<SalesOrderDetailEntity> salesOrderDetailEntityList = salesOrderDetailDTOList.stream().map(assemble->{ |
|
|
SalesOrderDetailEntity salesOrderDetailEntity = new SalesOrderDetailEntity(); |
|
|
SalesOrderDetailEntity salesOrderDetailEntity = new SalesOrderDetailEntity(); |
|
|