Merge branch '20211122' of http://git.shengws.com/csx/XT_New into 20211122

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

@@ -548,7 +548,7 @@ func (c *HisApiController) GetHisPatientList() {
 	recordDateTime := theTime.Unix()
 	adminInfo := c.GetAdminUserInfo()
 	//patients, _ := service.GetHisPatientList(adminInfo.CurrentOrgId, "", recordDateTime)
-	patients, _ := service.GetNewHisPatientList(adminInfo.CurrentOrgId, recordDateTime)
+	patients, _ := service.GetNewHisPatientList(adminInfo.CurrentOrgId, recordDateTime, sch_type)
 	patients_two, _ := service.GetScheduleHisPatientList(adminInfo.CurrentOrgId, "", recordDateTime, sch_type)
 	//获取当前用户的信息
 	adminUserInfo, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, adminInfo.AdminUser.Id)
@@ -4602,9 +4602,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 { //月结
 
@@ -4626,8 +4626,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")
@@ -4669,7 +4670,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,
@@ -4699,9 +4700,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
@@ -5261,15 +5261,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
 
@@ -6147,9 +6149,17 @@ func (c *HisApiController) GetFaPiaoData() {
 				chineseTraditionalMedicineCostSelfTotal = chineseTraditionalMedicineCostTotal
 			}
 
-			if item.MedChrgitmType == "0" || item.MedChrgitmType == "12" { //其他费
-				otherCostTotal, _ = decimal.NewFromFloat(otherCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
-				otherCostSelfTotal = otherCostTotal
+			if c.GetAdminUserInfo().CurrentOrgId == 10106 {
+				if item.MedChrgitmType == "0" || item.MedChrgitmType == "12" || item.MedChrgitmType == "02" { //其他费
+					otherCostTotal, _ = decimal.NewFromFloat(otherCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+					otherCostSelfTotal = otherCostTotal
+				}
+			} else {
+				if item.MedChrgitmType == "0" || item.MedChrgitmType == "12" { //其他费
+					otherCostTotal, _ = decimal.NewFromFloat(otherCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+					otherCostSelfTotal = otherCostTotal
+				}
+
 			}
 
 		}

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 {

models/his_hospital_models.go

@@ -77,6 +77,7 @@ type HisHospitalCheckRecord struct {
 	Phone                string           `gorm:"column:phone" json:"phone" form:"phone"`
 	HisHospitalOrder     HisHospitalOrder `gorm:"ForeignKey:MdtrtId,PatientId;AssociationForeignKey:Number,PatientId" json:"order"`
 	BalanceAccountsType  int64            `gorm:"column:balance_accounts_type" json:"balance_accounts_type" form:"balance_accounts_type"`
+	InsuplcAdmdvs        string           `gorm:"column:insuplc_admdvs" json:"insuplc_admdvs" form:"insuplc_admdvs"`
 }
 
 func (HisHospitalCheckRecord) TableName() string {
@@ -212,3 +213,25 @@ type HisHospitalOrderInfo struct {
 func (HisHospitalOrderInfo) TableName() string {
 	return "his_order_info"
 }
+
+type HisPsn struct {
+	ID           int64   `gorm:"column:id" json:"id" form:"id"`
+	PsnNo        string  `gorm:"column:psn_no" json:"psn_no" form:"psn_no"`
+	Age          float64 `gorm:"column:age" json:"age" form:"age"`
+	PatientId    int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Certno       string  `gorm:"column:certno" json:"certno" form:"certno"`
+	Brdy         string  `gorm:"column:brdy" json:"brdy" form:"brdy"`
+	Gend         string  `gorm:"column:gend" json:"gend" form:"gend"`
+	Naty         string  `gorm:"column:naty" json:"naty" form:"naty"`
+	PsnCertType  string  `gorm:"column:psn_cert_type" json:"psn_cert_type" form:"psn_cert_type"`
+	PsnName      string  `gorm:"column:psn_name" json:"psn_name" form:"psn_name"`
+	Idetinfo     string  `gorm:"column:idetinfo" json:"idetinfo" form:"idetinfo"`
+	Insuinfo     string  `gorm:"column:insuinfo" json:"insuinfo" form:"insuinfo"`
+	UserOrgId    int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	CardInfo     string  `gorm:"column:card_info" json:"card_info" form:"card_info"`
+	VerifyNumber string  `gorm:"column:verify_number" json:"verify_number" form:"verify_number"`
+}
+
+func (HisPsn) TableName() string {
+	return "his_psn"
+}

service/his_hospital_service.go

@@ -552,3 +552,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
 }
 

service/his_service.go

@@ -260,9 +260,12 @@ func (HisPrescriptionTwo) TableName() string {
 	return "his_prescription"
 }
 
-func GetNewHisPatientList(org_id int64, record_date int64) (patients []*PatientTwo, err error) {
+func GetNewHisPatientList(org_id int64, record_date int64, sch_type int64) (patients []*PatientTwo, err error) {
 	db := readDb.Model(&PatientTwo{}).Where("xt_patients.user_org_id = ? AND xt_patients.status = 1", org_id).
 		Joins("join his_patient as hp ON hp.patient_id = xt_patients.id AND hp.record_date = ? AND hp.status = 1 AND hp.user_org_id = ?", record_date, org_id)
+	if sch_type > 0 {
+		db = db.Joins("join xt_schedule as sch ON sch.patient_id = xt_patients.id AND sch.schedule_date = ? AND sch.status = 1 AND sch.user_org_id = ? AND schedule_type = ?", record_date, org_id, sch_type)
+	}
 	db = db.Preload("HisPatient", func(db *gorm.DB) *gorm.DB {
 		return db.Preload("HisPrescriptionTwo", "status = 1 AND user_org_id = ?  AND record_date = ?", org_id, record_date).Where("user_org_id = ? AND status = 1 AND record_date = ?", org_id, record_date)
 	})
@@ -1208,10 +1211,9 @@ func UpdataOrderStatus(id int64, number string, user_org_id int64) (err error) {
 
 func UpdataHospitalOrderStatus(id int64, number string, user_org_id int64, log string, result string) (err error) {
 	err = writeDb.Model(&models.HisOrder{}).Where("status = 1 AND id = ? AND user_org_id = ?", id, user_org_id).Updates(map[string]interface{}{"order_status": 3, "mtime": time.Now().Unix(), "refund_request_log": log, "refund_log": result, "status": 0}).Error
-	err = writeDb.Model(&models.HisPrescription{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"order_status": 1, "mtime": time.Now().Unix()}).Error
-	err = writeDb.Model(&models.HisPrescriptionInfo{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"prescription_status": 1, "mtime": time.Now().Unix()}).Error
+	err = writeDb.Model(&models.HisPrescription{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"order_status": 4, "mtime": time.Now().Unix()}).Error
+	err = writeDb.Model(&models.HisPrescriptionInfo{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"prescription_status": 4, "mtime": time.Now().Unix()}).Error
 	return
-
 }
 
 func UpdataOrderInfoStatus(id int64, number string, user_org_id int64) {

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")