gdyb/controllers/coordinate/coordinate_controller.go

package coordinate

import (
	"encoding/json"
	"fmt"
	"gdyb/controllers"
	"gdyb/enums"
	"gdyb/models"
	"gdyb/service"
	"gdyb/utils"
	"github.com/astaxie/beego"
	"math/rand"
	"os"
	"strconv"
	"strings"
	"time"
)

type ResultUpload struct {
	Code   string `json:"code"`
	Msg    string `json:"msg"`
	Result []struct {
		List            []interface{} `json:"list"`
		Page            int64         `json:"page"`
		Pagenumber      int64         `json:"pagenumber"`
		Records         int64         `json:"records"`
		RecordsFiltered int64         `json:"recordsFiltered"`
		RecordsTotal    int64         `json:"recordsTotal"`
		Result          string        `json:"result"`
		ResultMsg       string        `json:"resultMsg"`
		Total           int64         `json:"total"`
		TotalPage       int64         `json:"totalPage"`
		Userdata        string        `json:"userdata"`
		Code            string        `json:"code"`
	} `json:"result"`
}

type ResultQuery struct {
	Msg    string `json:"msg"`
	Result []struct {
		Type      string `json:"type"`
		Name      string `json:"name"`
		Vaa01     int    `json:"vaa01"`
		Vaa07     int    `json:"vaa07"`
		Visittime string `json:"visittime"`
	} `json:"result"`
	Code string `json:"code"`
}

type CoordinateController struct {
	controllers.BaseAuthAPIController
}

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

func CoordinateRegistRouters() {
	beego.Router("/coordinate/settleAccount", &CoordinateController{}, "get:SettleAccount")

}

