耗材参数

controllers/drug_stock_api_contorller.go

 				}
 				id := int64(items["id"].(float64))
 
+				if items["dealer"] == nil || reflect.TypeOf(items["dealer"]).String() != "float64" {
+					utils.ErrorLog("dealer")
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+					return
+				}
+				dealer := int64(items["dealer"].(float64))
+
+				if items["manufacturer"] == nil || reflect.TypeOf(items["manufacturer"]).String() != "float64" {
+					utils.ErrorLog("manufacturer")
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+					return
+				}
+				manufacturer := int64(items["manufacturer"].(float64))
 				if id == 0 {
 					warehouseInfo := &models.DrugWarehouseInfo{
 						WarehousingOrder: warehouse.WarehousingOrder,
 						Remark:           remark,
 						OrgId:            adminUserInfo.CurrentOrgId,
 						Type:             types,
-						Manufacturer:     manufacturer_id,
-						Dealer:           dealer_id,
+						Manufacturer:     manufacturer,
+						Dealer:           dealer,
 						RetailPrice:      retail_price,
 						RetailTotalPrice: retail_price_total,
 					}
 						Remark:           remark,
 						OrgId:            adminUserInfo.CurrentOrgId,
 						Type:             types,
-						Manufacturer:     manufacturer_id,
-						Dealer:           dealer_id,
+						Manufacturer:     manufacturer,
+						Dealer:           dealer,
 						RetailPrice:      retail_price,
 						RetailTotalPrice: retail_price_total,
 					}

controllers/gobal_config_api_controller.go

 	beego.Router("/api/drugstock/getdrugoutdetail", &GobalConfigApiController{}, "get:GetDrugOutDetail")
 
 	beego.Router("/api/drugstock/getdrugcanceldetail", &GobalConfigApiController{}, "get:GetDrugCancelDetail")
+
+	beego.Router("/api/monitor/open", &GobalConfigApiController{}, "get:AddMonitorOpen")
+	beego.Router("/api/monitor/getmonitorconfig", &GobalConfigApiController{}, "Get:GetMonitorConfig")
+	beego.Router("/api/order/addorderconfig", &GobalConfigApiController{}, "Get:AddOrderConfig")
+	beego.Router("/api/order/getorderconfig", &GobalConfigApiController{}, "Get:GetOrderConfig")
+
 }
 
 //provinces, _ := service.GetDistrictsByUpid(0)21
 		"total": total,
 	})
 }
+
+func (c *GobalConfigApiController) AddMonitorOpen() {
+
+	is_open, _ := c.GetInt64("is_open")
+	fmt.Println("is_open22222222", is_open)
+	adminUserInfo := c.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	config := models.XtMonitorConfig{
+		IsOpen:    is_open,
+		UserOrgId: orgId,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+	}
+	//查询该机构是否存在
+	_, errcode := service.GetMonitorConfigById(orgId)
+	if errcode == gorm.ErrRecordNotFound {
+		err := service.AddMonitorOpen(&config)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
+			return
+		}
+		c.ServeSuccessJSON(map[string]interface{}{
+			"config": config,
+		})
+	} else if errcode == nil {
+		err := service.UpdateMonitorOpen(orgId, &config)
+		fmt.Println("err", err)
+	}
+
+}
+
+func (c *GobalConfigApiController) GetMonitorConfig() {
+
+	userInfo := c.GetAdminUserInfo()
+	orgId := userInfo.CurrentOrgId
+
+	config, err := service.GetMonitorConfig(orgId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"config": config,
+	})
+
+}
+
+func (c *GobalConfigApiController) AddOrderConfig() {
+
+	is_open, _ := c.GetInt64("is_open")
+	fmt.Println("344555555555555", is_open)
+	adminUserInfo := c.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	config := models.XtOrderConfig{
+		IsOpen:    is_open,
+		UserOrgId: orgId,
+		Status:    1,
+		Ctime:     time.Now().Unix(),
+	}
+	//查询
+	_, errcode := service.GetOrderConfigById(orgId)
+	if errcode == gorm.ErrRecordNotFound {
+		err := service.AddOrderConfig(&config)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
+			return
+		}
+		c.ServeSuccessJSON(map[string]interface{}{
+			"config": config,
+		})
+	} else if errcode == nil {
+
+		err := service.UpdateOrderConfig(orgId, &config)
+		fmt.Println("2222", err)
+	}
+
+}
+
+func (c *GobalConfigApiController) GetOrderConfig() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	config, err := service.GetOrderConfig(orgId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
+		return
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"config": config,
+	})
+}

