拉取代码

main.go

@@ -8,8 +8,10 @@ import (
 
 func init() {
 	service.ConnectDB()
+
 }
 
 func main() {
 	beego.Run()
+
 }

models/dialysis.go

@@ -890,6 +890,7 @@ type SgjUserAdminRole struct {
 	OrgName       string `gorm:"column:org_name" json:"org_name" form:"org_name"`
 	OrgLogo       string `gorm:"column:org_logo" json:"org_logo" form:"org_logo"`
 	Creator       int64  `gorm:"column:creator" json:"creator" form:"creator"`
+	Name          string
 }
 
 func (SgjUserAdminRole) TableName() string {

models/drug.go

@@ -91,3 +91,59 @@ type MedicineInsurancePercentage struct {
 func (MedicineInsurancePercentage) TableName() string {
 	return "xt_medicine_insurance_percentage"
 }
+
+type BaseDrugList struct {
+	ID                     int64   `gorm:"column:id" json:"id" form:"id"`
+	DrugName               string  `gorm:"column:drug_name" json:"drug_name" form:"drug_name"`
+	Pinyin                 string  `gorm:"column:pinyin" json:"pinyin" form:"pinyin"`
+	Wubi                   string  `gorm:"column:wubi" json:"wubi" form:"wubi"`
+	DrugAlias              string  `gorm:"column:drug_alias" json:"drug_alias" form:"drug_alias"`
+	DrugAliasPinyin        string  `gorm:"column:drug_alias_pinyin" json:"drug_alias_pinyin" form:"drug_alias_pinyin"`
+	DrugAliasWubi          string  `gorm:"column:drug_alias_wubi" json:"drug_alias_wubi" form:"drug_alias_wubi"`
+	DrugCategory           int64   `gorm:"column:drug_category" json:"drug_category" form:"drug_category"`
+	DrugSpec               string  `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
+	DrugType               int64   `gorm:"column:drug_type" json:"drug_type" form:"drug_type"`
+	DrugStockLimit         string  `gorm:"column:drug_stock_limit" json:"drug_stock_limit" form:"drug_stock_limit"`
+	DrugOriginPlace        string  `gorm:"column:drug_origin_place" json:"drug_origin_place" form:"drug_origin_place"`
+	DrugDosageForm         int64   `gorm:"column:drug_dosage_form" json:"drug_dosage_form" form:"drug_dosage_form"`
+	MedicalInsuranceLevel  int64   `gorm:"column:medical_insurance_level" json:"medical_insurance_level" form:"medical_insurance_level"`
+	MaxUnit                string  `gorm:"column:max_unit" json:"max_unit" form:"max_unit"`
+	MinUnit                string  `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
+	UnitMatrixing          string  `gorm:"column:unit_matrixing" json:"unit_matrixing" form:"unit_matrixing"`
+	RetailPrice            float64 `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	LastPrice              float64 `gorm:"column:last_price" json:"last_price" form:"last_price"`
+	DrugControl            int64   `gorm:"column:drug_control" json:"drug_control" form:"drug_control"`
+	Number                 string  `gorm:"column:number" json:"number" form:"number"`
+	DrugClassify           string  `gorm:"column:drug_classify" json:"drug_classify" form:"drug_classify"`
+	DrugDose               float64 `gorm:"column:drug_dose" json:"drug_dose" form:"drug_dose"`
+	DrugDoseUnit           int64   `gorm:"column:drug_dose_unit" json:"drug_dose_unit" form:"drug_dose_unit"`
+	MedicalInsuranceNumber string  `gorm:"column:medical_insurance_number" json:"medical_insurance_number" form:"medical_insurance_number"`
+	Manufacturer           int64   `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	PharmacologyCategory   int64   `gorm:"column:pharmacology_category" json:"pharmacology_category" form:"pharmacology_category"`
+	StatisticsCategory     int64   `gorm:"column:statistics_category" json:"statistics_category" form:"statistics_category"`
+	Code                   string  `gorm:"column:code" json:"code" form:"code"`
+	IsSpecialDiseases      int64   `gorm:"column:is_special_diseases" json:"is_special_diseases" form:"is_special_diseases"`
+	IsRecord               int64   `gorm:"column:is_record" json:"is_record" form:"is_record"`
+	Agent                  string  `gorm:"column:agent" json:"agent" form:"agent"`
+	DrugStatus             string  `gorm:"column:drug_status" json:"drug_status" form:"drug_status"`
+	LimitRemark            string  `gorm:"column:limit_remark" json:"limit_remark" form:"limit_remark"`
+	DeliveryWay            string  `gorm:"column:delivery_way" json:"delivery_way" form:"delivery_way"`
+	ExecutionFrequency     string  `gorm:"column:execution_frequency" json:"execution_frequency" form:"execution_frequency"`
+	SingleDose             float64 `gorm:"column:single_dose" json:"single_dose" form:"single_dose"`
+	PrescribingNumber      float64 `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
+	Label                  int64   `gorm:"column:label" json:"label" form:"label"`
+	Sort                   int64   `gorm:"column:sort" json:"sort" form:"sort"`
+	IsUseDoctorAdvice      int64   `gorm:"column:is_use_doctor_advice" json:"is_use_doctor_advice" form:"is_use_doctor_advice"`
+	IsDefault              int64   `gorm:"column:is_default" json:"is_default" form:"is_default"`
+	IsChargePredict        int64   `gorm:"column:is_charge_predict" json:"is_charge_predict" form:"is_charge_predict"`
+	IsStatisticsWork       int64   `gorm:"column:is_statistics_work" json:"is_statistics_work" form:"is_statistics_work"`
+	IsChargeUse            int64   `gorm:"column:is_charge_use" json:"is_charge_use" form:"is_charge_use"`
+	Status                 int64   `gorm:"column:status" json:"status" form:"status"`
+	Ctime                  int64   `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime                  int64   `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	OrgId                  int64   `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	DrugCode               string  `gorm:"column:drug_code" json:"drug_code" form:"drug_code"`
+	Dealer                 int64   `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	ManufacturerName       string  `gorm:"column:manufacturer_name" json:"manufacturer_name" form:"manufacturer_name"`
+	DrugDosageName         string
+}

models/his_models.go

@@ -993,3 +993,46 @@ type MedicalInsuranceCostCompare struct {
 func (MedicalInsuranceCostCompare) TableName() string {
 	return "medical_insurance_cost_compare"
 }
+
+type XtDrugDataConfig struct {
+	ID             int64     `gorm:"column:id" json:"id" form:"id"`
+	ParentId       int64     `gorm:"column:parent_id" json:"parent_id" form:"parent_id"`
+	Module         string    `gorm:"column:module" json:"module" form:"module"`
+	OrgId          int64     `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Name           string    `gorm:"column:name" json:"name" form:"name"`
+	FieldName      string    `gorm:"column:field_name" json:"field_name" form:"field_name"`
+	Value          int64     `gorm:"column:value" json:"value" form:"value"`
+	CreateTime     time.Time `gorm:"column:create_time" json:"create_time" form:"create_time"`
+	UpdateTime     time.Time `gorm:"column:update_time" json:"update_time" form:"update_time"`
+	CreateUserId   int64     `gorm:"column:create_user_id" json:"create_user_id" form:"create_user_id"`
+	Status         int64     `gorm:"column:status" json:"status" form:"status"`
+	Remark         string    `gorm:"column:remark" json:"remark" form:"remark"`
+	DeleteIdSystem int64     `gorm:"column:delete_id_system" json:"delete_id_system" form:"delete_id_system"`
+	Title          string    `gorm:"column:title" json:"title" form:"title"`
+	Content        string    `gorm:"column:content" json:"content" form:"content"`
+	Orders         int64     `gorm:"column:orders" json:"orders" form:"orders"`
+}
+
+func (XtDrugDataConfig) TableName() string {
+	return "xt_drug_data_config"
+}
+
+type XtRole struct {
+	Id           int64  `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"`
+	RoleName     string `gorm:"column:role_name" json:"name"`
+	RoleIntro    string `gorm:"column:role_introduction" json:"intro"`
+	Creator      int64  `json:"-"`
+	OrgId        int64  `gorm:"column:org_id" json:"-"`
+	AppId        int64  `gorm:"column:app_id" json:"-"`
+	IsSuperAdmin bool   `gorm:"column:is_super_admin" json:"is_super_admin"`
+	Status       int8   `json:"status"`                // 状态 0.无效 1.有效 2.禁用
+	CreateTime   int64  `gorm:"column:ctime" json:"-"` // 创建时间
+	ModifyTime   int64  `gorm:"column:mtime" json:"-"` // 修改时间
+	StaffNumber  int64  `gorm:"-" json:"staff_number"`
+	Number       int64  `gorm:"number" json:"number"`
+	IsSystem     int64  `gorm:"column:is_system" json:"is_system" form:"is_system"`
+}
+
+func (XtRole) TableName() string {
+	return "sgj_user_role"
+}

models/sz_his_models.go

@@ -18,3 +18,58 @@ type CustomDetail struct {
 	Spec               string
 	CustomNumber       string
 }
+
+type DrugDetail struct {
+	MedicalInsuranceNumber string  //社保目录编码
+	Code                   string  // 药品本位码
+	DrugName               string  //医药机构内部目录名称
+	DrugSpec               string  //规格
+	DrugDosageName         string  //剂型
+	MinUnit                string  //计价单位
+	ManufacturerName       string  //厂家
+	RetailPrice            float64 //药品收费价格
+	LastPrice              float64 // 药品进货价格
+	LimitRemark            string  //药品备注
+}
+
+type DocDetail struct {
+	UserName                                string //医护姓名
+	RoleId                                  string //医护人员类别
+	Sex                                     string //性别
+	CardType                                string //证件类型
+	IdCard                                  string //证件号码
+	Phone                                   string //联系电话
+	WorkMajorName                           string // 从事专业名称
+	Nation                                  string //民族
+	BirthDay                                int64  // 出生日期
+	WorkTime                                int64  //参加工作日期
+	Education                               string //学历
+	StudyMajorName                          string //所学专业名称
+	CertificateCode                         string //证书编码
+	MedicalCode                             string //医师资格编码
+	MedicalRangeCode                        string //医师执业范围代码
+	MedicalLevel                            string //医生级别
+	TypeJob                                 string //职业类别
+	DoctorNumber                            string //医师编号
+	Licensing                               string //职业标志
+	DoctorServiceStatus                     string //医师医保服务资格状态
+	MonitoringLevel                         string //监控等级
+	DrugPsychotropicSubstances              string //毒麻精神药品资格
+	HealthCareCode                          string // 母婴保健技术考核合格证书编号
+	PlanningTechnicalServiceCode            string //计划生育技术服务人员合格证编号
+	PharmacistType                          string //药师类别
+	PharmacistPracticeCategory              string //药师执业类别
+	PharmacistsLicensing                    string //药师执业范围
+	PharmacistRegistrationNumber            string //执业药师注册证编号
+	OfficeCode                              string //科室编码
+	JobNumber                               string //工号
+	PostName                                string //职位名称
+	TechnicalJobLevelCode                   string //专业技术职务级别编码
+	IsActive                                string //在职与否
+	PrescriptionQualificationIdentification string //处方资格标识
+	IdentificationOutpatients               string //门诊大病医师标识
+	OutpatientIllnessCategory               string //门诊大病类别
+	StartTime                               int64  //开始日期
+	StaffCode                               string //医护人员编码
+	EndTime                                 int64  // 结束日期
+}

service/his_service.go

@@ -1,6 +1,7 @@
 package service
 
 import (
+	"fmt"
 	"gdyb/models"
 	"github.com/jinzhu/gorm"
 	"time"
@@ -960,3 +961,34 @@ func GetPatientByIDTwo(orgID int64, patientID int64) (Patients, error) {
 	err := readDb.Model(&Patients{}).Where("id = ? and user_org_id=? and status=1", patientID, orgID).First(&patient).Error
 	return patient, err
 }
+
+func GetDrugList(orgID int64) (drug []*models.BaseDrugList, err error) {
+
+	db := XTReadDB().Table("xt_base_drug as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_manufacturer as m")
+	fmt.Print(table)
+	if orgID > 0 {
+		db = db.Where("x.org_id = ? and x.id = 278", orgID)
+	}
+	err = db.Select("x.id,x.medical_insurance_number,x.code,x.drug_name,x.drug_spec,x.drug_type,x.min_unit,x.last_price,x.retail_price,x.limit_remark,x.drug_dosage_form,m.manufacturer_name").Joins("left join xt_manufacturer as m on m.id = x.manufacturer").Scan(&drug).Error
+
+	return drug, err
+}
+
+func GetDrugDosageForm(orgid int64) (dataconfig []*models.XtDrugDataConfig, err error) {
+
+	err = XTReadDB().Where("(org_id = ? or org_id = 0) and parent_id = 4 and status = 1", orgid).Find(&dataconfig).Error
+	return dataconfig, err
+}
+
+func GetDoctorList(orgid int64) (role []*models.SgjUserAdminRole, err error) {
+
+	err = UserReadDB().Model(&role).Where("org_id = ? and status = 1", orgid).Find(&role).Error
+	return role, err
+}
+
+func GetRoleList(orgid int64) (role []*models.SgjUserRole, err error) {
+
+	err = UserReadDB().Model(&role).Where("org_id = ? and status =1", orgid).Find(&role).Error
+	return role, err
+}

service/sz_his_service.go

@@ -297,16 +297,128 @@ func SzybFY005(doctor string, doctor_code string, fixmedins_code string, dept_co
 	str := string(respBytes)
 	return str
 }
-func SzybJY002(doctor string, doctor_code string, fixmedins_code string, dept_code string, number string, verify_code string) string {
-	// 生成输入报文
-	inputMessage := SetSZInputMessage(doctor, doctor_code, fixmedins_code, verify_code)
+
+//func SzybJY002(doctor string, doctor_code string, fixmedins_code string, dept_code string, number string, verify_code string) string {
+//	// 生成输入报文
+//	inputMessage := SetSZInputMessage(doctor, doctor_code, fixmedins_code, verify_code)
+//	inputData := make(map[string]interface{})
+//	inputMessage["transType"] = "JY002" // 交易编码
+//
+//	inputData["akc190"] = "2021033012131415"
+//	inputData["bke384"] = number
+//
+//	inputMessage["transBody"] = inputData
+//	bytesData, err := json.Marshal(inputMessage)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//	reader := bytes.NewReader(bytesData)
+//	//url := "http://192.168.1.99:10000"
+//	url := "http://192.168.1.228:17001/szsi-portal/transData"
+//
+//	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")
+//
+//	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()
+//	}
+//	fmt.Println(string(respBytes))
+//	str := string(respBytes)
+//	return str
+//}
+
+//func SzybJY003(doctor string, doctor_code string, fixmedins_code string, dept_code string, number string, verify_code string) string {
+//	// 生成输入报文
+//	inputMessage := SetSZInputMessage(doctor, doctor_code, fixmedins_code, verify_code)
+//	inputData := make(map[string]interface{})
+//	inputMessage["transType"] = "JY002" // 交易编码
+//
+//	inputData["akc190"] = "2021033012131415"
+//	inputData["bke384"] = number
+//
+//	inputMessage["transBody"] = inputData
+//	bytesData, err := json.Marshal(inputMessage)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//	reader := bytes.NewReader(bytesData)
+//	//url := "http://192.168.1.99:10000"
+//	url := "http://192.168.1.228:17001/szsi-portal/transData"
+//
+//	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")
+//
+//	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()
+//	}
+//	fmt.Println(string(respBytes))
+//	str := string(respBytes)
+//	return str
+//}
+
+func SzybML008(doctor string, doctor_code string, fixmedins_code string, datas []*models.DrugDetail) string {
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
+
 	inputData := make(map[string]interface{})
-	inputMessage["transType"] = "JY002" // 交易编码
 
-	inputData["akc190"] = "2021033012131415"
-	inputData["bke384"] = number
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML008" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
+
+	for _, item := range datas {
+		fmt.Println("中国222222", item.DrugDosageName)
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["ake001"] = item.MedicalInsuranceNumber
+		feedetailInfo["bkm017"] = item.Code
+		feedetailInfo["ake005"] = "110100002"
+		feedetailInfo["ake006"] = item.DrugName
+		feedetailInfo["aka074"] = item.DrugSpec
+		feedetailInfo["aka070"] = item.DrugDosageName
+		//feedetailInfo["aka070"] = "片"
+		feedetailInfo["aka067"] = item.MinUnit
+		feedetailInfo["bka053"] = item.ManufacturerName
+		feedetailInfo["aka064"] = "1"
+		feedetailInfo["bka505"] = item.LastPrice
+		feedetailInfo["bka506"] = item.RetailPrice
+		feedetailInfo["aae030"] = 20210406
+		feedetailInfo["aae013"] = item.LimitRemark
+		feedetail = append(feedetail, feedetailInfo)
+	}
 
+	inputData["inputlist"] = feedetail
 	inputMessage["transBody"] = inputData
+
 	bytesData, err := json.Marshal(inputMessage)
 	fmt.Println(string(bytesData))
 	if err != nil {
@@ -339,18 +451,117 @@ func SzybJY002(doctor string, doctor_code string, fixmedins_code string, dept_co
 	fmt.Println(string(respBytes))
 	str := string(respBytes)
 	return str
+
 }
 
-func SzybJY003(doctor string, doctor_code string, fixmedins_code string, dept_code string, number string, verify_code string) string {
-	// 生成输入报文
-	inputMessage := SetSZInputMessage(doctor, doctor_code, fixmedins_code, verify_code)
+// 生成基础报文
+func SetSZInputMessage(doctor string, doctor_code string, fixmedins_code string, verify_code string, number string) map[string]interface{} {
+	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")
+
+	//生成输入报文
+	inputMessage := make(map[string]interface{})
+	//
+
+	inputMessage["cardArea"] = "440300" // 发卡地行政区划代码
+	inputMessage["extendDeviceId"] = ""
+	inputMessage["extendSerialNumber"] = ""
+	inputMessage["extendUserId"] = ""
+	inputMessage["hospitalCode"] = fixmedins_code // 协议机构编码
+	inputMessage["operatorCode"] = doctor_code    // 操作员编码
+	inputMessage["operatorName"] = doctor         // 操作员名字
+	inputMessage["operatorPass"] = ""             // 定点协议机构操作人员编码
+	inputMessage["serialNumber"] = fixmedins_code + year + month + day +
+		fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
+	inputMessage["serialNumber"] = number
+
+	inputMessage["transReturnCode"] = ""                                           //
+	inputMessage["transReturnMessage"] = ""                                        //
+	inputMessage["transTime"] = year + month + day + hour + min + sec + ":" + msec //
+	inputMessage["transVersion"] = "V0.3"                                          //
+	inputMessage["verifyCode"] = verify_code                                       //
+	inputMessage["transChannel"] = "10"                                            //
+
+	return inputMessage
+}
+func msToTime(ms int64) string {
+	tm := time.Unix(0, ms*int64(time.Millisecond))
+	return tm.Format("2006-02-01 15:04:05.000")
+}
+
+// 生成基础报文
+func SetSZDrugMessage(doctor string, doctor_code string, fixmedins_code string) map[string]interface{} {
+	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")
+
+	//生成输入报文
+	inputMessage := make(map[string]interface{})
+	//
+
+	inputMessage["cardArea"] = "440300" // 发卡地行政区划代码
+	inputMessage["extendDeviceId"] = ""
+	inputMessage["extendSerialNumber"] = ""
+	inputMessage["extendUserId"] = ""
+	inputMessage["hospitalCode"] = "G5540"     // 协议机构编码
+	inputMessage["operatorCode"] = doctor_code // 操作员编码
+	inputMessage["operatorName"] = doctor      // 操作员名字
+	inputMessage["operatorPass"] = ""          // 定点协议机构操作人员编码
+	//inputMessage["serialNumber"] = "G5540" + year + month + day +
+	//  fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
+	inputMessage["serialNumber"] = "G554020210406" + fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
+	inputMessage["verifyCode"] = "000000|8ec5b7745a5cc45b631f23b4bf1e417e"
+
+	inputMessage["transReturnCode"] = ""                                           //
+	inputMessage["transReturnMessage"] = ""                                        //
+	inputMessage["transTime"] = year + month + day + hour + min + sec + ":" + msec //
+	inputMessage["transVersion"] = "V0.3"                                          //   //
+	inputMessage["transChannel"] = "10"                                            //
+
+	return inputMessage
+}
+
+func SzybML009(doctor string, doctor_code string, fixmedins_code string, datas []*models.DrugDetail) string {
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
+
 	inputData := make(map[string]interface{})
-	inputMessage["transType"] = "JY002" // 交易编码
 
-	inputData["akc190"] = "2021033012131415"
-	inputData["bke384"] = number
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML009" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
 
+	for _, item := range datas {
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["ake001"] = item.MedicalInsuranceNumber //社保目录编码
+		feedetailInfo["ake005"] = "110100002"                 //协议机构内部目录编码
+		feedetailInfo["ake006"] = item.DrugName               // 协议机构内部目录名称
+		feedetailInfo["bkf131"] = "4"                         //协议机构项目类别
+		feedetailInfo["bkm062"] = "0"                         // 门诊特检项目标识
+		feedetailInfo["bka506"] = item.RetailPrice            // 协议机构内部项目收费价格
+		feedetailInfo["aae030"] = 20210407                    // 备案日期
+		feedetailInfo["aae013"] = item.LimitRemark            // 备注
+		feedetail = append(feedetail, feedetailInfo)
+	}
+	fmt.Println("feeedDetal2333333333", feedetail)
+	inputData["inputlist"] = feedetail
 	inputMessage["transBody"] = inputData
+
 	bytesData, err := json.Marshal(inputMessage)
 	fmt.Println(string(bytesData))
 	if err != nil {
@@ -383,47 +594,299 @@ func SzybJY003(doctor string, doctor_code string, fixmedins_code string, dept_co
 	fmt.Println(string(respBytes))
 	str := string(respBytes)
 	return str
+
 }
 
-// 生成基础报文
-func SetSZInputMessage(doctor string, doctor_code string, fixmedins_code string, verify_code string, number string) map[string]interface{} {
-	month := time.Unix(1557042972, 0).Format("1")
-	year := time.Now().Format("2006")
-	month = time.Now().Format("01")
-	day := time.Now().Format("02")
+func SzybML010(doctor string, doctor_code string, fixmedins_code string, datas []*models.DrugDetail) string {
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
 
-	hour := time.Now().Format("15")
-	min := time.Now().Format("04")
-	sec := time.Now().Format("05")
+	inputData := make(map[string]interface{})
 
-	msec := time.Now().Format("000")
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML010" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
 
-	// 生成输入报文
-	inputMessage := make(map[string]interface{})
-	//
+	for _, item := range datas {
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["ake003"] = "1"
+		feedetailInfo["ake001"] = item.MedicalInsuranceNumber //社保目录编码
+		feedetailInfo["ake005"] = "110100002"                 //协议机构内部目录编码
+		feedetail = append(feedetail, feedetailInfo)
+	}
 
-	inputMessage["cardArea"] = "440300" // 发卡地行政区划代码
-	inputMessage["extendDeviceId"] = ""
-	inputMessage["extendSerialNumber"] = ""
-	inputMessage["extendUserId"] = ""
-	inputMessage["hospitalCode"] = fixmedins_code // 协议机构编码
-	inputMessage["operatorCode"] = doctor_code    // 操作员编码
-	inputMessage["operatorName"] = doctor         // 操作员名字
-	inputMessage["operatorPass"] = ""             // 定点协议机构操作人员编码
-	inputMessage["serialNumber"] = fixmedins_code + year + month + day +
-		fmt.Sprintf("%07v", rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000000)) // 定点协议机构编码（5位）+日期（8位）+流水号（7位）
-	inputMessage["serialNumber"] = number
+	inputData["inputlist"] = feedetail
+	inputMessage["transBody"] = inputData
 
-	inputMessage["transReturnCode"] = ""                                           //
-	inputMessage["transReturnMessage"] = ""                                        //
-	inputMessage["transTime"] = year + month + day + hour + min + sec + ":" + msec //
-	inputMessage["transVersion"] = "V0.3"                                          //
-	inputMessage["verifyCode"] = verify_code                                       //
-	inputMessage["transChannel"] = "10"                                            //
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://192.168.1.99:10000"
+	url := "http://192.168.1.228:17001/szsi-portal/transData"
+
+	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")
+
+	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()
+	}
+	fmt.Println(string(respBytes))
+	str := string(respBytes)
+	return str
 
-	return inputMessage
 }
-func msToTime(ms int64) string {
-	tm := time.Unix(0, ms*int64(time.Millisecond))
-	return tm.Format("2006-02-01 15:04:05.000")
+
+func SzybYS001(doctor string, doctor_code string, fixmedins_code string, datas []*models.DocDetail) string {
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
+
+	inputData := make(map[string]interface{})
+
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML010" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
+
+	for _, item := range datas {
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["aac003"] = item.UserName
+		feedetailInfo["bka633"] = item.RoleId
+		feedetailInfo["aac004"] = item.Sex
+		feedetailInfo["aac058"] = item.CardType
+		feedetailInfo["aac147"] = item.IdCard
+		feedetailInfo["aae005"] = item.Phone
+		feedetailInfo["bkc322"] = item.WorkMajorName
+		feedetailInfo["aac005"] = item.Nation
+		feedetailInfo["aac006"] = item.BirthDay
+		feedetailInfo["aac007"] = item.WorkTime
+		feedetailInfo["aac011"] = item.Education
+		feedetailInfo["aac183"] = item.StudyMajorName
+		feedetailInfo["bkc323"] = item.CertificateCode
+		feedetailInfo["bke955"] = item.MedicalCode
+		feedetailInfo["akc055"] = item.MedicalRangeCode
+		feedetailInfo["bcc950"] = item.MedicalLevel
+		feedetailInfo["bcc955"] = item.TypeJob
+		feedetailInfo["bka503"] = item.DoctorNumber
+		feedetailInfo["bkc324"] = item.Licensing
+		feedetailInfo["bkc326"] = item.DoctorServiceStatus
+		feedetailInfo["bkc328"] = item.MonitoringLevel
+		feedetailInfo["bkc329"] = item.DrugPsychotropicSubstances
+		feedetailInfo["bke801"] = item.HealthCareCode
+		feedetailInfo["bkc330"] = item.PlanningTechnicalServiceCode
+		feedetailInfo["bkc332"] = item.PharmacistType
+		feedetailInfo["bkc333"] = item.PharmacistPracticeCategory
+		feedetailInfo["bkc334"] = item.PharmacistsLicensing
+		feedetailInfo["bkc335"] = item.PharmacistRegistrationNumber
+		feedetailInfo["akf001"] = item.OfficeCode
+		feedetailInfo["acc501"] = item.JobNumber
+		feedetailInfo["ahc451"] = item.PostName
+		feedetailInfo["aaf009"] = item.TechnicalJobLevelCode
+		feedetailInfo["bkc321"] = item.IsActive
+		feedetailInfo["ckc302"] = item.PrescriptionQualificationIdentification
+		feedetailInfo["bkc325"] = item.IdentificationOutpatients
+		feedetailInfo["ckc304"] = item.OutpatientIllnessCategory
+		feedetailInfo["aae030"] = item.StartTime
+		feedetail = append(feedetail, feedetailInfo)
+	}
+
+	inputData["inputlist"] = feedetail
+	inputMessage["transBody"] = inputData
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://192.168.1.99:10000"
+	url := "http://192.168.1.228:17001/szsi-portal/transData"
+
+	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")
+
+	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()
+	}
+	fmt.Println(string(respBytes))
+	str := string(respBytes)
+	return str
+
+}
+
+func SzybYS002(doctor string, doctor_code string, fixmedins_code string, datas []*models.DocDetail) string {
+
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
+
+	inputData := make(map[string]interface{})
+
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML010" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
+
+	for _, item := range datas {
+		fmt.Println("item2222", item)
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["bkc320"] = 1111
+		feedetailInfo["bke155"] = ""
+		feedetail = append(feedetail, feedetailInfo)
+	}
+
+	inputData["inputlist"] = feedetail
+	inputMessage["transBody"] = inputData
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://192.168.1.99:10000"
+	url := "http://192.168.1.228:17001/szsi-portal/transData"
+
+	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")
+
+	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()
+	}
+	fmt.Println(string(respBytes))
+	str := string(respBytes)
+	return str
+}
+
+func SzybYS003(doctor string, doctor_code string, fixmedins_code string, datas []*models.DocDetail) string {
+
+	//生成输入报文
+	inputMessage := SetSZDrugMessage(doctor, doctor_code, fixmedins_code)
+
+	inputData := make(map[string]interface{})
+
+	inputData["listsize"] = len(datas)
+	inputMessage["transType"] = "ML010" // 交易编码
+	feedetail := make([]map[string]interface{}, 0)
+
+	for _, item := range datas {
+		feedetailInfo := make(map[string]interface{})
+		feedetailInfo["bkc320"] = ""
+		feedetailInfo["aac003"] = item.UserName
+		feedetailInfo["bka633"] = item.RoleId
+		feedetailInfo["aac004"] = item.Sex
+		feedetailInfo["aac058"] = item.CardType
+		feedetailInfo["aac147"] = item.IdCard
+		feedetailInfo["aae005"] = item.Phone
+		feedetailInfo["bkc322"] = item.WorkMajorName
+		feedetailInfo["aac005"] = item.Nation
+		feedetailInfo["aac006"] = item.BirthDay
+		feedetailInfo["aac007"] = item.WorkTime
+		feedetailInfo["aac011"] = item.Education
+		feedetailInfo["aac183"] = item.StudyMajorName
+		feedetailInfo["bkc323"] = item.CertificateCode
+		feedetailInfo["bke955"] = item.MedicalCode
+		feedetailInfo["akc055"] = item.MedicalRangeCode
+		feedetailInfo["bcc950"] = item.MedicalLevel
+		feedetailInfo["bcc955"] = item.TypeJob
+		feedetailInfo["bka503"] = item.DoctorNumber
+		feedetailInfo["bkc324"] = item.Licensing
+		feedetailInfo["bkc326"] = item.DoctorServiceStatus
+		feedetailInfo["bkc328"] = item.MonitoringLevel
+		feedetailInfo["bkc329"] = item.DrugPsychotropicSubstances
+		feedetailInfo["bke801"] = item.HealthCareCode
+		feedetailInfo["bkc330"] = item.PlanningTechnicalServiceCode
+		feedetailInfo["bkc332"] = item.PharmacistType
+		feedetailInfo["bkc333"] = item.PharmacistPracticeCategory
+		feedetailInfo["bkc334"] = item.PharmacistsLicensing
+		feedetailInfo["bkc335"] = item.PharmacistRegistrationNumber
+		feedetailInfo["akf001"] = item.OfficeCode
+		feedetailInfo["acc501"] = item.JobNumber
+		feedetailInfo["ahc451"] = item.PostName
+		feedetailInfo["aaf009"] = item.TechnicalJobLevelCode
+		feedetailInfo["bkc321"] = item.IsActive
+		feedetailInfo["ckc302"] = item.PrescriptionQualificationIdentification
+		feedetailInfo["bkc325"] = item.IdentificationOutpatients
+		feedetailInfo["ckc304"] = item.OutpatientIllnessCategory
+		feedetailInfo["aae030"] = item.StartTime
+		feedetailInfo["aae031"] = item.EndTime
+		feedetail = append(feedetail, feedetailInfo)
+	}
+
+	inputData["inputlist"] = feedetail
+	inputMessage["transBody"] = inputData
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://192.168.1.99:10000"
+	url := "http://192.168.1.228:17001/szsi-portal/transData"
+
+	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")
+
+	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()
+	}
+	fmt.Println(string(respBytes))
+	str := string(respBytes)
+	return str
 }