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

controllers/sz/sz_his_api_controller.go

 
 	//退费
 	beego.Router("/sz/api/refund/get", &SZHisApiController{}, "get:Refund")
+
+	beego.Router("/sz/api/readcard", &SZHisApiController{}, "get:ReadCard")
+
+	beego.Router("sz/api/refundnumber/get", &SZHisApiController{}, "get:RefundNumber")
+
 	beego.Router("/sz/api/monthrefund/get", &SZHisApiController{}, "get:MonthRefund")
 	//查询交易
 	beego.Router("/sz/api/settle/query", &SZHisApiController{}, "get:GetSettleAccounts")
 	ItemId           int64
 }
 
+func (c *SZHisApiController) ReadCard() {
+	id_card_type, _ := c.GetInt64("id_card_type")
+	adminInfo := c.GetAdminUserInfo()
+	if id_card_type != 1 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorNoReadCardException)
+		return
+	}
+	month := time.Unix(1557042972, 0).Format("1")
+	year := time.Now().Format("2006")
+	month = time.Now().Format("01")
+	day := time.Now().Format("02")
+
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId)
+	number := miConfig.Code + year + month + day +
+		fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
+	id_card_number, health_card_no, _, ret4 := ReadBasCard("MZ002" + "|" + number + "|" + miConfig.Code + "|")
+	if ret4 == 0 {
+		patient, _ := service.GetPatientByNumber(id_card_number, adminInfo.CurrentOrgId)
+		if patient.ID == 0 {
+			patient.HealthCareNo = health_card_no
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+			return
+		} else {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"patient": patient,
+			})
+		}
+	} else {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
+		return
+	}
+
+}
+
 //获取读卡信息 -- 门诊挂号
 //func (c *SZHisApiController) GetRegisterInfo() {
 //	adminInfo := c.GetAdminUserInfo()
 	}
 }
 
+func (c *SZHisApiController) RefundNumber() {
+	order_id, _ := c.GetInt64("order_id")
+	record_time := c.GetString("record_time")
+	patient_id, _ := c.GetInt64("patient_id")
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	adminUser := c.GetAdminUserInfo()
+	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
+	fmt.Println(err)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordDateTime := theTime.Unix()
+	fmt.Println(recordDateTime)
+	var order models.HisOrder
+	order, _ = service.GetHisOrderByID(order_id)
+	if order.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisOrderNoExistParamWrong)
+		return
+	}
+	his, _ := service.GetHisPatientInfo(adminUser.CurrentOrgId, patient_id, theTime.Unix())
+	roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id)
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	//结算流程
+	var doctor_name string
+	var doctor_code string
+	if roles.ID == 0 {
+		doctor_name = "管理员"
+		doctor_code = "01"
+	} else {
+		doctor_name = roles.UserName
+		doctor_code = strconv.FormatInt(admin_user_id, 10)
+
+	}
+	month := time.Unix(1557042972, 0).Format("1")
+	year := time.Now().Format("2006")
+	month = time.Now().Format("01")
+	day := time.Now().Format("02")
+	//number := miConfig.Code  + year + month + day + "1367866"
+	number := miConfig.Code + year + month + day +
+		fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
+	//number := miConfig.Code + year + month + day + "1590003"
+
+	//流水号
+	//number_two := miConfig.Code + "-" + year + month + day + "-" + strconv.FormatInt(patient_id, 10)
+	verifyCode, version_code := ReadCardGetCode("JY002" + "|" + number + "|" + miConfig.Code)
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+	if config.IsOpen == 1 { //对接了医保，走医保流程
+		result := service.SzybJY002(doctor_name, doctor_code, miConfig.Code, his.MzNumber, order.Number, verifyCode, number, version_code)
+		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 ResultThree
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		if res.Transreturncode == "00000000" {
+			service.UpdataHisStatusSZ(adminUser.CurrentOrgId, his.MzNumber, his.Number, result)
+			c.ServeSuccessJSON(map[string]interface{}{
+				"msg": "退号成功",
+			})
+		} else {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"failed_code": -10,
+				"msg":         res.Transreturnmessage,
+			})
+
+		}
+	}
+
+}
+
 //上传明细----结算----确认订单
 func (c *SZHisApiController) GetSettleInfo() {
 	pay_way, _ := c.GetInt64("pay_way")
 	return "", ""
 }
 
-////读卡
+////获取卡信息
 func ReadBasCardGetNumber(request string) (string, string, string, string, error, int64) {
 	DllDef2 := syscall.MustLoadDLL("SSCardDriver_SZ.dll")
 	readCards := DllDef2.MustFindProc("iReadCardBas")
 	return "", "", "", "", err, -10
 }
 
