Merge branch '20230223_xt_api_new_branch' of http://git.shengws.com/csx/XT_New into 20230223_xt_api_new_branch

.idea/.gitignore

-# Default ignored files
-/workspace.xml
-# Datasource local storage ignored files
-/dataSources.local.xml

.idea/codeStyles/codeStyleConfig.xml

-<component name="ProjectCodeStyleConfiguration">
-  <state>
-    <option name="PREFERRED_PROJECT_CODE_STYLE" value="Default" />
-  </state>
-</component>

.idea/dataSources.xml

-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="DataSourceManagerImpl" format="xml" multifile-model="true">
-    <data-source source="LOCAL" name="@rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com" uuid="a5e97996-c706-42df-9eba-66746647237e">
-      <driver-ref>mysql.8</driver-ref>
-      <synchronize>true</synchronize>
-      <remarks>lijc de database</remarks>
-      <jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver>
-      <jdbc-url>jdbc:mysql://rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com:3306</jdbc-url>
-    </data-source>
-  </component>
-</project>

.idea/encodings.xml

-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="Encoding" addBOMForNewFiles="with NO BOM" />
-</project>

.idea/misc.xml

-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="JavaScriptSettings">
-    <option name="languageLevel" value="ES6" />
-  </component>
-  <component name="SvnBranchConfigurationManager">
-    <option name="myConfigurationMap">
-      <map>
-        <entry key="$PROJECT_DIR$/../CDM">
-          <value>
-            <SvnBranchConfiguration>
-              <option name="trunkUrl" value="svn://112.74.16.180/Product/SGJ/SGJ1.0/Project/SGJ1.0/Application/MBGL" />
-            </SvnBranchConfiguration>
-          </value>
-        </entry>
-        <entry key="$PROJECT_DIR$/../SYB_Admin">
-          <value>
-            <SvnBranchConfiguration>
-              <option name="trunkUrl" value="svn://112.74.16.180/Product/SYB/SYB1.0/Application/SYB_Admin" />
-            </SvnBranchConfiguration>
-          </value>
-        </entry>
-      </map>
-    </option>
-  </component>
-</project>

.idea/vcs.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="GitSharedSettings">
-    <option name="FORCE_PUSH_PROHIBITED_PATTERNS">
-      <list />
-    </option>
-  </component>
   <component name="VcsDirectoryMappings">
     <mapping directory="$PROJECT_DIR$" vcs="Git" />
   </component>

conf/app.conf

 readmysqlpass2 = Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4
 readmysqlname2 = sgj_xt
 
+readmysqlhost3 = rm-wz9r3iil42mn24675oo.mysql.rds.aliyuncs.com
+readmysqlport3 = 3306
+readmysqluser3 = syh
+readmysqlpass3 = Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4
+readmysqlname3 = sgj_xt
+
+
 writemysqlhost = kuyicloud2024lt.mysql.rds.aliyuncs.com
 writemysqlport = 3306
 writemysqluser = syh
 readsgjpatientmysqlpass = Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4
 readsgjpatientmysqlname = sgj_patient
 
+
+
 writesgjpatientmysqlhost = kuyicloud2024lt.mysql.rds.aliyuncs.com
 writesgjpatientmysqlport = 3306
 writesgjpatientmysqluser = syh
 readpatientpass = Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4
 readpatientname = sgj_cdm
 
+
+
 writepatienthost = kuyicloud2024lt.mysql.rds.aliyuncs.com
 writepatientport = 3306
 writepatientuser = syh
 writepatientpass = Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4
 writepatientname = sgj_cdm
 
+
+
 redishost = kuyicloud.redis.rds.aliyuncs.com
 redisport = 6379
 redispasswrod = 1Q2W3e4r!@#$

controllers/base_api_controller.go

 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 9478 //机构id
+		subscibe.OrgId = 10721 //机构id
 		subscibe.PeriodStart = 1547447814
 		subscibe.PeriodEnd = 1550039814
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 9478  //机构id小英9675或4
-		adminUserInfo.CurrentAppId = 18470 //4
+		adminUserInfo.CurrentOrgId = 10721 //机构id小英9675或4
+		adminUserInfo.CurrentAppId = 18723 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
 		this.SetSession("admin_user_info", &adminUserInfo)
 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 9478 //机构id小英9675或4
+		subscibe.OrgId = 10721 //机构id小英9675或4
 		subscibe.PeriodStart = 1538035409
 		subscibe.PeriodEnd = 1569571409
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 9478  //机构id小英9675或4
-		adminUserInfo.CurrentAppId = 18470 //4
+		adminUserInfo.CurrentOrgId = 10721 //机构id小英9675或4
+		adminUserInfo.CurrentAppId = 18723 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
 		this.SetSession("admin_user_info", &adminUserInfo)

controllers/common_api_controller.go

 package controllers
 
 import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"time"
+
 	"XT_New/enums"
 	"XT_New/models"
 	"XT_New/service"
 	"XT_New/utils"
-	"encoding/json"
-	"fmt"
 	"github.com/jinzhu/gorm"
-	"strconv"
-	"time"
 )
 
 type CommonApiController struct {
 func (this *CommonApiController) GetTotalSexCount() {
 	adminUser := this.GetAdminUserInfo()
 	orgid := adminUser.CurrentOrgId
-	fmt.Println("orgid", orgid)
-	startime, _ := this.GetInt64("startime")
-	fmt.Println("开始时间", startime)
-	endtime, _ := this.GetInt64("endtime")
-	fmt.Println("结束时间", endtime)
+	//startime, _ := this.GetInt64("startime")
+	//
+	//endtime, _ := this.GetInt64("endtime")
+
 	lapsetotype, _ := this.GetInt64("lapsetotype")
 	sourcetype, _ := this.GetInt64("sourcetype")
 	total := service.GetPatientTotalCount(orgid, lapsetotype, sourcetype)
 func (this *CommonApiController) GetTotalAgeCount() {
 	adminUser := this.GetAdminUserInfo()
 	orgid := adminUser.CurrentOrgId
-	fmt.Println("orgid", orgid)
-	startime, _ := this.GetInt64("startime")
-	fmt.Println("开始时间", startime)
-	endtime, _ := this.GetInt64("endtime")
-	fmt.Println("结束时间", endtime)
 	lapsetotype, _ := this.GetInt64("lapsetotype")
 	sourcetype, _ := this.GetInt64("sourcetype")
 	//统计透析总人数
 	limit, _ := this.GetInt64("limit")
 
 	patients, total, err := service.GetPatientsControl(orgid, lapstor, startimeStrUnix, endtimeStrsUnix, page, limit)
+
 	control, err := service.GetLastPatientsControl(orgid, lapstor, startimeStrUnix, endtimeStrsUnix)
 
 	infectiousControl, err := service.GetInfectiousControl(orgid, lapstor, startimeStrUnix, endtimeStrsUnix)

controllers/dialysis_api_controller.go

 
 			}
 		}
+
+		if adminUserInfo.CurrentOrgId == 10744 {
+			evaluation, _ := service.GetAssessmentBeforThrity(adminUserInfo.CurrentOrgId, patient, recordDate.Unix())
+			if evaluation.WeightBefore > 0 {
+				assessment.WeightLoss = evaluation.WeightBefore - assessment.WeightAfter
+			}
+
+		}
+
 		err = service.UpdateAssessmentAfterDislysisRecord(&assessment)
 		//记录日志
 		byterequest, _ := json.Marshal(assessment)
 			service.CreateDialysisFinish(finish)
 		}
 
