添加机构信息模块

controllers/admin_user/org_controller.go

@@ -0,0 +1,294 @@
+package admin_user
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/district_service"
+	"SCRM/service/org_service"
+	"SCRM/utils"
+	"encoding/json"
+	"reflect"
+	"time"
+
+	"github.com/astaxie/beego"
+)
+
+func OrgInfoCtlRegistRouters() {
+	beego.Router("/api/orginfo/getinfo", &OrgInfoApiController{}, "get:GetOrgInfo")
+	beego.Router("/api/orginfo/savegallery", &OrgInfoApiController{}, "post:SaveOrgGallery")
+	beego.Router("/api/orginfo/deletegallery", &OrgInfoApiController{}, "delete:DeleteOrgGallery")
+	beego.Router("/api/orginfo/edit", &OrgInfoApiController{}, "post:EditOrgInfo")
+}
+
+type OrgInfoApiController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *OrgInfoApiController) GetOrgInfo() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+
+	orgInfo := adminUserInfo.Orgs[adminUserInfo.CurrentOrgId]
+	provinces, _ := district_service.GetDistrictsByUpid(0)
+	var citys []*models.District
+	var districts []*models.District
+	if orgInfo.Province > 0 {
+		citys, _ = district_service.GetDistrictsByUpid(orgInfo.Province)
+	}
+	if orgInfo.City > 0 {
+		districts, _ = district_service.GetDistrictsByUpid(orgInfo.City)
+	}
+
+	orgtypes, _ := org_service.GetOrgTypes()
+
+	illness, _ := org_service.GetIllnessList()
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"orginfo":   orgInfo,
+		"provinces": provinces,
+		"citys":     citys,
+		"districts": districts,
+		"orgtypes":  orgtypes,
+		"illness":   illness,
+	})
+	return
+}
+
+func (c *OrgInfoApiController) EditOrgInfo() {
+	adminUserInfo := c.GetAdminUserInfo()
+
+	if !adminUserInfo.AdminUser.IsSuperAdmin {
+		c.ServeFailJsonSend(enums.ErrorCodePermissionDenied, "权限不足")
+		return
+	}
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	orgInfo := adminUserInfo.Orgs[adminUserInfo.CurrentOrgId]
+	org := *orgInfo
+
+	if dataBody["org_name"] == nil || reflect.TypeOf(dataBody["org_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数：机构名称")
+		return
+	}
+	orgName, _ := dataBody["org_name"].(string)
+	if len(orgName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "机构名称不能为空")
+		return
+	}
+	org.OrgName = orgName
+
+	if dataBody["contact_name"] == nil || reflect.TypeOf(dataBody["contact_name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数：联系人姓名")
+		return
+	}
+	contactName, _ := dataBody["contact_name"].(string)
+	if len(contactName) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "联系人姓名不能为空")
+		return
+	}
+	org.ContactName = contactName
+
+	// if dataBody["org_short_name"] == nil || reflect.TypeOf(dataBody["org_short_name"]).String() != "string" {
+	// 	c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数：商家简称")
+	// 	return
+	// }
+	// orgShortName, _ := dataBody["org_short_name"].(string)
+	// if len(orgShortName) == 0 {
+	// 	c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "商家简称不能为空")
+	// 	return
+	// }
+	org.OrgShortName = orgName
+
+	if dataBody["org_introduction"] == nil || reflect.TypeOf(dataBody["org_introduction"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数：机构介绍")
+		return
+	}
+	orgIntroduction, _ := dataBody["org_introduction"].(string)
+	if len(orgIntroduction) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "机构介绍不能为空")
+		return
+	}
+	org.OrgIntroduction = orgIntroduction
+
+	if dataBody["org_logo"] == nil || reflect.TypeOf(dataBody["org_logo"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数：机构头像")
+		return
+	}
+	orgLogo, _ := dataBody["org_logo"].(string)
+	if len(orgLogo) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "机构头像不能为空")
+		return
+	}
+	org.OrgLogo = orgLogo
+
+	if dataBody["province"] != nil || reflect.TypeOf(dataBody["province"]).String() == "float64" {
+		province := int64(dataBody["province"].(float64))
+		org.Province = province
+	}
+
+	if dataBody["city"] != nil || reflect.TypeOf(dataBody["city"]).String() == "float64" {
+		city := int64(dataBody["city"].(float64))
+		org.City = city
+	}
+
+	if dataBody["district"] != nil || reflect.TypeOf(dataBody["district"]).String() == "float64" {
+		district := int64(dataBody["district"].(float64))
+		org.District = district
+	}
+
+	if dataBody["address"] != nil || reflect.TypeOf(dataBody["address"]).String() == "string" {
+		address, _ := dataBody["address"].(string)
+		org.Address = address
+	}
+
+	if dataBody["org_type"] != nil || reflect.TypeOf(dataBody["org_type"]).String() == "float64" {
+		orgType := int64(dataBody["org_type"].(float64))
+		org.OrgType = orgType
+	}
+
+	if dataBody["telephone"] != nil || reflect.TypeOf(dataBody["telephone"]).String() == "string" {
+		telephone, _ := dataBody["telephone"].(string)
+		org.Telephone = telephone
+	}
+
+	if dataBody["operating_state"] != nil || reflect.TypeOf(dataBody["operating_state"]).String() == "float64" {
+		operatingState := int64(dataBody["operating_state"].(float64))
+		org.OperatingState = operatingState
+	}
+
+	if dataBody["business_week"] != nil || reflect.TypeOf(dataBody["business_week"]).String() == "string" {
+		businessWeek, _ := dataBody["business_week"].(string)
+		org.BusinessWeek = businessWeek
+	}
+
+	if dataBody["business_time"] != nil || reflect.TypeOf(dataBody["business_time"]).String() == "string" {
+		businessTime, _ := dataBody["business_time"].(string)
+		org.BusinessTime = businessTime
+	}
+	if dataBody["illness"] != nil || reflect.TypeOf(dataBody["illness"]).String() == "string" {
+		illness, _ := dataBody["illness"].(string)
+		org.Illness = illness
+	}
+
+	timeNow := time.Now().Unix()
+	org.ModifyTime = timeNow
+	org.OrgGallery = nil
+	err = org_service.UpdateOrgInfo(&org)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	orgInfo.OrgName = orgName
+	orgInfo.OrgShortName = orgName
+	orgInfo.OrgIntroduction = orgIntroduction
+	orgInfo.OrgLogo = orgLogo
+	orgInfo.Province = org.Province
+	orgInfo.District = org.District
+	orgInfo.City = org.City
+	orgInfo.OrgType = org.OrgType
+	orgInfo.Telephone = org.Telephone
+	orgInfo.OperatingState = org.OperatingState
+	orgInfo.BusinessWeek = org.BusinessWeek
+	orgInfo.BusinessTime = org.BusinessTime
+	orgInfo.Illness = org.Illness
+	orgInfo.ContactName = org.ContactName
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+	return
+}
+
+func (c *OrgInfoApiController) SaveOrgGallery() {
+	adminUserInfo := c.GetAdminUserInfo()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	if dataBody["type"] == nil || reflect.TypeOf(dataBody["type"]).String() != "float64" {
+		utils.ErrorLog("type")
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	galleryType := int64(dataBody["type"].(float64))
+	if galleryType != 1 && galleryType != 2 {
+		utils.ErrorLog("galleryType != 1&&2")
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	if dataBody["url"] == nil || reflect.TypeOf(dataBody["url"]).String() != "string" {
+		utils.ErrorLog("url")
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	url, _ := dataBody["url"].(string)
+	if len(url) == 0 {
+		utils.ErrorLog("len(url) == 0")
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	timeNow := time.Now().Unix()
+	var gallery models.OrgGallery
+	gallery.Type = galleryType
+	gallery.Url = url
+	gallery.OrgId = adminUserInfo.CurrentOrgId
+	gallery.Status = 1
+	gallery.Ctime = timeNow
+	gallery.Mtime = timeNow
+	err = org_service.CreateOrgGalleryItem(&gallery)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	orgInfo := adminUserInfo.Orgs[adminUserInfo.CurrentOrgId]
+	orgInfo.OrgGallery = append(orgInfo.OrgGallery, &gallery)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+	return
+
+}
+
+func (c *OrgInfoApiController) DeleteOrgGallery() {
+	adminUserInfo := c.GetAdminUserInfo()
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	err := org_service.DeleteOrgGalleryItem(id)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	orgInfo := adminUserInfo.Orgs[adminUserInfo.CurrentOrgId]
+	for index, item := range orgInfo.OrgGallery {
+		if item.ID == id {
+			orgInfo.OrgGallery = append(orgInfo.OrgGallery[:index], orgInfo.OrgGallery[index+1:]...)
+		}
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+	return
+
+}

controllers/admin_user/router_collector.go

@@ -2,4 +2,5 @@ package admin_user
 
 func RegisterRouters() {
 	AdminCtlRegistRouters()
+	OrgInfoCtlRegistRouters()
 }

controllers/global/district_controller.go

@@ -0,0 +1,26 @@
+package global
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/service/district_service"
+
+	"github.com/astaxie/beego"
+)
+
+type DistrictApiController struct {
+	base_ctl.BaseAPIController
+}
+
+func DistrictCtlRegistRouters() {
+	beego.Router("/api/district/getdistrictsbyupid", &DistrictApiController{}, "get:GetDistrictsByUpid")
+}
+
+func (c *DistrictApiController) GetDistrictsByUpid() {
+	id, _ := c.GetInt64("id", 0)
+	citys, _ := district_service.GetDistrictsByUpid(id)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"citys": citys,
+	})
+	return
+}

controllers/global/qiniu_controller.go

@@ -0,0 +1,35 @@
+package global
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	base_service "SCRM/service"
+	"fmt"
+
+	"github.com/astaxie/beego"
+)
+
+type QiNiuApiController struct {
+	base_ctl.BaseAPIController
+}
+
+func QiniuCtlRegistRouters() {
+	beego.Router("/api/qiniu/uptoken", &QiNiuApiController{}, "get:GetQNUpToken")
+}
+
+func (c *QiNiuApiController) GetQNUpToken() {
+	redisClient := base_service.RedisClient()
+	defer redisClient.Close()
+
+	token, err := redisClient.Get("qn_token").Result()
+	if err != nil {
+		defer fmt.Println(err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeGetQiniuUpToken)
+		return
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"uptoken": token,
+	})
+	return
+}

