增加分割品入库

B3ClientService/B3ClientService.csproj

@@ -104,6 +104,7 @@
     <Compile Include="BO\Bill\WeightBill\WeightDetail.cs" />
     <Compile Include="BO\ClientGoodsSet_\ClientGoodsSet.cs" />
     <Compile Include="BO\ClientGoodsSet_\ClientGoodsSet_Detail.cs" />
+    <Compile Include="BO\SegmentationInStoreRecord_\SegmentationInStoreRecord.cs" />
     <Compile Include="BO\SegmentationWeightRecord_\SegmentationWeightRecord.cs" />
     <Compile Include="BO\SyncBase.cs" />
     <Compile Include="BO\SyncBill.cs" />
@@ -118,6 +119,7 @@
     <Compile Include="CTuple.cs" />
     <Compile Include="NamedValueTemplate.cs" />
     <Compile Include="Rpcs\BillRpc\ClientGoodsSetRpc.cs" />
+    <Compile Include="Rpcs\BillRpc\SegmentationInStoreRecordRpc.cs" />
     <Compile Include="Rpcs\BillRpc\SegmentationWeightRecordRpc.cs" />
     <Compile Include="Rpcs\RpcBO\Bill\ClientGoodsSetDto.cs" />
     <Compile Include="Rpcs\RpcBO\Bill\GradeAndWeight\GradeAndWeight.cs" />

B3ClientService/BO/SegmentationInStoreRecord_/SegmentationInStoreRecord.cs

@@ -0,0 +1,35 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Text;
+using BWP.B3Frameworks.BO;
+using Forks.EnterpriseServices.DomainObjects2;
+
+namespace BWP.B3ClientService.BO
+{
+  /// <summary>
+  /// 分割品入库
+  /// </summary>
+  [Serializable]
+  public  class SegmentationInStoreRecord:Base
+  {
+    private DateTime mCreateTime = DateTime.Now;
+
+    [DbColumn(DbType = SqlDbType.DateTime)]
+    public DateTime CreateTime { get { return mCreateTime; } set { mCreateTime = value; } }
+
+    public string BarCode { get; set; }//条码
+
+    public long Goods_ID { get; set; }
+    
+    public string Goods_Name { get; set; }
+
+    public string Goods_Spec { get; set; }
+    public decimal Weight { get; set; }
+   public long? Store_ID { get; set; }
+    public string Store_Name { get; set; }
+    public string CreateUserName { get; set; }
+
+  }
+}

B3ClientService/BO/SegmentationWeightRecord_/SegmentationWeightRecord.cs

@@ -9,6 +9,9 @@ using Forks.EnterpriseServices.DomainObjects2;
 namespace BWP.B3ClientService.BO
 {
 
+  /// <summary>
+  /// 分割品称重
+  /// </summary>
   [Serializable]
   public class SegmentationWeightRecord:Base
   {
@@ -32,5 +35,9 @@ namespace BWP.B3ClientService.BO
     public string CardBarCode { get; set; }//放产品的车的条码
 
     public string BiaoShi { get; set; }//用来记录那个工作台或者哪台触摸屏做的
+    public string CreateUserName { get; set; }
+
+    [DbColumn(DefaultValue = false)]
+    public bool IsInStored { get; set; }//是否已经入库
   }
 }

B3ClientService/Rpcs/BillRpc/SegmentationInStoreRecordRpc.cs

@@ -0,0 +1,38 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using BWP.B3ClientService.BO;
+using Forks.EnterpriseServices.DomainObjects2;
+using Forks.EnterpriseServices.DomainObjects2.DQuery;
+using Forks.EnterpriseServices.JsonRpc;
+using Newtonsoft.Json;
+
+namespace BWP.B3ClientService.Rpcs.BillRpc
+{
+
+  [Rpc]
+  public static class SegmentationInStoreRecordRpc
+  {
+    [Rpc]
+    public static long Insert(string json)
+    {
+      var dmo = JsonConvert.DeserializeObject<SegmentationInStoreRecord>(json);
+      using (var session=Dmo.NewSession())
+      {
+        UpdateWeightRecordInStored(session, dmo.BarCode);
+        session.Insert(dmo);
+        session.Commit();
+      }
+      return dmo.ID;
+    }
+
+    private static void UpdateWeightRecordInStored(IDmoSession session, string barCode)
+    {
+      var updateDom=new DQUpdateDom(typeof(SegmentationWeightRecord));
+      updateDom.Where.Conditions.Add(DQCondition.EQ("BarCode",barCode));
+      updateDom.Columns.Add(new DQUpdateColumn("IsInStored",true));
+      session.ExecuteNonQuery(updateDom);
+    }
+  }
+}

B3ClientService/Rpcs/BillRpc/SegmentationWeightRecordRpc.cs

@@ -4,8 +4,10 @@ using System.Linq;
 using System.Text;
 using BWP.B3ClientService.BO;
 using Forks.EnterpriseServices.DomainObjects2;
+using Forks.EnterpriseServices.DomainObjects2.DQuery;
 using Forks.EnterpriseServices.JsonRpc;
 using Newtonsoft.Json;
+using TSingSoft.WebPluginFramework;
 
 namespace BWP.B3ClientService.Rpcs.BillRpc
 {
@@ -24,5 +26,50 @@ namespace BWP.B3ClientService.Rpcs.BillRpc
       }
       return record.ID;
     }
+
+    /// <summary>
+    /// 获取为入库的
+    /// </summary>
+    /// <returns></returns>
+    [Rpc]
+    public static string GetNotInStoreList()
+    {
+      var query=new DmoQuery(typeof(SegmentationWeightRecord));
+      query.Where.Conditions.Add(DQCondition.EQ("IsInStored",false));
+      var list = query.EExecuteList().Cast<SegmentationWeightRecord>().ToList();
+      return JsonConvert.SerializeObject(list);
+    }
+
+    /// <summary>
+    /// 获取为入库的
+    /// </summary>
+    /// <returns></returns>
+    [Rpc]
+    public static string GetNotInStoreListByMaxId(long id)
+    {
+      var query = new DmoQuery(typeof(SegmentationWeightRecord));
+      query.Where.Conditions.Add(DQCondition.EQ("IsInStored", false));
+      query.Where.Conditions.Add(DQCondition.GreaterThan("ID", id));
+      var list = query.EExecuteList().Cast<SegmentationWeightRecord>().ToList();
+      return JsonConvert.SerializeObject(list);
+    }
+
+
+    /// <summary>
+    /// 批量 设置已入库
+    /// </summary>
+    /// <param name="json"></param>
+    /// <returns></returns>
+    [Rpc]
+    public static bool SetInStored(string json)
+    {
+      var list = JsonConvert.DeserializeObject<List<int>>(json);
+      var whereList = list.Select(x => DQExpression.Value(x)).ToArray();
+      var updateDom=new DQUpdateDom(typeof(SegmentationWeightRecord));
+      updateDom.Columns.Add(new DQUpdateColumn("IsInStored",true));
+      updateDom.Where.Conditions.Add(DQCondition.InList(DQExpression.Field("ID"),whereList));
+      updateDom.EExecute();
+      return true;
+    }
   }
 }