XT_New/controllers/coordinate_controller.go

package controllers

import (
	"XT_New/enums"
	"XT_New/models"
	"XT_New/service"
	"XT_New/utils"
	"encoding/json"
	"fmt"
	"github.com/astaxie/beego"
	"io/ioutil"
	"math/rand"
	"strconv"
	"strings"
	"time"
)

type CoordinateController struct {
	BaseAPIController
}

type ResultReg struct {
	ResultCode string `json:"resultCode"`
	ResultDesc string `json:"resultDesc"`
	InfoSeq    string `json:"infoSeq"`
}

type ResultSettle struct {
	ResultCode string `json:"resultCode"`
	ResultDesc string `json:"resultDesc"`
	DocId      string `json:"docId"`
	Amount     string `json:"amount"`
}

type ResultCancelSettle struct {
	ResultCode string `json:"resultCode"`
	ResultDesc string `json:"resultDesc"`
}

type Settle struct {
	PatientId string `json:"resultCode"`
	DocId     string `json:"docId"`
	InfoSeq   string `json:"infoSeq"`
}

type Refund struct {
	PatientId string `json:"resultCode"`
	DocId     string `json:"docId"`
	InfoSeq   string `json:"infoSeq"`
}

type RefundDetail struct {
	Msg    string `json:"msg"`
	Result []struct {
		ResultMsg string `json:"resultMsg"`
		Code      string `json:"code"`
		Records   int    `json:"records"`
		TotalPage int    `json:"totalPage"`
		List      []struct {
			Zae01 int64 `json:"ZAE01"`
		} `json:"list"`
		RecordsTotal  int    `json:"recordsTotal"`
		Pagenumber    int    `json:"pagenumber"`
		Result        string `json:"result"`
		Total         int    `json:"total"`
		RecordsFtered int    `json:"recordsFtered"`
		Page          int    `json:"page"`
	} `json:"result"`
	Code string `json:"code"`
}

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")
	//坐标撤销记账
	beego.Router("/coordinate/opCancelKeepAccounts", &CoordinateController{}, "get:OpCancelKeepAccounts")
	//坐标结算回调
	beego.Router("/coordinate/settle", &CoordinateController{}, "post:Settle")
	//坐标退费回调
	beego.Router("/coordinate/refund", &CoordinateController{}, "post:Refund")

}

func (c *CoordinateController) Settle() {
	//参数1 patient_id
	//参数2 就诊号
	//参数3 单据id
	fmt.Println(c.Ctx.Request.Body)

	body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
	fmt.Println(string(body))

	var respJSON map[string]interface{}
	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
		return
	}
	patien_id := respJSON["patientid"].(string)
	infoSeq := respJSON["infoseq"].(string)
	docId := respJSON["docid"].(string)
	fmt.Println(patien_id)
	fmt.Println(infoSeq)
	fmt.Println(docId)

	order, _ := service.GetHisOrderFour(patien_id, infoSeq, "")
	order.SetlId = docId
	if order.ID == 0 {
		json := make(map[string]interface{})
		json["msg"] = "结算记录不存在，请检查参数是否正确"
		json["code"] = "-1"
		c.Data["json"] = json
		c.ServeJSON()
		return
	}
	order.OrderStatus = 2
	service.UpDateOrder(order)
	service.UpdataOrderStatusTwo(order.Number, order.UserOrgId)
	json := make(map[string]interface{})
	json["msg"] = "结算成功"
	json["code"] = "0"
	c.Data["json"] = json
	c.ServeJSON()
	return
}
func (c *CoordinateController) Refund() {
	//参数1 patient_id
	//参数2 就诊号
	//参数3 单据id
	body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
	var respJSON map[string]interface{}
	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
		return
	}
	patien_id := respJSON["patientid"].(string)
	infoSeq := respJSON["infoseq"].(string)
	docId := respJSON["docid"].(string)
	order, _ := service.GetHisOrderFour(patien_id, infoSeq, docId)
	if order.ID == 0 {
		json := make(map[string]interface{})
		json["msg"] = "结算记录不存在，请检查参数是否正确"
		json["code"] = "-1"
		c.Data["json"] = json
		c.ServeJSON()
		return
	}
	service.UpdataOrderStatus(order.ID, order.Number, order.UserOrgId)
	json := make(map[string]interface{})
	json["msg"] = "退费成功"
	json["code"] = "0"
	c.Data["json"] = json
	c.ServeJSON()
	return
}

