using Model;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Pub_Class;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Web.Http;
using System.Windows.Forms;
using WebAPI.Models;
using System.Web;
using WebAPI.Controllers.SCGL.日计划管理;
using System.IO;
using SyntacticSugar.constant;
namespace WebAPI.Controllers
{
public class Gy_DisposeWayController : ApiController
{
private json objJsonResult = new json();
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
DataSet ds;
///
/// 处理方案列表
///参数:string sql。
///返回值:object。
///
[Route("Gy_DisposeWay/list")]
[HttpGet]
public object list(string sWhere, string user)
{
try
{
List columnNameList = new List();
//查看权限
if (!DBUtility.ClsPub.Security_Log("Gy_DisposeWay_Query", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无查看权限!";
objJsonResult.data = null;
return objJsonResult;
}
if (sWhere == null || sWhere.Equals(""))
{
ds = oCN.RunProcReturn("select * from h_v_Gy_DisposeWayList order by HItemID ", "h_v_Gy_DisposeWayList");
}
else
{
string sql1 = "select * from h_v_Gy_DisposeWayList where 1 = 1 ";
string sql = sql1 + sWhere + " order by HItemID ";
ds = oCN.RunProcReturn(sql, "h_v_Gy_DisposeWayList");
}
//添加列名
foreach (DataColumn col in ds.Tables[0].Columns)
{
Type dataType = col.DataType;
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
}
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "Sucess!";
objJsonResult.data = ds.Tables[0];
objJsonResult.list = columnNameList;
return objJsonResult;
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
///
/// 处理方案列表
///参数:string sql。
///返回值:object。
///
[Route("Gy_DisposeWay/Gy_DisposeWay_Edit")]
[HttpGet]
public object Gy_DisposeWay_Edit(string HID, string user)
{
try
{
List columnNameList = new List();
//查看权限
if (!DBUtility.ClsPub.Security_Log("Gy_DisposeWay_Query", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无查看权限!";
objJsonResult.data = null;
return objJsonResult;
}
string sql = "select * from h_v_Gy_DisposeWayList where 1 = 1 and HItemID="+HID;
ds = oCN.RunProcReturn(sql, "h_v_Gy_DisposeWayList");
if (ds.Tables[0].Rows.Count != 0 && ds != null)
{
//添加列名
foreach (DataColumn col in ds.Tables[0].Columns)
{
Type dataType = col.DataType;
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
}
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "Sucess!";
objJsonResult.data = ds.Tables[0];
objJsonResult.list = columnNameList;
return objJsonResult;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "没有查询到数据!";
objJsonResult.data = ds.Tables[0];
objJsonResult.list = columnNameList;
return objJsonResult;
}
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
///
/// 保存按钮
///参数:string sql。
///返回值:object。
///
[Route("Gy_DisposeWay/ModifyByID")]
[HttpPost]
public object ModifyByID([FromBody] JObject oMain)
{
try
{
DAL.ClsGy_DisposeWay_Ctl oBill = new DAL.ClsGy_DisposeWay_Ctl();
var _value = oMain["oMain"].ToString();
string msg1 = _value.ToString();
string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
string msg2 = sArray[0].ToString();
string user = sArray[1].ToString();//用户名
//判断是否有编辑权限
if (!DBUtility.ClsPub.Security_Log("Gy_DisposeWay_Edit", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无权限编辑!";
objJsonResult.data = null;
return objJsonResult;
}
//反序列化
msg2 = "[" + msg2.ToString() + "]";
List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2);
long HItemID = list[0].HItemID;
foreach (Model.ClsGy_DisposeWay_Model oItem in list)
{
oItem.HMakeEmp = user;
oBill.oModel = oItem;
}
//保存
bool bResult;
//保存完毕后处理
if (HItemID == 0)
{
bResult = oBill.AddNew( ref DBUtility.ClsPub.sExeReturnInfo);
}
else
{
bResult = oBill.ModifyByID(HItemID, ref DBUtility.ClsPub.sExeReturnInfo);
}
if (bResult)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "保存成功!";
objJsonResult.data = 1;
return objJsonResult;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败!" + DBUtility.ClsPub.sExeReturnInfo;
objJsonResult.data = 1;
return objJsonResult;
}
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception!" + e.Message;
objJsonResult.data = null;
return objJsonResult;
}
}
///
/// 处理方案列表删除功能
///
///
[Route("Gy_DisposeWay/DeltetGy_DisposeWay")]
[HttpGet]
public object DeltetGy_DisposeWay(string HItemID, string user)
{
DataSet ds;
DataSet ds1;
try
{
//删除权限
if (!DBUtility.ClsPub.Security_Log("Gy_DisposeWay_Delete", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无删除权限!";
objJsonResult.data = null;
return objJsonResult;
}
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
if (string.IsNullOrWhiteSpace(HItemID))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "HItemID为空!";
objJsonResult.data = null;
return objJsonResult;
}
oCN.BeginTran();//开始事务
ds = oCN.RunProcReturn("select * from Gy_DisposeWay where HItemID=" + HItemID, "Gy_DisposeWay");
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "没有数据,无法删除!";
objJsonResult.data = null;
return objJsonResult; ;
}
string HUseFlag = Convert.ToString(ds.Tables[0].Rows[0]["HUseFlag"]);
if (HUseFlag == "已使用")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "此项目已使用,不能删除!";
objJsonResult.data = null;
return objJsonResult;
}
//删除前控制=========================================
string sql1 = "exec h_p_Gy_DisposeWay_BeforeDelCtrl " + HItemID + ",'" + user + "'";
ds = oCN.RunProcReturn(sql1, "h_p_Gy_DisposeWay_BeforeDelCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "删除失败!原因:删除前判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "删除失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.RunProc("delete from Gy_DisposeWay where HItemID=" + HItemID);
//删除后控制=========================================
string sql2 = "exec h_p_Gy_DisposeWay_AfterDelCtrl " + HItemID + ",'" + user + "'";
ds = oCN.RunProcReturn(sql2, "h_p_Gy_DisposeWay_AfterDelCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "删除失败!原因:删除后判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "删除失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.Commit();//提交事务
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "* 数据删除成功!";
objJsonResult.data = null;
return objJsonResult; ;
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "删除失败!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#region 处理方案审核、反审核
///
///
///
/// 单据ID
/// 审核(0),反审核(1)
/// 审核人
///
[Route("Gy_DisposeWay/AuditGy_DisposeWay")]
[HttpGet]
public object AuditGy_DisposeWay(int HInterID, int IsAudit, string CurUserName)
{
try
{
//审核权限
if (!DBUtility.ClsPub.Security_Log_second("Gy_DisposeWay_Check", 1, false, CurUserName))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "审核失败!无权限!";
objJsonResult.data = null;
return objJsonResult;
}
var ds = oCN.RunProcReturn("select * from Gy_DisposeWay where HItemID=" + HInterID, "Gy_DisposeWay");
if (ds.Tables[0].Rows.Count > 0)
{
if (IsAudit == 0) //审核判断
{
if (ds.Tables[0].Rows[0]["HCheckEmp"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据已审核!不能再次审核!";
objJsonResult.data = null;
return objJsonResult;
}
}
if (IsAudit == 1) //反审核判断
{
if (ds.Tables[0].Rows[0]["HCheckEmp"].ToString() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据未审核!不需要反审核!";
objJsonResult.data = null;
return objJsonResult;
}
}
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据不存在!";
objJsonResult.data = null;
return objJsonResult;
}
oCN.BeginTran();
if (IsAudit == 0) //审核判断
{
//审核前控制=========================================
string sql1 = "exec h_p_Gy_DisposeWay_BeforeCheckCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql1, "h_p_Gy_DisposeWay_BeforeCheckCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "审核失败!原因:审核前判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "审核失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.RunProc("update Gy_DisposeWay set HCheckEmp='" + CurUserName + "',HCheckTime=getdate() where HItemID=" + HInterID);
//审核后控制=========================================
string sql2 = "exec h_p_Gy_DisposeWay_AfterCheckCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql2, "h_p_Gy_DisposeWay_AfterCheckCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "审核失败!原因:审核后判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "审核失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "审核成功";
objJsonResult.data = null;
}
if (IsAudit == 1) //反审核判断
{
//反审核前控制=========================================
string sql1 = "exec h_p_Gy_DisposeWay_BeforeUnCheckCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql1, "h_p_Gy_DisposeWay_BeforeCheckCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反审核失败!原因:反审核前判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反审核失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.RunProc("update Gy_DisposeWay set HCheckEmp='',HCheckTime=null where HItemID=" + HInterID);
//反审核后控制=========================================
string sql2 = "exec h_p_Gy_DisposeWay_AfterUnCheckCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql2, "h_p_Gy_DisposeWay_AfterCheckCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反审核失败!原因:反审核后判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反审核失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "反审核成功";
objJsonResult.data = null;
}
oCN.Commit();
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "审核失败或者反审核失败!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 处理方案禁用、反禁用
///
///
///
/// 单据ID
/// 禁用(0),反禁用(1)
/// 审核人
///
[Route("Gy_DisposeWay/StopGy_DisposeWay")]
[HttpGet]
public object StopGy_DisposeWay(int HInterID, int IsStop, string CurUserName)
{
try
{
//审核权限
if (!DBUtility.ClsPub.Security_Log_second("Gy_DisposeWay_Stop", 1, false, CurUserName))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "禁用失败!无权限!";
objJsonResult.data = null;
return objJsonResult;
}
var ds = oCN.RunProcReturn("select * from Gy_DisposeWay where HItemID=" + HInterID, "Gy_DisposeWay");
if (ds.Tables[0].Rows.Count > 0)
{
if (IsStop == 0) //禁用判断
{
if (ds.Tables[0].Rows[0]["HStopEmp"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据已禁用!不能再次禁用!";
objJsonResult.data = null;
return objJsonResult;
}
}
if (IsStop == 1) //反禁用判断
{
if (ds.Tables[0].Rows[0]["HStopEmp"].ToString() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据未禁用!不需要反禁用!";
objJsonResult.data = null;
return objJsonResult;
}
}
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据不存在!";
objJsonResult.data = null;
return objJsonResult;
}
oCN.BeginTran();
if (IsStop == 0) //禁用判断
{
//禁用前控制=========================================
string sql1 = "exec h_p_Gy_DisposeWay_BeforeStopCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql1, "h_p_Gy_DisposeWay_BeforeStopCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "禁用失败!原因:禁用前判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.RunProc("update Gy_DisposeWay set HStopEmp='" + CurUserName + "',HStopTime=getdate(),HStopflag=1 where HItemID=" + HInterID);
//禁用后控制=========================================
string sql2 = "exec h_p_Gy_DisposeWay_AfterStopCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql2, "h_p_Gy_DisposeWay_AfterStopCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "禁用失败!原因:禁用后判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "禁用成功";
objJsonResult.data = null;
}
if (IsStop == 1) //反禁用判断
{
//反禁用前控制=========================================
string sql1 = "exec h_p_Gy_DisposeWay_BeforeUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql1, "h_p_Gy_DisposeWay_BeforeUnStopCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反禁用失败!原因:反禁用前判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
oCN.RunProc("update Gy_DisposeWay set HStopEmp='',HStopTime=null,HStopflag=0 where HItemID=" + HInterID);
//反禁用后控制=========================================
string sql2 = "exec h_p_Gy_DisposeWay_AfterUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
ds = oCN.RunProcReturn(sql2, "h_p_Gy_DisposeWay_AfterUnStopCtrl");
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反禁用失败!原因:反禁用后判断失败,请与网络管理人员联系";
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
objJsonResult.data = null;
oCN.RollBack();
return objJsonResult;
}
//==================================================================================
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "反禁用成功";
objJsonResult.data = null;
}
oCN.Commit();
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "禁用失败或者反禁用失败!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 处理方案 文件导入保存
#region 处理方案 文件上传
[Route("Gy_DisposeWay/Gy_DisposeWay_Excel")]
[HttpPost]
public object Gy_DisposeWay_Excel()
{
try
{
//获取文件名称
var file = HttpContext.Current.Request.Files[0];
//获取文件物理路径
string ExcelPath = HttpContext.Current.Server.MapPath("~/" + file.FileName);
//保存文件
file.SaveAs(ExcelPath);
NpoiHelper np = new NpoiHelper();
DataSet ExcelDs = np.ReadExcel(ExcelPath, 1, 1, "0");
//删除文件
File.Delete(ExcelPath);
//创建临时表
DataTable tb2 = new DataTable("dt2");
//添加列名
for (int i = 0; i < ExcelDs.Tables[0].Columns.Count; i++)
{
tb2.Columns.Add(ExcelDs.Tables[0].Rows[0][i].ToString());
}
//模板缺少列 但需要从数据库中查询出来显示在页面的字段
tb2.Columns.Add("HOrgID", typeof(Int32));//组织ID
//添加数据
for (int i = 1; i < ExcelDs.Tables[0].Rows.Count; i++)
{
DataRow row = tb2.NewRow();
for (int j = 0; j < ExcelDs.Tables[0].Columns.Count; j++)
{
row[j] = ExcelDs.Tables[0].Rows[i][j].ToString();
}
tb2.Rows.Add(row);
}
var error = "";
//查询没有的列
if (!tb2.Columns.Contains("组织代码"))
error += "没有找到【组织代码】的标题,";
if (!tb2.Columns.Contains("组织名称"))
error += "没有找到【组织名称】的标题,";
if (!tb2.Columns.Contains("处理方案"))
error += "没有找到【处理方案名称】的标题,";
if (!tb2.Columns.Contains("处理方案代码"))
error += "没有找到【处理方案代码】的标题,";
if (!tb2.Columns.Contains("备注"))
error += "没有找到【备注】的标题,";
if (!tb2.Columns.Contains("助记码"))
error += "没有找到【助记码】的标题,";
if (error.Length > 0)
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = $"Excel模板存在错误,{error}\r\n";
objJsonResult.data = null;
return objJsonResult;
}
for (int i = 0; i <= tb2.Rows.Count - 1; i++)
{
string HProcessName = "";
string HProcessNum = "";
string HORGNumber = "";
string HORGName = "";
HProcessName = DBUtility.ClsPub.isStrNull(tb2.Rows[i]["处理方案"].ToString());
HProcessNum = DBUtility.ClsPub.isStrNull(tb2.Rows[i]["处理方案代码"].ToString());
HORGNumber = DBUtility.ClsPub.isStrNull(tb2.Rows[i]["组织代码"].ToString());
HORGName = DBUtility.ClsPub.isStrNull(tb2.Rows[i]["组织名称"].ToString());
//检查物料
int index = i + 1;
if (HORGNumber != "")
{
//查询组织
ds = oCN.RunProcReturn("select * from Xt_ORGANIZATIONS where HNumber='" + HORGNumber + "' and Hname='" + HORGName + "'", "Xt_ORGANIZATIONS");
if (ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "第" + index + "行,组织不存在!";
objJsonResult.data = null;
return objJsonResult;
}
else
{
tb2.Rows[i]["HOrgID"] = ds.Tables[0].Rows[0]["HItemID"].ToString();
}
string HORGid = ds.Tables[0].Rows[0]["HItemID"].ToString();
//处理方案名称
if (HProcessName == "")
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "第" + index + "行,处理方案名称不能为空!";
objJsonResult.data = null;
return objJsonResult;
}
//处理方案代码
if (HProcessNum == "")
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "第" + index + "行,处理方案代码不能为空!";
objJsonResult.data = null;
return objJsonResult;
}
}
else
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "第" + index + "行,组织代码为空";
objJsonResult.data = null;
return objJsonResult;
}
}
objJsonResult.code = CodeConstant.SUCCEED;
objJsonResult.count = CountConstant.SUCCEED;
objJsonResult.Message = error;
objJsonResult.data = tb2;
return objJsonResult;
}
catch (Exception e)
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "Exception!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 处理方案项目 导入(保存)
[Route("Gy_DisposeWay/Gy_DisposeWay_btnSave")]
[HttpPost]
public object Gy_DisposeWay_btnSave([FromBody] JObject sMainSub)
{
var _value = sMainSub["sMainSub"].ToString();
string msg1 = _value.ToString();
string[] sArray = msg1.Split(new string[] { "&和" }, StringSplitOptions.RemoveEmptyEntries);
string msg2 = sArray[0].ToString();
string user = sArray[1].ToString();
try
{
if (!DBUtility.ClsPub.Security_Log("Gy_DisposeWay_Edit", 1, false, user))
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "无保存权限!";
objJsonResult.data = null;
return objJsonResult;
}
List Excel = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2);
List> list = new List>();
foreach (JObject item in Excel)
{
Dictionary dic = new Dictionary();
foreach (var itm in item.Properties())
{
dic.Add(itm.Name, itm.Value.ToString());
}
list.Add(dic);
}
oCN.BeginTran();
int i = 1;
foreach (Dictionary item in list)
{
string HOrgID = item["HOrgID"].ToString();//组织ID
string HName = item["处理方案"].ToString();
string HNumber = item["处理方案代码"].ToString();
string HRemark = item["备注"].ToString();
string HHelpCode = item["助记码"].ToString();
string HUseFlag = "未检测";
string HShortNumber;
HShortNumber = DBUtility.ClsPub.GetShortNumber(HNumber);//短代码
if (HShortNumber.Trim() == "")
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "保存失败!短代码为空!";
objJsonResult.data = 1;
return objJsonResult;
}
int HEndFlag = 1;//末级标志
int HLevel = DBUtility.ClsPub.GetLevel(HNumber); //等级
if (!DBUtility.ClsPub.AllowNumber(HNumber.Trim()))
{
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "保存失败!代码中不能出现连续‘.’并且首位末位不能为‘.’!";
objJsonResult.data = 1;
return objJsonResult;
}
ds = oCN.RunProcReturn("select * from Gy_DisposeWay where HNumber='" + HNumber + "'", "Gy_DisposeWay");
if (ds.Tables[0].Rows.Count == 0)
{
oCN.RunProc("Insert into " + "Gy_DisposeWay" +
" (HNumber,HName,HHelpCode,HShortNumber,HParentID" +
",HLevel,HEndFlag,HStopflag,HRemark,HUseFlag,HUSEORGID,HCREATEORGID,HMakeEmp,HMakeTime) " +
" Values('" + HNumber + "','" + HName + "','" + HHelpCode + "','" + HShortNumber + "'," + 0 +
"," + HLevel + "," + HEndFlag + "," + 0 + ",'" + HRemark + "','" + HUseFlag + "'," + HOrgID + "," + HOrgID + ",'" + user + "',GETDATE()" + ")");
}
else
{
oCN.RunProc("Update " + "Gy_DisposeWay" + " set " +
"HName='" + HName + "'" +
",HShortNumber='" + HShortNumber + "'" +
",HHelpCode='" + HHelpCode + "'" +
",HLevel=" + HLevel +
",HModifyEmp='" + user + "'" +
",HModifyTime=GETDATE()" +
",HRemark= '" + HRemark + "' Where HNumber='" + HNumber + "'");
}
i++;
}
oCN.Commit();
objJsonResult.code = CodeConstant.SUCCEED;
objJsonResult.count = CountConstant.SUCCEED;
objJsonResult.Message = "导入成功!";
objJsonResult.data = null;
return objJsonResult;
}
catch (Exception e)
{
LogService.Write(e);
objJsonResult.code = CodeConstant.FAIL;
objJsonResult.count = CountConstant.FAIL;
objJsonResult.Message = "Exception!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#endregion
}
}