门诊随访新增 28天内就诊患者随访过的不再随访

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi/Controllers/TestController.cs

                     {
                         continue;
                     }
-                    ///根据姓名手机号就诊时间判断是否已经发送过短信
-                    var massageinfo = await _IHzsfMassagesRepository.GetSingle(p => p.PAT_PHONE == item && p.NAME == name && p.mzjztime == Convert.ToDateTime(jzdatetimes));
-                    if (massageinfo != null)
+                    #region 判断是否28天内就诊过 28天后的随访 28天内的不再随访
+                    int days = 0;
+                    DateTime? smzjz = null;
+                    //string jzdatetimes = "2021-02-04 15:30:13";
+                    var sort = Builders<HzsfMassages>.Sort.Descending("mzjztime");
+                    //根据条件查询集合
+                    var listApp = new List<FilterDefinition<HzsfMassages>>();
+                    listApp.Add(Builders<HzsfMassages>.Filter.Eq("isdelete", 0));
+                    listApp.Add(Builders<HzsfMassages>.Filter.Eq("PAT_PHONE", item));
+                    listApp.Add(Builders<HzsfMassages>.Filter.Eq("NAME", name));
+                    var filter = Builders<HzsfMassages>.Filter.And(listApp);
+
+                    var list = await _IHzsfMassagesRepository.Get(filter, null, sort);
+                    HzsfMassages testuserlist = null;
+                    foreach (var items in list)
                     {
-                        continue;
+                        testuserlist = items;
+                        break;
                     }
