/// ///WCF service ///FOR TABLE t_erp_customer ///By wm ///on 08/04/2023 /// using System.Collections.Generic; using System.Data; using DeiNiu.wms.Data.Model.Wcf ; using DeiNiu.wms.Data.Model; using System.Transactions; using DeiNiu.Utils; using System; using DeiNiu.Wcf.erp.wcfData; namespace DeiNiu.Wcf { // 注意: 使用“重构”菜单上的“重命名”命令,可以同时更改代码、svc 和配置文件中的类名 。 public class T_ERP_CUSTOMER :baseSvc, IErp_customer { #region options /*: basicService, private static lErp_customer _lErp_customer ; lErp_customer lErp_customerObj { get { if ( _lErp_customer == null || _lErp_customer.operId != getOperId()) { _lErp_customer= new lErp_customer(getOperId()); } return _lErp_customer; } } */ #endregion public WcfErp_customer getObj(int Id) { log.Debug("getObj called --->" + Id); WcfErp_customer wcfObj = new WcfErp_customer (); Erp_customer dbObj = new Erp_customer(Id); log.Debug("return json :" + Util.getJson( wcfObj.getWcfObject(dbObj))); return wcfObj.getWcfObject(dbObj); } public Result add(WcfErp_customer obj) { log.Debug("add called --->" + Util.getJson(obj)); int id = 0; try { id = obj.getDbObject().Add(); } catch (Exception ex) { log.Error(ex); return new Result(enumDbResult.失败, ex.Message); } Result rt = id > 0 ? new Result(id, enumDbResult.成功) : new Result(enumDbResult.失败); log.Debug(Util.getJson(rt)); return rt; } public Result update(WcfErp_customer obj) { log.Debug("update called --->" + Util.getJson(obj)); int cnt = 0; try { cnt = obj.getDbObject().Update(); } catch (Exception ex) { log.Error(ex); return new Result(enumDbResult.失败, ex.Message); } Result rt = cnt > 0 ? new Result(cnt, enumDbResult.成功) : new Result(enumDbResult.失败); log.Debug(Util.getJson(rt)); return rt; } #region options /* public enumDbResult delete(WcfErp_customer obj) { int cnt = 0; try { cnt = obj.getDbObject().Delete(); }catch(Exception er) { return new Result(enumDbResult.失败, er.Message); } return new Result(cnt, enumDbResult.成功); } public List updateList(List objs) { List results = new List(); // using (TransactionScope scope = new TransactionScope()) { foreach (WcfErp_customer obj in objs) { Result rs = new Result(obj.id, obj.getDbObject().Update()); results.Add(rs); } // scope.Complete(); } return results; } public List addList(List objs) { List results = new List(); // using (TransactionScope scope = new TransactionScope()) { foreach (WcfErp_customer obj in objs) { Result rs = new Result( obj.getDbObject().Add(),1); results.Add(rs); } // scope.Complete(); } return results; } public List deleteList(List objs) { List results = new List(); // using (TransactionScope scope = new TransactionScope()) { foreach (WcfErp_customer obj in objs) { Result rs = new Result(obj.id, obj.getDbObject().Delete()); results.Add(rs); } // scope.Complete(); } return results; }*/ #endregion public WcfErp_customerList query(string condition, int pageno) { log.Debug("query called --->" + condition +", pageno " +pageno); condition = filterRisk(condition); WcfErp_customerList objLst = new WcfErp_customerList(); List lst = new List(); Erp_customer dbObj = new Erp_customer(); dbObj.rownumStart =(Convert.ToInt16( pageno)-1)* WmsConstants.PAGER_SIZE; dbObj.rownumEnd = dbObj.rownumStart + DeiNiu.Utils.WmsConstants.PAGER_SIZE; DataSet ds = dbObj.Query(condition); if (ds.Tables.Count >1) { DataTable dt = ds.Tables[0]; foreach(DataRow dr in dt.Rows) { lst.Add(new WcfErp_customer(dr)); } objLst.rows = Convert.ToInt32(ds.Tables[1].Rows[0][0].ToString()); } objLst.list =lst; objLst.page = Convert.ToInt16(pageno); objLst.pageSize = WmsConstants.PAGER_SIZE; objLst.pageCnt = objLst.rows / WmsConstants.PAGER_SIZE; log.Debug(Util.getJson(objLst)); return objLst; } } }