医保对接

controllers/coordinate_controller.go

@@ -10,6 +10,7 @@ import (
 	"github.com/astaxie/beego"
 	"io/ioutil"
 	"math/rand"
+	"os"
 	"strconv"
 	"strings"
 	"time"
@@ -28,8 +29,6 @@ type ResultReg struct {
 type ResultSettle struct {
 	ResultCode string `json:"resultCode"`
 	ResultDesc string `json:"resultDesc"`
-	DocId      string `json:"docId"`
-	Amount     string `json:"amount"`
 }
 
 type ResultCancelSettle struct {
@@ -73,7 +72,6 @@ func CoordinateRcegistRouters() {
 	beego.Router("/coordinate/check", &CoordinateController{}, "get:SavePatientMessageInfo")
 	//坐标挂号
 	beego.Router("/coordinate/register", &CoordinateController{}, "get:Register")
-	//beego.Router("/coordinate/getWaitPayDetail", &CoordinateController{}, "get:GetWaitPayDetail")
 	//坐标记账
 	beego.Router("/coordinate/opKeepAccounts", &CoordinateController{}, "get:OpKeepAccounts")
 	//坐标撤销记账
@@ -170,8 +168,8 @@ func (c *CoordinateController) Register() {
 	record_date := c.GetString("record_date")
 	admin_user_id, _ := c.GetInt64("admin_user_id")
 	org_id, _ := c.GetInt64("org_id")
-	org_id = 4
 	patient, _ := service.GetPatientByID(org_id, patient_id)
+	org, _ := service.GetOrgById(org_id)
 
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
@@ -180,40 +178,40 @@ func (c *CoordinateController) Register() {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	if len(patient.ZbPatientId) == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorPsnNoEmpty)
+		return
+	}
+
 	recordDateTime := theTime.Unix()
 	patientPrescription, _ := service.FindPatientPrescriptionInfoTwo(org_id, patient.ID, recordDateTime, 2)
 	if patientPrescription.ID == 0 {
 		patientPrescription, _ = service.FindLastPatientPrescriptionInfo(org_id, patient.ID, recordDateTime)
 	}
-	//department, _ := service.GetDepartMentDetail(patientPrescription.Departments)
 	doctor_info, _ := service.GetAdminUserInfoByID(org_id, patientPrescription.DoctorId)
-
-	//admin_user_info, _ := service.GetAdminUserInfoByID(org_id, admin_user_id)
-
+	admin_user_info, _ := service.GetAdminUserInfoByID(org_id, admin_user_id)
 	reg := models.Reg{
 		DeptId:      "0112",
 		PatientId:   patient.ZbPatientId,
 		PatientName: patient.Name,
 		DoctorId:    doctor_info.DoctorNumber,
 		RegDate:     strings.Split(diagnosis_time, " ")[0],
-		RegFee:      "8",
-		TreatFee:    "10",
-		OperatorId:  "测试",
+		RegFee:      "0",
+		TreatFee:    "0",
+		OperatorId:  admin_user_info.UserName,
 		IdCardNo:    patient.IdCardNo,
 	}
 
 	result, request_log := service.SaveReg(reg)
 	fmt.Println(result)
 	fmt.Println(request_log)
-
+	saveLog(result, request_log, "登记", "登记", org.OrgName)
 	var res ResultReg
-	//if err := json.Unmarshal([]byte(result), &res); err != nil {
-	//	utils.ErrorLog("解析失败：%v", err)
-	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-	//	return
-	//}
-	res.ResultCode = "0"
-	res.InfoSeq = "122333"
+	if err := json.Unmarshal([]byte(result), &res); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
 	if res.ResultCode == "0" {
 		timestamp := time.Now().Unix()
 		tempTime := time.Unix(timestamp, 0)
@@ -262,8 +260,12 @@ func (c *CoordinateController) Register() {
 			"his_info": his,
 		})
 	} else {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeRegisterTwoException)
-		return
+
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ResultDesc,
+		})
+
 	}
 }
 
@@ -287,7 +289,8 @@ func (c *CoordinateController) OpKeepAccounts() {
 	sick_type, _ := c.GetInt64("sick_type")
 	reg_type, _ := c.GetInt64("p_type")
 	org_id, _ := c.GetInt64("org_id")
-	org_id = 4
+	org, _ := service.GetOrgById(org_id)
+
 	his, _ := service.GetHisPatientByIdThree(his_patient_id)
 
 	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
@@ -433,22 +436,17 @@ func (c *CoordinateController) OpKeepAccounts() {
 		}
 	}
 	result, request_log := service.OpKeepAccounts(his.Number, customs)
