销售订单 同步

jeecg-boot-module-system/src/main/java/org/jeecg/modules/quartz/job/AddOrderJob.java

@@ -77,8 +77,8 @@ public class AddOrderJob implements Job,ApplicationContextAware {
                 /*
                 SO_SOMain 销售订单数据 单据时间没有详细时间 只有日期
                 SO_SODetails SO_SOMain
-                 //销售订单审核字段问题：
-                select istatus,iverifystate,cSOCode  from so_somain where istatus=1 and iverifystate!=2
+                //销售订单审核字段问题：
+                //select istatus,iverifystate,cSOCode  from so_somain where istatus=1 and iverifystate!=2
                 */
 
                 String sql = "SELECT " +
@@ -226,14 +226,25 @@ public class AddOrderJob implements Job,ApplicationContextAware {
                     syOrderDataItemService.save(sy2);
                     size++;
                 }
+                //添加单证id 原数据账套+原数据id
+                String syId = sy.getId();
+                sy.setId(sy.getAccount()+sy.getId());
+
                 if(size<=0){
+                    //回写不拉取的数据状态 0
+                    String blackWrite = "UPDATE SO_SOMain SET cdefine15 = '0' WHERE id='"+syId+"'";
+                    if(sy.getAccount().equals("901")){
+                        senYuDataSourceOne.update(blackWrite);
+                    }else if(sy.getAccount().equals("902")){
+                        senYuDataSourceTwo.update(blackWrite);
+                    }else if(sy.getAccount().equals("903")){
+                        senYuDataSourceThree.update(blackWrite);
+                    }
                     continue;
                 }
                 //添加主表数据进入数据库
-                String syId = sy.getId();
-                sy.setId(sy.getAccount()+sy.getId());
                 syOrderDataService.save(sy);
-
+                //回写拉取的数据状态 1
                 String blackWrite = "UPDATE SO_SOMain SET cdefine15 = '1' WHERE id='"+syId+"'";
                 if(sy.getAccount().equals("901")){
                     senYuDataSourceOne.update(blackWrite);