修改同步策略

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/ims/kingdeeapi/SynKingdeeApi.java

@@ -48,7 +48,7 @@ public class SynKingdeeApi implements web_api {
         //查询未同步数据
         List<List<Object>> list = categoryDao.queryList(sFormId, key, new HashMap<String, String>() {{
             put("F_LQKJ_SyncCheck","0");
-        }},"同步记录查询",0,10);
+        }},"同步记录查询",0,200);
         return Syn(list);
     }
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/iost/ims/service/impl/ISynServiceImpl.java

@@ -64,6 +64,7 @@ public class ISynServiceImpl extends ServiceImpl<SynMapper, Syn> implements ISyn
         List<Map<String, String>> maps = kingdeeApi.select(null, null);
         Boolean success=true;
         List<Map<String,Object>> list=new ArrayList<>();
+        List<Syn> pojolist=new ArrayList<>();
         LoginUser sysUser = null;
         for (Map<String, String> data:maps) {
             if(!data.get("formid").equals("LQKJ_IMSSync")) {
@@ -77,33 +78,7 @@ public class ISynServiceImpl extends ServiceImpl<SynMapper, Syn> implements ISyn
                 syn.setCreatetime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
                 //把字符串转换成布尔类型
                 syn.setSynchronization("同步成功");
-                this.save(syn);
-                //每次同步一个数据
-                //物料成品信息
-                if (data.get("formid").equals("BD_MATERIAL")) {
-                    success = iImsMtrlService.synchronization(data.get("dataid"),sysUser);
-                    //库存管理
-                }else if (data.get("formid").equals("BD_STOCK")) {
-                    success=iImsStoreService.synchronization(data.get("dataid"),sysUser);
-                    //客户
-                }else if (data.get("formid").equals("BD_Customer")) {
-                    success=iImsCustomerService.synchronization(data.get("dataid"),sysUser);
-                    //部门
-                }else if(data.get("formid").equals("BD_Department")) {
-                    success=iImsDeptService.synchronization(data.get("dataid"),sysUser);
-                    //供应商
-                }else if (data.get("formid").equals("BD_Supplier")) {
-                    success= iImsSupplierService.synchronization(data.get("dataid"),sysUser);
-                    //生产订单
-                }else if(data.get("formid").equals("PRD_MO")) {
-                    success= iImsWplanService.synchronization(data.get("dataid"),sysUser);
-                    //发货通知单
-                }else if(data.get("formid").equals("SAL_DELIVERYNOTICE")) {
-                    success= iImsDnService.synchronization(data.get("dataid"),sysUser);
-                    //出库申请单
-                }else if(data.get("formid").equals("STK_OutStockApply")) {
-                    success=iImsAuditService.synchronization(data.get("dataid"),sysUser);
-                }
+                pojolist.add(syn);
                 //将金蝶云的数据同步该成1
                 Map<String, Object> result = new HashMap<>();
                 result.put("FID", data.get("fid"));
@@ -111,8 +86,37 @@ public class ISynServiceImpl extends ServiceImpl<SynMapper, Syn> implements ISyn
                 result.put("F_LQKJ_SyndDatetime",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
                 list.add(result);
             }
-            //批量保存
-            String add = kingdeeApi.batchAdd(list);
+        }
+        //批量保存
+        this.saveBatch(pojolist);
+        String add = kingdeeApi.batchAdd(list);
+        for (Map<String, String> data:maps) {
+            //每次同步一个数据
+            //物料成品信息
+            if (data.get("formid").equals("BD_MATERIAL")) {
+                success = iImsMtrlService.synchronization(data.get("dataid"),sysUser);
+                //库存管理
+            }else if (data.get("formid").equals("BD_STOCK")) {
+                success=iImsStoreService.synchronization(data.get("dataid"),sysUser);
+                //客户
+            }else if (data.get("formid").equals("BD_Customer")) {
+                success=iImsCustomerService.synchronization(data.get("dataid"),sysUser);
+                //部门
+            }else if(data.get("formid").equals("BD_Department")) {
+                success=iImsDeptService.synchronization(data.get("dataid"),sysUser);
+                //供应商
+            }else if (data.get("formid").equals("BD_Supplier")) {
+                success= iImsSupplierService.synchronization(data.get("dataid"),sysUser);
+                //生产订单
+            }else if(data.get("formid").equals("PRD_MO")) {
+                success= iImsWplanService.synchronization(data.get("dataid"),sysUser);
+                //发货通知单
+            }else if(data.get("formid").equals("SAL_DELIVERYNOTICE")) {
+                success= iImsDnService.synchronization(data.get("dataid"),sysUser);
+                //出库申请单
+            }else if(data.get("formid").equals("STK_OutStockApply")) {
+                success=iImsAuditService.synchronization(data.get("dataid"),sysUser);
+            }
         }
         return success;
     }