Merge branch 'master' of http://git.shengws.com/csx/XT_New

controllers/device_api_controller.go

 	}
 
 	adminInfo := this.GetAdminUserInfo()
-  _, errcode := service.GetDeviceGroupName(name, adminInfo.CurrentOrgId)
-  if errcode == gorm.ErrRecordNotFound{
-    group, createErr := service.CreateDeviceGroup(adminInfo.CurrentOrgId, name)
-    if createErr != nil {
-      this.ErrorLog("创建设备分组失败:%v", createErr)
-      this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
-      return
-    }
-    this.ServeSuccessJSON(map[string]interface{}{
-      "group": group,
-    })
-  }else if errcode == nil{
-    this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
-    return
-  }
+	_, errcode := service.GetDeviceGroupName(name, adminInfo.CurrentOrgId)
+	if errcode == gorm.ErrRecordNotFound {
+		group, createErr := service.CreateDeviceGroup(adminInfo.CurrentOrgId, name)
+		if createErr != nil {
+			this.ErrorLog("创建设备分组失败:%v", createErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"group": group,
+		})
+	} else if errcode == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+		return
+	}
 
 }
 
 
 	group.Name = name
 	group.ModifyTime = time.Now().Unix()
-  byName, getGroupErr := service.GetUpdateDeviceGroupByName(name, adminInfo.CurrentOrgId)
-  if byName.ID > 0 && byName.ID != id {
-    this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-    return
-  }
-  updateErr := service.UpdateDeviceGroup(group)
+	byName, getGroupErr := service.GetUpdateDeviceGroupByName(name, adminInfo.CurrentOrgId)
+	if byName.ID > 0 && byName.ID != id {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	updateErr := service.UpdateDeviceGroup(group)
 	if updateErr != nil {
 		this.ErrorLog("修改设备分组失败:%v", updateErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
 		return
 	}
 
-  _, errcode := service.GetCreateDeviceNumber(num, adminInfo.CurrentOrgId)
-  if errcode == gorm.ErrRecordNotFound{
-    number, createErr := service.CreateDeviceNumber(adminInfo.CurrentOrgId, num, zoneID, groupID)
-    if createErr != nil {
-      this.ErrorLog("创建机号失败:%v", createErr)
-      this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
-      return
-    }
-    numberJson := map[string]interface{}{
-      "id":         number.ID,
-      "number":     number.Number,
-      "zone_id":    number.ZoneID,
-      "group_id":   number.GroupID,
-      "zone_name":  zone.Name,
-      "group_name": group.Name,
-    }
-    this.ServeSuccessJSON(map[string]interface{}{
-      "number": numberJson,
-    })
-  }else if errcode == nil{
-    this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
-    return
-  }
+	_, errcode := service.GetCreateDeviceNumber(num, adminInfo.CurrentOrgId)
+	if errcode == gorm.ErrRecordNotFound {
+		number, createErr := service.CreateDeviceNumber(adminInfo.CurrentOrgId, num, zoneID, groupID)
+		if createErr != nil {
+			this.ErrorLog("创建机号失败:%v", createErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+			return
+		}
+		numberJson := map[string]interface{}{
+			"id":         number.ID,
+			"number":     number.Number,
+			"zone_id":    number.ZoneID,
+			"group_id":   number.GroupID,
+			"zone_name":  zone.Name,
+			"group_name": group.Name,
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"number": numberJson,
+		})
+	} else if errcode == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+		return
+	}
 
 }
 
 	number.Number = num
 	number.ZoneID = zoneID
 	number.GroupID = groupID
-  byName, _ := service.GetDeviceNumberByName(num, adminInfo.CurrentOrgId)
-  if byName.ID > 0 && byName.ID != id {
-    this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-    return
-  }
-  updateErr := service.UpdateDeviceNumber(number)
+	byName, _ := service.GetDeviceNumberByName(num, adminInfo.CurrentOrgId)
+	if byName.ID > 0 && byName.ID != id {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	updateErr := service.UpdateDeviceNumber(number)
 	if updateErr != nil {
 		this.ErrorLog("修改机号失败:%v", updateErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)

controllers/gobal_config_api_controller.go

 	beego.Router("/api/public/orgs", &GobalConfigApiController{}, "get:GetOrgs")
 	beego.Router("/api/org/change", &GobalConfigApiController{}, "post:ChangeOrg")
 
+	beego.Router("/api/log/generate", &GobalConfigApiController{}, "get:GenerateLog")
+
 }
 
 //provinces, _ := service.GetDistrictsByUpid(0)21
 	}
 	return
 }
+
+func (this *GobalConfigApiController) GenerateLog() {
+	log_type, _ := this.GetInt64("log_type", 0)
+	logs, err := service.GetExportLogByType(this.GetAdminUserInfo().CurrentOrgId, log_type)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"logs": logs,
+	})
+
+}

