using com.hnshituo.core.webapp.vo; using CoreFS.CA06; using iCore.Rtdb; using System; using System.Collections; using System.Collections.Generic; using System.Linq; namespace Common { public class MeterWorkCarActualFirstService { /// /// 直接新增一次计量数据(无业务) /// /// MeterWorkCarActualFirst /// public RESTfulResult doAdd(PbSomeModel info) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "/add", new object[] { info }, 1); RESTfulResult result = new RESTfulResult(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; result.Data = rm.Data; return rm; } /// /// 直接新增一次计量数据(无业务) /// /// MeterWorkCarActualFirst /// public RESTfulResult doDoubleAdd(PbSomeModel info) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "/doDoubleAdd", new object[] { info }, 1); RESTfulResult result = new RESTfulResult(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; result.Data = rm.Data; return rm; } /// /// 加密车号获取 /// /// MeterWorkCarActualFirst /// public RESTfulResult DecryptionForWfTest(Hashtable hashtable) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "/DecryptionForWfTest", new object[] { hashtable }, 1); RESTfulResult result = new RESTfulResult(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; result.Data = rm.Data; return rm; } private CoreRESTfulService restful = new CoreRESTfulService(AppConfigCache.serviceUrl, "", true); /// /// 根据预报编号查数据 /// /// /// public RESTfulResult> doQueryWf(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/", new object[] { info }, 0); List lt = new List(); //如果一次数据在当前过期时间外,则将数据设置为失效状态 if (rm.Succeed) { DateTime dtNow = DateTime.Now; if (rm.Data.list.Count > 0) { foreach (MeterWorkCarActualFirst meter in rm.Data.list) { if (meter.createTime.Value.AddHours(PbCache.isEndHour).CompareTo(dtNow) < 0) { doUpdateWf(new MeterWorkCarActualFirst { actualFirstNo = meter.actualFirstNo, valueFlag = "0", updateTime = dtNow, updateManName = "超期未使用" }); } else if (meter.baseSpotNo != "00018") //由于车辆可能在计量了吊钩秤后,几天才去回皮,还得让这个车进行其它作业任务 { lt.Add(meter); } } } } RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (lt != null && lt.Count > 0) { result.Data = rm.Data.list; } return result; } public RESTfulResult> doQueryListLike(MeterBaseMatterInfo info) { DbHelper db = new DbHelper(); RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/like/", new object[] { info }, 1); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (rm.Data != null && rm.Data.list != null && rm.Data.list.Count > 0) { result.Data = rm.Data.list; } return result; } /// /// 按车号查询最近的一条计量实绩数据 /// /// /// public RESTfulResult> doQueryByCarNo(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); info.pageNum = 1; info.pageSize = 3; RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/", new object[] { info }, 0); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (rm != null && rm.Data != null & rm.Data.list != null && rm.Data.list.Count > 0) { result.Data = rm.Data.list; } return result; } /// /// 按车号查询最近的一条计量实绩数据 /// /// /// public RESTfulResult> doQueryOrderByTime(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); info.pageNum = 1; info.pageSize = 3; RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/queryOrderByTime", new object[] { info }, 0); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (rm != null && rm.Data != null & rm.Data.list != null && rm.Data.list.Count > 0) { result.Data = rm.Data.list; } return result; } /// /// 按车号查询最近的一条计量实绩数据 /// /// /// public RESTfulResult> doLikeQuery(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); info.pageNum = 1; info.pageSize = 3; RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/queryOrderByTime", new object[] { info }, 0); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (rm != null && rm.Data != null & rm.Data.list != null && rm.Data.list.Count > 0) { result.Data = rm.Data.list; } return result; } /// /// 按车号查询查询计量时间及期限皮重时间:按照时间进行排序 /// /// /// public RESTfulResult> queryForTimeInterval(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); RESTfulResult> rm = db.doOption>("meterworkcaractualfirsts", "/queryForTimeInterval", new object[] { info }, 1); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (rm != null && rm.Data != null & rm.Data != null && rm.Data.Count > 0) { result.Data = rm.Data; } return result; } /// /// 修改 /// /// /// public RESTfulResult doUpdateWf(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doUpdateWf", new object[] { info }, 1); return rm; } /// /// 新增 /// /// MeterWorkCarActualFirst /// MeterWorkPreLink /// 只有一车的互锁需要传值 "1" isLock 1互锁 其它为非互锁 /// 0 不保存历史皮,1保存历史皮 /// public RESTfulResult doAddWf(MeterWorkCarActualFirst info, MeterWorkPreLink link, MeterMonitorNote monitorNote, string isLock, string saveTare) { if (info.weightType == "0" && PbCache.unloadTimes != null) { MeterBaseUnloadTime mbut = PbCache.unloadTimes.Where(s => s.loadPointNo == info.loadPointNo && s.baseSpotNo == info.baseSpotNo).FirstOrDefault(); if (mbut != null) { info.loadEndTime = info.createTime.Value.AddMinutes(mbut.loadTime.Value); } } DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = info; pbSomeModel.two = link; pbSomeModel.sOne = isLock; pbSomeModel.sTwo = saveTare; pbSomeModel.four = monitorNote; if (info != null && string.IsNullOrEmpty(info.createManNo)) { info.createManNo = info.baseSpotNo; info.createManName = info.baseSpotName; } //RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddWf", new object[] { info, link, isLock, saveTare }, 1); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 结净 /// /// MeterWorkCarActualFirst /// MeterWorkCarActual /// MeterWorkPreLink /// 只有一车的互锁需要传值 "1" isLock 1互锁 其它为非互锁 /// 0 不保存历史皮,1保存历史皮 /// public RESTfulResult doAddNetWf(MeterWorkCarActualFirst secondDb, MeterWorkCarActual netDb, MeterWorkPreLink link, MeterMonitorNote monitorNote, string isLock, string saveTare) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = secondDb; pbSomeModel.two = netDb; pbSomeModel.three = link; pbSomeModel.sOne = isLock; pbSomeModel.sTwo = saveTare; pbSomeModel.four = monitorNote; if (secondDb != null && string.IsNullOrEmpty(secondDb.createManNo)) { secondDb.createManNo = secondDb.baseSpotNo; secondDb.createManName = secondDb.baseSpotName; } //RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetWf", new object[] { secondDb, netDb, link, isLock, saveTare }, 1); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 新增 /// /// MeterWorkCarActualFirst /// 0 不保存历史皮,1保存历史皮 /// public RESTfulResult doAddInnerWf(MeterWorkCarActualFirst info, MeterMonitorNote monitorNote, string saveTare) { if (info.weightType == "0" && PbCache.unloadTimes != null) { MeterBaseUnloadTime mbut = PbCache.unloadTimes.Where(s => s.loadPointNo == info.loadPointNo && s.baseSpotNo == info.baseSpotNo).FirstOrDefault(); if (mbut != null) { info.loadEndTime = info.createTime.Value.AddMinutes(mbut.loadTime.Value); } } DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = info; pbSomeModel.four = monitorNote; pbSomeModel.sOne = saveTare; if (info != null && string.IsNullOrEmpty(info.createManNo)) { info.createManNo = info.baseSpotNo; info.createManName = info.baseSpotName; } //RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddInnerWf", new object[] { info, saveTare }, 1); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddInnerWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 结净 /// /// MeterWorkCarActualFirst /// MeterWorkCarActual /// 0 不保存历史皮,1保存历史皮 /// public RESTfulResult doAddNetInnerWf(MeterWorkCarActualFirst secondDb, MeterWorkCarActual netDb, MeterMonitorNote monitorNote, string saveTare) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = secondDb; pbSomeModel.two = netDb; pbSomeModel.sOne = saveTare; pbSomeModel.four = monitorNote; if (secondDb != null && string.IsNullOrEmpty(secondDb.createManNo)) { secondDb.createManNo = secondDb.baseSpotNo; secondDb.createManName = secondDb.baseSpotName; } //RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetInnerWf", new object[] { secondDb, netDb, saveTare }, 1); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetInnerWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 根据预报编号查数据 /// /// /// public RESTfulResult doQRCodeWf(string strCode) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "encryptionForWeb", new object[] { new QRModel { str = strCode } }, 1); return rm; } public RESTfulResult doAddNetByTermWf(MeterWorkCarActualFirst first, MeterWorkCarActual netDb, MeterMonitorNote monitorNote) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = first; pbSomeModel.two = netDb; pbSomeModel.three = monitorNote; if (first != null && string.IsNullOrEmpty(first.createManNo)) { first.createManNo = first.baseSpotNo; first.createManName = first.baseSpotName; } RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetByTermWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 联达保存毛重 /// /// /// /// public RESTfulResult doAddLianDaWf(MeterWorkCarActualFirst mwaf, MeterMonitorNote monitorNote) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = mwaf; pbSomeModel.two = monitorNote; if (mwaf != null && string.IsNullOrEmpty(mwaf.createManNo)) { mwaf.createManNo = mwaf.baseSpotNo; mwaf.createManName = mwaf.baseSpotName; } RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddLianDaWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 联达保存皮重 /// /// /// /// /// public RESTfulResult doAddNetLianDaWf(MeterWorkCarActualFirst secondDb, MeterWorkCarActual netDb, MeterMonitorNote monitorNote) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = secondDb; pbSomeModel.two = netDb; pbSomeModel.three = monitorNote; if (secondDb != null && string.IsNullOrEmpty(secondDb.createManNo)) { secondDb.createManNo = secondDb.baseSpotNo; secondDb.createManName = secondDb.baseSpotName; } RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doAddNetLianDaWf", new object[] { pbSomeModel }, 1); return rm; } public RESTfulResult doCraneDbWf(MeterWorkCarActualFirst first, MeterMonitorNote monitorNote) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = first; pbSomeModel.two = monitorNote; RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doCraneDbWf", new object[] { pbSomeModel }, 1); return rm; } public RESTfulResult doCraneNetDbWf(MeterWorkCarActualFirst first, MeterWorkCarActual netDb, MeterMonitorNote monitorNote) { DbHelper db = new DbHelper(); PbSomeModel pbSomeModel = new PbSomeModel(); pbSomeModel.one = first; pbSomeModel.two = netDb; pbSomeModel.three = monitorNote; RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "doCraneNetDbWf", new object[] { pbSomeModel }, 1); return rm; } /// /// 根据预报编号查数据 /// /// /// public RESTfulResult> doQueryDefault(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); RESTfulResult>> rm = db.doOption>>("meterworkcaractualfirsts", "/", new object[] { info }, 0); List lt = new List(); RESTfulResult> result = new RESTfulResult>(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; if (lt != null && lt.Count > 0) { result.Data = rm.Data.list; } return result; } //多条件模糊查询 自带自定义状态 public RESTfulResult> doQueryAndMultiple(CommonPage info) { DbHelper db = new DbHelper(); RESTfulResult> rm = db.doOption>("meterworkcaractualfirsts", "doQueryAndMultiple", new object[] { info }, 1); return rm; } public RESTfulResult addEmergency(List meterWorkCarActualFirsts) { DbHelper db = new DbHelper(); RESTfulResult rm = db.doOption("meterworkcaractualfirsts", "/addEmergency", new object[] { meterWorkCarActualFirsts }, 1); RESTfulResult result = new RESTfulResult(); result.Succeed = rm.Succeed; result.Status = rm.Status; result.Message = rm.Message; result.ResultMessage = rm.ResultMessage; result.Code = rm.Code; result.Data = rm.Data; return rm; } #region JISCO特殊接口 By BourneCao 20220122 /// /// 按车号查询状态为未使用或使用中的计量实绩数据 /// /// /// public RESTfulResult> doQueryByFlag(MeterWorkCarActualFirst info) { DbHelper db = new DbHelper(); info.pageNum = 1; info.pageSize = 3; RESTfulResult> result = db.doOption>("meterworkcaractualfirsts", "/queryByFlag", new object[] { info }, 1); return result; } #endregion } public class QRModel { public string str { get; set; } } }