更新代码

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -1,17 +1,314 @@
 package new_mobile_api_controllers
 
 import (
+	"XT_New/enums"
+	"XT_New/models"
 	"XT_New/service"
+	"XT_New/utils"
+	"encoding/json"
 	"fmt"
+	"github.com/jinzhu/gorm"
+	"strconv"
+	"strings"
+	"time"
 )
 
 type NewDialysisApiController struct {
 	NewMobileBaseAPIAuthController
 }
 
+func (this *NewDialysisApiController) GetIllnesslist() {
+
+	illnesslist, err := service.GetIllnessListTwo()
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"illnesslist": illnesslist,
+	})
+}
+
 func (this *NewDialysisApiController) GetPatient() {
-	patient, err := service.GetBloodDialysisPatient(7957)
-	fmt.Print(patient)
-	fmt.Print("报错------------------", err)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+	patient, total, err := service.GetBloodDialysisPatient(orgid, page, limit)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+		"total":   total,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllPatient() {
+	fmt.Print("--------------------触发了没有")
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	patient, err := service.GetAllPatient(orgid)
+	fmt.Print("err--------------------", err)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}
+
+func (this *NewDialysisApiController) GetGeneratedialysisno() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	dialysisNo := service.ChechLastDialysisNoTwo(orgid)
+	//fmt.Print("机构ID",adminUserInfo.CurrentOrgId)
+	if dialysisNo == 0 {
+		dialysisNo = 1
+	} else {
+		dialysisNo++
+	}
+	no := strconv.FormatInt(dialysisNo, 10)
+
+	rep := 3 - len(no)
+
+	if rep > 0 {
+		no = strings.Repeat("0", rep) + no
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"no": no,
+	})
+	return
+}
+
+func (this *NewDialysisApiController) SavePatient() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Print("err", err)
+	name := dataBody["name"].(string)
+	fmt.Println("姓名", name)
+	sex := int64(dataBody["sex"].(float64))
+	fmt.Print("性别", sex)
+	idCard := dataBody["idCard"].(string)
+	fmt.Print("身份证", idCard)
+	birthday := dataBody["birthday"].(string)
+	births := strings.Split(birthday, "-")
+	fmt.Print("生日", birthday)
+	birYear, _ := strconv.Atoi(births[0])
+	age := time.Now().Year() - birYear
+	ages := int64(age)
+	fmt.Println("age是多少", ages)
+	timeLayout := "2006-01-02 15:04:05"
+	theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
+	birth := theTime.Unix()
+	fmt.Print(birth)
+	phone := dataBody["phone"].(string)
+	fmt.Print("电话号码", phone)
+	patientType := dataBody["result"].([]interface{})
+	fmt.Print("患者标签", patientType)
+	dialysis := dataBody["dialysis"].(string)
+	fmt.Print("透析号", dialysis)
+	patientsoure := int64(dataBody["patientsoure"].(float64))
+	fmt.Print("患者来源", patientsoure)
+	lapseto := int64(dataBody["lapseto"].(float64))
+	fmt.Print("留置状态", lapseto)
+	contagions := dataBody["resultTwo"].([]interface{})
+	fmt.Print("传染病", contagions)
+	adminssionNumber := dataBody["admissionNumber"].(string)
+	fmt.Print("住院号", adminssionNumber)
+	fistdate := dataBody["fistDate"].(string)
+	fmt.Print("首次透析日期", fistdate)
+	times, err := utils.ParseTimeStringToTime(timeLayout, fistdate+"00:00:00")
+	fisttime := times.Unix()
+	fmt.Print(fisttime)
+	diagonse := dataBody["diagnose"].(string)
+	fmt.Print("诊断", diagonse)
+	avatar := dataBody["avatar"].(string)
+	fmt.Print("头像", avatar)
+	//慢性病
+	requipmentId := dataBody["requipmentId"].(string)
+	fmt.Print("设备ID", requipmentId)
+	slowContagions := dataBody["resultThree"].([]interface{})
+	fmt.Print("慢性传染病", slowContagions)
+	slowDisease := int64(dataBody["slowDisease"].(float64))
+	fmt.Print("slowDisease", slowDisease)
+	bloodPatient := int64(dataBody["bloodPatient"].(float64))
+	fmt.Print("血透病人", bloodPatient)
+	slowpatient := int64(dataBody["slowPatient"].(float64))
+	fmt.Print("慢病病人", slowpatient)
+	memberpatient := int64(dataBody["memberPatient"].(float64))
+	fmt.Print("会员病人", memberpatient)
+	//会员
+	memberFistDate := dataBody["memberFistDate"].(string)
+	fmt.Print("首次透析日期", memberFistDate)
+	membertimes, err := utils.ParseTimeStringToTime(timeLayout, memberFistDate+"00:00:00")
+	memtime := membertimes.Unix()
+	fmt.Print(memtime)
+	patient_type := int64(dataBody["patientType"].(float64))
+	fmt.Print("病种", patient_type)
+	treatmentmethod := int64(dataBody["treatmentMethod"].(float64))
+	fmt.Print("治疗方式", treatmentmethod)
+
+	_, errcode := service.GetPatientData(phone, orgid)
+	if errcode == gorm.ErrRecordNotFound {
+		patients := models.Patients{
+			Name:              name,
+			Gender:            sex,
+			Birthday:          birth,
+			Age:               ages,
+			Phone:             phone,
+			Lapseto:           lapseto,
+			AdmissionNumber:   adminssionNumber,
+			FirstDialysisDate: fisttime,
+			Diagnose:          diagonse,
+			Source:            patientsoure,
+			DialysisNo:        dialysis,
+			UserOrgId:         orgid,
+			Status:            1,
+			CreatedTime:       time.Now().Unix(),
+			Avatar:            avatar,
+		}
+		err := service.CreateOldPatient(&patients)
+		fmt.Print("报错-------------", err)
+		patient, err := service.GetLastOldPatient(7957)
+		fmt.Print("病人ID", patient.ID)
+		patientsNew := models.XtPatientsNew{
+			Name:              name,
+			Gender:            sex,
+			Birthday:          birth,
+			Age:               ages,
+			Phone:             phone,
+			Lapseto:           lapseto,
+			AdmissionNumber:   adminssionNumber,
+			FirstDialysisDate: fisttime,
+			Diagnose:          diagonse,
+			Source:            patientsoure,
+			DialysisNo:        dialysis,
+			UserOrgId:         orgid,
+			Status:            1,
+			CreatedTime:       time.Now().Unix(),
+			Avatar:            avatar,
+			MemberPatients:    memberpatient,
+			BloodPatients:     bloodPatient,
+			SlowPatients:      slowpatient,
+			BloodId:           patient.ID,
+		}
+		err = service.CreateNewPatient(&patientsNew)
+		fmt.Print("报错", err)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"patient": patientsNew,
+		})
+	} else if errcode == nil {
+		fmt.Print("病人已存在")
+		return
+	} else {
+
+	}
+}
+
+func (this *NewDialysisApiController) GetPatientDetail() {
+	id, _ := this.GetInt64("id")
+	//获取病人详情信息
+	detail, err := service.GetPatientDetailTwo(id)
+	//获取血透医嘱管理
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patientDetail": detail,
+	})
+}
+
+func (this *NewDialysisApiController) GetDoctorAdvices() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	//跟据新表id获取老表id
+	newPatientInfo, _ := service.GetPatientDetailTwo(id)
+	//获取病人ID
+	doctor_type, _ := this.GetInt64("type")
+	fmt.Print("医嘱内型", doctor_type)
+	start := this.GetString("startime")
+	fmt.Print("start", start)
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("开始时间", startime)
+	end := this.GetString("endtime")
+	fmt.Print("end", end)
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("结束时间", endtime)
+	limit, _ := this.GetInt64("limit")
+	page, _ := this.GetInt64("page")
+	advice, total, err := service.GetNewDoctorAdvice(newPatientInfo.BloodId, doctor_type, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"advice": advice,
+		"total":  total,
+	})
+}
+
+func (this *NewDialysisApiController) GetDryWeight() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	dryweight, total, err := service.GetDryWeight(patient.BloodId, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"dryweight": dryweight,
+		"total":     total,
+	})
+}
 