controllers/mobile_api_controllers/mobile_api_base_controller.go

 
 func (this *MobileBaseAPIController) Prepare() {
 	this.BaseAPIController.Prepare()
+
 	// beego.Trace("============================================================")
 	// beego.Trace("session ID: %v", this.Ctx.Input.Cookie("beegosessionID"))
 	// beego.Trace("session : %v", this.GetSession("info"))

controllers/patient_api_controller.go

 	"XT_New/service"
 	"XT_New/utils"
 	"encoding/json"
+	"log"
 	"reflect"
+	"regexp"
 	"strconv"
 	"strings"
 	"time"
 
 	beego.Router("/api/remind/is_open", &PatientApiController{}, "Post:PostIsOpenRemind")
 	beego.Router("/api/patients/advices/getpatientschedules", &PatientApiController{}, "Get:GetPatientScheduleOne")
+
+	beego.Router("/api/patients/export", &PatientApiController{}, "Post:ExportPatients")
+
 	beego.Router("/api/patients/advices/saveditadvices", &PatientApiController{}, "Get:SaveEditAdvices")
 }
 
 	//获取老表的最后一条数据
 	patients, err := service.GetLastPatientData(adminUserInfo.CurrentOrgId)
 	patientsNew := models.XtPatientsNew{
-		UserOrgId:                    adminUserInfo.CurrentOrgId,
-		UserId:                       0,
-		Avatar:                       patients.Avatar,
-		PatientType:                  patients.PatientType,
-		DialysisNo:                   patients.DialysisNo,
-		AdmissionNumber:              patients.AdmissionNumber,
-		Source:                       patients.Source,
-		Lapseto:                      patients.Lapseto,
-		PartitionId:                  patients.PartitionId,
-		BedId:                        patients.BedId,
-		Name:                         patients.Name,
-		Alias:                        patients.Alias,
-		Gender:                       patients.Gender,
-		MaritalStatus:                patients.MaritalStatus,
-		IdCardNo:                     patients.IdCardNo,
-		Birthday:                     patients.Birthday,
-		ReimbursementWayId:           patients.ReimbursementWayId,
-		HealthCareType:               patients.HealthCareType,
-		HealthCareNo:                 patients.HealthCareNo,
-		HealthCareDueDate:            patients.HealthCareDueDate,
-		Height:                       patients.Height,
-		BloodType:                    patients.BloodType,
-		Rh:                           patients.Rh,
+		UserOrgId:          adminUserInfo.CurrentOrgId,
+		UserId:             0,
+		Avatar:             patients.Avatar,
+		PatientType:        patients.PatientType,
+		DialysisNo:         patients.DialysisNo,
+		AdmissionNumber:    patients.AdmissionNumber,
+		Source:             patients.Source,
+		Lapseto:            patients.Lapseto,
+		PartitionId:        patients.PartitionId,
+		BedId:              patients.BedId,
+		Name:               patients.Name,
+		Alias:              patients.Alias,
+		Gender:             patients.Gender,
+		MaritalStatus:      patients.MaritalStatus,
+		IdCardNo:           patients.IdCardNo,
+		Birthday:           patients.Birthday,
+		ReimbursementWayId: patients.ReimbursementWayId,
+		HealthCareType:     patients.HealthCareType,
+		HealthCareNo:       patients.HealthCareNo,
+		HealthCareDueDate:  patients.HealthCareDueDate,
+		Height:             patients.Height,
+		BloodType:          patients.BloodType,
+		Rh:                 patients.Rh,
 		HealthCareDueAlertDate:       patients.HealthCareDueAlertDate,
 		EducationLevel:               patients.EducationLevel,
 		Profession:                   patients.Profession,
 		Nation:                       patients.Nation,
 		NativePlace:                  patients.NativePlace,
 		Age:                          patients.Age,
-		InfectiousNextRecordTime:     patients.InfectiousNextRecordTime,
-		IsInfectious:                 patients.IsInfectious,
-		RemindCycle:                  patients.RemindCycle,
-		ResponseResult:               patients.ResponseResult,
-		IsOpenRemind:                 patients.IsOpenRemind,
-		FirstTreatmentDate:           patients.FirstTreatmentDate,
-		DialysisAge:                  patients.DialysisAge,
-		ExpenseKind:                  patients.ExpenseKind,
-		TellPhone:                    patients.TellPhone,
-		ContactName:                  patients.ContactName,
-		BloodPatients:                1,
-		SlowPatients:                 0,
-		MemberPatients:               0,
-		EcommerPatients:              "",
-		BloodId:                      patients.ID,
-		SlowId:                       0,
-		MemberId:                     0,
-		MemberFistdate:               0,
-		MemberPatienttype:            0,
-		MemberTreatement:             0,
-		EquitmentId:                  "",
-		UserSysBeforeCount:           patient.UserSysBeforeCount,
+		InfectiousNextRecordTime: patients.InfectiousNextRecordTime,
+		IsInfectious:             patients.IsInfectious,
+		RemindCycle:              patients.RemindCycle,
+		ResponseResult:           patients.ResponseResult,
+		IsOpenRemind:             patients.IsOpenRemind,
+		FirstTreatmentDate:       patients.FirstTreatmentDate,
+		DialysisAge:              patients.DialysisAge,
+		ExpenseKind:              patients.ExpenseKind,
+		TellPhone:                patients.TellPhone,
+		ContactName:              patients.ContactName,
+		BloodPatients:            1,
+		SlowPatients:             0,
+		MemberPatients:           0,
+		EcommerPatients:          "",
+		BloodId:                  patients.ID,
+		SlowId:                   0,
+		MemberId:                 0,
+		MemberFistdate:           0,
+		MemberPatienttype:        0,
+		MemberTreatement:         0,
+		EquitmentId:              "",
+		UserSysBeforeCount:       patient.UserSysBeforeCount,
 	}
 
 	err = service.CreatePatientsNew(&patientsNew)
 	}
 	fmt.Println("病人--------------------------------------------------------------", patient.Name, patient.Age)
 	patientsNew := models.XtPatientsNew{
-		UserOrgId:                 patient.UserOrgId,
-		UserId:                    patient.UserId,
-		Avatar:                    patient.Avatar,
-		PatientType:               patient.PatientType,
-		DialysisNo:                patient.DialysisNo,
-		AdmissionNumber:           patient.AdmissionNumber,
-		Source:                    patient.Source,
-		Lapseto:                   patient.Lapseto,
-		PartitionId:               patient.PartitionId,
-		BedId:                     patient.BedId,
-		Name:                      patient.Name,
-		Alias:                     patient.Alias,
-		Gender:                    patient.Gender,
-		MaritalStatus:             patient.MaritalStatus,
-		IdCardNo:                  patient.IdCardNo,
-		Birthday:                  patient.Birthday,
-		ReimbursementWayId:        patient.ReimbursementWayId,
-		HealthCareType:            patient.HealthCareType,
-		HealthCareNo:              patient.HealthCareNo,
-		HealthCareDueDate:         patient.HealthCareDueDate,
-		Height:                    patient.Height,
-		BloodType:                 patient.BloodType,
-		Rh:                        patient.Rh,
+		UserOrgId:          patient.UserOrgId,
+		UserId:             patient.UserId,
+		Avatar:             patient.Avatar,
+		PatientType:        patient.PatientType,
+		DialysisNo:         patient.DialysisNo,
+		AdmissionNumber:    patient.AdmissionNumber,
+		Source:             patient.Source,
+		Lapseto:            patient.Lapseto,
+		PartitionId:        patient.PartitionId,
+		BedId:              patient.BedId,
+		Name:               patient.Name,
+		Alias:              patient.Alias,
+		Gender:             patient.Gender,
+		MaritalStatus:      patient.MaritalStatus,
+		IdCardNo:           patient.IdCardNo,
+		Birthday:           patient.Birthday,
+		ReimbursementWayId: patient.ReimbursementWayId,
+		HealthCareType:     patient.HealthCareType,
+		HealthCareNo:       patient.HealthCareNo,
+		HealthCareDueDate:  patient.HealthCareDueDate,
+		Height:             patient.Height,
+		BloodType:          patient.BloodType,
+		Rh:                 patient.Rh,
 		HealthCareDueAlertDate:    patient.HealthCareDueAlertDate,
 		EducationLevel:            patient.EducationLevel,
 		Profession:                patient.Profession,
 		Nation:                    patient.Nation,
 		NativePlace:               patient.NativePlace,
 		Age:                       patient.Age,
-		InfectiousNextRecordTime:  patient.InfectiousNextRecordTime,
-		IsInfectious:              patient.IsInfectious,
-		RemindCycle:               patient.RemindCycle,
-		ResponseResult:            patient.ResponseResult,
-		IsOpenRemind:              patient.IsOpenRemind,
-		FirstTreatmentDate:        patient.FirstTreatmentDate,
-		DialysisAge:               patient.DialysisAge,
-		ExpenseKind:               patient.ExpenseKind,
-		TellPhone:                 patient.TellPhone,
-		ContactName:               patient.ContactName,
-		UpdatedTime:               time.Now().Unix(),
+		InfectiousNextRecordTime: patient.InfectiousNextRecordTime,
+		IsInfectious:             patient.IsInfectious,
+		RemindCycle:              patient.RemindCycle,
+		ResponseResult:           patient.ResponseResult,
+		IsOpenRemind:             patient.IsOpenRemind,
+		FirstTreatmentDate:       patient.FirstTreatmentDate,
+		DialysisAge:              patient.DialysisAge,
+		ExpenseKind:              patient.ExpenseKind,
+		TellPhone:                patient.TellPhone,
+		ContactName:              patient.ContactName,
+		UpdatedTime:              time.Now().Unix(),
 	}
 	//	//更新病人ID获取新表病人ID
 	err = service.UpdatepatientTwo(&patientsNew, id)
 	})
 }
 