func (c *CoordinateController) SavePatientMessageInfo() {
	result, request_log := service.SavePatientMessageInfo()
	fmt.Println(result)
	fmt.Println(request_log)

}

func (c *CoordinateController) Register() {
	patient_id, _ := c.GetInt64("patient_id")
	diagnosis_time := c.GetString("diagnosis_time")
	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)

	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_date+" 00:00:00", loc)
	if err != nil {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		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)

	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:  "测试",
		IdCardNo:    patient.IdCardNo,
	}

	result, request_log := service.SaveReg(reg)
	fmt.Println(result)
	fmt.Println(request_log)

	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 res.ResultCode == "0" {
		timestamp := time.Now().Unix()
		tempTime := time.Unix(timestamp, 0)
		timeFormat := tempTime.Format("20060102150405")
		chrgBchno := rand.Intn(100000) + 10000
		ipt_otp_no := timeFormat + strconv.FormatInt(int64(chrgBchno), 10) + strconv.FormatInt(patient.ID, 10)
		his := models.VMHisPatient{
			Name:                   patient.Name,
			Gender:                 patient.Gender,
			Birthday:               patient.Birthday,
			MedicalTreatmentType:   0,
			IdType:                 1,
			IdCardNo:               patient.IdCardNo,
			BalanceAccountsType:    1,
			MedicalInsuranceNumber: "",
			RegisterType:           0,
			RegisterCost:           0,
			TreatmentCost:          0,
			Status:                 1,
			Ctime:                  time.Now().Unix(),
			Mtime:                  time.Now().Unix(),
			PsnNo:                  patient.ZbPatientId,
			PsnCertType:            "",
			Certno:                 patient.IdCardNo,
			PsnName:                patient.Name,
			Gend:                   "",
			Naty:                   "",
			Brdy:                   "",
			Age:                    0,
			Iinfo:                  "",
			Idetinfo:               "",
			PatientId:              patient.ID,
			RecordDate:             theTime.Unix(),
			UserOrgId:              org_id,
			AdminUserId:            admin_user_id,
			IsReturn:               1,
			Doctor:                 patientPrescription.DoctorId,
			Departments:            patientPrescription.Departments,
			IptOtpNo:               ipt_otp_no,
			Number:                 res.InfoSeq,
			PhoneNumber:            patient.Phone,
		}
		service.UpdateHisPatientStatus(&his)
		service.UpdateHisPrescriptionHisID(his.ID, patient.ID, recordDateTime, org_id)
		c.ServeSuccessJSON(map[string]interface{}{
			"his_info": his,
		})
	} else {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeRegisterTwoException)
		return
	}
}

//func (c *CoordinateController) GetWaitPayDetail() {
//	result, request_log := service.GetWaitPayDetail()
//	fmt.Println(result)
//	fmt.Println(request_log)
//
//}

