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

controllers/js/jsyb_controller.go

@@ -4,11 +4,15 @@ import (
 	"encoding/json"
 	"fmt"
 	"gdyb/controllers"
+	"gdyb/enums"
 	"gdyb/models"
 	"gdyb/service"
 	"gdyb/utils"
 	"github.com/astaxie/beego"
+	"github.com/axgle/mahonia"
 	"io/ioutil"
+	"syscall"
+	"unsafe"
 )
 
 type JSybController struct {
@@ -26,7 +30,7 @@ func JSybRegistRouters() {
 	beego.Router("/jsyb/2207", &JSybController{}, "get:PostEight")
 	beego.Router("/jsyb/2208", &JSybController{}, "get:PostNine")
 	beego.Router("/jsyb/5203", &JSybController{}, "get:PostTen")
-	//beego.Router("/jsyb/readcard", &JSybController{}, "get:ReadCard")
+	beego.Router("/jsyb/readcard", &JSybController{}, "get:ReadCard")
 
 }
 
@@ -462,29 +466,96 @@ func (c *JSybController) PostTen() {
 	})
 }
 
-//var initFlag int64 = 0
-
-//func (c *JSybController) ReadCard() {
-//	if initFlag == 0 {
-//		c.TestGetBasBaseInit()
-//	}
-//}
-//
-//func (c *JSybController) TestGetBasBaseInit() {
-//	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
-//	Iinit := DllDef.MustFindProc("Init")
-//	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
-//
-//	ret, _, err := Iinit.Call(StrPtr("http://igb.hsa.gdgov.cn/gdyb_api/prd/api/card/initDll"), StrPtr(miConfig.InsuplcAdmdvs))
-//	if ret != 0 {
-//		fmt.Println("SSCard的报错原因:", err)
-//		fmt.Println("SSCard的运算结果为:", ret)
-//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
-//		return
-//	}
-//
-//	result := int(ret)
-//	fmt.Println("SSCard的运算结果为1:", result)
-//	initFlag = 1
-//	return
-//}
+var initFlag int64 = 0
+
+func (c *JSybController) ReadCard() {
+	fixmedins_code := c.GetString("fixmedins_code")
+	secret_key := c.GetString("secret_key")
+	ak := c.GetString("ak")
+
+	if initFlag == 0 {
+		c.TestGetBasBaseInit(fixmedins_code, secret_key, ak)
+	}
+	basStr := c.GetBasBaseInfo()
+	fmt.Println(basStr)
+
+}
+
+func (c *JSybController) TestGetBasBaseInit(code string, secret_key string, ak string) {
+	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
+	Iinit := DllDef.MustFindProc("Init")
+	//miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	str := make([]byte, 1024)
+
+	inputData := make(map[string]interface{})
+
+	inputData["IP"] = "10.72.3.87"
+	inputData["PORT"] = "8086"
+	inputData["TIMEOUT"] = "180"
+	inputData["LOG_PATH"] = "C:\\log\\"
+	inputData["EC_URL"] = "http://10.72.42.210:10081/localcfc/api/hsecfc/localQrCodeQuery"
+	inputData["CARD_PASSTYPE"] = "1"
+	inputData["API_NAME"] = "hssServives"
+	inputData["API_VERSION"] = "1.0.0"
+	inputData["ACCESS_KEY"] = ak
+	inputData["SECRETKEY"] = secret_key
+	inputData["ORG_ID"] = code
+	inputData["EXT"] = ""
+	bytesData, _ := json.Marshal(inputData)
+	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
+	}
+
+	result := int(ret)
+	fmt.Println("SSCard的运算结果为1:", result)
+	initFlag = 1
+	return
+}
+func (c *JSybController) GetBasBaseInfo() string {
+	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
+	readCard := DllDef.MustFindProc("ReadCardBas")
+	if readCard == nil {
+		fmt.Println("readcard is nil")
+		readCard = DllDef.MustFindProc("ReadCardBas")
+	}
+	str := make([]byte, 2048)
+	str1 := make([]byte, 8192)
+	ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&str[0])), uintptr(1024), (uintptr)(unsafe.Pointer(&str1[0])), uintptr(1024))
+	fmt.Println(string(str1))
+	fmt.Println(string(str))
+	fmt.Println(":", ConvertToString(string(str1), "gbk", "utf-8"))
+	fmt.Println(":", ConvertToString(string(str), "gbk", "utf-8"))
+	if ret2 != 0 {
+		return ""
+	}
+	return string(str)
+}
+
+func IntPtr(n int) uintptr {
+	return uintptr(n)
+}
+
+func StrPtr(s string) uintptr {
+	return uintptr(unsafe.Pointer(syscall.StringBytePtr(s)))
+}
+
+type Charset string
+
+const (
+	UTF8    = Charset("UTF-8")
+	GB18030 = Charset("GB18030")
+)
+
+func ConvertToString(src string, srcCode string, tagCode string) string {
+	srcCoder := mahonia.NewDecoder(srcCode)
+	srcResult := srcCoder.ConvertString(src)
+	tagCoder := mahonia.NewDecoder(tagCode)
+	_, cdata, _ := tagCoder.Translate([]byte(srcResult), true)
+	result := string(cdata)
+	return result
+}

