11月8日库存管理

controllers/supply_order_api_contorller.go

@@ -52,6 +52,8 @@ func SupplyOrderApiRegistRouters() {
 	beego.Router("/api/supply/getgoodorderlist", &SupplyOrderApiController{}, "Get:GetGoodOrderList")
 	//反审核购货订单
 	beego.Router("/api/supply/getreturnorder", &SupplyOrderApiController{}, "Get:GetReturnOrder")
+	//判断是否全部入库
+	beego.Router("/api/supply/getgoodordercountlist", &SupplyOrderApiController{}, "Get:GetGoodOrderCountList")
 }
 
 func (this *SupplyOrderApiController) GetInitOrder() {
@@ -1446,3 +1448,99 @@ func (this *SupplyOrderApiController) GetReturnOrder() {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 	}
 }
+
+func (this *SupplyOrderApiController) GetGoodOrderCountList() {
+	id, _ := this.GetInt64("id")
+	warehousing_id, _ := this.GetInt64("warehousing_id")
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	checker := this.GetAdminUserInfo().AdminUser.Id
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+	record_date := recordDate.Unix()
+	out := models.SpSupplierWarehouseOut{
+		IsCheck:   1,
+		Checker:   checker,
+		CheckTime: record_date,
+	}
+	err := service.CheckGoodOrder(id, orgId, out)
+	//获取购货订单的数据
+	purcaseOrder, _ := service.GetAllPurcaseOrderById(warehousing_id, orgId)
+	//获取购货单的数据
+	goodOrder, _ := service.GetAllGoodOrderByIdTwo(warehousing_id, orgId)
+
+	//查询该购货单是否审核成功
+	detail, _ := service.GetGoodOrderDetail(id, orgId)
+	var warehousingInfo []*models.WarehousingInfo
+	//如果审核成功
+	if detail.IsCheck == 1 {
+		//入库
+		if len(goodOrder) > 0 {
+			for _, item := range goodOrder {
+				//药品
+				if item.IsSource == 1 {
+
+				}
+				//耗材
+				if item.IsSource == 2 {
+					//获取耗材类型
+					good, _ := service.GetGoodInformationByGoodId(item.ProjectId)
+					timeStr := time.Now().Format("2006-01-02")
+					timeArr := strings.Split(timeStr, "-")
+					total, _ := service.FindAllWarehouseTotal(orgId)
+					total = total + 1
+					warehousing_order := "RKD" + strconv.FormatInt(orgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+					operation_time := time.Now().Unix()
+					creater := this.GetAdminUserInfo().AdminUser.Id
+					warehousing := models.Warehousing{
+						WarehousingOrder: warehousing_order,
+						OperationTime:    operation_time,
+						OrgId:            orgId,
+						Creater:          creater,
+						Ctime:            time.Now().Unix(),
+						Status:           1,
+						WarehousingTime:  record_date,
+						Type:             1,
+					}
+					service.AddSigleWarehouse(&warehousing)
+
+					//入库单表格
+					warehouseInfo := &models.WarehousingInfo{
+						WarehousingOrder: warehousing.WarehousingOrder,
+						WarehousingId:    warehousing.ID,
+						GoodId:           item.ProjectId,
+						Number:           item.SupplyBatchNumber,
+						GoodTypeId:       good.GoodTypeId,
+						ProductDate:      item.SupplyProductDate,
+						ExpiryDate:       item.SupplyExpiryDate,
+						WarehousingCount: item.Count,
+						Price:            item.Price,
+						TotalPrice:       0,
+						Status:           1,
+						Ctime:            time.Now().Unix(),
+						Remark:           item.Remark,
+						OrgId:            orgId,
+						Type:             1,
+						Manufacturer:     item.ManufacturerId,
+						StockCount:       item.Count,
+						Dealer:           good.Dealer,
+						LicenseNumber:    item.SupplyLicenseNumber,
+						PackingPrice:     good.PackingPrice,
+					}
+					warehousingInfo = append(warehousingInfo, warehouseInfo)
+
+				}
+			}
+		}
+	}
+
+	drugList, _ := service.GetSupplyDrugList(orgId)
+	if err == nil {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"purcaseOrder": purcaseOrder,
+			"goodOrder":    goodOrder,
+			"drugList":     drugList,
+		})
+	} else {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+	}
+}

service/supply_service.go

@@ -219,6 +219,12 @@ func GetAllGoodOrderById(id int64, orgid int64) (order []*models.VSpSupplierWare
 	return order, err
 }
 
+func GetAllGoodOrderByIdTwo(id int64, orgid int64) (order []*models.SpSupplierWarehousingOutOrder, err error) {
+
+	err = XTReadDB().Where("warehousing_id = ? and user_org_id = ? and status = 1", id, orgid).Find(&order).Error
+	return order, err
+}
+
 func GetGoodOrderList(id int64, orgid int64) (info []*models.SpSupplierWarehouseOut, err error) {
 
 	err = XTReadDB().Where("warehousing_id = ? and status = 1 and user_org_id = ?", id, orgid).Find(&info).Error
@@ -230,3 +236,9 @@ func GetReturnOrder(id int64, orgid int64) error {
 	err := XTWriteDB().Model(&models.SupplierWarehouseInfo{}).Where("id = ? and status = 1 and user_org_id = ?", id, orgid).Updates(map[string]interface{}{"is_check": 2, "mtime": time.Now().Unix(), "check_time": 0, "checker": 0}).Error
 	return err
 }
+
+func CheckGoodOrder(id int64, orgid int64, out models.SpSupplierWarehouseOut) error {
+
+	err := XTWriteDB().Model(&models.SpSupplierWarehouseOut{}).Where("id = ? and user_org_id =? and status = 1", id, orgid).Updates(map[string]interface{}{"is_check": out.IsCheck, "checker": out.Checker, "check_time": out.CheckTime, "mtime": time.Now().Unix()}).Error
+	return err
+}