|
|
@@ -68,77 +68,79 @@ public class PurchaseProofingServiceImpl implements PurchaseProofingService {
|
|
|
@Autowired
|
|
|
private PagingReleaseCountDao pagingReleaseCountDao;
|
|
|
|
|
|
-// @Autowired
|
|
|
-// private RoleDao roleDao;
|
|
|
-//
|
|
|
-// @Autowired
|
|
|
-// private UserDao userDao;
|
|
|
-//
|
|
|
-// @Autowired
|
|
|
-// private VendorDao vendorDao;
|
|
|
-//
|
|
|
-// @Autowired
|
|
|
-// private DistributeDao distributeDao;
|
|
|
-//
|
|
|
+ @Autowired
|
|
|
+ private RoleDao roleDao;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private UserDao userDao;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private VendorDao vendorDao;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DistributeDao distributeDao;
|
|
|
+
|
|
|
@Autowired
|
|
|
private UserOrderDao userOrderDao;
|
|
|
|
|
|
public void save(List<PurchaseProofingItem> proofingItems) {
|
|
|
proofingItems = purchaseProofingItemDao.save(proofingItems);
|
|
|
-// saveUserOrders(proofingItems);
|
|
|
+ saveUserOrders(proofingItems);
|
|
|
ContextUtils.publishEvent(new PurchaseProofingItemSaveEvent(proofingItems));
|
|
|
}
|
|
|
|
|
|
-// private void saveUserOrders(final List<PurchaseProofingItem> proofingItems) {
|
|
|
-//
|
|
|
-// ThreadTask.getInstance().execute(new Runnable() {
|
|
|
-// @Override
|
|
|
-// public void run() {
|
|
|
-// /* 添加供应商的阅读记录*/
|
|
|
-// for(PurchaseProofingItem item : proofingItems) {
|
|
|
-// Set<Long> userUUs = new HashSet<>();
|
|
|
-// // 添加管理员
|
|
|
-// List<Role> roles = roleDao.findByEnUUAndIssys(item.getVendUU(), Constant.YES);
|
|
|
-// if (!CollectionUtils.isEmpty(roles)) {
|
|
|
-// List<User> admins = userDao.findByRole(roles.get(0).getId());
|
|
|
-// for (User admin : admins) {
|
|
|
-// if (!userUUs.contains(admin.getUserUU())) {
|
|
|
-// userUUs.add(admin.getUserUU());
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// List<Vendor> vendors = vendorDao.findByMyEnUUAndVendUU(item.getVendUU(), item.getProofing().getEnUU());
|
|
|
-// // 查找有权限的用户
|
|
|
-// if (!CollectionUtils.isEmpty(vendors)) {
|
|
|
-// Long vendorId = vendors.get(0).getId();
|
|
|
-// List<Distribute> distributes = distributeDao.findByVendorId(vendorId);
|
|
|
-// if (!CollectionUtils.isEmpty(distributes)) {
|
|
|
-// for (Distribute distribute : distributes) {
|
|
|
-// if (!userUUs.contains(distribute.getUserUU())) {
|
|
|
-// userUUs.add(distribute.getUserUU());
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// }
|
|
|
-// UserOrders userOrders;
|
|
|
-// List<UserOrders> list = new ArrayList<>();
|
|
|
-// for (Long userUU : userUUs) {
|
|
|
-// if (userUU == null) {
|
|
|
-// continue;
|
|
|
-// }
|
|
|
-// userOrders = new UserOrders(userUU, item.getVendUU(), item.getId(), "sale", "purc$proofingitems");
|
|
|
-// list.add(userOrders);
|
|
|
-// }
|
|
|
-//
|
|
|
-// /* 添加采购员的阅读记录*/
|
|
|
-// userOrders = new UserOrders(item.getProofing().getUserUU(), item.getProofing().getEnUU(), item.getId(), "purc", "purc$proofingitems");
|
|
|
-// list.add(userOrders);
|
|
|
-// userOrderDao.save(list);
|
|
|
-// }
|
|
|
-// }
|
|
|
-// });
|
|
|
-//
|
|
|
-// }
|
|
|
+ private void saveUserOrders(final List<PurchaseProofingItem> proofingItems) {
|
|
|
+
|
|
|
+ ThreadTask.getInstance().execute(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ /* 添加供应商的阅读记录*/
|
|
|
+ for(PurchaseProofingItem item : proofingItems) {
|
|
|
+ Set<Long> userUUs = new HashSet<>();
|
|
|
+ // 添加管理员
|
|
|
+ List<Role> roles = roleDao.findByEnUUAndIssys(item.getVendUU(), Constant.YES);
|
|
|
+ if (!CollectionUtils.isEmpty(roles)) {
|
|
|
+ List<User> admins = userDao.findByRole(roles.get(0).getId());
|
|
|
+ for (User admin : admins) {
|
|
|
+ if (!userUUs.contains(admin.getUserUU())) {
|
|
|
+ userUUs.add(admin.getUserUU());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<Vendor> vendors = vendorDao.findByMyEnUUAndVendUU(item.getVendUU(), item.getProofing().getEnUU());
|
|
|
+ // 查找有权限的用户
|
|
|
+ if (!CollectionUtils.isEmpty(vendors)) {
|
|
|
+ Long vendorId = vendors.get(0).getId();
|
|
|
+ List<Distribute> distributes = distributeDao.findByVendorId(vendorId);
|
|
|
+ if (!CollectionUtils.isEmpty(distributes)) {
|
|
|
+ for (Distribute distribute : distributes) {
|
|
|
+ if (!userUUs.contains(distribute.getUserUU())) {
|
|
|
+ userUUs.add(distribute.getUserUU());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ UserOrders userOrders;
|
|
|
+ List<UserOrders> list = new ArrayList<>();
|
|
|
+ for (Long userUU : userUUs) {
|
|
|
+ if (userUU == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ userOrders = new UserOrders(userUU, item.getVendUU(), item.getId(), "sale", "purc$proofingitems");
|
|
|
+ list.add(userOrders);
|
|
|
+ }
|
|
|
+
|
|
|
+ /* 添加采购员的阅读记录*/
|
|
|
+ if (item.getProofing().getUserUU() != null) {
|
|
|
+ userOrders = new UserOrders(item.getProofing().getUserUU(), item.getProofing().getEnUU(), item.getId(), "purc", "purc$proofingitems");
|
|
|
+ list.add(userOrders);
|
|
|
+ }
|
|
|
+ userOrderDao.save(list);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
|
public void saveAttach(List<Attach> attachs) {
|