controllers/his_api_controller.go

 
 	//beego.Router("/api/export/template", &HisApiController{}, "get:ExportOrderTemplate")
 
+	beego.Router("/api/postprojectinformation", &HisApiController{}, "post:PostProjectInformation")
 }
 
 func (c *HisApiController) Sscard() {
 //
 //
 //}
+
+func (c *HisApiController) PostProjectInformation() {
+
+	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)
+	var projectList []*models.HisProject
+	var total_goods []interface{}
+	tempProjects := dataBody["projects"].([]interface{})
+
+	total_goods = tempProjects
+	for index, projectMap := range tempProjects {
+
+		projectM := projectMap.(map[string]interface{})
+
+		var project models.HisProject
+		if projectM["project_name"] == nil || reflect.TypeOf(projectM["project_name"]).String() != "string" {
+			utils.ErrorLog("project_name")
+			return
+		}
+
+		project_name, _ := projectM["project_name"].(string)
+		if len(project_name) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的项目名称不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		project.ProjectName = project_name
+
+		price := projectM["price"].(float64)
+
+		if price <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的零价不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		project.Price = price
+
+		if projectM["unit"] == nil || reflect.TypeOf(projectM["unit"]).String() != "string" {
+			utils.ErrorLog("unit_id")
+			return
+		}
+
+		unit := projectM["unit"].(string)
+		if len(unit) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的单位不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		project.Unit = unit
+
+		if projectM["cost_classify_id"] == nil || reflect.TypeOf(projectM["cost_classify_id"]).String() != "float64" {
+			utils.ErrorLog("cost_classify_id")
+			return
+		}
+
+		cost_classify_id := int64(projectM["cost_classify_id"].(float64))
+		if cost_classify_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的费用类别不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		project.CostClassify = cost_classify_id
+		executive_section_id := int64(projectM["executive_section_id"].(float64))
+		if executive_section_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的费用类别不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		project.ExecutiveSection = executive_section_id
+
+		if projectM["medical_insurance_level_id"] == nil || reflect.TypeOf(projectM["medical_insurance_level_id"]).String() != "float64" {
+			utils.ErrorLog("medical_insurance_level_id")
+			return
+		}
+
+		medical_insurance_level_id := int64(projectM["medical_insurance_level_id"].(float64))
+		if executive_section_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的费用类别不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		project.MedicalCoverage = medical_insurance_level_id
+
+		projectList = append(projectList, &project)
+	}
+	adminUser := c.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	export_time := time.Now().Unix()
+	errLogs, _ := service.FindPatientExportLog(c.GetAdminUserInfo().CurrentOrgId, export_time)
+	if len(projectList) > 0 {
+		for _, item := range projectList {
+			service.CreateProjectInfomation(item, orgId)
+
+			log := models.ExportLog{
+				LogType:    6,
+				UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+				TotalNum:   int64(len(total_goods)),
+				FailNum:    int64(len(errLogs)),
+				SuccessNum: int64(len(projectList)),
+				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_goods),
+				"success_num": len(projectList),
+				"fail_num":    int64(len(errLogs)),
+			})
+		}
+	} else {
+		log := models.ExportLog{
+			LogType:    6,
+			UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+			TotalNum:   int64(len(total_goods)),
+			FailNum:    int64(len(errLogs)),
+			SuccessNum: int64(len(projectList)),
+			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_goods),
+			"success_num": len(projectList),
+			"fail_num":    int64(len(errLogs)),
+		})
+	}
+}

controllers/stock_in_api_controller.go

 	beego.Router("/api/warehouseout/getoutstocktotalcount", &StockManagerApiController{}, "Get:GetOutStockTotalCount")
 
 	beego.Router("/api/good/postgoodinformation", &StockManagerApiController{}, "Post:AddGoodInformation")
