|
|
@@ -28,7 +28,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_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("");
|
|
|
@@ -55,7 +55,7 @@ public class ProductTask {
|
|
|
|
|
|
@Scheduled(cron = "0 0 23 * * ?")
|
|
|
public void syncUpdateProducts() {
|
|
|
- SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate)) left join product on pis_prodcode=pr_code order by pr_id");
|
|
|
+ SqlRowList rs = baseDao.queryForRowSet("select * from (select distinct pis_prodcode from productInfoSync where trunc(pis_date)=trunc(sysdate)) 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 {
|