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

conf/app.conf

@@ -45,7 +45,7 @@ appsecret="61ee2e6268497d5aa9de0b0187c39aea"
 
 
 [prod]
-org_id = 10215
+org_id = 10188
 mobile_token_expiration_second = 86400
 httpdomain = https://api.xt.kuyicloud.com
 sso_domain = https://sso.kuyicloud.com
@@ -67,7 +67,7 @@ gdyb_url = "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/"
 #深圳
 # gdyb_paasid = "sz_prd_yjyy"
 #肇庆
- gdyb_paasid = "zq_prd_yjyy"
+#  gdyb_paasid = "zq_prd_yjyy"
 
 
 

controllers/sg/his_api_controller.go

@@ -8914,8 +8914,8 @@ func (c *HisApiController) GetSettleAccounts() {
 		} else {
 			//result2 := service.Gdyb1101()
 
-			result2 := service.Gdyb5204(baseParams, businessParams)
-			saveLog(result2, "", "5204", "查询")
+			//result2 := service.Gdyb5204(baseParams, businessParams)
+			//saveLog(result2, "", "5204", "查询")
 			result := service.Gdyb5203(baseParams, businessParams)
 			var dat map[string]interface{}
 			if err := json.Unmarshal([]byte(result), &dat); err == nil {

controllers/zh/zh_his_api_controller.go

@@ -10,12 +10,16 @@ import (
 	"gdyb/utils"
 	"github.com/astaxie/beego"
 	"github.com/axgle/mahonia"
+	"github.com/jinzhu/gorm"
 	"math"
 	"math/rand"
 	"os"
+	"regexp"
 	"strconv"
 	"strings"
+	"syscall"
 	"time"
+	"unsafe"
 )
 
 type ZHHisApiController struct {
@@ -471,6 +475,7 @@ func ZHHisManagerApiRegistRouters() {
 	beego.Router("/zh/api/refund", &ZHHisApiController{}, "get:ZHRefund")
 	beego.Router("/zh/api/refunddetail", &ZHHisApiController{}, "get:ZHRefundDetail")
 	beego.Router("/zh/api/patient/info", &ZHHisApiController{}, "get:GetZHPatientInfo")
+	beego.Router("/zh/api/readcard", &ZHHisApiController{}, "get:ReadCard")
 
 }
 func (c *ZHHisApiController) GetZHPatientInfo() {
@@ -2408,3 +2413,318 @@ func ConvertToString(src string, srcCode string, tagCode string) string {
 	result := string(cdata)
 	return result
 }
+
+type ELeData struct {
+	Data struct {
+		IdNo        string `json:"idNo"`
+		IdType      string `json:"idType"`
+		UserName    string `json:"userName"`
+		EcToken     string `json:"ecToken"`
+		InsuOrg     string `json:"insuOrg"`
+		Gender      string `json:"gender"`
+		Birthday    string `json:"birthday"`
+		Nationality string `json:"nationality"`
+		Email       string `json:"email"`
+		Extra       string `json:"extra"`
+	} `json:"data"`
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+}
+
+func (c *ZHHisApiController) ReadCard() {
+	id_card_type, _ := c.GetInt64("id_card_type")
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+	certificates, _ := c.GetInt64("certificates")
+	fmt.Println(c.GetAdminUserInfo().CurrentOrgId)
+	roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+
+	switch id_card_type {
+	case 1:
+		if initFlag == 0 {
+			c.TestGetBasBaseInit()
+		}
+		basStr := c.GetBasBaseInfo(miConfig.Code, miConfig.MdtrtareaAdmvs, roles.UserName, roles.ID, miConfig.OrgName)
+		if len(basStr) == 0 {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
+			return
+		}
+		fmt.Println(basStr)
+		bas := strings.Split(basStr, "|")
+		basNumber := bas[1]
+		fmt.Println(basNumber)
+		card_sn := bas[3]
+		fmt.Println(card_sn)
+		result := service.Gdyb1101B(basNumber, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, card_sn, certificates)
+		var dat map[string]interface{}
+		if err := json.Unmarshal([]byte(result), &dat); err == nil {
+			fmt.Println(dat)
+		} else {
+			fmt.Println(err)
+		}
+
+		userJSONBytes, _ := json.Marshal(dat)
+		var res ResultTwo
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+
+		if res.Infcode == 0 {
+			patient, err := service.GetPatientByNumber(basNumber, c.GetAdminUserInfo().CurrentOrgId)
+			if err == gorm.ErrRecordNotFound {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+				return
+			} else if err != nil {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+				return
+
+			} else {
+				c.ServeSuccessJSON(map[string]interface{}{
+					"patient": patient,
+					"number":  basNumber,
+				})
+			}
+		} else {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+			return
+		}
+		break
+	case 2:
+		SFZStr := c.GetSFZBaseInfo()
+		id_card_str := strings.Split(SFZStr, "^")
+		id_card_number := id_card_str[0]
+		card_sn := ""
+		result := service.Gdyb1101B(id_card_number, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, card_sn, certificates)
+		var dat map[string]interface{}
+		if err := json.Unmarshal([]byte(result), &dat); err == nil {
+			fmt.Println(dat)
+		} else {
+			fmt.Println(err)
+		}
+
+		userJSONBytes, _ := json.Marshal(dat)
+		var res ResultTwo
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+
+		if res.Infcode == 0 {
+			patient, err := service.GetPatientByNumber(id_card_number, c.GetAdminUserInfo().CurrentOrgId)
+			if err == gorm.ErrRecordNotFound {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+				return
+			} else if err != nil {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+				return
+
+			} else {
+				c.ServeSuccessJSON(map[string]interface{}{
+					"patient": patient,
+					"number":  id_card_number,
+				})
+			}
+		} else {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+			return
+		}
+
+		break
+	case 3:
+		_, pBusiCardInfo := c.GetELeInfo(miConfig.Code, strconv.FormatInt(roles.ID, 64), roles.UserName)
+
+		var ele ELeData
+		err := json.Unmarshal([]byte(pBusiCardInfo), &ele)
+		if err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+		}
+		token := ele.Data.EcToken
+		if len(token) > 0 {
+			result, _ := service.Gdyb1101B(org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IdNo)
+			var dat map[string]interface{}
+			if err := json.Unmarshal([]byte(result), &dat); err == nil {
+				fmt.Println(dat)
+			} else {
+				fmt.Println(err)
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status": "0",
+				//"card_info":      pCardInfo,
+				"busi_card_info": pBusiCardInfo,
+				"token":          token,
+				"result":         dat,
+				"type":           "2",
+			})
+		} else {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"status": "-1",
+			})
+
+		}
+		break
+	}
+
+}
+
+var initFlag int64 = 0
+
+func (c *ZHHisApiController) TestGetBasBaseInit() {
+	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
+	Iinit := DllDef.MustFindProc("Init")
+	//miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	str := make([]byte, 2048)
+	inputData := make(map[string]interface{})
+	inputData["IP"] = "10.144.211.75"
+	inputData["PORT"] = "7021"
+	inputData["TIMEOUT"] = "180"
+	inputData["LOG_PATH"] = "C:\\log\\"
+
+	bytesData, _ := json.Marshal(inputData)
+	fmt.Println(inputData)
+	fmt.Println(bytesData)
+
+	ret, _, err := Iinit.Call((uintptr)(unsafe.Pointer(&bytesData[0])), (uintptr)(unsafe.Pointer(&str[0])))
+	if ret != 0 {
+		fmt.Println("SSCard的报错原因:", err)
+		fmt.Println("SSCard的运算结果为:", ret)
+		fmt.Println("SSCard的返回结果为:", string(str))
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
+		return
+	}
+	fmt.Println("SSCard的返回结果为:", string(str))
+
+	result := int(ret)
+	fmt.Println("SSCard的运算结果为1:", result)
+	//initFlag = 1
+	return
+}
+
+func (c *ZHHisApiController) GetSFZBaseInfo() string {
+	DllDef := syscall.MustLoadDLL("SSCard.dll")
+	readCard := DllDef.MustFindProc("ReadSFZ")
+	if readCard == nil {
+		fmt.Println("readcard is nil")
+		readCard = DllDef.MustFindProc("ReadSFZ")
+	}
+
+	str := make([]byte, 256)
+	str1 := make([]byte, 256)
+	r, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&str[0])), IntPtr(1024), (uintptr)(unsafe.Pointer(&str1[0])), IntPtr(1024))
+
+	fmt.Println(r)
+	return string(str)
+}
+
+func (c *ZHHisApiController) GetBasBaseInfo(fixmedins_code string, mdtrtarea_admvs string, opter_name string, opter_id string, fixmedins_name string) string {
+	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
+	readCard := DllDef.MustFindProc("ReadCardBas")
+	fmt.Println(readCard)
+	fmt.Println("!!!!!")
+
+	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")
+
+	msec := time.Now().Format("000")
+	timestamp := time.Now().Unix()
+
+	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)
+
+	inputData := make(map[string]interface{})
+	inputData["infno"] = "1199"
+	//inputData["msgid"] = "7021"
+	inputData["msgid"] = fixmedins_code + year + month + day + hour + min + sec + msec + "0" // 发送方报文 ID
+	inputData["mdtrtarea_admvs"] = mdtrtarea_admvs                                           // 发送方报文 ID
+	inputData["recer_sys_code"] = "01"
+	inputData["infver"] = "V1.0"
+	inputData["opter_type"] = "1"
+	inputData["opter"] = opter_id
+	inputData["opter_name"] = opter_name
+	inputData["inf_time"] = timeFormatOne
+	inputData["fixmedins_code"] = fixmedins_code
+	inputData["fixmedins_name"] = fixmedins_name
+
+	inputData["dev_no"] = ""
+	inputData["dev_safe_info"] = ""
+	inputData["cainfo"] = ""
+	inputData["signtype"] = ""
+	inputData["sign_no"] = ""
+
+	bytesData, _ := json.Marshal(inputData)
+	pBusiCardInfo := make([]byte, 8192)
+	ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&bytesData[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
+	fmt.Println(ret2)
+	fmt.Println(DeleteExtraSpace(string(pBusiCardInfo)))
+	fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
+	if ret2 != 0 {
+		return ""
+	}
+	return DeleteExtraSpace(string(pBusiCardInfo))
+}
+
+func DeleteExtraSpace(s string) string {
+	//删除字符串中的多余空格，有多个空格时，仅保留一个空格
+	s1 := strings.Replace(s, "  ", " ", -1)      //替换tab为空格
+	regstr := "\\s{2,}"                          //两个及两个以上空格的正则表达式
+	reg, _ := regexp.Compile(regstr)             //编译正则表达式
+	s2 := make([]byte, len(s1))                  //定义字符数组切片
+	copy(s2, s1)                                 //将字符串复制到切片
+	spc_index := reg.FindStringIndex(string(s2)) //在字符串中搜索
+	for len(spc_index) > 0 {                     //找到适配项
+		s2 = append(s2[:spc_index[0]+1], s2[spc_index[1]:]...) //删除多余空格
+		spc_index = reg.FindStringIndex(string(s2))            //继续在字符串中搜索
+	}
+	return string(s2)
+}
+
+func (c *ZHHisApiController) GetELeInfo(code string, operator_id string, operator_name string) (string, string) {
+	DllDef := syscall.MustLoadDLL("NationECCode.dll")
+	readCard := DllDef.MustFindProc("NationEcTrans")
+	fmt.Println(readCard)
+	fmt.Println("!!!!!")
+	pBusiCardInfo := make([]byte, 8192)
+	inputData := make(map[string]interface{})
+	inputData["orgId"] = code
+	inputData["businessType"] = "01101"
+	inputData["operatorId"] = operator_id
+	inputData["operatorName"] = operator_name
+	inputData["officeId"] = "001"
+	inputData["officeName"] = "血透室"
+	inputData["deviceType"] = ""
+	bytesData, _ := json.Marshal(inputData)
+	url := "http://localcfc/api/hsecfc/localQrCodeQuery"
+	ret2, _, _ := readCard.Call(StrPtr(url), StrPtr(string(bytesData)), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
+	fmt.Println(ret2)
+	fmt.Println(DeleteExtraSpace(string(pBusiCardInfo)))
+	fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
+	if ret2 != 0 {
+		return "", ""
+	}
+	return DeleteExtraSpace(""), DeleteExtraSpace(string(pBusiCardInfo))
+}
+
+func StrPtr(s string) uintptr {
+	return uintptr(unsafe.Pointer(syscall.StringBytePtr(s)))
+}
+
+func Remove0000(s string) string {
+	str := make([]rune, 0, len(s))
+	for _, v := range []rune(s) {
+		if v == 0 {
+			continue
+		}
+		str = append(str, v)
+	}
+	return string(str)
+}

main.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"gdyb/models"
 	_ "gdyb/routers"
-	"gdyb/service"
+	//"gdyb/service"
 	"github.com/astaxie/beego"
 	"github.com/qiniu/api.v7/auth/qbox"
 	"github.com/qiniu/api.v7/storage"
@@ -15,12 +15,12 @@ import (
 )
 
 func init() {
-	service.ConnectDB()
-	org_id, _ := beego.AppConfig.Int64("org_id")
-
-	miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
-	CreateLog(miConfig)
-	UploadLog(miConfig)
+	//service.ConnectDB()
+	//org_id, _ := beego.AppConfig.Int64("org_id")
+	//
+	//miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
+	//CreateLog(miConfig)
+	//UploadLog(miConfig)
 
 	//UploadSettleList(org_id)
 }

service/gdyb_service.go

@@ -4381,7 +4381,7 @@ func SetInputMessageFour(nonce string, timestamp int64, org_name string, doctor
 	//randNum := rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000)
 
 	msec := time.Now().Format("000")
-
+	fmt.Println(utils.GetNetTime())
 	// 生成输入报文
 	inputMessage := make(map[string]interface{})
 	inputMessage["msgid"] = fixmedins_code + utils.GetNetTime() + msec + "0" // 发送方报文 ID

service/jsyb_service.go

@@ -637,9 +637,9 @@ func Jsyb2205(psnNo string, mdtrtId string, chrgBchno string, org_name string, d
 	inputData := make(map[string]interface{})
 	inputMessage["infno"] = "2205" // 交易编码
 
-	inputData["mdtrt_id"] = mdtrtId     // 就诊 ID（来自2201接口返回）
-	inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
-	inputData["psn_no"] = psnNo         // 人员编号 （来自1101接口返回）
+	inputData["mdtrt_id"] = mdtrtId  // 就诊 ID（来自2201接口返回）
+	inputData["chrg_bchno"] = "0000" // 收费批次号(来自2204生成的)
+	inputData["psn_no"] = psnNo      // 人员编号 （来自1101接口返回）
 
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入