|
|
@@ -95,21 +95,23 @@ public class ComponentTask extends AbstractTask {
|
|
|
* @author hejq
|
|
|
* @date 2018-01-12 19:05
|
|
|
*/
|
|
|
-/* @TaskMapping(title = "同步ERP的替代料到商城", fixedDelay = 60000*60*24, method = Method.UPLOAD)
|
|
|
+ @TaskMapping(title = "同步ERP的替代料到商城", cron = "0 0 1 * * ?", method = Method.UPLOAD)
|
|
|
public void uploadProduct() {
|
|
|
List<ProductReplaceErp> prods = jdbcTemplate.queryForBeanList("select BPR_ID,BPR_STATUSCODE,BPR_SENDSTATUS,BPR_PRODCODE,BPR_REPCODE,BPR_DATE,BPR_PRODBRAND,BPR_PRODOSCODE,BPR_REPBAND,BPR_REPOSCODE,BPR_ENUU " +
|
|
|
- "from B2B_PRODREPLACE where nvl(BPR_SENDSTATUS,' ')<>'已上传' and rownum <500 ",
|
|
|
+ "from B2B_PRODREPLACE where nvl(BPR_SENDSTATUS,' ')<>'已上传' and rownum <=500 ",
|
|
|
ProductReplaceErp.class);
|
|
|
String jsons = JSON.toJSONString(prods);
|
|
|
if (!CollectionUtils.isEmpty(prods)) {
|
|
|
productReplaceService.update(jsons);
|
|
|
-
|
|
|
}
|
|
|
for (ProductReplaceErp erp : prods) {
|
|
|
String sql = "update B2B_PRODREPLACE set BPR_SENDSTATUS = '已上传' where BPR_ID = " + erp.getBPR_ID();
|
|
|
jdbcTemplate.execute(sql);
|
|
|
-
|
|
|
}
|
|
|
- }*/
|
|
|
+ //迭代,
|
|
|
+ while(prods.size()>500){
|
|
|
+ uploadProduct();
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
}
|