777

controllers/sg/his_api_controller.go

 						if res3.Infcode != -1{
 							item.IsChange = 1
 							item.Bchno = item.NewDrugWarehouseInfo.Bchno
-							service.SaveDF(item)
+							service.SaveDF2(item)
 						}else{
 							err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 						}
 								if res3.Infcode != -1 {
 									item.IsChange = 1
 									item.Bchno = item.NewDrugWarehouseInfo.Bchno
-									service.SaveDF(item)
+									service.SaveDF2(item)
 								} else {
 									err = append(err, item.HisDoctorAdviceInfo.AdviceName+",销售变更失败："+res3.ErrMsg)
 								}
 					if res3.Infcode != -1{
 						item.IsChange = 1
 						item.Bchno = item.NewDrugWarehouseInfo.Bchno
-						service.SaveDF(item)
+						service.SaveDF2(item)
 					}else{
 						err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 					}
 				if item.IsSale == 1 { //是否已经销售，1是   0否
 					//是否已经变更 1是  0否
 					if item.IsChange == 0 { //没变更，进行变更操作
-						result, result2  :=ChangeStock(item.Count, item, miConfig, "107", roles)
+						result, result2  := ChangeStock(item.Count, item, miConfig, "107", roles)
 						saveLog(result, result2, "3502", "自动出库，未销售，未变更3502")
 
 						var respJSON3 map[string]interface{}
 						if res3.Infcode != -1{
 							item.IsChange = 1
 							item.Bchno = item.NewDrugWarehouseInfo.Bchno
-							service.SaveDF(item)
+							service.SaveDF2(item)
 						}else{
 							err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 						}
 						if res3.Infcode != -1{
 							item.IsChange = 1
 							item.Bchno = item.NewDrugWarehouseInfo.Bchno
-							service.SaveDF(item)
+							service.SaveDF2(item)
 						}else{
 							err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 						}
 					if res3.Infcode != -1{
 						item.IsChange = 1
 						item.Bchno = item.NewDrugWarehouseInfo.Bchno
-						service.SaveDF(item)
+						service.SaveDF2(item)
 					}else{
 						err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 					}
 				if res3.Infcode != -1{
 					item.IsChange = 1
 					item.Bchno = item.NewDrugWarehouseInfo.Bchno
-					service.SaveDF(item)
+					service.SaveDF2(item)
 				}else{
 					err = append(err,item.HisDoctorAdviceInfo.AdviceName +",销售变更失败："+res3.ErrMsg)
 				}

service/his_service.go

 }
 
 func GetNewDrugFlowInfo(id_arr []string) (flows []*models.DrugFlow, err error) {
-	err = readDb.Model(&models.DrugFlow{}).Where("org_id = ? and status = 1 and id in (?)", 10191, id_arr).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+	err = readDb.Model(&models.DrugFlow{}).Where("user_org_id = ? and status = 1 and id in (?)", 10191, id_arr).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
 		return db.Where("status = 1").Preload("BaseDrugLib", "status=1").Preload("NewDrugWarehouseInfo", "status = 1")
 	}).Find(&flows).Error
 	return
 }
 
 func SaveDF(df *models.DrugFlow) (err error) {
-	err = writeDb.Save(&df).Error
+	//err = writeDb.(&df).Error
+	err = XTWriteDB().Model(&models.DrugFlow{}).Where("id = ? ", df.ID).Updates(map[string]interface{}{
+		"is_sale":   df.IsSale,
+		"sale_date": df.SaleDate,
+		//"is_change"
+	}).Error
+	return
+}
+
+func SaveDF2(df *models.DrugFlow) (err error) {
+	//err = writeDb.(&df).Error
+	err = XTWriteDB().Model(&models.DrugFlow{}).Where("id = ? ", df.ID).Updates(map[string]interface{}{
+		"is_change": df.IsChange,
+		"bchno":     df.Bchno,
+		//"is_change"
+	}).Error
 	return
 }