+func (c *PatientApiController) ExportPatients() {
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		return
+	}
+	utils.ErrorLog("%v", dataBody)
+	export_time := time.Now().Unix()
+	var patients []*models.Patients
+	var total_patients []interface{}
+
+	if dataBody["patients"] != nil || reflect.TypeOf(dataBody["patients"]).String() == "[]interface {}" {
+		tempPatients := dataBody["patients"].([]interface{})
+		total_patients = tempPatients
+		for index, patientMap := range tempPatients {
+			patientNameM := patientMap.(map[string]interface{})
+			var patient models.Patients
+
+			if patientNameM["name"] == nil || reflect.TypeOf(patientNameM["name"]).String() != "string" {
+				utils.ErrorLog("name")
+				return
+			}
+			name, _ := patientNameM["name"].(string)
+			if len(name) == 0 { //名字为空则生成一条导入错误日志
+				err_log := models.ExportErrLog{
+					LogType:    1,
+					UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的姓名不能为空",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				continue
+			}
+			patient.Name = name
+
+			if patientNameM["gender"] != nil || reflect.TypeOf(patientNameM["gender"]).String() == "string" {
+				gender, _ := strconv.ParseInt(patientNameM["gender"].(string), 10, 64)
+				if gender == 0 { //性别不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的性别不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					patient.Gender = gender
+				}
+			}
+
+			if patientNameM["phone"] != nil || reflect.TypeOf(patientNameM["phone"]).String() == "string" {
+				phone, _ := patientNameM["phone"].(string)
+				if VerifyMobileFormat(phone) == false { //手机号码不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的手机号码格式不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					//需要判断该号码是否已经在系统内存在了，存在了则生成一条导入错误日志
+					count := service.FindPatientPhoneIsExist(phone, c.GetAdminUserInfo().CurrentOrgId)
+					if count > 0 {
+						err_log := models.ExportErrLog{
+							LogType:    1,
+							UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的手机号码在系统中已经存在",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						continue
+					}
+					patient.Phone = phone
+				}
+			}
+
+			if patientNameM["id_card_no"] != nil || reflect.TypeOf(patientNameM["id_card_no"]).String() == "string" {
+				id_card_no, _ := patientNameM["id_card_no"].(string)
+				fmt.Println(id_card_no)
+
+				if IsIdCard(id_card_no) == false { //身份证号码不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的身份证号码格式不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					count := service.FindPatientIdCardNoIsExist(id_card_no, c.GetAdminUserInfo().CurrentOrgId)
+					if count > 0 {
+						err_log := models.ExportErrLog{
+							LogType:    1,
+							UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的身份证号码在系统中已经存在",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						continue
+					}
+					patient.IdCardNo = id_card_no
+					patient.Birthday = GetBirthDay(id_card_no).Unix()
+				}
+			}
+
+			if patientNameM["first_treatment_date"] != nil || reflect.TypeOf(patientNameM["first_treatment_date"]).String() == "string" {
+				first_treatment_date, _ := patientNameM["first_treatment_date"].(string)
+				timeLayout := "2006/01/02"
+				loc, _ := time.LoadLocation("Local")
+				first_dialysis_date, err := time.ParseInLocation(timeLayout, first_treatment_date, loc)
+
+				if err != nil { //首次肾脏治疗时间不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的首次肾脏治疗时间格式不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+
+				} else {
+					if first_dialysis_date.Unix() == 0 { //首次肾脏治疗时间不符合要求则生成一条导入错误日志
+						err_log := models.ExportErrLog{
+							LogType:    1,
+							UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的首次肾脏治疗时间格式不符合要求",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						continue
+					} else {
+						patient.FirstDialysisDate = first_dialysis_date.Unix()
+					}
+				}
+			}
+
+			if patientNameM["source"] != nil || reflect.TypeOf(patientNameM["source"]).String() == "string" {
+				source, _ := strconv.ParseInt(patientNameM["source"].(string), 10, 64)
+				if source == 0 { //患者来源不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的患者来源不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					patient.Source = source
+				}
+			}
+
+			if patientNameM["lapseto"] != nil || reflect.TypeOf(patientNameM["lapseto"]).String() == "string" {
+				lapseto, _ := strconv.ParseInt(patientNameM["lapseto"].(string), 10, 64)
+				if lapseto == 0 { //治疗状态不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的治疗状态不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					patient.Lapseto = lapseto
+				}
+			}
+
+			if patientNameM["is_infectious"] != nil || reflect.TypeOf(patientNameM["is_infectious"]).String() == "string" {
+				is_infectious, _ := strconv.ParseInt(patientNameM["is_infectious"].(string), 10, 64)
+				if is_infectious == 0 { //传染病不符合要求则生成一条导入错误日志
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+2) + "行" + "的传染病状态不符合要求",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				} else {
+					patient.IsInfectious = is_infectious
+				}
+			}
+
+			if patientNameM["contagions"] != nil && reflect.TypeOf(patientNameM["contagions"]).String() == "[]interface {}" {
+				var contagions []int64
+				thisContagions, _ := patientNameM["contagions"].([]interface{})
+				if len(thisContagions) > 0 {
+					for _, item := range thisContagions {
+						if reflect.TypeOf(item).String() != "float64" {
+							continue
+						}
+						contagion := int64(item.(float64))
+						if contagion > 0 {
+							contagions = append(contagions, contagion)
+						}
+					}
+				}
+				patient.ContagionIds = contagions
+			}
+
+			if patientNameM["diagnose"] != nil || reflect.TypeOf(patientNameM["diagnose"]).String() == "string" {
+				diagnose, _ := patientNameM["diagnose"].(string)
+				patient.Diagnose = diagnose
+
+			}
+			patient.CreatedTime = time.Now().Unix()
+			patient.UpdatedTime = time.Now().Unix()
+			patient.Status = 1
+			patient.UserOrgId = c.GetAdminUserInfo().CurrentOrgId
+			patient.IsExcelExport = 1
+			patient.PatientType = 1
+			patients = append(patients, &patient)
+		}
+	}
+	errLogs, _ := service.FindPatientExportLog(c.GetAdminUserInfo().CurrentOrgId, export_time)
+
+	if len(patients) > 0 {
+		for _, item := range patients {
+			service.CreateExportPatient(item, item.ContagionIds)
+		}
+
+		log := models.ExportLog{
+			LogType:    1,
+			UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+			TotalNum:   int64(len(total_patients)),
+			FailNum:    int64(len(errLogs)),
+			SuccessNum: int64(len(patients)),
+			CreateTime: time.Now().Unix(),
+			UpdateTime: time.Now().Unix(),
+			ExportTime: export_time,
+			Status:     1,
+		}
+		service.CreateExportLog(&log)
+
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg":         "导入成功",
+			"total_num":   len(total_patients),
+			"success_num": len(patients),
+			"fail_num":    int64(len(errLogs)),
+		})
+	} else {
+		log := models.ExportLog{
+			LogType:    1,
+			UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+			TotalNum:   int64(len(total_patients)),
+			FailNum:    int64(len(errLogs)),
+			SuccessNum: int64(len(patients)),
+			CreateTime: time.Now().Unix(),
+			UpdateTime: time.Now().Unix(),
+			ExportTime: export_time,
+			Status:     1,
+		}
+		service.CreateExportLog(&log)
+
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg":         "导入成功",
+			"total_num":   len(total_patients),
+			"success_num": len(patients),
+			"fail_num":    int64(len(errLogs)),
+		})
+	}
+}
+
+func GetBirthDay(IDCardNo string) *time.Time {
+	dayStr := IDCardNo[6:14] + "000001"
+	birthDay, err := time.Parse("20060102150405", dayStr)
+	if err != nil {
+		log.Fatal(err)
+		return nil
+	}
+
+	return &birthDay
+}
+
+func VerifyMobileFormat(mobileNum string) bool {
+	regular := "^((13[0-9])|(14[5,7])|(15[0-3,5-9])|(17[0,3,5-8])|(18[0-9])|166|198|199|(147))\\d{8}$"
+
+	reg := regexp.MustCompile(regular)
+	return reg.MatchString(mobileNum)
+}
+
+func IsIdCard(idCard string) (res bool) {
+	res, _ = regexp.Match("^[1-9]\\d{7}((0\\d)|(1[0-2]))(([0|1|2]\\d)|3[0-1])\\d{3}$|^[1-9]\\d{5}[1-9]\\d{3}((0\\d)|(1[0-2]))(([0|1|2]\\d)|3[0-1])\\d{3}([0-9]|X)$", []byte(idCard))
+	return
+}
+
 func (c *PatientApiController) SaveEditAdvices() {
 	adminInfo := c.GetAdminUserInfo()
 	orgid := adminInfo.CurrentOrgId

controllers/public_api_controller.go

 }
 
 func (c *PublicApiController) HandleData() {
-	service.HandleData()
+	//service.HandleData()
 
 	//org_app, _ := service.GetAllAppOrg()
 	//org_role, _ := service.GetAllRole()

controllers/schedule_api_controller.go

 	"XT_New/utils"
 	"encoding/json"
 	"fmt"
+	"github.com/jinzhu/gorm"
 	"reflect"
 	"strconv"
 	"time"
 func ScheduleApiRegistRouters() {
 	beego.Router("/api/schedule/weekpanel", &ScheduleApiController{}, "Get:GetWeekPanels")
 	beego.Router("/api/schedule/schedules", &ScheduleApiController{}, "Get:GetSchedules")
+	beego.Router("/api/excel_date/init", &ScheduleApiController{}, "Get:GetInitExcelInitDate")
+
 	beego.Router("/api/schedule/patients", &ScheduleApiController{}, "Get:GetPatients")
 	beego.Router("/api/schedule/create", &ScheduleApiController{}, "Post:CreateSchedule")
 	beego.Router("/api/schedule/delete", &ScheduleApiController{}, "Delete:DeleteSchedule")
 	beego.Router("/api/schedule/change", &ScheduleApiController{}, "Put:ChangeSchedule")
 	beego.Router("/api/schedule/urgentinit", &ScheduleApiController{}, "Get:UrgentScheduleData")
-
 	beego.Router("/api/schedule/print/initdata", &ScheduleApiController{}, "get:PrintInitData")
-
 	beego.Router("/api/schedule/search", &ScheduleApiController{}, "get:SearchSchedulePatients")
-
 	beego.Router("/api/schedule/week", &ScheduleApiController{}, "get:GetWeekDaySchedule")
+	beego.Router("/api/schedule/export", &ScheduleApiController{}, "post:ExportSchedule")
+	beego.Router("/api/schedule_template/export", &ScheduleApiController{}, "post:ExportScheduleTemplate")
 
 }
 
 	}
 	return data
 }
