|
|
@@ -5,14 +5,17 @@ import com.crm.rely.backend.model.config.VaultodyConfig;
|
|
|
import com.crm.rely.backend.model.dto.vaultody.vaults.TransactionItemDto;
|
|
|
import com.crm.rely.backend.model.pojo.table.TransactionItemTable;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
import java.util.LinkedList;
|
|
|
import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
@Service
|
|
|
@Slf4j
|
|
|
@@ -43,6 +46,14 @@ public class VaultsJob {
|
|
|
BeanUtils.copyProperties(transactionItemDto, table);
|
|
|
table.setVaultId(config.getVaultId());
|
|
|
table.setItemId(transactionItemDto.getId());
|
|
|
+ if(StringUtils.isNotBlank(table.getTransactionId())){
|
|
|
+ List<String> transactionIds = new ArrayList<>();
|
|
|
+ transactionIds.add(table.getTransactionId());
|
|
|
+ Map<String, String> orderSerialByTransactionIds = vaultodyService.getOrderSerialByTransactionIds(transactionIds);
|
|
|
+ if(!CollectionUtils.isEmpty(orderSerialByTransactionIds)){
|
|
|
+ table.setOrderId(orderSerialByTransactionIds.get(table.getTransactionId()));
|
|
|
+ }
|
|
|
+ }
|
|
|
tables.add(table);
|
|
|
}
|
|
|
}
|