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

controllers/sg/his_api_controller.go

 	beego.Router("/api/3276", &HisApiController{}, "get:Get3276")
 	beego.Router("/api/3277", &HisApiController{}, "get:Get3277")
 
+	beego.Router("/api/3103", &HisApiController{}, "get:Get3103")
+
 	beego.Router("/api/comfirm/upload", &HisApiController{}, "get:Get4102")
 
 	beego.Router("/api/batch/check_drug", &HisApiController{}, "get:Drugscheck")
 
 }
 
-func (c *HisApiController) Get2505() {
+func (c *HisApiController) Get3103() {
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+	warm_type, _ := c.GetInt64("warm_type")
+	fk_state, _ := c.GetInt64("fk_state")
+	warm_ids := c.GetString("warm_ids")
+	desc := c.GetString("desc")
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	curRoles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
+	result, requestLog := service.Gdyb3103(miConfig.OrgName, curRoles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, warm_type, warm_ids, fk_state, desc)
+	saveLog(result, requestLog, "3103", "反馈")
+	var res2 ResultSix
+	var respJSON2 map[string]interface{}
+	if err := json.Unmarshal([]byte(string(result)), &respJSON2); err != nil {
+		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	userJSONBytes2, _ := json.Marshal(respJSON2)
+	if err := json.Unmarshal(userJSONBytes2, &res2); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	if res2.Infcode != 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res2.ErrMsg,
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "反馈成功",
+		})
+		return
+	}
+}
+
+func (c *HisApiController) Get3103() {
 	admin_user_id, _ := c.GetInt64("admin_user_id")
 	miConfig, _ := service.FindMedicalInsuranceInfo(10375)
 	curRoles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
 									c.ServeSuccessJSON(map[string]interface{}{
 										"failed_code": -10,
 										"failed_type": 100,
+										"warm_type":   1,
 										"msg":         res3101.Output.Result,
 									})
 									return
 								c.ServeSuccessJSON(map[string]interface{}{
 									"failed_code": -10,
 									"failed_type": 100,
+									"warm_type":   2,
 									"msg":         result3101.Output.Result,
 								})
 								return
 									c.ServeSuccessJSON(map[string]interface{}{
 										"failed_code": -10,
 										"failed_type": 100,
+										"warm_type":   1,
 										"msg":         result3101.Output.Result,
 									})
 									return
 									c.ServeSuccessJSON(map[string]interface{}{
 										"failed_code": -10,
 										"failed_type": 100,
-										"msg":         result3101.Output.Result,
+
+										"msg": result3101.Output.Result,
 									})
 
 									return
 										c.ServeSuccessJSON(map[string]interface{}{
 											"failed_code": -10,
 											"failed_type": 100,
+											"warm_type":   2,
 											"msg":         result3101.Output.Result,
 										})
 										return

service/gdyb_service.go

 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 
- {
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 			fmt.Println(err.Error())
 		url = gdyb_url + "2201"
 	}
 
-	  {
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 			fmt.Println(err.Error())
 		url = gdyb_url + "2201"
 	}
 
-	  {
+	{
 		fmt.Println(url)
 		fmt.Println(gdyb_paasid)
 		fmt.Println(secret_key)
 	} else {
 		url = gdyb_url + "2203"
 	}
- {
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 			fmt.Println(err.Error())
 		url = gdyb_url + "2203"
 	}
 
- {
+	{
 
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 	var url string
 
 	url = gdyb_url + "2203"
-{
+	{
 
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2204"
 
- {
+	{
 
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
-{
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		fmt.Println(err)
 
 			inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
 		}
 	}
-	 {
+	{
 		inputData["med_type"] = med_type // 医疗类别 11 普通门诊  12 门诊挂号
 	}
 
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2206"
 
-	 {
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 			fmt.Println(err.Error())
 	if med_type == "1111" || med_type == "1112" {
 		med_type = "11"
 	}
- {
+	{
 		inputData["med_type"] = med_type // 医疗类别 11 普通门诊  12 门诊挂号
 	}
 	inputData["medfee_sumamt"] = total           // 医疗费总额
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
- {
+	{
 
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
 
- {
+	{
 
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 
 	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
 
-	 {
+	{
 		request, err := http.NewRequest("POST", url, reader)
 		if err != nil {
 			fmt.Println(err.Error())
 	} else {
 		url = gdyb_url + "3260"
 	}
- {
+	{
 
 		//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 		request, err := http.NewRequest("POST", url, reader)
 		url = gdyb_url + "3262"
 	}
 
-	 {
+	{
 
 		//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 		request, err := http.NewRequest("POST", url, reader)
 		url = gdyb_url + "9001"
 	}
 
- {
+	{
 
 		//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 
 		url = gdyb_url + "9001"
 	}
 
-	 {
+	{
 
 		//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 
 		url = gdyb_url + "1101"
 	}
 
- {
+	{
 
 		//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
 		request, err := http.NewRequest("POST", url, reader)
 	input["invinfo"] = inputData
 	inputMessage["input"] = input //交易输入
 
-
 	bytesData, err := json.Marshal(inputMessage)
 	fmt.Println(string(bytesData))
 	if err != nil {
 	inputData["rxno"] = struct3505.Rxno                   // 人员编号 （来自1101接口返回）
 	inputData["rx_circ_flag"] = struct3505.RxCircFlag     // 人员编号 （来自1101接口返回）
 
-	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
-	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
+	inputData["rtal_docno"] = struct3505.RtalDocno          // 人员编号 （来自1101接口返回）
+	inputData["stoout_no"] = struct3505.StooutNo            // 人员编号 （来自1101接口返回）
 	inputData["MDTRT_SETL_TYPE"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
 
 	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
-	inputData["drug_trac_codg"] = "--"        // 人员编号 （来自1101接口返回）
+	inputData["drug_trac_codg"] = "--"                             // 人员编号 （来自1101接口返回）
 	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
 	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
 	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
 	inputMessage := SetGdInputMessage(timestamp, struct3507.OrgName, struct3507.Opter, struct3507.FixmedinsCode, struct3507.InsuplcAdmdvs, struct3507.MdtrtareaAdmvs, struct3507.Cainfo)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "3507"                          // 交易编码
+	inputMessage["infno"] = "3507"                           // 交易编码
 	inputData["fixmedins_bchno"] = struct3507.FixmedinsBchno // 人员编号 （来自1101接口返回）
-	inputData["inv_data_type"] = struct3507.InvDataType     // 人员编号 （来自1101接口返回）
+	inputData["inv_data_type"] = struct3507.InvDataType      // 人员编号 （来自1101接口返回）
 
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入
 	inputData["bchno"] = struct3505.Bchno // 人员编号 （来自1101接口返回）
 	codes := strings.Split(struct3505.DrugTracCodg, ",")
 
-	inputData["drug_trac_codg"] = codes[0]          // 人员编号 （来自1101接口返回）
+	inputData["drug_trac_codg"] = codes[0]                         // 人员编号 （来自1101接口返回）
 	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
 	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
 	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
 
 	//codes = strings.Split(struct3505.DrugTracCodg, ",")
 	for _, item := range codes {
-		if len(item) > 0{
+		if len(item) > 0 {
 			druginputData := make(map[string]interface{})
 			druginputData["drug_trac_codg"] = item
 			feedetail = append(feedetail, druginputData)
 	//inputMessage["sign_no"] = "GZYBCS4101A20220202"
 	return inputMessage
 }
+
+func Gdyb3103(org_name string, opera string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, warm_type int64, ids string, dspo_way int64, desc string) (string, string) {
+	fmt.Println(opera)
+
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce, secret_key)
+
+	// 生成输入报文
+	inputMessage := SetInputMessagenosign(nonce, timestamp, org_name, opera, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3103" // 交易编码
+
+	inputData["warn_type"] = warm_type // 人员编号 （来自1101接口返回）
+
+	id_arr := strings.Split(ids, "~")
+	feedetail := make([]map[string]interface{}, 0)
+	for _, item := range id_arr {
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["warn_rslt_id"] = item
+		feedetailInfo["dspo_way"] = dspo_way // 就诊 ID（来自2201接口返回）
+		feedetailInfo["dspo_way_rea"] = desc // 人员编号 （来自1101接口返回）
+		feedetail = append(feedetail, feedetailInfo)
+	}
+	inputData["warns"] = feedetail
+	input["data"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	var requestLog string
+	bytesData, err := json.Marshal(inputMessage)
+	requestLog = string(bytesData)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2201"
+	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2201"
+
+	gdyb_url := beego.AppConfig.String("gdyb_url")
+	gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
+
+	var url string
+
+	url = gdyb_url + "3103"
+
+	{
+		request, err := http.NewRequest("POST", url, reader)
+		if err != nil {
+			fmt.Println(err.Error())
+			return err.Error(), ""
+		}
+
+		request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+		request.Header.Set("x-tif-paasid", gdyb_paasid)
+		request.Header.Set("x-tif-signature", signature)
+		request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+		request.Header.Set("x-tif-nonce", nonce)
+
+		client := http.Client{}
+		resp, err := client.Do(request)
+		if err != nil {
+			fmt.Println(err.Error())
+			return err.Error(), ""
+		}
+		respBytes, err := ioutil.ReadAll(resp.Body)
+		if err != nil {
+			fmt.Println(err.Error())
+			return err.Error(), ""
+		}
+		str := string(respBytes)
+		fmt.Println(str)
+		return str, requestLog
+
+	}
+}