/************************************************************************* * 文件名称 ：ServiceBaseEdit.cs * 描述说明 ：定义数据服务基类中的编辑处理 * * 创建信息 : create by liuhuisheng.xm@gmail.com on 2012-11-10 * 修订信息 : modify by (person) on (date) for (reason) * * 版权信息 : Copyright (c) 2013 厦门纵云信息科技有限公司 www.zoewin.com **************************************************************************/ using System; using System.Collections.Generic; using Newtonsoft.Json.Linq; using Zephyr.Utils; namespace Zephyr.Core { public partial class ServiceBase where T : ModelBase, new() { protected virtual bool OnBeforeEditPage(EditPageEventArgs arg) { return true; } protected virtual bool OnBeforeEditPageForm(EditPageEventArgs arg) { return true; } protected virtual void OnAfterEditPageForm(EditPageEventArgs arg) { } protected virtual bool OnBeforeEditPageRow(EditPageEventArgs arg) { return true; } protected virtual void OnAfterEditPageRow(EditPageEventArgs arg) { } protected virtual void OnAfterEditPage(EditPageEventArgs arg) { } public int EditPage(JObject data,RequestWrapper formWrapper, List tabsWrapper) { const string DATA_TYPE_DELETED = "deleted"; const string DATA_TYPE_UPDATED = "updated"; const string DATA_TYPE_INSERTED = "inserted"; const string DATA_TYPE_FORM = "form"; const string DATA_TYPE_TABS = "tabs"; const string DATA_TYPE_ARRAY = "Array"; Dictionary actionTypes = new Dictionary{ {DATA_TYPE_DELETED ,OptType.Del}, {DATA_TYPE_UPDATED ,OptType.Mod}, {DATA_TYPE_INSERTED ,OptType.Add}}; var handles = new Dictionary>{ {DATA_TYPE_DELETED , x => BuilderParse(x.ToParamDelete()).Execute()}, {DATA_TYPE_UPDATED , x => BuilderParse(x.ToParamUpdate()).Execute()}, {DATA_TYPE_INSERTED , x => BuilderParse(x.ToParamInsert()).Execute()}}; var rowsAffected = 0; Logger("编辑记录", () => { var formData = data[DATA_TYPE_FORM]; var tabsData = data[DATA_TYPE_TABS]; var editArgs = new EditPageEventArgs() { db = db, data=data, formWrapper=formWrapper, tabsWrapper=tabsWrapper}; //开启事务 db.UseTransaction(true); //更新全部数据之前事件 var rtnBefore = this.OnBeforeEditPage(editArgs); if (!rtnBefore) return; //更新主表 if (formData != null && formWrapper != null) { formWrapper.SetRequestData(formData); var changedFieldCount = formWrapper.ToParamUpdate().GetData().Columns.Count; //如果有字段被修改则更新 if (changedFieldCount > 0) { //到数据库中取得旧值 var formOld = BuilderParse(formWrapper.ToParamQuery()).QuerySingleDynamic(); var strAction = (formOld == null) ? DATA_TYPE_INSERTED : DATA_TYPE_UPDATED; //事件参数 editArgs.dataNew = formData; editArgs.dataOld = formOld??new JObject(); editArgs.dataAction = actionTypes[strAction]; editArgs.dataWrapper = formWrapper; //主表编辑前事件 rtnBefore = this.OnBeforeEditPageForm(editArgs); if (!rtnBefore) return; //主表数据处理 formWrapper.SetRequestData(editArgs.dataNew); editArgs.executeValue = handles[strAction](formWrapper); rowsAffected += editArgs.executeValue; //把未修改的数据更新到form新值上,避免在后面的事件中使用formNew值时为null出现错误 if (editArgs.dataAction == OptType.Mod) { EachHelper.EachObjectProperty(editArgs.dataOld as object, (i, name, value) => { if (editArgs.dataNew[name] == null) editArgs.dataNew[name] = JToken.FromObject(value ?? string.Empty); }); } //主表编辑结束事件 this.OnAfterEditPageForm(editArgs); } } //更新tabs if (tabsData != null && tabsWrapper != null) { var current = 0; var wrapperCount = tabsWrapper.Count; foreach (JToken tab in tabsData.Children()) { //如果Tab数据长度大于wrapper长度，则结束 if (current > wrapperCount - 1) break; //如果数据为null或未配置相应的wrapper则跳过处理 var wrapper = tabsWrapper[current++]; if (tab == null || wrapper == null) continue; //判断是form类型还是grid类型 bool IsGrid = (tab[DATA_TYPE_DELETED] != null && tab[DATA_TYPE_DELETED].Type.ToString() == DATA_TYPE_ARRAY) || (tab[DATA_TYPE_UPDATED] != null && tab[DATA_TYPE_UPDATED].Type.ToString() == DATA_TYPE_ARRAY) || (tab[DATA_TYPE_INSERTED] != null && tab[DATA_TYPE_INSERTED].Type.ToString() == DATA_TYPE_ARRAY); //事件参数 editArgs.dataWrapper = wrapper; editArgs.tabIndex = current; editArgs.tabType = IsGrid ? TabType.Grid : TabType.Form; editArgs.tabData = tab; if (IsGrid) { foreach (JProperty item in tab.Children()) { //只处理deleted updated inserted三个节点 if (!handles.ContainsKey(item.Name)) continue; //循环每一行数据 foreach (var row in item.Value.Children()) { //到数据库中取得旧值 wrapper.SetRequestData(row); var rowOld = BuilderParse(wrapper.ToParamQuery()).QuerySingleDynamic(); //事件参数 editArgs.dataNew = row; editArgs.dataOld = rowOld ?? new JObject(); editArgs.dataAction = actionTypes[item.Name]; //行编辑前事件 rtnBefore = this.OnBeforeEditPageRow(editArgs); if (!rtnBefore) return; //数据处理 wrapper.SetRequestData(editArgs.dataNew); editArgs.executeValue = handles[item.Name](wrapper); rowsAffected += editArgs.executeValue; //行编辑后事件 this.OnAfterEditPageRow(editArgs); } } } else { wrapper.SetRequestData(tab); var changedFieldCount = wrapper.ToParamUpdate().GetData().Columns.Count; //如果有字段被修改则更新 if (changedFieldCount > 0)//更新主表 { //到数据库中取得旧值 var formOld = BuilderParse(wrapper.ToParamQuery()).QuerySingleDynamic(); var strAction = (formOld == null) ? DATA_TYPE_INSERTED : DATA_TYPE_UPDATED; //事件参数 editArgs.dataNew = tab; editArgs.dataOld = formOld ?? new JObject(); editArgs.dataAction = actionTypes[strAction]; editArgs.dataWrapper = wrapper; //Form编辑前事件 rtnBefore = this.OnBeforeEditPageRow(editArgs); if (!rtnBefore) return; //Form数据处理 wrapper.SetRequestData(editArgs.dataNew); editArgs.executeValue = handles[strAction](wrapper); rowsAffected += editArgs.executeValue; //把未修改的数据更新到form新值上 if (editArgs.dataAction == OptType.Mod) { EachHelper.EachObjectProperty(editArgs.dataOld as object, (i, name, value) => { if (editArgs.dataNew[name] == null) editArgs.dataNew[name] = JToken.FromObject(value ?? string.Empty); }); } //Form编辑结束事件 this.OnAfterEditPageRow(editArgs); } } } //更新全部数据之后事件 editArgs.executeValue = rowsAffected; this.OnAfterEditPage(editArgs); //提交事务 if (rowsAffected > 0) { db.Commit(); Msg.Set(MsgType.Success, APP.MSG_SAVE_SUCCESS); } } }, e => db.Rollback()); return rowsAffected; } } }