Merge branch 'master' of http://git.shengws.com/csx/gdyb

service/gdyb_service.go

@@ -7,6 +7,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"gdyb/models"
+	"gdyb/utils"
 	"github.com/astaxie/beego"
 	"github.com/go-ole/go-ole"
 	"github.com/go-ole/go-ole/oleutil"
@@ -1994,7 +1995,7 @@ func Gdyb5203(baseParams models.BaseParams, businessParams models.BusinessParams
 	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
 
 	// 生成输入报文
-	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
+	inputMessage := SetInputMessageFour(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
 	inputMessage["infno"] = "5203" // 交易编码
@@ -4371,3 +4372,33 @@ func Gdyb1101D(certNo string, org_name string, doctor string, fixmedins_code str
 	}
 
 }
+
+func SetInputMessageFour(nonce string, timestamp int64, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) map[string]interface{} {
+	// 生成签名
+	//tempTime := time.Unix(timestamp, 0)
+	//timeFormat := tempTime.Format("20060102150405")
+	//timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
+	//randNum := rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000)
+
+	msec := time.Now().Format("000")
+
+	// 生成输入报文
+	inputMessage := make(map[string]interface{})
+	inputMessage["msgid"] = fixmedins_code + utils.GetNetTime() + msec + "0" // 发送方报文 ID
+	inputMessage["mdtrtarea_admvs"] = mdtrtarea_admvs                        // 就医地医保区划
+	inputMessage["insuplc_admdvs"] = insuplc_admdvs                          // 参保地医保区划
+	inputMessage["recer_sys_code"] = "1"                                     // 接收方系统代码
+	inputMessage["dev_no"] = ""                                              // 设备编号
+	inputMessage["dev_safe_info"] = ""                                       // 设备安全信息
+	inputMessage["cainfo"] = ""                                              // 数字签名信息
+	inputMessage["signtype"] = "SM3"                                         // 签名类型
+	inputMessage["infver"] = "V1.0"                                          // 接收方系统代码
+	inputMessage["opter_type"] = "1"                                         // 经办人类别
+	inputMessage["opter"] = doctor                                           // 经办人
+	inputMessage["opter_name"] = doctor                                      // 经办人姓名
+	inputMessage["inf_time"] = utils.GetNetTime()                            // 交易时间
+	inputMessage["fixmedins_code"] = fixmedins_code                          // 定点医药机构编号
+	inputMessage["fixmedins_name"] = org_name                                //定点医药机构名称
+	inputMessage["sign_no"] = ""                                             //交易签到流水号
+	return inputMessage
+}

utils/time_helper.go

@@ -1,9 +1,33 @@
 package utils
 
 import (
+	"encoding/binary"
+	"flag"
+	"log"
+	"net"
 	"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")
@@ -25,3 +49,33 @@ func MonthBeginningToEnd(year int, month int) (time.Time, time.Time) {
 	endOfMonth := beginningOfNextMonth.Add(time.Duration(-1))
 	return beginningOfMonth, endOfMonth
 }
+
+func GetNetTime() string {
+	var host string
+	flag.StringVar(&host, "e", "182.92.12.11:123", "NTP host")
+	flag.Parse()
+
+	conn, err := net.Dial("udp", host)
+	if err != nil {
+		log.Fatalf("failed to connect: %v", err)
+	}
+	defer conn.Close()
+	if err := conn.SetDeadline(time.Now().Add(15 * time.Second)); err != nil {
+		log.Fatalf("failed to set deadline: %v", err)
+	}
+
+	req := &packet{Settings: 0x1B}
+
+	if err := binary.Write(conn, binary.BigEndian, req); err != nil {
+		log.Fatalf("failed to send request: %v", err)
+	}
+
+	rsp := &packet{}
+	if err := binary.Read(conn, binary.BigEndian, rsp); err != nil {
+		log.Fatalf("failed to read server response: %v", err)
+	}
+	secs := float64(rsp.TxTimeSec) - ntpEpochOffset
+	nanos := (int64(rsp.TxTimeFrac) * 1e9) >> 32
+	showtime := time.Unix(int64(secs), nanos)
+	return time.Unix(showtime.Unix(), 0).Format("2006-01-02 15:04:05")
+}