-		if adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 3877 || adminUserInfo.CurrentOrgId == 10469 || adminUserInfo.CurrentOrgId == 10551 || adminUserInfo.CurrentOrgId == 10579 || adminUserInfo.CurrentOrgId == 10580 || adminUserInfo.CurrentOrgId == 10585 || adminUserInfo.CurrentOrgId == 10344 || adminUserInfo.CurrentOrgId == 10622 || adminUserInfo.CurrentOrgId == 10702 || adminUserInfo.CurrentOrgId == 10635 || adminUserInfo.CurrentOrgId == 10723 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10727 || adminUserInfo.CurrentOrgId == 10726 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10727 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10752 {
+		if adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 3877 || adminUserInfo.CurrentOrgId == 10469 || adminUserInfo.CurrentOrgId == 10551 || adminUserInfo.CurrentOrgId == 10579 || adminUserInfo.CurrentOrgId == 10580 || adminUserInfo.CurrentOrgId == 10585 || adminUserInfo.CurrentOrgId == 10344 || adminUserInfo.CurrentOrgId == 10622 || adminUserInfo.CurrentOrgId == 10702 || adminUserInfo.CurrentOrgId == 10635 || adminUserInfo.CurrentOrgId == 10723 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10727 || adminUserInfo.CurrentOrgId == 10726 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10727 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10752 || adminUserInfo.CurrentOrgId == 10480 || adminUserInfo.CurrentOrgId == 10293 || adminUserInfo.CurrentOrgId == 9478 {
 			var dewater_amount float64
 			dewater_amount = 0
 			if dry_weight > 0 {
 				dewater_amount = weight_before - dry_weight - additional_weight
 
-				if adminUserInfo.CurrentOrgId != 10551 && adminUserInfo.CurrentOrgId != 10579 && adminUserInfo.CurrentOrgId != 10580 && adminUserInfo.CurrentOrgId != 10585 && adminUserInfo.CurrentOrgId != 10344 && adminUserInfo.CurrentOrgId != 10622 && adminUserInfo.CurrentOrgId != 10702 && adminUserInfo.CurrentOrgId != 10635 && adminUserInfo.CurrentOrgId != 10723 {
+				if adminUserInfo.CurrentOrgId != 10551 && adminUserInfo.CurrentOrgId != 10579 && adminUserInfo.CurrentOrgId != 10580 && adminUserInfo.CurrentOrgId != 10585 && adminUserInfo.CurrentOrgId != 10344 && adminUserInfo.CurrentOrgId != 10622 && adminUserInfo.CurrentOrgId != 10702 && adminUserInfo.CurrentOrgId != 10635 && adminUserInfo.CurrentOrgId != 10723 && adminUserInfo.CurrentOrgId != 10480 && adminUserInfo.CurrentOrgId != 10293 && adminUserInfo.CurrentOrgId != 9478 {
 					dewater_amount = dewater_amount * 1000
 				}
 
 		dewater_amount = 0
 		if evaluation.DryWeight > 0 {
 			dewater_amount = evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight
-			if templateInfo.TemplateId == 17 || templateInfo.TemplateId == 22 || templateInfo.TemplateId == 21 || templateInfo.TemplateId == 34 || adminUserInfo.CurrentOrgId == 10551 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10757 {
-				if adminUserInfo.CurrentOrgId != 10551 && adminUserInfo.CurrentOrgId != 10751 {
+			if templateInfo.TemplateId == 17 || templateInfo.TemplateId == 22 || templateInfo.TemplateId == 21 || templateInfo.TemplateId == 34 || adminUserInfo.CurrentOrgId == 10551 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10757 || adminUserInfo.CurrentOrgId == 9478 {
+				if adminUserInfo.CurrentOrgId != 10551 && adminUserInfo.CurrentOrgId != 10751 && adminUserInfo.CurrentOrgId != 9478 {
 					dewater_amount = dewater_amount * 1000
 				}
 
 		}
 
 		//针对孝昌康桥超滤率计算问题
-		if adminUserInfo.CurrentOrgId == 10702 || adminUserInfo.CurrentOrgId == 10635 || adminUserInfo.CurrentOrgId == 10723 || adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10726 || adminUserInfo.CurrentOrgId == 10742 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10752 || adminUserInfo.CurrentOrgId == 10697 {
+		if adminUserInfo.CurrentOrgId == 10702 || adminUserInfo.CurrentOrgId == 10635 || adminUserInfo.CurrentOrgId == 10723 || adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10726 || adminUserInfo.CurrentOrgId == 10742 || adminUserInfo.CurrentOrgId == 10751 || adminUserInfo.CurrentOrgId == 10752 || adminUserInfo.CurrentOrgId == 10697 || adminUserInfo.CurrentOrgId == 9478 {
 			if assessmentBeforeDislysis.ID == 0 {
 				dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.CurrentOrgId, patient, recordDate.Unix())
 				if dialysisPrescribeOne.ID > 0 && assessmentBeforeDislysis.ID > 0 {
 				}
 			}
 
-			if assessmentBeforeDislysis.ID > 0 {
-				dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.CurrentOrgId, patient, recordDate.Unix())
-				if dialysisPrescribeOne.ID > 0 && assessmentBeforeDislysis.ID > 0 {
-					dewater_amount = assessmentBeforeDislysis.WeightBefore - assessmentBeforeDislysis.DryWeight - assessmentBeforeDislysis.AdditionalWeight
-					if adminUserInfo.CurrentOrgId == 10751 {
-						dewater_amount = dewater_amount * 1000
+			if adminUserInfo.CurrentOrgId != 10751 {
+				if assessmentBeforeDislysis.ID > 0 {
+					dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.CurrentOrgId, patient, recordDate.Unix())
+					if dialysisPrescribeOne.ID > 0 && assessmentBeforeDislysis.ID > 0 {
+						dewater_amount = assessmentBeforeDislysis.WeightBefore - assessmentBeforeDislysis.DryWeight - assessmentBeforeDislysis.AdditionalWeight
+						//if adminUserInfo.CurrentOrgId == 10751 {
+						//	dewater_amount = dewater_amount * 1000
+						//}
+						service.UpdateMobileGetDialysisPrescribeOne(dialysisPrescribeOne.ID, dewater_amount)
 					}
-					service.UpdateMobileGetDialysisPrescribeOne(dialysisPrescribeOne.ID, dewater_amount)
 				}
 			}
 

controllers/gobal_config_api_controller.go

 	idsInters := dataBody["ids"].([]interface{})
 	advice_type, _ := c.GetInt64("advice_type")
 	stop_type, _ := c.GetInt64("stop_type")
+	his_str := c.GetString("his_str")
+	if len(his_str) == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	idStrs := strings.Split(his_str, ",")
 	if len(idsInters) == 0 {
 		if err != nil {
 			c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
 		id := int64(idsInter.(float64))
 		ids = append(ids, id)
 	}
+
 	getPrint, err := service.GetPrint(ids, OrgID, advice_type, stop_type)
+
+	hisPrint, _ := service.GetHisPrint(idStrs, OrgID)
 	c.ServeSuccessJSON(map[string]interface{}{
-		"doctoradvice": getPrint,
+		"doctoradvice":    getPrint,
+		"hisdoctoradvice": hisPrint,
 	})
 }
 

controllers/his_api_controller.go

 	var adviceList []models.HisDoctorAdviceInfo
 	var projectList []models.HisPrescriptionProject
 
-	if adminInfo.CurrentOrgId == 10489 || adminInfo.CurrentOrgId == 10510 || adminInfo.CurrentOrgId == 10164 || adminInfo.CurrentOrgId == 10478 || adminInfo.CurrentOrgId == 10318 || adminInfo.CurrentOrgId == 10480 || adminInfo.CurrentOrgId == 10633 || adminInfo.CurrentOrgId == 10610 || adminInfo.CurrentOrgId == 10402 || adminInfo.CurrentOrgId == 10138 || adminInfo.CurrentOrgId == 10278 || adminInfo.CurrentOrgId == 10537 || adminInfo.CurrentOrgId == 10265 || adminInfo.CurrentOrgId == 10644 || adminInfo.CurrentOrgId == 10635 || adminInfo.CurrentOrgId == 10598 || adminInfo.CurrentOrgId == 10028 || adminInfo.CurrentOrgId == 10721 || adminInfo.CurrentOrgId == 10726 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10571 || adminInfo.CurrentOrgId == 10724 || adminInfo.CurrentOrgId == 9671 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10653 || adminInfo.CurrentOrgId == 10567 || adminInfo.CurrentOrgId == 10751 || adminInfo.CurrentOrgId == 10752 {
+	if adminInfo.CurrentOrgId == 10489 || adminInfo.CurrentOrgId == 10510 || adminInfo.CurrentOrgId == 10164 || adminInfo.CurrentOrgId == 10478 || adminInfo.CurrentOrgId == 10318 || adminInfo.CurrentOrgId == 10480 || adminInfo.CurrentOrgId == 10633 || adminInfo.CurrentOrgId == 10610 || adminInfo.CurrentOrgId == 10402 || adminInfo.CurrentOrgId == 10138 || adminInfo.CurrentOrgId == 10278 || adminInfo.CurrentOrgId == 10537 || adminInfo.CurrentOrgId == 10265 || adminInfo.CurrentOrgId == 10644 || adminInfo.CurrentOrgId == 10635 || adminInfo.CurrentOrgId == 10598 || adminInfo.CurrentOrgId == 10028 || adminInfo.CurrentOrgId == 10721 || adminInfo.CurrentOrgId == 10726 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10571 || adminInfo.CurrentOrgId == 10724 || adminInfo.CurrentOrgId == 9671 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10653 || adminInfo.CurrentOrgId == 10567 || adminInfo.CurrentOrgId == 10751 || adminInfo.CurrentOrgId == 10752 || adminInfo.CurrentOrgId == 9478 {
 		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
 			prescriptions, _ := dataBody["prescriptions"].([]interface{})
 
 
 											}
 
-											fmt.Println("s.ID==========================", s.ID)
-
 											if s.ID > 0 {
 												//查询改药品是否已经停用
 												base, _ := service.GetBasedrugById(s.DrugId, s.UserOrgId)

controllers/mobile_api_controllers/check_weight_api_controller.go

 			evaluation.UserOrgId = adminUserInfo.Org.Id
 			// 获取上一次透前评估信息，部分数据是需要从上一次透前评估继承
 			lastPredialysisEvaluation, _ := service.MobileGetLastTimePredialysisEvaluationOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
+
 			// 获取上一次透后评估，插入本次透前评估的上次透后体重（weight_after_last_transparency）字段
 			assessmentAfterDislysis, getAADErr := service.MobileGetLastTimeAssessmentAfterDislysisOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
 			if getAADErr != nil {
 				if adminUserInfo.Org.Id == 10702 {
 					evaluation.PulseFrequency = 0
 				}
+				if adminUserInfo.Org.Id == 10121 || adminUserInfo.Org.Id == 10234 {
+					evaluation.Height = lastPredialysisEvaluation.Height
+				}
 			}
 		} else {
 			evaluation.UpdatedTime = time.Now().Unix()
 		}
 
 		afterevaluation.WeightAfter = weight_after
+
 		afterevaluation.WeightLoss = weight_loss
 
 		if adminUserInfo.Org.Id == 10138 {
 			afterevaluation.Temperature = 36.5
 		}
 
+		if adminUserInfo.Org.Id == 10744 {
+			evaluation, _ := service.GetAssessmentBeforThrity(adminUserInfo.Org.Id, id, theAssessmentDateTime)
+			if evaluation.WeightBefore > 0 {
+				afterevaluation.WeightLoss = evaluation.WeightBefore - weight_after
+			}
+
+		}
+
 		err := service.UpdateAssessmentAfterDislysisRecord(&afterevaluation)
 
 		//记录日志

controllers/mobile_api_controllers/dialysis_api_controller.go

 
 	}
 
+	//查找是否开启配置
+	//orderSetting, _ := service.GetDialysisOrderSetting(adminUserInfo.Org.Id)
+	////开启下机扣减
+	//if orderSetting.IsOpen == 1 {
+	//
+	//	//查询今日患者排班的模式
+	//	db := service.XTWriteDB()
+	//	// 开始外部循环的事务
+	//	tx := db.Begin()
+	//	// 在函数结束时处理事务回滚
+	//	defer func() {
+	//		if r := recover(); r != nil {
+	//			tx.Rollback()
+	//		}
+	//	}()
+	//
+	//	schedule, _ := service.GetDialysisOrderSchedule(id, recordDate.Unix(), adminUserInfo.Org.Id, tx)
+	//
+	//	if schedule.ModeId == 1 {
+	//		//扣减库存
+	//		service.ReducePatientCount(1, schedule.ModeId, id, tx)
+	//
+	//		patient, _ := service.GetSfPatientById(tx, id)
+	//		var over_count int64
+	//		if schedule.ModeId == 1 {
+	//			over_count = patient.HdCount
+	//		}
+	//		if schedule.ModeId == 2 {
+	//			over_count = patient.HdfCount
+	//		}
+	//
+	//		if schedule.ModeId == 3 {
+	//			over_count = patient.HdhpCount
+	//		}
+	//		if schedule.ModeId == 4 {
+	//			over_count = patient.HpCount
+	//		}
+	//		if schedule.ModeId == 5 {
+	//			over_count = patient.OtherCount
+	//		}
+	//		patientCountFlow := models.SfPatientCountFlow{
+	//			PatientId:      id,
+	//			ModeId:         schedule.ModeId,
+	//			Count:          1,
+	//			Status:         1,
+	//			Ctime:          time.Now().Unix(),
+	//			Mtime:          time.Now().Unix(),
+	//			RecordDate:     recordDate.Unix(),
+	//			UserOrgId:      adminUserInfo.Org.Id,
+	//			Creater:        adminUserInfo.AdminUser.Id,
+	//			IsType:         1,
+	//			OverCount:      over_count,
+	//			WarehouseOutId: 0,
+	//		}
+	//
+	//		service.CreatePatientCountFlow(patientCountFlow, tx)
+	//	}
+	//
+	//	if schedule.ModeId == 2 {
+	//
+	//		//扣减库存
+	//		service.ReducePatientCount(1, schedule.ModeId, id, tx)
+	//
+	//		patient, _ := service.GetSfPatientById(tx, id)
+	//		var over_count int64
+	//		if schedule.ModeId == 1 {
+	//			over_count = patient.HdCount
+	//		}
+	//		if schedule.ModeId == 2 {
+	//			over_count = patient.HdfCount
+	//		}
+	//
+	//		if schedule.ModeId == 3 {
+	//			over_count = patient.HdhpCount
+	//		}
+	//		if schedule.ModeId == 4 {
+	//			over_count = patient.HpCount
+	//		}
+	//		if schedule.ModeId == 5 {
+	//			over_count = patient.OtherCount
+	//		}
+	//		patientCountFlow := models.SfPatientCountFlow{
+	//			PatientId:      id,
+	//			ModeId:         schedule.ModeId,
+	//			Count:          1,
+	//			Status:         1,
+	//			Ctime:          time.Now().Unix(),
+	//			Mtime:          time.Now().Unix(),
+	//			RecordDate:     recordDate.Unix(),
+	//			UserOrgId:      adminUserInfo.Org.Id,
+	//			Creater:        adminUserInfo.AdminUser.Id,
+	//			IsType:         2,
+	//			OverCount:      over_count,
+	//			WarehouseOutId: 0,
+	//		}
+	//
+	//		service.CreatePatientCountFlow(patientCountFlow, tx)
+	//	}
+	//
+	//	if schedule.ModeId == 3 {
+	//
+	//		//扣减库存
+	//		service.ReducePatientCount(1, schedule.ModeId, id, tx)
+	//
+	//		patient, _ := service.GetSfPatientById(tx, id)
+	//		var over_count int64
+	//		if schedule.ModeId == 1 {
+	//			over_count = patient.HdCount
+	//		}
+	//		if schedule.ModeId == 2 {
+	//			over_count = patient.HdfCount
+	//		}
+	//
+	//		if schedule.ModeId == 3 {
+	//			over_count = patient.HdhpCount
+	//		}
+	//		if schedule.ModeId == 4 {
+	//			over_count = patient.HpCount
+	//		}
+	//		if schedule.ModeId == 5 {
+	//			over_count = patient.OtherCount
+	//		}
+	//		patientCountFlow := models.SfPatientCountFlow{
+	//			PatientId:      id,
+	//			ModeId:         schedule.ModeId,
+	//			Count:          1,
+	//			Status:         1,
+	//			Ctime:          time.Now().Unix(),
+	//			Mtime:          time.Now().Unix(),
+	//			RecordDate:     recordDate.Unix(),
+	//			UserOrgId:      adminUserInfo.Org.Id,
+	//			Creater:        adminUserInfo.AdminUser.Id,
+	//			IsType:         3,
+	//			OverCount:      over_count,
+	//			WarehouseOutId: 0,
+	//		}
+	//
+	//		service.CreatePatientCountFlow(patientCountFlow, tx)
+	//	}
+	//	if schedule.ModeId == 4 {
+	//
+	//		//扣减库存
+	//		service.ReducePatientCount(1, schedule.ModeId, id, tx)
+	//
+	//		patient, _ := service.GetSfPatientById(tx, id)
+	//		var over_count int64
+	//		if schedule.ModeId == 1 {
+	//			over_count = patient.HdCount
+	//		}
+	//		if schedule.ModeId == 2 {
+	//			over_count = patient.HdfCount
+	//		}
+	//
+	//		if schedule.ModeId == 3 {
+	//			over_count = patient.HdhpCount
+	//		}
+	//		if schedule.ModeId == 4 {
+	//			over_count = patient.HpCount
+	//		}
+	//		if schedule.ModeId == 5 {
+	//			over_count = patient.OtherCount
+	//		}
+	//		patientCountFlow := models.SfPatientCountFlow{
+	//			PatientId:      id,
+	//			ModeId:         schedule.ModeId,
+	//			Count:          1,
+	//			Status:         1,
+	//			Ctime:          time.Now().Unix(),
+	//			Mtime:          time.Now().Unix(),
+	//			RecordDate:     recordDate.Unix(),
+	//			UserOrgId:      adminUserInfo.Org.Id,
+	//			Creater:        adminUserInfo.AdminUser.Id,
+	//			IsType:         4,
+	//			OverCount:      over_count,
+	//			WarehouseOutId: 0,
+	//		}
+	//
+	//		service.CreatePatientCountFlow(patientCountFlow, tx)
+	//	}
+	//	if schedule.ModeId != 1 && schedule.ModeId != 2 && schedule.ModeId != 3 && schedule.ModeId != 4 {
+	//
+	//		//扣减库存
+	//		service.ReducePatientCount(1, schedule.ModeId, id, tx)
+	//
+	//		patient, _ := service.GetSfPatientById(tx, id)
+	//		var over_count int64
+	//		if schedule.ModeId == 1 {
+	//			over_count = patient.HdCount
+	//		}
+	//		if schedule.ModeId == 2 {
+	//			over_count = patient.HdfCount
+	//		}
+	//
+	//		if schedule.ModeId == 3 {
+	//			over_count = patient.HdhpCount
+	//		}
+	//		if schedule.ModeId == 4 {
+	//			over_count = patient.HpCount
+	//		}
+	//		if schedule.ModeId == 5 {
+	//			over_count = patient.OtherCount
+	//		}
+	//		patientCountFlow := models.SfPatientCountFlow{
+	//			PatientId:      id,
+	//			ModeId:         schedule.ModeId,
+	//			Count:          1,
+	//			Status:         1,
+	//			Ctime:          time.Now().Unix(),
+	//			Mtime:          time.Now().Unix(),
+	//			RecordDate:     recordDate.Unix(),
+	//			UserOrgId:      adminUserInfo.Org.Id,
+	//			Creater:        adminUserInfo.AdminUser.Id,
+	//			IsType:         5,
+	//			OverCount:      over_count,
+	//			WarehouseOutId: 0,
+	//		}
+	//
+	//		service.CreatePatientCountFlow(patientCountFlow, tx)
+	//	}
+	//
+	//	tx.Commit()
+	//	return
+	//}
+
 }
 
 func (c *DialysisAPIController) GetAllZone() {
 				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration / float64(totalMin) * 60 * 1000)
 			}
 
-			if adminUserInfo.Org.Id == 10742 || adminUserInfo.Org.Id == 10740 || adminUserInfo.Org.Id == 10745 {
+			if adminUserInfo.Org.Id == 10742 || adminUserInfo.Org.Id == 10740 || adminUserInfo.Org.Id == 10745 || adminUserInfo.Org.Id == 9478 {
 				ultrafiltration_rate = math.Floor(prescription.PrescriptionWater / float64(totalMin) * 60 * 1000)
 			}
 
 				}
 			}
 
-			if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10731 || adminUserInfo.Org.Id == 10727 {
+			if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10731 || adminUserInfo.Org.Id == 10727 || adminUserInfo.Org.Id == 10744 {
 				if prescription.ModeId == 2 {
 					totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
 					if totalMin == 0 {
 			}
 
 			//重庆塘坝卫生院
-			if adminInfo.Org.Id == 10742 || adminInfo.Org.Id == 10740 || adminInfo.Org.Id == 10745 {
+			if adminInfo.Org.Id == 10742 || adminInfo.Org.Id == 10740 || adminInfo.Org.Id == 10745 || adminInfo.Org.Id == 9478 {
 				ultrafiltration_rate = math.Floor(prescription.PrescriptionWater / float64(totalMin) * 60 * 1000)
+				fmt.Println("ultrafiltration_rate--------------------", ultrafiltration_rate)
 				record.UltrafiltrationRate = ultrafiltration_rate
 			}
 
 	}
 
 	//长沙南雅
-	if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 10469 || adminInfo.Org.Id == 10375 || adminInfo.Org.Id == 10610 || adminInfo.Org.Id == 10537 || adminInfo.Org.Id == 10667 {
+	if adminInfo.Org.Id == 10395 || adminInfo.Org.Id == 10138 || adminInfo.Org.Id == 10278 || adminInfo.Org.Id == 10432 || adminInfo.Org.Id == 10441 || adminInfo.Org.Id == 10445 || adminInfo.Org.Id == 10469 || adminInfo.Org.Id == 10375 || adminInfo.Org.Id == 10610 || adminInfo.Org.Id == 10537 || adminInfo.Org.Id == 10667 || adminInfo.Org.Id == 9478 {
 
 		if ultrafiltration_rate > 0 {
 			ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
 		}
 	}
 
-	if adminInfo.Org.Id == 10721 || adminInfo.Org.Id == 10757 {
+	if adminInfo.Org.Id == 10721 || adminInfo.Org.Id == 10757 || adminInfo.Org.Id == 9478 || adminInfo.Org.Id == 10290 {
 		var replacement_rate float64
 		var displacement_quantity float64
 		totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
 
 	}
 
-	if adminInfo.Org.Id == 10740 || adminInfo.Org.Id == 10742 || adminInfo.Org.Id == 10745 {
+	if adminInfo.Org.Id == 10740 || adminInfo.Org.Id == 10742 || adminInfo.Org.Id == 10745 || adminInfo.Org.Id == 9478 {
 
 		var replacement_rate float64
 		var displacement_quantity float64
 		record.UltrafiltrationVolume = ultrafiltration_volume
 	}
 
-	if adminInfo.Org.Id == 10731 || adminInfo.Org.Id == 10727 {
+	if adminInfo.Org.Id == 10731 || adminInfo.Org.Id == 10727 || adminInfo.Org.Id == 10744 {
 
 		var replacement_rate float64
 		var displacement_quantity float64
 		StopTime:              0,
 		StopReason:            "",
 		StopDoctor:            0,
-		StopState:             0,
+		StopState:             2,
 		ParentId:              0,
 		ExecutionTime:         0,
 		ExecutionStaff:        0,

controllers/mobile_api_controllers/patient_api_controller.go

 					infor, _ := service.GetDialysisInformationByRecordDate(advices.PatientId, advices.AdviceDate, adminUserInfo.Org.Id, 4)
 					//申请状态不允许的情况 拒绝修改
 					if infor.ApplicationStatus != 1 {
+
 						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeInformationExist)
 						return
+
 					}
 
 				}
 
 		storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminUserInfo.Org.Id)
 
-		if drugStockConfig.IsOpen == 1 {
+		if drugStockConfig.IsOpen == 1 && adminUserInfo.Org.Id != 10644 && adminUserInfo.Org.Id != 10721 {
 			if groupno > 0 {
 				advices, _ := service.FindAllDoctorAdviceByGoroupNoTwety(adminUserInfo.Org.Id, groupno)
 
 			// 查询信息规挡的设置天数
 
 			infor, _ := service.GetDialysisInformationSetting(item.UserOrgId)
+
+			fmt.Println("infor==================", infor.ID)
 			if infor.ID > 0 {
 
 				var cha_time int64
 								PrescribingNumberUnit: item.PrescribingNumberUnit,
 							}
 							service.CreateDrugError(drugError)
+							tx.Rollback()
 						}
 					}
 					advice, _ := service.FindHisDoctorAdviceByIdTwo(adminInfo.Org.Id, item.ID, tx)
 						}
 					}
 
+					fmt.Println("prescribing_number_total", prescribing_number_total)
+					fmt.Println("total------------", total)
+
 					if prescribing_number_total <= total {
 
 						pharmacyConfig, _ := service.FindPharmacyConfig(advice.UserOrgId)
 	if evaluation.DryWeight > 0 {
 		dewater_amount = evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight
 
-		if template.TemplateId == 17 || template.TemplateId == 22 || template.TemplateId == 21 || template.TemplateId == 26 || template.TemplateId == 34 || template.TemplateId == 32 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 10551 || adminUserInfo.Org.Id == 10579 || adminUserInfo.Org.Id == 10580 || adminUserInfo.Org.Id == 10585 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10727 || adminUserInfo.Org.Id == 10751 || adminUserInfo.Org.Id == 10752 || adminUserInfo.Org.Id == 10757 {
+		if template.TemplateId == 17 || template.TemplateId == 22 || template.TemplateId == 21 || template.TemplateId == 26 || template.TemplateId == 34 || template.TemplateId == 32 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 10551 || adminUserInfo.Org.Id == 10579 || adminUserInfo.Org.Id == 10580 || adminUserInfo.Org.Id == 10585 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10727 || adminUserInfo.Org.Id == 10751 || adminUserInfo.Org.Id == 10752 || adminUserInfo.Org.Id == 10757 || adminUserInfo.Org.Id == 9478 {
 
-			if adminUserInfo.Org.Id != 10551 && adminUserInfo.Org.Id != 10579 && adminUserInfo.Org.Id != 10580 && adminUserInfo.Org.Id != 10585 && adminUserInfo.Org.Id != 10752 {
+			if adminUserInfo.Org.Id != 10551 && adminUserInfo.Org.Id != 10579 && adminUserInfo.Org.Id != 10580 && adminUserInfo.Org.Id != 10585 && adminUserInfo.Org.Id != 10752 && adminUserInfo.Org.Id != 9478 {
 				dewater_amount = dewater_amount * 1000
 			}
 
 	}
 
 	//针对孝昌康桥超滤率计算问题
-	if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10726 || adminUserInfo.Org.Id == 10164 || adminUserInfo.Org.Id == 10751 || adminUserInfo.Org.Id == 10752 || adminUserInfo.Org.Id == 10757 {
+	if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10726 || adminUserInfo.Org.Id == 10164 || adminUserInfo.Org.Id == 10751 || adminUserInfo.Org.Id == 10752 || adminUserInfo.Org.Id == 10757 || adminUserInfo.Org.Id == 9478 {
 		if evaluation.ID == 0 {
 			dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
 			if dialysisPrescribeOne.ID > 0 && evaluation.ID > 0 {
 			}
 		}
 
-		if evaluation.ID > 0 {
-			dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
-			if dialysisPrescribeOne.ID > 0 && evaluation.ID > 0 {
-				dewater_amount = evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight
-				if adminUserInfo.Org.Id == 10751 {
-					dewater_amount = dewater_amount * 1000
+		if adminUserInfo.Org.Id != 10751 {
+			if evaluation.ID > 0 {
+				dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
+				if dialysisPrescribeOne.ID > 0 && evaluation.ID > 0 {
+					dewater_amount = evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight
+					//if adminUserInfo.Org.Id == 10751 {
+					//	dewater_amount = dewater_amount * 1000
+					//}
+					service.UpdateMobileGetDialysisPrescribeOne(dialysisPrescribeOne.ID, dewater_amount)
 				}
-				service.UpdateMobileGetDialysisPrescribeOne(dialysisPrescribeOne.ID, dewater_amount)
 			}
 		}
 
 func (c *PatientApiController) CreateGroupAdvice() {
 	is_child, _ := c.GetInt64("is_child", 0)
 
+	fmt.Println("hhhhhhhhhhhhhhhhhhhhhhhhhhhhhh", is_child)
 	if is_child == 1 {
 		patient, _ := c.GetInt64("id", 0)
 		if patient <= 0 {
 				}
 			}
 
-			err = service.DeleteDoctorAdviceByGroupNo(&advice)
+			err = service.DeleteDoctorAdviceByGroupNoOne(&advice)
 			//记录日志
 			byterequest, _ := json.Marshal(advice)
 			adviceLog := models.XtDoctorAdviceLog{

controllers/new_mobile_api_controllers/staff_schedule_api_controller.go

 	timenow := time.Now().Format("2006-01-02")
 	timeNewDate, _ := utils.ParseTimeStringToTime("2006-01-02", timenow)
 	//针对百霖和贝尔
-	if orgid == 10138 || orgid == 10278 || orgid == 3877 {
+	if orgid == 10138 || orgid == 10278 || orgid == 3877 || orgid == 10610 || orgid == 10537 {
 		//获取今日的排班数据
 		list, _ := service.GetMobileScheduleListByScheduleDate(orgid, startTime)
 		for _, item := range list {
 		"order": order,
 	})
 }
+
+func (c *StaffScheduleApiController) GetPatientialysisSolutonByPatientId() {
+
+	patient_id, _ := c.GetInt64("patient_id")
+
+	record_date, _ := c.GetInt64("record_date")
+
+	orgId := c.GetAdminUserInfo().CurrentOrgId
+
+	schedule, _ := service.GetPatientScheduleByPatient(patient_id, record_date, orgId)
+
+	dialysisSolution, _ := service.GetDialysisSolutonByScheduleModeId(schedule.ModeId, patient_id, orgId)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"dialysisSolution": dialysisSolution,
+	})
+
+}

controllers/new_mobile_api_controllers/staff_schedule_api_router.go

 
 	beego.Router("/m/api/patient/getmobiledialysiscount", &StaffScheduleApiController{}, "Get:GetMobileDialysisCount")
 
+	beego.Router("/api/schedule/getpatientdialysissolutionbypatientid", &StaffScheduleApiController{}, "Get:GetPatientialysisSolutonByPatientId")
+
 }

controllers/patient_api_controller.go

 
 	beego.Router("/api/patient/getinspectionbyprojectid", &PatientApiController{}, "Get:GetInspectionByProjectId")
 
+	beego.Router("/api/patient/getpatientmaplist", &PatientApiController{}, "Get:GetPatientMapList")
+
+	beego.Router("/api/patient/savepatientcount", &PatientApiController{}, "Get:SavePatientCount")
+
+	beego.Router("/api/patient/getpatientcount", &PatientApiController{}, "Get:GetPatientCountList")
+
+	beego.Router("/api/patient/checkpatientcount", &PatientApiController{}, "Get:CheckPatientCount")
+
+	beego.Router("/api/patient/returncheck", &PatientApiController{}, "Get:ReturnCheckPatientCount")
+
+	beego.Router("/api/patient/deletepatientcount", &PatientApiController{}, "Get:DeletePatientCount")
+
+	beego.Router("/api/patient/savepatientoutcount", &PatientApiController{}, "Get:SavePatientOutCount")
+
+	beego.Router("/api/patient/getpatientoutcountlist", &PatientApiController{}, "Get:GetPatientOutCountList")
+
+	beego.Router("/api/patient/deletepatientoutcount", &PatientApiController{}, "Get:DeletePatientOutCount")
+
+	beego.Router("/api/patient/checkpatientoutcount", &PatientApiController{}, "Get:CheckPatientOutCount")
+
+	beego.Router("/api/patient/returnpatientoutlist", &PatientApiController{}, "Get:ReturnPatientOutList")
+
+	beego.Router("/api/patient/getpatientcountmaplist", &PatientApiController{}, "Get:GetPatientCountMapList")
+
+	beego.Router("/api/patient/getpatientcountflow", &PatientApiController{}, "Get:GetPatientCountFlow")
+
+	beego.Router("/api/patient/getdialysisordersetting", &PatientApiController{}, "Get:GetDialysisOrderSetting")
+
+	beego.Router("/api/patient/savepatientordersetting", &PatientApiController{}, "Get:SavePatientOrderSetting")
+
+	beego.Router("/api/patient/getpatientcountflowlist", &PatientApiController{}, "Get:GetPatientCountFlowList")
+
+	beego.Router("/api/patient/getpatientcountflowbyid", &PatientApiController{}, "Get:GetPatientCountFlowById")
+
 }
 func (c *PatientApiController) GetExportList() {
 	startTime := c.GetString("start_time")
 }
 
 func (c *PatientApiController) CreateGroupAdvice() {
+
 	var err error
 	defer func() {
 		if rec := recover(); rec != nil {
 	}
 	utils.ErrorLog("%v", dataBody)
 
-	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
-	if appRole.UserType == 3 {
-		headNursePermission, getPermissionErr := service.GetAdminUserSpecialPermission(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, models.SpecialPermissionTypeHeadNurse)
-		if getPermissionErr != nil {
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-			return
-		} else if headNursePermission == nil {
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateAdvice)
-			return
-		}
-	}
+	//appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
+	//if appRole.UserType == 3 {
+	//	headNursePermission, getPermissionErr := service.GetAdminUserSpecialPermission(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, models.SpecialPermissionTypeHeadNurse)
+	//	if getPermissionErr != nil {
+	//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//		return
+	//	} else if headNursePermission == nil {
+	//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateAdvice)
+	//		return
+	//	}
+	//}
 
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 		return
 	}
 	adviceType := int64(dataBody["advice_type"].(float64))
+
+	fmt.Println("adviceType----------------", adviceType)
 	if adviceType != 1 && adviceType != 2 && adviceType != 3 && adviceType != 4 {
 		utils.ErrorLog("advice_type != 1&&2")
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		"inspection": inspection,
 	})
 }
+
+func (this *PatientApiController) GetPatientMapList() {
+
+	keyword := this.GetString("keyword")
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	patient, _ := service.GetPatientMapList(orgId, keyword)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}
+
+func (this *PatientApiController) SavePatientCount() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	creater := this.GetAdminUserInfo().AdminUser.Id
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	hd_count, _ := this.GetInt64("hd_count")
+
+	hdf_count, _ := this.GetInt64("hdf_count")
+
+	hdhp_count, _ := this.GetInt64("hdhp_count")
+
+	hp_count, _ := this.GetInt64("hp_count")
+
+	other_count, _ := this.GetInt64("other_count")
+
+	remark := this.GetString("remark")
+
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+
+	nowtime := recordDate.Unix()
+
+	db := service.XTWriteDB()
+	// 开始外部循环的事务
+	tx := db.Begin()
+	// 在函数结束时处理事务回滚
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+		}
+	}()
+
+	if hd_count > 0 {
+		patientInCount := models.SfPatientInCount{
+			PatientId:  patient_id,
+			UserOrgId:  orgId,
+			IsType:     1,
+			Count:      hd_count,
+			Status:     1,
+			Creater:    creater,
+			Ctime:      time.Now().Unix(),
+			Mtime:      time.Now().Unix(),
+			IsCheck:    2,
+			RecordDate: nowtime,
+			Remark:     remark,
+			StockCount: hd_count,
+		}
+
+		service.CreatePatientInCount(tx, patientInCount)
+
+	}
+
+	if hdf_count > 0 {
+
+		patientInCount := models.SfPatientInCount{
+			PatientId:  patient_id,
+			UserOrgId:  orgId,
+			IsType:     2,
+			Count:      hdf_count,
+			Status:     1,
+			Creater:    creater,
+			Ctime:      time.Now().Unix(),
+			Mtime:      time.Now().Unix(),
+			IsCheck:    2,
+			RecordDate: nowtime,
+			Remark:     remark,
+			StockCount: hdf_count,
+		}
+
+		service.CreatePatientInCount(tx, patientInCount)
+
+	}
+
+	if hdhp_count > 0 {
+
+		patientInCount := models.SfPatientInCount{
+			PatientId:  patient_id,
+			UserOrgId:  orgId,
+			IsType:     3,
+			Count:      hdhp_count,
+			Status:     1,
+			Creater:    creater,
+			Ctime:      time.Now().Unix(),
+			Mtime:      time.Now().Unix(),
+			IsCheck:    2,
+			RecordDate: nowtime,
+			Remark:     remark,
+			StockCount: hdhp_count,
+		}
+
+		service.CreatePatientInCount(tx, patientInCount)
+	}
+
+	if hp_count > 0 {
+
+		patientInCount := models.SfPatientInCount{
+			PatientId:  patient_id,
+			UserOrgId:  orgId,
+			IsType:     4,
+			Count:      hp_count,
+			Status:     1,
+			Creater:    creater,
+			Ctime:      time.Now().Unix(),
+			Mtime:      time.Now().Unix(),
+			IsCheck:    2,
+			RecordDate: nowtime,
+			Remark:     remark,
+			StockCount: hp_count,
+		}
+		service.CreatePatientInCount(tx, patientInCount)
+	}
+
+	if other_count > 0 {
+
+		patientInCount := models.SfPatientInCount{
+			PatientId:  patient_id,
+			UserOrgId:  orgId,
+			IsType:     5,
+			Count:      other_count,
+			Status:     1,
+			Creater:    creater,
+			Ctime:      time.Now().Unix(),
+			Mtime:      time.Now().Unix(),
+			IsCheck:    2,
+			RecordDate: nowtime,
+			Remark:     remark,
+			StockCount: other_count,
+		}
+
+		service.CreatePatientInCount(tx, patientInCount)
+	}
+
+	tx.Commit()
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "保存成功",
+	})
+
+}
+
+func (this *PatientApiController) GetPatientCountList() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	appId := this.GetAdminUserInfo().CurrentAppId
+	patient_id, _ := this.GetInt64("patient_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	list, total, _ := service.GetPatientCountList(orgId, patient_id, page, limit, startTime, endTime)
+	patient, _ := service.GetPatientMapListOne(orgId)
+
+	userList, _ := service.GetAllAdminUserList(orgId, appId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":     list,
+		"total":    total,
+		"patient":  patient,
+		"userList": userList,
+	})
+}
+
+func (this *PatientApiController) CheckPatientCount() {
+
+	id, _ := this.GetInt64("id")
+
+	db := service.XTWriteDB()
+	// 开始外部循环的事务
+	tx := db.Begin()
+	// 在函数结束时处理事务回滚
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+		}
+	}()
+
+	creater := this.GetAdminUserInfo().AdminUser.Id
+
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+
+	warehouseInfo, _ := service.GetPatientCountById(id, tx)
+
+	if warehouseInfo.ID > 0 {
+		service.ModiftyPatientCount(warehouseInfo.Count, warehouseInfo.IsType, warehouseInfo.PatientId, tx)
+		patient, _ := service.GetSfPatientById(tx, warehouseInfo.PatientId)
+
+		var over_count int64
+		if warehouseInfo.IsType == 1 {
+			over_count = patient.HdCount
+		}
+		if warehouseInfo.IsType == 2 {
+			over_count = patient.HdfCount
+		}
+
+		if warehouseInfo.IsType == 3 {
+			over_count = patient.HdhpCount
+		}
+		if warehouseInfo.IsType == 4 {
+			over_count = patient.HpCount
+		}
+		if warehouseInfo.IsType == 5 {
+			over_count = patient.OtherCount
+		}
+		patientCountFlow := models.SfPatientCountFlow{
+			UserOrgId:       warehouseInfo.UserOrgId,
+			Count:           warehouseInfo.Count,
+			ModeId:          warehouseInfo.IsType,
+			IsType:          1,
+			PatientId:       warehouseInfo.PatientId,
+			Status:          1,
+			Ctime:           time.Now().Unix(),
+			Mtime:           time.Now().Unix(),
+			OverCount:       over_count,
+			RecordDate:      recordDate.Unix(),
+			Creater:         creater,
+			WarehouseInfoId: warehouseInfo.ID,
+		}
+		service.CreatePatientCountFlow(patientCountFlow, tx)
+	}
+
+	checkpatientcount, _ := service.CheckPatientCount(id, tx)
+
+	tx.Commit()
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"checkpatientcount": checkpatientcount,
+	})
+}
+
+func (this *PatientApiController) ReturnCheckPatientCount() {
+
+	id, _ := this.GetInt64("id")
+
+	db := service.XTWriteDB()
+	// 开始外部循环的事务
+	tx := db.Begin()
+	// 在函数结束时处理事务回滚
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+		}
+	}()
+
+	patientCountObj, _ := service.GetPatientCountById(id, tx)
+
+	service.ReducePatientCount(patientCountObj.Count, patientCountObj.IsType, patientCountObj.PatientId, tx)
+
+	patientCount, _ := service.ReturnCheckPatientCount(id, tx)
+
+	service.UpdatePatientCountFlow(id, tx)
+
+	tx.Commit()
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patientCount": patientCount,
+	})
+
+}
+
+func (this *PatientApiController) DeletePatientCount() {
+
+	id, _ := this.GetInt64("id")
+
+	service.DeletePatientCount(id)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "删除成功!",
+	})
+
+}
+
+func (this *PatientApiController) SavePatientOutCount() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	count, _ := this.GetInt64("count")
+
+	remark := this.GetString("remark")
+
+	mode_id, _ := this.GetInt64("mode_id")
+
+	creater := this.GetAdminUserInfo().AdminUser.Id
+
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	sfPatientOutCount := models.SfPatientOutCount{
+		UserOrgId:  orgId,
+		PatientId:  patient_id,
+		ModeId:     mode_id,
+		Count:      count,
+		Remark:     remark,
+		Creater:    creater,
+		Status:     1,
+		Ctime:      time.Now().Unix(),
+		Mtime:      time.Now().Unix(),
+		IsCheck:    2,
+		RecordDate: recordDate.Unix(),
+	}
+
+	service.CreateSfPatientOutCount(sfPatientOutCount)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "保存成功!",
+	})
+
+}
+
+func (this *PatientApiController) GetPatientOutCountList() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	limit, _ := this.GetInt64("limit")
+
+	page, _ := this.GetInt64("page")
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	outcount, total, _ := service.GetPatientOutCountList(patient_id, orgId, limit, page, startTime, endTime)
+
+	patient, _ := service.GetPatientMapListOne(orgId)
+
+	appId := this.GetAdminUserInfo().CurrentAppId
+	userList, _ := service.GetAllAdminUserList(orgId, appId)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":     outcount,
+		"total":    total,
+		"patient":  patient,
+		"userList": userList,
+	})
+
+}
+
+func (this *PatientApiController) DeletePatientOutCount() {
+
+	id, _ := this.GetInt64("id")
+
+	service.DeletePatientOutCount(id)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+
+}
+
+func (this *PatientApiController) CheckPatientOutCount() {
+
+	id, _ := this.GetInt64("id")
+	db := service.XTWriteDB()
+	// 开始外部循环的事务
+	tx := db.Begin()
+	// 在函数结束时处理事务回滚
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+		}
+	}()
+	outCountList, _ := service.GetPatientOutCountById(id, tx)
+
+	creater := this.GetAdminUserInfo().AdminUser.Id
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+
+	if outCountList.ID > 0 {
+
+		//扣减库存
+		service.ReducePatientCount(outCountList.Count, outCountList.ModeId, outCountList.PatientId, tx)
+
+		patient, _ := service.GetSfPatientById(tx, outCountList.PatientId)
+
+		var over_count int64
+		if outCountList.ModeId == 1 {
+			over_count = patient.HdCount
+		}
+		if outCountList.ModeId == 2 {
+			over_count = patient.HdfCount
+		}
+
+		if outCountList.ModeId == 3 {
+			over_count = patient.HdhpCount
+		}
+		if outCountList.ModeId == 4 {
+			over_count = patient.HpCount
+		}
+		if outCountList.ModeId == 5 {
+			over_count = patient.OtherCount
+		}
+
+		patientCountFlow := models.SfPatientCountFlow{
+			PatientId:      outCountList.PatientId,
+			ModeId:         outCountList.ModeId,
+			Count:          outCountList.Count,
+			Status:         1,
+			Ctime:          time.Now().Unix(),
+			Mtime:          time.Now().Unix(),
+			RecordDate:     recordDate.Unix(),
+			UserOrgId:      orgId,
+			Creater:        creater,
+			IsType:         2,
+			OverCount:      over_count,
+			WarehouseOutId: outCountList.ID,
+		}
+
+		service.CreatePatientCountFlow(patientCountFlow, tx)
+
+	}
+	//审核
+	service.CheckPatientOutCount(id, tx)
+
+	tx.Commit()
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+
+}
+
+func (this *PatientApiController) ReturnPatientOutList() {
+
+	id, _ := this.GetInt64("id")
+	db := service.XTWriteDB()
+	// 开始外部循环的事务
+	tx := db.Begin()
+	// 在函数结束时处理事务回滚
+	defer func() {
+		if r := recover(); r != nil {
+			tx.Rollback()
+		}
+	}()
+	outCountList, _ := service.GetPatientOutCountById(id, tx)
+
+	if outCountList.ID > 0 {
+		//回退库存
+		service.ModiftyPatientCount(outCountList.Count, outCountList.ModeId, outCountList.PatientId, tx)
+
+		service.DeletePatientCountFlow(id, tx)
+	}
+	//反审核
+	service.ReturnPatientOutCount(id, tx)
+
+	tx.Commit()
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "ok",
+	})
+}
+
+func (this *PatientApiController) GetPatientCountMapList() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	limit, _ := this.GetInt64("limit")
+
+	page, _ := this.GetInt64("page")
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	list, total, _ := service.GetPatientCountMapList(patient_id, limit, page, orgId)
+
+	patient, _ := service.GetPatientMapListOne(orgId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":    list,
+		"total":   total,
+		"patient": patient,
+	})
+}
+
+func (this *PatientApiController) GetPatientCountFlow() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+	is_type, _ := this.GetInt64("is_type")
+	mode_id, _ := this.GetInt64("mode_id")
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	list, total, _ := service.GetPatientCountFlow(patient_id, orgId, is_type, mode_id, startTime, endTime)
+
+	patient, _ := service.GetSfPatientByIdOne(patient_id)
+
+	appId := this.GetAdminUserInfo().CurrentAppId
+	userList, _ := service.GetAllAdminUserList(orgId, appId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":     list,
+		"total":    total,
+		"patient":  patient,
+		"userList": userList,
+	})
+}
+
+func (this *PatientApiController) GetDialysisOrderSetting() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	order, _ := service.GetDialysisOrderSetting(orgId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"order": order,
+	})
+}
+
+func (this *PatientApiController) SavePatientOrderSetting() {
+
+	is_open, _ := this.GetInt64("is_open")
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	orderSetting := models.XtDialysisOrderSetting{
+		IsOpen:    is_open,
+		UserOrgId: orgId,
+		Ctime:     time.Now().Unix(),
+		Mtime:     time.Now().Unix(),
+		Status:    1,
+	}
+
+	service.CreateDialysisOrder(orderSetting)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"order": orderSetting,
+	})
+}
+
+func (this *PatientApiController) GetPatientCountFlowList() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	start_time := this.GetString("start_time")
+
+	end_time := this.GetString("end_time")
+
+	limit, _ := this.GetInt64("limit")
+
+	page, _ := this.GetInt64("page")
+
+	is_type, _ := this.GetInt64("is_type")
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	list, total, _ := service.GetPatientCountFlowList(patient_id, startTime, endTime, limit, page, orgId, is_type)
+
+	flowList, _ := service.GetPatientCountListFlowOne(patient_id, startTime, endTime, is_type, orgId)
+
+	patient, _ := service.GetPatientMapListOne(orgId)
+
+	appId := this.GetAdminUserInfo().CurrentAppId
+	userList, _ := service.GetAllAdminUserList(orgId, appId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":     list,
+		"total":    total,
+		"patient":  patient,
+		"userList": userList,
+		"flowList": flowList,
+	})
+}
+
+func (this *PatientApiController) GetPatientCountFlowById() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+
+	start_time := this.GetString("start_time")
+
+	end_time := this.GetString("end_time")
+
+	is_type, _ := this.GetInt64("is_type")
+
+	mode_id, _ := this.GetInt64("mode_id")
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	appId := this.GetAdminUserInfo().CurrentAppId
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	flowList, _ := service.GetPatientCountFlowByIdList(patient_id, orgId, mode_id, is_type, startTime, endTime)
+
+	patient, _ := service.GetPatientMapListOne(orgId)
+
+	userList, _ := service.GetAllAdminUserList(orgId, appId)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":     flowList,
+		"patient":  patient,
+		"userList": userList,
+	})
+}

