物联网

controllers/mobile_api_controllers/check_weight_api_controller.go

@@ -713,6 +713,39 @@ func (c *CheckWeightApiController) GetPatientList() {
 		"servicetime": serviceTime,
 	})
 }
+
+func (c *CheckWeightApiController) GetPatientListForSchedules() {
+	thisTime := time.Now()
+	scheduleDateStart := thisTime.Format("2006-01-02") + " 00:00:00"
+	timeLayout := "2006-01-02 15:04:05"
+	loc, _ := time.LoadLocation("Local")
+	theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
+	syncTime := theStartTime.Unix()
+	adminUserInfo := c.GetMobileAdminUserInfo()
+	patientList, total, error := service.GetPatientListBySchedules(adminUserInfo.Org.Id, syncTime)
+	patientSchedule := make([]map[string]interface{},0)
+	for _, item := range patientList {
+		patientTemp := make(map[string]interface{})
+		patientTemp["patient_id"] = item.PatientId
+		patientTemp["patient_name"] = item.Patient.Name
+		patientTemp["schedule_type"] = item.ScheduleType
+		patientSchedule = append(patientSchedule, patientTemp)
+	}
+
+	if error != nil {
+		c.ErrorLog("获取病人列表失败:%v", error)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	serviceTime := time.Now().Unix()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"patientlist": patientSchedule,
+		"total":       total,
+		"servicetime": serviceTime,
+	})
+}
+
+
 func (c *CheckWeightApiController) GetPatientListById() {
 	patientId, _ := c.GetInt64("patient_id", 0)
 	if patientId <= 0 {

controllers/mobile_api_controllers/mobile_api_router_register.go

@@ -12,6 +12,7 @@ func MobileAPIControllersRegisterRouters() {
 	beego.Router("/m/api/savebloodpressure", &CheckWeightApiController{}, "Post:SaveBloodPressure")
 	beego.Router("/m/api/checkbeforedialysis", &CheckWeightApiController{}, "get:GetPatientInfoBeforeDialysis")
 	beego.Router("/m/api/getpatientlist", &CheckWeightApiController{}, "get:GetPatientList")
+	beego.Router("/m/api/getschedulepatient", &CheckWeightApiController{}, "get:GetPatientListForSchedules")
 	beego.Router("/m/api/getpatientinfo", &CheckWeightApiController{}, "get:GetPatientListById")
 	beego.Router("/m/api/checkdialysis", &CheckWeightApiController{}, "get:GetPatientInfoDialysis")
 	beego.Router("/m/api/savecheckdialysis", &CheckWeightApiController{}, "Post:SavePatientInfoDialysis")

models/schedule_models.go

@@ -28,6 +28,28 @@ func (Schedule) TableName() string {
 	return "xt_schedule"
 }
 
+type SchedulePatients 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"`
+	PartitionId  int64 `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId        int64 `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId    int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate int64 `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType int64 `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek int64 `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId       int64 `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	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"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	Patient      PatientListForFace        `json:"patient" gorm:"foreignkey:ID;AssociationForeignKey:PatientId;"`
+}
+
+func (SchedulePatients) TableName() string {
+	return "xt_schedule"
+}
+
+
 type PatientSchedule struct {
 	Schedule
 

service/gdyb_service.go

@@ -716,6 +716,200 @@ func Gdyb2208(psnNo string, mdtrtId string, setlId string) string {
 	return str
 }
 
+//  门诊结算撤销
+func Gdyb4101(psnNo string, mdtrtId string, setlId string) string {
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce)
+
+	// 生成输入报文
+	inputMessage := SetInputMessage(nonce, timestamp)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "4101" // 交易编码
+
+	inputData["mdtrt_id"] = mdtrtId // 就诊 ID  必填（来自2201接口返回）
+	inputData["setl_id"] = setlId   // 结算 ID  必填
+	inputData["fixmedins_name"] = ""   // 定点医药机构名称  必填
+	inputData["fixmedins_code"] = ""   // 定点医药机构编码  必填
+	inputData["hi_setl_lv"] = ""   // 医保结算等级
+	inputData["hi_no"] = ""   // 医保编号
+	inputData["medcasno"] = ""   // 病案号  必填
+	inputData["dcla_time"] = ""   // 申报时间  必填
+	inputData["psn_name"] = ""   // 人员姓名  必填
+	inputData["gend"] = ""   // 性别  必填
+	inputData["brdy"] = ""   // 出生日期  必填
+	inputData["age"] = ""   // 年龄  必填
+	inputData["ntly"] = ""   // 国籍  必填
+	inputData["nwb_age"] = ""   // 年龄  必填
+	inputData["naty"] = ""   // 民族  必填
+	inputData["patn_cert_type"] = ""   // 患者证件类别  必填
+	inputData["certno"] = ""   // 证件号码  必填
+	inputData["prfs"] = ""   // 职业  必填
+	inputData["curr_addr"] = ""   // 现住址  必填
+	inputData["emp_name"] = ""   // 单位名称  必填
+	inputData["emp_addr"] = ""   // 单位地址  必填
+	inputData["emp_tel"] = ""   // 单位电话  必填
+	inputData["poscode"] = ""   // 邮编  必填
+	inputData["coner_name"] = ""   // 联系人姓名  必填
+	inputData["patn_rlts"] = ""   // 与患者关系  必填
+	inputData["coner_addr"] = ""   // 联系人地址  必填
+	inputData["coner_tel"] = ""   // 联系人电话  必填
+	inputData["hi_type"] = ""   // 医保类型  必填
+	inputData["insuplc"] = ""   // 参保地  必填
+	inputData["sp_psn_type"] = ""   // 特殊人员类型  必填
+	inputData["nwb_adm_type"] = ""   // 新生儿入院类型  必填
+	inputData["nwb_bir_wt"] = ""   // 新生儿出生体重  必填
+	inputData["nwb_adm_wt"] = ""   // 新生儿入院体重  必填
+	inputData["opsp_diag_caty"] = ""   // 门诊慢特病诊断  必填
+	inputData["opsp_mdtrt_date"] = ""   // 门诊慢特病就诊日期  必填
+	inputData["ipt_med_type"] = ""   // 住院医疗类型  必填
+	inputData["adm_way"] = ""   // 入院途径  必填
+	inputData["trt_type"] = ""   // 治疗类别  必填
+	inputData["adm_time"] = ""   // 入院时间  必填
+	inputData["adm_caty"] = ""   // 入院科别  必填
+	inputData["refldept_dept"] = ""   // 转科科别  必填
+	inputData["dscg_time"] = ""   // 出院时间  必填
+	inputData["dscg_caty"] = ""   // 出院科别  必填
+	inputData["act_ipt_days"] = ""   // 实际住院天数  必填
+	inputData["otp_wm_dise"] = ""   // 门（急） 诊西医诊断  必填
+	inputData["wm_dise_code"] = ""   // 门（急） 诊中医诊断  必填
+	inputData["otp_tcm_dise"] = ""   // 西医诊断疾病代码  必填
+	inputData["tcm_dise_code"] = ""   // 中医诊断代码  必填
+	inputData["oprn_oprt_code_cnt"] = ""   // 手术操作代码计数  必填
+	inputData["vent_used_dura"] = ""   // 呼吸机使用时长  必填
+	inputData["pwcry_bfadm_coma_dura"] = ""   // 颅脑损伤患者入院前昏迷时长  必填
+	inputData["pwcry_afadm_coma_dura"] = ""   // 颅脑损伤患者入院后昏迷时长  必填
+	inputData["bld_cat"] = ""   // 输血品种  必填
+	inputData["bld_amt"] = ""   // 输血量  必填
+	inputData["bld_unt"] = ""   // 输血计量单位  必填
+	inputData["spga_nurscare_days"] = ""   // 特级护理天数  必填
+	inputData["lv1_nurscare_days"] = ""   // 一级护理天数  必填
+	inputData["scd_nurscare_days"] = ""   // 二级护理天数  必填
+	inputData["lv3_nurscare_days"] = ""   // 三级护理天数  必填
+	inputData["acp_medins_name"] = ""   // 拟接收机构名称  必填
+	inputData["acp_optins_code"] = ""   // 拟接收机构代码  必填
+	inputData["bill_code"] = ""   // 票据代码  必填
+	inputData["bill_no"] = ""   // 票据号码  必填
+	inputData["biz_sn"] = ""   // 业务流水号  必填
+	inputData["days_rinp_flag_31"] = ""   // 出院 31 天内再住院计划标志  必填
+	inputData["days_rinp_pup_31"] = ""   // 出院 31 天内再住院目的  必填
+	inputData["chfpdr_name"] = ""   // 主诊医师姓名  必填
+	inputData["chfpdr_code"] = ""   // 主诊医师代码  必填
+	inputData["setl_begn_date"] = ""   // 结算开始日期  必填
+	inputData["setl_end_date"] = ""   // 结算结束日期  必填
+	inputData["psn_selfpay"] = ""   // 个人自付  必填
+	inputData["psn_ownpay"] = ""   // 个人自费  必填
+	inputData["acct_pay"] = ""   // 个人账户支出  必填
+	inputData["hi_paymtd"] = ""   // 医保支付方式  必填
+	inputData["hsorg"] = ""   // 医保机构  必填
+	inputData["hsorg_opter"] = ""   // 医保机构经办人  必填
+	inputData["medins_fill_dept"] = ""   // 医疗机构填报部门  必填
+	inputData["medins_fill_psn"] = ""   // 医疗机构填报人  必填
+
+	payinfo := make([]map[string]interface{},0)  // 基金支付信息
+	payinfotemp := make(map[string]interface{})
+	payinfotemp["fund_pay_type"] =  "" // 基金支付类型  必填
+	payinfotemp["fund_payamt"] = ""    // 基金支付金额
+	payinfo = append(payinfo,payinfotemp)
+
+	opspdiseinfo := make([]map[string]interface{},0) // 门诊慢特病诊断信息
+	opspdiseinfotemp := make(map[string]interface{})
+	opspdiseinfotemp["diag_name"] =  "" // 诊断名称  必填
+	opspdiseinfotemp["diag_code"] = ""    // 诊断代码 必填
+	opspdiseinfotemp["oprn_oprt_name"] = ""    // 手术操作名称 必填
+	opspdiseinfotemp["oprn_oprt_code"] = ""    // 手术操作代码 必填
+	opspdiseinfo = append(opspdiseinfo,opspdiseinfotemp)
+
+	diseinfo := make([]map[string]interface{},0) // 住院诊断信息
+	diseinfotemp := make(map[string]interface{})
+	diseinfotemp["diag_type"] =  "" // 诊断类别  必填
+	diseinfotemp["diag_code"] = ""    // 诊断代码 必填
+	diseinfotemp["diag_name"] = ""    // 诊断名称 必填
+	diseinfotemp["adm_cond_type"] = ""    // 入院病情类型 必填
+	diseinfo = append(diseinfo,diseinfotemp)
+
+	iteminfo := make([]map[string]interface{},0) // 住院诊断信息
+	iteminfotemp := make(map[string]interface{})
+	iteminfotemp["med_chrgitm"] =  "" // 医疗收费项目  必填
+	iteminfotemp["amt"] = ""    // 金额 必填
+	iteminfotemp["claa_sumfee"] = ""    // 甲类费用合计 必填
+	iteminfotemp["clab_amt"] = ""    // 乙类金额 必填
+	iteminfotemp["fulamt_ownpay_amt"] = ""    // 全自费金额 必填
+	iteminfotemp["oth_amt"] = ""    // 其他金额 必填
+	iteminfo = append(iteminfo,iteminfotemp)
+
+	oprninfo := make([]map[string]interface{},0) // 手术操作信息
+	oprninfotemp := make(map[string]interface{})
+	oprninfotemp["oprn_oprt_type"] =  "" // 手术操作类别  必填
+	oprninfotemp["oprn_oprt_name"] = ""    // 手术操作名称 必填
+	oprninfotemp["oprn_oprt_code"] = ""    // 手术操作代码 必填
+	oprninfotemp["oprn_oprt_date"] = ""    // 手术操作日期 必填
+	oprninfotemp["anst_way"] = ""    // 麻醉方式 必填
+	oprninfotemp["oper_dr_name"] = ""    // 术者医师姓名 必填
+	oprninfotemp["oper_dr_code"] = ""    // 术者医师代码 必填
+	oprninfotemp["anst_dr_name"] = ""    // 麻醉医师姓名 必填
+	oprninfotemp["anst_dr_code"] = ""    // 麻醉医师代码 必填
+	oprninfo = append(oprninfo,iteminfotemp)
+
+	icuinfo := make([]map[string]interface{},0) // 重症监护信息
+	icuinfotemp := make(map[string]interface{})
+	icuinfotemp["scs_cutd_ward_type"] =  "" // 重症监护病房类型  必填
+	icuinfotemp["scs_cutd_inpool_time"] = ""    // 重症监护进入时间 必填
+	icuinfotemp["scs_cutd_exit_time"] = ""    // 重症监护退出时间 必填
+	icuinfotemp["scs_cutd_sum_dura"] = ""    // 重症监护合计时长 必填
+	icuinfo = append(icuinfo,iteminfotemp)
+
+
+
+
+	input["setlinfo"] = inputData
+	input["payinfo"] = payinfo
+	input["opspdiseinfo"] = opspdiseinfo
+	input["diseinfo"] = diseinfo
+	input["iteminfo"] = iteminfo
+	input["oprninfo"] = oprninfo
+	input["icuinfo"] = icuinfo
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+
+	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	request.Header.Set("x-tif-paasid", "test_hosp")
+	request.Header.Set("x-tif-signature", signature)
+	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+	request.Header.Set("x-tif-nonce", nonce)
+
+	client := http.Client{}
+	resp, err := client.Do(request)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	str := string(respBytes)
+	fmt.Println(str)
+	return str
+}
+
 // 生成签名
 func setSignature(timestamp int64, nonce string) string {
 	str := strconv.FormatInt(timestamp, 10) + SceretKey + nonce + strconv.FormatInt(timestamp, 10)

service/patient_service.go

@@ -89,6 +89,12 @@ func GetPatientListByUpdateTime(orgID int64, syncTime int64, force int64) (patie
 	return
 }
 
+func GetPatientListBySchedules(orgID int64, syncTime int64) (patients []*models.SchedulePatients, total int64, err error) {
+	db := readDb.Model(&models.SchedulePatients{}).Where("user_org_id=?  AND  status=1  AND  schedule_date = ?", orgID,syncTime).Preload("Patient", "status = 1 AND user_org_id = ? ", orgID,)
+	err = db.Count(&total).Find(&patients).Error
+	return
+}
+
 func GetPatientListById(orgID int64, patientId int64) (patients models.PatientListForFace, err error) {
 	err = readDb.Model(&models.PatientListForFaceList{}).Where("user_org_id=? and id = ? and status=1", orgID, patientId).First(&patients).Error
 	return