+
+	beego.Router("/api/good/postdruginformation", &StockManagerApiController{}, "Post:AddDrugInformation")
 }
 
 func (c *StockManagerApiController) CreateWarehouse() {
 	id, _ := c.GetInt64("id", 0)
 	warehouseOutInfo, _ := service.FindWarehouseOutInfoById(id)
 	warehouseOut, _ := service.FindWareHouseOutById(id)
+	adminUserInfo := c.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	wareoutList, _ := service.GetWareOutInfoById(id, orgId)
 	c.ServeSuccessJSON(map[string]interface{}{
-		"list": warehouseOutInfo,
-		"info": warehouseOut,
+		"list":        warehouseOutInfo,
+		"info":        warehouseOut,
+		"wareoutList": wareoutList,
 	})
 
 }
 		return
 	}
 	utils.ErrorLog("%v", dataBody)
-
+	var goods []*models.GoodInfo
+	var total_goods []interface{}
 	tempGoods := dataBody["goods"].([]interface{})
 	fmt.Println("3333333333", tempGoods)
-	var goods []*models.GoodInfo
+	total_goods = tempGoods
 	for index, goodMap := range tempGoods {
 		goodNameM := goodMap.(map[string]interface{})
 		fmt.Println("00000", goodNameM)
 		var good models.GoodInfo
+
 		if goodNameM["good_name"] == nil || reflect.TypeOf(goodNameM["good_name"]).String() != "string" {
 			utils.ErrorLog("good_name")
 			return
 		}
 		fmt.Println("33333333", good_name)
 		good.GoodName = good_name
-		if goodNameM["medical_insurance_level"] == nil || reflect.TypeOf(goodNameM["medical_insurance_level"]).String() != "string" {
-			utils.ErrorLog("medical_insurance_level")
+
+		if goodNameM["good_kind_id"] == nil || reflect.TypeOf(goodNameM["good_kind_id"]).String() != "float64" {
+			utils.ErrorLog("good_kind_id")
+			return
+		}
+
+		good_kind := int64(goodNameM["good_kind_id"].(float64))
+		if good_kind <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的耗材种类不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", good_kind)
+		good.GoodKind = good_kind
+
+		if goodNameM["good_type_id"] == nil || reflect.TypeOf(goodNameM["good_type_id"]).String() != "float64" {
+			utils.ErrorLog("good_type_id")
+			return
+		}
+
+		good_type := int64(goodNameM["good_type_id"].(float64))
+
+		if good_type <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的耗材类型不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", good_type)
+		good.GoodTypeId = good_type
+
+		if goodNameM["medical_insurance_id"] == nil || reflect.TypeOf(goodNameM["medical_insurance_id"]).String() != "float64" {
+			utils.ErrorLog("medical_insurance_id")
+			return
+		}
+		medical_insurance_id := int64(goodNameM["medical_insurance_id"].(float64))
+		if medical_insurance_id < 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		good.MedicalInsuranceLevel = medical_insurance_id
+
+		if goodNameM["specification_name"] == nil || reflect.TypeOf(goodNameM["specification_name"]).String() != "string" {
+			utils.ErrorLog("specification_name")
+			return
+		}
+		specification_name := goodNameM["specification_name"].(string)
+		if len(specification_name) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "规格型号不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		good.SpecificationName = specification_name
+
+		if goodNameM["manufacturer_id"] == nil || reflect.TypeOf(goodNameM["manufacturer_id"]).String() != "float64" {
+			utils.ErrorLog("manufacturer_id")
+			return
+		}
+
+		manufacturer_id := int64(goodNameM["manufacturer_id"].(float64))
+		if manufacturer_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的生产厂商不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", manufacturer_id)
+		good.Manufacturer = manufacturer_id
+
+		if goodNameM["unit_id"] == nil || reflect.TypeOf(goodNameM["unit_id"]).String() != "float64" {
+			utils.ErrorLog("unit_id")
+			return
+		}
+
+		unit_id := int64(goodNameM["unit_id"].(float64))
+		if unit_id > 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的单位不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", unit_id)
+		good.GoodUnit = unit_id
+
+		if goodNameM["retail_price"] == nil || reflect.TypeOf(goodNameM["retail_price"]).String() != "float64" {
+			utils.ErrorLog("retail_price")
+			return
+		}
+
+		retail_price := goodNameM["retail_price"].(float64)
+		if retail_price <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的价格不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", retail_price)
+		good.RetailPrice = retail_price
+
+		if goodNameM["stock_warn_count"] == nil || reflect.TypeOf(goodNameM["stock_warn_count"]).String() != "float64" {
+			utils.ErrorLog("stock_warn_count")
+			return
+		}
+
+		stock_warn_count := int64(goodNameM["stock_warn_count"].(float64))
+		if stock_warn_count > 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的库存警戒不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", stock_warn_count)
+		good.StockWarnCount = stock_warn_count
+
+		if goodNameM["dealer_id"] == nil || reflect.TypeOf(goodNameM["dealer_id"]).String() != "float64" {
+			utils.ErrorLog("dealer_id")
+			return
+		}
+
+		dealer_id := int64(goodNameM["dealer_id"].(float64))
+		if dealer_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    5,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的经销商不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+		fmt.Println("33333333", dealer_id)
+		good.Dealer = dealer_id
+
+		if goodNameM["pinyin"] == nil || reflect.TypeOf(goodNameM["pinyin"]).String() != "string" {
+			utils.ErrorLog("pinyin")
+			return
+		}
+		pinyin := goodNameM["pinyin"].(string)
+
+		good.Pinyin = pinyin
+
+		if goodNameM["wubi"] == nil || reflect.TypeOf(goodNameM["wubi"]).String() != "string" {
+			utils.ErrorLog("wubi")
+			return
+		}
+		wubi := goodNameM["wubi"].(string)
+
+		good.Pinyin = wubi
+
+		if goodNameM["buy_price"] == nil || reflect.TypeOf(goodNameM["buy_price"]).String() != "float64" {
+			utils.ErrorLog("buy_price")
+			return
+		}
+
+		buy_price := goodNameM["buy_price"].(float64)
+		good.BuyPrice = buy_price
+
+		if goodNameM["social_security_directory_code"] == nil || reflect.TypeOf(goodNameM["social_security_directory_code"]).String() != "string" {
+			utils.ErrorLog("social_security_directory_code")
+			return
+		}
+		social_security_directory_code := goodNameM["social_security_directory_code"].(string)
+
+		good.SocialSecurityDirectoryCode = social_security_directory_code
+
+		if goodNameM["is_special_diseases"] == nil || reflect.TypeOf(goodNameM["is_special_diseases"]).String() != "float64" {
+			utils.ErrorLog("is_special_diseases")
+			return
+		}
+
+		is_special_diseases := int64(goodNameM["is_special_diseases"].(float64))
+		good.IsSpecialDiseases = is_special_diseases
+
+		if goodNameM["is_record"] == nil || reflect.TypeOf(goodNameM["is_record"]).String() != "float64" {
+			utils.ErrorLog("is_record")
+			return
+		}
+
+		is_record := int64(goodNameM["is_record"].(float64))
+		good.IsRecord = is_record
+
+		if goodNameM["good_status"] == nil || reflect.TypeOf(goodNameM["good_status"]).String() != "string" {
+			utils.ErrorLog("good_status")
+			return
+		}
+		good_status := goodNameM["good_status"].(string)
+		good.GoodStatus = good_status
+
+		if goodNameM["medical_insurance_number"] == nil || reflect.TypeOf(goodNameM["medical_insurance_number"]).String() != "string" {
+			utils.ErrorLog("medical_insurance_number")
+			return
+		}
+		medical_insurance_number := goodNameM["medical_insurance_number"].(string)
+		good.MedicalInsuranceNumber = medical_insurance_number
+
+		if goodNameM["production_type"] == nil || reflect.TypeOf(goodNameM["production_type"]).String() != "string" {
+			utils.ErrorLog("production_type")
 			return
 		}
-		medical_insurance_level := goodNameM["medical_insurance_level"].(string)
-		medical_insurance_levels, _ := strconv.ParseInt(medical_insurance_level, 10, 64)
-		good.MedicalInsuranceLevel = medical_insurance_levels
+		production_type := goodNameM["production_type"].(string)
+		good.ProductionType = production_type
+
+		if goodNameM["remark"] == nil || reflect.TypeOf(goodNameM["remark"]).String() != "string" {
+			utils.ErrorLog("remark")
+			return
+		}
+		remark := goodNameM["remark"].(string)
+		good.Remark = remark
 
 		goods = append(goods, &good)
 	}
 	adminUser := this.GetAdminUserInfo()
 	orgId := adminUser.CurrentOrgId
+	export_time := time.Now().Unix()
+	errLogs, _ := service.FindPatientExportLog(this.GetAdminUserInfo().CurrentOrgId, export_time)
 	if len(goods) > 0 {
 		for _, item := range goods {
 			service.CreateGoodsInfomation(item, orgId)
+
+			log := models.ExportLog{
+				LogType:    1,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				TotalNum:   int64(len(total_goods)),
+				FailNum:    int64(len(errLogs)),
+				SuccessNum: int64(len(goods)),
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: export_time,
+				Status:     1,
+			}
+			service.CreateExportLog(&log)
 			this.ServeSuccessJSON(map[string]interface{}{
-				"msg": "导入成功",
+				"msg":         "导入成功",
+				"total_num":   len(total_goods),
+				"success_num": len(goods),
+				"fail_num":    int64(len(errLogs)),
 			})
 		}
 	}
 }