+func (this *NewDialysisApiController) ToSearch() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	name := this.GetString("name")
+	search, err := service.ToSearch(orgId, name)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"search": search,
+	})
 }

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -5,5 +5,13 @@ import "github.com/astaxie/beego"
 // 平板端路由，以 /m/api 为前缀
 func NewMobileAPIControllersRegisterRouters() {
 
+	beego.Router("m/api/patient/getillnesslist", &NewDialysisApiController{}, "Get:GetIllnesslist")
+	beego.Router("/m/api/patients/generatedialysisnotwo", &NewDialysisApiController{}, "Get:GetGeneratedialysisno")
 	beego.Router("/m/api/patient/getbloodDialysisPatient", &NewDialysisApiController{}, "Get:GetPatient")
+	beego.Router("/m/api/patient/savepatient", &NewDialysisApiController{}, "Post:SavePatient")
+	beego.Router("/m/api/patient/getpatientdetail", &NewDialysisApiController{}, "Get:GetPatientDetail")
+	beego.Router("/m/api/patient/getdoctoradvices", &NewDialysisApiController{}, "Get:GetDoctorAdvices")
+	beego.Router("/m/api/paitent/getdryweight", &NewDialysisApiController{}, "Get:GetDryWeight")
+	beego.Router("m/api/patient/getbloodDialysisPatientwo", &NewDialysisApiController{}, "Get:GetAllPatient")
+	beego.Router("m/api/patient/tosearch", &NewDialysisApiController{}, "Get:ToSearch")
 }

