新的对接方式才分析图片

src/main/java/com/uas/eis/task/ProductMITask.java

@@ -30,7 +30,7 @@ public class ProductMITask {
 
     @Scheduled(cron = "0 0/5 * * * ?")
     public void syncProductMIImg() {
-        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM ZN_P.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
+        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM ZN_P.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_NEWFLAG=1 AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
         File file = null;
         List<String> sqls = new ArrayList<>();
         String prCode = " ";
@@ -84,7 +84,7 @@ public class ProductMITask {
 
     @Scheduled(cron = "0 0/5 * * * ?")
     public void syncJXKXProductMIImg() {
-        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM N_KX_JXKX.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
+        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM N_KX_JXKX.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_NEWFLAG=1 AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
         File file = null;
         List<String> sqls = new ArrayList<>();
         String prCode = " ";
@@ -136,7 +136,7 @@ public class ProductMITask {
     }
     @Scheduled(cron = "0 0/5 * * * ?")
     public void syncGZKXProductMIImg() {
-        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM GZKX.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
+        SqlRowList sl = baseDao.queryForRowSet("SELECT  * FROM  (SELECT PR_MIIMG,PR_CODE FROM GZKX.PRODUCT WHERE PR_GROUPCODE='成品' AND NVL(PR_MISTATUS,' ')='已上网' AND PR_NEWFLAG=1 AND PR_MIIMG IS NULL ORDER BY PR_ID DESC) WHERE ROWNUM<=200");
         File file = null;
         List<String> sqls = new ArrayList<>();
         String prCode = " ";