|
|
@@ -58,30 +58,25 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
PurchaseInquiry inquiry = item.getInquiry();
|
|
|
if (item.getVendUserUU() != null) {
|
|
|
// Android
|
|
|
- XingePusher.pushSingleAccountAndroid(item.getVendUserUU()
|
|
|
- .toString(), "新增一条客户询价-", "单号:" + inquiry.getCode()
|
|
|
- + ",客户:" + inquiry.getEnterprise().getEnName(),
|
|
|
- "com.sas.mobile.activity.PurchaseChangeActivity");
|
|
|
+ XingePusher.pushSingleAccountAndroid(item.getVendUserUU().toString(), "新增一条客户询价-", "单号:" + inquiry.getCode() + ",客户:"
|
|
|
+ + inquiry.getEnterprise().getEnName(), "com.sas.mobile.activity.PurchaseChangeActivity");
|
|
|
// IOS
|
|
|
- XingePusher.pushSingleAccountIOS(item.getVendUserUU()
|
|
|
- .toString(), "新增一条客户询价-" + "单号:" + inquiry.getCode()
|
|
|
- + ",客户:" + inquiry.getEnterprise().getEnName());
|
|
|
+ XingePusher.pushSingleAccountIOS(item.getVendUserUU().toString(), "新增一条客户询价-" + "单号:" + inquiry.getCode() + ",客户:"
|
|
|
+ + inquiry.getEnterprise().getEnName());
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<PurchaseInquiryItem> findNotUploadReply() {
|
|
|
- return purchaseInquiryItemDao.findByEnUUAndBackStatus(SystemSession
|
|
|
- .getUser().getEnterprise().getUu(),
|
|
|
+ return purchaseInquiryItemDao.findByEnUUAndBackStatus(SystemSession.getUser().getEnterprise().getUu(),
|
|
|
(short) Status.NOT_UPLOAD.value());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void onReplyUploadSuccess(String[] idArray) {
|
|
|
for (String id : idArray) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long
|
|
|
- .parseLong(id));
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long.parseLong(id));
|
|
|
if (item != null) {
|
|
|
item.setBackStatus((short) Status.DOWNLOADED.value());
|
|
|
purchaseInquiryItemDao.save(item);
|
|
|
@@ -95,19 +90,13 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
// 将客户处理报价结果推送通知供应商联系人UU号
|
|
|
for (PurchaseInquiryItem item : inquiryItems) {
|
|
|
PurchaseInquiry inquiry = item.getInquiry();
|
|
|
- String tittle = (item.getAgreed() == Constant.YES) ? "客户同意了您的报价"
|
|
|
- : "客户不同意您的报价";
|
|
|
+ String tittle = (item.getAgreed() == Constant.YES) ? "客户同意了您的报价" : "客户不同意您的报价";
|
|
|
if (item.getVendUserUU() != null) {
|
|
|
// Android
|
|
|
- XingePusher.pushSingleAccountAndroid(item.getVendUserUU()
|
|
|
- .toString(), tittle, "物料:"
|
|
|
- + item.getProduct().getTitle() + ",客户:"
|
|
|
- + inquiry.getEnterprise().getEnName(),
|
|
|
- "com.sas.mobile.activity.PurchaseChangeActivity");
|
|
|
+ XingePusher.pushSingleAccountAndroid(item.getVendUserUU().toString(), tittle, "物料:" + item.getProduct().getTitle() + ",客户:"
|
|
|
+ + inquiry.getEnterprise().getEnName(), "com.sas.mobile.activity.PurchaseChangeActivity");
|
|
|
// IOS
|
|
|
- XingePusher.pushSingleAccountIOS(item.getVendUserUU()
|
|
|
- .toString(), tittle + "物料:"
|
|
|
- + item.getProduct().getTitle() + ",客户:"
|
|
|
+ XingePusher.pushSingleAccountIOS(item.getVendUserUU().toString(), tittle + "物料:" + item.getProduct().getTitle() + ",客户:"
|
|
|
+ inquiry.getEnterprise().getEnName());
|
|
|
}
|
|
|
}
|
|
|
@@ -115,16 +104,14 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public List<PurchaseInquiryItem> findNotUploadInquiry() {
|
|
|
- return purchaseInquiryItemDao.findByVendUUAndSendStatus(SystemSession
|
|
|
- .getUser().getEnterprise().getUu(),
|
|
|
+ return purchaseInquiryItemDao.findByVendUUAndSendStatus(SystemSession.getUser().getEnterprise().getUu(),
|
|
|
(short) Status.NOT_UPLOAD.value());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void onQuotationDownSuccess(String[] idArray) {
|
|
|
for (String id : idArray) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long
|
|
|
- .parseLong(id));
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long.parseLong(id));
|
|
|
if (item != null) {
|
|
|
item.setSendStatus((short) Status.DOWNLOADED.value());
|
|
|
purchaseInquiryItemDao.save(item);
|
|
|
@@ -135,8 +122,7 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
@Override
|
|
|
public void reply(List<QuotationDown> downs) {
|
|
|
for (QuotationDown down : downs) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(down
|
|
|
- .getB2b_id_id());
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(down.getB2b_id_id());
|
|
|
if (item != null) {
|
|
|
item.setMinOrderQty(down.getQu_minbuyqty());
|
|
|
item.setMinPackQty(down.getQu_minqty());
|
|
|
@@ -162,13 +148,11 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
// 消息推送
|
|
|
if (userUU != null && userUU != 0) {
|
|
|
// Android
|
|
|
- XingePusher.pushSingleAccountAndroid(userUU.toString(),
|
|
|
- "询价单回复", "单号:" + item.getInquiry().getCode()
|
|
|
- + ",第" + item.getNumber() + "行", "");
|
|
|
+ XingePusher.pushSingleAccountAndroid(userUU.toString(), "询价单回复",
|
|
|
+ "单号:" + item.getInquiry().getCode() + ",第" + item.getNumber() + "行", "");
|
|
|
// IOS
|
|
|
XingePusher.pushSingleAccountIOS(userUU.toString(),
|
|
|
- "询价单回复" + "单号:" + item.getInquiry().getCode()
|
|
|
- + ",第" + item.getNumber() + "行");
|
|
|
+ "询价单回复" + "单号:" + item.getInquiry().getCode() + ",第" + item.getNumber() + "行");
|
|
|
}
|
|
|
}
|
|
|
purchaseInquiryItemDao.save(item);
|
|
|
@@ -178,16 +162,14 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public List<PurchaseInquiryItem> findNotUploadInquiryReply() {
|
|
|
- return purchaseInquiryItemDao.findByVendUUAndReplySendStatus(
|
|
|
- SystemSession.getUser().getEnterprise().getUu(),
|
|
|
+ return purchaseInquiryItemDao.findByVendUUAndReplySendStatus(SystemSession.getUser().getEnterprise().getUu(),
|
|
|
(short) Status.NOT_UPLOAD.value());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void onReplyDownSuccess(String[] idArray) {
|
|
|
for (String id : idArray) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long
|
|
|
- .parseLong(id));
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long.parseLong(id));
|
|
|
if (item != null) {
|
|
|
item.setReplySendStatus((short) Status.DOWNLOADED.value());
|
|
|
purchaseInquiryItemDao.save(item);
|
|
|
@@ -197,16 +179,14 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public List<PurchaseInquiryItem> findNotUploadInquiryReplyDecide() {
|
|
|
- return purchaseInquiryItemDao.findByVendUUAndDecideStatus(SystemSession
|
|
|
- .getUser().getEnterprise().getUu(),
|
|
|
+ return purchaseInquiryItemDao.findByVendUUAndDecideStatus(SystemSession.getUser().getEnterprise().getUu(),
|
|
|
(short) Status.NOT_UPLOAD.value());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void onReplyDecideDownSuccess(String[] idArray) {
|
|
|
for (String id : idArray) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long
|
|
|
- .parseLong(id));
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(Long.parseLong(id));
|
|
|
if (item != null) {
|
|
|
item.setDecideStatus((short) Status.DOWNLOADED.value());
|
|
|
purchaseInquiryItemDao.save(item);
|
|
|
@@ -216,22 +196,21 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public Page<PurchaseInquiryItem> findAllByPageInfo(final PageInfo pageInfo) {
|
|
|
- return purchaseInquiryItemDao.findAll(
|
|
|
- new Specification<PurchaseInquiryItem>() {
|
|
|
+ return purchaseInquiryItemDao.findAll(new Specification<PurchaseInquiryItem>() {
|
|
|
|
|
|
- public Predicate toPredicate(
|
|
|
- Root<PurchaseInquiryItem> root,
|
|
|
- CriteriaQuery<?> query, CriteriaBuilder builder) {
|
|
|
- query.where(pageInfo
|
|
|
- .getPredicates(root, query, builder));
|
|
|
- return null;
|
|
|
- }
|
|
|
- }, pageInfo);
|
|
|
+ public Predicate toPredicate(Root<PurchaseInquiryItem> root, CriteriaQuery<?> query, CriteriaBuilder builder) {
|
|
|
+ query.where(pageInfo.getPredicates(root, query, builder));
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+ }, pageInfo);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public PurchaseInquiry findById(Long id) {
|
|
|
- return purchaseInquiryDao.findOne(id);
|
|
|
+ List<PurchaseInquiry> inquiries = purchaseInquiryDao.findByVendUUAndId(SystemSession.getUser().getEnterprise().getUu(), id);
|
|
|
+ if (!CollectionUtils.isEmpty(inquiries))
|
|
|
+ return inquiries.get(0);
|
|
|
+ return null;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -246,11 +225,9 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public PurchaseInquiryItem reply(PurchaseInquiryItem inquiryItem) {
|
|
|
- PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(inquiryItem
|
|
|
- .getId());
|
|
|
+ PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(inquiryItem.getId());
|
|
|
if (item.getStatus() == Status.REPLIED.value()
|
|
|
- || (item.getReplySendStatus() != null && item
|
|
|
- .getReplySendStatus() == Status.DOWNLOADED.value()))
|
|
|
+ || (item.getReplySendStatus() != null && item.getReplySendStatus() == Status.DOWNLOADED.value()))
|
|
|
throw new IllegalStatusException("该询价单已经报价,不允许再次报价");
|
|
|
inquiryItem.setStatus((short) Status.REPLIED.value());
|
|
|
inquiryItem.setBackStatus((short) Status.NOT_UPLOAD.value());
|
|
|
@@ -263,13 +240,11 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
// 消息推送
|
|
|
if (userUU != null && userUU != 0) {
|
|
|
// Android
|
|
|
- XingePusher.pushSingleAccountAndroid(userUU.toString(),
|
|
|
- "询价单回复", "单号:" + item.getInquiry().getCode() + ",第"
|
|
|
- + item.getNumber() + "行", "");
|
|
|
+ XingePusher.pushSingleAccountAndroid(userUU.toString(), "询价单回复",
|
|
|
+ "单号:" + item.getInquiry().getCode() + ",第" + item.getNumber() + "行", "");
|
|
|
// IOS
|
|
|
- XingePusher.pushSingleAccountIOS(userUU.toString(),
|
|
|
- "询价单回复" + "单号:" + item.getInquiry().getCode() + ",第"
|
|
|
- + item.getNumber() + "行");
|
|
|
+ XingePusher.pushSingleAccountIOS(userUU.toString(), "询价单回复" + "单号:" + item.getInquiry().getCode() + ",第" + item.getNumber()
|
|
|
+ + "行");
|
|
|
}
|
|
|
}
|
|
|
return purchaseInquiryItemDao.save(inquiryItem);
|
|
|
@@ -277,8 +252,7 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
|
|
|
@Override
|
|
|
public int getOnhandCount() {
|
|
|
- return purchaseInquiryItemDao.getCountByVendUUAndStatus(SystemSession
|
|
|
- .getUser().getEnterprise().getUu(),
|
|
|
+ return purchaseInquiryItemDao.getCountByVendUUAndStatus(SystemSession.getUser().getEnterprise().getUu(),
|
|
|
(short) Status.NOT_REPLY.value());
|
|
|
}
|
|
|
|
|
|
@@ -287,8 +261,7 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
PurchaseInquiryItem item = purchaseInquiryItemDao.findOne(itemId);
|
|
|
if (item != null) {
|
|
|
final PageInfo pageInfo = new PageInfo(1, 3, 1);
|
|
|
- pageInfo.filter("vendUU", SystemSession.getUser().getEnterprise()
|
|
|
- .getUu());
|
|
|
+ pageInfo.filter("vendUU", SystemSession.getUser().getEnterprise().getUu());
|
|
|
pageInfo.filter("productId", item.getProductId());
|
|
|
pageInfo.filter("status", (short) Status.REPLIED.value());
|
|
|
pageInfo.sorting("inquiry.date", Direction.DESC);
|
|
|
@@ -304,9 +277,7 @@ public class PurchaseInquiryServiceImpl implements PurchaseInquiryService {
|
|
|
if (!CollectionUtils.isEmpty(attachs)) {
|
|
|
long enUU = SystemSession.getUser().getEnterprise().getUu();
|
|
|
for (Attach attach : attachs) {
|
|
|
- List<PurchaseInquiry> inquiries = purchaseInquiryDao
|
|
|
- .findByEnUUAndSourceId(enUU,
|
|
|
- Long.parseLong(attach.getSourceId()));
|
|
|
+ List<PurchaseInquiry> inquiries = purchaseInquiryDao.findByEnUUAndSourceId(enUU, Long.parseLong(attach.getSourceId()));
|
|
|
if (!CollectionUtils.isEmpty(inquiries)) {
|
|
|
PurchaseInquiry inquiry = inquiries.get(0);
|
|
|
attach.setRelativeTable("purc$inquiry");
|