models/patient_models.go

@@ -379,3 +379,113 @@ type FormItem struct {
 	RangeType   int64  `json:"range_type"`
 	Value       string `json:"value"`
 }
+
+type SgjUserIllness struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	IllnessName string `gorm:"column:illness_name" json:"illness_name" form:"illness_name"`
+	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"`
+}
+
+func (SgjUserIllness) TableName() string {
+	return "sgj_user_illness"
+}
+
+type XtPatientsNew struct {
+	ID                           int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                    int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId                       int64   `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Avatar                       string  `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	PatientType                  int64   `gorm:"column:patient_type" json:"patient_type" form:"patient_type"`
+	DialysisNo                   string  `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	AdmissionNumber              string  `gorm:"column:admission_number" json:"admission_number" form:"admission_number"`
+	Source                       int64   `gorm:"column:source" json:"source" form:"source"`
+	Lapseto                      int64   `gorm:"column:lapseto" json:"lapseto" form:"lapseto"`
+	PartitionId                  int64   `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId                        int64   `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	Name                         string  `gorm:"column:name" json:"name" form:"name"`
+	Alias                        string  `gorm:"column:alias" json:"alias" form:"alias"`
+	Gender                       int64   `gorm:"column:gender" json:"gender" form:"gender"`
+	MaritalStatus                int64   `gorm:"column:marital_status" json:"marital_status" form:"marital_status"`
+	IdCardNo                     string  `gorm:"column:id_card_no" json:"id_card_no" form:"id_card_no"`
+	Birthday                     int64   `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	ReimbursementWayId           int64   `gorm:"column:reimbursement_way_id" json:"reimbursement_way_id" form:"reimbursement_way_id"`
+	HealthCareType               int64   `gorm:"column:health_care_type" json:"health_care_type" form:"health_care_type"`
+	HealthCareNo                 string  `gorm:"column:health_care_no" json:"health_care_no" form:"health_care_no"`
+	HealthCareDueDate            int64   `gorm:"column:health_care_due_date" json:"health_care_due_date" form:"health_care_due_date"`
+	Height                       int64   `gorm:"column:height" json:"height" form:"height"`
+	BloodType                    int64   `gorm:"column:blood_type" json:"blood_type" form:"blood_type"`
+	Rh                           int64   `gorm:"column:rh" json:"rh" form:"rh"`
+	HealthCareDueAlertDate       int64   `gorm:"column:health_care_due_alert_date" json:"health_care_due_alert_date" form:"health_care_due_alert_date"`
+	EducationLevel               int64   `gorm:"column:education_level" json:"education_level" form:"education_level"`
+	Profession                   int64   `gorm:"column:profession" json:"profession" form:"profession"`
+	Phone                        string  `gorm:"column:phone" json:"phone" form:"phone"`
+	HomeTelephone                string  `gorm:"column:home_telephone" json:"home_telephone" form:"home_telephone"`
+	RelativePhone                string  `gorm:"column:relative_phone" json:"relative_phone" form:"relative_phone"`
+	RelativeRelations            string  `gorm:"column:relative_relations" json:"relative_relations" form:"relative_relations"`
+	HomeAddress                  string  `gorm:"column:home_address" json:"home_address" form:"home_address"`
+	WorkUnit                     string  `gorm:"column:work_unit" json:"work_unit" form:"work_unit"`
+	UnitAddress                  string  `gorm:"column:unit_address" json:"unit_address" form:"unit_address"`
+	Children                     int64   `gorm:"column:children" json:"children" form:"children"`
+	ReceivingDate                int64   `gorm:"column:receiving_date" json:"receiving_date" form:"receiving_date"`
+	IsHospitalFirstDialysis      int64   `gorm:"column:is_hospital_first_dialysis" json:"is_hospital_first_dialysis" form:"is_hospital_first_dialysis"`
+	FirstDialysisDate            int64   `gorm:"column:first_dialysis_date" json:"first_dialysis_date" form:"first_dialysis_date"`
+	FirstDialysisHospital        string  `gorm:"column:first_dialysis_hospital" json:"first_dialysis_hospital" form:"first_dialysis_hospital"`
+	PredialysisCondition         string  `gorm:"column:predialysis_condition" json:"predialysis_condition" form:"predialysis_condition"`
+	PreHospitalDialysisFrequency string  `gorm:"column:pre_hospital_dialysis_frequency" json:"pre_hospital_dialysis_frequency" form:"pre_hospital_dialysis_frequency"`
+	PreHospitalDialysisTimes     int64   `gorm:"column:pre_hospital_dialysis_times" json:"pre_hospital_dialysis_times" form:"pre_hospital_dialysis_times"`
+	HospitalFirstDialysisDate    int64   `gorm:"column:hospital_first_dialysis_date" json:"hospital_first_dialysis_date" form:"hospital_first_dialysis_date"`
+	InductionPeriod              int64   `gorm:"column:induction_period" json:"induction_period" form:"induction_period"`
+	InitialDialysis              int64   `gorm:"column:initial_dialysis" json:"initial_dialysis" form:"initial_dialysis"`
+	TotalDialysis                int64   `gorm:"column:total_dialysis" json:"total_dialysis" form:"total_dialysis"`
+	AttendingDoctorId            int64   `gorm:"column:attending_doctor_id" json:"attending_doctor_id" form:"attending_doctor_id"`
+	HeadNurseId                  int64   `gorm:"column:head_nurse_id" json:"head_nurse_id" form:"head_nurse_id"`
+	Evaluate                     string  `gorm:"column:evaluate" json:"evaluate" form:"evaluate"`
+	Diagnose                     string  `gorm:"column:diagnose" json:"diagnose" form:"diagnose"`
+	Remark                       string  `gorm:"column:remark" json:"remark" form:"remark"`
+	RegistrarsId                 int64   `gorm:"column:registrars_id" json:"registrars_id" form:"registrars_id"`
+	Registrars                   string  `gorm:"column:registrars" json:"registrars" form:"registrars"`
+	QrCode                       string  `gorm:"column:qr_code" json:"qr_code" form:"qr_code"`
+	BindingState                 int64   `gorm:"column:binding_state" json:"binding_state" form:"binding_state"`
+	PatientComplains             string  `gorm:"column:patient_complains" json:"patient_complains" form:"patient_complains"`
+	PresentHistory               string  `gorm:"column:present_history" json:"present_history" form:"present_history"`
+	PastHistory                  string  `gorm:"column:past_history" json:"past_history" form:"past_history"`
+	Temperature                  float64 `gorm:"column:temperature" json:"temperature" form:"temperature"`
+	Pulse                        int64   `gorm:"column:pulse" json:"pulse" form:"pulse"`
+	Respiratory                  int64   `gorm:"column:respiratory" json:"respiratory" form:"respiratory"`
+	Sbp                          int64   `gorm:"column:sbp" json:"sbp" form:"sbp"`
+	Dbp                          int64   `gorm:"column:dbp" json:"dbp" form:"dbp"`
+	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"`
+	Nation                       string  `gorm:"column:nation" json:"nation" form:"nation"`
+	NativePlace                  string  `gorm:"column:native_place" json:"native_place" form:"native_place"`
+	Age                          int64   `gorm:"column:age" json:"age" form:"age"`
+	InfectiousNextRecordTime     int64   `gorm:"column:infectious_next_record_time" json:"infectious_next_record_time" form:"infectious_next_record_time"`
+	IsInfectious                 int64   `gorm:"column:is_infectious" json:"is_infectious" form:"is_infectious"`
+	RemindCycle                  int64   `gorm:"column:remind_cycle" json:"remind_cycle" form:"remind_cycle"`
+	ResponseResult               string  `gorm:"column:response_result" json:"response_result" form:"response_result"`
+	IsOpenRemind                 int64   `gorm:"column:is_open_remind" json:"is_open_remind" form:"is_open_remind"`
+	FirstTreatmentDate           int64   `gorm:"column:first_treatment_date" json:"first_treatment_date" form:"first_treatment_date"`
+	DialysisAge                  int64   `gorm:"column:dialysis_age" json:"dialysis_age" form:"dialysis_age"`
+	ExpenseKind                  int64   `gorm:"column:expense_kind" json:"expense_kind" form:"expense_kind"`
+	TellPhone                    string  `gorm:"column:tell_phone" json:"tell_phone" form:"tell_phone"`
+	ContactName                  string  `gorm:"column:contact_name" json:"contact_name" form:"contact_name"`
+	BloodPatients                int64   `gorm:"column:blood_patients" json:"blood_patients" form:"blood_patients"`
+	SlowPatients                 int64   `gorm:"column:slow_patients" json:"slow_patients" form:"slow_patients"`
+	MemberPatients               int64   `gorm:"column:member_patients" json:"member_patients" form:"member_patients"`
+	EcommerPatients              string  `gorm:"column:ecommer_patients" json:"ecommer_patients" form:"ecommer_patients"`
+	BloodId                      int64   `gorm:"column:blood_id" json:"blood_id" form:"blood_id"`
+	SlowId                       int64   `gorm:"column:slow_id" json:"slow_id" form:"slow_id"`
+	MemberId                     int64   `gorm:"column:member_id" json:"member_id" form:"member_id"`
+}
+
+func (XtPatientsNew) TableName() string {
+	return "xt_patients_new"
+}
+
+type PatientsNew struct {
+	ID   int64  `gorm:"column:id" json:"id" form:"id"`
+	Name string `gorm:"column:name" json:"name" form:"name"`
+}

