111

controllers/sg/his_api_controller.go

@@ -2943,6 +2943,8 @@ func (c *HisApiController) GetSettleList() {
 	var res ResultSeventeen
 
 	if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+		struct4101.BillCode = order.Number
+		struct4101.BillNo = order.SetlId
 		var resOther ResultSeventeenOther
 		var pp models.PublicParams
 		pp.InsuplcAdmdvs = miConfig.InsuplcAdmdvs
@@ -2981,7 +2983,7 @@ func (c *HisApiController) GetSettleList() {
 			return
 		}
 
-		respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+		respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
 		userJSONBytes, _ := json.Marshal(respJSON)
 		fmt.Println("log")
 		fmt.Println(string(userJSONBytes))
@@ -10236,9 +10238,10 @@ func (c *HisApiController) GetCheckAccount() {
 				AcctPay:          acct_pay,
 				FixmedinsSetlCnt: fixmedins_setl_cnt,
 			}
-			result, requestLog := service.FJyb3201(baseParams, businessParams)
+			result, requestLog, err_msg := service.FJyb3201(baseParams, businessParams)
 			fmt.Println(requestLog)
 			fmt.Println(result)
+			fmt.Println(err_msg)
 
 		} else {
 			if len(clr_type) == 0 {

main.go

@@ -1,15 +1,7 @@
 package main
 
 import (
-	"context"
-	"fmt"
-	"gdyb/models"
 	"gdyb/service"
-	"github.com/qiniu/api.v7/auth/qbox"
-	"github.com/qiniu/api.v7/storage"
-	"os"
-	"strconv"
-	"time"
 
 	//"github.com/qiniu/api.v7/auth/qbox"
 	//"github.com/qiniu/api.v7/storage"
@@ -34,8 +26,8 @@ func init() {
 	service.ConnectDB()
 	org_id, _ := beego.AppConfig.Int64("org_id")
 	miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
-	CreateLog(miConfig)
-	UploadLog(miConfig)
+	//CreateLog(miConfig)
+	//UploadLog(miConfig)
 	if org_id == 10191 {
 		service.GetFjAuthorizationInfo(miConfig.Code)
 	}
@@ -800,138 +792,138 @@ type ResultSeventeen struct {
 //	}
 //}
 
-func CreateLog(miConfig models.MedicalInsuranceOrgConfig) {
-	Mkdir(miConfig.OrgName + "日志")
-	//org_id,_ := beego.AppConfig.Int("org_id")
-	month := time.Unix(1557042972, 0).Format("1")
-	year := time.Now().Format("2006")
-	month = time.Now().Format("01")
-	day := time.Now().Format("02")
-	file := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + year + month + day + "_log"
-	file_name := file + ".txt"
-	file_path := miConfig.OrgName + "日志" + "/" + file_name
-	exist, _ := 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\r\r"
-		n, _ := f.Seek(0, 2)
-		_, err = f.WriteAt([]byte(content), n)
-
-	} else { //不存在
-		fmt.Println("文件不存在，创建文件")
-		f, err := os.Create(miConfig.OrgName + "日志" + "/" + file_name)
-		defer f.Close()
-		if err != nil {
-		} else {
-			_, err = f.Write([]byte("记录日志"))
-		}
-	}
-
-}
-
-func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
-	//获取七牛云上的文件信息，不存在则表示没上传到七牛云，上传昨天日志信息
-	nTime := time.Now()
-	yesTime := nTime.AddDate(0, 0, -1)
-	file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
-	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
-	cfg := storage.Config{
-		// 是否使用https域名进行资源管理
-		UseHTTPS: true,
-	}
-	// 指定空间所在的区域，如果不指定将自动探测
-	// 如果没有特殊需求，默认不需要指定
-	//cfg.Zone=&storage.ZoneHuabei
-	bucketManager := storage.NewBucketManager(mac, &cfg)
-	bucket := beego.AppConfig.String("qiniu_bucket")
-	key := file_key
-	file, sErr := bucketManager.Stat(bucket, key)
-	fmt.Println(file)
-	fmt.Println(sErr)
-	fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
-
-	if sErr != nil {
-		fmt.Println("七牛云上文件不存在，上传到七牛云")
-		//判断本地文件是否存在，存在则执行上传操作
-		exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
-		if exist {
-			upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
-		} else {
-			fmt.Println("本地文件不存在")
-
-		}
-	} else {
-		fmt.Println("七牛云文件存在")
-	}
+//func CreateLog(miConfig models.MedicalInsuranceOrgConfig) {
+//	Mkdir(miConfig.OrgName + "日志")
+//	//org_id,_ := beego.AppConfig.Int("org_id")
+//	month := time.Unix(1557042972, 0).Format("1")
+//	year := time.Now().Format("2006")
+//	month = time.Now().Format("01")
+//	day := time.Now().Format("02")
+//	file := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + year + month + day + "_log"
+//	file_name := file + ".txt"
+//	file_path := miConfig.OrgName + "日志" + "/" + file_name
+//	exist, _ := 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\r\r"
+//		n, _ := f.Seek(0, 2)
+//		_, err = f.WriteAt([]byte(content), n)
+//
+//	} else { //不存在
+//		fmt.Println("文件不存在，创建文件")
+//		f, err := os.Create(miConfig.OrgName + "日志" + "/" + file_name)
+//		defer f.Close()
+//		if err != nil {
+//		} else {
+//			_, err = f.Write([]byte("记录日志"))
+//		}
+//	}
+//
+//}
 
-}
-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
-}
+//func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
+//	//获取七牛云上的文件信息，不存在则表示没上传到七牛云，上传昨天日志信息
+//	nTime := time.Now()
+//	yesTime := nTime.AddDate(0, 0, -1)
+//	file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
+//	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
+//	cfg := storage.Config{
+//		// 是否使用https域名进行资源管理
+//		UseHTTPS: true,
+//	}
+//	// 指定空间所在的区域，如果不指定将自动探测
+//	// 如果没有特殊需求，默认不需要指定
+//	//cfg.Zone=&storage.ZoneHuabei
+//	bucketManager := storage.NewBucketManager(mac, &cfg)
+//	bucket := beego.AppConfig.String("qiniu_bucket")
+//	key := file_key
+//	file, sErr := bucketManager.Stat(bucket, key)
+//	fmt.Println(file)
+//	fmt.Println(sErr)
+//	fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
+//
+//	if sErr != nil {
+//		fmt.Println("七牛云上文件不存在，上传到七牛云")
+//		//判断本地文件是否存在，存在则执行上传操作
+//		exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
+//		if exist {
+//			upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
+//		} else {
+//			fmt.Println("本地文件不存在")
+//
+//		}
+//	} else {
+//		fmt.Println("七牛云文件存在")
+//	}
+//
+//}
+//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
+//}
 
-func upload_qiniu(filePath string, keys string) {
-	key := keys
-	//上传凭证,关于凭证这块大家可以去看看官方文档
-	putPolicy := storage.PutPolicy{
-		Scope: beego.AppConfig.String("qiniu_bucket"),
-	}
-	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
-	upToken := putPolicy.UploadToken(mac)
-	cfg := storage.Config{}
-	//空间对应机房
-	//其中关于Zone对象和机房的关系如下：
-	//    机房    Zone对象
-	//    华东    storage.ZoneHuadong
-	//    华北    storage.ZoneHuabei
-	//    华南    storage.ZoneHuanan
-	//    北美    storage.ZoneBeimei
-	//七牛云存储空间设置首页有存储区域
-	cfg.Zone = &storage.ZoneHuadong
-	//不启用HTTPS域名
-	cfg.UseHTTPS = false
-	//不使用CND加速
-	cfg.UseCdnDomains = false
-	//构建上传表单对象
-	formUploader := storage.NewFormUploader(&cfg)
-	ret := storage.PutRet{}
-	// 可选
-	putExtra := storage.PutExtra{
-		Params: map[string]string{},
-	}
-	err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
-	if err != nil {
-		fmt.Println(err)
-		return
-	}
-	fmt.Println(ret.Key, ret.Hash)
-}
+//func upload_qiniu(filePath string, keys string) {
+//	key := keys
+//	//上传凭证,关于凭证这块大家可以去看看官方文档
+//	putPolicy := storage.PutPolicy{
+//		Scope: beego.AppConfig.String("qiniu_bucket"),
+//	}
+//	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
+//	upToken := putPolicy.UploadToken(mac)
+//	cfg := storage.Config{}
+//	//空间对应机房
+//	//其中关于Zone对象和机房的关系如下：
+//	//    机房    Zone对象
+//	//    华东    storage.ZoneHuadong
+//	//    华北    storage.ZoneHuabei
+//	//    华南    storage.ZoneHuanan
+//	//    北美    storage.ZoneBeimei
+//	//七牛云存储空间设置首页有存储区域
+//	cfg.Zone = &storage.ZoneHuadong
+//	//不启用HTTPS域名
+//	cfg.UseHTTPS = false
+//	//不使用CND加速
+//	cfg.UseCdnDomains = false
+//	//构建上传表单对象
+//	formUploader := storage.NewFormUploader(&cfg)
+//	ret := storage.PutRet{}
+//	// 可选
+//	putExtra := storage.PutExtra{
+//		Params: map[string]string{},
+//	}
+//	err := formUploader.PutFile(context.Background(), &ret, upToken, key, filePath, &putExtra)
+//	if err != nil {
+//		fmt.Println(err)
+//		return
+//	}
+//	fmt.Println(ret.Key, ret.Hash)
+//}

service/fj_service.go

@@ -752,7 +752,7 @@ func FJyb6201(org_name string, doctor string, fixmedins_code string, insuplc_adm
 }
 
 //  医药机构费用结算对总账 func Gdyb3201( org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) string {
-func FJyb3201(baseParams models.BaseParams, businessParams models.BusinessParams) (string, string) {
+func FJyb3201(baseParams models.BaseParams, businessParams models.BusinessParams) (string, string, string) {
 
 	fmt.Println(baseParams)
 	fmt.Println(businessParams)
@@ -772,8 +772,8 @@ func FJyb3201(baseParams models.BaseParams, businessParams models.BusinessParams
 	inputMessage["enc_key"] = baseParams.EncKey       // 险种
 
 	inputData["insutype"] = businessParams.Insutype                   // 险种
-	inputData["clr_type"] = businessParams.ClrType                    // 就诊 ID（来自2201接口返回）
-	inputData["setl_optins"] = baseParams.InsuplcAdmdvs               // 结算经办机构
+	inputData["clr_type"] = "11"                                      // 就诊 ID（来自2201接口返回）
+	inputData["setl_optins"] = "350581"                               // 结算经办机构
 	inputData["stmt_begndate"] = businessParams.StmtBegndate          // 对帐开始时间
 	inputData["stmt_enddate"] = businessParams.StmtEnddate            //对帐结束时间
 	inputData["medfee_sumamt"] = businessParams.MedfeeSumamt          //医疗费总额
@@ -789,17 +789,14 @@ func FJyb3201(baseParams models.BaseParams, businessParams models.BusinessParams
 	fmt.Println(string(bytesData))
 	if err != nil {
 		fmt.Println(err.Error())
-		return err.Error(), ""
-	}
-
-	cmd := exec.Command("java", "-jar", "FJYB_SDK.jar", string(bytesData))
-	out, err := cmd.Output()
-	if err != nil {
-		fmt.Println("error:", err.Error())
+		return err.Error(), "", ""
 	}
 
-	fmt.Println(string(out))
-	return ConvertToString(string(out), "gbk", "utf-8"), string(bytesData)
+	var requestLog string
+	requestLog = string(bytesData)
+	enc := mahonia.NewEncoder("gbk")
+	output, err_msg := GetFjBusinessHandleInfo([]byte(enc.ConvertString(string(bytesData))))
+	return output, requestLog, err_msg
 
 }