+
+func (this *StockManagerApiController) AddDrugInformation() {
+	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)
+	var drugList []*models.BaseDrugLib
+	var total_goods []interface{}
+	tempDrugs := dataBody["drugs"].([]interface{})
+
+	total_goods = tempDrugs
+	for index, drugMap := range tempDrugs {
+		goodNameM := drugMap.(map[string]interface{})
+		var drug models.BaseDrugLib
+		if goodNameM["drug_name"] == nil || reflect.TypeOf(goodNameM["drug_name"]).String() != "string" {
+			utils.ErrorLog("drug_name")
+			return
+		}
+
+		drug_name, _ := goodNameM["drug_name"].(string)
+		if len(drug_name) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品名称不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugName = drug_name
+
+		if goodNameM["drug_alias"] == nil || reflect.TypeOf(goodNameM["drug_alias"]).String() != "string" {
+			utils.ErrorLog("drug_alias")
+			return
+		}
+
+		drug_alias, _ := goodNameM["drug_alias"].(string)
+		if len(drug_alias) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品别名不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugAlias = drug_alias
+
+		drug_spec, _ := goodNameM["drug_spec"].(string)
+		if len(drug_spec) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品规格不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugSpec = drug_spec
+
+		drug_type_id := int64(goodNameM["drug_type_id"].(float64))
+		if drug_type_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品规格不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugType = drug_type_id
+
+		drug_stock_limit, _ := goodNameM["drug_stock_limit"].(string)
+		if len(drug_stock_limit) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品规格不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugStockLimit = drug_stock_limit
+
+		drug_origin_place, _ := goodNameM["drug_origin_place"].(string)
+		if len(drug_origin_place) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的产地不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugOriginPlace = drug_origin_place
+
+		drug_dosage_form_id := int64(goodNameM["drug_dosage_form_id"].(float64))
+		if drug_dosage_form_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的药品剂型不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugDosageForm = drug_dosage_form_id
+
+		medical_insurance_level_id := int64(goodNameM["medical_insurance_level_id"].(float64))
+		if medical_insurance_level_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.MedicalInsuranceLevel = medical_insurance_level_id
+
+		max_unit_id := goodNameM["max_unit"].(string)
+		if len(max_unit_id) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.MaxUnit = max_unit_id
+
+		min_unit := goodNameM["min_unit"].(string)
+		if len(max_unit_id) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.MinUnit = min_unit
+
+		unit_matrixing := goodNameM["unit_matrixing"].(string)
+		if len(max_unit_id) == 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.UnitMatrixing = unit_matrixing
+
+		retail_price := goodNameM["retail_price"].(float64)
+		if retail_price <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.RetailPrice = retail_price
+
+		last_price := goodNameM["last_price"].(float64)
+		if last_price <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.LastPrice = last_price
+
+		drug_classify_id := int64(goodNameM["drug_classify_id"].(float64))
+		fmt.Println("医保登记", drug_classify_id)
+		fmt.Println("机构第", this.GetAdminUserInfo().CurrentOrgId)
+		if drug_classify_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的医保等级不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.DrugCategory = drug_classify_id
+
+		manufacturer_id := int64(goodNameM["manufacturer_id"].(float64))
+		if manufacturer_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的生产商不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.Manufacturer = manufacturer_id
+
+		dealer_id := int64(goodNameM["dealer_id"].(float64))
+		if dealer_id <= 0 { //名字为空则生成一条导入错误日志
+			err_log := models.ExportErrLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的经销商不能为空",
+				Status:     1,
+				CreateTime: time.Now().Unix(),
+				UpdateTime: time.Now().Unix(),
+				ExportTime: time.Now().Unix(),
+			}
+			service.CreateExportErrLog(&err_log)
+			continue
+		}
+
+		drug.Dealer = dealer_id
+
+		drugList = append(drugList, &drug)
+	}
+
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	export_time := time.Now().Unix()
+	errLogs, _ := service.FindPatientExportLog(this.GetAdminUserInfo().CurrentOrgId, export_time)
+	fmt.Println("数组", drugList)
+	if len(drugList) > 0 {
+		for _, item := range drugList {
+			service.CreateDrugsInfomation(item, orgId)
+			log := models.ExportLog{
+				LogType:    4,
+				UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+				TotalNum:   int64(len(total_goods)),
+				FailNum:    int64(len(errLogs)),
+				SuccessNum: int64(len(drugList)),
+				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_goods),
+				"success_num": len(drugList),
+				"fail_num":    int64(len(errLogs)),
+			})
+		}
+	} else {
+		log := models.ExportLog{
+			LogType:    4,
+			UserOrgId:  this.GetAdminUserInfo().CurrentOrgId,
+			TotalNum:   int64(len(total_goods)),
+			FailNum:    int64(len(errLogs)),
+			SuccessNum: int64(len(drugList)),
+			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_goods),
+			"success_num": len(drugList),
+			"fail_num":    int64(len(errLogs)),
+		})
+	}
+}