controllers/global/router_collector.go

@@ -2,4 +2,6 @@ package global
 
 func RegisterRouters() {
 	ErrorCtlRegistRouters()
+	DistrictCtlRegistRouters()
+	QiniuCtlRegistRouters()
 }

controllers/login/login_controller.go

@@ -122,17 +122,17 @@ func (this *VerifyUserLoginAPIController) VerifyToken() {
 			}
 
 			orgApps := adminUserInfo.OrgApps[curOrg.Id]
-			didRegistedForSCRM := false
+			didRegistedForXT := false
 			didRegistedForMall := false
 			didRegistedForCDM := false
 			for _, app := range orgApps {
-				if app.AppType == 1 {
-					didRegistedForSCRM = true
+				if app.AppType == 3 && app.OpenStatus == 1 {
+					didRegistedForXT = true
 				}
-				if app.AppType == 4 {
+				if app.AppType == 4 && app.OpenStatus == 1 {
 					didRegistedForCDM = true
 				}
-				if app.AppType == 5 {
+				if app.AppType == 5 && app.OpenStatus == 1 {
 					didRegistedForMall = true
 				}
 			}
@@ -144,7 +144,7 @@ func (this *VerifyUserLoginAPIController) VerifyToken() {
 				"current_org_id":  adminUserInfo.CurrentOrgId,
 				"current_app_id":  adminUserInfo.CurrentAppId,
 				"subscibe":        subscibe,
-				"scrm_role_exist": didRegistedForSCRM,
+				"xt_role_exist":   didRegistedForXT,
 				"cdm_role_exist":  didRegistedForCDM,
 				"mall_role_exist": didRegistedForMall,
 			})

models/district_models.go

@@ -0,0 +1,18 @@
+package models
+
+type District struct {
+	ID        int64  `gorm:"column:id" json:"id" form:"id"`
+	Name      string `gorm:"column:name" json:"name" form:"name"`
+	Level     int64  `gorm:"column:level" json:"level" form:"level"`
+	Upid      int64  `gorm:"column:upid" json:"upid" form:"upid"`
+	Path      string `gorm:"column:path" json:"path" form:"path"`
+	Namepath  string `gorm:"column:namepath" json:"namepath" form:"namepath"`
+	Initial   string `gorm:"column:initial" json:"initial" form:"initial"`
+	Longitude string `gorm:"column:longitude" json:"longitude" form:"longitude"`
+	Latitude  string `gorm:"column:latitude" json:"latitude" form:"latitude"`
+	Adcode    int64  `gorm:"column:adcode" json:"adcode" form:"adcode"`
+}
+
+func (District) TableName() string {
+	return "sgj_user_district"
+}

models/org_models.go

@@ -15,17 +15,44 @@ type Org struct {
 	Status          int8   `json:"status"`                    // 状态 0.无效 1.有效 2.禁用
 	CreateTime      int64  `gorm:"column:ctime" json:"ctime"` // 创建时间
 	ModifyTime      int64  `gorm:"column:mtime" json:"mtime"` // 修改时间
+
+	OrgType        int64   `gorm:"column:org_type" json:"org_type"`
+	Evaluate       float64 `gorm:"column:evaluate" json:"evaluate"`
+	Comments       int64   `gorm:"column:comments" json:"comments"`
+	OperatingState int64   `gorm:"column:operating_state" json:"operating_state"`
+	Claim          int64   `gorm:"column:claim" json:"claim"`
+	Telephone      string  `gorm:"column:telephone" json:"telephone"`
+	BusinessWeek   string  `gorm:"column:business_week" json:"business_week"`
+	BusinessTime   string  `gorm:"column:business_time" json:"business_time"`
+	Gallery        string  `gorm:"column:gallery" json:"gallery"`
+	ContactName    string  `gorm:"column:contact_name" json:"contact_name"`
 }
 
 func (Org) TableName() string {
 	return "sgj_user_org"
 }
 
+type OrgGallery struct {
+	ID     int64  `gorm:"column:id" json:"id" form:"id"`
+	Url    string `gorm:"column:url" json:"url" form:"url"`
+	Type   int64  `gorm:"column:type" json:"type" form:"type"`
+	OrgId  int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	UserId int64  `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Status int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime  int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime  int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (OrgGallery) TableName() string {
+	return "sgj_user_org_gallery"
+}
+
 type OrgApp struct {
 	Id         int64 `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // ID
 	AppType    int   `gorm:"column:app_type" json:"app_type"`      // 应用类型 1.病友经营；2.科普号；3.血透经营；4.慢病管理
 	Creator    int   `json:"creator"`                              // 创建者，即管理员用户的 id
 	OrgId      int   `gorm:"column:org_id" json:"org_id"`
+	OpenStatus int   `gorm:"column:open_status" json:"open_status"`
 	Status     int8  `json:"status"`                    // 状态 0.无效 1.有效 2.禁用
 	CreateTime int64 `gorm:"column:ctime" json:"ctime"` // 创建时间
 	ModifyTime int64 `gorm:"column:mtime" json:"mtime"` // 修改时间
@@ -48,3 +75,30 @@ type OrgBan struct {
 func (OrgBan) TableName() string {
 	return "sgj_user_admin_org_ban"
 }
+
+type OrgType struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	Name        string `gorm:"column:name" json:"name" form:"name"`
+	ShortName   string `gorm:"column:short_name" json:"short_name" form:"short_name"`
+	Pid         int64  `gorm:"column:pid" json:"pid" form:"pid"`
+	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"`
+	SortNo      int64  `gorm:"column:sort_no" json:"sort_no" form:"sort_no"`
+}
+
+func (OrgType) TableName() string {
+	return "sgj_user_org_type"
+}
+
+type Illness struct {
+	ID          int64  `gorm:"column:id" json:"id"`
+	IllnessName string `gorm:"column:illness_name" json:"illness_name"`
+	Status      int64  `gorm:"column:status" json:"status"`
+	CreatedTime int64  `gorm:"column:created_time" json:"created_time"`
+	UpdatedTime int64  `gorm:"column:updated_time" json:"updated_time"`
+}
+
+func (Illness) TableName() string {
+	return "sgj_user_illness"
+}

service/admin_service/verify_login_token_service.go

@@ -10,6 +10,7 @@ import (
 
 	"SCRM/models"
 	"SCRM/service"
+	"SCRM/service/org_service"
 	"SCRM/utils"
 
 	"github.com/astaxie/beego"
@@ -20,7 +21,7 @@ type AdminUserInfo struct {
 	CurrentOrgId int64                                `json:"current_org_id"`
 	CurrentAppId int64                                `json:"current_app_id"`
 	OrgIds       []int64                              `json:"org_ids"`
-	Orgs         map[int64]*models.Org                `json:"orgs"`
+	Orgs         map[int64]*org_service.Org           `json:"orgs"`
 	OrgAppIds    map[int64][]int64                    `json:"org_app_ids"`
 	OrgApps      map[int64](map[int64]*models.OrgApp) `json:"org_apps"`
 	App2OrgIds   map[int64]int64                      `json:"app_to_org_ids"`
@@ -204,12 +205,12 @@ func processOrgIds(data map[string]interface{}) []int64 {
 // 	1: { Org's json },
 // 	2: { Org's json },
 // },
-func processOrgs(data map[string]interface{}) map[int64]*models.Org {
+func processOrgs(data map[string]interface{}) map[int64]*org_service.Org {
 	orgJSONs := data["orgs"].(map[string]interface{})
-	orgs := make(map[int64]*models.Org)
+	orgs := make(map[int64]*org_service.Org)
 	for orgIdStr, orgJSON := range orgJSONs {
 		orgId, _ := strconv.Atoi(orgIdStr)
-		var org models.Org
+		var org org_service.Org
 		json.Unmarshal([]byte(orgJSON.(string)), &org)
 		orgs[int64(orgId)] = &org
 	}

service/db.go

@@ -95,10 +95,10 @@ func ConnectDB() {
 	writeUserDb.LogMode(true)
 }
 
-func XTReadDB() *gorm.DB {
+func PatientReadDB() *gorm.DB {
 	return readDb
 }
-func XTWriteDB() *gorm.DB {
+func PatientWriteDB() *gorm.DB {
 	return writeDb
 }
 func UserReadDB() *gorm.DB {

service/district_service/district_service.go

@@ -0,0 +1,11 @@
+package district_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+)
+
+func GetDistrictsByUpid(id int64) (dis []*models.District, err error) {
+	err = service.UserReadDB().Model(&models.District{}).Where("upid=?", id).Find(&dis).Error
+	return
+}

service/org_service/org_info_models.go

@@ -0,0 +1,14 @@
+package org_service
+
+import (
+	"SCRM/models"
+)
+
+type Org struct {
+	models.Org
+	OrgGallery []*models.OrgGallery `gorm:"ForeignKey:OrgId" json:"org_gallery"`
+}
+
+func (Org) TableName() string {
+	return "sgj_user_org"
+}

service/org_service/org_info_service.go

@@ -0,0 +1,32 @@
+package org_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"time"
+)
+
+func GetOrgTypes() (ots []*models.OrgType, err error) {
+	err = service.UserReadDB().Model(&models.OrgType{}).Where("status=1").Order("sort_no").Find(&ots).Error
+	return
+}
+
+func UpdateOrgInfo(org *Org) (err error) {
+	err = service.UserWriteDB().Model(&models.Org{}).Where("id=?", org.Id).Update(org).Error
+	return
+}
+
+func GetIllnessList() (ills []*models.Illness, err error) {
+	err = service.UserReadDB().Where("status=1").Find(&ills).Error
+	return
+}
+
+func CreateOrgGalleryItem(item *models.OrgGallery) (err error) {
+	err = service.UserWriteDB().Create(item).Error
+	return
+}
+
+func DeleteOrgGalleryItem(id int64) (err error) {
+	err = service.UserWriteDB().Model(&models.OrgGallery{}).Where("id=?", id).Update(map[string]interface{}{"Status": 0, "Mtime": time.Now().Unix()}).Error
+	return
+}