批量价格修改增加采购验退、委外验收、委外验退单上传

src/main/java/com/uas/erp/schedular/b2b/domain/ProdInOutRefreshPrice.java

@@ -6,6 +6,7 @@ public class ProdInOutRefreshPrice extends KeyEntity {
 	private String pbu_inoutno; // 单据编号
 	private Double pbu_orderprice;// 采购成本
 	private Long pbu_id; //erpid
+	private String pbu_piclass;// 单据类型
 	public Short getPbu_pdno() {
 		return pbu_pdno;
 	}
@@ -30,6 +31,15 @@ public class ProdInOutRefreshPrice extends KeyEntity {
 	public void setPbu_id(Long pbu_id) {
 		this.pbu_id = pbu_id;
 	}
+
+	public String getPbu_piclass() {
+		return pbu_piclass;
+	}
+
+	public void setPbu_piclass(String pbu_piclass) {
+		this.pbu_piclass = pbu_piclass;
+	}
+
 	@Override
 	public Object getKey() {
 		return this.pbu_id;

src/main/java/com/uas/erp/schedular/b2b/task/PurchaseProdInOutTask.java

@@ -191,4 +191,43 @@ public class PurchaseProdInOutTask extends AbstractTask {
         }
     }
 
+    @TaskMapping(title = "批量更新采购验退单明细单价", fixedDelay = 60000)
+    public void uploadUpdatePurcReturnPriceByBatch() {
+        List<ProdInOutRefreshPrice> prods = jdbcTemplate.queryForBeanList("select pbu_pdno,pbu_inoutno,pbu_orderprice,pbu_id from PriceBatchUpdate where pbu_piclass = '采购验退单' and pbu_status = '99' and pbu_sendstatus = '待上传' and rownum < 200",
+                ProdInOutRefreshPrice.class);
+        if (!CollectionUtils.isEmpty(prods)) {
+            ContextHolder.setDataSize(prods.size());
+            post("/erp/purchase/prodInOut/refreshPrice/purc/return", dataWrap(prods));
+            // 更新状态
+            String idStr = CollectionUtil.getKeyString(prods);
+            jdbcTemplate.execute("update PriceBatchUpdate set pbu_sendstatus='已上传' where pbu_id in (" + idStr + ")");
+        }
+    }
+
+    @TaskMapping(title = "批量更新委外验收单明细单价", fixedDelay = 60000)
+    public void uploadUpdateMakeAcceptPriceByBatch() {
+        List<ProdInOutRefreshPrice> prods = jdbcTemplate.queryForBeanList("select pbu_pdno,pbu_inoutno,pbu_orderprice,pbu_id from PriceBatchUpdate where pbu_piclass = '委外验收单' and pbu_status = '99' and pbu_sendstatus = '待上传' and rownum < 200",
+                ProdInOutRefreshPrice.class);
+        if (!CollectionUtils.isEmpty(prods)) {
+            ContextHolder.setDataSize(prods.size());
+            post("/erp/purchase/prodInOut/refreshPrice/make/accept", dataWrap(prods));
+            // 更新状态
+            String idStr = CollectionUtil.getKeyString(prods);
+            jdbcTemplate.execute("update PriceBatchUpdate set pbu_sendstatus='已上传' where pbu_id in (" + idStr + ")");
+        }
+    }
+
+    @TaskMapping(title = "批量更新委外验退单明细单价", fixedDelay = 60000)
+    public void uploadUpdateMakeReutrnPriceByBatch() {
+        List<ProdInOutRefreshPrice> prods = jdbcTemplate.queryForBeanList("select pbu_pdno,pbu_inoutno,pbu_orderprice,pbu_id from PriceBatchUpdate where pbu_piclass = '委外验退单' and pbu_status = '99' and pbu_sendstatus = '待上传' and rownum < 200",
+                ProdInOutRefreshPrice.class);
+        if (!CollectionUtils.isEmpty(prods)) {
+            ContextHolder.setDataSize(prods.size());
+            post("/erp/purchase/prodInOut/refreshPrice/make/return", dataWrap(prods));
+            // 更新状态
+            String idStr = CollectionUtil.getKeyString(prods);
+            jdbcTemplate.execute("update PriceBatchUpdate set pbu_sendstatus='已上传' where pbu_id in (" + idStr + ")");
+        }
+    }
+
 }