controllers/sg/his_api_controller.go

@@ -339,6 +339,82 @@ func (c *HisApiController) ReadCard() {
 				return
 			}
 
+		} else if miConfig.MdtrtareaAdmvs == "320921" {
+			var res ResultTwo
+			api := "http://192.168.124.4:9532/" + "hbyb/1101?cert_no=" + "" +
+				"&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code +
+				"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(certificates, 10)
+			resp, requestErr := http.Get(api)
+			if requestErr != nil {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			body, ioErr := ioutil.ReadAll(resp.Body)
+			if ioErr != nil {
+				utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+			var respJSON map[string]interface{}
+			if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+				utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+			result, _ := json.Marshal(respJSON)
+			fmt.Println("log")
+			fmt.Println(string(result))
+
+			if err := json.Unmarshal([]byte(result), &res); err != nil {
+				utils.ErrorLog("解析失败：%v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			if res.Infcode == 0 {
+				patient, err := service.GetPatientByIDCard(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId)
+				if err == gorm.ErrRecordNotFound {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+					return
+				} else if err != nil {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+
+				} else {
+
+					Iinfos, _ := json.Marshal(res.Output.Iinfo)
+					Idetinfos, _ := json.Marshal(res.Output.Idetinfo)
+					infoStr := string(Iinfos)
+					idetinfoStr := string(Idetinfos)
+					psn := &models.HisPsn{
+						PsnNo:       res.Output.Baseinfo.PsnNo,
+						Age:         res.Output.Baseinfo.Age,
+						PatientId:   patient.ID,
+						Certno:      res.Output.Baseinfo.Certno,
+						Brdy:        res.Output.Baseinfo.Brdy,
+						Gend:        res.Output.Baseinfo.Gend,
+						Naty:        res.Output.Baseinfo.Naty,
+						PsnCertType: res.Output.Baseinfo.PsnCertType,
+						PsnName:     res.Output.Baseinfo.PsnName,
+						Idetinfo:    idetinfoStr,
+						Insuinfo:    infoStr,
+						UserOrgId:   c.GetAdminUserInfo().CurrentOrgId,
+					}
+					service.CreateHisPsn(psn)
+
+					c.ServeSuccessJSON(map[string]interface{}{
+						"patient": patient,
+						"number":  res.Output.Baseinfo.Certno,
+					})
+				}
+			} else {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+				return
+			}
+
 		} else {
 			if initFlag == 0 {
 				c.TestGetBasBaseInit()
@@ -1871,7 +1947,7 @@ func (c *HisApiController) GetHisPatientInfo() {
 //
 //	str := make([]byte, 256)
 //	str1 := make([]byte, 256)
-//	r, _, _ := ReadCardBas.Call((uintptr)(unsafe.Pointer(&str[0])), IntPtr(1024), (uintptr)(unsafe.Pointer(&str1[0])), IntPtr(1024))
+	r, _, _ := ReadCardBas.Call((uintptr)(unsafe.Pointer(&str[0])), IntPtr(1024), (uintptr)(unsafe.Pointer(&str1[0])), IntPtr(1024))
 //
 //	fmt.Println(string(str))
 //	fmt.Println(r)
@@ -2925,10 +3001,7 @@ func (c *HisApiController) GetRegisterInfo() {
 
 		} else if miConfig.MdtrtareaAdmvs == "320921" {
 			var res ResultTwo
-			api := "http://192.168.3.111:9532/" + "jsyb/1101?cert_no=" + "" +
-				"&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code +
-				"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(certificates, 10) + "&url=" + miConfig.Url + "&ak=" + miConfig.ChannelNumber
-			fmt.Println(api)
+			api := "http://192.168.3.111:9532/" + "jsyb/readcard?" +"fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&ak=" + miConfig.ChannelNumber
 			resp, requestErr := http.Get(api)
 			if requestErr != nil {
 				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)

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,11 +15,11 @@ 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)
 
 }
 func main() {