controllers/pharmacy_controller.go

 
 	adviceList, _ := service.GetDrugTocalCountByDrugId(drug_id, startTime, orgId)
 
+	drug, _ := service.GetNewBaseDrugById(drug_id)
+
 	this.ServeSuccessJSON(map[string]interface{}{
 		"adviceList": adviceList,
+		"drug":       drug,
 	})
 }

controllers/sign_api_controller.go

 
 	//
 
-	adviceInfo, _ := service.GetHisDoctorAdviceByUserOrgId(10752)
-	adminInfo := this.GetAdminUserInfo()
-	db := service.XTWriteDB()
-	tx := db.Begin()
-	if len(adviceInfo) > 0 {
-		for _, item := range adviceInfo {
-
-			drug, _ := service.FindBaseDrugLibRecordSeven(adminInfo.CurrentOrgId, item.DrugId)
-			var local_count int64
-			if item.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
-
-				prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
-				prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
-
-				local_count += prescribingNumberSevenTy * drug.MinNumber
-			}
-
-			if item.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
-
-				prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
-				prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
-				local_count += prescribingNumberSevenTy
-			}
-
-			if item.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
-
-				prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
-				prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
-				local_count += prescribingNumberSevenTy
-			}
-
-			item.PrescribingNumberUnit = drug.MinUnit
-
-			service.BloodNewHisDrugsDelivery(item.UserOrgId, 5685, item, tx)
+	//adviceInfo, _ := service.GetHisDoctorAdviceByUserOrgId(10752)
+	//adminInfo := this.GetAdminUserInfo()
+	//db := service.XTWriteDB()
+	//tx := db.Begin()
+	//if len(adviceInfo) > 0 {
+	//	for _, item := range adviceInfo {
+	//
+	//		drug, _ := service.FindBaseDrugLibRecordSeven(adminInfo.CurrentOrgId, item.DrugId)
+	//		var local_count int64
+	//		if item.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
+	//
+	//			prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
+	//			prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
+	//
+	//			local_count += prescribingNumberSevenTy * drug.MinNumber
+	//		}
+	//
+	//		if item.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
+	//
+	//			prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
+	//			prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
+	//			local_count += prescribingNumberSevenTy
+	//		}
+	//
+	//		if item.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
+	//
+	//			prescribingNumberTenty := strconv.FormatFloat(item.PrescribingNumber, 'f', -1, 64)
+	//			prescribingNumberSevenTy, _ := strconv.ParseInt(prescribingNumberTenty, 10, 64)
+	//			local_count += prescribingNumberSevenTy
+	//		}
+	//
+	//		item.PrescribingNumberUnit = drug.MinUnit
+	//
+	//		service.BloodNewHisDrugsDelivery(item.UserOrgId, 5685, item, tx)
+	//
+	//		storeConfig, _ := service.GetNewAllStoreHouseConfig(item.UserOrgId, tx)
+	//
+	//		stockInfo, _ := service.GetNewDrugAllStockInfo(storeConfig.DrugStorehouseOut, item.UserOrgId, item.DrugId, tx)
+	//		var sum_count int64
+	//		for _, its := range stockInfo {
+	//			baseDrug, _ := service.GetNewBaseDrugMedical(its.DrugId, tx)
+	//			if its.MaxUnit == baseDrug.MaxUnit {
+	//				its.StockMaxNumber = its.StockMaxNumber * baseDrug.MinNumber
+	//			}
+	//			sum_count += its.StockMaxNumber + its.StockMinNumber
+	//		}
+	//		//更新基础库存
+	//		service.UpdateNewBaseDrugSumTwo(item.DrugId, sum_count, item.UserOrgId, tx)
+	//		//剩余库存
+	//		service.UpdateNewDrugStockCount(item.DrugId, item.UserOrgId, storeConfig.DrugStorehouseOut, sum_count, tx)
+	//
+	//		over, _ := service.FindNewOverCount(item.DrugId, item.UserOrgId, storeConfig.DrugStorehouseOut, tx)
+	//		service.UpdateNewActOut(over.ID, over.SumInCount, over.FlushCount, over.SumCancelCount, tx)
+	//	}
+	//}
 