+//读卡
+func ReadBasCard(request string) (string, string, error, int64) {
+	DllDef2 := syscall.MustLoadDLL("SSCardDriver_SZ.dll")
+	readCards := DllDef2.MustFindProc("iReadCardBas")
+	str := request
+	str3 := make([]byte, 1024)
+	ret4, _, err := readCards.Call(IntPtr(1), StrPtr(str), (uintptr)(unsafe.Pointer(&str3[0])))
+	fmt.Println(":", string(str3))
+	fmt.Println(":", ConvertToString(string(str3), "gbk", "utf-8"))
+	if ret4 == 0 {
+		result := string(str3)
+		result_arr := strings.Split(result, "|")
+		//根据业务的人员信息跟设备读社保卡获取的信息进行匹配，判断是否为同一个人，相同则进行挂号操作，不同则报错
+		id_card_number := result_arr[1]
+		health_card_no := result_arr[2]
+
+		return id_card_number, health_card_no, err, 0
+	}
+	return "", "", err, -10
+}
+
 //
 ////iReadCardBas_HSM_Step1 ---- 1903 iCardInnerAuthentication ---  	iReadCardBas_HSM_Step2
 //func ReadCardBasHSM(number string) string {
 						RetailPrice:            item.RetailPrice, //协议机构内部项目收费价格
 						LimitRemark:            item.LimitRemark,
 						MedicalInsuranceNumber: item.MedicalInsuranceNumber, //社保目录
-
 					}
 					customs = append(customs, detail)
 				}
 				IdentificationOutpatients:               "",                                //门诊大病医师标识
 				OutpatientIllnessCategory:               item.OutpatientIllnessCategory,    //门诊大病类别
 				StartTime:                               20201012,                          //开始日期
-
 			}
 			result := service.SzybYS001(doctor_name, doctor_code, miConfig.Code, detail)
 			fmt.Println("reuslt9999999999999999", result)
 				IdentificationOutpatients:               "1",      //门诊大病医师标识
 				OutpatientIllnessCategory:               "血友病",    //门诊大病类别
 				StartTime:                               20210311, //开始日期
-
 			}
 			result := service.SzybYS002(doctor_name, doctor_code, miConfig.Code, detail)
 			fmt.Println("reuslt9999999999999999", result)

enums/error_code.go

 	ErrorDrugPreSettleFaildParamWrong = 30002
 	ErrorDrugReturnFaildParamWrong    = 30003
 	ErrorDoctorLoginFaildParamWrong   = 30004
+
+	ErrorNoReadCardException = 30005
 )
 
 var ErrCodeMsgs = map[int]string{
 	ErrorDrugPreSettleFaildParamWrong:  "备案失败",
 	ErrorDrugReturnFaildParamWrong:     "撤销失败",
 	ErrorDoctorLoginFaildParamWrong:    "登记失败",
+
+	ErrorNoReadCardException: "无法读取除社保卡以外的卡",
 }
 
 type SGJError struct {

service/sz_his_service.go

 	err = writeDb.Model(&models.HisOrder{}).Where("status = 1 AND id = ? AND user_org_id = ?", id, user_org_id).Updates(map[string]interface{}{"order_status": 3, "mtime": time.Now().Unix(), "status": 0}).Error
 	err = writeDb.Model(&models.HisPrescription{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"order_status": 1, "mtime": time.Now().Unix()}).Error
 	err = writeDb.Model(&models.HisPrescriptionInfo{}).Where("status = 1 AND batch_number = ? AND user_org_id = ?", number, user_org_id).Updates(map[string]interface{}{"prescription_status": 1, "mtime": time.Now().Unix()}).Error
-	err = writeDb.Model(&models.HisPatient{}).Where("status = 1 AND user_org_id = ? AND mz_number = ? AND number = ?", user_org_id, his_mz_number, his_number).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
 
 	return
 
 }
 
+func UpdataHisStatusSZ(user_org_id int64, his_mz_number string, his_number string, result string) (err error) {
+	err = writeDb.Model(&models.HisPatient{}).Where("status = 1 AND user_org_id = ? AND mz_number = ? AND number = ?", user_org_id, his_mz_number, his_number).Updates(map[string]interface{}{"status": 0, "mtime": time.Now().Unix(), "refund_detail": result}).Error
+	return
+}
+
 func UpdataOrderlog(id int64, user_org_id int64, refund_log string) (err error) {
 	err = writeDb.Model(&models.HisOrder{}).Where("status = 1 AND id = ? AND user_org_id = ?", id, user_org_id).Updates(map[string]interface{}{"order_status": 3, "mtime": time.Now().Unix(), "status": 0, "refund_log": refund_log}).Error