新供应商 数据恢复 升级exe优化
This commit is contained in:
wule committed
1 parent
456b0534e3
commit
dcb82684f4
13 files changed
+419
-21
No files matched your search
@@ -0,0 +1,48 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Web;
|
||||
|
||||
namespace KJD_Web.Model.WxModel
|
||||
{
|
||||
public class distrib_return_order_info
|
||||
{
|
||||
/// <summary>
|
||||
/// 退货主订单唯一ID
|
||||
/// </summary>
|
||||
public long id { get; set; }
|
||||
public string order_code { get; set; } // varchar 255 退货订单编码
|
||||
public string order_code_source { get; set; } // varchar 255 原始订单来源编码
|
||||
public string logistics_code { get; set; } // varchar 50 物流系统编码（如SF、ZTO）
|
||||
public string logistics_express_no { get; set; } // varchar 100 物流单号
|
||||
public string platform { get; set; } // varchar 50 中转仓平台来源（如OTHER、JD、PDD）
|
||||
public string shop_name { get; set; } // varchar 255 店铺名称
|
||||
public string sender_name { get; set; } // varchar 100 发件人姓名（冗余字段，便于快速查询，不依赖JSON解析）
|
||||
public string sender_phone { get; set; } // varchar 20 发件人电话（冗余字段，便于快速查询，不依赖JSON解析）
|
||||
public string sender_info { get; set; } // json 发货人信息（JSON格式：姓名、电话、省市区地址）
|
||||
public string receiver_name { get; set; } // varchar 100 收货人姓名
|
||||
public string receiver_phone { get; set; } // varchar 20 收货人电话
|
||||
public string receiver_province { get; set; } // varchar 100 收货省份
|
||||
public string receiver_city { get; set; } // varchar 100 收货城市
|
||||
public string receiver_area { get; set; } // varchar 100 收货区县
|
||||
public string receiver_address { get; set; } // 收货详细地址
|
||||
public DateTime created_at { get; set; } // 记录创建时间
|
||||
public DateTime updated_at { get; set; } // 记录更新时间
|
||||
public DateTime warehouse_in_time { get; set; } // 入库时间（仓库接收退货商品的时间）
|
||||
public DateTime warehouse_out_time { get; set; } // 出库时间（仓库发出补货或处理后商品的时间）
|
||||
public int? warehouse_status { get; set; } // 出入库状态：0待处理、1已入库、2创建异常、3处理中
|
||||
public int? return_order_status { get; set; } // 退货订单创建与处理状态
|
||||
public int? first_weight_fee { get; set; } // 首重费用
|
||||
public int? additional_weight_fee { get; set; } // 超重费用
|
||||
public int? order_void_status { get; set; } // 订单作废状态：0=正常，1=已作废，2=作废失败
|
||||
public string real_logistics_code { get; set; } // 255 下游物流公司
|
||||
public string real_logistics_express_code { get; set; } // 255 下游物流单号
|
||||
public string response_msg { get; set; } //
|
||||
public string ext_field1 { get; set; } // 备用扩展字段1
|
||||
public string ext_field2 { get; set; } // 备用扩展字段2
|
||||
public string platform_code { get; set; } // 退货订单平台来源
|
||||
public string platform_order_no { get; set; } // 平台订单号
|
||||
public string after_sale_no { get; set; } // 售后单号
|
||||
public int? postage { get; set; } // 订单初始费用（分）
|
||||
}
|
||||
}
|
||||
@@ -53,23 +53,25 @@ namespace KJD_Web
|
||||
[WebMethod]
|
||||
public void repair_miss_direct_order()
|
||||
{
|
||||
return;
|
||||
string conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
|
||||
MysqlUtils mySql = new MysqlUtils(conn);
|
||||
|
||||
//var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE add_time > '2026-08-15 15:30' AND buy_type = '直发'";
|
||||
|
||||
//var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE add_time > '2026-08-10 15:30' AND add_time < '2026-08-15 15:30' buy_type = '直发'";
|
||||
var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE order_id in ('3738460213351447040') AND buy_type = '直发'";
|
||||
//var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE add_time > '2026-08-13 15:30' AND add_time < '2026-08-15 15:30' And buy_type = '直发'";
|
||||
var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE add_time > '2026-08-10 15:30' AND add_time < '2026-08-12 15:30' And buy_type = '直发'";
|
||||
//var s = "SELECT order_id,out_order_id FROM `wxxd`.`order_item_ext` WHERE order_id in ('3738460213351447040') AND buy_type = '直发'";
|
||||
var dt1 = mySql.ExecuteDataTable(s);
|
||||
s = "Select order_id FROM erp.oms_wei_order WHERE order_id in ('" + string.Join("','", dt1.Rows.Cast<System.Data.DataRow>().Select(r => r["order_id"].ParseToLong()))+ "') and out_order_no is null";
|
||||
//out_order_no //out_express_no //out_shipped=0
|
||||
s = " Select order_id FROM erp.oms_wei_order WHERE order_id in ('" + string.Join("','", dt1.Rows.Cast<System.Data.DataRow>().Select(r => r["order_id"].ParseToLong()))+ "') " +
|
||||
" and out_order_no is null";
|
||||
dt1 = mySql.ExecuteDataTable(s);
|
||||
|
||||
mySql.Close();
|
||||
|
||||
conn = System.Configuration.ConfigurationManager.ConnectionStrings["ConnKJD"].ConnectionString;
|
||||
mySql = new MysqlUtils(conn);
|
||||
string sql = "Select * FROM wxxd.order_pdd_buyer_order WHERE wx_order_id in ('" + string.Join("','", dt1.Rows.Cast<System.Data.DataRow>().Select(r => r["order_id"].ParseToLong())) + "')";
|
||||
string sql = "Select * FROM wxxd.order_pdd_buyer_order WHERE wx_order_id in ('" + string.Join("','", dt1.Rows.Cast<System.Data.DataRow>().Select(r => r["order_id"].ParseToLong())) + "') And wx_send_type=1";
|
||||
var dt = mySql.ExecuteDataTable(sql);
|
||||
List<Model.WxModel.order_pdd_buyer_order> buyerOrderList = new List<Model.WxModel.order_pdd_buyer_order>();
|
||||
mySql.Close();
|
||||
@@ -113,17 +115,47 @@ namespace KJD_Web
|
||||
//46
|
||||
foreach (var pddOrder in buyerOrderList)
|
||||
{
|
||||
//if (!pddOrder.outExpressCompanyCode.IsNullOrEmpty() && !pddOrder.tracking_number.IsNullOrEmpty())
|
||||
// continue;
|
||||
|
||||
bool isSend = false;
|
||||
|
||||
if (!pddOrder.outExpressCompanyCode.IsNullOrEmpty() && !pddOrder.tracking_number.IsNullOrEmpty())
|
||||
{
|
||||
mySql = new MysqlUtils(conn);
|
||||
var sqlStr = " Select status FROM erp.oms_wei_order WHERE order_id in ('" + pddOrder.wx_order_id + "')";
|
||||
var status = mySql.ExecuteFirstInt(sqlStr);
|
||||
if (status > 20)
|
||||
{
|
||||
isSend = true;
|
||||
//sqlStr = "update `erp`.`oms_wei_order` set out_express_company='" + pddOrder.outExpressCompanyCode + "',out_express_no='" + pddOrder.tracking_number +
|
||||
// "' WHERE order_id = '" + pddOrder.wx_order_id + "'";
|
||||
}
|
||||
|
||||
|
||||
sqlStr = "update `erp`.`oms_wei_order` set out_express_company='" + pddOrder.outExpressCompanyCode + "',out_express_no='" + pddOrder.tracking_number +
|
||||
"' WHERE order_id = '" + pddOrder.wx_order_id + "'";
|
||||
var rows = mySql.ExecuteAffectedRows(sqlStr);
|
||||
|
||||
|
||||
mySql.Close();
|
||||
if (!mySql.Message.IsNullOrEmpty())
|
||||
continue;
|
||||
}
|
||||
|
||||
Newtonsoft.Json.Linq.JObject obj = new Newtonsoft.Json.Linq.JObject();
|
||||
obj["platform"] = "WEISHOP";
|
||||
obj["outAmount"] = (pddOrder.order_amount.ParseToDecimal()).ParseToInt() + "";
|
||||
obj["outAccount"] = pddOrder.buyerName;
|
||||
obj["orderId"] = pddOrder.wx_order_id;
|
||||
obj["outOrderNo"] = pddOrder.order_sn;
|
||||
//if (!order.outExpressCompanyCode.IsNullOrEmpty() && !order.tracking_number.IsNullOrEmpty())
|
||||
//{
|
||||
// obj["outExpressCompany"] = order.outExpressCompanyCode;
|
||||
// obj["outExpressNo"] = order.tracking_number;
|
||||
//}
|
||||
if (!isSend && !pddOrder.outExpressCompanyCode.IsNullOrEmpty() && !pddOrder.tracking_number.IsNullOrEmpty())
|
||||
{
|
||||
obj["outExpressCompany"] = pddOrder.outExpressCompanyCode;
|
||||
obj["outExpressNo"] = pddOrder.tracking_number;
|
||||
}
|
||||
|
||||
|
||||
var dataStr = JsonUtils.SerializeObject(obj);
|
||||
var url = "https://po.e57.cn/prod-api/api/oms-api/external_procurement/bind/v2";
|
||||
//成功 "<ResultVo><code>0</code><msg>SUCCESS</msg><data/><totalRecords/></ResultVo>"
|
||||
@@ -134,6 +166,8 @@ namespace KJD_Web
|
||||
{
|
||||
err += "\r\n" + pddOrder.order_sn + " " + exportRst;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in new issue
Block a user