|
@@ -1,6 +1,7 @@
|
|
|
package com.uas.platform.b2b.erp.service.impl;
|
|
package com.uas.platform.b2b.erp.service.impl;
|
|
|
|
|
|
|
|
import com.uas.account.util.AccountUtils;
|
|
import com.uas.account.util.AccountUtils;
|
|
|
|
|
+import com.uas.platform.b2b.core.util.ContextUtils;
|
|
|
import com.uas.platform.b2b.dao.*;
|
|
import com.uas.platform.b2b.dao.*;
|
|
|
import com.uas.platform.b2b.erp.model.Inquiry;
|
|
import com.uas.platform.b2b.erp.model.Inquiry;
|
|
|
import com.uas.platform.b2b.erp.model.InquiryDecide;
|
|
import com.uas.platform.b2b.erp.model.InquiryDecide;
|
|
@@ -8,6 +9,7 @@ import com.uas.platform.b2b.erp.model.InquiryDetail;
|
|
|
import com.uas.platform.b2b.erp.model.InquiryDetailDet;
|
|
import com.uas.platform.b2b.erp.model.InquiryDetailDet;
|
|
|
import com.uas.platform.b2b.erp.service.InquiryService;
|
|
import com.uas.platform.b2b.erp.service.InquiryService;
|
|
|
import com.uas.platform.b2b.erp.support.ErpBufferedLogger;
|
|
import com.uas.platform.b2b.erp.support.ErpBufferedLogger;
|
|
|
|
|
+import com.uas.platform.b2b.event.PurchaseInquiryItemSaveReleaseEvent;
|
|
|
import com.uas.platform.b2b.model.*;
|
|
import com.uas.platform.b2b.model.*;
|
|
|
import com.uas.platform.b2b.support.SystemSession;
|
|
import com.uas.platform.b2b.support.SystemSession;
|
|
|
import com.uas.platform.b2b.temporary.model.PartnershipRecord;
|
|
import com.uas.platform.b2b.temporary.model.PartnershipRecord;
|
|
@@ -19,9 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
-import java.util.ArrayList;
|
|
|
|
|
-import java.util.Date;
|
|
|
|
|
-import java.util.List;
|
|
|
|
|
|
|
+import java.util.*;
|
|
|
|
|
|
|
|
@Service
|
|
@Service
|
|
|
public class InquiryServiceImpl implements InquiryService {
|
|
public class InquiryServiceImpl implements InquiryService {
|
|
@@ -229,6 +229,8 @@ public class InquiryServiceImpl implements InquiryService {
|
|
|
@Override
|
|
@Override
|
|
|
public void save(List<InquiryDetail> details) {
|
|
public void save(List<InquiryDetail> details) {
|
|
|
if(!CollectionUtils.isEmpty(details)) {
|
|
if(!CollectionUtils.isEmpty(details)) {
|
|
|
|
|
+ Set<String> codes = new HashSet<>();
|
|
|
|
|
+ List<PurchaseInquiryItem> items = new ArrayList<>();
|
|
|
for(InquiryDetail detail : details) {
|
|
for(InquiryDetail detail : details) {
|
|
|
//先查询已经上传的询价单主表信息
|
|
//先查询已经上传的询价单主表信息
|
|
|
Inquiry inquiry = getInquiry(detail.getIn_code(), detail.getId_id());
|
|
Inquiry inquiry = getInquiry(detail.getIn_code(), detail.getId_id());
|
|
@@ -252,8 +254,17 @@ public class InquiryServiceImpl implements InquiryService {
|
|
|
logger.log("自动询价明细上传", "新增了自动询价的明细(" + id + ")", 1);
|
|
logger.log("自动询价明细上传", "新增了自动询价的明细(" + id + ")", 1);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ // 产生消息
|
|
|
|
|
+ PurchaseInquiryItem inquiryItem = detail.convert();
|
|
|
|
|
+ if (!codes.contains(detail.getIn_code())) {
|
|
|
|
|
+ codes.add(detail.getIn_code());
|
|
|
|
|
+ items.add(inquiryItem);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ if (!CollectionUtils.isEmpty(items)) {
|
|
|
|
|
+ ContextUtils.publishEvent(new PurchaseInquiryItemSaveReleaseEvent(items));
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|