RB企业管理系统 / rebuild-CRM-ERP-库存生产管理系统

/*! Copyright (c) REBUILD <https://getrebuild.com/> and/or its owners. All rights reserved. rebuild is dual-licensed under commercial and open source licenses (GPLv3). See LICENSE and COMMERCIAL in the project root for license information. */ package com.rebuild.core.service.general; import cn.devezhao.bizz.privileges.Permission; import cn.devezhao.bizz.privileges.impl.BizzPermission; import cn.devezhao.persist4j.Entity; import cn.devezhao.persist4j.Field; import cn.devezhao.persist4j.Filter; import cn.devezhao.persist4j.PersistManagerFactory; import cn.devezhao.persist4j.Query; import cn.devezhao.persist4j.Record; import cn.devezhao.persist4j.engine.ID; import com.rebuild.core.Application; import com.rebuild.core.RebuildException; import com.rebuild.core.UserContextHolder; import com.rebuild.core.metadata.DeleteRecord; import com.rebuild.core.metadata.EntityHelper; import com.rebuild.core.metadata.MetadataHelper; import com.rebuild.core.metadata.MetadataSorter; import com.rebuild.core.metadata.easymeta.DisplayType; import com.rebuild.core.metadata.easymeta.EasyField; import com.rebuild.core.metadata.easymeta.EasyMetaFactory; import com.rebuild.core.privileges.UserService; import com.rebuild.core.privileges.bizz.InternalPermission; import com.rebuild.core.privileges.bizz.User; import com.rebuild.core.service.BaseService; import com.rebuild.core.service.DataSpecificationException; import com.rebuild.core.service.NoRecordFoundException; import com.rebuild.core.service.approval.ApprovalHelper; import com.rebuild.core.service.approval.ApprovalState; import com.rebuild.core.service.general.recyclebin.RecycleStore; import com.rebuild.core.service.general.series.SeriesGeneratorFactory; import com.rebuild.core.service.notification.NotificationObserver; import com.rebuild.core.service.query.QueryHelper; import com.rebuild.core.service.trigger.ActionType; import com.rebuild.core.service.trigger.RobotTriggerManager; import com.rebuild.core.service.trigger.RobotTriggerManual; import com.rebuild.core.service.trigger.RobotTriggerObserver; import com.rebuild.core.service.trigger.TriggerAction; import com.rebuild.core.service.trigger.TriggerWhen; import com.rebuild.core.service.trigger.impl.AutoApproval; import com.rebuild.core.support.i18n.Language; import com.rebuild.core.support.task.TaskExecutors; import com.rebuild.utils.CommonsUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import org.springframework.util.Assert; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; /** * 业务实体核心服务，所有业务实体都应该使用此类（或子类） * <br>- 有业务验证 * <br>- 会带有系统设置规则的执行 * <br>- 会开启一个事务，详见 <tt>application-bean.xml</tt> 配置 * * <p>如有需要，其他实体可根据自身业务继承并复写</p> * * FIXME 删除主记录时会关联删除明细记录（持久层实现），但明细记录不会触发业务规则 * * @author Zixin (RB) * @since 11/06/2017 */ @Slf4j @Service public class GeneralEntityService extends ObservableService implements EntityService { // 有明细 public static final String HAS_DETAILS = "$DETAILS$"; protected GeneralEntityService(PersistManagerFactory aPMFactory) { super(aPMFactory); // 通知 addObserver(new NotificationObserver()); // 触发器 addObserver(new RobotTriggerObserver()); } @Override public int getEntityCode() { return 0; } // 此方法具备明细实体批处理能力 // 此方法具备重复检查能力 @Override public Record createOrUpdate(Record record) { @SuppressWarnings("unchecked") final List<Record> details = (List<Record>) record.removeValue(HAS_DETAILS); final int rcm = GeneralEntityServiceContextHolder.getRepeatedCheckModeOnce(); if (rcm == GeneralEntityServiceContextHolder.RCM_CHECK_MAIN || rcm == GeneralEntityServiceContextHolder.RCM_CHECK_ALL) { List<Record> repeated = getAndCheckRepeated(record, 20); if (!repeated.isEmpty()) { throw new RepeatedRecordsException(repeated); } } // 含明细 final boolean hasDetails = details != null && !details.isEmpty(); boolean lazyAutoApprovalForDetails = false; boolean lazyAutoTransformForDetails = false; if (hasDetails) { // fix: v3.2.2 TriggerAction[] hasAutoApprovalTriggers = getSpecTriggers( record.getEntity(), ActionType.AUTOAPPROVAL, TriggerWhen.CREATE, TriggerWhen.UPDATE); lazyAutoApprovalForDetails = hasAutoApprovalTriggers.length > 0; // FIXME 此判断可能无意义，待进一步测试后确定是否保留 if (!lazyAutoApprovalForDetails) { TriggerAction[] hasOnApprovedTriggers = getSpecTriggers( record.getEntity().getDetailEntity(), null, TriggerWhen.APPROVED); lazyAutoApprovalForDetails = hasOnApprovedTriggers.length > 0; } // 自动审批延迟执行，因为明细尚未保存好 if (lazyAutoApprovalForDetails) AutoApproval.setLazyAutoApproval(); TriggerAction[] hasAutoTransformTriggers = getSpecTriggers( record.getEntity(), ActionType.AUTOTRANSFORM, TriggerWhen.CREATE, TriggerWhen.UPDATE); lazyAutoTransformForDetails = hasAutoTransformTriggers.length > 0; // 记录转换延迟执行，因为明细尚未保存好 if (lazyAutoTransformForDetails) CommonsUtils.invokeMethod("com.rebuild.rbv.trigger.AutoTransform#setLazyAutoTransform"); } try { record = record.getPrimary() == null ? create(record) : update(record); if (!hasDetails) return record; // 主记录+明细记录处理 final String dtfField = MetadataHelper.getDetailToMainField(record.getEntity().getDetailEntity()).getName(); final ID mainid = record.getPrimary(); final boolean checkDetailsRepeated = rcm == GeneralEntityServiceContextHolder.RCM_CHECK_DETAILS || rcm == GeneralEntityServiceContextHolder.RCM_CHECK_ALL; // 先删除 for (Record d : details) { if (d instanceof DeleteRecord) delete(d.getPrimary()); } // 再保存 for (Record d : details) { if (d instanceof DeleteRecord) continue; if (checkDetailsRepeated) { d.setID(dtfField, mainid); // for check List<Record> repeated = getAndCheckRepeated(d, 20); if (!repeated.isEmpty()) { throw new RepeatedRecordsException(repeated); } } if (d.getPrimary() == null) { d.setID(dtfField, mainid); create(d); } else { update(d); } } return record; } finally { if (lazyAutoApprovalForDetails) { AutoApproval.executeLazyAutoApproval(); } if (lazyAutoTransformForDetails) { CommonsUtils.invokeMethod("com.rebuild.rbv.trigger.AutoTransform#executeLazyAutoTransform"); } } } /** * 优先使用 `#createOrUpdate(Record) ` */ @Override public Record create(Record record) { appendDefaultValue(record); checkModifications(record, BizzPermission.CREATE); setSeriesValue(record); return super.create(record); } /** * 优先使用 `#createOrU