|
@@ -97,6 +97,38 @@ public class PurchaseTask extends AbstractTask {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @TaskMapping(title = "从平台下载更新代采订单可发货状态", fixedDelay = 30000, method = Method.DOWNLOAD)
|
|
|
|
|
+ public void downloadhasIssued() {
|
|
|
|
|
+ List<PurchaseDetail> issued = getForList("/erp/purchase/issued", PurchaseDetail.class);
|
|
|
|
|
+ if (!CollectionUtils.isEmpty(issued)) {
|
|
|
|
|
+ ContextHolder.setDataSize(issued.size());
|
|
|
|
|
+ savePurchaseIssued(issued);
|
|
|
|
|
+ // 回执
|
|
|
|
|
+ onIssuedSuccess(issued);
|
|
|
|
|
+ // TODO notice++
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 更新可发货状态
|
|
|
|
|
+ * @param issued
|
|
|
|
|
+ */
|
|
|
|
|
+ private void savePurchaseIssued(List<PurchaseDetail> issued) {
|
|
|
|
|
+ List<String> sqls = new ArrayList<String>();
|
|
|
|
|
+ for (PurchaseDetail detail : issued) {
|
|
|
|
|
+ sqls.add("update purchasedetail set pd_hasissued = '是' where pd_detno="+detail.getPd_custpurchasedetno()+" and pd_puid=(select pu_id from purchase where pu_code='"+detail.getPd_custpurchasecode()+"')");
|
|
|
|
|
+ }
|
|
|
|
|
+ jdbcTemplate.batchExecute(sqls);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 回执给平台
|
|
|
|
|
+ * @param issued
|
|
|
|
|
+ */
|
|
|
|
|
+ private void onIssuedSuccess(List<PurchaseDetail> issued) {
|
|
|
|
|
+ post("/erp/purchase/issued/back", dataWrap(issued));
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 保存回复记录,并更新到采购单明细
|
|
* 保存回复记录,并更新到采购单明细
|
|
|
*
|
|
*
|