-
-	fmt.Println(result)
-	fmt.Println(request_log)
+	saveLog(result, request_log, "记账", "记账", org.OrgName)
 
 	var res ResultSettle
-	res.ResultCode = "0"
-	res.DocId = "708275799870021632"
-	res.Amount = "1088.00"
-	//if err := json.Unmarshal([]byte(result), &res); err != nil {
-	//	utils.ErrorLog("解析失败：%v", err)
-	//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-	//	return
-	//}
+	if err := json.Unmarshal([]byte(result), &res); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
 	if res.ResultCode == "0" {
-		//allTotal := fmt.Sprintf("%.4f", total)
-		totals, _ := strconv.ParseFloat(res.Amount, 64)
+
+		//totals, _ := strconv.ParseFloat(total, 64)
 		order := &models.HisOrder{
 			PsnNo:              his.PsnNo,
 			UserOrgId:          org_id,
@@ -461,8 +459,8 @@ func (c *CoordinateController) OpKeepAccounts() {
 			OrderStatus:        1,
 			MdtrtId:            his.Number,
 			Number:             chrg_bchno,
-			SetlId:             res.DocId,
-			MedfeeSumamt:       totals,
+			SetlId:             "",
+			MedfeeSumamt:       total,
 			MedType:            strconv.Itoa(int(reg_type)),
 			SettleEndTime:      end_time,
 			SettleStartTime:    start_time,
@@ -536,6 +534,11 @@ func (c *CoordinateController) OpKeepAccounts() {
 				"msg": "记账成功",
 			})
 		}
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ResultDesc,
+		})
 	}
 
 }