func (c *CoordinateController) SettleAccount() {
	patient_id, _ := c.GetInt64("patient_id")
	record_date := c.GetString("record_date")
	admin_user_id, _ := c.GetInt64("admin_user_id")
	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 = 10340
	org, _ := service.GetOrgById(org_id)
	patient, _ := service.GetPatientByID(org.Id, patient_id)
	settle_accounts_type, _ := c.GetInt64("settle_accounts_type")

	result, request := service.GetHisPatientForCoordinate(patient.IdCardNo)
	saveLog(result, request, "查询", "查询", org.OrgName)
	var res ResultQuery
	if err := json.Unmarshal([]byte(result), &res); err != nil {
		utils.ErrorLog("解析失败：%v", err)
		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
		return
	}
	if res.Code == "10000" {
		if len(res.Result) == 0 {
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisPatientNoRegException)
			return
		}
		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
		}
		org_id := org.Id
		recordDateTime := theTime.Unix()
		patientPrescription, _ := service.FindPatientPrescriptionInfoTwo(org_id, patient.ID, recordDateTime, 2)
		if patientPrescription.ID == 0 {
			patientPrescription, _ = service.FindLastPatientPrescriptionInfoTwoTen(org_id, patient.ID, recordDateTime)
		}
		departmwnt, _ := service.GetDepartMentDetail(patientPrescription.Departments)
		doctor_info, _ := service.GetAdminUserInfoByID(org_id, patientPrescription.DoctorId)
		//admin_user_info, _ := service.GetAdminUserInfoByID(org_id, admin_user_id)

		var prescriptions []*models.HisPrescription

		if settle_accounts_type == 1 { //日结
			prescriptions, _ = service.GetUnSettleHisPrescriptionFiveTen(org_id, patient_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()
			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()
			prescriptions, _ = service.GetUnSettleMonthHisPrescription(org_id, patient_id, recordStartTime, recordEndTime)
		}
		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)
				}
			}

		}

		var ids []int64

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

		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.BaseDrugLib.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)
					}

				}
			}
		}

		var info models.UploadInfo
		info.Vaa01 = res.Result[0].Vaa01
		info.Fasong = "1"
		info.Vaa07 = res.Result[0].Vaa07
		info.Bck01c = departmwnt.Number
		info.Bce02a = doctor_info.DoctorNumber

		diagnosis_ids := strings.Split(patientPrescription.Diagnosis, ",")
		var config []*models.HisXtDiagnoseConfig
		for _, item := range diagnosis_ids {
			id, _ := strconv.ParseInt(item, 10, 64)
			diagnosisConfig, _ := service.FindDiagnoseById(id)
			config = append(config, &diagnosisConfig)
		}
		for index, item := range config {
			var diag models.Diag
			diag.Vao06 = strconv.FormatInt(int64(index+1), 10)
			diag.Bak02 = item.CountryCode
			info.Diag = append(info.Diag, &diag)
		}
		var presInfos []*models.PresInfo
		var presDetails []*models.PresDetail
		for index, item := range prescriptions {
			var presDetail models.PresDetail
			var presInfo models.PresInfo
			presInfo.Cbmid = strconv.FormatInt(item.ID, 10)
			if item.Type == 1 {
				presInfo.Cbm06 = "0"
			} else {
				presInfo.Cbm06 = "5"
			}

			if item.Type == 1 {
				presInfo.Cbm07 = item.MedType
			} else {
				presInfo.Cbm07 = item.MedType
			}

			presDetail.Vaf59 = strconv.FormatInt(int64(index+1), 10)
			var infoItems []*models.Item
			for index, subItem := range item.HisDoctorAdviceInfo {
				ef, _ := service.GetExecutionFrequencyByName(subItem.ExecutionFrequency, subItem.UserOrgId)

				var infoItem models.Item
				infoItem.Rownr = strconv.FormatInt(int64(index+1), 10)
				infoItem.Vaf11 = "2"
				infoItem.Vaf36 = time.Unix(subItem.ExecutionTime, 0).Format("2006-01-02 15:04:05")
				infoItem.Bbx01 = subItem.BaseDrugLib.MedicalInsuranceNumber
				infoItem.Bda01 = "1"
				infoItem.Bby01 = ""
				if subItem.BaseDrugLib.MinUnit != subItem.BaseDrugLib.DoseUnit {
					infoItem.Vaf22 = subItem.BaseDrugLib.DrugName + " " + subItem.BaseDrugLib.Dose + subItem.BaseDrugLib.DoseUnit + "*" + strconv.FormatInt(subItem.BaseDrugLib.MinNumber, 10) + subItem.BaseDrugLib.MinUnit + "/" + subItem.BaseDrugLib.MaxUnit
				}
				infoItem.Vaf14 = subItem.BaseDrugLib.DrugName
				infoItem.Bdi01 = ef.Code
				infoItem.Vaf17 = strconv.FormatInt(subItem.Day, 10)
				infoItem.Vaf20 = fmt.Sprintf("%.2f", subItem.SingleDose)
				infoItem.Vaf21 = fmt.Sprintf("%.2f", subItem.PrescribingNumber)
				infoItem.Vaf35 = "0"
				infoItem.Vaf32 = "0"
				infoItem.Bck01b = departmwnt.Number
				infoItem.Bck01d = departmwnt.Number
				infoItem.Vaf58 = "0"
				infoItem.Vaf61 = "1"
				infoItems = append(infoItems, &infoItem)
			}
			for _, subItem := range item.HisPrescriptionProject {
				//ef, _ := service.GetExecutionFrequencyByName(subItem.ExecutionFrequency, subItem.UserOrgId)

				if subItem.Type == 2 {
					if subItem.HisProject.CostClassify == 10 {
						var infoItem models.Item
						infoItem.Rownr = "0"
						infoItem.Vaf11 = "2"
						infoItem.Vaf36 = time.Unix(subItem.ExecutionTime, 0).Format("2006-01-02 15:04:05")
						infoItem.Bbx01 = subItem.HisProject.MedicalCode
						infoItem.Bda01 = "Z"
						infoItem.Bby01 = ""
						infoItem.Vaf14 = subItem.HisProject.ProjectName
						infoItem.Vaf15 = subItem.HisProject.ProjectName
						infoItem.Bdi01 = "160"
						infoItem.Vaf17 = subItem.Day
						infoItem.Vaf20 = subItem.SingleDose
						infoItem.Vaf21 = subItem.Count
						infoItem.Vaf35 = "0"
						infoItem.Vaf18 = 0
						infoItem.Vaf32 = "1"
						infoItem.Bck01b = departmwnt.Number
						infoItem.Bck01d = departmwnt.Number
						infoItem.Vaf58 = "0"
						infoItem.Vaf61 = "1"
						infoItems = append(infoItems, &infoItem)

					} else {

						var infoItem models.Item
						infoItem.Rownr = "0"
						infoItem.Vaf11 = "1"
						infoItem.Vaf36 = time.Unix(subItem.ExecutionTime, 0).Format("2006-01-02 15:04:05")
						infoItem.Bbx01 = subItem.HisProject.MedicalCode

						if subItem.HisProject.CostClassify == 2 {
							infoItem.Bda01 = "T"
						} else if subItem.HisProject.CostClassify == 3 {
							infoItem.Bda01 = "L"
						} else {
							infoItem.Bda01 = "T"
						}
						infoItem.Bby01 = ""
						infoItem.Vaf14 = subItem.HisProject.ProjectName

						infoItem.Bdi01 = "160"
						infoItem.Vaf17 = subItem.Day
						infoItem.Vaf20 = subItem.SingleDose
						infoItem.Vaf21 = subItem.Count
						infoItem.Vaf35 = "0"
						infoItem.Vaf18 = 0
						infoItem.Vaf32 = "0"
						infoItem.Bck01b = departmwnt.Number
						infoItem.Bck01d = departmwnt.Number
						infoItem.Vaf58 = "0"
						infoItem.Vaf61 = "1"
						infoItems = append(infoItems, &infoItem)

					}

				} else {
					var infoItem models.Item
					infoItem.Rownr = "0"
					infoItem.Vaf11 = "1"
					infoItem.Vaf36 = time.Unix(subItem.ExecutionTime, 0).Format("2006-01-02 15:04:05")
					infoItem.Bbx01 = subItem.GoodInfo.MedicalInsuranceNumber
					infoItem.Bda01 = "M"
					infoItem.Bby01 = ""
					infoItem.Vaf14 = subItem.GoodInfo.GoodName + " " + subItem.GoodInfo.SpecificationName
					infoItem.Bdi01 = "160"
					infoItem.Vaf17 = subItem.Day
					infoItem.Vaf20 = subItem.SingleDose
					infoItem.Vaf21 = subItem.Count
					infoItem.Vaf35 = "0"
					infoItem.Vaf32 = "0"
					infoItem.Bck01b = departmwnt.Number
					infoItem.Bck01d = departmwnt.Number
					infoItem.Vaf58 = "0"
					infoItem.Vaf61 = "1"
					infoItems = append(infoItems, &infoItem)

				}

			}
			presDetail.Item = infoItems
			presDetails = append(presDetails, &presDetail)
			presInfo.PresDetail = presDetails
			presInfos = append(presInfos, &presInfo)
		}
		info.PresInfo = presInfos
		var result2 string
		var request2 string
		if res.Result[0].Type == "1" {
			result2, request2 = service.UploadPrescriptionForCoordinate(info)
		} else {
			result2, request2 = service.UploadPrescriptionForCoordinateHospital(info)
		}
		saveLog(result2, request2, "上传明细", "上传明细", org.OrgName)

		var res2 ResultUpload
		if err := json.Unmarshal([]byte(result2), &res2); err != nil {
			utils.ErrorLog("解析失败：%v", err)
			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
			return
		}
		if res2.Code == "10000" && len(res2.Result) > 0 && res2.Result[0].Code != "500" && len(res2.Result[0].List) > 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:                  strconv.FormatInt(int64(res.Result[0].Vaa01), 10),
				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:                 strconv.FormatInt(int64(res.Result[0].Vaa07), 10),
				PhoneNumber:            patient.Phone,
			}
			service.UpdateHisPatientStatusTwo(&his)
			service.UpdateHisPrescriptionHisID(his.ID, patient.ID, recordDateTime, org_id)
			tm := time.Unix(time.Now().Unix(), 0)

			order := &models.HisOrder{
				PsnNo:              his.PsnNo,
				UserOrgId:          org_id,
				HisPatientId:       his.ID,
				PatientId:          patient_id,
				SettleAccountsDate: recordDateTime,
				Ctime:              time.Now().Unix(),
				Mtime:              time.Now().Unix(),
				Status:             1,
				OrderStatus:        1,
				MdtrtId:            his.Number,
				Number:             ipt_otp_no,
				SetlId:             "",
				MedfeeSumamt:       total,
				MedType:            strconv.Itoa(int(reg_type)),
				SettleEndTime:      0,
				SettleStartTime:    0,
				SettleType:         settle_accounts_type,
				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:        patient_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.UpdataHisPateintTwoTen(&his)
			err = service.UpDatePrescriptionNumber(org_id, ids, order.Number)
			err = service.UpDateHisPrescriptionInfoNumberTen(org_id, patient_id, order.Number, recordDateTime, his.ID)
			err = service.UpdataOrderStatusThreeTen(strconv.FormatInt(int64(chrgBchno), 10), org_id)

			c.ServeSuccessJSON(map[string]interface{}{
				"msg": "医嘱保存成功",
			})

		} else {
			c.ServeSuccessJSON(map[string]interface{}{
				"failed_code": -10,
				"msg":         res2.Msg + "----" + res2.Result[0].ResultMsg,
			})

		}

	} else {
		c.ServeSuccessJSON(map[string]interface{}{
			"failed_code": -10,
			"msg":         res.Msg,
		})

	}

}

type Charset string

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("记录日志"))
		}
	}

}