routers/router.go

@@ -5,7 +5,6 @@ import (
 	//admin_api "XT_New/controllers/admin_api_controllers"
 	m_api "XT_New/controllers/mobile_api_controllers"
 	new_m_api "XT_New/controllers/new_mobile_api_controllers"
-
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/plugins/cors"
 )

service/patientmanage_service.go

@@ -1,9 +1,253 @@
 package service
 
-import "XT_New/models"
+import (
+	"XT_New/models"
+	"fmt"
+	"github.com/jinzhu/gorm"
+	"strconv"
+	"strings"
+)
 
-func GetBloodDialysisPatient(orgid int64) (paitents []*models.Patients, err error) {
+func GetIllnessListTwo() (ills []*models.Illness, err error) {
+	err = readUserDb.Where("status=1").Find(&ills).Error
+	return
+}
+
+func GetBloodDialysisPatient(orgid int64, page int64, limit int64) (patients []*models.Patients, total int64, err error) {
+	db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
+		Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
+	fmt.Println("err是什么", err)
+	return
+}
+
+func GetAllPatient(orgid int64) (patients []*models.PatientsNew, err error) {
+	db := XTReadDB().Table("xt_patients_new as x")
+
+	err = db.Raw("select id,name from xt_patients_new where user_org_id = ? and status =1", orgid).Scan(&patients).Error
+	return
+}
+
+func ChechLastDialysisNoTwo(orgID int64) (dialysisNo int64) {
+	var patient models.Patients
+	err := readDb.Model(&models.Patients{}).Where("user_org_id=? and status = 1", orgID).Order("dialysis_no desc").First(&patient).Error
+	if err != nil {
+		return
+	}
+
+	if patient.ID == 0 {
+		return
+	}
+	dialysisNo, _ = strconv.ParseInt(patient.DialysisNo, 10, 64)
+	return
+}
+
+func CreateOldPatient(patients *models.Patients) error {
+
+	err := XTWriteDB().Create(&patients).Error
+	return err
+}
+
+func GetLastOldPatient(orgid int64) (models.Patients, error) {
+	patients := models.Patients{}
+	err := XTReadDB().Model(&patients).Where("user_org_id = ? and status =1", orgid).Last(&patients).Error
+	return patients, err
+}
+
+func CreateNewPatient(patientsNew *models.XtPatientsNew) error {
+	err := XTWriteDB().Create(&patientsNew).Error
+	return err
+}
+
+func GetPatientDetailTwo(id int64) (models.XtPatientsNew, error) {
+	patients := models.XtPatientsNew{}
+	err := XTReadDB().Where("id=? and status = 1", id).Find(&patients).Error
+	return patients, err
+}
+
+func CreatePatientTwo(patient *models.Patients, contagions []int64, diseases []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
+	}
+
+	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
+		}
+	}
+	if len(diseases) > 0 {
+		thisSQL := "INSERT INTO xt_patients_chronic_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
+		insertParams := make([]string, 0)
+		insertData := make([]interface{}, 0)
+		for _, disease := range diseases {
+			insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
+			insertData = append(insertData, patient.ID)
+			insertData = append(insertData, disease)
+			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 GetPatientData(phone string, orgid int64) (*models.Patients, error) {
+	var patientnew models.Patients
+	var err error
+	err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status =?", orgid, phone, 1).Find(&patientnew).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patientnew, nil
+}
+
+func GetNewDoctorAdvice(patientid int64, doctype int64, startime int64, endtime int64, limit int64, page int64, orgId int64) (doctoradvice []*models.DoctorAdvices, total int64, err error) {
+	db := XTReadDB().Table("xt_doctor_advice as x").Where("x.status = 1")
+	if orgId > 0 {
+		db = db.Where("x.user_org_id = ?", orgId)
+	}
+
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if startime != 0 {
+		db = db.Where("x.record_date>= ?", startime)
+	}
+	if endtime != 0 {
+		db = db.Where("x.record_date<=?", endtime)
+	}
+
+	if doctype > 0 {
+		db = db.Where("x.advice_type = ?", doctype)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.record_date desc").Offset(offset).Limit(limit).Group("x.id").Select("x.id, x.user_org_id, x.patient_id, x.advice_type, x.advice_date, x.record_date, x.start_time, x.advice_name,x.advice_desc, x.reminder_date, x.drug_spec, x.drug_spec_unit, x.single_dose, x.single_dose_unit, x.prescribing_number, x.prescribing_number_unit, x.delivery_way, x.execution_frequency, x.advice_doctor, x.created_time,x.updated_time, x.advice_affirm, x.remark, x.stop_time, x.stop_reason, x.stop_doctor, x.stop_state, x.parent_id, x.execution_time, x.execution_staff, x.execution_state, x.checker, x.check_state, x.check_time, x.groupno,x.remind_type,x.frequency_type,x.day_count,x.week_day,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.advice_doctor").Scan(&doctoradvice).Error
+	return
+}
+
+func GetDryWeight(patientid int64, startime int64, endtime int64, limit int64, page int64, orgId int64) (dryWeight []*models.XtPatientDryweight, total int64, err error) {
+	db := XTReadDB().Table("xt_patient_dryweight as x").Where("x.status = 1")
+	if orgId > 0 {
+		db = db.Where("x.user_org_id = ?", orgId)
+	}
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if startime > 0 {
+		db = db.Where("x.ctime >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.ctime <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.ctime desc").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.dry_weight,x.creator,x.remakes,x.patient_id,x.ctime,x.adjusted_value,x.user_id,x.user_org_id,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.creator").Scan(&dryWeight).Error
+	return dryWeight, total, err
+}
 
-	err = XTReadDB().Model(&paitents).Where("user_org_id = ? and status =1", orgid).Find(&paitents).Error
-	return paitents, err
+func ToSearch(orgId int64, name string) (patient []*models.XtPatientsNew, err error) {
+	likeKey := "%" + name + "%"
+	err = XTReadDB().Where("name like ? and user_org_id = ?", likeKey, orgId).Find(&patient).Error
+	return patient, err
 }