@@ -544,7 +547,8 @@ func (c *CoordinateController) OpCancelKeepAccounts() {
 	order_id, _ := c.GetInt64("order_id")
 	admin_user_id, _ := c.GetInt64("admin_user_id")
 	org_id, _ := c.GetInt64("org_id")
-	org_id = 4
+	org, _ := service.GetOrgById(org_id)
+
 	order, _ := service.GetHisOrderByID(order_id)
 	if order.ID == 0 {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrderParamWrong)
@@ -553,7 +557,7 @@ func (c *CoordinateController) OpCancelKeepAccounts() {
 
 	role, _ := service.GetAdminUserInfoByID(org_id, admin_user_id)
 	result, request_log := service.OpCancelKeepAccounts(order.SetlId, role.UserName, role.DoctorNumber)
-
+	saveLog(result, request_log, "撤销记账", "撤销记账", org.OrgName)
 	var res RefundDetail
 	if err := json.Unmarshal([]byte(result), &res); err != nil {
 		utils.ErrorLog("解析失败：%v", err)
@@ -573,6 +577,10 @@ func (c *CoordinateController) OpCancelKeepAccounts() {
 	if len(res.Result) == flag {
 		isSuccess = true
 	}
+	var errMsg string
+	for _, item := range res.Result {
+		errMsg = errMsg + "\n" + item.ResultMsg
+	}
 
 	if isSuccess {
 		err := service.UpdataOrderStatus(order_id, order.Number, org_id)
@@ -585,8 +593,11 @@ func (c *CoordinateController) OpCancelKeepAccounts() {
 			return
 		}
 	} else {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         errMsg,
+		})
+
 	}
 }
 
@@ -638,3 +649,45 @@ const (
 	UTF8    = Charset("UTF-8")
 	GB18030 = Charset("GB18030")
 )
+
+func saveLog(result string, request string, infno string, desc string, org_name string) {
+
+	//org_id, _ := beego.AppConfig.Int64("org_id")
+	//miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
+	dir := org_name + "日志"
+	utils.Mkdir(dir)
+	month := time.Unix(1557042972, 0).Format("1")
+	year := time.Now().Format("2006")
+	month = time.Now().Format("01")
+	day := time.Now().Format("02")
+	hour := time.Now().Format("15")
+	min := time.Now().Format("04")
+	sec := time.Now().Format("05")
+
+	result_time := year + "-" + month + "-" + day + " " + hour + ":" + min + ":" + sec
+
+	file := org_name + "_" + year + month + day + "_log"
+	file_name := file + ".txt"
+	file_path := org_name + "日志" + "/" + file_name
+	exist, _ := utils.PathExists(file_path)
+	if exist { //存在
+		fmt.Println("存在")
+		f, err := os.OpenFile(file_path, os.O_WRONLY, 0644)
+		if err != nil {
+			fmt.Println("read fail")
+		}
+		content := "\r\n" + "\r\n" + "\r\n" + result_time + " " + "【 " + desc + infno + "入参" + " 】：" + "\r\n" + request + "\r\n" + result_time + " " + "【 " + desc + infno + "出参" + " 】：" + "\r\n" + result
+		n, _ := f.Seek(0, 2)
+		_, err = f.WriteAt([]byte(content), n)
+
+	} else { //不存在
+		fmt.Println("文件不存在，创建文件")
+		f, err := os.Create(org_name + "日志" + "/" + file_name)
+		defer f.Close()
+		if err != nil {
+		} else {
+			_, err = f.Write([]byte("记录日志"))
+		}
+	}
+
+}

controllers/his_api_controller.go

@@ -4547,40 +4547,9 @@ func (c *HisApiController) GetUploadInfo() {
 	reg_type, _ := c.GetInt64("p_type")
 	order_id, _ := c.GetInt64("order_id")
 
-	dec_way := c.GetString("dec_way") //是否使用押金支付bool类型
-	tmp_decimal := c.GetString("tmp_decimal")
-	var decimal float64 //本次使用的押金
-	var errmsg error
-	tx := service.XTWriteDB().Begin() //开了事务
-	//只检测扣费函数SpendDeposit有没有返回错误，如果有则回滚所有以TX结尾的方法（去掉TX即为原先的方法）
-	defer func() {
-		if errmsg != nil {
-			utils.ErrorLog("事务失败,原因为: %v", errmsg.Error())
-			tx.Rollback()
-		} else {
-			tx.Commit()
-		}
-	}()
-	if dec_way == "true" && tmp_decimal == "0" && tmp_decimal == "" {
-		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金不能为0")
-		return
-	}
-	if len(tmp_decimal) > 0 {
-		if tmp_decimal[0] == 45 {
-			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金不能为负数")
-			return
-		}
-	}
-	tt, errs := strconv.ParseFloat(tmp_decimal, 64)
-	if errs != nil {
-		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金金额错误")
-		return
-	}
-	decimal = tt
-
-	his, _ := service.GetHisPatientByIdThreeTX(his_patient_id, tx)
+	his, _ := service.GetHisPatientByIdThree(his_patient_id)
 
-	tempOrder, _ := service.GetHisOrderByIDTX(order_id, tx)
+	tempOrder, _ := service.GetHisOrderByID(order_id)
 
 	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
 	if err != nil {
@@ -4601,9 +4570,9 @@ func (c *HisApiController) GetUploadInfo() {
 
 			if reg_type == 11 || reg_type == 1111 || reg_type == 1112 {
 
-				prescriptions, _ = service.GetPrescriptionByIdsTX(ids_arr, adminUser.CurrentOrgId, tx)
+				prescriptions, _ = service.GetPrescriptionByIds(ids_arr, adminUser.CurrentOrgId)
 			} else {
-				prescriptions, _ = service.GetSettleHisPrescriptionTX(adminUser.CurrentOrgId, id, his_patient_id, recordDateTime, reg_type, tx)
+				prescriptions, _ = service.GetSettleHisPrescription(adminUser.CurrentOrgId, id, his_patient_id, recordDateTime, reg_type)
 			}
 		} else { //月结
 
@@ -4625,8 +4594,9 @@ func (c *HisApiController) GetUploadInfo() {
 			}
 			recordEndTime := theEndTime.Unix()
 			end_time = recordEndTime
-			prescriptions, _ = service.GetMonthHisPrescriptionTX(adminUser.CurrentOrgId, id, recordStartTime, recordEndTime, reg_type, tx)
+			prescriptions, _ = service.GetMonthHisPrescription(adminUser.CurrentOrgId, id, recordStartTime, recordEndTime, reg_type)
 		}
+
 		timestamp := time.Now().Unix()
 		tempTime := time.Unix(timestamp, 0)
 		timeFormat := tempTime.Format("20060102150405")
@@ -4668,7 +4638,7 @@ func (c *HisApiController) GetUploadInfo() {
 
 		allTotal := fmt.Sprintf("%.4f", total)
 		totals, _ := strconv.ParseFloat(allTotal, 64)
-		order := &models.HisOrder{ //
+		order := &models.HisOrder{
 			UserOrgId:             adminUser.CurrentOrgId,
 			HisPatientId:          his.ID,
 			PatientId:             id,
@@ -4698,9 +4668,8 @@ func (c *HisApiController) GetUploadInfo() {
 			Diagnosis:             diagnosis_id,
 			PType:                 2,
 			SetlTime:              tm.Format("2006-01-02 15:04:05"),
-			Decimal:               decimal,
 		}
-		err = service.CreateOrderTX(order, tx)
+		err = service.CreateOrder(order)
 		if err != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateOrderException)
 			return
@@ -4796,28 +4765,16 @@ func (c *HisApiController) GetUploadInfo() {
 				Type:             types,
 				ItemId:           item_id,
 			}
-			service.CreateOrderInfoTX(info, tx)
+			service.CreateOrderInfo(info)
 		}
 		his.Diagnosis = diagnosis_id
 		his.SickType = sick_type
 		his.RegisterType = reg_type
 		his.MedicalTreatmentType = reg_type
-		service.UpdataHisPateintTX(&his, tx)
-		err = service.UpDatePrescriptionNumberTX(adminUser.CurrentOrgId, ids, chrg_bchno, tx)
-		err = service.UpDateHisPrescriptionInfoNumberTX(adminUser.CurrentOrgId, id, chrg_bchno, recordDateTime, his_patient_id, tx)
-		err = service.UpdataOrderStatusTwoTX(chrg_bchno, adminUser.CurrentOrgId, tx)
-		//判断是否使用了押金
-		if dec_way == "true" {
-
-			tmpstring := strconv.FormatInt(order.ID, 10)
-			//扣押金
-			errmsg = service.SpendDeposit(c.GetAdminUserInfo().CurrentOrgId, id, c.GetAdminUserInfo().AdminUser.Id, tmpstring, decimal)
-			if errmsg != nil {
-				c.ServeFailJsonSend(enums.ErrorCodeParamWrong, errmsg.Error())
-				//c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateOrderException)
-				return
-			}
-		}
+		service.UpdataHisPateint(&his)
+		err = service.UpDatePrescriptionNumber(adminUser.CurrentOrgId, ids, chrg_bchno)
+		err = service.UpDateHisPrescriptionInfoNumber(adminUser.CurrentOrgId, id, chrg_bchno, recordDateTime, his_patient_id)
+		err = service.UpdataOrderStatusTwo(chrg_bchno, adminUser.CurrentOrgId)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"msg": "结算成功",
@@ -4862,21 +4819,15 @@ func (c *HisApiController) Refund() {
 	order_id, _ := c.GetInt64("order_id")
 	order, _ := service.GetHisOrderByID(order_id)
 	adminUser := c.GetAdminUserInfo()
-	orgid := c.GetAdminUserInfo().CurrentOrgId
 	err := service.UpdataOrderStatus(order_id, order.Number, adminUser.CurrentOrgId)
-	if err != nil {
-		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
-	tmp := strconv.FormatInt(order.ID, 10)
-	err = service.MoneyIncrease(orgid, order.HisPatientId, tmp, order.Decimal)
-	if err != nil {
+	if err == nil {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "退费成功",
+		})
+	} else {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
-	c.ServeSuccessJSON(map[string]interface{}{
-		"msg": "退费成功",
-	})
 }
 
 func (c *HisApiController) RefundNumber() {
@@ -5257,15 +5208,17 @@ func (c *HisApiController) GetAllOrderDetail() {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrderParamWrong)
 		return
 	}
+	record, _ := service.GetInHospitalRecordByNumber(order.MdtrtId)
 	org_id := c.GetAdminUserInfo().CurrentOrgId
 	adminInfo, _ := service.GetAdminUserInfoByID(org_id, order.Creator)
 	patient, _ := service.GetPatientByID(org_id, order.PatientId)
 	order_info, _ := service.GetHisOrderDetailByNumber(order.Number, org_id)
 	c.ServeSuccessJSON(map[string]interface{}{
-		"order":      order,
-		"order_info": order_info,
-		"patient":    patient,
-		"admin_info": adminInfo,
+		"order":           order,
+		"order_info":      order_info,
+		"patient":         patient,
+		"admin_info":      adminInfo,
+		"hospital_record": record,
 	})
 	return
 

controllers/his_project_api_controller.go

@@ -1240,6 +1240,10 @@ func (this *HisProjectApiController) GetDoctorAdvicePrint() {
 	//hisPatient, _ := service.GetHisPatientById(patient_id)
 	hisHospitalRecord, _ := service.GetLastHospitalRecordTwo(patient_id, adminUserInfo.CurrentOrgId)
 
+	//psn_info, _ := service.GetPsnInfo(patient_id)
+
+	psn_info, _ := service.GetPsnByPatientId(patient_id)
+
 	eles, _ := service.GetNewAdminUserES(adminUserInfo.CurrentOrgId)
 
 	if err != nil {
@@ -1254,6 +1258,7 @@ func (this *HisProjectApiController) GetDoctorAdvicePrint() {
 		"hisHospitalRecord": hisHospitalRecord,
 		"info":              prescriptionInfo,
 		"eles":              eles,
+		"psn_info":          psn_info,
 	})
 }
 

enums/error_code.go

@@ -245,6 +245,8 @@ const ( // ErrorCode
 	ErrorCodeHospitalExistDataException = 300010
 
 	ErrorCodeRecordFailedException = 300011
+
+	ErrorPsnNoEmpty = 310000
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -480,6 +482,8 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeRecordFailedException: "记录不存在",
 
 	ErrorCodeStockExced: "请先出库,执行失败",
+
+	ErrorPsnNoEmpty: "人员编码不能为空",
 }
 
 type SGJError struct {

service/his_hospital_service.go

@@ -548,3 +548,8 @@ func UpdataHospitalOrderStatusTwo(number string, user_org_id int64) (err error)
 	return
 
 }
+
+func GetPsnByPatientId(patient_id int64) (psn models.HisPsn, err error) {
+	err = readDb.Model(&models.HisPsn{}).Where("patient_id = ?", patient_id).Last(&psn).Error
+	return
+}

service/his_project_service.go

@@ -755,7 +755,7 @@ func GetHisPatientByIdThreeTX(id int64, tx *gorm.DB) (models.HisPatient, error)
 }
 
 func GetLastHisPatient(patient_id int64, org_id int64) (his models.HisPatient, err error) {
-	err = XTReadDB().Model(&models.HisPatient{}).Where("user_org_id = ? AND patient_id = ? and status = 1 AND patient_info <> ''", org_id, patient_id).First(&his).Error
+	err = XTReadDB().Model(&models.HisPatient{}).Where("user_org_id = ? AND patient_id = ? and status = 1 and patient_info <> ''", org_id, patient_id).First(&his).Error
 	return
 }
 

utils/log.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	"fmt"
+	"os"
 	"time"
 )
 
@@ -64,3 +65,34 @@ func magenta(s string) string {
 func formatLog(prefix string) string {
 	return time.Now().Format("[2006/01/02 15:04:05]") + " " + prefix + " "
 }
+
+func Mkdir(dir string) {
+	// 创建文件夹
+	exist, err := PathExists(dir)
+	if err != nil {
+		fmt.Println(err.Error())
+	} else {
+		if exist {
+			fmt.Println(dir + "文件夹已存在！")
+		} else {
+			// 文件夹名称，权限
+			err := os.Mkdir(dir, os.ModePerm)
+			if err != nil {
+				fmt.Println(dir+"文件夹创建失败：", err.Error())
+			} else {
+				fmt.Println(dir + "文件夹创建成功！")
+			}
+		}
+	}
+}
+
+func PathExists(path string) (bool, error) {
+	_, err := os.Stat(path)
+	if err == nil {
+		return true, nil
+	}
+	if os.IsNotExist(err) {
+		return false, nil
+	}
+	return false, err
+}

utils/time_helper.go

@@ -4,6 +4,26 @@ import (
 	"time"
 )
 
+const ntpEpochOffset = 2208988800
+
+type packet struct {
+	Settings       uint8
+	Stratum        uint8
+	Poll           int8
+	Precision      int8
+	RootDelay      uint32
+	RootDispersion uint32
+	ReferenceID    uint32
+	RefTimeSec     uint32
+	RefTimeFrac    uint32
+	OrigTimeSec    uint32
+	OrigTimeFrac   uint32
+	RxTimeSec      uint32
+	RxTimeFrac     uint32
+	TxTimeSec      uint32
+	TxTimeFrac     uint32
+}
+
 // day 当天凌晨0点
 func ZeroHourTimeOfDay(day time.Time) time.Time {
 	dayStr := day.Format("2006-01-02")