|
|
@@ -984,25 +984,26 @@ public class PublicInquiryServiceImpl implements PublicInquiryService {
|
|
|
@Override
|
|
|
public void onReplyInvalid(List<Inquiry> inquiries, final Long enuu) {
|
|
|
final List<PublicInquiryItem> newInquiryItems = new ArrayList<>();
|
|
|
- ThreadUtils.tasks(new IRunnable<Inquiry>() {
|
|
|
-
|
|
|
- @Override
|
|
|
- public void run(Inquiry inquiry) {
|
|
|
- List<PublicInquiry> purchaseInquiries = publicInquiryDao.findByEnUUAndCode(enuu, inquiry.getIn_code());
|
|
|
- if (!CollectionUtils.isEmpty(purchaseInquiries)) {
|
|
|
- PublicInquiry publicInquiry = purchaseInquiries.get(0);
|
|
|
- for (PublicInquiryItem item : publicInquiry.getInquiryItems()) {
|
|
|
- item.setStatus((short) Status.DISABLED.value());
|
|
|
- // 获取作废信息时,更新作废上传状态为 待上传
|
|
|
- item.setInvalidStatus((short) Status.NOT_UPLOAD.value());
|
|
|
- synchronized (newInquiryItems) {
|
|
|
- newInquiryItems.add(item);
|
|
|
+ for (final Inquiry inquiry : inquiries) {
|
|
|
+ ThreadUtils.task(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ List<PublicInquiry> purchaseInquiries = publicInquiryDao.findByEnUUAndCode(enuu, inquiry.getIn_code());
|
|
|
+ if (!CollectionUtils.isEmpty(purchaseInquiries)) {
|
|
|
+ PublicInquiry publicInquiry = purchaseInquiries.get(0);
|
|
|
+ for (PublicInquiryItem item : publicInquiry.getInquiryItems()) {
|
|
|
+ item.setStatus((short) Status.DISABLED.value());
|
|
|
+ // 获取作废信息时,更新作废上传状态为 待上传
|
|
|
+ item.setInvalidStatus((short) Status.NOT_UPLOAD.value());
|
|
|
+ synchronized (newInquiryItems) {
|
|
|
+ newInquiryItems.add(item);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- }
|
|
|
+ });
|
|
|
+ }
|
|
|
|
|
|
- }, inquiries);
|
|
|
}
|
|
|
|
|
|
/**
|