集成配置

controllers/integration_config_api_controller.go

@@ -22,6 +22,162 @@ func IntegrationConfigRegistRouters() {
 	beego.Router("/api/adminhis/edit", &IntegrationConfigApiController{}, "post:EditAdminHis")
 	beego.Router("/api/adminhis/create", &IntegrationConfigApiController{}, "post:CreateAdminHis")
 
+	beego.Router("/api/patienthis/getinterface", &IntegrationConfigApiController{}, "post:GetInterface")
+	beego.Router("/api/patienthis/saveinterface", &IntegrationConfigApiController{}, "post:SaveInterface")
+	beego.Router("/api/integration/synclist", &IntegrationConfigApiController{}, "get:GetSyncList")
+	beego.Router("/api/integration/sysinspectionlist", &IntegrationConfigApiController{}, "get:GetSysInspectionList")
+	beego.Router("/api/patienthis/saveinspectionsysitemid", &IntegrationConfigApiController{}, "post:SaveInspectionSysItemId")
+}
+
+func (c *IntegrationConfigApiController) SaveInspectionSysItemId() {
+	adminUserInfo := c.GetAdminUserInfo()
+	org_id,_ := c.GetInt64("org_id",0)
+	sys_item_id,_ := c.GetInt64("sys_item_id",0)
+	id,_ := c.GetInt64("id",0)
+	if org_id != adminUserInfo.CurrentOrgId || sys_item_id<= 0 || id <= 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	}
+
+	inspection_reference := &models.InspectionReference{
+		ID : id,
+		SysItemId : sys_item_id,
+		UpdatedTime : time.Now().Unix(),
+	}
+	err := service.UpdateSysItemIdByID(inspection_reference)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"inspection_reference":  inspection_reference,
+	})
+	return
+}
+
+func (c *IntegrationConfigApiController) GetSysInspectionList() {
+	adminUserInfo := c.GetAdminUserInfo()
+	sysInspection,ownerInspection,err := service.GetSysInspectionList(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	}
+
+	type InspectionStruce struct {
+		ProjectName string  `gorm:"-" json:"project_name" form:"project_name"`
+		ProjectId int64 `gorm:"-" json:"project_id" form:"project_id"`
+		InspectionReference []*models.InspectionReference  `gorm:"-" json:"inspection_reference" form:"inspection_reference"`
+	}
+
+	sysInspec := make(map[int64]*InspectionStruce, 0)
+	ownerInspec := make(map[int64]*InspectionStruce, 0)
+
+	
+
+	for _, item := range sysInspection {
+		result := sysInspec[item.ProjectId]
+		if result == nil {
+			result = new(InspectionStruce)
+			result.ProjectName = item.ProjectName
+			result.ProjectId = item.ProjectId
+		}
+		result.InspectionReference = append(result.InspectionReference, item)
+		sysInspec[item.ProjectId] = result
+	}
+
+	for _, oitem := range ownerInspection {
+		oresult := ownerInspec[oitem.ProjectId]
+		if oresult == nil {
+			oresult = new(InspectionStruce)
+			oresult.ProjectName = oitem.ProjectName
+			oresult.ProjectId = oitem.ProjectId
+		}
+		oresult.InspectionReference = append(oresult.InspectionReference, oitem)
+		ownerInspec[oitem.ProjectId] = oresult
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"sysInspec":  sysInspec,
+		"ownerInspec": ownerInspec,
+	})
+	return
+}
+
+func (c *IntegrationConfigApiController) GetSyncList() {
+	page, _ := c.GetInt64("page", 1)
+	limit, _ := c.GetInt64("limit", 10)
+
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+
+	adminUserInfo := c.GetAdminUserInfo()
+	patients, total, _ := service.GetSyncList(adminUserInfo.CurrentOrgId, page, limit)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list":  patients,
+		"total": total,
+	})
+	return
+}
+
+func (c *IntegrationConfigApiController) SaveInterface() {
+	adminUserInfo := c.GetAdminUserInfo()
+	ID,_ := c.GetInt64("id",0)
+	OrgId := adminUserInfo.CurrentOrgId
+	Creater := adminUserInfo.AdminUser.Id 
+	Pattern,_ := c.GetInt("pattern",0)		
+	Dbhost := c.GetString("dbhost") 
+	Dbuser := c.GetString("dbuser")
+	Dbpassword := c.GetString("dbpassword") 
+	Dbname := c.GetString("dbname")
+	InterfaceUrl := c.GetString("interface_url") 
+	InterFaceToken := c.GetString("interface_token")
+	AllowIp := c.GetString("allow_ip")
+	AllowToken := c.GetString("allow_token")		
+	SyncFrequency,_ := c.GetInt("sync_frequency")
+	Status := 1
+	UpdatedTime :=  time.Now().Unix()
+	interfaceinfo := &models.MiddleInterface{
+		ID  		: ID,
+	OrgId   		: OrgId	,
+	Creater   		: Creater	,
+	Pattern 		: Pattern	,
+	Dbhost 			: Dbhost	,
+	Dbuser 			: Dbuser	,
+	Dbpassword 		: Dbpassword	,
+	Dbname 			: Dbname	,
+	InterfaceUrl 	: InterfaceUrl	,
+	InterFaceToken 	: InterFaceToken	,
+	AllowIp 		: AllowIp	,
+	AllowToken 		: AllowToken	,
+	SyncFrequency 	: SyncFrequency	,
+	Status			: Status	,
+	UpdatedTime     : UpdatedTime	,
+	}
+	if ID <= 0 {
+		interfaceinfo.CreatedTime =  time.Now().Unix()
+	}
+	err:= service.SaveInterface(interfaceinfo)
+
+	if err == nil {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"interfaceinfo":  interfaceinfo,
+		})
+	} else {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	}
+	return
+}
+
+func (c *IntegrationConfigApiController) GetInterface() {
+	adminUserInfo := c.GetAdminUserInfo()
+	interfaceinfo, _ := service.GetInterface(adminUserInfo.CurrentOrgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"interfaceinfo":  interfaceinfo,
+	})
+	return
+
 }
 
 func (c *IntegrationConfigApiController) GetPatientsList() {
@@ -43,7 +199,6 @@ func (c *IntegrationConfigApiController) GetPatientsList() {
 		"total": total,
 	})
 	return
