去掉B2B物料上传（现在物料已由物料服务上传）

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

@@ -280,16 +280,6 @@ public class AbstractTask {
         }
     }
 
-    /**
-     * 处理物料上传的工具
-     */
-    protected final class ProductHandler extends StatusBasedHandler<Prod>{
-
-        public ProductHandler(List<Prod> data) {
-            super("product", "pr_id", "PR_SENDSTATUS", "/erp/product", data);
-        }
-    }
-
     /**
      * 查找附件
      * @param attachIds 附件ID

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

@@ -22,7 +22,6 @@ public class InquiryMouldTask extends AbstractTask {
 
     @TaskMapping(title = "上传模具询价单", fixedDelay = 60000)
     public void uploadInquiryMould() {
-        uploadProduct();
         List<InquiryMould> inquiries = getInquiryMouldUpload();
         if (!CollectionUtils.isEmpty(inquiries)) {
             ContextHolder.setDataSize(inquiries.size());
@@ -30,21 +29,6 @@ public class InquiryMouldTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select pr_id,pr_code,pr_detail,pr_spec,pr_unit,pr_zxbzs,pr_zxdhl,pr_leadtime,pr_ltinstock,pr_brand from product where exists(select 1 from inquirymoulddetail left join inquirymoulddet on ind_iddid=idd_id left join inquirymould on idd_inid=in_id left join vendor on in_vendcode=ve_code  where (IN_SENDSTATUS='待上传' or IN_SENDSTATUS='上传中') and nvl(in_sourcetype,' ')<>'模具报价单'and ve_uu is not null and pr_code=ind_prodcode and pr_sendstatus<>'已上传')) where rownum <= 500",
-                Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的模具询价单
      *

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

@@ -22,7 +22,6 @@ public class PurchaseAPBillTask extends AbstractTask {
 
     @TaskMapping(title = "上传应付发票", fixedDelay = 120000)
     public void uploadAPBill() {
-        uploadProduct();
         List<PurchaseAPBill> purchaseAPBills = getAPBillUpload();
         if (!CollectionUtils.isEmpty(purchaseAPBills)) {
             ContextHolder.setDataSize(purchaseAPBills.size());
@@ -40,21 +39,6 @@ public class PurchaseAPBillTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select pr_id,pr_code,pr_detail,pr_spec,pr_unit,pr_zxbzs,pr_zxdhl,pr_leadtime,pr_ltinstock,pr_brand from product where exists (select 1 from apbill left join vendor on ab_vendcode=ve_code left join apbilldetail on abd_abid=ab_id where (ab_SENDSTATUS='待上传' or ab_SENDSTATUS='上传中') and ab_statuscode='POSTED' and ve_uu is not null and nvl(ve_b2benable,0)=1 and abd_prodcode=pr_code) and nvl(pr_sendstatus,' ')<>'已上传' order by pr_id) where rownum <= 500",
-                Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的应付发票
      *

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

@@ -31,7 +31,6 @@ public class PurchaseChangeTask extends AbstractTask {
 
     @TaskMapping(title = "上传采购变更单", fixedDelay = 60000)
     public void uploadPurchaseChange() {
-        uploadProduct();
         List<PurchaseChange> changes = getPurchaseChangeUpload();
         if (!CollectionUtils.isEmpty(changes)) {
             ContextHolder.setDataSize(changes.size());
@@ -39,21 +38,6 @@ public class PurchaseChangeTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select distinct product.* from product where exists (select 1 from purchasechange left join purchase on pc_purccode=pu_code left join vendor on pu_vendcode=ve_code left join purchasechangedetail on pcd_pcid=pc_id where PC_SENDSTATUS='待上传' and nvl(pu_ordertype,' ')<>'B2C' and nvl(pc_agreed,1)<>0 and pc_statuscode in ('AUDITED','TO_CONFIRM') and ve_uu is not null and nvl(ve_b2benable,0)=1 and pcd_newprodcode=pr_code) and pr_statuscode='AUDITED' and nvl(pr_sendstatus,' ')<>'已上传') where rownum <= 500",
-                Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的采购变更单
      *

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

@@ -21,7 +21,6 @@ public class PurchaseForecastTask extends AbstractTask {
 
     @TaskMapping(title = "上传采购预测单", fixedDelay = 60000)
     public void uploadPurchaseForecasts() {
-        uploadProduct();
         List<PurchaseForecast> purchaseForecasts = getPurchaseForecastsUpload();
         if (!CollectionUtils.isEmpty(purchaseForecasts)) {
             ContextHolder.setDataSize(purchaseForecasts.size());
@@ -29,24 +28,6 @@ public class PurchaseForecastTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select distinct product.* from product where exists " +
-                " (select 1 from purchaseforecastdetail left join vendor on pfd_vendcode=ve_code " +
-                " left join purchaseForecast on pfd_pfid=pf_id " +
-                " where PF_SENDSTATUS='待上传' and ve_uu is not null and nvl(ve_b2benable,0)=1 and pfd_prodcode=pr_code) " +
-                " and pr_statuscode='AUDITED' and nvl(pr_sendstatus,' ')<>'已上传') where rownum <= 500", Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的采购预测
      *
@@ -61,7 +42,8 @@ public class PurchaseForecastTask extends AbstractTask {
             List<PurchaseForecastDetail> purchaseForecastDetails = jdbcTemplate.queryForBeanList("select purchaseforecastdetail.*, ve_uu, ve_contact, ve_contactuu from purchaseforecastDetail "
                                     + "left join vendor on pfd_vendcode=ve_code where pfd_pfid=? and ve_uu is not null and nvl(ve_b2benable,0)=1 ",
                     PurchaseForecastDetail.class, purchaseForecast.getPf_id());
-            if (purchaseForecastDetails.size() > 0) {// 存在有效的明细的单上传，明细都无效的不上传
+            // 存在有效的明细的单上传，明细都无效的不上传
+            if (purchaseForecastDetails.size() > 0) {
                 purchaseForecast.setPurchaseForecastDetails(purchaseForecastDetails);
                 forecasts.add(purchaseForecast);
             }

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

@@ -56,7 +56,6 @@ public class PurchaseProdInOutTask extends AbstractTask {
 
     @TaskMapping(title = "上传采购验退单", fixedDelay = 60000)
     public void uploadProdReturn() {
-        uploadProduct();
         List<PurchaseProdInOut> prodReturns = getProdReturnUpload();
         if (!CollectionUtils.isEmpty(prodReturns)) {
             ContextHolder.setDataSize(prodReturns.size());
@@ -65,21 +64,6 @@ public class PurchaseProdInOutTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select pr_id,pr_code,pr_detail,pr_spec,pr_unit,pr_zxbzs,pr_zxdhl,pr_leadtime,pr_ltinstock,pr_brand from product where  exists (select 1 from prodinout left join vendor on prodinout.pi_cardcode = vendor.ve_code left join prodiodetail on pi_id=pd_piid where pi_class='采购验退单' and pi_status = '已过账' and (pi_sendstatus = '待上传' or pi_sendstatus='上传中') and ve_uu is not null and nvl(ve_b2benable,0)=1 and pd_prodcode=pr_code) and nvl(pr_sendstatus,' ')<>'已上传' order by pr_id)  where rownum <= 500",
-                Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的采购验退单
      *

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

@@ -39,25 +39,6 @@ public class PurchaseSampleTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select * from (select distinct product.* from product where exists" +
-                " (select 1 from productsample left join productsampledetail on" +
-                " productsample.ps_id=productsampledetail.pd_psid left join vendor on" +
-                " productsampledetail.pd_vendcode=vendor.ve_code where productsample.ps_sendstatus='待上传'" +
-                " and ve_uu is not null and nvl(ve_b2benable,0)=1 and productsample.ps_prodcode=pr_code)" +
-                " and nvl(pr_sendstatus,' ')<>'已上传') where rownum <= 500", Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-            if (prods.size() == DATA_SIZE_LIMIT) {
-                // 递归，直到相关物料全部传完
-                uploadProduct();
-            }
-        }
-    }
-
     /**
      * 获取需要上传的打样申请单
      *

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

@@ -271,7 +271,6 @@ public class QuotationDownTask extends AbstractTask {
 
     @TaskMapping(title = "上传主动报价", fixedDelay = 60000)
     public void uploadQuotation() {
-        uploadProduct();
         List<Quotation> quotations = getQuotationsUpload();
         if (!CollectionUtils.isEmpty(quotations)) {
             ContextHolder.setDataSize(quotations.size());
@@ -286,17 +285,6 @@ public class QuotationDownTask extends AbstractTask {
         }
     }
 
-    /**
-     * 上传物料资料
-     */
-    private void uploadProduct() {
-        final List<Prod> prods = jdbcTemplate.queryForBeanList("select distinct product.* from product where exists (select 1 from quotation left join customer on qu_custcode=cu_code left join quotationdetail on qd_quid=qu_id where QU_SENDSTATUS='待上传' and cu_uu is not null and qd_prodcode=pr_code) and pr_statuscode='AUDITED' and nvl(pr_sendstatus,' ')<>'已上传'",
-                Prod.class);
-        if (!CollectionUtils.isEmpty(prods)) {
-            new ProductHandler(prods).run();
-        }
-    }
-
     /**
      * 获取需要上传的主动报价
      *