-			storeConfig, _ := service.GetNewAllStoreHouseConfig(item.UserOrgId, tx)
+	//tx.Commit()
+	schedule, _ := service.CheckSchedule()
 
-			stockInfo, _ := service.GetNewDrugAllStockInfo(storeConfig.DrugStorehouseOut, item.UserOrgId, item.DrugId, tx)
-			var sum_count int64
-			for _, its := range stockInfo {
-				baseDrug, _ := service.GetNewBaseDrugMedical(its.DrugId, tx)
-				if its.MaxUnit == baseDrug.MaxUnit {
-					its.StockMaxNumber = its.StockMaxNumber * baseDrug.MinNumber
-				}
-				sum_count += its.StockMaxNumber + its.StockMinNumber
-			}
-			//更新基础库存
-			service.UpdateNewBaseDrugSumTwo(item.DrugId, sum_count, item.UserOrgId, tx)
-			//剩余库存
-			service.UpdateNewDrugStockCount(item.DrugId, item.UserOrgId, storeConfig.DrugStorehouseOut, sum_count, tx)
+	if len(schedule) > 0 {
+		for _, item := range schedule {
+			fmt.Println("item.p------------------", item.PatientId)
 
-			over, _ := service.FindNewOverCount(item.DrugId, item.UserOrgId, storeConfig.DrugStorehouseOut, tx)
-			service.UpdateNewActOut(over.ID, over.SumInCount, over.FlushCount, over.SumCancelCount, tx)
+			service.UpdateScheduleByIdOneList(item.ID, item.ScheduleDate, item.ScheduleType, item.ScheduleWeek, item.Status, item.PatientId, item.PartitionId, item.BedId, item.DialysisMachineName, item.UserOrgId, item.ModeId)
 		}
 	}
 
