using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Http;
|
using System.Web.Http;
|
using WebAPI.Models;
|
|
namespace WebAPI.Controllers.仓存管理.委外用料
|
{
|
public class WW_PPBomBillController : ApiController
|
{
|
public DBUtility.ClsPub.Enum_BillStatus BillStatus;//单据状态（新增，修改，浏览，更新单价，变更）
|
private json objJsonResult = new json();
|
public DataSet ds = new DataSet();
|
public SQLHelper.ClsCN oCn = new SQLHelper.ClsCN();
|
public DLL.ClsWW_PPBomBill BillNew0 = new DLL.ClsWW_PPBomBill();
|
public DLL.ClsWW_PPBomBill BillOld0 = new DLL.ClsWW_PPBomBill();
|
|
#region 委外用料列表
|
|
[Route("WW_PPBomBillController/Get_WW_PPBomBillList")]
|
[HttpGet]
|
public object Get_WW_PPBomBillList(string sWhere,string user)
|
{
|
try
|
{
|
List<object> columnNameList = new List<object>(); //定义声明变量 ，把通过 new List<object>()创建的 实例，赋值给变量
|
//判断是否有查询权限
|
if (!DBUtility.ClsPub.Security_Log("WW_PPBomBill_Query", 1, false, user))
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "无查询权限!";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
|
ds = WW_PPBomBillList(sWhere);
|
|
|
if (ds.Tables[0].Rows.Count != 0 || ds != null)
|
{
|
foreach (DataColumn col in ds.Tables[0].Columns)//遍历ds中第一个表（Tables[0]）的所有列（Columns）每次循环中，col变量会持有当前列的引用
|
{
|
Type dataType = col.DataType; //获取当前数据类型传入 自定义变量datadataType
|
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}"; //字符串拼接 // 将列名和数据类型信息拼接成一个JSON格式的字符串
|
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
|
}
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "Sucess！";
|
objJsonResult.data = ds.Tables[0];//代码将第一个DataTable（索引为0）赋值给objJsonResult的data属性
|
objJsonResult.list = columnNameList;//将columnNameList赋值给objJsonResult的list属性
|
return objJsonResult;
|
}
|
else
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "无数据";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
catch (Exception ex)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "查询数据异常，请与管理员联系！" + ex.ToString();
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
|
public static DataSet WW_PPBomBillList(string sWhere)
|
{
|
string sql1 = string.Format(@"select * from h_v_WW_PPBomBillList where 1=1 ");
|
if (sWhere == null || sWhere.Equals(""))
|
{
|
return new SQLHelper.ClsCN().RunProcReturn(sql1 + sWhere + " order by hmainid desc", "h_v_WW_PPBomBillList");
|
}
|
else
|
{
|
string sql = sql1 + sWhere + " order by hmainid desc";
|
return new SQLHelper.ClsCN().RunProcReturn(sql, "h_v_WW_PPBomBillList");
|
}
|
|
}
|
|
|
|
#region 委外用料清单订单 金蝶同步
|
[Route("WW_PPBomBillController/SaveWW_PPBomBillApi")]
|
[HttpPost]
|
public object SaveWW_PPBomBillApi([FromBody] JObject sMainSub)
|
{
|
LogService.Write("开始同步");
|
try
|
{
|
LogService.Write($"接收到的完整数据: {sMainSub.ToString()}");
|
var model = sMainSub["model"].ToString();
|
var entry = sMainSub["model"]["HENTRY"].ToString();
|
model = "[" + model.ToString() + "]";
|
LogService.Write($"主表模型JSON: {model}");
|
LogService.Write($"子表模型JSON: {entry}");
|
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
|
ListModels oListModels = new ListModels();
|
List<ClsWW_PPBomBill> mainList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<ClsWW_PPBomBill>>(model);
|
List<ClsWW_PPBomBillSubERP> subList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<ClsWW_PPBomBillSubERP>>(entry);
|
// 添加类型检查日志
|
LogService.Write($"主表HInterID类型: {mainList[0].HInterID.GetType()}");
|
LogService.Write($"主表HInterID值: {mainList[0].HInterID}");
|
string sql = string.Empty;
|
LogService.Write($"主模型数据{mainList}");
|
LogService.Write($"子模型数据{subList}");
|
//保存
|
oCN.BeginTran();
|
int hInterID = mainList[0].HInterID;
|
LogService.Write($"开始处理 HInterID: {hInterID}");
|
|
string checkSql = $"SELECT COUNT(1) FROM WW_PPBomBillSub WHERE HInterID = {hInterID}";
|
LogService.Write($"检查子表数据是否存在: {checkSql}");
|
|
// 2. 删除子表数据
|
string deleteSubSql = $"DELETE FROM WW_PPBomBillSub WHERE HInterID = {hInterID}";
|
LogService.Write($"删除子表SQL: {deleteSubSql}");
|
oCN.RunProc(deleteSubSql, ref DBUtility.ClsPub.sExeReturnInfo);
|
LogService.Write("子表数据删除完成");
|
|
// 3. 删除主表数据
|
string deleteMainSql = $"DELETE FROM WW_PPBomBillMain WHERE HInterID = {hInterID}";
|
LogService.Write($"删除主表SQL: {deleteMainSql}");
|
oCN.RunProc(deleteMainSql, ref DBUtility.ClsPub.sExeReturnInfo);
|
LogService.Write("主表数据删除完成");
|
|
|
oCN.RunProc($@"insert into WW_PPBomBillMain
|
(HInterID,HYear,HPeriod,HBillType,HBillSubType,HDate
|
,HBillNo,HBillStatus,HICMOInterID,HICMOEntryID,HSUBBILLNO,HSUBREQENTRYSEQ
|
,HMaterID,HUnitID,HQty,HSupID,HDEPTID,HPOOrderBillNo,HPOOrderSeq
|
,HMaker,HMakeDate,HChecker,HCheckDate,HUpDater,HUpDateDate
|
,HSeOrderBillNo,HSeOrderInterID,HSeOrderEntryID,HSeOrderSEQ
|
,HPRDORGID,HENTRUSTORGID,HPARENTOWNERID,HPARENTOWNERTYPEID
|
,HERPInterID,HERPBillType,HSETTLEORGID,HREQSRC)
|
values({mainList[0].HInterID},'{mainList[0].HYear}','{mainList[0].HPeriod}','{mainList[0].HBillType}','{mainList[0].HBillSubType}','{mainList[0].HDate}','{mainList[0].HBillNo}'
|
,'{mainList[0].HBillStatus}','{mainList[0].HICMOInterID}','{mainList[0].HICMOEntryID}','{mainList[0].HSUBBILLNO}','{mainList[0].HSUBREQENTRYSEQ}','{mainList[0].HMaterID}',{mainList[0].HUnitID},'{mainList[0].HQty}','{mainList[0].HSupID}','{mainList[0].HDeptID}',
|
'{mainList[0].HPOOrderBillNo}','{mainList[0].HPOOrderSeq}','{mainList[0].HMaker}','{mainList[0].HMakeDate}','{mainList[0].HChecker}','{mainList[0].HCheckDate}','{mainList[0].HUpDater}','{mainList[0].HUpDateDate}','{mainList[0].HSeOrderBillNo}','{mainList[0].HSeOrderInterID}','{mainList[0].HSeOrderEntryID}','{mainList[0].HSeOrderSEQ}'
|
,'{mainList[0].HPRDORGID}','{mainList[0].HENTRUSTORGID}','{mainList[0].HPARENTOWNERID}'
|
,'{mainList[0].HPARENTOWNERTYPEID}','{mainList[0].HERPInterID}','{mainList[0].HERPBillType}','{mainList[0].HSETTLEORGID}','{mainList[0].HREQSRC}'
|
|
)", ref DBUtility.ClsPub.sExeReturnInfo);
|
LogService.Write("主表插入成功");
|
|
foreach (var oSub in subList)
|
{
|
var count = subList.Count();
|
LogService.Write($"子表数据条数为{count}");
|
//新增子表：
|
oCN.RunProc($@" insert into WW_PPBomBillSub
|
(HInterID,HEntryID,HMaterID,HUnitID,HQty,HQtyMust,HWHID,HRemark
|
,HSourceInterID,HSourceEntryID,HSourceBillNo,HSourceBillType
|
,HICMOInterID,HICMOEntryID,HICMOBillNo
|
,HCHILDSUPPLYORGID,HSUPPLYORGID,HENTRUSTPICKORGID,HSRCTRANSORGID,HGROUPBYOWNERID,HOWNERID,HOWNERTYPEID
|
,HRelationQty,HMoveStockQty,HAuxPropID,HBatchNO,HMTONo,HQtyScrap,HERPInterID,HERPEntryID
|
,HBackRelationQty
|
,HPROCESSID,HBASEUNITID,HPROJECTNO,HOPERID,HSEQ
|
,HSTOCKSTATUSID,HRESERVETYPE
|
)
|
values({oSub.HInterID},'{oSub.HEntryID}','{oSub.HMaterID}','{oSub.HUnitID}','{oSub.HQty}',{oSub.HQtyMust},'{oSub.HWHID}',
|
'{oSub.HRemark}','{oSub.HSourceInterID}','{oSub.HSourceEntryID}','{oSub.HSourceBillNo}','{oSub.HSourceBillType}',{oSub.HICMOInterID },'{oSub.HICMOEntryID}','{oSub.HICMOBillNo}','{oSub.HCHILDSUPPLYORGID}','{oSub.HSUPPLYORGID}'
|
,'{oSub.HENTRUSTPICKORGID}','{oSub.HSRCTRANSORGID}','{oSub.HGROUPBYOWNERID}','{oSub.HOWNERID}','{oSub.HOWNERTYPEID}','{oSub.HRelationQty}','{oSub.HMoveStockQty}','{oSub.HAuxPropID}','{oSub.HBatChNo}','{oSub.HMTONo}','{oSub.HQtyScrap}',
|
{oSub.HERPInterID},'{oSub.HERPEntryID}','{oSub.HBackRelationQty}','{oSub.HPROCESSID}',{oSub.HBASEUNITID },'{oSub.HPROJECTNO}','{oSub.HOPERID}','{oSub.HSEQ}','{oSub.HSTOCKSTATUSID}','{oSub.HRESERVETYPE}'
|
)", ref DBUtility.ClsPub.sExeReturnInfo);
|
}
|
LogService.Write("子表插入成功");
|
|
|
|
|
|
oCN.Commit();
|
|
|
|
|
|
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "保存成功！";
|
objJsonResult.data = 1;
|
return objJsonResult;
|
}
|
catch (Exception e)
|
{
|
LogService.Write("异常信息：" + e.ToString());
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "保存失败！" + e.ToString();
|
objJsonResult.data = 1;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
}
|
|
#endregion
|
}
|