-                    List<V_MZ_FIRSTPAGE_NEW> modelinfo = _Iv_csm_zhuyuanRepository.geitmzinfoby(item, name, jzdatetimes);
-
-                    if (modelinfo.Count > 0)
+                    if (testuserlist != null)
+                    {
+                        smzjz = testuserlist.mzjztime;
+                        TimeSpan ts = Convert.ToDateTime(jzdatetimes) - Convert.ToDateTime(smzjz);
+                        days = ts.Days;
+                    }
+                    //判断本次随访的患者就诊时间跟上一次的时间差是否超过28天
+                    if (days > 28)
                     {
-                        V_MZ_FIRSTPAGE_NEW mzsfinfomodel = new V_MZ_FIRSTPAGE_NEW();
-                        foreach (var itemmod in modelinfo)
+                        ///根据姓名手机号就诊时间判断是否已经发送过短信
+                        var massageinfo = await _IHzsfMassagesRepository.GetSingle(p => p.PAT_PHONE == item && p.NAME == name && p.mzjztime == Convert.ToDateTime(jzdatetimes));
+                        if (massageinfo != null)
                         {
-                            mzsfinfomodel = itemmod;
+                            continue;
                         }
+                        //获取门诊患者信息
+                        List<V_MZ_FIRSTPAGE_NEW> modelinfo = _Iv_csm_zhuyuanRepository.geitmzinfoby(item, name, jzdatetimes);
 
-                        //发送成功一条就添加一条记录var a = _IHzsfMassagesRepository.AddRetID(tp);
-                        //发送手机号
-                        var sendtel = item;
-                        //发送内容
-                        var sendcenter = _configuration["sendcent:mzcenters"].ToString();
-                        string resultstrs = sendcyinfo(sendtel, sendcenter);
-                        if (Convert.ToInt32(resultstrs) > 0)//
-                        {
-                            //定义发送记录实例
-                            #region 添加发送记录信息
-                            HzsfMassages tp = new HzsfMassages();
-                            tp.sendcenters = sendcenter;// 发送内容
-                            tp.replaycenters = "";// 回复内容
-                            tp.replaytime = null;//回复内容默认为空
-                            tp.nomybecause = "";//不满意原因
-                            tp.sendmyeds = ""; // 满意度
-                            tp.senddate = DateTime.Now;// 发送时间
-                            tp.ZY_NO = mzsfinfomodel.clinic_no;  // --门诊号
-                            tp.NAME = mzsfinfomodel.patient_name;  // --病人姓名
-                            tp.SEX = mzsfinfomodel.sex;    // --病人性别
-                            tp.ZY_AGE = 0;    // --住院年龄
-                            tp.PAT_PHONE = mzsfinfomodel.phone;         // --本人联系电话
-                            tp.PA_ADDRESS = "";//患者联系地址
-                            tp.JB_NAME = mzsfinfomodel.CLINIC_DIAG_NAME;    // --疾病描述（名称）
-                            tp.CY_ZD = "";       //   --出院诊断
-                            tp.IS_OP = 0;  // --是否手术
-                            tp.DIA_NAME = "";        // --诊断方式
-                            tp.NURSE_IN_CHARGE = "";     // --责任护士
-                            tp.CY_DEPT_NAME = "";    // --出院科室名称
-                            tp.RY_DATE = ""; // --入院日期
-                            tp.CY_DATE = new DateTime();  // --出院日期
-                            tp.ZY_TIMES = 0; // --住院次数
-                            tp.DIRECTOR = "";    // 科主任
-                            tp.ZZ_DOC = mzsfinfomodel.DOCTOR_NAME;    // 主治医师
-                            tp.JZ_DOC = ""; // 经治医师
-                            tp.ZY_DAYS = "";    // 住院天数
-                            tp.ZY_DEPT_NAME = "";  // 住院科室名称
-                            tp.JOB = "";           // 职业
-                            tp.OUT_OR_IN = "";   // 住院或出院
-                            tp.iszyormz = "门诊患者";//住院患者、门诊患者
-                            tp.statesissuccess = "成功";
-                            tp.mzjztime = mzsfinfomodel.CLINIC_DATE;//就诊时间
-                            tp.mzjzdeptname = mzsfinfomodel.dept_name;//就诊科室
-                            tp.isdelete = 0;  //是否删除
-                            var a = _IHzsfMassagesRepository.AddRetID(tp);
-                            #endregion
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -5)
-                        {
-                            return Error("余额不足，请充值");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -6)
-                        {
-                            return Error("定时发送时间不是有效的时间格式");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -7)
-                        {
-                            return Error("提交信息末尾未签名，请添加中文的企业签名【 】");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -8)
-                        {
-                            return Error("发送内容需在1到300字之间");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -9)
+                        if (modelinfo.Count > 0)
                         {
-                            return Error("发送号码为空");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -10)
-                        {
-                            return Error("定时时间不能小于系统当前时间");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -100)
-                        {
-                            return Error("IP黑名单");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -102)
-                        {
-                            return Error("账号黑名单");
-                        }
-                        else if (Convert.ToInt32(resultstrs) == -103)
-                        {
-                            return Error("IP未导白");
-                        }
-                        else
-                        {
-                            return Error("调用接口失败");
+                            V_MZ_FIRSTPAGE_NEW mzsfinfomodel = new V_MZ_FIRSTPAGE_NEW();
+                            foreach (var itemmod in modelinfo)
+                            {
+                                mzsfinfomodel = itemmod;
+                            }
+
+                            //发送成功一条就添加一条记录var a = _IHzsfMassagesRepository.AddRetID(tp);
+                            //发送手机号
+                            var sendtel = item;
+                            //发送内容
+                            var sendcenter = _configuration["sendcent:mzcenters"].ToString();
+                            string resultstrs = sendcyinfo(sendtel, sendcenter);
+                            if (Convert.ToInt32(resultstrs) > 0)//
+                            {
+                                //定义发送记录实例
+                                #region 添加发送记录信息
+                                HzsfMassages tp = new HzsfMassages();
+                                tp.sendcenters = sendcenter;// 发送内容
+                                tp.replaycenters = "";// 回复内容
+                                tp.replaytime = null;//回复内容默认为空
+                                tp.nomybecause = "";//不满意原因
+                                tp.sendmyeds = ""; // 满意度
+                                tp.senddate = DateTime.Now;// 发送时间
+                                tp.ZY_NO = mzsfinfomodel.clinic_no;  // --门诊号
+                                tp.NAME = mzsfinfomodel.patient_name;  // --病人姓名
+                                tp.SEX = mzsfinfomodel.sex;    // --病人性别
+                                tp.ZY_AGE = 0;    // --住院年龄
+                                tp.PAT_PHONE = mzsfinfomodel.phone;         // --本人联系电话
+                                tp.PA_ADDRESS = "";//患者联系地址
+                                tp.JB_NAME = mzsfinfomodel.CLINIC_DIAG_NAME;    // --疾病描述（名称）
+                                tp.CY_ZD = "";       //   --出院诊断
+                                tp.IS_OP = 0;  // --是否手术
+                                tp.DIA_NAME = "";        // --诊断方式
+                                tp.NURSE_IN_CHARGE = "";     // --责任护士
+                                tp.CY_DEPT_NAME = "";    // --出院科室名称
+                                tp.RY_DATE = ""; // --入院日期
+                                tp.CY_DATE = new DateTime();  // --出院日期
+                                tp.ZY_TIMES = 0; // --住院次数
+                                tp.DIRECTOR = "";    // 科主任
+                                tp.ZZ_DOC = mzsfinfomodel.DOCTOR_NAME;    // 主治医师
+                                tp.JZ_DOC = ""; // 经治医师
+                                tp.ZY_DAYS = "";    // 住院天数
+                                tp.ZY_DEPT_NAME = "";  // 住院科室名称
+                                tp.JOB = "";           // 职业
+                                tp.OUT_OR_IN = "";   // 住院或出院
+                                tp.iszyormz = "门诊患者";//住院患者、门诊患者
+                                tp.statesissuccess = "成功";
+                                tp.mzjztime = mzsfinfomodel.CLINIC_DATE;//就诊时间
+                                tp.mzjzdeptname = mzsfinfomodel.dept_name;//就诊科室
+                                tp.isdelete = 0;  //是否删除
+                                var a = _IHzsfMassagesRepository.AddRetID(tp);
+                                #endregion
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -5)
+                            {
+                                return Error("余额不足，请充值");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -6)
+                            {
+                                return Error("定时发送时间不是有效的时间格式");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -7)
+                            {
+                                return Error("提交信息末尾未签名，请添加中文的企业签名【 】");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -8)
+                            {
+                                return Error("发送内容需在1到300字之间");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -9)
+                            {
+                                return Error("发送号码为空");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -10)
+                            {
+                                return Error("定时时间不能小于系统当前时间");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -100)
+                            {
+                                return Error("IP黑名单");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -102)
+                            {
+                                return Error("账号黑名单");
+                            }
+                            else if (Convert.ToInt32(resultstrs) == -103)
+                            {
+                                return Error("IP未导白");
+                            }
+                            else
+                            {
+                                return Error("调用接口失败");
+                            }
                         }
                     }