models/self_drug_models.go

 	Creater                 int64   `gorm:"column:creater" json:"creater" form:"creater"`
 	MinUnit                 string  `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
 }
+
+type XtMonitorConfig 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"`
+	Ctime     int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status    int64 `gorm:"column:status" json:"status" form:"status"`
+	IsOpen    int64 `gorm:"column:is_open" json:"is_open" form:"is_open"`
+}
+
+func (XtMonitorConfig) TableName() string {
+	return "xt_monitor_config"
+}
+
+type XtOrderConfig 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"`
+	Ctime     int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime     int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status    int64 `gorm:"column:status" json:"status" form:"status"`
+	IsOpen    int64 `gorm:"column:is_open" json:"is_open" form:"is_open"`
+}
+
+func (XtOrderConfig) TableName() string {
+	return "xt_order_config"
+}

service/gobal_config_service.go

 	"XT_New/models"
 	"fmt"
 	"github.com/jinzhu/gorm"
+	"time"
 )
 
 func CreateAutomaticReduceRecord(config *models.GobalConfig) (err error) {
 
 	return autoMatic, err
 }
+
+func AddMonitorOpen(config *models.XtMonitorConfig) error {
+
+	err := XTWriteDB().Create(&config).Error
+
+	return err
+}
+
+func UpdateMonitorOpen(orgid int64, config *models.XtMonitorConfig) error {
+
+	err := XTWriteDB().Model(&config).Where("user_org_id = ? and status = 1", orgid).Updates(map[string]interface{}{"is_open": config.IsOpen, "mtime": time.Now().Unix()}).Error
+	return err
+}
+
+func GetMonitorConfig(orgid int64) (models.XtMonitorConfig, error) {
+
+	config := models.XtMonitorConfig{}
+	err := XTReadDB().Model(&config).Where("user_org_id = ? and status = 1", orgid).Find(&config).Error
+	return config, err
+}
+
+func AddOrderConfig(config *models.XtOrderConfig) error {
+
+	err := XTWriteDB().Create(&config).Error
+	return err
+}
+
+func UpdateOrderConfig(orgid int64, config *models.XtOrderConfig) error {
+
+	err := XTWriteDB().Model(&config).Where("user_org_id = ? and status = 1", orgid).Updates(map[string]interface{}{"is_open": config.IsOpen, "mtime": time.Now().Unix()}).Error
+	return err
+}
+
+func GetOrderConfigById(orgid int64) (*models.XtOrderConfig, error) {
+	config := models.XtOrderConfig{}
+	err := XTReadDB().Model(&config).Where("user_org_id = ? and status = 1", orgid).Find(&config).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &config, nil
+}
+
+func GetOrderConfig(orgid int64) (models.XtOrderConfig, error) {
+	config := models.XtOrderConfig{}
+	err := XTReadDB().Where("user_org_id = ? and status = 1", orgid).Find(&config).Error
+	return config, err
+}
+
+func GetMonitorConfigById(orgid int64) (*models.XtMonitorConfig, error) {
+
+	config := models.XtMonitorConfig{}
+	err := XTReadDB().Model(&config).Where("user_org_id = ? and status = 1", orgid).Find(&config).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &config, nil
+}

