产品导入和物料导入时，也添加到个人产品库

src/main/java/com/uas/platform/b2b/service/impl/BaseInfoServiceImpl.java

@@ -325,14 +325,29 @@ public class BaseInfoServiceImpl implements BaseInfoService {
             List<Product> products = productTempDao.getProducts(importId);
             System.out.println("取匹配后结果:" + (System.currentTimeMillis() - start));
             start = System.currentTimeMillis();
-            try {
-                // 更新物料
-                List<Long> ids = ProductUtils.paginationUpdate(products);
-                System.out.println("更新物料:" + (System.currentTimeMillis() - start));
-                modelMap.put("success", ids.size());
-            } catch (Exception e) {
-                modelMap.put("error", "物料添加失败（" + e.getMessage() + ")");
-            }
+			try {
+				// 更新物料并插入个人物料
+				ModelMap map = ProductUtils.paginationUpdateAndAddToProductUser(products);
+				System.out.println("更新物料:" + (System.currentTimeMillis() - start));
+				if ("true".equals(map.get("success"))) {
+					modelMap.put("success", null != map.get("result") ? map.get("result") : 0);
+				} else {
+					modelMap.put("error", "物料添加失败（" + null != map.get("message") ? map.get("message") : "" + ")");
+				}
+//                start = System.currentTimeMillis();
+//                if (!CollectionUtils.isEmpty(idList)) {
+//                    // 更新个人物料
+//                    List<ProductUsers> productUsersList = productTempDao.getNotMatchedProductUsers(importId,
+//                            temps.get(0).getPr_enuu(), temps.get(0).getPr_useruu(), idList);
+//                    if (!CollectionUtils.isEmpty(productUsersList)) {
+//                        ProductUtils.updateProductUsersByBatch(productUsersList);
+//                        modelMap.put("success", productUsersList.size());
+//                        System.out.println("更新个人物料:" + (System.currentTimeMillis() - start));
+//                    }
+//                }
+			} catch (Exception e) {
+				modelMap.put("error", "物料添加失败（" + e.getMessage() + ")");
+			}
         }
     }
 

src/main/java/com/uas/platform/b2b/service/impl/PurcProductServiceImpl.java

@@ -234,10 +234,25 @@ public class PurcProductServiceImpl implements PurcProductService {
             System.out.println("取匹配后结果:" + (System.currentTimeMillis() - start));
             start = System.currentTimeMillis();
             try {
-                // 更新物料
-                List<Long> ids = ProductUtils.paginationUpdate(products);
+                // 更新物料并插入个人物料
+                ModelMap map = ProductUtils.paginationUpdateAndAddToProductUser(products);
                 System.out.println("更新物料:" + (System.currentTimeMillis() - start));
-                modelMap.put("success", ids.size());
+                if ("true".equals(map.get("success"))) {
+                    modelMap.put("success", null != map.get("result") ? map.get("result") : 0);
+                } else {
+                    modelMap.put("error", "物料添加失败（" + null != map.get("message") ? map.get("message") : "" + ")");
+                }
+//                start = System.currentTimeMillis();
+//                if (!CollectionUtils.isEmpty(idList)) {
+//                    // 更新个人物料
+//                    List<ProductUsers> productUsersList = productTempDao.getNotMatchedProductUsers(importId,
+//                            temps.get(0).getPr_enuu(), temps.get(0).getPr_useruu(), idList);
+//                    if (!CollectionUtils.isEmpty(productUsersList)) {
+//                        ProductUtils.updateProductUsersByBatch(productUsersList);
+//                        modelMap.put("success", productUsersList.size());
+//                        System.out.println("更新个人物料:" + (System.currentTimeMillis() - start));
+//                    }
+//                }
             } catch (Exception e) {
                 modelMap.put("error", "物料添加失败（" + e.getMessage() + ")");
             }