添加消息发送

@@ -155,6 +155,9 @@ func (productRecordService *ProductRecordService) CreateProductRecord(operateInf
 			return nil, application.ThrowError(application.ARG_ERROR, "保存生产记录"+err.Error())
 			return nil, application.ThrowError(application.ARG_ERROR, "保存生产记录"+err.Error())
 		}
 		}
 		productRecordIds = append(productRecordIds, productRecordData.ProductRecordId)
 		productRecordIds = append(productRecordIds, productRecordData.ProductRecordId)
+		if param.SaveAndApprove {
+			_ = domainService.SendProductRecordStaticsJob(productRecordData)
+		}
 	}
 	}
 	if err := transactionContext.CommitTransaction(); err != nil {
 	if err := transactionContext.CommitTransaction(); err != nil {
 		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
 		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())