|
|
@@ -31,7 +31,7 @@ public class ProductTask {
|
|
|
|
|
|
@Scheduled(cron = "0 0/15 * * * ?")
|
|
|
public void syncProducts() {
|
|
|
- SqlRowList rs = baseDao.queryForRowSet("select * from (select * from product where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' and upper(nvl(pr_brand,' ')) <> 'EASYDETEK' and nvl(pr_sendstatus,' ')='待上传' order by pr_id) where rownum<=200");
|
|
|
+ SqlRowList rs = baseDao.queryForRowSet("select * from (select * from product where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' and nvl(pr_sendstatus,' ')='待上传' order by pr_id) where rownum<=200");
|
|
|
while (rs.next()){
|
|
|
Product product = setProduct(rs);
|
|
|
product.set_id("");
|
|
|
@@ -94,7 +94,7 @@ public class ProductTask {
|
|
|
|
|
|
@Scheduled(cron = "0 0 19 * * ?")
|
|
|
public void syncUpdateProducts() {
|
|
|
- SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate) and pis_updatedate is null and PIS_ERROR is null) left join product on pis_prodcode=pr_code where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' and upper(nvl(pr_brand,' ')) <> 'EASYDETEK' order by pr_id");
|
|
|
+ SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate) and pis_updatedate is null and PIS_ERROR is null) left join product on pis_prodcode=pr_code where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' order by pr_id");
|
|
|
while (rs.next()){
|
|
|
Product product = setProduct(rs);
|
|
|
try {
|
|
|
@@ -116,7 +116,7 @@ public class ProductTask {
|
|
|
|
|
|
@Scheduled(cron = "0 0 1-6 * * ?")
|
|
|
public void syncUpdateProductsAgain() {
|
|
|
- SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate)-1 and pis_updatedate is null and PIS_ERROR is null) left join product on pis_prodcode=pr_code where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' and upper(nvl(pr_brand,' ')) <> 'EASYDETEK' order by pr_id");
|
|
|
+ SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate)-1 and pis_updatedate is null and PIS_ERROR is null) left join product on pis_prodcode=pr_code where nvl(pr_statuscode,' ')='AUDITED' and nvl(pr_sfjszy_user,' ')<>'是' order by pr_id");
|
|
|
while (rs.next()){
|
|
|
Product product = setProduct(rs);
|
|
|
try {
|
|
|
@@ -195,7 +195,7 @@ public class ProductTask {
|
|
|
product.setCategory("6");
|
|
|
product.setField_uwFmi__c(rs.getGeneralString("pr_aflypstock_user"));//艾富利样品仓库存
|
|
|
product.setField_ehcac__c(rs.getGeneralString("pr_aflplstock_user"));//艾富利批量仓库存
|
|
|
- product.setField_f0qjS__c("祥瑞微".equals(rs.getGeneralString("pr_brand")) || "Easydetek".equals(rs.getGeneralString("pr_brand")) ? null : rs.getGeneralDouble("pr_afllasttaxpurcprice_user"));//艾富利成本(含税)
|
|
|
+ product.setField_f0qjS__c("祥瑞微".equals(rs.getGeneralString("pr_brand")) || "Easydetek".equals(rs.getGeneralString("pr_brand")) || "EasyDetek".equals(rs.getGeneralString("pr_brand")) ? null : rs.getGeneralDouble("pr_afllasttaxpurcprice_user"));//艾富利成本(含税)
|
|
|
product.setField_rY1jT__c(rs.getGeneralString("pr_yjhhkplstock_user"));//越加红(香港)仓批量库存
|
|
|
product.setField_CN00a__c(rs.getGeneralString("pr_tjxz_user"));//推荐星值
|
|
|
product.setField_1WO33__c(rs.getGeneralString("pr_abc"));
|