-	tx.Commit()
 	this.ServeSuccessJSON(map[string]interface{}{
 		"msg": "ok",
 	})
 		"msg": "ok",
 	})
 }
+
+func (this *SignApiController) CheckSchedule() {
+
+	service.CheckSchedule()
+}

controllers/statistics_api_controller.go

 package controllers
 
 import (
+	"fmt"
+	"sort"
+	"strconv"
+	"strings"
+	"time"
+
 	"XT_New/enums"
 	"XT_New/models"
 	"XT_New/service"
 	"XT_New/service/statistics_service"
 	"XT_New/utils"
-	"fmt"
 	"github.com/astaxie/beego"
-	"sort"
-	"strconv"
-	"strings"
-	"time"
 )
 
 type StatisticsApiController struct {
 	mode, _ := c.GetInt64("mode")
 	origin, _ := c.GetInt64("origin")
 	time_way, _ := c.GetInt64("time_way")
-	//timeLayout := "2006-01-02"
-	//loc, _ := time.LoadLocation("Local")
-	//var startTime int64
-	//if len(start_date) > 0 {
-	//	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
-	//	fmt.Println("err-----------", err)
-	//	if err != nil {
-	//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-	//		return
-	//	}
-	//	//startTime = theTime.Unix()
-	//}
-	//var endTime int64
-	//if len(end_date) > 0 {
-	//	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
-	//	if err != nil {
-	//		utils.ErrorLog(err.Error())
-	//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-	//		return
-	//	}
-	//	//endTime = theTime.Unix()
-	//}
+
 	dates, err := splitDateRange(start_date, end_date)
 	if err != nil {
 		fmt.Println("Error:", err)
 	var startTime int64
 	if len(start_date) > 0 {
 		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
-		fmt.Println("err-----------", err)
+
 		if err != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 			return

models/dialysis.go

 	SystolicBloodPressure  float64 `gorm:"column:systolic_blood_pressure" json:"systolic_blood_pressure"`
 	DiastolicBloodPressure float64 `gorm:"column:diastolic_blood_pressure" json:"diastolic_blood_pressure"`
 	DryWeight              float64 `gorm:"column:dry_weight" json:"dry_weight"`
+	Height                 string  `gorm:"column:height" json:"height" form:"height"`
 }
 
 func (PredialysisEvaluationList) TableName() string {

models/his_models.go

 	return "his_prescription"
 }
 
-type HisDoctorAdviceTeamInfo 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"`
-	PatientId             int64       `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	AdviceName            string      `gorm:"column:advice_name" json:"advice_name" form:"advice_name"`
-	AdviceDesc            string      `gorm:"column:advice_desc" json:"advice_desc" form:"advice_desc"`
-	SingleDose            float64     `gorm:"column:single_dose" json:"single_dose" form:"single_dose"`
-	SingleDoseUnit        string      `gorm:"column:single_dose_unit" json:"single_dose_unit" form:"single_dose_unit"`
-	PrescribingNumber     float64     `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
-	PrescribingNumberUnit string      `gorm:"column:prescribing_number_unit" json:"prescribing_number_unit" form:"prescribing_number_unit"`
-	DeliveryWay           string      `gorm:"column:delivery_way" json:"delivery_way" form:"delivery_way"`
-	ExecutionFrequency    string      `gorm:"column:execution_frequency" json:"execution_frequency" form:"execution_frequency"`
-	AdviceDoctor          int64       `gorm:"column:advice_doctor" json:"advice_doctor" form:"advice_doctor"`
-	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"`
-	Remark                string      `gorm:"column:remark" json:"remark" form:"remark"`
-	DrugSpec              float64     `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
-	DrugSpecUnit          string      `gorm:"column:drug_spec_unit" json:"drug_spec_unit" form:"drug_spec_unit"`
-	Groupno               int64       `gorm:"column:groupno" json:"groupno" form:"groupno"`
-	RemindType            int64       `gorm:"column:remind_type" json:"remind_type" form:"remind_type"`
-	FrequencyType         int64       `gorm:"column:frequency_type" json:"frequency_type" form:"frequency_type"`
-	DayCount              int64       `gorm:"column:day_count" json:"day_count" form:"day_count"`
-	WeekDay               string      `gorm:"column:week_day" json:"week_day" form:"week_day"`
-	TemplateId            string      `gorm:"column:template_id" json:"template_id" form:"template_id"`
-	Modifier              int64       `gorm:"column:modifier" json:"modifier" form:"modifier"`
-	DrugId                int64       `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
-	Price                 float64     `gorm:"column:price" json:"price" form:"price"`
-	BaseDrugLib           BaseDrugLib `gorm:"ForeignKey:ID;AssociationForeignKey:DrugId" json:"drug"`
-}
-
-func (HisDoctorAdviceTeamInfo) TableName() string {
-	return "his_doctor_advice_team_info"
-}
-
-type NewHisOrderInfo struct {
-	ID               int64   `gorm:"column:id" json:"id" form:"id"`
-	OrderNumber      string  `gorm:"column:order_number" json:"order_number" form:"order_number"`
-	UploadDate       int64   `gorm:"column:upload_date" json:"upload_date" form:"upload_date"`
-	AdviceId         int64   `gorm:"column:advice_id" json:"advice_id" form:"advice_id"`
-	DetItemFeeSumamt float64 `gorm:"column:det_item_fee_sumamt" json:"det_item_fee_sumamt" form:"det_item_fee_sumamt"`
-	Cnt              float64 `gorm:"column:cnt" json:"cnt" form:"cnt"`
-	Pric             float64 `gorm:"column:pric" json:"pric" form:"pric"`
-	PatientId        int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	PricUplmtAmt     float64 `gorm:"column:pric_uplmt_amt" json:"pric_uplmt_amt" form:"pric_uplmt_amt"`
-	SelfpayProp      float64 `gorm:"column:selfpay_prop" json:"selfpay_prop" form:"selfpay_prop"`
-	FulamtOwnpayAmt  float64 `gorm:"column:fulamt_ownpay_amt" json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
-	OverlmtAmt       float64 `gorm:"column:overlmt_amt" json:"overlmt_amt" form:"overlmt_amt"`
-	PreselfpayAmt    float64 `gorm:"column:preselfpay_amt" json:"preselfpay_amt" form:"preselfpay_amt"`
-	BasMednFlag      string  `gorm:"column:bas_medn_flag" json:"bas_medn_flag" form:"bas_medn_flag"`
-	MedChrgitmType   string  `gorm:"column:med_chrgitm_type" json:"med_chrgitm_type" form:"med_chrgitm_type"`
-	HiNegoDrugFlag   string  `gorm:"column:hi_nego_drug_flag" json:"hi_nego_drug_flag" form:"hi_nego_drug_flag"`
-	Status           int64   `gorm:"column:status" json:"status" form:"status"`
-	Memo             string  `gorm:"column:memo" json:"memo" form:"memo"`
-	FeedetlSn        string  `gorm:"column:feedetl_sn" json:"feedetl_sn" form:"feedetl_sn"`
-	Mtime            int64   `gorm:"column:mtime" json:"mtime" form:"mtime"`
-	InscpScpAmt      float64 `gorm:"column:inscp_scp_amt" json:"inscp_scp_amt" form:"inscp_scp_amt"`
-	DrtReimFlag      string  `gorm:"column:drt_reim_flag" json:"drt_reim_flag" form:"drt_reim_flag"`
-	Ctime            int64   `gorm:"column:ctime" json:"ctime" form:"ctime"`
-	ListSpItemFlag   string  `gorm:"column:list_sp_item_flag" json:"list_sp_item_flag" form:"list_sp_item_flag"`
-	ChldMedcFlag     string  `gorm:"column:chld_medc_flag" json:"chld_medc_flag" form:"chld_medc_flag"`
-	LmtUsedFlag      string  `gorm:"column:lmt_used_flag" json:"lmt_used_flag" form:"lmt_used_flag"`
-	ChrgitmLv        string  `gorm:"column:chrgitm_lv" json:"chrgitm_lv" form:"chrgitm_lv"`
-	UserOrgId        int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
-	HisPatientId     int64   `gorm:"column:his_patient_id" json:"his_patient_id" form:"his_patient_id"`
-	OrderId          int64   `gorm:"column:order_id" json:"order_id" form:"order_id"`
-	ProjectId        int64   `gorm:"column:project_id" json:"project_id" form:"project_id"`
-	Type             int64   `gorm:"column:type" json:"type" form:"type"`
-	ItemId           int64   `gorm:"column:item_id" json:"item_id" form:"item_id"`
-	SettleType       int64   `gorm:"column:settle_type" json:"settle_type" form:"settle_type"`
+type NBHisDoctorAdviceInfo 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"`
+	PatientId             int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	AdviceDate            int64   `gorm:"column:advice_date" json:"advice_date" form:"advice_date"`
+	AdviceName            string  `gorm:"column:advice_name" json:"advice_name" form:"advice_name"`
+	PrescribingNumber     float64 `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
+	PrescribingNumberUnit string  `gorm:"column:prescribing_number_unit" json:"prescribing_number_unit" form:"prescribing_number_unit"`
+	AdviceDoctor          int64   `gorm:"column:advice_doctor" json:"advice_doctor" form:"advice_doctor"`
+	Status                int64   `gorm:"column:status" json:"status" form:"status"`
+	DrugId                int64   `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
+	DrugCode              string  `gorm:"column:drug_code" json:"drug_code" form:"drug_code"`
 }
 
-func (NewHisOrderInfo) TableName() string {
-	return "his_order_info"
+func (NBHisDoctorAdviceInfo) TableName() string {
+	return "his_doctor_advice_info"
+}
+
+type NBXtBaseDrug struct {
+	ID       int64  `gorm:"column:id" json:"id" form:"id"`
+	DrugName string `gorm:"column:drug_name" json:"drug_name" form:"drug_name"`
+	Status   int64  `gorm:"column:status" json:"status" form:"status"`
+	OrgId    int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ScanCode string `gorm:"column:scan_code" json:"scan_code" form:"scan_code"`
+}
+
+func (NBXtBaseDrug) TableName() string {
+	return "xt_base_drug"
 }

models/patient_models.go

 	ScheduleRemark     string `gorm:"column:schedule_remark" json:"schedule_remark" form:"schedule_remark"`
 	FirstLetter        string `gorm:"column:first_letter" json:"first_letter" form:"first_letter"`
 	IsInfectious       int64  `gorm:"column:is_infectious" json:"is_infectious" form:"is_infectious"`
+	Height             int64  `gorm:"column:height" json:"height" form:"height"`
 }
 
 func (MSchedualPatientList) TableName() string {
 	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
 	Count        int64
 }
+
+type SfPatients 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"`
+	Name        string `gorm:"column:name" json:"name" form:"name"`
+	Status      int64  `gorm:"column:status" json:"status" form:"status"`
+	Lapseto     int64  `gorm:"column:lapseto" json:"lapseto" form:"lapseto"`
+	FirstLetter string `gorm:"column:first_letter" json:"first_letter" form:"first_letter"`
+	HdCount     int64  `gorm:"column:hd_count" json:"hd_count" form:"hd_count"`
+	HdfCount    int64  `gorm:"column:hdf_count" json:"hdf_count" form:"hdf_count"`
+	HdhpCount   int64  `gorm:"column:hdhp_count" json:"hdhp_count" form:"hdhp_count"`
+	HpCount     int64  `gorm:"column:hp_count" json:"hp_count" form:"hp_count"`
+	OtherCount  int64  `gorm:"column:other_count" json:"other_count" form:"other_count"`
+}
+
+func (SfPatients) TableName() string {
+	return "xt_patients"
+}
+
+type SfPatientInCount struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	UserOrgId  int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	IsType     int64  `gorm:"column:is_type" json:"is_type" form:"is_type"`
+	Status     int64  `gorm:"column:status" json:"status" form:"status"`
+	Creater    int64  `gorm:"column:creater" json:"creater" form:"creater"`
+	Ctime      int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime      int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	IsCheck    int64  `gorm:"column:is_check" json:"is_check" form:"is_check"`
+	RecordDate int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	Remark     string `gorm:"column:remark" json:"remark" form:"remark"`
+	Count      int64  `gorm:"column:count" json:"count" form:"count"`
+	StockCount int64  `gorm:"column:stock_count" json:"stock_count" form:"stock_count"`
+}
+
+func (SfPatientInCount) TableName() string {
+	return "xt_patient_in_count"
+}
+
+type SfPatientOutCount struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ModeId     int64  `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Count      int64  `gorm:"column:count" json:"count" form:"count"`
+	Remark     string `gorm:"column:remark" json:"remark" form:"remark"`
+	Creater    int64  `gorm:"column:creater" json:"creater" form:"creater"`
+	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"`
+	IsCheck    int64  `gorm:"column:is_check" json:"is_check" form:"is_check"`
+	RecordDate int64  `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	UserOrgId  int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+}
+
+func (SfPatientOutCount) TableName() string {
+	return "xt_patient_out_count"
+}
+
+type SfPatientCountFlow 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"`
+	Count           int64 `gorm:"column:count" json:"count" form:"count"`
+	ModeId          int64 `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	IsType          int64 `gorm:"column:is_type" json:"is_type" form:"is_type"`
+	PatientId       int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_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"`
+	OverCount       int64 `gorm:"column:over_count" json:"over_count" form:"over_count"`
+	RecordDate      int64 `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	Creater         int64 `gorm:"column:creater" json:"creater" form:"creater"`
+	WarehouseInfoId int64 `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
+	WarehouseOutId  int64 `gorm:"column:warehouse_out_id" json:"warehouse_out_id" form:"warehouse_out_id"`
+}
+
+func (SfPatientCountFlow) TableName() string {
+	return "xt_patient_count_flow"
+}
+
+type XtDialysisOrderSetting struct {
+	ID        int64 `gorm:"column:id" json:"id" form:"id"`
+	IsOpen    int64 `gorm:"column:is_open" json:"is_open" form:"is_open"`
+	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"`
+}
+
+func (XtDialysisOrderSetting) TableName() string {
+	return "xt_dialysis_order_setting"
+}

