增加上传取件码

Store.SyncLogistics/Services/VirtualLogisticsService.cs

@@ -181,9 +181,46 @@ public class VirtualLogisticsService : ITransientDependency
 	/// <summary>
 	/// 上传取件码
 	/// </summary>
-	public Result<List<PickupResultItem>> UploadPickup(List<PickupItem> data)
+	public bool UploadPickup(string userName, string orderId, string pickupCode)
 	{
-		return _api.UploadPickup(data);
+		var user = _userService.GetUserByUserName(userName);
+		if (user == null) throw new Exception("错误的账号");
+		var syncLogistics = _freeSql.Select<YhSyncLogisticsEntity>()
+			.Where(a => a.OrderId == orderId)
+			.First();
+		if (syncLogistics == null) throw new Exception("错误的订单号");
+
+		var ret = _api.UploadPickup(new List<PickupItem>
+		{
+			new PickupItem
+			{
+				BufaSn = syncLogistics.SourceTrackingNumber,
+				PickupCode = pickupCode
+			}
+		});
+		syncLogistics.pickup_code = pickupCode;
+		syncLogistics.upload_pickup_Time = DateTime.Now;
+		syncLogistics.upload_pickup_status = ret.Success;
+		if (ret.Success == false)
+		{
+			string msg = $"推送取件码失败：{ret.Msg}";
+			syncLogistics.Remark = msg;
+			_logger.Error(msg);
+			throw new Exception("推送取件码失败");
+		}
+		var affrows = _freeSql.Update<YhSyncLogisticsEntity>()
+			.Set(a => a.pickup_code, syncLogistics.pickup_code)
+			.Set(a => a.upload_pickup_Time, syncLogistics.upload_pickup_Time)
+			.Set(a => a.upload_pickup_status, syncLogistics.upload_pickup_status)
+			.Set(a => a.Remark, syncLogistics.Remark)
+			.Where(a => a.Id == syncLogistics.Id)
+			.ExecuteAffrows();
+		if (affrows != 1)
+		{
+			_logger.Error("取件码保存错误");
+			throw new Exception("取件码保存错误");
+		}
+		return true;
 	}
 
 	public YhSyncLogisticsEntity GetSyncLogistics(string orderId)