开发

controllers/new_mobile_api_controllers/common_api_controller.go

@@ -70,25 +70,33 @@ func (this *CommonApiController) SaveConfiguration() {
 	sort := dataBody["sort"].(string)
 	sorts, err := strconv.ParseInt(sort, 10, 64)
 	fmt.Println("sort", sort)
-	standard := models.XtQualityControlStandard{
-		InspectionMajor: inspectionmajor,
-		InspectionMinor: inspectionMinor,
-		MinRange:        minrange,
-		LargeRange:      largerange,
-		Sort:            sorts,
-		UserOrgId:       orgid,
-		Status:          1,
-		CreatedTime:     time.Now().Unix(),
-	}
-	fmt.Println(standard)
-	err = service.SaveInspection(&standard)
-	if err != nil {
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+
+	_, errcode := service.GetConfigurationById(inspectionmajor, inspectionMinor, orgid)
+	if errcode == gorm.ErrRecordNotFound {
+		standard := models.XtQualityControlStandard{
+			InspectionMajor: inspectionmajor,
+			InspectionMinor: inspectionMinor,
+			MinRange:        minrange,
+			LargeRange:      largerange,
+			Sort:            sorts,
+			UserOrgId:       orgid,
+			Status:          1,
+			CreatedTime:     time.Now().Unix(),
+		}
+		fmt.Println(standard)
+		err = service.SaveInspection(&standard)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"standard": standard,
+		})
+	} else if errcode == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
-	this.ServeSuccessJSON(map[string]interface{}{
-		"standard": standard,
-	})
+
 }
 
 func (this *CommonApiController) GetConfigurationlist() {
@@ -147,7 +155,15 @@ func (this *CommonApiController) UpdateConfiguration() {
 	largerange := dataBody["large_range"].(string)
 	fmt.Println("largerange", largerange)
 	sort := int64(dataBody["sort"].(float64))
-
+	fmt.Println("排序", sort)
+	adminInfo := this.GetAdminUserInfo()
+	orgId := adminInfo.CurrentOrgId
+	configuration, err := service.GetConfigurationByIdTwo(inspectionmajor, inspectionMinor, orgId)
+	fmt.Println("err", err)
+	if configuration.ID > 0 && configuration.ID != id {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
 	standard := models.XtQualityControlStandard{
 		InspectionMajor: inspectionmajor,
 		InspectionMinor: inspectionMinor,
@@ -219,7 +235,7 @@ func (this *CommonApiController) SaveCheckConfiguration() {
 	sort := dataBody["sort"].(string)
 	sorts, err := strconv.ParseInt(sort, 10, 64)
 	fmt.Println("sort", sort)
-	_, errcode := service.GetInspectionMajorById(inspectionmajor)
+	_, errcode := service.GetInspectionMajorById(inspectionmajor, orgid)
 	if errcode == gorm.ErrRecordNotFound {
 		configuration := models.XtCheckConfiguration{
 			InspectionMajor:     inspectionmajor,
@@ -285,8 +301,9 @@ func (this *CommonApiController) UpdateCheck() {
 	fmt.Println("凭次", frequency)
 	sort := int64(dataBody["sort"].(float64))
 	fmt.Println("sort", sort)
-
-	Inspection, err := service.GetInspectionMajorById(inspectionmajor)
+	adminInfo := this.GetAdminUserInfo()
+	orgId := adminInfo.CurrentOrgId
+	Inspection, err := service.GetInspectionMajorByIdTwo(inspectionmajor, orgId)
 	if Inspection.ID > 0 && Inspection.ID != id {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return
@@ -320,3 +337,136 @@ func (this *CommonApiController) DeleteCheck() {
 	this.ServeSuccessJSON(returnData)
 	return
 }
+
+func (this *CommonApiController) GetDialysisModeType() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime := this.GetString("startime")
+	endtime := this.GetString("endtime")
+	fmt.Println("endtime", endtime)
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
+	startimes := startTimes.Unix()
+	// fmt.Println("startime",startimes)
+	endtimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", endtime+" 00:00:00", loc)
+	endtimeData := endtimes.Unix()
+	// fmt.Println("结束日期",endtimeData)
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	//统计透析总量
+	_, total, _ := service.GetDialysiTotal(startimes, endtimeData, orgid)
+
+	modeType, err := service.GetDialysisCountMode(startimes, endtimeData, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total":    total,
+		"modetype": modeType,
+	})
+}
+
+func (this *CommonApiController) GetTotalLapseCount() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	startime, _ := this.GetInt64("startime")
+	fmt.Println("startime--", startime)
+	endtime, _ := this.GetInt64("endtime")
+	fmt.Println("endtime--", endtime)
+
+	//统计一个月内转出的病人
+	patients, total, err := service.GetTotalRollOut(startime, endtime, orgid)
+	//统计总共病人
+	_, count, _ := service.GetPatientTotalCountTwo(orgid, startime, endtime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+		"total":    total,
+		"count":    count,
+	})
+}
+
+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)
+	//统计这个月透析病人的总数
+	_, total, err := service.GetPatientTotalCountTwo(orgid, startime, endtime)
+	//统计改月男病人的总数
+	_, totalSex, err := service.GetManPatientTotalCount(orgid, startime, endtime)
+
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total":    total,
+		"totalSex": totalSex,
+	})
+}
+
+func (this *CommonApiController) GetTotalInfectiouscount() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	fmt.Println("orgid", orgid)
+	startime, _ := this.GetInt64("startime")
+	fmt.Println("开始时间", startime)
+	endtime, _ := this.GetInt64("endtime")
+	fmt.Println("结束时间", endtime)
+	//统计本月透析总人数
+	_, total, err := service.GetPatientTotalCountTwo(orgid, startime, endtime)
+	fmt.Println("err--", err)
+	fmt.Println("total", total)
+	//统计本月透析人数传染病所占比例
+	count, err := service.GetPatientInfectiousCount(orgid, startime, endtime)
+	fmt.Println("报错-------------", count)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total": total,
+		"count": count,
+	})
+}
+
+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)
+	//统计本月透析总人数
+	_, total, err := service.GetPatientTotalCountTwo(orgid, startime, endtime)
+	fmt.Println("err--", err)
+	fmt.Println("total", total)
+	agecount, err := service.GetTotalAgeCount(orgid, startime, endtime)
+	//two, err := service.GetTotalAgeCountTwo(orgid, startime, endtime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total":    total,
+		"ageCount": agecount,
+	})
+}
+
+func (this *CommonApiController) GetTotalDialysisCount() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	fmt.Println("org", orgid)
+	startime, _ := this.GetInt64("startime")
+	fmt.Println(startime)
+	endtime, _ := this.GetInt64("endtime")
+	fmt.Println(endtime)
+}

