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

controllers/sg/his_api_controller.go

@@ -34,8 +34,6 @@ import (
 	"syscall"
 	"time"
 	"unsafe"
-	"github.com/go-ole/go-ole"
-
 )
 
 type HisApiController struct {
@@ -2939,6 +2937,214 @@ func (c *HisApiController) DeleteXSandBGTwo() {
 
 }
 
+// 删除
+func (c *HisApiController) DeleteXSandBGThree() {
+	id, _ := c.GetInt64("id")
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+
+	advicelist, _ := service.FindHisAdviceDocAdvice(id)
+	var flows []*models.DrugFlow
+	for _, item := range advicelist {
+		flow, _ := service.GetNewUploadDrugFlowInfoByPatientTwo(item.PatientId, item.DrugId, item.RecordDate, c.GetAdminUserInfo().CurrentOrgId)
+		flows = append(flows, flow...)
+	}
+
+	//flows, _ := service.GetNewDrugFlowInfo(c.GetAdminUserInfo().CurrentOrgId, id_arr)
+	roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+
+	var err []string
+	for _, item := range flows {
+		if item.IsSale == 1 {
+			var res FJ3507Result
+
+			var struct3507 models.Struct3507
+			struct3507.FixmedinsBchno = item.Bchno
+			struct3507.InvDataType = "4"
+			struct3507.Opter = roles.UserName
+			struct3507.OrgName = miConfig.OrgName
+			struct3507.AccessKey = miConfig.AccessKey
+			struct3507.RequestUrl = miConfig.Url
+			struct3507.FixmedinsCode = miConfig.Code
+			struct3507.SecretKey = miConfig.SecretKey
+			struct3507.MdtrtareaAdmvs = miConfig.MdtrtareaAdmvs
+			struct3507.InsuplcAdmdvs = miConfig.InsuplcAdmdvs
+			struct3507.Url = miConfig.Url
+			struct3507.AppId = miConfig.Cainfo
+			struct3507.AppSecret = miConfig.AppSecret
+			struct3507.Enckey = miConfig.EncKey
+			struct3507.SignKey = miConfig.SignKey
+			struct3507.SecretKey = miConfig.SecretKey
+
+			if miConfig.MdtrtareaAdmvs == "350500" {
+				result, result1, _ := service.FJyb3507(struct3507)
+				saveLog(result, result1, "3507", "3507")
+				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, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+				data := make(map[string]interface{})
+				data["struct_3507s"] = struct3507
+				client := &http.Client{}
+				bytesData, _ := json.Marshal(data)
+				var req *http.Request
+				if miConfig.MdtrtareaAdmvs == "320921" {
+					req, _ = http.NewRequest("POST", "http://192.168.2.3:9532/"+"jsyb/3507", bytes.NewReader(bytesData))
+				} else {
+					req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3507", bytes.NewReader(bytesData))
+				}
+
+				resp, _ := client.Do(req)
+				defer resp.Body.Close()
+				body, ioErr := ioutil.ReadAll(resp.Body)
+				if ioErr != nil {
+					utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+				}
+				var respJSON map[string]interface{}
+				if err := json.Unmarshal([]byte(body), &respJSON); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				var resSix10265 ResultSix10265 //1101结果
+				respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+				result, _ := json.Marshal(respJSON)
+				if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				res.InfRefmsgid = resSix10265.InfRefmsgid
+				//res.Output = resSix10265.Output
+				res.ErrMsg = resSix10265.ErrMsg
+				res.Cainfo = resSix10265.Cainfo
+				res.WarnMsg = resSix10265.WarnMsg
+				infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+				res.Infcode = infocode
+			} else if miConfig.MdtrtareaAdmvs == "440100" {
+				result1, result2 := service.Gzyb3507(struct3507, struct3507.SecretKey)
+				saveLog(result2, result1, "3507", "3507")
+				var respJSON2 map[string]interface{}
+				if err := json.Unmarshal([]byte(string(result1)), &respJSON2); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				userJSONBytes2, _ := json.Marshal(respJSON2)
+				if err := json.Unmarshal(userJSONBytes2, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else if strings.HasPrefix(miConfig.MdtrtareaAdmvs[0:3], "440") {
+				result1, result2 := service.Gdyb3507(struct3507, struct3507.SecretKey)
+				saveLog(result2, result1, "3507", "3507")
+				var respJSON2 map[string]interface{}
+				if err := json.Unmarshal([]byte(string(result1)), &respJSON2); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				userJSONBytes2, _ := json.Marshal(respJSON2)
+				if err := json.Unmarshal(userJSONBytes2, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else if strings.HasPrefix(miConfig.MdtrtareaAdmvs[0:3], "361") {
+				result1, result2 := service.Jxyb3507(struct3507)
+				saveLog(result2, result1, "3507", "3507")
+				var respJSON2 map[string]interface{}
+				if err := json.Unmarshal([]byte(string(result1)), &respJSON2); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				userJSONBytes2, _ := json.Marshal(respJSON2)
+				if err := json.Unmarshal(userJSONBytes2, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else if miConfig.MdtrtareaAdmvs == "340699" {
+				result1, result2 := service.AHyb3507(struct3507)
+				saveLog(result2, result1, "3507", "3507")
+				var respJSON2 map[string]interface{}
+				if err := json.Unmarshal([]byte(string(result1)), &respJSON2); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				userJSONBytes2, _ := json.Marshal(respJSON2)
+				if err := json.Unmarshal(userJSONBytes2, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else if miConfig.MdtrtareaAdmvs == "150499" {
+
+				data := make(map[string]interface{})
+				data["struct_3507s"] = struct3507
+				client := &http.Client{}
+				bytesData, _ := json.Marshal(data)
+				var req *http.Request
+
+				req, _ = http.NewRequest("POST", "http://172.16.13.254:9532"+"/nmyb/3507", bytes.NewReader(bytesData))
+
+				resp, _ := client.Do(req)
+				defer resp.Body.Close()
+				body, ioErr := ioutil.ReadAll(resp.Body)
+				if ioErr != nil {
+					utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+				}
+				var respJSON map[string]interface{}
+				if err := json.Unmarshal([]byte(body), &respJSON); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+				}
+
+				var resSix10265 ResultSix10265 //1101结果
+				respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+				result, _ := json.Marshal(respJSON)
+				if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				res.InfRefmsgid = resSix10265.InfRefmsgid
+				res.ErrMsg = resSix10265.ErrMsg
+				res.Cainfo = resSix10265.Cainfo
+				res.WarnMsg = resSix10265.WarnMsg
+				infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+				res.Infcode = infocode
+			}
+
+			if res.Infcode == 0 {
+				service.SaveDoctoradviceStatusTwo(item.HisDoctorAdviceInfo.ID)
+				item.IsSale = 0
+				item.SaleDate = ""
+				item.Bchno = ""
+				service.SaveDF(item)
+			} else {
+				err = append(err, "删除"+item.HisDoctorAdviceInfo.BaseDrugLib.DrugName+"盘存失败,失败原因："+res.ErrMsg)
+			}
+		}
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"msg": "删除销售数据成功",
+	})
+
+}
+
 // 获取当天起止时间戳
 func GetNowTime() (int64, int64) {
 	t := time.Now()