lpf
/
CNCEC_SUBQHSE_WUHUAN
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
CNCEC_SUBQHSE_WUHUAN/SGGL/BLL/ZHGL/RealName/SynchroSetService.cs

1516 lines
77 KiB
C#
Raw Normal View History

20210430
2021-04-30 10:28:37 +08:00
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Net;
namespace BLL
{
public class SynchroSetService
{
/// <summary>
/// 根据主键获取同步设置
/// </summary>
/// <param name="SynchroSetId"></param>
/// <returns></returns>
public static Model.RealName_SynchroSet GetSynchroSetById(string SynchroSetId)
{
return Funs.DB.RealName_SynchroSet.FirstOrDefault(e => e.SynchroSetId == SynchroSetId);
}
/// <summary>
/// 根据单位ID获取同步设置
/// </summary>
/// <param name="SynchroSetId"></param>
/// <returns></returns>
public static Model.RealName_SynchroSet GetSynchroSetByUnitId(string unitId, string proCode)
{
//return Funs.DB.RealName_SynchroSet.FirstOrDefault(e => e.UnitId == unitId);
if (!string.IsNullOrEmpty(proCode))
{
return Funs.DB.RealName_SynchroSet.FirstOrDefault(e => e.UnitId == unitId && e.ProCode == proCode);
}
else
{
return Funs.DB.RealName_SynchroSet.FirstOrDefault(e => e.UnitId == unitId);
}
}
#region 国家基础数据下拉框
/// <summary>
/// 表下拉框
/// </summary>
/// <param name="dropName">下拉框名字</param>
/// <param name="isShowPlease">是否显示请选择</param>
public static void InitCountryDropDownList(FineUIPro.DropDownList dropName, bool isShowPlease)
{
dropName.DataValueField = "CountryId";
dropName.DataTextField = "Cname";
dropName.DataSource = (from x in Funs.DB.RealName_Country orderby x.Cname select x).ToList();
dropName.DataBind();
if (isShowPlease)
{
Funs.FineUIPleaseSelect(dropName);
}
}
#endregion
#region 项目基础数据下拉框
/// <summary>
/// 表下拉框
/// </summary>
/// <param name="dropName">下拉框名字</param>
/// <param name="isShowPlease">是否显示请选择</param>
public static void InitProjectDropDownList(FineUIPro.DropDownList dropName, bool isShowPlease)
{
dropName.DataValueField = "ProCode";
dropName.DataTextField = "ProName";
dropName.DataSource = (from x in Funs.DB.RealName_Project
orderby x.ProCode
select x).ToList();
dropName.DataBind();
if (isShowPlease)
{
Funs.FineUIPleaseSelect(dropName);
}
}
#endregion
#region 同步设置 数据维护
/// <summary>
///
/// </summary>
/// <param name="SynchroSet"></param>
public static void SaveSynchroSet(Model.RealName_SynchroSet SynchroSet)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
var getSynchroSet = db.RealName_SynchroSet.FirstOrDefault(e => e.UnitId == SynchroSet.UnitId && e.ProCode == SynchroSet.ProCode);
if (getSynchroSet != null)
{
getSynchroSet.ApiUrl = Funs.RealNameApiUrl;
getSynchroSet.ClientId = SynchroSet.ClientId;
getSynchroSet.UserName = SynchroSet.UserName;
getSynchroSet.Password = SynchroSet.Password;
getSynchroSet.Timestamp = SynchroSet.Timestamp;
getSynchroSet.ProCode = SynchroSet.ProCode;
if (!string.IsNullOrEmpty(SynchroSet.Token))
{
getSynchroSet.Token = SynchroSet.Token;
getSynchroSet.Tokenendtime = SynchroSet.Tokenendtime;
}
getSynchroSet.Intervaltime = SynchroSet.Intervaltime;
db.SubmitChanges();
}
else
{
SynchroSet.SynchroSetId = SQLHelper.GetNewID();
db.RealName_SynchroSet.InsertOnSubmit(SynchroSet);
db.SubmitChanges();
}
}
}
/// <summary>
/// 根据主键删除同步设置
/// </summary>
/// <param name="SynchroSetId"></param>
public static void DeleteSynchroSetById(string SynchroSetId)
{
Model.SGGLDB db = Funs.DB;
Model.RealName_SynchroSet SynchroSet = db.RealName_SynchroSet.FirstOrDefault(e => e.SynchroSetId == SynchroSetId);
if (SynchroSet != null)
{
db.RealName_SynchroSet.DeleteOnSubmit(SynchroSet);
db.SubmitChanges();
}
}
/// <summary>
/// 根据主键删除同步设置
/// </summary>
/// <param name="SynchroSetId"></param>
public static void DeleteSynchroSetByUnitId(string unitId)
{
Model.SGGLDB db = Funs.DB;
Model.RealName_SynchroSet SynchroSet = db.RealName_SynchroSet.FirstOrDefault(e => e.UnitId == unitId);
if (SynchroSet != null)
{
db.RealName_SynchroSet.DeleteOnSubmit(SynchroSet);
db.SubmitChanges();
}
}
#endregion
#region 获取access_token信息
/// <summary>
/// 获取凭证
/// </summary>
/// <returns></returns>
public static string getaccess_token(string proCode)
{
string access_token = string.Empty;
20210906
2021-09-06 12:27:07 +08:00
Model.RealName_SynchroSet getToken = new Model.RealName_SynchroSet();
if (!string.IsNullOrEmpty(proCode))
{
getToken = Funs.DB.RealName_SynchroSet.FirstOrDefault(x => x.ProCode == proCode);
}
else
{
getToken = Funs.DB.RealName_SynchroSet.FirstOrDefault(x => x.Tokenendtime > DateTime.Now);
}
20210430
2021-04-30 10:28:37 +08:00
if (getToken != null)
{
if (getToken.Tokenendtime > DateTime.Now)
{
access_token = getToken.Token;
}
else
{
access_token = SaveToken(getToken);
}
}
return access_token;
}
/// <summary>
/// 获取access_token信息
/// </summary>
/// <param name="url"></param>
/// <returns></returns>
public static string SaveToken(Model.RealName_SynchroSet SynchroSet)
{
try
{
string access_token = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string clientId = SynchroSet.ClientId;
string userName = SynchroSet.UserName;
string password = Funs.EncryptionPassword(SynchroSet.Password);
string timestamp = string.Format("{0:yyyy-MM-dd HH:mm:ss}", DateTime.Now.AddMinutes(-2));
string sign = Funs.EncryptionPassword(clientId + userName + password + timestamp);
var getToken = new
{
clientId,
userName,
password,
timestamp,
sign
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string contenttype = "application/json;charset=utf-8";
pushContent= JsonConvert.SerializeObject(getToken);
var returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/auth/accessToken", "POST", contenttype, null,pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
if (obj["success"] != null && Convert.ToBoolean(obj["success"].ToString()))
{
access_token = obj["data"].ToString();
SynchroSet.Token = access_token;
SynchroSet.Tokenendtime = DateTime.Now.AddHours(23);
SynchroSet.Timestamp = Funs.GetNewDateTime(timestamp);
SaveSynchroSet(SynchroSet);
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, SynchroSet.ProCode, "获取凭证", obj["success"].ToString(), obj["code"].ToString(), obj["message"].ToString(),access_token, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, SynchroSet.ProCode, "获取凭证", "False", "", returndata, access_token, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
}
else
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, SynchroSet.ProCode, "获取凭证", "False", "", "获取凭证失败", access_token, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
return access_token;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, " 获取access_token信息", "SynchroSetService.SaveToken");
return "";
}
}
#endregion
#region 实名制推送记录日志
/// <summary>
/// 实名制推送记录日志
/// </summary>
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
public static void InsertRealNamePushLog(string ProjectId, string JTProjectCode, string PushType, string Success, string Code, string Message, string ReturnData, string PushContent)
20210430
2021-04-30 10:28:37 +08:00
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
Model.RealName_PushLog newLog = new Model.RealName_PushLog
{
PushLogId = SQLHelper.GetNewID(),
ProjectId = ProjectId,
20210708
2021-07-08 20:34:29 +08:00
ProjectCode = JTProjectCode,
20210430
2021-04-30 10:28:37 +08:00
PushType = PushType,
Success = Success,
Code = Code,
Message = Message,
PushTime = DateTime.Now,
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
ReturnData = ReturnData,
PushContent = PushContent,
20210430
2021-04-30 10:28:37 +08:00
};
db.RealName_PushLog.InsertOnSubmit(newLog);
db.SubmitChanges();
}
}
#endregion
#region 获取基础字典数据
/// <summary>
/// 获取基础字典数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string getBasicData(string type)
{
try
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/baseData/getDict";
var dictTypeCode = new
{
dictTypeCode = type
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(null) }
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(dictTypeCode);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
if (Convert.ToBoolean(obj["success"].ToString()))
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
JArray arr = JArray.Parse(data);
20210430
2021-04-30 10:28:37 +08:00
foreach (var item in arr)
{
string dictCode = item["dictCode"].ToString();
string name = item["dictName"].ToString();
if (!string.IsNullOrEmpty(name) && !string.IsNullOrEmpty(dictCode))
{
var getBasicData = db.RealName_BasicData.FirstOrDefault(x => x.DictCode == dictCode && x.DictTypeCode == type);
if (getBasicData != null)
{
getBasicData.DictName = name;
db.SubmitChanges();
}
else
{
Model.RealName_BasicData newBasicData = new Model.RealName_BasicData
{
BasicDataId = SQLHelper.GetNewID(),
DictTypeCode = type,
DictCode = dictCode,
DictName = name
};
db.RealName_BasicData.InsertOnSubmit(newBasicData);
db.SubmitChanges();
}
if (type == "LAB_WORK_TYPE")
{
var getWorkPost = Funs.DB.Base_WorkPost.FirstOrDefault(x => x.WorkPostCode == dictCode);
if (getWorkPost == null)
{
Model.Base_WorkPost newWorkPost = new Model.Base_WorkPost
{
WorkPostId = SQLHelper.GetNewID(),
WorkPostCode = dictCode,
WorkPostName = name,
PostType = "3",
Remark = "来源实名制系统"
};
Funs.DB.Base_WorkPost.InsertOnSubmit(newWorkPost);
Funs.DB.SubmitChanges();
}
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, null, "获取基础字典[" + type + "]", sucess, code, mess,data,pushContent);
20210430
2021-04-30 10:28:37 +08:00
return mess;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, "获取基础字典", "SynchroSetService.getBasicData");
return "";
}
}
#endregion
#region 获取国家字典数据
/// <summary>
/// 获取基础字典数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string getCountry()
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/baseData/getCountry";
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(null) }
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
};
20210430
2021-04-30 10:28:37 +08:00
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, null);
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
if (Convert.ToBoolean(obj["success"].ToString()))
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
JArray arr = JArray.Parse(data);
20210430
2021-04-30 10:28:37 +08:00
foreach (var item in arr)
{
string countryId = item["countryId"].ToString();
string cname = item["cname"].ToString();
string name = item["name"].ToString();
if (!string.IsNullOrEmpty(countryId))
{
var getCountry = db.RealName_Country.FirstOrDefault(x => x.CountryId == countryId);
if (getCountry != null)
{
getCountry.Cname = cname;
getCountry.Name = name;
db.SubmitChanges();
}
else
{
Model.RealName_Country newCountry = new Model.RealName_Country
{
ID = SQLHelper.GetNewID(),
CountryId = countryId,
Cname = cname,
Name = name
};
db.RealName_Country.InsertOnSubmit(newCountry);
db.SubmitChanges();
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, null, "获取国家数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
return mess;
}
#endregion
#region 获取省份字典数据
/// <summary>
/// 获取基础字典数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string getCity(string countryId)
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/baseData/getCity";
var getCountrys = from x in db.RealName_Country where countryId == null || x.CountryId == countryId select x;
foreach (var citem in getCountrys)
{
var country = new
{
countryId = citem.CountryId
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(null) }
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(country);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken,pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
if (Convert.ToBoolean(obj["success"].ToString()))
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
JArray arr = JArray.Parse(data);
20210430
2021-04-30 10:28:37 +08:00
foreach (var item in arr)
{
string provinceCode = item["provinceCode"].ToString();
string cityCode = item["cityCode"].ToString();
string cname = item["cname"].ToString();
string cnShortName = item["cnShortName"].ToString();
string name = item["name"].ToString();
if (!string.IsNullOrEmpty(provinceCode))
{
var getCity = db.RealName_City.FirstOrDefault(x => x.CountryId == citem.CountryId && x.ProvinceCode == provinceCode);
if (getCity == null)
{
Model.RealName_City newCity = new Model.RealName_City
{
ID = SQLHelper.GetNewID(),
CountryId = citem.CountryId,
ProvinceCode = provinceCode,
CityCode = cityCode,
Cname = cname,
CnShortName = cnShortName,
Name = name
};
db.RealName_City.InsertOnSubmit(newCity);
db.SubmitChanges();
}
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, null, "获取省份数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
return mess;
}
#endregion
#region 获取项目数据
/// <summary>
/// 获取项目数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
20210708
2021-07-08 20:34:29 +08:00
public static string getProject(string proCode)
{
20210430
2021-04-30 10:28:37 +08:00
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/baseData/getProjectList";
Hashtable newToken = new Hashtable
{
20210708
2021-07-08 20:34:29 +08:00
{ "token", getaccess_token(proCode) }
20210430
2021-04-30 10:28:37 +08:00
};
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, null);
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
if (Convert.ToBoolean(obj["success"].ToString()))
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
JArray arr = JArray.Parse(data);
20210430
2021-04-30 10:28:37 +08:00
foreach (var item in arr)
{
20210830
2021-08-30 21:49:56 +08:00
string JTproCode = item["proCode"].ToString();
20210430
2021-04-30 10:28:37 +08:00
string proName = item["proName"].ToString();
string proShortName = item["proShortName"].ToString();
if (!string.IsNullOrEmpty(proCode))
{
20210708
2021-07-08 20:34:29 +08:00
var getProject = Funs.DB.RealName_Project.FirstOrDefault(x => x.ProCode == proCode);
20210430
2021-04-30 10:28:37 +08:00
if (getProject != null)
{
getProject.ProName = proName;
getProject.ProShortName = proShortName;
20210830
2021-08-30 21:49:56 +08:00
getProject.JTproCode = JTproCode;
20210708
2021-07-08 20:34:29 +08:00
Funs.DB.SubmitChanges();
20210430
2021-04-30 10:28:37 +08:00
}
else
{
Model.RealName_Project newProject = new Model.RealName_Project
{
ID = SQLHelper.GetNewID(),
ProCode = proCode,
20210830
2021-08-30 21:49:56 +08:00
JTproCode=JTproCode,
20210430
2021-04-30 10:28:37 +08:00
ProName = proName,
ProShortName = proShortName
};
20210708
2021-07-08 20:34:29 +08:00
Funs.DB.RealName_Project.InsertOnSubmit(newProject);
Funs.DB.SubmitChanges();
20210430
2021-04-30 10:28:37 +08:00
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "获取项目数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
return mess;
}
#endregion
#region 获取施工队字典数据
/// <summary>
/// 获取基础字典数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string getCollTeam(string proCode)
{
try
{
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/baseData/getCollTeam";
var getProjects = from x in Funs.DB.RealName_Project where proCode == null || x.ProCode == proCode select x;
foreach (var citem in getProjects)
{
var getProject = new
{
20210906
2021-09-06 12:27:07 +08:00
proCode = RealName_ProjectService.GeJTproCodeByproCode(citem.ProCode),
20210430
2021-04-30 10:28:37 +08:00
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(citem.ProCode) }
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(getProject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
if (Convert.ToBoolean(obj["success"].ToString()))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
JArray arr = JArray.Parse(data);
20210430
2021-04-30 10:28:37 +08:00
foreach (var item in arr)
{
long? teamId = Funs.GetNewlong(item["teamId"].ToString());
string teamName = item["teamName"].ToString();
string teamLeaderName = item["teamLeaderName"].ToString();
string teamLeaderMobile = item["teamLeaderMobile"].ToString();
string thirdTeamCode = item["thirdTeamCode"].ToString();
if (teamId.HasValue)
{
var getCollTeam = db.RealName_CollTeam.FirstOrDefault(x => x.ProCode == citem.ProCode && x.TeamId == teamId);
if (getCollTeam == null)
{
Model.RealName_CollTeam newCollTeam = new Model.RealName_CollTeam
{
ID = SQLHelper.GetNewID(),
TeamId = teamId,
ProCode = citem.ProCode,
TeamName = teamName,
TeamLeaderName = teamLeaderName,
TeamLeaderMobile = teamLeaderMobile
};
db.RealName_CollTeam.InsertOnSubmit(newCollTeam);
db.SubmitChanges();
}
else
{
if (getCollTeam.TeamName != teamName || getCollTeam.TeamLeaderName != teamLeaderName)
{
getCollTeam.TeamName = teamName;
getCollTeam.TeamLeaderName = teamLeaderName;
getCollTeam.TeamLeaderMobile = teamLeaderMobile;
db.SubmitChanges();
}
}
var getTeamGroup = db.ProjectData_TeamGroup.FirstOrDefault(x => x.TeamGroupId == thirdTeamCode && (x.TeamId != teamId || x.TeamId == null));
if (getTeamGroup != null)
{
getTeamGroup.TeamId = teamId;
getTeamGroup.RealNamePushTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
}
else
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "获取施工队数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
}
else
{
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "获取施工队数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
}
return mess;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, "获取施工队数据", "SynchroSetService.getCollTeam");
return "";
}
}
#endregion
#region 推送参建企业数据
/// <summary>
/// 推送参建企业数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string PushCollCompany()
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/accept/collCompany";
var getUnit = (from x in db.Base_Unit
where !x.RealNamePushTime.HasValue && x.CollCropCode != null && x.CollCropCode != ""
select x).Take(200).ToList();
if (getUnit.Count() > 0)
{
var listObject = new
{
list = getUnit.Select(x => new { collCompanyName = x.UnitName, collCropCode = x.CollCropCode, isChina = x.IsChina })
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(null) }
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(listObject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (Convert.ToBoolean(obj["success"].ToString()))
{
foreach (var item in getUnit)
{
item.RealNamePushTime = DateTime.Now;
20210618
2021-06-18 20:37:07 +08:00
Funs.DB.SubmitChanges();
20210430
2021-04-30 10:28:37 +08:00
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, null, "推送参建企业数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
#endregion
#region 推送项目参建企业数据
/// <summary>
/// 推送项目参建企业数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static string PushProCollCompany(string proCode)
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/accept/proCollCompany";
var getProjectUnits = (from x in db.Project_ProjectUnit
join y in db.Base_Project on x.ProjectId equals y.ProjectId
20210708
2021-07-08 20:34:29 +08:00
join z in db.RealName_Project on y.JTProjectCode equals z.ProCode
20210430
2021-04-30 10:28:37 +08:00
join u in db.Base_Unit on x.UnitId equals u.UnitId
where z.ProCode != null && !x.RealNamePushTime.HasValue && x.UnitType != null
20210708
2021-07-08 20:34:29 +08:00
&& (proCode == null || y.JTProjectCode == proCode)
20210430
2021-04-30 10:28:37 +08:00
&& u.CollCropCode != null && u.CollCropCode != ""
select new
{
unitId=x.UnitId,
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
collCropCode = u.CollCropCode,
collCropType = db.Sys_Const.First(t => t.GroupId == ConstValue.Group_ProjectUnitType && t.ConstValue == x.UnitType).Remark,
entryTime = string.Format("{0:yyyy-MM-dd}", x.InTime),
exitTime = string.Format("{0:yyyy-MM-dd}", x.OutTime),
linkName = u.LinkName,
idcardType = u.IdcardType,
idcardNumber = u.IdcardNumber,
linkMobile = u.LinkMobile,
collCropStatus = u.CollCropStatus,
x.RealNamePushTime,
x.ProjectUnitId,
}).Take(200).ToList();
if (getProjectUnits.Count() > 0)
{
var listObject = new
{
list = getProjectUnits.Select(x => new { x.proCode, x.collCropCode, x.collCropType, x.entryTime, x.exitTime, x.linkName, x.idcardType, x.idcardNumber, x.linkMobile, x.collCropStatus, })
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(proCode) }
};
PushCollCompany(getProjectUnits.Select(x => x.unitId).Distinct().ToList(), newToken);
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(listObject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (Convert.ToBoolean(obj["success"].ToString()))
{
foreach (var item in getProjectUnits)
{
var getPUnit = db.Project_ProjectUnit.FirstOrDefault(x => x.ProjectUnitId == item.ProjectUnitId);
if (getPUnit != null)
{
getPUnit.RealNamePushTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "推送项目参建企业数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
/// <summary>
/// 推送参建企业数据
/// </summary>
/// <param name="type"></param>
/// <returns></returns>
public static void PushCollCompany(List<string> unitIdLists, Hashtable newToken)
{
Model.SGGLDB db = Funs.DB;
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/accept/collCompany";
var getUnit = (from x in db.Base_Unit
where unitIdLists.Contains(x.UnitId) && !x.RealNamePushTime.HasValue
select x).ToList();
if (getUnit.Count() > 0)
{
var listObject = new
{
list = getUnit.Select(x => new { collCompanyName = x.UnitName, collCropCode = x.CollCropCode, isChina = x.IsChina })
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
};
pushContent = JsonConvert.SerializeObject(listObject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (Convert.ToBoolean(obj["success"].ToString()))
{
foreach (var item in getUnit)
{
item.RealNamePushTime = DateTime.Now;
db.SubmitChanges();
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, null, "推送参建企业数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
}
#endregion
#region 推送项目部/施工队（以下简称施工队）数据
/// <summary>
/// 推送项目部/施工队（以下简称施工队）数据
/// </summary>
/// <returns></returns>
public static string PushCollTeam(string proCode)
{
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/accept/collTeam";
var getCollTeam = (from x in Funs.DB.ProjectData_TeamGroup
join y in Funs.DB.Base_Project on x.ProjectId equals y.ProjectId
20210708
2021-07-08 20:34:29 +08:00
join z in Funs.DB.RealName_Project on y.JTProjectCode equals z.ProCode
20210430
2021-04-30 10:28:37 +08:00
join u in Funs.DB.Base_Unit on x.UnitId equals u.UnitId
join s in Funs.DB.SitePerson_Person on x.GroupLeaderId equals s.PersonId into jonPerson
from s in jonPerson.DefaultIfEmpty()
where z.ProCode != null && !x.RealNamePushTime.HasValue && x.TeamTypeId != null
20210708
2021-07-08 20:34:29 +08:00
&& (proCode == null || y.JTProjectCode == proCode)
20210430
2021-04-30 10:28:37 +08:00
&& u.CollCropCode != null && u.CollCropCode != ""
select new
{
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
collCropCode = u.CollCropCode,
teamType = x.TeamTypeId,
teamName = x.TeamGroupName,
thirdTeamCode = x.TeamGroupId,
entryTime = string.Format("{0:yyyy-MM-dd}", x.EntryTime),
exitTime = string.Format("{0:yyyy-MM-dd}", x.ExitTime),
teamLeaderName = s.PersonName,
teamLeaderIdcardType = s.IdcardType,
teamLeaderIdcardNumber = s.IdentityCard,
teamLeaderMobile = s.Telephone,
x.RealNamePushTime,
x.TeamGroupId,
}).Take(200).ToList();
if (getCollTeam.Count() > 0)
{
var listObject = new
{
list = getCollTeam.Select(x => new { x.proCode, x.collCropCode, x.teamType, x.teamName, x.thirdTeamCode, x.entryTime, x.exitTime, x.teamLeaderName, x.teamLeaderIdcardType, x.teamLeaderIdcardNumber, x.teamLeaderMobile })
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(proCode) }
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(listObject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (obj["success"] != null && Convert.ToBoolean(obj["success"].ToString()))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
foreach (var item in getCollTeam)
{
var getTeamGroup = db.ProjectData_TeamGroup.FirstOrDefault(x => x.TeamGroupId == item.TeamGroupId);
if (getTeamGroup != null)
{
getTeamGroup.RealNamePushTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
}
20210909
2021-09-09 16:46:34 +08:00
InsertRealNamePushLog(null, proCode, "推送项目部/施工队", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
#endregion
#region 推送人员数据
/// <summary>
/// 推送人员数据
/// </summary>
/// <returns></returns>
public static string PushPersons(string type, string proCode,string identityCard)
{
try
{
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
var getData = (from x in Funs.DB.SitePerson_Person
join y in Funs.DB.Base_Project on x.ProjectId equals y.ProjectId
20210830
2021-08-30 21:49:56 +08:00
join z in Funs.DB.RealName_Project on y.JTProjectCode equals z.ProCode
20210906
2021-09-06 12:27:07 +08:00
join p in Funs.DB.Project_ProjectUnit on new { x.UnitId, x.ProjectId } equals new { p.UnitId, p.ProjectId }
20210430
2021-04-30 10:28:37 +08:00
join v in Funs.DB.ProjectData_TeamGroup on x.TeamGroupId equals v.TeamGroupId
join w in Funs.DB.Base_WorkPost on x.WorkPostId equals w.WorkPostId
20210906
2021-09-06 12:27:07 +08:00
where (identityCard == null || x.IdentityCard == identityCard)
20210909
2021-09-09 16:46:34 +08:00
&& y.JTProjectCode == proCode && z.JTproCode != null && x.IsCardNoOK ==true && v.TeamId.HasValue
&& ((type == Const.BtnModify && !x.RealNameUpdateTime.HasValue && x.RealNameAddTime.HasValue)
|| (type != Const.BtnModify && !x.RealNameAddTime.HasValue && x.IsUsed && !x.OutTime.HasValue
&& x.HeadImage != null && x.HeadImage.Length > 0))
20210906
2021-09-06 12:27:07 +08:00
&& p.UnitType != Const.ProjectUnitType_3 && p.UnitType != Const.ProjectUnitType_4
20210430
2021-04-30 10:28:37 +08:00
select new
{
name = x.PersonName,
20210816
2021-08-16 17:41:00 +08:00
idcardType = "SHENFEN_ZHENGJIAN",
20210430
2021-04-30 10:28:37 +08:00
idcardNumber = x.IdentityCard,
idcardStartDate = x.IdcardStartDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardStartDate) : null,
idcardEndDate = x.IdcardEndDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardEndDate) : null,
20210919 实名制同步身份证有效期 永久
2021-09-19 09:04:08 +08:00
idcardForever = "Y",
20210430
2021-04-30 10:28:37 +08:00
politicsStatus = x.PoliticsStatus,
eduLevel = x.EduLevel,
maritalStatus = x.MaritalStatus,
sex = (x.Sex == "2" ? "F" : "M"),
idcardAddress = x.IdcardAddress,
homeAddress = x.Address,
birthday = x.Birthday.HasValue ? string.Format("{0:yyyy-MM-dd}", x.Birthday) : null,
nation = x.Nation,
countryCode = x.CountryCode,
provinceCode = x.ProvinceCode,
//positiveIdcardImage = db.AttachFile.First(t => (x.PersonId + "#1") == t.ToKeyId).ImageByte,
//negativeIdcardImage = db.AttachFile.First(t => (x.PersonId + "#5") == t.ToKeyId).ImageByte,
headImage = x.HeadImage,
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
teamId = v.TeamId,
mobile = x.Telephone,
teamLeaderFlag = (v.GroupLeaderId == x.PersonId ? "Y" : "N"),
userType = ((w.PostType == "1" || w.PostType == "4") ? "LAB_USER_MANAGE" : "LAB_USER_BULIDER"),
workType = w.WorkPostCode,
20210906
2021-09-06 12:27:07 +08:00
isLeave = x.OutTime.HasValue ? "Y" : "N",
20210430
2021-04-30 10:28:37 +08:00
entryTime = x.InTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.InTime) : null,
exitTime = x.OutTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.OutTime) : null,
x.RealNameAddTime,
x.RealNameUpdateTime,
x.PersonId,
}).Take(200).ToList();
if (getData.Count() > 0)
{
string returndata = string.Empty;
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(proCode) }
};
if (type == Const.BtnModify)
{
var updatelistObject = new
{
list = getData.Select(x => new { x.name, x.idcardType, x.idcardNumber, x.idcardStartDate, x.idcardEndDate, x.idcardForever, x.politicsStatus, x.eduLevel, x.maritalStatus, x.sex, x.idcardAddress, x.homeAddress, x.birthday, x.nation, x.countryCode, x.provinceCode, x.proCode, x.teamId, x.mobile, x.teamLeaderFlag, x.userType, x.workType, x.isLeave, x.entryTime, x.exitTime })
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(updatelistObject);
returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/updatePersons", "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
var addlistObject = new
{
list = getData.Select(x => new { x.name, x.idcardType, x.idcardNumber, x.idcardStartDate, x.idcardEndDate, x.idcardForever, x.politicsStatus, x.eduLevel, x.maritalStatus, x.sex, x.idcardAddress, x.homeAddress, x.birthday, x.nation, x.countryCode, x.provinceCode, x.headImage, x.proCode, x.teamId, x.mobile, x.teamLeaderFlag, x.userType, x.workType, x.isLeave, x.entryTime, x.exitTime })
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(addlistObject);
returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/persons", "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (obj["success"] != null && Convert.ToBoolean(obj["success"].ToString()) )
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
foreach (var item in getData)
{
var getPerson = db.SitePerson_Person.FirstOrDefault(x => x.PersonId == item.PersonId);
if (getPerson != null)
{
if (!getPerson.RealNameAddTime.HasValue)
{
getPerson.RealNameAddTime = DateTime.Now;
}
getPerson.RealNameUpdateTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "推送人员数据", sucess, code, mess, data, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, "推送人员数据", "SynchroSetService.PushPersons");
return "";
}
}
/// <summary>
/// 推送人员数据
/// </summary>
/// <returns></returns>
public static string PushPersonsByIdentityCard(string type, string proCode, string identityCard)
{
try
{
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
string contenttype = "application/json;charset=unicode";
var getData = (from x in Funs.DB.SitePerson_Person
join y in Funs.DB.Base_Project on x.ProjectId equals y.ProjectId
20210906
2021-09-06 12:27:07 +08:00
join z in Funs.DB.RealName_Project on y.JTProjectCode equals z.ProCode
20210430
2021-04-30 10:28:37 +08:00
join v in Funs.DB.ProjectData_TeamGroup on x.TeamGroupId equals v.TeamGroupId
join w in Funs.DB.Base_WorkPost on x.WorkPostId equals w.WorkPostId
20210906
2021-09-06 12:27:07 +08:00
join p in Funs.DB.Project_ProjectUnit on new { x.UnitId,x.ProjectId } equals new { p.UnitId,p.ProjectId }
20210708
2021-07-08 20:34:29 +08:00
where x.IdentityCard == identityCard && y.JTProjectCode == proCode
20210909
2021-09-09 16:46:34 +08:00
&& v.TeamId.HasValue && z.JTproCode != null
&& ((type ==Const.BtnAdd && x.HeadImage != null && x.HeadImage.Length > 0) || (type == Const.BtnModify && x.RealNameAddTime.HasValue))
20210906
2021-09-06 12:27:07 +08:00
&& p.UnitType != Const.ProjectUnitType_3 && p.UnitType != Const.ProjectUnitType_4
20210430
2021-04-30 10:28:37 +08:00
select new
{
name = x.PersonName,
20210820
2021-08-20 10:00:34 +08:00
idcardType ="SHENFEN_ZHENGJIAN",
20210430
2021-04-30 10:28:37 +08:00
idcardNumber = x.IdentityCard,
idcardStartDate = x.IdcardStartDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardStartDate) : null,
idcardEndDate = x.IdcardEndDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardEndDate) : null,
20210919 实名制同步身份证有效期 永久
2021-09-19 09:04:08 +08:00
idcardForever = "Y",
20210430
2021-04-30 10:28:37 +08:00
politicsStatus = x.PoliticsStatus,
eduLevel = x.EduLevel,
maritalStatus = x.MaritalStatus,
sex = (x.Sex == "2" ? "F" : "M"),
idcardAddress = x.IdcardAddress,
homeAddress = x.Address,
birthday = x.Birthday.HasValue ? string.Format("{0:yyyy-MM-dd}", x.Birthday) : null,
nation = x.Nation,
countryCode = x.CountryCode,
provinceCode = x.ProvinceCode,
headImage = x.HeadImage,
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
teamId = v.TeamId,
mobile = x.Telephone,
teamLeaderFlag = (v.GroupLeaderId == x.PersonId ? "Y" : "N"),
userType = ((w.PostType == "1" || w.PostType == "4") ? "LAB_USER_MANAGE" : "LAB_USER_BULIDER"),
workType = w.WorkPostCode,
20210906
2021-09-06 12:27:07 +08:00
isLeave = x.OutTime.HasValue ? "Y" : "N",
20210430
2021-04-30 10:28:37 +08:00
entryTime = x.InTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.InTime) : null,
exitTime = x.OutTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.OutTime) : null,
x.RealNameAddTime,
x.RealNameUpdateTime,
x.PersonId,
}).ToList();
if (getData.Count() > 0)
{
string returndata = string.Empty;
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(proCode) }
};
if (type == Const.BtnModify)
{
var updatelistObject = new
{
list = getData.Select(x => new { x.name, x.idcardType, x.idcardNumber, x.idcardStartDate, x.idcardEndDate, x.idcardForever, x.politicsStatus, x.eduLevel, x.maritalStatus, x.sex, x.idcardAddress, x.homeAddress, x.birthday, x.nation, x.countryCode, x.provinceCode, x.proCode, x.teamId, x.mobile, x.teamLeaderFlag, x.userType, x.workType, x.isLeave, x.entryTime, x.exitTime })
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(updatelistObject);
returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/updatePersons", "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
else
{
var addlistObject = new
{
list = getData.Select(x => new { x.name, x.idcardType, x.idcardNumber, x.idcardStartDate, x.idcardEndDate, x.idcardForever, x.politicsStatus, x.eduLevel, x.maritalStatus, x.sex, x.idcardAddress, x.homeAddress, x.birthday, x.nation, x.countryCode, x.provinceCode, x.headImage, x.proCode, x.teamId, x.mobile, x.teamLeaderFlag, x.userType, x.workType, x.isLeave, x.entryTime, x.exitTime })
};
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(addlistObject);
returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/persons", "POST", contenttype, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
}
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (obj["success"] != null && Convert.ToBoolean(obj["success"].ToString()))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
foreach (var item in getData)
{
var getPerson = db.SitePerson_Person.FirstOrDefault(x => x.PersonId == item.PersonId);
if (getPerson != null)
{
if (!getPerson.RealNameAddTime.HasValue)
{
getPerson.RealNameAddTime = DateTime.Now;
}
getPerson.RealNameUpdateTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "推送人员数据", sucess, code, mess, data, pushContent);
20210909
2021-09-09 16:46:34 +08:00
if (data.Contains("已存在") || mess.Contains("已存在"))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
foreach (var item in getData)
{
if (data.Contains(item.idcardNumber) || mess.Contains(item.idcardNumber))
{
var getPerson = db.SitePerson_Person.FirstOrDefault(x => x.PersonId == item.PersonId);
if (getPerson != null)
{
if (!getPerson.RealNameAddTime.HasValue)
{
getPerson.RealNameAddTime = DateTime.Now;
}
db.SubmitChanges();
}
}
}
}
}
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, "推送人员数据", "SynchroSetService.PushPersons");
return "";
}
}
#endregion
#region 推送考勤数据
/// <summary>
/// 推送考勤数据
/// </summary>
/// <returns></returns>
public static string PushAttendance(string proCode)
{
try
{
string mess = string.Empty;
string sucess = string.Empty;
string code = string.Empty;
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
string data = string.Empty;
string pushContent = string.Empty;
20210430
2021-04-30 10:28:37 +08:00
//string contenttype = "application/json;charset=unicode";
string url = Funs.RealNameApiUrl + "/foreignApi/accept/attendance";
var getData = (from x in Funs.DB.RealName_PersonInOutNow
join p in Funs.DB.SitePerson_Person on x.PersonId equals p.PersonId
join v in Funs.DB.ProjectData_TeamGroup on p.TeamGroupId equals v.TeamGroupId
join r in Funs.DB.RealName_CollTeam on v.TeamId equals r.TeamId
20210830
2021-08-30 21:49:56 +08:00
join z in Funs.DB.RealName_Project on x.ProCode equals z.ProCode
20211011 考勤限制业主监理推送
2021-10-11 09:10:19 +08:00
join pu in Funs.DB.Project_ProjectUnit on new { x.UnitId, x.ProjectId } equals new { pu.UnitId, pu.ProjectId }
20210430
2021-04-30 10:28:37 +08:00
where x.IdcardNumber != null && x.IdcardType != null && x.ChangeTime.HasValue
&& (proCode == null || x.ProCode == proCode) && p.HeadImage != null && p.HeadImage.Length > 0
&& v.TeamId.HasValue && p.HeadImage != null && r.TeamId.HasValue
20210908 离职人员不上传实名制
2021-09-08 15:15:08 +08:00
&& p.IsCardNoOK ==true && z.JTproCode != null
&& (!p.OutTime.HasValue || p.OutTime > x.ChangeTime)
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
&& !x.RealNamePushTime.HasValue
20211011 考勤限制业主监理推送
2021-10-11 09:10:19 +08:00
&& pu.UnitType != Const.ProjectUnitType_3 && pu.UnitType != Const.ProjectUnitType_4
20210826
2021-08-26 11:26:04 +08:00
orderby x.ChangeTime descending
20210430
2021-04-30 10:28:37 +08:00
select new
{
p.PersonId,
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
name = x.Name,
idcardType = x.IdcardType,
idcardNumber = x.IdcardNumber,
checkType = x.CheckType,
checkTime = string.Format("{0:yyyy-MM-dd HH:mm:ss}", x.ChangeTime),
dierction = x.IsIn == true ? "JINCHANG_JINCHU" : "TUICHANG_JINCHU",
checkWay = x.CheckWay,
checkLocation = x.CheckLocation,
longitude = x.Longitude,
latitude = x.Latitude,
x.RealNamePushTime,
x.PersonInOutId,
v.TeamGroupId,
}).Take(200).ToList();
if (getData.Count() > 0)
{
var listObject = new
{
list = getData.Select(x => new { x.proCode, x.name, x.idcardType, x.idcardNumber, x.checkType, x.checkTime, x.dierction, x.checkWay, x.checkLocation, x.longitude, x.latitude })
};
Hashtable newToken = new Hashtable
{
{ "token", getaccess_token(proCode) }
};
addTeam(getData.Select(x => x.TeamGroupId).Distinct().ToList(), newToken);
getTeam(proCode, newToken);
addPerson(getData.Select(x => x.PersonId).Distinct().ToList(), newToken);
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
pushContent = JsonConvert.SerializeObject(listObject);
var returndata = BLL.APIGetHttpService.OutsideHttp(url, "POST", null, newToken, pushContent);
20210430
2021-04-30 10:28:37 +08:00
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
mess = obj["message"].ToString();
code = obj["code"].ToString();
sucess = obj["success"].ToString();
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
data = obj["data"].ToString();
20210430
2021-04-30 10:28:37 +08:00
if (obj["success"] != null && Convert.ToBoolean(obj["success"].ToString()))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
foreach (var item in getData)
{
var getPersonInOutNow = db.RealName_PersonInOutNow.FirstOrDefault(x => x.PersonInOutId == item.PersonInOutId);
if (getPersonInOutNow != null)
{
//getPersonInOutNow.RealNamePushTime = DateTime.Now;
db.RealName_PersonInOutNow.DeleteOnSubmit(getPersonInOutNow);
db.SubmitChanges();
}
}
}
}
}
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
InsertRealNamePushLog(null, proCode, "推送考勤数据", sucess, code, mess, data, pushContent);
20210909
2021-09-09 16:46:34 +08:00
if (data.Contains("无法入场") || mess.Contains("班组"))
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
{
foreach (var item in getData)
{
20210909
2021-09-09 16:46:34 +08:00
if (data.Contains(item.idcardNumber) || mess.Contains(item.idcardNumber))
20210908 实名制推送日志增加推送内容、返回数据字段
2021-09-08 19:13:25 +08:00
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
var getPersonInOutNow = db.RealName_PersonInOutNow.FirstOrDefault(x => x.IdcardNumber == item.idcardNumber);
if (getPersonInOutNow != null)
{
getPersonInOutNow.RealNamePushTime = DateTime.Now;
// db.RealName_PersonInOutNow.DeleteOnSubmit(getPersonInOutNow);
db.SubmitChanges();
}
}
}
}
}
20210430
2021-04-30 10:28:37 +08:00
}
else
{
mess = "没有符合条件的数据！";
}
return mess;
}
catch (Exception ex)
{
ErrLogInfo.WriteLog(ex, "推送考勤数据", "SynchroSetService.PushAttendance");
return "";
}
}
/// <summary>
///
/// </summary>
/// <param name="proCode"></param>
/// <param name="newToken"></param>
public static void getTeam(string proCode, Hashtable newToken)
{
var getProject = new
{
20210830
2021-08-30 21:49:56 +08:00
proCode = RealName_ProjectService.GeJTproCodeByproCode(proCode),
20210430
2021-04-30 10:28:37 +08:00
};
var returndata = BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/baseData/getCollTeam", "POST", null, newToken, JsonConvert.SerializeObject(getProject));
if (!string.IsNullOrEmpty(returndata))
{
JObject obj = JObject.Parse(returndata);
if (Convert.ToBoolean(obj["success"].ToString()))
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
JArray arr = JArray.Parse(obj["data"].ToString());
foreach (var item in arr)
{
long? teamId = Funs.GetNewlong(item["teamId"].ToString());
string teamName = item["teamName"].ToString();
string teamLeaderName = item["teamLeaderName"].ToString();
string teamLeaderMobile = item["teamLeaderMobile"].ToString();
string thirdTeamCode = item["thirdTeamCode"].ToString();
if (teamId.HasValue)
{
var getCollTeam = db.RealName_CollTeam.FirstOrDefault(x => x.ProCode == proCode && x.TeamId == teamId);
if (getCollTeam == null)
{
Model.RealName_CollTeam newCollTeam = new Model.RealName_CollTeam
{
ID = SQLHelper.GetNewID(),
TeamId = teamId,
ProCode = proCode,
TeamName = teamName,
TeamLeaderName = teamLeaderName,
TeamLeaderMobile = teamLeaderMobile
};
db.RealName_CollTeam.InsertOnSubmit(newCollTeam);
db.SubmitChanges();
}
var getTeamGroup = db.ProjectData_TeamGroup.FirstOrDefault(x => x.TeamGroupId == thirdTeamCode && (x.TeamId != teamId || x.TeamId == null));
if (getTeamGroup != null)
{
getTeamGroup.TeamId = teamId;
getTeamGroup.RealNamePushTime = DateTime.Now;
db.SubmitChanges();
}
}
}
}
}
}
}
/// <summary>
/// 推送 施工队
/// </summary>
public static void addTeam(List<string> teamGroupIds, Hashtable newToken)
{
var getCollTeam = (from x in Funs.DB.ProjectData_TeamGroup
join y in Funs.DB.Base_Project on x.ProjectId equals y.ProjectId
20210830
2021-08-30 21:49:56 +08:00
join z in Funs.DB.RealName_Project on y.JTProjectCode equals z.ProCode
20210430
2021-04-30 10:28:37 +08:00
join u in Funs.DB.Base_Unit on x.UnitId equals u.UnitId
join s in Funs.DB.SitePerson_Person on x.GroupLeaderId equals s.PersonId into jonPerson
from s in jonPerson.DefaultIfEmpty()
20210830
2021-08-30 21:49:56 +08:00
where teamGroupIds.Contains(x.TeamGroupId) && z.JTproCode != null
20210430
2021-04-30 10:28:37 +08:00
select new
{
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
collCropCode = u.CollCropCode,
teamType = x.TeamTypeId,
teamName = x.TeamGroupName,
thirdTeamCode = x.TeamGroupId,
entryTime = string.Format("{0:yyyy-MM-dd}", x.EntryTime),
exitTime = string.Format("{0:yyyy-MM-dd}", x.ExitTime),
teamLeaderName = s.PersonName,
teamLeaderIdcardType = s.IdcardType,
teamLeaderIdcardNumber = s.IdentityCard,
teamLeaderMobile = s.Telephone,
x.RealNamePushTime,
x.TeamGroupId,
}).ToList();
if (getCollTeam.Count() > 0)
{
var listObject = new
{
list = getCollTeam.Select(x => new { x.proCode, x.collCropCode, x.teamType, x.teamName, x.thirdTeamCode, x.entryTime, x.exitTime, x.teamLeaderName, x.teamLeaderIdcardType, x.teamLeaderIdcardNumber, x.teamLeaderMobile })
};
BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/collTeam", "POST", null, newToken, JsonConvert.SerializeObject(listObject));
}
}
/// <summary>
/// 推送人员
/// </summary>
/// <param name="personList"></param>
public static void addPerson(List<string> personList, Hashtable newToken)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
var getData = (from x in db.SitePerson_Person
join y in db.Base_Project on x.ProjectId equals y.ProjectId
20210906
2021-09-06 12:27:07 +08:00
join z in db.RealName_Project on y.JTProjectCode equals z.ProCode
20210430
2021-04-30 10:28:37 +08:00
join v in db.ProjectData_TeamGroup on x.TeamGroupId equals v.TeamGroupId
join w in db.Base_WorkPost on x.WorkPostId equals w.WorkPostId
20210906
2021-09-06 12:27:07 +08:00
join p in db.Project_ProjectUnit on new { x.UnitId, x.ProjectId } equals new { p.UnitId, p.ProjectId }
20210830
2021-08-30 21:49:56 +08:00
where personList.Contains(x.PersonId) && z.JTproCode != null
20210906
2021-09-06 12:27:07 +08:00
&& p.UnitType != Const.ProjectUnitType_3 && p.UnitType != Const.ProjectUnitType_4
20210430
2021-04-30 10:28:37 +08:00
select new
{
name = x.PersonName,
idcardType = x.IdcardType ?? "SHENFEN_ZHENGJIAN",
idcardNumber = x.IdentityCard,
idcardStartDate = x.IdcardStartDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardStartDate) : null,
idcardEndDate = x.IdcardEndDate.HasValue ? string.Format("{0:yyyy-MM-dd}", x.IdcardEndDate) : null,
20210919 实名制同步身份证有效期 永久
2021-09-19 09:04:08 +08:00
idcardForever = "Y",
20210430
2021-04-30 10:28:37 +08:00
politicsStatus = x.PoliticsStatus,
eduLevel = x.EduLevel,
maritalStatus = x.MaritalStatus,
sex = (x.Sex == "2" ? "F" : "M"),
idcardAddress = x.IdcardAddress,
homeAddress = x.Address,
birthday = x.Birthday.HasValue ? string.Format("{0:yyyy-MM-dd}", x.Birthday) : null,
nation = x.Nation,
countryCode = x.CountryCode,
provinceCode = x.ProvinceCode,
//positiveIdcardImage = db.AttachFile.First(t => (x.PersonId + "#1") == t.ToKeyId).ImageByte,
//negativeIdcardImage = db.AttachFile.First(t => (x.PersonId + "#5") == t.ToKeyId).ImageByte,
headImage = x.HeadImage,
20210830
2021-08-30 21:49:56 +08:00
proCode = z.JTproCode,
20210430
2021-04-30 10:28:37 +08:00
teamId = v.TeamId,
mobile = x.Telephone,
teamLeaderFlag = (v.GroupLeaderId == x.PersonId ? "Y" : "N"),
userType = ((w.PostType == "1" || w.PostType == "4") ? "LAB_USER_MANAGE" : "LAB_USER_BULIDER"),
workType = w.WorkPostCode,
20210906
2021-09-06 12:27:07 +08:00
isLeave = x.OutTime.HasValue ? "Y" : "N",
20210430
2021-04-30 10:28:37 +08:00
entryTime = x.InTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.InTime) : null,
exitTime = x.OutTime.HasValue ? string.Format("{0:yyyy-MM-dd}", x.OutTime) : null,
x.RealNameAddTime,
x.RealNameUpdateTime,
x.PersonId,
}).ToList();
if (getData.Count() > 0)
{
var addlistObject = new
{
list = getData.Select(x => new { x.name, x.idcardType, x.idcardNumber, x.idcardStartDate, x.idcardEndDate, x.idcardForever, x.politicsStatus, x.eduLevel, x.maritalStatus, x.sex, x.idcardAddress, x.homeAddress, x.birthday, x.nation, x.countryCode, x.provinceCode, x.headImage, x.proCode, x.teamId, x.mobile, x.teamLeaderFlag, x.userType, x.workType, x.isLeave, x.entryTime, x.exitTime })
};
BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/persons", "POST", null, newToken, JsonConvert.SerializeObject(addlistObject));
BLL.APIGetHttpService.OutsideHttp(Funs.RealNameApiUrl + "/foreignApi/accept/updatePersons", "POST", null, newToken, JsonConvert.SerializeObject(addlistObject));
}
}
}
#endregion
}
}