controllers/new_mobile_api_controllers/common_api_router.go

@@ -21,4 +21,10 @@ func CommonApiControllersRegisterRouters() {
 	beego.Router("/com/api/getcheckdetail", &CommonApiController{}, "Get:GetCheckdetail")
 	beego.Router("/com/api/updatecheck", &CommonApiController{}, "Post:UpdateCheck")
 	beego.Router("/com/api/deletecheck", &CommonApiController{}, "Delete:DeleteCheck")
+	beego.Router("/com/api/getdialysismodetype", &CommonApiController{}, "Get:GetDialysisModeType")
+	beego.Router("/com/api/gettotallapsecount", &CommonApiController{}, "Get:GetTotalLapseCount")
+	beego.Router("/com/api/gettotalsexcount", &CommonApiController{}, "Get:GetTotalSexCount")
+	beego.Router("/com/api/gettoalinfectiouscount", &CommonApiController{}, "Get:GetTotalInfectiouscount")
+	beego.Router("/com/api/gettotalagecount", &CommonApiController{}, "Get:GetTotalAgeCount")
+	beego.Router("/com/api/gettotaldialysiscount", &CommonApiController{}, "Get:GetTotalDialysisCount")
 }

models/common_models.go

@@ -59,3 +59,53 @@ type XtCheckConfiguration struct {
 func (XtCheckConfiguration) TableName() string {
 	return "xt_check_configuration"
 }
+
+type PatientPrescriptionCountStruct struct {
+	ModeId int64 `json:"mode_id"`
+	Count  int64 `json:"count"`
+}
+
+type PatientLapsetoCountStruct struct {
+	lapseto_type int64 `json:"lapseto_type"`
+	Count        int64 `json:"count"`
+}
+
+type SgjDialysisOrder struct {
+	ID             int64  `gorm:"column:id" json:"id" form:"id"`
+	DialysisDate   int64  `gorm:"column:dialysis_date" json:"dialysis_date" form:"dialysis_date"`
+	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"`
+	PrescriptionId int64  `gorm:"column:prescription_id" json:"prescription_id" form:"prescription_id"`
+	Stage          int64  `gorm:"column:stage" json:"stage" form:"stage"`
+	Remark         string `gorm:"column:remark" json:"remark" form:"remark"`
+	BedId          int64  `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	StartNurse     int64  `gorm:"column:start_nurse" json:"start_nurse" form:"start_nurse"`
+	FinishNurse    int64  `gorm:"column:finish_nurse" json:"finish_nurse" form:"finish_nurse"`
+	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"`
+	StartTime      int64  `gorm:"column:start_time" json:"start_time" form:"start_time"`
+	EndTime        int64  `gorm:"column:end_time" json:"end_time" form:"end_time"`
+	PunctureNurse  int64  `gorm:"column:puncture_nurse" json:"puncture_nurse" form:"puncture_nurse"`
+	Creator        int64  `gorm:"column:creator" json:"creator" form:"creator"`
+	Modifier       int64  `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	FinishCreator  int64  `gorm:"column:finish_creator" json:"finish_creator" form:"finish_creator"`
+	FinishModifier int64  `gorm:"column:finish_modifier" json:"finish_modifier" form:"finish_modifier"`
+	SchedualType   int64  `gorm:"column:schedual_type" json:"schedual_type" form:"schedual_type"`
+	Number         int64  `gorm:"column:number" json:"number" form:"number"`
+	UserName       int64  `gorm:"column:user_name" json:"user_name" form:"user_name"`
+}
+
+func (SgjDialysisOrder) TableName() string {
+	return "xt_dialysis_order"
+}
+
+type PatientContagionsCountStruct struct {
+	DiseaseId int64 `json:"disease_id"`
+	Count     int64 `json:"count"`
+}
+
+type PatientAgeCountStruct struct {
+	Age   int64 `json:"age"`
+	Count int64 `json:"count"`
+}

service/common_service.go

@@ -25,6 +25,24 @@ func GetInspectionRange(id int64) (models.XtInspectionReference, error) {
 	return reference, err
 }
 
+func GetConfigurationById(major int64, moni int64, orgid int64) (*models.XtQualityControlStandard, error) {
+	standard := models.XtQualityControlStandard{}
+	err := XTReadDB().Model(&standard).Where("inspection_major = ? and inspection_minor = ? and user_org_id = ? and status = 1", major, moni, orgid).Find(&standard).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &standard, nil
+}
+
+func GetConfigurationByIdTwo(major int64, moni int64, orgid int64) (standard models.XtQualityControlStandard, err error) {
+
+	err = XTReadDB().Model(&standard).Where("inspection_major = ? and inspection_minor = ? and user_org_id = ? and status = 1", major, moni, orgid).First(&standard).Error
+	return standard, err
+}
+
 func SaveInspection(standard *models.XtQualityControlStandard) error {
 
 	err := XTWriteDB().Create(&standard).Error
@@ -87,9 +105,9 @@ func GetAllInspectiondatatwo(orgid int64) (reference []*models.XtInspectionRefer
 	return reference, err
 }
 
-func GetInspectionMajorById(marjor int64) (*models.XtCheckConfiguration, error) {
+func GetInspectionMajorById(marjor int64, orgid int64) (*models.XtCheckConfiguration, error) {
 	configuration := models.XtCheckConfiguration{}
-	err := XTReadDB().Model(&configuration).Where("inspection_major = ? and status =1", marjor).Find(&configuration).Error
+	err := XTReadDB().Model(&configuration).Where("inspection_major = ? and user_org_id = ? and status =1", marjor, orgid).Find(&configuration).Error
 	if err == gorm.ErrRecordNotFound {
 		return nil, err
 	}
@@ -99,6 +117,11 @@ func GetInspectionMajorById(marjor int64) (*models.XtCheckConfiguration, error)
 	return &configuration, nil
 }
 
+func GetInspectionMajorByIdTwo(marjor int64, orgid int64) (configuration models.XtCheckConfiguration, err error) {
+	err = XTReadDB().Model(&configuration).Where("inspection_major = ? and user_org_id = ? and status =1", marjor, orgid).First(&configuration).Error
+	return configuration, err
+}
+
 func CreateCheckConfiguration(configuration *models.XtCheckConfiguration) error {
 	err := XTWriteDB().Create(&configuration).Error
 	return err
@@ -136,3 +159,77 @@ func DeleteCheck(id int64) error {
 	err := XTWriteDB().Model(models.XtCheckConfiguration{}).Where("id=?", id).Updates(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
 	return err
 }
+
+func GetDialysiTotal(startime int64, endtime int64, orgid int64) (prescription []*models.DialysisPrescription, total int64, err error) {
+	err = XTReadDB().Model(&prescription).Where("record_date >= ? and record_date<=? and user_org_id = ?", startime, endtime, orgid).Count(&total).Find(&prescription).Error
+	return prescription, total, err
+}
+
+func GetDialysisCountMode(starttime int64, endtime int64, orgid int64) (counts []*models.PatientPrescriptionCountStruct, err error) {
+	err = readDb.Table("xt_dialysis_prescription as p").Where("p.record_date>= ? and p.record_date<=? and p.user_org_id=?", starttime, endtime, orgid).Select("p.mode_id,count(p.mode_id) as count").Group("p.mode_id").Scan(&counts).Error
+	return counts, err
+}
+
+func GetTotalRollOut(starttime int64, endtime int64, orgid int64) (counts []*models.PatientLapseto, total int64, err error) {
+
+	db := readDb.Table("xt_patient_lapseto as x").Where("x.status = 1")
+	table := readDb.Table("xt_dialysis_order as s")
+	fmt.Println(table)
+	err = db.Select("x.patient_id,x.lapseto_type").Joins("left join xt_dialysis_order as s on s.patient_id = x.patient_id").Where("x.lapseto_time >=? and x.lapseto_time <= ? and x.lapseto_type = 2 and s.user_org_id = ?", starttime, endtime, orgid).Group("x.patient_id").Count(&total).Scan(&counts).Error
+	return counts, total, err
+}
+
+func GetPatientTotalCount(orgID int64) (total int64) {
+	readDb.Model(&models.XtPatients{}).Where("user_org_id=? and status=1", orgID).Count(&total)
+	return
+}
+
+func GetPatientTotalCountTwo(orgid int64, starttime int64, endtime int64) (dialysisorder []*models.XtDialysisOrder, total int64, err error) {
+
+	err = XTReadDB().Model(&dialysisorder).Group("patient_id").Where("user_org_id = ? and dialysis_date >= ? and dialysis_date <=? and status =1", orgid, starttime, endtime).Count(&total).Find(&dialysisorder).Error
+	return dialysisorder, total, err
+}
+
+func GetManPatientTotalCount(orgid int64, starttime int64, endtime int64) (dialysisorder []*models.SgjDialysisOrder, total int64, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_order as s").Where("s.status = 1")
+	table := XTReadDB().Table("xt_patients as x")
+	fmt.Println("table", table)
+	err = db.Select("s.dialysis_date,s.prescription_id").Joins("left join xt_patients as x on x.id = s.patient_id").Where("s.dialysis_date>=? and s.dialysis_date<=? and s.user_org_id = ? and s.status = 1 and x.gender = 1", starttime, endtime, orgid).Group("s.patient_id").Count(&total).Scan(&dialysisorder).Error
+	return dialysisorder, total, err
+
+}
+
+func GetPatientInfectiousCount(orgid int64, starttime int64, endtime int64) (counts []*models.PatientContagionsCountStruct, err error) {
+	err = readDb.Table("xt_patients_infectious_diseases as x").Joins("join xt_dialysis_order as o on o.patient_id = x.patient_id").Joins("join xt_patients as s on s.id = x.patient_id").Where("o.user_org_id = ? and o.status =1 and o.dialysis_date>=? and o.dialysis_date <=? and x.status =1 and s.is_infectious = 2", orgid, starttime, endtime).Select("x.disease_id,count(x.disease_id) as count").Group("x.disease_id").Scan(&counts).Error
+	return counts, err
+}
+
+func GetTotalAgeCount(orgid int64, starttime int64, endtime int64) (counts []*models.PatientAgeCountStruct, err error) {
+
+	readDb.Raw(`SELECT nnd AS 'age',COUNT(*) AS 'count' FROM(
+	 SELECT
+	 CASE
+	  WHEN (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%m%d') <= DATE_FORMAT(NOW(), '%m%d') )<=20 THEN '20'
+	  WHEN (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )>20 AND (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )<=40 THEN '40'
+	  WHEN (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )>40 AND (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )<=60 THEN '60'
+	  WHEN (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )>60 AND (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )<=80 THEN '80'
+	  WHEN (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )>80 AND (YEAR(NOW())-DATE_FORMAT(DATE_ADD(FROM_UNIXTIME(0), INTERVAL birthday SECOND),'%Y')-1) + ( FROM_UNIXTIME(birthday, '%m%d') <= DATE_FORMAT(NOW(), '%m%d') )<=150 THEN '150'
+	  ELSE '-1'
+	 END
+	 AS nnd FROM xt_patients as s  left join xt_dialysis_order as o on o.patient_id = s.id where s.user_org_id=? and s.status=1 and o.dialysis_date>= ? and o.dialysis_date<=?
+	 )a GROUP BY nnd`, orgid, starttime, endtime).Scan(&counts)
+	return
+
+}
+
+func GetTotalAgeCountTwo(orgid int64, starttime int64, endtime int64) (counts []*models.PatientAgeCountStruct, err error) {
+	readDb.Raw(`SELECT nnd AS 'age',COUNT(*) AS 'count' FROM(
+	 SELECT
+	 CASE
+	    when (substring(now(),1,4)-substring(id_card_no,7,4))-(substring(id_card_no,11,4)-date_format(now(),'%m%d')>0) and  (substring(now(),1,4)-substring(id_card_no,7,4))-(substring(id_card_no,11,4)-date_format(now(),'%m%d')<20) THEN '20'
+	   END
+       AS nnd FROM xt_patients as s  left join xt_dialysis_order as o on o.patient_id = s.id where s.user_org_id=? and s.status=1 and o.dialysis_date>= ? and o.dialysis_date<=?
+       )a GROUP BY nnd`, orgid, starttime, endtime).Scan(&counts)
+	return
+}