service/mobile_dialysis_service.go

 }
 
 func BatchHisAdviceExecution(ids []string, creator int64, execution_state int64) error {
+
 	advice := models.HisDoctorAdviceInfo{}
 	err := XTWriteDB().Model(&advice).Where("id IN(?) and status = 1", ids).Updates(map[string]interface{}{"execution_state": 1, "execution_staff": creator, "execution_time": execution_state}).Error
 	return err

service/stock_service.go

 	err = XTReadDB().Where("org_id = ? and status = 1", orgid).Find(&goodInfo).Error
 	return goodInfo, err
 }
+
+func CreateDrugsInfomation(info *models.BaseDrugLib, orgid int64) error {
+
+	goodInfo := models.BaseDrugLib{
+		DrugName:              info.DrugName,
+		DrugAlias:             info.DrugAlias,
+		DrugSpec:              info.DrugSpec,
+		DrugType:              info.DrugType,
+		DrugStockLimit:        info.DrugStockLimit,
+		DrugOriginPlace:       info.DrugOriginPlace,
+		DrugDosageForm:        info.DrugDosageForm,
+		MedicalInsuranceLevel: info.MedicalInsuranceLevel,
+		MaxUnit:               info.MaxUnit,
+		MinUnit:               info.MinUnit,
+		UnitMatrixing:         info.UnitMatrixing,
+		RetailPrice:           info.RetailPrice,
+		LastPrice:             info.LastPrice,
+		DrugClassify:          info.DrugClassify,
+		Manufacturer:          info.Manufacturer,
+		Dealer:                info.Dealer,
+		OrgId:                 orgid,
+		Status:                1,
+		Ctime:                 time.Now().Unix(),
+	}
+	err := XTWriteDB().Create(&goodInfo).Error
+	return err
+}
+
+func CreateProjectInfomation(info *models.HisProject, orgid int64) error {
+
+	project := models.HisProject{
+		ProjectName:      info.ProjectName,
+		Price:            info.Price,
+		Unit:             info.Unit,
+		CostClassify:     info.CostClassify,
+		ExecutiveSection: info.ExecutiveSection,
+		MedicalCoverage:  info.MedicalCoverage,
+		UserOrgId:        orgid,
+		Status:           1,
+		CreatedTime:      time.Now().Unix(),
+	}
+	err := XTWriteDB().Create(&project).Error
+	return err
+}
+
+func GetWareOutInfoById(warehouseoutid int64, orgid int64) (warehouseinfo []*models.WarehouseOutInfo, err error) {
+
+	err = XTReadDB().Model(&warehouseinfo).Where("warehouse_out_id = ? and org_id = ? and status= 1 and is_sys = 0", warehouseoutid, orgid).Find(&warehouseinfo).Error
+	return warehouseinfo, err
+}