更新数据

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -1713,7 +1713,6 @@ func (this *NewDialysisApiController) SaveBirthday() {
 	timeLayout := "2006-01-02 15:04:05"
 	theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
 	birth := theTime.Unix()
-	fmt.Print("-----======", birth)
 	role := models.App_Role{
 		Birthday: birth,
 	}
@@ -1758,3 +1757,180 @@ func (this *NewDialysisApiController) GetRoleName() {
 		"positionName": positionName,
 	})
 }
+
+func (this *NewDialysisApiController) SavePartition() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	name := this.GetString("name")
+	fmt.Println("分区名称", name)
+	zonetype, _ := this.GetInt64("type")
+	fmt.Println("分区型号", zonetype)
+	strInt64 := strconv.FormatInt(zonetype, 10)
+	typeid, _ := strconv.Atoi(strInt64)
+	zone := models.DeviceZone{
+		Name:       name,
+		Type:       typeid,
+		OrgID:      adminInfo.Org.Id,
+		Status:     1,
+		CreateTime: time.Now().Unix(),
+	}
+	err := service.CreatedZone(&zone)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"zone": zone,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllZone() {
+
+	adminUser := this.GetMobileAdminUserInfo()
+	orgid := adminUser.Org.Id
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+	zone, total, err := service.GetAllZone(orgid, page, limit)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"zone":  zone,
+		"total": total,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteZone() {
+	id, _ := this.GetInt64("id")
+	err := service.DeleteZoneById(id)
+	fmt.Println("删除失败", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "删除失败"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *NewDialysisApiController) SaveGroup() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgid := adminUser.Org.Id
+	name := this.GetString("name")
+	fmt.Println("name", name)
+	group := models.DeviceGroup{
+		Name:       name,
+		Status:     1,
+		CreateTime: time.Now().Unix(),
+		OrgID:      orgid,
+	}
+	err := service.SaveGroup(&group)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"group": group,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllGroup() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgid := adminUser.Org.Id
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	group, total, err := service.GetAllGroup(orgid, page, limit)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"group": group,
+		"total": total,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteGroup() {
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", id)
+	err := service.DeleteGroup(id)
+	fmt.Println("删除失败", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "删除失败"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *NewDialysisApiController) GetAllGroupOne() {
+	admininfo := this.GetMobileAdminUserInfo()
+	orgid := admininfo.Org.Id
+	zone, _ := service.GetAllZoneOne(orgid)
+	group, err := service.GetAllGroupOne(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"zone":  zone,
+		"group": group,
+	})
+}
+
+func (this *NewDialysisApiController) SaveBed() {
+	adminuser := this.GetMobileAdminUserInfo()
+	orgid := adminuser.Org.Id
+	name := this.GetString("name")
+	fmt.Println("name", name)
+	zone, _ := this.GetInt64("zone")
+	fmt.Print("zone", zone)
+	group, _ := this.GetInt64("group")
+	fmt.Println("group", group)
+	number := models.DeviceNumber{
+		Number:     name,
+		ZoneID:     zone,
+		GroupID:    group,
+		OrgID:      orgid,
+		Status:     1,
+		CreateTime: time.Now().Unix(),
+	}
+	err := service.CreateNumber(&number)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"number": number,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllNumber() {
+	admininfo := this.GetMobileAdminUserInfo()
+	orgid := admininfo.Org.Id
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	number, total, err := service.GetAllNumber(page, limit, orgid)
+	zone, _ := service.GetAllZoneOne(orgid)
+	group, _ := service.GetAllGroupOne(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"number": number,
+		"total":  total,
+		"zone":   zone,
+		"group":  group,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteBed() {
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", id)
+	err := service.DeleteBed(id)
+	fmt.Println("删除失败", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "删除失败"
+	this.ServeSuccessJSON(returnData)
+	return
+}

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -107,4 +107,14 @@ func NewMobileAPIControllersRegisterRouters() {
 	beego.Router("/m/api/patient/savebirthday", &NewDialysisApiController{}, "Post:SaveBirthday")
 	beego.Router("/m/api/patient/getorgname", &NewDialysisApiController{}, "Get:GetOrgName")
 	beego.Router("/m/api/patient/getrolename", &NewDialysisApiController{}, "Get:GetRoleName")
+	beego.Router("/m/api/patient/savepartition", &NewDialysisApiController{}, "Get:SavePartition")
+	beego.Router("/m/api/patient/getallzone", &NewDialysisApiController{}, "Get:GetAllZone")
+	beego.Router("/m/api/patient/deletezone", &NewDialysisApiController{}, "Delete:DeleteZone")
+	beego.Router("/m/api/patient/savegroup", &NewDialysisApiController{}, "Get:SaveGroup")
+	beego.Router("/m/api/patient/getallgroup", &NewDialysisApiController{}, "Get:GetAllGroup")
+	beego.Router("/m/api/patient/deletegroup", &NewDialysisApiController{}, "Delete:DeleteGroup")
+	beego.Router("m/api/patient/getallgroupone", &NewDialysisApiController{}, "Get:GetAllGroupOne")
+	beego.Router("/m/api/patient/savebed", &NewDialysisApiController{}, "Get:SaveBed")
+	beego.Router("/m/api/patient/getallnumber", &NewDialysisApiController{}, "Get:GetAllNumber")
+	beego.Router("/m/api/patient/deletebed", &NewDialysisApiController{}, "Delete:DeleteBed")
 }

service/patientmanage_service.go

@@ -1001,3 +1001,81 @@ func SaveBirthday(id int64, orgid int64, appid int64, role *models.App_Role) err
 	err := UserWriteDB().Model(models.App_Role{}).Where("org_id = ? and app_id = ? and admin_user_id = ?", orgid, appid, id).Update(map[string]interface{}{"birthday": role.Birthday, "mtime": time.Now().Unix()}).Error
 	return err
 }
+
+func CreatedZone(zone *models.DeviceZone) error {
+
+	err := XTWriteDB().Model(&zone).Create(&zone).Error
+	return err
+}
+
+func GetAllZone(orgid int64, page int64, limit int64) (zone []*models.DeviceZone, total int64, err error) {
+
+	db := XTReadDB().Table("xt_device_zone as x").Where("x.status =1")
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("x.ctime desc").Select("x.id,x.org_id,x.name,x.type").Find(&zone).Error
+	return zone, total, err
+}
+
+func DeleteZoneById(id int64) error {
+
+	err := XTWriteDB().Model(models.DeviceZone{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
+	return err
+}
+
+func SaveGroup(group *models.DeviceGroup) error {
+	err := XTWriteDB().Model(&group).Create(&group).Error
+	return err
+}
+
+func GetAllGroup(orgid int64, page int64, limit int64) (group []*models.DeviceGroup, total int64, err error) {
+	db := XTReadDB().Table("xt_device_group as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("x.ctime desc").Select("x.id,x.org_id,x.name,x.status,x.ctime,x.mtime").Find(&group).Error
+	return group, total, err
+}
+
+func DeleteGroup(id int64) error {
+	err := XTWriteDB().Model(models.DeviceGroup{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
+	return err
+}
+
+func GetAllZoneOne(orgid int64) (zone []*models.DeviceZone, err error) {
+
+	err = XTReadDB().Model(&zone).Where("org_id = ?", orgid).Find(&zone).Error
+	return zone, err
+}
+
+func GetAllGroupOne(orgid int64) (group []*models.DeviceGroup, err error) {
+
+	err = XTReadDB().Model(&group).Where("org_id =?", orgid).Find(&group).Error
+	return group, err
+}
+
+func CreateNumber(number *models.DeviceNumber) error {
+
+	err := XTWriteDB().Model(&number).Create(&number).Error
+	return err
+}
+
+func GetAllNumber(page int64, limit int64, orgid int64) (number []*models.DeviceNumber, total int64, err error) {
+
+	db := XTReadDB().Table("xt_device_number as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("x.ctime desc").Select("x.id,x.org_id,x.number,x.group_id,x.zone_id,x.status").Find(&number).Error
+
+	return number, total, err
+}
+
+func DeleteBed(id int64) error {
+	err := XTWriteDB().Model(models.DeviceNumber{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "ctime": time.Now().Unix()}).Error
+	return err
+}