+
+func (this *ScheduleApiController) ExportSchedule() {
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		return
+	}
+	utils.ErrorLog("%v", dataBody)
+	export_time := time.Now().Unix()
+	var schedules []*models.Schedule
+	var total_schedule []interface{}
+
+	var patients []*models.Patients
+
+	patients, _, _ = service.GetAllPatientList(this.GetAdminUserInfo().CurrentOrgId)
+
+	if dataBody["schedule"] != nil || reflect.TypeOf(dataBody["schedule"]).String() == "[]interface {}" {
+		tempSchedule := dataBody["schedule"].([]interface{})
+		total_schedule = tempSchedule
+		for _, schMap := range tempSchedule {
+			schMapM := schMap.(map[string]interface{})
+			var sch models.Schedule
+
+			if schMapM["name"] == nil || reflect.TypeOf(schMapM["name"]).String() != "string" {
+				utils.ErrorLog("name")
+				return
+			}
+
+			name, _ := schMapM["name"].(string)
+			fmt.Println(name)
+			if len(name) == 0 { //名字为空则生成一条导入错误日志
+				err_log := models.ExportErrLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行,第" + schMapM["row"].(string) + "列的姓名不能为空",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				continue
+
+			} else {
+				var patient []*models.Patients
+				for _, item := range patients {
+					if item.Name == name {
+						patient = append(patient, item)
+					}
+				}
+				if len(patient) == 0 { //错误日志
+					err_log := models.ExportErrLog{
+						LogType:    2,
+						UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行,第" + schMapM["row"].(string) + "列的姓名在系统中不存在,请在系统中添加该病人",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+
+				} else if len(patient) == 1 { //
+					sch.PatientId = patient[0].ID
+
+				} else if len(patient) > 2 { //出现同名的情况
+
+					err_log := models.ExportErrLog{
+						LogType:    2,
+						UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "存在同名同姓的两个病人",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+
+				}
+			}
+
+			if schMapM["schedule_type"] == nil && reflect.TypeOf(schMapM["schedule_type"]).String() != "float64" {
+				utils.ErrorLog("schedule_type")
+				return
+			}
+			schedule_type := int64(schMapM["schedule_type"].(float64))
+			if schedule_type <= 0 { //班次格式有误，插入日志
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第2行第" + schMapM["row"].(string) + "列的班次格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				sch.ScheduleType = schedule_type
+			}
+
+			if schMapM["partition_name"] == nil || reflect.TypeOf(schMapM["partition_name"]).String() != "string" {
+				utils.ErrorLog("partition_name")
+				return
+			}
+
+			partition_name, _ := schMapM["partition_name"].(string)
+			if len(partition_name) == 0 { //分区为空
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:   2,
+					UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+					//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+					ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第1列所属的分区格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				zone, err := service.FindDeviceZoneByName(partition_name, this.GetAdminUserInfo().CurrentOrgId)
+				if err == nil {
+					sch.PartitionId = zone.ID
+				} else if err == gorm.ErrRecordNotFound { //查不到数据，插入错误日志
+
+					log := models.ExportLog{
+						LogType:    2,
+						UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+						TotalNum:   int64(len(total_schedule)),
+						FailNum:    1,
+						SuccessNum: int64(len(schedules)),
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+						Status:     1,
+					}
+					service.CreateExportLog(&log)
+
+					err_log := models.ExportErrLog{
+						LogType:   2,
+						UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+						//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+						ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第1列所属的分区格式有误",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+					return
+
+				}
+
+			}
+
+			if schMapM["device_number_name"] == nil || reflect.TypeOf(schMapM["device_number_name"]).String() != "string" {
+				utils.ErrorLog("device_number_name")
+				return
+			}
+
+			device_number_name, _ := schMapM["device_number_name"].(string)
+			if len(device_number_name) == 0 { //分区为空
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:   2,
+					UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+					//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+					ErrMsg: "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第2列机号格式有误",
+
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				device, err := service.FindDeviceByName(device_number_name, this.GetAdminUserInfo().CurrentOrgId, sch.PartitionId)
+				if err == nil {
+					if len(device) == 0 { //没查到数据，插入错误日志
+
+						log := models.ExportLog{
+							LogType:    2,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							TotalNum:   int64(len(total_schedule)),
+							FailNum:    1,
+							SuccessNum: int64(len(schedules)),
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+							Status:     1,
+						}
+						service.CreateExportLog(&log)
+
+						err_log := models.ExportErrLog{
+							LogType:    2,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第2列机号格式有误",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+						return
+
+					} else if len(device) == 1 {
+						sch.BedId = device[0].ID
+
+					} else if len(device) > 1 { //出现重名，插入错误日志
+
+						log := models.ExportLog{
+							LogType:    2,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							TotalNum:   int64(len(total_schedule)),
+							FailNum:    1,
+							SuccessNum: int64(len(schedules)),
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+							Status:     1,
+						}
+						service.CreateExportLog(&log)
+
+						err_log := models.ExportErrLog{
+							LogType:    2,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "出现两个床位号相同的床位",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+						return
+
+					}
+				}
+			}
+
+			if schMapM["schedule_week"] == nil || reflect.TypeOf(schMapM["schedule_week"]).String() != "string" {
+				utils.ErrorLog("schedule_week")
+				return
+			}
+			schedule_week, _ := schMapM["schedule_week"].(string)
+			if len(schedule_week) == 0 { //周几为空则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:   2,
+					UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+					//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+					ErrMsg: "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else if schedule_week == "0" { //周几不符合格式则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				schedule_week, _ := strconv.ParseInt(schedule_week, 10, 64)
+				sch.ScheduleWeek = schedule_week
+
+			}
+
+			if schMapM["schedule_date"] == nil || reflect.TypeOf(schMapM["schedule_date"]).String() != "string" {
+				utils.ErrorLog("schedule_date")
+				return
+			}
+			schedule_date, _ := schMapM["schedule_date"].(string)
+
+			if len(schedule_date) == 0 { //周几为空则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else if schedule_date == "0" { //周几不符合格式则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				date, _ := utils.ParseTimeStringToTime("2006-01-02", schedule_date)
+				sch.ScheduleDate = date.Unix()
+			}
+			sch.CreatedTime = time.Now().Unix()
+			sch.UpdatedTime = time.Now().Unix()
+			sch.ModeId = 1
+			sch.Status = 1
+			sch.UserOrgId = this.GetAdminUserInfo().CurrentOrgId
+			sch.IsExport = 1
+			schedules = append(schedules, &sch)
+		}
+
+		errLogs, _ := service.FindSchedualExportLog(this.GetAdminUserInfo().CurrentOrgId, export_time)
+
+		if len(schedules) > 0 {
+			schedule_date := this.GetString("date")
+			date, _ := utils.ParseTimeStringToTime("2006-01-02", schedule_date)
+			clear_schedule_date := date.Unix() //根据日期去清除，该日期以及未来的排班数据
+			err := service.UpdateScheduleStatus(clear_schedule_date, this.GetAdminUserInfo().CurrentOrgId)
+			if err == nil {
+				for _, item := range schedules {
+					service.CreateSchedule(item)
+				}
+
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    int64(len(errLogs)),
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				this.ServeSuccessJSON(map[string]interface{}{
+					"msg":         "导入成功",
+					"total_num":   len(total_schedule),
+					"success_num": len(schedules),
+					"fail_num":    int64(len(errLogs)),
+				})
+			} else {
+				log := models.ExportLog{
+					LogType:    2,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    int64(len(errLogs)),
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				this.ServeSuccessJSON(map[string]interface{}{
+					"msg":         "导入成功",
+					"total_num":   len(total_schedule),
+					"success_num": len(schedules),
+					"fail_num":    int64(len(errLogs)),
+				})
+			}
+		} else {
+			log := models.ExportLog{
+				LogType:    2,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				TotalNum:   int64(len(total_schedule)),
+				FailNum:    int64(len(errLogs)),
+				SuccessNum: int64(len(schedules)),
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: export_time,
+				Status:     1,
+			}
+			service.CreateExportLog(&log)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"msg":         "导入成功",
+				"total_num":   len(total_schedule),
+				"success_num": len(schedules),
+				"fail_num":    int64(len(errLogs)),
+			})
+		}
+	}
+
+}
+
+func (this *ScheduleApiController) ExportScheduleTemplate() {
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		return
+	}
+	utils.ErrorLog("%v", dataBody)
+	export_time := time.Now().Unix()
+	var schedules []*models.PatientScheduleTemplateItem
+	var total_schedule []interface{}
+
+	patients, _, _ := service.GetAllPatientList(this.GetAdminUserInfo().CurrentOrgId)
+
+	if dataBody["schedule"] != nil || reflect.TypeOf(dataBody["schedule"]).String() == "[]interface {}" {
+		tempSchedule := dataBody["schedule"].([]interface{})
+		total_schedule = tempSchedule
+		for _, schMap := range tempSchedule {
+			schMapM := schMap.(map[string]interface{})
+			var sch models.PatientScheduleTemplateItem
+
+			if schMapM["name"] == nil || reflect.TypeOf(schMapM["name"]).String() != "string" {
+				utils.ErrorLog("name")
+				return
+			}
+
+			name, _ := schMapM["name"].(string)
+			fmt.Println(name)
+			if len(name) == 0 { //名字为空则生成一条导入错误日志
+				err_log := models.ExportErrLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行,第" + schMapM["row"].(string) + "列的姓名不能为空",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				continue
+
+			} else {
+				var patient []*models.Patients
+				for _, item := range patients {
+					if item.Name == name {
+						patient = append(patient, item)
+					}
+				}
+				if len(patient) == 0 { //错误日志
+					err_log := models.ExportErrLog{
+						LogType:    3,
+						UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行,第" + schMapM["row"].(string) + "列的姓名在系统中不存在,请在系统中添加该病人",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+
+				} else if len(patient) == 1 { //
+					sch.PatientID = patient[0].ID
+
+				} else if len(patient) > 2 { //出现同名的情况
+
+					err_log := models.ExportErrLog{
+						LogType:    3,
+						UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "存在同名同姓的两个病人",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+
+				}
+			}
+
+			if schMapM["schedule_type"] == nil && reflect.TypeOf(schMapM["schedule_type"]).String() != "float64" {
+				utils.ErrorLog("schedule_type")
+				return
+			}
+			schedule_type := int64(schMapM["schedule_type"].(float64))
+			if schedule_type <= 0 { //班次格式有误，插入日志
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第2行第" + schMapM["row"].(string) + "列的班次格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				sch.TimeType = int8(schedule_type)
+			}
+
+			if schMapM["template_id"] == nil && reflect.TypeOf(schMapM["template_id"]).String() != "float64" {
+				utils.ErrorLog("template_id")
+				return
+			}
+
+			template_id := int64(schMapM["template_id"].(float64))
+			sch.TemplateID = template_id
+
+			if schMapM["device_number_name"] == nil || reflect.TypeOf(schMapM["device_number_name"]).String() != "string" {
+				utils.ErrorLog("device_number_name")
+				return
+			}
+
+			device_number_name, _ := schMapM["device_number_name"].(string)
+			if len(device_number_name) == 0 { //分区为空
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:   3,
+					UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+					//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+					ErrMsg: "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第2列机号格式有误",
+
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				device, err := service.FindDeviceByNameTwo(device_number_name, this.GetAdminUserInfo().CurrentOrgId)
+				if err == nil {
+					if len(device) == 0 { //没查到数据，插入错误日志
+						log := models.ExportLog{
+							LogType:    3,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							TotalNum:   int64(len(total_schedule)),
+							FailNum:    1,
+							SuccessNum: int64(len(schedules)),
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+							Status:     1,
+						}
+						service.CreateExportLog(&log)
+
+						err_log := models.ExportErrLog{
+							LogType:    3,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "第" + strconv.FormatInt(int64(schMapM["index"].(float64)), 10) + "行第2列机号格式有误",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+						return
+
+					} else if len(device) == 1 {
+						sch.DeviceNumberID = device[0].ID
+
+					} else if len(device) > 1 { //出现重名，插入错误日志
+						log := models.ExportLog{
+							LogType:    3,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							TotalNum:   int64(len(total_schedule)),
+							FailNum:    1,
+							SuccessNum: int64(len(schedules)),
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+							Status:     1,
+						}
+						service.CreateExportLog(&log)
+
+						err_log := models.ExportErrLog{
+							LogType:    3,
+							UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+							ErrMsg:     "出现两个床位号相同的床位",
+							Status:     1,
+							CreateTime: time.Now().Unix(),
+							UpdateTime: time.Now().Unix(),
+							ExportTime: export_time,
+						}
+						service.CreateExportErrLog(&err_log)
+						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+						return
+
+					}
+				}
+			}
+
+			if schMapM["schedule_week"] == nil || reflect.TypeOf(schMapM["schedule_week"]).String() != "string" {
+				utils.ErrorLog("schedule_week")
+				return
+			}
+			schedule_week, _ := schMapM["schedule_week"].(string)
+			if len(schedule_week) == 0 { //周几为空则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:   3,
+					UserOrgId: this.GetAdminUserInfo().CurrentOrgId,
+					//ErrMsg:     "第" + 	strconv.FormatInt(int64(schMapM["index"].(float64)) ,10)+ "行" + "的姓名不能为空",
+					ErrMsg: "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else if schedule_week == "0" { //周几不符合格式则生成一条导入错误日志
+
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    1,
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				err_log := models.ExportErrLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					ErrMsg:     "第1行第" + schMapM["row"].(string) + "列的星期名格式有误",
+					Status:     1,
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+				}
+				service.CreateExportErrLog(&err_log)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeExportError)
+				return
+
+			} else {
+				schedule_week, _ := strconv.ParseInt(schedule_week, 10, 64)
+				sch.Weekday = int8(schedule_week)
+
+			}
+
+			sch.CreateTime = time.Now().Unix()
+			sch.ModifyTime = time.Now().Unix()
+			sch.TreatMode = 1
+			sch.Status = 1
+			sch.OrgID = this.GetAdminUserInfo().CurrentOrgId
+			sch.IsExport = 1
+			schedules = append(schedules, &sch)
+		}
+
+		errLogs, _ := service.FindSchedualTemplateExportLog(this.GetAdminUserInfo().CurrentOrgId, export_time)
+
+		if len(schedules) > 0 {
+			err := service.UpdateScheduleTemplateStatus(this.GetAdminUserInfo().CurrentOrgId)
+			if err == nil {
+				for _, item := range schedules {
+					service.CreateScheduleTemplate(item)
+				}
+
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    int64(len(errLogs)),
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				this.ServeSuccessJSON(map[string]interface{}{
+					"msg":         "导入成功",
+					"total_num":   len(total_schedule),
+					"success_num": len(schedules),
+					"fail_num":    int64(len(errLogs)),
+				})
+			} else {
+				log := models.ExportLog{
+					LogType:    3,
+					UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+					TotalNum:   int64(len(total_schedule)),
+					FailNum:    int64(len(errLogs)),
+					SuccessNum: int64(len(schedules)),
+					CreateTime: time.Now().Unix(),
+					UpdateTime: time.Now().Unix(),
+					ExportTime: export_time,
+					Status:     1,
+				}
+				service.CreateExportLog(&log)
+
+				this.ServeSuccessJSON(map[string]interface{}{
+					"msg":         "导入成功",
+					"total_num":   len(total_schedule),
+					"success_num": len(schedules),
+					"fail_num":    int64(len(errLogs)),
+				})
+			}
+		} else {
+			log := models.ExportLog{
+				LogType:    3,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				TotalNum:   int64(len(total_schedule)),
+				FailNum:    int64(len(errLogs)),
+				SuccessNum: int64(len(schedules)),
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: export_time,
+				Status:     1,
+			}
+			service.CreateExportLog(&log)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"msg":         "导入成功",
+				"total_num":   len(total_schedule),
+				"success_num": len(schedules),
+				"fail_num":    int64(len(errLogs)),
+			})
+		}
+	}
+
+}
+
+func (c *ScheduleApiController) GetInitExcelInitDate() {
+
+	thisTime := time.Now()
+	thisTime1 := time.Now()
+	thisTime2 := time.Now()
+
+	thisTime1 = thisTime1.AddDate(0, 0, 7)
+	thisTime2 = thisTime2.AddDate(0, 0, 14)
+
+	weekDay := int(thisTime.Weekday())
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	days := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+
+	weekDay1 := int(thisTime1.Weekday())
+	if weekDay1 == 0 {
+		weekDay1 = 7
+	}
+	weekEnd1 := 7 - weekDay1
+	weekStart1 := weekEnd1 - 6
+	for index := weekStart1; index <= weekEnd1; index++ {
+		theDay := thisTime1.AddDate(0, 0, index)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+
+	weekDay2 := int(thisTime2.Weekday())
+	if weekDay2 == 0 {
+		weekDay2 = 7
+	}
+	weekEnd2 := 7 - weekDay2
+	weekStart2 := weekEnd2 - 6
+	for index := weekStart2; index <= weekEnd2; index++ {
+		theDay := thisTime2.AddDate(0, 0, index)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"days": days,
+	})
+	return
+}

enums/error_code.go

 	ErrorCodePhone = 20039
 
 	ErrorCodeLogOut = 20049
+
+	ErrorCodeExportError = 20050
 )
 
 var ErrCodeMsgs = map[int]string{
 	ErrorCodeAdminUserIsExit: "用户不存在",
 	ErrorCodePhone:           "请填写正确的联系电话",
 
-	ErrorCodeLogOut: "退出",
+	ErrorCodeLogOut:      "退出",
+	ErrorCodeExportError: "导入出错,请下载并查看相关日志",
 }
 
 type SGJError struct {

models/device_models.go

 type DeviceNumber struct {
 	ID         int64  `gorm:"column:id" json:"id"`
 	OrgID      int64  `gorm:"column:org_id" json:"-"`
-	Number     string `json:"number"`
+	Number     string `gorm:"column:number" json:"number"`
 	GroupID    int64  `gorm:"column:group_id" json:"group_id"`
 	ZoneID     int64  `gorm:"column:zone_id" json:"zone_id"`
 	Status     int8   `json:"-"`

models/patient_models.go

 	FirstTreatmentDate       int64  `gorm:"column:first_treatment_date" json:"first_treatment_date" form:"first_treatment_date"`
 	ContactName              string `gorm:"column:contact_name" json:"contact_name" form:"contact_name"`
 	UserSysBeforeCount       int64  `gorm:"column:user_sys_before_count" json:"user_sys_before_count" form:"user_sys_before_count"`
+	IsExcelExport            int64  `gorm:"column:is_excel_export" json:"is_excel_export" form:"is_excel_export"`
+
+	ContagionIds []int64 `gorm:"-"`
 }
 
 func (Patients) TableName() string {
 
 	return "sgj_user_role"
 }
+
+type ExportErrLog struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	LogType    int64  `gorm:"column:log_type" json:"log_type" form:"log_type"`
+	UserOrgId  int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	ErrMsg     string `gorm:"column:err_msg" json:"err_msg" form:"err_msg"`
+	CreateTime int64  `gorm:"column:create_time" json:"create_time" form:"create_time"`
+	UpdateTime int64  `gorm:"column:update_time" json:"update_time" form:"update_time"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	ExportTime int64  `gorm:"column:export_time" json:"export_time" form:"export_time"`
+}
+
+func (ExportErrLog) TableName() string {
+	return "xt_export_err_log"
+}
+
+type ExportLog struct {
+	ID           int64           `gorm:"column:id" json:"id" form:"id"`
+	LogType      int64           `gorm:"column:log_type" json:"log_type" form:"log_type"`
+	UserOrgId    int64           `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	TotalNum     int64           `gorm:"column:total_num" json:"total_num" form:"total_num"`
+	FailNum      int64           `gorm:"column:fail_num" json:"fail_num" form:"fail_num"`
+	SuccessNum   int64           `gorm:"column:success_num" json:"success_num" form:"success_num"`
+	CreateTime   int64           `gorm:"column:create_time" json:"create_time" form:"create_time"`
+	UpdateTime   int64           `gorm:"column:update_time" json:"update_time" form:"update_time"`
+	ExportTime   int64           `gorm:"column:export_time" json:"export_time" form:"export_time"`
+	Status       int64           `gorm:"column:status" json:"status" form:"status"`
+	ExportErrLog []*ExportErrLog `json:"err_logs" gorm:"foreignkey:ExportTime;AssociationForeignKey:ExportTime;"`
+}
+
+func (ExportLog) TableName() string {
+	return "xt_export_log"
+}