models/stock_models.go

 	StorehouseId     int64   `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
 	OrgId            int64   `gorm:"column:org_id" json:"org_id"`
 	Price            float64 `gorm:"column:price" json:"price" form:"price"`
+	PackingPrice     float64 `gorm:"column:packing_price" json:"packing_price" form:"packing_price"`
 }
 
 func (StWarehousingInfoOne) TableName() string {

service/common_service.go

 
 func GetPatientTotalCount(orgID int64, lapsetotype int64, sourcetype int64) (total int64) {
 	db := readDb.Table("xt_patients as x")
-	//if lapsetotype > 0 {
-	// db = db.Where("x.lapseto = ?", lapsetotype)
-	//}
-	//if sourcetype > 0 {
-	// db = db.Where("x.source = ?", sourcetype)
-	//}
-	db.Where("x.user_org_id=? and x.status=1", orgID).Count(&total)
+	db.Where("x.user_org_id=? and x.status=1 and x.patient_type=1", orgID).Count(&total)
 	return
 }
 
 
 func GetManPatientTotal(orgid int64, lapsetotype int64, sourcetype int64) (patients []*models.XtPatients, total int64, err error) {
 
-	db := XTReadDB().Table("xt_patients as x").Where("x.status  = 1")
+	db := XTReadDB().Table("xt_patients as x").Where("x.status  = 1 and x.patient_type =1")
 	if lapsetotype > 0 {
 		db = db.Where("x.lapseto = ?", lapsetotype)
 	}
 }
 
 func GetWoManPatientTotal(orgid int64, lapsetotype int64, sourcetype int64) (patients []*models.XtPatients, total int64, err error) {
-	db := XTReadDB().Table("xt_patients as x").Where("x.status  = 1")
+	db := XTReadDB().Table("xt_patients as x").Where("x.status  = 1 and x.patient_type =1")
 	if lapsetotype > 0 {
 		db = db.Where("x.lapseto = ?", lapsetotype)
 	}
 func GetPatientInfectiousCount(orgid int64, startime int64, endtime int64, lapsetotype int64, sourcetype int64) (counts []*models.PatientContagionsCountStruct, err error) {
 
 	if lapsetotype == 0 {
-		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and x.status = 1 and x.updated_time>=? and x.updated_time<=?", orgid, startime, endtime).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
+		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and s.patient_type =1 and x.status = 1 and x.updated_time>=? and x.updated_time<=?", orgid, startime, endtime).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
 	}
 	if sourcetype == 0 {
-		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and x.status = 1 and x.updated_time>=? and x.updated_time<=?", orgid, startime, endtime).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
+		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and s.patient_type =1 and x.status = 1 and x.updated_time>=? and x.updated_time<=?", orgid, startime, endtime).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
 	}
 
 	if lapsetotype > 0 {
-		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and x.status = 1 and x.updated_time>=? and x.updated_time<=? and s.lapseto = ?", orgid, startime, endtime, lapsetotype).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
+		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and s.patient_type =1 and x.status = 1 and x.updated_time>=? and x.updated_time<=? and s.lapseto = ?", orgid, startime, endtime, lapsetotype).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
 	}
 
 	if sourcetype > 0 {
-		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and x.status = 1 and x.updated_time>=? and x.updated_time<=? and s.source = ?", orgid, startime, endtime, sourcetype).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
+		err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_patients as s on s.id = x.patient_id").Where("s.user_org_id = ? and s.status = 1 and s.patient_type =1 and x.status = 1 and x.updated_time>=? and x.updated_time<=? and s.source = ?", orgid, startime, endtime, sourcetype).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
 	}
 
 	return counts, err
     WHEN ( substring( now( ), 1, 4 ) - substring( id_card_no, 7, 4 ) ) - ( substring( id_card_no, 11, 4 ) - date_format( now( ), '%m%d' ) > 0 )<=80 THEN '80'
     ELSE '150'
 	 END
-	 AS nnd FROM xt_patients as s  where s.user_org_id=? and s.status=1
+	 AS nnd FROM xt_patients as s  where s.user_org_id=? and s.status=1 and s.patient_type =1
 	 )a GROUP BY nnd`, orgid).Scan(&counts)
 
 	}

service/db.go

 
 var readDb *gorm.DB
 var readDb2 *gorm.DB
+var readDb3 *gorm.DB
 var writeDb *gorm.DB
 var readUserDb *gorm.DB
 var writeUserDb *gorm.DB
 var readMiddleDb *gorm.DB
 var writeMiddleDb *gorm.DB
 
+var newReadMiddleDb *gorm.DB
+
 var readPatientDb *gorm.DB
 var writePatientDb *gorm.DB
 
 	readPass2 := beego.AppConfig.String("readmysqlpass2")
 	readName2 := beego.AppConfig.String("readmysqlname2")
 
+	readHost3 := beego.AppConfig.String("readmysqlhost3")
+	readPort3 := beego.AppConfig.String("readmysqlport3")
+	readUser3 := beego.AppConfig.String("readmysqluser3")
+	readPass3 := beego.AppConfig.String("readmysqlpass3")
+	readName3 := beego.AppConfig.String("readmysqlname3")
+
 	writeHost := beego.AppConfig.String("writemysqlhost")
 	writePort := beego.AppConfig.String("writemysqlport")
 	writeUser := beego.AppConfig.String("writemysqluser")
 
 	rdsn2 := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUser2, readPass2, readHost2, readPort2, readName2)
 
+	rdsn3 := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUser3, readPass3, readHost3, readPort3, readName3)
+
 	wdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeUser, writePass, writeHost, writePort, writeName)
 
 	rudsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUserUser, readUserPass, readUserHost, readUserPort, readUserName)
 
 	readDb2, err = gorm.Open("mysql", rdsn2)
 
