金蝶K3Cloud插件开发*单据下推

ListSelectedRowCollection selectRows = new ListSelectedRowCollection();
selectRows.Add(new ListSelectedRow(100000, 100000, 0, "PRD_MO"));

DynamicObject[] collection = (from p in convertOperationResult.TargetDataEntities
                                                  select p.DataEntity).ToArray<DynamicObject>();

/// <summary>
/// 获取单据转换规则
/// </summary>
public static ConvertRuleElement GetConvertRule(string src, string dest, Context ctx, string convertRuleKey = "")
{
  var rules = ServiceHelper.GetService<IConvertService>().GetConvertRules(ctx, src, dest);
  if (string.IsNullOrEmpty(convertRuleKey))
    return rules.FirstOrDefault();
  return (from e in rules
      where e.Id.Equals(convertRuleKey)
      select e).FirstOrDefault<ConvertRuleElement>();
}
/// <summary>
/// 单据转换
/// </summary>
/// <param name="ctx">会话上下文</param>
/// <param name="buildBillParam">下推参数</param>
/// <param name="autoSubmit">是否自动提交</param>
/// <param name="modifyAction">委托，对下推的单据执行修改</param>
/// <returns></returns>
public static IOperationResult Invoke(Context ctx, BuildBillParam buildBillParam, bool autoSubmit = false, Action<DynamicObject[]> modifyAction = null)
{
  IOperationResult result = new OperationResult();
  var ruleElement = GetConvertRule(buildBillParam.SourceFormId, buildBillParam.TargetFormId, ctx, buildBillParam.ConvertRuleKey);
  FormMetadata formMetadata = ServiceHelper.GetService<IMetaDataService>().Load(ctx, buildBillParam.TargetFormId) as FormMetadata;
  if (ruleElement != null && formMetadata != null && !buildBillParam.BizSelectRows.IsEmpty<ListSelectedRow>())
  {
    PushArgs pushArgs = new PushArgs(ruleElement, buildBillParam.BizSelectRows.ToArray());
    OperateOption operateOption = OperateOption.Create();
    operateOption.SetVariableValue("ValidatePermission", true);
    if (!string.IsNullOrEmpty(buildBillParam.TargetBillTypeId))
      pushArgs.TargetBillTypeId = buildBillParam.TargetBillTypeId;
    else
    {
      BillTypeMapPolicyElement billTypeMapPolicyElement = (from x in ruleElement.Policies
                                 where x is BillTypeMapPolicyElement
                                 select x).FirstOrDefault<ConvertPolicyElement>() as BillTypeMapPolicyElement;
      BillTypeMapElement billTypeMapElement = billTypeMapPolicyElement.BillTypeMaps.FirstOrDefault((BillTypeMapElement x) => x.SourceBillTypeId == "(All)");
      if (!billTypeMapElement.IsNullOrEmpty())
      {
        pushArgs.TargetBillTypeId = billTypeMapElement.TargetBillTypeId;
      }
    }
    //下推
    ConvertOperationResult convertOperationResult = ServiceHelper.GetService<IConvertService>().Push(ctx, pushArgs, operateOption, true);
    result.MergeResult(convertOperationResult);
    if (!convertOperationResult.IsSuccess)
    {
      goto end;
    }
    DynamicObject[] collection = (from p in convertOperationResult.TargetDataEntities
                    select p.DataEntity).ToArray<DynamicObject>();
    //修改目标单据
    modifyAction?.Invoke(collection);
    //保存目标单据
    buildBillParam.Option.SetIgnoreInteractionFlag(buildBillParam.Option.HasInteractionFlag("Kingdee.K3.SCM.App.Core.AppBusinessService.UpdateStockService,Kingdee.K3.SCM.App.Core"));
    IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(ctx, formMetadata.BusinessInfo, collection, OperateOption.Create());
    result.MergeResult(saveResult);
    if (!saveResult.IsSuccess)
    {
      goto end;
    }
    //提交\审核
    if (autoSubmit)
    {
      var ids = from bill in collection select bill["Id"];
      buildBillParam.Option.AddInteractionFlag("Kingdee.K3.SCM.App.Core.AppBusinessService.UpdateStockService,Kingdee.K3.SCM.App.Core");
      var submitResult = ServiceHelper.GetService<ISubmitService>().Submit(ctx, formMetadata.BusinessInfo, ids.ToArray(), "Submit", buildBillParam.Option);
      result.MergeResult(submitResult);
      //if (!submitResult.IsSuccess)
      //    throw new KDException("提交异常", $"单据下推并保存成功，但是提交失败{ValidErrorUtil.FormatError(submitResult.ValidationErrors)}");
      if (submitResult.IsSuccess)
      {
        buildBillParam.Option.AddInteractionFlag("Kingdee.K3.SCM.App.Core.AppBusinessService.UpdateStockService,Kingdee.K3.SCM.App.Core");
        var auditResult = ServiceHelper.GetService<IAuditService>().Audit(ctx, formMetadata.BusinessInfo, ids.ToArray(), buildBillParam.Option);
        result.MergeResult(auditResult);
      }
    }
  }
  else
  {
    throw new KDException("参数异常", "参数异常，未获取到目标单据元数据、转换规则、源单数据为空");
  }
  if (result.ValidationErrors != null && result.ValidationErrors.Count > 0)
  {
    result.IsSuccess = false;
  }
  end:
  return result;
}

var ppbomRows = new ListSelectedRowCollection();
ppbomRows.Add(new ListSelectedRow(row["F_PXJT_PPBOMFID"].ToString(), row["F_PXJT_PPBOMENTRYID"].ToString(), 0, "PRD_PPBOM"));
var pickMtrlParam = new BuildBillParam()
{
  SourceFormId =PrdFormIdEnum.PRD_PPBOM.ToString(), //"PRD_PPBOM",
  TargetFormId =PrdFormIdEnum.PRD_PickMtrl.ToString(), //"PRD_PickMtrl",
  ConvertRuleKey =_rulePickMtrlKey, //"PRD_PPBOM2PICKMTRL_NORMAL",
  BizSelectRows = ppbomRows.ToList(),
  Option = option,
};
IOperationResult pickMtrlResult = BuildTarget.Invoke(base.Context, pickMtrlParam, true, list =>
{
  var entrys = (DynamicObjectCollection)list[0]["Entity"];
  list[0]["OwnerId_Id"] = _orgId;
  list[0]["StockOrgId_Id"] = _orgId;
  foreach (var dy in entrys)
  {
    dy["Lot_Id"] = stockEntrys[0]["Lot_Id"]; //批号
    dy["Lot_Text"] = stockEntrys[0]["Lot_Text"];
    dy["OwnerTypeId"] = "BD_OwnerOrg"; //货主类型
    dy["OwnerId_Id"] = _orgId; //货主
    dy["OwnerId"] = _org;
    dy["StockId_Id"] = _whse["Id"]; //仓库
    dy["StockStatusId_Id"] = 10000;
    dy["APPQTY"] = _moveQty;
    dy["ACTUALQTY"] = _moveQty;
    dy["BASEAPPQTY"] = _moveQty * x;
    dy["BASEACTUALQTY"] = _moveQty * x;
    dy["STOCKAPPQTY"] = _moveQty;
    dy["STOCKACTUALQTY"] = _moveQty;
  }
});