models/patient_schedule_template_models.go

 	Status         int8  `gorm:"column:status" json:"-" form:"status"`
 	CreateTime     int64 `gorm:"column:ctime" json:"-" form:"ctime"`
 	ModifyTime     int64 `gorm:"column:mtime" json:"-" form:"mtime"`
+	IsExport       int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 }
 
 func (PatientScheduleTemplateItem) TableName() string {

models/schedule_models.go

 	Status       int64 `gorm:"column:status" json:"status" form:"status"`
 	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 
 	Patient       string        `gorm:"-" json:"patient" form:"patient"`
 	DeviceZone    DeviceZone    `json:"zone" gorm:"foreignkey:ID;AssociationForeignKey:PartitionId;"`
 	Status       int64 `gorm:"column:status" json:"status" form:"status"`
 	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 
 	Patient string `gorm:"-" json:"patient" form:"patient"`
 }
 	Status       int64 `gorm:"column:status" json:"status" form:"status"`
 	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 
 	Patient              string           `gorm:"-" json:"patient" form:"patient"`
 	DeviceZone           DeviceZone       `json:"zone" gorm:"foreignkey:ID;AssociationForeignKey:PartitionId;"`

models/vm_models.go

 	Status       int64 `gorm:"column:status" json:"status" form:"status"`
 	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
 }
 
 func (VMSchedule) TableName() string {

service/app_version.go

 }
 
 func HandleData() {
-	var prescription []*models.DialysisPrescription
-	readDb.Model(&models.DialysisPrescription{}).Where("user_org_id = 12 AND record_date <= 1587571200").Find(&prescription)
-	for _, item := range prescription {
-		writeDb.Model(&models.AssessmentAfterDislysis{}).Where("user_org_id =12 AND assessment_date = ?", item.RecordDate).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "actual_ultrafiltration": item.Ultrafiltration})
+	var pe []*models.PredialysisEvaluation
+	//readDb.Model(&models.DialysisPrescription{}).Where("user_org_id = 12 AND record_date <= 1587571200").Find(&prescription)
+	//for _, item := range prescription {
+	//	writeDb.Model(&models.AssessmentAfterDislysis{}).Where("user_org_id =12 AND assessment_date = ?", item.RecordDate).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "actual_ultrafiltration": item.Ultrafiltration})
+	//}
+	readDb.Model(&models.PredialysisEvaluation{}).Where("status = 1 AND user_org_id = 9538 AND dialysis_order_id > 0").Find(&pe)
+
+	for _, item := range pe {
+		var sch models.Schedule
+		err := readDb.Model(&models.Schedule{}).Where("status = 1 AND schedule_date = ? AND patient_id = ? AND user_org_id = 9538", item.AssessmentDate, item.PatientId).First(&sch).Error
+
+		if err == nil {
+			if sch.ID > 0 {
+				order := &models.DialysisOrder{
+					DialysisDate:   sch.ScheduleDate,
+					UserOrgId:      9538,
+					PatientId:      sch.PatientId,
+					Stage:          2,
+					BedID:          sch.BedId,
+					StartNurse:     554,
+					FinishNurse:    554,
+					Status:         1,
+					CreatedTime:    sch.ScheduleDate,
+					UpdatedTime:    sch.ScheduleDate,
+					StartTime:      sch.ScheduleDate,
+					EndTime:        sch.ScheduleDate,
+					PunctureNurse:  554,
+					Creator:        554,
+					Modifier:       554,
+					FinishCreator:  554,
+					FinishModifier: 554,
+					SchedualType:   sch.ScheduleType,
+				}
+				writeDb.Create(&order)
+			}
+		}
+
 	}