+	readDb3, err = gorm.Open("mysql", rdsn3)
+
 	readDb, err = gorm.Open("mysql", rdsn)
 	if err != nil {
 		//beego.Error(err)
 	readDb2.DB().SetMaxOpenConns(100)
 	readDb2.LogMode(true)
 
+	readDb3.DB().SetMaxIdleConns(10)
+	readDb3.DB().SetMaxOpenConns(100)
+	readDb3.LogMode(true)
+
 	writeDb, err = gorm.Open("mysql", wdsn)
 	if err != nil {
 		//beego.Error(err)

service/dialysis_service.go

 	return
 }
 
+func DeleteDoctorAdviceByGroupNoOne(m *models.DoctorAdvice) (err error) {
+	ut := writeDb.Begin()
+	err = ut.Model(&models.DoctorAdvice{}).Where("groupno = ? AND user_org_id =  ? and patient_id = ? and advice_date = ?", m.GroupNo, m.UserOrgId, m.PatientId, m.AdviceDate).Update(map[string]interface{}{"UpdatedTime": m.UpdatedTime, "Status": 0, "modifier": m.Modifier}).Error
+	if err != nil {
+		ut.Rollback()
+		return
+	}
+	ut.Commit()
+
+	return
+}
+
 func GetDialysisBoard(orgID int64, scheduleDate int64, offset, limit int64) ([]*models.DialysisBoardVM, error) {
 	var boards []*models.DialysisBoardVM
 	db := readDb.

service/gobal_config_service.go

 	return doctor, err
 }
 
+func GetHisPrint(ids []string, org_id int64) (advice []*models.HisDoctorAdviceInfo, err error) {
+
+	err = XTReadDB().Where("id in (?) and user_org_id = ?", ids, org_id).Order("execution_time asc").Find(&advice).Error
+	return advice, err
+}
+
 func GetExportLogByType(org_id int64, log_type int64) (log []*models.ExportLog, err error) {
 	err = readDb.Model(&models.ExportLog{}).Where("user_org_id = ? AND status = 1 AND log_type = ?", org_id, log_type).
 		Preload("ExportErrLog", "status = 1").Order("export_time desc").Find(&log).Error

service/mobile_dialysis_service.go

 	SchRemark          string `gorm:"column:sch_remark" json:"sch_remark" form:"sch_remark"`
 	ScheduleRemark     string `gorm:"column:schedule_remark" json:"schedule_remark" form:"schedule_remark"`
 	FirstLetter        string `gorm:"column:first_letter" json:"first_letter" form:"first_letter"`
+	Height             int64  `gorm:"column:height" json:"height" form:"height"`
 }
 
 func (MSchedualPatientVMList) TableName() string {
 
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate, 10) + ":receive_treatment_asses"
 	receive_treatment_asses_str, _ := redis.Get(key).Result()
+
 	if len(receive_treatment_asses_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		err = readDb.Model(&models.ReceiveTreatmentAsses{}).Where("patient_id = ? and user_org_id = ? and status = 1 and record_date = ?", patientID, orgID, recordDate).First(&record).Error
 		if err != nil {
 		}
 		if patient_id > 0 {
 			if execution_state > 0 {
-				fmt.Println("execution_state---------------------", execution_state)
 				if cost_type > 0 {
 					db = db.Preload("SchedualPatient", "status = 1 AND user_org_id = ? and id = ?", orgID, patient_id).
 						Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).

service/new_warehouse_service.go

 
 	if lastWarehouse.MaxUnit != lastWarehouse.MinUnit && drup.MaxUnit != drup.MinUnit && lastWarehouse.MinUnit != "" {
 		if lastWarehouse.StockMinNumber >= drup.MinNumber {
-			fmt.Println("hahhahahahahhaah")
 			var stockMax int64
 			var stockMin int64
+
 			stockMax = lastWarehouse.StockMinNumber / drup.MinNumber
 			stockMin = lastWarehouse.StockMinNumber % drup.MinNumber
 
 	}
 
 	if lastWarehouse.MaxUnit == lastWarehouse.MinUnit && drup.MaxUnit != drup.MinUnit && lastWarehouse.MinUnit != "" {
-		fmt.Println("ooowowowowowowowowowo")
 		lastWarehouse.StockMaxNumber = lastWarehouse.StockMaxNumber + lastWarehouse.StockMinNumber
 		ChangeNewMaxNumberOne(lastWarehouse.ID, lastWarehouse.StockMaxNumber, tx)
 
 
 	}
 
-	fmt.Println("stock_number", stock_number)
-	fmt.Println("deliver_number=============", deliver_number)
+	//fmt.Println("stock_number", stock_number)
+	//fmt.Println("deliver_number=============", deliver_number)
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
 	if stock_number >= deliver_number {
 
 		maxNumber = deliver_number / drup.MinNumber
 		minNumber = deliver_number % drup.MinNumber
 
-		fmt.Println("max_Number=====================", maxNumber)
-		fmt.Println("minNumber=====================", minNumber)
+		//fmt.Println("max_Number=====================", maxNumber)
+		//fmt.Println("minNumber=====================", minNumber)
 
 		if warehouse.StockMaxNumber == 0 && drup.MaxUnit == drup.MinUnit {
 			minNumber = maxNumber
 
 		if drup.MinUnit == warehouse.MaxUnit && drup.MaxUnit != drup.MinUnit {
 
-			fmt.Println("金1")
+			//fmt.Println("金1")
 
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber*drup.MinNumber
 		}
 
 		if drup.MaxUnit == warehouse.MaxUnit && drup.MaxUnit != drup.MinUnit {
-			fmt.Println("jin2")
+			//fmt.Println("jin2")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
 		}
 
 		if drup.MaxUnit == warehouse.MaxUnit && drup.MaxUnit == drup.MinUnit {
-			fmt.Println("jin3")
+			//fmt.Println("jin3")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
 		}
 
 
 		warehouse.Mtime = time.Now().Unix()
 
-		fmt.Println("hahhahahah", warehouse.StockMinNumber)
-		fmt.Println("howowowoowow", minNumber)
+		//fmt.Println("hahhahahah", warehouse.StockMinNumber)
+		//fmt.Println("howowowoowow", minNumber)
 		if warehouse.StockMinNumber < minNumber {
 
 			if warehouse.MaxUnit != warehouse.MinUnit {
 			if warehouse.MaxUnit != warehouse.MinUnit {
 				warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
 			}
-			fmt.Println("minNumber------", minNumber)
-			fmt.Println("warehouse.StockMinNumber", warehouse.StockMinNumber)
-			fmt.Println(" warehouse.MaxUnit", warehouse.MaxUnit)
-			fmt.Println(" warehouse.MinUnit", warehouse.MinUnit)
+			//fmt.Println("minNumber------", minNumber)
+			//fmt.Println("warehouse.StockMinNumber", warehouse.StockMinNumber)
+			//fmt.Println(" warehouse.MaxUnit", warehouse.MaxUnit)
+			//fmt.Println(" warehouse.MinUnit", warehouse.MinUnit)
 
 			if warehouse.MaxUnit == warehouse.MinUnit {
 				//改动的地方

service/patient_service.go

 }
 
 func GetPatientCount(orgID int64) (total int64) {
-	readDb.Model(&models.Patients{}).Where("user_org_id=? and status=1 and lapseto = 1", orgID).Count(&total)
+	readDb.Model(&models.Patients{}).Where("user_org_id=? and status=1 and lapseto = 1 and patient_type = 1", orgID).Count(&total)
 	return
 }
 func GetLapsetoPatientCount(orgID int64, lapseto int64) (total int64) {
 }
 
 func FindPatientWithDeviceByNo(orgID int64, no string, time int64) (patient models.SchedualPatient2, err error) {
-	err = readDb.Preload("DialysisSchedule", func(db *gorm.DB) *gorm.DB {
-		return db.Preload("DeviceNumber", "org_id = ?", orgID).
-			Preload("DeviceZone", "org_id = ?", orgID).
-			Where("user_org_id = ? AND schedule_date = ? ", orgID, time)
-	}).Preload("InfectiousDiseases", "status = 1").Where("user_org_id=? and dialysis_no = ? and status = 1 ", orgID, no).First(&patient).Error
+
+	if orgID != 9882 {
+		err = readDb.Preload("DialysisSchedule", func(db *gorm.DB) *gorm.DB {
+			return db.Preload("DeviceNumber", "org_id = ?", orgID).
+				Preload("DeviceZone", "org_id = ?", orgID).
+				Where("user_org_id = ? AND schedule_date = ? ", orgID, time)
+		}).Preload("InfectiousDiseases", "status = 1").Where("user_org_id=? and dialysis_no = ? and status = 1 ", orgID, no).First(&patient).Error
+	}
+
+	if orgID == 9882 {
+		err = readDb.Preload("DialysisSchedule", func(db *gorm.DB) *gorm.DB {
+			return db.Preload("DeviceNumber", "org_id = ?", orgID).
+				Preload("DeviceZone", "org_id = ?", orgID).
+				Where("user_org_id = ? AND schedule_date = ? ", orgID, time)
+		}).Preload("InfectiousDiseases", "status = 1").Where("user_org_id=? and dialysis_no = ? and status = 1 and  lapseto =1", orgID, no).First(&patient).Error
+
+	}
+
 	return
+
 }
 
 func FindPatientWithDeviceByPatientId(orgID int64, id int64, time int64) (patient models.SchedualPatient2, err error) {
 
 	return err
 }
+
+func GetPatientMapList(user_org_id int64, keyword string) (patient []*models.SfPatients, err error) {
+
+	keyword = "%" + keyword + "%"
+
+	err = XTReadDB().Where("user_org_id = ? and status=1 and lapseto =1 and (name like ? or first_letter like ?)", user_org_id, keyword, keyword).Find(&patient).Error
+
+	return patient, err
+}
+
+func GetPatientMapListOne(user_org_id int64) (patient []*models.SfPatients, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and status=1 and lapseto =1", user_org_id).Find(&patient).Error
+
+	return patient, err
+}
+
+func GetAllAdminUserList(org_id int64, app_id int64) (admin []*models.SgjUserAdminRole, err error) {
+
+	err = UserReadDB().Where("org_id = ? and app_id = ? and status=1", org_id, app_id).Find(&admin).Error
+
+	return admin, err
+}
+
+func CreatePatientInCount(tx *gorm.DB, patientCount models.SfPatientInCount) error {
+
+	err := tx.Create(&patientCount).Error
+
+	if err != nil {
+		tx.Rollback()
+		return err
+	}
+	return err
+}
+
+func ModifyPatientCount(tx *gorm.DB, hd_count int64, hdf_count int64, hdhp_count int64, hp_count int64, other_count int64, patient_id int64) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+
+	err = tx.Model(&patients).Where("id = ?", patient_id).UpdateColumn("hd_count", gorm.Expr("hd_count + ?", hd_count)).Error
+
+	err = tx.Model(&patients).Where("id = ?", patient_id).UpdateColumn("hdf_count", gorm.Expr("hdf_count + ?", hdf_count)).Error
+
+	err = tx.Model(&patients).Where("id=?", patient_id).UpdateColumn("hdhp_count", gorm.Expr("hdhp_count + ?", hdhp_count)).Error
+
+	err = tx.Model(&patients).Where("id=?", patient_id).UpdateColumn("hp_count", gorm.Expr("hp_count + ?", hp_count)).Error
+
+	err = tx.Model(&patients).Where("id=?", patient_id).UpdateColumn("other_count", gorm.Expr("other_count + ?", other_count)).Error
+
+	return patients, err
+}
+
+func UpdatePatientInCount(tx *gorm.DB, hd_count int64, hdf_count int64, hdhp_count int64, hp_count int64, patient_id int64) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+
+	err = tx.Model(&patients).Where("id = ?", patient_id).UpdateColumn("hd_count", gorm.Expr("hd_count - ?", hd_count)).Error
+
+	err = tx.Model(&patients).Where("id = ?", patient_id).UpdateColumn("hdf_count", gorm.Expr("hdf_count - ?", hdf_count)).Error
+
+	err = tx.Model(&patients).Where("id=?", patient_id).UpdateColumn("hdhp_count", gorm.Expr("hdhp_count - ?", hdhp_count)).Error
+
+	err = tx.Model(&patients).Where("id=?", patient_id).UpdateColumn("hp_count", gorm.Expr("hp_count - ?", hp_count)).Error
+
+	return patients, err
+}
+
+func ModiftyPatientCount(count int64, is_type int64, patient_id int64, tx *gorm.DB) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+	if is_type == 1 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hd_count", gorm.Expr("hd_count + ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 2 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hdf_count", gorm.Expr("hdf_count + ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 3 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hdhp_count", gorm.Expr("hdhp_count + ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 4 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hp_count", gorm.Expr("hp_count + ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 5 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("other_count", gorm.Expr("other_count + ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	return patients, err
+}
+
+func ReducePatientCount(count int64, is_type int64, patient_id int64, tx *gorm.DB) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+	if is_type == 1 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hd_count", gorm.Expr("hd_count - ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 2 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hdf_count", gorm.Expr("hdf_count - ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 3 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hdhp_count", gorm.Expr("hdhp_count - ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 4 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("hp_count", gorm.Expr("hp_count - ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	if is_type == 5 {
+		err = tx.Model(&models.SfPatients{}).Where("id=?", patient_id).UpdateColumn("other_count", gorm.Expr("other_count - ?", count)).Error
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	return patients, err
+}
+
+func GetPatientCountList(user_org_id int64, patient_id int64, page int64, limit int64, start_time int64, end_time int64) (patient []*models.SfPatientInCount, total int64, err error) {
+
+	db := XTReadDB().Model(&patient).Where("status=1")
+
+	offset := (page - 1) * limit
+
+	if patient_id > 0 {
+		db = db.Where("patient_id = ?", patient_id)
+	}
+
+	if user_org_id > 0 {
+		db = db.Where("user_org_id = ?", user_org_id)
+	}
+
+	if start_time > 0 {
+		db = db.Where("record_date >=?", start_time)
+	}
+	if end_time > 0 {
+		db = db.Where("record_date<=?", end_time)
+	}
+
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("record_date desc").Find(&patient).Error
+
+	return patient, total, err
+}
+
+func CheckPatientCount(id int64, tx *gorm.DB) (models.SfPatientInCount, error) {
+
+	patientInCount := models.SfPatientInCount{}
+
+	err = tx.Model(&patientInCount).Where("id = ?", id).Updates(map[string]interface{}{"is_check": 1}).Error
+	if err != nil {
+		tx.Rollback()
+		return patientInCount, err
+	}
+	return patientInCount, err
+}
+
+func ReturnCheckPatientCount(id int64, tx *gorm.DB) (models.SfPatientInCount, error) {
+
+	patientInCount := models.SfPatientInCount{}
+
+	err = tx.Model(&patientInCount).Where("id = ?", id).Updates(map[string]interface{}{"is_check": 2}).Error
+
+	if err != nil {
+		tx.Rollback()
+		return patientInCount, err
+	}
+
+	return patientInCount, err
+}
+
+func UpdatePatientCountFlow(id int64, tx *gorm.DB) error {
+
+	err := tx.Model(&models.SfPatientCountFlow{}).Where("warehouse_info_id = ?", id).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+
+	if err != nil {
+		tx.Rollback()
+		return err
+	}
+	return err
+}
+
+func GetPatientCountById(id int64, tx *gorm.DB) (models.SfPatientInCount, error) {
+
+	patientInCount := models.SfPatientInCount{}
+
+	err := tx.Where("id = ?", id).Find(&patientInCount).Error
+	if err != nil {
+		tx.Rollback()
+		return patientInCount, err
+	}
+
+	return patientInCount, err
+}
+
+func DeletePatientCount(id int64) (models.SfPatientInCount, error) {
+
+	patientCount := models.SfPatientInCount{}
+
+	err := XTWriteDB().Model(&patientCount).Where("id = ?", id).Updates(map[string]interface{}{"status": 0}).Error
+
+	return patientCount, err
+}
+
+func CreateSfPatientOutCount(outCount models.SfPatientOutCount) error {
+
+	err := XTWriteDB().Create(&outCount).Error
+
+	return err
+}
+
+func GetPatientOutCountList(patient_id int64, user_org_id int64, limit int64, page int64, start_time int64, end_time int64) (outcount []*models.SfPatientOutCount, total int64, err error) {
+
+	db := XTReadDB().Model(&outcount).Where("status=1")
+
+	offset := (page - 1) * limit
+
+	if patient_id > 0 {
+		db = db.Where("patient_id = ?", patient_id)
+	}
+
+	if user_org_id > 0 {
+		db = db.Where("user_org_id = ?", user_org_id)
+	}
+
+	if start_time > 0 {
+		db = db.Where("start_time>=?", start_time)
+	}
+
+	if end_time > 0 {
+		db = db.Where("end_time<=?", end_time)
+	}
+
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("record_date desc").Find(&outcount).Error
+
+	return outcount, total, err
+
+}
+
+func GetPatientScheduleByPatient(patient_id int64, record_date int64, user_org_id int64) (models.XtSchedule, error) {
+
+	schedule := models.XtSchedule{}
+	err = XTReadDB().Where("patient_id = ? and schedule_date = ? and user_org_id = ? and status=1", patient_id, record_date, user_org_id).Last(&schedule).Error
+
+	return schedule, err
+}
+
+func GetDialysisSolutonByScheduleModeId(mode_id int64, patient_id int64, user_org_id int64) (models.DialysisSolution, error) {
+
+	solution := models.DialysisSolution{}
+
+	err = XTReadDB().Where("mode_id = ? and patient_id = ? and user_org_id = ? and solution_status =1", mode_id, patient_id, user_org_id).Find(&solution).Error
+
+	return solution, err
+}
+
+func DeletePatientOutCount(id int64) error {
+
+	outCount := models.SfPatientOutCount{}
+
+	err := XTWriteDB().Model(&outCount).Where("id = ? and status=1", id).Updates(map[string]interface{}{"status": 0}).Error
+
+	return err
+}
+
+func GetPatientOutCountById(id int64, tx *gorm.DB) (models.SfPatientOutCount, error) {
+
+	outCount := models.SfPatientOutCount{}
+	err = tx.Where("id=? and status=1", id).Find(&outCount).Error
+
+	if err != gorm.ErrRecordNotFound {
+		if err != nil {
+			tx.Rollback()
+			return outCount, err
+		}
+	}
+	return outCount, err
+}
+
+func CreatePatientCountFlow(flow models.SfPatientCountFlow, tx *gorm.DB) error {
+
+	err := tx.Create(&flow).Error
+
+	if err != nil {
+		tx.Rollback()
+		return err
+	}
+
+	return err
+}
+
+func GetSfPatientById(tx *gorm.DB, patient_id int64) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+	err := tx.Where("id =? and status=1", patient_id).Find(&patients).Error
+
+	if err != gorm.ErrRecordNotFound {
+		if err != nil {
+			tx.Rollback()
+			return patients, err
+		}
+	}
+	return patients, err
+}
+
+func GetSfPatientByIdOne(patient_id int64) (models.SfPatients, error) {
+
+	patients := models.SfPatients{}
+	err := XTReadDB().Where("id =? and status=1", patient_id).Find(&patients).Error
+
+	return patients, err
+}
+
+func CheckPatientOutCount(id int64, tx *gorm.DB) error {
+
+	patients := models.SfPatientOutCount{}
+
+	err := tx.Model(&patients).Where("id=? and status=1", id).Updates(map[string]interface{}{"is_check": 1, "mtime": time.Now().Unix()}).Error
+
+	return err
+}
+
+func ReturnPatientOutCount(id int64, tx *gorm.DB) error {
+
+	err = tx.Model(&models.SfPatientOutCount{}).Where("id=?", id).Updates(map[string]interface{}{"is_check": 2}).Error
+
+	if err != nil {
+		tx.Rollback()
+		return err
+	}
+
+	return err
+}
+
+func DeletePatientCountFlow(id int64, tx *gorm.DB) error {
+
+	err := tx.Model(&models.SfPatientCountFlow{}).Where("warehouse_out_id = ?", id).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+
+	if err != nil {
+		tx.Rollback()
+		return err
+	}
+	return err
+
+}
+
+func GetPatientCountMapList(patient_id int64, limit int64, page int64, user_org_id int64) (patient []*models.SfPatients, total int64, err error) {
+
+	db := XTReadDB().Model(&patient).Where("status=1")
+
+	offset := (page - 1) * limit
+
+	if (patient_id) > 0 {
+		db = db.Where("id = ?", patient_id)
+	}
+	if (user_org_id) > 0 {
+		db = db.Where("user_org_id = ?", user_org_id)
+	}
+
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("id desc").Find(&patient).Error
+
+	return patient, total, err
+}
+
+func GetPatientCountFlow(patient_id int64, user_org_id int64, is_type int64, mode_id int64, start_time int64, end_time int64) (flow []*models.SfPatientCountFlow, total int64, err error) {
+
+	db := XTReadDB().Model(&flow).Where("status=1")
+
+	if patient_id > 0 {
+		db = db.Where("patient_id=?", patient_id)
+	}
+	if user_org_id > 0 {
+		db = db.Where("user_org_id = ?", user_org_id)
+	}
+	if is_type > 0 {
+		db = db.Where("is_type = ?", is_type)
+	}
+	if mode_id > 0 {
+		db = db.Where("mode_id = ?", mode_id)
+	}
+
+	if start_time > 0 {
+		db = db.Where("ctime>=?", start_time)
+	}
+	if end_time > 0 {
+		db = db.Where("ctime<=?", end_time)
+	}
+	err = db.Find(&flow).Error
+
+	return flow, total, err
+}
+
+func GetDialysisOrderSetting(user_org_id int64) (models.XtDialysisOrderSetting, error) {
+
+	orderSetting := models.XtDialysisOrderSetting{}
+	err = XTReadDB().Model(&orderSetting).Where("user_org_id = ? and status=1", user_org_id).Find(&orderSetting).Error
+
+	return orderSetting, err
+}
+
+func GetDialysisOrderSchedule(patient_id int64, schedule_date int64, user_org_id int64, tx *gorm.DB) (models.XtSchedule, error) {
+
+	schedule := models.XtSchedule{}
+
+	err = tx.Where("patient_id=? and schedule_date = ? and user_org_id=? and status=1", patient_id, schedule_date, user_org_id).Find(&schedule).Error
+
+	if err != nil {
+		tx.Rollback()
+		return schedule, err
+	}
+
+	return schedule, err
+}
+
+func CreateDialysisOrder(setting models.XtDialysisOrderSetting) error {
+
+	err := XTWriteDB().Create(&setting).Error
+
+	return err
+}
+
+func GetPatientCountFlowList(patient_id int64, start_time int64, end_time int64, limit int64, page int64, orgId int64, is_type int64) (flow []*models.SfPatientCountFlow, total int64, err error) {
+
+	db := XTReadDB().Model(&flow).Where("status=1")
+
+	offset := (page - 1) * limit
+
+	if patient_id > 0 {
+		db = db.Where("patient_id = ?", patient_id)
+	}
+	if start_time > 0 {
+		db = db.Where("ctime>=?", start_time)
+	}
+
+	if end_time > 0 {
+		db = db.Where("ctime<=?", end_time)
+	}
+
+	if orgId > 0 {
+		db = db.Where("user_org_id = ?", orgId)
+	}
+
+	if is_type > 0 {
+		db = db.Where("is_type = ?", is_type)
+	}
+
+	err = db.Group("patient_id,mode_id,is_type").Count(&total).Offset(offset).Limit(limit).Order("id desc").Find(&flow).Error
+
+	return flow, total, err
+}
+
+func GetPatientCountListFlowOne(patient_id int64, start_time int64, end_time int64, is_type int64, orgId int64) (flow []*models.SfPatientCountFlow, err error) {
+
+	db := XTReadDB().Model(&flow).Where("status=1")
+
+	if patient_id > 0 {
+		db = db.Where("patient_id = ?", patient_id)
+	}
+	if start_time > 0 {
+		db = db.Where("ctime>=?", start_time)
+	}
+
+	if end_time > 0 {
+		db = db.Where("ctime<=?", end_time)
+	}
+
+	if orgId > 0 {
+		db = db.Where("user_org_id = ?", orgId)
+	}
+
+	if is_type > 0 {
+		db = db.Where("is_type = ?", is_type)
+	}
+
+	err = db.Order("id desc").Find(&flow).Error
+
+	return flow, err
+
+}
+
+func GetPatientCountFlowByIdList(patient_id int64, orgId int64, mode_id int64, is_type int64, startTime int64, endTime int64) (flow []*models.SfPatientCountFlow, err error) {
+
+	db := XTReadDB().Model(&flow).Where("status=1")
+
+	if patient_id > 0 {
+		db = db.Where("patient_id=?", patient_id)
+	}
+	if orgId > 0 {
+		db = db.Where("user_org_id =?", orgId)
+	}
+
+	if mode_id > 0 {
+		db = db.Where("mode_id = ?", mode_id)
+	}
+
+	if is_type > 0 {
+		db = db.Where("is_type =?", is_type)
+	}
+
+	if startTime > 0 {
+		db = db.Where("ctime>=?", startTime)
+	}
+	if endTime > 0 {
+		db = db.Where("ctime<=?", endTime)
+	}
+	if mode_id > 0 {
+		db = db.Where("mode_id = ?", mode_id)
+	}
+	err = db.Find(&flow).Error
+
+	return flow, err
+}

service/patientmanage_service.go

 
 func GetNormalInspectionTotalByID(startime int64, endtime int64, orgid int64, item_name string, max_value float64, min_value float64) (total int64, err error) {
 	var count []*models.Inspection
-	err2 := XTReadDB().Table("xt_inspection as xti ").Select("count(*) as count").Joins("join (SELECT max(inspect_date) as ind, patient_id as pid  FROM xt_inspection as x Join xt_patients pp on pp.id = x.patient_id and pp.lapseto = 1  WHERE (x.status = 1) AND (x.org_id = ?  and x.item_name = ?  and x.inspect_date >= ? and x.inspect_date <= ?) group by patient_id) as ta on ta.ind = xti.`inspect_date` and xti.patient_id = ta.pid  WHERE (xti.status = 1) AND (xti.org_id = ?  and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date<= ? and xti.`inspect_value` <= ? and xti.inspect_value >= ? ) Group by xti.patient_id", orgid, item_name, startime, endtime, orgid, item_name, startime, endtime, max_value, min_value).Scan(&count).Error
+	err2 := XTReadDB().Table("xt_inspection as xti ").Select("count(*) as count").Joins("join (SELECT max(inspect_date) as ind, patient_id as pid  FROM xt_inspection as x Join xt_patients pp on pp.id = x.patient_id and pp.lapseto = 1 and pp.patient_type =1  WHERE (x.status = 1) AND (x.org_id = ?  and x.item_name = ?  and x.inspect_date >= ? and x.inspect_date <= ?) group by patient_id) as ta on ta.ind = xti.`inspect_date` and xti.patient_id = ta.pid  WHERE (xti.status = 1) AND (xti.org_id = ?  and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date<= ? and xti.`inspect_value` <= ? and xti.inspect_value >= ? ) Group by xti.patient_id", orgid, item_name, startime, endtime, orgid, item_name, startime, endtime, max_value, min_value).Scan(&count).Error
 
 	return int64(len(count)), err2
 }
 func GetUnusualInspectionTotalByID(startime int64, endtime int64, orgid int64, item_name string, max_value float64, min_value float64) (total int64, err error) {
 	var count []*models.Inspection
-	err2 := XTReadDB().Table("xt_inspection as xti ").Select("count(*) as count").Joins("join (SELECT max(inspect_date) as ind, patient_id as pid  FROM xt_inspection as x JOIN xt_patients pp on pp.id = x.patient_id and pp.status = 1 and pp.lapseto = 1  WHERE (x.status = 1) AND (x.org_id = ? and x.item_name = ?  and x.inspect_date >= ? and x.inspect_date <= ?) group by patient_id) as ta on ta.ind = xti.`inspect_date` and xti.patient_id = ta.pid  WHERE   (xti.status = 1 AND xti.org_id = ? and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date <= ? and xti.inspect_value > ?) OR (xti.status = 1 AND xti.org_id = ?  and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date <= ? and xti.inspect_value < ?) Group by xti.patient_id", orgid, item_name, startime, endtime, orgid, item_name, startime, endtime, max_value, orgid, item_name, startime, endtime, min_value).Scan(&count).Error
+	err2 := XTReadDB().Table("xt_inspection as xti ").Select("count(*) as count").Joins("join (SELECT max(inspect_date) as ind, patient_id as pid  FROM xt_inspection as x JOIN xt_patients pp on pp.id = x.patient_id and pp.status = 1 and pp.lapseto = 1 and pp.patient_type =1   WHERE (x.status = 1) AND (x.org_id = ? and x.item_name = ?  and x.inspect_date >= ? and x.inspect_date <= ?) group by patient_id) as ta on ta.ind = xti.`inspect_date` and xti.patient_id = ta.pid  WHERE   (xti.status = 1 AND xti.org_id = ? and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date <= ? and xti.inspect_value > ?) OR (xti.status = 1 AND xti.org_id = ?  and xti.item_name = ?  and xti.inspect_date >= ? and xti.inspect_date <= ? and xti.inspect_value < ?) Group by xti.patient_id", orgid, item_name, startime, endtime, orgid, item_name, startime, endtime, max_value, orgid, item_name, startime, endtime, min_value).Scan(&count).Error
 	return int64(len(count)), err2
 }
 func GetPatientNotInspectionTotal(startime int64, endtime int64, orgid int64, item_name string) (total int64, err error) {
-	err = XTReadDB().Model(models.XtPatients{}).Joins("LEFT JOIN xt_inspection pd ON xt_patients.id = pd.patient_id and pd.org_id = ? and pd.item_name = ? and pd.inspect_date >= ? and pd.inspect_date<=? ", orgid, item_name, startime, endtime).Where("xt_patients.user_org_id = ? and xt_patients.status = 1 and pd.patient_id IS NULL and xt_patients.lapseto = 1", orgid).Count(&total).Error
+	err = XTReadDB().Model(models.XtPatients{}).Joins("LEFT JOIN xt_inspection pd ON xt_patients.id = pd.patient_id and pd.org_id = ? and pd.item_name = ? and pd.inspect_date >= ? and pd.inspect_date<=? ", orgid, item_name, startime, endtime).Where("xt_patients.user_org_id = ? and xt_patients.status = 1 and pd.patient_id IS NULL and xt_patients.lapseto = 1 and xt_patients.patient_type = 1", orgid).Count(&total).Error
 	return total, err
 }
 
 func GetPatientInspectionByID(startime int64, endtime int64, orgid int64, patient_id int64, item_name string) (inspections []*models.Inspection, err error) {
-	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("join xt_patients p On p.id = x.patient_id and p.status = 1 and p.lapseto = 1").Where("x.status = 1")
+	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("join xt_patients p On p.id = x.patient_id and p.status = 1 and p.lapseto = 1 and p.patient_type =1").Where("x.status = 1")
 	if startime > 0 {
 		db = db.Where("x.inspect_date >= ?", startime)
 	}
 }
 
 func GetPatientKTVORURRInspectionByID(startime int64, endtime int64, orgid int64, projectid int64, item_id int64, patient_id int64) (inspections []*models.Inspection, err error) {
-	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("join xt_patients p On p.id = x.patient_id and p.status = 1 and p.lapseto = 1").Where("x.status = 1")
+	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("join xt_patients p On p.id = x.patient_id and p.status = 1 and p.lapseto = 1 and p.patient_type =1").Where("x.status = 1")
 	if startime > 0 {
 		db = db.Where("x.inspect_date >= ?", startime)
 	}

service/pharmacy_service.go

 	return
 }
 
-func GetDrugTocalCountByDrugId(drug_id int64, advice_date int64, user_org_id int64) (advice []*models.HisDoctorAdviceInfo, err error) {
+func GetDrugTocalCountByDrugId(drug_id int64, advice_date int64, user_org_id int64) (advice []*models.NBHisDoctorAdviceInfo, err error) {
 
 	err = XTReadDB().Where("drug_id = ? and advice_date>=? and user_org_id = ? and status=1 and drug_code!=''", drug_id, advice_date, user_org_id).Find(&advice).Error
 
 	return advice, err
 }
+
+func GetNewBaseDrugById(id int64) (models.NBXtBaseDrug, error) {
+
+	drug := models.NBXtBaseDrug{}
+	err := XTReadDB().Where("id = ?", id).Find(&drug).Error
+
+	return drug, err
+}

service/self_drug_service.go

 		if orgid > 0 {
 			db = db.Where("x.org_id = ?", orgid)
 		}
-		err = db.Select("x.drug_id,x.number,x.product_date,x.expiry_date,x.stock_max_number,x.stock_min_number,x.batch_number,t.drug_name,t.max_unit,t.min_unit,t.min_number,t.dose,t.dose_unit,x.manufacturer,x.dealer,t.sum_count,x.max_unit as max_unit_one,x.min_unit as min_unit_one").Joins("left join xt_base_drug as t on t.id = x.drug_id").Group("x.drug_id,x.batch_number").Scan(&info).Error
+		err = db.Select("x.drug_id,x.number,x.product_date,x.expiry_date,x.stock_max_number,x.stock_min_number,x.batch_number,t.drug_name,t.max_unit,t.min_unit,t.min_number,t.dose,t.dose_unit,x.manufacturer,x.dealer,t.sum_count,x.max_unit as max_unit_one,x.min_unit as min_unit_one").Joins("left join xt_base_drug as t on t.id = x.drug_id").Group("x.drug_id,x.id").Scan(&info).Error
 		return info, err
 	} else {
 		db := XTReadDB().Table("xt_drug_warehouse_info as x").Where("x.status = 1 and (x.warehousing_count>0)")

service/sign_service.go

 
 func GetScheduleListByOrder(user_org_id int64) (list []*models.XtSchedule, err error) {
 
-	err = XTReadDB().Where("user_org_id = ? and schedule_date >=? and status =1 and schedule_date<=?", 10579, 1703260800, 1703347200).Find(&list).Error
+	err = XTReadDB().Where("user_org_id = ? and schedule_date >=? and status =1 and schedule_date<=?", 10579, 1741795200, 1742054400).Find(&list).Error
 	return list, err
 }
 
 
 	return
 }
+
+func CheckSchedule() (schedule []*models.XtSchedule, err error) {
+
+	err = readDb3.Where("user_org_id = 9535 and schedule_date<1741536000").Find(&schedule).Error
+
+	return schedule, err
+}
+
+func UpdateScheduleByIdOneList(id int64, schedule_date int64, schedule_type int64, schedule_week int64, status int64, patient_id int64, partition_id int64, bed_id int64, dialysis_machine_name string, user_org_id int64, mode_id int64) error {
+
+	err := XTWriteDB().Model(&models.XtSchedule{}).Where("id = ?", id).Updates(map[string]interface{}{"schedule_date": schedule_date, "schedule_type": schedule_type, "schedule_week": schedule_week, "status": status, "patient_id": patient_id, "partition_id": partition_id, "bed_id": bed_id, "dialysis_machine_name": dialysis_machine_name, "user_org_id": user_org_id, "mode_id": mode_id}).Error
+
+	return err
+}

service/warhouse_service.go

 		if lastWarehouse.StockMinNumber >= drup.MinNumber {
 			var stockMax int64
 			var stockMin int64
+
+			var stockMac_One int64
+
 			stockMax = lastWarehouse.StockMinNumber / drup.MinNumber
 			stockMin = lastWarehouse.StockMinNumber % drup.MinNumber
 
-			ChangeNewMaxNumberOne(lastWarehouse.ID, stockMax, tx)
+			stockMac_One = lastWarehouse.StockMaxNumber + stockMax
+
+			ChangeNewMaxNumberOne(lastWarehouse.ID, stockMac_One, tx)
 			UpdateNewMinNumber(lastWarehouse.ID, stockMin, tx)
 
 		}
 	if lastWarehouse.MaxUnit == lastWarehouse.MinUnit && drup.MaxUnit != drup.MinUnit && lastWarehouse.MinUnit != "" {
 
 		lastWarehouse.StockMaxNumber = lastWarehouse.StockMaxNumber + lastWarehouse.StockMinNumber
+
 		ChangeNewMaxNumberOne(lastWarehouse.ID, lastWarehouse.StockMaxNumber, tx)
 
 	}
 		stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
 
 	}
+
+	fmt.Println("stock_number--------------", stock_number)
+	fmt.Println("deliver_number", deliver_number)
 	if stock_number >= deliver_number {
 
 		var maxNumber int64 = 0
 		maxNumber = deliver_number / drup.MinNumber
 		minNumber = deliver_number % drup.MinNumber
 
+		fmt.Println("maxNumber==============", maxNumber)
+
+		fmt.Println("maxNumber==============", minNumber)
+
 		if warehouse.StockMaxNumber == 0 && drup.MaxUnit == drup.MinUnit {
 			minNumber = maxNumber
 		}
 			}
 		}
 
+		fmt.Println("warehouse.StockMaxNumber", warehouse.StockMaxNumber)
+		fmt.Println("warehouse.StockMinNumber", warehouse.StockMinNumber)
+
 		if drup.MinUnit == warehouse.MaxUnit && drup.MaxUnit != drup.MinUnit {
-			//fmt.Println("金1")
+			fmt.Println("金1")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber*drup.MinNumber
 		}
 
 		if drup.MaxUnit == warehouse.MaxUnit && drup.MaxUnit != drup.MinUnit {
-			//fmt.Println("金2")
+			fmt.Println("金2")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
 		}
 		if drup.MaxUnit == warehouse.MaxUnit && drup.MaxUnit == drup.MinUnit {
-			//fmt.Println("金3")
+			fmt.Println("金3")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
 		}
 
 
 		warehouse.Mtime = time.Now().Unix()
 
+		fmt.Println("warehouse.StockMinNumber", warehouse.StockMinNumber)
+
+		fmt.Println("minNumber222222222222222", minNumber)
+
 		if warehouse.StockMinNumber < minNumber {
-			//fmt.Println("金4")
+			fmt.Println("金4")
 			warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
 			if warehouse.MaxUnit != warehouse.MinUnit {
 				warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
 				warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
 			}
 		} else {
-			//fmt.Println("金5")
+			fmt.Println("金5", minNumber)
 			if minNumber > 0 {
 				if (warehouse.StockMinNumber - minNumber) >= 0 {
 					warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
 			}
 
 			if minNumber == 0 && maxNumber != 1 && warehouse.StockMaxNumber <= 0 {
-				//fmt.Println("6")
+				fmt.Println("金6", warehouse.StockMinNumber)
 				if warehouse.StockMinNumber > 0 {
 					if warehouse.StockMinNumber-deliver_number >= 0 {
 						warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
 
 		if maxNumber == 1 && minNumber == 0 && drup.MaxUnit != drup.MinUnit && warehouse.MaxUnit != warehouse.MinUnit {
 			if (warehouse.StockMinNumber - deliver_number) >= 0 {
-				//fmt.Println("金7")
+				fmt.Println("金7")
 				warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
 			}