func (c *CoordinateController) OpKeepAccounts() {
	id, _ := c.GetInt64("id")
	record_time := c.GetString("record_time")
	his_patient_id, _ := c.GetInt64("his_patient_id")
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	settle_accounts_type, _ := c.GetInt64("settle_accounts_type")
	fapiao_code := c.GetString("fapiao_code")
	fapiao_number := c.GetString("fapiao_number")
	diagnosis_id := c.GetString("diagnosis")
	sick_type, _ := c.GetInt64("sick_type")
	reg_type, _ := c.GetInt64("p_type")
	org_id, _ := c.GetInt64("org_id")
	org_id = 4
	his, _ := service.GetHisPatientByIdThree(his_patient_id)

	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
	if err != nil {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	recordDateTime := theTime.Unix()
	//adminUser := c.GetAdminUserInfo()
	var prescriptions []*models.HisPrescription
	var start_time int64
	var end_time int64

	//ids_str := c.GetString("ids")
	//ids_arr := strings.Split(ids_str, ",")

	if settle_accounts_type == 1 { //日结
		//fmt.Println(reg_type)
		prescriptions, _ = service.GetUnSettleHisPrescriptionFive(org_id, id, recordDateTime, 2)

	} else { //月结

		start_time_str := c.GetString("start_time")
		end_time_str := c.GetString("end_time")
		timeLayout := "2006-01-02"
		loc, _ := time.LoadLocation("Local")
		theStartTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time_str+" 00:00:00", loc)
		if err != nil {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
			return
		}
		recordStartTime := theStartTime.Unix()
		start_time = recordStartTime
		theEndTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time_str+" 00:00:00", loc)
		if err != nil {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
			return
		}
		recordEndTime := theEndTime.Unix()
		end_time = recordEndTime
		prescriptions, _ = service.GetUnSettleMonthHisPrescription(org_id, id, recordStartTime, recordEndTime)
	}

	timestamp := time.Now().Unix()
	tempTime := time.Unix(timestamp, 0)
	timeFormat := tempTime.Format("20060102150405")
	chrgBchno := rand.Intn(100000) + 10000
	chrg_bchno := timeFormat + strconv.FormatInt(int64(chrgBchno), 10) + strconv.FormatInt(his.PatientId, 10)
	strconv.FormatInt(his.PatientId, 10)

	var ids []int64

	for _, item := range prescriptions {
		ids = append(ids, item.ID)
	}
	var total float64

	for _, item := range prescriptions {
		fmt.Println(item)
		if item.Type == 1 { //药品
			for _, subItem := range item.HisDoctorAdviceInfo {
				total = total + (subItem.Price * subItem.PrescribingNumber)
			}
		}
		if item.Type == 2 { //项目
			for _, subItem := range item.HisPrescriptionProject {
				cnt, _ := strconv.ParseFloat(subItem.Count, 64)
				total = total + (subItem.Price * cnt)
			}
		}

		for _, subItem := range item.HisAdditionalCharge {
			total = total + (subItem.Price * float64(subItem.Count))
		}
	}

	tm := time.Unix(time.Now().Unix(), 0)

	var customs []*models.NewCustomTwo
	for _, item := range prescriptions {
		if item.Type == 1 { //药品
			for _, subItem := range item.HisDoctorAdviceInfo {
				cus := &models.NewCustomTwo{
					AdviceId:         subItem.ID,
					ProjectId:        0,
					DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*subItem.PrescribingNumber),
					Cut:              fmt.Sprintf("%.4f", subItem.PrescribingNumber),
					FeedetlSn:        subItem.FeedetlSn,
					Price:            fmt.Sprintf("%.2f", subItem.Price),
					MedListCodg:      subItem.Drug.MedicalInsuranceNumber,
					Type:             1,
				}
				customs = append(customs, cus)
			}
		}
		if item.Type == 2 { //项目
			for _, subItem := range item.HisPrescriptionProject {
				if subItem.Type == 2 {
					cnt, _ := strconv.ParseFloat(subItem.Count, 64)
					cus := &models.NewCustomTwo{
						AdviceId:         0,
						ProjectId:        subItem.ID,
						DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
						Cut:              fmt.Sprintf("%.4f", cnt),
						FeedetlSn:        subItem.FeedetlSn,
						Price:            fmt.Sprintf("%.4f", float64(subItem.Price)),
						MedListCodg:      subItem.HisProject.MedicalCode,
						Type:             2,
					}
					customs = append(customs, cus)

				} else {
					cnt, _ := strconv.ParseFloat(subItem.Count, 64)
					cus := &models.NewCustomTwo{
						AdviceId:         0,
						ProjectId:        subItem.ID,
						DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
						Cut:              fmt.Sprintf("%.4f", cnt),
						FeedetlSn:        subItem.FeedetlSn,
						Price:            fmt.Sprintf("%.4f", float64(subItem.Price)),
						MedListCodg:      subItem.GoodInfo.MedicalInsuranceNumber,
						Type:             3,
					}
					customs = append(customs, cus)

				}

			}
		}
		for _, item := range item.HisAdditionalCharge {
			cus := &models.NewCustomTwo{
				ItemId:           item.ID,
				AdviceId:         0,
				ProjectId:        0,
				DetItemFeeSumamt: fmt.Sprintf("%.4f", item.Price),
				Cut:              fmt.Sprintf("%.4f", float64(item.Count)),
				FeedetlSn:        item.FeedetlSn,
				Price:            fmt.Sprintf("%.4f", float64(item.Price)),
				MedListCodg:      item.XtHisAddtionConfig.Code,
				Type:             3,
			}
			customs = append(customs, cus)
		}
	}
	result, request_log := service.OpKeepAccounts(his.Number, customs)

	fmt.Println(result)
	fmt.Println(request_log)

	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 res.ResultCode == "0" {
		//allTotal := fmt.Sprintf("%.4f", total)
		totals, _ := strconv.ParseFloat(res.Amount, 64)
		order := &models.HisOrder{
			PsnNo:              his.PsnNo,
			UserOrgId:          org_id,
			HisPatientId:       his.ID,
			PatientId:          id,
			SettleAccountsDate: recordDateTime,
			Ctime:              time.Now().Unix(),
			Mtime:              time.Now().Unix(),
			Status:             1,
			OrderStatus:        1,
			MdtrtId:            his.Number,
			Number:             chrg_bchno,
			SetlId:             res.DocId,
			MedfeeSumamt:       totals,
			MedType:            strconv.Itoa(int(reg_type)),
			SettleEndTime:      end_time,
			SettleStartTime:    start_time,
			SettleType:         settle_accounts_type,
			FaPiaoCode:         fapiao_code,
			FaPiaoNumber:       fapiao_number,
			Diagnosis:          diagnosis_id,
			PType:              2,
			SetlTime:           tm.Format("2006-01-02 15:04:05"),
		}
		err = service.CreateOrder(order)
		if err != nil {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateOrderException)
			return
		}

		for _, item := range customs {
			var advice_id int64 = 0
			var project_id int64 = 0
			var item_id int64 = 0

			var types int64 = 0

			if item.Type == 1 {
				advice_id = item.AdviceId
				project_id = 0
				item_id = 0
			} else if item.Type == 2 {
				advice_id = 0
				item_id = 0

				project_id = item.ProjectId
			} else if item.Type == 3 {
				advice_id = 0
				item_id = item.ItemId
				project_id = 0
			}
			detItemFeeSumamt, _ := strconv.ParseFloat(item.DetItemFeeSumamt, 32)
			cut, _ := strconv.ParseFloat(item.Cut, 32)
			pric, _ := strconv.ParseFloat(item.Price, 32)
			info := &models.HisOrderInfo{
				OrderNumber:      order.Number,
				UploadDate:       time.Now().Unix(),
				AdviceId:         advice_id,
				DetItemFeeSumamt: detItemFeeSumamt,
				Cnt:              cut,
				Pric:             pric,
				PatientId:        id,
				Status:           1,
				Mtime:            time.Now().Unix(),
				Ctime:            time.Now().Unix(),
				UserOrgId:        org_id,
				HisPatientId:     his.ID,
				OrderId:          order.ID,
				ProjectId:        project_id,
				Type:             types,
				ItemId:           item_id,
			}
			service.CreateOrderInfo(info)
		}
		his.Diagnosis = diagnosis_id
		his.SickType = sick_type
		his.RegisterType = reg_type
		his.MedicalTreatmentType = reg_type
		service.UpdataHisPateint(&his)
		err = service.UpDatePrescriptionNumber(org_id, ids, chrg_bchno)
		err = service.UpDateHisPrescriptionInfoNumber(org_id, id, chrg_bchno, recordDateTime, his_patient_id)
		err = service.UpdataOrderStatusThree(chrg_bchno, org_id)
		if err == nil {
			c.ServeSuccessJSON(map[string]interface{}{
				"msg": "记账成功",
			})
		}
	}

}

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
	order, _ := service.GetHisOrderByID(order_id)
	if order.ID == 0 {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrderParamWrong)
		return
	}

	role, _ := service.GetAdminUserInfoByID(org_id, admin_user_id)
	result, request_log := service.OpCancelKeepAccounts(order.SetlId, role.UserName, role.DoctorNumber)

	var res RefundDetail
	if err := json.Unmarshal([]byte(result), &res); err != nil {
		utils.ErrorLog("解析失败：%v", err)
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
	fmt.Println(result)
	fmt.Println(request_log)
	fmt.Println(res)
	flag := 0
	isSuccess := false
	for _, item := range res.Result {
		if item.Code == "200" {
			flag = flag + 1
		}
	}
	if len(res.Result) == flag {
		isSuccess = true
	}

	if isSuccess {
		err := service.UpdataOrderStatus(order_id, order.Number, org_id)
		if err == nil {
			c.ServeSuccessJSON(map[string]interface{}{
				"msg": "撤销记账成功",
			})
		} else {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}
	} else {
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
}

//func saveLog(result string, request string, infno string, desc string) {
//
//	org_id, _ := beego.AppConfig.Int64("org_id")
//	miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
//	dir := miConfig.OrgName + "日志"
//	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 := strconv.FormatInt(org_id, 10) + "_" + year + month + day + "_log"
//	file_name := file + ".txt"
//	file_path := miConfig.OrgName + "日志" + "/" + 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(miConfig.OrgName + "日志" + "/" + file_name)
//		defer f.Close()
//		if err != nil {
//		} else {
//			_, err = f.Write([]byte("记录日志"))
//		}
//	}
//
//}

type Charset string

const (
	UTF8    = Charset("UTF-8")
	GB18030 = Charset("GB18030")
)