-
 }
 
 func (c *IntegrationConfigApiController) EditPatientHis() {

models/inspection_models.go

@@ -43,23 +43,25 @@ type Inspections struct {
 }
 
 type InspectionReference struct {
-	ID               int64  `gorm:"column:id" json:"id" form:"id"`
-	OrgId            int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
-	ProjectName      string `gorm:"column:project_name" json:"project_name" form:"project_name"`
-	Project          string `gorm:"column:project" json:"project" form:"project"`
-	ProjectId        int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
-	ItemName         string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectName string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	Project string `gorm:"column:project" json:"project" form:"project"`
+	ProjectId int64 `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemName string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ItemId string `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	SysItemId int64 `gorm:"column:sys_item_id" json:"sys_item_id" form:"sys_item_id"`
 	ItemNameAddition string `gorm:"column:item_name_addition" json:"item_name_addition" form:"item_name_addition"`
-	Item             string `gorm:"column:item" json:"item" form:"item"`
-	RangeType        int64  `gorm:"column:range_type" json:"range_type" form:"range_type"`
-	RangeMin         string `gorm:"column:range_min" json:"range_min" form:"range_min"`
-	RangeMax         string `gorm:"column:range_max" json:"range_max" form:"range_max"`
-	RangeValue       string `gorm:"column:range_value" json:"range_value" form:"range_value"`
-	RangeOptions     string `gorm:"column:range_options" json:"range_options" form:"range_options"`
-	Unit             string `gorm:"column:unit" json:"unit" form:"unit"`
-	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"`
+	Item string `gorm:"column:item" json:"item" form:"item"`
+	RangeType int64 `gorm:"column:range_type" json:"range_type" form:"range_type"`
+	RangeMin string `gorm:"column:range_min" json:"range_min" form:"range_min"`
+	RangeMax string `gorm:"column:range_max" json:"range_max" form:"range_max"`
+	RangeValue string `gorm:"column:range_value" json:"range_value" form:"range_value"`
+	RangeOptions string `gorm:"column:range_options" json:"range_options" form:"range_options"`
+	Unit string `gorm:"column:unit" json:"unit" form:"unit"`
+	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 (InspectionReference) TableName() string {

models/intergration_models.go

@@ -1,5 +1,45 @@
 package models
 
+type MiddleSyncInfo struct {
+	ID             	int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId       	int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	SyncTime       int64 `gorm:"column:sync_time" json:"sync_time" form:"sync_time"`
+	SyncResultType  int	  `gorm:"column:sync_result_type" json:"sync_result_type" form:"sync_result_type"`
+	SyncRsultRemark string `gorm:"column:sync_result_remark" json:"sync_result_remark" form:"sync_result_remark"`
+	SyncTotalNum    int64 `gorm:"column:sync_total_num" json:"sync_total_num" form:"sync_total_num"`
+	SyncSuccessNum  int64 `gorm:"column:sync_success_num" json:"sync_success_num" form:"sync_success_num"`
+	SyncInfo      	string `gorm:"column:sync_info" json:"sync_info" form:"sync_info"`
+	CreateTime      int64 `gorm:"column:create_time" json:"create_time" form:"create_time"`
+	UpdateTime    	int64 `gorm:"column:update_time" json:"update_time" form:"update_time"`
+}
+
+func (MiddleSyncInfo) TableName() string {
+	return "xt_middle_sync_info"
+}
+
+type MiddleInterface struct {
+	ID          	int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId   		int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Creater   		int64 `gorm:"column:creater" json:"creater" form:"creater"`
+	Pattern 		int  `gorm:"column:pattern" json:"pattern" form:"pattern"`
+	Dbhost 			string  `gorm:"column:dbhost" json:"dbhost" form:"dbhost"`
+	Dbuser 			string  `gorm:"column:dbuser" json:"dbuser" form:"dbuser"`
+	Dbpassword 		string  `gorm:"column:dbpassword" json:"dbpassword" form:"dbpassword"`
+	Dbname 			string  `gorm:"column:dbname" json:"dbname" form:"dbname"`
+	InterfaceUrl 	string  `gorm:"column:interface_url" json:"interface_url" form:"interface_url"`
+	InterFaceToken 	string  `gorm:"column:interface_token" json:"interface_token" form:"interface_token"`
+	AllowIp 		string  `gorm:"column:allow_ip" json:"allow_ip" form:"allow_ip"`
+	AllowToken 		string  `gorm:"column:allow_token" json:"allow_token" form:"allow_token"`
+	SyncFrequency 	int  `gorm:"column:sync_frequency" json:"sync_frequency" form:"sync_frequency"`
+	Status			int  `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 (MiddleInterface) TableName() string {
+	return "xt_middle_interface"
+}
+
 type VMPatients 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"`
@@ -265,8 +305,6 @@ type VMUserRole struct {
 	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"`
-	Number           int64  `gorm:"column:number" json:"number" form:"number"`
-	IsSystem         int64  `gorm:"column:is_system" json:"is_system" form:"is_system"`
 }
 
 func (VMUserRole) TableName() string {

service/integration_service.go

@@ -6,6 +6,44 @@ import (
 	"time"
 )
 
+func UpdateSysItemIdByID(sysInspection *models.InspectionReference) error {
+	db := XTWriteDB()
+	err := db.Model(&models.InspectionReference{}).Update(&sysInspection).Error
+	return err
+}
+
+func GetSysInspectionList(orgID int64) (sysInspection []*models.InspectionReference,ownerInspection []*models.InspectionReference, err error) {
+	db := XTReadDB()
+	err = db.Model(&models.InspectionReference{}).Where("org_id= 0 and status=1").Find(&sysInspection).Error
+	err = db.Model(&models.InspectionReference{}).Where("org_id= ? and status=1", orgID).Find(&ownerInspection).Error
+	return
+}
+
+func GetSyncList(orgID int64, page, limit int64) (patients []*models.MiddleSyncInfo, total int64, err error) {
+	//db := MiddleReadDB()
+	db := MiddleReadDB()
+	offset := (page - 1) * limit
+	err = db.Model(&models.MiddleSyncInfo{}).Where("org_id=? ", orgID).Count(&total).Offset(offset).Limit(limit).Find(&patients).Error
+	return
+}
+
+func SaveInterface(interfaceinfo *models.MiddleInterface) error {
+	db := MiddleWriteDB()
+	if (interfaceinfo.ID > 0 ) {
+		err := db.Save(&interfaceinfo).Error
+		return err
+	} else {
+		err := db.Create(&interfaceinfo).Error
+		return err
+	}
+}
+
+func GetInterface(orgID int64) (interfaceinfo models.MiddleInterface, err error){
+	db := MiddleReadDB()
+	err = db.Model(&models.MiddleInterface{}).Where("org_id=? and status=1", orgID).First(&interfaceinfo).Error
+	return
+}
+
 func GetIntegrationPatientList(orgID int64, page, limit int64) (patients []*models.VMPatients, total int64, err error) {
 	//db := MiddleReadDB()
 	db := readDb.Model(&models.VMPatients{}).Where("status=1")