|
|
@@ -30,22 +30,26 @@ public class SourceDataToDb
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + content, "补原始数据");
|
|
|
string[] data = content.Split('|');
|
|
|
string jsonString = data[2];
|
|
|
int BrandId = int.Parse(data[1]);
|
|
|
string Kind = data[0];
|
|
|
WebCMSEntities db = new WebCMSEntities();
|
|
|
string key = "kxs_" + Kind + "_list_" + BrandId;
|
|
|
+ function.WriteLog(key, "补原始数据");
|
|
|
JobMqMsg obj = RedisDbconn.Instance.GetList<JobMqMsg>("GetSpData", 1, 1000).FirstOrDefault(m => m.OrderString.Contains(key));
|
|
|
if(obj != null)
|
|
|
{
|
|
|
+ function.WriteLog("找到job", "补原始数据");
|
|
|
PublicImportDataService.Instance.InsertData(key, jsonString, obj, BrandId);
|
|
|
+ function.WriteLog("执行完毕", "补原始数据");
|
|
|
}
|
|
|
db.Dispose();
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "接收云长WIFI设备绑定异常");
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "补原始数据异常");
|
|
|
}
|
|
|
}
|
|
|
else
|