+                    else
+                    {
+                        continue;
+                    }
+                    #endregion
 
                 }
                 return Success("成功");
         //[HttpGet("ceshishuju")]
         //public async Task<IActionResult> ceshishuju()
         //{
-        //    ///根据获取到的手机号查找发送信息表中的发送信息修改回复内容
-        //   // HzsfMassages testuserlist = await _IHzsfMassagesRepository.GetSingle(p => p.PAT_PHONE == "15617789736");//
-
-        //    //排序字段
-        //    var sort = Builders<HzsfMassages>.Sort.Descending("senddate");
-        //    //根据条件查询集合
-        //    var listApp = new List<FilterDefinition<HzsfMassages>>();
-        //    listApp.Add(Builders<HzsfMassages>.Filter.Eq("isdelete", 0));
-        //    listApp.Add(Builders<HzsfMassages>.Filter.Eq("PAT_PHONE", "15617789736"));
-        //    var filter = Builders<HzsfMassages>.Filter.And(listApp);
-
-        //    var list = await _IHzsfMassagesRepository.Get(filter, null, sort);
-        //    HzsfMassages testuserlist = null;
-        //    foreach (var item in list)
-        //    {
-        //        testuserlist = item;
-        //        break;
-        //    }
+            
         //    return Success("成功");
         //}
         #endregion