+
 }

service/device_service.go

 	return &group, nil
 }
 
-func GetDeviceGroupName(name string,orgid int64)(*models.DeviceGroup,error)  {
-  group := models.DeviceGroup{}
-  err := XTReadDB().Model(&group).Where("name = ? and org_id = ? and status =1", name, orgid).Find(&group).Error
-  if err == gorm.ErrRecordNotFound {
-    return nil, err
-  }
-  if err != nil {
-    return nil, err
-  }
+func GetDeviceGroupName(name string, orgid int64) (*models.DeviceGroup, error) {
+	group := models.DeviceGroup{}
+	err := XTReadDB().Model(&group).Where("name = ? and org_id = ? and status =1", name, orgid).Find(&group).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
 
-  return &group, nil
+	return &group, nil
 
 }
 
 	return &group, nil
 }
 
-func GetUpdateDeviceGroupByName(name string,orgid int64)(group models.DeviceGroup,err error)  {
-  err = XTReadDB().Model(&group).Where("name = ? and org_id = ? and status =1",name,orgid).Find(&group).Error
-  return group,err
+func GetUpdateDeviceGroupByName(name string, orgid int64) (group models.DeviceGroup, err error) {
+	err = XTReadDB().Model(&group).Where("name = ? and org_id = ? and status =1", name, orgid).Find(&group).Error
+	return group, err
 }
 
 func UpdateDeviceGroup(group *models.DeviceGroup) error {
 	return &number, nil
 }
 
-func GetCreateDeviceNumber(num string,orgid int64)(*models.DeviceNumber,error)  {
-  number := models.DeviceNumber{}
-  err := XTReadDB().Model(&number).Where("number = ? and org_id = ? and status = 1", num, orgid).Find(&number).Error
-  if err == gorm.ErrRecordNotFound {
-    return nil, err
-  }
-  if err != nil {
-    return nil, err
-  }
+func GetCreateDeviceNumber(num string, orgid int64) (*models.DeviceNumber, error) {
+	number := models.DeviceNumber{}
+	err := XTReadDB().Model(&number).Where("number = ? and org_id = ? and status = 1", num, orgid).Find(&number).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
 
-  return &number, nil
+	return &number, nil
 }
 
 func CreateDeviceNumber(orgID int64, number string, zoneID int64, groupID int64) (*models.DeviceNumber, error) {
 	return &numberModel, nil
 }
 
-func GetDeviceNumberByName(num string,orgid int64)(number models.DeviceNumber,err error)  {
+func GetDeviceNumberByName(num string, orgid int64) (number models.DeviceNumber, err error) {
 
-  err = XTReadDB().Model(&number).Where("number = ? and org_id = ? and status =1",num,orgid).First(&number).Error
-  return number,err
+	err = XTReadDB().Model(&number).Where("number = ? and org_id = ? and status =1", num, orgid).First(&number).Error
+	return number, err
 }
 
 func UpdateDeviceNumber(number *models.DeviceNumber) error {

service/gobal_config_service.go

 
 	return doctor, err
 }
+
+func GetExportLogByType(org_id int64, log_type int64) (log []*models.ExportLog, err error) {
+	err = readDb.Model(&models.ExportLog{}).Where("user_org_id = ? AND status = 1 AND log_type = ?", org_id, log_type).
+		Preload("ExportErrLog", "status = 1").Find(&log).Error
+	return
+}

service/patient_service.go

 	return schedule, err
 }
 
-func UpdateDoctorEditAdvice(advice models.XtDoctorAdvice,orgid int64,groupno int64,date int64,patientid int64)error {
+func CreateExportPatient(patient *models.Patients, contagions []int64) (err error) {
+	user, _ := GetSgjUserByMobild(patient.Phone)
+	customer, _ := GetSgjCoustomerByMobile(patient.UserOrgId, patient.Phone)
+	utx := writeDb.Begin()
+	btx := writeUserDb.Begin()
+	if user.ID == 0 {
+		user.Mobile = patient.Phone
+		user.Avatar = patient.Avatar
+		user.AvatarThumb = patient.Avatar
+		user.Birthday = patient.Birthday
+		user.Username = patient.Name
+		user.Gender = patient.Gender
+		user.Sources = 11
+		user.Introduce = patient.Remark
+		user.Status = 1
+		user.UpdatedTime = patient.UpdatedTime
+		user.CreatedTime = patient.CreatedTime
+		err = btx.Create(&user).Error
+		if err != nil {
+			utx.Rollback()
+			btx.Rollback()
+			return
+		}
+	}
+	patient.UserId = user.ID
+
+	if customer == nil {
+		err = btx.Create(&models.SgjCustomer{
+			UserOrgId:   patient.UserOrgId,
+			UserId:      user.ID,
+			Mobile:      patient.Phone,
+			Name:        patient.Name,
+			Gender:      patient.Gender,
+			Birthday:    patient.Birthday,
+			Sources:     11,
+			Status:      1,
+			CreatedTime: patient.CreatedTime,
+			UpdatedTime: patient.UpdatedTime,
+			Avatar:      patient.Avatar,
+			Remark:      patient.Remark,
+		}).Error
+		if err != nil {
+			utx.Rollback()
+			btx.Rollback()
+			return
+		}
+	}
+
+	err = utx.Create(patient).Error
+	if err != nil {
+		utx.Rollback()
+		btx.Rollback()
+		return
+	}
+
+	var lapseto models.PatientLapseto
+	lapseto.PatientId = patient.ID
+	lapseto.LapsetoType = patient.Lapseto
+	lapseto.CreatedTime = patient.CreatedTime
+	lapseto.UpdatedTime = patient.CreatedTime
+	lapseto.Status = 1
+	lapseto.LapsetoTime = patient.CreatedTime
+
+	err = utx.Create(&lapseto).Error
+	if err != nil {
+		utx.Rollback()
+		btx.Rollback()
+		return
+	}
 
-  err := XTWriteDB().Model(&advice).Where("user_org_id = ? and groupno = ? and advice_date = ? and patient_id = ?", orgid, groupno, date, patientid).Update(map[string]interface{}{"start_time": advice.StartTime, "updated_time": advice.UpdatedTime}).Error
-  return err
+	if len(contagions) > 0 {
+		thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
+		insertParams := make([]string, 0)
+		insertData := make([]interface{}, 0)
+		for _, contagion := range contagions {
+			insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
+			insertData = append(insertData, patient.ID)
+			insertData = append(insertData, contagion)
+			insertData = append(insertData, 1)
+			insertData = append(insertData, patient.CreatedTime)
+			insertData = append(insertData, patient.UpdatedTime)
+		}
+		thisSQL += strings.Join(insertParams, ", ")
+		err = utx.Exec(thisSQL, insertData...).Error
+		if err != nil {
+			utx.Rollback()
+			btx.Rollback()
+			return
+		}
+	}
+	utx.Commit()
+	btx.Commit()
+
+	return
+}
+
+func FindPatientPhoneIsExist(phone string, org_id int64) (count int64) {
+	readDb.Model(&models.Patients{}).Where("user_org_id = ? AND phone = ? AND status = 1", org_id, phone).Count(&count)
+	return
+}
+
+func FindPatientIdCardNoIsExist(id_card_no string, org_id int64) (count int64) {
+	readDb.Model(&models.Patients{}).Where("user_org_id = ? AND id_card_no = ? AND status = 1", org_id, id_card_no).Count(&count)
+	return
+}
+
+func CreateExportErrLog(log *models.ExportErrLog) {
+	writeDb.Create(&log)
+	return
+}
+
+func FindPatientExportLog(org_id int64, export_time int64) (errLogs []*models.ExportErrLog, err error) {
+	err = readDb.Model(&models.ExportErrLog{}).Where("user_org_id = ? AND export_time = ? AND log_type = 1", org_id, export_time).Find(&errLogs).Error
+	return
+}
+
+func CreateExportLog(log *models.ExportLog) {
+	writeDb.Create(&log)
+}
+
+func UpdateDoctorEditAdvice(advice models.XtDoctorAdvice, orgid int64, groupno int64, date int64, patientid int64) error {
+
+	err := XTWriteDB().Model(&advice).Where("user_org_id = ? and groupno = ? and advice_date = ? and patient_id = ?", orgid, groupno, date, patientid).Update(map[string]interface{}{"start_time": advice.StartTime, "updated_time": advice.UpdatedTime}).Error
+	return err
 }

service/schedule_service.go

 	err = readDb.Model(&models.DoctorAdvice{}).Where("status = 1 AND user_org_id = ? AND patient_id = ? AND advice_type = 2   AND frequency_type = 2 AND advice_date > ? AND advice_date < ? AND template_id = ?  ", orgId, patient_id, end, now, temp_id).Preload("ChildDoctorAdvice", "status = 1").Find(&advice).Error
 	return
 }
+
+func FindSchPatientNameByName(name string, user_org_id int64) (patient []*models.Patients, err error) {
+	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? AND name = ? AND status = 1", user_org_id, name).Find(&patient).Error
+	return
+}
+
+func UpdateScheduleStatus(date int64, org_id int64) (err error) {
+	err = readDb.Model(&models.Schedule{}).Where("user_org_id = ? AND schedule_date >= ? AND status = 1", org_id, date).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return
+}
+
+func FindDeviceZoneByName(name string, org_id int64) (zone models.DeviceZone, err error) {
+	err = readDb.Model(&models.DeviceZone{}).Where("org_id = ? AND name = ? AND status = 1", org_id, name).First(&zone).Error
+	return
+}
+
+func FindDeviceByName(device_name string, org_id int64, zone_id int64) (devices []*models.DeviceNumber, err error) {
+	err = readDb.Model(&models.DeviceNumber{}).Where("org_id = ? AND number = ? AND zone_id = ? AND status = 1", org_id, device_name, zone_id).Find(&devices).Error
+	return
+}
+
+func FindSchedualExportLog(org_id int64, export_time int64) (errLogs []*models.ExportErrLog, err error) {
+	err = readDb.Model(&models.ExportErrLog{}).Where("user_org_id = ? AND export_time = ? AND log_type = 2", org_id, export_time).Find(&errLogs).Error
+	return
+}
+
+func FindDeviceByNameTwo(device_name string, org_id int64) (devices []*models.DeviceNumber, err error) {
+	err = readDb.Model(&models.DeviceNumber{}).Where("org_id = ? AND number = ? AND status = 1", org_id, device_name).Find(&devices).Error
+	return
+}
+
+func UpdateScheduleTemplateStatus(org_id int64) (err error) {
+	err = readDb.Model(&models.PatientScheduleTemplateItem{}).Where("org_id = ? AND status = 1", org_id).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return
+}
+
+func CreateScheduleTemplate(m *models.PatientScheduleTemplateItem) error {
+	return writeDb.Model(&models.PatientScheduleTemplateItem{}).Create(&m).Error
+}
+
+func FindSchedualTemplateExportLog(org_id int64, export_time int64) (errLogs []*models.ExportErrLog, err error) {
+	err = readDb.Model(&models.ExportErrLog{}).Where("user_org_id = ? AND export_time = ? AND log_type = 3", org_id, export_time).Find(&errLogs).Error
+	return
+}

utils/regex_helper.go

 import (
 	"fmt"
 	"regexp"
+	"strings"
 )
 
 // 正整数正则
 	fmt.Println("020-390069171 是否匹配：", reg.MatchString("020-390069171"))
 	fmt.Println("020-3900691 是否匹配：", reg.MatchString("020-3900691"))
 }
+
+var (
+	coefficient []int32 = []int32{7, 9, 10, 5, 8, 4, 2, 1, 6, 3, 7, 9, 10, 5, 8, 4, 2}
+	code        []byte  = []byte{'1', '0', 'X', '9', '8', '7', '6', '5', '4', '3', '2'}
+)
+
+// 校验一个身份证是否是合法的身份证
+func Verification(idCardNo string) bool {
+	if len(idCardNo) != 18 {
+		return false
+	}
+
+	idByte := []byte(strings.ToUpper(idCardNo))
+
+	sum := int32(0)
+	for i := 0; i < 17; i++ {
+		sum += int32(byte(idByte[i])-byte('0')) * coefficient[i]
+	}
+	return code[sum%11] == idByte[17]
+}